feat: implement initial version of service

Author: sgtoj

.dockerignore

@@ -0,0 +1,5 @@
+.git
+.gitignore
+bin
+tmp
+.DS_Store

.editorconfig

@@ -0,0 +1,26 @@
+[*]
+indent_style = space
+indent_size = 2
+end_of_line = lf
+insert_final_newline = true
+trim_trailing_whitespace = true
+charset = utf-8
+
+[{Dockerfile,Dockerfile.*}]
+indent_size = 4
+tab_width = 4
+
+[{Makefile,makefile,GNUmakefile}]
+indent_style = tab
+indent_size = 4
+
+[Makefile.*]
+indent_style = tab
+indent_size = 4
+
+[**/*.{go,mod,sum}]
+indent_style = tab
+indent_size = unset
+
+[**/*.py]
+indent_size = 4

.github/dependabot.yaml

@@ -0,0 +1,11 @@
+version: 2
+updates:
+  - package-ecosystem: "github-actions"
+    directory: "/"
+    schedule:
+      interval: "weekly"
+
+  - package-ecosystem: "gomod"
+    directory: "/"
+    schedule:
+      interval: "weekly"

.github/workflows/ci.yaml

@@ -0,0 +1,78 @@
+name: ci
+
+on:
+  push:
+    branches:
+      - main
+  pull_request:
+    branches:
+      - main
+
+permissions:
+  contents: read
+
+jobs:
+  lint:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout Code
+        uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6.0.1
+
+      - name: Setup Go
+        uses: actions/setup-go@7a3fe6cf4cb3a834922a1244abfce67bcef6a0c5 # v6.2.0
+        with:
+          go-version: '1.26.2'
+
+      - name: Run go vet
+        run: go vet ./...
+
+      - name: Check formatting
+        run: |
+          unformatted=$(gofmt -l .)
+          if [ -n "$unformatted" ]; then
+            echo "The following files are not formatted:"
+            echo "$unformatted"
+            exit 1
+          fi
+
+  test-unit:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout Code
+        uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6.0.1
+
+      - name: Setup Go
+        uses: actions/setup-go@7a3fe6cf4cb3a834922a1244abfce67bcef6a0c5 # v6.2.0
+        with:
+          go-version: '1.26.2'
+
+      - name: Run unit tests
+        run: make test-unit
+
+  test-integration:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout Code
+        uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6.0.1
+
+      - name: Setup Go
+        uses: actions/setup-go@7a3fe6cf4cb3a834922a1244abfce67bcef6a0c5 # v6.2.0
+        with:
+          go-version: '1.26.2'
+
+      - name: Run integration tests
+        run: make test-integration
+
+  build:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout Code
+        uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6.0.1
+
+      - name: Setup Go
+        uses: actions/setup-go@7a3fe6cf4cb3a834922a1244abfce67bcef6a0c5 # v6.2.0
+        with:
+          go-version: '1.26.2'
+
+      - name: Build
+        run: make build

.github/workflows/release.yaml

@@ -0,0 +1,29 @@
+name: release
+
+on:
+  push:
+    branches:
+      - main
+
+permissions:
+  contents: write
+
+jobs:
+  release:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout Code
+        uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6.0.1
+      - name: Bump Version
+        id: tag_version
+        uses: mathieudutour/github-tag-action@a22cf08638b34d5badda920f9daf6e72c477b07b # v6.2.0
+        with:
+          github_token: ${{ secrets.GITHUB_TOKEN }}
+          default_bump: minor
+          custom_release_rules: bug:patch:Fixes,chore:patch:Chores,docs:patch:Documentation,feat:minor:Features,refactor:minor:Refactors,test:patch:Tests,ci:patch:Development,dev:patch:Development
+      - name: Create Release
+        uses: ncipollo/release-action@b7eabc95ff50cbeeedec83973935c8f306dfcd0b # v1.20.0
+        with:
+          tag: ${{ steps.tag_version.outputs.new_tag }}
+          name: ${{ steps.tag_version.outputs.new_tag }}
+          body: ${{ steps.tag_version.outputs.changelog }}

.github/workflows/semantic-check.yaml

@@ -0,0 +1,26 @@
+name: semantic-check
+on:
+  pull_request:
+    types:
+      - opened
+      - edited
+      - synchronize
+
+permissions:
+  contents: read
+  pull-requests: read
+
+jobs:
+  main:
+    name: Semantic Commit Message Check
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout Code
+        uses: actions/checkout@8e8c483db84b4bee98b60c0593521ed34d9990e8 # v6.0.1
+      - uses: amannn/action-semantic-pull-request@48f256284bd46cdaab1048c3721360e808335d50 # v6.1.1
+        name: Check PR for Semantic Commit Message
+        env:
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+        with:
+          requireScope: false
+          validateSingleCommit: true

.gitignore

@@ -0,0 +1,10 @@
+!**/.gitkeep
+
+tmp/
+dist/
+.DS_Store
+
+.local/
+.env
+
+

