feat: relaybox v0.2.0 — 프로젝트 리네이밍, 파서 파이프라인, CEL/Expr 표현식 엔진, TCP 어댑터

[ppzxc]

요약

• Phase 1: 모듈명 webhook-relay → relaybox 변경, 바이너리/cobra/버전 문자열 업데이트, README 범용 릴레이 컨셉으로 재작성
• Phase 2: 도메인 용어 변경 Alert→Message, Channel→Output, Route→Rule, SourceType→InputType; HTTP 경로 /sources/{sourceId}/alerts → /inputs/{inputId}/messages; SQLite 스키마 alerts→messages 테이블 재생성
• Phase 3: 파서 파이프라인 추가 — JSON/Form/XML/Logfmt/Regex 파서 + ParserRegistry; Message.ParsedData map[string]any 필드 추가; 파서를 YAML 설정으로 인바운드별 지정 가능
• Phase 4: Go 템플릿 → CEL/Expr 표현식 엔진으로 교체; RelayWorker에 filter→mapping→routing→template 파이프라인 추가; Output.Template map[string]string; RuleConfig에 Engine/Filter/Mapping/Routing 필드 추가
• Phase 5: TCP 인바운드 어댑터 추가 (구분자 기반 프레이밍, 커넥션당 고루틴, 우아한 종료); InputConfig에 Address/Delimiter 필드 추가; TCP 설정 검증 강화

테스트 계획

• CGO_ENABLED=1 go build -o relaybox ./cmd/server/ 빌드 성공
• go test -race ./... -timeout 60s — 15개 패키지 전체 통과
• go vet ./... — 경고 없음
• E2E: HTTP POST JSON → CEL 필터/매핑 → 웹훅 아웃바운드 전달 확인
• E2E: TCP 클라이언트에서 개행 구분 메시지 전송 → 파싱 → 릴레이 확인
• 설정 핫리로드: config.yaml 룰 수정 → 재시작 없이 반영 확인

[ppzxc]

Code Review Summary

Overall quality is high. Hexagonal architecture is maintained throughout all 5 phases, all 15 test packages pass with the race detector, and go vet is clean.

Important (should fix before or shortly after merge)

1. buildEvalData ParsedData key shadowing built-ins
internal/application/service/relay_worker.go:215-228
ParsedData keys are merged into the flat data map alongside built-ins (id, input, payload, createdAt, status). A JSON body with {"id": "attacker-controlled"} silently overwrites the built-in id. Document priority order explicitly or enforce built-in precedence (iterate ParsedData first, then overwrite with built-ins).

2. Deduplication aliases stored outputs slice backing array
internal/application/service/relay_worker.go:116-150
When len(rule.Routing) == 0, routedOutputs = outputs aliases the slice returned by GetRule. The subsequent deduped := routedOutputs[:0] trick then aliases the stored slice's backing array. Safe today (no duplicates in practice) but fragile — use slices.Clone(outputs) or an explicit copy.

3. time.Sleep-based test assertions
internal/application/service/relay_worker_test.go
Several tests use time.Sleep(150ms) to wait for async processing. Replace with a poll-with-timeout pattern (similar to the waitForCalls helper already used in listener_test.go) for robustness.

4. Config validation missing inputId reference check
internal/config/config.go — validateIDs()
Rules with an inputId that doesn't match any declared input silently have no effect. Add a check alongside the existing outputId validation.

Suggestions

• internal/adapter/output/webhook/sender.go — new http.Client allocated on every Send() call, preventing connection reuse. Consider a shared client with per-output TLS config.
• internal/adapter/input/http/router.go:57 — GET /inputs/{inputId}/messages/{messageId} placeholder returns 200 OK (healthz). Should return 501 Not Implemented to avoid confusing API consumers.
• internal/domain/input_type.go — IsValid() hard-codes 3 types (BESZEL, DOZZLE, GENERIC). Inconsistent with the generic relay concept — either remove or adopt an open-world assumption.
• Missing tests: TCP 1 MiB size limit boundary, ParsedData key collision priority order.

What Was Done Well

