Skip to content

Commit 88a7ba4

Browse files
cctdanielcctdaniel
committed
add price_pusher for ton
1 parent 629f011 commit 88a7ba4

File tree

6 files changed

+1602
-874
lines changed

6 files changed

+1602
-874
lines changed

‎apps/price_pusher/config.ton.mainnet.sample.json‎

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
{
2+
"endpoint": "https://toncenter.com/api/v2/jsonRPC",
3+
"pyth-contract-address": "EQBU6k8HH6yX4Jf3d18swWbnYr31D3PJI7PgjXT",
4+
"price-service-endpoint": "https://hermes.pyth.network",
5+
"private-key-file": "./mnemonic",
6+
"price-config-file": "./price-config.stable.sample.yaml"
7+
}

‎apps/price_pusher/config.ton.testnet.sample.json‎

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
{
2+
"endpoint": "https://testnet.toncenter.com/api/v2/jsonRPC",
3+
"pyth-contract-address": "EQB4ZnrI5qsP_IUJgVJNwEGKLzZWsQOFhiaqDbD7pTt_f9oU",
4+
"price-service-endpoint": "https://hermes.pyth.network",
5+
"private-key-file": "./mnemonic",
6+
"price-config-file": "./price-config.stable.sample.yaml"
7+
}

‎apps/price_pusher/package.json‎

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,12 +62,15 @@
6262
"@mysten/sui": "^1.3.0",
6363
"@pythnetwork/price-service-client": "workspace:*",
6464
"@pythnetwork/price-service-sdk": "workspace:^",
65+
"@pythnetwork/pyth-fuel-js": "workspace:*",
6566
"@pythnetwork/pyth-sdk-solidity": "workspace:*",
6667
"@pythnetwork/pyth-solana-receiver": "workspace:*",
6768
"@pythnetwork/pyth-sui-js": "workspace:*",
69+
"@pythnetwork/pyth-ton-js": "workspace:*",
6870
"@pythnetwork/solana-utils": "workspace:*",
69-
"@pythnetwork/pyth-fuel-js": "workspace:*",
7071
"@solana/web3.js": "^1.93.0",
72+
"@ton/crypto": "^3.3.0",
73+
"@ton/ton": "^15.1.0",
7174
"@types/pino": "^7.0.5",
7275
"aptos": "^1.8.5",
7376
"fuels": "^0.94.5",

‎apps/price_pusher/src/ton/command.ts‎

Lines changed: 107 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,107 @@
1+
import { Options } from "yargs";
2+
import * as options from "../options";
3+
import { readPriceConfigFile } from "../price-config";
4+
import { PriceServiceConnection } from "@pythnetwork/price-service-client";
5+
import { PythPriceListener } from "../pyth-price-listener";
6+
import { TonPriceListener, TonPricePusher } from "./ton";
7+
import { Controller } from "../controller";
8+
import { Address, TonClient } from "@ton/ton";
9+
import fs from "fs";
10+
import pino from "pino";
11+
12+
export default {
13+
command: "ton",
14+
describe: "run price pusher for TON",
15+
builder: {
16+
endpoint: {
17+
description: "TON RPC API endpoint",
18+
type: "string",
19+
required: true,
20+
} as Options,
21+
"private-key-file": {
22+
description: "Path to the private key file",
23+
type: "string",
24+
required: true,
25+
} as Options,
26+
"pyth-contract-address": {
27+
description: "Pyth contract address on TON",
28+
type: "string",
29+
required: true,
30+
} as Options,
31+
...options.priceConfigFile,
32+
...options.priceServiceEndpoint,
33+
...options.pushingFrequency,
34+
...options.pollingFrequency,
35+
...options.logLevel,
36+
...options.priceServiceConnectionLogLevel,
37+
...options.controllerLogLevel,
38+
},
39+
handler: async function (argv: any) {
40+
const {
41+
endpoint,
42+
privateKeyFile,
43+
pythContractAddress,
44+
priceConfigFile,
45+
priceServiceEndpoint,
46+
pushingFrequency,
47+
pollingFrequency,
48+
logLevel,
49+
priceServiceConnectionLogLevel,
50+
controllerLogLevel,
51+
} = argv;
52+
53+
const logger = pino({ level: logLevel });
54+
55+
const priceConfigs = readPriceConfigFile(priceConfigFile);
56+
57+
const priceServiceConnection = new PriceServiceConnection(
58+
priceServiceEndpoint,
59+
{
60+
logger: logger.child(
61+
{ module: "PriceServiceConnection" },
62+
{ level: priceServiceConnectionLogLevel }
63+
),
64+
}
65+
);
66+
67+
const priceItems = priceConfigs.map(({ id, alias }) => ({ id, alias }));
68+
69+
const pythListener = new PythPriceListener(
70+
priceServiceConnection,
71+
priceItems,
72+
logger.child({ module: "PythPriceListener" })
73+
);
74+
75+
const client = new TonClient({ endpoint });
76+
const privateKey = fs.readFileSync(privateKeyFile, "utf8").trim();
77+
const contractAddress = Address.parse(pythContractAddress);
78+
const provider = client.provider(contractAddress);
79+
80+
const tonPriceListener = new TonPriceListener(
81+
provider,
82+
contractAddress,
83+
priceItems,
84+
logger.child({ module: "TonPriceListener" }),
85+
{ pollingFrequency }
86+
);
87+
88+
const tonPricePusher = new TonPricePusher(
89+
client,
90+
privateKey,
91+
contractAddress,
92+
priceServiceConnection,
93+
logger.child({ module: "TonPricePusher" })
94+
);
95+
96+
const controller = new Controller(
97+
priceConfigs,
98+
pythListener,
99+
tonPriceListener,
100+
tonPricePusher,
101+
logger.child({ module: "Controller" }, { level: controllerLogLevel }),
102+
{ pushingFrequency }
103+
);
104+
105+
await controller.start();
106+
},
107+
};

