← Back to branch summary

~launchpad-pqm/launchpad/devel

« back to all changes in this revision

Viewing changes to lib/lp/codehosting/sshserver/service.py

Split the events classes into their own module.

Show diffs side-by-side

added added

removed removed

Lines of Context:
lib/lp/codehosting/sshserver/service.py
25
25
from zope.event import notify
26
26
 
27
27
from canonical.config import config
28
 
from lp.codehosting.sshserver import accesslog
 
28
from lp.codehosting.sshserver import accesslog, events
29
29
from lp.codehosting.sshserver.auth import get_portal, SSHUserAuthServer
30
30
from lp.services.twistedsupport import gatherResults
31
31
 
103
103
        transport._realConnectionLost = transport.connectionLost
104
104
        transport.connectionLost = (
105
105
            lambda reason: self.connectionLost(transport, reason))
106
 
        notify(accesslog.UserConnected(transport, address))
 
106
        notify(events.UserConnected(transport, address))
107
107
        return transport
108
108
 
109
109
    def connectionLost(self, transport, reason):
122
122
            # b) the server doesn't normally generate a "go away" event.
123
123
            # Rather, the client simply stops trying.
124
124
            if getattr(transport, 'avatar', None) is None:
125
 
                notify(accesslog.AuthenticationFailed(transport))
126
 
            notify(accesslog.UserDisconnected(transport))
 
125
                notify(events.AuthenticationFailed(transport))
 
126
            notify(events.UserDisconnected(transport))
127
127
 
128
128
    def getPublicKeys(self):
129
129
        """Return the server's configured public key.
170
170
    def startService(self):
171
171
        """Start the SSH service."""
172
172
        accesslog.LoggingManager().setUp(configure_oops_reporting=True)
173
 
        notify(accesslog.ServerStarting())
 
173
        notify(events.ServerStarting())
174
174
        # By default, only the owner of files should be able to write to them.
175
175
        # Perhaps in the future this line will be deleted and the umask
176
176
        # managed by the startup script.
184
184
            defer.maybeDeferred(service.Service.stopService, self),
185
185
            defer.maybeDeferred(self.service.stopService)])
186
186
        def log_stopped(ignored):
187
 
            notify(accesslog.ServerStopped())
 
187
            notify(events.ServerStopped())
188
188
            return ignored
189
189
        return deferred.addBoth(log_stopped)