fix(tests): pass message_id from FCM payload to outstanding endpoint

The emulator was calling GET /v1/messages/outstanding without the
required message_id query parameter, causing a 422 validation error.
Also fixed response parsing since the API returns a single message
object, not an array.

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>

Author: AchoArnold

tests/emulator/events.go

@@ -11,10 +11,10 @@ import (
 )
 
 // ProcessOutstandingMessages fetches outstanding messages and fires SENT/DELIVERED events.
-func (e *Emulator) ProcessOutstandingMessages() {
+func (e *Emulator) ProcessOutstandingMessages(messageID string) {
 	time.Sleep(500 * time.Millisecond)
 
-	messages := e.fetchOutstandingMessages()
+	messages := e.fetchOutstandingMessages(messageID)
 	for _, msg := range messages {
 		msgID, ok := msg["id"].(string)
 		if !ok {
@@ -32,9 +32,9 @@ func (e *Emulator) ProcessOutstandingMessages() {
 	}
 }
 
-// fetchOutstandingMessages calls GET /v1/messages/outstanding.
-func (e *Emulator) fetchOutstandingMessages() []map[string]interface{} {
-	url := fmt.Sprintf("%s/v1/messages/outstanding", e.apiBaseURL)
+// fetchOutstandingMessages calls GET /v1/messages/outstanding?message_id=<id>.
+func (e *Emulator) fetchOutstandingMessages(messageID string) []map[string]interface{} {
+	url := fmt.Sprintf("%s/v1/messages/outstanding?message_id=%s", e.apiBaseURL, messageID)
 
 	req, err := http.NewRequest(http.MethodGet, url, nil)
 	if err != nil {
@@ -67,21 +67,15 @@ func (e *Emulator) fetchOutstandingMessages() []map[string]interface{} {
 		return nil
 	}
 
-	data, ok := result["data"].([]interface{})
+	// The API returns a single message object in "data", not an array
+	data, ok := result["data"].(map[string]interface{})
 	if !ok {
-		log.Printf("[EVENTS] no data array in response")
+		log.Printf("[EVENTS] no data object in response")
 		return nil
 	}
 
-	var messages []map[string]interface{}
-	for _, item := range data {
-		if msg, ok := item.(map[string]interface{}); ok {
-			messages = append(messages, msg)
-		}
-	}
-
-	log.Printf("[EVENTS] found %d outstanding messages", len(messages))
-	return messages
+	log.Printf("[EVENTS] found outstanding message")
+	return []map[string]interface{}{data}
 }
 
 // fireEvent posts a message event (SENT or DELIVERED).

tests/emulator/fcm_handler.go

@@ -1,24 +1,44 @@
 package main
 
 import (
+	"encoding/json"
 	"log"
 
 	"github.com/gofiber/fiber/v3"
 )
 
+// fcmRequest represents the FCM push notification payload from the API.
+type fcmRequest struct {
+	Message struct {
+		Data map[string]string `json:"data"`
+	} `json:"message"`
+}
+
 // HandleFCM receives FCM push notification requests from the API.
 // After receiving a push, it triggers SENT and DELIVERED events asynchronously.
 func (e *Emulator) HandleFCM(c fiber.Ctx) error {
 	log.Printf("[FCM] %s %s", c.Method(), c.Path())
 	log.Printf("[FCM] body: %s", string(c.Body()))
 
+	var req fcmRequest
+	if err := json.Unmarshal(c.Body(), &req); err != nil {
+		log.Printf("[FCM] error parsing body: %v", err)
+		return c.Status(400).JSON(fiber.Map{"error": "invalid request"})
+	}
+
+	messageID := req.Message.Data["KEY_MESSAGE_ID"]
+	if messageID == "" {
+		log.Printf("[FCM] no KEY_MESSAGE_ID in data payload")
+		return c.Status(400).JSON(fiber.Map{"error": "missing KEY_MESSAGE_ID"})
+	}
+
 	// Respond with a fake FCM success response
 	err := c.JSON(fiber.Map{
 		"name": "projects/httpsms-test/messages/fake-message-id",
 	})
 
 	// Fire events asynchronously (mimics phone receiving push and responding)
-	go e.ProcessOutstandingMessages()
+	go e.ProcessOutstandingMessages(messageID)
 
 	return err
 }