fix: update watering status of tc while creating it

internal/entities/events.go

@@ -11,6 +11,7 @@ const (
 	EventTypeCreateTree         EventType = "create tree"
 	EventTypeDeleteTree         EventType = "delete tree"
 	EventTypeUpdateTreeCluster  EventType = "update tree cluster"
+	EventTypeCreateTreeCluster  EventType = "create tree cluster"
 	EventTypeNewSensorData      EventType = "receive sensor data"
 	EventTypeUpdateWateringPlan EventType = "update watering plan"
 )
@@ -71,6 +72,11 @@ type EventUpdateTreeCluster struct {
 	New  *TreeCluster
 }
 
+type EventCreateTreeCluster struct {
+	BasicEvent
+	New *TreeCluster
+}
+
 func NewEventUpdateTreeCluster(prev, newTc *TreeCluster) EventUpdateTreeCluster {
 	return EventUpdateTreeCluster{
 		BasicEvent: BasicEvent{eventType: EventTypeUpdateTreeCluster},
@@ -79,6 +85,13 @@ func NewEventUpdateTreeCluster(prev, newTc *TreeCluster) EventUpdateTreeCluster
 	}
 }
 
+func NewEventCreateTreeCluster(newTc *TreeCluster) EventCreateTreeCluster {
+	return EventCreateTreeCluster{
+		BasicEvent: BasicEvent{eventType: EventTypeCreateTreeCluster},
+		New:        newTc,
+	}
+}
+
 type EventNewSensorData struct {
 	BasicEvent
 	New *SensorData

internal/service/domain/treecluster/treecluster.go

@@ -69,6 +69,7 @@ func (s *TreeClusterService) publishUpdateEvent(ctx context.Context, prevTc *dom
 	}
 
 	event := domain.NewEventUpdateTreeCluster(prevTc, updatedTc)
+
 	err = s.eventManager.Publish(ctx, event)
 	if err != nil {
 		log.Error("error while sending event after updating tree cluster", "err", err)
@@ -77,6 +78,16 @@ func (s *TreeClusterService) publishUpdateEvent(ctx context.Context, prevTc *dom
 	return nil
 }
 
+func (s *TreeClusterService) publishCreateEvent(ctx context.Context, tc *domain.TreeCluster) {
+	log := logger.GetLogger(ctx)
+	log.Debug("publish new event", "event", domain.EventTypeCreateTreeCluster, "service", "TreeClusterService")
+
+	event := domain.NewEventCreateTreeCluster(tc)
+	if err := s.eventManager.Publish(ctx, event); err != nil {
+		log.Error("error while sending event after creating tree cluster", "err", err)
+	}
+}
+
 func (s *TreeClusterService) Create(ctx context.Context, createTc *domain.TreeClusterCreate) (*domain.TreeCluster, error) {
 	log := logger.GetLogger(ctx)
 	if err := s.validator.Struct(createTc); err != nil {
@@ -126,6 +137,8 @@ func (s *TreeClusterService) Create(ctx context.Context, createTc *domain.TreeCl
 	}
 
 	log.Info("tree cluster created successfully", "cluster_id", c.ID)
+	s.publishCreateEvent(ctx, c)
+
 	return c, nil
 }
 

main.go

@@ -166,6 +166,7 @@ func initializeEventManager() *worker.EventManager {
 	return worker.NewEventManager(
 		entities.EventTypeUpdateTree,
 		entities.EventTypeUpdateTreeCluster,
+		entities.EventTypeCreateTreeCluster,
 		entities.EventTypeCreateTree,
 		entities.EventTypeDeleteTree,
 		entities.EventTypeNewSensorData,