Claude Code
In your code

import { Claude, EVENT_TEXT } from '@scottwalker/claude-connector'

const claude = new Claude({ model: 'sonnet' })
await claude.init()

// Ask anything, get answers instantly
const result = await claude.query('Find and fix all bugs in auth.ts')
console.log(result.text)

// Or stream the response in real time
await claude.stream('Find bugs')
  .on(EVENT_TEXT, t => process.stdout.write(t))
  .done()

import { Claude, EVENT_TEXT, EVENT_TOOL_USE, EVENT_RESULT } from '@scottwalker/claude-connector'

// Fluent API — register callbacks, await completion
const result = await claude.stream('Refactor the auth module')
  .on(EVENT_TEXT, t => process.stdout.write(t))
  .on(EVENT_TOOL_USE, e => console.log(`[tool: ${e.toolName}]`))
  .done()

console.log(`Done in ${result.durationMs}ms`)

// Or collect all text at once
const text = await claude.stream('Summarize').text()

// Or pipe to stdout
await claude.stream('Explain').pipe(process.stdout)

import { Claude, EVENT_TEXT, EVENT_TOOL_USE, EVENT_RESULT } from '@scottwalker/claude-connector'

// for-await works too — full control over each event
for await (const event of claude.stream('Analyze this project')) {
  switch (event.type) {
    case EVENT_TEXT:
      process.stdout.write(event.text)
      break
    case EVENT_TOOL_USE:
      console.log(`[tool: ${event.toolName}]`)
      break
    case EVENT_RESULT:
      console.log(`Tokens: ${event.usage.inputTokens}in / ${event.usage.outputTokens}out`)
      break
  }
}

import { Claude, EVENT_TEXT } from '@scottwalker/claude-connector'

const chat = claude.chat()
  .on(EVENT_TEXT, t => process.stdout.write(t))

const r1 = await chat.send('What files are in src/?')
console.log(`\n[${r1.durationMs}ms]`)

const r2 = await chat.send('Refactor the largest file')
console.log(`\n[${r2.durationMs}ms]`)

chat.end()  // graceful close

import { pipeline } from 'node:stream/promises'
import { createReadStream, createWriteStream } from 'node:fs'

// Full Node.js Duplex — write prompts in, read text out
const duplex = claude.chat().toDuplex()

await pipeline(
  createReadStream('prompts.txt'),  // one prompt per line
  duplex,
  createWriteStream('responses.txt'),
)

import { WebSocketServer } from 'ws'
import { Claude, EVENT_TEXT, EVENT_RESULT } from '@scottwalker/claude-connector'

wss.on('connection', (ws) => {
  const chat = claude.chat()
    .on(EVENT_TEXT, t => ws.send(JSON.stringify({ type: 'text', t })))
    .on(EVENT_RESULT, r => ws.send(JSON.stringify({ type: 'done', usage: r.usage })))

  ws.on('message', async (data) => {
    await chat.send(JSON.parse(data).prompt)
  })
  ws.on('close', () => chat.end())
})

import { Claude, PERMISSION_PLAN } from '@scottwalker/claude-connector'

// Only allow reading and searching — no edits, no bash
const claude = new Claude({
  allowedTools: ['Read', 'Glob', 'Grep'],
  permissionMode: PERMISSION_PLAN,
})

// Allow Bash but only for specific commands
const claude = new Claude({
  allowedTools: [
    'Read', 'Edit', 'Write',
    'Bash(npm run *)',       // only npm scripts
    'Bash(git status)',      // only git status
    'Bash(npx prettier *)',  // only prettier
  ],
})

import { Claude, PERMISSION_ACCEPT_EDITS } from '@scottwalker/claude-connector'

// Allow everything except web access and file deletion
const claude = new Claude({
  disallowedTools: ['WebFetch', 'WebSearch'],
  permissionMode: PERMISSION_ACCEPT_EDITS,
})

import { readFileSync } from 'node:fs'

// Attach an image for analysis
const screenshot = readFileSync('./bug-screenshot.png', 'base64')
const result = await claude.query('What bug do you see in this screenshot?', {
  input: screenshot,
})

// Attach error logs
const logs = readFileSync('./error.log', 'utf-8')
const result = await claude.query('Analyze these errors and suggest fixes', {
  input: logs,
})

// Attach any document — configs, CSVs, JSON, etc.
const config = readFileSync('./docker-compose.yml', 'utf-8')
const result = await claude.query('Review this config for security issues', {
  input: config,
})