feat: answer/dial/control WhatsApp calls and stream their audio/video over WebSocket

.gitignore

@@ -7,3 +7,4 @@ coverage.*
 .idea/
 .vscode/
 .DS_Store
+.superpowers/

cmd/evolution-go/main.go

@@ -22,7 +22,9 @@ import (
 	_ "modernc.org/sqlite"
 
 	call_handler "github.com/evolution-foundation/evolution-go/pkg/call/handler"
+	call_registry "github.com/evolution-foundation/evolution-go/pkg/call/registry"
 	call_service "github.com/evolution-foundation/evolution-go/pkg/call/service"
+	call_stream "github.com/evolution-foundation/evolution-go/pkg/call/stream"
 	chat_handler "github.com/evolution-foundation/evolution-go/pkg/chat/handler"
 	chat_service "github.com/evolution-foundation/evolution-go/pkg/chat/service"
 	community_handler "github.com/evolution-foundation/evolution-go/pkg/community/handler"
@@ -85,6 +87,7 @@ func init() {
 func setupRouter(db *gorm.DB, authDB *sql.DB, sqliteDB *sql.DB, config *config.Config, conn *amqp.Connection, exPath string, runtimeCtx *core.RuntimeContext) *gin.Engine {
 	killChannel := make(map[string](chan bool))
 	clientPointer := make(map[string]*whatsmeow.Client)
+	callRegistry := call_registry.NewCallRegistry()
 
 	loggerWrapper := logger_wrapper.NewLoggerManager(config)
 
@@ -177,6 +180,7 @@ func setupRouter(db *gorm.DB, authDB *sql.DB, sqliteDB *sql.DB, config *config.C
 		exPath,
 		mediaStorage,
 		natsProducer,
+		callRegistry,
 		loggerWrapper,
 	)
 	instanceService := instance_service.NewInstanceService(
@@ -192,7 +196,7 @@ func setupRouter(db *gorm.DB, authDB *sql.DB, sqliteDB *sql.DB, config *config.C
 	messageService := message_service.NewMessageService(clientPointer, messageRepository, whatsmeowService, loggerWrapper)
 	chatService := chat_service.NewChatService(clientPointer, whatsmeowService, loggerWrapper)
 	groupService := group_service.NewGroupService(clientPointer, whatsmeowService, loggerWrapper)
-	callService := call_service.NewCallService(clientPointer, whatsmeowService, loggerWrapper)
+	callService := call_service.NewCallService(clientPointer, whatsmeowService, callRegistry, loggerWrapper)
 	communityService := community_service.NewCommunityService(clientPointer, whatsmeowService, loggerWrapper)
 	labelService := label_service.NewLabelService(clientPointer, whatsmeowService, labelRepository, loggerWrapper)
 	newsletterService := newsletter_service.NewNewsletterService(clientPointer, whatsmeowService, loggerWrapper)
@@ -224,6 +228,7 @@ func setupRouter(db *gorm.DB, authDB *sql.DB, sqliteDB *sql.DB, config *config.C
 	// Passkey ceremony routes — PUBLIC (called by the browser extension from the
 	// web.whatsapp.com origin, gated only by an opaque ephemeral token).
 	passkey_handler.RegisterRoutes(r, whatsmeowService)
+	call_stream.RegisterRoutes(r, callService, instanceService)
 
 	routes.NewRouter(
 		auth_middleware.NewMiddleware(config, instanceService),