initial

Author: bobymicroby

.dockerignore

@@ -0,0 +1,15 @@
+node_modules
+Dockerfile*
+docker-compose*
+.dockerignore
+.git
+.gitignore
+README.md
+LICENSE
+.vscode
+Makefile
+helm-charts
+.env
+.editorconfig
+.idea
+coverage*

.gitignore

@@ -0,0 +1,2 @@
+# deps
+node_modules/

Dockerfile

@@ -0,0 +1,35 @@
+FROM oven/bun:alpine AS build
+
+WORKDIR /app
+
+COPY bun.lock package.json ./
+
+RUN bun install --frozen-lockfile --production --verbose
+
+COPY . .
+
+RUN bun build --target bun --compile --minify --sourcemap ./src/index.ts --outfile resp-proxy
+
+FROM oven/bun:alpine AS runner
+
+# Required
+ENV LISTEN_PORT="6379"
+ENV TARGET_HOST=""
+ENV TARGET_PORT=""
+
+# Optional
+ENV LISTEN_HOST="127.0.0.1"
+ENV TIMEOUT=""
+ENV ENABLE_LOGGING="false"
+ENV API_PORT="3000"
+
+#Default proxy port
+EXPOSE 6379 
+#Default api port
+EXPOSE 3000
+
+WORKDIR /app
+
+COPY --from=build /app/resp-proxy .
+
+ENTRYPOINT ["./resp-proxy"]

README.md

