Merge branch 'main' into main

Author: chenliu0831

.github/pull_request_template.md

@@ -0,0 +1,17 @@
+### What behavior changes?
+Describe the observable difference in behavior before and after this change.
+
+### Why is this change needed?
+Explain the motivation: bug, feature request, refactor, performance, etc.
+
+### How was this validated?
+List tests added, benchmarks run, or manual verification performed.
+
+### What should reviewers focus on?
+Point reviewers to the files or sections that contain the interesting logic.
+
+### Additional Links
+Related issues, design docs, or prior art.
+
+---
+By submitting this pull request, I confirm that my contribution is made under the terms of the Apache 2.0 license.

.github/workflows/ci.yml

@@ -9,8 +9,72 @@ on:
 permissions:
   pull-requests: write
 
+concurrency:
+  group: ci-${{ github.event.pull_request.number || github.ref }}
+  cancel-in-progress: true
+
 jobs:
+  format:
+    runs-on: ubuntu-latest
+    name: Auto-format
+    if: github.event_name == 'pull_request' && github.event.pull_request.head.repo.full_name == github.repository
+    steps:
+      - uses: actions/checkout@v6
+        with:
+          ref: ${{ github.head_ref }}
+          token: ${{ secrets.PR_TOKEN }}
+
+      - name: Check if last commit is from bot
+        id: check-bot
+        run: |
+          LAST_AUTHOR=$(git log -1 --format='%an')
+          if [ "$LAST_AUTHOR" = "github-actions[bot]" ]; then
+            echo "skip=true" >> "$GITHUB_OUTPUT"
+          else
+            echo "skip=false" >> "$GITHUB_OUTPUT"
+          fi
+
+      - name: Set up JDK 21
+        if: steps.check-bot.outputs.skip != 'true'
+        uses: actions/setup-java@v5
+        with:
+          java-version: 21
+          distribution: 'corretto'
+
+      - name: Cache compiled buildscripts
+        if: steps.check-bot.outputs.skip != 'true'
+        uses: actions/cache@v5
+        with:
+            key: ${{ runner.os }}-gradle-${{ hashFiles('buildSrc/**/*.kts') }}
+            path: |
+              ./buildSrc/build
+
+      - name: Setup Gradle
+        if: steps.check-bot.outputs.skip != 'true'
+        uses: gradle/actions/setup-gradle@v6
+        with:
+          cache-encryption-key: ${{ secrets.GRADLE_ENCRYPTION_KEY }}
+          gradle-home-cache-includes: |
+            caches
+
+      - name: Run spotlessApply
+        if: steps.check-bot.outputs.skip != 'true'
+        run: ./gradlew spotlessApply
+
+      - name: Commit formatting changes
+        if: steps.check-bot.outputs.skip != 'true'
+        run: |
+          if [ -n "$(git status --porcelain)" ]; then
+            git config user.name "github-actions[bot]"
+            git config user.email "41898282+github-actions[bot]@users.noreply.github.com"
+            git add -A
+            git commit -m "Auto-format: apply spotless formatting"
+            git push
+          fi
+
   build:
+    needs: [format]
+    if: always() && !cancelled()
     runs-on: ${{ matrix.os }}
     name: Java ${{ matrix.java }} ${{ matrix.os }}
     strategy:

aws/client/aws-client-awsjson/src/main/java/software/amazon/smithy/java/aws/client/awsjson/AwsJsonProtocol.java

@@ -141,6 +141,6 @@ private EventDecoderFactory<AwsEventFrame> getEventDecoderFactory(ApiOperation<?
     private static DataStream bodyDataStream(HttpResponse response) {
         var contentType = response.headers().contentType();
         var contentLength = response.headers().contentLength();
-        return DataStream.withMetadata(response.body(), contentType, contentLength, null);
+        return DataStream.withMetadata(response.body(), contentType, contentLength == null ? -1 : contentLength);
     }
 }

client/client-http/src/main/java/software/amazon/smithy/java/client/http/DataStreamBodyPublisher.java

@@ -0,0 +1,32 @@
+/*
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package software.amazon.smithy.java.client.http;
+
+import java.net.http.HttpRequest;
+import java.nio.ByteBuffer;
+import java.util.concurrent.Flow;
+import software.amazon.smithy.java.io.datastream.DataStream;
+
+/**
+ * Adapts a Smithy {@link DataStream} to the JDK HttpClient's {@link HttpRequest.BodyPublisher} contract.
+ */
+final class DataStreamBodyPublisher implements HttpRequest.BodyPublisher {
+    private final DataStream dataStream;
+
+    DataStreamBodyPublisher(DataStream dataStream) {
+        this.dataStream = dataStream;
+    }
+
+    @Override
+    public long contentLength() {
+        return dataStream.contentLength();
+    }
+
+    @Override
+    public void subscribe(Flow.Subscriber<? super ByteBuffer> subscriber) {
+        dataStream.subscribe(subscriber);
+    }
+}