Chistream API

const API_KEY = 'cs_xxxxxxxxxxxxxxxxxxxxxxxx';
const BASE_URL = 'https://chistream.my.id';

async function downloadFromChistream(url, format = 'mp3') {
  // 1. Bikin job download
  const startRes = await fetch(`${BASE_URL}/api/v1/download`, {
    method: 'POST',
    headers: {
      'Content-Type': 'application/json',
      'X-API-Key': API_KEY,
    },
    body: JSON.stringify({ url, format }),
  });
  const startData = await startRes.json();
  if (!startData.success) throw new Error(startData.error);

  const jobId = startData.jobId;

  // 2. Poll sampai selesai
  while (true) {
    await new Promise((r) => setTimeout(r, 2000));
    const statusRes = await fetch(`${BASE_URL}/api/v1/status/${jobId}`, {
      headers: { 'X-API-Key': API_KEY },
    });
    const statusData = await statusRes.json();

    if (statusData.status === 'COMPLETED') return statusData;
    if (statusData.status === 'FAILED' || statusData.status === 'CANCELLED') {
      throw new Error(statusData.error || 'Download gagal');
    }
  }
}

downloadFromChistream('https://youtu.be/VIDEO_ID', 'mp3')
  .then((r) => console.log('Selesai:', r.downloadUrl))
  .catch((e) => console.error('Error:', e.message));

const axios = require('axios');

const API_KEY = 'cs_xxxxxxxxxxxxxxxxxxxxxxxx';
const BASE_URL = 'https://chistream.my.id';
const headers = { 'X-API-Key': API_KEY };

async function downloadFromChistream(url, format = 'mp3') {
  const { data: start } = await axios.post(
    `${BASE_URL}/api/v1/download`,
    { url, format },
    { headers }
  );
  if (!start.success) throw new Error(start.error);

  let result;
  while (true) {
    await new Promise((r) => setTimeout(r, 2000));
    const { data: status } = await axios.get(
      `${BASE_URL}/api/v1/status/${start.jobId}`,
      { headers }
    );
    if (status.status === 'COMPLETED') { result = status; break; }
    if (status.status === 'FAILED' || status.status === 'CANCELLED') {
      throw new Error(status.error || 'Download gagal');
    }
  }
  return result;
}

downloadFromChistream('https://youtu.be/VIDEO_ID', 'mp3')
  .then((r) => console.log('Selesai:', r.downloadUrl))
  .catch((e) => console.error('Error:', e.message));

import requests
import time

API_KEY = 'cs_xxxxxxxxxxxxxxxxxxxxxxxx'
BASE_URL = 'https://chistream.my.id'
headers = {'X-API-Key': API_KEY}


def download_from_chistream(url, fmt='mp3'):
    start = requests.post(
        f'{BASE_URL}/api/v1/download',
        json={'url': url, 'format': fmt},
        headers=headers,
    ).json()
    if not start.get('success'):
        raise Exception(start.get('error'))

    job_id = start['jobId']

    while True:
        time.sleep(2)
        status = requests.get(
            f'{BASE_URL}/api/v1/status/{job_id}', headers=headers
        ).json()

        if status['status'] == 'COMPLETED':
            return status
        if status['status'] in ('FAILED', 'CANCELLED'):
            raise Exception(status.get('error', 'Download gagal'))


result = download_from_chistream('https://youtu.be/VIDEO_ID', 'mp3')
print('Selesai:', result['downloadUrl'])

<?php

$apiKey = 'cs_xxxxxxxxxxxxxxxxxxxxxxxx';
$baseUrl = 'https://chistream.my.id';

function chistreamRequest($method, $path, $apiKey, $body = null) {
    $ch = curl_init("https://chistream.my.id{$path}");
    $headers = ["X-API-Key: {$apiKey}"];
    if ($body !== null) {
        $headers[] = 'Content-Type: application/json';
        curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($body));
    }
    curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method);
    curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    $res = curl_exec($ch);
    curl_close($ch);
    return json_decode($res, true);
}

$start = chistreamRequest('POST', '/api/v1/download', $apiKey, [
    'url' => 'https://youtu.be/VIDEO_ID',
    'format' => 'mp3',
]);

if (!$start['success']) {
    die('Error: ' . $start['error']);
}

$jobId = $start['jobId'];

while (true) {
    sleep(2);
    $status = chistreamRequest('GET', "/api/v1/status/{$jobId}", $apiKey);

    if ($status['status'] === 'COMPLETED') {
        echo 'Selesai: ' . $status['downloadUrl'];
        break;
    }
    if (in_array($status['status'], ['FAILED', 'CANCELLED'])) {
        die('Download gagal: ' . ($status['error'] ?? ''));
    }
}

package main

import (
	"bytes"
	"encoding/json"
	"fmt"
	"io"
	"net/http"
	"time"
)

const apiKey = "cs_xxxxxxxxxxxxxxxxxxxxxxxx"
const baseURL = "https://chistream.my.id"

func chistreamRequest(method, path string, body any) map[string]any {
	var reqBody io.Reader
	if body != nil {
		b, _ := json.Marshal(body)
		reqBody = bytes.NewReader(b)
	}
	req, _ := http.NewRequest(method, baseURL+path, reqBody)
	req.Header.Set("X-API-Key", apiKey)
	if body != nil {
		req.Header.Set("Content-Type", "application/json")
	}
	resp, _ := http.DefaultClient.Do(req)
	defer resp.Body.Close()

	var out map[string]any
	json.NewDecoder(resp.Body).Decode(&out)
	return out
}

func main() {
	start := chistreamRequest("POST", "/api/v1/download", map[string]string{
		"url":    "https://youtu.be/VIDEO_ID",
		"format": "mp3",
	})
	if start["success"] != true {
		panic(start["error"])
	}
	jobID := start["jobId"].(string)

	for {
		time.Sleep(2 * time.Second)
		status := chistreamRequest("GET", "/api/v1/status/"+jobID, nil)

		switch status["status"] {
		case "COMPLETED":
			fmt.Println("Selesai:", status["downloadUrl"])
			return
		case "FAILED", "CANCELLED":
			panic(status["error"])
		}
	}
}