merch-tracker-v2/task-processor
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

structs moved

Browse source
This commit is contained in:
nquidox 2026-02-21 16:59:38 +03:00
parent 150c5193e1
commit 9c79b04d4c
2 changed files with 10 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

9
internal/taskAgent/interface.go
View file

@ -1,8 +1,11 @@
package taskAgent package taskAgent
import "context" import (
"context"
"task-processor/internal/structs"
)
type TaskAgent interface { type TaskAgent interface {
FetchTasks(ctx context.Context) ([]Task, error) FetchTasks(ctx context.Context) ([]structs.Task, error)
SendResults(ctx context.Context, results []Result) error SendResults(ctx context.Context, results []structs.Result) error
} }

7
internal/taskAgent/service.go
View file

@ -5,6 +5,7 @@ import (
log "github.com/sirupsen/logrus" log "github.com/sirupsen/logrus"
"google.golang.org/protobuf/types/known/emptypb" "google.golang.org/protobuf/types/known/emptypb"
"io" "io"
"task-processor/internal/structs"
tt "task-processor/pkg/taskTransport/v1" tt "task-processor/pkg/taskTransport/v1"
"time" "time"
) )
@ -21,7 +22,7 @@ func newService(c tt.TaskProcessorClient, timeout time.Duration) *service {
} }
} }
func (s *service) FetchTasks(ctx context.Context) (received []Task, err error) { func (s *service) FetchTasks(ctx context.Context) (received []structs.Task, err error) {
fetchCtx, cancel := context.WithTimeout(ctx, s.timeout) fetchCtx, cancel := context.WithTimeout(ctx, s.timeout)
defer cancel() defer cancel()
@ -42,7 +43,7 @@ func (s *service) FetchTasks(ctx context.Context) (received []Task, err error) {
return nil, err return nil, err
} }
received = append(received, Task{ received = append(received, structs.Task{
MerchUuid: task.MerchUuid, MerchUuid: task.MerchUuid,
Origins: task.Origins, Origins: task.Origins,
}) })
@ -52,7 +53,7 @@ func (s *service) FetchTasks(ctx context.Context) (received []Task, err error) {
return received, nil return received, nil
} }
func (s *service) SendResults(ctx context.Context, results []Result) error { func (s *service) SendResults(ctx context.Context, results []structs.Result) error {
sendCtx, cancel := context.WithTimeout(ctx, s.timeout) sendCtx, cancel := context.WithTimeout(ctx, s.timeout)
defer cancel() defer cancel()