Bind phone received events

Author: AchoArnold

api/pkg/listeners/websocket_listener.go

@@ -32,9 +32,10 @@ func NewWebsocketListener(
 	}
 
 	return l, map[string]events.EventListener{
-		events.EventTypePhoneUpdated:      l.onPhoneUpdated,
-		events.EventTypeMessagePhoneSent:  l.onMessagePhoneSent,
-		events.EventTypeMessageSendFailed: l.onMessagePhoneFailed,
+		events.EventTypePhoneUpdated:         l.onPhoneUpdated,
+		events.EventTypeMessagePhoneSent:     l.onMessagePhoneSent,
+		events.EventTypeMessageSendFailed:    l.onMessagePhoneFailed,
+		events.EventTypeMessagePhoneReceived: l.onMessagePhoneReceived,
 	}
 }
 
@@ -57,6 +58,25 @@ func (listener *WebsocketListener) onMessagePhoneSent(ctx context.Context, event
 	return nil
 }
 
+// onMessagePhoneReceived handles the events.EventTypeMessagePhoneReceived event
+func (listener *WebsocketListener) onMessagePhoneReceived(ctx context.Context, event cloudevents.Event) error {
+	ctx, span, _ := listener.tracer.StartWithLogger(ctx, listener.logger)
+	defer span.End()
+
+	var payload events.MessagePhoneReceivedPayload
+	if err := event.DataAs(&payload); err != nil {
+		msg := fmt.Sprintf("cannot decode [%s] into [%T]", event.Data(), payload)
+		return listener.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg))
+	}
+
+	if err := listener.client.Trigger(payload.UserID.String(), event.Type(), event.ID()); err != nil {
+		msg := fmt.Sprintf("cannot trigger websocket [%s] event with ID [%s] for user with ID [%s]", event.Type(), event.ID(), payload.UserID)
+		return listener.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg))
+	}
+
+	return nil
+}
+
 // onMessagePhoneFailed handles the events.EventTypeMessageSendFailed event
 func (listener *WebsocketListener) onMessagePhoneFailed(ctx context.Context, event cloudevents.Event) error {
 	ctx, span, _ := listener.tracer.StartWithLogger(ctx, listener.logger)