Config

requirements.txt

@@ -1,2 +1,3 @@
 pycryptodome
 pydh
+unipath

server/authentication.py

@@ -11,6 +11,7 @@ from Crypto.Hash import SHA256
 from Crypto.Protocol.KDF import bcrypt, bcrypt_check
 from Crypto.PublicKey import RSA
 from Crypto.PublicKey.RSA import RsaKey
+from Crypto.Random import get_random_bytes
 
 auth_logger = logging.getLogger('AUTH APPLICATION ')
 auth_logger.setLevel(logging.INFO)
@@ -51,7 +52,7 @@ class Authetication:
                     b64pwd = b64encode(SHA256.new(password.encode('utf-8')).digest())
                     bcrypt_check(b64pwd, user['password'].encode('utf-8'))
                     auth_logger.debug("User logged in: " + username)
-                    return user['homeDir']
+                    return self.HOME_DIRECTORY_LOCATION + os.path.sep + user['homeDir']
                 except ValueError:
                     auth_logger.debug("User NOT logged in: " + username)
                     return ''
@@ -76,14 +77,16 @@ class Authetication:
 
         shutil.rmtree(self.HOME_DIRECTORY_LOCATION)
         os.mkdir(self.HOME_DIRECTORY_LOCATION)
+        os.mkdir(self.HOME_DIRECTORY_LOCATION + os.path.sep + '0')
         shutil.rmtree(self.PRIVATE_KEY_DIRECTORY_LOCATION)
         os.mkdir(self.PRIVATE_KEY_DIRECTORY_LOCATION)
 
 
     def saveUser(self, username: str, password: str) -> bool:
+        user_salt = get_random_bytes(16)
         bytePass = password.encode('utf-8')
         b64pwd = b64encode(SHA256.new(bytePass).digest())
-        bcrypt_hash = bcrypt(b64pwd, 12)
+        bcrypt_hash = bcrypt(password=b64pwd, cost=12, salt=user_salt)
 
         with open(self.CONFIG_FILE_LOCATION) as json_file:
             data = json.load(json_file)
@@ -123,7 +126,7 @@ class Authetication:
         dictionary = dict()
 
         for user in data['user']:
-            key = data['publicKey']
+            key = user['publicKey']
             key = bytes.fromhex(key)
             try:
                 rsaKey = RSA.import_key(key)

server/authentication_test.py

@@ -35,7 +35,7 @@ def testAuth(username: str, password: str):
     auth.saveUser(username, password)
     homeDir = auth.login(username, password)
 
-    if homeDir == '1':
+    if homeDir == auth.HOME_DIRECTORY_LOCATION + os.path.sep + '1':
         test_logger.info('TEST 1 --> Authentication test with VALID :: PASSED')
     else:
         test_logger.info('TEST 1 --> Authentication test with VALID :: FAILED')
@@ -118,4 +118,4 @@ if __name__ == '__main__':
     testSaveUser("Diósbejglia", "Diósbejgli")
     testAuth("Diósbejglia", "Diósbejgli")
     testUserExists("Diósbejglia", "Diósbejgli")
-    testPersistency()
+    #testPersistency()

server/authenticator.py

@@ -1,2 +0,0 @@
-#!/usr/bin/env python3
-

server/config_init.py

