Fix lint

Signed-off-by: Ricardo Zanini <[email protected]>

Author: ricardozanini

expr/expr.go

@@ -17,8 +17,9 @@ package expr
 import (
 	"errors"
 	"fmt"
-	"github.com/itchyny/gojq"
 	"strings"
+
+	"github.com/itchyny/gojq"
 )
 
 // IsStrictExpr returns true if the string is enclosed in `${ }`

impl/json_schema.go

@@ -18,6 +18,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+
 	"github.com/serverlessworkflow/sdk-go/v3/model"
 	"github.com/xeipuuv/gojsonschema"
 )

impl/runner.go

@@ -17,6 +17,7 @@ package impl
 import (
 	"context"
 	"fmt"
+
 	"github.com/serverlessworkflow/sdk-go/v3/model"
 )
 

impl/task_runner.go

@@ -16,6 +16,7 @@ package impl
 
 import (
 	"fmt"
+
 	"github.com/serverlessworkflow/sdk-go/v3/expr"
 	"github.com/serverlessworkflow/sdk-go/v3/model"
 )

impl/task_runner_do.go

@@ -16,6 +16,7 @@ package impl
 
 import (
 	"fmt"
+
 	"github.com/serverlessworkflow/sdk-go/v3/expr"
 	"github.com/serverlessworkflow/sdk-go/v3/model"
 )

impl/task_runner_raise_test.go

@@ -17,9 +17,10 @@ package impl
 import (
 	"encoding/json"
 	"errors"
+	"testing"
+
 	"github.com/serverlessworkflow/sdk-go/v3/model"
 	"github.com/stretchr/testify/assert"
-	"testing"
 )
 
 func TestRaiseTaskRunner_WithDefinedError(t *testing.T) {
@@ -47,16 +48,20 @@ func TestRaiseTaskRunner_WithDefinedError(t *testing.T) {
 
 	expectedErr := model.NewErrValidation(errors.New("Invalid input data"), "task_raise_defined")
 
-	assert.Equal(t, expectedErr.Type.String(), err.(*model.Error).Type.String())
-	assert.Equal(t, expectedErr.Status, err.(*model.Error).Status)
-	assert.Equal(t, expectedErr.Title.String(), err.(*model.Error).Title.String())
-	assert.Equal(t, "Invalid input data", err.(*model.Error).Detail.String())
-	assert.Equal(t, expectedErr.Instance.String(), err.(*model.Error).Instance.String())
+	var modelErr *model.Error
+	if errors.As(err, &modelErr) {
+		assert.Equal(t, expectedErr.Type.String(), modelErr.Type.String())
+		assert.Equal(t, expectedErr.Status, modelErr.Status)
+		assert.Equal(t, expectedErr.Title.String(), modelErr.Title.String())
+		assert.Equal(t, "Invalid input data", modelErr.Detail.String())
+		assert.Equal(t, expectedErr.Instance.String(), modelErr.Instance.String())
+	} else {
+		t.Errorf("expected error of type *model.Error but got %T", err)
+	}
 }
 
 func TestRaiseTaskRunner_WithReferencedError(t *testing.T) {
-	var ref string
-	ref = "someErrorRef"
+	ref := "someErrorRef"
 	raiseTask := &model.RaiseTask{
 		Raise: model.RaiseTaskConfiguration{
 			Error: model.RaiseTaskError{
@@ -97,11 +102,16 @@ func TestRaiseTaskRunner_TimeoutErrorWithExpression(t *testing.T) {
 
 	expectedErr := model.NewErrTimeout(errors.New("Request took too long"), "task_raise_timeout_expr")
 
-	assert.Equal(t, expectedErr.Type.String(), err.(*model.Error).Type.String())
-	assert.Equal(t, expectedErr.Status, err.(*model.Error).Status)
-	assert.Equal(t, expectedErr.Title.String(), err.(*model.Error).Title.String())
-	assert.Equal(t, "Request took too long", err.(*model.Error).Detail.String())
-	assert.Equal(t, expectedErr.Instance.String(), err.(*model.Error).Instance.String())
+	var modelErr *model.Error
+	if errors.As(err, &modelErr) {
+		assert.Equal(t, expectedErr.Type.String(), modelErr.Type.String())
+		assert.Equal(t, expectedErr.Status, modelErr.Status)
+		assert.Equal(t, expectedErr.Title.String(), modelErr.Title.String())
+		assert.Equal(t, "Request took too long", modelErr.Detail.String())
+		assert.Equal(t, expectedErr.Instance.String(), modelErr.Instance.String())
+	} else {
+		t.Errorf("expected error of type *model.Error but got %T", err)
+	}
 }
 
 func TestRaiseTaskRunner_Serialization(t *testing.T) {
@@ -134,8 +144,7 @@ func TestRaiseTaskRunner_Serialization(t *testing.T) {
 }
 
 func TestRaiseTaskRunner_ReferenceSerialization(t *testing.T) {
-	var ref string
-	ref = "errorReference"
+	ref := "errorReference"
 	raiseTask := &model.RaiseTask{
 		Raise: model.RaiseTaskConfiguration{
 			Error: model.RaiseTaskError{

impl/task_runner_test.go

@@ -15,12 +15,13 @@
 package impl
 
 import (
-	"github.com/serverlessworkflow/sdk-go/v3/model"
-	"github.com/serverlessworkflow/sdk-go/v3/parser"
-	"github.com/stretchr/testify/assert"
 	"os"
 	"path/filepath"
 	"testing"
+
+	"github.com/serverlessworkflow/sdk-go/v3/model"
+	"github.com/serverlessworkflow/sdk-go/v3/parser"
+	"github.com/stretchr/testify/assert"
 )
 
 // runWorkflowTest is a reusable test function for workflows

impl/task_set_test.go

@@ -15,10 +15,11 @@
 package impl
 
 import (
-	"github.com/serverlessworkflow/sdk-go/v3/model"
-	"github.com/stretchr/testify/assert"
 	"reflect"
 	"testing"
+
+	"github.com/serverlessworkflow/sdk-go/v3/model"
+	"github.com/stretchr/testify/assert"
 )
 
 func TestSetTaskExecutor_Exec(t *testing.T) {

model/errors.go

@@ -297,13 +297,13 @@ func GenerateJSONPointer(workflow *Workflow, targetNode interface{}) (string, er
 	// Convert struct to JSON
 	jsonData, err := json.Marshal(workflow)
 	if err != nil {
-		return "", fmt.Errorf("error marshalling to JSON: %v", err)
+		return "", fmt.Errorf("error marshalling to JSON: %w", err)
 	}
 
 	// Convert JSON to a generic map for traversal
 	var jsonMap map[string]interface{}
 	if err := json.Unmarshal(jsonData, &jsonMap); err != nil {
-		return "", fmt.Errorf("error unmarshalling JSON: %v", err)
+		return "", fmt.Errorf("error unmarshalling JSON: %w", err)
 	}
 
 	transformedNode := ""

model/errors_test.go

@@ -15,8 +15,9 @@
 package model
 
 import (
-	"github.com/stretchr/testify/assert"
 	"testing"
+
+	"github.com/stretchr/testify/assert"
 )
 
 // TestGenerateJSONPointer_SimpleTask tests a simple workflow task.