Get Progress

curl -X POST https://api.dangofish.com/api.v1.Service/GetProgress \
  -H "Authorization: Bearer $DANGO_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"projectId": "aB3xK9"}'

import os
import time
import requests

url = "https://api.dangofish.com/api.v1.Service/GetProgress"
headers = {
    "Authorization": f"Bearer {os.environ['DANGO_API_KEY']}",
    "Content-Type": "application/json",
}

while True:
    resp = requests.post(url, headers=headers, json={"projectId": "aB3xK9"})
    resp.raise_for_status()
    progress = resp.json()
    print(progress["status"], progress["enriched"], "/", progress["totalLines"])
    if progress["status"] == "completed":
        break
    time.sleep(5)

const url = "https://api.dangofish.com/api.v1.Service/GetProgress";
const headers = {
  Authorization: `Bearer ${process.env.DANGO_API_KEY}`,
  "Content-Type": "application/json",
};

type Progress = {
  status: "pending" | "enriching" | "completed";
  totalLines: number;
  enriched: number;
  inProgress: number;
  failed: number;
  submittedAt: string;
  completedAt: string;
};

while (true) {
  const resp = await fetch(url, {
    method: "POST",
    headers,
    body: JSON.stringify({ projectId: "aB3xK9" }),
  });
  if (!resp.ok) throw new Error(`GetProgress failed: ${resp.status}`);
  const progress = (await resp.json()) as Progress;
  console.log(progress.status, progress.enriched, "/", progress.totalLines);
  if (progress.status === "completed") break;
  await new Promise((r) => setTimeout(r, 5000));
}

package main

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

type progress struct {
	Status     string `json:"status"`
	TotalLines int64  `json:"totalLines"`
	Enriched   int64  `json:"enriched"`
	InProgress int64  `json:"inProgress"`
	Failed     int64  `json:"failed"`
}

func main() {
	body, _ := json.Marshal(map[string]string{"projectId": "aB3xK9"})
	for {
		req, _ := http.NewRequest("POST",
			"https://api.dangofish.com/api.v1.Service/GetProgress",
			bytes.NewReader(body))
		req.Header.Set("Authorization", "Bearer "+os.Getenv("DANGO_API_KEY"))
		req.Header.Set("Content-Type", "application/json")

		resp, err := http.DefaultClient.Do(req)
		if err != nil {
			panic(err)
		}
		var p progress
		json.NewDecoder(resp.Body).Decode(&p)
		resp.Body.Close()

		fmt.Printf("%s %d/%d\n", p.Status, p.Enriched, p.TotalLines)
		if p.Status == "completed" {
			break
		}
		time.Sleep(5 * time.Second)
	}
}