| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent af57e73 commit 129dced
90 files changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -12,7 +12,7 @@ require ( | |||
| 12 | 12 | github.com/NdoleStudio/go-otelroundtripper v0.0.15 | |
| 13 | 13 | github.com/NdoleStudio/lemonsqueezy-go v1.3.1 | |
| 14 | 14 | github.com/NdoleStudio/plunk-go v0.0.2 | |
| 15 | - github.com/NdoleStudio/stacktrace v1.0.0 | ||
| 15 | + github.com/NdoleStudio/stacktrace v1.1.0 | ||
| 16 | 16 | github.com/avast/retry-go/v5 v5.0.0 | |
| 17 | 17 | github.com/axiomhq/axiom-go v0.32.0 | |
| 18 | 18 | github.com/carlmjohnson/requests v0.25.1 | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -62,6 +62,8 @@ github.com/NdoleStudio/plunk-go v0.0.2 h1:afPW7MHK4Z3rsybpJBnmTmxKCLKF1M7sPI+BNG | |||
| 62 | 62 | github.com/NdoleStudio/plunk-go v0.0.2/go.mod h1:pqG3zKhpn/A2bL1K+WsWzvfTpOeSkYgXhNk5H65uEc8= | |
| 63 | 63 | github.com/NdoleStudio/stacktrace v1.0.0 h1:YIDg0twM2BXRKIFjorX7v2dC0l8z4VEITurI+MNqvVQ= | |
| 64 | 64 | github.com/NdoleStudio/stacktrace v1.0.0/go.mod h1:WOBcbXShYu+v8JtjFEM+rRV9GJW50m+dwIvp4sLuVTg= | |
| 65 | + github.com/NdoleStudio/stacktrace v1.1.0 h1:Ai0j//4tDo/So3nR8bZgS3pQ4NYmViHlarpIReiyb5k= | ||
| 66 | + github.com/NdoleStudio/stacktrace v1.1.0/go.mod h1:WOBcbXShYu+v8JtjFEM+rRV9GJW50m+dwIvp4sLuVTg= | ||
| 65 | 67 | github.com/PuerkitoBio/goquery v1.12.0 h1:pAcL4g3WRXekcB9AU/y1mbKez2dbY2AajVhtkO8RIBo= | |
| 66 | 68 | github.com/PuerkitoBio/goquery v1.12.0/go.mod h1:802ej+gV2y7bbIhOIoPY5sT183ZW0YFofScC4q/hIpQ= | |
| 67 | 69 | github.com/andybalholm/brotli v1.2.1 h1:R+f5xP285VArJDRgowrfb9DqL18yVK0gKAW/F+eTWro= | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -30,7 +30,7 @@ func (cache *memoryCache) Get(ctx context.Context, key string) (value string, er | |||
| 30 | 30 | ||
| 31 | 31 | response, ok := cache.store.Get(key) | |
| 32 | 32 | if !ok { | |
| 33 | - return "", stacktrace.NewError("no item found in cache with key [%s]", key) | ||
| 33 | + return "", stacktrace.NewErrorf("no item found in cache with key [%s]", key) | ||
| 34 | 34 | } | |
| 35 | 35 | ||
| 36 | 36 | return response.(string), nil | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -31,10 +31,10 @@ func (cache *redisCache) Get(ctx context.Context, key string) (value string, err | |||
| 31 | 31 | ||
| 32 | 32 | response, err := cache.client.Get(ctx, key).Result() | |
| 33 | 33 | if errors.Is(err, redis.Nil) { | |
| 34 | - return "", stacktrace.Propagate(err, "no item found in redis with key [%s]", key) | ||
| 34 | + return "", stacktrace.Propagatef(err, "no item found in redis with key [%s]", key) | ||
| 35 | 35 | } | |
| 36 | 36 | if err != nil { | |
| 37 | - return "", stacktrace.Propagate(err, "cannot get item in redis with key [%s]", key) | ||
| 37 | + return "", stacktrace.Propagatef(err, "cannot get item in redis with key [%s]", key) | ||
| 38 | 38 | } | |
| 39 | 39 | return response, nil | |
| 40 | 40 | } | |
@@ -46,7 +46,7 @@ func (cache *redisCache) Set(ctx context.Context, key string, value string, ttl | |||
| 46 | 46 | ||
| 47 | 47 | err := cache.client.Set(ctx, key, value, ttl).Err() | |
| 48 | 48 | if err != nil { | |
| 49 | - return cache.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, "cannot set item in redis")) | ||
| 49 | + return cache.tracer.WrapErrorSpan(span, stacktrace.Propagatef(err, "cannot set item in redis")) | ||
| 50 | 50 | } | |
| 51 | 51 | return nil | |
| 52 | 52 | } | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -268,7 +268,7 @@ func (container *Container) DedicatedDB() (db *gorm.DB) { | |||
| 268 | 268 | } | |
| 269 | 269 | ||
| 270 | 270 | if err = db.Use(tracing.NewPlugin()); err != nil { | |
| 271 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot use GORM tracing plugin")) | ||
| 271 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot use GORM tracing plugin")) | ||
| 272 | 272 | } | |
| 273 | 273 | ||
| 274 | 274 | container.dedicatedDB = db | |
@@ -279,11 +279,11 @@ func (container *Container) DedicatedDB() (db *gorm.DB) { | |||
| 279 | 279 | ||
| 280 | 280 | container.logger.Debug(fmt.Sprintf("Running migrations for dedicated [%T]", db)) | |
| 281 | 281 | if err = db.AutoMigrate(&entities.Heartbeat{}); err != nil { | |
| 282 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot migrate %T", &entities.Heartbeat{})) | ||
| 282 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot migrate %T", &entities.Heartbeat{})) | ||
| 283 | 283 | } | |
| 284 | 284 | ||
| 285 | 285 | if err = db.AutoMigrate(&entities.HeartbeatMonitor{}); err != nil { | |
| 286 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot migrate %T", &entities.HeartbeatMonitor{})) | ||
| 286 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot migrate %T", &entities.HeartbeatMonitor{})) | ||
| 287 | 287 | } | |
| 288 | 288 | ||
| 289 | 289 | return container.dedicatedDB | |
@@ -326,7 +326,7 @@ func (container *Container) DBWithoutMigration() (db *gorm.DB) { | |||
| 326 | 326 | container.db = db | |
| 327 | 327 | ||
| 328 | 328 | if err = db.Use(tracing.NewPlugin()); err != nil { | |
| 329 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot use GORM tracing plugin")) | ||
| 329 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot use GORM tracing plugin")) | ||
| 330 | 330 | } | |
| 331 | 331 | return container.db | |
| 332 | 332 | } | |
@@ -351,7 +351,7 @@ func (container *Container) DB() (db *gorm.DB) { | |||
| 351 | 351 | container.db = db | |
| 352 | 352 | ||
| 353 | 353 | if err = db.Use(tracing.NewPlugin()); err != nil { | |
| 354 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot use GORM tracing plugin")) | ||
| 354 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot use GORM tracing plugin")) | ||
| 355 | 355 | } | |
| 356 | 356 | ||
| 357 | 357 | if os.Getenv("DATABASE_MIGRATION_SKIP") != "" { | |
@@ -371,47 +371,47 @@ ALTER TABLE discords ADD CONSTRAINT IF NOT EXISTS uni_discords_server_id CHECK ( | |||
| 371 | 371 | } | |
| 372 | 372 | ||
| 373 | 373 | if err = db.AutoMigrate(&entities.Message{}); err != nil { | |
| 374 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot migrate %T", &entities.Message{})) | ||
| 374 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot migrate %T", &entities.Message{})) | ||
| 375 | 375 | } | |
| 376 | 376 | ||
| 377 | 377 | if err = db.AutoMigrate(&entities.MessageThread{}); err != nil { | |
| 378 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot migrate %T", &entities.MessageThread{})) | ||
| 378 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot migrate %T", &entities.MessageThread{})) | ||
| 379 | 379 | } | |
| 380 | 380 | ||
| 381 | 381 | if err = db.AutoMigrate(&entities.User{}); err != nil { | |
| 382 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot migrate %T", &entities.User{})) | ||
| 382 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot migrate %T", &entities.User{})) | ||
| 383 | 383 | } | |
| 384 | 384 | ||
| 385 | 385 | if err = db.AutoMigrate(&entities.MessageSendSchedule{}); err != nil { | |
| 386 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot migrate %T", &entities.MessageSendSchedule{})) | ||
| 386 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot migrate %T", &entities.MessageSendSchedule{})) | ||
| 387 | 387 | } | |
| 388 | 388 | ||
| 389 | 389 | if err = db.AutoMigrate(&entities.Phone{}); err != nil { | |
| 390 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot migrate %T", &entities.Phone{})) | ||
| 390 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot migrate %T", &entities.Phone{})) | ||
| 391 | 391 | } | |
| 392 | 392 | ||
| 393 | 393 | if err = db.AutoMigrate(&entities.PhoneNotification{}); err != nil { | |
| 394 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot migrate %T", &entities.PhoneNotification{})) | ||
| 394 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot migrate %T", &entities.PhoneNotification{})) | ||
| 395 | 395 | } | |
| 396 | 396 | ||
| 397 | 397 | if err = db.AutoMigrate(&entities.BillingUsage{}); err != nil { | |
| 398 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot migrate %T", &entities.BillingUsage{})) | ||
| 398 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot migrate %T", &entities.BillingUsage{})) | ||
| 399 | 399 | } | |
| 400 | 400 | ||
| 401 | 401 | if err = db.AutoMigrate(&entities.Webhook{}); err != nil { | |
| 402 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot migrate %T", &entities.Webhook{})) | ||
| 402 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot migrate %T", &entities.Webhook{})) | ||
| 403 | 403 | } | |
| 404 | 404 | ||
| 405 | 405 | if err = db.AutoMigrate(&entities.Discord{}); err != nil { | |
| 406 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot migrate %T", &entities.Discord{})) | ||
| 406 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot migrate %T", &entities.Discord{})) | ||
| 407 | 407 | } | |
| 408 | 408 | ||
| 409 | 409 | if err = db.AutoMigrate(&entities.Integration3CX{}); err != nil { | |
| 410 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot migrate %T", &entities.Integration3CX{})) | ||
| 410 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot migrate %T", &entities.Integration3CX{})) | ||
| 411 | 411 | } | |
| 412 | 412 | ||
| 413 | 413 | if err = db.AutoMigrate(&entities.PhoneAPIKey{}); err != nil { | |
| 414 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot migrate %T", &entities.PhoneAPIKey{})) | ||
| 414 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot migrate %T", &entities.PhoneAPIKey{})) | ||
| 415 | 415 | } | |
| 416 | 416 | ||
| 417 | 417 | return container.db | |
@@ -423,7 +423,7 @@ func (container *Container) FirebaseApp() (app *firebase.App) { | |||
| 423 | 423 | ||
| 424 | 424 | app, err := firebase.NewApp(context.Background(), nil, option.WithCredentialsJSON(container.FirebaseCredentials())) | |
| 425 | 425 | if err != nil { | |
| 426 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot initialize firebase application")) | ||
| 426 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot initialize firebase application")) | ||
| 427 | 427 | } | |
| 428 | 428 | return app | |
| 429 | 429 | } | |
@@ -444,7 +444,7 @@ func (container *Container) Cache() cache.Cache { | |||
| 444 | 444 | container.logger.Debug("creating cache.Cache") | |
| 445 | 445 | opt, err := redis.ParseURL(os.Getenv("REDIS_URL")) | |
| 446 | 446 | if err != nil { | |
| 447 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot parse redis url [%s]", os.Getenv("REDIS_URL"))) | ||
| 447 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot parse redis url [%s]", os.Getenv("REDIS_URL"))) | ||
| 448 | 448 | } | |
| 449 | 449 | if strings.HasPrefix(os.Getenv("REDIS_URL"), "rediss://") { | |
| 450 | 450 | opt.TLSConfig = &tls.Config{ | |
@@ -456,12 +456,12 @@ func (container *Container) Cache() cache.Cache { | |||
| 456 | 456 | ||
| 457 | 457 | // Enable tracing instrumentation. | |
| 458 | 458 | if err = redisotel.InstrumentTracing(redisClient); err != nil { | |
| 459 | - container.logger.Error(stacktrace.Propagate(err, "cannot instrument redis tracing")) | ||
| 459 | + container.logger.Error(stacktrace.Propagatef(err, "cannot instrument redis tracing")) | ||
| 460 | 460 | } | |
| 461 | 461 | ||
| 462 | 462 | // Enable metrics instrumentation. | |
| 463 | 463 | if err = redisotel.InstrumentMetrics(redisClient); err != nil { | |
| 464 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot instrument redis metrics")) | ||
| 464 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot instrument redis metrics")) | ||
| 465 | 465 | } | |
| 466 | 466 | ||
| 467 | 467 | return cache.NewRedisCache(container.Tracer(), redisClient) | |
@@ -472,7 +472,7 @@ func (container *Container) FirebaseAuthClient() (client *auth.Client) { | |||
| 472 | 472 | container.logger.Debug(fmt.Sprintf("creating %T", client)) | |
| 473 | 473 | authClient, err := container.FirebaseApp().Auth(context.Background()) | |
| 474 | 474 | if err != nil { | |
| 475 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot initialize firebase auth client")) | ||
| 475 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot initialize firebase auth client")) | ||
| 476 | 476 | } | |
| 477 | 477 | return authClient | |
| 478 | 478 | } | |
@@ -483,7 +483,7 @@ func (container *Container) CloudTasksClient() (client *cloudtasks.Client) { | |||
| 483 | 483 | ||
| 484 | 484 | client, err := cloudtasks.NewClient(context.Background(), option.WithCredentialsJSON(container.FirebaseCredentials())) | |
| 485 | 485 | if err != nil { | |
| 486 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot initialize cloud tasks client")) | ||
| 486 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot initialize cloud tasks client")) | ||
| 487 | 487 | } | |
| 488 | 488 | ||
| 489 | 489 | return client | |
@@ -551,7 +551,7 @@ func (container *Container) FCMClient() services.FCMClient { | |||
| 551 | 551 | container.logger.Debug("creating FirebaseFCMClient") | |
| 552 | 552 | messagingClient, err := container.FirebaseApp().Messaging(context.Background()) | |
| 553 | 553 | if err != nil { | |
| 554 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot initialize firebase messaging client")) | ||
| 554 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot initialize firebase messaging client")) | ||
| 555 | 555 | } | |
| 556 | 556 | return services.NewFirebaseFCMClient(messagingClient) | |
| 557 | 557 | } | |
@@ -745,7 +745,7 @@ func (container *Container) Float64Histogram(name, unit, description string) ote | |||
| 745 | 745 | ) | |
| 746 | 746 | histogram, err := meter.Float64Histogram(name, otelMetric.WithUnit(unit), otelMetric.WithDescription(description)) | |
| 747 | 747 | if err != nil { | |
| 748 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot create float64 histogram")) | ||
| 748 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot create float64 histogram")) | ||
| 749 | 749 | } | |
| 750 | 750 | return histogram | |
| 751 | 751 | } | |
@@ -1525,7 +1525,7 @@ func (container *Container) RegisterWebsocketListeners() { | |||
| 1525 | 1525 | container.logger.Debug(fmt.Sprintf("registering listeners for %T", listeners.WebsocketListener{})) | |
| 1526 | 1526 | ||
| 1527 | 1527 | if os.Getenv("PUSHER_SECRET") == "" { | |
| 1528 | - container.logger.Warn(stacktrace.NewError("skipping websocket listeners because the PUSHER_SECRET env variable is not set")) | ||
| 1528 | + container.logger.Warn(stacktrace.NewErrorf("skipping websocket listeners because the PUSHER_SECRET env variable is not set")) | ||
| 1529 | 1529 | return | |
| 1530 | 1530 | } | |
| 1531 | 1531 | ||
@@ -1579,7 +1579,7 @@ func (container *Container) AttachmentRepository() repositories.AttachmentReposi | |||
| 1579 | 1579 | container.logger.Debug("creating GoogleCloudStorageAttachmentRepository") | |
| 1580 | 1580 | client, err := storage.NewClient(context.Background(), option.WithAuthCredentialsJSON(option.ServiceAccount, container.FirebaseCredentials())) | |
| 1581 | 1581 | if err != nil { | |
| 1582 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot create GCS client")) | ||
| 1582 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot create GCS client")) | ||
| 1583 | 1583 | } | |
| 1584 | 1584 | container.attachmentRepository = repositories.NewGoogleCloudStorageAttachmentRepository( | |
| 1585 | 1585 | container.Logger(), | |
@@ -1767,7 +1767,7 @@ func (container *Container) PhoneRistrettoCache() *ristretto.Cache[string, *enti | |||
| 1767 | 1767 | BufferItems: 64, | |
| 1768 | 1768 | }) | |
| 1769 | 1769 | if err != nil { | |
| 1770 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot create phone ristretto cache")) | ||
| 1770 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot create phone ristretto cache")) | ||
| 1771 | 1771 | } | |
| 1772 | 1772 | container.phoneRistrettoCache = ristrettoCache | |
| 1773 | 1773 | return container.phoneRistrettoCache | |
@@ -1785,7 +1785,7 @@ func (container *Container) UserRistrettoCache() *ristretto.Cache[string, entiti | |||
| 1785 | 1785 | BufferItems: 64, | |
| 1786 | 1786 | }) | |
| 1787 | 1787 | if err != nil { | |
| 1788 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot create user ristretto cache")) | ||
| 1788 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot create user ristretto cache")) | ||
| 1789 | 1789 | } | |
| 1790 | 1790 | container.userRistrettoCache = ristrettoCache | |
| 1791 | 1791 | return ristrettoCache | |
@@ -1801,7 +1801,7 @@ func (container *Container) initializeGoogleTraceProvider(version string, namesp | |||
| 1801 | 1801 | ||
| 1802 | 1802 | traceExporter, err := cloudtrace.New(cloudtrace.WithProjectID(os.Getenv("GCP_PROJECT_ID"))) | |
| 1803 | 1803 | if err != nil { | |
| 1804 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot create cloud trace traceExporter")) | ||
| 1804 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot create cloud trace traceExporter")) | ||
| 1805 | 1805 | } | |
| 1806 | 1806 | ||
| 1807 | 1807 | tp := trace.NewTracerProvider( | |
@@ -1813,7 +1813,7 @@ func (container *Container) initializeGoogleTraceProvider(version string, namesp | |||
| 1813 | 1813 | ||
| 1814 | 1814 | metricExporter, err := mexporter.New(mexporter.WithProjectID(os.Getenv("GCP_PROJECT_ID"))) | |
| 1815 | 1815 | if err != nil { | |
| 1816 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot create cloud metric traceExporter")) | ||
| 1816 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot create cloud metric traceExporter")) | ||
| 1817 | 1817 | } | |
| 1818 | 1818 | ||
| 1819 | 1819 | meterProvider := metric.NewMeterProvider( | |
@@ -1824,10 +1824,10 @@ func (container *Container) initializeGoogleTraceProvider(version string, namesp | |||
| 1824 | 1824 | ||
| 1825 | 1825 | return func() { | |
| 1826 | 1826 | if err = metricExporter.Shutdown(context.Background()); err != nil { | |
| 1827 | - container.logger.Error(stacktrace.Propagate(err, "cannot shutdown cloud metric metric exporter")) | ||
| 1827 | + container.logger.Error(stacktrace.Propagatef(err, "cannot shutdown cloud metric metric exporter")) | ||
| 1828 | 1828 | } | |
| 1829 | 1829 | if err = traceExporter.Shutdown(context.Background()); err != nil { | |
| 1830 | - container.logger.Error(stacktrace.Propagate(err, "cannot shutdown cloud trace trace exporter")) | ||
| 1830 | + container.logger.Error(stacktrace.Propagatef(err, "cannot shutdown cloud trace trace exporter")) | ||
| 1831 | 1831 | } | |
| 1832 | 1832 | } | |
| 1833 | 1833 | } | |
@@ -1846,7 +1846,7 @@ func (container *Container) initializeAxiomTraceProvider(version string, namespa | |||
| 1846 | 1846 | otlptracehttp.WithHeaders(traceHeaders), | |
| 1847 | 1847 | ) | |
| 1848 | 1848 | if err != nil { | |
| 1849 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot create axiom OTLP trace exporter")) | ||
| 1849 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot create axiom OTLP trace exporter")) | ||
| 1850 | 1850 | } | |
| 1851 | 1851 | ||
| 1852 | 1852 | tp := trace.NewTracerProvider( | |
@@ -1872,7 +1872,7 @@ func (container *Container) initializeAxiomTraceProvider(version string, namespa | |||
| 1872 | 1872 | otlpmetrichttp.WithHeaders(metricHeaders), | |
| 1873 | 1873 | ) | |
| 1874 | 1874 | if err != nil { | |
| 1875 | - container.logger.Fatal(stacktrace.Propagate(err, "cannot create axiom OTLP metric exporter")) | ||
| 1875 | + container.logger.Fatal(stacktrace.Propagatef(err, "cannot create axiom OTLP metric exporter")) | ||
| 1876 | 1876 | } | |
| 1877 | 1877 | ||
| 1878 | 1878 | meterProvider := metric.NewMeterProvider( | |
@@ -1883,10 +1883,10 @@ func (container *Container) initializeAxiomTraceProvider(version string, namespa | |||
| 1883 | 1883 | ||
| 1884 | 1884 | return func() { | |
| 1885 | 1885 | if err := tp.Shutdown(context.Background()); err != nil { | |
| 1886 | - container.logger.Error(stacktrace.Propagate(err, "cannot shutdown axiom trace provider")) | ||
| 1886 | + container.logger.Error(stacktrace.Propagatef(err, "cannot shutdown axiom trace provider")) | ||
| 1887 | 1887 | } | |
| 1888 | 1888 | if err := meterProvider.Shutdown(context.Background()); err != nil { | |
| 1889 | - container.logger.Error(stacktrace.Propagate(err, "cannot shutdown axiom meter provider")) | ||
| 1889 | + container.logger.Error(stacktrace.Propagatef(err, "cannot shutdown axiom meter provider")) | ||
| 1890 | 1890 | } | |
| 1891 | 1891 | } | |
| 1892 | 1892 | } | |
@@ -1937,7 +1937,7 @@ func axiomLogger(skipFrameCount int) *zerodriver.Logger { | |||
| 1937 | 1937 | axiomzerolog.SetDataset(os.Getenv("AXIOM_DATASET_EVENTS")), | |
| 1938 | 1938 | ) | |
| 1939 | 1939 | if err != nil { | |
| 1940 | - log.Fatal(stacktrace.Propagate(err, "cannot create axiom zerolog writer")) | ||
| 1940 | + log.Fatal(stacktrace.Propagatef(err, "cannot create axiom zerolog writer")) | ||
| 1941 | 1941 | } | |
| 1942 | 1942 | ||
| 1943 | 1943 | zl := zerolog.New(axiomWriter).With().Timestamp().CallerWithSkipFrameCount(skipFrameCount).Logger() | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -62,12 +62,12 @@ func (factory *hermesNotificationEmailFactory) DiscordSendFailed(user *entities. | |||
| 62 | 62 | ||
| 63 | 63 | html, err := factory.generator.GenerateHTML(email) | |
| 64 | 64 | if err != nil { | |
| 65 | - return nil, stacktrace.Propagate(err, "cannot generate html email") | ||
| 65 | + return nil, stacktrace.Propagatef(err, "cannot generate html email") | ||
| 66 | 66 | } | |
| 67 | 67 | ||
| 68 | 68 | text, err := factory.generator.GeneratePlainText(email) | |
| 69 | 69 | if err != nil { | |
| 70 | - return nil, stacktrace.Propagate(err, "cannot generate text email") | ||
| 70 | + return nil, stacktrace.Propagatef(err, "cannot generate text email") | ||
| 71 | 71 | } | |
| 72 | 72 | ||
| 73 | 73 | return &Email{ | |
@@ -120,7 +120,7 @@ func (factory *hermesNotificationEmailFactory) WebhookSendFailed(user *entities. | |||
| 120 | 120 | ||
| 121 | 121 | html, err := factory.generator.GenerateHTML(email) | |
| 122 | 122 | if err != nil { | |
| 123 | - return nil, stacktrace.Propagate(err, "cannot generate html email") | ||
| 123 | + return nil, stacktrace.Propagatef(err, "cannot generate html email") | ||
| 124 | 124 | } | |
| 125 | 125 | ||
| 126 | 126 | eventPayloadEntryIndex := len(email.Body.Dictionary) - 1 | |
@@ -129,7 +129,7 @@ func (factory *hermesNotificationEmailFactory) WebhookSendFailed(user *entities. | |||
| 129 | 129 | return factory.generator.GeneratePlainText(email) | |
| 130 | 130 | }, formattedPayload) | |
| 131 | 131 | if err != nil { | |
| 132 | - return nil, stacktrace.Propagate(err, "cannot generate text email") | ||
| 132 | + return nil, stacktrace.Propagatef(err, "cannot generate text email") | ||
| 133 | 133 | } | |
| 134 | 134 | ||
| 135 | 135 | return &Email{ | |
@@ -198,12 +198,12 @@ func (factory *hermesNotificationEmailFactory) MessageExpired(user *entities.Use | |||
| 198 | 198 | ||
| 199 | 199 | html, err := factory.generator.GenerateHTML(email) | |
| 200 | 200 | if err != nil { | |
| 201 | - return nil, stacktrace.Propagate(err, "cannot generate html email") | ||
| 201 | + return nil, stacktrace.Propagatef(err, "cannot generate html email") | ||
| 202 | 202 | } | |
| 203 | 203 | ||
| 204 | 204 | text, err := factory.generator.GeneratePlainText(email) | |
| 205 | 205 | if err != nil { | |
| 206 | - return nil, stacktrace.Propagate(err, "cannot generate text email") | ||
| 206 | + return nil, stacktrace.Propagatef(err, "cannot generate text email") | ||
| 207 | 207 | } | |
| 208 | 208 | ||
| 209 | 209 | return &Email{ | |
@@ -249,12 +249,12 @@ func (factory *hermesNotificationEmailFactory) MessageFailed(user *entities.User | |||
| 249 | 249 | ||
| 250 | 250 | html, err := factory.generator.GenerateHTML(email) | |
| 251 | 251 | if err != nil { | |
| 252 | - return nil, stacktrace.Propagate(err, "cannot generate html email") | ||
| 252 | + return nil, stacktrace.Propagatef(err, "cannot generate html email") | ||
| 253 | 253 | } | |
| 254 | 254 | ||
| 255 | 255 | text, err := factory.generator.GeneratePlainText(email) | |
| 256 | 256 | if err != nil { | |
| 257 | - return nil, stacktrace.Propagate(err, "cannot generate text email") | ||
| 257 | + return nil, stacktrace.Propagatef(err, "cannot generate text email") | ||
| 258 | 258 | } | |
| 259 | 259 | ||
| 260 | 260 | return &Email{ | |
| Back | FazBrowse Home | New Git URL |
0 commit comments