#71 feat(release): release 1.0.7

#71 feat(release): release 1.0.7

Author: rustatian

.golangci.yml

@@ -57,7 +57,7 @@ linters: # All available linters list: <https://golangci-lint.run/usage/linters/
     - gocritic # The most opinionated Go source code linter
     - gofmt # Gofmt checks whether code was gofmt-ed. By default this tool runs with -s option to check for code simplification
     - goimports # Goimports does everything that gofmt does. Additionally it checks unused imports
-    - golint # Golint differs from gofmt. Gofmt reformats Go source code, whereas golint prints out style mistakes
+    - revive
     - goprintffuncname # Checks that printf-like functions are named with `f` at the end
     - gosec # Inspects source code for security problems
     - gosimple # Linter for Go source code that specializes in simplifying a code

activity/activity_pool.go

@@ -11,10 +11,10 @@ import (
 	"github.com/spiral/roadrunner/v2/pkg/pool"
 	rrWorker "github.com/spiral/roadrunner/v2/pkg/worker"
 	"github.com/spiral/roadrunner/v2/plugins/server"
+	"github.com/spiral/roadrunner/v2/utils"
 	roadrunner_temporal "github.com/temporalio/roadrunner-temporal"
 	"github.com/temporalio/roadrunner-temporal/client"
 	rrt "github.com/temporalio/roadrunner-temporal/protocol"
-	"github.com/temporalio/roadrunner-temporal/utils"
 	"go.temporal.io/api/common/v1"
 	"go.temporal.io/sdk/activity"
 	"go.temporal.io/sdk/converter"
@@ -23,9 +23,9 @@ import (
 )
 
 // RR_MODE env variable
-const RR_MODE = "RR_MODE" //nolint:golint,stylecheck
+const RR_MODE = "RR_MODE" //nolint:revive,stylecheck
 // RR_CODEC env variable
-const RR_CODEC = "RR_CODEC" //nolint:golint,stylecheck
+const RR_CODEC = "RR_CODEC" //nolint:revive,stylecheck
 
 //
 const doNotCompleteOnReturn = "doNotCompleteOnReturn"
@@ -118,7 +118,7 @@ func (pool *activityPoolImpl) ActivityNames() []string {
 // ActivityNames returns list of all available activity names.
 func (pool *activityPoolImpl) GetActivityContext(taskToken []byte) (context.Context, error) {
 	const op = errors.Op("activity_pool_get_activity_context")
-	c, ok := pool.running.Load(utils.ToString(taskToken))
+	c, ok := pool.running.Load(utils.AsString(taskToken))
 	if !ok {
 		return nil, errors.E(op, errors.Str("heartbeat on non running activity"))
 	}
@@ -187,8 +187,8 @@ func (pool *activityPoolImpl) executeActivity(ctx context.Context, args *common.
 		msg.Payloads.Payloads = append(msg.Payloads.Payloads, heartbeatDetails.Payloads...)
 	}
 
-	pool.running.Store(utils.ToString(info.TaskToken), ctx)
-	defer pool.running.Delete(utils.ToString(info.TaskToken))
+	pool.running.Store(utils.AsString(info.TaskToken), ctx)
+	defer pool.running.Delete(utils.AsString(info.TaskToken))
 
 	result, err := pool.codec.Execute(pool.wp, rrt.Context{TaskQueue: info.TaskQueue}, msg)
 	if err != nil {

constants.go

@@ -1,7 +1,7 @@
-package roadrunner_temporal //nolint:golint,stylecheck
+package roadrunner_temporal //nolint:revive,stylecheck
 
 const (
-	// Main plugin name
+	// RootPluginName ...
 	RootPluginName = "temporal"
 
 	// RRMode sets as RR_MODE env variable to let worker know about the mode to run.

go.mod

@@ -9,9 +9,9 @@ require (
 	github.com/json-iterator/go v1.1.11
 	github.com/pborman/uuid v1.2.1
 	// SPIRAL ========
-	github.com/spiral/endure v1.0.1
+	github.com/spiral/endure v1.0.2
 	github.com/spiral/errors v1.0.11
-	github.com/spiral/roadrunner/v2 v2.2.1
+	github.com/spiral/roadrunner/v2 v2.3.0
 	// ===========
 	github.com/stretchr/testify v1.7.0
 	go.temporal.io/api v1.4.1-0.20210420220407-6f00f7f98373

go.sum

@@ -6,7 +6,7 @@ import (
 	"github.com/spiral/errors"
 	"github.com/spiral/roadrunner/v2/pkg/payload"
 	"github.com/spiral/roadrunner/v2/plugins/logger"
-	"github.com/temporalio/roadrunner-temporal/utils"
+	"github.com/spiral/roadrunner/v2/utils"
 	"go.temporal.io/api/common/v1"
 	"go.temporal.io/api/failure/v1"
 )
@@ -99,7 +99,7 @@ func (c *JSONCodec) Execute(e Endpoint, ctx Context, msg ...Message) ([]Message,
 	}
 
 	if c.level >= DebugNormal {
-		logMessage := utils.ToString(p.Body) + " " + utils.ToString(p.Context)
+		logMessage := utils.AsString(p.Body) + " " + utils.AsString(p.Context)
 		if c.level >= DebugHumanized {
 			logMessage = color.GreenString(logMessage)
 		}
@@ -118,7 +118,7 @@ func (c *JSONCodec) Execute(e Endpoint, ctx Context, msg ...Message) ([]Message,
 	}
 
 	if c.level >= DebugNormal {
-		logMessage := utils.ToString(out.Body)
+		logMessage := utils.AsString(out.Body)
 		if c.level >= DebugHumanized {
 			logMessage = color.HiYellowString(logMessage)
 		}

protocol/json_codec.go

@@ -22,10 +22,10 @@ import (
 )
 
 // RR_MODE env variable key
-const RR_MODE = "RR_MODE" //nolint:golint,stylecheck
+const RR_MODE = "RR_MODE" //nolint:revive,stylecheck
 
 // RR_CODEC env variable key
-const RR_CODEC = "RR_CODEC" //nolint:golint,stylecheck
+const RR_CODEC = "RR_CODEC" //nolint:revive,stylecheck
 
 // Workflow pool
 type pool interface {