feat: add big example

big/big.pkl

@@ -0,0 +1,72 @@
+import
+  "https://raw.githubusercontent.com/Frnd-me/Cirrina/refs/heads/develop/src/main/resources/pkl/csm/csml.pkl"
+
+sm = new csml.StateMachine {
+  transient {
+    ["target"] = "''"
+    ["pingCounter"] = "0"
+    ["pongCounter"] = "0"
+  }
+  states {
+    ["sendPing"] = new csml.Initial {
+      always {
+        new csml.Transition {
+          to = "waitForPingOrPong"
+          iif = "pingCounter < 100"
+          do {
+            new csml.Eval { expression = "++pingCounter" }
+            new csml.Eval { expression = "target = std:takeRandom(otherBigs)" }
+            new csml.Raise {
+              event = new csml.Global {
+                topic = "ping"
+                data { ["sender"] = "bigId" }
+              }
+              target = "target"
+            }
+          }
+          or = "receiveRemaining"
+        }
+      }
+    }
+    ["waitForPingOrPong"] = new csml.State {
+      on {
+        ["ping"] = new csml.Transition {
+          do {
+            new csml.Raise {
+              event = new csml.Global {
+                topic = "pong"
+                data { ["sender"] = "bigId" }
+              }
+              target = "$sender"
+            }
+          }
+        }
+        ["pong"] = new csml.Transition {
+          iif = "$sender == target"
+          to = "sendPing"
+        }
+      }
+    }
+    ["receiveRemaining"] = new csml.State {
+      entry {
+        new csml.Raise { event = new csml.Global { topic = "donePinging" } }
+      }
+      on {
+        ["ping"] = new csml.Transition {
+          do {
+            new csml.Raise {
+              event = new csml.Global {
+                topic = "pong"
+                data { ["sender"] = "bigId" }
+              }
+            }
+          }
+        }
+        ["shutdown"] = new csml.Transition {
+          to = "done"
+        }
+      }
+    }
+    ["done"] = new csml.Terminal {}
+  }
+}

big/defs.pkl

@@ -0,0 +1 @@
+bigs = List("zero", "one", "two", "three", "four", "five", "six", "seven", "eight", "nine", "ten", "eleven")

big/main.pkl

@@ -0,0 +1,30 @@
+amends
+  "https://raw.githubusercontent.com/Frnd-me/Cirrina/refs/heads/develop/src/main/resources/pkl/csm/csml.pkl"
+
+import "big.pkl"
+import "defs.pkl"
+import "sink.pkl"
+
+version = "4.0.0"
+collaborativeStateMachine {
+  stateMachines {
+    ["sink"] = sink.sm
+    ["big"] = big.sm
+  }
+}
+
+instantiate {
+  ["sink"] = "sink"
+  for (b in defs.bigs) {
+    [b] = "big"
+  }
+}
+instanceData {
+  for (b in defs.bigs) {
+    [b] {
+      ["bigId"] = "'\(b)'"
+      ["otherBigs"] = "['zero', 'one', 'two', 'three', 'four', 'five', 'six', 'seven', 'eight', 'nine', 'ten', 'eleven', ...] - ['\(b)']"
+    }
+  }
+}
+instanceSubscriptions {}

big/services.pkl

@@ -0,0 +1,4 @@
+amends
+  "https://raw.githubusercontent.com/Frnd-me/Cirrina/refs/heads/develop/src/main/resources/pkl/csm/bindings.pkl"
+
+bindings {}

big/sink.pkl

@@ -0,0 +1,34 @@
+import
+  "https://raw.githubusercontent.com/Frnd-me/Cirrina/refs/heads/develop/src/main/resources/pkl/csm/csml.pkl"
+
+sm = new csml.StateMachine {
+  transient {
+    ["doneCounter"] = "0"
+    ["cumulatedPongCounter"] = "0"
+  }
+  states {
+    ["waitingForBigs"] = new csml.Initial {
+      on {
+        ["donePinging"] = new csml.Transition {
+          to = "isFinal"
+          do {
+            new csml.Eval { expression = "++doneCounter" }
+          }
+        }
+      }
+    }
+    ["isFinal"] = new csml.State {
+      always {
+        new csml.Transition {
+          to = "done"
+          iif = "doneCounter == 12"
+          do {
+            new csml.Raise { event = new csml.Global { topic = "shutdown" } }
+          }
+          or = "waitingForBigs"
+        }
+      }
+    }
+    ["done"] = new csml.Terminal {}
+  }
+}

chameneos/chameneos.pkl

