Method uploadAttachments

api/pkg/services/message_service.go:633–680

(ctx context.Context, userID entities.UserID, messageID uuid.UUID, attachments []ServiceAttachment)

}

func (service *MessageService) uploadAttachments(ctx context.Context, userID entities.UserID, messageID uuid.UUID, attachments []ServiceAttachment) ([]string, error) {
	if len(attachments) == 0 {
		return []string{}, nil
	}

	ctx, span, ctxLogger := service.tracer.StartWithLogger(ctx, service.logger)
	defer span.End()

	g, gCtx := errgroup.WithContext(ctx)
	urls := make([]string, len(attachments))
	paths := make([]string, len(attachments))

	for i, attachment := range attachments {
		i, attachment := i, attachment
		g.Go(func() error {
			decoded, err := base64.StdEncoding.DecodeString(attachment.Content)
			if err != nil {
				return stacktrace.Propagate(err, fmt.Sprintf("cannot decode base64 content for attachment [%d]", i))
			}

			sanitizedName := repositories.SanitizeFilename(attachment.Name, i)
			ext := repositories.ExtensionFromContentType(attachment.ContentType)
			filename := sanitizedName + ext

			path := fmt.Sprintf("attachments/%s/%s/%d/%s", userID, messageID, i, filename)
			paths[i] = path

			if err = service.attachmentRepository.Upload(gCtx, path, decoded, attachment.ContentType); err != nil {
				return stacktrace.Propagate(err, fmt.Sprintf("cannot upload attachment [%d] to path [%s]", i, path))
			}

			urls[i] = fmt.Sprintf("%s/v1/attachments/%s/%s/%d/%s", service.apiBaseURL, userID, messageID, i, filename)
			ctxLogger.Info(fmt.Sprintf("uploaded attachment [%d] to [%s]", i, path))
			return nil
		})
	}

	if err := g.Wait(); err != nil {
		for _, path := range paths {
			if path != "" {
				_ = service.attachmentRepository.Delete(ctx, path)
			}
		}
		return nil, stacktrace.Propagate(err, "cannot upload attachments")
	}

	return urls, nil
}

// HandleMessageParams are parameters for handling a message event
type HandleMessageParams struct {