++ genesis commit

Author: EditUndo

.gitmodules

@@ -0,0 +1,3 @@
+[submodule "deps/a2a"]
+	path = deps/a2a
+	url = https://github.com/google/A2A.git

CHANGELOG.md

@@ -0,0 +1,43 @@
+# Changelog
+
+All notable changes to the @artinet/sdk package will be documented in this file.
+
+The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
+and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
+
+## [Unreleased]
+
+### Fixed
+
+- Fixed TypeScript errors related to the eventsource-parser package imports
+  - Updated imports to use the correct types from eventsource-parser v1.1.1
+  - Properly typed the EventSourceMessage as ParsedEvent
+  - Refactored createParser implementation to match the package's API
+- Fixed streaming response handler to use the correct event type checking
+
+### Changed
+
+- Updated tsconfig.json to add isolatedModules: true for better compatibility with ts-jest
+- Modified package.json test scripts to include NODE_OPTIONS=--experimental-vm-modules flag to support ES modules in Jest tests
+
+### Improved
+
+- Expanded test suite to achieve 95% code coverage
+  - Added tests for all client methods
+  - Added robust error handling tests
+  - Added tests for streaming functionality
+  - Added tests for push notification configuration
+  - Added tests for edge cases in agent card fetching and capability detection
+
+## [0.1.0] - 2023-04-23
+
+### Added
+
+- Initial release of the @artinet/sdk package
+- Implementation of the Agent2Agent (A2A) Protocol client
+- Support for sending tasks, retrieving statuses, and canceling operations
+- Support for streaming responses and push notifications
+- Comprehensive test suite and documentation
+
+[Unreleased]: https://github.com/artinet/sdk/compare/v0.1.0...HEAD
+[0.1.0]: https://github.com/artinet/sdk/releases/tag/v0.1.0

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2025 Artinet
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE. 

README.md

