Method sendMessage

api/pkg/services/discord_service.go:256–292

(ctx context.Context, event cloudevents.Event, discord *entities.Discord)

}

func (service *DiscordService) sendMessage(ctx context.Context, event cloudevents.Event, discord *entities.Discord) {
	ctx, span, ctxLogger := service.tracer.StartWithLogger(ctx, service.logger)
	defer span.End()

	payload := new(events.MessagePhoneReceivedPayload)
	if err := event.DataAs(payload); err != nil {
		ctxLogger.Error(stacktrace.Propagate(err, fmt.Sprintf("cannot unmarshal event [%s] with ID [%s] into [%T]", event.Type(), event.ID(), payload)))
		return
	}

	request := service.createDiscordMessage(ctxLogger, payload)
	message, response, err := service.client.Channel.CreateMessage(ctx, discord.IncomingChannelID, request)
	if err != nil {
		msg := fmt.Sprintf("cannot send [%s] event to discord channel [%s] for user [%s]", event.Type(), discord.IncomingChannelID, discord.UserID)
		ctxLogger.Warn(service.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg)))

		eventPayload := &events.DiscordSendFailedPayload{
			DiscordID:        discord.ID,
			UserID:           discord.UserID,
			MessageID:        payload.MessageID,
			Owner:            payload.Owner,
			EventType:        event.Type(),
			ErrorMessage:     err.Error(),
			DiscordChannelID: discord.IncomingChannelID,
		}

		if response != nil {
			eventPayload.HTTPResponseStatusCode = &response.HTTPResponse.StatusCode
			eventPayload.ErrorMessage = string(*response.Body)
		}

		service.handleDiscordMessageFailed(ctx, event.Source(), eventPayload)
		return
	}

	ctxLogger.Info(fmt.Sprintf("sent discord message [%s] to channel [%s] for [%s] event with ID [%s]", message["id"].(string), discord.IncomingChannelID, event.Type(), event.ID()))
}

func (service *DiscordService) createDiscordMessage(ctxLogger telemetry.Logger, payload *events.MessagePhoneReceivedPayload) fiber.Map {
	return fiber.Map{