@@ -12,7 +12,7 @@ def generatePrivateKeyForUser(auth: Authetication,username: str, user_passphrase
         with open(auth.CONFIG_FILE_LOCATION) as json_file:
             data = json.load(json_file)
 
-        private_key = RSA.generate(2048)
+        private_key = RSA.generate(8192)
         public_key = private_key.publickey()
         private_key_value = bytes.hex(private_key.exportKey('DER', passphrase=user_passphrase, pkcs=8))
         public_key_value = bytes.hex(public_key.exportKey('DER', pkcs=8))
@@ -44,7 +44,7 @@ def generatePrivateKeyForServer(auth: Authetication,passphrase: str) -> str:
         data = json.load(json_file)
     json_file.close()
 
-    private_key = RSA.generate(2048)
+    private_key = RSA.generate(8192)
     public_key = private_key.publickey()
     private_key_value = bytes.hex(private_key.exportKey('DER', passphrase=passphrase, pkcs=8, protection="scryptAndAES128-CBC"))
     public_key_value = bytes.hex(public_key.exportKey('DER', pkcs=8))

server/executor.py

@@ -3,16 +3,14 @@
 import os
 import re
 
+from unipath import Path
 
 class Executor:
     """This class executes commands recieved by the server"""
 
-    def __init__(self, currentDiectory: str, baseDir: str = ""):
+    def __init__(self, baseDir: str):
-        self.currentDirectory = currentDiectory
+        self.currentDirectory = ""
-        if baseDir == "":
+        self.baseDir = baseDir + os.path.sep
-            self.baseDir = self.currentDirectory
-        else:
-            self.baseDir = baseDir
 
     def sanitizeDirectory(self, inDirectory: str) -> str:
         return re.sub('[^a-zA-Z0-9]', '', inDirectory)
@@ -22,13 +20,13 @@ class Executor:
 
     def createDirectory(self, dirName: str) -> str:
         dirName = self.sanitizeDirectory(dirName)
-        actualDirName = os.path.join(self.currentDirectory, dirName)
+        actualDirName: str = os.path.join(self.baseDir,self.currentDirectory,dirName)
         os.mkdir(actualDirName)
         return actualDirName
 
     def removeDirectory(self, dirName: str) -> str:
         dirName = self.sanitizeDirectory(dirName)
-        actualDirName = os.path.join(self.currentDirectory, dirName)
+        actualDirName: str = os.path.join(self.baseDir, self.currentDirectory, dirName)
         if actualDirName:
             os.rmdir(actualDirName)
         return actualDirName
@@ -38,26 +36,27 @@ class Executor:
 
     def setCurrentDirectory(self, dirName: str) -> str:
         if dirName == "..":
-            if self.currentDirectory == self.baseDir:
+            p = Path(os.path.join(self.baseDir, self.currentDirectory))
+            parentpath = p.parent
+            if (str(parentpath) + os.path.sep)== self.baseDir:
+                self.currentDirectory = ""
                 return self.currentDirectory
             else:
-                directories = self.currentDirectory.split(os.path.sep)
+                if len(str(parentpath).split('/')) < len(self.baseDir.split('/')):
-                strdirectory = ""
+                    return self.currentDirectory
-                for dir in directories:
+                newpath = str(parentpath).replace(self.baseDir,'')
-                    strdirectory += dir + os.path.sep
+                if os.path.exists(os.path.join(self.baseDir,newpath)):
-                    strdirectory = strdirectory[:-3]
+                    self.currentDirectory = newpath
-                if os.path.exists(strdirectory):
-                    self.currentDirectory = strdirectory
                 return self.currentDirectory
         else:
             dirName = self.sanitizeDirectory(dirName)
             joinedDir = os.path.join(self.currentDirectory, dirName)
-            if os.path.exists(joinedDir):
+            if os.path.join(self.baseDir, joinedDir):
                 self.currentDirectory = joinedDir
             return self.currentDirectory
 
     def listCurrentDirectoryContent(self) -> str:
-        contents = os.listdir(self.currentDirectory)
+        contents = os.listdir(os.path.join(self.baseDir, self.currentDirectory))
         strdirectory = ""
         for content in contents:
             strdirectory += content + ", "
@@ -66,23 +65,29 @@ class Executor:
 
     def putFileInCurrentDirectory(self, filename: str, content: bytes) -> str:
         filename = self.sanitizeFile(filename)
-        currenctfile = os.path.join(self.currentDirectory, filename)
+        currenctfile = os.path.join(self.baseDir, self.currentDirectory, filename)
         f = open(currenctfile, "wb")
         f.write(content)
         f.close()
         return currenctfile
 
-    def getFileInCurrentDirectory(self, file: str):
+    def getFileInCurrentDirectory(self, file: str) -> bytes:
         file = self.sanitizeFile(file)
-        currentfile = os.path.join(self.currentDirectory, file)
+        currentfile = os.path.join(self.baseDir, self.currentDirectory, file)
         if os.path.exists(currentfile):
-            return open(currentfile, "r")
+            f = open(currentfile, "rb")
+            content = f.read()
+            f.close()
+            return content
         else:
             raise Exception('File not found')
 
     def removeFileInCurrentDirectory(self, file: str) -> str:
         file = self.sanitizeFile(file)
-        currentfile = os.path.join(self.currentDirectory, file)
+        if self.currentDirectory == "":
+            currentfile = os.path.join(self.baseDir, file)
+        else:
+            currentfile = os.path.join(self.baseDir, self.currentDirectory, file)
         if os.path.exists(currentfile):
             os.remove(currentfile)
         return currentfile

server/netwrapper.py

@@ -2,110 +2,150 @@
 import json
 from base64 import b64encode, b64decode
 import pyDH
+from Crypto.Hash import SHA512
 from Crypto.Cipher import PKCS1_OAEP
-from Crypto.PublicKey import RSA
+from Crypto.Cipher import ChaCha20_Poly1305
-from Crypto.Cipher import ChaCha20
 from Crypto.PublicKey.RSA import RsaKey
-from Crypto.Random import get_random_bytes
+from Crypto.Signature import pkcs1_15
 
 from netsim import network_interface
-from server.server import Server
+from authentication import Authetication
 
 
 class NetWrapper:
 
-    def __init__(self, clientPublicKey: dict, serverPrivateKey: RsaKey, serverInstance: Server):
+    def __init__(self, clientPublicKey: dict, serverPrivateKey: RsaKey, authenticationInstance: Authetication):
         self.clientPublicKey = clientPublicKey
         self.currentClientPublicKey = "".encode('UTF-8')
         self.serverPrivateKey = serverPrivateKey
         self.cipherkey = "".encode('UTF-8')
-        self.network = network_interface('./', 'A')
+        self.network = network_interface('./../../netsim/network/', 'A')
         self.clientAddr = ""
         self.currentUser = ""
-        self.serverInstance = serverInstance
+        self.homeDirectory = ""
+        self.authenticationInstance = authenticationInstance
+
+    def encryptRSAMessage(self, message: bytes) -> bytes:
+        cipher_rsa = PKCS1_OAEP.new(self.currentClientPublicKey)
+        encrypted_msg = cipher_rsa.encrypt(message)
+        return encrypted_msg
+
+    def signRSAHeader(self, type: str, extradata: dict) -> (bytes, bytes):
+        mandatory = {'type': type, 'source': self.network.own_addr}
+        header = json.dumps({**mandatory, **extradata}).encode('UTF-8')
+        h = SHA512.new(header)
+        headersignature = pkcs1_15.new(self.serverPrivateKey).sign(h)
+        return header, headersignature
+
+    def verifyRSAHeaderSignature(self, header: bytes, headersignature: bytes) -> bool:
+        h = SHA512.new(header)
+        try:
+            pkcs1_15.new(self.currentClientPublicKey).verify(h, headersignature)
+            return True
+        except Exception:
+            return False
+
+    def decryptRSAMessage(self, message: bytes) -> bytes:
+        cipher_rsa = PKCS1_OAEP.new(self.serverPrivateKey)
+        return cipher_rsa.decrypt(message)
 
     def serverIdentify(self, msg: bytes) -> None:
         incommingJson = json.loads(msg.decode('UTF-8'))
-        if incommingJson['type'] != "IDY":
+        header = json.loads(b64decode(incommingJson['header']).decode('UTF-8'))
-            raise Exception('Wrong message type encountered')
+        self.clientAddr = header['source']
-        self.clientAddr = incommingJson['source']
+        self.currentUser = header['username']
-        self.currentUser = incommingJson['username']
         self.currentClientPublicKey = self.clientPublicKey[self.currentUser]
-        cipher_rsa = PKCS1_OAEP.new(self.serverPrivateKey)
+        if not self.verifyRSAHeaderSignature(b64decode(incommingJson['header']),
-        retmsg = cipher_rsa.decrypt(b64decode(incommingJson['message'])).decode('UTF-8')
+                                             b64decode(incommingJson['headersignature'])) or header[
-        cipher = PKCS1_OAEP.new(self.currentClientPublicKey)
+            'type'] != 'IDY':
+            raise Exception('Bad initial message')
+        retheader, retheadersignature = self.signRSAHeader("IDY", {})
+        dcryptedmsg = self.decryptRSAMessage(b64decode(incommingJson['message']))
+        retmsg = self.encryptRSAMessage(dcryptedmsg)
         identMsg = json.dumps(
-            {'type': 'IDY', 'source': self.network.own_addr,
+            {'header': b64encode(retheader).decode('UTF-8'),
-             'message': b64encode(cipher.encrypt(retmsg.encode('UTF-8'))).decode('ASCII')}).encode(
+             'headersignature': b64encode(retheadersignature).decode('UTF-8'),
+             'message': b64encode(retmsg).decode('UTF-8')}).encode(
             'UTF-8')
         self.network.send_msg(self.clientAddr, identMsg)
 
     def sendMessage(self, message: bytes) -> None:
-        cipher = ChaCha20.new(self.cipherkey, get_random_bytes(12))
+        self.sendTypedMessage(message, "CMD")
-        ciphertext = cipher.encrypt(message)
+
-        nonce = b64encode(cipher.nonce).decode('ASCII')
+    def sendTypedMessage(self, message: bytes, type: str) -> None:
-        ct = b64encode(ciphertext).decode('ASCII')
+        if not (type == "AUT" or type == "CMD"):
-        sendjson = json.dumps({'type': 'CMD', 'source': self.network.own_addr, 'nonce': nonce, 'message': ct}).encode(
+            raise Exception('Unknown message type')
+        cipher = ChaCha20_Poly1305.new(key=self.cipherkey)
+        header = json.dumps({'source': self.network.own_addr, 'type': type}).encode('UTF-8')
+        cipher.update(header)
+        ciphertext, tag = cipher.encrypt_and_digest(message)
+        nonce = b64encode(cipher.nonce).decode('UTF-8')
+        ct = b64encode(ciphertext).decode('UTF-8')
+        b64tag = b64encode(tag).decode('UTF-8')
+        sendjson = json.dumps(
+            {'header': b64encode(header).decode('UTF-8'), 'nonce': nonce, 'message': ct, 'tag': b64tag}).encode(
             'UTF-8')
         self.network.send_msg(self.clientAddr, sendjson)
 
     def keyExchange(self) -> None:
         dh = pyDH.DiffieHellman()
-        cipher = PKCS1_OAEP.new(self.currentClientPublicKey)
+        mypubkey = self.encryptRSAMessage(str(dh.gen_public_key()).encode('UTF-8'))
-        mypubkey = b64encode(cipher.encrypt(str(dh.gen_public_key()).encode('UTF-8'))).decode('ASCII')
+        header, headersignature = self.signRSAHeader("DH", {})
-        jsonmsg = json.dumps({'type': 'DH', 'source': self.network.own_addr, 'message': mypubkey}).encode('UTF-8')
+        jsonmsg = json.dumps(
+            {'header': b64encode(header).decode('UTF-8'), 'headersignature': b64encode(headersignature).decode('UTF-8'),
+             'message': b64encode(mypubkey).decode('UTF-8')}).encode('UTF-8')
         self.network.send_msg(self.clientAddr, jsonmsg)
-        decodedmsg = {'source': '', 'type': ''}
-        while not (decodedmsg['source'] == self.clientAddr and decodedmsg['type'] == 'DH'):
         status, msg = self.network.receive_msg(blocking=True)
         if not status:
             raise Exception('Network error during connection.')
         decodedmsg = json.loads(msg.decode('UTF-8'))
-        cipher_rsa = PKCS1_OAEP.new(self.serverPrivateKey)
+        header = json.loads(b64decode(decodedmsg['header']).decode('UTF-8'))
-        serverpubkey = int(cipher_rsa.decrypt(b64decode(decodedmsg['message'])).decode('UTF-8'))
+        if not self.verifyRSAHeaderSignature(b64decode(decodedmsg['header']),
-        self.cipherkey = dh.gen_shared_key(serverpubkey).encode('UTF-8')
+                                             b64decode(decodedmsg['headersignature'])) or not (
+                header['source'] == self.clientAddr and header['type'] == 'DH'):
+            raise Exception('Header signature error')
+        clientpubkey = int(self.decryptRSAMessage(b64decode(decodedmsg['message'])).decode('UTF-8'))
+        cipherkey = dh.gen_shared_key(clientpubkey).encode('UTF-8')
+        hasher = SHA512.new()
+        hasher.update(cipherkey)
+        self.cipherkey = (hasher.hexdigest()[:32]).encode('UTF-8')
 
     def login(self) -> bool:
-        b64 = {'source': '', 'type': ''}
-        while not (b64['source'] == self.clientAddr and b64['type'] == 'AUT'):
         status, msg = self.network.receive_msg(blocking=True)
         if not status:
             raise Exception('Network error during connection.')
-            b64 = json.loads(msg.decode('UTF-8'))
+        cleartext = self.recieveEncryptedMessage(msg, "AUT").decode('UTF-8')
-        try:
+        if cleartext == "ERROR":
-            retnonce = b64decode(b64['nonce'])
+            return False
-            retciphertext = b64decode(b64['message'])
+        else:
-            retcipher = ChaCha20.new(self.cipherkey, nonce=retnonce)
+            plaintext = cleartext.split(' ')
-            plaintext = retcipher.decrypt(retciphertext).decode('UTF-8').split(' ')
+        self.homeDirectory = self.authenticationInstance.login(plaintext[1], plaintext[2])
         linsuccess = (not (len(plaintext) != 3 or plaintext[0] != "LIN" or plaintext[
-                1] != self.currentUser)) and self.serverInstance.login(plaintext[1], plaintext[2])
+            1] != self.currentUser)) and self.homeDirectory
         if linsuccess:
             message = "OK".encode('UTF-8')
         else:
             message = "ERROR".encode('UTF-8')
