MinIO — Object Storage แบบ S3 ในเครื่องเรา

services:
  minio:
    image: minio/minio
    command: server /data --console-address ":9001"
    environment:
      MINIO_ROOT_USER: admin
      MINIO_ROOT_PASSWORD: password123
    ports:
      - "9000:9000"   # S3 API
      - "9001:9001"   # เว็บ console
    volumes:
      - minio-data:/data

  api:
    build: ./api
    environment:
      MINIO_HOST: minio      # ← ชื่อ service ใน compose ใช้เป็น hostname ได้เลย
      MINIO_USER: admin
      MINIO_PASS: password123
    ports:
      - "3000:3000"
    depends_on:
      - minio

volumes:
  minio-data:

cd ~/projects/k8s-video-pipeline/api
npm install minio

const Minio = require('minio')

const minio = new Minio.Client({
  endPoint: process.env.MINIO_HOST || 'localhost',
  port: parseInt(process.env.MINIO_PORT || '9000'),
  useSSL: false,
  accessKey: process.env.MINIO_USER,
  secretKey: process.env.MINIO_PASS,
})

// สร้าง bucket ที่ต้องใช้ตอนแอปสตาร์ท (idempotent — มีอยู่แล้วก็ข้าม)
async function ensureBuckets() {
  for (const b of ['uploads', 'vod']) {
    if (!(await minio.bucketExists(b))) {
      await minio.makeBucket(b)
      console.log('สร้าง bucket:', b)
    }
  }
}
ensureBuckets().catch((err) => {
  console.error('ต่อ MinIO ไม่ได้:', err.message)
  process.exit(1)
})

// แก้ handler อัปโหลดให้เก็บไฟล์ลง MinIO
app.post('/api/upload', upload.single('video'), async (req, res) => {
  if (!req.file) {
    return res.status(400).json({ error: 'ต้องแนบไฟล์ใน field ชื่อ "video"' })
  }
  const videoId = crypto.randomUUID().slice(0, 8)
  await minio.fPutObject('uploads', videoId + '/source.mp4', req.file.path)
  console.log('เก็บต้นฉบับแล้ว: uploads/' + videoId + '/source.mp4')
  res.json({ videoId, status: 'uploaded' })
})

cd ~/projects/k8s-video-pipeline
docker compose up --build

# terminal อื่น
curl -F "video=@sample.mp4" http://localhost:3000/api/upload
# → {"videoId":"...","status":"uploaded"}