| Index: third_party/twisted_8_1/twisted/news/news.py
|
| diff --git a/third_party/twisted_8_1/twisted/news/news.py b/third_party/twisted_8_1/twisted/news/news.py
|
| deleted file mode 100644
|
| index 2aad86cc2d42f9fb2538f6e9ae0ade9d74d67d32..0000000000000000000000000000000000000000
|
| --- a/third_party/twisted_8_1/twisted/news/news.py
|
| +++ /dev/null
|
| @@ -1,90 +0,0 @@
|
| -# Copyright (c) 2001-2004 Twisted Matrix Laboratories.
|
| -# See LICENSE for details.
|
| -
|
| -
|
| -"""
|
| -Maintainer: U{Jp Calderone<mailto:exarkun@twistedmatrix.com>}
|
| -"""
|
| -
|
| -from twisted.news import nntp
|
| -from twisted.internet import protocol, reactor
|
| -
|
| -import time
|
| -
|
| -class NNTPFactory(protocol.ServerFactory):
|
| - """A factory for NNTP server protocols."""
|
| -
|
| - protocol = nntp.NNTPServer
|
| -
|
| - def __init__(self, backend):
|
| - self.backend = backend
|
| -
|
| - def buildProtocol(self, connection):
|
| - p = self.protocol()
|
| - p.factory = self
|
| - return p
|
| -
|
| -
|
| -class UsenetClientFactory(protocol.ClientFactory):
|
| - def __init__(self, groups, storage):
|
| - self.lastChecks = {}
|
| - self.groups = groups
|
| - self.storage = storage
|
| -
|
| -
|
| - def clientConnectionLost(self, connector, reason):
|
| - pass
|
| -
|
| -
|
| - def clientConnectionFailed(self, connector, reason):
|
| - print 'Connection failed: ', reason
|
| -
|
| -
|
| - def updateChecks(self, addr):
|
| - self.lastChecks[addr] = time.mktime(time.gmtime())
|
| -
|
| -
|
| - def buildProtocol(self, addr):
|
| - last = self.lastChecks.setdefault(addr, time.mktime(time.gmtime()) - (60 * 60 * 24 * 7))
|
| - p = nntp.UsenetClientProtocol(self.groups, last, self.storage)
|
| - p.factory = self
|
| - return p
|
| -
|
| -
|
| -# XXX - Maybe this inheritence doesn't make so much sense?
|
| -class UsenetServerFactory(NNTPFactory):
|
| - """A factory for NNTP Usenet server protocols."""
|
| -
|
| - protocol = nntp.NNTPServer
|
| -
|
| - def __init__(self, backend, remoteHosts = None, updatePeriod = 60):
|
| - NNTPFactory.__init__(self, backend)
|
| - self.updatePeriod = updatePeriod
|
| - self.remoteHosts = remoteHosts or []
|
| - self.clientFactory = UsenetClientFactory(self.remoteHosts, self.backend)
|
| -
|
| -
|
| - def startFactory(self):
|
| - self._updateCall = reactor.callLater(0, self.syncWithRemotes)
|
| -
|
| -
|
| - def stopFactory(self):
|
| - if self._updateCall:
|
| - self._updateCall.cancel()
|
| - self._updateCall = None
|
| -
|
| -
|
| - def buildProtocol(self, connection):
|
| - p = self.protocol()
|
| - p.factory = self
|
| - return p
|
| -
|
| -
|
| - def syncWithRemotes(self):
|
| - for remote in self.remoteHosts:
|
| - reactor.connectTCP(remote, 119, self.clientFactory)
|
| - self._updateCall = reactor.callLater(self.updatePeriod, self.syncWithRemotes)
|
| -
|
| -
|
| -# backwards compatability
|
| -Factory = UsenetServerFactory
|
|
|