fix: use %w in errors (#367)

Signed-off-by: Chris Gianelloni <wolf31o2@blinklabs.io>

Author: wolf31o2

internal/config/config.go

@@ -77,19 +77,19 @@ func (c *Config) Load(configFile string) error {
 	if configFile != "" {
 		buf, err := os.ReadFile(configFile)
 		if err != nil {
-			return fmt.Errorf("error reading config file: %s", err)
+			return fmt.Errorf("error reading config file: %w", err)
 		}
 		err = yaml.Unmarshal(buf, c)
 		if err != nil {
-			return fmt.Errorf("error parsing config file: %s", err)
+			return fmt.Errorf("error parsing config file: %w", err)
 		}
 	}
 	// Load config values from environment variables
 	// We use "dummy" as the app name here to (mostly) prevent picking up env
 	// vars that we hadn't explicitly specified in annotations above
 	err := envconfig.Process("dummy", c)
 	if err != nil {
-		return fmt.Errorf("error processing environment: %s", err)
+		return fmt.Errorf("error processing environment: %w", err)
 	}
 	return nil
 }

output/embedded/embedded.go

@@ -51,7 +51,7 @@ func (e *EmbeddedOutput) Start() error {
 			}
 			if e.callbackFunc != nil {
 				if err := e.callbackFunc(evt); err != nil {
-					e.errorChan <- fmt.Errorf("callback function error: %s", err)
+					e.errorChan <- fmt.Errorf("callback function error: %w", err)
 					return
 				}
 			}

output/push/push.go

@@ -346,7 +346,7 @@ func extractCIP20FromMetadata(metadata *cbor.LazyValue) (string, error) {
 
 	jsonBytes, err := json.Marshal(msgStruct)
 	if err != nil {
-		return "", fmt.Errorf("error marshalling message to JSON: %v", err)
+		return "", fmt.Errorf("error marshalling message to JSON: %w", err)
 	}
 
 	return string(jsonBytes), nil

output/webhook/webhook.go

@@ -249,7 +249,7 @@ func (w *WebhookOutput) SendWebhook(e *event.Event) error {
 		bytes.NewReader(data),
 	)
 	if err != nil {
-		return fmt.Errorf("%s", err)
+		return fmt.Errorf("%w", err)
 	}
 	req.Header.Add("Content-Type", "application/json")
 	req.Header.Add(
@@ -277,14 +277,14 @@ func (w *WebhookOutput) SendWebhook(e *event.Event) error {
 	// Send payload
 	resp, err := client.Do(req)
 	if err != nil {
-		return fmt.Errorf("%s", err)
+		return fmt.Errorf("%w", err)
 	}
 	if resp == nil {
 		return fmt.Errorf("failed to send payload: %s", data)
 	}
 	respBody, err := io.ReadAll(resp.Body)
 	if err != nil {
-		return fmt.Errorf("%s", err)
+		return fmt.Errorf("%w", err)
 	}
 	defer resp.Body.Close()
 

pipeline/pipeline.go

@@ -62,7 +62,7 @@ func (p *Pipeline) Start() error {
 	// Start inputs
 	for _, input := range p.inputs {
 		if err := input.Start(); err != nil {
-			return fmt.Errorf("failed to start input: %s", err)
+			return fmt.Errorf("failed to start input: %w", err)
 		}
 		// Start background process to send input events to combined filter channel
 		go p.chanCopyLoop(input.OutputChan(), p.filterChan)
@@ -72,7 +72,7 @@ func (p *Pipeline) Start() error {
 	// Start filters
 	for idx, filter := range p.filters {
 		if err := filter.Start(); err != nil {
-			return fmt.Errorf("failed to start input: %s", err)
+			return fmt.Errorf("failed to start input: %w", err)
 		}
 		if idx == 0 {
 			// Start background process to send events from combined filter channel to first filter plugin
@@ -96,7 +96,7 @@ func (p *Pipeline) Start() error {
 	// Start outputs
 	for _, output := range p.outputs {
 		if err := output.Start(); err != nil {
-			return fmt.Errorf("failed to start output: %s", err)
+			return fmt.Errorf("failed to start output: %w", err)
 		}
 		// Start background error listener
 		go p.errorChanWait(output.ErrorChan())
@@ -114,13 +114,13 @@ func (p *Pipeline) Stop() error {
 	// Stop inputs
 	for _, input := range p.inputs {
 		if err := input.Stop(); err != nil {
-			return fmt.Errorf("failed to stop input: %s", err)
+			return fmt.Errorf("failed to stop input: %w", err)
 		}
 	}
 	// Stop outputs
 	for _, output := range p.outputs {
 		if err := output.Stop(); err != nil {
-			return fmt.Errorf("failed to stop output: %s", err)
+			return fmt.Errorf("failed to stop output: %w", err)
 		}
 	}
 	return nil

plugin/option.go

@@ -114,21 +114,21 @@ func (p *PluginOption) ProcessEnvVars(envPrefix string) error {
 			case PluginOptionTypeBool:
 				value, err := strconv.ParseBool(value)
 				if err != nil {
-					return fmt.Errorf("error processing env vars: %s", err)
+					return fmt.Errorf("error processing env vars: %w", err)
 				}
 				*(p.Dest.(*bool)) = value
 			case PluginOptionTypeInt:
 				// We limit to 32-bit to not get inconsistent behavior on 32-bit platforms
 				value, err := strconv.ParseInt(value, 10, 32)
 				if err != nil {
-					return fmt.Errorf("error processing env vars: %s", err)
+					return fmt.Errorf("error processing env vars: %w", err)
 				}
 				*(p.Dest.(*int)) = int(value)
 			case PluginOptionTypeUint:
 				// We limit to 32-bit to not get inconsistent behavior on 32-bit platforms
 				value, err := strconv.ParseUint(value, 10, 32)
 				if err != nil {
-					return fmt.Errorf("error processing env vars: %s", err)
+					return fmt.Errorf("error processing env vars: %w", err)
 				}
 				*(p.Dest.(*uint)) = uint(value)
 			default: