Compare commits
3 Commits
f6461273ab
...
4bd161de54
Author | SHA1 | Date | |
---|---|---|---|
4bd161de54 | |||
0874645719 | |||
8d7754edc2 |
@ -3,4 +3,5 @@ from server import Server
|
|||||||
|
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
server = Server()
|
server = Server()
|
||||||
|
server.initServer()
|
||||||
server.startServer()
|
server.startServer()
|
||||||
|
@ -36,7 +36,7 @@ class NetWrapper:
|
|||||||
cipher = PKCS1_OAEP.new(self.currentClientPublicKey)
|
cipher = PKCS1_OAEP.new(self.currentClientPublicKey)
|
||||||
identMsg = json.dumps(
|
identMsg = json.dumps(
|
||||||
{'type': 'IDY', 'source': self.network.own_addr,
|
{'type': 'IDY', 'source': self.network.own_addr,
|
||||||
'message': b64encode(cipher.encrypt(retmsg.encode('UTF-8')))}).encode(
|
'message': b64encode(cipher.encrypt(retmsg.encode('UTF-8')))}).decode(
|
||||||
'ASCII')
|
'ASCII')
|
||||||
self.network.send_msg(self.clientAddr, identMsg)
|
self.network.send_msg(self.clientAddr, identMsg)
|
||||||
|
|
||||||
|
@ -12,8 +12,13 @@ class Server:
|
|||||||
self.sessionTimeout = sessionTimeout
|
self.sessionTimeout = sessionTimeout
|
||||||
self.availableServer = availableServer
|
self.availableServer = availableServer
|
||||||
self.executor = Executor(homeDirectory)
|
self.executor = Executor(homeDirectory)
|
||||||
|
|
||||||
|
def initServer(self):
|
||||||
|
print("Please enter your private key passphrase")
|
||||||
|
passphrase = input()
|
||||||
self.auth = Authetication()
|
self.auth = Authetication()
|
||||||
self.networkInstance = NetWrapper(self.auth.loadUserPublicKeys(),self.auth.loadServerPrivateKey(),self)
|
self.networkInstance = NetWrapper(self.auth.loadUserPublicKeys(), self.auth.loadServerPrivateKey(passphrase),
|
||||||
|
self)
|
||||||
|
|
||||||
def login(self, username: str, password: str) -> bool:
|
def login(self, username: str, password: str) -> bool:
|
||||||
self.isAuthenticated = True
|
self.isAuthenticated = True
|
||||||
@ -107,14 +112,4 @@ class Server:
|
|||||||
def startServer(self):
|
def startServer(self):
|
||||||
while True:
|
while True:
|
||||||
message = self.networkInstance.recieveMessage().decode('UTF-8')
|
message = self.networkInstance.recieveMessage().decode('UTF-8')
|
||||||
command = self.parseCommand(message)
|
self.parseCommand(message)
|
||||||
#ha LINOK vagy LINERROR donothing
|
|
||||||
if command == "LINERROR" or command == "LINOK" or command == "ERROR":
|
|
||||||
print("not right commands")
|
|
||||||
elif len(command) == 1:
|
|
||||||
execute_message = self.execute(self,command, "", "")
|
|
||||||
elif len(command) == 2:
|
|
||||||
execute_message = self.execute(self, command, command[1], "")
|
|
||||||
elif len(command) == 3:
|
|
||||||
execute_message = self.execute(self, command, command[1], command[2])
|
|
||||||
self.networkInstance.sendMessage(self, execute_message)
|
|
||||||
|
Loading…
Reference in New Issue
Block a user