fix: correct the test issue

internal/infra/cmq/cmq.go

@@ -197,7 +197,7 @@ func (c *CMQ) Publish(ctx context.Context, id string, data []byte) error {
 	msg.Header = make(nats.Header)
 	otel.GetTextMapPropagator().Inject(ctx, propagation.HeaderCarrier(msg.Header))
 
-	if _, err := c.jetstream.PublishMsg(ctx, msg, jetstream.WithMsgID(id)); err != nil {
+	if _, err := c.jetstream.PublishMsg(context.Background(), msg, jetstream.WithMsgID(id)); err != nil {
 		return fmt.Errorf("jetstream publish message failed %w", err)
 	}
 

internal/infra/http/handler/event.go

@@ -55,7 +55,11 @@ func (h Event) Receive(c *fiber.Ctx) error {
 	}
 
 	{
-		ctx, span := h.Tracer.Start(ctx, "handler.event.publish", trace.WithSpanKind(trace.SpanKindProducer))
+		ctx, span := h.Tracer.Start(
+			ctx,
+			"handler.event.publish",
+			trace.WithSpanKind(trace.SpanKindProducer),
+		)
 		defer span.End()
 
 		if err := h.CMQ.Publish(ctx, rq.ID, data); err != nil {

internal/infra/http/handler/event_test.go

@@ -4,6 +4,7 @@ import (
 	"bytes"
 	"context"
 	"encoding/json"
+	"io"
 	"net/http"
 	"net/http/httptest"
 	"testing"
@@ -64,7 +65,11 @@ func (suite *EventSuite) TestHandler() {
 
 	resp, err := suite.engine.Test(req)
 	require.NoError(err)
-	require.Equal(http.StatusOK, resp.StatusCode)
+
+	body, err := io.ReadAll(resp.Body)
+	require.NoError(err)
+
+	require.Equal(http.StatusOK, resp.StatusCode, string(body))
 	require.NoError(resp.Body.Close())
 }
 

justfile

@@ -23,7 +23,7 @@ dev cmd *flags:
     fi
 
 # run tests in the dev environment
-test $saf_telemetry__meter__enabled="false": (dev "up")
+test $saf_telemetry__meter__enabled="false": (dev "up --wait")
     go test -v ./... -covermode=atomic -coverprofile=coverage.out
 
 # run golangci-lint