Index: third_party/twisted_8_1/twisted/web/monitor.py |
diff --git a/third_party/twisted_8_1/twisted/web/monitor.py b/third_party/twisted_8_1/twisted/web/monitor.py |
deleted file mode 100644 |
index 052e94c3b4cbbb7373f53009713cee5b2f90ba27..0000000000000000000000000000000000000000 |
--- a/third_party/twisted_8_1/twisted/web/monitor.py |
+++ /dev/null |
@@ -1,85 +0,0 @@ |
-# Copyright (c) 2001-2004 Twisted Matrix Laboratories. |
-# See LICENSE for details. |
- |
-# |
-from twisted.web import client |
-from twisted.internet import reactor |
-import md5 |
-from zope.interface import implements |
- |
-class IChangeNotified: |
- pass |
- |
-class BaseChangeNotified: |
- |
- implements(IChangeNotified) |
- |
- def reportChange(self, old, new): |
- pass |
- |
- def reportNoChange(self): |
- pass |
- |
-class ChangeChecker: |
- |
- working = 0 |
- call = None |
- |
- def __init__(self, notified, url, delay=60): |
- self.notified = notified |
- self.url = url |
- self.md5 = None |
- self.delay = delay |
- |
- def start(self): |
- self.working = 1 |
- self._getPage() |
- |
- def stop(self): |
- if self.call: |
- self.call.cancel() |
- self.call = None |
- self.working = 0 |
- |
- def _getPage(self): |
- d = client.getPage(self.url) |
- d.addErrback(self.noPage) |
- d.addCallback(self.page) |
- self.call = None |
- |
- def noPage(self, e): |
- self.gotMD5(None) |
- |
- def page(self, p): |
- if p is None: |
- return self.gotMD5(None) |
- m = md5.new() |
- m.update(p) |
- self.gotMD5(m.digest()) |
- |
- def gotMD5(self, md5): |
- if not self.working: |
- return |
- if md5 != self.md5: |
- self.notified.reportChange(self.md5, md5) |
- self.md5 = md5 |
- else: |
- self.notified.reportNoChange() |
- if not self.call: |
- self.call = reactor.callLater(self.delay, self._getPage) |
- |
- |
-class ProxyChangeChecker(ChangeChecker): |
- |
- def __init__(self, proxyHost, proxyPort, notified, url, delay=60): |
- self.proxyHost = proxyHost |
- self.proxyPort = proxyPort |
- ChangeChecker.__init__(self, notified, url, delay) |
- |
- def _getPage(self): |
- factory = client.HTTPClientFactory(self.proxyHost, self.url) |
- factory.headers = {'pragma': 'no-cache'} |
- reactor.connectTCP(self.proxyHost, self.proxyPort, factory) |
- d = factory.deferred |
- d.addErrback(self.noPage) |
- d.addCallback(self.page) |