refactor: moved resync to controller

core/application/reconcile.go

@@ -35,28 +35,6 @@ func (a *app) ReconcileMicroVM(ctx context.Context, vmid models.VMID) error {
 	return a.reconcile(ctx, spec, logger)
 }
 
-func (a *app) ResyncMicroVMs(ctx context.Context, namespace string) error {
-	logger := log.GetLogger(ctx).WithFields(logrus.Fields{
-		"action":    "resync",
-		"namespace": "ns",
-	})
-	logger.Info("Resyncing specs")
-	logger.Debug("Getting all specs")
-
-	specs, err := a.ports.Repo.GetAll(ctx, models.ListMicroVMQuery{"namespace": namespace})
-	if err != nil {
-		return fmt.Errorf("getting all microvm specs for resync: %w", err)
-	}
-
-	for _, spec := range specs {
-		if err := a.reconcile(ctx, spec, logger); err != nil {
-			return fmt.Errorf("resync reconcile for spec %s: %w", spec.ID, err)
-		}
-	}
-
-	return nil
-}
-
 func (a *app) plan(spec *models.MicroVM, logger *logrus.Entry) planner.Plan {
 	l := logger.WithField("stage", "plan")
 	l.Info("Generate plan")

core/ports/usecases.go

@@ -26,7 +26,4 @@ type MicroVMQueryUseCases interface {
 type ReconcileMicroVMsUseCase interface {
 	// ReconcileMicroVM is a use case for reconciling a specific microvm.
 	ReconcileMicroVM(ctx context.Context, vmid models.VMID) error
-	// ResyncMicroVMs is used to resync the microvms. If a namespace is supplied then it will
-	// resync only the microvms in that namespaces.
-	ResyncMicroVMs(ctx context.Context, namespace string) error
 }

infrastructure/controllers/microvm_controller.go

@@ -16,17 +16,19 @@ import (
 	"github.com/weaveworks-liquidmetal/flintlock/pkg/queue"
 )
 
-func New(eventSvc ports.EventService, reconcileUC ports.ReconcileMicroVMsUseCase) *MicroVMController {
+func New(eventSvc ports.EventService, reconcileUC ports.ReconcileMicroVMsUseCase, queryUC ports.MicroVMQueryUseCases) *MicroVMController {
 	return &MicroVMController{
 		eventSvc:    eventSvc,
 		reconcileUC: reconcileUC,
+		queryUC:     queryUC,
 		queue:       queue.NewSimpleSyncQueue(),
 	}
 }
 
 type MicroVMController struct {
 	eventSvc    ports.EventService
 	reconcileUC ports.ReconcileMicroVMsUseCase
+	queryUC     ports.MicroVMQueryUseCases
 
 	queue queue.Queue
 }
@@ -186,11 +188,17 @@ func (r *MicroVMController) handleEvent(envelope *ports.EventEnvelope, logger *l
 func (r *MicroVMController) resyncSpecs(ctx context.Context, logger *logrus.Entry) error {
 	logger.Info("resyncing microvm specs")
 
-	err := r.reconcileUC.ResyncMicroVMs(ctx, "")
+	specs, err := r.queryUC.GetAllMicroVM(ctx, models.ListMicroVMQuery{
+		"Namespace": "",
+	})
+
 	if err != nil {
-		logger.Errorf("failed to resync microvms: %s", err)
+		return fmt.Errorf("getting all microvm specs for resync: %w", err)
+	}
 
-		return fmt.Errorf("resyncing microvms: %w", err)
+	for _, spec := range specs {
+		logger.Debugf("enqueing vmid %s for resync", spec.ID)
+		r.queue.Enqueue(spec.ID.String())
 	}
 
 	return nil

infrastructure/controllers/microvm_controller_test.go

@@ -120,13 +120,14 @@ func TestMicroVMController(t *testing.T) {
 
 			em := mock.NewMockEventService(mockCtrl)
 			uc := mock.NewMockReconcileMicroVMsUseCase(mockCtrl)
+			quc := mock.NewMockMicroVMQueryUseCases(mockCtrl)
 
 			evtCh := make(chan *ports.EventEnvelope)
 			evtErrCh := make(chan error, 1)
 
 			tc.expect(em.EXPECT(), uc.EXPECT(), evtCh, evtErrCh)
 
-			controller := controllers.New(em, uc)
+			controller := controllers.New(em, uc, quc)
 
 			ctrlWG := sync.WaitGroup{}
 			ctrlWG.Add(1)

internal/inject/wire.go

@@ -47,7 +47,7 @@ func InitializeApp(cfg *config.Config, ports *ports.Collection) application.App
 }
 
 func InializeController(app application.App, ports *ports.Collection) *controllers.MicroVMController {
-	wire.Build(controllers.New, eventSvcFromScope, reconcileUCFromApp)
+	wire.Build(controllers.New, eventSvcFromScope, reconcileUCFromApp, queryUCFromApp)
 
 	return nil
 }