@@ -0,0 +1,64 @@
+import
+  "https://raw.githubusercontent.com/CollaborativeStateMachines/Cirrina/refs/heads/develop/src/main/resources/pkl/csm/csml.pkl"
+
+import "defs.pkl"
+
+function complement(myColor: String, otherColor: String): String =
+  defs.colorComplementMap[myColor][otherColor]
+
+function createChameneos(id: Int) = new csml.StateMachine {
+  transient {
+    ["chameneosId"] = "\(id)"
+    ["color"] = "std:takeRandom([1,2,3,...])"
+    ["individualMeetingCounter"] = "0"
+  }
+  states {
+    ["requestingPartner"] = new csml.Initial {
+      entry {
+        new csml.Raise {
+          event = new csml.Global {
+            topic = "requestingPartner"
+            data { ["chameneosId"] = "chameneosId"; ["chameneosColor"] = "color" }
+          }
+        }
+      }
+      on {
+        ["matchMade"] = new csml.Transition {
+          to = "matchFound"
+          iif = "$chameneos == chameneosId"
+        }
+        ["change"] = new csml.Transition {
+          to = "requestingPartner"
+          iif = "$partner == chameneosId"
+          do {
+            new csml.Eval {
+              expression =
+                "color = (function (x,y) { if (x == y) {x} else  {x ^ y} })(color, $color)"
+            }
+            new csml.Eval { expression = "individualMeetingCounter = individualMeetingCounter + 1" }
+          }
+        }
+        ["done"] = new csml.Transition {
+          to = "done"
+        }
+      }
+    }
+    ["matchFound"] = new csml.State {
+      entry {
+        new csml.Eval { expression = "individualMeetingCounter = individualMeetingCounter + 1" }
+        new csml.Raise {
+          event = new csml.Global {
+            topic = "change"
+            data { ["partner"] = "$partner"; ["color"] = "color" }
+          }
+        }
+
+        new csml.Eval {
+          expression = "color = (function (x,y) { if (x == y) {x} else  {x ^ y} })(color, $color)"
+        }
+      }
+      always { new csml.Transition { to = "requestingPartner"; iif = "color < 4"; or = "done" } }
+    }
+    ["done"] = new csml.Terminal {}
+  }
+}

chameneos/defs.pkl

@@ -0,0 +1,8 @@
+chameneos = List(0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11)
+
+colorComplementMap =
+  Map(
+    "RED", Map("RED", "RED", "YELLOW", "BLUE", "BLUE", "YELLOW"),
+    "YELLOW", Map("RED", "BLUE", "YELLOW", "YELLOW", "BLUE", "RED"),
+    "BLUE", Map("RED", "YELLOW", "YELLOW", "RED", "BLUE", "RED")
+  )

chameneos/main.pkl

@@ -0,0 +1,14 @@
+amends
+  "https://raw.githubusercontent.com/CollaborativeStateMachines/Cirrina/refs/heads/develop/src/main/resources/pkl/csm/csml.pkl"
+
+import "chameneos.pkl"
+import "defs.pkl"
+import "mall.pkl"
+
+version = "4.0.0"
+stateMachines {
+  ["mall"] = mall.sm
+  for (c in defs.chameneos) {
+    [c.toString()] = chameneos.createChameneos(c)
+  }
+}

chameneos/mall.pkl

@@ -0,0 +1,53 @@
+import
+  "https://raw.githubusercontent.com/CollaborativeStateMachines/Cirrina/refs/heads/develop/src/main/resources/pkl/csm/csml.pkl"
+
+sm = new csml.StateMachine {
+  transient {
+    ["waitingList"] = "[...]"
+    ["meetingCounter"] = "0"
+  }
+  states {
+    ["waitingForChameneos"] = new csml.Initial {
+      on {
+        ["requestingPartner"] = new csml.Transition {
+          to = "waitingForChameneos"
+          iif = "waitingList.isEmpty() && meetingCounter < 20000"
+          do {
+            new csml.Eval {
+              expression = "waitingList = waitingList + [$chameneosId]"
+            }
+          }
+          or = "scheduleMeeting"
+        }
+      }
+    }
+    ["scheduleMeeting"] = new csml.State {
+      always {
+        new csml.Transition {
+          to = "waitingForChameneos"
+          iif = "!waitingList.isEmpty() && meetingCounter < 20000"
+          do {
+            new csml.Eval { expression = "meetingCounter = meetingCounter + 1" }
+            new csml.Raise {
+              event = new csml.Global {
+                topic = "matchMade"
+                data {
+                  ["chameneos"] = "waitingList.get(0)"
+                  ["partner"] = "$chameneosId"
+                  ["color"] = "$chameneosColor"
+                }
+              }
+            }
+            new csml.Eval { expression = "waitingList = waitingList - [waitingList.get(0)]" }
+          }
+          or = "done"
+        }
+      }
+    }
+    ["done"] = new csml.Terminal {
+      entry {
+        new csml.Raise { event = new csml.Global { topic = "done" } }
+      }
+    }
+  }
+}

chameneos/services.pkl

@@ -0,0 +1,4 @@
+amends
+  "https://raw.githubusercontent.com/CollaborativeStateMachines/Cirrina/refs/heads/develop/src/main/resources/pkl/csm/bindings.pkl"
+
+bindings {}