@@ -0,0 +1,235 @@
+# Redis RESP Proxy
+
+A Redis protocol proxy with HTTP API for response injection.
+
+## Features
+
+- **Redis Transparent Protocol Proxy**: Forwards Redis connections from clients to target Redis servers
+- **HTTP API**: RESTful API for managing connections and sending commands to clients
+- **Connection Management**: Track active connections, view statistics, and close connections
+- **Data Encoding Support**: Send data in base64 or raw binary format
+- **Docker Support**: Containerized deployment with environment variable configuration
+- **Real-time Stats**: Monitor active connections and proxy statistics
+
+## Quick Start
+
+### Prerequisites
+- Docker or [Bun](https://bun.sh/) runtime
+- Running Redis server (target)
+
+### Basic Usage
+
+#### Docker (Recommended)
+
+The easiest way to get started is with Docker :
+
+
+```bash
+# Build the docker image first
+docker build -t resp-proxy .
+```
+
+
+
+```bash
+# Run with Docker - connects to Redis on host
+docker run -d \
+  -p 6379:6379 \ # the proxy will listen for incoming connections on this port
+  -p 3000:3000 \ # the rest api will listen for http requests on this port
+  -e TARGET_HOST=host.docker.internal \ #<-- redis server host ( the proxy target )
+  -e TARGET_PORT=6380 \ # redis server port
+  -e LISTEN_PORT=6379 \ # proxy listen port
+  -e API_PORT = 3000 \ # rest api port 
+  resp-proxy
+```
+
+### Local Development 
+
+```bash
+# Install dependencies
+bun install
+
+# Start the proxy with CLI arguments
+bun run proxy --listenPort=6379 --targetHost=localhost --targetPort=6380
+
+# Or use the dev mode with hot reload
+bun run dev --listenPort=6379 --targetHost=localhost --targetPort=6380
+```
+
+#### Environment Variables
+You can use env variables instead of cli arguments.
+
+```bash
+# Set required environment variables
+export LISTEN_PORT=6379
+export TARGET_HOST=localhost
+export TARGET_PORT=6380
+
+# Optional variables
+export LISTEN_HOST=127.0.0.1
+export TIMEOUT=30000
+export ENABLE_LOGGING=true
+export API_PORT=3000
+
+# Start the proxy
+bun run proxy
+```
+
+## Configuration
+
+### Required Parameters
+
+| Parameter | CLI Flag | Environment Variable | Description |
+|-----------|----------|---------------------|-------------|
+| Target Host | `--targetHost` | `TARGET_HOST` | Redis server hostname/IP |
+| Target Port | `--targetPort` | `TARGET_PORT` | Redis server port |
+
+### Optional Parameters
+
+| Parameter | CLI Flag | Environment Variable | Default | Description |
+|-----------|----------|---------------------|---------|-------------|
+| Listen Port | `--listenPort` | `LISTEN_PORT` | `6379` | Port for Redis clients to connect to |
+| Listen Host | `--listenHost` | `LISTEN_HOST` | `127.0.0.1` | Host interface to bind to |
+| Timeout | `--timeout` | `TIMEOUT` | - | Connection timeout (ms) |
+| Enable Logging | `--enableLogging` | `ENABLE_LOGGING` | `false` | Verbose logging |
+| API Port | `--apiPort` | `API_PORT` | `3000` | HTTP API port |
+
+## HTTP API Reference
+
+The proxy provides a REST API for managing connections and sending commands.
+
+
+### Endpoints
+
+
+#### Get Statistics
+```http
+GET /stats
+```
+Returns detailed proxy statistics including active connections, total connections, and connection details.
+
+**Response:**
+```json
+{
+  "activeConnections": 2,
+  "totalConnections": 5,
+  "connections": [
+    {
+      "id": "conn_123",
+      "clientAddress": "127.0.0.1:54321",
+      "connectedAt": "2024-01-01T10:00:00Z"
+    }
+  ]
+}
+```
+
+#### Get Active Connections
+```http
+GET /connections
+```
+Returns list of active connection IDs.
+
+**Response:**
+```json
+{
+  "connectionIds": ["conn_123", "conn_456"]
+}
+```
+
+#### Send Data to Specific Client
+```http
+POST /send-to-client/{connectionId}?encoding={base64|raw}
+```
+Send Redis protocol data to a specific client connection.
+
+**Parameters:**
+- `connectionId` (path): Target connection ID
+- `encoding` (query): Data encoding format (`base64` or `raw`, default: `base64`)
+
+**Body:** Raw data or base64-encoded data
+
+**Example:**
+```bash
+# Send PING command (base64 encoded)
+curl -X POST "http://localhost:3000/send-to-client/conn_123?encoding=base64" \
+  -d "KjENCiQ0DQpQSU5HDQo="
+
+# Send raw binary data
+curl -X POST "http://localhost:3000/send-to-client/conn_123?encoding=raw" \
+  --data-binary "*1\r\n$4\r\nPING\r\n"
+```
+
+**Response:**
+```json
+{
+  "success": true,
+  "connectionId": "conn_123"
+}
+```
+
+#### Send Data to Multiple Clients
+```http
+POST /send-to-clients?connectionIds={id1,id2}&encoding={base64|raw}
+```
+Send data to multiple specific client connections.
+
+**Parameters:**
+- `connectionIds` (query): Comma-separated list of connection IDs
+- `encoding` (query): Data encoding format (`base64` or `raw`, default: `base64`)
+
+**Example:**
+```bash
+curl -X POST "http://localhost:3000/send-to-clients?connectionIds=conn_123,conn_456&encoding=base64" \
+  -d "KjENCiQ0DQpQSU5HDQo="
+```
+
+#### Send Data to All Clients
+```http
+POST /send-to-all-clients?encoding={base64|raw}
+```
+Broadcast data to all active client connections.
+
+**Example:**
+```bash
+curl -X POST "http://localhost:3000/send-to-all-clients?encoding=base64" \
+  -d "KjENCiQ0DQpQSU5HDQo="
+```
+
+#### Close Connection
+```http
+DELETE /connections/{connectionId}
+```
+Forcefully close a specific client connection.
+
+**Response:**
+```json
+{
+  "success": true,
+  "connectionId": "conn_123"
+}
+```
+
+## Use Cases
+
+### Testing Redis Applications
+Intercept and inspect Redis commands during development and testing.
+
+### Response Injection
+Send custom Redis responses to specific clients for testing scenarios.
+
+### Protocol Analysis
+Analyze Redis protocol communication patterns.
+
+## Development
+
+### Running Tests
+
+```bash
+bun test
+```
+
+### Development Mode
+
+```bash
+bun run dev --targetHost=localhost --targetPort=6380
+```

bun.lock

@@ -0,0 +1,38 @@
+{
+  "lockfileVersion": 1,
+  "workspaces": {
+    "": {
+      "name": "resp-proxy",
+      "dependencies": {
+        "@hono/zod-validator": "^0.7.2",
+        "hono": "^4.8.5",
+        "redis-monorepo": "github:redis/node-redis",
+        "zod": "^4.0.8",
+      },
+      "devDependencies": {
+        "@types/bun": "latest",
+      },
+    },
+  },
+  "packages": {
+    "@hono/zod-validator": ["@hono/[email protected]", "", { "peerDependencies": { "hono": ">=3.9.0", "zod": "^3.25.0 || ^4.0.0" } }, "sha512-ub5eL/NeZ4eLZawu78JpW/J+dugDAYhwqUIdp9KYScI6PZECij4Hx4UsrthlEUutqDDhPwRI0MscUfNkvn/mqQ=="],
+
+    "@types/bun": ["@types/[email protected]", "", { "dependencies": { "bun-types": "1.2.19" } }, "sha512-d9ZCmrH3CJ2uYKXQIUuZ/pUnTqIvLDS0SK7pFmbx8ma+ziH/FRMoAq5bYpRG7y+w1gl+HgyNZbtqgMq4W4e2Lg=="],
+
+    "@types/node": ["@types/[email protected]", "", { "dependencies": { "undici-types": "~7.8.0" } }, "sha512-ut5FthK5moxFKH2T1CUOC6ctR67rQRvvHdFLCD2Ql6KXmMuCrjsSsRI9UsLCm9M18BMwClv4pn327UvB7eeO1w=="],
+
+    "@types/react": ["@types/[email protected]", "", { "dependencies": { "csstype": "^3.0.2" } }, "sha512-AwAfQ2Wa5bCx9WP8nZL2uMZWod7J7/JSplxbTmBQ5ms6QpqNYm672H0Vu9ZVKVngQ+ii4R/byguVEUZQyeg44g=="],
+
+    "bun-types": ["[email protected]", "", { "dependencies": { "@types/node": "*" }, "peerDependencies": { "@types/react": "^19" } }, "sha512-uAOTaZSPuYsWIXRpj7o56Let0g/wjihKCkeRqUBhlLVM/Bt+Fj9xTo+LhC1OV1XDaGkz4hNC80et5xgy+9KTHQ=="],
+
+    "csstype": ["[email protected]", "", {}, "sha512-M1uQkMl8rQK/szD0LNhtqxIPLpimGm8sOBwU7lLnCpSbTyY3yeU1Vc7l4KT5zT4s/yOxHH5O7tIuuLOCnLADRw=="],
+
+    "hono": ["[email protected]", "", {}, "sha512-Up2cQbtNz1s111qpnnECdTGqSIUIhZJMLikdKkshebQSEBcoUKq6XJayLGqSZWidiH0zfHRCJqFu062Mz5UuRA=="],
+
+    "redis-monorepo": ["redis-monorepo@github:redis/node-redis#e96db0d", {}, "redis-node-redis-e96db0d"],
+
+    "undici-types": ["[email protected]", "", {}, "sha512-9UJ2xGDvQ43tYyVMpuHlsgApydB8ZKfVYTsLDhXkFL/6gfkp+U8xTGdh8pMJv1SpZna0zxG1DwsKZsreLbXBxw=="],
+
+    "zod": ["[email protected]", "", {}, "sha512-+MSh9cZU9r3QKlHqrgHMTSr3QwMGv4PLfR0M4N/sYWV5/x67HgXEhIGObdBkpnX8G78pTgWnIrBL2lZcNJOtfg=="],
+  }
+}

package.json

@@ -0,0 +1,17 @@
+{
+  "name": "resp-proxy",
+  "scripts": {
+    "proxy": "bun run src/index.ts",
+    "dev": "bun run --hot src/index.ts",
+    "test": "bun test **/*.test.ts"
+  },
+  "dependencies": {
+    "@hono/zod-validator": "^0.7.2",
+    "hono": "^4.8.5",
+    "redis-monorepo": "github:redis/node-redis",
+    "zod": "^4.0.8"
+  },
+  "devDependencies": {
+    "@types/bun": "latest"
+  }
+}