Basic test module

Author: coolreader18

crates/bindings-typescript/src/lib/binary_reader.ts

@@ -158,9 +158,6 @@ export default class BinaryReader {
 
   readString(): string {
     const uint8Array = this.readUInt8Array();
-    const decoder = new TextDecoder('utf-8');
-    const value = decoder.decode(uint8Array);
-    this.#offset += length;
-    return value;
+    return new TextDecoder('utf-8').decode(uint8Array);
   }
 }

crates/bindings-typescript/src/server/rt.ts

@@ -146,6 +146,13 @@ const _syscalls = () => ({
 });
 
 const sys = {} as ReturnType<typeof _syscalls>;
+function initSys() {
+  if (Object.isFrozen(sys)) return;
+  for (const [name, syscall] of Object.entries(_syscalls())) {
+    (sys as any)[name] = wrapSyscall(syscall);
+  }
+  freeze(sys);
+}
 
 globalThis.__call_reducer__ = function __call_reducer__(
   reducer_id,
@@ -154,6 +161,7 @@ globalThis.__call_reducer__ = function __call_reducer__(
   timestamp,
   args_buf
 ) {
+  initSys();
   const args_type = AlgebraicType.Product(
     MODULE_DEF.reducers[reducer_id].params
   );
@@ -171,11 +179,7 @@ globalThis.__call_reducer__ = function __call_reducer__(
 };
 
 globalThis.__describe_module__ = function __describe_module__() {
-  for (const [name, syscall] of Object.entries(_syscalls())) {
-    (sys as any)[name] = wrapSyscall(syscall);
-  }
-  freeze(sys);
-
+  initSys();
   return RawModuleDef.V9(MODULE_DEF);
 };
 

crates/core/src/host/v8/mod.rs

@@ -421,12 +421,12 @@ pub(crate) fn with_scope<R>(
         logic(scope)
     };
 
-    let timeout_thread_cancel_flag = run_reducer_timeout(callback_every, callback, budget, isolate_handle);
+    // let timeout_thread_cancel_flag = run_reducer_timeout(callback_every, callback, budget, isolate_handle);
 
     let ret = with_isolate(&mut isolate);
 
     // Cancel the execution timeout in `run_reducer_timeout`.
-    timeout_thread_cancel_flag.store(true, Ordering::Relaxed);
+    // timeout_thread_cancel_flag.store(true, Ordering::Relaxed);
 
     (isolate, ret)
 }
@@ -542,7 +542,7 @@ fn call_call_reducer(
         let sender = serialize_to_js(scope, &sender.to_u256())?;
         let conn_id: v8::Local<'_, v8::Value> = serialize_to_js(scope, &conn_id.to_u128())?;
         let timestamp = serialize_to_js(scope, &timestamp)?;
-        let reducer_args = serialize_to_js(scope, &reducer_args.tuple.elements)?;
+        let reducer_args = serialize_to_js(scope, reducer_args.get_bsatn())?;
         let args = &[reducer_id, sender, conn_id, timestamp, reducer_args];
 
         // Get the function on the global proxy object and convert to a function.

modules/module-test-ts/index.ts

@@ -0,0 +1,32 @@
+import 'fast-text-encoding';
+import { schema, table, t } from '../../sdks/typescript/src/server';
+
+const spacetime = schema(
+  table(
+    {
+      name: 'person',
+      public: true,
+      indexes: [{ name: 'age', algorithm: 'btree', columns: ['age'] }],
+    },
+    {
+      id: t.u32().primaryKey().autoInc(),
+      name: t.string(),
+      age: t.u8(),
+    }
+  )
+);
+
+spacetime.reducer(
+  'add',
+  { name: t.string(), age: t.u8() },
+  (ctx, { name, age }) => {
+    ctx.db.person.insert({ id: 0, name, age });
+  }
+);
+
+spacetime.reducer('say_hello', {}, ctx => {
+  for (const person of ctx.db.person.iter()) {
+    console.log(`Hello, ${person.name}}!`);
+  }
+  console.log('Hello, World!');
+});

modules/module-test-ts/package.json

@@ -0,0 +1,15 @@
+{
+  "name": "sdk-test-module",
+  "license": "ISC",
+  "type": "module",
+  "sideEffects": false,
+  "scripts": {
+    "build": "tsup"
+  },
+  "dependencies": {
+    "fast-text-encoding": "^1.0.0"
+  },
+  "devDependencies": {
+    "tsup": "^8.1.0"
+  }
+}

modules/module-test-ts/tsup.config.ts

@@ -0,0 +1,28 @@
+// tsup.config.ts
+import { defineConfig, type Options } from 'tsup';
+
+const outExtension = (ctx: { format: string }) => ({
+  js: ctx.format === 'cjs' ? '.cjs' : ctx.format === 'esm' ? '.mjs' : '.js',
+});
+
+export default defineConfig([
+  {
+    entry: { index: 'index.ts' },
+    format: ['esm'],
+    target: 'es2022',
+    outDir: 'dist',
+    dts: false,
+    sourcemap: true,
+    clean: true,
+    platform: 'neutral', // flip to 'node' if you actually rely on Node builtins
+    treeshake: 'smallest',
+    external: ['undici'],
+    noExternal: ['base64-js', 'fast-text-encoding'],
+    outExtension,
+  },
+]) satisfies
+  | Options
+  | Options[]
+  | ((
+      overrideOptions: Options
+    ) => Options | Options[] | Promise<Options | Options[]>);

pnpm-lock.yaml

@@ -2,4 +2,5 @@ packages:
   - 'crates/bindings-typescript'
   - 'crates/bindings-typescript/test-app'
   - 'crates/bindings-typescript/examples/quickstart-chat'
-  - 'docs'
+  - 'modules/module-test-ts'
+  - 'docs'