-            cipher = ChaCha20.new(self.cipherkey, get_random_bytes(12))
+        self.sendTypedMessage(message, "AUT")
-            ciphertext = cipher.encrypt(message)
-            nonce = b64encode(cipher.nonce).decode('ASCII')
-            ct = b64encode(ciphertext).decode('ASCII')
-            sendjson = json.dumps(
-                {'type': 'AUT', 'source': self.network.own_addr, 'nonce': nonce, 'message': ct}).encode(
-                'UTF-8')
-            self.network.send_msg(self.clientAddr, sendjson)
         return linsuccess
-        except Exception:
-            print("Incorrect decryption")
 
     def initClientConnection(self, msg: bytes) -> bytes:
+        print('A client is trying to connect')
         try:
+            print('Server and Client identity verification started')
             self.serverIdentify(msg)
+            print('Key exchange started')
             self.keyExchange()
+            print('Authorization started')
             success = self.login()
+            print(f'Authorization completed, success: {success}')
             if success:
                 return "LINOK".encode('UTF-8')
             else:
                 self.logout()
                 return "LINERROR".encode('UTF-8')
         except Exception:
+            print("Error ecountered, resetting")
             self.logout()
             return "LINERROR".encode('UTF-8')
 
@@ -116,27 +156,31 @@ class NetWrapper:
         if not self.clientAddr:
             return self.initClientConnection(msg)
         else:
-            return self.recieveEncryptedMessage(msg)
+            return self.recieveEncryptedMessage(msg, "CMD")
 
     def logout(self) -> None:
-        self.serverInstance.logout()
         self.clientAddr = ""
         self.cipherkey = "".encode('UTF-8')
         self.currentClientPublicKey = "".encode('UTF-8')
         self.currentUser = ""
+        self.homeDirectory = ""
 
-    def recieveEncryptedMessage(self, msg: bytes) -> bytes:
+    def recieveEncryptedMessage(self, msg: bytes, type: str) -> bytes:
+        if not (type == "AUT" or type == "CMD"):
+            raise Exception('Unknown message type')
         try:
             b64 = json.loads(msg.decode('UTF-8'))
-            while not (b64['source'] == self.clientAddr and b64['type'] == 'CMD'):
+            retheader = json.loads(b64decode(b64['header']).decode('UTF-8'))
-                status, msg = self.network.receive_msg(blocking=True)
-                if not status:
-                    raise Exception('Network error during connection.')
-                b64 = json.loads(msg.decode('UTF-8'))
             retnonce = b64decode(b64['nonce'])
             retciphertext = b64decode(b64['message'])
-            retcipher = ChaCha20.new(self.cipherkey, nonce=retnonce)
+            rettag = b64decode(b64['tag'])
-            plaintext = retcipher.decrypt(retciphertext)
+            retcipher = ChaCha20_Poly1305.new(key=self.cipherkey, nonce=retnonce)
+            retcipher.update(b64decode(b64['header']))
+            plaintext = retcipher.decrypt_and_verify(retciphertext, rettag)
+            if not (retheader['source'] == self.clientAddr and retheader['type'] == type):
+                return "ERROR".encode('UTF-8')
+            else:
                 return plaintext
         except Exception:
             print("Incorrect decryption")
