feat(api): capa SAP con sesión compartida, mutex de login y cola de peticiones
- SapSessionService: una sesión para todos; un solo login aunque lleguen peticiones concurrentes o 401 simultáneos (loginInFlight); logout al apagar. - SapClientService: proxy con reintento único ante 401, errores SAP traducidos (SapHttpException) y fallos de red/TLS mapeados a 502/504. Un login rechazado se informa como 502, nunca 401 (el frontend lo toma como sesión web expirada). - Confianza TLS: SAPB1_SL_CA_FILE opcional (autofirmado de SAP o CA de firewall) sumado a las CA del sistema; VERIFY_SSL=true por defecto y no se puede apagar en producción. - SAPB1_SL_MAX_CONCURRENCY (default 1): medido en SAP10, más de ~2 peticiones en paralelo retrasan ~7 s cada una extra; en serie ~60 ms. - GET /api/health/sap, tests unitarios (MockAgent) y e2e opcional contra SAP real (SAP_LIVE=1). apps/api/certs documentado; *.pem/*.cer ignorados. Co-Authored-By: Claude Sonnet 5.5 <noreply@anthropic.com>
This commit is contained in:
1 parent
445efc998d
commit
bb4acb5510
19 files changed
+629
-22
No files matched your search
@@ -0,0 +1,94 @@
|
||||
import { Inject, Injectable, Logger } from '@nestjs/common';
|
||||
import { type Dispatcher, request } from 'undici';
|
||||
import { AppConfigService } from '../config/app-config.service.js';
|
||||
import { SAP_DISPATCHER } from './sap.constants.js';
|
||||
import { describeConnectionError, toSapException } from './sap-errors.js';
|
||||
import { type SapSession, SapSessionService } from './sap-session.service.js';
|
||||
|
||||
export type SapQuery = Record<string, string | number | boolean | undefined>;
|
||||
|
||||
export interface SapRequest {
|
||||
method: 'GET' | 'POST' | 'PATCH' | 'PUT' | 'DELETE';
|
||||
/** Ruta relativa al Service Layer, ej. `Items('A001')` o `Orders`. */
|
||||
path: string;
|
||||
query?: SapQuery;
|
||||
body?: unknown;
|
||||
/** Cabeceras B1S-* u otras que decide quien llama. */
|
||||
headers?: Record<string, string>;
|
||||
}
|
||||
|
||||
export interface SapResponse<T = unknown> {
|
||||
status: number;
|
||||
headers: Dispatcher.ResponseData['headers'];
|
||||
data: T;
|
||||
}
|
||||
|
||||
/** Proxy centralizado hacia el Service Layer con reautenticación transparente. */
|
||||
@Injectable()
|
||||
export class SapClientService {
|
||||
private readonly logger = new Logger(SapClientService.name);
|
||||
|
||||
constructor(
|
||||
private readonly config: AppConfigService,
|
||||
private readonly sessions: SapSessionService,
|
||||
@Inject(SAP_DISPATCHER) private readonly dispatcher: Dispatcher,
|
||||
) {}
|
||||
|
||||
async request<T = unknown>(req: SapRequest): Promise<SapResponse<T>> {
|
||||
let session = await this.sessions.getSession();
|
||||
let res = await this.send(session, req);
|
||||
|
||||
if (res.status === 401) {
|
||||
this.logger.warn(`Sesión SAP expirada (401) en ${req.method} ${req.path}; reautenticando`);
|
||||
session = await this.sessions.renew(session);
|
||||
res = await this.send(session, req);
|
||||
}
|
||||
|
||||
if (res.status >= 400) throw toSapException(res.status, res.text);
|
||||
return {
|
||||
status: res.status,
|
||||
headers: res.headers,
|
||||
data: (res.text ? JSON.parse(res.text) : undefined) as T,
|
||||
};
|
||||
}
|
||||
|
||||
get<T = unknown>(path: string, query?: SapQuery, headers?: Record<string, string>) {
|
||||
return this.request<T>({ method: 'GET', path, query, headers });
|
||||
}
|
||||
|
||||
private async send(session: SapSession, req: SapRequest) {
|
||||
const timeout = this.config.get('SAPB1_SL_TIMEOUT_MS');
|
||||
const url = `${this.config.get('SAPB1_SL_URL')}/${req.path}${buildQuery(req.query)}`;
|
||||
const started = Date.now();
|
||||
try {
|
||||
const res = await request(url, {
|
||||
method: req.method,
|
||||
dispatcher: this.dispatcher,
|
||||
headers: {
|
||||
'content-type': 'application/json',
|
||||
accept: 'application/json',
|
||||
...req.headers,
|
||||
cookie: session.cookie,
|
||||
},
|
||||
body: req.body === undefined ? undefined : JSON.stringify(req.body),
|
||||
headersTimeout: timeout,
|
||||
bodyTimeout: timeout,
|
||||
});
|
||||
const text = await res.body.text();
|
||||
this.logger.debug(`${req.method} ${req.path} -> ${res.statusCode} (${Date.now() - started} ms)`);
|
||||
return { status: res.statusCode, headers: res.headers, text };
|
||||
} catch (err) {
|
||||
this.logger.error(`${req.method} ${req.path}: ${(err as Error).message}`);
|
||||
throw describeConnectionError(err);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/** Codifica los valores (no las claves `$filter`, `$top`...) con %20 para espacios. */
|
||||
export function buildQuery(query?: SapQuery): string {
|
||||
if (!query) return '';
|
||||
const parts = Object.entries(query)
|
||||
.filter(([, v]) => v !== undefined && v !== '')
|
||||
.map(([k, v]) => `${k}=${encodeURIComponent(String(v))}`);
|
||||
return parts.length ? `?${parts.join('&')}` : '';
|
||||
}
|
||||
Reference in new issue
Block a user