Skip to content

Commit a65d681

Browse files
committed
fix: check acct loader to re remove oracle
1 parent 261e651 commit a65d681

File tree

2 files changed

+1
-50
lines changed

2 files changed

+1
-50
lines changed

sdk/src/accounts/customizedCadenceBulkAccountLoader.ts

Lines changed: 0 additions & 48 deletions
Original file line numberDiff line numberDiff line change
@@ -55,54 +55,6 @@ export class CustomizedCadenceBulkAccountLoader extends BulkAccountLoader {
5555

5656
private async handleAccountLoading(): Promise<void> {
5757
const accounts = this.getAccountsToLoad();
58-
console.log('ORACLEDATA handleAccountLoading', accounts.length);
59-
60-
const oracleAddresses = [
61-
'3m6i4RFWEDw2Ft4tFHPJtYgmpPe21k56M3FHeWYrgGBz', // SOL
62-
'35MbvS1Juz2wf7GsyHrkCw8yfKciRLxVpEhfZDZFrB4R', // BTC
63-
'93FG52TzNKCnMiasV14Ba34BYcHDb9p4zK4GjZnLwqWR', // ETH
64-
'CXZhzKePYajrZgZyrzgvHYFKK3c5tNgDrRobAgySo8Nb', // APT
65-
'BERaNi6cpEresbq6HC1EQGaB1H1UjvEo4NGnmYSSJof4', // BONK
66-
'HDveCibToLf157NtUqShCEWX3GcF4Aq8Ngt2bst1s1cc', // POL
67-
'r8eNLQ8jysUyk9rrWXuicwAoKZ7V3YngAB6737zfxmv', // BERA
68-
'8M8mjNJ42k2Xi12Q1zRnQRC3xhggu3WGuftiu5VZZmsF', // KAITO
69-
'AZVVDFve8ijzLAm9z6W53GFsoWbcycFsdxCL7WUjMz8S', // IP
70-
'2sZomfWMDuQLcFak3nuharXorHrZ3hK8iaML6ZGSHtso', // FARTCOIN
71-
'55722FS8VeAxRghz5h2ARJvNjkFiHyzkZ9BF7CEQWN6E', // ADA
72-
];
73-
74-
const oracleMatches = accounts.filter(account =>
75-
oracleAddresses.some(addr =>
76-
account.publicKey.toBase58().includes(addr)
77-
)
78-
);
79-
80-
console.log('ORACLEDATA loading oracle accounts:', oracleMatches.length);
81-
console.log('ORACLEDATA oracle pubkeys found:',
82-
oracleMatches.map(account => {
83-
const pubkey = account.publicKey.toBase58();
84-
let marketName = '';
85-
if (pubkey.includes('3m6i4RFWEDw2Ft4tFHPJtYgmpPe21k56M3FHeWYrgGBz')) marketName = 'SOL';
86-
else if (pubkey.includes('35MbvS1Juz2wf7GsyHrkCw8yfKciRLxVpEhfZDZFrB4R')) marketName = 'BTC';
87-
else if (pubkey.includes('93FG52TzNKCnMiasV14Ba34BYcHDb9p4zK4GjZnLwqWR')) marketName = 'ETH';
88-
else if (pubkey.includes('CXZhzKePYajrZgZyrzgvHYFKK3c5tNgDrRobAgySo8Nb')) marketName = 'APT';
89-
else if (pubkey.includes('BERaNi6cpEresbq6HC1EQGaB1H1UjvEo4NGnmYSSJof4')) marketName = 'BONK';
90-
else if (pubkey.includes('HDveCibToLf157NtUqShCEWX3GcF4Aq8Ngt2bst1s1cc')) marketName = 'POL';
91-
else if (pubkey.includes('r8eNLQ8jysUyk9rrWXuicwAoKZ7V3YngAB6737zfxmv')) marketName = 'BERA';
92-
else if (pubkey.includes('8M8mjNJ42k2Xi12Q1zRnQRC3xhggu3WGuftiu5VZZmsF')) marketName = 'KAITO';
93-
else if (pubkey.includes('AZVVDFve8ijzLAm9z6W53GFsoWbcycFsdxCL7WUjMz8S')) marketName = 'IP';
94-
else if (pubkey.includes('2sZomfWMDuQLcFak3nuharXorHrZ3hK8iaML6ZGSHtso')) marketName = 'FARTCOIN';
95-
else if (pubkey.includes('55722FS8VeAxRghz5h2ARJvNjkFiHyzkZ9BF7CEQWN6E')) marketName = 'ADA';
96-
return `${marketName} (${pubkey})`;
97-
})
98-
);
99-
const hasBonkOracle = accounts.some((account) =>
100-
account.publicKey.toBase58().includes(
101-
'BERaNi6cpEresbq6HC1EQGaB1H1UjvEo4NGnmYSSJof4'
102-
)
103-
);
104-
// console.log('ORACLEDATA loading accounts hasBonkOracle', hasBonkOracle);
105-
console.log('ORACLEDATA loading accounts', accounts.map((account) => account.publicKey.toBase58()));
10658

10759
if (accounts.length > 0) {
10860
const chunks = this.chunks(

sdk/src/accounts/externalOracleDataDriftClientSubscriber.ts

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,8 +29,7 @@ export class ExternalOracleDataDriftClientSubscriber extends PollingDriftClientA
2929
const oracleId = getOracleId(oracleInfo.publicKey, oracleInfo.source);
3030
this.oracles.set(oracleId, { data: priceData, slot });
3131
this.oracleLastUpdate.set(oracleId, Date.now());
32-
33-
if (this.pollingOracles.has(oracleId)) {
32+
if (this.pollingOracles.has(oracleId) || this.accountLoader.accountsToLoad.has(oracleInfo.publicKey.toBase58())) {
3433
const oracleToPoll = this.oraclesToPoll.get(oracleId);
3534
if (oracleToPoll) {
3635
this.accountLoader.removeAccount(

0 commit comments

Comments
 (0)