Merge branch 'main' into feat-tool-email

Author: gozhuang

.gitattributes

@@ -1,5 +1,7 @@
 .resources/*.png filter=lfs diff=lfs merge=lfs -text
 .resources/**/*.png filter=lfs diff=lfs merge=lfs -text
+.resources/**/*.gif filter=lfs diff=lfs merge=lfs -text
 *.png filter=lfs diff=lfs merge=lfs -text
+*.gif filter=lfs diff=lfs merge=lfs -text
 examples/artifact/**/*.png filter=lfs diff=lfs merge=lfs -text
 examples/artifact/*.png filter=lfs diff=lfs merge=lfs -text

.github/codecov.yaml

@@ -9,4 +9,8 @@ coverage: # https://docs.codecov.com/docs/codecovyml-reference#coverage
         branches:
           - ^main$
         target: 85.0 # the minimum coverage ratio that the commit must meet to be considered a success.
-        threshold: 1% # allow the coverage to drop by X%, and posting a success status. 
+        threshold: 1% # allow the coverage to drop by X%, and posting a success status.
+    patch:
+      default:
+        target: 85.0 # require new/changed lines to be ≥ 85%
+        threshold: 0% # do not allow patch coverage to fall below target

.github/scripts/run-go-tests.sh

@@ -5,13 +5,43 @@ script_dir="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
 repo_root="$(cd "${script_dir}/../.." && pwd)"
 cd "${repo_root}"
 
+declare -a requested_modules=()
+while [[ $# -gt 0 ]]; do
+  case "$1" in
+    --module)
+      if [[ $# -lt 2 ]]; then
+        echo "missing value for --module" >&2
+        exit 1
+      fi
+      requested_modules+=("$2")
+      shift 2
+      ;;
+    *)
+      echo "unknown argument: $1" >&2
+      exit 1
+      ;;
+  esac
+done
+
 gomodules=()
-while IFS= read -r mod; do
-  gomodules+=("${mod}")
-done < <(find . -name go.mod \
-  -not -path "./.resource/*" \
-  -not -path "./docs/*" \
-  -not -path "./examples/*" | sort)
+if [ "${#requested_modules[@]}" -gt 0 ]; then
+  for module in "${requested_modules[@]}"; do
+    normalized="${module#./}"
+    normalized="./${normalized}"
+    if [ ! -f "${normalized}" ]; then
+      echo "module file not found: ${module}" >&2
+      exit 1
+    fi
+    gomodules+=("${normalized}")
+  done
+else
+  while IFS= read -r mod; do
+    gomodules+=("${mod}")
+  done < <(find . -name go.mod \
+    -not -path "./.resource/*" \
+    -not -path "./docs/*" \
+    -not -path "./examples/*" | sort)
+fi
 
 if [ "${#gomodules[@]}" -eq 0 ]; then
   echo "no go modules found"

.github/workflows/prc.yml

@@ -17,9 +17,96 @@ jobs:
         go-version: '1.21'
     - name: Build
       run: go build -v ./...
-    - name: Test All Modules
+  discover-go-modules:
+    name: discover go modules
+    runs-on: ubuntu-latest
+    outputs:
+      matrix: ${{ steps.set-matrix.outputs.matrix }}
+    steps:
+    - uses: actions/checkout@v3
+    - id: set-matrix
+      shell: bash
+      run: |
+        set -euo pipefail
+        mapfile -t modules < <(find . -name go.mod \
+          -not -path "./.resource/*" \
+          -not -path "./docs/*" \
+          -not -path "./examples/*" | sort)
+        if [ "${#modules[@]}" -eq 0 ]; then
+          echo "matrix={\"module\":[]}" >> "$GITHUB_OUTPUT"
+          exit 0
+        fi
+        matrix=$(printf '%s\n' "${modules[@]}" | sed 's|^\./||' | jq -R -s -c 'split("\n") | map(select(length>0))')
+        echo "matrix={\"module\":${matrix}}" >> "$GITHUB_OUTPUT"
+  test-go-modules:
+    name: go test (${{ matrix.module }})
+    runs-on: ubuntu-latest
+    needs: discover-go-modules
+    strategy:
+      fail-fast: false
+      matrix: ${{ fromJson(needs.discover-go-modules.outputs.matrix) }}
+    steps:
+    - uses: actions/checkout@v3
+    - uses: actions/setup-go@v5
+      with:
+        go-version: '1.21'
+    - name: Prepare module metadata
+      id: module-info
+      shell: bash
+      run: |
+        set -euo pipefail
+        module='${{ matrix.module }}'
+        if [ -z "${module}" ]; then
+          echo "empty module path" >&2
+          exit 1
+        fi
+        rel="${module#./}"
+        if [ "${rel}" = "go.mod" ]; then
+          readable="root"
+        else
+          readable="${rel%/go.mod}"
+        fi
+        safe="${readable//\//_}"
+        safe="${safe//./_}"
+        if [ -z "${safe}" ]; then
+          safe="root"
+        fi
+        echo "safe_name=${safe}" >> "$GITHUB_OUTPUT"
+    - name: Test module
       shell: bash
-      run: bash .github/scripts/run-go-tests.sh
+      run: bash .github/scripts/run-go-tests.sh --module "${{ matrix.module }}"
+    - name: Prepare coverage artifact
+      shell: bash
+      run: mv coverage.out "coverage-${{ steps.module-info.outputs.safe_name }}.out"
+    - name: Upload coverage artifact
+      uses: actions/upload-artifact@v4
+      with:
+        name: coverage-${{ steps.module-info.outputs.safe_name }}
+        path: coverage-${{ steps.module-info.outputs.safe_name }}.out
+        if-no-files-found: error
+  coverage:
+    name: coverage
+    runs-on: ubuntu-latest
+    needs: test-go-modules
+    steps:
+    - uses: actions/download-artifact@v4
+      with:
+        pattern: coverage-*
+        merge-multiple: true
+    - name: Combine coverage reports
+      shell: bash
+      run: |
+        set -euo pipefail
+        shopt -s nullglob
+        files=(coverage-*.out)
+        if [ "${#files[@]}" -eq 0 ]; then
+          echo "no coverage files found" >&2
+          exit 1
+        fi
+        cp "${files[0]}" coverage.out
+        for file in "${files[@]:1}"; do
+          tail -n +2 "${file}" >> coverage.out
+        done
     - name: Upload coverage reports to Codecov
       uses: codecov/codecov-action@v5
       with:
@@ -58,3 +145,18 @@ jobs:
       with:
         go-version: '1.21'
     - uses: joelanford/go-apidiff@main 
+  docs-build:
+    name: docs-build
+    runs-on: ubuntu-latest
+    defaults:
+      run:
+        working-directory: docs
+    steps:
+    - uses: actions/checkout@v3
+    - uses: actions/setup-python@v5
+      with:
+        python-version: '3.11'
+    - name: Install MkDocs dependencies
+      run: pip install -r mkdocs/assets/requirements.txt
+    - name: Build documentation
+      run: mkdocs build --strict

.resource/images/examples/agui-report.gif

@@ -32,3 +32,5 @@ indexes = "indexes"
 indexs = "indexs"
 ba = "ba"
 UE = "UE"
+rin = "rin"
+dify = "dify"

.typos.toml

@@ -243,7 +243,10 @@ func (r *A2AAgent) runStreaming(ctx context.Context, invocation *agent.Invocatio
 			return
 		}
 
-		var aggregatedContentBuilder strings.Builder
+		var (
+			responseID               string
+			aggregatedContentBuilder strings.Builder
+		)
 		for streamEvent := range streamChan {
 			if err := agent.CheckContextCancelled(ctx); err != nil {
 				return
@@ -257,6 +260,9 @@ func (r *A2AAgent) runStreaming(ctx context.Context, invocation *agent.Invocatio
 
 			// Aggregate content from delta
 			if evt.Response != nil && len(evt.Response.Choices) > 0 {
+				if evt.Response.ID != "" {
+					responseID = evt.Response.ID
+				}
 				if r.streamingRespHandler != nil {
 					content, err := r.streamingRespHandler(evt.Response)
 					if err != nil {
@@ -278,6 +284,8 @@ func (r *A2AAgent) runStreaming(ctx context.Context, invocation *agent.Invocatio
 			invocation.InvocationID,
 			r.name,
 			event.WithResponse(&model.Response{
+				ID:        responseID,
+				Object:    model.ObjectTypeChatCompletion,
 				Done:      true,
 				IsPartial: false,
 				Timestamp: time.Now(),

agent/a2aagent/a2a_agent.go

@@ -77,6 +77,9 @@ func WithA2AClientExtraOptions(opts ...client.Option) Option {
 // WithStreamingChannelBufSize set the buf size of streaming protocol
 func WithStreamingChannelBufSize(size int) Option {
 	return func(a *A2AAgent) {
+		if size < 0 {
+			size = defaultStreamingChannelSize
+		}
 		a.streamingBufSize = size
 	}
 }