DeepSeek Harness: 防御的プログラミングとインシデントレビュー

// ❌ API Key のハードコード
const apiKey = 'sk-abc123def456'

// ❌ API Key をログに書き込む
ctx.logger.info(`connecting with key：${apiKey}`)

// ❌ API Key を URL に含める
const url = `https：//api.example.com?key=${apiKey}`

// ❌ API Key をエラーメッセージに含める
throw new Error(`Authentication failed for key：${apiKey}`)

// ✅ 設定から読み取り
export const Config = Schema.object({
  apiKey：Schema.string().required().hidden()
})

export function apply(ctx：Context) {
  const apiKey = ctx.config.apiKey
}

// ✅ 環境変数を使用
const apiKey = process.env.MY_PLUGIN_API_KEY

// ✅ リクエストヘッダーで渡す（URL には含めない）
const response = await fetch(url, {
  headers：{ 'Authorization'：`Bearer ${apiKey}` }
})

// ✅ ログで機密情報を隠す
ctx.logger.info(`connecting to ${endpoint}`)

// ✅ カスタムログフィルタ
function sanitize(obj：any)：any {
  const sanitized = { ...obj }
  if (sanitized.apiKey) sanitized.apiKey = '***'
  if (sanitized.authorization) sanitized.authorization = '***'
  return sanitized
}

ctx.logger.info('request：', sanitize(request))

export const Config = Schema.object({
  apiKey：Schema.string().required().hidden(),
  keyRotationDays：Schema.number().default(90)
})

export function apply(ctx：Context) {
  ctx.setInterval(() => {
    const age = getKeyAge()
    if (age > ctx.config.keyRotationDays * 86400000) {
      ctx.logger.warn('API key is overdue for rotation')
    }
  }, 86400000)
}

// ❌ ツール結果をバリデーションしない
async execute({ path }, ctx) {
  const result = await ctx.shell.execute(`ls ${path}`)
  return result.stdout
}

// ✅ ツール結果をバリデーション
async execute({ path }, ctx) {
  const result = await ctx.shell.execute(`ls ${path}`)
  
  if (result.exitCode !== 0) {
    return {
      error：true,
      message：`ls failed：${result.stderr}`,
      exitCode：result.exitCode
    }
  }
  
  if (!result.stdout || result.stdout.trim().length === 0) {
    return {
      error：true,
      message：'Directory is empty or does not exist'
    }
  }
  
  const files = result.stdout.trim().split('\n')
  return { count：files.length, files }
}

// ❌ API レスポンスをバリデーションしない
const data = await response.json()
return data.result

// ✅ API レスポンスをバリデーション
async function callAPI(ctx：Context, endpoint：string)：Promise<any> {
  const response = await fetch(endpoint)
  
  if (!response.ok) {
    throw new Error(`API error：${response.status} ${response.statusText}`)
  }
  
  let data：any
  try {
    data = await response.json()
  } catch {
    throw new Error('API returned invalid JSON')
  }
  
  if (!data || typeof data !== 'object') {
    throw new Error('API returned unexpected format')
  }
  
  return data
}

// ❌ ユーザー入力をバリデーションしない
async execute({ command }, ctx) {
  return await ctx.shell.execute(command)
}

// ✅ 入力をバリデーション・サニタイズ
async execute({ command }, ctx) {
  if (!command || typeof command !== 'string') {
    return { error：true, message：'Invalid command' }
  }
  
  if (command.length > 1000) {
    return { error：true, message：'Command too long' }
  }
  
  const allowed = ['ls', 'cat', 'grep', 'wc', 'head', 'tail']
  const baseCommand = command.split(' ')[0]
  if (!allowed.includes(baseCommand)) {
    return { error：true, message：`Command not allowed：${baseCommand}` }
  }
  
  return await ctx.shell.execute(command)
}

