proxyManager.js

// proxyManager.js
const fs = require("fs");
const path = require("path");

class ProxyManager {
  constructor(path = "proxy.txt") {
    this.proxies = fs
      .readFileSync(path, "utf-8")
      .split("\n")
      .map((line) => line.trim())
      .filter((line) => line.length > 0 && !line.startsWith("#"))
      .map((line) => this.normalizeProxy(line))
      .filter((p) => p !== null);

    this.queue = [...this.proxies];
  }

  normalizeProxy(line) {
    // Full url just keep it
    if (line.startsWith("http://") || line.startsWith("https://")) {
      return line;
    }

    const parts = line.split(":");

    if (parts.length === 4) {
      // BrightData format: host:port:user:pass
      const [host, port, user, pass] = parts;
      return `http://${user}:${pass}@${host}:${port}`;
    }

    if (parts.length === 2) {
      // ip:port
      const [ip, port] = parts;
      return `http://${ip}:${port}`;
    }

    console.warn(`[ProxyManager] Unknown proxy format: ${line}`);
    return null;
  }

  getNext() {
    if (this.queue.length === 0) this.queue = [...this.proxies];
    const proxy = this.queue.shift();
    if (proxy) this.queue.push(proxy);
    return proxy;
  }

  getAll() {
    return [...this.proxies];
  }
}


module.exports = new ProxyManager(path.resolve(__dirname, "proxy.txt"));