From acca2a858bf8b69a6dbfdea42eaafd9ecc2967c9 Mon Sep 17 00:00:00 2001
From: Pavel <pashamullin202@gmail.com>
Date: Thu, 18 Apr 2024 16:20:05 +0300
Subject: [PATCH] add another check methods to amo repo

---
 repository/amo/amo.go | 26 ++++++++++++++++++++++++++
 1 file changed, 26 insertions(+)

diff --git a/repository/amo/amo.go b/repository/amo/amo.go
index 2a95bf4..cc55cd2 100644
--- a/repository/amo/amo.go
+++ b/repository/amo/amo.go
@@ -300,6 +300,19 @@ func (r *AmoRepository) GetPipelinesWithPagination(ctx context.Context, req *mod
 }
 
 func (r *AmoRepository) CheckPipelines(ctx context.Context, pipelines []model.Pipeline) error {
+	var dollar1 []json.RawMessage
+	for _, pipeline := range pipelines {
+		jsonTag, err := json.Marshal(pipeline)
+		if err != nil {
+			return err
+		}
+		dollar1 = append(dollar1, jsonTag)
+	}
+	_, err := r.queries.CheckPipelines(ctx, dollar1)
+	if err != nil {
+		return err
+	}
+
 	return nil
 }
 
@@ -359,7 +372,20 @@ func (r *AmoRepository) UpdateListSteps(ctx context.Context) error {
 }
 
 func (r *AmoRepository) CheckSteps(ctx context.Context, steps []model.Step) error {
+	var dollar1 []json.RawMessage
+	for _, step := range steps {
+		jsonTag, err := json.Marshal(step)
+		if err != nil {
+			return err
+		}
+		dollar1 = append(dollar1, jsonTag)
+	}
+	_, err := r.queries.CheckSteps(ctx, dollar1)
+	if err != nil {
+		return err
+	}
 
+	return nil
 }
 
 func (r *AmoRepository) GetStepByID(ctx context.Context, accountID string, amoid int) (*model.Step, error) {