import { FetchOptions, FetchResult, SimpleAdapter } from '../../adapters/types'
import { CHAIN } from '../../helpers/chains'

const OPINION_EXCHANGE_CONTRACT = '0x5F45344126D6488025B0b84A3A8189F2487a7246'
const OPINION_FEE_MANAGER_CONTRACT = '0xC9063Dc52dEEfb518E5b6634A6b8D624bc5d7c36'
const ORDER_FILLED_EVENT = 'event OrderFilled (bytes32 indexed orderHash,  address indexed maker,address indexed taker, uint256 makerAssetId, uint256 takerAssetId, uint256 makerAmountFilled, uint256 takerAmountFilled, uint256 fee)'
const REBATE_EARNED_EVENT = 'event RebateEarned (address indexed referrer, address indexed trader, address indexed collateralToken, uint256 amount)'

/**
 * WASH TRADING BLACKLIST
 *
 * Confirmed wash trading wallets identified through on-chain analysis.
 *
 * Detection criteria:
 * - ≤2 counterparties with >95% concentration
 * - >80% offsetting positions (betting both YES and NO) with significant volume
 * - Part of circular trading clusters
 * - Wash score ≥95 based on offsetting % and counterparty concentration
 *
 * Analysis dates: Jan 14-15, 19, 22, 24, 2026
 * These are Gnosis Safe "funder" addresses used on Opinion Protocol.
 */
const WASH_TRADING_BLACKLIST = new Set(
  [
    // === Original cluster (identified Oct-Nov 2025) ===
    '0xd006482147f77970ef07a91cd84b532433d57400', // $54.7M - Hub wallet
    '0xc23395fc42ba0b79c89f2ab942fcd73deeb355f2', // $21.7M - 85% volume with hub
    '0xb76ba8797850b2cc2aa3ad7299a008573f28cb9d', // $19.0M - 84% volume with hub
    '0x418a3003b9a3e481e2866336fca3007d9474827c', // $10.1M - 99% volume with hub
    '0x6c3326f52f5a251b5504099242a9cdbcc3ab87e7', // $9.4M - 99% volume with hub

    // === New confirmed wash traders (Jan 2026 analysis) ===
    // High volume wash traders ($5M+)
    '0x72ffa4098788ab41c78da0ed04b4a3eaa4ff9e3d', // $30.2M - 100% offsetting, score 100
    '0x0a7300dbc3fcef290601793bf4395ea0fd38f35c', // $18.7M - 100% offsetting, score 100
    '0x44df52c5c8ffb86da6044b81577f0dd537dec07f', // $5.0M - only 2 CPs, 100% concentration
    '0x015e2b259233ac5c805b14703ef2144dedfc8b01', // $5.0M - only 2 CPs, 82% concentration

    // Medium-high volume wash traders ($1M-$5M)
    // '0xfe5d02c0dcb5f7ee642713628be52e6f4de9f08e', // $4.1M - 100% offsetting, score 100
    // '0xe9209e46699190d99215f1697381ce637925cac3', // $4.0M - 100% offsetting, only 1-7 CPs
    // '0xb850edbc7dc207f7fe6aecb9be06e0e4d7bc69ac', // $4.0M - 100% offsetting, only 1-2 CPs
    // '0x0f61a1f7717b51fd13cc76de9092e5209808b91c', // $3.2M - 99% offsetting
    // '0x608601662152b9c37708b610a4be5d1a15567e78', // $3.1M - score 100
    // '0xf4852d5bc219c31386e36a836d82439f61160c82', // $3.1M - score 100
    // '0x0dcb08000fb624bb64aca0015cbd9b2307dc46fd', // $2.1M - score 100
    // '0xc2823f06eb7536f23c4ff9be799058a204ce4add', // $2.1M - score 100
    // '0x686fa7c3b7ca92d98a00f58b46066c51d802dafb', // $1.7M - score 100
    // '0x0a9e71ecece618a920a883a0858d9d983810758d', // $1.6M - 98% offsetting, only 2 CPs
    // '0xd7c2d443a4fde099f9423b5962270bbe333c9558', // $1.6M - 100% offsetting, only 2 CPs
    // '0x127ff13f0b5b1070a36fa30b083b4644016ad30f', // $1.6M - score 40 but only 1 CP
    // '0xec78b801a379daf065b2e946e8aa352a70511153', // $1.4M - only 1 CP, 100% concentration
    // '0x0b8bb27fd7dac838df100f8270b3c35dd270360c', // $1.4M - only 1 CP, 100% concentration
    // '0xe225ea7da5d13deacd308c37b7e2d3c5c87e44db', // $1.2M - 99% offsetting
    // '0xf9085026722167af624c82f4a51190212f1358ec', // $1.1M - score 100
    // '0xc1d70151b25b8831d38bc0b2c5717e6d7079e522', // $1.0M - only 2 CPs, 100% concentration
    // '0xfa679b1ec37f5c61711a540a25e43153b1dfda57', // $1.0M - 94% offsetting, score 97
    // '0x6fcc720d5538d848117469ee17011eb25ba3373d', // $1.0M - 97% offsetting, score 98
  ].map((addr) => addr.toLowerCase())
)

