Initial commit

Author: gkoos

.github/workflows/ci.yml

@@ -0,0 +1,16 @@
+name: CI
+
+on:
+  push:
+    branches: [main]
+  pull_request:
+
+jobs:
+  test:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: actions/setup-go@v5
+        with:
+          go-version: '1.25.1'
+      - run: go test -v ./...

.github/workflows/release.yml

@@ -0,0 +1,24 @@
+name: Release
+
+on:
+  push:
+    tags:
+      - 'v*.*.*'
+
+jobs:
+  release:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: actions/setup-go@v5
+        with:
+          go-version: '1.25.1'
+      - name: Run tests
+        run: go test -v ./...
+      - name: Set up GoReleaser
+        uses: goreleaser/goreleaser-action@v5
+        with:
+          version: latest
+          args: release --clean
+        env:
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}

.gitignore

@@ -0,0 +1,43 @@
+# Binaries and build output
+dist/
+bin/
+*.exe
+*.dll
+*.so
+*.dylib
+*.test
+
+# Go modules
+vendor/
+
+# IDE/editor files
+.vscode/
+.idea/
+*.swp
+*.swo
+*.bak
+*.tmp
+
+# OS files
+.DS_Store
+Thumbs.db
+
+# Logs
+*.log
+
+# Dependency directories
+node_modules/
+
+# Coverage and test output
+coverage.out
+*.coverprofile
+
+# GoReleaser
+release/
+
+# Misc
+.env
+.env.*
+
+# Go workspace file
+go.work

.goreleaser.yaml

@@ -0,0 +1,16 @@
+project_name: chaos-proxy-go
+builds:
+  - main: ./main.go
+    goos: [linux, windows, darwin]
+    goarch: [amd64, arm64]
+archives:
+  - format: tar.gz
+    name_template: "{{ .ProjectName }}_{{ .Version }}_{{ .Os }}_{{ .Arch }}"
+checksum:
+  name_template: "checksums.txt"
+release:
+  github:
+    owner: fetch-kit
+    name: chaos-proxy-go
+ldflags:
+      - "-X main.version={{.Version}} -X main.commit={{.Commit}} -X main.date={{.Date}}"

.pre-commit-config.yaml

@@ -0,0 +1,21 @@
+repos:
+  - repo: https://github.com/dnephin/pre-commit-golang
+    rev: v0.5.1
+    hooks:
+      # - id: go-fmt
+      # - id: go-imports
+      - id: go-lint
+      - id: go-vet
+
+  - repo: https://github.com/golangci/golangci-lint
+    rev: v2.5.0
+    hooks:
+      - id: golangci-lint
+
+  - repo: local
+    hooks:
+      - id: go-test
+        name: go test
+        entry: go test ./...
+        language: system
+        pass_filenames: false

CHANGELOG.md

