Database triggers

backend/.vscode/settings.json

@@ -1,5 +1,8 @@
 {
   "python.analysis.typeCheckingMode": "basic",
   "rust-analyzer.linkedProjects": ["./windmill-common/Cargo.toml"],
-  "rust-analyzer.showUnlinkedFileNotification": false
+  "rust-analyzer.showUnlinkedFileNotification": false,
+  "conventionalCommits.scopes": [
+    "restructring triggers, decoding trigger message on work"
+  ]
 }

backend/Cargo.toml

@@ -112,6 +112,8 @@ serde.workspace = true
 deno_core = { workspace = true, optional = true }
 object_store = { workspace = true, optional = true }
 quote.workspace = true
+memchr.workspace = true
+
 
 [target.'cfg(not(target_env = "msvc"))'.dependencies]
 tikv-jemallocator = { optional = true, workspace = true }
@@ -152,6 +154,7 @@ windmill-parser-graphql = { path = "./parsers/windmill-parser-graphql" }
 windmill-parser-php = { path = "./parsers/windmill-parser-php" }
 windmill-api-client = { path = "./windmill-api-client" }
 
+memchr = "2.7.4"
 axum = { version = "^0.7", features = ["multipart"] }
 headers = "^0"
 hyper = { version = "^1", features = ["full"] }
@@ -258,6 +261,7 @@ wasm-bindgen-test = "0.3.42"
 convert_case = "0.6.0"
 getrandom = "0.2"
 tokio-postgres = {version = "^0.7", features = ["array-impls", "with-serde_json-1", "with-chrono-0_4", "with-uuid-1", "with-bit-vec-0_6"]}
+rust-postgres = { package = "tokio-postgres", git = "https://github.com/imor/rust-postgres", rev = "20265ef38e32a06f76b6f9b678e2077fc2211f6b"}
 bit-vec = "=0.6.3"
 mappable-rc = "^0"
 mysql_async = { version = "*", default-features = false, features = ["minimal", "default", "native-tls-tls"]}
@@ -285,7 +289,7 @@ openssl = "=0.10"
 mail-parser = "^0"
 matchit = "=0.7.3"
 rdkafka = { version = "0.36.2", features = ["cmake-build", "ssl-vendored"] }
-
+pg_escape = "0.1.1"
 datafusion = "39.0.0"
 object_store = { version = "0.10.0", features = ["aws", "azure"] }
 openidconnect = { version = "4.0.0-rc.1" }
@@ -307,6 +311,7 @@ opentelemetry-semantic-conventions = { version = "*", features = ["semconv_exper
 bollard = "0.18.1"
 
 tonic = { version = "^0", features = ["tls-native-roots"] }
+byteorder = "1.5.0"
 
 tikv-jemallocator = { version = "0.5" }
 tikv-jemalloc-sys  = { version = "^0.5" }

backend/migrations/20241123152203_database_triggers.down.sql

@@ -0,0 +1,3 @@
+-- Add down migration script here
+DROP TABLE IF EXISTS database_trigger;
+DROP TYPE IF EXISTS transaction;

backend/migrations/20241123152203_database_triggers.up.sql

@@ -0,0 +1,21 @@
+-- Add up migration script here
+CREATE TYPE transaction AS ENUM ('Insert', 'Update', 'Delete');
+CREATE TABLE database_trigger(
+    path VARCHAR(255) NOT NULL,
+    script_path VARCHAR(255) NOT NULL,
+    is_flow BOOLEAN NOT NULL,
+    workspace_id VARCHAR(50) NOT NULL,
+    edited_by VARCHAR(50) NOT NULL,
+    email VARCHAR(255) NOT NULL,
+    edited_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
+    extra_perms JSONB NULL,
+    database_resource_path VARCHAR(255) NOT NULL,
+    error TEXT NULL,
+    server_id VARCHAR(50) NULL,
+    last_server_ping TIMESTAMPTZ NULL,
+    replication_slot_name VARCHAR(255) NOT NULL,
+    publication_name VARCHAR(255) NOT NULL,
+    last_lsn bigint NOT NULL DEFAULT 0,
+    enabled BOOLEAN NOT NULL,
+    CONSTRAINT PK_database_trigger PRIMARY KEY (path,workspace_id)
+);

backend/windmill-api/Cargo.toml

@@ -104,8 +104,12 @@ matchit = { workspace = true, optional = true }
 tokio-tungstenite = { workspace = true, optional = true}
 rdkafka = { workspace = true, optional = true }
 const_format.workspace = true
-
+rust-postgres.workspace = true
 pin-project.workspace = true
 http.workspace = true
 async-stream.workspace = true
 ulid.workspace = true
+pg_escape.workspace = true
+byteorder.workspace = true
+memchr.workspace = true
+thiserror.workspace = true