import * as plugins from './dockersock.plugins';
import { DockerContainer } from './docker.classes.container';

export class DockerHost {
  /**
   * the path where the docker sock can be found
   */
  sockPath: string;

  /**
   * keeping track of currently active requests to safely end this module at any time
   */
  requestObjectmap = new plugins.lik.Objectmap<any>();

  /**
   * the constructor to instantiate a new docker sock instance
   * @param pathArg
   */
  constructor(pathArg: string = 'http://unix:/var/run/docker.sock:') {
    this.sockPath = pathArg;
  }

  /**
   * authenticate against a registry
   * @param userArg
   * @param passArg
   */
  auth(registryArg: string, userArg: string, passArg: string) {
    let done = plugins.smartpromise.defer();
    this.request('POST', '');
    return done.promise;
  }

  /**
   *
   */
  async getContainers() {
    const containerArray = await DockerContainer.getContainers(this);
    return containerArray;
  };

  async getEventObservable(): Promise<plugins.rxjs.Observable<any>> {
    const response = await this.requestStreaming('GET', '/events');
    return plugins.rxjs.Observable.create(observer => {
      response.on('data', data => {
        observer.next(data.toString());
      });
      return () => {
        response.emit('end');
      };
    });
  }

  /**
   * fire a request
   */
  async request(methodArg: string, routeArg: string, dataArg = {}) {
    const requestUrl = `${this.sockPath}${routeArg}`;
    const response = await plugins.smartrequest.request(requestUrl, {
      method: methodArg,
      headers: {
        'Content-Type': 'application/json',
        Host: 'docker.sock'
      },
      requestBody: dataArg
    });
    return response;
  }

  async requestStreaming(methodArg: string, routeArg: string, dataArg = {}) {
    const requestUrl = `${this.sockPath}${routeArg}`;
    const response = await plugins.smartrequest.request(
      requestUrl, {
      method: methodArg,
      headers: {
        // 'Content-Type': 'application/json',
        Host: 'docker.sock'
      },
      requestBody: null
    },
    true
    );
    console.log(response.statusCode);
    console.log(response.body);
    return response;
  }
}