syndicate-nim/tests/test_box_and_client.nim

# SPDX-License-Identifier: ISC

import syndicate/assertions, syndicate/dataspaces, syndicate/events, syndicate/skeletons
import preserves, preserves/records
import asyncdispatch, tables, options

const N = 100000

const
  BoxState = RecordClass(label: symbol"BoxState", arity: 1)
  SetBox = RecordClass(label: symbol"SetBox", arity: 1)


proc boot(facet: Facet) =

  facet.spawn("box") do (facet: Facet):
    facet.declareField(value, int, 0)

    discard facet.addEndpoint do (facet: Facet) -> EndpointSpec:
      # echo "recomputing published BoxState ", facet.fields.value
      let a = BoxState % value.get
      result.assertion = some a

    discard facet.addDataflow do (facet: Facet):
      # echo "box dataflow saw new value ", facet.fields.value
      if value.get == N:
        facet.stop do (facet: Facet):
          echo "terminated box root facet"

    facet.onMessage(SetBox % `?*`) do (facet: Facet; vs: seq[Value]):
        value.set(vs[0])
        echo "box updated value ", vs[0]

  facet.spawn("client") do (facet: Facet):

    facet.onAsserted(BoxState % `?*`) do (facet: Facet; vs: seq[Value]):
      let v = SetBox % vs[0].int.succ
      # echo "client sending ", v
      facet.send(v)

    facet.onRetracted(BoxState % `?_`) do (facet: Facet; vs: seq[Value]):
      echo "box gone"

  facet.actor.dataspace.ground.addStopHandler do (_: Dataspace):
    echo "stopping box-and-client"

waitFor bootModule("box-and-client", boot)