131868bdca
Major security, observability, and configuration improvements:
## Security Hardening
- Implemented configurable CORS (no more wildcards)
- Added comprehensive auth middleware for admin endpoints
- Enhanced webhook HMAC validation
- Added input validation and rate limiting
- Security headers and CSP policies
## Configuration Management
- Made N8N webhook URL configurable (WHOOSH_N8N_BASE_URL)
- Replaced all hardcoded endpoints with environment variables
- Added feature flags for LLM vs heuristic composition
- Gitea fetch hardening with EAGER_FILTER and FULL_RESCAN options
## API Completeness
- Implemented GetCouncilComposition function
- Added GET /api/v1/councils/{id} endpoint
- Council artifacts API (POST/GET /api/v1/councils/{id}/artifacts)
- /admin/health/details endpoint with component status
- Database lookup for repository URLs (no hardcoded fallbacks)
## Observability & Performance
- Added OpenTelemetry distributed tracing with goal/pulse correlation
- Performance optimization database indexes
- Comprehensive health monitoring
- Enhanced logging and error handling
## Infrastructure
- Production-ready P2P discovery (replaces mock implementation)
- Removed unused Redis configuration
- Enhanced Docker Swarm integration
- Added migration files for performance indexes
## Code Quality
- Comprehensive input validation
- Graceful error handling and failsafe fallbacks
- Backwards compatibility maintained
- Following security best practices
🤖 Generated with [Claude Code](https://claude.ai/code)
Co-Authored-By: Claude <noreply@anthropic.com>
84 lines
1.7 KiB
Markdown
84 lines
1.7 KiB
Markdown
# Legacy JetStream API
|
|
|
|
This is a documentation for the legacy JetStream API. A README for the current
|
|
API can be found [here](jetstream/README.md)
|
|
|
|
## JetStream Basic Usage
|
|
|
|
```go
|
|
import "github.com/nats-io/nats.go"
|
|
|
|
// Connect to NATS
|
|
nc, _ := nats.Connect(nats.DefaultURL)
|
|
|
|
// Create JetStream Context
|
|
js, _ := nc.JetStream(nats.PublishAsyncMaxPending(256))
|
|
|
|
// Simple Stream Publisher
|
|
js.Publish("ORDERS.scratch", []byte("hello"))
|
|
|
|
// Simple Async Stream Publisher
|
|
for i := 0; i < 500; i++ {
|
|
js.PublishAsync("ORDERS.scratch", []byte("hello"))
|
|
}
|
|
select {
|
|
case <-js.PublishAsyncComplete():
|
|
case <-time.After(5 * time.Second):
|
|
fmt.Println("Did not resolve in time")
|
|
}
|
|
|
|
// Simple Async Ephemeral Consumer
|
|
js.Subscribe("ORDERS.*", func(m *nats.Msg) {
|
|
fmt.Printf("Received a JetStream message: %s\n", string(m.Data))
|
|
})
|
|
|
|
// Simple Sync Durable Consumer (optional SubOpts at the end)
|
|
sub, err := js.SubscribeSync("ORDERS.*", nats.Durable("MONITOR"), nats.MaxDeliver(3))
|
|
m, err := sub.NextMsg(timeout)
|
|
|
|
// Simple Pull Consumer
|
|
sub, err := js.PullSubscribe("ORDERS.*", "MONITOR")
|
|
msgs, err := sub.Fetch(10)
|
|
|
|
// Unsubscribe
|
|
sub.Unsubscribe()
|
|
|
|
// Drain
|
|
sub.Drain()
|
|
```
|
|
|
|
## JetStream Basic Management
|
|
|
|
```go
|
|
import "github.com/nats-io/nats.go"
|
|
|
|
// Connect to NATS
|
|
nc, _ := nats.Connect(nats.DefaultURL)
|
|
|
|
// Create JetStream Context
|
|
js, _ := nc.JetStream()
|
|
|
|
// Create a Stream
|
|
js.AddStream(&nats.StreamConfig{
|
|
Name: "ORDERS",
|
|
Subjects: []string{"ORDERS.*"},
|
|
})
|
|
|
|
// Update a Stream
|
|
js.UpdateStream(&nats.StreamConfig{
|
|
Name: "ORDERS",
|
|
MaxBytes: 8,
|
|
})
|
|
|
|
// Create a Consumer
|
|
js.AddConsumer("ORDERS", &nats.ConsumerConfig{
|
|
Durable: "MONITOR",
|
|
})
|
|
|
|
// Delete Consumer
|
|
js.DeleteConsumer("ORDERS", "MONITOR")
|
|
|
|
// Delete Stream
|
|
js.DeleteStream("ORDERS")
|
|
```
|