Quantam: 경량 Async 워크플로 엔진 for Node.js

Source: Dev.to

문제점

구조화된 프레임워크가 없으면 async 코드는 금방 통제 불능 상태가 됩니다:

• 지저분한 Promise 체인 — 몇 단계만 지나도 파악이 불가능
• 어디에나 중첩된 try/catch — 흩어진 오류 처리
• 깨진 재시도 — 종종 조용히 실패하는 수동 로직
• 경쟁 조건 — 동시에 실행되는 작업이 서로 방해함
• 취소 불가 — 장시간 실행 작업을 중단할 수 없음
• 컨텍스트 손실 — 단계 사이에 데이터가 사라짐
• 비결정적 동작 — 같은 입력에 다른 출력이 나옴

해결책

Quantam은 하나의 깔끔하고 유창한 API를 제공하여 async 워크플로를 구성·실행·제어합니다:

const result = await quantam()
  .step(fetchUser)
  .step(enrichUserData)
  .parallel([saveToCache, logAnalytics])
  .retry(3)
  .timeout(5000)
  .run(userId);

이 간단한 구문만으로도 재시도, 병렬 실행, 타임아웃, 취소 등을 손쉽게 처리할 수 있습니다.

주요 기능

• ✅ 유창한 API — 읽고 쓰기 쉬움
• ✅ 순차 및 병렬 실행 — 원하는 대로 단계 혼합 가능
• ✅ 자동 재시도 — 지수 백오프 포함
• ✅ 타임아웃 및 취소 — SLA와 장시간 작업 제어
• ✅ 배치 처리 — 다수 입력을 효율적으로 실행
• ✅ 오류 전파 — 마지막에 한 번만 오류 잡기
• ✅ 결정적·테스트 가능 — 같은 입력은 같은 출력, 모킹이 쉬움

빠른 시작

npm으로 설치:

npm install quantam-async

비동기 단계 정의:

import { quantam } from 'quantam-async';

// 예시 비동기 함수
async function fetchUser(id: string) {
  return { id, name: 'Alice' };
}

async function fetchOrders(user: any) {
  return { user, orders: [1, 2, 3] };
}

async function enrichData(data: any) {
  return { ...data, enriched: true };
}

// 파이프라인을 구성하고 실행
const result = await quantam()
  .step(fetchUser)
  .step(fetchOrders)
  .step(enrichData)
  .run('user-123');

console.log(result);
// { user: { id: 'user-123', name: 'Alice' }, orders: [...], enriched: true }

병렬 실행 예시

await quantam()
  .step(fetchUser)
  .parallel([saveToCache, logAnalytics])
  .run(userId);

오류 처리

try {
  await quantam()
    .step(riskyOperation)
    .run(input);
} catch (error) {
  console.error('Pipeline failed:', error.message);
}

취소

const controller = new AbortController();
const promise = quantam()
  .step(longTask)
  .run(input, { signal: controller.signal });

// 나중에 파이프라인 중단
controller.abort();

버전

v0.1.0 — 핵심 기능만 포함. 향후 버전에서 API가 변경될 수 있습니다.