[net] react

- When we add a data into a place,
  try to fire all the neighboring transitions.

TODO.md

@@ -1,13 +1,10 @@
 # net
 
-[net] `react`
+[net] react.test.ts
 
-- when we add a data into a place,
-  all the neighboring transitions are checked for preparedness,
-  prepared transitions are executed
-  -- let's not handle non-deterministic for now.
+[net] `transitionEntryFire` -- put input back on file
 
-[net] transitionEntryPutOutputs -- error handling
+[net] `transitionEntryPutOutputs` -- error handling
 
 - task should have more information
 

src/lang/net/index.ts

@@ -1,9 +1,9 @@
 export * from "./Net"
-export * from "./fireTransitionEntry"
-export * from "./createNet"
 export * from "./addPlace"
 export * from "./addTransition"
+export * from "./createNet"
 export * from "./findPlaceEntry"
 export * from "./findPlaceEntryOrFail"
 export * from "./findTransitionEntry"
 export * from "./findTransitionEntryOrFail"
+export * from "./transitionEntryFire"

src/lang/net/transitionEntryFire.ts

@@ -2,7 +2,7 @@ import { TransitionEntry } from "./Net"
 
 export type FiringResult = "Fired" | "NotFired" | "FiringError"
 
-export async function fireTransitionEntry(
+export async function transitionEntryFire(
   transitionEntry: TransitionEntry,
 ): Promise<FiringResult> {
   if (!transitionEntry.task) return "NotFired"

src/lang/react/react.ts

@@ -1,6 +1,37 @@
-import { reactive } from "@vue/runtime-core"
-import { Net } from "../net"
+import { reactive, watch } from "@vue/runtime-core"
+import { Net, PlaceEntry, transitionEntryFire } from "../net"
 
 export function react(net: Net): void {
-  reactive
+  for (const [nodekey, placeEntry] of net.placeEntries) {
+    placeEntry.queue = reactive(placeEntry.queue)
+    reactivelyFireOutputTransitions(placeEntry)
+  }
+
+  initialAction(net)
+}
+
+async function initialAction(net: Net): Promise<void> {
+  for (const [nodeKey, transitionEntry] of net.transitionEntries) {
+    await transitionEntryFire(transitionEntry)
+  }
+}
+
+// When we add a data into a place,
+// try to fire all the neighboring transitions.
+
+function reactivelyFireOutputTransitions(placeEntry: PlaceEntry): void {
+  watch(
+    () => placeEntry.queue,
+    async () => {
+      if (placeEntry.queue.length > 0) {
+        for (const transitionEntry of placeEntry.outputTransitionEntries) {
+          const result = await transitionEntryFire(transitionEntry)
+          if (result === "Fired") return
+        }
+      }
+    },
+    {
+      deep: true,
+    },
+  )
 }