umekikazuya · umekikazuya · Apr 27, 2026 · Apr 21, 2026 · Apr 21, 2026 · Apr 22, 2026
diff --git a/backend/.golangci.yml b/backend/.golangci.yml
@@ -17,13 +17,19 @@ linters:
     - nolintlint
     - prealloc
     - rowserrcheck
+    - sloglint
     - sqlclosecheck
     - staticcheck
     - tparallel
     - unconvert
     - unparam
     - whitespace
     - wrapcheck
+  settings:
+    sloglint:
+      no-mixed-args: true
+      context: scope
+      static-msg: true
   exclusions:
     rules:
       - text: '(slog|log)\.\w+'

diff --git a/backend/cmd/api/main.go b/backend/cmd/api/main.go
@@ -3,12 +3,17 @@ package main
 import (
 	"context"
 	"encoding/json"
+	"errors"
 	"log/slog"
 	"net/http"
 	"os"
+	"os/signal"
 	"strings"
+	"syscall"
 	"time"
 
+	"go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp"
+
 	"github.com/umekikazuya/me/internal/app/eventhandler"
 	"github.com/umekikazuya/me/internal/app/identity"
 	appme "github.com/umekikazuya/me/internal/app/me"
@@ -18,27 +23,65 @@ import (
 	infraevent "github.com/umekikazuya/me/internal/infra/event"
 	"github.com/umekikazuya/me/internal/infra/token"
 	"github.com/umekikazuya/me/pkg/middleware"
-	"github.com/umekikazuya/me/pkg/slogx"
+	"github.com/umekikazuya/me/pkg/obs"
 )
 
+// shutdownTimeout は SIGINT/SIGTERM 受信後にインフライトリクエストを捌き切る猶予。
+// ALB / API Gateway のドレイン時間との整合を意識して設定する。
+const shutdownTimeout = 30 * time.Second
+
 func main() {
-	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Minute)
-	defer cancel()
+	// run に集約するのは os.Exit が defer をスキップするため。
+	// 直接 main で os.Exit すると obs の shutdown が走らず traces/metrics が flush されない。
+	os.Exit(run())
+}
 
