add another check methods to amo repo

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) {