- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| src | -
-
- |
- 84.61% | -22/26 | -33.33% | -1/3 | -100% | -0/0 | -84.61% | -22/26 | -
| src/container | -
-
- |
- 100% | -82/82 | -100% | -14/14 | -100% | -10/10 | -100% | -82/82 | -
| src/models | -
-
- |
- 100% | -61/61 | -100% | -3/3 | -100% | -0/0 | -100% | -61/61 | -
| src/repositories/memory | -
-
- |
- 100% | -247/247 | -98.36% | -60/61 | -100% | -30/30 | -100% | -247/247 | -
| src/routes | -
-
- |
- 100% | -179/179 | -93.87% | -46/49 | -100% | -0/0 | -100% | -179/179 | -
| src/services | -
-
- |
- 100% | -170/170 | -100% | -36/36 | -100% | -15/15 | -100% | -170/170 | -
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| migrations.ts | -
-
- |
- 100% | -98/98 | -100% | -12/12 | -100% | -6/6 | -100% | -98/98 | -
| validate-schema.ts | -
-
- |
- 100% | -34/34 | -100% | -6/6 | -100% | -2/2 | -100% | -34/34 | -
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 -78 -79 -80 -81 -82 -83 -84 -85 -86 -87 -88 -89 -90 -91 -92 -93 -94 -95 -96 -97 -98 -99 | 1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -5x -5x -5x -1x -1x -1x -1x -3x -3x -3x -3x -3x -3x -3x -3x -1x -1x -1x -1x -1x -6x -5x -5x -1x -1x -1x -1x -4x -4x -4x -4x -4x -4x -4x -4x -1x -1x -1x -1x -2x -2x -2x -2x -2x -2x -2x -2x -2x -2x -2x -2x -2x -2x -1x -1x -1x -1x -1x -2x -2x -2x -2x -2x -2x -2x -2x -2x -2x -2x -1x -1x -1x -1x -2x -2x - | import { readdir, readFile } from 'fs/promises';
-import { join } from 'path';
-import type { DbClient } from './client.js';
-
-const SCHEMA_MIGRATIONS_TABLE = `
-CREATE TABLE IF NOT EXISTS schema_migrations (
- version TEXT PRIMARY KEY,
- applied_at TIMESTAMPTZ NOT NULL DEFAULT now()
-);
-`;
-
-/** Expected core tables that must exist after initial schema. */
-export const EXPECTED_TABLES = [
- 'borrowers',
- 'credit_lines',
- 'risk_evaluations',
- 'transactions',
- 'events',
-] as const;
-
-/**
- * Ensure schema_migrations table exists (for first-run or standalone migration).
- */
-export async function ensureSchemaMigrations(client: DbClient): Promise<void> {
- await client.query(SCHEMA_MIGRATIONS_TABLE);
-}
-
-/**
- * Return sorted list of migration filenames (e.g. 001_initial_schema.sql) in the given directory.
- */
-export async function listMigrationFiles(dir: string): Promise<string[]> {
- const entries = await readdir(dir, { withFileTypes: true });
- const files = entries
- .filter((e) => e.isFile() && e.name.endsWith('.sql'))
- .map((e) => e.name)
- .sort();
- return files;
-}
-
-/**
- * Extract version string from migration filename (e.g. 001_initial_schema.sql -> 001_initial_schema).
- */
-export function versionFromFilename(filename: string): string {
- if (!filename.endsWith('.sql')) return filename;
- return filename.slice(0, -4);
-}
-
-/**
- * Get applied migration versions from schema_migrations.
- */
-export async function getAppliedVersions(client: DbClient): Promise<string[]> {
- await ensureSchemaMigrations(client);
- const result = await client.query(
- 'SELECT version FROM schema_migrations ORDER BY version'
- );
- const rows = result.rows as { version: string }[];
- return rows.map((r) => r.version);
-}
-
-/**
- * Apply a single migration file (run its SQL and record version).
- */
-export async function applyMigration(
- client: DbClient,
- migrationsDir: string,
- filename: string
-): Promise<void> {
- const path = join(migrationsDir, filename);
- const sql = await readFile(path, 'utf-8');
- await client.query(sql);
- const version = versionFromFilename(filename);
- await client.query(
- 'INSERT INTO schema_migrations (version, applied_at) VALUES ($1, now()) ON CONFLICT (version) DO NOTHING',
- [version]
- );
-}
-
-/**
- * Run all pending migrations in the given directory.
- * Uses process.cwd() if migrationsDir is not absolute to resolve relative to cwd.
- */
-export async function runPendingMigrations(
- client: DbClient,
- migrationsDir: string
-): Promise<string[]> {
- const applied = await getAppliedVersions(client);
- const files = await listMigrationFiles(migrationsDir);
- const appliedSet = new Set(applied);
- const run: string[] = [];
- for (const file of files) {
- const version = versionFromFilename(file);
- if (appliedSet.has(version)) continue;
- await applyMigration(client, migrationsDir, file);
- run.push(version);
- appliedSet.add(version);
- }
- return run;
-}
- |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 | 1x -1x -1x -1x -1x -1x -1x -7x -7x -7x -7x -7x -7x -7x -7x -7x -7x -7x -7x -7x -7x -7x -7x -1x -1x -1x -1x -1x -3x -3x -3x -2x -2x -3x - | import type { DbClient } from './client.js';
-import { EXPECTED_TABLES } from './migrations.js';
-
-/**
- * Check that the given tables exist in the current schema (public).
- * Returns list of missing table names; empty if all exist.
- */
-export async function missingTables(
- client: DbClient,
- tables: readonly string[] = EXPECTED_TABLES
-): Promise<string[]> {
- const placeholders = tables.map((_, i) => `$${i + 1}`).join(', ');
- const result = await client.query(
- `SELECT table_name FROM information_schema.tables
- WHERE table_schema = 'public' AND table_name IN (${placeholders})`,
- [...tables]
- );
- const found = (result.rows as { table_name: string }[]).map(
- (r) => r.table_name
- );
- const foundSet = new Set(found);
- return tables.filter((t) => !foundSet.has(t));
-}
-
-/**
- * Validate that the core schema is present (all EXPECTED_TABLES exist).
- * Throws if any are missing.
- */
-export async function validateSchema(client: DbClient): Promise<void> {
- const missing = await missingTables(client);
- if (missing.length > 0) {
- throw new Error(`Missing tables: ${missing.join(', ')}`);
- }
-}
- |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 -78 -79 -80 -81 -82 | 1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -10x -10x -10x -10x -10x -10x -1x -1x -10x -10x -10x -10x -10x -10x -10x -10x -10x -1x -1x -15x -10x -10x -15x -15x -1x -1x -1x -63x -63x -1x -1x -57x -57x -1x -1x -5x -5x -1x -1x -1x -44x -44x -1x -1x -32x -32x -1x -1x -1x -5x -5x -5x -5x -5x -3x -3x -3x -5x -5x -2x -2x -2x -5x -5x -2x -2x -5x -1x | import { CreditLineRepository } from '../repositories/interfaces/CreditLineRepository.js';
-import { RiskEvaluationRepository } from '../repositories/interfaces/RiskEvaluationRepository.js';
-import { TransactionRepository } from '../repositories/interfaces/TransactionRepository.js';
-import { InMemoryCreditLineRepository } from '../repositories/memory/InMemoryCreditLineRepository.js';
-import { InMemoryRiskEvaluationRepository } from '../repositories/memory/InMemoryRiskEvaluationRepository.js';
-import { InMemoryTransactionRepository } from '../repositories/memory/InMemoryTransactionRepository.js';
-import { CreditLineService } from '../services/CreditLineService.js';
-import { RiskEvaluationService } from '../services/RiskEvaluationService.js';
-
-export class Container {
- private static instance: Container;
-
- // Repositories
- private _creditLineRepository: CreditLineRepository;
- private _riskEvaluationRepository: RiskEvaluationRepository;
- private _transactionRepository: TransactionRepository;
-
- // Services
- private _creditLineService: CreditLineService;
- private _riskEvaluationService: RiskEvaluationService;
-
- private constructor() {
- // Initialize repositories (in-memory implementations for now)
- this._creditLineRepository = new InMemoryCreditLineRepository();
- this._riskEvaluationRepository = new InMemoryRiskEvaluationRepository();
- this._transactionRepository = new InMemoryTransactionRepository();
-
- // Initialize services
- this._creditLineService = new CreditLineService(this._creditLineRepository);
- this._riskEvaluationService = new RiskEvaluationService(this._riskEvaluationRepository);
- }
-
- public static getInstance(): Container {
- if (!Container.instance) {
- Container.instance = new Container();
- }
- return Container.instance;
- }
-
- // Repository getters
- get creditLineRepository(): CreditLineRepository {
- return this._creditLineRepository;
- }
-
- get riskEvaluationRepository(): RiskEvaluationRepository {
- return this._riskEvaluationRepository;
- }
-
- get transactionRepository(): TransactionRepository {
- return this._transactionRepository;
- }
-
- // Service getters
- get creditLineService(): CreditLineService {
- return this._creditLineService;
- }
-
- get riskEvaluationService(): RiskEvaluationService {
- return this._riskEvaluationService;
- }
-
- // Method to replace repositories (useful for testing or switching to DB implementations)
- public setRepositories(repositories: {
- creditLineRepository?: CreditLineRepository;
- riskEvaluationRepository?: RiskEvaluationRepository;
- transactionRepository?: TransactionRepository;
- }): void {
- if (repositories.creditLineRepository) {
- this._creditLineRepository = repositories.creditLineRepository;
- this._creditLineService = new CreditLineService(this._creditLineRepository);
- }
-
- if (repositories.riskEvaluationRepository) {
- this._riskEvaluationRepository = repositories.riskEvaluationRepository;
- this._riskEvaluationService = new RiskEvaluationService(this._riskEvaluationRepository);
- }
-
- if (repositories.transactionRepository) {
- this._transactionRepository = repositories.transactionRepository;
- }
- }
-} |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| Container.ts | -
-
- |
- 100% | -82/82 | -100% | -14/14 | -100% | -10/10 | -100% | -82/82 | -
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| index.ts | -
-
- |
- 84.61% | -22/26 | -33.33% | -1/3 | -100% | -0/0 | -84.61% | -22/26 | -
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 | 1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x - - - - -1x -1x - | import express from 'express';
-import cors from 'cors';
-import { creditRouter } from './routes/credit.js';
-import { riskRouter } from './routes/risk.js';
-
-const app = express();
-const port = process.env.PORT ?? 3000;
-
-app.use(cors());
-app.use(express.json());
-
-app.get('/health', (_req, res) => {
- res.json({ status: 'ok', service: 'creditra-backend' });
-});
-
-app.use('/api/credit', creditRouter);
-app.use('/api/risk', riskRouter);
-
-// Only start server if this file is run directly (not imported for testing)
-if (import.meta.url === `file://${process.argv[1]}`) {
- app.listen(port, () => {
- console.log(`Creditra API listening on http://localhost:${port}`);
- });
-}
-
-export default app;
- |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 | 1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x | export interface CreditLine {
- id: string;
- walletAddress: string;
- creditLimit: string; // Using string for precise decimal handling
- availableCredit: string;
- interestRateBps: number; // Basis points (e.g., 500 = 5%)
- status: CreditLineStatus;
- createdAt: Date;
- updatedAt: Date;
-}
-
-export enum CreditLineStatus {
- ACTIVE = 'active',
- SUSPENDED = 'suspended',
- CLOSED = 'closed',
- PENDING = 'pending'
-}
-
-export interface CreateCreditLineRequest {
- walletAddress: string;
- creditLimit: string;
- interestRateBps: number;
-}
-
-export interface UpdateCreditLineRequest {
- creditLimit?: string;
- interestRateBps?: number;
- status?: CreditLineStatus;
-} |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 | 1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x -1x | export interface Transaction {
- id: string;
- creditLineId: string;
- walletAddress: string;
- amount: string;
- type: TransactionType;
- status: TransactionStatus;
- blockchainTxHash?: string;
- createdAt: Date;
- processedAt?: Date;
-}
-
-export enum TransactionType {
- BORROW = 'borrow',
- REPAY = 'repay',
- INTEREST_ACCRUAL = 'interest_accrual',
- FEE = 'fee'
-}
-
-export enum TransactionStatus {
- PENDING = 'pending',
- CONFIRMED = 'confirmed',
- FAILED = 'failed',
- CANCELLED = 'cancelled'
-}
-
-export interface CreateTransactionRequest {
- creditLineId: string;
- amount: string;
- type: TransactionType;
- blockchainTxHash?: string;
-} |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| CreditLine.ts | -
-
- |
- 100% | -29/29 | -100% | -1/1 | -100% | -0/0 | -100% | -29/29 | -
| Transaction.ts | -
-
- |
- 100% | -32/32 | -100% | -2/2 | -100% | -0/0 | -100% | -32/32 | -
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 -78 -79 -80 -81 -82 -83 -84 | 1x -1x -1x -1x -1x -1x -1x -1x -27x -27x -27x -27x -27x -27x -27x -27x -27x -27x -27x -27x -27x -27x -27x -27x -27x -1x -1x -7x -7x -1x -1x -4x -4x -4x -1x -1x -5x -5x -5x -1x -1x -6x -6x -2x -2x -4x -4x -4x -4x -4x -4x -4x -4x -6x -3x -3x -3x -3x -3x -3x -3x -3x -4x -4x -4x -6x -1x -1x -4x -4x -1x -1x -2x -2x -1x -1x -6x -6x -1x -1x -1x -20x -20x -1x | import { CreditLine, CreateCreditLineRequest, UpdateCreditLineRequest, CreditLineStatus } from '../../models/CreditLine.js';
-import { CreditLineRepository } from '../interfaces/CreditLineRepository.js';
-import { randomUUID } from 'crypto';
-
-export class InMemoryCreditLineRepository implements CreditLineRepository {
- private creditLines: Map<string, CreditLine> = new Map();
-
- async create(request: CreateCreditLineRequest): Promise<CreditLine> {
- const id = randomUUID();
- const now = new Date();
-
- const creditLine: CreditLine = {
- id,
- walletAddress: request.walletAddress,
- creditLimit: request.creditLimit,
- availableCredit: request.creditLimit, // Initially full credit available
- interestRateBps: request.interestRateBps,
- status: CreditLineStatus.ACTIVE,
- createdAt: now,
- updatedAt: now
- };
-
- this.creditLines.set(id, creditLine);
- return creditLine;
- }
-
- async findById(id: string): Promise<CreditLine | null> {
- return this.creditLines.get(id) || null;
- }
-
- async findByWalletAddress(walletAddress: string): Promise<CreditLine[]> {
- return Array.from(this.creditLines.values())
- .filter(cl => cl.walletAddress === walletAddress);
- }
-
- async findAll(offset = 0, limit = 100): Promise<CreditLine[]> {
- const all = Array.from(this.creditLines.values());
- return all.slice(offset, offset + limit);
- }
-
- async update(id: string, request: UpdateCreditLineRequest): Promise<CreditLine | null> {
- const existing = this.creditLines.get(id);
- if (!existing) {
- return null;
- }
-
- const updated: CreditLine = {
- ...existing,
- ...request,
- updatedAt: new Date()
- };
-
- // If credit limit changed, adjust available credit proportionally
- if (request.creditLimit && request.creditLimit !== existing.creditLimit) {
- const oldLimit = parseFloat(existing.creditLimit);
- const newLimit = parseFloat(request.creditLimit);
- const oldAvailable = parseFloat(existing.availableCredit);
-
- // Maintain the same ratio of available credit
- const ratio = oldLimit > 0 ? oldAvailable / oldLimit : 1;
- updated.availableCredit = (newLimit * ratio).toString();
- }
-
- this.creditLines.set(id, updated);
- return updated;
- }
-
- async delete(id: string): Promise<boolean> {
- return this.creditLines.delete(id);
- }
-
- async exists(id: string): Promise<boolean> {
- return this.creditLines.has(id);
- }
-
- async count(): Promise<number> {
- return this.creditLines.size;
- }
-
- // Helper method for testing
- clear(): void {
- this.creditLines.clear();
- }
-} |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 | 1x -1x -1x -1x -1x -1x -1x -1x -31x -31x -31x -31x -31x -31x -31x -31x -31x -1x -1x -16x -16x -16x -16x -16x -16x -1x -1x -4x -4x -1x -1x -6x -6x -6x -6x -6x -6x -1x -1x -1x -1x -1x -1x -2x -1x -1x -1x -2x -1x -1x -1x -1x -1x -10x -10x -7x -7x -3x -3x -10x -1x -1x -3x -3x -3x -3x -3x -1x -1x -2x -2x -1x -1x -1x -17x -17x -1x | import { RiskEvaluation } from '../../models/RiskEvaluation.js';
-import { RiskEvaluationRepository } from '../interfaces/RiskEvaluationRepository.js';
-import { randomUUID } from 'crypto';
-
-export class InMemoryRiskEvaluationRepository implements RiskEvaluationRepository {
- private evaluations: Map<string, RiskEvaluation> = new Map();
-
- async save(evaluation: Omit<RiskEvaluation, 'id'>): Promise<RiskEvaluation> {
- const id = randomUUID();
- const newEvaluation: RiskEvaluation = {
- id,
- ...evaluation
- };
-
- this.evaluations.set(id, newEvaluation);
- return newEvaluation;
- }
-
- async findLatestByWalletAddress(walletAddress: string): Promise<RiskEvaluation | null> {
- const evaluations = Array.from(this.evaluations.values())
- .filter(evaluation => evaluation.walletAddress === walletAddress)
- .sort((a, b) => b.evaluatedAt.getTime() - a.evaluatedAt.getTime());
-
- return evaluations[0] || null;
- }
-
- async findById(id: string): Promise<RiskEvaluation | null> {
- return this.evaluations.get(id) || null;
- }
-
- async findByWalletAddress(walletAddress: string, offset = 0, limit = 100): Promise<RiskEvaluation[]> {
- const filtered = Array.from(this.evaluations.values())
- .filter(evaluation => evaluation.walletAddress === walletAddress)
- .sort((a, b) => b.evaluatedAt.getTime() - a.evaluatedAt.getTime());
-
- return filtered.slice(offset, offset + limit);
- }
-
- async deleteExpired(): Promise<number> {
- const now = new Date();
- let deletedCount = 0;
-
- for (const [id, evaluation] of this.evaluations.entries()) {
- if (evaluation.expiresAt < now) {
- this.evaluations.delete(id);
- deletedCount++;
- }
- }
-
- return deletedCount;
- }
-
- async isValid(walletAddress: string): Promise<boolean> {
- const latest = await this.findLatestByWalletAddress(walletAddress);
- if (!latest) {
- return false;
- }
-
- return latest.expiresAt > new Date();
- }
-
- async findAll(offset = 0, limit = 100): Promise<RiskEvaluation[]> {
- const all = Array.from(this.evaluations.values())
- .sort((a, b) => b.evaluatedAt.getTime() - a.evaluatedAt.getTime());
-
- return all.slice(offset, offset + limit);
- }
-
- async count(): Promise<number> {
- return this.evaluations.size;
- }
-
- // Helper method for testing
- clear(): void {
- this.evaluations.clear();
- }
-} |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 -78 -79 -80 -81 -82 -83 -84 -85 -86 | 1x -1x -1x -1x -1x -1x -1x -1x -35x -35x -35x -35x -35x -35x -35x -35x -35x -35x -35x -35x -35x -35x -35x -35x -35x -1x -1x -2x -2x -1x -1x -3x -3x -3x -3x -3x -3x -1x -1x -2x -2x -2x -2x -2x -2x -1x -1x -4x -4x -1x -1x -3x -3x -3x -3x -4x -4x -4x -4x -4x -4x -1x -1x -2x -2x -2x -2x -2x -1x -1x -3x -3x -1x -1x -4x -4x -4x -4x -4x -4x -1x -1x -1x -1x -1x -1x | import { Transaction, CreateTransactionRequest, TransactionStatus, TransactionType } from '../../models/Transaction.js';
-import { TransactionRepository } from '../interfaces/TransactionRepository.js';
-import { randomUUID } from 'crypto';
-
-export class InMemoryTransactionRepository implements TransactionRepository {
- private transactions: Map<string, Transaction> = new Map();
-
- async create(request: CreateTransactionRequest): Promise<Transaction> {
- const id = randomUUID();
- const now = new Date();
-
- const transaction: Transaction = {
- id,
- creditLineId: request.creditLineId,
- walletAddress: '', // Will be set by service layer
- amount: request.amount,
- type: request.type,
- status: TransactionStatus.PENDING,
- blockchainTxHash: request.blockchainTxHash,
- createdAt: now
- };
-
- this.transactions.set(id, transaction);
- return transaction;
- }
-
- async findById(id: string): Promise<Transaction | null> {
- return this.transactions.get(id) || null;
- }
-
- async findByCreditLineId(creditLineId: string, offset = 0, limit = 100): Promise<Transaction[]> {
- const filtered = Array.from(this.transactions.values())
- .filter(tx => tx.creditLineId === creditLineId)
- .sort((a, b) => b.createdAt.getTime() - a.createdAt.getTime());
-
- return filtered.slice(offset, offset + limit);
- }
-
- async findByWalletAddress(walletAddress: string, offset = 0, limit = 100): Promise<Transaction[]> {
- const filtered = Array.from(this.transactions.values())
- .filter(tx => tx.walletAddress === walletAddress)
- .sort((a, b) => b.createdAt.getTime() - a.createdAt.getTime());
-
- return filtered.slice(offset, offset + limit);
- }
-
- async updateStatus(id: string, status: TransactionStatus, processedAt?: Date): Promise<Transaction | null> {
- const existing = this.transactions.get(id);
- if (!existing) {
- return null;
- }
-
- const updated: Transaction = {
- ...existing,
- status,
- processedAt: processedAt || new Date()
- };
-
- this.transactions.set(id, updated);
- return updated;
- }
-
- async findAll(offset = 0, limit = 100): Promise<Transaction[]> {
- const all = Array.from(this.transactions.values())
- .sort((a, b) => b.createdAt.getTime() - a.createdAt.getTime());
-
- return all.slice(offset, offset + limit);
- }
-
- async count(): Promise<number> {
- return this.transactions.size;
- }
-
- async findByStatus(status: TransactionStatus, offset = 0, limit = 100): Promise<Transaction[]> {
- const filtered = Array.from(this.transactions.values())
- .filter(tx => tx.status === status)
- .sort((a, b) => b.createdAt.getTime() - a.createdAt.getTime());
-
- return filtered.slice(offset, offset + limit);
- }
-
- // Helper method for testing
- clear(): void {
- this.transactions.clear();
- }
-} |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| InMemoryCreditLineRepository.ts | -
-
- |
- 100% | -84/84 | -94.73% | -18/19 | -100% | -10/10 | -100% | -84/84 | -
| InMemoryRiskEvaluationRepository.ts | -
-
- |
- 100% | -77/77 | -100% | -21/21 | -100% | -10/10 | -100% | -77/77 | -
| InMemoryTransactionRepository.ts | -
-
- |
- 100% | -86/86 | -100% | -21/21 | -100% | -10/10 | -100% | -86/86 | -
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 -78 -79 -80 -81 -82 -83 -84 -85 -86 -87 -88 -89 -90 -91 -92 -93 -94 -95 -96 -97 -98 -99 -100 -101 -102 -103 -104 -105 -106 -107 -108 -109 | 1x -1x -1x -1x -1x -1x -1x -4x -4x -4x -4x -4x -4x -3x -3x -3x -3x -3x -3x -3x -4x -4x -4x -4x -1x -1x -4x -1x -1x -3x -3x -2x -3x -1x -1x -1x -1x -1x -1x -1x -3x -1x -1x -4x -4x -4x -4x -2x -2x -2x -2x -2x -2x -2x -2x -2x -2x -1x -1x -1x -1x -1x -1x -4x -1x -1x -4x -4x -4x -4x -4x -4x -4x -4x -2x -4x -1x -1x -1x -1x -4x -2x -2x -2x -4x -1x -1x -3x -3x -2x -3x -1x -1x -1x -1x -1x -1x -1x -3x -1x -1x -3x -3x -2x -3x -1x -1x -3x - | import { Router } from 'express';
-import { Container } from '../container/Container.js';
-
-export const creditRouter = Router();
-const container = Container.getInstance();
-
-creditRouter.get('/lines', async (req, res) => {
- try {
- const { offset, limit } = req.query;
- const offsetNum = offset ? parseInt(offset as string) : undefined;
- const limitNum = limit ? parseInt(limit as string) : undefined;
-
- const creditLines = await container.creditLineService.getAllCreditLines(offsetNum, limitNum);
- const total = await container.creditLineService.getCreditLineCount();
-
- res.json({
- creditLines,
- pagination: {
- total,
- offset: offsetNum || 0,
- limit: limitNum || 100
- }
- });
- } catch (error) {
- res.status(500).json({ error: 'Failed to fetch credit lines' });
- }
-});
-
-creditRouter.get('/lines/:id', async (req, res) => {
- try {
- const creditLine = await container.creditLineService.getCreditLine(req.params.id);
-
- if (!creditLine) {
- return res.status(404).json({ error: 'Credit line not found', id: req.params.id });
- }
-
- res.json(creditLine);
- } catch (error) {
- res.status(500).json({ error: 'Failed to fetch credit line' });
- }
-});
-
-creditRouter.post('/lines', async (req, res) => {
- try {
- const { walletAddress, creditLimit, interestRateBps } = req.body;
-
- if (!walletAddress || !creditLimit || interestRateBps === undefined) {
- return res.status(400).json({
- error: 'Missing required fields: walletAddress, creditLimit, interestRateBps'
- });
- }
-
- const creditLine = await container.creditLineService.createCreditLine({
- walletAddress,
- creditLimit,
- interestRateBps
- });
-
- res.status(201).json(creditLine);
- } catch (error) {
- const message = error instanceof Error ? error.message : 'Failed to create credit line';
- res.status(400).json({ error: message });
- }
-});
-
-creditRouter.put('/lines/:id', async (req, res) => {
- try {
- const { creditLimit, interestRateBps, status } = req.body;
-
- const creditLine = await container.creditLineService.updateCreditLine(req.params.id, {
- creditLimit,
- interestRateBps,
- status
- });
-
- if (!creditLine) {
- return res.status(404).json({ error: 'Credit line not found', id: req.params.id });
- }
-
- res.json(creditLine);
- } catch (error) {
- const message = error instanceof Error ? error.message : 'Failed to update credit line';
- res.status(400).json({ error: message });
- }
-});
-
-creditRouter.delete('/lines/:id', async (req, res) => {
- try {
- const deleted = await container.creditLineService.deleteCreditLine(req.params.id);
-
- if (!deleted) {
- return res.status(404).json({ error: 'Credit line not found', id: req.params.id });
- }
-
- res.status(204).send();
- } catch (error) {
- res.status(500).json({ error: 'Failed to delete credit line' });
- }
-});
-
-creditRouter.get('/wallet/:walletAddress/lines', async (req, res) => {
- try {
- const creditLines = await container.creditLineService.getCreditLinesByWallet(req.params.walletAddress);
- res.json({ creditLines });
- } catch (error) {
- res.status(500).json({ error: 'Failed to fetch credit lines for wallet' });
- }
-});
- |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 | 1x -1x -1x -1x -1x -1x -1x -9x -9x -9x -9x -2x -2x -7x -7x -7x -7x -7x -6x -6x -9x -1x -1x -1x -9x -1x -1x -3x -3x -2x -3x -1x -1x -1x -1x -1x -1x -1x -3x -1x -1x -3x -3x -2x -3x -1x -1x -1x -1x -1x -1x -1x -3x -1x -1x -5x -5x -5x -5x -5x -5x -5x -5x -5x -5x -4x -4x -5x -1x -1x -5x - | import { Router } from 'express';
-import { Container } from '../container/Container.js';
-
-export const riskRouter = Router();
-const container = Container.getInstance();
-
-riskRouter.post('/evaluate', async (req, res) => {
- try {
- const { walletAddress, forceRefresh } = req.body ?? {};
-
- if (!walletAddress) {
- return res.status(400).json({ error: 'walletAddress required' });
- }
-
- const result = await container.riskEvaluationService.evaluateRisk({
- walletAddress,
- forceRefresh
- });
-
- res.json(result);
- } catch (error) {
- const message = error instanceof Error ? error.message : 'Risk evaluation failed';
- res.status(500).json({ error: message });
- }
-});
-
-riskRouter.get('/evaluations/:id', async (req, res) => {
- try {
- const evaluation = await container.riskEvaluationService.getRiskEvaluation(req.params.id);
-
- if (!evaluation) {
- return res.status(404).json({ error: 'Risk evaluation not found', id: req.params.id });
- }
-
- res.json(evaluation);
- } catch (error) {
- res.status(500).json({ error: 'Failed to fetch risk evaluation' });
- }
-});
-
-riskRouter.get('/wallet/:walletAddress/latest', async (req, res) => {
- try {
- const evaluation = await container.riskEvaluationService.getLatestRiskEvaluation(req.params.walletAddress);
-
- if (!evaluation) {
- return res.status(404).json({ error: 'No risk evaluation found for wallet' });
- }
-
- res.json(evaluation);
- } catch (error) {
- res.status(500).json({ error: 'Failed to fetch latest risk evaluation' });
- }
-});
-
-riskRouter.get('/wallet/:walletAddress/history', async (req, res) => {
- try {
- const { offset, limit } = req.query;
- const offsetNum = offset ? parseInt(offset as string) : undefined;
- const limitNum = limit ? parseInt(limit as string) : undefined;
-
- const evaluations = await container.riskEvaluationService.getRiskEvaluationHistory(
- req.params.walletAddress,
- offsetNum,
- limitNum
- );
-
- res.json({ evaluations });
- } catch (error) {
- res.status(500).json({ error: 'Failed to fetch risk evaluation history' });
- }
-});
- |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 | 1x -1x -1x -1x -1x -1x -1x -15x -15x -1x -1x -14x -15x -1x -1x -13x -15x -1x -1x -12x -12x -15x -1x -1x -5x -5x -1x -1x -3x -3x -1x -1x -3x -3x -1x -1x -6x -6x -2x -2x -4x -4x -6x -1x -1x -3x -3x -6x -1x -1x -3x -3x -1x -1x -4x -4x -1x | import { CreditLine, CreateCreditLineRequest, UpdateCreditLineRequest } from '../models/CreditLine.js';
-import { CreditLineRepository } from '../repositories/interfaces/CreditLineRepository.js';
-
-export class CreditLineService {
- constructor(private creditLineRepository: CreditLineRepository) {}
-
- async createCreditLine(request: CreateCreditLineRequest): Promise<CreditLine> {
- // Validate request
- if (!request.walletAddress) {
- throw new Error('Wallet address is required');
- }
-
- if (!request.creditLimit || parseFloat(request.creditLimit) <= 0) {
- throw new Error('Credit limit must be greater than 0');
- }
-
- if (request.interestRateBps < 0 || request.interestRateBps > 10000) {
- throw new Error('Interest rate must be between 0 and 10000 basis points');
- }
-
- return await this.creditLineRepository.create(request);
- }
-
- async getCreditLine(id: string): Promise<CreditLine | null> {
- return await this.creditLineRepository.findById(id);
- }
-
- async getCreditLinesByWallet(walletAddress: string): Promise<CreditLine[]> {
- return await this.creditLineRepository.findByWalletAddress(walletAddress);
- }
-
- async getAllCreditLines(offset?: number, limit?: number): Promise<CreditLine[]> {
- return await this.creditLineRepository.findAll(offset, limit);
- }
-
- async updateCreditLine(id: string, request: UpdateCreditLineRequest): Promise<CreditLine | null> {
- // Validate update request
- if (request.creditLimit && parseFloat(request.creditLimit) <= 0) {
- throw new Error('Credit limit must be greater than 0');
- }
-
- if (request.interestRateBps !== undefined &&
- (request.interestRateBps < 0 || request.interestRateBps > 10000)) {
- throw new Error('Interest rate must be between 0 and 10000 basis points');
- }
-
- return await this.creditLineRepository.update(id, request);
- }
-
- async deleteCreditLine(id: string): Promise<boolean> {
- return await this.creditLineRepository.delete(id);
- }
-
- async getCreditLineCount(): Promise<number> {
- return await this.creditLineRepository.count();
- }
-} |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 -61 -62 -63 -64 -65 -66 -67 -68 -69 -70 -71 -72 -73 -74 -75 -76 -77 -78 -79 -80 -81 -82 -83 -84 -85 -86 -87 -88 -89 -90 -91 -92 -93 -94 -95 -96 -97 -98 -99 -100 -101 -102 -103 -104 -105 -106 -107 -108 -109 -110 -111 -112 -113 | 1x -1x -1x -1x -1x -1x -1x -17x -1x -1x -16x -16x -17x -9x -9x -2x -2x -2x -2x -2x -2x -2x -2x -2x -2x -2x -9x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -17x -1x -1x -4x -4x -1x -1x -3x -3x -1x -1x -5x -5x -1x -1x -1x -1x -1x -1x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -42x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -14x -1x | import { RiskEvaluation, RiskEvaluationRequest, RiskEvaluationResult, RiskFactor } from '../models/RiskEvaluation.js';
-import { RiskEvaluationRepository } from '../repositories/interfaces/RiskEvaluationRepository.js';
-
-export class RiskEvaluationService {
- constructor(private riskEvaluationRepository: RiskEvaluationRepository) {}
-
- async evaluateRisk(request: RiskEvaluationRequest): Promise<RiskEvaluationResult> {
- if (!request.walletAddress) {
- throw new Error('Wallet address is required');
- }
-
- // Check if we have a valid cached evaluation
- if (!request.forceRefresh) {
- const isValid = await this.riskEvaluationRepository.isValid(request.walletAddress);
- if (isValid) {
- const cached = await this.riskEvaluationRepository.findLatestByWalletAddress(request.walletAddress);
- if (cached) {
- return {
- walletAddress: cached.walletAddress,
- riskScore: cached.riskScore,
- creditLimit: cached.creditLimit,
- interestRateBps: cached.interestRateBps,
- message: 'Using cached risk evaluation'
- };
- }
- }
- }
-
- // Perform new risk evaluation (placeholder implementation)
- const evaluation = await this.performRiskEvaluation(request.walletAddress);
-
- // Save the evaluation
- await this.riskEvaluationRepository.save(evaluation);
-
- return {
- walletAddress: evaluation.walletAddress,
- riskScore: evaluation.riskScore,
- creditLimit: evaluation.creditLimit,
- interestRateBps: evaluation.interestRateBps,
- message: 'New risk evaluation completed'
- };
- }
-
- async getRiskEvaluation(id: string): Promise<RiskEvaluation | null> {
- return await this.riskEvaluationRepository.findById(id);
- }
-
- async getLatestRiskEvaluation(walletAddress: string): Promise<RiskEvaluation | null> {
- return await this.riskEvaluationRepository.findLatestByWalletAddress(walletAddress);
- }
-
- async getRiskEvaluationHistory(walletAddress: string, offset?: number, limit?: number): Promise<RiskEvaluation[]> {
- return await this.riskEvaluationRepository.findByWalletAddress(walletAddress, offset, limit);
- }
-
- async cleanupExpiredEvaluations(): Promise<number> {
- return await this.riskEvaluationRepository.deleteExpired();
- }
-
- private async performRiskEvaluation(walletAddress: string): Promise<Omit<RiskEvaluation, 'id'>> {
- // Placeholder risk evaluation logic
- // In a real implementation, this would analyze wallet history, transaction patterns, etc.
-
- const now = new Date();
- const expiresAt = new Date(now.getTime() + 24 * 60 * 60 * 1000); // 24 hours
-
- // Mock risk factors
- const factors: RiskFactor[] = [
- {
- name: 'wallet_age',
- value: 0.8,
- weight: 0.3,
- description: 'Age of the wallet in months'
- },
- {
- name: 'transaction_volume',
- value: 0.6,
- weight: 0.4,
- description: 'Historical transaction volume'
- },
- {
- name: 'defi_participation',
- value: 0.7,
- weight: 0.3,
- description: 'Participation in DeFi protocols'
- }
- ];
-
- // Calculate weighted risk score
- const riskScore = factors.reduce((score, factor) => {
- return score + (factor.value * factor.weight);
- }, 0) * 100;
-
- // Determine credit limit based on risk score
- const baseCreditLimit = 1000;
- const creditLimit = (baseCreditLimit * (riskScore / 100)).toString();
-
- // Determine interest rate (higher risk = higher rate)
- const baseRateBps = 500; // 5%
- const riskMultiplier = (100 - riskScore) / 100;
- const interestRateBps = Math.round(baseRateBps + (baseRateBps * (1 - riskMultiplier)));
-
- return {
- walletAddress,
- riskScore: Math.round(riskScore),
- creditLimit,
- interestRateBps,
- factors,
- evaluatedAt: now,
- expiresAt
- };
- }
-} |
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| CreditLineService.ts | -
-
- |
- 100% | -57/57 | -100% | -23/23 | -100% | -8/8 | -100% | -57/57 | -
| RiskEvaluationService.ts | -
-
- |
- 100% | -113/113 | -100% | -13/13 | -100% | -7/7 | -100% | -113/113 | -
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| File | -- | Statements | -- | Branches | -- | Functions | -- | Lines | -- |
|---|---|---|---|---|---|---|---|---|---|
| response.ts | -
-
- |
- 100% | -15/15 | -100% | -10/10 | -100% | -2/2 | -100% | -15/15 | -
- Press n or j to go to the next uncovered block, b, p or k for the previous block. -
- -| 1 -2 -3 -4 -5 -6 -7 -8 -9 -10 -11 -12 -13 -14 -15 -16 -17 -18 -19 -20 -21 -22 -23 -24 -25 -26 -27 -28 -29 -30 -31 -32 -33 -34 -35 -36 -37 -38 -39 -40 -41 -42 -43 -44 -45 -46 -47 -48 -49 -50 -51 -52 -53 -54 -55 -56 -57 -58 -59 -60 | - - - - - - - - - - - - - - -2x -5x - - - -5x - - - - - - - - - - - -2x -7x - -7x - -5x -3x -2x -1x - -1x - - - -2x -1x - - - - -7x - - - - -7x - - | import { Response } from 'express';
-
-// Standardized response envelope interface
-export interface ApiResponse<T = unknown> {
- data: T | null;
- error: string | null;
-}
-
-/**
- * Sends a successful response with the unified envelope format.
- *
- * @param res The Express response object
- * @param data The payload to send
- * @param statusCode The HTTP status code (defaults to 200)
- */
-export const ok = <T>(res: Response, data: T, statusCode = 200): Response => {
- const payload: ApiResponse<T> = {
- data,
- error: null,
- };
- return res.status(statusCode).json(payload);
-};
-
-/**
- * Sends a failure response with the unified envelope format.
- * Prevents internal details from leaking by forcing generic messages for 500 errors
- * unless a specific string message is provided.
- *
- * @param res The Express response object
- * @param error The original error or error message
- * @param statusCode The HTTP status code (defaults to 500)
- */
-export const fail = (res: Response, error: unknown, statusCode = 500): Response => {
- let errorMessage = 'Internal server error';
-
- if (statusCode < 500) {
- // For client errors (4xx), it's generally safe to send the message
- if (typeof error === 'string') {
- errorMessage = error;
- } else if (error instanceof Error) {
- errorMessage = error.message;
- } else {
- errorMessage = 'Bad request';
- }
- } else {
- // For server errors (5xx), we strictly limit what we send
- if (typeof error === 'string') {
- errorMessage = error; // Only explicit strings are allowed to be sent for 5xx
- }
- // Note: We deliberately drop standard Error objects for 500 to avoid leaking internals like stack traces or SQL errors
- }
-
- const payload: ApiResponse<null> = {
- data: null,
- error: errorMessage,
- };
-
- return res.status(statusCode).json(payload);
-};
- |