typescript module

Author: joshua-spacetime

modules/sdk-test-procedural-view-pk-ts/.npmrc

@@ -0,0 +1 @@
+minimum-release-age=1440

modules/sdk-test-procedural-view-pk-ts/package.json

@@ -0,0 +1,14 @@
+{
+  "name": "sdk-test-procedural-view-pk-ts",
+  "version": "1.0.0",
+  "license": "ISC",
+  "type": "module",
+  "scripts": {
+    "build": "cargo build -p spacetimedb-standalone && cargo run -p spacetimedb-cli -- build",
+    "generate-ts": "cargo build -p spacetimedb-standalone && cargo run -p spacetimedb-cli -- generate --lang typescript --out-dir ts-codegen",
+    "publish": "cargo run -p spacetimedb-cli -- publish"
+  },
+  "dependencies": {
+    "spacetimedb": "workspace:^"
+  }
+}

modules/sdk-test-procedural-view-pk-ts/src/index.ts

@@ -0,0 +1,58 @@
+import { schema, t, table } from 'spacetimedb/server';
+
+const LeftSource = t.row('LeftSource', {
+  id: t.u64().primaryKey(),
+  sender: t.identity().index('btree'),
+  filter: t.u64(),
+});
+
+const RightSource = t.row('RightSource', {
+  id: t.u64().primaryKey(),
+  sender: t.identity().index('btree'),
+  filter: t.u64(),
+});
+
+const left_source = table({ public: true }, LeftSource);
+const right_source = table({ public: true }, RightSource);
+
+const spacetimedb = schema({ left_source, right_source });
+export default spacetimedb;
+
+export const insert_left = spacetimedb.reducer(
+  { id: t.u64(), filter: t.u64() },
+  (ctx, { id, filter }) => {
+    ctx.db.left_source.insert({ id, sender: ctx.sender, filter });
+  }
+);
+
+export const update_left = spacetimedb.reducer(
+  { id: t.u64(), filter: t.u64() },
+  (ctx, { id, filter }) => {
+    ctx.db.left_source.id.update({ id, sender: ctx.sender, filter });
+  }
+);
+
+export const insert_right = spacetimedb.reducer(
+  { id: t.u64(), filter: t.u64() },
+  (ctx, { id, filter }) => {
+    ctx.db.right_source.insert({ id, sender: ctx.sender, filter });
+  }
+);
+
+export const sender_left_view = spacetimedb.view(
+  { public: true },
+  t.array(left_source.rowType),
+  ctx =>
+    Array.from(ctx.db.left_source.iter()).filter(row =>
+      row.sender.isEqual(ctx.sender)
+    )
+);
+
+export const sender_right_view = spacetimedb.view(
+  { public: true },
+  t.array(right_source.rowType),
+  ctx =>
+    Array.from(ctx.db.right_source.iter()).filter(row =>
+      row.sender.isEqual(ctx.sender)
+    )
+);

modules/sdk-test-procedural-view-pk-ts/tsconfig.json

@@ -0,0 +1,26 @@
+{
+  "compilerOptions": {
+    "target": "ESNext",
+    "module": "ESNext",
+
+    "strict": true,
+    "declaration": false,
+    "emitDeclarationOnly": false,
+    "noEmit": true,
+    "skipLibCheck": true,
+    "forceConsistentCasingInFileNames": true,
+    "allowImportingTsExtensions": true,
+    "noImplicitAny": true,
+    "moduleResolution": "Bundler",
+    "isolatedDeclarations": false,
+
+    "esModuleInterop": false,
+    "allowSyntheticDefaultImports": false,
+    "useDefineForClassFields": true,
+
+    "verbatimModuleSyntax": true,
+    "isolatedModules": true
+  },
+  "include": ["src/index.ts"],
+  "exclude": ["node_modules", "dist/**/*"]
+}

pnpm-lock.yaml

@@ -19,6 +19,7 @@ packages:
   - 'templates/chat-react-ts/spacetimedb'
   - 'modules/sdk-test-connect-disconnect-ts'
   - 'modules/sdk-test-procedure-ts'
