From a8e8eed61993fd657188a2039d82588d789cd025 Mon Sep 17 00:00:00 2001 From: Emery Hemingway Date: Tue, 30 Aug 2022 11:48:46 -0500 Subject: [PATCH] Remove broken tests --- syndicate.nimble | 2 +- tests/box_and_client.nim | 20 ----------- tests/test_box_and_client.nim | 66 ----------------------------------- tests/test_dsl.nim | 35 ------------------- tests/test_timer.nim | 27 -------------- 5 files changed, 1 insertion(+), 149 deletions(-) delete mode 100644 tests/box_and_client.nim delete mode 100644 tests/test_box_and_client.nim delete mode 100644 tests/test_dsl.nim delete mode 100644 tests/test_timer.nim diff --git a/syndicate.nimble b/syndicate.nimble index 86b25ad..b6a5244 100644 --- a/syndicate.nimble +++ b/syndicate.nimble @@ -1,6 +1,6 @@ # Package -version = "20220829" +version = "20220830" author = "Emery Hemingway" description = "Syndicated actors for conversational concurrency" license = "Unlicense" diff --git a/tests/box_and_client.nim b/tests/box_and_client.nim deleted file mode 100644 index a101954..0000000 --- a/tests/box_and_client.nim +++ /dev/null @@ -1,20 +0,0 @@ - -## Date of generation: 2021-09-01 13:32 -import - std/typetraits, preserves - -type - EmbeddedType = void - BoxState* {.record: "box-state".} = object ## ```` - `value`*: BiggestInt - - SetBox* {.record: "set-box".} = object ## ```` - `value`*: BiggestInt - -proc prsBoxState*(value: Preserve | BiggestInt): Preserve = - initRecord[EmbeddedType](symbol("box-state", EmbeddedType), - toPreserve(value, EmbeddedType)) - -proc prsSetBox*(value: Preserve | BiggestInt): Preserve = - initRecord[EmbeddedType](symbol("set-box", EmbeddedType), - toPreserve(value, EmbeddedType)) diff --git a/tests/test_box_and_client.nim b/tests/test_box_and_client.nim deleted file mode 100644 index 2f995e4..0000000 --- a/tests/test_box_and_client.nim +++ /dev/null @@ -1,66 +0,0 @@ -# SPDX-FileCopyrightText: 2021 ☭ Emery Hemingway -# SPDX-License-Identifier: Unlicense - -import syndicate/assertions, syndicate/dataspaces, syndicate/events, syndicate/skeletons -import preserves, preserves/records -import asyncdispatch, tables, options - -import ./box_and_client - -const N = 100000 - -let - `?_` = Discard().toPreserve - `?$` = Capture().toPreserve - -proc boot(facet: Facet) = - - facet.spawn("box") do (facet: Facet): - facet.declareField(value, int, 0) - - facet.addEndpoint do (facet: Facet) -> EndpointSpec: - # echo "recomputing published BoxState ", facet.fields.value - result.assertion = prsBoxState(value.getPreserve) - - 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.addEndpoint do (facet: Facet) -> EndpointSpec: - let a = prsSetBox(`?$`) - result.analysis = some analyzeAssertion(a) - proc cb(facet: Facet; vs: seq[Value]) = - facet.scheduleScript do (facet: Facet): - value.set(vs[0]) - # echo "box updated value ", vs[0] - result.callback = facet.wrap(messageEvent, cb) - result.assertion = observe(prsSetBox(`?$`)) - - facet.spawn("client") do (facet: Facet): - - facet.addEndpoint do (facet: Facet) -> EndpointSpec: - let a = prsBoxState(`?$`) - result.analysis = some analyzeAssertion(a) - proc cb(facet: Facet; vs: seq[Value]) = - facet.scheduleScript do (facet: Facet): - let v = prsSetBox(vs[0].int.succ.toPreserve) - # echo "client sending ", v - facet.send(v) - result.callback = facet.wrap(addedEvent, cb) - result.assertion = observe(prsBoxState(`?$`)) - - facet.addEndpoint do (facet: Facet) -> EndpointSpec: - let a = prsBoxState(`?_`) - result.analysis = some analyzeAssertion(a) - proc cb(facet: Facet; vs: seq[Value]) = - facet.scheduleScript do (facet: Facet): - echo "box gone" - result.callback = facet.wrap(removedEvent, cb) - result.assertion = observe(prsBoxState(`?_`)) - - facet.actor.dataspace.ground.addStopHandler do (_: Dataspace): - echo "stopping box-and-client" - -waitFor bootModule("box-and-client", boot) diff --git a/tests/test_dsl.nim b/tests/test_dsl.nim deleted file mode 100644 index 6d9da6b..0000000 --- a/tests/test_dsl.nim +++ /dev/null @@ -1,35 +0,0 @@ -# SPDX-FileCopyrightText: ☭ 2021 Emery Hemingway -# SPDX-License-Identifier: Unlicense - -import std/asyncdispatch -import preserves -import syndicate - -import ./box_and_client - -syndicate testDsl: - - spawn "box": - field(currentValue, BiggestInt, 0) - publish prsBoxState(currentValue.get) - stopIf currentValue.get == 10: - echo "box: terminating" - onMessage(prsSetBox(?newValue)) do (newValue: int): - # The SetBox message is unpacked to `newValue: int` - echo "box: taking on new value ", newValue - currentValue.set(newValue) - - spawn "client": - #stopIf retracted(observe(SetBox, _)): - # echo "client: box has gone" - onAsserted(prsBoxState(?v)) do (v: BiggestInt): - echo "client: learned that box's value is now ", v - send(prsSetBox(v.succ)) - onRetracted(prsBoxState(?_)) do (_): - echo "client: box state disappeared" - onStop: - quit(0) # Quit explicitly rather than let the dispatcher run empty. - -runForever() - # The dataspace is driven by the async dispatcher. - # Without `runForever` this module would exit immediately. diff --git a/tests/test_timer.nim b/tests/test_timer.nim deleted file mode 100644 index 9148660..0000000 --- a/tests/test_timer.nim +++ /dev/null @@ -1,27 +0,0 @@ -# SPDX-FileCopyrightText: 2021 ☭ Emery Hemingway -# SPDX-License-Identifier: Unlicense - -import std/[asyncdispatch, monotimes, times] -import preserves, preserves/records -import syndicate - -import syndicate/drivers/timers - -syndicate plainTimerDemo: - boot timerDriver - - spawn "laterThanDemo": - field(deadline, MonoTime, getMonoTime()) - field(count, int, 0) - - onAsserted(prsTimeLaterThan(deadline.get)) do (): - echo "TimeLaterThan ticked for deadline ", deadline.get - count.set(count.get.succ) - if count.get < 5: - deadline.set(getMonoTime() + initDuration(milliseconds = 500)) - - onStop: - echo "dataspace stopped" - quit(0) - -runForever()