‎apps/price_pusher/src/ton/ton.ts‎

Lines changed: 125 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,125 @@
1+
import { PriceServiceConnection } from "@pythnetwork/price-service-client";
2+
import {
3+
ChainPriceListener,
4+
IPricePusher,
5+
PriceInfo,
6+
PriceItem,
7+
} from "../interface";
8+
import { DurationInSeconds } from "../utils";
9+
import { Logger } from "pino";
10+
import {
11+
Address,
12+
ContractProvider,
13+
OpenedContract,
14+
Sender,
15+
TonClient,
16+
WalletContractV4,
17+
} from "@ton/ton";
18+
import { keyPairFromSeed } from "@ton/crypto";
19+
import {
20+
PythContract,
21+
calculateUpdatePriceFeedsFee,
22+
} from "@pythnetwork/pyth-ton-js";
23+
24+
export class TonPriceListener extends ChainPriceListener {
25+
private contract: OpenedContract<PythContract>;
26+
27+
constructor(
28+
private provider: ContractProvider,
29+
private contractAddress: Address,
30+
priceItems: PriceItem[],
31+
private logger: Logger,
32+
config: {
33+
pollingFrequency: DurationInSeconds;
34+
}
35+
) {
36+
super(config.pollingFrequency, priceItems);
37+
this.contract = this.provider.open(
38+
PythContract.createFromAddress(this.contractAddress)
39+
);
40+
}
41+
42+
async getOnChainPriceInfo(priceId: string): Promise<PriceInfo | undefined> {
43+
try {
44+
const priceInfo = await this.contract.getPriceUnsafe(priceId);
45+
46+
this.logger.debug(
47+
`Polled a TON on chain price for feed ${this.priceIdToAlias.get(
48+
priceId
49+
)} (${priceId}).`
50+
);
51+
52+
return {
53+
conf: priceInfo.conf.toString(),
54+
price: priceInfo.price.toString(),
55+
publishTime: priceInfo.publishTime,
56+
};
57+
} catch (err) {
58+
this.logger.error({ err, priceId }, `Polling on-chain price failed.`);
59+
return undefined;
60+
}
61+
}
62+
}
63+
64+
export class TonPricePusher implements IPricePusher {
65+
private contract: OpenedContract<PythContract>;
66+
private sender: Sender;
67+
68+
constructor(
69+
private client: TonClient,
70+
private privateKey: string,
71+
private contractAddress: Address,
72+
private priceServiceConnection: PriceServiceConnection,
73+
private logger: Logger
74+
) {
75+
this.contract = this.client
76+
.provider(this.contractAddress)
77+
.open(PythContract.createFromAddress(this.contractAddress));
78+
const keyPair = keyPairFromSeed(Buffer.from(this.privateKey, "hex"));
79+
const wallet = WalletContractV4.create({
80+
publicKey: keyPair.publicKey,
81+
workchain: 0,
82+
});
83+
const provider = this.client.open(wallet);
84+
this.sender = provider.sender(keyPair.secretKey);
85+
}
86+
87+
async updatePriceFeed(
88+
priceIds: string[],
89+
// eslint-disable-next-line @typescript-eslint/no-unused-vars
90+
pubTimesToPush: number[]
91+
): Promise<void> {
92+
if (priceIds.length === 0) {
93+
return;
94+
}
95+
96+
let priceFeedUpdateData: string[];
97+
try {
98+
priceFeedUpdateData = await this.priceServiceConnection.getLatestVaas(
99+
priceIds
100+
);
101+
} catch (err: any) {
102+
this.logger.error(err, "getPriceFeedsUpdateData failed");
103+
return;
104+
}
105+
106+
try {
107+
for (const updateData of priceFeedUpdateData) {
108+
const updateDataBuffer = Buffer.from(updateData, "base64");
109+
const updateFee = await this.contract.getUpdateFee(updateDataBuffer);
110+
const totalFee =
111+
calculateUpdatePriceFeedsFee(BigInt(updateFee)) + BigInt(updateFee);
112+
113+
await this.contract.sendUpdatePriceFeeds(
114+
this.sender,
115+
updateDataBuffer,
116+
totalFee
117+
);
118+
}
119+
120+
this.logger.info("updatePriceFeed successful");
121+
} catch (err: any) {
122+
this.logger.error(err, "updatePriceFeed failed");
123+
}
124+
}
125+
}

0 commit comments

Comments
 (0)