Http Trigger Proxy (#125)

* Propose proxy

* Improve path resolution inside generate-chain selectors script

Author: ernest-nowacki

bun.lock

@@ -10,9 +10,21 @@
         "typescript": "5.9.2",
       },
     },
+    "packages/cre-http-trigger": {
+      "name": "@chainlink/cre-http-trigger",
+      "version": "0.0.8-alpha",
+      "dependencies": {
+        "uuid": "13.0.0",
+        "viem": "2.38.0",
+        "zod": "3.25.76",
+      },
+      "devDependencies": {
+        "@types/bun": "1.2.21",
+      },
+    },
     "packages/cre-sdk": {
       "name": "@chainlink/cre-sdk",
-      "version": "0.0.5-alpha",
+      "version": "0.0.8-alpha",
       "bin": {
         "cre-compile": "bin/cre-compile.ts",
       },
@@ -37,7 +49,7 @@
     },
     "packages/cre-sdk-examples": {
       "name": "@chainlink/cre-sdk-examples",
-      "version": "0.0.5-alpha",
+      "version": "0.0.8-alpha",
       "dependencies": {
         "@bufbuild/protobuf": "2.6.3",
         "@chainlink/cre-sdk": "workspace:*",
@@ -50,7 +62,7 @@
     },
     "packages/cre-sdk-javy-plugin": {
       "name": "@chainlink/cre-sdk-javy-plugin",
-      "version": "0.0.4-alpha",
+      "version": "0.0.6-alpha",
       "bin": {
         "cre-setup": "bin/setup.ts",
         "cre-compile-workflow": "bin/compile-workflow.ts",
@@ -100,6 +112,8 @@
 
     "@bufbuild/protoplugin": ["@bufbuild/[email protected]", "", { "dependencies": { "@bufbuild/protobuf": "2.6.3", "@typescript/vfs": "^1.5.2", "typescript": "5.4.5" } }, "sha512-VceMuxeRukxGeABfo34SXq0VqY1MU+mzS+PBf0HAWo97ylFut8F6sQ3mV0tKiM08UQ/xQco7lxCn83BkoxrWrA=="],
 
+    "@chainlink/cre-http-trigger": ["@chainlink/cre-http-trigger@workspace:packages/cre-http-trigger"],
+
     "@chainlink/cre-sdk": ["@chainlink/cre-sdk@workspace:packages/cre-sdk"],
 
     "@chainlink/cre-sdk-examples": ["@chainlink/cre-sdk-examples@workspace:packages/cre-sdk-examples"],
@@ -108,7 +122,7 @@
 
     "@noble/ciphers": ["@noble/[email protected]", "", {}, "sha512-2I0gnIVPtfnMw9ee9h1dJG7tp81+8Ob3OJb3Mv37rx5L40/b0i7djjCVvGOVqc9AEIQyvyu1i6ypKdFw8R8gQw=="],
 
-    "@noble/curves": ["@noble/[email protected].6", "", { "dependencies": { "@noble/hashes": "1.8.0" } }, "sha512-GIKz/j99FRthB8icyJQA51E8Uk5hXmdyThjgQXRKiv9h0zeRlzSCLIzFw6K1LotZ3XuB7yzlf76qk7uBmTdFqA=="],
+    "@noble/curves": ["@noble/[email protected].1", "", { "dependencies": { "@noble/hashes": "1.8.0" } }, "sha512-k11yZxZg+t+gWvBbIswW0yoJlu8cHOC7dhunwOzoWH/mXGBiYyR4YY6hAEK/3EUs4UpB8la1RfdRpeGsFHkWsA=="],
 
     "@noble/hashes": ["@noble/[email protected]", "", {}, "sha512-jCs9ldd7NwzpgXDIf6P3+NrHh9/sD6CQdxHyjQI+h/6rDNo88ypBxxz45UDuZHz9r3tNz7N/VInSVoVdtXEI4A=="],
 
@@ -134,7 +148,7 @@
 
     "@typescript/vfs": ["@typescript/[email protected]", "", { "dependencies": { "debug": "^4.1.1" }, "peerDependencies": { "typescript": "*" } }, "sha512-JwoxboBh7Oz1v38tPbkrZ62ZXNHAk9bJ7c9x0eI5zBfBnBYGhURdbnh7Z4smN/MV48Y5OCcZb58n972UtbazsA=="],
 
-    "abitype": ["abitype@1.0.8", "", { "peerDependencies": { "typescript": ">=5.0.4", "zod": "^3 >=3.22.0" }, "optionalPeers": ["typescript", "zod"] }, "sha512-ZeiI6h3GnW06uYDLx0etQtX/p8E24UaHHBj57RSjK7YBFe7iuVn07EDpOeP451D06sF27VOz9JJPlIKJmXgkEg=="],
+    "abitype": ["abitype@1.1.0", "", { "peerDependencies": { "typescript": ">=5.0.4", "zod": "^3.22.0 || ^4.0.0" }, "optionalPeers": ["typescript", "zod"] }, "sha512-6Vh4HcRxNMLA0puzPjM5GBgT4aAcFGKZzSgAXvuZ27shJP6NEpielTuqbBmZILR5/xd0PizkBGy5hReKz9jl5A=="],
 
     "braces": ["[email protected]", "", { "dependencies": { "fill-range": "^7.1.1" } }, "sha512-yQbXgO/OSZVD2IsiLlro+7Hf6Q18EJrKSEsdoMzKePKXct3gvD8oLcOQdIzGupr5Fj+EDe8gO/lxc1BzfMpxvA=="],
 
@@ -176,7 +190,7 @@
 
     "ms": ["[email protected]", "", {}, "sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA=="],
 
-    "ox": ["ox@0.8.7", "", { "dependencies": { "@adraffy/ens-normalize": "^1.11.0", "@noble/ciphers": "^1.3.0", "@noble/curves": "^1.9.1", "@noble/hashes": "^1.8.0", "@scure/bip32": "^1.7.0", "@scure/bip39": "^1.6.0", "abitype": "^1.0.8", "eventemitter3": "5.0.1" }, "peerDependencies": { "typescript": ">=5.4.0" }, "optionalPeers": ["typescript"] }, "sha512-W1f0FiMf9NZqtHPEDEAEkyzZDwbIKfmH2qmQx8NNiQ/9JhxrSblmtLJsSfTtQG5YKowLOnBlLVguCyxm/7ztxw=="],
+    "ox": ["ox@0.9.6", "", { "dependencies": { "@adraffy/ens-normalize": "^1.11.0", "@noble/ciphers": "^1.3.0", "@noble/curves": "1.9.1", "@noble/hashes": "^1.8.0", "@scure/bip32": "^1.7.0", "@scure/bip39": "^1.6.0", "abitype": "^1.0.9", "eventemitter3": "5.0.1" }, "peerDependencies": { "typescript": ">=5.4.0" }, "optionalPeers": ["typescript"] }, "sha512-8SuCbHPvv2eZLYXrNmC0EC12rdzXQLdhnOMlHDW2wiCPLxBrOOJwX5L5E61by+UjTPOryqQiRSnjIKCI+GykKg=="],
 
     "picomatch": ["[email protected]", "", {}, "sha512-JU3teHTNjmE2VCGFzuY8EXzCDVwEqB2a8fsIvwaStHhAWJEeVd1o1QD80CU6+ZdEXXSLbSsuLwJjkCBWqRQUVA=="],
 
@@ -212,7 +226,9 @@
 
     "undici-types": ["[email protected]", "", {}, "sha512-goOacqME2GYyOZZfb5Lgtu+1IDmAlAEu5xnD3+xTzS10hT0vzpf0SPjkXwAw9Jm+4n/mQGDP3LO8CPbYROeBfQ=="],
 
-    "viem": ["[email protected]", "", { "dependencies": { "@noble/curves": "1.9.6", "@noble/hashes": "1.8.0", "@scure/bip32": "1.7.0", "@scure/bip39": "1.6.0", "abitype": "1.0.8", "isows": "1.0.7", "ox": "0.8.7", "ws": "8.18.3" }, "peerDependencies": { "typescript": ">=5.0.4" }, "optionalPeers": ["typescript"] }, "sha512-HJZG9Wt0DLX042MG0PK17tpataxtdAEhpta9/Q44FqKwy3xZMI5Lx4jF+zZPuXFuYjZ68R0PXqRwlswHs6r4gA=="],
+    "uuid": ["[email protected]", "", { "bin": { "uuid": "dist-node/bin/uuid" } }, "sha512-XQegIaBTVUjSHliKqcnFqYypAd4S+WCYt5NIeRs6w/UAry7z8Y9j5ZwRRL4kzq9U3sD6v+85er9FvkEaBpji2w=="],
+
+    "viem": ["[email protected]", "", { "dependencies": { "@noble/curves": "1.9.1", "@noble/hashes": "1.8.0", "@scure/bip32": "1.7.0", "@scure/bip39": "1.6.0", "abitype": "1.1.0", "isows": "1.0.7", "ox": "0.9.6", "ws": "8.18.3" }, "peerDependencies": { "typescript": ">=5.0.4" }, "optionalPeers": ["typescript"] }, "sha512-YU5TG8dgBNeYPrCMww0u9/JVeq2ZCk9fzk6QybrPkBooFysamHXL1zC3ua10aLPt9iWoA/gSVf1D9w7nc5B1aA=="],
 
     "ws": ["[email protected]", "", { "peerDependencies": { "bufferutil": "^4.0.1", "utf-8-validate": ">=5.0.2" }, "optionalPeers": ["bufferutil", "utf-8-validate"] }, "sha512-PEIGCY5tSlUt50cqyMXfCzX+oOPqN0vuGqWzbcJ2xvnkzkq46oOpz7dQaTDBdfICb4N14+GARUDw2XV2N4tvzg=="],
 
@@ -221,5 +237,23 @@
     "zod": ["[email protected]", "", {}, "sha512-gzUt/qt81nXsFGKIFcC3YnfEAx5NkunCfnDlvuBSSFS02bcXu4Lmea0AFIUwbLWxWPx3d9p8S5QoaujKcNQxcQ=="],
 
     "@bufbuild/protoplugin/typescript": ["[email protected]", "", { "bin": { "tsc": "bin/tsc", "tsserver": "bin/tsserver" } }, "sha512-vcI4UpRgg81oIRUFwR0WSIHKt11nJ7SAVlYNIu+QpqeyXP+gpQJy/Z4+F0aGxSE4MqwjyXvW/TzgkLAx2AGHwQ=="],
+
+    "@chainlink/cre-sdk/viem": ["[email protected]", "", { "dependencies": { "@noble/curves": "1.9.6", "@noble/hashes": "1.8.0", "@scure/bip32": "1.7.0", "@scure/bip39": "1.6.0", "abitype": "1.0.8", "isows": "1.0.7", "ox": "0.8.7", "ws": "8.18.3" }, "peerDependencies": { "typescript": ">=5.0.4" }, "optionalPeers": ["typescript"] }, "sha512-HJZG9Wt0DLX042MG0PK17tpataxtdAEhpta9/Q44FqKwy3xZMI5Lx4jF+zZPuXFuYjZ68R0PXqRwlswHs6r4gA=="],
+
+    "@chainlink/cre-sdk-examples/viem": ["[email protected]", "", { "dependencies": { "@noble/curves": "1.9.6", "@noble/hashes": "1.8.0", "@scure/bip32": "1.7.0", "@scure/bip39": "1.6.0", "abitype": "1.0.8", "isows": "1.0.7", "ox": "0.8.7", "ws": "8.18.3" }, "peerDependencies": { "typescript": ">=5.0.4" }, "optionalPeers": ["typescript"] }, "sha512-HJZG9Wt0DLX042MG0PK17tpataxtdAEhpta9/Q44FqKwy3xZMI5Lx4jF+zZPuXFuYjZ68R0PXqRwlswHs6r4gA=="],
+
+    "@scure/bip32/@noble/curves": ["@noble/[email protected]", "", { "dependencies": { "@noble/hashes": "1.8.0" } }, "sha512-GIKz/j99FRthB8icyJQA51E8Uk5hXmdyThjgQXRKiv9h0zeRlzSCLIzFw6K1LotZ3XuB7yzlf76qk7uBmTdFqA=="],
+
+    "@chainlink/cre-sdk-examples/viem/@noble/curves": ["@noble/[email protected]", "", { "dependencies": { "@noble/hashes": "1.8.0" } }, "sha512-GIKz/j99FRthB8icyJQA51E8Uk5hXmdyThjgQXRKiv9h0zeRlzSCLIzFw6K1LotZ3XuB7yzlf76qk7uBmTdFqA=="],
+
+    "@chainlink/cre-sdk-examples/viem/abitype": ["[email protected]", "", { "peerDependencies": { "typescript": ">=5.0.4", "zod": "^3 >=3.22.0" }, "optionalPeers": ["typescript", "zod"] }, "sha512-ZeiI6h3GnW06uYDLx0etQtX/p8E24UaHHBj57RSjK7YBFe7iuVn07EDpOeP451D06sF27VOz9JJPlIKJmXgkEg=="],
+
+    "@chainlink/cre-sdk-examples/viem/ox": ["[email protected]", "", { "dependencies": { "@adraffy/ens-normalize": "^1.11.0", "@noble/ciphers": "^1.3.0", "@noble/curves": "^1.9.1", "@noble/hashes": "^1.8.0", "@scure/bip32": "^1.7.0", "@scure/bip39": "^1.6.0", "abitype": "^1.0.8", "eventemitter3": "5.0.1" }, "peerDependencies": { "typescript": ">=5.4.0" }, "optionalPeers": ["typescript"] }, "sha512-W1f0FiMf9NZqtHPEDEAEkyzZDwbIKfmH2qmQx8NNiQ/9JhxrSblmtLJsSfTtQG5YKowLOnBlLVguCyxm/7ztxw=="],
+
+    "@chainlink/cre-sdk/viem/@noble/curves": ["@noble/[email protected]", "", { "dependencies": { "@noble/hashes": "1.8.0" } }, "sha512-GIKz/j99FRthB8icyJQA51E8Uk5hXmdyThjgQXRKiv9h0zeRlzSCLIzFw6K1LotZ3XuB7yzlf76qk7uBmTdFqA=="],
+
+    "@chainlink/cre-sdk/viem/abitype": ["[email protected]", "", { "peerDependencies": { "typescript": ">=5.0.4", "zod": "^3 >=3.22.0" }, "optionalPeers": ["typescript", "zod"] }, "sha512-ZeiI6h3GnW06uYDLx0etQtX/p8E24UaHHBj57RSjK7YBFe7iuVn07EDpOeP451D06sF27VOz9JJPlIKJmXgkEg=="],
+
+    "@chainlink/cre-sdk/viem/ox": ["[email protected]", "", { "dependencies": { "@adraffy/ens-normalize": "^1.11.0", "@noble/ciphers": "^1.3.0", "@noble/curves": "^1.9.1", "@noble/hashes": "^1.8.0", "@scure/bip32": "^1.7.0", "@scure/bip39": "^1.6.0", "abitype": "^1.0.8", "eventemitter3": "5.0.1" }, "peerDependencies": { "typescript": ">=5.4.0" }, "optionalPeers": ["typescript"] }, "sha512-W1f0FiMf9NZqtHPEDEAEkyzZDwbIKfmH2qmQx8NNiQ/9JhxrSblmtLJsSfTtQG5YKowLOnBlLVguCyxm/7ztxw=="],
   }
 }

packages/cre-http-trigger/.env.example

@@ -0,0 +1,14 @@
+# MAKE A COPY OF THIS FILE AND NAME IT .env
+# Fill your .env variables with your desired values.
+# NEVER commit your actual .env file to the repository. 
+#
+###############################################################################
+### REQUIRED ENVIRONMENT VARIABLES - SENSITIVE INFORMATION                  ###
+### DO NOT STORE RAW SECRETS HERE IN PLAINTEXT IF AVOIDABLE                 ###
+### DO NOT UPLOAD OR SHARE THIS FILE UNDER ANY CIRCUMSTANCES                ###
+###############################################################################
+#
+# Private key that is allowed to trigger your Http Trigger based workflows
+PRIVATE_KEY=0x
+# CRE Gateway url to use, starts with https
+GATEWAY_URL=http://localhost:5002/user

packages/cre-http-trigger/README.md

@@ -0,0 +1,29 @@
+# CRE HTTP Trigger Proxy
+
+Utility app that allows for easy triggering of workflows via HTTP.
+
+## Setup
+
+First you need to prepare your environment variables. You can do this by copying the `.env.example` file to `.env` and filling in the values.
+
+`PRIVATE_KEY=0x...` - This is the private key corresponding with your workflow `authorizedKeys`.
+`GATEWAY_URL=http://localhost:5002/user` - This is the URL of the gateway you are using. You can use https:// and point to the published gateway.
+
+Next you would need to install the dependencies, for that run: `bun install`.
+
+Next you would need to run the app with `bun start`. This will spin tiny http server, that would validate the env variables and will prepare the request that will trigger the workflow. Basically it's your **proxy** now.
+
+## Usage
+
+You can use postman or any other http client to send a request.
+
+```http
+POST http://localhost:3000/trigger?workflowID=0xYourWorkflowID
+Content-Type: application/json
+
+{
+  "input": {
+    "anyInput": "your workflow expects"
+  }
+}
+```

packages/cre-http-trigger/biome.json

@@ -0,0 +1,42 @@
+{
+	"$schema": "https://biomejs.dev/schemas/2.2.4/schema.json",
+	"vcs": {
+		"enabled": false,
+		"clientKind": "git",
+		"useIgnoreFile": false
+	},
+	"files": {
+		"ignoreUnknown": false,
+		"includes": ["src/**/*", "**/*.json"]
+	},
+	"formatter": {
+		"enabled": true,
+		"indentStyle": "tab",
+		"lineWidth": 100
+	},
+	"assist": {
+		"enabled": true
+	},
+	"linter": {
+		"enabled": true,
+		"includes": ["!src/generated/**"],
+		"rules": {
+			"recommended": true,
+			"correctness": {
+				"noUnusedVariables": "error"
+			},
+			"suspicious": {
+				"noExplicitAny": "warn"
+			},
+			"style": {
+				"useConst": "error"
+			}
+		}
+	},
+	"javascript": {
+		"formatter": {
+			"quoteStyle": "single",
+			"semicolons": "asNeeded"
+		}
+	}
+}

packages/cre-http-trigger/package.json

@@ -0,0 +1,29 @@
+{
+	"name": "@chainlink/cre-http-trigger",
+	"private": true,
+	"version": "0.0.8-alpha",
+	"type": "module",
+	"main": "src/index.ts",
+	"author": "Ernest Nowacki",
+	"license": "BUSL-1.1",
+	"description": "Utility app that allows for easy triggering of workflows via HTTP.",
+	"scripts": {
+		"start": "bun src/index.ts",
+		"check": "biome check --write ${BIOME_PATHS:-.}",
+		"format": "biome format --write ${BIOME_PATHS:-.}",
+		"full-checks": "bun typecheck && bun check",
+		"lint": "biome lint --write",
+		"typecheck": "tsc"
+	},
+	"dependencies": {
+		"uuid": "13.0.0",
+		"viem": "2.38.0",
+		"zod": "3.25.76"
+	},
+	"devDependencies": {
+		"@types/bun": "1.2.21"
+	},
+	"engines": {
+		"bun": ">=1.2.21"
+	}
+}

packages/cre-http-trigger/src/createJWT.ts

@@ -0,0 +1,73 @@
+import { v4 as uuidv4 } from 'uuid'
+import { type Hex, parseSignature } from 'viem'
+import { privateKeyToAccount } from 'viem/accounts'
+import type { WorkflowSelector } from './schemas'
+import { base64URLEncode, sha256 } from './utils'
+
+export interface JSONRPCRequest {
+	jsonrpc: string
+	id: string
+	method: string
+	params: {
+		input: any
+		workflow: WorkflowSelector
+	}
+}
+
+export const createJWT = async (request: JSONRPCRequest, privateKey: Hex): Promise<string> => {
+	const account = privateKeyToAccount(privateKey)
+	const address = account.address
+
+	// Create JWT header
+	const header = {
+		alg: 'ETH',
+		typ: 'JWT',
+	}
+
+	// Create JWT payload with request and metadata
+	const now = Math.floor(Date.now() / 1000)
+
+	// Note: Request needs to be in the following order:
+	// Version string  `json:"jsonrpc"`
+	// ID      string  `json:"id"`
+	// Method  string  `json:"method"`
+	// Params  *Params `json:"params"`
+
+	const payload = {
+		digest: `0x${sha256(request)}`,
+		iss: address,
+		iat: now,
+		exp: now + 300, // 5 minutes expiration
+		jti: uuidv4(),
+	}
+
+	// Encode header and payload
+	const encodedHeader = base64URLEncode(JSON.stringify(header))
+	const encodedPayload = base64URLEncode(JSON.stringify(payload))
+	const rawMessage = `${encodedHeader}.${encodedPayload}`
+
+	// Sign the message - viem's signMessage handles the Ethereum Signed Message prefix and hashing
+	const signature = await account.signMessage({
+		message: rawMessage,
+	})
+
+	// Convert signature to JWT format (r, s, v components)
+	const { r, s, v, yParity } = parseSignature(signature)
+	// Use yParity if v is undefined (yParity is 0 or 1)
+	const recoveryId = v !== undefined ? (v >= 27n ? v - 27n : v) : yParity
+
+	if (recoveryId === undefined) {
+		throw new Error('Unable to extract recovery ID from signature')
+	}
+
+	// Combine r, s, and adjusted v into a single buffer
+	const signatureBytes = Buffer.concat([
+		Buffer.from(r.slice(2), 'hex'), // Remove 0x prefix from r
+		Buffer.from(s.slice(2), 'hex'), // Remove 0x prefix from s
+		Buffer.from([Number(recoveryId)]),
+	])
+
+	const encodedSignature = base64URLEncode(signatureBytes.toString('binary'))
+
+	return `${rawMessage}.${encodedSignature}`
+}

packages/cre-http-trigger/src/getConfig.ts

@@ -0,0 +1,24 @@
+import { type Hex } from 'viem'
+import { z } from 'zod'
+
+const configSchema = z.object({
+	gatewayURL: z.string(),
+	privateKey: z.string(),
+})
+
+export type Config = z.infer<typeof configSchema>
+
+export const getConfig = () => {
+	const config = configSchema.parse({
+		gatewayURL: process.env.GATEWAY_URL,
+		privateKey:
+			(process.env.PRIVATE_KEY?.startsWith('0x')
+				? process.env.PRIVATE_KEY
+				: `0x${process.env.PRIVATE_KEY}`) || '0x',
+	})
+
+	return {
+		gatewayURL: config.gatewayURL,
+		privateKey: config.privateKey as Hex,
+	}
+}