@@ -0,0 +1,172 @@
+# Artinet SDK
+
+A TypeScript client library for the [Agent2Agent (A2A) Protocol](https://github.com/google/A2A) - an open protocol for communication between AI agents.
+
+## Installation
+
+```bash
+npm install @artinet/sdk
+```
+
+## Features
+
+- Full implementation of the A2A Protocol using the official Google schema
+- TypeScript types for all protocol structures
+- Streaming support for real-time updates
+- Push notification capabilities
+- Built-in error handling
+- Flexible authentication mechanisms
+
+## Usage
+
+### Basic Usage
+
+```typescript
+import { A2AClient, Message, Part, TaskSendParams } from "@artinet/sdk";
+
+// Create a new client instance
+const client = new A2AClient("https://your-a2a-server.com");
+
+// Get the agent card to discover capabilities
+const agentCard = await client.agentCard();
+console.log(`Connected to agent: ${agentCard.name}`);
+
+// Check if the server supports streaming
+const supportsStreaming = await client.supports("streaming");
+
+// Create a message to send
+const message: Message = {
+  role: "user",
+  parts: [
+    {
+      type: "text",
+      text: "Hello! Can you help me with a question?",
+    },
+  ],
+};
+
+// Send a task
+const task = await client.sendTask({
+  id: "task-123",
+  message,
+});
+
+console.log(`Task status: ${task?.status.state}`);
+```
+
+### Streaming Updates
+
+```typescript
+import { A2AClient, Message } from "@artinet/sdk";
+
+const client = new A2AClient("https://your-a2a-server.com");
+
+// Check if the server supports streaming
+if (await client.supports("streaming")) {
+  const message = {
+    role: "user",
+    parts: [{ type: "text", text: "Tell me a story about space exploration" }],
+  };
+
+  // Send a task and subscribe to updates
+  const stream = client.sendTaskSubscribe({
+    id: "streaming-task-123",
+    message,
+  });
+
+  // Process the updates as they arrive
+  for await (const update of stream) {
+    if ("status" in update) {
+      console.log(`Task status: ${update.status.state}`);
+
+      // Display agent's response when available
+      if (update.status.message) {
+        const textParts = update.status.message.parts
+          .filter((part) => part.type === "text")
+          .map((part) => (part as any).text);
+
+        console.log("Agent response:", textParts.join("\n"));
+      }
+    } else if ("artifact" in update) {
+      console.log("Received artifact:", update.artifact.name);
+    }
+  }
+}
+```
+
+### Authentication
+
+```typescript
+import { A2AClient } from "@artinet/sdk";
+
+// Add authentication headers
+const client = new A2AClient("https://your-a2a-server.com");
+client.addHeader("Authorization", "Bearer your-token-here");
+
+// Or set multiple headers at once
+client.setHeaders({
+  Authorization: "Bearer your-token-here",
+  "X-Custom-Header": "custom-value",
+});
+```
+
+## Logging
+
+The SDK uses [pino](https://github.com/pinojs/pino), a fast and low overhead logging library:
+
+```typescript
+import { logger, configureLogger, LogLevel } from "@artinet/sdk";
+
+// Configure the logger
+configureLogger({
+  level: "debug", // Options: 'silent', 'error', 'warn', 'info', 'debug', 'trace'
+  name: "MyApplication" // Optional custom logger name
+});
+
+// Use the logger directly
+logger.info("Connection established");
+logger.error({ err: new Error("Failed to connect") }, "Connection error");
+logger.debug({ data: { id: 123, status: "active" } }, "Task details");
+
+// In production, set a more restrictive level
+configureLogger({ level: "error" });
+// Or disable completely
+configureLogger({ level: "silent" });
+```
+
+The default log level is 'error', which means only error messages and above are shown.
+
+For more advanced configurations, you can access the pino logger instance directly:
+
+```typescript
+import { logger } from "@artinet/sdk";
+import { pino } from "pino";
+
+// Create a custom child logger
+const customLogger = logger.child({ module: "TaskProcessor" });
+customLogger.info("Processing started");
+```
+
+## API Reference
+
+### Classes
+
+- `A2AClient` - Main client for interacting with A2A servers
+- `RpcError` - Error class for handling A2A protocol errors
+
+### Utilities
+
+- `logger` - Pino logger instance for SDK operations
+- `configureLogger()` - Utility function to configure the logger
+
+## Contributing
+
+Contributions are welcome! Please feel free to submit a Pull Request.
+
+## License
+
+This project is licensed under the MIT License - see the LICENSE file for details.
+
+## Acknowledgements
+
+This SDK directly incorporates the [official A2A Protocol schema](https://github.com/google/A2A/blob/main/samples/js/src/schema.ts) created by Google, ensuring complete compatibility with the specification.

deps/a2a

@@ -0,0 +1,79 @@
+/**
+ * Basic usage example for the Artinet SDK
+ *
+ * This example demonstrates how to:
+ * - Create an A2AClient instance
+ * - Get the agent card
+ * - Send a simple task
+ * - Handle the response
+ */
+
+import { A2AClient } from "../dist/index.js";
+
+async function main() {
+  try {
+    // Create a new client instance
+    // Replace with your actual A2A server URL
+    const client = new A2AClient("https://your-a2a-server.com");
+    console.log("Client initialized");
+
+    // You can add authentication if required
+    client.addHeader("Authorization", "Bearer your-token-here");
+
+    // Get the agent card to discover capabilities
+    try {
+      const agentCard = await client.agentCard();
+      console.log(`Connected to agent: ${agentCard.name}`);
+      console.log(`Agent version: ${agentCard.version}`);
+      console.log(
+        `Streaming supported: ${
+          agentCard.capabilities.streaming ? "Yes" : "No"
+        }`
+      );
+    } catch (error) {
+      console.log("Could not retrieve agent card, continuing anyway...");
+    }
+
+    // Create a message to send
+    const message = {
+      role: "user",
+      parts: [
+        {
+          type: "text",
+          text: "Hello! Can you help me with a question about climate change?",
+        },
+      ],
+    };
+
+    // Generate a unique task ID
+    const taskId = `task-${Date.now()}`;
+
+    // Send a task
+    console.log(`Sending task with ID: ${taskId}...`);
+
+    const task = await client.sendTask({
+      id: taskId,
+      message,
+    });
+
+    if (task) {
+      console.log(`Task status: ${task.status.state}`);
+
+      if (task.status.message) {
+        // Extract the text parts from the response
+        const textParts = task.status.message.parts
+          .filter((part) => part.type === "text")
+          .map((part) => part.text);
+
+        console.log("Agent response:", textParts.join("\n"));
+      }
+    } else {
+      console.log("No task response received");
+    }
+  } catch (error) {
+    console.error("Error:", error.message);
+  }
+}
+
+// Run the example
+main().catch(console.error);