???? ??? ?? ? ??? ?? ????? ???? ??? ?? ?????. ????, ?????, ?? ??? ???? ??? ??? ??? ???? ?? ???? ???? ??? ????? ?????. ? ??? ????? Node.js? TypeScript? ???? ????? ??, ??, ?? ??????? ???????.

?? ????? ???? ??????

????? ??? ??? ??? ??? ?? ??? ?????. ? ????? ???? ???? ?? ??? ???? ???? ?? ??? ????. ? ?? ??? ??? ?? ??? ?? ?????.

→ ??? ?? ? ??
→ ??? ??.
→ ??? ??? ??.

? ????? ??? ??

???: ?????? ? ??? ????? ?? ??? ? ?? ??? ? ????.

????: ????? ??? ??? ??????? ???????? ???? ? ????.

???: ?? ??? ?? ??? ????? ?? ??? ??? ? ????.

???: ?? ????? ??? ???? ?? ??? ????? ??? ? ????.

??? TypeScript? ???? Node.js?? ????? ?? ??

?????? ?? ??? ??? ???? ???? ??? ??? ??? ?????.

?? ??: ??? ???? ????, ??? ??? ????, ?????? ???? ???? ??? ???? ??????.

interface User {
  name: string;
  email: string;
  timestamp?: string;
}

type PipelineStage = (input: User) => User;

// Stage 1: Convert names to uppercase
const toUpperCaseStage: PipelineStage = (user) => {
  return { ...user, name: user.name.toUpperCase() };
};

// Stage 2: Validate email format
const validateEmailStage: PipelineStage = (user) => {
  const emailRegex = /^[^\s@]+@[^\s@]+\.[^\s@]+$/;
  if (!emailRegex.test(user.email)) {
    throw new Error(`Invalid email format: ${user.email}`);
  }
  return user;
};

// Stage 3: Enrich data with timestamp
const enrichDataStage: PipelineStage = (user) => {
  return { ...user, timestamp: new Date().toISOString() };
};

// Pipeline runner
const runPipeline = (user: User, stages: PipelineStage[]): User => {
  return stages.reduce((currentData, stage) => stage(currentData), user);
};

// Example usage
const userData: User = { name: "John Doe", email: "john.doe@example.com" };
const stages: PipelineStage[] = [toUpperCaseStage, validateEmailStage, enrichDataStage];

try {
  const processedUser = runPipeline(userData, stages);
  console.log(processedUser);
} catch (error) {
  console.error(error.message);
}

?? ??: ??? ?????

?? ?? ?????? ? ???? API ???? ?????? ??? ?? ??? ??? ??? ? ????. ????? ??? ??? ??? ?? ???? ??? ?????.

// Asynchronous stage type
type AsyncPipelineStage = (input: User) => Promise<User>;

// Example: Asynchronous data enrichment
const asyncEnrichDataStage: AsyncPipelineStage = async (user) => {
  // Simulate an API call
  await new Promise((resolve) => setTimeout(resolve, 100));
  return { ...user, enriched: true };
};

// Asynchronous pipeline runner
const runAsyncPipeline = async (user: User, stages: AsyncPipelineStage[]): Promise<User> => {
  for (const stage of stages) {
    user = await stage(user);
  }
  return user;
};

// Example usage
(async () => {
  const asyncStages: AsyncPipelineStage[] = [
    asyncEnrichDataStage,
    async (user) => ({ ...user, processed: true }),
  ];

  const result = await runAsyncPipeline(userData, asyncStages);
  console.log(result);
})();

? ????? ??? ???? ?? ??

????? ??? ??? ?? ??? ??????.

1?? ??? ?? ?????: ETL(??, ??, ??) ??

2?? ???? ??: HTTP ??/?? ??

3?? ??? ??: ??? ??? ?? ??? ??

4?? ??? ?? ??? ??: ?? ??? ????? ??

??

???? ?? ???? ?? ???? ???? ?? ? ??? ????? ?????. ??? ?????? ???, ?? ??? ? ???? ?????. ? ??? ???? ?? ??? ????? ??? ??? ?????? ???? ?????? ???? ?? ???? ? ????.

? ??? ????? ??: ????? ????? ??? ?? ???? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!