Revert "Replace interface{} with any"

Author: cschleiden

analyzer/analyzer.go

@@ -24,7 +24,7 @@ func New() *analysis.Analyzer {
 	return a
 }
 
-func run(pass *analysis.Pass) (any, error) {
+func run(pass *analysis.Pass) (interface{}, error) {
 	inspector := pass.ResultOf[inspect.Analyzer].(*inspector.Inspector)
 
 	// Expect workflows to be top level functions in a file. Therefore it should be enough to just keep track if the current

analyzer/testdata/src/github.com/cschleiden/go-workflows/workflow/workflow.go

@@ -1,3 +1,3 @@
 package workflow
 
-type Context any
+type Context interface{}

backend/converter/converter.go

@@ -6,10 +6,10 @@ import (
 
 type Converter interface {
 	// To converts the given value to a payload
-	To(v any) (payload.Payload, error)
+	To(v interface{}) (payload.Payload, error)
 
 	// From converts the given payload to a value
-	From(data payload.Payload, v any) error
+	From(data payload.Payload, v interface{}) error
 }
 
 var DefaultConverter Converter = &jsonConverter{}

backend/converter/json.go

@@ -8,10 +8,10 @@ import (
 
 type jsonConverter struct{}
 
-func (jc *jsonConverter) To(v any) (payload.Payload, error) {
+func (jc *jsonConverter) To(v interface{}) (payload.Payload, error) {
 	return json.Marshal(v)
 }
 
-func (jc *jsonConverter) From(data payload.Payload, vptr any) error {
+func (jc *jsonConverter) From(data payload.Payload, vptr interface{}) error {
 	return json.Unmarshal(data, vptr)
 }

backend/history/history.go

@@ -131,7 +131,7 @@ type Event struct {
 	ScheduleEventID int64 `json:"seid,omitempty"`
 
 	// Attributes are event type specific attributes
-	Attributes any `json:"attr,omitempty"`
+	Attributes interface{} `json:"attr,omitempty"`
 
 	VisibleAt *time.Time `json:"vat,omitempty"`
 }
@@ -154,7 +154,7 @@ func VisibleAt(visibleAt time.Time) HistoryEventOption {
 	}
 }
 
-func NewHistoryEvent(sequenceID int64, timestamp time.Time, eventType EventType, attributes any, opts ...HistoryEventOption) *Event {
+func NewHistoryEvent(sequenceID int64, timestamp time.Time, eventType EventType, attributes interface{}, opts ...HistoryEventOption) *Event {
 	e := &Event{
 		ID:         uuid.NewString(),
 		SequenceID: sequenceID,
@@ -170,7 +170,7 @@ func NewHistoryEvent(sequenceID int64, timestamp time.Time, eventType EventType,
 	return e
 }
 
-func NewPendingEvent(timestamp time.Time, eventType EventType, attributes any, opts ...HistoryEventOption) *Event {
+func NewPendingEvent(timestamp time.Time, eventType EventType, attributes interface{}, opts ...HistoryEventOption) *Event {
 	return NewHistoryEvent(0, timestamp, eventType, attributes, opts...)
 }
 

backend/history/serialization.go

@@ -28,11 +28,11 @@ func (e *Event) UnmarshalJSON(data []byte) error {
 	return nil
 }
 
-func SerializeAttributes(attributes any) ([]byte, error) {
+func SerializeAttributes(attributes interface{}) ([]byte, error) {
 	return json.Marshal(attributes)
 }
 
-func DeserializeAttributes(eventType EventType, attributes []byte) (attr any, err error) {
+func DeserializeAttributes(eventType EventType, attributes []byte) (attr interface{}, err error) {
 	switch eventType {
 	case EventType_WorkflowExecutionStarted:
 		attr = &ExecutionStartedAttributes{}

backend/mock_Backend.go

@@ -28,13 +28,13 @@ func insertEvents(ctx context.Context, tx *sql.Tx, tableName string, instance *c
 		batchEvents := events[batchStart:batchEnd]
 
 		aquery := "INSERT IGNORE INTO `attributes` (event_id, instance_id, execution_id, data) VALUES (?, ?, ?, ?)" + strings.Repeat(", (?, ?, ?, ?)", len(batchEvents)-1)
-		aargs := make([]any, 0, len(batchEvents)*4)
+		aargs := make([]interface{}, 0, len(batchEvents)*4)
 
 		query := "INSERT INTO `" + tableName +
 			"` (event_id, sequence_id, instance_id, execution_id, event_type, timestamp, schedule_event_id, visible_at) VALUES (?, ?, ?, ?, ?, ?, ?, ?)" +
 			strings.Repeat(", (?, ?, ?, ?, ?, ?, ?, ?)", len(batchEvents)-1)
 
-		args := make([]any, 0, len(batchEvents)*8)
+		args := make([]interface{}, 0, len(batchEvents)*8)
 
 		for _, newEvent := range batchEvents {
 			a, err := history.SerializeAttributes(newEvent.Attributes)

backend/mysql/events.go

@@ -239,7 +239,7 @@ func (b *mysqlBackend) RemoveWorkflowInstances(ctx context.Context, options ...b
 
 		placeholders := strings.Repeat(",?", len(instanceIDs)-1)
 		whereCondition := fmt.Sprintf("instance_id IN (?%v) AND execution_id IN (?%v)", placeholders, placeholders)
-		args := make([]any, 0, len(instanceIDs)*2)
+		args := make([]interface{}, 0, len(instanceIDs)*2)
 		for i := range instanceIDs {
 			args = append(args, instanceIDs[i])
 		}
@@ -670,7 +670,7 @@ func (b *mysqlBackend) CompleteWorkflowTask(
 
 	// Remove handled events from task
 	if len(executedEvents) > 0 {
-		args := make([]any, 0, len(executedEvents)+1)
+		args := make([]interface{}, 0, len(executedEvents)+1)
 		args = append(args, instance.InstanceID, instance.ExecutionID)
 		for _, e := range executedEvents {
 			args = append(args, e.ID)
@@ -817,7 +817,7 @@ func (b *mysqlBackend) GetActivityTask(ctx context.Context, queues []workflow.Qu
 
 	now := time.Now()
 
-	args := make([]any, 0, len(queues)+1)
+	args := make([]interface{}, 0, len(queues)+1)
 	args = append(args, now)
 	for _, q := range queues {
 		args = append(args, string(q))

backend/mysql/mysql.go

@@ -17,7 +17,7 @@ type eventWithoutAttributes struct {
 func (e *eventWithoutAttributes) MarshalJSON() ([]byte, error) {
 	return json.Marshal(&struct {
 		*history.Event
-		Attributes any `json:"attr"`
+		Attributes interface{} `json:"attr"`
 	}{
 		Event:      e.Event,
 		Attributes: nil,
@@ -44,7 +44,7 @@ var addPayloadsCmd = redis.NewScript(`
 `)
 
 func (rb *redisBackend) addEventPayloadsP(ctx context.Context, p redis.Pipeliner, instance *core.WorkflowInstance, events []*history.Event) error {
-	args := make([]any, 0)
+	args := make([]interface{}, 0)
 
 	for _, event := range events {
 		payload, err := json.Marshal(event.Attributes)
@@ -67,7 +67,7 @@ func addEventToStreamP(ctx context.Context, p redis.Pipeliner, streamKey string,
 	return p.XAdd(ctx, &redis.XAddArgs{
 		Stream: streamKey,
 		ID:     "*",
-		Values: map[string]any{
+		Values: map[string]interface{}{
 			"event": string(eventData),
 		},
 	}).Err()