Typescript SDK

npm install @qwen-code/sdk

import { query } from '@qwen-code/sdk';
 
// Single-Turn-Abfrage
const result = query({
  prompt: 'Welche Dateien befinden sich im aktuellen Verzeichnis?',
  options: {
    cwd: '/pfad/zum/projekt',
  },
});
 
// Über Nachrichten iterieren
for await (const message of result) {
  if (message.type === 'assistant') {
    console.log('Assistant:', message.message.content);
  } else if (message.type === 'result') {
    console.log('Ergebnis:', message.result);
  }
}

const query = qwen.query('Dein Prompt', {
  timeout: {
    canUseTool: 60000, // 60 Sekunden für Berechtigungs-Callback
    mcpRequest: 600000, // 10 Minuten für MCP-Toolaufrufe
    controlRequest: 60000, // 60 Sekunden für Steuerungsanfragen
    streamClose: 15000, // 15 Sekunden für Wartezeit beim Stream-Schließen
  },
});

import {
  isSDKUserMessage,
  isSDKAssistantMessage,
  isSDKSystemMessage,
  isSDKResultMessage,
  isSDKPartialAssistantMessage,
} from '@qwen-code/sdk';
 
for await (const message of result) {
  if (isSDKAssistantMessage(message)) {
    // Assistant-Nachricht verarbeiten
  } else if (isSDKResultMessage(message)) {
    // Ergebnisnachricht verarbeiten
  }
}

const q = query({ prompt: 'Hallo', options: {} });
 
// Sitzungs-ID abrufen
const sessionId = q.getSessionId();
 
// Prüfen, ob geschlossen
const closed = q.isClosed();
 
// Aktuelle Operation unterbrechen
await q.interrupt();
 
// Berechtigungsmodus während der Sitzung ändern
await q.setPermissionMode('yolo');
 
// Modell während der Sitzung ändern
await q.setModel('qwen-max');
 
// Nutzung des Kontextfensters abrufen (Token-Anzahl pro Kategorie)
const usage = await q.getContextUsage();
// true übergeben, um anzuzeigen, dass Details pro Element angezeigt werden sollen
const detail = await q.getContextUsage(true);
 
// Sitzung schließen
await q.close();

import { query, type SDKUserMessage } from '@qwen-code/sdk';
 
async function* generateMessages(): AsyncIterable<SDKUserMessage> {
  yield {
    type: 'user',
    session_id: 'my-session',
    message: { role: 'user', content: 'Erstelle eine Datei hello.txt' },
    parent_tool_use_id: null,
  };
 
  // Auf eine Bedingung oder Benutzereingabe warten
  yield {
    type: 'user',
    session_id: 'my-session',
    message: { role: 'user', content: 'Lies jetzt die Datei zurück' },
    parent_tool_use_id: null,
  };
}
 
const result = query({
  prompt: generateMessages(),
  options: {
    permissionMode: 'auto-edit',
  },
});
 
for await (const message of result) {
  console.log(message);
}

import { query, type CanUseTool } from '@qwen-code/sdk';
 
const canUseTool: CanUseTool = async (toolName, input, { signal }) => {
  // Alle Leseoperationen erlauben
  if (toolName.startsWith('read_')) {
    return { behavior: 'allow', updatedInput: input };
  }
 
  // Benutzer bei Schreiboperationen um Bestätigung bitten (in einer echten Anwendung)
  const userApproved = await promptUser(`Erlaube ${toolName}?`);
 
  if (userApproved) {
    return { behavior: 'allow', updatedInput: input };
  }
 
  return { behavior: 'deny', message: 'Benutzer hat die Operation abgelehnt' };
};
 
const result = query({
  prompt: 'Erstelle eine neue Datei',
  options: {
    canUseTool,
  },
});

import { query } from '@qwen-code/sdk';
 
const result = query({
  prompt: 'Verwende das benutzerdefinierte Tool von meinem MCP-Server',
  options: {
    mcpServers: {
      'mein-server': {
        command: 'node',
        args: ['pfad/zu/mcp-server.js'],
        env: { PORT: '3000' },
      },
    },
  },
});

import { query } from '@qwen-code/sdk';
 
const result = query({
  prompt: 'Sag Hallo in einem Satz.',
  options: {
    systemPrompt: 'Du bist ein knapper Assistent. Antworte in genau einem Satz.',
  },
});

import { query } from '@qwen-code/sdk';
 
const result = query({
  prompt: 'Überprüfe das aktuelle Verzeichnis.',
  options: {
    systemPrompt: {
      type: 'preset',
      preset: 'qwen_code',
      append: 'Sei knapp und konzentriere dich auf konkrete Ergebnisse.',
    },
  },
});

{
  content: Array<
    | { type: 'text'; text: string }
    | { type: 'image'; data: string; mimeType: string }
    | { type: 'resource'; uri: string; mimeType?: string; text?: string }
  >;
  isError?: boolean;
}

import { z } from 'zod';
import { query, tool, createSdkMcpServer } from '@qwen-code/sdk';
 
// Define a tool with Zod schema
const calculatorTool = tool(
  'calculate_sum',
  'Add two numbers',
  { a: z.number(), b: z.number() },
  async (args) => ({
    content: [{ type: 'text', text: String(args.a + args.b) }],
  }),
);
 
// Create the MCP server
const server = createSdkMcpServer({
  name: 'calculator',
  tools: [calculatorTool],
});
 
// Use the server in a query
const result = query({
  prompt: 'What is 42 + 17?',
  options: {
    permissionMode: 'yolo',
    mcpServers: {
      calculator: server,
    },
  },
});
 
for await (const message of result) {
  console.log(message);
}

import { query, isAbortError } from '@qwen-code/sdk';
 
const abortController = new AbortController();
 
const result = query({
  prompt: 'Long running task...',
  options: {
    abortController,
  },
});
 
// Abort after 5 seconds
setTimeout(() => abortController.abort(), 5000);
 
try {
  for await (const message of result) {
    console.log(message);
  }
} catch (error) {
  if (isAbortError(error)) {
    console.log('Query was aborted');
  } else {
    throw error;
  }
}

import { AbortError, isAbortError } from '@qwen-code/sdk';
 
try {
  // ... query operations
} catch (error) {
  if (isAbortError(error)) {
    // Handle abort
  } else {
    // Handle other errors
  }
}