-	// ロガー初期化
-	slog.SetDefault(slogx.New(os.Stdout))
+func run() int {
+	ctx := context.Background()
+
+	// 観測性基盤初期化: logs / traces / metrics を stdout に出す。
+	// アクセスログはインフラ層 (API Gateway/ALB 等) の責務とし、アプリでは出さない。
+	prov, shutdown, err := obs.Bootstrap(ctx, obs.Config{
+		ServiceName:   "api",
+		Level:         obs.ParseLevel(os.Getenv("LOG_LEVEL")),
+		SensitiveKeys: []string{"password", "password_hash", "authorization", "cookie", "set-cookie", "token", "refresh_token"},
+		AddSource:     true,
+		EnableTraces:  true,
+		EnableMetrics: true,
+	})
+	if err != nil {
+		slog.Error("観測性基盤の初期化に失敗しました", "error", err)
+		return 1
+	}
+	// shutdown は長寿命な ctx に縛られないよう、呼び出し時に bounded な context を渡す。
+	// ListenAndServe から戻った時点では元 ctx が cancel 済みの可能性があり、
+	// その場合 tracer/meter の flush が即座に諦められてしまう。
+	// signal 受信時に作成した共有 shutdownCtx を使うことで、HTTP と observability の
+	// shutdown が同一タイムアウト予算を共有し、合計で shutdownTimeout 以内に収まる。
+	var shutdownCtx context.Context
+	var shutdownCancel context.CancelFunc
+	defer func() {
+		if shutdownCtx == nil {
+			shutdownCtx, shutdownCancel = context.WithTimeout(context.Background(), 5*time.Second)
+		}
-	defer func() {
-		if shutdownCtx == nil {
-			shutdownCtx, shutdownCancel = context.WithTimeout(context.Background(), 5*time.Second)
-		}
+	defer func() {
+		if shutdownCtx == nil {
+			shutdownCtx, shutdownCancel = context.WithTimeout(context.Background(), shutdownTimeout)
+		}
-	defer func() {
-		if shutdownCtx == nil {
-			shutdownCtx, shutdownCancel = context.WithTimeout(context.Background(), 5*time.Second)
-		}
+	defer func() {
+		if shutdownCtx == nil {
+			shutdownCtx, shutdownCancel = context.WithTimeout(context.Background(), shutdownTimeout)
+		}
+		_ = shutdown(shutdownCtx)
+		if shutdownCancel != nil {
+			shutdownCancel()
+		}
+	}()
+	slog.SetDefault(prov.Logger)
 
 	// 具像実装の初期化
 	meRepo, identityRepo, sessionRepo, articleInteractor, err := setupRepo(ctx)
 	if err != nil {
 		slog.Error("インフラの初期化に失敗しました", "error", err)
-		os.Exit(1)
+		return 1
 	}
 	articleHandler := handlerarticle.NewHandler(articleInteractor)
 	jwtSecret := strings.TrimSpace(os.Getenv("JWT_SECRET"))
 	if jwtSecret == "" {
 		slog.Error("JWT_SECRET が未設定です")
-		os.Exit(1)
+		return 1
 	}
 	tokenSrv := token.NewJWTTokenService(
 		jwtSecret,
@@ -129,19 +172,68 @@ func main() {
 		),
 	))
 
-	slog.Info("サーバーを起動します")
-
 	// サーバー起動
+	// middleware chain (外側 → 内側):
+	//   RequestID (obs.WithRequestID で context に積む)
+	//     → otelhttp (root span を作成、trace_id を context に載せる)
+	//       → Recover (panic → 500 ProblemDetail + ERROR ログ、trace_id が自動で付く)
+	//         → router
 	srv := &http.Server{
-		Addr:              ":8080",
-		Handler:           middleware.RequestID(middleware.Logging(r)),
+		Addr: ":8080",
+		Handler: middleware.RequestID(
+			otelhttp.NewHandler(
+				middleware.Recover(r),
+				"api",
+			),
+		),
 		ReadHeaderTimeout: 5 * time.Second,
 		ReadTimeout:       10 * time.Second,
 		WriteTimeout:      10 * time.Second,
 		IdleTimeout:       60 * time.Second,
 	}
-	if err := srv.ListenAndServe(); err != nil {
+
+	// signal 受信準備を ListenAndServe の goroutine 起動より前に行う。
+	// 先に goroutine を起動すると、早期の SIGINT/SIGTERM がデフォルトハンドラで
+	// 処理され、graceful shutdown が実行されないリスクがある。
+	sigCh := make(chan os.Signal, 1)
+	signal.Notify(sigCh, syscall.SIGINT, syscall.SIGTERM)
+	defer signal.Stop(sigCh)
+
+	// ListenAndServe は別 goroutine で動かし、main は signal 受信を待つ。
+	// 起動直後に失敗 (port 競合など) した場合は srvErrCh から即座に戻る。
+	srvErrCh := make(chan error, 1)
+	go func() {
+		srvErrCh <- srv.ListenAndServe()
+	}()
+
+	slog.Info("サーバーを起動します")
+
+	select {
+	case err := <-srvErrCh:
+		// SIGINT/SIGTERM を受ける前に ListenAndServe が返った = 起動失敗。
+		// Shutdown 経由の終了ではないので ErrServerClosed は来ない想定だが、念のため除外。
+		if err != nil && !errors.Is(err, http.ErrServerClosed) {
+			slog.Error("起動エラー", "error", err)
+			return 1
+		}
+		return 0
+	case sig := <-sigCh:
+		slog.Info("シャットダウン開始", "signal", sig.String())
+	}
+
+	// HTTP shutdown と observability shutdown の両方で共有する単一の context を作成。
+	// 合計で shutdownTimeout 以内に両方の shutdown を完了させる。
+	shutdownCtx, shutdownCancel = context.WithTimeout(context.Background(), shutdownTimeout)
+	if err := srv.Shutdown(shutdownCtx); err != nil {
+		// Shutdown が猶予内に完了できなかった = インフライトが残っている。
+		// それでも ListenAndServe は Close 済みで戻るので、goroutine は解放される。
+		slog.Error("サーバーシャットダウン失敗", "error", err)
+	}
+	// Shutdown 後は ListenAndServe が ErrServerClosed で戻る。goroutine のクローズ待ち。
+	if err := <-srvErrCh; err != nil && !errors.Is(err, http.ErrServerClosed) {
 		slog.Error("起動エラー", "error", err)
-		os.Exit(1) // TODO: SIGINT/SIGTERM グレースフルシャットダウン
+		return 1
 	}
+	slog.Info("サーバーを停止しました")
+	return 0
 }
diff --git a/backend/cmd/batch/local.go b/backend/cmd/batch/local.go
@@ -4,6 +4,7 @@ import (
 	"context"
 	"log/slog"
 	"os"
+	"time"
 
 	"github.com/aws/aws-sdk-go-v2/aws"
 	"github.com/aws/aws-sdk-go-v2/config"
@@ -14,14 +15,37 @@ import (
 	"github.com/umekikazuya/me/internal/infra/db"
 	"github.com/umekikazuya/me/internal/infra/fetcher"
 	"github.com/umekikazuya/me/internal/infra/tokenizer"
+	"github.com/umekikazuya/me/pkg/obs"
 )
 
 var targetPlatforms = []string{"qiita", "zenn"}
 
 func main() {
-	slog.SetDefault(slog.New(slog.NewJSONHandler(os.Stdout, nil)))
 	ctx := context.Background()
 
+	prov, shutdown, err := obs.Bootstrap(ctx, obs.Config{
+		ServiceName:   "batch",
+		Level:         obs.ParseLevel(os.Getenv("LOG_LEVEL")),
+		AddSource:     true,
+		EnableTraces:  true,
+		EnableMetrics: true,
+	})
+	if err != nil {
+		slog.Error("観測性基盤の初期化に失敗しました", "error", err)
+		os.Exit(1)
+	}
+	// shutdown は bounded な context で呼ぶ。呼び出し時点で ctx が cancel
+	// されていると tracer/meter の flush が即座に諦められてしまう。
+	defer func() {
+		shutdownCtx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
+		defer cancel()
+		_ = shutdown(shutdownCtx)
+	}()
-	defer func() {
-		shutdownCtx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
-		defer cancel()
-		_ = shutdown(shutdownCtx)
-	}()
+	defer func() {
+		shutdownCtx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
+		defer cancel()
+		if err := shutdown(shutdownCtx); err != nil {
+			slog.Error("observability shutdown failed", "error", err)
+		}
+	}()
-	defer func() {
-		shutdownCtx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
-		defer cancel()
-		_ = shutdown(shutdownCtx)
-	}()
+	defer func() {
+		shutdownCtx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
+		defer cancel()
+		if err := shutdown(shutdownCtx); err != nil {
+			slog.Error("observability shutdown failed", "error", err)
+		}
+	}()
+	slog.SetDefault(prov.Logger)
+	// RecoverProcess はログ出力後に re-panic するので、batch のプロセス終了は
+	// 非ゼロ exit になる (runtime のデフォルト panic ハンドラが exit 2 を返す)。
+	defer obs.RecoverProcess(ctx, "batch.main")
+
-	// RecoverProcess はログ出力後に re-panic するので、batch のプロセス終了は
-	// 非ゼロ exit になる (runtime のデフォルト panic ハンドラが exit 2 を返す)。
-	defer obs.RecoverProcess(ctx, "batch.main")
+	// RecoverProcess はログ出力後に re-panic するので、batch のプロセス終了は
+	// 非ゼロ exit になる (runtime のデフォルト panic ハンドラが exit 2 を返す)。
+	defer func() {
+		obs.RecoverProcess(ctx, "batch.main")
+	}()
-	// RecoverProcess はログ出力後に re-panic するので、batch のプロセス終了は
-	// 非ゼロ exit になる (runtime のデフォルト panic ハンドラが exit 2 を返す)。
-	defer obs.RecoverProcess(ctx, "batch.main")
+	// RecoverProcess はログ出力後に re-panic するので、batch のプロセス終了は
+	// 非ゼロ exit になる (runtime のデフォルト panic ハンドラが exit 2 を返す)。
+	defer func() {
+		obs.RecoverProcess(ctx, "batch.main")
+	}()
 	// TODO: パラメータを注入する機構を考える(実行環境も)
 	endpoint := os.Getenv("DYNAMODB_ENDPOINT")
 	tableName := os.Getenv("DYNAMODB_TABLE_NAME")
@@ -93,3 +117,4 @@ func main() {
 		os.Exit(1)
 	}
 }
+
diff --git a/backend/go.mod b/backend/go.mod
@@ -30,12 +30,25 @@ require (
 	github.com/aws/aws-sdk-go-v2/service/ssooidc v1.35.20 // indirect
 	github.com/aws/aws-sdk-go-v2/service/sts v1.42.0 // indirect
 	github.com/aws/smithy-go v1.25.0 // indirect
+	github.com/cespare/xxhash/v2 v2.3.0 // indirect
+	github.com/felixge/httpsnoop v1.0.4 // indirect
 	github.com/gabriel-vasile/mimetype v1.4.13 // indirect
+	github.com/go-logr/logr v1.4.3 // indirect
+	github.com/go-logr/stdr v1.2.2 // indirect
 	github.com/go-playground/locales v0.14.1 // indirect
 	github.com/go-playground/universal-translator v0.18.1 // indirect
 	github.com/ikawaha/kagome-dict v1.1.7 // indirect
 	github.com/leodido/go-urn v1.4.0 // indirect
-	github.com/stretchr/testify v1.9.0 // indirect
+	github.com/stretchr/testify v1.11.1 // indirect
+	go.opentelemetry.io/auto/sdk v1.2.1 // indirect
+	go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.68.0 // indirect
+	go.opentelemetry.io/otel v1.43.0 // indirect
+	go.opentelemetry.io/otel/exporters/stdout/stdoutmetric v1.43.0 // indirect
+	go.opentelemetry.io/otel/exporters/stdout/stdouttrace v1.43.0 // indirect
+	go.opentelemetry.io/otel/metric v1.43.0 // indirect
+	go.opentelemetry.io/otel/sdk v1.43.0 // indirect
+	go.opentelemetry.io/otel/sdk/metric v1.43.0 // indirect
+	go.opentelemetry.io/otel/trace v1.43.0 // indirect
 	golang.org/x/sys v0.43.0 // indirect
 	golang.org/x/text v0.36.0 // indirect
 )
diff --git a/backend/go.sum b/backend/go.sum
@@ -34,10 +34,19 @@ github.com/aws/aws-sdk-go-v2/service/sts v1.42.0 h1:ks8KBcZPh3PYISr5dAiXCM5/Thcu
 github.com/aws/aws-sdk-go-v2/service/sts v1.42.0/go.mod h1:pFw33T0WLvXU3rw1WBkpMlkgIn54eCB5FYLhjDc9Foo=
 github.com/aws/smithy-go v1.25.0 h1:Sz/XJ64rwuiKtB6j98nDIPyYrV1nVNJ4YU74gttcl5U=
 github.com/aws/smithy-go v1.25.0/go.mod h1:YE2RhdIuDbA5E5bTdciG9KrW3+TiEONeUWCqxX9i1Fc=
+github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=
+github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/felixge/httpsnoop v1.0.4 h1:NFTV2Zj1bL4mc9sqWACXbQFVBBg2W3GPvqp8/ESS2Wg=
+github.com/felixge/httpsnoop v1.0.4/go.mod h1:m8KPJKqk1gH5J9DgRY2ASl2lWCfGKXixSwevea8zH2U=
 github.com/gabriel-vasile/mimetype v1.4.13 h1:46nXokslUBsAJE/wMsp5gtO500a4F3Nkz9Ufpk2AcUM=
 github.com/gabriel-vasile/mimetype v1.4.13/go.mod h1:d+9Oxyo1wTzWdyVUPMmXFvp4F9tea18J8ufA774AB3s=
+github.com/go-logr/logr v1.2.2/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A=
+github.com/go-logr/logr v1.4.3 h1:CjnDlHq8ikf6E492q6eKboGOC0T8CDaOvkHCIg8idEI=
+github.com/go-logr/logr v1.4.3/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY=
+github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag=
+github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE=
 github.com/go-playground/assert/v2 v2.2.0 h1:JvknZsQTYeFEAhQwI4qEt9cyV5ONwRHC+lYKSsYSR8s=
 github.com/go-playground/assert/v2 v2.2.0/go.mod h1:VDjEfimB/XKnb+ZQfWdccd7VUvScMdVu0Titje2rxJ4=
 github.com/go-playground/locales v0.14.1 h1:EWaQ/wswjilfKLTECiXz7Rh+3BjFhfDFKv/oXslEjJA=
@@ -60,8 +69,26 @@ github.com/leodido/go-urn v1.4.0 h1:WT9HwE9SGECu3lg4d/dIA+jxlljEa1/ffXKmRjqdmIQ=
 github.com/leodido/go-urn v1.4.0/go.mod h1:bvxc+MVxLKB4z00jd1z+Dvzr47oO32F/QSNjSBOlFxI=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
-github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
+github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U=
+github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U=
+go.opentelemetry.io/auto/sdk v1.2.1 h1:jXsnJ4Lmnqd11kwkBV2LgLoFMZKizbCi5fNZ/ipaZ64=
+go.opentelemetry.io/auto/sdk v1.2.1/go.mod h1:KRTj+aOaElaLi+wW1kO/DZRXwkF4C5xPbEe3ZiIhN7Y=
+go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.68.0 h1:CqXxU8VOmDefoh0+ztfGaymYbhdB/tT3zs79QaZTNGY=
+go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.68.0/go.mod h1:BuhAPThV8PBHBvg8ZzZ/Ok3idOdhWIodywz2xEcRbJo=
+go.opentelemetry.io/otel v1.43.0 h1:mYIM03dnh5zfN7HautFE4ieIig9amkNANT+xcVxAj9I=
+go.opentelemetry.io/otel v1.43.0/go.mod h1:JuG+u74mvjvcm8vj8pI5XiHy1zDeoCS2LB1spIq7Ay0=
+go.opentelemetry.io/otel/exporters/stdout/stdoutmetric v1.43.0 h1:TC+BewnDpeiAmcscXbGMfxkO+mwYUwE/VySwvw88PfA=
+go.opentelemetry.io/otel/exporters/stdout/stdoutmetric v1.43.0/go.mod h1:J/ZyF4vfPwsSr9xJSPyQ4LqtcTPULFR64KwTikGLe+A=
+go.opentelemetry.io/otel/exporters/stdout/stdouttrace v1.43.0 h1:mS47AX77OtFfKG4vtp+84kuGSFZHTyxtXIN269vChY0=
+go.opentelemetry.io/otel/exporters/stdout/stdouttrace v1.43.0/go.mod h1:PJnsC41lAGncJlPUniSwM81gc80GkgWJWr3cu2nKEtU=
+go.opentelemetry.io/otel/metric v1.43.0 h1:d7638QeInOnuwOONPp4JAOGfbCEpYb+K6DVWvdxGzgM=
+go.opentelemetry.io/otel/metric v1.43.0/go.mod h1:RDnPtIxvqlgO8GRW18W6Z/4P462ldprJtfxHxyKd2PY=
+go.opentelemetry.io/otel/sdk v1.43.0 h1:pi5mE86i5rTeLXqoF/hhiBtUNcrAGHLKQdhg4h4V9Dg=
+go.opentelemetry.io/otel/sdk v1.43.0/go.mod h1:P+IkVU3iWukmiit/Yf9AWvpyRDlUeBaRg6Y+C58QHzg=
+go.opentelemetry.io/otel/sdk/metric v1.43.0 h1:S88dyqXjJkuBNLeMcVPRFXpRw2fuwdvfCGLEo89fDkw=
+go.opentelemetry.io/otel/sdk/metric v1.43.0/go.mod h1:C/RJtwSEJ5hzTiUz5pXF1kILHStzb9zFlIEe85bhj6A=
+go.opentelemetry.io/otel/trace v1.43.0 h1:BkNrHpup+4k4w+ZZ86CZoHHEkohws8AY+WTX09nk+3A=
+go.opentelemetry.io/otel/trace v1.43.0/go.mod h1:/QJhyVBUUswCphDVxq+8mld+AvhXZLhe+8WVFxiFff0=
 golang.org/x/crypto v0.50.0 h1:zO47/JPrL6vsNkINmLoo/PH1gcxpls50DNogFvB5ZGI=
 golang.org/x/crypto v0.50.0/go.mod h1:3muZ7vA7PBCE6xgPX7nkzzjiUq87kRItoJQM1Yo8S+Q=
 golang.org/x/sys v0.43.0 h1:Rlag2XtaFTxp19wS8MXlJwTvoh8ArU6ezoyFsMyCTNI=

diff --git a/backend/internal/app/article/interactor.go b/backend/internal/app/article/interactor.go
@@ -59,7 +59,7 @@ func (i *interactor) Search(ctx context.Context, input InputSearchDto) (*OutputS
 	}
 	result, err := i.repo.FindAll(ctx, criteria)
 	if err != nil {
-		return nil, errs.WrapInternal(ctx, "article.repo.FindAll", err)
+		return nil, errs.WrapInternal("article.repo.FindAll", err)
 	}
 
 	items := make([]OutputArticleItemDto, 0, len(result.Articles))
@@ -84,7 +84,7 @@ func (i *interactor) Search(ctx context.Context, input InputSearchDto) (*OutputS
 func (i *interactor) GetTagsAll(ctx context.Context) (*OutputTagAllDto, error) {
 	tags, err := i.repo.AllTags(ctx)
 	if err != nil {
-		return nil, errs.WrapInternal(ctx, "article.repo.AllTags", err)
+		return nil, errs.WrapInternal("article.repo.AllTags", err)
 	}
 
 	items := make([]OutputTagItemDto, 0, len(tags))
@@ -97,11 +97,11 @@ func (i *interactor) GetTagsAll(ctx context.Context) (*OutputTagAllDto, error) {
 func (i *interactor) GetSuggests(ctx context.Context, input InputGetSuggestDto) (*OutputGetSuggestAllDto, error) {
 	tags, err := i.repo.AllTags(ctx)
 	if err != nil {
-		return nil, errs.WrapInternal(ctx, "article.repo.AllTags", err)
+		return nil, errs.WrapInternal("article.repo.AllTags", err)
 	}
 	tokens, err := i.repo.AllTokens(ctx)
 	if err != nil {
-		return nil, errs.WrapInternal(ctx, "article.repo.AllTokens", err)
+		return nil, errs.WrapInternal("article.repo.AllTokens", err)
 	}
 
 	var suggestions []OutputGetSuggestItemDto
@@ -135,7 +135,7 @@ func (i *interactor) GetSuggests(ctx context.Context, input InputGetSuggestDto)
 func (i *interactor) Register(ctx context.Context, input InputRegisterDto) error {
 	existing, err := i.repo.FindByExternalID(ctx, input.ExternalID)
 	if err != nil {
-		return errs.WrapInternal(ctx, "article.repo.FindByExternalID", err)
+		return errs.WrapInternal("article.repo.FindByExternalID", err)
 	}
 	if existing != nil {
 		return fmt.Errorf("article already exists: %s: %w", input.ExternalID, errs.ErrConflict)
@@ -157,15 +157,15 @@ func (i *interactor) Register(ctx context.Context, input InputRegisterDto) error
 		return fmt.Errorf("%s: %w", err.Error(), errs.ErrUnprocessable)
 	}
 	if err := i.repo.Save(ctx, article); err != nil {
-		return errs.WrapInternal(ctx, "article.repo.Save", err)
+		return errs.WrapInternal("article.repo.Save", err)
 	}
 	return nil
 }
 
 func (i *interactor) Update(ctx context.Context, input InputUpdateDto) error {
 	article, err := i.repo.FindByExternalID(ctx, input.ExternalID)
 	if err != nil {
-		return errs.WrapInternal(ctx, "article.repo.FindByExternalID", err)
+		return errs.WrapInternal("article.repo.FindByExternalID", err)
 	}
 	if article == nil {
 		return fmt.Errorf("article not found: %s: %w", input.ExternalID, errs.ErrNotFound)
@@ -186,15 +186,15 @@ func (i *interactor) Update(ctx context.Context, input InputUpdateDto) error {
 		return fmt.Errorf("%s: %w", err.Error(), errs.ErrUnprocessable)
 	}
 	if err := i.repo.Save(ctx, article); err != nil {
-		return errs.WrapInternal(ctx, "article.repo.Save", err)
+		return errs.WrapInternal("article.repo.Save", err)
 	}
 	return nil
 }
 
 func (i *interactor) Remove(ctx context.Context, input InputRemoveDto) error {
 	article, err := i.repo.FindByExternalID(ctx, input.ExternalID)
 	if err != nil {
-		return errs.WrapInternal(ctx, "article.repo.FindByExternalID", err)
+		return errs.WrapInternal("article.repo.FindByExternalID", err)
 	}
 	if article == nil {
 		return fmt.Errorf("article not found: %s: %w", input.ExternalID, errs.ErrNotFound)
@@ -204,7 +204,7 @@ func (i *interactor) Remove(ctx context.Context, input InputRemoveDto) error {
 		return fmt.Errorf("%s: %w", err.Error(), errs.ErrUnprocessable)
 	}
 	if err := i.repo.Save(ctx, article); err != nil {
-		return errs.WrapInternal(ctx, "article.repo.Save", err)
+		return errs.WrapInternal("article.repo.Save", err)
 	}
 	return nil
 }