const fs = require('fs');

// 메모리가 1GB밖에 없는 서버라도 스트림을 사용하면 대용량 파일도 거뜬합니다!
console.log('--- Stream 파이프라인 전송 시작 ---');

// 1. 읽기 스트림(수도꼭지) 생성 (기본 단위: 64KB)
const readStream = fs.createReadStream('big-video.mp4'); 
// 2. 쓰기 스트림(하수구) 생성
const writeStream = fs.createWriteStream('big-video-copy.mp4');

let chunkCount = 0;

// 데이터가 단위 크기(Chunk)만큼 쪼개져서 들어올 때마다 발생하는 이벤트
readStream.on('data', (chunk) => {
    chunkCount++;
    console.log(`> 데이터 청크(Chunk) 수신 완료! (진행: ${chunkCount}번째, 크기: ${chunk.length} bytes)`);
    console.log(`> 파일에 쓰는 중... (메모리 점유율 최소 유지)`);
});

// 모든 데이터를 다 읽었을 때 발생하는 이벤트
readStream.on('end', () => {
    console.log('\n✅ 전송 완료! (이벤트: readStream.on("end"))');
    console.log('(설명: 파일 전체를 메모리에 올리지 않아 서버가 안전합니다)');
});

// 스트림을 잇는 가장 완벽한 방법 (파이프 연결)
// 위 동작을 내부적으로 자동 처리하며 읽고 쓰는 속도(Backpressure)를 알아서 조절합니다.
readStream.pipe(writeStream);