Merge pull request #29 from fermyon/add-fwaffic-demo

import traffic splitting demo from FWaFfic repo

Author: itowlson

README.md

@@ -18,6 +18,7 @@
 - [Cookie Parsing](./samples/parse-cookie/)
 - [Traffic Filtering: Block By IP address](./samples/block-by-ip/)
 - [Traffic Filtering: Block By user country](./samples/block-by-country/)
+- [Traffic mirroring and splitting](./samples/traffic-splitting/)
 - [Reading the Body of a POST Request](./samples/read-post/)
 - [Respond with Another Site](./samples/respond-with-another-site/)
 - [Response Header Modification](./samples/response-header-modification/)

samples/traffic-splitting/.gitignore

@@ -0,0 +1,5 @@
+*.wasm
+.spin/
+node_modules/
+.DS_Store
+.spin-aka/

samples/traffic-splitting/api/.gitignore

@@ -0,0 +1,5 @@
+node_modules
+dist
+target
+.spin/
+build/

samples/traffic-splitting/api/.npmrc

@@ -0,0 +1 @@
+KNITWIT_SOURCE=./config/knitwit.json

samples/traffic-splitting/api/config/knitwit.json

@@ -0,0 +1,14 @@
+{
+  "version": 1,
+  "project": {
+    "worlds": [
+      "spin-http"
+    ]
+  },
+  "packages": {
+    "@fermyon/spin-sdk": {
+      "witPath": "../../bin/wit",
+      "world": "spin-imports"
+    }
+  }
+}

samples/traffic-splitting/api/migrations/001_initial_schema.sql

@@ -0,0 +1,22 @@
+CREATE TABLE apps (
+    id TEXT PRIMARY KEY,
+    name TEXT NOT NULL,
+    url TEXT NOT NULL,
+    created_at DATETIME NOT NULL,
+    logger_url TEXT NOT NULL,
+    api_key TEXT NOT NULL
+);
+
+CREATE TABLE requests (
+    id TEXT PRIMARY KEY,
+    app_id TEXT NOT NULL,
+    timestamp DATETIME NOT NULL,
+    url TEXT NOT NULL,
+    method TEXT NOT NULL,
+    headers TEXT NOT NULL,
+    body_length INTEGER NOT NULL,
+    FOREIGN KEY (app_id) REFERENCES apps(id) ON DELETE CASCADE
+);
+
+CREATE INDEX idx_requests_app_id ON requests(app_id);
+CREATE INDEX idx_requests_timestamp ON requests(timestamp); 

samples/traffic-splitting/api/migrations/002_add_responses_table.sql

@@ -0,0 +1,15 @@
+CREATE TABLE responses (
+  id TEXT PRIMARY KEY,
+  request_id TEXT NOT NULL,
+  app_id TEXT NOT NULL,
+  timestamp DATETIME NOT NULL,
+  status_code INTEGER NOT NULL,
+  headers TEXT NOT NULL,
+  body_length INTEGER NOT NULL,
+  FOREIGN KEY (app_id) REFERENCES apps(id) ON DELETE CASCADE,
+  FOREIGN KEY (request_id) REFERENCES requests(id) ON DELETE CASCADE
+);
+
+CREATE INDEX idx_responses_app_id ON responses(app_id);
+CREATE INDEX idx_responses_request_id ON responses(request_id);
+CREATE INDEX idx_responses_timestamp ON responses(timestamp); 

samples/traffic-splitting/api/migrations/003_add_user_id_to_apps.sql

@@ -0,0 +1,2 @@
+ALTER TABLE apps ADD COLUMN user_id TEXT NOT NULL DEFAULT '';
+CREATE INDEX idx_apps_user_id ON apps(user_id); 

samples/traffic-splitting/api/migrations/004_create_users_table.sql

@@ -0,0 +1,13 @@
+CREATE TABLE users (
+    id TEXT PRIMARY KEY,
+    github_id INTEGER NOT NULL,
+    login TEXT NOT NULL,
+    name TEXT,
+    email TEXT,
+    avatar_url TEXT,
+    created_at DATETIME NOT NULL,
+    last_signin_at DATETIME NOT NULL
+);
+
+CREATE INDEX idx_users_github_id ON users(github_id);
+CREATE INDEX idx_users_login ON users(login);