latch-nfqueue.py

import nfqueue
import socket
import latch

q = None

def cb(dummy, payload):
  response = api.status("ACCOUNT_ID_HERE").get_data()
  if response["operations"][appId]["status"] == 'on'
    payload.set_verdict(nfqueue.NF_DROP)
  else
    payload.set_verdict(nfqueue.NF_ACCEPT)

api = latch.Latch("APP_ID_HERE", "SECRET_KEY_HERE")

q = nfqueue.queue()
q.open()
q.bind(socket.AF_INET)
q.set_callback(cb)
q.create_queue(0)
try:
  q.try_run()
except KeyboardInterrupt:
  print "Exiting..."
q.unbind(socket.AF_INET)
q.close()