Method Update

api/pkg/services/discord_service.go:199–225

Update an entities.Discord

(ctx context.Context, params *DiscordUpdateParams)

// Update an entities.Discord
func (service *DiscordService) Update(ctx context.Context, params *DiscordUpdateParams) (*entities.Discord, error) {
	ctx, span, ctxLogger := service.tracer.StartWithLogger(ctx, service.logger)
	defer span.End()

	discordIntegration, err := service.repository.Load(ctx, params.UserID, params.DiscordID)
	if err != nil {
		msg := fmt.Sprintf("cannot load discord integration with userID [%s] and discordID [%s]", params.UserID, params.DiscordID)
		return nil, service.tracer.WrapErrorSpan(span, stacktrace.PropagateWithCode(err, stacktrace.GetCode(err), msg))
	}

	if err = service.createSlashCommand(ctx, params.ServerID); err != nil {
		msg := fmt.Sprintf("cannot create slash command for server [%s]", params.ServerID)
		return nil, service.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg))
	}

	discordIntegration.Name = params.Name
	discordIntegration.ServerID = params.ServerID
	discordIntegration.IncomingChannelID = params.IncomingChannelID

	if err = service.repository.Save(ctx, discordIntegration); err != nil {
		msg := fmt.Sprintf("cannot save discord integration with id [%s] after update", discordIntegration.ID)
		return nil, service.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg))
	}

	ctxLogger.Info(fmt.Sprintf("discord integration updated with id [%s] in the [%T]", discordIntegration.ID, service.repository))
	return discordIntegration, nil
}

// HandleMessageReceived sends an incoming SMS to a discord channel
func (service *DiscordService) HandleMessageReceived(ctx context.Context, userID entities.UserID, event cloudevents.Event) error {