Method blob_handler

dshell/plugins/ftp/ftp.py:197–340

(self, conn, blob)

    def blob_handler(self, conn, blob):
        try:
            info = self.conns[conn.addr]
        except KeyError:
            # connection was not initialized correctly
            # set the blob to hidden and move on
            blob.hidden = True
            return

        if info['mode'] == DATA_CONN:
            return conn, blob

        try:
            data = blob.data
            data = data.decode('ascii')
        except UnicodeDecodeError as e:
            # Could not convert command data to readable ASCII
            blob.hidden = True
            return

        if blob.direction == 'cs':
            # client-to-server: try and get the command issued
            if ' ' not in data.rstrip():
                command = data.rstrip()
                param = ''
            else:
                command, param = data.rstrip().split(' ', 1)
            command = command.upper()
            info['lastcommand'] = command

            if command == 'USER':
                info['user'] = param

            elif command == 'PASS':
                info['pass'] = param

            elif command == 'CWD':
                info['path'].append(param)

            elif command == 'PASV' or command == 'EPSV':
                if self.dump:
                    # Temporarily store the pair of IP addresses
                    # to open up the BPF filter until blob_handler processes
                    # the response with the full IP/Port information.
                    # Note: Due to the way blob processing works, we don't
                    # get this information until after the data channel is
                    # established.
                    info['tempippair'] = tuple(
                        sorted((conn.clientip, conn.serverip))
                    )
                    self.__update_bpf()

            # For file transfers (including LIST), store tuple
            # (Direction, Path, Filename) in info['file']
            elif command == 'LIST':
                if param == '':
                    info['file'] = (
                        'RETR', os.path.normpath(os.path.join(*info['path']))