export function apply(ctx：Context) {
  const resources：{ close：() => void | Promise<void> }[] = []

  function acquireResource<T extends { close：() => void | Promise<void> }>(
    resource：T
  )：T {
    resources.push(resource)
    return resource
  }

  ctx.effect(() => {
    return async () => {
      for (const r of resources.reverse()) {
        try {
          await r.close()
        } catch (e) {
          ctx.logger.warn('cleanup error：', e)
        }
      }
    }
  })

  const db = acquireResource(openDatabase())
  const ws = acquireResource(new WebSocket('ws：//localhost：8080'))
}

export function apply(ctx：Context) {
  const tempFiles：string[] = []

  ctx.effect(() => {
    return async () => {
      for (const file of tempFiles.reverse()) {
        try {
          await ctx.fs.unlink(file)
        } catch {}
      }
    }
  })

  async function createTempFile(content：string)：Promise<string> {
    const path = `/tmp/dsh-${Date.now()}-${Math.random().toString(36).slice(2)}`
    await ctx.fs.writeFile(path, content)
    tempFiles.push(path)
    return path
  }
}

原則1：副作用を最小限に
  → 必要な操作のみ実行
  → 読取専用を優先、次に冪等書込

原則2：副作用は可逆に
  → 書込前に元の状態を保存
  → アンドゥ操作を提供

原則3：副作用は監査可能に
  → 各副作用の詳細を記録
  → ユーザーが操作履歴を確認可能

原則4：副作用には承認が必要
  → 破壊的操作には承認が必須
  → 非冪等操作には承認を推奨

interface ReversibleAction {
  execute()：Promise<void>
  rollback()：Promise<void>
}

class FileEditAction implements ReversibleAction {
  private originalContent：string | null = null

  constructor(
    private path：string,
    private newContent：string,
    private ctx：Context
  ) {}

  async execute() {
    try {
      this.originalContent = await this.ctx.fs.readFile(this.path)
    } catch {
      this.originalContent = null
    }
    await this.ctx.fs.writeFile(this.path, this.newContent)
  }

  async rollback() {
    if (this.originalContent !== null) {
      await this.ctx.fs.writeFile(this.path, this.originalContent)
    } else {
      await this.ctx.fs.unlink(this.path)
    }
  }
}

const auditLog：AuditEntry[] = []

function audit(action：string, details：any, reversible：boolean) {
  auditLog.push({
    timestamp：Date.now(),
    action,
    details,
    reversible,
    user：'agent'
  })
  ctx.emit('audit/action', { action, details, reversible })
}

audit('file_edit', { path：'src/app.ts', operation：'edit' }, true)
audit('email_send', { to：'alice@example.com' }, false)

# Incident Review：[タイトル]

## 基本信息
- Date：YYYY-MM-DD
- Impact：[影響を受けた機能/ユーザー]
- Severity：P0/P1/P2
- Handler：[名前]

## タイムライン
- HH：MM — [イベント1]
- HH：MM — [イベント2]
- HH：MM — [修正]

## 根因分析
[5 Whys 分析]

## 修正対応
- 短期：[即時修正]
- 長期：[予防策]

## 教訓
- [教訓1]
- [教訓2]

インシデント：Agent がユーザーのプロジェクトファイルを削除

Why 1：Agent が rm -rf /project を実行
  → ツールにパスバリデーションがなかったから

Why 2：ツールにパスバリデーションがなかった
  → 開発者がホワイトリストチェックを実装しなかったから

Why 3：開発者がホワイトリストチェックを実装しなかった
  → セキュリティレビュープロセスがなかったから

Why 4：セキュリティレビュープロセスがなかった
  → チームにセキュリティチェックリストが確立されていなかったから

Why 5：セキュリティチェックリストが確立されていなかった
  → セキュリティ意識の教育が不足していたから

修正：セキュリティ監査チェックリストを確立；全プラグインは公開前にチェック必須

# セキュリティ監査を実行
dsh audit my-plugin

# 出力
🔒 Security Audit：my-plugin

✅ No hardcoded credentials
✅ All ctx.effect() have cleanup functions
⚠️ Tool 'db_query' has no input validation
❌ API response not validated in 'fetch_data'
✅ Approval policy configured for destructive operations
⚠️ Permission 'shell.execute' may not be necessary

2 errors, 2 warnings found. Fix before publishing.