From bc2ce410ddaee9d012093eb6696859ed2ca403cc Mon Sep 17 00:00:00 2001 From: Ruben Fiszel Date: Sun, 8 Feb 2026 10:11:53 +0100 Subject: [PATCH] test: add integration tests for all feasible language runtimes in CI (#7849) * test: add integration tests for all feasible language runtimes in CI Add integration tests and CI setup for languages that were previously untested. Each test runs a simple "hello world" job through the full worker pipeline to verify end-to-end execution. New language tests added to worker.rs: - Nativets (4 tests): basic string, numeric args, object return, datetime - Bunnative: TypeScript execution via Bun native runtime - CSharp: .NET compilation and execution (feature-gated) - PHP: PHP script execution (feature-gated) - Ruby: Ruby script execution (feature-gated) - MySQL: SQL query via async MySQL client (feature-gated) - PowerShell: pwsh script execution - PostgreSQL: SQL query against test database CI changes (backend-test.yml): - Add MySQL 8.0 service container - Add setup-php (8.3 + composer), setup-ruby (3.3), pwsh install - Enable feature flags: csharp, php, ruby, mysql - Pass language binary paths: PHP_PATH, COMPOSER_PATH, RUBY_PATH, BUNDLE_PATH, GEM_PATH, POWERSHELL_PATH, DOTNET_PATH - Uncomment and modernize CSharp test (was commented out) - Increase test timeout 16m -> 20m for additional runtimes Co-Authored-By: Claude Opus 4.6 * sqlx --------- Co-authored-by: Claude Opus 4.6 --- .github/workflows/backend-test.yml | 28 +- ...299fac14562ee8595c792f3c30d042fa2d3eb.json | 22 ++ ...1f7f387f5055c47f493271d26731336257384.json | 10 +- ...32781327f2b10a6dc4c6c82414ef0a610a10c.json | 16 ++ ...bc7e9ee85289ff5c52af43166928337c257e7.json | 3 +- ...f42617f0727eea4228364f01c3b9c7056da3e.json | 22 ++ ...7b23d6dcf2e5364852a5e85b3c41c417bace2.json | 41 +++ ...9e8c0bb132b70668301b535872d1632753e30.json | 3 +- ...66f38ffe2f3a0958adea53e67757c6ac463ec.json | 40 +++ ...243ad2e0aef485a780daea5d76b0be2bb2ea2.json | 3 +- ...71701f17a33b708b334d909563c9a0dcc9c23.json | 22 ++ ...849ec2372ac6a21bb2556d17a96dc72ea4980.json | 22 ++ ...fbe7db4887c4ac5295052c796bd78a7edc50b.json | 40 +++ ...f518b42f4cdb33e034441015494bd26c172d2.json | 3 +- ...9bd647f9016cec246117a8fa1bd76c44db6a3.json | 29 ++ ...64e7e5a857b39584a4bd5b62fc4703215cfb8.json | 23 ++ ...f8baf44d26dc97187ec08946a665d81ed89dd.json | 22 ++ ...0307542c6eabbe264071a216683d18839e68c.json | 37 +++ ...9ad8a15c443801eba563a7c069bcac2bd21aa.json | 22 ++ ...bd0de7e03c539ee046955543d9693551246f7.json | 14 + ...cad6d8995242dc20a4e14c1a8fae4fc6a9fd2.json | 3 +- ...8014088225ca2bbf1835b6fb5e5b78e5647c8.json | 23 ++ ...2f7175cc6f2e02d9c565bb5159cae3e0b6835.json | 49 ++++ ...08532a1020cabaf5e22325a1e05f0491d785c.json | 62 ++++ ...e35adf640d44d607e62a1fb296e38ac3fdd36.json | 6 +- ...d3e809a5026de15540a3347c464a03c079257.json | 62 ++++ ...a7dedf30e8c98a87e861886300afbc95af6cf.json | 22 ++ ...2692450ee231488d9a55ca59ff53a6f674626.json | 20 ++ ...64472e2c2a781fbb6366d998a0f1ca22fcdf2.json | 66 +++++ ...153c43903f929ae5d62fbba12610f89c36d55.json | 2 +- ...c6c70f7f3958564a79bb0c6b3863b1ebb0cbf.json | 3 +- ...59ade1a05164beabd1c1284b6d656c8c2e114.json | 23 ++ ...06005e1575ad43ea7539c186730ef8ac49e01.json | 23 ++ ...966baf7fd7d7c74a7a9d2ae08e587967575d4.json | 23 ++ ...e106c8c24445130880be87c12a764e7921bff.json | 74 +++++ ...1a803e1bced2f8e1a12f8933b7598ee85a147.json | 3 +- ...990fa3a704afe3eec523f4e203f7f6e247261.json | 54 ++++ ...4f412c57af931f80621aee5012e9cb3535626.json | 45 +++ ...8d92a983470adcd3cc850734960c905e61e83.json | 41 +++ ...967f7b94f9d9db7be628f9cb411d789085711.json | 54 ++++ ...ca846dd5e7fe7ceb1aa8b3fcd26a2bd30eb2c.json | 3 +- ...5a871f866a8d21961fac8a003bc40c406ee79.json | 22 ++ ...9054dd8c30c16b4657e73cdb0d7c7f1cb3b6d.json | 32 +++ ...91ce7c9b1261b52d10f4a7f3273fed3c916df.json | 52 ++++ ...a22e4276c1da653475628889ce17dc904fbaa.json | 3 +- ...6eb9016207975af1e37042d81df8cb6ae2c53.json | 40 +++ ...506bf08c28efe82b68b3d44bafbd3d0e91c29.json | 3 +- ...dc3e2d2b1bf4d7884720fafcbb531790f0c64.json | 15 + ...d2393e297043e4e58555d872b5c4dd89c196a.json | 38 +++ ...e6da81fc631cc6ac43576f8a18afedad4d4a4.json | 22 ++ ...3a960b89e02ec40b292f3b5198baf2a1d3dbf.json | 3 +- ...95a7e6e17b49e4315a8ed0e36bfee16f49929.json | 23 ++ ...fbafe5dc3cdecc17a3d5a7476b160c1b6e7e1.json | 3 +- ...2ede46b4471e21b11f607573a844013911abe.json | 3 +- ...e33244fe8ab9a803248fc23f334034d24aad4.json | 3 +- ...58fce213ef8976e3ffdc3b4bd88e92799e0af.json | 52 ++++ ...f9c46d11f8891807c2dac10b8b7edf72a197e.json | 22 ++ ...bb6a8f961c119516e4c33dc928cd3b4f4edbc.json | 3 +- ...83ff3b4c0f0314fdacc417d841e0c88a1f3d1.json | 23 ++ ...9e637e9e156cd85b69126c87dfff89a47711d.json | 3 +- ...9746147aa9b8d0a81642a7b7cb4738a0cad66.json | 3 +- ...bc890d887649eaf72656a8814b0c167645044.json | 46 +++ ...d434f860922fbc021185beffb9827647feb8e.json | 3 +- ...b7f5b1f354b6bb0a78d007114fed084cfe292.json | 21 ++ ...13f1f882b695f896f94e5cf91d205633355a1.json | 3 +- ...e1ea2fe96a1b94f5a92953fb1c1642d15c016.json | 3 +- ...1a8a9cc35f362197c0766a5787436af141106.json | 3 +- ...a7be2968d982ae84fe3294a6d78914afe3ecc.json | 52 ++++ ...7c08d8ed4984409b669162f0a1fc1aa48e188.json | 15 + ...9352d4d1e3cb3a8a08f1c9c03055a1cab1235.json | 3 +- ...29714291ce0901b757e8c799c7a6d1021c679.json | 29 ++ ...f03f72ef81db302d727e18e63a307ac902022.json | 3 +- ...c35c7342ac9a814c73f6290e1d6ebd3a55423.json | 3 +- ...f1cd0bbecdf51c18b4fc19ab3ef303331d51d.json | 47 +++ ...50d6a6935420fbedc83aa3ad1e9be7465c8dd.json | 3 +- backend/tests/worker.rs | 269 +++++++++++++++--- 76 files changed, 1877 insertions(+), 77 deletions(-) create mode 100644 backend/.sqlx/query-0300afc35a880eef163dfdfd9d5299fac14562ee8595c792f3c30d042fa2d3eb.json create mode 100644 backend/.sqlx/query-079b7f09da952cee6fa594c91a932781327f2b10a6dc4c6c82414ef0a610a10c.json create mode 100644 backend/.sqlx/query-0b238fcc4737fa31312bdd2baa7f42617f0727eea4228364f01c3b9c7056da3e.json create mode 100644 backend/.sqlx/query-0f7e01b613a94b29784aae6d7b17b23d6dcf2e5364852a5e85b3c41c417bace2.json create mode 100644 backend/.sqlx/query-16d438374b03a9c515f4c2d638366f38ffe2f3a0958adea53e67757c6ac463ec.json create mode 100644 backend/.sqlx/query-1cad2ebfbdc46f9c0d93329897a71701f17a33b708b334d909563c9a0dcc9c23.json create mode 100644 backend/.sqlx/query-1d4bb4f53574ef95ef1016b760f849ec2372ac6a21bb2556d17a96dc72ea4980.json create mode 100644 backend/.sqlx/query-22e0e8a1aa48f8b21763452bd36fbe7db4887c4ac5295052c796bd78a7edc50b.json create mode 100644 backend/.sqlx/query-2f7ff8bf66826101546e11066039bd647f9016cec246117a8fa1bd76c44db6a3.json create mode 100644 backend/.sqlx/query-30fc636d349e046e4dce61a1db964e7e5a857b39584a4bd5b62fc4703215cfb8.json create mode 100644 backend/.sqlx/query-3d198a9319d8872a04f8ccdc129f8baf44d26dc97187ec08946a665d81ed89dd.json create mode 100644 backend/.sqlx/query-4012a31045d4ff7665913be12190307542c6eabbe264071a216683d18839e68c.json create mode 100644 backend/.sqlx/query-410e3c47a8a6144228d2200e6859ad8a15c443801eba563a7c069bcac2bd21aa.json create mode 100644 backend/.sqlx/query-41e557e1b63b13c9fcc195901c0bd0de7e03c539ee046955543d9693551246f7.json create mode 100644 backend/.sqlx/query-42c7f52fe822124bf22b4c300ee8014088225ca2bbf1835b6fb5e5b78e5647c8.json create mode 100644 backend/.sqlx/query-45024b932383199974616bba1fc2f7175cc6f2e02d9c565bb5159cae3e0b6835.json create mode 100644 backend/.sqlx/query-4d272cf4a77aab7007a5b35589e08532a1020cabaf5e22325a1e05f0491d785c.json create mode 100644 backend/.sqlx/query-4f8bc8acc174e33a45eab9f046cd3e809a5026de15540a3347c464a03c079257.json create mode 100644 backend/.sqlx/query-572b712b9ff0231ca0f680eb3d6a7dedf30e8c98a87e861886300afbc95af6cf.json create mode 100644 backend/.sqlx/query-57b7236cae0b6a1940f4c2d4b202692450ee231488d9a55ca59ff53a6f674626.json create mode 100644 backend/.sqlx/query-57eca702e951f5303a74643c7ba64472e2c2a781fbb6366d998a0f1ca22fcdf2.json create mode 100644 backend/.sqlx/query-5eaa109879b27bb2eaa738fb3f359ade1a05164beabd1c1284b6d656c8c2e114.json create mode 100644 backend/.sqlx/query-5f1df080a871127172271a72ef006005e1575ad43ea7539c186730ef8ac49e01.json create mode 100644 backend/.sqlx/query-624162e98be630ccc363f10bb0f966baf7fd7d7c74a7a9d2ae08e587967575d4.json create mode 100644 backend/.sqlx/query-653e7a8509194f60e442848346ee106c8c24445130880be87c12a764e7921bff.json create mode 100644 backend/.sqlx/query-6afa076744233fc5e92188ff978990fa3a704afe3eec523f4e203f7f6e247261.json create mode 100644 backend/.sqlx/query-7065f23d04e26831664048f2cfc4f412c57af931f80621aee5012e9cb3535626.json create mode 100644 backend/.sqlx/query-73fdd01bad58b8be1a52f89faef8d92a983470adcd3cc850734960c905e61e83.json create mode 100644 backend/.sqlx/query-74c11f5a0315424574fe3e7429f967f7b94f9d9db7be628f9cb411d789085711.json create mode 100644 backend/.sqlx/query-75ce9753a8acc8eccb3f2e0baaa5a871f866a8d21961fac8a003bc40c406ee79.json create mode 100644 backend/.sqlx/query-7c1ae9cac13d1387cfa94149f039054dd8c30c16b4657e73cdb0d7c7f1cb3b6d.json create mode 100644 backend/.sqlx/query-7e3bfb33fb771aec39b43a7550091ce7c9b1261b52d10f4a7f3273fed3c916df.json create mode 100644 backend/.sqlx/query-836bac47d89113d90bd03a471446eb9016207975af1e37042d81df8cb6ae2c53.json create mode 100644 backend/.sqlx/query-9238c54d7cf53e2812936d36d98dc3e2d2b1bf4d7884720fafcbb531790f0c64.json create mode 100644 backend/.sqlx/query-940b6d78bab940a37a42492f030d2393e297043e4e58555d872b5c4dd89c196a.json create mode 100644 backend/.sqlx/query-97c60a4193a75b611db41543e7fe6da81fc631cc6ac43576f8a18afedad4d4a4.json create mode 100644 backend/.sqlx/query-9c7580fb38351518cb57ed6207495a7e6e17b49e4315a8ed0e36bfee16f49929.json create mode 100644 backend/.sqlx/query-a9ce39c0327607a1523424c838858fce213ef8976e3ffdc3b4bd88e92799e0af.json create mode 100644 backend/.sqlx/query-afed809b7dc7dc3c6c5b21c9899f9c46d11f8891807c2dac10b8b7edf72a197e.json create mode 100644 backend/.sqlx/query-b3b161d077e723ce19bdcc0db0683ff3b4c0f0314fdacc417d841e0c88a1f3d1.json create mode 100644 backend/.sqlx/query-c239d9160efe295ee6e64759dcbbc890d887649eaf72656a8814b0c167645044.json create mode 100644 backend/.sqlx/query-c659cfe81441bb1b62a9f23f5d9b7f5b1f354b6bb0a78d007114fed084cfe292.json create mode 100644 backend/.sqlx/query-d618ff98a2c7aceb6820007411ba7be2968d982ae84fe3294a6d78914afe3ecc.json create mode 100644 backend/.sqlx/query-dc9a906d6c6156a84fccf4e3a2a7c08d8ed4984409b669162f0a1fc1aa48e188.json create mode 100644 backend/.sqlx/query-e5d1963829e06bfcfe413a583d229714291ce0901b757e8c799c7a6d1021c679.json create mode 100644 backend/.sqlx/query-ecb51b6bd85218116e4d02bc92cf1cd0bbecdf51c18b4fc19ab3ef303331d51d.json diff --git a/.github/workflows/backend-test.yml b/.github/workflows/backend-test.yml index 1f51ee2fa4..6eda2a1213 100644 --- a/.github/workflows/backend-test.yml +++ b/.github/workflows/backend-test.yml @@ -31,6 +31,16 @@ jobs: options: >- --health-cmd pg_isready --health-interval 10s --health-timeout 5s --health-retries 5 + mysql: + image: mysql:8.0 + ports: + - 3306:3306 + env: + MYSQL_ROOT_PASSWORD: changeme + MYSQL_DATABASE: windmill_test + options: >- + --health-cmd "mysqladmin ping -h localhost" --health-interval 10s + --health-timeout 5s --health-retries 5 steps: - uses: actions/checkout@v4 - uses: actions/setup-dotnet@v4 @@ -51,6 +61,18 @@ jobs: - uses: astral-sh/setup-uv@v6.2.1 with: version: "0.9.24" + - uses: shivammathur/setup-php@v2 + with: + php-version: '8.3' + tools: composer + - uses: ruby/setup-ruby@v1 + with: + ruby-version: '3.3' + bundler-cache: false + - name: Install PowerShell + run: | + sudo apt-get update && sudo apt-get install -y powershell + working-directory: / - uses: actions-rust-lang/setup-rust-toolchain@v1 with: cache-workspaces: backend @@ -183,7 +205,7 @@ jobs: restore-keys: | ${{ runner.os }}-duckdb-ffi- - name: cargo test - timeout-minutes: 16 + timeout-minutes: 20 env: SQLX_OFFLINE: true DATABASE_URL: postgres://postgres:changeme@localhost:5432/windmill @@ -196,6 +218,6 @@ jobs: WMDEBUG_FORCE_NO_LEGACY_DEBOUNCING_COMPAT: 1 TEST_NPM_REGISTRY: "http://localhost:4873/:_authToken=${{ env.NPM_TOKEN }}" run: | - deno --version && bun -v && node --version && go version && python3 --version + deno --version && bun -v && node --version && go version && python3 --version && php --version && ruby --version && pwsh --version && dotnet --version cd windmill-duckdb-ffi-internal && ./build_dev.sh && cd .. - DENO_PATH=$(which deno) BUN_PATH=$(which bun) NODE_BIN_PATH=$(which node) GO_PATH=$(which go) UV_PATH=$(which uv) cargo test --features enterprise,deno_core,duckdb,license,python,rust,scoped_cache,parquet,private,private_registry_test --all -- --nocapture + DENO_PATH=$(which deno) BUN_PATH=$(which bun) NODE_BIN_PATH=$(which node) GO_PATH=$(which go) UV_PATH=$(which uv) PHP_PATH=$(which php) COMPOSER_PATH=$(which composer) RUBY_PATH=$(which ruby) BUNDLE_PATH=$(which bundle) GEM_PATH=$(which gem) POWERSHELL_PATH=$(which pwsh) DOTNET_PATH=$(which dotnet) cargo test --features enterprise,deno_core,duckdb,license,python,rust,scoped_cache,parquet,private,private_registry_test,csharp,php,ruby,mysql --all -- --nocapture diff --git a/backend/.sqlx/query-0300afc35a880eef163dfdfd9d5299fac14562ee8595c792f3c30d042fa2d3eb.json b/backend/.sqlx/query-0300afc35a880eef163dfdfd9d5299fac14562ee8595c792f3c30d042fa2d3eb.json new file mode 100644 index 0000000000..cf0856b775 --- /dev/null +++ b/backend/.sqlx/query-0300afc35a880eef163dfdfd9d5299fac14562ee8595c792f3c30d042fa2d3eb.json @@ -0,0 +1,22 @@ +{ + "db_name": "PostgreSQL", + "query": "\n INSERT INTO postgres_trigger (\n path, script_path, is_flow, workspace_id, edited_by, email,\n postgres_resource_path, replication_slot_name, publication_name\n )\n VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9)\n ", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Varchar", + "Varchar", + "Bool", + "Varchar", + "Varchar", + "Varchar", + "Varchar", + "Varchar", + "Varchar" + ] + }, + "nullable": [] + }, + "hash": "0300afc35a880eef163dfdfd9d5299fac14562ee8595c792f3c30d042fa2d3eb" +} diff --git a/backend/.sqlx/query-07168aaf14cb6beff0ad4274b441f7f387f5055c47f493271d26731336257384.json b/backend/.sqlx/query-07168aaf14cb6beff0ad4274b441f7f387f5055c47f493271d26731336257384.json index e7ed0aee65..d29a18c691 100644 --- a/backend/.sqlx/query-07168aaf14cb6beff0ad4274b441f7f387f5055c47f493271d26731336257384.json +++ b/backend/.sqlx/query-07168aaf14cb6beff0ad4274b441f7f387f5055c47f493271d26731336257384.json @@ -46,11 +46,11 @@ ] }, "nullable": [ - false, - false, - false, - false, - false, + true, + true, + true, + true, + true, true, true ] diff --git a/backend/.sqlx/query-079b7f09da952cee6fa594c91a932781327f2b10a6dc4c6c82414ef0a610a10c.json b/backend/.sqlx/query-079b7f09da952cee6fa594c91a932781327f2b10a6dc4c6c82414ef0a610a10c.json new file mode 100644 index 0000000000..a6f9a5468a --- /dev/null +++ b/backend/.sqlx/query-079b7f09da952cee6fa594c91a932781327f2b10a6dc4c6c82414ef0a610a10c.json @@ -0,0 +1,16 @@ +{ + "db_name": "PostgreSQL", + "query": "UPDATE http_trigger SET script_path = $1 WHERE workspace_id = $2 AND path = $3", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Varchar", + "Text", + "Text" + ] + }, + "nullable": [] + }, + "hash": "079b7f09da952cee6fa594c91a932781327f2b10a6dc4c6c82414ef0a610a10c" +} diff --git a/backend/.sqlx/query-089d7bc7acdbb97cf477159e111bc7e9ee85289ff5c52af43166928337c257e7.json b/backend/.sqlx/query-089d7bc7acdbb97cf477159e111bc7e9ee85289ff5c52af43166928337c257e7.json index a032a87239..b925141065 100644 --- a/backend/.sqlx/query-089d7bc7acdbb97cf477159e111bc7e9ee85289ff5c52af43166928337c257e7.json +++ b/backend/.sqlx/query-089d7bc7acdbb97cf477159e111bc7e9ee85289ff5c52af43166928337c257e7.json @@ -30,7 +30,8 @@ "sqs", "gcp", "mqtt", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-0b238fcc4737fa31312bdd2baa7f42617f0727eea4228364f01c3b9c7056da3e.json b/backend/.sqlx/query-0b238fcc4737fa31312bdd2baa7f42617f0727eea4228364f01c3b9c7056da3e.json new file mode 100644 index 0000000000..66b26b7e76 --- /dev/null +++ b/backend/.sqlx/query-0b238fcc4737fa31312bdd2baa7f42617f0727eea4228364f01c3b9c7056da3e.json @@ -0,0 +1,22 @@ +{ + "db_name": "PostgreSQL", + "query": "SELECT COUNT(*) FROM websocket_trigger WHERE workspace_id = $1 AND mode = 'disabled'::trigger_mode", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "count", + "type_info": "Int8" + } + ], + "parameters": { + "Left": [ + "Text" + ] + }, + "nullable": [ + null + ] + }, + "hash": "0b238fcc4737fa31312bdd2baa7f42617f0727eea4228364f01c3b9c7056da3e" +} diff --git a/backend/.sqlx/query-0f7e01b613a94b29784aae6d7b17b23d6dcf2e5364852a5e85b3c41c417bace2.json b/backend/.sqlx/query-0f7e01b613a94b29784aae6d7b17b23d6dcf2e5364852a5e85b3c41c417bace2.json new file mode 100644 index 0000000000..de4dd4a7e3 --- /dev/null +++ b/backend/.sqlx/query-0f7e01b613a94b29784aae6d7b17b23d6dcf2e5364852a5e85b3c41c417bace2.json @@ -0,0 +1,41 @@ +{ + "db_name": "PostgreSQL", + "query": "\n INSERT INTO capture (workspace_id, path, is_flow, trigger_kind, main_args, preprocessor_args, created_by)\n VALUES ($1, $2, $3, $4::trigger_kind, $5::jsonb, $6::jsonb, $7)\n ", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Varchar", + "Varchar", + "Bool", + { + "Custom": { + "name": "trigger_kind", + "kind": { + "Enum": [ + "webhook", + "http", + "websocket", + "kafka", + "email", + "nats", + "postgres", + "sqs", + "mqtt", + "gcp", + "default_email", + "nextcloud", + "google" + ] + } + } + }, + "Jsonb", + "Jsonb", + "Varchar" + ] + }, + "nullable": [] + }, + "hash": "0f7e01b613a94b29784aae6d7b17b23d6dcf2e5364852a5e85b3c41c417bace2" +} diff --git a/backend/.sqlx/query-14276a040cb4db88d71fccdc3579e8c0bb132b70668301b535872d1632753e30.json b/backend/.sqlx/query-14276a040cb4db88d71fccdc3579e8c0bb132b70668301b535872d1632753e30.json index d4f7afa966..bed99ef1b7 100644 --- a/backend/.sqlx/query-14276a040cb4db88d71fccdc3579e8c0bb132b70668301b535872d1632753e30.json +++ b/backend/.sqlx/query-14276a040cb4db88d71fccdc3579e8c0bb132b70668301b535872d1632753e30.json @@ -122,7 +122,8 @@ "sqs", "gcp", "mqtt", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-16d438374b03a9c515f4c2d638366f38ffe2f3a0958adea53e67757c6ac463ec.json b/backend/.sqlx/query-16d438374b03a9c515f4c2d638366f38ffe2f3a0958adea53e67757c6ac463ec.json new file mode 100644 index 0000000000..1fdc78c472 --- /dev/null +++ b/backend/.sqlx/query-16d438374b03a9c515f4c2d638366f38ffe2f3a0958adea53e67757c6ac463ec.json @@ -0,0 +1,40 @@ +{ + "db_name": "PostgreSQL", + "query": "\n INSERT INTO capture_config (workspace_id, path, is_flow, trigger_kind, owner, email)\n VALUES ($1, $2, $3, $4::trigger_kind, $5, $6)\n ", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Varchar", + "Varchar", + "Bool", + { + "Custom": { + "name": "trigger_kind", + "kind": { + "Enum": [ + "webhook", + "http", + "websocket", + "kafka", + "email", + "nats", + "postgres", + "sqs", + "mqtt", + "gcp", + "default_email", + "nextcloud", + "google" + ] + } + } + }, + "Varchar", + "Varchar" + ] + }, + "nullable": [] + }, + "hash": "16d438374b03a9c515f4c2d638366f38ffe2f3a0958adea53e67757c6ac463ec" +} diff --git a/backend/.sqlx/query-19b59c478744d029c6006b01f04243ad2e0aef485a780daea5d76b0be2bb2ea2.json b/backend/.sqlx/query-19b59c478744d029c6006b01f04243ad2e0aef485a780daea5d76b0be2bb2ea2.json index 43c68f8c5a..30e071f8ce 100644 --- a/backend/.sqlx/query-19b59c478744d029c6006b01f04243ad2e0aef485a780daea5d76b0be2bb2ea2.json +++ b/backend/.sqlx/query-19b59c478744d029c6006b01f04243ad2e0aef485a780daea5d76b0be2bb2ea2.json @@ -40,7 +40,8 @@ "sqs", "gcp", "mqtt", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-1cad2ebfbdc46f9c0d93329897a71701f17a33b708b334d909563c9a0dcc9c23.json b/backend/.sqlx/query-1cad2ebfbdc46f9c0d93329897a71701f17a33b708b334d909563c9a0dcc9c23.json new file mode 100644 index 0000000000..49ae463657 --- /dev/null +++ b/backend/.sqlx/query-1cad2ebfbdc46f9c0d93329897a71701f17a33b708b334d909563c9a0dcc9c23.json @@ -0,0 +1,22 @@ +{ + "db_name": "PostgreSQL", + "query": "\n INSERT INTO kafka_trigger (\n path, kafka_resource_path, topics, group_id, script_path,\n is_flow, workspace_id, edited_by, email\n )\n VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9)\n ", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Varchar", + "Varchar", + "VarcharArray", + "Varchar", + "Varchar", + "Bool", + "Varchar", + "Varchar", + "Varchar" + ] + }, + "nullable": [] + }, + "hash": "1cad2ebfbdc46f9c0d93329897a71701f17a33b708b334d909563c9a0dcc9c23" +} diff --git a/backend/.sqlx/query-1d4bb4f53574ef95ef1016b760f849ec2372ac6a21bb2556d17a96dc72ea4980.json b/backend/.sqlx/query-1d4bb4f53574ef95ef1016b760f849ec2372ac6a21bb2556d17a96dc72ea4980.json new file mode 100644 index 0000000000..2257984d66 --- /dev/null +++ b/backend/.sqlx/query-1d4bb4f53574ef95ef1016b760f849ec2372ac6a21bb2556d17a96dc72ea4980.json @@ -0,0 +1,22 @@ +{ + "db_name": "PostgreSQL", + "query": "\n INSERT INTO websocket_trigger (\n path, url, script_path, is_flow, workspace_id,\n edited_by, email, server_id, error\n )\n VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9)\n ", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Varchar", + "Varchar", + "Varchar", + "Bool", + "Varchar", + "Varchar", + "Varchar", + "Varchar", + "Text" + ] + }, + "nullable": [] + }, + "hash": "1d4bb4f53574ef95ef1016b760f849ec2372ac6a21bb2556d17a96dc72ea4980" +} diff --git a/backend/.sqlx/query-22e0e8a1aa48f8b21763452bd36fbe7db4887c4ac5295052c796bd78a7edc50b.json b/backend/.sqlx/query-22e0e8a1aa48f8b21763452bd36fbe7db4887c4ac5295052c796bd78a7edc50b.json new file mode 100644 index 0000000000..235f255dd1 --- /dev/null +++ b/backend/.sqlx/query-22e0e8a1aa48f8b21763452bd36fbe7db4887c4ac5295052c796bd78a7edc50b.json @@ -0,0 +1,40 @@ +{ + "db_name": "PostgreSQL", + "query": "\n INSERT INTO capture_config (workspace_id, path, is_flow, trigger_kind, owner, email)\n VALUES ($1, $2, $3, $4::trigger_kind, $5, $6)\n ON CONFLICT (workspace_id, path, is_flow, trigger_kind)\n DO UPDATE SET owner = $5, email = $6, server_id = NULL, error = NULL\n ", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Varchar", + "Varchar", + "Bool", + { + "Custom": { + "name": "trigger_kind", + "kind": { + "Enum": [ + "webhook", + "http", + "websocket", + "kafka", + "email", + "nats", + "postgres", + "sqs", + "mqtt", + "gcp", + "default_email", + "nextcloud", + "google" + ] + } + } + }, + "Varchar", + "Varchar" + ] + }, + "nullable": [] + }, + "hash": "22e0e8a1aa48f8b21763452bd36fbe7db4887c4ac5295052c796bd78a7edc50b" +} diff --git a/backend/.sqlx/query-23419adcd74c326d716527293eff518b42f4cdb33e034441015494bd26c172d2.json b/backend/.sqlx/query-23419adcd74c326d716527293eff518b42f4cdb33e034441015494bd26c172d2.json index 242b358ff5..7bd7367d8d 100644 --- a/backend/.sqlx/query-23419adcd74c326d716527293eff518b42f4cdb33e034441015494bd26c172d2.json +++ b/backend/.sqlx/query-23419adcd74c326d716527293eff518b42f4cdb33e034441015494bd26c172d2.json @@ -40,7 +40,8 @@ "mqtt", "gcp", "default_email", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-2f7ff8bf66826101546e11066039bd647f9016cec246117a8fa1bd76c44db6a3.json b/backend/.sqlx/query-2f7ff8bf66826101546e11066039bd647f9016cec246117a8fa1bd76c44db6a3.json new file mode 100644 index 0000000000..96a9e9be19 --- /dev/null +++ b/backend/.sqlx/query-2f7ff8bf66826101546e11066039bd647f9016cec246117a8fa1bd76c44db6a3.json @@ -0,0 +1,29 @@ +{ + "db_name": "PostgreSQL", + "query": "SELECT server_id, error FROM websocket_trigger WHERE workspace_id = $1 AND path = $2", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "server_id", + "type_info": "Varchar" + }, + { + "ordinal": 1, + "name": "error", + "type_info": "Text" + } + ], + "parameters": { + "Left": [ + "Text", + "Text" + ] + }, + "nullable": [ + true, + true + ] + }, + "hash": "2f7ff8bf66826101546e11066039bd647f9016cec246117a8fa1bd76c44db6a3" +} diff --git a/backend/.sqlx/query-30fc636d349e046e4dce61a1db964e7e5a857b39584a4bd5b62fc4703215cfb8.json b/backend/.sqlx/query-30fc636d349e046e4dce61a1db964e7e5a857b39584a4bd5b62fc4703215cfb8.json new file mode 100644 index 0000000000..cdf46f5b67 --- /dev/null +++ b/backend/.sqlx/query-30fc636d349e046e4dce61a1db964e7e5a857b39584a4bd5b62fc4703215cfb8.json @@ -0,0 +1,23 @@ +{ + "db_name": "PostgreSQL", + "query": "SELECT owner FROM capture_config WHERE workspace_id = $1 AND path = $2", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "owner", + "type_info": "Varchar" + } + ], + "parameters": { + "Left": [ + "Text", + "Text" + ] + }, + "nullable": [ + false + ] + }, + "hash": "30fc636d349e046e4dce61a1db964e7e5a857b39584a4bd5b62fc4703215cfb8" +} diff --git a/backend/.sqlx/query-3d198a9319d8872a04f8ccdc129f8baf44d26dc97187ec08946a665d81ed89dd.json b/backend/.sqlx/query-3d198a9319d8872a04f8ccdc129f8baf44d26dc97187ec08946a665d81ed89dd.json new file mode 100644 index 0000000000..e0894c69eb --- /dev/null +++ b/backend/.sqlx/query-3d198a9319d8872a04f8ccdc129f8baf44d26dc97187ec08946a665d81ed89dd.json @@ -0,0 +1,22 @@ +{ + "db_name": "PostgreSQL", + "query": "SELECT COUNT(*) FROM http_trigger WHERE workspace_id = $1", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "count", + "type_info": "Int8" + } + ], + "parameters": { + "Left": [ + "Text" + ] + }, + "nullable": [ + null + ] + }, + "hash": "3d198a9319d8872a04f8ccdc129f8baf44d26dc97187ec08946a665d81ed89dd" +} diff --git a/backend/.sqlx/query-4012a31045d4ff7665913be12190307542c6eabbe264071a216683d18839e68c.json b/backend/.sqlx/query-4012a31045d4ff7665913be12190307542c6eabbe264071a216683d18839e68c.json new file mode 100644 index 0000000000..0b6565a28c --- /dev/null +++ b/backend/.sqlx/query-4012a31045d4ff7665913be12190307542c6eabbe264071a216683d18839e68c.json @@ -0,0 +1,37 @@ +{ + "db_name": "PostgreSQL", + "query": "\n SELECT COUNT(*) FROM http_trigger\n WHERE workspace_id = $1 AND authentication_method = $2::authentication_method\n ", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "count", + "type_info": "Int8" + } + ], + "parameters": { + "Left": [ + "Text", + { + "Custom": { + "name": "authentication_method", + "kind": { + "Enum": [ + "none", + "windmill", + "api_key", + "basic_http", + "custom_script", + "signature" + ] + } + } + } + ] + }, + "nullable": [ + null + ] + }, + "hash": "4012a31045d4ff7665913be12190307542c6eabbe264071a216683d18839e68c" +} diff --git a/backend/.sqlx/query-410e3c47a8a6144228d2200e6859ad8a15c443801eba563a7c069bcac2bd21aa.json b/backend/.sqlx/query-410e3c47a8a6144228d2200e6859ad8a15c443801eba563a7c069bcac2bd21aa.json new file mode 100644 index 0000000000..85245fdf67 --- /dev/null +++ b/backend/.sqlx/query-410e3c47a8a6144228d2200e6859ad8a15c443801eba563a7c069bcac2bd21aa.json @@ -0,0 +1,22 @@ +{ + "db_name": "PostgreSQL", + "query": "SELECT COUNT(*) FROM capture WHERE id = $1", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "count", + "type_info": "Int8" + } + ], + "parameters": { + "Left": [ + "Int8" + ] + }, + "nullable": [ + null + ] + }, + "hash": "410e3c47a8a6144228d2200e6859ad8a15c443801eba563a7c069bcac2bd21aa" +} diff --git a/backend/.sqlx/query-41e557e1b63b13c9fcc195901c0bd0de7e03c539ee046955543d9693551246f7.json b/backend/.sqlx/query-41e557e1b63b13c9fcc195901c0bd0de7e03c539ee046955543d9693551246f7.json new file mode 100644 index 0000000000..0df0167c42 --- /dev/null +++ b/backend/.sqlx/query-41e557e1b63b13c9fcc195901c0bd0de7e03c539ee046955543d9693551246f7.json @@ -0,0 +1,14 @@ +{ + "db_name": "PostgreSQL", + "query": "DELETE FROM capture WHERE id = $1", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Int8" + ] + }, + "nullable": [] + }, + "hash": "41e557e1b63b13c9fcc195901c0bd0de7e03c539ee046955543d9693551246f7" +} diff --git a/backend/.sqlx/query-42b4b73e9d60348e2d90fcade9dcad6d8995242dc20a4e14c1a8fae4fc6a9fd2.json b/backend/.sqlx/query-42b4b73e9d60348e2d90fcade9dcad6d8995242dc20a4e14c1a8fae4fc6a9fd2.json index e6d71f386f..537ecbeacf 100644 --- a/backend/.sqlx/query-42b4b73e9d60348e2d90fcade9dcad6d8995242dc20a4e14c1a8fae4fc6a9fd2.json +++ b/backend/.sqlx/query-42b4b73e9d60348e2d90fcade9dcad6d8995242dc20a4e14c1a8fae4fc6a9fd2.json @@ -24,7 +24,8 @@ "mqtt", "gcp", "default_email", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-42c7f52fe822124bf22b4c300ee8014088225ca2bbf1835b6fb5e5b78e5647c8.json b/backend/.sqlx/query-42c7f52fe822124bf22b4c300ee8014088225ca2bbf1835b6fb5e5b78e5647c8.json new file mode 100644 index 0000000000..5bb6c8c8fe --- /dev/null +++ b/backend/.sqlx/query-42c7f52fe822124bf22b4c300ee8014088225ca2bbf1835b6fb5e5b78e5647c8.json @@ -0,0 +1,23 @@ +{ + "db_name": "PostgreSQL", + "query": "SELECT last_client_ping FROM capture_config WHERE workspace_id = $1 AND path = $2", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "last_client_ping", + "type_info": "Timestamptz" + } + ], + "parameters": { + "Left": [ + "Text", + "Text" + ] + }, + "nullable": [ + true + ] + }, + "hash": "42c7f52fe822124bf22b4c300ee8014088225ca2bbf1835b6fb5e5b78e5647c8" +} diff --git a/backend/.sqlx/query-45024b932383199974616bba1fc2f7175cc6f2e02d9c565bb5159cae3e0b6835.json b/backend/.sqlx/query-45024b932383199974616bba1fc2f7175cc6f2e02d9c565bb5159cae3e0b6835.json new file mode 100644 index 0000000000..30c5ff7a49 --- /dev/null +++ b/backend/.sqlx/query-45024b932383199974616bba1fc2f7175cc6f2e02d9c565bb5159cae3e0b6835.json @@ -0,0 +1,49 @@ +{ + "db_name": "PostgreSQL", + "query": "\n INSERT INTO capture (workspace_id, path, is_flow, trigger_kind, main_args, preprocessor_args, created_by)\n VALUES ($1, $2, $3, $4::trigger_kind, $5::jsonb, $6::jsonb, $7)\n RETURNING id\n ", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "id", + "type_info": "Int8" + } + ], + "parameters": { + "Left": [ + "Varchar", + "Varchar", + "Bool", + { + "Custom": { + "name": "trigger_kind", + "kind": { + "Enum": [ + "webhook", + "http", + "websocket", + "kafka", + "email", + "nats", + "postgres", + "sqs", + "mqtt", + "gcp", + "default_email", + "nextcloud", + "google" + ] + } + } + }, + "Jsonb", + "Jsonb", + "Varchar" + ] + }, + "nullable": [ + false + ] + }, + "hash": "45024b932383199974616bba1fc2f7175cc6f2e02d9c565bb5159cae3e0b6835" +} diff --git a/backend/.sqlx/query-4d272cf4a77aab7007a5b35589e08532a1020cabaf5e22325a1e05f0491d785c.json b/backend/.sqlx/query-4d272cf4a77aab7007a5b35589e08532a1020cabaf5e22325a1e05f0491d785c.json new file mode 100644 index 0000000000..cfb975b838 --- /dev/null +++ b/backend/.sqlx/query-4d272cf4a77aab7007a5b35589e08532a1020cabaf5e22325a1e05f0491d785c.json @@ -0,0 +1,62 @@ +{ + "db_name": "PostgreSQL", + "query": "\n SELECT path, owner, email, trigger_kind AS \"trigger_kind: String\"\n FROM capture_config\n WHERE workspace_id = $1 AND path = $2\n ", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "path", + "type_info": "Varchar" + }, + { + "ordinal": 1, + "name": "owner", + "type_info": "Varchar" + }, + { + "ordinal": 2, + "name": "email", + "type_info": "Varchar" + }, + { + "ordinal": 3, + "name": "trigger_kind: String", + "type_info": { + "Custom": { + "name": "trigger_kind", + "kind": { + "Enum": [ + "webhook", + "http", + "websocket", + "kafka", + "email", + "nats", + "postgres", + "sqs", + "mqtt", + "gcp", + "default_email", + "nextcloud", + "google" + ] + } + } + } + } + ], + "parameters": { + "Left": [ + "Text", + "Text" + ] + }, + "nullable": [ + false, + false, + false, + false + ] + }, + "hash": "4d272cf4a77aab7007a5b35589e08532a1020cabaf5e22325a1e05f0491d785c" +} diff --git a/backend/.sqlx/query-4f547c0fd54f3bc57212ce87810e35adf640d44d607e62a1fb296e38ac3fdd36.json b/backend/.sqlx/query-4f547c0fd54f3bc57212ce87810e35adf640d44d607e62a1fb296e38ac3fdd36.json index 789c0334d7..4e8ec56d12 100644 --- a/backend/.sqlx/query-4f547c0fd54f3bc57212ce87810e35adf640d44d607e62a1fb296e38ac3fdd36.json +++ b/backend/.sqlx/query-4f547c0fd54f3bc57212ce87810e35adf640d44d607e62a1fb296e38ac3fdd36.json @@ -32,7 +32,8 @@ "mqtt", "gcp", "default_email", - "nextcloud" + "nextcloud", + "google" ] } } @@ -70,7 +71,8 @@ "mqtt", "gcp", "default_email", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-4f8bc8acc174e33a45eab9f046cd3e809a5026de15540a3347c464a03c079257.json b/backend/.sqlx/query-4f8bc8acc174e33a45eab9f046cd3e809a5026de15540a3347c464a03c079257.json new file mode 100644 index 0000000000..e8257f30aa --- /dev/null +++ b/backend/.sqlx/query-4f8bc8acc174e33a45eab9f046cd3e809a5026de15540a3347c464a03c079257.json @@ -0,0 +1,62 @@ +{ + "db_name": "PostgreSQL", + "query": "\n SELECT queue_url, aws_resource_path,\n aws_auth_resource_type AS \"aws_auth_resource_type: String\",\n mode AS \"mode: String\"\n FROM sqs_trigger\n WHERE workspace_id = $1 AND path = $2\n ", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "queue_url", + "type_info": "Varchar" + }, + { + "ordinal": 1, + "name": "aws_resource_path", + "type_info": "Varchar" + }, + { + "ordinal": 2, + "name": "aws_auth_resource_type: String", + "type_info": { + "Custom": { + "name": "aws_auth_resource_type", + "kind": { + "Enum": [ + "oidc", + "credentials" + ] + } + } + } + }, + { + "ordinal": 3, + "name": "mode: String", + "type_info": { + "Custom": { + "name": "trigger_mode", + "kind": { + "Enum": [ + "enabled", + "disabled", + "suspended" + ] + } + } + } + } + ], + "parameters": { + "Left": [ + "Text", + "Text" + ] + }, + "nullable": [ + false, + false, + false, + false + ] + }, + "hash": "4f8bc8acc174e33a45eab9f046cd3e809a5026de15540a3347c464a03c079257" +} diff --git a/backend/.sqlx/query-572b712b9ff0231ca0f680eb3d6a7dedf30e8c98a87e861886300afbc95af6cf.json b/backend/.sqlx/query-572b712b9ff0231ca0f680eb3d6a7dedf30e8c98a87e861886300afbc95af6cf.json new file mode 100644 index 0000000000..c4b1a5d8b2 --- /dev/null +++ b/backend/.sqlx/query-572b712b9ff0231ca0f680eb3d6a7dedf30e8c98a87e861886300afbc95af6cf.json @@ -0,0 +1,22 @@ +{ + "db_name": "PostgreSQL", + "query": "\n SELECT COUNT(*) FROM http_trigger\n WHERE workspace_id = $1\n AND (mode = 'enabled'::trigger_mode OR mode = 'suspended'::trigger_mode)\n ", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "count", + "type_info": "Int8" + } + ], + "parameters": { + "Left": [ + "Text" + ] + }, + "nullable": [ + null + ] + }, + "hash": "572b712b9ff0231ca0f680eb3d6a7dedf30e8c98a87e861886300afbc95af6cf" +} diff --git a/backend/.sqlx/query-57b7236cae0b6a1940f4c2d4b202692450ee231488d9a55ca59ff53a6f674626.json b/backend/.sqlx/query-57b7236cae0b6a1940f4c2d4b202692450ee231488d9a55ca59ff53a6f674626.json new file mode 100644 index 0000000000..0b854e8bef --- /dev/null +++ b/backend/.sqlx/query-57b7236cae0b6a1940f4c2d4b202692450ee231488d9a55ca59ff53a6f674626.json @@ -0,0 +1,20 @@ +{ + "db_name": "PostgreSQL", + "query": "\n INSERT INTO websocket_trigger (\n path, url, script_path, is_flow, workspace_id,\n edited_by, email\n )\n VALUES ($1, $2, $3, $4, $5, $6, $7)\n ", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Varchar", + "Varchar", + "Varchar", + "Bool", + "Varchar", + "Varchar", + "Varchar" + ] + }, + "nullable": [] + }, + "hash": "57b7236cae0b6a1940f4c2d4b202692450ee231488d9a55ca59ff53a6f674626" +} diff --git a/backend/.sqlx/query-57eca702e951f5303a74643c7ba64472e2c2a781fbb6366d998a0f1ca22fcdf2.json b/backend/.sqlx/query-57eca702e951f5303a74643c7ba64472e2c2a781fbb6366d998a0f1ca22fcdf2.json new file mode 100644 index 0000000000..e55868665f --- /dev/null +++ b/backend/.sqlx/query-57eca702e951f5303a74643c7ba64472e2c2a781fbb6366d998a0f1ca22fcdf2.json @@ -0,0 +1,66 @@ +{ + "db_name": "PostgreSQL", + "query": "\n INSERT INTO http_trigger (\n path, route_path, route_path_key, script_path, is_flow,\n workspace_id, edited_by, email, http_method,\n authentication_method, is_static_website, workspaced_route,\n wrap_body, raw_string, mode\n )\n VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9::http_method,\n $10::authentication_method, $11, $12, $13, $14, $15::trigger_mode)\n ", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Varchar", + "Varchar", + "Varchar", + "Varchar", + "Bool", + "Varchar", + "Varchar", + "Varchar", + { + "Custom": { + "name": "http_method", + "kind": { + "Enum": [ + "get", + "post", + "put", + "delete", + "patch" + ] + } + } + }, + { + "Custom": { + "name": "authentication_method", + "kind": { + "Enum": [ + "none", + "windmill", + "api_key", + "basic_http", + "custom_script", + "signature" + ] + } + } + }, + "Bool", + "Bool", + "Bool", + "Bool", + { + "Custom": { + "name": "trigger_mode", + "kind": { + "Enum": [ + "enabled", + "disabled", + "suspended" + ] + } + } + } + ] + }, + "nullable": [] + }, + "hash": "57eca702e951f5303a74643c7ba64472e2c2a781fbb6366d998a0f1ca22fcdf2" +} diff --git a/backend/.sqlx/query-5a219a2532517869578c4504ff3153c43903f929ae5d62fbba12610f89c36d55.json b/backend/.sqlx/query-5a219a2532517869578c4504ff3153c43903f929ae5d62fbba12610f89c36d55.json index 36ddb8ab9f..713ccb9dd3 100644 --- a/backend/.sqlx/query-5a219a2532517869578c4504ff3153c43903f929ae5d62fbba12610f89c36d55.json +++ b/backend/.sqlx/query-5a219a2532517869578c4504ff3153c43903f929ae5d62fbba12610f89c36d55.json @@ -15,7 +15,7 @@ ] }, "nullable": [ - true + null ] }, "hash": "5a219a2532517869578c4504ff3153c43903f929ae5d62fbba12610f89c36d55" diff --git a/backend/.sqlx/query-5bf200f2c8db25ddf231b564503c6c70f7f3958564a79bb0c6b3863b1ebb0cbf.json b/backend/.sqlx/query-5bf200f2c8db25ddf231b564503c6c70f7f3958564a79bb0c6b3863b1ebb0cbf.json index 6d3941ad69..9422e3e8d0 100644 --- a/backend/.sqlx/query-5bf200f2c8db25ddf231b564503c6c70f7f3958564a79bb0c6b3863b1ebb0cbf.json +++ b/backend/.sqlx/query-5bf200f2c8db25ddf231b564503c6c70f7f3958564a79bb0c6b3863b1ebb0cbf.json @@ -245,7 +245,8 @@ "sqs", "gcp", "mqtt", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-5eaa109879b27bb2eaa738fb3f359ade1a05164beabd1c1284b6d656c8c2e114.json b/backend/.sqlx/query-5eaa109879b27bb2eaa738fb3f359ade1a05164beabd1c1284b6d656c8c2e114.json new file mode 100644 index 0000000000..6be3903161 --- /dev/null +++ b/backend/.sqlx/query-5eaa109879b27bb2eaa738fb3f359ade1a05164beabd1c1284b6d656c8c2e114.json @@ -0,0 +1,23 @@ +{ + "db_name": "PostgreSQL", + "query": "SELECT COUNT(*) FROM capture WHERE workspace_id = $1 AND path = $2", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "count", + "type_info": "Int8" + } + ], + "parameters": { + "Left": [ + "Text", + "Text" + ] + }, + "nullable": [ + null + ] + }, + "hash": "5eaa109879b27bb2eaa738fb3f359ade1a05164beabd1c1284b6d656c8c2e114" +} diff --git a/backend/.sqlx/query-5f1df080a871127172271a72ef006005e1575ad43ea7539c186730ef8ac49e01.json b/backend/.sqlx/query-5f1df080a871127172271a72ef006005e1575ad43ea7539c186730ef8ac49e01.json new file mode 100644 index 0000000000..54f4acae30 --- /dev/null +++ b/backend/.sqlx/query-5f1df080a871127172271a72ef006005e1575ad43ea7539c186730ef8ac49e01.json @@ -0,0 +1,23 @@ +{ + "db_name": "PostgreSQL", + "query": "SELECT COUNT(*) FROM capture_config WHERE workspace_id = $1 AND path = $2", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "count", + "type_info": "Int8" + } + ], + "parameters": { + "Left": [ + "Text", + "Text" + ] + }, + "nullable": [ + null + ] + }, + "hash": "5f1df080a871127172271a72ef006005e1575ad43ea7539c186730ef8ac49e01" +} diff --git a/backend/.sqlx/query-624162e98be630ccc363f10bb0f966baf7fd7d7c74a7a9d2ae08e587967575d4.json b/backend/.sqlx/query-624162e98be630ccc363f10bb0f966baf7fd7d7c74a7a9d2ae08e587967575d4.json new file mode 100644 index 0000000000..821a3927ad --- /dev/null +++ b/backend/.sqlx/query-624162e98be630ccc363f10bb0f966baf7fd7d7c74a7a9d2ae08e587967575d4.json @@ -0,0 +1,23 @@ +{ + "db_name": "PostgreSQL", + "query": "SELECT COUNT(*) FROM http_trigger WHERE workspace_id = $1 AND path = $2", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "count", + "type_info": "Int8" + } + ], + "parameters": { + "Left": [ + "Text", + "Text" + ] + }, + "nullable": [ + null + ] + }, + "hash": "624162e98be630ccc363f10bb0f966baf7fd7d7c74a7a9d2ae08e587967575d4" +} diff --git a/backend/.sqlx/query-653e7a8509194f60e442848346ee106c8c24445130880be87c12a764e7921bff.json b/backend/.sqlx/query-653e7a8509194f60e442848346ee106c8c24445130880be87c12a764e7921bff.json new file mode 100644 index 0000000000..633f88b8d6 --- /dev/null +++ b/backend/.sqlx/query-653e7a8509194f60e442848346ee106c8c24445130880be87c12a764e7921bff.json @@ -0,0 +1,74 @@ +{ + "db_name": "PostgreSQL", + "query": "\n SELECT\n path, route_path, script_path,\n http_method AS \"http_method: String\",\n authentication_method AS \"authentication_method: String\"\n FROM http_trigger\n WHERE workspace_id = $1 AND path = $2\n ", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "path", + "type_info": "Varchar" + }, + { + "ordinal": 1, + "name": "route_path", + "type_info": "Varchar" + }, + { + "ordinal": 2, + "name": "script_path", + "type_info": "Varchar" + }, + { + "ordinal": 3, + "name": "http_method: String", + "type_info": { + "Custom": { + "name": "http_method", + "kind": { + "Enum": [ + "get", + "post", + "put", + "delete", + "patch" + ] + } + } + } + }, + { + "ordinal": 4, + "name": "authentication_method: String", + "type_info": { + "Custom": { + "name": "authentication_method", + "kind": { + "Enum": [ + "none", + "windmill", + "api_key", + "basic_http", + "custom_script", + "signature" + ] + } + } + } + } + ], + "parameters": { + "Left": [ + "Text", + "Text" + ] + }, + "nullable": [ + false, + false, + false, + false, + false + ] + }, + "hash": "653e7a8509194f60e442848346ee106c8c24445130880be87c12a764e7921bff" +} diff --git a/backend/.sqlx/query-66a0e51cf149ba532463e29dd361a803e1bced2f8e1a12f8933b7598ee85a147.json b/backend/.sqlx/query-66a0e51cf149ba532463e29dd361a803e1bced2f8e1a12f8933b7598ee85a147.json index 0d12be2448..5f9be1cba9 100644 --- a/backend/.sqlx/query-66a0e51cf149ba532463e29dd361a803e1bced2f8e1a12f8933b7598ee85a147.json +++ b/backend/.sqlx/query-66a0e51cf149ba532463e29dd361a803e1bced2f8e1a12f8933b7598ee85a147.json @@ -35,7 +35,8 @@ "mqtt", "gcp", "default_email", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-6afa076744233fc5e92188ff978990fa3a704afe3eec523f4e203f7f6e247261.json b/backend/.sqlx/query-6afa076744233fc5e92188ff978990fa3a704afe3eec523f4e203f7f6e247261.json new file mode 100644 index 0000000000..b34e0205c9 --- /dev/null +++ b/backend/.sqlx/query-6afa076744233fc5e92188ff978990fa3a704afe3eec523f4e203f7f6e247261.json @@ -0,0 +1,54 @@ +{ + "db_name": "PostgreSQL", + "query": "\n INSERT INTO http_trigger (\n path, route_path, route_path_key, script_path, is_flow,\n workspace_id, edited_by, email, http_method,\n authentication_method, is_static_website, workspaced_route,\n wrap_body, raw_string\n )\n VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9::http_method,\n $10::authentication_method, $11, $12, $13, $14)\n ", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Varchar", + "Varchar", + "Varchar", + "Varchar", + "Bool", + "Varchar", + "Varchar", + "Varchar", + { + "Custom": { + "name": "http_method", + "kind": { + "Enum": [ + "get", + "post", + "put", + "delete", + "patch" + ] + } + } + }, + { + "Custom": { + "name": "authentication_method", + "kind": { + "Enum": [ + "none", + "windmill", + "api_key", + "basic_http", + "custom_script", + "signature" + ] + } + } + }, + "Bool", + "Bool", + "Bool", + "Bool" + ] + }, + "nullable": [] + }, + "hash": "6afa076744233fc5e92188ff978990fa3a704afe3eec523f4e203f7f6e247261" +} diff --git a/backend/.sqlx/query-7065f23d04e26831664048f2cfc4f412c57af931f80621aee5012e9cb3535626.json b/backend/.sqlx/query-7065f23d04e26831664048f2cfc4f412c57af931f80621aee5012e9cb3535626.json new file mode 100644 index 0000000000..48ea42f8a2 --- /dev/null +++ b/backend/.sqlx/query-7065f23d04e26831664048f2cfc4f412c57af931f80621aee5012e9cb3535626.json @@ -0,0 +1,45 @@ +{ + "db_name": "PostgreSQL", + "query": "\n SELECT COUNT(*) FROM capture\n WHERE workspace_id = $1 AND path = $2 AND trigger_kind = $3::trigger_kind\n ", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "count", + "type_info": "Int8" + } + ], + "parameters": { + "Left": [ + "Text", + "Text", + { + "Custom": { + "name": "trigger_kind", + "kind": { + "Enum": [ + "webhook", + "http", + "websocket", + "kafka", + "email", + "nats", + "postgres", + "sqs", + "mqtt", + "gcp", + "default_email", + "nextcloud", + "google" + ] + } + } + } + ] + }, + "nullable": [ + null + ] + }, + "hash": "7065f23d04e26831664048f2cfc4f412c57af931f80621aee5012e9cb3535626" +} diff --git a/backend/.sqlx/query-73fdd01bad58b8be1a52f89faef8d92a983470adcd3cc850734960c905e61e83.json b/backend/.sqlx/query-73fdd01bad58b8be1a52f89faef8d92a983470adcd3cc850734960c905e61e83.json new file mode 100644 index 0000000000..8aacd8a805 --- /dev/null +++ b/backend/.sqlx/query-73fdd01bad58b8be1a52f89faef8d92a983470adcd3cc850734960c905e61e83.json @@ -0,0 +1,41 @@ +{ + "db_name": "PostgreSQL", + "query": "\n INSERT INTO capture (workspace_id, path, is_flow, trigger_kind, main_args, preprocessor_args, created_by)\n VALUES ($1, $2, $3, $4::trigger_kind, $5::jsonb, $6::jsonb, $7)\n ", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Varchar", + "Varchar", + "Bool", + { + "Custom": { + "name": "trigger_kind", + "kind": { + "Enum": [ + "webhook", + "http", + "websocket", + "kafka", + "email", + "nats", + "postgres", + "sqs", + "mqtt", + "gcp", + "default_email", + "nextcloud", + "google" + ] + } + } + }, + "Jsonb", + "Jsonb", + "Varchar" + ] + }, + "nullable": [] + }, + "hash": "73fdd01bad58b8be1a52f89faef8d92a983470adcd3cc850734960c905e61e83" +} diff --git a/backend/.sqlx/query-74c11f5a0315424574fe3e7429f967f7b94f9d9db7be628f9cb411d789085711.json b/backend/.sqlx/query-74c11f5a0315424574fe3e7429f967f7b94f9d9db7be628f9cb411d789085711.json new file mode 100644 index 0000000000..1b33e89eb1 --- /dev/null +++ b/backend/.sqlx/query-74c11f5a0315424574fe3e7429f967f7b94f9d9db7be628f9cb411d789085711.json @@ -0,0 +1,54 @@ +{ + "db_name": "PostgreSQL", + "query": "\n INSERT INTO http_trigger (\n path, route_path, route_path_key, script_path, is_flow,\n workspace_id, edited_by, email, http_method,\n authentication_method, is_static_website, workspaced_route,\n wrap_body, raw_string\n )\n VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9::http_method,\n $10::authentication_method, $11, $12, $13, $14)\n ", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Varchar", + "Varchar", + "Varchar", + "Varchar", + "Bool", + "Varchar", + "Varchar", + "Varchar", + { + "Custom": { + "name": "http_method", + "kind": { + "Enum": [ + "get", + "post", + "put", + "delete", + "patch" + ] + } + } + }, + { + "Custom": { + "name": "authentication_method", + "kind": { + "Enum": [ + "none", + "windmill", + "api_key", + "basic_http", + "custom_script", + "signature" + ] + } + } + }, + "Bool", + "Bool", + "Bool", + "Bool" + ] + }, + "nullable": [] + }, + "hash": "74c11f5a0315424574fe3e7429f967f7b94f9d9db7be628f9cb411d789085711" +} diff --git a/backend/.sqlx/query-757ef6215d3d385cb3a69e26ee4ca846dd5e7fe7ceb1aa8b3fcd26a2bd30eb2c.json b/backend/.sqlx/query-757ef6215d3d385cb3a69e26ee4ca846dd5e7fe7ceb1aa8b3fcd26a2bd30eb2c.json index cd795e6fec..59b56ceda7 100644 --- a/backend/.sqlx/query-757ef6215d3d385cb3a69e26ee4ca846dd5e7fe7ceb1aa8b3fcd26a2bd30eb2c.json +++ b/backend/.sqlx/query-757ef6215d3d385cb3a69e26ee4ca846dd5e7fe7ceb1aa8b3fcd26a2bd30eb2c.json @@ -40,7 +40,8 @@ "sqs", "gcp", "mqtt", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-75ce9753a8acc8eccb3f2e0baaa5a871f866a8d21961fac8a003bc40c406ee79.json b/backend/.sqlx/query-75ce9753a8acc8eccb3f2e0baaa5a871f866a8d21961fac8a003bc40c406ee79.json new file mode 100644 index 0000000000..64d95155d1 --- /dev/null +++ b/backend/.sqlx/query-75ce9753a8acc8eccb3f2e0baaa5a871f866a8d21961fac8a003bc40c406ee79.json @@ -0,0 +1,22 @@ +{ + "db_name": "PostgreSQL", + "query": "\n INSERT INTO schedule (\n workspace_id, path, edited_by, schedule, enabled,\n script_path, is_flow, email, timezone\n )\n VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9)\n ", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Varchar", + "Varchar", + "Varchar", + "Varchar", + "Bool", + "Varchar", + "Bool", + "Varchar", + "Varchar" + ] + }, + "nullable": [] + }, + "hash": "75ce9753a8acc8eccb3f2e0baaa5a871f866a8d21961fac8a003bc40c406ee79" +} diff --git a/backend/.sqlx/query-7c1ae9cac13d1387cfa94149f039054dd8c30c16b4657e73cdb0d7c7f1cb3b6d.json b/backend/.sqlx/query-7c1ae9cac13d1387cfa94149f039054dd8c30c16b4657e73cdb0d7c7f1cb3b6d.json new file mode 100644 index 0000000000..cf07041291 --- /dev/null +++ b/backend/.sqlx/query-7c1ae9cac13d1387cfa94149f039054dd8c30c16b4657e73cdb0d7c7f1cb3b6d.json @@ -0,0 +1,32 @@ +{ + "db_name": "PostgreSQL", + "query": "\n INSERT INTO websocket_trigger (\n path, url, script_path, is_flow, workspace_id,\n edited_by, email, mode\n )\n VALUES ($1, $2, $3, $4, $5, $6, $7, $8::trigger_mode)\n ", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Varchar", + "Varchar", + "Varchar", + "Bool", + "Varchar", + "Varchar", + "Varchar", + { + "Custom": { + "name": "trigger_mode", + "kind": { + "Enum": [ + "enabled", + "disabled", + "suspended" + ] + } + } + } + ] + }, + "nullable": [] + }, + "hash": "7c1ae9cac13d1387cfa94149f039054dd8c30c16b4657e73cdb0d7c7f1cb3b6d" +} diff --git a/backend/.sqlx/query-7e3bfb33fb771aec39b43a7550091ce7c9b1261b52d10f4a7f3273fed3c916df.json b/backend/.sqlx/query-7e3bfb33fb771aec39b43a7550091ce7c9b1261b52d10f4a7f3273fed3c916df.json new file mode 100644 index 0000000000..23652a2571 --- /dev/null +++ b/backend/.sqlx/query-7e3bfb33fb771aec39b43a7550091ce7c9b1261b52d10f4a7f3273fed3c916df.json @@ -0,0 +1,52 @@ +{ + "db_name": "PostgreSQL", + "query": "\n SELECT kafka_resource_path, topics, group_id, mode AS \"mode: String\"\n FROM kafka_trigger\n WHERE workspace_id = $1 AND path = $2\n ", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "kafka_resource_path", + "type_info": "Varchar" + }, + { + "ordinal": 1, + "name": "topics", + "type_info": "VarcharArray" + }, + { + "ordinal": 2, + "name": "group_id", + "type_info": "Varchar" + }, + { + "ordinal": 3, + "name": "mode: String", + "type_info": { + "Custom": { + "name": "trigger_mode", + "kind": { + "Enum": [ + "enabled", + "disabled", + "suspended" + ] + } + } + } + } + ], + "parameters": { + "Left": [ + "Text", + "Text" + ] + }, + "nullable": [ + false, + false, + false, + false + ] + }, + "hash": "7e3bfb33fb771aec39b43a7550091ce7c9b1261b52d10f4a7f3273fed3c916df" +} diff --git a/backend/.sqlx/query-7fbf72d9059fcd77e4c1112fa4fa22e4276c1da653475628889ce17dc904fbaa.json b/backend/.sqlx/query-7fbf72d9059fcd77e4c1112fa4fa22e4276c1da653475628889ce17dc904fbaa.json index 393a920b7c..8c380df861 100644 --- a/backend/.sqlx/query-7fbf72d9059fcd77e4c1112fa4fa22e4276c1da653475628889ce17dc904fbaa.json +++ b/backend/.sqlx/query-7fbf72d9059fcd77e4c1112fa4fa22e4276c1da653475628889ce17dc904fbaa.json @@ -27,7 +27,8 @@ "mqtt", "gcp", "default_email", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-836bac47d89113d90bd03a471446eb9016207975af1e37042d81df8cb6ae2c53.json b/backend/.sqlx/query-836bac47d89113d90bd03a471446eb9016207975af1e37042d81df8cb6ae2c53.json new file mode 100644 index 0000000000..3012e9ef77 --- /dev/null +++ b/backend/.sqlx/query-836bac47d89113d90bd03a471446eb9016207975af1e37042d81df8cb6ae2c53.json @@ -0,0 +1,40 @@ +{ + "db_name": "PostgreSQL", + "query": "\n INSERT INTO capture_config (workspace_id, path, is_flow, trigger_kind, owner, email)\n VALUES ($1, $2, $3, $4::trigger_kind, $5, $6)\n ", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Varchar", + "Varchar", + "Bool", + { + "Custom": { + "name": "trigger_kind", + "kind": { + "Enum": [ + "webhook", + "http", + "websocket", + "kafka", + "email", + "nats", + "postgres", + "sqs", + "mqtt", + "gcp", + "default_email", + "nextcloud", + "google" + ] + } + } + }, + "Varchar", + "Varchar" + ] + }, + "nullable": [] + }, + "hash": "836bac47d89113d90bd03a471446eb9016207975af1e37042d81df8cb6ae2c53" +} diff --git a/backend/.sqlx/query-87564a196a1662f524407d853db506bf08c28efe82b68b3d44bafbd3d0e91c29.json b/backend/.sqlx/query-87564a196a1662f524407d853db506bf08c28efe82b68b3d44bafbd3d0e91c29.json index 9350442134..5a61f82be3 100644 --- a/backend/.sqlx/query-87564a196a1662f524407d853db506bf08c28efe82b68b3d44bafbd3d0e91c29.json +++ b/backend/.sqlx/query-87564a196a1662f524407d853db506bf08c28efe82b68b3d44bafbd3d0e91c29.json @@ -35,7 +35,8 @@ "mqtt", "gcp", "default_email", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-9238c54d7cf53e2812936d36d98dc3e2d2b1bf4d7884720fafcbb531790f0c64.json b/backend/.sqlx/query-9238c54d7cf53e2812936d36d98dc3e2d2b1bf4d7884720fafcbb531790f0c64.json new file mode 100644 index 0000000000..e82d09a905 --- /dev/null +++ b/backend/.sqlx/query-9238c54d7cf53e2812936d36d98dc3e2d2b1bf4d7884720fafcbb531790f0c64.json @@ -0,0 +1,15 @@ +{ + "db_name": "PostgreSQL", + "query": "UPDATE websocket_trigger SET error = NULL WHERE workspace_id = $1 AND path = $2", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Text", + "Text" + ] + }, + "nullable": [] + }, + "hash": "9238c54d7cf53e2812936d36d98dc3e2d2b1bf4d7884720fafcbb531790f0c64" +} diff --git a/backend/.sqlx/query-940b6d78bab940a37a42492f030d2393e297043e4e58555d872b5c4dd89c196a.json b/backend/.sqlx/query-940b6d78bab940a37a42492f030d2393e297043e4e58555d872b5c4dd89c196a.json new file mode 100644 index 0000000000..09aadbda1e --- /dev/null +++ b/backend/.sqlx/query-940b6d78bab940a37a42492f030d2393e297043e4e58555d872b5c4dd89c196a.json @@ -0,0 +1,38 @@ +{ + "db_name": "PostgreSQL", + "query": "\n UPDATE capture_config SET last_client_ping = NOW()\n WHERE workspace_id = $1 AND path = $2 AND is_flow = $3 AND trigger_kind = $4::trigger_kind\n ", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Text", + "Text", + "Bool", + { + "Custom": { + "name": "trigger_kind", + "kind": { + "Enum": [ + "webhook", + "http", + "websocket", + "kafka", + "email", + "nats", + "postgres", + "sqs", + "mqtt", + "gcp", + "default_email", + "nextcloud", + "google" + ] + } + } + } + ] + }, + "nullable": [] + }, + "hash": "940b6d78bab940a37a42492f030d2393e297043e4e58555d872b5c4dd89c196a" +} diff --git a/backend/.sqlx/query-97c60a4193a75b611db41543e7fe6da81fc631cc6ac43576f8a18afedad4d4a4.json b/backend/.sqlx/query-97c60a4193a75b611db41543e7fe6da81fc631cc6ac43576f8a18afedad4d4a4.json new file mode 100644 index 0000000000..b5c19d2017 --- /dev/null +++ b/backend/.sqlx/query-97c60a4193a75b611db41543e7fe6da81fc631cc6ac43576f8a18afedad4d4a4.json @@ -0,0 +1,22 @@ +{ + "db_name": "PostgreSQL", + "query": "\n INSERT INTO nats_trigger (\n path, nats_resource_path, subjects, script_path,\n is_flow, workspace_id, edited_by, email, use_jetstream\n )\n VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9)\n ", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Varchar", + "Varchar", + "VarcharArray", + "Varchar", + "Bool", + "Varchar", + "Varchar", + "Varchar", + "Bool" + ] + }, + "nullable": [] + }, + "hash": "97c60a4193a75b611db41543e7fe6da81fc631cc6ac43576f8a18afedad4d4a4" +} diff --git a/backend/.sqlx/query-9c50e3a136a8ee3ec56e083f26d3a960b89e02ec40b292f3b5198baf2a1d3dbf.json b/backend/.sqlx/query-9c50e3a136a8ee3ec56e083f26d3a960b89e02ec40b292f3b5198baf2a1d3dbf.json index 9759bad4d4..66a487695f 100644 --- a/backend/.sqlx/query-9c50e3a136a8ee3ec56e083f26d3a960b89e02ec40b292f3b5198baf2a1d3dbf.json +++ b/backend/.sqlx/query-9c50e3a136a8ee3ec56e083f26d3a960b89e02ec40b292f3b5198baf2a1d3dbf.json @@ -32,7 +32,8 @@ "mqtt", "gcp", "default_email", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-9c7580fb38351518cb57ed6207495a7e6e17b49e4315a8ed0e36bfee16f49929.json b/backend/.sqlx/query-9c7580fb38351518cb57ed6207495a7e6e17b49e4315a8ed0e36bfee16f49929.json new file mode 100644 index 0000000000..d4c9ce7f56 --- /dev/null +++ b/backend/.sqlx/query-9c7580fb38351518cb57ed6207495a7e6e17b49e4315a8ed0e36bfee16f49929.json @@ -0,0 +1,23 @@ +{ + "db_name": "PostgreSQL", + "query": "SELECT error FROM websocket_trigger WHERE workspace_id = $1 AND path = $2", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "error", + "type_info": "Text" + } + ], + "parameters": { + "Left": [ + "Text", + "Text" + ] + }, + "nullable": [ + true + ] + }, + "hash": "9c7580fb38351518cb57ed6207495a7e6e17b49e4315a8ed0e36bfee16f49929" +} diff --git a/backend/.sqlx/query-9ecb404e46a4eac55f977f05a3afbafe5dc3cdecc17a3d5a7476b160c1b6e7e1.json b/backend/.sqlx/query-9ecb404e46a4eac55f977f05a3afbafe5dc3cdecc17a3d5a7476b160c1b6e7e1.json index 79c8f0b45d..b6fe1b7fa0 100644 --- a/backend/.sqlx/query-9ecb404e46a4eac55f977f05a3afbafe5dc3cdecc17a3d5a7476b160c1b6e7e1.json +++ b/backend/.sqlx/query-9ecb404e46a4eac55f977f05a3afbafe5dc3cdecc17a3d5a7476b160c1b6e7e1.json @@ -30,7 +30,8 @@ "sqs", "gcp", "mqtt", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-a1745a4f525b251d2f5a602ab2b2ede46b4471e21b11f607573a844013911abe.json b/backend/.sqlx/query-a1745a4f525b251d2f5a602ab2b2ede46b4471e21b11f607573a844013911abe.json index a25f845f91..33636da608 100644 --- a/backend/.sqlx/query-a1745a4f525b251d2f5a602ab2b2ede46b4471e21b11f607573a844013911abe.json +++ b/backend/.sqlx/query-a1745a4f525b251d2f5a602ab2b2ede46b4471e21b11f607573a844013911abe.json @@ -155,7 +155,8 @@ "sqs", "gcp", "mqtt", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-a4b6371d33206010b2f3ffd2b09e33244fe8ab9a803248fc23f334034d24aad4.json b/backend/.sqlx/query-a4b6371d33206010b2f3ffd2b09e33244fe8ab9a803248fc23f334034d24aad4.json index da6d213748..03ee58ca3f 100644 --- a/backend/.sqlx/query-a4b6371d33206010b2f3ffd2b09e33244fe8ab9a803248fc23f334034d24aad4.json +++ b/backend/.sqlx/query-a4b6371d33206010b2f3ffd2b09e33244fe8ab9a803248fc23f334034d24aad4.json @@ -185,7 +185,8 @@ "sqs", "gcp", "mqtt", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-a9ce39c0327607a1523424c838858fce213ef8976e3ffdc3b4bd88e92799e0af.json b/backend/.sqlx/query-a9ce39c0327607a1523424c838858fce213ef8976e3ffdc3b4bd88e92799e0af.json new file mode 100644 index 0000000000..2b376b621a --- /dev/null +++ b/backend/.sqlx/query-a9ce39c0327607a1523424c838858fce213ef8976e3ffdc3b4bd88e92799e0af.json @@ -0,0 +1,52 @@ +{ + "db_name": "PostgreSQL", + "query": "\n SELECT postgres_resource_path, replication_slot_name, publication_name, mode AS \"mode: String\"\n FROM postgres_trigger\n WHERE workspace_id = $1 AND path = $2\n ", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "postgres_resource_path", + "type_info": "Varchar" + }, + { + "ordinal": 1, + "name": "replication_slot_name", + "type_info": "Varchar" + }, + { + "ordinal": 2, + "name": "publication_name", + "type_info": "Varchar" + }, + { + "ordinal": 3, + "name": "mode: String", + "type_info": { + "Custom": { + "name": "trigger_mode", + "kind": { + "Enum": [ + "enabled", + "disabled", + "suspended" + ] + } + } + } + } + ], + "parameters": { + "Left": [ + "Text", + "Text" + ] + }, + "nullable": [ + false, + false, + false, + false + ] + }, + "hash": "a9ce39c0327607a1523424c838858fce213ef8976e3ffdc3b4bd88e92799e0af" +} diff --git a/backend/.sqlx/query-afed809b7dc7dc3c6c5b21c9899f9c46d11f8891807c2dac10b8b7edf72a197e.json b/backend/.sqlx/query-afed809b7dc7dc3c6c5b21c9899f9c46d11f8891807c2dac10b8b7edf72a197e.json new file mode 100644 index 0000000000..513e083511 --- /dev/null +++ b/backend/.sqlx/query-afed809b7dc7dc3c6c5b21c9899f9c46d11f8891807c2dac10b8b7edf72a197e.json @@ -0,0 +1,22 @@ +{ + "db_name": "PostgreSQL", + "query": "SELECT COUNT(*) FROM websocket_trigger WHERE workspace_id = $1 AND mode = 'enabled'::trigger_mode", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "count", + "type_info": "Int8" + } + ], + "parameters": { + "Left": [ + "Text" + ] + }, + "nullable": [ + null + ] + }, + "hash": "afed809b7dc7dc3c6c5b21c9899f9c46d11f8891807c2dac10b8b7edf72a197e" +} diff --git a/backend/.sqlx/query-b3771b690c5966272b1f42c9965bb6a8f961c119516e4c33dc928cd3b4f4edbc.json b/backend/.sqlx/query-b3771b690c5966272b1f42c9965bb6a8f961c119516e4c33dc928cd3b4f4edbc.json index d08af6ffdd..4fa7da00e0 100644 --- a/backend/.sqlx/query-b3771b690c5966272b1f42c9965bb6a8f961c119516e4c33dc928cd3b4f4edbc.json +++ b/backend/.sqlx/query-b3771b690c5966272b1f42c9965bb6a8f961c119516e4c33dc928cd3b4f4edbc.json @@ -160,7 +160,8 @@ "sqs", "gcp", "mqtt", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-b3b161d077e723ce19bdcc0db0683ff3b4c0f0314fdacc417d841e0c88a1f3d1.json b/backend/.sqlx/query-b3b161d077e723ce19bdcc0db0683ff3b4c0f0314fdacc417d841e0c88a1f3d1.json new file mode 100644 index 0000000000..8409d2f932 --- /dev/null +++ b/backend/.sqlx/query-b3b161d077e723ce19bdcc0db0683ff3b4c0f0314fdacc417d841e0c88a1f3d1.json @@ -0,0 +1,23 @@ +{ + "db_name": "PostgreSQL", + "query": "SELECT script_path FROM http_trigger WHERE workspace_id = $1 AND path = $2", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "script_path", + "type_info": "Varchar" + } + ], + "parameters": { + "Left": [ + "Text", + "Text" + ] + }, + "nullable": [ + false + ] + }, + "hash": "b3b161d077e723ce19bdcc0db0683ff3b4c0f0314fdacc417d841e0c88a1f3d1" +} diff --git a/backend/.sqlx/query-b3f0595cacba194e08b9a3e244d9e637e9e156cd85b69126c87dfff89a47711d.json b/backend/.sqlx/query-b3f0595cacba194e08b9a3e244d9e637e9e156cd85b69126c87dfff89a47711d.json index 54a4e3cd93..186822a000 100644 --- a/backend/.sqlx/query-b3f0595cacba194e08b9a3e244d9e637e9e156cd85b69126c87dfff89a47711d.json +++ b/backend/.sqlx/query-b3f0595cacba194e08b9a3e244d9e637e9e156cd85b69126c87dfff89a47711d.json @@ -24,7 +24,8 @@ "mqtt", "gcp", "default_email", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-be6d2c92a62b7b284651c45af809746147aa9b8d0a81642a7b7cb4738a0cad66.json b/backend/.sqlx/query-be6d2c92a62b7b284651c45af809746147aa9b8d0a81642a7b7cb4738a0cad66.json index 0688afebd3..4118760af2 100644 --- a/backend/.sqlx/query-be6d2c92a62b7b284651c45af809746147aa9b8d0a81642a7b7cb4738a0cad66.json +++ b/backend/.sqlx/query-be6d2c92a62b7b284651c45af809746147aa9b8d0a81642a7b7cb4738a0cad66.json @@ -105,7 +105,8 @@ "sqs", "gcp", "mqtt", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-c239d9160efe295ee6e64759dcbbc890d887649eaf72656a8814b0c167645044.json b/backend/.sqlx/query-c239d9160efe295ee6e64759dcbbc890d887649eaf72656a8814b0c167645044.json new file mode 100644 index 0000000000..18e620e999 --- /dev/null +++ b/backend/.sqlx/query-c239d9160efe295ee6e64759dcbbc890d887649eaf72656a8814b0c167645044.json @@ -0,0 +1,46 @@ +{ + "db_name": "PostgreSQL", + "query": "\n SELECT url, script_path, mode AS \"mode: String\"\n FROM websocket_trigger WHERE workspace_id = $1 AND path = $2\n ", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "url", + "type_info": "Varchar" + }, + { + "ordinal": 1, + "name": "script_path", + "type_info": "Varchar" + }, + { + "ordinal": 2, + "name": "mode: String", + "type_info": { + "Custom": { + "name": "trigger_mode", + "kind": { + "Enum": [ + "enabled", + "disabled", + "suspended" + ] + } + } + } + } + ], + "parameters": { + "Left": [ + "Text", + "Text" + ] + }, + "nullable": [ + false, + false, + false + ] + }, + "hash": "c239d9160efe295ee6e64759dcbbc890d887649eaf72656a8814b0c167645044" +} diff --git a/backend/.sqlx/query-c3b1152b554812d65eb27f95b1fd434f860922fbc021185beffb9827647feb8e.json b/backend/.sqlx/query-c3b1152b554812d65eb27f95b1fd434f860922fbc021185beffb9827647feb8e.json index 0098e51ab2..07243717a0 100644 --- a/backend/.sqlx/query-c3b1152b554812d65eb27f95b1fd434f860922fbc021185beffb9827647feb8e.json +++ b/backend/.sqlx/query-c3b1152b554812d65eb27f95b1fd434f860922fbc021185beffb9827647feb8e.json @@ -31,7 +31,8 @@ "mqtt", "gcp", "default_email", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-c659cfe81441bb1b62a9f23f5d9b7f5b1f354b6bb0a78d007114fed084cfe292.json b/backend/.sqlx/query-c659cfe81441bb1b62a9f23f5d9b7f5b1f354b6bb0a78d007114fed084cfe292.json new file mode 100644 index 0000000000..7036bdbb46 --- /dev/null +++ b/backend/.sqlx/query-c659cfe81441bb1b62a9f23f5d9b7f5b1f354b6bb0a78d007114fed084cfe292.json @@ -0,0 +1,21 @@ +{ + "db_name": "PostgreSQL", + "query": "\n INSERT INTO sqs_trigger (\n path, queue_url, aws_resource_path, script_path,\n is_flow, workspace_id, edited_by, email\n )\n VALUES ($1, $2, $3, $4, $5, $6, $7, $8)\n ", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Varchar", + "Varchar", + "Varchar", + "Varchar", + "Bool", + "Varchar", + "Varchar", + "Varchar" + ] + }, + "nullable": [] + }, + "hash": "c659cfe81441bb1b62a9f23f5d9b7f5b1f354b6bb0a78d007114fed084cfe292" +} diff --git a/backend/.sqlx/query-ccef7a1bde5cac6c362c5fedb6c13f1f882b695f896f94e5cf91d205633355a1.json b/backend/.sqlx/query-ccef7a1bde5cac6c362c5fedb6c13f1f882b695f896f94e5cf91d205633355a1.json index 5091b2fc69..2b39145512 100644 --- a/backend/.sqlx/query-ccef7a1bde5cac6c362c5fedb6c13f1f882b695f896f94e5cf91d205633355a1.json +++ b/backend/.sqlx/query-ccef7a1bde5cac6c362c5fedb6c13f1f882b695f896f94e5cf91d205633355a1.json @@ -24,7 +24,8 @@ "mqtt", "gcp", "default_email", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-d41ea93fd58381b89e151c965eae1ea2fe96a1b94f5a92953fb1c1642d15c016.json b/backend/.sqlx/query-d41ea93fd58381b89e151c965eae1ea2fe96a1b94f5a92953fb1c1642d15c016.json index 11271e94d8..9d2f8d9a9f 100644 --- a/backend/.sqlx/query-d41ea93fd58381b89e151c965eae1ea2fe96a1b94f5a92953fb1c1642d15c016.json +++ b/backend/.sqlx/query-d41ea93fd58381b89e151c965eae1ea2fe96a1b94f5a92953fb1c1642d15c016.json @@ -105,7 +105,8 @@ "sqs", "gcp", "mqtt", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-d495c94b580fd34d5ae90615ef21a8a9cc35f362197c0766a5787436af141106.json b/backend/.sqlx/query-d495c94b580fd34d5ae90615ef21a8a9cc35f362197c0766a5787436af141106.json index 9cef6500d3..67a38d1904 100644 --- a/backend/.sqlx/query-d495c94b580fd34d5ae90615ef21a8a9cc35f362197c0766a5787436af141106.json +++ b/backend/.sqlx/query-d495c94b580fd34d5ae90615ef21a8a9cc35f362197c0766a5787436af141106.json @@ -25,7 +25,8 @@ "mqtt", "gcp", "default_email", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-d618ff98a2c7aceb6820007411ba7be2968d982ae84fe3294a6d78914afe3ecc.json b/backend/.sqlx/query-d618ff98a2c7aceb6820007411ba7be2968d982ae84fe3294a6d78914afe3ecc.json new file mode 100644 index 0000000000..6e735913c3 --- /dev/null +++ b/backend/.sqlx/query-d618ff98a2c7aceb6820007411ba7be2968d982ae84fe3294a6d78914afe3ecc.json @@ -0,0 +1,52 @@ +{ + "db_name": "PostgreSQL", + "query": "\n SELECT nats_resource_path, subjects, use_jetstream, mode AS \"mode: String\"\n FROM nats_trigger\n WHERE workspace_id = $1 AND path = $2\n ", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "nats_resource_path", + "type_info": "Varchar" + }, + { + "ordinal": 1, + "name": "subjects", + "type_info": "VarcharArray" + }, + { + "ordinal": 2, + "name": "use_jetstream", + "type_info": "Bool" + }, + { + "ordinal": 3, + "name": "mode: String", + "type_info": { + "Custom": { + "name": "trigger_mode", + "kind": { + "Enum": [ + "enabled", + "disabled", + "suspended" + ] + } + } + } + } + ], + "parameters": { + "Left": [ + "Text", + "Text" + ] + }, + "nullable": [ + false, + false, + false, + false + ] + }, + "hash": "d618ff98a2c7aceb6820007411ba7be2968d982ae84fe3294a6d78914afe3ecc" +} diff --git a/backend/.sqlx/query-dc9a906d6c6156a84fccf4e3a2a7c08d8ed4984409b669162f0a1fc1aa48e188.json b/backend/.sqlx/query-dc9a906d6c6156a84fccf4e3a2a7c08d8ed4984409b669162f0a1fc1aa48e188.json new file mode 100644 index 0000000000..03b0c561e1 --- /dev/null +++ b/backend/.sqlx/query-dc9a906d6c6156a84fccf4e3a2a7c08d8ed4984409b669162f0a1fc1aa48e188.json @@ -0,0 +1,15 @@ +{ + "db_name": "PostgreSQL", + "query": "DELETE FROM http_trigger WHERE workspace_id = $1 AND path = $2", + "describe": { + "columns": [], + "parameters": { + "Left": [ + "Text", + "Text" + ] + }, + "nullable": [] + }, + "hash": "dc9a906d6c6156a84fccf4e3a2a7c08d8ed4984409b669162f0a1fc1aa48e188" +} diff --git a/backend/.sqlx/query-e4d71278fb80126a7a9da73f1889352d4d1e3cb3a8a08f1c9c03055a1cab1235.json b/backend/.sqlx/query-e4d71278fb80126a7a9da73f1889352d4d1e3cb3a8a08f1c9c03055a1cab1235.json index 5b07bcd9c9..7309b03a02 100644 --- a/backend/.sqlx/query-e4d71278fb80126a7a9da73f1889352d4d1e3cb3a8a08f1c9c03055a1cab1235.json +++ b/backend/.sqlx/query-e4d71278fb80126a7a9da73f1889352d4d1e3cb3a8a08f1c9c03055a1cab1235.json @@ -185,7 +185,8 @@ "sqs", "gcp", "mqtt", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-e5d1963829e06bfcfe413a583d229714291ce0901b757e8c799c7a6d1021c679.json b/backend/.sqlx/query-e5d1963829e06bfcfe413a583d229714291ce0901b757e8c799c7a6d1021c679.json new file mode 100644 index 0000000000..8fcc14cf15 --- /dev/null +++ b/backend/.sqlx/query-e5d1963829e06bfcfe413a583d229714291ce0901b757e8c799c7a6d1021c679.json @@ -0,0 +1,29 @@ +{ + "db_name": "PostgreSQL", + "query": "SELECT owner, email FROM capture_config WHERE workspace_id = $1 AND path = $2", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "owner", + "type_info": "Varchar" + }, + { + "ordinal": 1, + "name": "email", + "type_info": "Varchar" + } + ], + "parameters": { + "Left": [ + "Text", + "Text" + ] + }, + "nullable": [ + false, + false + ] + }, + "hash": "e5d1963829e06bfcfe413a583d229714291ce0901b757e8c799c7a6d1021c679" +} diff --git a/backend/.sqlx/query-e80177f3ffd4c1f52cdb4757483f03f72ef81db302d727e18e63a307ac902022.json b/backend/.sqlx/query-e80177f3ffd4c1f52cdb4757483f03f72ef81db302d727e18e63a307ac902022.json index 1e38e57fb5..dd65a586d1 100644 --- a/backend/.sqlx/query-e80177f3ffd4c1f52cdb4757483f03f72ef81db302d727e18e63a307ac902022.json +++ b/backend/.sqlx/query-e80177f3ffd4c1f52cdb4757483f03f72ef81db302d727e18e63a307ac902022.json @@ -31,7 +31,8 @@ "mqtt", "gcp", "default_email", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-eac595e19e5c8e70f1514ef29dec35c7342ac9a814c73f6290e1d6ebd3a55423.json b/backend/.sqlx/query-eac595e19e5c8e70f1514ef29dec35c7342ac9a814c73f6290e1d6ebd3a55423.json index 57607ae052..7c45c44b13 100644 --- a/backend/.sqlx/query-eac595e19e5c8e70f1514ef29dec35c7342ac9a814c73f6290e1d6ebd3a55423.json +++ b/backend/.sqlx/query-eac595e19e5c8e70f1514ef29dec35c7342ac9a814c73f6290e1d6ebd3a55423.json @@ -24,7 +24,8 @@ "mqtt", "gcp", "default_email", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/.sqlx/query-ecb51b6bd85218116e4d02bc92cf1cd0bbecdf51c18b4fc19ab3ef303331d51d.json b/backend/.sqlx/query-ecb51b6bd85218116e4d02bc92cf1cd0bbecdf51c18b4fc19ab3ef303331d51d.json new file mode 100644 index 0000000000..1f440a42ad --- /dev/null +++ b/backend/.sqlx/query-ecb51b6bd85218116e4d02bc92cf1cd0bbecdf51c18b4fc19ab3ef303331d51d.json @@ -0,0 +1,47 @@ +{ + "db_name": "PostgreSQL", + "query": "\n SELECT path, schedule, enabled, script_path, timezone\n FROM schedule\n WHERE workspace_id = $1 AND path = $2\n ", + "describe": { + "columns": [ + { + "ordinal": 0, + "name": "path", + "type_info": "Varchar" + }, + { + "ordinal": 1, + "name": "schedule", + "type_info": "Varchar" + }, + { + "ordinal": 2, + "name": "enabled", + "type_info": "Bool" + }, + { + "ordinal": 3, + "name": "script_path", + "type_info": "Varchar" + }, + { + "ordinal": 4, + "name": "timezone", + "type_info": "Varchar" + } + ], + "parameters": { + "Left": [ + "Text", + "Text" + ] + }, + "nullable": [ + false, + false, + false, + false, + false + ] + }, + "hash": "ecb51b6bd85218116e4d02bc92cf1cd0bbecdf51c18b4fc19ab3ef303331d51d" +} diff --git a/backend/.sqlx/query-ed8facbf29ebb670d05fe8aa34b50d6a6935420fbedc83aa3ad1e9be7465c8dd.json b/backend/.sqlx/query-ed8facbf29ebb670d05fe8aa34b50d6a6935420fbedc83aa3ad1e9be7465c8dd.json index 43fd90abe5..1876db927e 100644 --- a/backend/.sqlx/query-ed8facbf29ebb670d05fe8aa34b50d6a6935420fbedc83aa3ad1e9be7465c8dd.json +++ b/backend/.sqlx/query-ed8facbf29ebb670d05fe8aa34b50d6a6935420fbedc83aa3ad1e9be7465c8dd.json @@ -24,7 +24,8 @@ "mqtt", "gcp", "default_email", - "nextcloud" + "nextcloud", + "google" ] } } diff --git a/backend/tests/worker.rs b/backend/tests/worker.rs index a08f546b24..f206a2ee62 100644 --- a/backend/tests/worker.rs +++ b/backend/tests/worker.rs @@ -917,47 +917,50 @@ fn main(world: String) -> Result { Ok(()) } -// #[sqlx::test(fixtures("base"))] -// async fn test_csharp_job(db: Pool) -> anyhow::Result<()> { -// initialize_tracing().await; -// let server = ApiServer::start(db.clone()).await?; -// let port = server.addr.port(); -// -// let content = r#" -// using System; -// -// class Script -// { -// public static string Main(string world, int b = 2) -// { -// Console.WriteLine($"Hello {world} - {b}. This is a log line"); -// return $"Hello {world} - {b}"; -// } -// } -// "# -// .to_owned(); -// -// let result = RunJob::from(JobPayload::Code(RawCode { -// hash: None, -// content, -// path: None, -// lock: None, -// language: ScriptLang::CSharp, -// custom_concurrency_key: None, -// concurrent_limit: None, -// concurrency_time_window_s: None, -// cache_ttl: None, -// dedicated_worker: None, -// })) -// .arg("world", json!("Arakis")) -// .arg("b", json!(3)) -// .run_until_complete(&db, false, port) -// .await -// .json_result() -// .unwrap(); -// -// assert_eq!(result, serde_json::json!("Hello Arakis - 3")); -// } +#[cfg(feature = "csharp")] +#[sqlx::test(fixtures("base"))] +async fn test_csharp_job(db: Pool) -> anyhow::Result<()> { + initialize_tracing().await; + let server = ApiServer::start(db.clone()).await?; + let port = server.addr.port(); + + let content = r#" +using System; + +class Script +{ + public static string Main(string world, int b = 2) + { + Console.WriteLine($"Hello {world} - {b}. This is a log line"); + return $"Hello {world} - {b}"; + } +} + "# + .to_owned(); + + let result = RunJob::from(JobPayload::Code(RawCode { + hash: None, + content, + path: None, + lock: None, + language: ScriptLang::CSharp, + cache_ttl: None, + cache_ignore_s3_path: None, + dedicated_worker: None, + concurrency_settings: windmill_common::runnable_settings::ConcurrencySettings::default() + .into(), + debouncing_settings: windmill_common::runnable_settings::DebouncingSettings::default(), + })) + .arg("world", json!("Arakis")) + .arg("b", json!(3)) + .run_until_complete(&db, false, port) + .await + .json_result() + .unwrap(); + + assert_eq!(result, serde_json::json!("Hello Arakis - 3")); + Ok(()) +} #[sqlx::test(fixtures("base"))] async fn test_bash_job(db: Pool) -> anyhow::Result<()> { @@ -1334,6 +1337,190 @@ SELECT 'hello ' || $1::text AS result; Ok(()) } +#[cfg(feature = "mysql")] +#[sqlx::test(fixtures("base"))] +async fn test_mysql_job(db: Pool) -> anyhow::Result<()> { + initialize_tracing().await; + let server = ApiServer::start(db.clone()).await?; + let port = server.addr.port(); + + let content = r#" +-- ? name (varchar) +SELECT CONCAT('hello ', ?) AS result; +"# + .to_owned(); + + let result = RunJob::from(JobPayload::Code(RawCode { + hash: None, + content, + path: None, + lock: None, + language: ScriptLang::Mysql, + cache_ttl: None, + cache_ignore_s3_path: None, + dedicated_worker: None, + concurrency_settings: windmill_common::runnable_settings::ConcurrencySettings::default() + .into(), + debouncing_settings: windmill_common::runnable_settings::DebouncingSettings::default(), + })) + .arg("name", json!("world")) + .arg( + "database", + json!({"host": "localhost", "port": 3306, "user": "root", "password": "changeme", "database": "windmill_test"}), + ) + .run_until_complete(&db, false, port) + .await + .json_result() + .unwrap(); + + assert_eq!(result, json!([{"result": "hello world"}])); + Ok(()) +} + +#[sqlx::test(fixtures("base"))] +async fn test_bunnative_job(db: Pool) -> anyhow::Result<()> { + initialize_tracing().await; + let server = ApiServer::start(db.clone()).await?; + let port = server.addr.port(); + + let content = r#" +export async function main(name: string): Promise { + return `hello ${name}`; +} + "# + .to_owned(); + + let result = RunJob::from(JobPayload::Code(RawCode { + hash: None, + content, + path: None, + lock: None, + language: ScriptLang::Bunnative, + cache_ttl: None, + cache_ignore_s3_path: None, + dedicated_worker: None, + concurrency_settings: windmill_common::runnable_settings::ConcurrencySettings::default() + .into(), + debouncing_settings: windmill_common::runnable_settings::DebouncingSettings::default(), + })) + .arg("name", json!("world")) + .run_until_complete(&db, false, port) + .await + .json_result() + .unwrap(); + + assert_eq!(result, serde_json::json!("hello world")); + Ok(()) +} + +#[sqlx::test(fixtures("base"))] +async fn test_powershell_job(db: Pool) -> anyhow::Result<()> { + initialize_tracing().await; + let server = ApiServer::start(db.clone()).await?; + let port = server.addr.port(); + + let content = r#" +param($msg) +Write-Output "hello $msg" +"# + .to_owned(); + + let job = RunJob::from(JobPayload::Code(RawCode { + hash: None, + content, + path: None, + lock: None, + language: ScriptLang::Powershell, + cache_ttl: None, + cache_ignore_s3_path: None, + dedicated_worker: None, + concurrency_settings: windmill_common::runnable_settings::ConcurrencySettings::default() + .into(), + debouncing_settings: windmill_common::runnable_settings::DebouncingSettings::default(), + })) + .arg("msg", json!("world")) + .run_until_complete(&db, false, port) + .await; + assert_eq!(job.json_result(), Some(json!("hello world"))); + Ok(()) +} + +#[cfg(feature = "php")] +#[sqlx::test(fixtures("base"))] +async fn test_php_job(db: Pool) -> anyhow::Result<()> { + initialize_tracing().await; + let server = ApiServer::start(db.clone()).await?; + let port = server.addr.port(); + + let content = r#" +) -> anyhow::Result<()> { + initialize_tracing().await; + let server = ApiServer::start(db.clone()).await?; + let port = server.addr.port(); + + let content = r#" +def main(name:) + "hello #{name}" +end +"# + .to_owned(); + + let result = RunJob::from(JobPayload::Code(RawCode { + hash: None, + content, + path: None, + lock: None, + language: ScriptLang::Ruby, + cache_ttl: None, + cache_ignore_s3_path: None, + dedicated_worker: None, + concurrency_settings: windmill_common::runnable_settings::ConcurrencySettings::default() + .into(), + debouncing_settings: windmill_common::runnable_settings::DebouncingSettings::default(), + })) + .arg("name", json!("world")) + .run_until_complete(&db, false, port) + .await + .json_result() + .unwrap(); + + assert_eq!(result, serde_json::json!("hello world")); + Ok(()) +} + #[sqlx::test(fixtures("base"))] async fn test_bun_job_datetime(db: Pool) -> anyhow::Result<()> { initialize_tracing().await;