Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 | 1x 1x 1x 1x 1x | import { DEX_PROGRAMS, DISCRIMINATORS } from '../../constants';
import { convertToUiAmount, PoolEvent, PoolEventType, TransferData } from '../../types';
import { getInstructionData } from '../../utils';
import { BaseLiquidityParser } from '../base-liquidity-parser';
export class OrcaLiquidityParser extends BaseLiquidityParser {
public processLiquidity(): PoolEvent[] {
const events: PoolEvent[] = [];
this.classifiedInstructions
.filter(({ programId }) => programId === DEX_PROGRAMS.ORCA.id)
.forEach(({ instruction, programId, outerIndex, innerIndex }) => {
const event = this.parseInstruction(instruction, programId, outerIndex, innerIndex);
Iif (event) {
events.push(event);
}
});
return events;
}
private parseInstruction(
instruction: any,
programId: string,
outerIndex: number,
innerIndex?: number
): PoolEvent | null {
try {
const data = getInstructionData(instruction);
const action = this.getPoolAction(data);
Iif (!action) return null;
const transfers = this.getTransfersForInstruction(programId, outerIndex, innerIndex);
switch (action) {
case 'ADD':
return this.parseAddLiquidityEvent(instruction, outerIndex, data, transfers);
case 'REMOVE':
return this.parseRemoveLiquidityEvent(instruction, outerIndex, data, transfers);
}
return null;
} catch (error) {
console.error('parseInstruction error:', error);
return null;
}
}
private getPoolAction(data: Buffer): PoolEventType | null {
const instructionType = data.slice(0, 8);
if (
instructionType.equals(DISCRIMINATORS.ORCA.ADD_LIQUIDITY) ||
instructionType.equals(DISCRIMINATORS.ORCA.ADD_LIQUIDITY2)
) {
return 'ADD';
} else Iif (instructionType.equals(DISCRIMINATORS.ORCA.REMOVE_LIQUIDITY)) {
return 'REMOVE';
}
return null;
}
private parseAddLiquidityEvent(instruction: any, index: number, data: any, transfers: TransferData[]): PoolEvent {
const [token0, token1] = this.utils.getLPTransfers(transfers);
const token0Mint = token0?.info.mint;
const token1Mint = token1?.info.mint;
const programId = this.adapter.getInstructionProgramId(instruction);
const accounts = this.adapter.getInstructionAccounts(instruction);
const [token0Decimals, token1Decimals] = [
this.adapter.getTokenDecimals(token0Mint),
this.adapter.getTokenDecimals(token1Mint),
];
return {
...this.adapter.getPoolEventBase('ADD', programId),
idx: index.toString(),
poolId: accounts[0],
poolLpMint: accounts[0],
token0Mint: token0Mint,
token1Mint: token1Mint,
token0Amount: token0?.info.tokenAmount.uiAmount || convertToUiAmount(data.readBigUInt64LE(32), token0Decimals),
token0AmountRaw: token0?.info.tokenAmount.amount || data.readBigUInt64LE(32).toString(),
token1Amount: token1?.info.tokenAmount.uiAmount || convertToUiAmount(data.readBigUInt64LE(24), token1Decimals),
token1AmountRaw: token1?.info.tokenAmount.amount || data.readBigUInt64LE(24).toString(),
token0Decimals: token0Decimals,
token1Decimals: token1Decimals,
lpAmount: convertToUiAmount(data.readBigUInt64LE(8), this.adapter.getTokenDecimals(accounts[1])),
lpAmountRaw: data.readBigUInt64LE(8).toString(),
};
}
private parseRemoveLiquidityEvent(instruction: any, index: number, data: any, transfers: TransferData[]): PoolEvent {
const [token0, token1] = this.utils.getLPTransfers(transfers);
const token0Mint = token0?.info.mint;
const token1Mint = token1?.info.mint;
const programId = this.adapter.getInstructionProgramId(instruction);
const accounts = this.adapter.getInstructionAccounts(instruction);
const [token0Decimals, token1Decimals] = [
this.adapter.getTokenDecimals(token0Mint),
this.adapter.getTokenDecimals(token1Mint),
];
return {
...this.adapter.getPoolEventBase('REMOVE', programId),
idx: index.toString(),
poolId: accounts[0],
poolLpMint: accounts[0],
token0Mint: token0Mint,
token1Mint: token1Mint,
token0Amount: token0?.info.tokenAmount.uiAmount || convertToUiAmount(data.readBigUInt64LE(32), token0Decimals),
token0AmountRaw: token0?.info.tokenAmount.amount || data.readBigUInt64LE(32).toString(),
token1Amount: token1?.info.tokenAmount.uiAmount || convertToUiAmount(data.readBigUInt64LE(24), token1Decimals),
token1AmountRaw: token1?.info.tokenAmount.amount || data.readBigUInt64LE(24).toString(),
token0Decimals: token0Decimals,
token1Decimals: token1Decimals,
lpAmount: convertToUiAmount(data.readBigUInt64LE(8), this.adapter.getTokenDecimals(accounts[1])),
lpAmountRaw: data.readBigUInt64LE(8).toString(),
};
}
}
|