From e80cf07c2f8309a18f82cf144861591eb25083e8 Mon Sep 17 00:00:00 2001
From: nourbalaha <nourbalaha0@gmail.com>
Date: Mon, 23 Dec 2024 13:23:20 +0900
Subject: [PATCH] refactor

---
 .github/workflows/build_copier.yml               | 2 +-
 server/internal/infrastructure/gcp/taskrunner.go | 2 +-
 server/internal/usecase/interactor/model.go      | 3 ++-
 server/pkg/task/task.go                          | 4 ++++
 4 files changed, 8 insertions(+), 3 deletions(-)

diff --git a/.github/workflows/build_copier.yml b/.github/workflows/build_copier.yml
index 099dae2d2..f8682c4d7 100644
--- a/.github/workflows/build_copier.yml
+++ b/.github/workflows/build_copier.yml
@@ -29,7 +29,7 @@ jobs:
         env:
           BRANCH: ${{ github.event.workflow_run.head_branch }}
         run: |
-          echo "sha_short=$(git rev-parse --short HEAD))" >> "$GITHUB_OUTPUT"
+          echo "sha_short=$(git rev-parse --short HEAD)" >> "$GITHUB_OUTPUT"
           if [[ "$BRANCH" = "release" ]]; then
             TAG=$(git tag --points-at HEAD)
             if [[ ! -z "$TAG" ]]; then
diff --git a/server/internal/infrastructure/gcp/taskrunner.go b/server/internal/infrastructure/gcp/taskrunner.go
index 9962f97b0..0ae8c6cf8 100644
--- a/server/internal/infrastructure/gcp/taskrunner.go
+++ b/server/internal/infrastructure/gcp/taskrunner.go
@@ -145,7 +145,7 @@ func decompressAsset(ctx context.Context, p task.Payload, conf *TaskConfig) erro
 }
 
 func copy(ctx context.Context, p task.Payload, conf *TaskConfig) error {
-	if p.Copy == nil {
+	if !p.Copy.Validate() {
 		return nil
 	}
 
diff --git a/server/internal/usecase/interactor/model.go b/server/internal/usecase/interactor/model.go
index 5b51fedf8..b781ed301 100644
--- a/server/internal/usecase/interactor/model.go
+++ b/server/internal/usecase/interactor/model.go
@@ -413,6 +413,7 @@ func (i Model) copyMetaSchema(ctx context.Context, oldMetaSchemaId id.SchemaID,
 }
 
 func (i Model) copyItems(ctx context.Context, oldSchemaID, newSchemaID id.SchemaID, newModelID id.ModelID) error {
+	collection := "item"
 	filter, err := json.Marshal(bson.M{"schema": oldSchemaID.String()})
 	if err != nil {
 		return err
@@ -434,7 +435,7 @@ func (i Model) copyItems(ctx context.Context, oldSchemaID, newSchemaID id.Schema
 	if err != nil {
 		return err
 	}
-	return i.triggerCopyEvent(ctx, "item", string(filter), string(changes))
+	return i.triggerCopyEvent(ctx, collection, string(filter), string(changes))
 }
 
 func (i Model) triggerCopyEvent(ctx context.Context, collection, filter, changes string) error {
diff --git a/server/pkg/task/task.go b/server/pkg/task/task.go
index 9d0b2fb9a..3dab9097c 100644
--- a/server/pkg/task/task.go
+++ b/server/pkg/task/task.go
@@ -57,6 +57,10 @@ func (p *CopyPayload) Payload() Payload {
 	}
 }
 
+func (p *CopyPayload) Validate() bool {
+	return p != nil && p.Changes != "" && p.Collection != "" && p.Filter != ""
+}
+
 type Changes map[string]Change
 type Change struct {
 	Type  ChangeType