From 9c79b04d4c778b590aa9a03c0ce31df5a63c54cf Mon Sep 17 00:00:00 2001
From: nquidox <nquidox@gmail.com>
Date: Sat, 21 Feb 2026 16:59:38 +0300
Subject: [PATCH] structs moved

---
 internal/taskAgent/interface.go | 9 ++++++---
 internal/taskAgent/service.go   | 7 ++++---
 2 files changed, 10 insertions(+), 6 deletions(-)

diff --git a/internal/taskAgent/interface.go b/internal/taskAgent/interface.go
index 37160cb..92c6dfe 100644
--- a/internal/taskAgent/interface.go
+++ b/internal/taskAgent/interface.go
@@ -1,8 +1,11 @@
 package taskAgent
 
-import "context"
+import (
+	"context"
+	"task-processor/internal/structs"
+)
 
 type TaskAgent interface {
-	FetchTasks(ctx context.Context) ([]Task, error)
-	SendResults(ctx context.Context, results []Result) error
+	FetchTasks(ctx context.Context) ([]structs.Task, error)
+	SendResults(ctx context.Context, results []structs.Result) error
 }
diff --git a/internal/taskAgent/service.go b/internal/taskAgent/service.go
index bd435ec..fa6ba7f 100644
--- a/internal/taskAgent/service.go
+++ b/internal/taskAgent/service.go
@@ -5,6 +5,7 @@ import (
 	log "github.com/sirupsen/logrus"
 	"google.golang.org/protobuf/types/known/emptypb"
 	"io"
+	"task-processor/internal/structs"
 	tt "task-processor/pkg/taskTransport/v1"
 	"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)
 	defer cancel()
 
@@ -42,7 +43,7 @@ func (s *service) FetchTasks(ctx context.Context) (received []Task, err error) {
 			return nil, err
 		}
 
-		received = append(received, Task{
+		received = append(received, structs.Task{
 			MerchUuid: task.MerchUuid,
 			Origins:   task.Origins,
 		})
@@ -52,7 +53,7 @@ func (s *service) FetchTasks(ctx context.Context) (received []Task, err error) {
 	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)
 	defer cancel()