more logic

internal/tasks/processEvents.go

@@ -21,6 +21,7 @@ func (c *CronTask) RunVmCheck(ctx context.Context, logger *slog.Logger) error {
 		numVcpus   int32
 		numRam     int32
 		datacenter string
+		foundVm    bool
 	)
 
 	logger.Debug("Started Events processing", "time", time.Now())
@@ -60,6 +61,7 @@ func (c *CronTask) RunVmCheck(ctx context.Context, logger *slog.Logger) error {
 				numRam = vmObject.Vm.Config.Hardware.MemoryMB
 				//numVcpus = vmObject.Vm.Config.Hardware.NumCPU * vmObject.Vm.Config.Hardware.NumCoresPerSocket
 				numVcpus = vmObject.Vm.Config.Hardware.NumCPU
+				foundVm = true
 			} else {
 				c.Logger.Error("Empty VM config")
 			}
@@ -70,15 +72,20 @@ func (c *CronTask) RunVmCheck(ctx context.Context, logger *slog.Logger) error {
 			c.Logger.Error("unable to logout of vcenter", "error", err)
 		}
 
-		c.Logger.Debug("Simulate adding to Inventory", "vm_name", evt.VmName.String, "vcpus", numVcpus, "ram", numRam, "dc", datacenter)
+		if foundVm {
+			c.Logger.Debug("Simulate adding to Inventory", "vm_name", evt.VmName.String, "vcpus", numVcpus, "ram", numRam, "dc", datacenter)
 
-		// mark this event as processed
-		err = c.Database.Queries().UpdateEventsProcessed(ctx, evt.Eid)
-		if err != nil {
-			c.Logger.Error("Unable to mark this event as processed", "event_id", evt.Eid, "error", err)
+			// mark this event as processed
+			err = c.Database.Queries().UpdateEventsProcessed(ctx, evt.Eid)
+			if err != nil {
+				c.Logger.Error("Unable to mark this event as processed", "event_id", evt.Eid, "error", err)
+			} else {
+				c.Logger.Debug("Marked event as processed", "event_id", evt.Eid)
+			}
 		} else {
-			c.Logger.Debug("Marked event as processed", "event_id", evt.Eid)
+			c.Logger.Debug("Not simulate adding to Inventory due to missing vcenter config property", "vm_name", evt.VmName.String)
 		}
+
 	}
 
 	//fmt.Printf("processing at %s", time.Now())