mygpo/db/couchdb/pubsub.py

   1 from mygpo.pubsub.models import Subscription
   2 from mygpo.db.couchdb import get_pubsub_database
   3
   4
   5 def subscription_for_topic(topic):
   6     """ return the subscription for the given topic, one None """
   7
   8     db = get_pubsub_database()
   9
  10     r = db.view('subscriptions/by_topic',
  11             key          = topic,
  12             include_docs = True,
  13             reduce       = False,
  14             schema       = Subscription
  15         )
  16
  17     if r:
  18         sub = r.one()
  19         sub.set_db(db)
  20         return sub
  21
  22     else:
  23         return None