Live Client Sudo Logic.md

Live Client

• each client holds open one primary and potentially multiple secondary connections

• subscribe(qid, callback):

  • stores an item mapping qid to callback

  • opens a secondary_channel with qid

  • stores an item mapping qid to secondary_channel

  • on_primary_response:

    • dedupe_callback(qid, item) for item in items
    • update seen
    • for channel in secondary_channels:
      • add qid to primary if qid not in primary
      • flag secondary as ready_to_close

  • on_secondary_response

    • dedupe_callback(qid, item) for item in items
    • close() if ready_to_close

• unsubscribe(qid):

  • remove item mapping qid to callback
  • stores an item mapping qid to to_remove
  • for channel in secondary_channels:
    • flag as ready_to_close if channel.qid == qid

• constructor:

  • starts a cleanup loop that removes old items