-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #256 from hypercerts-org/develop
Push to PRD
- Loading branch information
Showing
11 changed files
with
1,183 additions
and
351 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Large diffs are not rendered by default.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,190 @@ | ||
| import "dotenv/config"; | ||
|
|
||
| import { createClient } from "@supabase/supabase-js"; | ||
| import { parseClaimOrFractionId } from "@hypercerts-org/sdk"; | ||
| import { createPublicClient, erc20Abi, zeroAddress } from "viem"; | ||
| import { http } from "viem"; | ||
| import { | ||
| arbitrum, | ||
| arbitrumSepolia, | ||
| base, | ||
| baseSepolia, | ||
| celo, | ||
| filecoin, | ||
| filecoinCalibration, | ||
| optimism, | ||
| } from "viem/chains"; | ||
| import { Chain } from "viem"; | ||
| import { sepolia } from "viem/chains"; | ||
| import { HypercertMinterAbi } from "@hypercerts-org/sdk"; | ||
| import { parseEventLogs } from "viem"; | ||
| import { TakerBid } from "../src/storage/storeTakerBid.js"; | ||
| import { getAddress } from "viem"; | ||
| import { getDeployment } from "../src/utils/getDeployment.js"; | ||
| import { getHypercertTokenId } from "../src/utils/tokenIds.js"; | ||
| import { HypercertExchangeAbi } from "@hypercerts-org/sdk"; | ||
| import { EvmClientFactory } from "../src/clients/evmClient.js"; | ||
|
|
||
| const getChain = (chainId: number) => { | ||
| const chains: Record<number, Chain> = { | ||
| 10: optimism, | ||
| 314: filecoin, | ||
| 8453: base, | ||
| 42161: arbitrum, | ||
| 42220: celo, | ||
| 84532: baseSepolia, | ||
| 314159: filecoinCalibration, | ||
| 421614: arbitrumSepolia, | ||
| 11155111: sepolia, | ||
| }; | ||
|
|
||
| const chain = chains[chainId]; | ||
| if (!chain) throw new Error(`Unsupported chain ID: ${chainId}`); | ||
| return chain; | ||
| }; | ||
|
|
||
| const main = async () => { | ||
| console.log("update_sales_values"); | ||
| // Get all sales rows | ||
| // Create supabase client | ||
| const supabase = createClient( | ||
| process.env.SUPABASE_CACHING_DB_URL!, | ||
| process.env.SUPABASE_CACHING_SERVICE_API_KEY!, | ||
| ); | ||
| const salesResponse = await supabase.from("sales").select("*"); | ||
| const sales = salesResponse.data; | ||
|
|
||
| if (!sales) { | ||
| console.log("No sales found"); | ||
| return; | ||
| } | ||
|
|
||
| const results: TakerBid[] = []; | ||
| for (const sale of sales) { | ||
| const tokenId = BigInt(sale.item_ids[0]); | ||
| const claimId = getHypercertTokenId(tokenId); | ||
| const hypercert_id = sale.hypercert_id.replace("undefined", claimId); | ||
| const chainId = parseClaimOrFractionId(hypercert_id).chainId; | ||
|
|
||
| if (!chainId) { | ||
| throw new Error( | ||
| `No chainId found for sale ${sale.transaction_hash} ${hypercert_id}`, | ||
| ); | ||
| } | ||
|
|
||
| // Get transaction and parse logs using viem | ||
| const client = EvmClientFactory.createClient(Number(chainId)); | ||
| const { addresses } = getDeployment(Number(chainId)); | ||
| const { currency } = sale; | ||
|
|
||
| try { | ||
| const transactionReceipt = await client.getTransactionReceipt({ | ||
| hash: sale.transaction_hash as `0x${string}`, | ||
| }); | ||
|
|
||
| // parse logs to get claimID, contractAddress and cid | ||
| const transactionLogsHypercertMinter = transactionReceipt.logs.filter( | ||
| (log) => | ||
| log.address.toLowerCase() === | ||
| addresses?.HypercertMinterUUPS?.toLowerCase(), | ||
| ); | ||
|
|
||
| let currencyAmount = 0n; | ||
| if (currency === zeroAddress) { | ||
| // Get value of the transaction | ||
| const transaction = await client.getTransaction({ | ||
| hash: sale.transaction_hash as `0x${string}`, | ||
| }); | ||
| currencyAmount = transaction.value; | ||
| } else { | ||
| const currencyLogs = transactionReceipt.logs.filter( | ||
| (log) => log.address.toLowerCase() === currency.toLowerCase(), | ||
| ); | ||
| const parsedCurrencyLogs = parseEventLogs({ | ||
| abi: erc20Abi, | ||
| logs: currencyLogs, | ||
| }); | ||
| const transferLogs = parsedCurrencyLogs.filter( | ||
| (log) => log.eventName === "Transfer", | ||
| ); | ||
| currencyAmount = transferLogs.reduce( | ||
| (acc, transferLog) => acc + (transferLog?.args?.value ?? 0n), | ||
| 0n, | ||
| ); | ||
| } | ||
|
|
||
| const exchangeLogs = transactionReceipt.logs.filter( | ||
| (log) => | ||
| log.address.toLowerCase() === | ||
| addresses?.HypercertExchange?.toLowerCase(), | ||
| ); | ||
|
|
||
| const parsedExchangeLog = parseEventLogs({ | ||
| abi: HypercertExchangeAbi, | ||
| logs: exchangeLogs, | ||
| // @ts-expect-error eventName is missing in the type | ||
| }).find((log) => log.eventName === "TakerBid"); | ||
|
|
||
| // @ts-expect-error args is missing in the type | ||
| const fee_amounts = parsedExchangeLog?.args?.feeAmounts; | ||
| // @ts-expect-error args is missing in the type | ||
| const fee_recipients = parsedExchangeLog?.args?.feeRecipients; | ||
|
|
||
| results.push( | ||
| TakerBid.parse({ | ||
| amounts: sale.amounts.map((amount) => BigInt(amount)), | ||
| seller: getAddress(sale.seller), | ||
| buyer: getAddress(sale.buyer), | ||
| currency: getAddress(sale.currency), | ||
| collection: getAddress(sale.collection), | ||
| item_ids: sale.item_ids.map((item_id) => BigInt(item_id)), | ||
| strategy_id: BigInt(sale.strategy_id), | ||
| hypercert_id: hypercert_id, | ||
| transaction_hash: sale.transaction_hash, | ||
| currency_amount: currencyAmount, | ||
| fee_amounts: fee_amounts, | ||
| fee_recipients: fee_recipients, | ||
| }), | ||
| ); | ||
| } catch (e) { | ||
| console.log("Error parsing transaction", JSON.stringify(sale, null, 2)); | ||
| console.log(e); | ||
| continue; | ||
| } | ||
| } | ||
|
|
||
| // Combine parsed results with original sales data by matching transaction hashes | ||
| const rowsToUpsert = results.map((result) => { | ||
| const originalSale = sales.find( | ||
| (sale) => sale.transaction_hash === result.transaction_hash, | ||
| ); | ||
| if (!originalSale) { | ||
| throw new Error( | ||
| `Could not find original sale for transaction ${result.transaction_hash}`, | ||
| ); | ||
| } | ||
| return { | ||
| ...originalSale, | ||
| ...result, | ||
| strategy_id: result.strategy_id.toString(), | ||
| item_ids: result.item_ids.map((id) => id.toString()), | ||
| amounts: result.amounts.map((amount) => amount.toString()), | ||
| currency_amount: result.currency_amount.toString(), | ||
| fee_amounts: result.fee_amounts.map((amount) => amount.toString()), | ||
| }; | ||
| }); | ||
|
|
||
|
|
||
| // Upsert rows | ||
| console.log("Upserting rows"); | ||
| console.log(JSON.stringify(rowsToUpsert, null, 2)); | ||
| const res = await supabase | ||
| .from("sales") | ||
| .upsert(rowsToUpsert) | ||
| .select("*") | ||
| .throwOnError(); | ||
| console.log("Rows after upsert"); | ||
| console.log(JSON.stringify(res.data, null, 2)); | ||
| }; | ||
|
|
||
| main(); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.