• Przemyslaw Kaminski's avatar
    [websockets] initial implementation of async notifications · 9de83328
    Przemyslaw Kaminski authored
    I'm currently able to do the following:
    - start gargantext-server (as it hosts central exchange and
    dispatcher, currently)
    - start a websocket connection:
      websocat ws://localhost:8008/ws
    - subscibe to a topic (in websocat):
      {"request": "subscribe", "topic": {"type": "update_tree", "node_id":
      15}}
    - optionally subscibe to other node_ids or start other websocat's with
      different subscriptions (can be multiple)
    - fire up
      cabal v2-run gargantext-central-exchange -- client
      This triggers a node_id: 15 and node_id: 16 notification to be sent
    
    You can send your own notifications, e.g. with Python:
    import json
    import nanomsg as n
    s = n.Socket(n.PUSH)
    s.connect('tcp://localhost:5560')
    s.send(json.dumps({'type': 'update_tree_first_level', 'node_id': 15}))
    9de83328
Name
Last commit
Last update
..
AsyncUpdates Loading commit data...
Ext Loading commit data...
Flow Loading commit data...
Mail Loading commit data...
Methods Loading commit data...
NodeStory Loading commit data...
Text Loading commit data...
Types Loading commit data...
Utils Loading commit data...
Viz Loading commit data...
AsyncUpdates.hs Loading commit data...
Mail.hs Loading commit data...
NLP.hs Loading commit data...
NodeStory.hs Loading commit data...
NodeStoryFile.hs.old Loading commit data...
Statistics.hs Loading commit data...
Text.hs Loading commit data...
Types.hs Loading commit data...
Utils.hs Loading commit data...
Viz.hs Loading commit data...