From 866eafabd7398fd1485e7aa285345a7dcea480d0 Mon Sep 17 00:00:00 2001
From: Trygve Laugstøl <trygvis@inamo.no>
Date: Wed, 30 Dec 2020 20:48:51 +0100
Subject: Moving everything under durable_rules-test.

---
 durable_rules-test/py/acme/rai/terraform.py | 41 +++++++++++++++++++++++++++++
 1 file changed, 41 insertions(+)
 create mode 100644 durable_rules-test/py/acme/rai/terraform.py

(limited to 'durable_rules-test/py/acme/rai/terraform.py')

diff --git a/durable_rules-test/py/acme/rai/terraform.py b/durable_rules-test/py/acme/rai/terraform.py
new file mode 100644
index 0000000..6feedd1
--- /dev/null
+++ b/durable_rules-test/py/acme/rai/terraform.py
@@ -0,0 +1,41 @@
+from durable.lang import *
+
+class Terraform:
+    @staticmethod
+    def recordSetForMachine(machineKey: str, terraformId: str, fqdn: str):
+        return {"type": "terraform-record-set",
+            "key": machineKey,
+            "terraformId": terraformId,
+            "fqdn": fqdn,
+            "rrType": "A",
+            "rrData": f"scaleway_instance_ip.{machineKey}.address",
+        }
+
+    @staticmethod
+    def machine(key: str):
+        return {"type": "terraform-machine",
+            "key": key,
+        }
+
+    @staticmethod
+    def declare_rules():
+        @when_all(
+            c.dns << (m.type == "dns-entry"),
+            c.machine << ((m.type == "terraform-machine") & (m.key == c.dns.key)),
+        )
+        def onDnsEntry(c):
+            terraformId = c.dns.fqdn.replace(".", "_")
+            c.assert_fact(Terraform.recordSetForMachine(c.machine.key, terraformId, c.dns.fqdn))
+
+        @when_all((m.type == "terraform-record-set"))
+        def defaultTerraformRecordSet(c):
+            pass
+
+        @when_all((m.type == "machine"))
+        def onDnsEntry(c):
+            print(f"matched machine: {c.m}")
+            c.assert_fact(Terraform.machine(c.m.key))
+
+        @when_all((m.type == "terraform-machine"))
+        def defaultTerraformMachine(c):
+            print(f"matched terraform-machine: {c.m}")
-- 
cgit v1.2.3