initial commit

Author: Tofel

framework/components/chip_ingress/chip_ingress.go

@@ -0,0 +1,61 @@
+package chipingress
+
+import (
+	"context"
+	"fmt"
+	"log"
+	"time"
+
+	"github.com/pkg/errors"
+	"github.com/testcontainers/testcontainers-go"
+	"github.com/testcontainers/testcontainers-go/modules/compose"
+)
+
+type Output struct {
+	InternalURL string
+	ExternalURL string
+}
+
+func New(ctx context.Context) (*Output, error) {
+	composeFile := "./docker-compose.yml"
+	stack, err := compose.NewDockerCompose([]string{composeFile},
+		compose.WithStackName("chip_stack"),
+		compose.WithEnv(map[string]string{
+			// optional: override any env vars here
+			// "SERVER_METRICS_OTEL_EXPORTER_GRPC_ENDPOINT": "otel-lgtm:4317",
+		}),
+	)
+	if err != nil {
+		return nil, errors.Wrap(err, "failed to create compose stack")
+	}
+
+	// Add to existing Docker network
+	stack = stack.WithAdditionalOptions(func(s *testcontainers.DockerCompose) {
+		s.WithCustomNetwork("my_shared_net") // your existing network name
+	})
+
+	fmt.Println("Bringing up stack...")
+	if err := stack.Up(ctx, compose.Wait(true)); err != nil {
+		log.Fatalf("Failed to start stack: %v", err)
+	}
+	defer func() {
+		_ = stack.Down(ctx, compose.RemoveOrphans(true), compose.RemoveImagesLocal)
+	}()
+
+	// Optional: wait for chip-ingress to become healthy
+	time.Sleep(5 * time.Second)
+
+	// Retrieve internal and external ports
+	ingress, err := stack.ServiceContainer(ctx, "chip-ingress")
+	if err != nil {
+		log.Fatalf("Failed to get chip-ingress container: %v", err)
+	}
+
+	internalHost := "chip-ingress"
+	internalPort := "50051" // from service definition
+	externalHost := "localhost"
+	externalPort, err := ingress.MappedPort(ctx, "50051")
+	if err != nil {
+		log.Fatalf("Failed to get mapped port: %v", err)
+	}
+}

framework/components/chip_ingress/docker-compose.yml

@@ -0,0 +1,106 @@
+services:
+
+  chip-ingress:
+    image: chip-ingress:latest
+    container_name: chip-ingress
+    depends_on:
+      - redpanda-0
+      - otel-lgtm
+
+    restart: on-failure
+    tty: true
+    command: ["write-service"]
+    environment:
+      SERVER_HOST: "0.0.0.0"
+      SERVER_GRPC_PORT: "50051"
+      SERVER_METRICS_PORT: "9090"
+      SERVER_HEALTHCHECKS_PORT: "9091"
+      SERVER_METRICS_IMPLEMENTATION: "otel"
+      SERVER_METRICS_OTEL_EXPORTER_GRPC_ENDPOINT: ${SERVER_METRICS_OTEL_EXPORTER_GRPC_ENDPOINT:-otel-lgtm:4317}
+      KAFKA_BROKERS: "redpanda-0:9092"
+      SCHEMA_REGISTRY_URL: "http://redpanda-0:8081"
+      BASIC_AUTH_ENABLED: ${BASIC_AUTH_ENABLED:-true}
+      BASIC_AUTH_PREFIX: ${BASIC_AUTH_PREFIX:-CE_SA_}
+      CE_SA_BEHOLDER_DEMO_CLIENT: |
+        {"username": "beholder-demo-client", "password": "password", "allowed_domains": ["*"]}
+      CSA_AUTH_ENABLED: ${CSA_AUTH_ENABLED:-false}
+      CSA_AUTH_ADDRESS: ${CSA_AUTH_ADDRESS:-}
+      CSA_AUTH_USERNAME: ${CSA_AUTH_USERNAME:-}
+      CSA_AUTH_PASSWORD: ${CSA_AUTH_PASSWORD:-}
+      CSA_AUTH_REQUIRE_TLS: ${CSA_AUTH_REQUIRE_TLS:-false}
+    ports:
+      - "50051:50051"
+      - "9090:9090"
+      - "9092:9091"
+    healthcheck:
+      # test: [ "CMD", "grpc_health_probe", "-addr=localhost:50051" ]
+      test: [ "CMD-SHELL", "sleep 1"]
+      interval: 200ms
+      timeout: 10s
+      retries: 10
+
+  redpanda-0:
+    image: docker.redpanda.com/redpandadata/redpanda
+    container_name: redpanda-0
+    hostname: redpanda-0
+    command:
+      - redpanda
+      - start
+      - --kafka-addr internal://0.0.0.0:9092,external://0.0.0.0:19092
+      - --advertise-kafka-addr internal://redpanda-0:9092,external://localhost:19092
+      - --pandaproxy-addr internal://0.0.0.0:8082,external://0.0.0.0:18082
+      - --advertise-pandaproxy-addr internal://redpanda-0:8082,external://localhost:18082
+      - --schema-registry-addr internal://0.0.0.0:8081,external://0.0.0.0:18081
+      - --rpc-addr redpanda-0:33145
+      - --advertise-rpc-addr redpanda-0:33145
+      - --mode dev-container
+      - --smp 1
+      - --default-log-level=info
+      - --set redpanda.auto_create_topics_enabled=true
+    ports:
+      - "18081:18081"
+      - "18082:18082"
+      - "19092:19092"
+      - "19644:9644"
+    healthcheck:
+      test: curl -f http://localhost:9644/v1/status/ready || exit 1
+      interval: 1s
+      timeout: 10s
+      retries: 5
+      start_period: 1s
+
+  redpanda-console:
+    container_name: redpanda-console
+    image: docker.redpanda.com/redpandadata/console
+    entrypoint: /bin/sh
+    command: -c 'echo "$$CONSOLE_CONFIG_FILE" > /tmp/config.yml; /app/console'
+    environment:
+      CONFIG_FILEPATH: /tmp/config.yml
+      CONSOLE_CONFIG_FILE: |
+        kafka:
+          brokers: ["redpanda-0:9092"]
+          schemaRegistry:
+            enabled: true
+            urls: ["http://redpanda-0:8081"]
+          protobuf:
+            enabled: true
+            schemaRegistry:
+              enabled: true
+              refreshInterval: 5s
+        redpanda:
+          adminApi:
+            enabled: true
+            urls: ["http://redpanda-0:9644"]
+    ports:
+      - "8080:8080"
+    depends_on:
+      - redpanda-0
+
+  otel-lgtm:
+    image: grafana/otel-lgtm
+    ports:
+      - "3000:3000"
+      - "4317:4317"
+      - "4318:4318"
+      - "3100:3100"
+