import amagi from '@ikenxuan/amagi'

const client = amagi({ cookies: { douyin: 'ttwid=...' } })

// 一次逻辑调用成功：data 是信封里的 data，其余信息全在 meta 上
client.events.on('api:success', (d) => {
  console.log(`[${d.meta.platform}] ${d.meta.endpoint} 成功，耗时 ${d.meta.durationMs}ms`)
})

// 失败：error 是标准 AmagiError（kind / code / message / platform 原文码）
client.on('api:error', (d) => {
  console.error(`[${d.meta.platform}] ${d.meta.endpoint} 失败：${d.error.kind} ${d.error.message}`)
})

// once 只触发一次
client.once('log:mark', (d) => console.log(d.message))

import amagi, { AMAGI_BUS_EVENT_NAMES } from '@ikenxuan/amagi'

const client = amagi({})

// 15 个名字的只读元组，类型是 AmagiBusEventName
for (const name of AMAGI_BUS_EVENT_NAMES) {
  client.events.on(name, (payload) => {
    console.log(name, payload.meta?.requestId)
  })
}

import amagi from '@ikenxuan/amagi'

const client = amagi({ cookies: { bilibili: '' } })
const byRequest = new Map<string, number>()

client.events.on('http:request', (d) => {
  byRequest.set(d.meta.requestId, (byRequest.get(d.meta.requestId) ?? 0) + 1)
  console.log(d.trace.reason, d.trace.method, d.trace.url)
})

client.events.on('api:success', (d) => {
  // 这两个数一定相等：meta.attempts 就是这次调用发出的请求数
  console.log(d.meta.requestId, d.meta.attempts, byRequest.get(d.meta.requestId))
})

import amagi from '@ikenxuan/amagi'

const client = amagi({})

client.events.on('log:warn', (d) => console.warn(`[WARN] ${d.message}`, ...(d.args ?? [])))
client.events.on('log:error', (d) => console.error(`[ERROR] ${d.message}`, ...(d.args ?? [])))
client.events.on('log:mark', (d) => console.log(`[MARK] ${d.message}`))

import amagi, { type EventBus } from '@ikenxuan/amagi'
import pino from 'pino'

const logger = pino()

const attachPino = (bus: EventBus): void => {
  bus.on('log:warn', (d) => logger.warn({ endpoint: d.meta?.endpoint }, d.message))
  bus.on('log:error', (d) => logger.error({ requestId: d.meta?.requestId }, d.message))
  bus.on('api:error', (d) => logger.error({ ...d.meta, kind: d.error.kind }, d.error.message))
}

attachPino(amagi({}).events)

import amagi from '@ikenxuan/amagi'
import winston from 'winston'

const logger = winston.createLogger({
  transports: [new winston.transports.Console()]
})

const client = amagi({})
client.events.on('log:warn', (d) => logger.warn(d.message))
client.events.on('log:error', (d) => logger.error(d.message))
client.events.on('api:error', (d) => logger.error(`${d.meta.endpoint}: ${d.error.message}`))

import amagi from '@ikenxuan/amagi'

const client = amagi({ cookies: { douyin: '' } })

client.events.on('network:retry', (d) => {
  console.warn(`第 ${d.attempt}/${d.maxRetries} 次重试，${d.delayMs}ms 后重发：${d.code} ${d.errno ?? d.status}`)
})

client.events.on('network:error', (d) => {
  console.error(`放弃：${d.message}（共发了 ${d.attempts} 次，最后一条 ${d.trace.url}）`)
})

client.events.on('http:error', (d) => {
  console.error(`HTTP ${d.status}：${d.trace.url}`)
})

import amagi from '@ikenxuan/amagi'

const client = amagi({ cookies: { bilibili: '' } })

// state.phase：pending → scanned → challenge → success，终止态 expired / rejected / risk / failed
client.events.on('session:state', (d) => console.log(d.meta.endpoint, d.state.phase))
client.events.on('session:success', (d) => console.log(d.credential.cookie))
client.events.on('session:error', (d) => console.error(d.error.code, d.error.message))

import amagi, { type AmagiBusEventMap } from '@ikenxuan/amagi'

const client = amagi({})

const onSuccess = (d: AmagiBusEventMap['api:success']): void => {
  console.log(d.meta.endpoint)
}

client.events.on('api:success', onSuccess)
console.log(client.events.listenerCount('api:success'))

client.events.off('api:success', onSuccess)
client.events.removeAllListeners('api:success')

import amagi from '@ikenxuan/amagi'

const client = amagi({ cookies: { douyin: '' } })
const stats = { success: 0, error: 0, totalMs: 0 }

client.events.on('api:success', (d) => {
  stats.success++
  stats.totalMs += d.meta.durationMs
})

client.events.on('api:error', (d) => {
  stats.error++
  console.error(`✗ [${d.meta.platform}] ${d.meta.endpoint} - ${d.error.message}`)
})

setInterval(() => {
  const avg = stats.success > 0 ? stats.totalMs / stats.success : 0
  console.log(`成功 ${stats.success}，失败 ${stats.error}，平均耗时 ${avg.toFixed(2)}ms`)
}, 60000)

import amagi, { amagiEvents } from '@ikenxuan/amagi'

// v6 负载：顶层平铺 + timestamp，没有 meta
amagiEvents.on('network:retry', (data) => {
  console.warn(data.errorCode, data.attempt, data.timestamp.toISOString())
})

// 构造函数上的静态面就是这条总线（不是实例总线）
amagi.on('log:warn', (data) => console.warn(data.message, data.timestamp))