deafult to anonymous auth when no credentials

Author: lkingland

e2e/e2e_test.go

@@ -128,11 +128,11 @@ var (
 	// MatrixRuntimes for which runtime-specific tests should be run.  Defaults
 	// to all core language runtimes.  Can be set with FUNC_E2E_MATRIX_RUNTIMES
 	// MatrixRuntimes = []string{"go", "python", "node", "typescript", "rust", "quarkus", "springboot"}
-	MatrixRuntimes = []string{"go", "python", "node", "typescript", "rust", "quarkus", "springboot"}
+	MatrixRuntimes = []string{"quarkus", "springboot"}
 
 	// MatrixTemplates specifies the templates to check during matrix tests.
 	// MatrixTemplates = []string{"http", "cloudevents"}
-	MatrixTemplates = []string{"cloudevents"}
+	MatrixTemplates = []string{"http", "cloudevents"}
 
 	// Plugin indicates func is being run as a plugin within Bin, and
 	// the value of this argument is the subcommand.  For example, when

generate/zz_filesystem_generated.go

@@ -19,13 +19,13 @@ init() {
 }
 
 find_executables() {
-  KUBECTL=$(find_executable "kubectl")
-  KIND=$(find_executable "kind")
-  DAPR=$(find_executable "dapr")
-  HELM=$(find_executable "helm")
-  STERN=$(find_executable "stern")
-  KN=$(find_executable "kn")
-  JQ=$(find_executable "jq")
+  KUBECTL=$(find_executable "kubectl" || true)
+  KIND=$(find_executable "kind" || true)
+  DAPR=$(find_executable "dapr" || true)
+  HELM=$(find_executable "helm" || true)
+  STERN=$(find_executable "stern" || true)
+  KN=$(find_executable "kn" || true)
+  JQ=$(find_executable "jq" || true)
 }
 
 populate_environment() {

hack/common.sh

@@ -25,10 +25,14 @@ source "$(dirname "$(realpath "$0")")/common.sh"
 output_file="${1:-cluster_log.txt}"
 
 echo "::group::cluster events" >> "$output_file"
-kubectl get events -A >> "$output_file" 2>&1
+"$KUBECTL" get events -A >> "$output_file" 2>&1
 echo "::endgroup::" >> "$output_file"
 
 echo "::group::cluster containers logs" >> "$output_file"
-stern '.*' --all-namespaces --no-follow >> "$output_file" 2>&1
+if [[ -n "${STERN:-}" && -x "${STERN}" ]]; then
+  "$STERN" '.*' --all-namespaces --no-follow >> "$output_file" 2>&1
+else
+  echo "stern not available, skipping container logs" >> "$output_file" 2>&1
+fi
 echo "::endgroup::" >> "$output_file"
 

hack/dump-logs.sh

@@ -1,47 +1,30 @@
 #!/usr/bin/env bash
 
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
+# This script runs unit, integration and e2e tests with all optional tests
+# enabled:
+# - Matrix (for each runtime/language/builder c. product)
+# - Podman
+# - Gitlab
+# - Pipelines
+# - etc.
 #
-#     https://www.apache.org/licenses/LICENSE-2.0
+# (See the environment variables which allow selective overriding.)
 #
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-#
-# Run full test suite with all features enabled
-# This script sets up the environment for comprehensive testing including
-# Podman, Tekton, GitLab, and matrix tests
-#
-# Cluster Setup:
-#   This script defaults to running all of the optional tests.  This requires
-#   one install the toolchains for all core language runtimes, Podman, 
-#   and configure the cluster with:
-#     hack/cluster.sh
-#     hack/registry.sh
-#     hack/git-server.sh
-#     hack/gitlab.sh
+# This script presumes a local testing environment set up using the
+# helper scripts in ./hack and performs some precondition checks to ensure
+# resources are available for the features enabled (nonexhaustive).
+#     hack/binaries.sh   - Installs necessary binaries in ./hack/bin
+#     hack/cluster.sh    - Start test cluster with Knative Serving/Eventing
+#     hack/registry.sh   - Starts and configures a local container registry
+#     hack/git-server.sh - Starts a git server in-cluster
+#     hack/gitlab.sh     - Installs GitLab in-cluster
 
 set -o errexit
 set -o nounset
 set -o pipefail
 
-# Determine script directory
-SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
-PROJECT_ROOT="$(cd "${SCRIPT_DIR}/.." && pwd)"
-
-# Generate a timestamp for use setting things which require uniqueness
-TIMESTAMP=$(date +%Y%m%d%H%M%S 2>/dev/null || date +%s 2>/dev/null || echo "$(date)")
-
-# Set up PATH and KUBECONFIG
-export PATH="${PROJECT_ROOT}/hack/bin:${PATH}"
-export KUBECONFIG="${KUBECONFIG:-${PROJECT_ROOT}/hack/bin/kubeconfig.yaml}"
-
-# Set up test environment variables
+# Enable Optional Tests
+# ---------------------
 # The defaults in the e2e test implementation are a bit more conservative.
 # Here we toggle on All The Things.  Note that we still allow any settings
 # made explicitly in the current environment to take precidence; just setting
@@ -55,13 +38,34 @@ export GITLAB_TESTS_ENABLED="${GITLAB_TESTS_ENABLED:-1}"
 export GITLAB_HOSTNAME="${GITLAB_HOSTNAME:-gitlab.localtest.me}"
 export PAC_CONTROLLER_HOSTNAME="${PAC_CONTROLLER_HOSTNAME:-pac-ctr.localtest.me}"
 
+
+# Environment Setup
+# -------------------
+
+# Determine script directory
+SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
+PROJECT_ROOT="$(cd "${SCRIPT_DIR}/.." && pwd)"
+
+# Set up PATH and KUBECONFIG
+export PATH="${PROJECT_ROOT}/hack/bin:${PATH}"
+export KUBECONFIG="${KUBECONFIG:-${PROJECT_ROOT}/hack/bin/kubeconfig.yaml}"
+
 # GitLab test configuration
 # This is the default set by ./hack/gitlab.sh, and is overridden in CI, and
 # a warning is issued that users should not only use ./hack/gitlab.sh for
 # configuring test cluster available locally, such as that created by
 # hack/cluster.sh
 export GITLAB_ROOT_PASSWORD="${GITLAB_ROOT_PASSWORD:-test-password-123}"
 
+# Generate a timestamp for use setting things which require uniqueness
+TIMESTAMP=$(date +%Y%m%d%H%M%S 2>/dev/null || date +%s 2>/dev/null || echo "$(date)")
+
+# Initialize coverage file
+echo "mode: atomic" > coverage.txt
+
+# Precondition Checks
+# -------------------
+
 # Check if binaries are installed
 if [ ! -d "${PROJECT_ROOT}/hack/bin" ]; then
     echo "ERROR: hack/bin directory not found!"
@@ -121,6 +125,9 @@ fi
 echo "✓ Prerequisites check passed"
 echo ""
 
+# Podman Setup
+# -------------
+
 # Check Podman service if Podman tests are enabled
 if [ "${FUNC_E2E_PODMAN}" = "true" ]; then
     # Check if Podman service is running
@@ -161,31 +168,36 @@ if [ "${FUNC_E2E_PODMAN}" = "true" ]; then
             export FUNC_E2E_PODMAN_HOST="unix://${PODMAN_SOCKET}"
         fi
     fi
-    echo "Podman socket: ${FUNC_E2E_PODMAN_HOST}"
+    echo "✓ Podman socket: ${FUNC_E2E_PODMAN_HOST}"
 fi
 
-# Initialize coverage file
-echo "mode: atomic" > coverage.txt
+# Unit and Integration Tests
+# --------------------------
 
-# Run unit and integration tests together
-# echo ""
-# echo "Running unit and integration tests..."
-# go test -tags integration -timeout 60m -coverprofile=coverage-integration.txt ./... -v
-# tail -n +2 coverage-integration.txt >> coverage.txt
-# rm -f coverage-integration.text -run TestMetadata_Labels_Remove
+Run unit and integration tests together
+echo ""
+echo "Running unit and integration tests..."
+go test -tags integration -timeout 60m -coverprofile=coverage-integration.txt ./... -v
+tail -n +2 coverage-integration.txt >> coverage.txt
+rm -f coverage-integration.text -run TestMetadata_Labels_Remove
+
+echo "✓ Unit and Integration tests completed successfully"
+
+# E2E Tests
+# --------------------------
 
 # Run E2E tests
-echo ""
-echo "Running E2E tests..."
-cd "${PROJECT_ROOT}/e2e"
-go test -tags e2e -timeout 120m -coverprofile=coverage-e2e.txt -coverpkg=../... -v -run TestMatrix_Deploy
+# echo ""
+# echo "Running E2E tests..."
+# cd "${PROJECT_ROOT}/e2e"
+# # go test -tags e2e -timeout 120m -coverprofile=coverage-e2e.txt -coverpkg=../... -v -run TestMatrix_Run
 # go test -tags e2e -timeout 120m -coverprofile=coverage-e2e.txt -coverpkg=../... -v
-tail -n +2 coverage-e2e.txt >> ../coverage.txt
-rm -f coverage-e2e.txt
+# tail -n +2 coverage-e2e.txt >> ../coverage.txt
+# rm -f coverage-e2e.txt
 
 cd "${PROJECT_ROOT}"
 echo ""
-echo "Coverage report created: coverage.txt"
+echo "✓ Coverage report created: coverage.txt"
 
 echo ""
-echo "All tests completed successfully!"
+echo "✓ All tests completed successfully"

hack/test-full.sh

@@ -172,9 +172,6 @@ func (p *Pusher) writeIndex(ctx context.Context, ref name.Reference, ii v1.Image
 		if err != nil {
 			return err
 		}
-		if a == nil {
-			return errors.New("no authentication option provided")
-		}
 		oo = append(oo, a)
 	}
 
@@ -210,5 +207,6 @@ func (p *Pusher) authOption(ctx context.Context, creds Credentials) (remote.Opti
 		return remote.WithAuth(&authn.Basic{Username: creds.Username, Password: creds.Password}), nil
 	}
 
-	return nil, nil
+	// Return anonymous auth when no credentials are provided (e.g., for localhost registries)
+	return remote.WithAuth(authn.Anonymous), nil
 }

pkg/oci/pusher.go

@@ -11,17 +11,35 @@ pub async fn handle(
 ) -> Result<Event, actix_web::Error> {
     info!("event: {}", event);
 
-    let input = match event.data() {
-        Some(Data::Binary(v)) => from_slice(v)?,
-        Some(Data::String(v)) => from_str(v)?,
-        Some(Data::Json(v)) => v.to_owned(),
-        None => json!({ "name": config.name }),
+    // Extract message from event data, or use default
+    let message = match event.data() {
+        Some(Data::Binary(v)) => {
+            let input: serde_json::Value = from_slice(v)?;
+            input.get("message")
+                .and_then(|v| v.as_str())
+                .unwrap_or(&config.name)
+                .to_string()
+        },
+        Some(Data::String(v)) => {
+            let input: serde_json::Value = from_str(v)?;
+            input.get("message")
+                .and_then(|v| v.as_str())
+                .unwrap_or(&config.name)
+                .to_string()
+        },
+        Some(Data::Json(v)) => {
+            v.get("message")
+                .and_then(|v| v.as_str())
+                .unwrap_or(&config.name)
+                .to_string()
+        },
+        None => config.name.clone(),
     };
 
     EventBuilderV10::from(event)
         .source("func://handler")
-        .ty("func.example")
-        .data("application/json", json!({ "hello": input["name"] }))
+        .ty("func.echo")
+        .data("application/json", json!({ "message": message }))
         .build()
         .map_err(ErrorInternalServerError)
 }
@@ -37,11 +55,11 @@ mod tests {
     #[actix_rt::test]
     async fn valid_input() {
         let mut input = Event::default();
-        input.set_data("application/json", json!({"name": "bootsy"}));
+        input.set_data("application/json", json!({"message": "test-echo"}));
         let resp = handle(input, config()).await;
         assert!(resp.is_ok());
         match resp.unwrap().data() {
-            Some(Data::Json(output)) => assert_eq!("bootsy", output["hello"]),
+            Some(Data::Json(output)) => assert_eq!("test-echo", output["message"]),
             _ => panic!(),
         }
     }
@@ -51,7 +69,7 @@ mod tests {
         let resp = handle(Event::default(), config()).await;
         assert!(resp.is_ok());
         match resp.unwrap().data() {
-            Some(Data::Json(output)) => assert_eq!("world", output["hello"]),
+            Some(Data::Json(output)) => assert_eq!("world", output["message"]),
             _ => panic!(),
         }
     }

templates/rust/cloudevents/src/handler.rs

@@ -6,7 +6,13 @@ use log::info;
 pub async fn index(req: HttpRequest, config: Data<HandlerConfig>) -> HttpResponse {
     info!("{:#?}", req);
     if req.method() == Method::GET {
-        HttpResponse::Ok().body(format!("Hello {}!\n", config.name))
+        // Echo back the query string if present, otherwise return greeting
+        let query = req.query_string();
+        if !query.is_empty() {
+            HttpResponse::Ok().body(query.to_string())
+        } else {
+            HttpResponse::Ok().body(format!("Hello {}!\n", config.name))
+        }
     } else {
         HttpResponse::Ok().body(format!("Thanks {}!\n", config.name))
     }
@@ -32,6 +38,19 @@ mod tests {
         );
     }
 
+    #[actix_rt::test]
+    async fn get_with_query() {
+        let req = TestRequest::get()
+            .uri("/?test=param&message=hello")
+            .to_http_request();
+        let resp = index(req, config()).await;
+        assert_eq!(resp.status(), http::StatusCode::OK);
+        assert_eq!(
+            &Bytes::from("test=param&message=hello"),
+            to_bytes(resp.into_body()).await.unwrap().as_ref()
+        );
+    }
+
     #[actix_rt::test]
     async fn post() {
         let req = TestRequest::post().to_http_request();

templates/rust/http/src/handler.rs

@@ -50,8 +50,8 @@ ${JSON.stringify(body)}
       }
     };
   } else {
-    return { 
-      statusCode: 405, 
+    return {
+      statusCode: 405,
       body: { error: 'Method not allowed' },
       headers: {
         'content-type': 'application/json'

templates/typescript/http/src/index.ts

@@ -14,7 +14,7 @@ test('Unit: handles a valid request', async (t) => {
   };
 
   // Invoke the function which should complete without error and echo the data
-  const result = await handle({ log: { info: (_) => _ } } as Context, body);
+  const result = await handle({ method: 'POST', log: { info: (_) => _ } } as Context, body);
   t.ok(result);
   t.equal(result.body, body);
   t.end();