Method storeSentMessage

api/pkg/services/message_service.go:1054–1092

storeSentMessage a new message

(ctx context.Context, payload events.MessageAPISentPayload)

// storeSentMessage a new message
func (service *MessageService) storeSentMessage(ctx context.Context, payload events.MessageAPISentPayload) (*entities.Message, error) {
	ctx, span := service.tracer.Start(ctx)
	defer span.End()

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

	timestamp := payload.RequestReceivedAt
	if payload.ScheduledSendTime != nil {
		timestamp = *payload.ScheduledSendTime
	}

	message := &entities.Message{
		ID:                payload.MessageID,
		Owner:             payload.Owner,
		Contact:           payload.Contact,
		UserID:            payload.UserID,
		Content:           payload.Content,
		Attachments:       payload.Attachments,
		RequestID:         payload.RequestID,
		SIM:               payload.SIM,
		Encrypted:         payload.Encrypted,
		ScheduledSendTime: payload.ScheduledSendTime,
		Type:              entities.MessageTypeMobileTerminated,
		Status:            entities.MessageStatusPending,
		RequestReceivedAt: payload.RequestReceivedAt,
		CreatedAt:         time.Now().UTC(),
		UpdatedAt:         time.Now().UTC(),
		MaxSendAttempts:   payload.MaxSendAttempts,
		OrderTimestamp:    timestamp,
	}

	if err := service.repository.Store(ctx, message); err != nil {
		msg := fmt.Sprintf("cannot save message with id [%s]", payload.MessageID)
		return nil, service.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg))
	}

	ctxLogger.Info(fmt.Sprintf("message saved with id [%s]", payload.MessageID))
	return message, nil
}

// storeMissedCallMessage a new message
func (service *MessageService) storeMissedCallMessage(ctx context.Context, payload *events.MessageCallMissedPayload) (*entities.Message, error) {