Code reorganization.

Moving main code to src, keeping modules in modules/

7 files changed, 187 insertions, 0 deletions

diff --git a/example/modules/acme/src/main/java/io/trygvis/acme/AcmeAppsMain.java b/example/modules/acme/src/main/java/io/trygvis/acme/AcmeAppsMain.java
new file mode 100644
index 0000000..c65a3b2
--- /dev/null
+++ b/example/modules/acme/src/main/java/io/trygvis/acme/AcmeAppsMain.java
@@ -0,0 +1,14 @@
+package io.trygvis.acme;
+
+public class AcmeAppsMain {
+//    public static void main(String[] args) throws IOException {
+//        try (var engine = new Engine(
+//                "acme-apps",
+//                new File("acme.yaml"),
+//                new File("acme-apps"),
+//                new String[]{"init", "generate"},
+//                new File[0])) {
+//            engine.io.dump(new File("out", "acme/apps.yaml"), engine.session.getFactHandles());
+//        }
+//    }
+}
diff --git a/example/modules/acme/src/main/java/io/trygvis/acme/VpnMain.java b/example/modules/acme/src/main/java/io/trygvis/acme/VpnMain.java
new file mode 100644
index 0000000..cbf962c
--- /dev/null
+++ b/example/modules/acme/src/main/java/io/trygvis/acme/VpnMain.java
@@ -0,0 +1,21 @@
+package io.trygvis.acme;
+
+public class VpnMain {
+//    public static void main(String[] args) throws IOException {
+//        try (var engine = new Engine(
+//                "acme-wireguard",
+//                new File("acme.yaml"),
+//                new File("acme-wireguard"),
+//                new String[]{"init", "generate"},
+//                new File[0])) {
+//            var outputFile = new File("out", "acme/wireguard.yaml");
+//            engine.io.dump(outputFile, engine.session.getFactHandles(), (Object o) ->
+//                    o.getClass().getName().contains("Wg")
+//                            || o instanceof Machine
+//                            || o instanceof DnsEntry
+//                            || o instanceof Ipv4Cidr
+//                            || o instanceof Ipv4Address
+//            );
+//        }
+//    }
+}
diff --git a/example/modules/acme/src/main/java/io/trygvis/acme/apps/AcmeMyApp.java b/example/modules/acme/src/main/java/io/trygvis/acme/apps/AcmeMyApp.java
new file mode 100644
index 0000000..9371af2
--- /dev/null
+++ b/example/modules/acme/src/main/java/io/trygvis/acme/apps/AcmeMyApp.java
@@ -0,0 +1,6 @@
+package io.trygvis.acme.apps;
+
+public class AcmeMyApp {
+    public String environment;
+    public String dockerTag;
+}
diff --git a/example/modules/acme/src/main/java/io/trygvis/acme/apps/AcmeOps.java b/example/modules/acme/src/main/java/io/trygvis/acme/apps/AcmeOps.java
new file mode 100644
index 0000000..be9d82b
--- /dev/null
+++ b/example/modules/acme/src/main/java/io/trygvis/acme/apps/AcmeOps.java
@@ -0,0 +1,4 @@
+package io.trygvis.acme.apps;
+
+public class AcmeOps {
+}
diff --git a/example/modules/acme/src/main/resources/META-INF/kmodule.xml b/example/modules/acme/src/main/resources/META-INF/kmodule.xml
new file mode 100644
index 0000000..da435d6
--- /dev/null
+++ b/example/modules/acme/src/main/resources/META-INF/kmodule.xml
@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<kmodule xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xmlns="http://www.drools.org/xsd/kmodule"
+         xsi:schemaLocation="http://www.drools.org/xsd/kmodule https://www.drools.org/xsd/kmodule_7_1.xsd">
+
+  <kbase name="acme-apps" packages="io.trygvis.acme.apps" includes="dba,engine,machine,terraform, acme-shared">
+    <ksession name="acme-apps" default="true"/>
+  </kbase>
+
+  <kbase name="acme-wireguard" packages="io.trygvis.acme.wireguard" includes="engine,wireguard, acme-shared">
+    <ksession name="acme-wireguard" default="true"/>
+  </kbase>
+
+  <kbase name="acme-shared" packages="io.trygvis.acme">
+    <ksession name="acme-shared" default="true"/>
+  </kbase>
+</kmodule>
diff --git a/example/modules/acme/src/main/resources/io/trygvis/acme/acme.drl b/example/modules/acme/src/main/resources/io/trygvis/acme/acme.drl
new file mode 100644
index 0000000..6a2f33b
--- /dev/null
+++ b/example/modules/acme/src/main/resources/io/trygvis/acme/acme.drl
@@ -0,0 +1,81 @@
+package io.trygvis.acme;
+
+import io.trygvis.rules.machine.Machine;
+import io.trygvis.rules.dba.Cluster;
+import io.trygvis.rules.dba.Container
+import io.trygvis.rules.terraform.TerraformResource;
+import io.trygvis.rules.terraform.TerraformMain
+import io.trygvis.rules.terraform.TerraformProvider;
+
+dialect "mvel"
+
+declare AcmeServer
+    name    : String
+    machine : Machine
+end
+
+rule "Create Acme servers"
+when
+    $m : Machine(name.startsWith("acme-"))
+    not(AcmeServer(name == $m.name))
+then
+    var s = new AcmeServer();
+    s.name = $m.name;
+    s.machine = $m;
+    insert(s);
+end
+
+rule "Set public domain for ACME servers"
+when
+    $m : Machine(fqdn == null)
+    $s : AcmeServer(machine == $m)
+then
+    var fqdn = "%s.machine.acme.com".formatted($m.name);
+    modify ($m) {
+        fqdn = fqdn
+    }
+end
+
+rule "Make Terraform module for machines"
+when
+    not TerraformMain(module == "terraform")
+then
+    var module = new TerraformMain("terraform");
+
+    var scaleway = new TerraformProvider("scaleway", "2.0.0-rc1");
+    module.getProviders().put("scaleway", scaleway);
+
+    insert(module)
+end
+
+rule "Make Scaleway Terraform resources for Machine"
+when
+    $m : Machine()
+    $s : AcmeServer(machine == $m)
+then
+    var ip = new TerraformResource("terraform/" + $m.name + "-ip.tf", "scaleway_instance_ip", $m.name);
+    var instance = new TerraformResource("terraform/" + $m.name + "-instance.tf", "scaleway_server_instance", $m.name)
+        .set("name", "acme-1")
+        .set("type", "DEV1-S")
+        .set("image", "b3042271-d2b1-4f87-b407-aedd3bbd1663")
+        .setExpression("ip_id", ip.name + ".ip")
+        .set("enable_dynamic_ip", false)
+        .set("enable_ipv6",  true);
+
+
+    var rev = new TerraformResource("terraform/" + $m.name + "-ip.tf", "scaleway_instance_reverse_dns", $m.name)
+        .set("reverse", $m.fqdn + ".")
+        .setExpression("ip_id", ip.name + ".id");
+    var dns = new TerraformResource("terraform/" + $m.name + "-dns.tf", "google_dns_record_set", $m.name)
+        .set("name", $m.fqdn)
+        .setExpression("managed_zone", "var.dns_zone")
+        .set("type", "A")
+        .set("ttl", 300)
+        .array("rrdatas")
+        .addExpression(ip.name + ".id");
+
+    insert(instance)
+    insert(ip)
+    insert(rev)
+    insert(dns)
+end
diff --git a/example/modules/acme/src/main/resources/io/trygvis/acme/apps/apps.drl b/example/modules/acme/src/main/resources/io/trygvis/acme/apps/apps.drl
new file mode 100644
index 0000000..670079f
--- /dev/null
+++ b/example/modules/acme/src/main/resources/io/trygvis/acme/apps/apps.drl
@@ -0,0 +1,44 @@
+package io.trygvis.acme.apps
+
+import io.trygvis.rules.machine.Machine;
+import io.trygvis.rules.dba.Cluster;
+import io.trygvis.rules.dba.Container
+import io.trygvis.rules.dns.DnsZone;
+import io.trygvis.rules.machine.Machine
+import io.trygvis.rules.machine.MachineSpecification
+import io.trygvis.rules.dba.Cluster
+import io.trygvis.rules.dba.Container
+
+dialect "mvel"
+
+rule "Ops"
+when
+    $ops: AcmeOps()
+then
+    var cluster = new Cluster("acme-ops");
+    insert(cluster);
+    insert(new Container(cluster, "pdb", "ops", "postgresql", "11", null));
+    insert(new Container(cluster, "n8n", "ops", "n8n", "0.84.1", null));
+end
+
+rule "MyApp"
+when
+    $app: AcmeMyApp()
+then
+    var zone = new DnsZone($app.environment + ".acme.com");
+    insert(zone)
+
+    var cluster = new Cluster("acme-myapp-" + $app.environment);
+    insert(cluster);
+
+    var app = $app.environment + "-app";
+    var db = $app.environment + "-db";
+
+    var tag = $app.dockerTag;
+    insert(new Container(cluster, "statera", app, "statera", tag, new MachineSpecification(200, 1000)));
+    insert(new Container(cluster, "statera-console", app, "statera-console", tag, new MachineSpecification(100, 50)));
+    insert(new Container(cluster, "4tune-web", app, "4tune-web", tag, new MachineSpecification(100, 50)));
+    insert(new Container(cluster, "4tune-api", app, "4tune-api", tag, new MachineSpecification(200, 200)));
+    insert(new Container(cluster, "pdb", db, "postgresql", "13", new MachineSpecification(500, 500)));
+    insert(new Container(cluster, "mdb", db, "mongodb", "3.2", new MachineSpecification(500, 200)));
+end