add health endpoint

Author: merlinfuchs

embedg-server/api/handlers/send_message/restore.go

@@ -101,6 +101,8 @@ func (h *SendMessageHandler) HandleRestoreMessageFromWebhook(c *fiber.Ctx, req w
 func downloadMessageAttachments(attachments []*discordgo.MessageAttachment) (files []*wire.MessageAttachmentWire) {
 	filesC := make(chan *wire.MessageAttachmentWire)
 
+	// TODO: can this block forever?
+
 	for _, attachment := range attachments {
 		go func(attachment *discordgo.MessageAttachment) {
 			if attachment.Size > 8*1024*1024 {

embedg-server/api/routes.go

@@ -28,6 +28,10 @@ import (
 )
 
 func registerRoutes(app *fiber.App, stores *stores, bot *bot.Bot, managers *managers) {
+	app.Get("/api/health", func(c *fiber.Ctx) error {
+		return c.SendStatus(fiber.StatusOK)
+	})
+
 	authHandler := auth.New(stores.pg, bot, managers.session)
 	app.Get("/api/auth/login", authHandler.HandleAuthRedirect)
 	app.Get("/api/auth/callback", authHandler.HandleAuthCallback)

embedg-server/db/s3/files.go

@@ -12,7 +12,9 @@ const imagesBucketName = "images"
 
 func (s *BlobStore) UploadFile(ctx context.Context, image *Image) error {
 	reader := bytes.NewReader(image.Body)
-	_, err := s.client.PutObject(ctx, imagesBucketName, image.FileName, reader, int64(len(image.Body)), minio.PutObjectOptions{})
+	_, err := s.client.PutObject(ctx, imagesBucketName, image.FileName, reader, int64(len(image.Body)), minio.PutObjectOptions{
+		ContentType: image.ContentType,
+	})
 	if err != nil {
 		return err
 	}