apps/api/src/app/shared/utils/mappers.ts - next - githubmirror/novu

apps/api/src/app/shared/utils/mappers.ts

61 строка2 KB

George Djabarov

feat(worker): surface inbound-email requests in activity log fixes NV-7927 (#11379)

01 июн 2026, 21:19

01 июн 2026, 21:19e3ec0c1

import { LogRepository, RequestLog, RequestLogSourceEnum } from '@novu/application-generic';
import { UserSessionData } from '@novu/shared';
import { getClientIp } from 'request-ip';
import { sanitizePayload } from '../../../utils/payload-sanitizer';
import { generateTransactionId } from '../helpers/generate-transaction-id';
import { RequestWithReqId } from '../middleware/request-id.middleware';
import { getRequestId } from './request-transaction.util';

function extractTransactionIdFromBody(body: unknown): string | undefined {
  if (!body || typeof body !== 'object') return undefined;

  const singleBody = body as { transactionId?: string };
  if (singleBody.transactionId) return singleBody.transactionId;

  const bulkBody = body as { events?: Array<{ transactionId?: string }> };
  if (Array.isArray(bulkBody.events)) {
    const ids = bulkBody.events.map((e) => e.transactionId).filter(Boolean);
    if (ids.length > 0) return ids.join(',');
  }

  return undefined;
}

export function buildLog(
  req: RequestWithReqId,
  statusCode: number,
  data: any,
  user: UserSessionData | null,
  duration: number = 0
): Omit<RequestLog, 'expires_at'> | null {
  // Skip logging when user data is incomplete to prevent orphaned log entries
  if (!user?._id || !user?.organizationId || !user?.environmentId || !user?.scheme) return null;

  const requestId = getRequestId(req);

  if (!requestId) {
    return null;
  }

  return {
    id: requestId,
    created_at: LogRepository.formatDateTime64(new Date()),
    path: req.path,
    url: req.originalUrl,
    url_pattern: req.route.path,
    hostname: req.hostname,
    status_code: statusCode,
    method: req.method,
    transaction_id: extractTransactionIdFromBody(req.body) || generateTransactionId(),
    ip: getClientIp(req) || '',
    user_agent: req.headers['user-agent'] || '',
    request_body: sanitizePayload(req.body),
    response_body: sanitizePayload(data),
    user_id: user._id,
    organization_id: user.organizationId,
    environment_id: user.environmentId,
    auth_type: user.scheme,
    duration_ms: duration,
    source: RequestLogSourceEnum.HTTP,
  };
}