robosats/mobile/services/Tor/index.ts

import Tor from 'react-native-tor';

class TorClient {
  baseUrl: string;
  daemon: ReturnType<typeof Tor>;

  constructor() {
    this.baseUrl = 'http://robosats6tkf3eva7x2voqso3a5wcorsnw34jveyxfqi2fu7oyheasid.onion';
    this.daemon = Tor({
      stopDaemonOnBackground: false,
      numberConcurrentRequests: 0,
    });
  }

  private connectDaemon: () => void = async () => {
    try {
      this.daemon.startIfNotStarted();
    } catch {
      console.log('TOR already started');
    }
  };

  public get: (path: string, headers: object) => Promise<object> = async (path, headers) => {
    return await new Promise<object>(async (resolve, reject) => {
      try {
        const response = await this.daemon.get(`${this.baseUrl}${path}`, headers);

        resolve(response);
      } catch (error) {
        reject(error);
      }
    });
  };

  public delete: (path: string, headers: object) => Promise<object> = async (path, headers) => {
    return await new Promise<object>(async (resolve, reject) => {
      try {
        const response = await this.daemon.delete(`${this.baseUrl}${path}`, '', headers);

        resolve(response);
      } catch (error) {
        reject(error);
      }
    });
  };

  public request: (path: string) => Promise<object> = async (path) => {
    return await new Promise<object>(async (resolve, reject) => {
      try {
        const response = await this.daemon
          .request(`${this.baseUrl}${path}`, 'GET', '', {}, true)
          .then((resp) => {
            resolve(resp);
          });

        resolve(response);
      } catch (error) {
        reject(error);
      }
    });
  };

  public post: (path: string, body: object, headers: object) => Promise<object> = async (
    path,
    body,
    headers,
  ) => {
    return await new Promise<object>(async (resolve, reject) => {
      try {
        const json = JSON.stringify(body);
        const response = await this.daemon.post(`${this.baseUrl}${path}`, json, headers);

        resolve(response);
      } catch (error) {
        reject(error);
      }
    });
  };
}

export default TorClient;