• CEL engine single cel.Env with map(string, dyn) wrapping correctly eliminates schema-keyed cache collision. TestCELEngine_DifferentSchemas_SameExpression directly validates the fix.
• TCP StartWithListener split is excellent for testability.
• Parallel-semantics mapping step is documented clearly in a comment.
• Retry backoff in relay_worker.go:deliver uses exponential backoff with context-aware cancellation.
• Graceful shutdown sequence in main.go (cancel → worker.Wait → srv.Shutdown) is correctly ordered.

[ppzxc]

코드 리뷰 요약

전체적으로 높은 품질입니다. 5개 Phase 전반에 걸쳐 헥사고날 아키텍처가 유지되었고, 15개 테스트 패키지 모두 레이스 디텍터 포함 통과, go vet 경고 없음.

(이전 영문 리뷰의 한글 버전입니다.)

---

중요 (머지 전후 수정 권장)

1. buildEvalData에서 ParsedData 키가 내장 키를 덮어씀
internal/application/service/relay_worker.go:215-228
ParsedData 키가 내장 키(id, input, payload, createdAt, status)와 동일한 flat map에 병합됩니다. 예를 들어 {"id": "공격자-제어값"}이 포함된 JSON 바디가 내장 id를 조용히 덮어씁니다. 우선순위를 명시적으로 문서화하거나, 내장 키가 항상 우선하도록 순서를 보장해야 합니다(ParsedData 먼저 순회 후 내장 키로 덮어쓰기).

2. 중복 제거 로직이 stored outputs slice의 backing array를 alias함
internal/application/service/relay_worker.go:116-150
len(rule.Routing) == 0일 때 routedOutputs = outputs가 GetRule이 반환한 슬라이스를 alias합니다. 이후 deduped := routedOutputs[:0] 트릭이 stored slice의 backing array를 alias하게 됩니다. 현재는 중복이 없어 안전하지만 잠재적으로 취약합니다 — slices.Clone(outputs) 또는 명시적 복사 사용을 권장합니다.

3. time.Sleep 기반 테스트 assertion
internal/application/service/relay_worker_test.go
일부 테스트가 비동기 처리를 기다리기 위해 time.Sleep(150ms)를 사용합니다. listener_test.go에서 이미 사용 중인 waitForCalls 헬퍼와 같이 poll-with-timeout 패턴으로 교체하면 더 견고해집니다.

4. 설정 검증에서 inputId 참조 확인 누락
internal/config/config.go — validateIDs()
선언된 input을 참조하지 않는 inputId를 가진 룰이 조용히 no-op 됩니다. 기존 outputId 검증과 동일하게 inputId 참조 확인을 추가해야 합니다.

---

제안 (선택 사항)

• internal/adapter/output/webhook/sender.go — Send() 호출마다 새 http.Client를 생성해 커넥션 재사용이 불가합니다. 공유 클라이언트에 output별 TLS 설정 방식을 고려해 보세요.
• internal/adapter/input/http/router.go:57 — GET /inputs/{inputId}/messages/{messageId} placeholder가 200 OK를 반환합니다. API 사용자 혼란 방지를 위해 501 Not Implemented를 반환하는 것이 좋습니다.
• internal/domain/input_type.go — IsValid()가 3개 타입(BESZEL, DOZZLE, GENERIC)만 하드코딩되어 있어 범용 릴레이 컨셉과 불일치합니다. 제거하거나 개방형 가정(open-world assumption)을 채택하는 것을 권장합니다.
• 추가 테스트 권장: TCP 1MiB 크기 제한 경계값, ParsedData 키 충돌 우선순위.

---

잘 된 점

• CEL 엔진의 단일 cel.Env + map(string, dyn) 래핑이 이전 스키마 키 기반 캐시 충돌 문제를 올바르게 해결했습니다. TestCELEngine_DifferentSchemas_SameExpression 테스트가 이를 직접 검증합니다.
• TCP StartWithListener 분리가 테스트 용이성을 크게 향상시켰습니다.
• 매핑 단계의 병렬 평가 시맨틱이 주석으로 명확히 문서화되어 있습니다.
• relay_worker.go:deliver의 재시도 백오프가 context 인식 지수 백오프를 사용합니다.
• main.go의 우아한 종료 순서(cancel → worker.Wait → srv.Shutdown)가 올바릅니다.