Makes the operator's own namespace available to its actions

Author: phantomjinx

Diff for: install/operator/pkg/controller/syndesis/syndesis_controller.go

@@ -120,7 +120,7 @@ func (r *ReconcileSyndesis) Reconcile(ctx context.Context, request reconcile.Req
 
 		if a.CanExecute(syndesis) {
 			log.V(synpkg.DEBUG_LOGGING_LVL).Info("Running action", "action", reflect.TypeOf(a))
-			if err := a.Execute(ctx, syndesis); err != nil {
+			if err := a.Execute(ctx, syndesis, request.Namespace); err != nil {
 				log.Error(err, "Error reconciling", "action", reflect.TypeOf(a), "phase", syndesis.Status.Phase)
 				return reconcile.Result{
 					Requeue:      true,

Diff for: install/operator/pkg/syndesis/action/action.go

@@ -36,7 +36,7 @@ var actionLog = logf.Log.WithName("action")
 
 type SyndesisOperatorAction interface {
 	CanExecute(syndesis *synapi.Syndesis) bool
-	Execute(ctx context.Context, syndesis *synapi.Syndesis) error
+	Execute(ctx context.Context, syndesis *synapi.Syndesis, operatorNamespace string) error
 }
 
 // NewOperatorActions gives the default set of actions operator will perform

Diff for: install/operator/pkg/syndesis/action/backup.go

@@ -49,7 +49,7 @@ func (a *backupAction) CanExecute(syndesis *synapi.Syndesis) bool {
 }
 
 // Schedule a cronjob for systematic backups
-func (a *backupAction) Execute(ctx context.Context, syndesis *synapi.Syndesis) error {
+func (a *backupAction) Execute(ctx context.Context, syndesis *synapi.Syndesis, operatorNamespace string) error {
 	entries := c.Entries()
 
 	if s := syndesis.Spec.Backup.Schedule; s != "" {
@@ -74,7 +74,7 @@ func (a *backupAction) Execute(ctx context.Context, syndesis *synapi.Syndesis) e
 			client, _ := a.clientTools.RuntimeClient()
 			return client.Status().Update(ctx, syndesis)
 		} else {
-			return fmt.Errorf("unsopported number of entries for cron instance, cron %v", c)
+			return fmt.Errorf("unsupported number of entries for cron instance, cron %v", c)
 		}
 	} else {
 		if len(entries) == 1 {
@@ -84,7 +84,7 @@ func (a *backupAction) Execute(ctx context.Context, syndesis *synapi.Syndesis) e
 			c.Remove(e.ID)
 			c.Stop()
 		} else if len(entries) > 1 {
-			return fmt.Errorf("unsopported number of entries for cron instance, cron %v", c)
+			return fmt.Errorf("unsupported number of entries for cron instance, cron %v", c)
 		}
 	}
 

Diff for: install/operator/pkg/syndesis/action/checkupdates.go

@@ -30,7 +30,7 @@ func (a checkUpdatesAction) CanExecute(syndesis *synapi.Syndesis) bool {
 		synapi.SyndesisPhaseStartupFailed)
 }
 
-func (a checkUpdatesAction) Execute(ctx context.Context, syndesis *synapi.Syndesis) error {
+func (a checkUpdatesAction) Execute(ctx context.Context, syndesis *synapi.Syndesis, operatorNamespace string) error {
 	if a.operatorVersion == "" {
 		a.operatorVersion = pkg.DefaultOperatorTag
 	}

Diff for: install/operator/pkg/syndesis/action/initialize.go

@@ -28,7 +28,7 @@ func (a *initializeAction) CanExecute(syndesis *synapi.Syndesis) bool {
 		synapi.SyndesisPhaseNotInstalled)
 }
 
-func (a *initializeAction) Execute(ctx context.Context, syndesis *synapi.Syndesis) error {
+func (a *initializeAction) Execute(ctx context.Context, syndesis *synapi.Syndesis, operatorNamespace string) error {
 	list := synapi.SyndesisList{}
 	rtClient, _ := a.clientTools.RuntimeClient()
 	err := rtClient.List(ctx, &list, &client.ListOptions{Namespace: syndesis.Namespace})

Diff for: install/operator/pkg/syndesis/action/install.go

@@ -96,7 +96,7 @@ func (a *installAction) CanExecute(syndesis *synapi.Syndesis) bool {
 
 var kindsReportedNotAvailable = map[schema.GroupVersionKind]time.Time{}
 
-func (a *installAction) Execute(ctx context.Context, syndesis *synapi.Syndesis) error {
+func (a *installAction) Execute(ctx context.Context, syndesis *synapi.Syndesis, operatorNamespace string) error {
 	if syndesisPhaseIs(syndesis, synapi.SyndesisPhaseInstalling) {
 		a.log.Info("installing Syndesis resource", "name", syndesis.Name)
 	} else if syndesisPhaseIs(syndesis, synapi.SyndesisPhasePostUpgradeRun) {

Diff for: install/operator/pkg/syndesis/action/pod_scheduling.go

@@ -43,7 +43,7 @@ func (a *podSchedulingAction) CanExecute(syndesis *synapi.Syndesis) bool {
 	return canExecute
 }
 
-func (a *podSchedulingAction) Execute(ctx context.Context, syndesis *synapi.Syndesis) error {
+func (a *podSchedulingAction) Execute(ctx context.Context, syndesis *synapi.Syndesis, operatorNamespace string) error {
 	if a.updateIntegrationScheduling {
 		a.executeIntegrationScheduling(ctx, syndesis)
 	}

Diff for: install/operator/pkg/syndesis/action/startup.go

@@ -32,7 +32,7 @@ func (a *startupAction) CanExecute(syndesis *synapi.Syndesis) bool {
 		synapi.SyndesisPhaseStartupFailed)
 }
 
-func (a *startupAction) Execute(ctx context.Context, syndesis *synapi.Syndesis) error {
+func (a *startupAction) Execute(ctx context.Context, syndesis *synapi.Syndesis, operatorNamespace string) error {
 
 	list := v1.DeploymentConfigList{
 		TypeMeta: metav1.TypeMeta{

Diff for: install/operator/pkg/syndesis/action/upgrade.go

@@ -41,7 +41,7 @@ func (a *upgradeAction) CanExecute(syndesis *synapi.Syndesis) bool {
 	)
 }
 
-func (a *upgradeAction) Execute(ctx context.Context, syndesis *synapi.Syndesis) error {
+func (a *upgradeAction) Execute(ctx context.Context, syndesis *synapi.Syndesis, operatorNamespace string) error {
 	targetVersion := pkg.DefaultOperatorTag
 
 	if syndesis.Status.Phase == synapi.SyndesisPhaseUpgrading {

Diff for: install/operator/pkg/syndesis/action/upgradebackoff.go

@@ -33,7 +33,7 @@ func (a *upgradeBackoffAction) CanExecute(syndesis *synapi.Syndesis) bool {
 	return syndesisPhaseIs(syndesis, synapi.SyndesisPhaseUpgradeFailureBackoff)
 }
 
-func (a *upgradeBackoffAction) Execute(ctx context.Context, syndesis *synapi.Syndesis) error {
+func (a *upgradeBackoffAction) Execute(ctx context.Context, syndesis *synapi.Syndesis, operatorNamespace string) error {
 	rtClient, _ := a.clientTools.RuntimeClient()
 
 	// Check number of attempts to fail fast