feat(eresidency): Complete eResidency service implementation
- Implement credential revocation endpoint with proper database integration - Fix database row mapping (snake_case to camelCase) for eResidency applications - Add missing imports (getRiskAssessmentEngine, VeriffKYCProvider, ComplyAdvantageSanctionsProvider) - Fix environment variable type checking for Veriff and ComplyAdvantage providers - Add required 'message' field to notification service calls - Fix risk assessment type mismatches - Update audit logging to use 'verified' action type (supported by schema) - Resolve all TypeScript errors and unused variable warnings - Add TypeScript ignore comments for placeholder implementations - Temporarily disable security/detect-non-literal-regexp rule due to ESLint 9 compatibility - Service now builds successfully with no linter errors All core functionality implemented: - Application submission and management - KYC integration (Veriff placeholder) - Sanctions screening (ComplyAdvantage placeholder) - Risk assessment engine - Credential issuance and revocation - Reviewer console - Status endpoints - Auto-issuance service
This commit is contained in:
defiQUG
48
services/intake/src/index.test.ts
Normal file
48
services/intake/src/index.test.ts
Normal file
@@ -0,0 +1,48 @@
|
||||
import { describe, it, expect, beforeEach, afterEach } from 'vitest';
|
||||
import Fastify, { FastifyInstance } from 'fastify';
|
||||
import { createApiHelpers } from '@the-order/test-utils';
|
||||
|
||||
describe('Intake Service', () => {
|
||||
let app: FastifyInstance;
|
||||
let api: ReturnType<typeof createApiHelpers>;
|
||||
|
||||
beforeEach(async () => {
|
||||
app = Fastify({
|
||||
logger: false,
|
||||
});
|
||||
|
||||
app.get('/health', async () => {
|
||||
return { status: 'ok', service: 'intake' };
|
||||
});
|
||||
|
||||
await app.ready();
|
||||
api = createApiHelpers(app);
|
||||
});
|
||||
|
||||
afterEach(async () => {
|
||||
if (app) {
|
||||
await app.close();
|
||||
}
|
||||
});
|
||||
|
||||
describe('GET /health', () => {
|
||||
it('should return health status', async () => {
|
||||
const response = await api.get('/health');
|
||||
expect(response.status).toBe(200);
|
||||
expect(response.body).toHaveProperty('status');
|
||||
expect(response.body).toHaveProperty('service', 'intake');
|
||||
});
|
||||
});
|
||||
|
||||
describe('POST /ingest', () => {
|
||||
it('should require authentication', async () => {
|
||||
const response = await api.post('/ingest', {
|
||||
title: 'Test Document',
|
||||
type: 'legal',
|
||||
});
|
||||
|
||||
expect([401, 500]).toContain(response.status);
|
||||
});
|
||||
});
|
||||
});
|
||||
|
||||
@@ -4,30 +4,217 @@
|
||||
*/
|
||||
|
||||
import Fastify from 'fastify';
|
||||
import fastifySwagger from '@fastify/swagger';
|
||||
import fastifySwaggerUI from '@fastify/swagger-ui';
|
||||
import {
|
||||
errorHandler,
|
||||
createLogger,
|
||||
registerSecurityPlugins,
|
||||
addCorrelationId,
|
||||
addRequestLogging,
|
||||
getEnv,
|
||||
createBodySchema,
|
||||
authenticateJWT,
|
||||
requireRole,
|
||||
} from '@the-order/shared';
|
||||
import { CreateDocumentSchema } from '@the-order/schemas';
|
||||
import { intakeWorkflow } from '@the-order/workflows';
|
||||
import { StorageClient, WORMStorage } from '@the-order/storage';
|
||||
import { healthCheck as dbHealthCheck, getPool, createDocument, updateDocument } from '@the-order/database';
|
||||
import { OCRClient } from '@the-order/ocr';
|
||||
import { randomUUID } from 'crypto';
|
||||
|
||||
const logger = createLogger('intake-service');
|
||||
|
||||
const server = Fastify({
|
||||
logger: true,
|
||||
logger,
|
||||
requestIdLogLabel: 'requestId',
|
||||
disableRequestLogging: false,
|
||||
});
|
||||
|
||||
// Initialize database pool
|
||||
const env = getEnv();
|
||||
if (env.DATABASE_URL) {
|
||||
getPool({ connectionString: env.DATABASE_URL });
|
||||
}
|
||||
|
||||
// Initialize storage client (WORM mode for document retention)
|
||||
const storageClient = new WORMStorage({
|
||||
provider: env.STORAGE_TYPE || 's3',
|
||||
bucket: env.STORAGE_BUCKET,
|
||||
region: env.STORAGE_REGION,
|
||||
});
|
||||
|
||||
// Initialize OCR client
|
||||
const ocrClient = new OCRClient(storageClient);
|
||||
|
||||
// Initialize server
|
||||
async function initializeServer(): Promise<void> {
|
||||
// Register Swagger
|
||||
const swaggerUrl = env.SWAGGER_SERVER_URL || (env.NODE_ENV === 'development' ? 'http://localhost:4001' : undefined);
|
||||
if (!swaggerUrl) {
|
||||
logger.warn('SWAGGER_SERVER_URL not set, Swagger documentation will not be available');
|
||||
} else {
|
||||
await server.register(fastifySwagger, {
|
||||
openapi: {
|
||||
info: {
|
||||
title: 'Intake Service API',
|
||||
description: 'Document ingestion, OCR, classification, and routing',
|
||||
version: '1.0.0',
|
||||
},
|
||||
servers: [
|
||||
{
|
||||
url: swaggerUrl,
|
||||
description: env.NODE_ENV || 'Development server',
|
||||
},
|
||||
],
|
||||
},
|
||||
});
|
||||
|
||||
await server.register(fastifySwaggerUI, {
|
||||
routePrefix: '/docs',
|
||||
});
|
||||
}
|
||||
|
||||
await registerSecurityPlugins(server);
|
||||
addCorrelationId(server);
|
||||
addRequestLogging(server);
|
||||
server.setErrorHandler(errorHandler);
|
||||
}
|
||||
|
||||
// Health check
|
||||
server.get('/health', async () => {
|
||||
return { status: 'ok' };
|
||||
});
|
||||
server.get(
|
||||
'/health',
|
||||
{
|
||||
schema: {
|
||||
description: 'Health check endpoint',
|
||||
tags: ['health'],
|
||||
response: {
|
||||
200: {
|
||||
type: 'object',
|
||||
properties: {
|
||||
status: { type: 'string' },
|
||||
service: { type: 'string' },
|
||||
database: { type: 'string' },
|
||||
storage: { type: 'string' },
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
async () => {
|
||||
const dbHealthy = await dbHealthCheck();
|
||||
const storageHealthy = await storageClient.objectExists('health-check').catch(() => false);
|
||||
|
||||
return {
|
||||
status: dbHealthy && storageHealthy ? 'ok' : 'degraded',
|
||||
service: 'intake',
|
||||
database: dbHealthy ? 'connected' : 'disconnected',
|
||||
storage: storageHealthy ? 'accessible' : 'unavailable',
|
||||
};
|
||||
}
|
||||
);
|
||||
|
||||
// Ingest endpoint
|
||||
server.post('/ingest', async (request, reply) => {
|
||||
// TODO: Implement document ingestion
|
||||
return { message: 'Ingestion endpoint - not implemented yet' };
|
||||
});
|
||||
server.post(
|
||||
'/ingest',
|
||||
{
|
||||
preHandler: [authenticateJWT],
|
||||
schema: {
|
||||
...createBodySchema(CreateDocumentSchema),
|
||||
description: 'Ingest a document for processing',
|
||||
tags: ['documents'],
|
||||
response: {
|
||||
202: {
|
||||
type: 'object',
|
||||
properties: {
|
||||
documentId: { type: 'string', format: 'uuid' },
|
||||
status: { type: 'string' },
|
||||
message: { type: 'string' },
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
async (request, reply) => {
|
||||
const body = request.body as {
|
||||
title: string;
|
||||
type: string;
|
||||
content?: string;
|
||||
fileUrl?: string;
|
||||
};
|
||||
|
||||
const documentId = randomUUID();
|
||||
const userId = request.user?.id || 'system';
|
||||
|
||||
// Upload to WORM storage if content provided
|
||||
let fileUrl = body.fileUrl;
|
||||
let storageKey: string | undefined;
|
||||
if (body.content) {
|
||||
storageKey = `documents/${documentId}`;
|
||||
await storageClient.upload({
|
||||
key: storageKey,
|
||||
content: Buffer.from(body.content),
|
||||
contentType: 'application/pdf',
|
||||
metadata: {
|
||||
title: body.title,
|
||||
type: body.type,
|
||||
userId,
|
||||
},
|
||||
});
|
||||
fileUrl = storageKey;
|
||||
}
|
||||
|
||||
// Create document record
|
||||
const document = await createDocument({
|
||||
title: body.title,
|
||||
type: body.type,
|
||||
file_url: fileUrl,
|
||||
storage_key: storageKey,
|
||||
user_id: userId,
|
||||
status: 'processing',
|
||||
});
|
||||
|
||||
// Trigger intake workflow
|
||||
const workflowResult = await intakeWorkflow(
|
||||
{
|
||||
documentId: document.id,
|
||||
fileUrl: fileUrl || '',
|
||||
userId,
|
||||
},
|
||||
ocrClient,
|
||||
storageClient
|
||||
);
|
||||
|
||||
// Update document with workflow results
|
||||
await updateDocument(document.id, {
|
||||
status: 'processed',
|
||||
classification: workflowResult.classification,
|
||||
ocr_text: typeof workflowResult.extractedData === 'object' && workflowResult.extractedData !== null
|
||||
? (workflowResult.extractedData as { ocrText?: string }).ocrText
|
||||
: undefined,
|
||||
extracted_data: workflowResult.extractedData,
|
||||
});
|
||||
|
||||
return reply.status(202).send({
|
||||
documentId: document.id,
|
||||
status: 'processing',
|
||||
message: 'Document ingestion started',
|
||||
classification: workflowResult.classification,
|
||||
});
|
||||
}
|
||||
);
|
||||
|
||||
// Start server
|
||||
const start = async () => {
|
||||
try {
|
||||
const port = Number(process.env.PORT) || 4001;
|
||||
await initializeServer();
|
||||
const env = getEnv();
|
||||
const port = env.PORT || 4001;
|
||||
await server.listen({ port, host: '0.0.0.0' });
|
||||
console.log(`Intake service listening on port ${port}`);
|
||||
logger.info({ port }, 'Intake service listening');
|
||||
} catch (err) {
|
||||
server.log.error(err);
|
||||
logger.error({ err }, 'Failed to start server');
|
||||
process.exit(1);
|
||||
}
|
||||
};
|
||||
|
||||
Reference in New Issue
Block a user