DeepSeek Harness: イベントシステム

// イベント発行
ctx.emit('session/created', { id: 'abc-123', user: 'Alice' })

// イベントリッスン
ctx.on('session/created', (data) => {
  ctx.logger.info(`new session: ${data.id}`)
})

ctx.on('session/created', (data) => {
  ctx.logger.info(`logger: ${data.id}`)
})

ctx.on('session/created', (data) => {
  ctx.metrics.inc('session_count')
})

ctx.on('session/created', (data) => {
  ctx.cache.set(`session:${data.id}`, data)
})

ctx.emit('session/created', { id: 'abc', user: 'Alice' })
// 3つのリスナーがすべて実行

// リスナーがイベントを「インターセプト」可能
ctx.on('tool/beforeExecute', (data) => {
  if (data.tool === 'shell' && data.params.command.includes('rm')) {
    return { denied: true, reason: 'dangerous command' }
  }
})

ctx.bail('tool/beforeExecute', { tool: 'shell', params: { command: 'rm -rf /' } })
// → { denied: true, reason: 'dangerous command' } を返す
// 後続リスナーは実行されない

// 承認ポリシープラグイン
ctx.on('tool/beforeExecute', (data) => {
  const policy = getApprovalPolicy(data.tool)
  if (policy === 'deny') {
    return { denied: true, reason: `${data.tool} is denied by policy` }
  }
  if (policy === 'ask') {
    return { pending: true, requiresApproval: true }
  }
  // undefined を返す → インターセプトせず、伝播を継続
})

// サンドボックスプラグイン（承認の後）
ctx.on('tool/beforeExecute', (data) => {
  if (!isInSandbox(data.params.cwd)) {
    return { denied: true, reason: 'execution outside sandbox' }
  }
})

const result = ctx.bail('tool/beforeExecute', data)
if (result) {
  // インターセプトされた
  ctx.logger.warn('tool execution denied:', result.reason)
} else {
  // インターセプトされていない、実行可能
  await executeTool(data)
}

ctx.on('session/initialized', async (data) => {
  await loadUserPreferences(data.userId)
})

ctx.on('session/initialized', async (data) => {
  await setupWorkspace(data.workspaceId)
})

ctx.on('session/initialized', async (data) => {
  await warmCache(data.projectPath)
})

// 3つのリスナーが順次実行
await ctx.serial('session/initialized', { userId: 'alice', workspaceId: 'ws-1' })

// emit：並列（待機しない）
ctx.emit('session/created', data)   // リスナーの完了を待機しない

// serial：順次（待機する）
await ctx.serial('session/created', data)  // 全リスナーの完了を待機

ctx.on('message/format', async (data, next) => {
  data.text = data.text.trim()
  return next(data)
})

ctx.on('message/format', async (data, next) => {
  data.text = data.text.replace(/\s+/g, ' ')
  return next(data)
})

ctx.on('message/format', async (data, next) => {
  data.text = data.text.substring(0, 4096)
  return next(data)
})

const result = await ctx.waterfall('message/format', { text: '  hello   world  ' })
// result.text === 'hello world' （trim → 空白統合 → 切り詰め）

ctx.on('event/name', async (data, next) => {
  // データを変更
  data.field = newValue
  
  // next を呼んで次のリスナーに渡す
  return next(data)
  
  // next を呼ばない → チェーン中断、データは先に渡されない
})

ctx.on('request/process', async (data, next) => {
  if (!data.authenticated) {
    return { error: 'unauthenticated' }  // next を呼ばない、チェーン中断
  }
  return next(data)
})

session/created        → セッションドメイン
session/destroyed      → セッションドメイン
tool/beforeExecute     → ツールドメイン（capability サブドメイン）
tool/afterExecute      → ツールドメイン
agent/initialized      → エージェントドメイン
llm/request            → LLM ドメイン

// ツールドメインのすべてのイベントをサブスクライブ
ctx.on('tool/*', (eventName, data) => {
  ctx.logger.info(`tool event: ${eventName}`)
})

// events.ts
interface MyPluginEvents {
  'my-plugin/data-loaded': { source: string; count: number }
  'my-plugin/data-error': { source: string; error: Error }
}

declare module '@deepseek-ai/cordis' {
  interface Events extends MyPluginEvents {}
}

ctx.emit('my-plugin/data-loaded', { source: 'api', count: 42 })  // ✅ 型正しい
ctx.emit('my-plugin/data-loaded', { wrong: true })                // ❌ 型エラー

ctx.on('my-plugin/data-loaded', (data) => {
  // data は自動的に { source: string; count: number } と推論
  ctx.logger.info(`loaded ${data.count} items from ${data.source}`)
})

// プラグイン内部イベント
interface InternalEvents {
  'cache/hit': { key: string; age: number }
  'cache/miss': { key: string }
  'cache/evicted': { key: string; reason: string }
}

// グローバル Events インターフェースを拡張
declare module '@deepseek-ai/cordis' {
  interface Events extends InternalEvents {}
}

// 他のプラグインが使用できるようエクスポート
export type CacheEvents = InternalEvents

{domain}/{verb-past-tense}    ✅ session/created
{domain}/{verb-present}       ✅ tool/execute （進行中）
{domain}/before{Action}       ✅ tool/beforeExecute （事前フック）
{domain}/after{Action}        ✅ tool/afterExecute （事後フック）
{domain}/{noun}-{state}       ✅ fiber/errored （状態）