Add handlers for message sent events

Author: AchoArnold

api/pkg/events/message_phone_sent_event.go

@@ -1,14 +1,19 @@
 package events
 
-import "github.com/google/uuid"
+import (
+	"time"
+
+	"github.com/google/uuid"
+)
 
 // EventTypeMessagePhoneSent is emitted when the phone sends a message
 const EventTypeMessagePhoneSent = "message.phone.sent"
 
 // MessagePhoneSentPayload is the payload of the EventTypeMessagePhoneSent event
 type MessagePhoneSentPayload struct {
-	ID      uuid.UUID `json:"id"`
-	From    string    `json:"from"`
-	To      string    `json:"to"`
-	Content string    `json:"content"`
+	ID        uuid.UUID `json:"id"`
+	From      string    `json:"from"`
+	To        string    `json:"to"`
+	Timestamp time.Time `json:"timestamp"`
+	Content   string    `json:"content"`
 }

api/pkg/handlers/message_handler.go

@@ -198,6 +198,7 @@ func (h *MessageHandler) PostEvent(c *fiber.Ctx) error {
 	}
 
 	request.MessageID = c.Params("messageID")
+	spew.Dump(request)
 	if errors := h.validator.ValidateMessageEvent(ctx, request); len(errors) != 0 {
 		msg := fmt.Sprintf("validation errors [%s], while storing event [%s] for message [%s]", spew.Sdump(errors), c.Body(), request.MessageID)
 		ctxLogger.Warn(stacktrace.NewError(msg))

api/pkg/listeners/message_listener.go

@@ -147,7 +147,7 @@ func (listener *MessageListener) OnMessagePhoneSent(ctx context.Context, event c
 
 	handleParams := services.HandleMessageParams{
 		ID:        payload.ID,
-		Timestamp: event.Time(),
+		Timestamp: payload.Timestamp,
 	}
 
 	if err = listener.service.HandleMessageSent(ctx, handleParams); err != nil {

api/pkg/listeners/message_thread_listener.go

@@ -111,7 +111,7 @@ func (listener *MessageThreadListener) OnMessagePhoneSent(ctx context.Context, e
 	updateParams := services.MessageThreadUpdateParams{
 		Owner:     payload.From,
 		Contact:   payload.To,
-		Timestamp: event.Time(),
+		Timestamp: payload.Timestamp,
 		Content:   payload.Content,
 		MessageID: payload.ID,
 	}

api/pkg/requests/message_sent_request.go

@@ -12,7 +12,7 @@ import (
 // MessageEvent is the payload for sending and SMS message
 type MessageEvent struct {
 	// Timestamp is the time when the event was emitted, Please send the timestamp in UTC with as much precision as possible
-	Timestamp time.Time `json:"sent_at" example:"2022-06-05T14:26:09.527976+03:00"`
+	Timestamp time.Time `json:"timestamp" example:"2022-06-05T14:26:09.527976+03:00"`
 
 	// EventName is the type of event
 	// * SENT: is emitted when a message is sent by the mobile phone (only SENT is implemented)

api/pkg/services/message_service.go

@@ -125,10 +125,11 @@ func (service *MessageService) handleMessageSentEvent(ctx context.Context, param
 	defer span.End()
 
 	event, err := service.createMessagePhoneSentEvent(params.Source, events.MessagePhoneSentPayload{
-		ID:      message.ID,
-		From:    message.From,
-		To:      message.To,
-		Content: message.Content,
+		ID:        message.ID,
+		From:      message.From,
+		Timestamp: params.Timestamp,
+		To:        message.To,
+		Content:   message.Content,
 	})
 	if err != nil {
 		msg := fmt.Sprintf("cannot create event [%s] for message [%s]", events.EventTypeMessagePhoneSent, message.ID)

api/pkg/validators/message_handler_validator.go

@@ -121,9 +121,6 @@ func (validator MessageHandlerValidator) ValidateMessageEvent(_ context.Context,
 	v := govalidator.New(govalidator.Options{
 		Data: &request,
 		Rules: govalidator.MapData{
-			"sent_at": []string{
-				"required",
-			},
 			"event_name": []string{
 				"required",
 				"in:SENT",