-
Notifications
You must be signed in to change notification settings - Fork 0
/
server.js
60 lines (48 loc) · 2.02 KB
/
server.js
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
const express = require('express');
const bodyParser = require('body-parser');
const { Connection, PublicKey } = require('@solana/web3.js');
const splToken = require('@solana/spl-token');
const app = express();
const port = process.env.PORT || 3000;
app.use(bodyParser.json());
app.post('/get-transaction-data', async (req, res) => {
const { fromPubkey, toPubkey, amount } = req.body;
if (!fromPubkey || !toPubkey || !amount) {
return res.status(400).json({ error: 'Missing parameters' });
}
try {
// Connexion à Solana via Alchemy
const connection = new Connection('https://solana-mainnet.g.alchemy.com/v2/L9KXbp7QOQKBKcM29Oyfey_T40s3X4IU');
// Adresse du mint USDT sur Solana
const usdtMintAddress = new PublicKey('Es9vMFrzaCERmJfrF4H2FYD4KCoNkY11McCe8BenwNYB');
// Adresses de l'expéditeur et du destinataire
const fromPublicKey = new PublicKey(fromPubkey);
const toPublicKey = new PublicKey(toPubkey);
// Récupérer ou créer les ATA (Associated Token Accounts) pour l'expéditeur et le destinataire
const fromTokenAccount = await splToken.getOrCreateAssociatedTokenAccount(
connection,
fromPublicKey, // Payer (généralement l'utilisateur)
usdtMintAddress,
fromPublicKey
);
const toTokenAccount = await splToken.getOrCreateAssociatedTokenAccount(
connection,
fromPublicKey, // Payer
usdtMintAddress,
toPublicKey
);
// Envoyer les informations nécessaires pour créer la transaction côté client
res.json({
fromTokenAccount: fromTokenAccount.address.toString(),
toTokenAccount: toTokenAccount.address.toString(),
usdtMintAddress: usdtMintAddress.toString(),
amount: amount * Math.pow(10, 6), // Convertir en base 6 pour les USDT (6 décimales)
});
} catch (error) {
console.error('Error getting transaction data:', error);
res.status(500).json({ error: 'Failed to get transaction data' });
}
});
app.listen(port, () => {
console.log(`API server running on port ${port}`);
});