1 # Copyright (c) 2011 Neal H. Walfield
3 # This program is free software: you can redistribute it and/or modify
4 # it under the terms of the GNU General Public License as published by
5 # the Free Software Foundation, either version 3 of the License, or
6 # (at your option) any later version.
8 # This program is distributed in the hope that it will be useful,
9 # but WITHOUT ANY WARRANTY; without even the implied warranty of
10 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
11 # GNU General Public License for more details.
13 # You should have received a copy of the GNU General Public License
14 # along with this program. If not, see <http://www.gnu.org/licenses/>.
17 logger = logging.getLogger(__name__)
20 # Don't fail if the Woodchuck modules are not available. Just disable
21 # Woodchuck's functionality.
23 # Whether we imported the woodchuck modules successfully.
24 woodchuck_imported = True
27 from pywoodchuck import PyWoodchuck
28 from pywoodchuck import woodchuck
29 except ImportError, exception:
31 "Unable to load Woodchuck modules: disabling Woodchuck support: %s"
32 % traceback.format_exc ())
33 woodchuck_imported = False
34 class PyWoodchuck (object):
39 # The default channel refresh interval: 6 hours.
40 refresh_interval = 6 * 60 * 60
42 class mywoodchuck (PyWoodchuck):
43 def __init__(self, listing, human_readable_name, identifier,
46 PyWoodchuck.__init__ (self, human_readable_name, identifier,
50 "Failed to establish a connection to the Woodchuck server: %s"
52 self.available = self.not_available
55 self.listing = listing
57 def not_available(self):
61 def stream_update_cb(self, stream, *args, **kwargs):
62 logger.debug("stream update called on %s (%s)"
63 % (stream.human_readable_name, stream.identifier,))
65 # Make sure no one else is concurrently updating this
68 self.listing.updateFeed(stream.identifier)
70 logger.debug("Updating %s: %s"
71 % (stream.identifier, traceback.format_exc ()))
73 def object_transfer_cb(self, stream, object,
74 version, filename, quality,
76 logger.debug ("object transfer called on %s (%s) in stream %s (%s)"
77 % (object.human_readable_name, object.identifier,
78 stream.human_readable_name, stream.identifier))
80 self[stream.identifier][object.identifier].dont_transfer = True
82 logger.warn("Setting '%s'(%s).'%s'(%s).DontTransfer: %s"
83 % (stream.human_readable_name, stream.identifier,
84 object.human_readable_name, object.identifier,
88 def wc_init(listing, request_feedback=False):
89 """Connect to the woodchuck server and initialize any state."""
93 _w = mywoodchuck (listing, "FeedingIt", "org.marcoz.feedingit",
96 if not woodchuck_imported or not _w.available ():
97 logger.info("Unable to contact Woodchuck server.")
99 logger.debug("Woodchuck appears to be available.")
102 """Return the Woodchuck singleton."""
104 assert _w is not None