Merge branch 'dev/ragil-before-sso' of https://gitlab.com/mbugroup/lti-api into dev/teguh

internal/database/migrations/20251018072532_project_flock_kandangs.down.sql

@@ -0,0 +1 @@
+DROP TABLE IF EXISTS project_flock_kandangs;

internal/database/migrations/20251018072532_project_flock_kandangs.up.sql

@@ -0,0 +1,17 @@
+CREATE TABLE project_flock_kandangs (
+    id BIGSERIAL PRIMARY KEY,
+    project_flock_id BIGINT NOT NULL REFERENCES project_flocks (id) ON DELETE CASCADE ON UPDATE CASCADE,
+    kandang_id BIGINT NOT NULL REFERENCES kandangs (id) ON DELETE CASCADE ON UPDATE CASCADE,
+    created_by BIGINT REFERENCES users (id) ON DELETE SET NULL ON UPDATE CASCADE,
+    assigned_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
+    detached_at TIMESTAMPTZ,
+    created_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
+    updated_at TIMESTAMPTZ NOT NULL DEFAULT NOW()
+);
+
+CREATE INDEX idx_project_flock_kandangs_project ON project_flock_kandangs (project_flock_id);
+CREATE INDEX idx_project_flock_kandangs_kandang ON project_flock_kandangs (kandang_id);
+
+CREATE UNIQUE INDEX idx_project_flock_kandangs_active ON project_flock_kandangs (project_flock_id, kandang_id)
+WHERE
+    detached_at IS NULL;

internal/database/seed/seeder.go

@@ -378,6 +378,9 @@ func seedKandangs(tx *gorm.DB, createdBy uint, locations map[string]uint, users
 			if err := tx.Create(&kandang).Error; err != nil {
 				return nil, err
 			}
+			if err := syncPivotRelation(tx, projectFlockID, kandang.Id, createdBy); err != nil {
+				return nil, err
+			}
 		} else if err != nil {
 			return nil, err
 		} else {
@@ -394,6 +397,9 @@ func seedKandangs(tx *gorm.DB, createdBy uint, locations map[string]uint, users
 			if err := tx.Model(&entity.Kandang{}).Where("id = ?", kandang.Id).Updates(updates).Error; err != nil {
 				return nil, err
 			}
+			if err := syncPivotRelation(tx, projectFlockID, kandang.Id, createdBy); err != nil {
+				return nil, err
+			}
 		}
 		result[seed.Name] = kandang.Id
 	}
@@ -401,6 +407,40 @@ func seedKandangs(tx *gorm.DB, createdBy uint, locations map[string]uint, users
 	return result, nil
 }
 
+func syncPivotRelation(tx *gorm.DB, projectFlockID *uint, kandangID uint, createdBy uint) error {
+	if err := detachActivePivot(tx, kandangID); err != nil {
+		return err
+	}
+	if projectFlockID == nil {
+		return nil
+	}
+	return ensureActivePivot(tx, *projectFlockID, kandangID, createdBy)
+}
+
+func detachActivePivot(tx *gorm.DB, kandangID uint) error {
+	return tx.Model(&entity.ProjectFlockKandang{}).
+		Where("kandang_id = ? AND detached_at IS NULL", kandangID).
+		Updates(map[string]any{"detached_at": time.Now()}).Error
+}
+
+func ensureActivePivot(tx *gorm.DB, projectFlockID, kandangID, createdBy uint) error {
+	var pivot entity.ProjectFlockKandang
+	err := tx.Where("project_flock_id = ? AND kandang_id = ? AND detached_at IS NULL", projectFlockID, kandangID).
+		First(&pivot).Error
+	if err == nil {
+		return nil
+	}
+	if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
+		return err
+	}
+	newRecord := entity.ProjectFlockKandang{
+		ProjectFlockId: projectFlockID,
+		KandangId:      kandangID,
+		CreatedBy:      createdBy,
+	}
+	return tx.Create(&newRecord).Error
+}
+
 func seedWarehouses(tx *gorm.DB, createdBy uint, areas map[string]uint, locations map[string]uint, kandangs map[string]uint) error {
 	seeds := []struct {
 		Name     string