From ceef93ed004e592f49c07155fd904a09aebdd598 Mon Sep 17 00:00:00 2001
From: freearhey <7253922+freearhey@users.noreply.github.com>
Date: Mon, 3 Feb 2025 21:54:21 +0300
Subject: [PATCH] Create apiClient.js

---
 src/utils/apiClient.js | 52 ++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 52 insertions(+)
 create mode 100644 src/utils/apiClient.js

diff --git a/src/utils/apiClient.js b/src/utils/apiClient.js
new file mode 100644
index 000000000..c83b08909
--- /dev/null
+++ b/src/utils/apiClient.js
@@ -0,0 +1,52 @@
+import axios from 'axios'
+import cliProgress from 'cli-progress'
+import numeral from 'numeral'
+
+export class ApiClient {
+  constructor({ storage }) {
+    this.storage = storage
+    this.client = axios.create({
+      responseType: 'stream'
+    })
+    this.progressBar = new cliProgress.MultiBar({
+      stopOnComplete: true,
+      hideCursor: true,
+      forceRedraw: true,
+      barsize: 36,
+      format(options, params, payload) {
+        const filename = payload.filename.padEnd(18, ' ')
+        const barsize = options.barsize || 40
+        const percent = (params.progress * 100).toFixed(2)
+        const speed = payload.speed ? numeral(payload.speed).format('0.0 b') + '/s' : 'N/A'
+        const total = numeral(params.total).format('0.0 b')
+        const completeSize = Math.round(params.progress * barsize)
+        const incompleteSize = barsize - completeSize
+        const bar =
+          options.barCompleteString && options.barIncompleteString
+            ? options.barCompleteString.substr(0, completeSize) +
+              options.barGlue +
+              options.barIncompleteString.substr(0, incompleteSize)
+            : '-'.repeat(barsize)
+
+        return `${filename} [${bar}] ${percent}% | ETA: ${params.eta}s | ${total} | ${speed}`
+      }
+    })
+  }
+
+  async download(filename) {
+    const stream = await this.storage.createStream(filename)
+
+    const bar = this.progressBar.create(0, 0, { filename })
+
+    this.client
+      .get(`https://iptv-org.github.io/api/${filename}`, {
+        onDownloadProgress({ total, loaded, rate }) {
+          if (total) bar.setTotal(total)
+          bar.update(loaded, { speed: rate })
+        }
+      })
+      .then(response => {
+        response.data.pipe(stream)
+      })
+  }
+}