协作头脑风暴
brainstorming
在实现前澄清需求、探索设计选择,并形成清晰的开发方向。
replit-webhooks-events【开发与工程】Implement Replit webhook signature validation and event handling. Use when setting up webhook endpoints, implementing signature verification, or handling Replit event notifications securely. Trigger with phrases like "replit webhook", "replit events", "replit webhook signature", "handle replit events", "replit notifications".
独立 GitHub 快照 · 自动分类 · 以原作者文档为准
Securely handle Replit webhooks with signature validation and replay protection.
import express from 'express';
import crypto from 'crypto';
const app = express();
// IMPORTANT: Raw body needed for signature verification
app.post('/webhooks/replit',
express.raw({ type: 'application/json' }),
async (req, res) => {
const signature = req.headers['x-replit-signature'] as string;
const timestamp = req.headers['x-replit-timestamp'] as string;
if (!verifyReplitSignature(req.body, signature, timestamp)) {
return res.status(401).json({ error: 'Invalid signature' });
}
const event = JSON.parse(req.body.toString());
await handleReplitEvent(event);
res.status(200).json({ received: true });
}
);
function verifyReplitSignature(
payload: Buffer,
signature: string,
timestamp: string
): boolean {
const secret = process.env.REPLIT_WEBHOOK_SECRET!;
// Reject old timestamps (replay attack protection)
const timestampAge = Date.now() - parseInt(timestamp) * 1000;
if (timestampAge > 300000) { // 5 minutes
console.error('Webhook timestamp too old');
return false;
}
// Compute expected signature
const signedPayload = `${timestamp}.${payload.toString()}`;
const expectedSignature = crypto
.createHmac('sha256', secret)
.update(signedPayload)
.digest('hex');
// Timing-safe comparison
return crypto.timingSafeEqual(
Buffer.from(signature),
Buffer.from(expectedSignature)
);
}
type ReplitEventType = 'resource.created' | 'resource.updated' | 'resource.deleted';
interface ReplitEvent {
id: string;
type: ReplitEventType;
data: Record<string, any>;
created: string;
}
const eventHandlers: Record<ReplitEventType, (data: any) => Promise<void>> = {
'resource.created': async (data) => { /* handle */ },
'resource.updated': async (data) => { /* handle */ },
'resource.deleted': async (data) => { /* handle */ }
};
async function handleReplitEvent(event: ReplitEvent): Promise<void> {
const handler = eventHandlers[event.type];
if (!handler) {
console.log(`Unhandled event type: ${event.type}`);
return;
}
try {
await handler(event.data);
console.log(`Processed ${event.type}: ${event.id}`);
} catch (error) {
console.error(`Failed to process ${event.type}: ${event.id}`, error);
throw error; // Rethrow to trigger retry
}
}
import { Redis } from 'ioredis';
const redis = new Redis(process.env.REDIS_URL);
async function isEventProcessed(eventId: string): Promise<boolean> {
const key = `replit:event:${eventId}`;
const exists = await redis.exists(key);
return exists === 1;
}
async function markEventProcessed(eventId: string): Promise<void> {
const key = `replit:event:${eventId}`;
await redis.set(key, '1', 'EX', 86400 * 7); // 7 days TTL
}
# Use Replit CLI to send test events
replit webhooks trigger resource.created --url http://localhost:3000/webhooks/replit
# Or use webhook.site for debugging
curl -X POST https://webhook.site/your-uuid \
-H "Content-Type: application/json" \
-d '{"type": "resource.created", "data": {}}'
Configure your webhook URL in the Replit dashboard.
Use the signature verification code to validate incoming webhooks.
Implement handlers for each event type your application needs.
Prevent duplicate processing with event ID tracking.
| Issue | Cause | Solution |
|---|---|---|
| Invalid signature | Wrong secret | Verify webhook secret |
| Timestamp rejected | Clock drift | Check server time sync |
| Duplicate events | Missing idempotency | Implement event ID tracking |
| Handler timeout | Slow processing | Use async queue |
# Use ngrok to expose local server
ngrok http 3000
# Send test webhook
curl -X POST https://your-ngrok-url/webhooks/replit \
-H "Content-Type: application/json" \
-d '{"type": "test", "data": {}}'
For performance optimization, see replit-performance-tuning.