Error handling refactor

constructor/dsl/dsl.go

@@ -52,7 +52,7 @@ func Parse(ctx context.Context, file string) ([]*job.Workflow, *Error) {
 	}
 	defer func() {
 		if err := f.Close(); err != nil {
-			log.Printf("%s: could not close %s\n", err.Error(), cleanedPath)
+			log.Printf("could not close %s: %s\n", cleanedPath, err.Error())
 		}
 	}()
 

fetcher/utils.go

@@ -104,11 +104,11 @@ func tryAgain(fetchMsg string, thisBackoff *Backoff, err *Error) *Error {
 
 	thisBackoff.attempts++
 	log.Printf(
-		"%s: retrying fetch for %s after %fs (prior attempts: %d)\n",
-		errMessage,
+		"retrying fetch for %s after %fs (prior attempts: %d): %s\n",
 		fetchMsg,
 		nextBackoff.Seconds(),
 		thisBackoff.attempts,
+		errMessage,
 	)
 	time.Sleep(nextBackoff)
 

parser/intent.go

@@ -131,9 +131,9 @@ func (p *Parser) ExpectedOperations(
 
 		if len(failedMatches) > 0 {
 			errString += fmt.Sprintf(
-				"%s: found matching ops with unsuccessful status %s",
-				errString,
+				"found matching ops with unsuccessful status %s: %s",
 				types.PrettyPrintStruct(failedMatches),
+				errString,
 			)
 		}
 

reconciler/reconciler.go

@@ -95,7 +95,7 @@ func (r *Reconciler) wrappedActiveEnqueue(
 			change.Currency,
 			BacklogFull,
 		); err != nil {
-			log.Printf("%s: reconciliation skipped handling failed\n", err.Error())
+			log.Printf("reconciliation skipped handling failed: %s\n", err.Error())
 		}
 	}
 }
@@ -106,9 +106,9 @@ func (r *Reconciler) wrappedInactiveEnqueue(
 ) {
 	if err := r.inactiveAccountQueue(true, accountCurrency, liveBlock, false); err != nil {
 		log.Printf(
-			"%s: unable to queue account %s",
-			err.Error(),
+			"unable to queue account %s: %s",
 			types.PrintStruct(accountCurrency),
+			err.Error(),
 		)
 	}
 }

storage/modules/balance_storage.go

@@ -884,8 +884,11 @@ func (b *BalanceStorage) UpdateBalance(
 
 	if bigNewVal.Sign() == -1 {
 		return false, fmt.Errorf(
-			"%s is invalid: %w",
+			"account balance %s of currency %s for account %s at block %s is invalid: %w",
 			newVal,
+			types.PrintStruct(change.Currency),
+			types.PrintStruct(change.Account),
+			types.PrintStruct(change.Block),
 			storageErrs.ErrNegativeBalance,
 		)
 	}

storage/modules/broadcast_storage.go

@@ -443,9 +443,9 @@ func (b *BroadcastStorage) performBroadcast(
 	if err != nil {
 		// Don't error on broadcast failure, retries will automatically be handled.
 		log.Printf(
-			"%s: unable to broadcast transaction %s",
-			err.Error(),
+			"unable to broadcast transaction %s: %s",
 			broadcast.TransactionIdentifier.Hash,
+			err.Error(),
 		)
 
 		return nil