From 0ec84b628389a19d78e8a6dc7e03627ef9418958 Mon Sep 17 00:00:00 2001 From: zajck Date: Thu, 13 Nov 2025 07:59:06 +0100 Subject: [PATCH 1/9] Calculate protocol fee --- fees/boson/index.ts | 53 +++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 53 insertions(+) create mode 100644 fees/boson/index.ts diff --git a/fees/boson/index.ts b/fees/boson/index.ts new file mode 100644 index 0000000000..2251230eac --- /dev/null +++ b/fees/boson/index.ts @@ -0,0 +1,53 @@ +import { Adapter, FetchOptions, FetchResultV2 } from "../../adapters/types"; +import { CHAIN } from "../../helpers/chains"; + +const ProtocolFeeCollectedEvent = + "event ProtocolFeeCollected(uint256 indexed exchangeId, address indexed exchangeToken, uint256 amount, address indexed executedBy)"; +const protocolFeeCollectedTopic = + "0x9399ed37d26489264206ddf87ad81aaa13557b4e56b5443503a2b64a24ec42db"; +const protocolDiamondAddress = "0x59A4C19b55193D5a2EAD0065c54af4d516E18Cb5"; + +async function getProtocolFees(options: FetchOptions): Promise { + const { getLogs, createBalances } = options; + const dailyFees = createBalances(); + + const logs = await getLogs({ + target: protocolDiamondAddress, + topics: [protocolFeeCollectedTopic], + eventAbi: ProtocolFeeCollectedEvent, + }); + + const encumberedByToken: Record = {}; + for (const log of logs) { + const token = log.exchangeToken; + const amount = BigInt(log.amount); + encumberedByToken[token] = (encumberedByToken[token] || 0n) + amount; + } + + for (const [token, amount] of Object.entries(encumberedByToken)) { + dailyFees.add(token, amount); + } + + return { + dailyFees, + dailyRevenue: dailyFees, + dailyProtocolRevenue: dailyFees, + }; +} + +const adapter: Adapter = { + fetch: getProtocolFees, + adapter: { + [CHAIN.POLYGON]: { start: "2022-10-12" }, + [CHAIN.ETHEREUM]: { start: "2023-09-29" }, + [CHAIN.BASE]: { start: "2025-01-31" }, + [CHAIN.ARBITRUM]: { start: "2025-04-01" }, + [CHAIN.OPTIMISM]: { start: "2025-03-10" }, + }, + version: 2, + methodology: { + Fees: "A fee is charged on every successful trade executed on the Boson Protocol.", + }, +}; + +export default adapter; From 0971424c5d3aed74115fb18e9eb42a465ea384d8 Mon Sep 17 00:00:00 2001 From: zajck Date: Thu, 13 Nov 2025 09:40:07 +0100 Subject: [PATCH 2/9] rename `encumberedByToken` -> `collectedByToken` --- fees/boson/index.ts | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/fees/boson/index.ts b/fees/boson/index.ts index 2251230eac..252b93c632 100644 --- a/fees/boson/index.ts +++ b/fees/boson/index.ts @@ -17,14 +17,14 @@ async function getProtocolFees(options: FetchOptions): Promise { eventAbi: ProtocolFeeCollectedEvent, }); - const encumberedByToken: Record = {}; + const collectedByToken: Record = {}; for (const log of logs) { const token = log.exchangeToken; const amount = BigInt(log.amount); - encumberedByToken[token] = (encumberedByToken[token] || 0n) + amount; + collectedByToken[token] = (collectedByToken[token] || 0n) + amount; } - for (const [token, amount] of Object.entries(encumberedByToken)) { + for (const [token, amount] of Object.entries(collectedByToken)) { dailyFees.add(token, amount); } From 7b392634a98ebb09180e4bc82aeeccdf4f8134a5 Mon Sep 17 00:00:00 2001 From: zajck Date: Thu, 13 Nov 2025 09:40:21 +0100 Subject: [PATCH 3/9] Daily volume calculation --- dexs/boson/constants.ts | 37 ++++++++++++++ dexs/boson/index.ts | 42 ++++++++++++++++ dexs/boson/utils.ts | 108 ++++++++++++++++++++++++++++++++++++++++ 3 files changed, 187 insertions(+) create mode 100644 dexs/boson/constants.ts create mode 100644 dexs/boson/index.ts create mode 100644 dexs/boson/utils.ts diff --git a/dexs/boson/constants.ts b/dexs/boson/constants.ts new file mode 100644 index 0000000000..a89112f9e1 --- /dev/null +++ b/dexs/boson/constants.ts @@ -0,0 +1,37 @@ +export const protocolDiamondAddress = + "0x59A4C19b55193D5a2EAD0065c54af4d516E18Cb5"; + +/** Event topics **/ +export const fundsEncumberedTopic = + "0x8080d30eb13935d67dfdc606fa5e4170aa03ffdfaf40136ef3fa4355c88b19f9"; +export const offerCreatedTopic_v2_0_0 = + "0x845c99b8425be384387e239b85d44b6cdf63aab6c45c2534f799743e341c74f8"; +export const offerCreatedTopic_v2_3_0 = + "0xb6a507882e43ec6bae2f276ce4a839f1ca9dcf2da73095eea9e633e96ecf6eb2"; +export const offerCreatedTopic_v2_4_0 = + "0xa76af238b31b285c9397e2a7c55650ca18a1baf6504de15d7dd1321693144cf7"; +export const offerCreatedTopic_v2_5_0 = + "0x5235a4f9db2e479e7353e22e7629a4556897ddaf0ab4eaeb9bb8660c8e49a903"; +export const rangeReservedTopic = + "0xede05ffdb8c59f6f9e12923efcf03736da40cda9a4c5ba60ac2b6238b8b86a60"; + +/** Event definitions **/ +/** + * Some event changed over time, but kept their name, so we define multiple versions here + */ +export const OfferCreatedEvent_v2_0_0 = + "event OfferCreated(uint256 indexed offerId, uint256 indexed sellerId, (uint256 id, uint256 sellerId, uint256 price, uint256 sellerDeposit, uint256 buyerCancelPenalty, uint256 quantityAvailable, address exchangeToken, string metadataUri, string metadataHash, bool voided) offer, (uint256 validFrom, uint256 validUntil, uint256 voucherRedeemableFrom, uint256 voucherRedeemableUntil) offerDates, (uint256 disputePeriod, uint256 voucherValid, uint256 resolutionPeriod) offerDurations, (uint256 disputeResolverId, uint256 escalationResponsePeriod, uint256 feeAmount, uint256 buyerEscalationDeposit) disputeResolutionTerms, (uint256 protocolFee, uint256 agentFee) offerFees, uint256 indexed agentId, address executedBy)"; +export const OfferCreatedEvent_v2_3_0 = + "event OfferCreated(uint256 indexed offerId, uint256 indexed sellerId, (uint256 id, uint256 sellerId, uint256 price, uint256 sellerDeposit, uint256 buyerCancelPenalty, uint256 quantityAvailable, address exchangeToken, string metadataUri, string metadataHash, bool voided, uint256 collectionIndex) offer, (uint256 validFrom, uint256 validUntil, uint256 voucherRedeemableFrom, uint256 voucherRedeemableUntil) offerDates, (uint256 disputePeriod, uint256 voucherValid, uint256 resolutionPeriod) offerDurations, (uint256 disputeResolverId, uint256 escalationResponsePeriod, uint256 feeAmount, uint256 buyerEscalationDeposit) disputeResolutionTerms, (uint256 protocolFee, uint256 agentFee) offerFees, uint256 indexed agentId, address executedBy)"; +export const OfferCreatedEvent_v2_4_0 = + "event OfferCreated(uint256 indexed offerId, uint256 indexed sellerId, (uint256 id, uint256 sellerId, uint256 price, uint256 sellerDeposit, uint256 buyerCancelPenalty, uint256 quantityAvailable, address exchangeToken, uint8 priceType, string metadataUri, string metadataHash, bool voided, uint256 collectionIndex, (address[] recipients, uint256[] bps)[] royaltyInfo) offer, (uint256 validFrom, uint256 validUntil, uint256 voucherRedeemableFrom, uint256 voucherRedeemableUntil) offerDates, (uint256 disputePeriod, uint256 voucherValid, uint256 resolutionPeriod) offerDurations, (uint256 disputeResolverId, uint256 escalationResponsePeriod, uint256 feeAmount, uint256 buyerEscalationDeposit) disputeResolutionTerms, (uint256 protocolFee, uint256 agentFee) offerFees, uint256 indexed agentId, address executedBy)"; +export const OfferCreatedEvent_v2_5_0 = + "event OfferCreated(uint256 indexed offerId, uint256 indexed sellerId, (uint256 id, uint256 sellerId, uint256 price, uint256 sellerDeposit, uint256 buyerCancelPenalty, uint256 quantityAvailable, address exchangeToken, uint8 priceType, uint8 creator, string metadataUri, string metadataHash, bool voided, uint256 collectionIndex, (address[] recipients, uint256[] bps)[] royaltyInfo, uint256 buyerId) offer, (uint256 validFrom, uint256 validUntil, uint256 voucherRedeemableFrom, uint256 voucherRedeemableUntil) offerDates, (uint256 disputePeriod, uint256 voucherValid, uint256 resolutionPeriod) offerDurations, (uint256 disputeResolverId, uint256 escalationResponsePeriod, uint256 feeAmount, uint256 buyerEscalationDeposit, address mutualizerAddress) disputeResolutionTerms, (uint256 protocolFee, uint256 agentFee) offerFees, uint256 indexed agentId, address executedBy)"; +export const RangeReservedEvent = + "event RangeReserved(uint256 indexed offerId, uint256 indexed sellerId, uint256 startExchangeId, uint256 endExchangeId, address owner, address indexed executedBy)"; +export const FundsEncumberedEvent = + "event FundsEncumbered(uint256 indexed entityId, address indexed exchangeToken, uint256 amount, address indexed executedBy)"; + +/** Contract Methods */ +export const getOffer_v2_5_0 = + "function getOffer(uint256 _offerId) view returns (bool exists, (uint256 id, uint256 sellerId, uint256 price, uint256 sellerDeposit, uint256 buyerCancelPenalty, uint256 quantityAvailable, address exchangeToken, uint8 priceType, uint8 creator, string metadataUri, string metadataHash, bool voided, uint256 collectionIndex, (address[] recipients, uint256[] bps)[] royaltyInfo, uint256 buyerId) offer, (uint256 validFrom, uint256 validUntil, uint256 voucherRedeemableFrom, uint256 voucherRedeemableUntil) offerDates, (uint256 disputePeriod, uint256 voucherValid, uint256 resolutionPeriod) offerDurations, (uint256 disputeResolverId, uint256 escalationResponsePeriod, uint256 feeAmount, uint256 buyerEscalationDeposit, address mutualizerAddress) disputeResolutionTerms, (uint256 protocolFee, uint256 agentFee) offerFees)"; diff --git a/dexs/boson/index.ts b/dexs/boson/index.ts new file mode 100644 index 0000000000..6f9a5232d7 --- /dev/null +++ b/dexs/boson/index.ts @@ -0,0 +1,42 @@ +import { Adapter, FetchOptions, FetchResultV2 } from "../../adapters/types"; +import { CHAIN } from "../../helpers/chains"; +import { getEncumberedFunds, getNewOffers, getReservedRanges } from "./utils"; + +async function getProtocolVolume( + options: FetchOptions +): Promise { + const { createBalances } = options; + const dailyVolume = createBalances(); + + const volumeByToken: Record = {}; + + await getEncumberedFunds(options, volumeByToken); + await getNewOffers(options, volumeByToken); + await getReservedRanges(options, volumeByToken); + + for (const [token, amount] of Object.entries(volumeByToken)) { + dailyVolume.add(token, amount); + } + + return { + dailyVolume, + }; +} + +const adapter: Adapter = { + fetch: getProtocolVolume, + adapter: { + [CHAIN.POLYGON]: { start: "2022-10-12" }, + [CHAIN.ETHEREUM]: { start: "2023-09-29" }, + [CHAIN.BASE]: { start: "2025-01-31" }, + [CHAIN.ARBITRUM]: { start: "2025-04-01" }, + [CHAIN.OPTIMISM]: { start: "2025-03-10" }, + }, + version: 2, + methodology: { + Volume: + "Sum of funds encumbered in exchanges and total value of newly created offers on the Boson Protocol.", + }, +}; + +export default adapter; diff --git a/dexs/boson/utils.ts b/dexs/boson/utils.ts new file mode 100644 index 0000000000..845d1da75e --- /dev/null +++ b/dexs/boson/utils.ts @@ -0,0 +1,108 @@ +import { ethers, MaxUint256 } from "ethers"; +import { FetchOptions } from "../../adapters/types"; + +import { + protocolDiamondAddress, + fundsEncumberedTopic, + offerCreatedTopic_v2_0_0, + offerCreatedTopic_v2_3_0, + offerCreatedTopic_v2_4_0, + offerCreatedTopic_v2_5_0, + rangeReservedTopic, + OfferCreatedEvent_v2_0_0, + OfferCreatedEvent_v2_3_0, + OfferCreatedEvent_v2_4_0, + OfferCreatedEvent_v2_5_0, + RangeReservedEvent, + FundsEncumberedEvent, + getOffer_v2_5_0, +} from "./constants"; + +export async function getNewOffers( + { getLogs }: FetchOptions, + volumeByToken: Record +) { + const response = await getLogs({ + target: protocolDiamondAddress, + topics: [ + [ + offerCreatedTopic_v2_0_0, + offerCreatedTopic_v2_3_0, + offerCreatedTopic_v2_4_0, + offerCreatedTopic_v2_5_0, + ], + ], + }); + + // Combine all versions of the OfferCreated event + const iface = new ethers.Interface([ + OfferCreatedEvent_v2_0_0, + OfferCreatedEvent_v2_3_0, + OfferCreatedEvent_v2_4_0, + OfferCreatedEvent_v2_5_0, + ]); + + const offerLogs = response.map((log) => { + return iface.parseLog(log)?.args; + }); + + for (const offer of offerLogs) { + const quantityAvailable = BigInt(offer.offer.quantityAvailable); + if (quantityAvailable === MaxUint256) continue; // skip unlimited offers + + const price = BigInt(offer.offer.price); + const amount = quantityAvailable * price; + const token = offer.offer.exchangeToken; + volumeByToken[token] = (volumeByToken[token] || 0n) + amount; + } +} + +export async function getReservedRanges( + { getLogs, api }: FetchOptions, + volumeByToken: Record +) { + // only for unlimited offers, since they are not counted in getNewOffers + const logs = await getLogs({ + target: protocolDiamondAddress, + topics: [rangeReservedTopic], + eventAbi: RangeReservedEvent, + }); + + for (const log of logs) { + const offerId = BigInt(log.offerId); + const startExchangeId = BigInt(log.startExchangeId); + const endExchangeId = BigInt(log.endExchangeId); + const quantityAvailable = endExchangeId - startExchangeId + 1n; + + // get offer details + const [, offer] = await api.call({ + target: protocolDiamondAddress, + abi: getOffer_v2_5_0, + params: [offerId.toString()], + }); + + if (offer.quantityAvailable !== MaxUint256) continue; // skip limited offers + + const price = BigInt(offer.price); + const amount = quantityAvailable * price; + const token = offer.exchangeToken; + volumeByToken[token] = (volumeByToken[token] || 0n) + amount; + } +} + +export async function getEncumberedFunds( + { getLogs }: FetchOptions, + volumeByToken: Record +) { + const FundsEncumberedLogs = await getLogs({ + target: protocolDiamondAddress, + topics: [fundsEncumberedTopic], + eventAbi: FundsEncumberedEvent, + }); + + for (const log of FundsEncumberedLogs) { + const token = log.exchangeToken; + const amount = BigInt(log.amount); + volumeByToken[token] = (volumeByToken[token] || 0n) + amount; + } +} From 125fa7fd10c9cdab2592eda9a0fb902260b6d379 Mon Sep 17 00:00:00 2001 From: "copilot-swe-agent[bot]" <198982749+Copilot@users.noreply.github.com> Date: Thu, 13 Nov 2025 11:24:19 +0000 Subject: [PATCH 4/9] Initial plan From 17ad86b61310e79b01c9058ac4b6ea4c037d34c0 Mon Sep 17 00:00:00 2001 From: Klemen <64400885+zajck@users.noreply.github.com> Date: Thu, 13 Nov 2025 15:19:30 +0100 Subject: [PATCH 5/9] Update dexs/boson/utils.ts Co-authored-by: Ludovic Levalleux --- dexs/boson/utils.ts | 3 +++ 1 file changed, 3 insertions(+) diff --git a/dexs/boson/utils.ts b/dexs/boson/utils.ts index 845d1da75e..dd731ebb48 100644 --- a/dexs/boson/utils.ts +++ b/dexs/boson/utils.ts @@ -75,11 +75,14 @@ export async function getReservedRanges( const quantityAvailable = endExchangeId - startExchangeId + 1n; // get offer details + const blockNumber = api.block; + api.block = "latest"; // to get the most recent offer data const [, offer] = await api.call({ target: protocolDiamondAddress, abi: getOffer_v2_5_0, params: [offerId.toString()], }); + api.block = blockNumber; // restore original block number if (offer.quantityAvailable !== MaxUint256) continue; // skip limited offers From df175b9ccd293f9f6172f87019251b3cad2b6487 Mon Sep 17 00:00:00 2001 From: Klemen <64400885+zajck@users.noreply.github.com> Date: Thu, 13 Nov 2025 15:35:12 +0100 Subject: [PATCH 6/9] Apply suggestions from code review Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> --- dexs/boson/index.ts | 2 +- dexs/boson/utils.ts | 8 ++++---- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/dexs/boson/index.ts b/dexs/boson/index.ts index 6f9a5232d7..63349f4ae0 100644 --- a/dexs/boson/index.ts +++ b/dexs/boson/index.ts @@ -35,7 +35,7 @@ const adapter: Adapter = { version: 2, methodology: { Volume: - "Sum of funds encumbered in exchanges and total value of newly created offers on the Boson Protocol.", + "Sum of funds encumbered in exchanges, total value of newly created offers, and newly reserved ranges for unlimited offers on the Boson Protocol.", }, }; diff --git a/dexs/boson/utils.ts b/dexs/boson/utils.ts index dd731ebb48..bd17f9c7aa 100644 --- a/dexs/boson/utils.ts +++ b/dexs/boson/utils.ts @@ -42,9 +42,9 @@ export async function getNewOffers( OfferCreatedEvent_v2_5_0, ]); - const offerLogs = response.map((log) => { - return iface.parseLog(log)?.args; - }); + const offerLogs = response + .map((log) => iface.parseLog(log)?.args) + .filter((args) => args != null); for (const offer of offerLogs) { const quantityAvailable = BigInt(offer.offer.quantityAvailable); @@ -84,7 +84,7 @@ export async function getReservedRanges( }); api.block = blockNumber; // restore original block number - if (offer.quantityAvailable !== MaxUint256) continue; // skip limited offers + if (BigInt(offer.quantityAvailable) !== MaxUint256) continue; // skip limited offers const price = BigInt(offer.price); const amount = quantityAvailable * price; From 3453893cc0905eeb797b520bce92d524a987ed25 Mon Sep 17 00:00:00 2001 From: zajck Date: Fri, 21 Nov 2025 16:28:30 +0100 Subject: [PATCH 7/9] Update daily volume calculation --- dexs/boson/constants.ts | 8 ++-- dexs/boson/index.ts | 13 ++----- dexs/boson/utils.ts | 84 ++++++++++++++++------------------------- 3 files changed, 40 insertions(+), 65 deletions(-) diff --git a/dexs/boson/constants.ts b/dexs/boson/constants.ts index a89112f9e1..9fe9897637 100644 --- a/dexs/boson/constants.ts +++ b/dexs/boson/constants.ts @@ -2,6 +2,8 @@ export const protocolDiamondAddress = "0x59A4C19b55193D5a2EAD0065c54af4d516E18Cb5"; /** Event topics **/ +export const fundsDepositedTopic = + "0x862dfcd9710943e66ad8f1f01a99cc98ab5612a09e62ecc68f63fe2e0f86cb0e"; export const fundsEncumberedTopic = "0x8080d30eb13935d67dfdc606fa5e4170aa03ffdfaf40136ef3fa4355c88b19f9"; export const offerCreatedTopic_v2_0_0 = @@ -29,9 +31,7 @@ export const OfferCreatedEvent_v2_5_0 = "event OfferCreated(uint256 indexed offerId, uint256 indexed sellerId, (uint256 id, uint256 sellerId, uint256 price, uint256 sellerDeposit, uint256 buyerCancelPenalty, uint256 quantityAvailable, address exchangeToken, uint8 priceType, uint8 creator, string metadataUri, string metadataHash, bool voided, uint256 collectionIndex, (address[] recipients, uint256[] bps)[] royaltyInfo, uint256 buyerId) offer, (uint256 validFrom, uint256 validUntil, uint256 voucherRedeemableFrom, uint256 voucherRedeemableUntil) offerDates, (uint256 disputePeriod, uint256 voucherValid, uint256 resolutionPeriod) offerDurations, (uint256 disputeResolverId, uint256 escalationResponsePeriod, uint256 feeAmount, uint256 buyerEscalationDeposit, address mutualizerAddress) disputeResolutionTerms, (uint256 protocolFee, uint256 agentFee) offerFees, uint256 indexed agentId, address executedBy)"; export const RangeReservedEvent = "event RangeReserved(uint256 indexed offerId, uint256 indexed sellerId, uint256 startExchangeId, uint256 endExchangeId, address owner, address indexed executedBy)"; +export const FundsDepositedEvent = + "event FundsDeposited(uint256 indexed entityId, address indexed executedBy, address indexed tokenAddress, uint256 amount)"; export const FundsEncumberedEvent = "event FundsEncumbered(uint256 indexed entityId, address indexed exchangeToken, uint256 amount, address indexed executedBy)"; - -/** Contract Methods */ -export const getOffer_v2_5_0 = - "function getOffer(uint256 _offerId) view returns (bool exists, (uint256 id, uint256 sellerId, uint256 price, uint256 sellerDeposit, uint256 buyerCancelPenalty, uint256 quantityAvailable, address exchangeToken, uint8 priceType, uint8 creator, string metadataUri, string metadataHash, bool voided, uint256 collectionIndex, (address[] recipients, uint256[] bps)[] royaltyInfo, uint256 buyerId) offer, (uint256 validFrom, uint256 validUntil, uint256 voucherRedeemableFrom, uint256 voucherRedeemableUntil) offerDates, (uint256 disputePeriod, uint256 voucherValid, uint256 resolutionPeriod) offerDurations, (uint256 disputeResolverId, uint256 escalationResponsePeriod, uint256 feeAmount, uint256 buyerEscalationDeposit, address mutualizerAddress) disputeResolutionTerms, (uint256 protocolFee, uint256 agentFee) offerFees)"; diff --git a/dexs/boson/index.ts b/dexs/boson/index.ts index 63349f4ae0..f55bb72968 100644 --- a/dexs/boson/index.ts +++ b/dexs/boson/index.ts @@ -1,6 +1,6 @@ import { Adapter, FetchOptions, FetchResultV2 } from "../../adapters/types"; import { CHAIN } from "../../helpers/chains"; -import { getEncumberedFunds, getNewOffers, getReservedRanges } from "./utils"; +import { getEncumberedFunds, getNewOffers } from "./utils"; async function getProtocolVolume( options: FetchOptions @@ -8,15 +8,8 @@ async function getProtocolVolume( const { createBalances } = options; const dailyVolume = createBalances(); - const volumeByToken: Record = {}; - - await getEncumberedFunds(options, volumeByToken); - await getNewOffers(options, volumeByToken); - await getReservedRanges(options, volumeByToken); - - for (const [token, amount] of Object.entries(volumeByToken)) { - dailyVolume.add(token, amount); - } + await getEncumberedFunds(options, dailyVolume); + await getNewOffers(options, dailyVolume); return { dailyVolume, diff --git a/dexs/boson/utils.ts b/dexs/boson/utils.ts index bd17f9c7aa..b09f07eb7a 100644 --- a/dexs/boson/utils.ts +++ b/dexs/boson/utils.ts @@ -1,26 +1,27 @@ -import { ethers, MaxUint256 } from "ethers"; +import { ethers } from "ethers"; import { FetchOptions } from "../../adapters/types"; +import { addTokensReceived, getETHReceived } from "../../helpers/token"; import { protocolDiamondAddress, + fundsDepositedTopic, fundsEncumberedTopic, offerCreatedTopic_v2_0_0, offerCreatedTopic_v2_3_0, offerCreatedTopic_v2_4_0, offerCreatedTopic_v2_5_0, - rangeReservedTopic, OfferCreatedEvent_v2_0_0, OfferCreatedEvent_v2_3_0, OfferCreatedEvent_v2_4_0, OfferCreatedEvent_v2_5_0, - RangeReservedEvent, + FundsDepositedEvent, FundsEncumberedEvent, - getOffer_v2_5_0, } from "./constants"; +import { Balances } from "@defillama/sdk"; export async function getNewOffers( { getLogs }: FetchOptions, - volumeByToken: Record + dailyVolume: Balances ) { const response = await getLogs({ target: protocolDiamondAddress, @@ -47,65 +48,46 @@ export async function getNewOffers( .filter((args) => args != null); for (const offer of offerLogs) { - const quantityAvailable = BigInt(offer.offer.quantityAvailable); - if (quantityAvailable === MaxUint256) continue; // skip unlimited offers - const price = BigInt(offer.offer.price); - const amount = quantityAvailable * price; const token = offer.offer.exchangeToken; - volumeByToken[token] = (volumeByToken[token] || 0n) + amount; + dailyVolume.add(token, price); } } -export async function getReservedRanges( - { getLogs, api }: FetchOptions, - volumeByToken: Record +export async function getEncumberedFunds( + options: FetchOptions, + dailyVolume: Balances ) { - // only for unlimited offers, since they are not counted in getNewOffers - const logs = await getLogs({ + const response = await options.getLogs({ target: protocolDiamondAddress, - topics: [rangeReservedTopic], - eventAbi: RangeReservedEvent, + topics: [[fundsDepositedTopic, fundsEncumberedTopic]], + onlyArgs: true, }); - for (const log of logs) { - const offerId = BigInt(log.offerId); - const startExchangeId = BigInt(log.startExchangeId); - const endExchangeId = BigInt(log.endExchangeId); - const quantityAvailable = endExchangeId - startExchangeId + 1n; - - // get offer details - const blockNumber = api.block; - api.block = "latest"; // to get the most recent offer data - const [, offer] = await api.call({ - target: protocolDiamondAddress, - abi: getOffer_v2_5_0, - params: [offerId.toString()], - }); - api.block = blockNumber; // restore original block number + // Combine all versions of the OfferCreated event + const iface = new ethers.Interface([ + FundsEncumberedEvent, + FundsDepositedEvent, + ]); - if (BigInt(offer.quantityAvailable) !== MaxUint256) continue; // skip limited offers + const parsedLogs = response + .map((log) => iface.parseLog(log)?.args) + .filter((args) => args != null); - const price = BigInt(offer.price); - const amount = quantityAvailable * price; - const token = offer.exchangeToken; - volumeByToken[token] = (volumeByToken[token] || 0n) + amount; - } -} + const uniqueTokens = new Set( + parsedLogs.map((i) => i.tokenAddress || i.exchangeToken) + ); -export async function getEncumberedFunds( - { getLogs }: FetchOptions, - volumeByToken: Record -) { - const FundsEncumberedLogs = await getLogs({ + await addTokensReceived({ target: protocolDiamondAddress, - topics: [fundsEncumberedTopic], - eventAbi: FundsEncumberedEvent, + tokens: Array.from(uniqueTokens), + options, + balances: dailyVolume, }); - for (const log of FundsEncumberedLogs) { - const token = log.exchangeToken; - const amount = BigInt(log.amount); - volumeByToken[token] = (volumeByToken[token] || 0n) + amount; - } + await getETHReceived({ + target: protocolDiamondAddress, + balances: dailyVolume, + options, + }); } From 3f1f7dbae454676a0ce9ee2954f7f3930dd5d587 Mon Sep 17 00:00:00 2001 From: zajck Date: Fri, 21 Nov 2025 16:31:10 +0100 Subject: [PATCH 8/9] Update methodology. --- dexs/boson/index.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dexs/boson/index.ts b/dexs/boson/index.ts index f55bb72968..afa4170d0c 100644 --- a/dexs/boson/index.ts +++ b/dexs/boson/index.ts @@ -28,7 +28,7 @@ const adapter: Adapter = { version: 2, methodology: { Volume: - "Sum of funds encumbered in exchanges, total value of newly created offers, and newly reserved ranges for unlimited offers on the Boson Protocol.", + "Sum of funds deposited and, sum of prices of newly created offers", }, }; From 7e3b8bab2ce6334a747d55e15fed788e71df3255 Mon Sep 17 00:00:00 2001 From: zajck Date: Thu, 4 Dec 2025 12:33:56 +0100 Subject: [PATCH 9/9] remove dex adapter --- dexs/boson/constants.ts | 37 ---------------- dexs/boson/index.ts | 35 ---------------- dexs/boson/utils.ts | 93 ----------------------------------------- 3 files changed, 165 deletions(-) delete mode 100644 dexs/boson/constants.ts delete mode 100644 dexs/boson/index.ts delete mode 100644 dexs/boson/utils.ts diff --git a/dexs/boson/constants.ts b/dexs/boson/constants.ts deleted file mode 100644 index 9fe9897637..0000000000 --- a/dexs/boson/constants.ts +++ /dev/null @@ -1,37 +0,0 @@ -export const protocolDiamondAddress = - "0x59A4C19b55193D5a2EAD0065c54af4d516E18Cb5"; - -/** Event topics **/ -export const fundsDepositedTopic = - "0x862dfcd9710943e66ad8f1f01a99cc98ab5612a09e62ecc68f63fe2e0f86cb0e"; -export const fundsEncumberedTopic = - "0x8080d30eb13935d67dfdc606fa5e4170aa03ffdfaf40136ef3fa4355c88b19f9"; -export const offerCreatedTopic_v2_0_0 = - "0x845c99b8425be384387e239b85d44b6cdf63aab6c45c2534f799743e341c74f8"; -export const offerCreatedTopic_v2_3_0 = - "0xb6a507882e43ec6bae2f276ce4a839f1ca9dcf2da73095eea9e633e96ecf6eb2"; -export const offerCreatedTopic_v2_4_0 = - "0xa76af238b31b285c9397e2a7c55650ca18a1baf6504de15d7dd1321693144cf7"; -export const offerCreatedTopic_v2_5_0 = - "0x5235a4f9db2e479e7353e22e7629a4556897ddaf0ab4eaeb9bb8660c8e49a903"; -export const rangeReservedTopic = - "0xede05ffdb8c59f6f9e12923efcf03736da40cda9a4c5ba60ac2b6238b8b86a60"; - -/** Event definitions **/ -/** - * Some event changed over time, but kept their name, so we define multiple versions here - */ -export const OfferCreatedEvent_v2_0_0 = - "event OfferCreated(uint256 indexed offerId, uint256 indexed sellerId, (uint256 id, uint256 sellerId, uint256 price, uint256 sellerDeposit, uint256 buyerCancelPenalty, uint256 quantityAvailable, address exchangeToken, string metadataUri, string metadataHash, bool voided) offer, (uint256 validFrom, uint256 validUntil, uint256 voucherRedeemableFrom, uint256 voucherRedeemableUntil) offerDates, (uint256 disputePeriod, uint256 voucherValid, uint256 resolutionPeriod) offerDurations, (uint256 disputeResolverId, uint256 escalationResponsePeriod, uint256 feeAmount, uint256 buyerEscalationDeposit) disputeResolutionTerms, (uint256 protocolFee, uint256 agentFee) offerFees, uint256 indexed agentId, address executedBy)"; -export const OfferCreatedEvent_v2_3_0 = - "event OfferCreated(uint256 indexed offerId, uint256 indexed sellerId, (uint256 id, uint256 sellerId, uint256 price, uint256 sellerDeposit, uint256 buyerCancelPenalty, uint256 quantityAvailable, address exchangeToken, string metadataUri, string metadataHash, bool voided, uint256 collectionIndex) offer, (uint256 validFrom, uint256 validUntil, uint256 voucherRedeemableFrom, uint256 voucherRedeemableUntil) offerDates, (uint256 disputePeriod, uint256 voucherValid, uint256 resolutionPeriod) offerDurations, (uint256 disputeResolverId, uint256 escalationResponsePeriod, uint256 feeAmount, uint256 buyerEscalationDeposit) disputeResolutionTerms, (uint256 protocolFee, uint256 agentFee) offerFees, uint256 indexed agentId, address executedBy)"; -export const OfferCreatedEvent_v2_4_0 = - "event OfferCreated(uint256 indexed offerId, uint256 indexed sellerId, (uint256 id, uint256 sellerId, uint256 price, uint256 sellerDeposit, uint256 buyerCancelPenalty, uint256 quantityAvailable, address exchangeToken, uint8 priceType, string metadataUri, string metadataHash, bool voided, uint256 collectionIndex, (address[] recipients, uint256[] bps)[] royaltyInfo) offer, (uint256 validFrom, uint256 validUntil, uint256 voucherRedeemableFrom, uint256 voucherRedeemableUntil) offerDates, (uint256 disputePeriod, uint256 voucherValid, uint256 resolutionPeriod) offerDurations, (uint256 disputeResolverId, uint256 escalationResponsePeriod, uint256 feeAmount, uint256 buyerEscalationDeposit) disputeResolutionTerms, (uint256 protocolFee, uint256 agentFee) offerFees, uint256 indexed agentId, address executedBy)"; -export const OfferCreatedEvent_v2_5_0 = - "event OfferCreated(uint256 indexed offerId, uint256 indexed sellerId, (uint256 id, uint256 sellerId, uint256 price, uint256 sellerDeposit, uint256 buyerCancelPenalty, uint256 quantityAvailable, address exchangeToken, uint8 priceType, uint8 creator, string metadataUri, string metadataHash, bool voided, uint256 collectionIndex, (address[] recipients, uint256[] bps)[] royaltyInfo, uint256 buyerId) offer, (uint256 validFrom, uint256 validUntil, uint256 voucherRedeemableFrom, uint256 voucherRedeemableUntil) offerDates, (uint256 disputePeriod, uint256 voucherValid, uint256 resolutionPeriod) offerDurations, (uint256 disputeResolverId, uint256 escalationResponsePeriod, uint256 feeAmount, uint256 buyerEscalationDeposit, address mutualizerAddress) disputeResolutionTerms, (uint256 protocolFee, uint256 agentFee) offerFees, uint256 indexed agentId, address executedBy)"; -export const RangeReservedEvent = - "event RangeReserved(uint256 indexed offerId, uint256 indexed sellerId, uint256 startExchangeId, uint256 endExchangeId, address owner, address indexed executedBy)"; -export const FundsDepositedEvent = - "event FundsDeposited(uint256 indexed entityId, address indexed executedBy, address indexed tokenAddress, uint256 amount)"; -export const FundsEncumberedEvent = - "event FundsEncumbered(uint256 indexed entityId, address indexed exchangeToken, uint256 amount, address indexed executedBy)"; diff --git a/dexs/boson/index.ts b/dexs/boson/index.ts deleted file mode 100644 index afa4170d0c..0000000000 --- a/dexs/boson/index.ts +++ /dev/null @@ -1,35 +0,0 @@ -import { Adapter, FetchOptions, FetchResultV2 } from "../../adapters/types"; -import { CHAIN } from "../../helpers/chains"; -import { getEncumberedFunds, getNewOffers } from "./utils"; - -async function getProtocolVolume( - options: FetchOptions -): Promise { - const { createBalances } = options; - const dailyVolume = createBalances(); - - await getEncumberedFunds(options, dailyVolume); - await getNewOffers(options, dailyVolume); - - return { - dailyVolume, - }; -} - -const adapter: Adapter = { - fetch: getProtocolVolume, - adapter: { - [CHAIN.POLYGON]: { start: "2022-10-12" }, - [CHAIN.ETHEREUM]: { start: "2023-09-29" }, - [CHAIN.BASE]: { start: "2025-01-31" }, - [CHAIN.ARBITRUM]: { start: "2025-04-01" }, - [CHAIN.OPTIMISM]: { start: "2025-03-10" }, - }, - version: 2, - methodology: { - Volume: - "Sum of funds deposited and, sum of prices of newly created offers", - }, -}; - -export default adapter; diff --git a/dexs/boson/utils.ts b/dexs/boson/utils.ts deleted file mode 100644 index b09f07eb7a..0000000000 --- a/dexs/boson/utils.ts +++ /dev/null @@ -1,93 +0,0 @@ -import { ethers } from "ethers"; -import { FetchOptions } from "../../adapters/types"; -import { addTokensReceived, getETHReceived } from "../../helpers/token"; - -import { - protocolDiamondAddress, - fundsDepositedTopic, - fundsEncumberedTopic, - offerCreatedTopic_v2_0_0, - offerCreatedTopic_v2_3_0, - offerCreatedTopic_v2_4_0, - offerCreatedTopic_v2_5_0, - OfferCreatedEvent_v2_0_0, - OfferCreatedEvent_v2_3_0, - OfferCreatedEvent_v2_4_0, - OfferCreatedEvent_v2_5_0, - FundsDepositedEvent, - FundsEncumberedEvent, -} from "./constants"; -import { Balances } from "@defillama/sdk"; - -export async function getNewOffers( - { getLogs }: FetchOptions, - dailyVolume: Balances -) { - const response = await getLogs({ - target: protocolDiamondAddress, - topics: [ - [ - offerCreatedTopic_v2_0_0, - offerCreatedTopic_v2_3_0, - offerCreatedTopic_v2_4_0, - offerCreatedTopic_v2_5_0, - ], - ], - }); - - // Combine all versions of the OfferCreated event - const iface = new ethers.Interface([ - OfferCreatedEvent_v2_0_0, - OfferCreatedEvent_v2_3_0, - OfferCreatedEvent_v2_4_0, - OfferCreatedEvent_v2_5_0, - ]); - - const offerLogs = response - .map((log) => iface.parseLog(log)?.args) - .filter((args) => args != null); - - for (const offer of offerLogs) { - const price = BigInt(offer.offer.price); - const token = offer.offer.exchangeToken; - dailyVolume.add(token, price); - } -} - -export async function getEncumberedFunds( - options: FetchOptions, - dailyVolume: Balances -) { - const response = await options.getLogs({ - target: protocolDiamondAddress, - topics: [[fundsDepositedTopic, fundsEncumberedTopic]], - onlyArgs: true, - }); - - // Combine all versions of the OfferCreated event - const iface = new ethers.Interface([ - FundsEncumberedEvent, - FundsDepositedEvent, - ]); - - const parsedLogs = response - .map((log) => iface.parseLog(log)?.args) - .filter((args) => args != null); - - const uniqueTokens = new Set( - parsedLogs.map((i) => i.tokenAddress || i.exchangeToken) - ); - - await addTokensReceived({ - target: protocolDiamondAddress, - tokens: Array.from(uniqueTokens), - options, - balances: dailyVolume, - }); - - await getETHReceived({ - target: protocolDiamondAddress, - balances: dailyVolume, - options, - }); -}