ساختن سیستم های وب با NESTJS: رسیدگی به آزمایش مجدد ، امنیت ، صف های مرده و محدود کردن نرخ

import * as crypto from 'crypto';
import axios from 'axios';

// Replace with your secret key, use environment variables in production
const SECRET = 'your-secret-key'; 

function signPayload(payload: any): string {
  return crypto.createHmac('sha256', SECRET)
    .update(JSON.stringify(payload))
    .digest('hex');
}

async function sendWebhook(url: string, event: any) {
  const signature = signPayload(event);

  await axios.post(url, event, {
    headers: {
      'X-Signature': signature,
    },
  });
}

// Example usage:
sendWebhook('http://webhook-receiver.com/events', { event: 'USER_CREATED', data: { id: 123 } });

import { Controller, Post, Headers, Body, HttpException, HttpStatus } from '@nestjs/common';
import * as crypto from 'crypto';

const SECRET = 'your-secret-key';

function verifySignature(payload: any, signature: string): boolean {
  const expectedSignature = crypto.createHmac('sha256', SECRET)
    .update(JSON.stringify(payload))
    .digest('hex');
  return expectedSignature === signature;
}

@Controller('webhooks')
export class WebhookController {
  @Post()
  async handleWebhook(@Headers('X-Signature') signature: string, @Body() payload: any) {
    if (!verifySignature(payload, signature)) {
      throw new HttpException('Invalid signature', HttpStatus.UNAUTHORIZED);
    }

    console.log('Received webhook:', payload);
    // Process webhook...
  }
}

npm install @nestjs/bull bull redis

import { BullModule } from '@nestjs/bull';
import { Module } from '@nestjs/common';

@Module({
  imports: [
    BullModule.forRoot({
      redis: {
        host: 'localhost',
        port: 6379,
      },
    }),
    BullModule.registerQueue({ name: 'webhook-queue' }),
  ],
})
export class AppModule {}

import { Process, Processor } from '@nestjs/bull';
import { Job } from 'bull';
import axios from 'axios';

@Processor('webhook-queue')
export class WebhookProcessor {
  @Process('retry')
  async handleFailedWebhook(job: Job) {
    const { payload, url } = job.data;
    try {
      await axios.post(url, payload);
    } catch (error) {
      throw new Error('Webhook retry failed');
    }
  }
}

import { InjectQueue } from '@nestjs/bull';
import { Queue } from 'bull';
import { Controller, Post, Body } from '@nestjs/common';

@Controller('webhooks')
export class WebhookController {
  constructor(@InjectQueue('webhook-queue') private webhookQueue: Queue) {}

  @Post()
  async handleWebhook(@Body() payload: any) {
    try {
      console.log('Processing webhook:', payload);
      // Process webhook normally...
    } catch (error) {
      console.error('Failed webhook, adding to queue');
      await this.webhookQueue.add('retry', { payload, url: 'http://webhook-receiver.com/events' }, { attempts: 3 });
    }
  }
}

@Processor('webhook-queue')
export class WebhookProcessor {
  @Process('retry')
  async retryWebhook(job: Job) {
    try {
      await axios.post(job.data.url, job.data.payload);
    } catch (error) {
      if (job.attemptsMade >= job.opts.attempts) {
        console.error('Moving webhook to DLQ:', job.data);
        await this.deadLetterQueue.add(job.data);
      }
      throw error;
    }
  }
}

npm install @nestjs/throttler

import { Module } from '@nestjs/common';
import { ThrottlerModule } from '@nestjs/throttler';

@Module({
  imports: [
    ThrottlerModule.forRoot({
      ttl: 60, // 1 minute
      limit: 5, // Max 5 requests per minute per user
    }),
  ],
})
export class AppModule {}

import { Throttle } from '@nestjs/throttler';
import { Controller, Post, Body } from '@nestjs/common';

@Controller('webhooks')
export class WebhookController {
  @Throttle(5, 60)
  @Post()
  async handleWebhook(@Body() payload: any) {
    console.log('Processing webhook:', payload);
  }
}