+  - 'modules/sdk-test-procedural-view-pk-ts'
   - 'modules/sdk-test-ts'
   - 'modules/sdk-test-case-conversion-ts'
   - 'docs'

pnpm-workspace.yaml

@@ -215,9 +215,9 @@ async fn exec_view_pk_right_semijoin(db_name: &str) {
 
 pub async fn dispatch(test: &str, db_name: &str) {
     match test {
-        "sender-procedural-view-pk-updates-are-scoped" => exec_sender_scoped_pk_view(db_name).await,
-        "procedural-view-pk-left-semijoin-query-builder" => exec_view_pk_left_semijoin(db_name).await,
-        "procedural-view-pk-right-semijoin-query-builder" => exec_view_pk_right_semijoin(db_name).await,
+        "sender-scoped-pk-view" => exec_sender_scoped_pk_view(db_name).await,
+        "view-pk-left-semijoin" => exec_view_pk_left_semijoin(db_name).await,
+        "view-pk-right-semijoin" => exec_view_pk_right_semijoin(db_name).await,
         _ => panic!("Unknown test: {test}"),
     }
 }

sdks/rust/tests/procedural-view-pk-client/src/test_handlers.rs

@@ -769,33 +769,40 @@ macro_rules! view_pk_tests {
 view_pk_tests!(rust_view_pk, "");
 view_pk_tests!(csharp_view_pk, "-cs");
 
-mod rust_procedural_view_pk {
-    use spacetimedb_testing::sdk::Test;
+macro_rules! procedural_view_pk_tests {
+    ($mod_name:ident, $module:literal) => {
+        mod $mod_name {
+            use spacetimedb_testing::sdk::Test;
 
-    const MODULE: &str = "sdk-test-procedural-view-pk";
-    const CLIENT: &str = concat!(env!("CARGO_MANIFEST_DIR"), "/tests/procedural-view-pk-client");
+            const MODULE: &str = $module;
+            const CLIENT: &str = concat!(env!("CARGO_MANIFEST_DIR"), "/tests/procedural-view-pk-client");
 
-    fn make_test(subcommand: &str) -> Test {
-        super::platform_test_builder(CLIENT, Some(subcommand))
-            .with_name(subcommand)
-            .with_module(MODULE)
-            .with_language("rust")
-            .with_bindings_dir("src/module_bindings")
-            .build()
-    }
+            fn make_test(subcommand: &str) -> Test {
+                super::platform_test_builder(CLIENT, Some(subcommand))
+                    .with_name(subcommand)
+                    .with_module(MODULE)
+                    .with_language("rust")
+                    .with_bindings_dir("src/module_bindings")
+                    .build()
+            }
 
-    #[test]
-    fn sender_procedural_view_with_pk_scopes_updates_by_sender() {
-        make_test("sender-procedural-view-pk-updates-are-scoped").run()
-    }
+            #[test]
+            fn sender_scoped_procedural_pk_view() {
+                make_test("sender-scoped-pk-view").run()
+            }
 
-    #[test]
-    fn procedural_view_pk_left_semijoin_query_builder() {
-        make_test("procedural-view-pk-left-semijoin-query-builder").run()
-    }
+            #[test]
+            fn procedural_view_pk_left_semijoin() {
+                make_test("view-pk-left-semijoin").run()
+            }
 
-    #[test]
-    fn procedural_view_pk_right_semijoin_query_builder() {
-        make_test("procedural-view-pk-right-semijoin-query-builder").run()
-    }
+            #[test]
+            fn procedural_view_pk_right_semijoin() {
+                make_test("view-pk-right-semijoin").run()
+            }
+        }
+    };
 }
+
+procedural_view_pk_tests!(rust_procedural_view_pk, "sdk-test-procedural-view-pk");
+procedural_view_pk_tests!(typescript_procedural_view_pk, "sdk-test-procedural-view-pk-ts");