Handle internal sandbox events from sandboxes in orchestrator

.github/actions/start-services/action.yml

@@ -75,12 +75,20 @@ runs:
         make -C packages/clickhouse migrate-without-build
       shell: bash
 
+    - name: Run Redis
+      run: |
+        echo "REDIS_URL=localhost:6379" >> .env.test
+
+        docker run -d --name redis -p 6379:6379 redis:7.4.2-alpine
+      shell: bash
+
     - name: Start Services
       env:
         ENVD_TIMEOUT: "60s"
         ORCHESTRATOR_SERVICES: "orchestrator,template-manager"
         SANDBOX_ACCESS_TOKEN_HASH_SEED: "abcdefghijklmnopqrstuvwxyz"
         TEMPLATE_MANAGER_HOST: "localhost:5008"
+        REDIS_URL: "localhost:6379"
         ARTIFACTS_REGISTRY_PROVIDER: "Local"
         STORAGE_PROVIDER: "Local"
         ENVIRONMENT: "local"

packages/api/go.mod

@@ -253,7 +253,7 @@ require (
 	golang.org/x/mod v0.25.0 // indirect
 	golang.org/x/net v0.41.0 // indirect
 	golang.org/x/oauth2 v0.30.0 // indirect
-	golang.org/x/sync v0.15.0
+	golang.org/x/sync v0.17.0
 	golang.org/x/sys v0.33.0 // indirect
 	golang.org/x/text v0.26.0 // indirect
 	golang.org/x/time v0.11.0 // indirect

packages/client-proxy/go.mod

@@ -82,7 +82,7 @@ require (
 	golang.org/x/crypto v0.39.0 // indirect
 	golang.org/x/mod v0.25.0 // indirect
 	golang.org/x/net v0.41.0 // indirect
-	golang.org/x/sync v0.15.0 // indirect
+	golang.org/x/sync v0.17.0 // indirect
 	golang.org/x/sys v0.33.0 // indirect
 	golang.org/x/text v0.26.0 // indirect
 	golang.org/x/tools v0.34.0 // indirect

packages/db/go.mod

@@ -81,7 +81,7 @@ require (
 	golang.org/x/exp v0.0.0-20250531010427-b6e5de432a8b // indirect
 	golang.org/x/mod v0.25.0 // indirect
 	golang.org/x/net v0.41.0 // indirect
-	golang.org/x/sync v0.15.0 // indirect
+	golang.org/x/sync v0.17.0 // indirect
 	golang.org/x/sys v0.33.0 // indirect
 	golang.org/x/text v0.26.0 // indirect
 	google.golang.org/genproto/googleapis/api v0.0.0-20250519155744-55703ea1f237 // indirect

packages/docker-reverse-proxy/go.mod

@@ -26,6 +26,6 @@ require (
 	github.com/rogpeppe/go-internal v1.13.1 // indirect
 	github.com/zclconf/go-cty v1.14.1 // indirect
 	golang.org/x/mod v0.25.0 // indirect
-	golang.org/x/sync v0.15.0 // indirect
+	golang.org/x/sync v0.17.0 // indirect
 	golang.org/x/text v0.26.0 // indirect
 )

packages/envd/go.mod

@@ -52,7 +52,7 @@ require (
 	github.com/vmware-labs/yaml-jsonpath v0.3.2 // indirect
 	github.com/yusufpapurcu/wmi v1.2.4 // indirect
 	golang.org/x/mod v0.25.0 // indirect
-	golang.org/x/sync v0.15.0 // indirect
+	golang.org/x/sync v0.17.0 // indirect
 	golang.org/x/text v0.26.0 // indirect
 	golang.org/x/tools v0.34.0 // indirect
 	gopkg.in/yaml.v2 v2.4.0 // indirect

packages/orchestrator/go.mod

@@ -37,7 +37,7 @@ require (
 	go.opentelemetry.io/otel/sdk/metric v1.36.0
 	go.opentelemetry.io/otel/trace v1.36.0
 	go.uber.org/zap v1.27.0
-	golang.org/x/sync v0.15.0
+	golang.org/x/sync v0.17.0
 	golang.org/x/sys v0.33.0
 	google.golang.org/grpc v1.73.0
 	google.golang.org/protobuf v1.36.6

packages/orchestrator/internal/consts.go

@@ -0,0 +1,20 @@
+package internal
+
+import (
+	"github.com/e2b-dev/infra/packages/shared/pkg/env"
+)
+
+const (
+	// Private IP don't leave the sandbox through the network bridge, so we use a reserved IP address for it:
+	// See TEST-NET-3 on https://en.wikipedia.org/wiki/Reserved_IP_addresses
+	defaultSandboxEventIP = "203.0.113.0"
+	defaultEventProxyPort = "5010"
+)
+
+func GetSandboxEventIP() string {
+	return env.GetEnv("SANDBOX_EVENT_IP", defaultSandboxEventIP)
+}
+
+func GetEventProxyPort() string {
+	return env.GetEnv("SANDBOX_EVENT_PROXY_PORT", defaultEventProxyPort)
+}

packages/orchestrator/internal/events/events_service.go

@@ -4,7 +4,7 @@ import (
 	"context"
 )
 
-type EventsService[T any] interface {
+type EventService[T any] interface {
 	HandleEvent(ctx context.Context, event T)
 	Close(ctx context.Context) error
 }

packages/orchestrator/internal/events/mock_events_service.go

@@ -4,23 +4,23 @@ import (
 	"context"
 )
 
-// MockEventsService implements EventsService interface for testing
-type MockEventsService[T any] struct {
+// MockEventService implements EventsService interface for testing
+type MockEventService[T any] struct {
 	HandleEventFunc func(ctx context.Context, event T) error
 	CloseFunc       func(ctx context.Context) error
 }
 
-func NewMockEventsService[T any]() *MockEventsService[T] {
-	return &MockEventsService[T]{
+func NewMockEventsService[T any]() *MockEventService[T] {
+	return &MockEventService[T]{
 		HandleEventFunc: func(ctx context.Context, event T) error { return nil },
 		CloseFunc:       func(ctx context.Context) error { return nil },
 	}
 }
 
-func (m *MockEventsService[T]) HandleEvent(ctx context.Context, event T) error {
+func (m *MockEventService[T]) HandleEvent(ctx context.Context, event T) error {
 	return m.HandleEventFunc(ctx, event)
 }
 
-func (m *MockEventsService[T]) Close(ctx context.Context) error {
+func (m *MockEventService[T]) Close(ctx context.Context) error {
 	return m.CloseFunc(ctx)
 }

packages/orchestrator/internal/events/mock_sandbox_events_proxy.go

@@ -0,0 +1,22 @@
+package events
+
+import (
+	"context"
+)
+
+// NoopSandboxEventProxy is a simple Noop that doesn't do anything
+type NoopSandboxEventProxy struct{}
+
+func NewNoopSandboxEventProxy() *NoopSandboxEventProxy {
+	return &NoopSandboxEventProxy{}
+}
+
+func (m *NoopSandboxEventProxy) Start() error {
+	// No-op
+	return nil
+}
+
+func (m *NoopSandboxEventProxy) Close(ctx context.Context) error {
+	// No-op
+	return nil
+}

packages/orchestrator/internal/events/mock_sandbox_events_service.go

@@ -0,0 +1,23 @@
+package events
+
+import (
+	"context"
+
+	"github.com/e2b-dev/infra/packages/shared/pkg/events/event"
+)
+
+// NoopSandboxEventsService is a simple Noop that doesn't do anything
+type NoopSandboxEventsService struct{}
+
+func NewNoopSandboxEventsService() *NoopSandboxEventsService {
+	return &NoopSandboxEventsService{}
+}
+
+func (m *NoopSandboxEventsService) HandleEvent(ctx context.Context, event event.SandboxEvent) {
+	// No-op
+}
+
+func (m *NoopSandboxEventsService) Close(ctx context.Context) error {
+	// No-op
+	return nil
+}

packages/orchestrator/internal/events/mock_sandbox_events_store.go

@@ -0,0 +1,53 @@
+package events
+
+import (
+	"context"
+	"time"
+)
+
+// NoopSandboxEventStore is a simple Noop that doesn't do anything
+type NoopSandboxEventStore struct{}
+
+func NewNoopSandboxEventStore() SandboxEventStore {
+	return &NoopSandboxEventStore{}
+}
+
+func (m *NoopSandboxEventStore) SetSandboxIP(ctx context.Context, sandboxID string, sandboxIP string) error {
+	// No-op
+	return nil
+}
+
+func (m *NoopSandboxEventStore) GetSandboxID(ctx context.Context, sandboxIP string) (string, error) {
+	// No-op
+	return "", nil
+}
+
+func (m *NoopSandboxEventStore) DelSandboxIP(ctx context.Context, sandboxIP string) error {
+	// No-op
+	return nil
+}
+
+func (m *NoopSandboxEventStore) GetLastEvent(ctx context.Context, sandboxID string) (*SandboxEvent, error) {
+	// No-op
+	return nil, nil
+}
+
+func (m *NoopSandboxEventStore) GetLastNEvents(ctx context.Context, sandboxID string, n int) ([]*SandboxEvent, error) {
+	// No-op
+	return nil, nil
+}
+
+func (m *NoopSandboxEventStore) AddEvent(ctx context.Context, sandboxID string, event *SandboxEvent, expiration time.Duration) error {
+	// No-op
+	return nil
+}
+
+func (m *NoopSandboxEventStore) DelEvent(ctx context.Context, sandboxID string) error {
+	// No-op
+	return nil
+}
+
+func (m *NoopSandboxEventStore) Close(ctx context.Context) error {
+	// No-op
+	return nil
+}