@@ -0,0 +1,12 @@
+# Changelog
+
+All notable changes to this project will be documented in this file.
+
+## [0.0.1] - 2025-10-09
+### Added
+- Initial release: Go port of [fetch-kit/chaos-proxy](https://github.com/fetch-kit/chaos-proxy)
+- Core proxy server and middleware registry
+- Middleware: latency, fail, headerTransform, bodyTransformJSON, rateLimit, cors, throttle, dropConnection, etc.
+- CLI and programmatic API
+- YAML configuration support
+- Full integration and unit test suite

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2025 chaos-proxy-go contributors
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

README.md

@@ -0,0 +1,98 @@
+[![Build](https://github.com/your-org/chaos-proxy-go/actions/workflows/ci.yml/badge.svg)](https://github.com/your-org/chaos-proxy-go/actions)
+[![GitHub stars](https://img.shields.io/github/stars/your-org/chaos-proxy-go?style=social)](https://github.com/your-org/chaos-proxy-go)
+
+# chaos-proxy-go
+
+**chaos-proxy-go** is a Go port of [fetch-kit/chaos-proxy](https://github.com/fetch-kit/chaos-proxy): a proxy server for injecting configurable network chaos (latency, failures, connection drops, rate-limiting, etc.) into any HTTP or HTTPS traffic. Use it via CLI or programmatically to apply ordered middleware (global and per-route) and forward requests to your target server, preserving method, path, headers, query, and body.
+
+---
+
+## Features
+
+- Simple configuration via a single `chaos.yaml` file
+- Programmatic API and CLI usage
+- Built-in middleware primitives: latency, latencyRange, fail, failRandomly, failNth, dropConnection, rateLimit, cors, throttle, bodyTransform
+- Extensible registry for custom middleware
+- Supports both request and response interception/modification
+- Method+path route support (e.g., `GET /api/users`)
+- Robust short-circuiting: middlewares halt further processing when sending a response or dropping a connection
+
+---
+
+## Installation
+
+Download the latest release from [GitHub Releases](https://github.com/your-org/chaos-proxy-go/releases) or build from source:
+
+```sh
+go build -o chaos-proxy-go .
+```
+
+---
+
+## Usage
+
+### CLI
+
+```sh
+./chaos-proxy-go --config chaos.yaml [--verbose]
+```
+- `--config <path>`: YAML config file (default `./chaos.yaml`)
+- `--verbose`: print loaded middlewares and request logs
+
+### Programmatic API
+
+```go
+import "your-org/chaos-proxy-go/internal/proxy"
+
+// Load config and start server
+cfg := config.Load("chaos.yaml")
+server := proxy.New(cfg, false)
+server.Start()
+// ...
+```
+
+---
+
+## Configuration (`chaos.yaml`)
+
+See the [original chaos-proxy README](https://github.com/fetch-kit/chaos-proxy) for detailed config options. This Go port supports a compatible YAML structure.
+
+---
+
+## Middleware Primitives
+
+- `latency(ms)` — delay every request
+- `latencyRange(minMs, maxMs)` — random delay
+- `fail({ status, body })` — always fail
+- `failRandomly({ rate, status, body })` — fail with probability
+- `failNth({ n, status, body })` — fail every nth request
+- `dropConnection({ prob })` — randomly drop connection
+- `rateLimit({ limit, windowMs, key })` — rate limiting (by IP, header, or custom)
+- `cors({ origin, methods, headers })` — enable and configure CORS headers
+- `throttle({ rate, chunkSize, burst, key })` — throttles bandwidth per request
+- `bodyTransform({ transform })` — parse and mutate request body with a custom function
+
+---
+
+## Extensibility
+
+Register custom middleware in Go. See the `internal/middleware` package for examples.
+
+---
+
+## Security & Limitations
+
+- Proxy forwards all headers; be careful with sensitive tokens.
+- Intended for local/dev/test only.
+- HTTPS pass-through requires TLS termination; not supported out-of-the-box.
+- Not intended for stress testing; connection limits apply.
+
+---
+
+## License
+
+MIT
+
+---
+
+> This is a Go port of [fetch-kit/chaos-proxy](https://github.com/fetch-kit/chaos-proxy).

chaos.yaml

@@ -0,0 +1,8 @@
+target: "https://httpbin.org"
+port: 5000
+routes:
+  "GET /get":
+    - latency:
+        ms: 5000
+  "GET /post":
+    - dropConnection:

cmd/cmd.go

@@ -0,0 +1,37 @@
+package cmd
+
+import (
+	"github.com/spf13/cobra"
+)
+
+var (
+	configPath string
+	verbose    bool
+)
+
+var rootCmd = &cobra.Command{
+	Use:   "chaos-proxy",
+	Short: "A proxy server for injecting configurable network chaos",
+	Long: `Chaos Proxy is a proxy server for injecting configurable network chaos 
+(latency, failures, connection drops, rate-limiting, etc.) into any HTTP or HTTPS traffic.`,
+}
+
+func init() {
+	rootCmd.Flags().StringVar(&configPath, "config", "chaos.yaml", "YAML config file path")
+	rootCmd.Flags().BoolVar(&verbose, "verbose", false, "Print loaded middlewares and request logs")
+}
+
+// Execute runs the root command.
+func Execute() error {
+	return rootCmd.Execute()
+}
+
+// GetConfigPath returns the config file path.
+func GetConfigPath() string {
+	return configPath
+}
+
+// GetVerbose returns whether verbose logging is enabled.
+func GetVerbose() bool {
+	return verbose
+}