Dockerfile

@@ -0,0 +1,23 @@
+FROM golang:1.26.2-alpine AS builder
+
+WORKDIR /src
+
+COPY go.mod go.sum ./
+RUN go mod download
+
+COPY . .
+
+RUN CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build -trimpath -ldflags="-s -w" -o /out/server ./cmd/server
+
+FROM alpine:3.21
+
+RUN adduser -D -g '' appuser
+
+USER appuser
+WORKDIR /app
+
+COPY --from=builder /out/server /app/server
+
+EXPOSE 8080
+
+ENTRYPOINT ["/app/server"]

Makefile

@@ -0,0 +1,51 @@
+COMPOSE ?= docker compose
+
+.PHONY: test test-unit test-integration build run docker-build up down logs demo-send demo health report
+
+test:
+	go test ./...
+
+test-unit:
+	go test ./...
+
+test-integration:
+	go test ./... -run Integration -count=1
+
+build:
+	go build ./...
+
+run:
+	go run ./cmd/server
+
+docker-build:
+	$(COMPOSE) build api
+
+up:
+	$(COMPOSE) up --build -d api
+
+down:
+	$(COMPOSE) down -v --remove-orphans
+
+logs:
+	$(COMPOSE) logs -f api
+
+demo-send:
+	$(COMPOSE) run --rm demo-sender
+
+demo: up demo-send
+	$(COMPOSE) logs api
+
+health:
+	@BASE_PATH="$${BASE_PATH:-/}"; \
+	URL_PATH="$${BASE_PATH%/}/v1/manage/healthz"; \
+	if [ -z "$${URL_PATH}" ]; then URL_PATH="/v1/manage/healthz"; fi; \
+	curl -fsS "http://localhost:8080$${URL_PATH}"
+
+report:
+	@BASE_PATH="$${BASE_PATH:-/}"; \
+	URL_PATH="$${BASE_PATH%/}/v1/reports"; \
+	if [ -z "$${URL_PATH}" ]; then URL_PATH="/v1/reports"; fi; \
+	curl -i -X POST \
+	  -H 'Content-Type: application/reports+json' \
+	  --data-binary @demo/reports.json \
+	  "http://localhost:8080$${URL_PATH}"

cmd/server/main.go

@@ -0,0 +1,74 @@
+package main
+
+import (
+	"context"
+	"log/slog"
+	"net/http"
+	"os"
+	"os/signal"
+	"syscall"
+	"time"
+
+	"github.com/cruxstack/browser-reporting-api/internal/config"
+	"github.com/cruxstack/browser-reporting-api/internal/httpx"
+	"github.com/cruxstack/browser-reporting-api/internal/management"
+	"github.com/cruxstack/browser-reporting-api/internal/parser"
+	"github.com/cruxstack/browser-reporting-api/internal/reporting"
+	"github.com/cruxstack/browser-reporting-api/internal/stream"
+)
+
+func main() {
+	slog.SetDefault(slog.New(slog.NewJSONHandler(os.Stderr, nil)))
+
+	cfg, err := config.LoadFromEnv()
+	if err != nil {
+		slog.Error("load config", "error", err)
+		os.Exit(1)
+	}
+
+	writer := stream.NewNDJSONWriter(os.Stdout)
+	reportsParser := parser.NewJSONBatchParser()
+	reportsService := reporting.NewService(reportsParser, writer)
+	originMatcher, err := httpx.NewOriginMatcher(cfg.AllowedOrigins)
+	if err != nil {
+		slog.Error("build origin matcher", "error", err)
+		os.Exit(1)
+	}
+
+	reportsHandler := reporting.NewHandler(reportsService, cfg.MaxBodyBytes, originMatcher)
+	managementHandler := management.NewHandler()
+	handler := httpx.NewRouter(cfg.BasePath, reportsHandler.Routes(), managementHandler.Routes())
+
+	srv := &http.Server{
+		Addr:              cfg.ListenAddr,
+		Handler:           handler,
+		ReadHeaderTimeout: 5 * time.Second,
+		ReadTimeout:       10 * time.Second,
+		WriteTimeout:      10 * time.Second,
+		IdleTimeout:       60 * time.Second,
+	}
+
+	go func() {
+		slog.Info("listening", "addr", cfg.ListenAddr, "base_path", cfg.BasePath)
+		if err := srv.ListenAndServe(); err != nil && err != http.ErrServerClosed {
+			slog.Error("server error", "error", err)
+			os.Exit(1)
+		}
+	}()
+
+	ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt, syscall.SIGTERM)
+	defer stop()
+
+	<-ctx.Done()
+	slog.Info("shutting down")
+
+	shutdownCtx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
+	defer cancel()
+
+	if err := srv.Shutdown(shutdownCtx); err != nil {
+		slog.Error("graceful shutdown failed", "error", err)
+		if closeErr := srv.Close(); closeErr != nil {
+			slog.Error("force close failed", "error", closeErr)
+		}
+	}
+}