fix: format Telemetry errors (#299)

Author: agneum

internal/retrieval/engine/postgres/logical/dump.go

@@ -376,18 +376,18 @@ func (d *DumpJob) getDBList(ctx context.Context) (map[string]DumpDefinition, err
 
 	querier, err := pgx.Connect(ctx, connStr)
 	if err != nil {
-		return nil, errors.Wrapf(err, "failed to connect to DB: %s", connStr)
+		return nil, fmt.Errorf("failed to connect to DB: %w", err)
 	}
 
 	rows, err := querier.Query(ctx, d.dumper.GetDatabaseListQuery())
 	if err != nil {
-		return nil, errors.Wrap(err, "failed to perform query listing databases")
+		return nil, fmt.Errorf("failed to perform query listing databases: %w", err)
 	}
 
 	for rows.Next() {
 		var dbName string
 		if err := rows.Scan(&dbName); err != nil {
-			return nil, errors.Wrap(err, "failed to scan next row in database list result set")
+			return nil, fmt.Errorf("failed to scan next row in database list result set: %w", err)
 		}
 
 		dbList[dbName] = DumpDefinition{}

internal/retrieval/retrieval.go

@@ -141,7 +141,8 @@ func (r *Retrieval) Run(ctx context.Context) error {
 	log.Msg("Pool to perform data retrieving: ", fsManager.Pool().Name)
 
 	if err := r.run(runCtx, fsManager); err != nil {
-		r.tm.SendEvent(ctx, telemetry.AlertEvent, telemetry.Alert{Level: models.RefreshFailed, Message: err.Error()})
+		r.tm.SendEvent(ctx, telemetry.AlertEvent, telemetry.Alert{Level: models.RefreshFailed,
+			Message: fmt.Sprintf("Failed to perform initial data retrieving: %s", r.State.Mode)})
 		return err
 	}
 
@@ -386,7 +387,8 @@ func (r *Retrieval) setupScheduler(ctx context.Context) {
 func (r *Retrieval) refreshFunc(ctx context.Context) func() {
 	return func() {
 		if err := r.fullRefresh(ctx); err != nil {
-			r.tm.SendEvent(ctx, telemetry.AlertEvent, telemetry.Alert{Level: models.RefreshFailed, Message: err.Error()})
+			r.tm.SendEvent(ctx, telemetry.AlertEvent, telemetry.Alert{Level: models.RefreshFailed,
+				Message: "Failed to run full-refresh"})
 			log.Err("Failed to run full-refresh: ", err)
 		}
 	}