Merge branch 'dapr:main' into main

Author: swatimodi-scout

.build-tools/go.mod

@@ -12,7 +12,7 @@ require (
 )
 
 require (
-	github.com/dapr/kit v0.15.3-0.20250717140748-8b780b4d81c5 // indirect
+	github.com/dapr/kit v0.16.1 // indirect
 	github.com/fxamacker/cbor/v2 v2.7.0 // indirect
 	github.com/gogo/protobuf v1.3.2 // indirect
 	github.com/iancoleman/orderedmap v0.0.0-20190318233801-ac98e3ecb4b0 // indirect

.build-tools/go.sum

@@ -1,6 +1,6 @@
 github.com/cpuguy83/go-md2man/v2 v2.0.2/go.mod h1:tgQtvFlXSQOSOSIRvRPT7W67SCa46tRHOmNcaadrF8o=
-github.com/dapr/kit v0.15.3-0.20250717140748-8b780b4d81c5 h1:Q26gmPxs6WnnBYoudOlznPHsmrbTawcYEpHg4VoB7v8=
-github.com/dapr/kit v0.15.3-0.20250717140748-8b780b4d81c5/go.mod h1:40ZWs5P6xfYf7O59XgwqZkIyDldTIXlhTQhGop8QoSM=
+github.com/dapr/kit v0.16.1 h1:MqLAhHVg8trPy2WJChMZFU7ToeondvxcNHYVvMDiVf4=
+github.com/dapr/kit v0.16.1/go.mod h1:40ZWs5P6xfYf7O59XgwqZkIyDldTIXlhTQhGop8QoSM=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc h1:U9qPSI2PIWSS1VwoXQT9A3Wy9MM3WgvqSxFWenqJduM=
 github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=

.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=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=nameresolution,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.0.1
+    image: docker.io/bitnamilegacy/cassandra:4.1
     ports:
       - '7000:7000'
       - '9042:9042'

.github/scripts/dapr_bot.js

@@ -1,32 +1,18 @@
 // list of owner who can control dapr-bot workflow
 // TODO: Read owners from OWNERS file.
 const owners = [
-    'addjuarez',
-    'amuluyavarote',
-    'artursouza',
+    'acroca',
     'berndverst',
+    'cicoyle',
     'daixiang0',
-    'DeepanshuA',
-    'elena-kolevska',
-    'halspang',
-    'ItalyPaleAle',
+    'javier-aliaga',
     'jjcollinge',
     'joshvanl',
     'mikeee',
     'msfussell',
-    'mukundansundar',
-    'pkedy',
-    'pravinpushkar',
-    'robertojrojas',
-    'RyanLettieri',
-    'shivamkm07',
-    'shubham1172',
+    'nelson-parente',
     'sicoyle',
-    'skyao',
-    'Taction',
-    'tmacam',
     'yaron2',
-    'yash-nisar',
 ]
 
 const docsIssueBodyTpl = (

.github/scripts/test-info.mjs

@@ -795,6 +795,23 @@ const components = {
         requiredSecrets: ['AzureSqlServerConnectionString'],
         sourcePkg: ['state/sqlserver', 'common/component/sql'],
     },
+    'state.sqlserver.v2': {
+        conformance: true,
+        certification: true,
+        conformanceSetup: 'docker-compose.sh sqlserver',
+        requiredSecrets: ['AzureSqlServerConnectionString'],
+        sourcePkg: ['state/sqlserver/v2', 'common/component/sql'],
+    },
+    'state.sqlserver.docker': {
+        conformance: true,
+        conformanceSetup: 'docker-compose.sh sqlserver',
+        sourcePkg: ['state/sqlserver', 'common/component/sql'],
+    },
+    'state.sqlserver.v2.docker': {
+        conformance: true,
+        conformanceSetup: 'docker-compose.sh sqlserver',
+        sourcePkg: ['state/sqlserver/v2', 'common/component/sql'],
+    },
     // 'state.gcp.firestore.docker': {
     //     conformance: true,
     //     requireDocker: true,

bindings/apns/metadata.yaml

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

bindings/gcp/bucket/bucket.go

@@ -47,8 +47,9 @@ const (
 	metadataEncodeBase64 = "encodeBase64"
 	metadataSignTTL      = "signTTL"
 
-	metadataKey = "key"
-	maxResults  = 1000
+	metadataContentType = "contentType"
+	metadataKey         = "key"
+	maxResults          = 1000
 
 	metadataKeyBC    = "name"
 	signOperation    = "sign"
@@ -77,6 +78,7 @@ 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"`
@@ -233,6 +235,12 @@ 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()
@@ -378,9 +386,15 @@ 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,6 +233,42 @@ 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,4 +44,12 @@ metadata:
     description: |
       Configuration to encode base64 file content before return the content. 
       (In case of saving a file with binary content).
-    example: '"true, false"'
+    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"'