cerc-io/laconic-faucet
16
0
Fork 1
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

Changes in faucet for shopify app (#4)

Browse Source 
Part of [Service provider auctions for web deployments](https://www.notion.so/Service-provider-auctions-for-web-deployments-104a6b22d47280dbad51d28aa3a91d75)

Co-authored-by: Shreerang Kale <shreerangkale@gmail.com>
Reviewed-on: #4
This commit is contained in:
nabarun 2024-10-28 07:19:50 +00:00
parent 3649cfb2fa
commit 39613f9ee3
2 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
environments/local.toml
View File

@ -8,6 +8,7 @@
[server] [server]
port = 3000 port = 3000
enableRateLimit=false
transferAmount = 10000000000 # 1 * 10^10 alnt transferAmount = 10000000000 # 1 * 10^10 alnt
periodTransferLimit = 30000000000 # 3 * 10^10 alnt periodTransferLimit = 30000000000 # 3 * 10^10 alnt
dbDir = "db" dbDir = "db"

15
src/index.ts
View File

@ -25,6 +25,7 @@ interface Config {
}, },
server: { server: {
port: number port: number
enableRateLimit: boolean
transferAmount: string transferAmount: string
periodTransferLimit: string periodTransferLimit: string
dbDir: string dbDir: string
@ -44,7 +45,7 @@ async function main (): Promise<void> {
app.use(cors()); app.use(cors());
app.post('/faucet', async (req, res) => { app.post('/faucet', async (req, res) => {
const { address: accountAddress } = req.body; const { address: accountAddress, amount } = req.body;
if (!accountAddress) { if (!accountAddress) {
return res.status(400).json({ error: 'address is required' }); return res.status(400).json({ error: 'address is required' });
@ -54,22 +55,24 @@ async function main (): Promise<void> {
return res.status(400).json({ error: 'invalid address' }); return res.status(400).json({ error: 'invalid address' });
} }
// Check rate limit
const now = Date.now(); const now = Date.now();
const today = new Date(now).toISOString().split('T')[0]; const today = new Date(now).toISOString().split('T')[0];
const faucetStoreKey = `${accountAddress}:${today}`; const faucetStoreKey = `${accountAddress}:${today}`;
const amountSentToAddress = await faucetDataStore.get(faucetStoreKey) || '0'; const amountSentToAddress = await faucetDataStore.get(faucetStoreKey) || '0';
if (BigInt(amountSentToAddress) + BigInt(config.server.transferAmount) > BigInt(config.server.periodTransferLimit)) { if (config.server.enableRateLimit) {
return res.status(429).json({ error: 'Limit exceeded' }); // Check rate limit
if (BigInt(amountSentToAddress) + BigInt(amount) > BigInt(config.server.periodTransferLimit)) {
return res.status(429).json({ error: 'Limit exceeded' });
}
} }
try { try {
const txHash = await sendTokens(config, accountAddress, String(config.server.transferAmount)); const txHash = await sendTokens(config, accountAddress, String(amount));
console.log(`Sent tokens to address: ${accountAddress}, txHash: ${txHash}`); console.log(`Sent tokens to address: ${accountAddress}, txHash: ${txHash}`);
// Update rate limit // Update rate limit
await faucetDataStore.set(faucetStoreKey, (BigInt(amountSentToAddress) + BigInt(config.server.transferAmount)).toString(), FAUCET_DATA_TTL); config.server.enableRateLimit && await faucetDataStore.set(faucetStoreKey, (BigInt(amountSentToAddress) + BigInt(amount)).toString(), FAUCET_DATA_TTL);
res.json({ success: true, txHash }); res.json({ success: true, txHash });
} catch (error) { } catch (error) {