Расскажи про свой последний проект

Последний проект: Platform для управления подписками (SaaS)

Обзор проекта

Мой последний проект — это Backend часть SaaS платформы для управления подписками и платежами для мобильных приложений. Проект разработан на Node.js с использованием современного стека технологий.

Стек технологий

Backend:

• Runtime: Node.js 18 LTS
• Framework: Express.js + TypeScript
• База данных: PostgreSQL 14 с Sequelize ORM
• Кэширование: Redis
• Message Queue: RabbitMQ
• Авторизация: JWT + OAuth2 (Google, Apple)

Infrastructure:

• Docker + Docker Compose для локального развития
• AWS (EC2, RDS, S3, CloudFront)
• CI/CD: GitHub Actions
• Мониторинг: ELK Stack (Elasticsearch, Logstash, Kibana)

Мой роль в проекте

Я был Senior Backend Developer и отвечал за:

• Дизайн архитектуры микросервисов
• Разработку критичных модулей (платежи, подписки)
• Оптимизацию производительности
• Менторство junior разработчиков
• Code review и архитектурные решения

Архитектура проекта

Микросервисная архитектура из 4 основных сервисов:

// 1. API Gateway - маршрутизация запросов
// 2. Auth Service - управление пользователями и доступом
// 3. Subscription Service - управление подписками
// 4. Payment Service - интеграция с платёжными системами

Каждый сервис имеет:

• Собственную базу данных (Database per service pattern)
• REST API с OpenAPI документацией
• Юнит и интеграционные тесты
• Docker образ для развёртывания

Главные задачи, которые я решал

1. Обработка платежей в реальном времени

// Интеграция с Stripe и Apple Pay
const processPayment = async (userId: string, subscriptionId: string) => {
  try {
    // 1. Валидируем данные пользователя
    const user = await getUserById(userId);
    const subscription = await getSubscriptionById(subscriptionId);
    
    // 2. Создаём платёж
    const charge = await stripe.charges.create({
      amount: subscription.price * 100, // в центах
      currency: 'usd',
      customer: user.stripeId,
      description: `Subscription: ${subscription.name}`
    });
    
    // 3. Сохраняем в БД
    await createPaymentRecord({
      userId,
      subscriptionId,
      externalId: charge.id,
      amount: subscription.price,
      status: 'success'
    });
    
    // 4. Отправляем событие в очередь
    await publishEvent('payment.completed', {
      userId,
      subscriptionId,
      chargeId: charge.id
    });
    
    return { success: true, chargeId: charge.id };
  } catch (error) {
    logger.error('Payment failed', { userId, subscriptionId, error });
    throw new PaymentError(error.message);
  }
};

2. Система уведомлений и webhooks

Реализовал обработку webhook'ов от платёжных систем:

// Обработка webhook от Stripe
router.post('/webhooks/stripe', async (req, res) => {
  const sig = req.headers['stripe-signature'];
  
  try {
    // Верифицируем подпись от Stripe
    const event = stripe.webhooks.constructEvent(
      req.body,
      sig,
      process.env.STRIPE_WEBHOOK_SECRET
    );
    
    switch (event.type) {
      case 'customer.subscription.updated':
        await handleSubscriptionUpdated(event.data.object);
        break;
      case 'customer.subscription.deleted':
        await handleSubscriptionDeleted(event.data.object);
        break;
      case 'charge.failed':
        await handleChargeFailed(event.data.object);
        break;
    }
    
    res.json({ received: true });
  } catch (error) {
    logger.error('Webhook error', { error });
    res.status(400).json({ error: 'Invalid signature' });
  }
});

3. Оптимизация запросов к БД

// Использовал батчинг для сокращения N+1 queries
const getUsersWithSubscriptions = async (userIds: string[]) => {
  // Один запрос вместо N
  const users = await User.findAll({
    where: { id: userIds },
    include: [{
      model: Subscription,
      through: { attributes: ['activatedAt', 'expiresAt'] },
      include: [{ model: Plan }]
    }]
  });
  
  return users;
};

4. Асинхронная обработка с RabbitMQ

// Consumer для обработки платежей в очереди
const paymentConsumer = async (message) => {
  const { userId, subscriptionId, chargeId } = message;
  
  try {
    // Долгая операция - отправка писем, обновление аналитики
    await sendSubscriptionConfirmationEmail(userId);
    await updateAnalytics({
      event: 'subscription.activated',
      userId,
      subscriptionId
    });
    
    // Подтверждаем обработку сообщения
    channel.ack(message);
  } catch (error) {
    logger.error('Payment consumer error', { error });
    // Отправляем обратно в очередь для повтора
    channel.nack(message, false, true);
  }
};

Результаты и метрики

Performance:

• Время отклика API: среднее 200ms, p95 < 500ms
• Throughput: обработка 5000+ платежей в час
• Uptime: 99.95%

Качество:

• Test coverage: 92% (Unit + Integration)
• 0 critical bugs в production за последние 6 месяцев
• Code review: 100% coverage для всех изменений

Business:

• Поддерживаем 50+ клиентов
• Обработано 1M+ платежей
• Среднее значение платежа: $9.99
• Процент успешных платежей: 98.5%

Ключевые вызовы и их решение

1. Обеспечение консистентности данных

• Проблема: Race conditions при одновременных платежах
• Решение: Database transactions с уровнем изоляции SERIALIZABLE

2. Масштабируемость

• Проблема: Растущий трафик требовал оптимизации
• Решение: Горизонтальное масштабирование сервисов + кэширование

3. Безопасность платежей

• Проблема: Необходимость соответствия PCI DSS
• Решение: Никогда не сохраняем данные карт, используем Stripe API

Что я выучил

1. Важность архитектуры — хорошо продуманная система легче масштабировать
2. Тестирование критично — для платежей нужны максимальные гарантии
3. Мониторинг необходим — видеть проблемы сразу после их появления
4. Документация спасает — команда быстрее вникает в код
5. Менторство ценно — помогал junior разработчикам вырасти

Этот проект дал мне глубокое понимание того, как строятся production-grade системы, работающие с реальными деньгами и требующие максимальной надёжности.