+            return "ERROR".encode('UTF-8')

server/server.py

@@ -1,4 +1,5 @@
 #!/usr/bin/env python3
+import os
 from authentication import Authetication
 from executor import Executor
 from netwrapper import NetWrapper
@@ -6,55 +7,59 @@ from netwrapper import NetWrapper
 
 class Server:
 
-    def __init__(self, homeDirectory: str = "", sessionTimeout: int = 120, availableServer: bool = True):
+    def __init__(self, sessionTimeout: int = 120, availableServer: bool = True):
         self.isAuthenticated = False
-        self.homeDirectory = homeDirectory
         self.sessionTimeout = sessionTimeout
         self.availableServer = availableServer
-        self.executor = Executor(homeDirectory)
+        self.executor = Executor("")
+        self.auth = Authetication()
 
     def initServer(self):
         print("Please enter your private key passphrase")
         passphrase = input()
-        self.auth = Authetication()
         self.networkInstance = NetWrapper(self.auth.loadUserPublicKeys(), self.auth.loadServerPrivateKey(passphrase),
-                                          self)
+                                          self.auth)
 
-    def login(self, username: str, password: str) -> bool:
+    def login(self, homeDir: str) -> None:
         self.isAuthenticated = True
-        home_directory = self.auth.login(username, password)
+        self.executor = Executor(homeDir + os.path.sep)
-        self.executor.baseDir = Executor(home_directory)
-        if not home_directory:
-            return False
-        else:
-            return True
 
     def logout(self) -> None:
+        self.networkInstance.logout()
         self.isAuthenticated = False
         self.availableServer = False
-        self.homeDirectory = ""
+        self.executor = Executor("")
-        self.executor.baseDir = Executor(self.homeDirectory)
 
     def parseCommand(self, command: str) -> None:
         if command == "LINOK":
-            self.networkInstance.sendMessage("LINOK".encode('UTF-8'))
+            self.login(self.networkInstance.homeDirectory)
+            self.networkInstance.sendMessage("OK".encode('UTF-8'))
+            return None
         elif command == "LINERROR":
-            self.networkInstance.sendMessage("LINERROR".encode('UTF-8'))
+            return None
+        elif command == "ERROR":
+            self.networkInstance.sendMessage("ERROR".encode('UTF-8'))
+            return None
         parsedCommand = command.split(" ")
         if len(parsedCommand) > 3:
             self.networkInstance.sendMessage("ERROR".encode('UTF-8'))
-        # TODO: Ez igy gecironda, ezt meg kene csinalni rendesen.
         elif len(parsedCommand) == 1:
-            return self.execute(parsedCommand[0])
+            self.execute(parsedCommand[0])
         elif len(parsedCommand) == 2:
-            return self.execute(parsedCommand[0], parsedCommand[1])
+            self.execute(parsedCommand[0], parsedCommand[1])
         elif len(parsedCommand) == 3:
-            return self.execute(parsedCommand[0], parsedCommand[1], parsedCommand[2])
+            self.execute(parsedCommand[0], parsedCommand[1], parsedCommand[2])
 
     def execute(self, command: str, firstParam: str = "", secondParam: str = "") -> None:
-        if self.homeDirectory == "" or self.executor.currentDirectory == "" or self.executor.baseDir == "":
+        if self.executor.baseDir == "":
-            raise Exception("Directories must not be empty string. Did the user log in?")
+            raise Exception("Home directory must not be empty string. Did the user log in?")
-        if command == "MKD":
+        if command == "LOUT":
+            if not (secondParam == "" and firstParam == ""):
+                self.networkInstance.sendMessage("ERROR".encode('UTF-8'))
+            else:
+                self.networkInstance.sendMessage("OK".encode('UTF-8'))
+                self.logout()
+        elif command == "MKD":
             if secondParam != "":
                 self.networkInstance.sendMessage("ERROR".encode('UTF-8'))
             else:
@@ -67,11 +72,10 @@ class Server:
                 self.executor.removeDirectory(firstParam)
                 self.networkInstance.sendMessage("OK".encode('UTF-8'))
         elif command == "GWD":
-            if secondParam != "" or firstParam != "":
+            if not (secondParam == "" and firstParam == ""):
                 self.networkInstance.sendMessage("ERROR".encode('UTF-8'))
             else:
-                self.executor.getCurrentDirectory()
+                self.networkInstance.sendMessage(self.executor.getCurrentDirectory().encode('UTF-8'))
-                self.networkInstance.sendMessage("OK".encode('UTF-8'))
         elif command == "CWD":
             if secondParam != "":
                 self.networkInstance.sendMessage("ERROR".encode('UTF-8'))
@@ -79,11 +83,10 @@ class Server:
                 self.executor.setCurrentDirectory(firstParam)
                 self.networkInstance.sendMessage("OK".encode('UTF-8'))
         elif command == "LST":
-            if secondParam != "" or firstParam != "":
+            if not (secondParam == "" and firstParam == ""):
                 self.networkInstance.sendMessage("ERROR".encode('UTF-8'))
             else:
-                self.executor.listCurrentDirectoryContent()
+                self.networkInstance.sendMessage(self.executor.listCurrentDirectoryContent().encode('UTF-8'))
-                self.networkInstance.sendMessage("OK".encode('UTF-8'))
         elif command == "RMF":
             if secondParam != "":
                 self.networkInstance.sendMessage("ERROR".encode('UTF-8'))
@@ -94,28 +97,31 @@ class Server:
             if secondParam != "":
                 self.networkInstance.sendMessage("ERROR".encode('UTF-8'))
             else:
-                # TODO
+                fileMessage = self.networkInstance.recieveMessage()
-                # Megkapod a filenevet argumentumneknt
+                eof = self.networkInstance.recieveMessage().decode('UTF-8')
-                # Fogadni kell egy uzenetet, ami a fajl tartalma
+                if eof == "EOF":
-                # Fogadni kell egy uzenetet, ami "EOF"
+                    self.executor.putFileInCurrentDirectory(firstParam, fileMessage)
-                # Mindig minden legyen UTF-8-kent kodolva, kiveve a falj, az marard
+                    self.networkInstance.sendMessage("OK".encode('UTF-8'))
-                # Ha sikeres, OK kuldese, kulonben ERROR kuldese
+                else:
-                pass
+                    self.networkInstance.sendMessage("ERROR".encode('UTF-8'))
         elif command == "DNL":
             if secondParam != "":
                 self.networkInstance.sendMessage("ERROR".encode('UTF-8'))
             else:
-                # TODO
+                try:
-                # Megkapod a filenevet arguemntumkent
+                    file = self.executor.getFileInCurrentDirectory(firstParam)
-                # Kuldeni kell egy uzenetet, ami a falj tartalma
+                    self.networkInstance.sendMessage(file)
-                # Kuldeni kell egy uzenetet, ami EOF
+                    self.networkInstance.sendMessage("EOF".encode('UTF-8'))
-                # Mindig minden legyen UTF-8-kent kodolva, kiveve a falj, az marard
+                except Exception:
-                # Ha sikeres, OK valaszt megkapod, kulonben ERROR valaszt megkapod
+                    self.networkInstance.sendMessage("ERROR".encode('UTF-8'))
-                pass
         else:
             self.networkInstance.sendMessage("ERROR".encode('UTF-8'))
 
     def startServer(self):
         while True:
+            try:
                 message = self.networkInstance.recieveMessage().decode('UTF-8')
                 self.parseCommand(message)
+            except Exception as e:
+                self.networkInstance.sendMessage("ERROR".encode('UTF-8'))
+                print(e)