mirror of
https://github.com/OCA/knowledge.git
synced 2025-07-26 10:28:40 -06:00
[FIX] flake8 fixes
This commit is contained in:
parent
109ce4c35b
commit
54520fb4f6
@ -48,4 +48,3 @@
|
||||
'images/3_document_ftp.jpeg'],
|
||||
'post_load': 'post_load',
|
||||
}
|
||||
|
||||
|
@ -26,18 +26,19 @@ import logging
|
||||
|
||||
import document_ftp.ftpserver.Authorizer
|
||||
import document_ftp.ftpserver.AbstractedFs
|
||||
import document_ftp.ftpserver.ftpserver
|
||||
import document_ftp.ftpserver.FtpServer
|
||||
|
||||
import openerp
|
||||
from openerp.tools import config
|
||||
_logger = logging.getLogger(__name__)
|
||||
import socket
|
||||
|
||||
|
||||
def start_server():
|
||||
if openerp.multi_process:
|
||||
_logger.info("FTP disabled in multiprocess mode")
|
||||
return
|
||||
ip_address = ([(s.connect(('8.8.8.8', 80)), s.getsockname()[0], s.close()) \
|
||||
ip_address = ([(s.connect(('8.8.8.8', 80)), s.getsockname()[0], s.close())
|
||||
for s in [socket.socket(socket.AF_INET, socket.SOCK_DGRAM)]][0][1])
|
||||
if not ip_address:
|
||||
ip_address = '127.0.0.1'
|
||||
@ -51,19 +52,19 @@ def start_server():
|
||||
class FtpServer(threading.Thread):
|
||||
|
||||
def run(self):
|
||||
autho = authorizer.Authorizer()
|
||||
ftpserver.FTPHandler.authorizer = autho
|
||||
ftpserver.max_cons = 300
|
||||
ftpserver.max_cons_per_ip = 50
|
||||
ftpserver.FTPHandler.abstracted_fs = abstracted_fs.AbstractedFs
|
||||
autho = Authorizer.Authorizer()
|
||||
FtpServer.FTPHandler.Authorizer = autho
|
||||
FtpServer.max_cons = 300
|
||||
FtpServer.max_cons_per_ip = 50
|
||||
FtpServer.FTPHandler.AbstractedFs = AbstractedFs.AbstractedFs
|
||||
if PASSIVE_PORTS:
|
||||
ftpserver.FTPHandler.passive_ports = PASSIVE_PORTS
|
||||
FtpServer.FTPHandler.passive_ports = PASSIVE_PORTS
|
||||
|
||||
ftpserver.log = lambda msg: _logger.info(msg)
|
||||
ftpserver.logline = lambda msg: None
|
||||
ftpserver.logerror = lambda msg: _logger.error(msg)
|
||||
FtpServer.log = lambda msg: _logger.info(msg)
|
||||
FtpServer.logline = lambda msg: None
|
||||
FtpServer.logerror = lambda msg: _logger.error(msg)
|
||||
|
||||
ftpd = ftpserver.FTPServer((HOST, PORT), ftpserver.FTPHandler)
|
||||
ftpd = FtpServer.FTPServer((HOST, PORT), FtpServer.FTPHandler)
|
||||
ftpd.serve_forever()
|
||||
|
||||
if HOST.lower() == 'none':
|
||||
|
@ -1,5 +1,9 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
|
||||
import pooler
|
||||
import security
|
||||
|
||||
|
||||
class Authorizer:
|
||||
read_perms = "elr"
|
||||
write_perms = "adfmw"
|
||||
@ -67,4 +71,3 @@ class Authorizer:
|
||||
def get_msg_quit(self, username):
|
||||
"""Return the user's quitting message."""
|
||||
return 'Bye.'
|
||||
|
||||
|
@ -23,4 +23,3 @@
|
||||
|
||||
from . import ftp_browse
|
||||
from . import ftp_configuration
|
||||
|
||||
|
@ -25,6 +25,7 @@ from openerp.osv.orm import fields
|
||||
from openerp.osv.orm import TransientModel
|
||||
from .. import ftpserver
|
||||
|
||||
|
||||
class DocumentFtpBrowse(TransientModel):
|
||||
_name = 'document.ftp.browse'
|
||||
_description = 'Document FTP Browse'
|
||||
|
Loading…
Reference in New Issue
Block a user