update hook with sentry for logger, update message

Taskfile.yaml

@@ -102,6 +102,14 @@ tasks:
         cmds:
             - pulumi up -y
     registry:
+        desc: Run registry locally
         cmds:
             - docker run -d -p 5000:5000 --restart=always --name registry registry:2
             - skaffold config set default-repo localhost:5000
+    send-test-string:
+        desc: Send test string
+        dotenv:
+            - local-secrets.env
+        cmds:
+            - http GET http://localhost:8080/api/${AUTH_TOKEN}/test?msg=test --raw="test body"
+

internal/post-forwarder/driven/telegram_message_sender.go

@@ -7,6 +7,7 @@ import (
 	"github.com/adlandh/post-forwarder/internal/post-forwarder/config"
 	"github.com/adlandh/post-forwarder/internal/post-forwarder/domain"
 	"github.com/go-telegram/bot"
+	"github.com/go-telegram/bot/models"
 )
 
 const MaxMessageLength = 4_096
@@ -36,14 +37,15 @@ func NewTelegramMessageSender(cfg *config.Config) (*TelegramMessageSender, error
 }
 
 func (t TelegramMessageSender) Send(ctx context.Context, service, msg string) error {
-	fullMessage := fmt.Sprintf("Message from %s: %s", service, msg)
-	if len(fullMessage) > MaxMessageLength {
+	fullMessage := fmt.Sprintf("<b>%s</b>:\n%s", service, msg)
+	if len([]rune(fullMessage)) > MaxMessageLength {
 		fullMessage = fullMessage[:MaxMessageLength]
 	}
 
 	_, err := t.bot.SendMessage(ctx, &bot.SendMessageParams{
-		ChatID: t.chatId,
-		Text:   fullMessage,
+		ChatID:    t.chatId,
+		Text:      fullMessage,
+		ParseMode: models.ParseModeHTML,
 	})
 
 	return err

internal/post-forwarder/main.go

@@ -2,7 +2,7 @@ package main
 
 import (
 	"context"
-	"fmt"
+	"strconv"
 	"time"
 
 	"github.com/adlandh/echo-sentry-middleware"
@@ -38,7 +38,14 @@ func NewLogger(cfg *config.Config) (*zap.Logger, error) {
 		func(entry zapcore.Entry) error {
 			if entry.Level == zapcore.ErrorLevel {
 				defer sentry.Flush(2 * time.Second)
-				sentry.CaptureMessage(fmt.Sprintf("%s, Line No: %d :: %s", entry.Caller.File, entry.Caller.Line, entry.Message))
+				localHub := sentry.CurrentHub().Clone()
+				localHub.ConfigureScope(func(scope *sentry.Scope) {
+					scope.SetTag("File", entry.Caller.File)
+					scope.SetTag("Line", strconv.Itoa(entry.Caller.Line))
+					scope.SetTag("message", entry.Message)
+					scope.SetLevel(sentry.LevelError)
+				})
+				localHub.CaptureMessage("error")
 			}
 			return nil
 		},
@@ -58,6 +65,7 @@ func NewSentry(lc fx.Lifecycle, cfg *config.Config) error {
 				EnableTracing:      true,
 				TracesSampleRate:   cfg.SentryTracesSampleRate,
 				ProfilesSampleRate: cfg.SentryProfilesSampleRate,
+				MaxErrorDepth:      1,
 			})
 		},
 		OnStop: func(ctx context.Context) error {