// fees = trade fees - rebate fees
async function fetch(options: FetchOptions): Promise<FetchResult> {
  const dailyVolume = options.createBalances()
  const tradeFees = options.createBalances()
  const rebateFees = options.createBalances()
  const dailyNotionalVolume = options.createBalances()

  const orderFilledLogs = await options.getLogs({
    eventAbi: ORDER_FILLED_EVENT,
    target: OPINION_EXCHANGE_CONTRACT,
  })

  const rebateEarnedLogs = await options.getLogs({
    eventAbi: REBATE_EARNED_EVENT,
    target: OPINION_FEE_MANAGER_CONTRACT,
  })

  orderFilledLogs.forEach((order: any) => {
    tradeFees.addUSDValue(Number(order.fee) / 1e18)

    const maker = (order.maker || '').toString().toLowerCase()
    const taker = (order.taker || '').toString().toLowerCase()

    if (WASH_TRADING_BLACKLIST.has(maker) || WASH_TRADING_BLACKLIST.has(taker)) {
      return
    }

    const tradeVolume = Number(order.makerAssetId == 0 ? order.makerAmountFilled : order.takerAmountFilled) / 1e18
    const notionalVolume = Number(order.makerAssetId == 0 ? order.takerAmountFilled : order.makerAmountFilled) / 1e18
    dailyVolume.addUSDValue(Number(tradeVolume) / 2)
    dailyNotionalVolume.addUSDValue(notionalVolume / 2)
  })

  rebateEarnedLogs.forEach((log: any) => {
    rebateFees.addUSDValue(Number(log.amount) / 1e18)
  })


  // Gross taker fees are the fees users pay; rebates are a distribution out of them, not a discount.
  const dailyFees = tradeFees
  const dailySupplySideRevenue = rebateFees
  const dailyRevenue = tradeFees.clone(1)
  dailyRevenue.subtract(rebateFees)

  return {
    dailyVolume,
    dailyFees,
    dailyUserFees: dailyFees,
    dailyRevenue,
    dailyProtocolRevenue: dailyRevenue,
    dailySupplySideRevenue,
    dailyNotionalVolume,
  }
}

const methodology = {
  Volume: 'Total value traded on Opinion prediction markets each day, and excluding wallets identified as wash trading.',
  Fees: 'Fees charged to traders when they fill an order. Only the side taking the trade pays a fee.',
  UserFees: 'Same as Fees — the fees traders pay.',
  Revenue: 'The fees Opinion keeps after paying out referral rebates.',
  ProtocolRevenue: 'Same as Revenue — the net fees go to the protocol.',
  SupplySideRevenue: 'Rebates paid out to referrers for bringing in trades.',
}

const adapter: SimpleAdapter = {
  version: 2,
  pullHourly: true,
  fetch,
  methodology,
  allowNegativeValue: true,  // Fees can be negative if rebate fees exceed trade fees in a given hour
  chains: [CHAIN.BSC],
  start: '2025-10-22',
}

export default adapter