Method ReceiveMessage

api/pkg/services/message_service.go:334–378

ReceiveMessage handles message received by a mobile phone

(ctx context.Context, params *MessageReceiveParams)

// ReceiveMessage handles message received by a mobile phone
func (service *MessageService) ReceiveMessage(ctx context.Context, params *MessageReceiveParams) (*entities.Message, error) {
	ctx, span := service.tracer.Start(ctx)
	defer span.End()

	ctxLogger := service.tracer.CtxLogger(service.logger, span)

	messageID := uuid.New()

	ctxLogger.Info(fmt.Sprintf("uploading [%d] attachments for user [%s] message [%s]", len(params.Attachments), params.UserID, messageID))
	attachmentURLs, err := service.uploadAttachments(ctx, params.UserID, messageID, params.Attachments)
	if err != nil {
		msg := fmt.Sprintf("cannot upload attachments for user [%s] message [%s]", params.UserID, messageID)
		return nil, service.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg))
	}

	eventPayload := events.MessagePhoneReceivedPayload{
		MessageID:   messageID,
		UserID:      params.UserID,
		Encrypted:   params.Encrypted,
		Owner:       phonenumbers.Format(&params.Owner, phonenumbers.E164),
		Contact:     params.Contact,
		Timestamp:   params.Timestamp,
		Content:     params.Content,
		SIM:         params.SIM,
		Attachments: attachmentURLs,
	}

	ctxLogger.Info(fmt.Sprintf("creating cloud event for received with ID [%s]", eventPayload.MessageID))

	event, err := service.createMessagePhoneReceivedEvent(params.Source, eventPayload)
	if err != nil {
		msg := fmt.Sprintf("cannot create %T from payload with message id [%s]", event, eventPayload.MessageID)
		return nil, service.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg))
	}

	ctxLogger.Info(fmt.Sprintf("created event [%s] with id [%s] and message id [%s]", event.Type(), event.ID(), eventPayload.MessageID))

	if err = service.eventDispatcher.Dispatch(ctx, event); err != nil {
		msg := fmt.Sprintf("cannot dispatch event type [%s] and id [%s]", event.Type(), event.ID())
		return nil, service.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg))
	}
	ctxLogger.Info(fmt.Sprintf("event [%s] dispatched successfully", event.ID()))

	return service.storeReceivedMessage(ctx, eventPayload)
}

func (service *MessageService) handleMessageSentEvent(ctx context.Context, params MessageStoreEventParams, message *entities.Message) error {
	ctx, span := service.tracer.Start(ctx)