fix: Bump stackable-operator for delayed controller functionality (#375)

* fix: Delay controller startup to avoid 404 in initial list

* chore: Fix clippy lints

* chore: Add changelog entry

* refactor: Change controller code to be more in line with other core operators

Author: Techassi

CHANGELOG.md

@@ -13,7 +13,7 @@ All notable changes to this project will be documented in this file.
 
 ### Changed
 
-- Bump stackable-operator to 0.106.2 and strum to 0.28 ([#373]).
+- Bump stackable-operator to 0.108.0 and strum to 0.28 ([#373], [#375]).
 - The operator now deploys the selected ListenerClass preset instead of relying on Helm ([#369]).
   - This mechanism is currently tied to CRD maintenance.
 - Gracefully shutdown all concurrent tasks by forwarding the SIGTERM signal ([#366]).
@@ -23,6 +23,10 @@ All notable changes to this project will be documented in this file.
   This behaviour is in line with the default behaviour of Helm and OLM.
 - Bump testing-tools to `0.3.0-stackable0.0.0-dev` ([#363]).
 
+### Fixed
+
+- Fix "404 page not found" error for the initial object list ([#375]).
+
 [#360]: https://github.com/stackabletech/listener-operator/pull/360
 [#363]: https://github.com/stackabletech/listener-operator/pull/363
 [#364]: https://github.com/stackabletech/listener-operator/pull/364
@@ -31,6 +35,7 @@ All notable changes to this project will be documented in this file.
 [#368]: https://github.com/stackabletech/listener-operator/pull/368
 [#369]: https://github.com/stackabletech/listener-operator/pull/369
 [#373]: https://github.com/stackabletech/listener-operator/pull/373
+[#375]: https://github.com/stackabletech/listener-operator/pull/375
 
 ## [25.11.0] - 2025-11-07
 

Cargo.lock

@@ -10,9 +10,8 @@ edition = "2021"
 repository = "https://github.com/stackabletech/listener-operator"
 
 [workspace.dependencies]
-stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", tag = "stackable-operator-0.106.2", features = [
-  "telemetry",
-  "versioned",
+stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", tag = "stackable-operator-0.108.0", features = [
+  "crds",
   "webhook",
 ] }
 

Cargo.nix

@@ -158,4 +158,7 @@ rules:
     verbs:
       - create
       - patch
+      # Required for startup condition
+      - list
+      - watch
 {{ end }}

Cargo.toml

@@ -62,8 +62,7 @@ fn deployer_env_var(deployment: &Deployment) -> Option<&Vec<EnvVar>> {
         .as_ref()?
         .containers
         .iter()
-        .filter(|c| c.name == "listener-operator-deployer")
-        .next_back()?
+        .rfind(|c| c.name == "listener-operator-deployer")?
         .env
         .as_ref()
 }

crate-hashes.json

@@ -44,8 +44,7 @@ fn deployment_resources(deployment: &Deployment) -> Option<&ResourceRequirements
         .as_ref()?
         .containers
         .iter()
-        .filter(|c| c.name == "listener-operator-deployer")
-        .next_back()?
+        .rfind(|c| c.name == "listener-operator-deployer")?
         .resources
         .as_ref()
 }

deploy/helm/listener-operator/templates/roles.yaml

@@ -124,17 +124,11 @@ where
             },
         )
         .graceful_shutdown_on(shutdown_signal)
-        .run(
-            reconcile,
-            error_policy,
-            Arc::new(Ctx {
-                client: client.clone(),
-            }),
-        )
+        .run(reconcile, error_policy, Arc::new(Ctx { client }))
         // We can let the reporting happen in the background
         .for_each_concurrent(
             16, // concurrency limit
-            |result| {
+            move |result| {
                 // The event_recorder needs to be shared across all invocations, so that
                 // events are correctly aggregated
                 let event_recorder = event_recorder.clone();

rust/olm-deployer/src/env/mod.rs

@@ -22,10 +22,10 @@ use stackable_operator::{
         PodListenersVersion, v1alpha1,
     },
     eos::EndOfSupportChecker,
-    kube::ResourceExt,
+    kube::{CustomResourceExt, ResourceExt},
     shared::yaml::SerializeOptions,
     telemetry::Tracing,
-    utils::signal::SignalWatcher,
+    utils::signal::{self, SignalWatcher},
 };
 use tokio::sync::oneshot;
 use tokio_stream::wrappers::UnixListenerStream;
@@ -211,14 +211,21 @@ async fn main() -> anyhow::Result<()> {
                         .map_err(|err| anyhow!(err).context("failed to run csi server"));
 
                     let controller =
-                        listener_controller::run(client, sigterm_watcher.handle()).map(anyhow::Ok);
+                        listener_controller::run(client.clone(), sigterm_watcher.handle())
+                            .map(anyhow::Ok);
+
+                    let delayed_controller = async {
+                        signal::crd_established(&client, v1alpha1::Listener::crd_name(), None)
+                            .await?;
+                        controller.await
+                    };
 
                     futures::try_join!(
+                        delayed_controller,
                         listener_classes,
                         webhook_server,
                         eos_checker,
                         csi_server,
-                        controller,
                     )?;
                 }
                 RunMode::Node => {