feat: add Anthropic Claude message format support to callModel

Add support for Anthropic Claude-style messages as input and output:

Input formats now supported:
- OpenResponses format (native)
- OpenAI Chat Completions format (Message[])
- Anthropic Claude format (ClaudeMessageParam[])

Output methods added/renamed:
- getChatMessage() - returns OpenAI chat format (renamed from getMessage)
- getClaudeMessage() - returns Anthropic Claude format (new)
- getNewChatMessagesStream() - stream chat messages (renamed from getNewMessagesStream)

Also includes:
- New ClaudeMessage types mirroring Anthropic SDK types
- Automatic format detection and conversion
- convertToClaudeMessage() helper for response transformation
- Updated examples demonstrating all input/output formats
- E2E tests for Claude-style message handling

BREAKING CHANGE: getMessage() renamed to getChatMessage()
BREAKING CHANGE: getNewMessagesStream() renamed to getNewChatMessagesStream()

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <[email protected]>

Author: mattapperson

.gitignore

@@ -33,3 +33,4 @@
 /examples/nextjs-example/package-lock.json
 /examples/nextjs-example/package.lock.json
 /temp
+.codanna/**

examples/betaResponsesSend.example.ts

@@ -11,7 +11,7 @@ dotenv.config();
  * npm run build && npx tsx betaResponsesSend.example.ts
  */
 
-import { OpenRouter } from "@openrouter/sdk";
+import { OpenRouter } from "../src/index.js";
 
 const openRouter = new OpenRouter({
   apiKey: process.env["OPENROUTER_API_KEY"] ?? "",

examples/callModel.example.ts

@@ -0,0 +1,89 @@
+/*
+ * Code generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.
+ */
+
+import dotenv from "dotenv";
+dotenv.config();
+/**
+ * Example usage of the @openrouter/sdk SDK
+ *
+ * To run this example from the examples directory:
+ * npm run build && npx tsx betaResponsesSend.example.ts
+ */
+
+import { OpenRouter } from "../src/index.js";
+import { Message, OpenResponsesEasyInputMessage } from "../src/models";
+
+import { MessageParam as AnthropicClaudeMessage } from "@anthropic-ai/sdk/resources/messages";
+
+const openRouter = new OpenRouter({
+  apiKey: process.env["OPENROUTER_API_KEY"] ?? "",
+});
+
+const chatMessages: Message[] = [
+  {
+    role: "user",
+    content: "Hello! What is your name?",
+  },
+];
+const text = "Hello! What is your name?";
+const responsesMessages: OpenResponsesEasyInputMessage[] = [
+  {
+    type: "message",
+    role: "user",
+    content: [
+      {
+        type: "input_text",
+        text: "What is your name?",
+      },
+    ],
+  },
+];
+
+const anthropicClaudeMessages: AnthropicClaudeMessage[] = [
+  {
+    role: "user",
+    content: "Hello! What is your name?",
+  },
+];
+
+const supportedInputSchemas = [
+  chatMessages,
+  text,
+  responsesMessages,
+  anthropicClaudeMessages,
+];
+
+for (const input of supportedInputSchemas) {
+  const result = await openRouter.callModel({
+    instructions: "You are a helpful assistant. Your name is Mark",
+    model: "openai/gpt-4",
+    input: input,
+  });
+
+  // get resulting output each time in...
+
+  // text format
+  console.log(await result.getText());
+
+  // chat message format (was names getMessage)
+  console.log(await result.getChatMessage());
+
+  // response message format
+  console.log(await result.getResponse().then((response) => response.output));
+
+  // AnthropicClaude message format
+  console.log(await result.getClaudeMessage());
+
+  // stream response message format
+  console.log(await result.getFullResponsesStream());
+
+  // stream text format
+  console.log(await result.getTextStream());
+
+  // stream chat message format
+  console.log(await result.getNewChatMessagesStream());
+
+  // stream response message format
+  console.log(await result.getFullResponsesStream());
+}

examples/chatCompletions.example.ts

@@ -2,7 +2,7 @@
  * Code generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.
  */
 
-import dotenv from 'dotenv';
+import dotenv from "dotenv";
 
 dotenv.config();
 
@@ -13,39 +13,40 @@ dotenv.config();
  * bun run chatCompletions.example.ts
  */
 
-import { OpenRouter } from '@openrouter/sdk';
+import { OpenRouter } from "../src/index.js";
 
-if (!process.env['OPENROUTER_API_KEY']) {
-  throw new Error('Missing OPENROUTER_API_KEY environment variable');
+if (!process.env["OPENROUTER_API_KEY"]) {
+  throw new Error("Missing OPENROUTER_API_KEY environment variable");
 }
 const openRouter = new OpenRouter({
-  apiKey: process.env['OPENROUTER_API_KEY'] ?? '',
+  apiKey: process.env["OPENROUTER_API_KEY"] ?? "",
   debugLogger: console,
 });
 
 async function nonStreamingExample() {
   const result = await openRouter.chat.send({
-    model: 'qwen/qwen3-max',
+    model: "qwen/qwen3-max",
     messages: [
       {
-        role: 'user',
-        content: 'Tell me a short joke about programming',
+        role: "user",
+        content: "Tell me a short joke about programming",
       },
     ],
     stream: false,
   });
 
-  if ('choices' in result) {
+  if ("choices" in result) {
+    console.log(result.choices[0].message.content);
   }
 }
 
 async function streamingExample() {
   const result = await openRouter.chat.send({
-    model: 'qwen/qwen3-max',
+    model: "qwen/qwen3-max",
     messages: [
       {
-        role: 'user',
-        content: 'Write a haiku about TypeScript',
+        role: "user",
+        content: "Write a haiku about TypeScript",
       },
     ],
     stream: true,
@@ -54,9 +55,9 @@ async function streamingExample() {
     },
   });
 
-  if (result && typeof result === 'object' && Symbol.asyncIterator in result) {
+  if (result && typeof result === "object" && Symbol.asyncIterator in result) {
     const stream = result;
-    let _fullContent = '';
+    let _fullContent = "";
 
     for await (const chunk of stream) {
       if (chunk.choices?.[0]?.delta?.content) {
@@ -66,6 +67,7 @@ async function streamingExample() {
       }
 
       if (chunk.usage) {
+        console.log(chunk.usage);
       }
     }
   }
@@ -75,7 +77,9 @@ async function main() {
   try {
     await nonStreamingExample();
     await streamingExample();
-  } catch (_error) {}
+  } catch (_error) {
+    console.error(_error);
+  }
 }
 
 main();