Skip to content

Commit

Permalink
enable quasar
Browse files Browse the repository at this point in the history
  • Loading branch information
F483 committed Feb 28, 2016
1 parent d09db20 commit 5c5f34c
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion storjnet/api.py
Original file line number Diff line number Diff line change
Expand Up @@ -31,6 +31,7 @@ def __init__(self, node_key=None, node_port=None, bootstrap=None,
self._setup_node(node_key)
self._setup_protocol(noisy, queue_limit)
self._setup_kademlia(bootstrap, node_port)
self._setup_quasar(queue_limit, history_limit)
# TODO setup streams

def _setup_node(self, node_key):
Expand Down Expand Up @@ -169,7 +170,7 @@ def dht_peers(self):
def pubsub_publish(self, topic, event):
"""Publish an event on the network for a given topic."""
# TODO sanatize input
# TODO use envelope { sender, body, signature } ?
# TODO use envelope { timestamp, sender, body, signature } ?
self._quasar.publish(topic, event)

@apigen.command()
Expand Down

0 comments on commit 5c5f34c

Please sign in to comment.