feat: Add submit task command to A2A CLI and update README with usage examples

Signed-off-by: Eden Reich <[email protected]>

Author: edenreich

cli/cli.go

@@ -93,6 +93,7 @@ func init() {
 	tasksCmd.AddCommand(listTasksCmd)
 	tasksCmd.AddCommand(getTaskCmd)
 	tasksCmd.AddCommand(historyCmd)
+	tasksCmd.AddCommand(submitTaskCmd)
 
 	rootCmd.AddCommand(configCmd)
 	rootCmd.AddCommand(tasksCmd)
@@ -105,6 +106,7 @@ func init() {
 	listTasksCmd.Flags().Int("limit", 50, "Maximum number of tasks to return")
 	listTasksCmd.Flags().Int("offset", 0, "Number of tasks to skip")
 	getTaskCmd.Flags().Int("history-length", 0, "Number of history messages to include")
+	submitTaskCmd.Flags().String("context-id", "", "Context ID for the task (optional, will generate new context if not provided)")
 }
 
 func initConfig() {
@@ -562,3 +564,63 @@ var versionCmd = &cobra.Command{
 		fmt.Printf("Built:      %s\n", buildDate)
 	},
 }
+
+var submitTaskCmd = &cobra.Command{
+	Use:   "submit [message]",
+	Short: "Submit a new task to the A2A server",
+	Long:  "Submits a new task to the A2A server with the specified message.",
+	Args:  cobra.ExactArgs(1),
+	RunE: func(cmd *cobra.Command, args []string) error {
+		ctx := context.Background()
+		ensureA2AClient()
+
+		message := args[0]
+		contextID, _ := cmd.Flags().GetString("context-id")
+
+		messageID := fmt.Sprintf("msg-%d", time.Now().Unix())
+
+		params := adk.MessageSendParams{
+			Message: adk.Message{
+				Kind:      "message",
+				MessageID: messageID,
+				Role:      "user",
+				Parts: []adk.Part{
+					map[string]interface{}{
+						"kind": "text",
+						"text": message,
+					},
+				},
+			},
+		}
+
+		if contextID != "" {
+			params.Message.ContextID = &contextID
+		}
+
+		logger.Debug("Submitting new task", zap.String("message", message), zap.String("context_id", contextID))
+
+		resp, err := a2aClient.SendTask(ctx, params)
+		if err != nil {
+			return handleA2AError(err, "message/send")
+		}
+
+		resultBytes, err := json.Marshal(resp.Result)
+		if err != nil {
+			return fmt.Errorf("failed to marshal response: %w", err)
+		}
+
+		var task adk.Task
+		if err := json.Unmarshal(resultBytes, &task); err != nil {
+			return fmt.Errorf("failed to unmarshal task: %w", err)
+		}
+
+		fmt.Printf("✅ Task submitted successfully!\n\n")
+		fmt.Printf("Task Details:\n")
+		fmt.Printf("  Task ID: %s\n", task.ID)
+		fmt.Printf("  Context ID: %s\n", task.ContextID)
+		fmt.Printf("  Status: %s\n", task.Status.State)
+		fmt.Printf("  Message ID: %s\n", messageID)
+
+		return nil
+	},
+}

example/README.md

@@ -43,6 +43,12 @@ docker compose run --rm a2a-debugger tasks list
 # List tasks with filtering
 docker compose run --rm a2a-debugger tasks list --state working --limit 10
 
+# Submit a new task
+docker compose run --rm a2a-debugger tasks submit "Hello, can you help me?"
+
+# Submit a task with a specific context ID
+docker compose run --rm a2a-debugger tasks submit "Continue our conversation" --context-id ctx-123
+
 # Get detailed information about a specific task
 docker compose run --rm a2a-debugger tasks get <task-id>
 

example/docker-compose.yml

@@ -3,16 +3,13 @@ services:
     image: ghcr.io/inference-gateway/google-calendar-agent:latest
     pull_policy: always
     environment:
-      APP_DEMO_MODE: 'true'
+      APP_DEMO_MODE: true
     networks:
       - a2a-network
 
   a2a-debugger:
-    # image: ghcr.io/inference-gateway/a2a-debugger:latest
-    # pull_policy: always
-    build:
-      context: ..
-      dockerfile: Dockerfile
+    image: ghcr.io/inference-gateway/a2a-debugger:latest
+    pull_policy: always
     entrypoint:
       - /a2a
       - --config