[1.16] Update release-1.16 with main

Signed-off-by: joshvanl <[email protected]>

Author: JoshVanL

.build-tools/pkg/metadataschema/schema.go

@@ -20,7 +20,7 @@ type ComponentMetadata struct {
 	// Version of the component metadata schema.
 	SchemaVersion string `json:"schemaVersion" yaml:"schemaVersion" jsonschema:"enum=v1"`
 	// Component type, of one of the allowed values.
-	Type string `json:"type" yaml:"type" jsonschema:"enum=bindings,enum=state,enum=secretstores,enum=pubsub,enum=workflows,enum=configuration,enum=lock,enum=middleware,enum=crypto,enum=nameresolution,enum=conversation"`
+	Type string `json:"type" yaml:"type" jsonschema:"enum=bindings,enum=state,enum=secretstores,enum=pubsub,enum=workflows,enum=configuration,enum=lock,enum=middleware,enum=crypto,enum=conversation"`
 	// Name of the component (without the inital type, e.g. "http" instead of "bindings.http").
 	Name string `json:"name" yaml:"name"`
 	// Version of the component, with the leading "v", e.g. "v1".

.github/infrastructure/docker-compose-cassandra.yml

@@ -2,7 +2,7 @@ version: '2'
 
 services:
   cassandra:
-    image: docker.io/bitnami/cassandra:4.1
+    image: docker.io/bitnami/cassandra:4.0.1
     ports:
       - '7000:7000'
       - '9042:9042'

bindings/apns/metadata.yaml

@@ -33,8 +33,8 @@ authenticationProfiles:
         description: "The APNS private key (P8 file content)"
 metadata:
   - name: development
-    type: bool
+    type: boolean
     required: false
     description: "The APNS environment is development or not"
-    example: "true"
-    default: "false"
+    example: true
+    default: false

bindings/gcp/bucket/bucket.go

@@ -47,9 +47,8 @@ const (
 	metadataEncodeBase64 = "encodeBase64"
 	metadataSignTTL      = "signTTL"
 
-	metadataContentType = "contentType"
-	metadataKey         = "key"
-	maxResults          = 1000
+	metadataKey = "key"
+	maxResults  = 1000
 
 	metadataKeyBC    = "name"
 	signOperation    = "sign"
@@ -78,7 +77,6 @@ type gcpMetadata struct {
 	TokenURI            string `json:"token_uri" mapstructure:"tokenURI" mdignore:"true" mapstructurealiases:"token_uri"`
 	AuthProviderCertURL string `json:"auth_provider_x509_cert_url" mapstructure:"authProviderX509CertURL" mdignore:"true" mapstructurealiases:"auth_provider_x509_cert_url"`
 	ClientCertURL       string `json:"client_x509_cert_url" mapstructure:"clientX509CertURL" mdignore:"true" mapstructurealiases:"client_x509_cert_url"`
-	ContentType         string `json:"contentType,omitempty" mapstructure:"contentType"`
 
 	Bucket       string `json:"bucket" mapstructure:"bucket"`
 	DecodeBase64 bool   `json:"decodeBase64,string" mapstructure:"decodeBase64"`
@@ -235,12 +233,6 @@ func (g *GCPStorage) create(ctx context.Context, req *bindings.InvokeRequest) (*
 	}
 
 	h := g.client.Bucket(g.metadata.Bucket).Object(name).NewWriter(ctx)
-
-	// Set content type if provided
-	if metadata.ContentType != "" {
-		h.ContentType = metadata.ContentType
-	}
-
 	// Cannot do `defer h.Close()` as Close() will flush the bytes and need to have error handling.
 	if _, err = io.Copy(h, r); err != nil {
 		cerr := h.Close()
@@ -386,15 +378,9 @@ func (metadata gcpMetadata) mergeWithRequestMetadata(req *bindings.InvokeRequest
 	if val, ok := req.Metadata[metadataEncodeBase64]; ok && val != "" {
 		merged.EncodeBase64 = strings.IsTruthy(val)
 	}
-
 	if val, ok := req.Metadata[metadataSignTTL]; ok && val != "" {
 		merged.SignTTL = val
 	}
-
-	if val, ok := req.Metadata[metadataContentType]; ok && val != "" {
-		merged.ContentType = val
-	}
-
 	return merged, nil
 }
 

bindings/gcp/bucket/bucket_test.go

@@ -233,42 +233,6 @@ func TestMergeWithRequestMetadata(t *testing.T) {
 		assert.NotNil(t, mergedMeta)
 		assert.False(t, mergedMeta.EncodeBase64)
 	})
-
-	t.Run("Has merged contentType metadata", func(t *testing.T) {
-		m := bindings.Metadata{}
-		m.Properties = map[string]string{
-			"bucket":      "my_bucket",
-			"projectID":   "my_project_id",
-			"contentType": "text/plain",
-		}
-		gs := GCPStorage{logger: logger.NewLogger("test")}
-		meta, err := gs.parseMetadata(m)
-		require.NoError(t, err)
-		assert.Equal(t, "text/plain", meta.ContentType)
-
-		// Empty request doesn't override
-		request := bindings.InvokeRequest{}
-		request.Metadata = map[string]string{}
-		mergedMeta, err := meta.mergeWithRequestMetadata(&request)
-		require.NoError(t, err)
-		assert.Equal(t, "text/plain", mergedMeta.ContentType)
-
-		// Request overrides component
-		request.Metadata = map[string]string{
-			"contentType": "text/csv",
-		}
-		mergedMeta, err = meta.mergeWithRequestMetadata(&request)
-		require.NoError(t, err)
-		assert.Equal(t, "text/csv", mergedMeta.ContentType)
-
-		// Empty string doesn't override
-		request.Metadata = map[string]string{
-			"contentType": "",
-		}
-		mergedMeta, err = meta.mergeWithRequestMetadata(&request)
-		require.NoError(t, err)
-		assert.Equal(t, "text/plain", mergedMeta.ContentType)
-	})
 }
 
 func TestInit(t *testing.T) {

bindings/gcp/bucket/metadata.yaml

@@ -44,12 +44,4 @@ metadata:
     description: |
       Configuration to encode base64 file content before return the content. 
       (In case of saving a file with binary content).
-    example: '"true, false"'
-  - name: contentType
-    type: string
-    required: false
-    description: |
-      The MIME type of the object being stored. If not specified, GCS will attempt to 
-      auto-detect the type, which may default to application/octet-stream or text/plain.
-      Common values include text/csv, application/json, image/png, etc.
-    example: '"text/csv", "application/json"'
+    example: '"true, false"'

bindings/kafka/metadata.yaml

@@ -352,6 +352,13 @@ metadata:
       It allows sending headers with special characters that are usually not allowed in HTTP headers.
     example: "true"
     default: "false"
+  - name: useAvroJSON
+    type: bool
+    required: false
+    description: |
+      Enables Avro JSON schema for serialization. Only applicable when the subscription uses valueSchemaType=Avro
+    example: "true"
+    default: "false"
   - name: compression
     type: string
     required: false

bindings/kubemq/metadata.yaml

@@ -37,20 +37,20 @@ metadata:
     description: The KubeMQ channel name.
     example: "my-channel"
   - name: pollMaxItems
-    type: number
+    type: int
     required: false
     description: The maximum number of items to poll.
-    example: "10"
-    default: "1"
+    example: 10
+    default: 1
   - name: pollTimeoutSeconds
-    type: number
+    type: int
     required: false
     description: The timeout in seconds for polling.
-    example: "3600"
-    default: "3600"
+    example: 3600
+    default: 3600
   - name: autoAcknowledged
     type: bool
     required: false
     description: Whether to automatically acknowledge messages.
-    example: "true"
-    default: "false"
+    example: true
+    default: false

bindings/kubernetes/kubernetes.go

@@ -119,9 +119,6 @@ func (k *kubernetesInput) Read(ctx context.Context, handler bindings.Handler) er
 		fields.Everything(),
 	)
 	resultChan := make(chan EventResponse)
-	// TODO:
-	// cache.NewInformer is deprecated: Use NewInformerWithOptions instead.
-	//nolint:staticcheck
 	_, controller := cache.NewInformer(
 		watchlist,
 		&corev1.Event{},

bindings/mqtt3/metadata.yaml

@@ -50,13 +50,13 @@ metadata:
   - name: retain
     required: false
     description: "Whether to retain messages"
-    example: "false"
-    default: "false"
+    example: false
+    default: false
   - name: cleanSession
     required: false
     description: "Whether to use clean session"
-    example: "true"
-    default: "true"
+    example: true
+    default: true
   - name: backOffMaxRetries
     required: false
     description: "Maximum retries for backoff"