add @spinframework/spin-trigger-redis package

Signed-off-by: karthik2804 <[email protected]>

Author: karthik2804

package-lock.json

@@ -0,0 +1,28 @@
+{
+  "name": "@spinframework/spin-trigger-redis",
+  "version": "1.0.0",
+  "description": "",
+  "main": "dist/index.js",
+  "types": "dist/index.d.ts",
+  "type": "module",
+  "scripts": {
+    "build": "tsc"
+  },
+  "keywords": [],
+  "author": "",
+  "license": "Apache-2.0",
+  "devDependencies": {
+    "typescript": "^5.7.3"
+  },
+  "config": {
+    "wasiDep": {
+      "witDeps": [
+        {
+          "witPath": "./wit",
+          "package": "fermyon:spin",
+          "world": "spin-trigger-redis"
+        }
+      ]
+    }
+  }
+}

packages/spin-trigger-redis/package.json

@@ -0,0 +1,11 @@
+/**
+ * Abstract class for handling Redis messages.
+ */
+export abstract class RedisHandler {
+    /**
+     * Handles a Redis message.
+     * @param msg - The message data as a Uint8Array.
+     * @returns A Promise that resolves when the message has been handled.
+     */
+    abstract handleMessage(msg: Uint8Array): Promise<void>;
+}

packages/spin-trigger-redis/src/index.ts

@@ -0,0 +1,19 @@
+{
+    "compilerOptions": {
+        "target": "ES2020",
+        "module": "ES2020",
+        "lib": [
+            "ES2020",
+            "WebWorker"
+        ],
+        "moduleResolution": "node",
+        "declaration": true,
+        "outDir": "dist",
+        "strict": true,
+        "esModuleInterop": true,
+    },
+    "exclude": [
+        "node_modules",
+        "dist"
+    ]
+}

packages/spin-trigger-redis/tsconfig.json

@@ -0,0 +1,24 @@
+interface redis-types {
+  // General purpose error.
+  enum error {
+      success,
+      error,
+  }
+
+  /// The message payload.
+  type payload = list<u8>;
+
+  /// A parameter type for the general-purpose `execute` function.
+  variant redis-parameter {
+      int64(s64),
+      binary(payload)
+  }
+
+  /// A return type for the general-purpose `execute` function.
+  variant redis-result {
+      nil,
+      status(string),
+      int64(s64),
+      binary(payload)
+  }
+}

packages/spin-trigger-redis/wit/redis-types.wit

@@ -0,0 +1,12 @@
+package fermyon:spin;
+
+interface inbound-redis {
+  use redis-types.{payload, error};
+
+  // The entrypoint for a Redis handler.
+  handle-message: func(message: payload) -> result<_, error>;
+}
+
+world spin-trigger-redis {
+  export inbound-redis;
+}