Skip to content

Commit

Permalink
add outbound redis example
Browse files Browse the repository at this point in the history
Signed-off-by: karthik2804 <karthik.ganeshram@fermyon.com>
  • Loading branch information
karthik2804 committed Jul 22, 2024
1 parent 534edb0 commit d1f1f35
Show file tree
Hide file tree
Showing 9 changed files with 180 additions and 1 deletion.
23 changes: 23 additions & 0 deletions examples/typescript/spin-host-apis/spin-redis/README.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,23 @@
# Using Spin Outbound Redis

This example showcases using outbound Redis using the Spin SDK.

## Install Dependencies
Install the necessary npm packages:

```bash
npm install
```

## Prerequisites

- A Redis server is running at `localhost:6379`

## Building and Running the Example

```bash
spin build
spin up
```

Use e.g. `curl -v http://127.0.0.1:3000/` to test the endpoint.
14 changes: 14 additions & 0 deletions examples/typescript/spin-host-apis/spin-redis/knitwit.json
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
{
"version": 1,
"project": {
"worlds": [
"spin-http"
]
},
"packages": {
"@fermyon/spin-sdk": {
"witPath": "../../bin/wit",
"world": "spin-imports"
}
}
}
23 changes: 23 additions & 0 deletions examples/typescript/spin-host-apis/spin-redis/package.json
Original file line number Diff line number Diff line change
@@ -0,0 +1,23 @@
{
"name": "spin-redis",
"version": "1.0.0",
"description": "",
"main": "index.js",
"scripts": {
"build": "npx webpack --mode=production && npx mkdirp target && npx j2w -i dist.js -n spin-http -o target/spin-redis.wasm",
"test": "echo \"Error: no test specified\" && exit 1"
},
"keywords": [],
"author": "",
"license": "ISC",
"devDependencies": {
"mkdirp": "^3.0.1",
"ts-loader": "^9.4.1",
"typescript": "^4.8.4",
"webpack": "^5.74.0",
"webpack-cli": "^4.10.0"
},
"dependencies": {
"@fermyon/spin-sdk": "^2.0.0-alpha.3"
}
}
19 changes: 19 additions & 0 deletions examples/typescript/spin-host-apis/spin-redis/spin.toml
Original file line number Diff line number Diff line change
@@ -0,0 +1,19 @@
spin_manifest_version = 2

[application]
authors = ["karthik2804 <karthik.ganeshram@fermyon.com>"]
description = ""
name = "spin-redis"
version = "0.1.0"

[[trigger.http]]
route = "/..."
component = "spin-redis"

[component.spin-redis]
source = "target/spin-redis.wasm"
exclude_files = ["**/node_modules"]
allowed_hosts = ["redis://*:*"]
[component.spin-redis.build]
command = "npm run build"
watch = ["src/**/*.ts", "package.json"]
25 changes: 25 additions & 0 deletions examples/typescript/spin-host-apis/spin-redis/src/index.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
import { ResponseBuilder, Redis } from "@fermyon/spin-sdk";

const encoder = new TextEncoder()
const decoder = new TextDecoder()
const redisAddress = "redis://localhost:6379/"

export async function handler(_req: Request, res: ResponseBuilder) {

try {
let db = Redis.open(redisAddress)
db.set("test", encoder.encode("Hello world"))
let val = db.get("test")

if (!val) {
res.status(404)
res.send()
return
}

res.send(val)
} catch (e: any) {
res.status(500)
res.send(`Error: ${JSON.stringify(e.payload)}`)
}
}
22 changes: 22 additions & 0 deletions examples/typescript/spin-host-apis/spin-redis/src/spin.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,22 @@
import { ResponseBuilder } from "@fermyon/spin-sdk";
import { handler } from ".";

//@ts-ignore
addEventListener('fetch', (event: FetchEvent) => {
handleEvent(event);
});

async function handleEvent(event: FetchEvent) {

let resolve: any, reject: any;
let responsePromise = new Promise(async (res, rej) => {
resolve = res;
reject = rej;
});
//@ts-ignore
event.respondWith(responsePromise);

let res = new ResponseBuilder(resolve);

await handler(event.request, res)
}
18 changes: 18 additions & 0 deletions examples/typescript/spin-host-apis/spin-redis/tsconfig.json
Original file line number Diff line number Diff line change
@@ -0,0 +1,18 @@
{
"compilerOptions": {
"outDir": "./dist/",
"noImplicitAny": true,
"module": "es6",
"target": "es2020",
"jsx": "react",
"skipLibCheck": true,
"lib": [
"ES2015",
"WebWorker"
],
"allowJs": true,
"strict": true,
"noImplicitReturns": true,
"moduleResolution": "node"
}
}
35 changes: 35 additions & 0 deletions examples/typescript/spin-host-apis/spin-redis/webpack.config.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,35 @@
const path = require('path');
const SpinSdkPlugin = require("@fermyon/spin-sdk/plugins/webpack")

module.exports = {
entry: './src/spin.ts',
experiments: {
outputModule: true,
},
module: {
rules: [
{
test: /\.tsx?$/,
use: 'ts-loader',
exclude: /node_modules/,
},
],
},
resolve: {
extensions: ['.tsx', '.ts', '.js'],
},
output: {
path: path.resolve(__dirname, './'),
filename: 'dist.js',
module: true,
library: {
type: "module",
}
},
plugins: [
new SpinSdkPlugin()
],
optimization: {
minimize: false
},
};
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
"description": "",
"main": "index.js",
"scripts": {
"build": "npx webpack --mode=production && npx mkdirp target && npx j2w -i dist.js -n spin-http -o target/octokit-rest.wasm",
"build": "npx webpack --mode=production && npx mkdirp target && npx j2w -i dist.js -n spin-http -o target/spin-variables.wasm",
"test": "echo \"Error: no test specified\" && exit 1"
},
"keywords": [],
Expand Down

0 comments on commit d1f1f35

Please sign in to comment.