gitlab.js

const $fs = require('fs');
const { read } = require_('utils.js');
const $settings = JSON.parse(read('settings.json', '{}'));

const gitlab = {
  GITLAB: {
    endpoint: $settings.endpoint,
    apiVer: $settings.apiVer || 'api/v4',
    privateToken: $settings.privateToken,
    nsId: $settings.nsId,
    ns:$settings.ns,
    prefixes: $settings.prefixes || 'npmpkg,comp,util,prefab,ske,tex,particle',
    moduleDirectory: $settings.moduleDirectory || 'cc_modules'
  },
  init(endpoint, privateToken, api) {
    this.GITLAB.endpoint = endpoint;
    this.GITLAB.privateToken = privateToken;
    this.GITLAB.apiVer = api;
  },
  setMainNamespace(nsId) {
    this.GITLAB.nsId = nsId;
    return this;
  },
  getProjectsOfNamespace(nameFilter) {
    const nsUrl = this.urlOfProject('');
  },
  urlOfProject(name) {
    return `${this.GITLAB.endpoint}/${this.GITLAB.ns}/${name}`;
  },
  urlOfRawFile(filename, branch) {
    if (!branch) branch = 'master'
    return `${this.GITLAB.endpoint}/${this.GITLAB.ns}/raw/${branch}/${filename}`;
  },
  urlOfArchive(projectId, sha, ext) {
    if (typeof ext === 'undefined') ext = '.zip'
    return this.apiUrl(`projects/${projectId}/repository/archive${ext}?sha=${sha}`);
  },
  fetchRaw() {

  },
  fetch(url, type, onprogress) {
    return window.fetch(url, {
      headers: {
        'Access-Control-Allow-Headers': 'Content-Length',
        'PRIVATE-TOKEN': this.GITLAB.privateToken
      }
    }).then(response => {
      const contentLength = response.headers.get('content-length');
      if (contentLength) {
        const total = parseInt(contentLength, 10);
        let loaded = 0;

        return new Response(
          new ReadableStream({
            start(controller) {
              const reader = response.body.getReader();
              read();
              function read() {
                reader.read().then(({done,value}) => {
                  if (done) {
                    controller.close();
                    return;
                  }
                  loaded += value.byteLength;
                  if (typeof onprogress === 'function') onprogress(loaded, total);
                  controller.enqueue(value);
                  read();
                }).catch(error => {
                  controller.error(error)
                })
              }
            }
          })
        )
      } else {
        return response;
      }
    }).then(res => {
      if (typeof res[type] === 'function') {
        return res[type]();
      } else {
        return res.text();
      }
    });
  },
  fetchJson(url, onprogress) {
    return this.fetch(url, 'json', onprogress);
  },
  fetchText(url, onprogress) {
    return this.fetch(url, 'text', onprogress);
  },
  apiUrl(path, rest) {
    const url =`${this.GITLAB.endpoint}/${this.GITLAB.apiVer}/${path}`;
    if (rest) {
      if (Array.isArray(rest)) {
        return [url].concat(rest).join('/')
      } else if (typeof rest === 'string') {
        return [url, rest].join('/');
      }
    }
    return url;
  },
  // gitlab apis
  groups (id) {
    id = id || this.GITLAB.nsId;
    const url = this.apiUrl('groups', id);
    return this.fetchJson(url);
  },
  branches (id, branch) {
    if (typeof branch === 'undefined') branch = 'master';
    const url = this.apiUrl('projects', [id, 'repository/branches', branch]);
    return this.fetchJson(url);
  },
  tags (id) {
    id = id || this.GITLAB.nsId;
    const url = this.apiUrl('projects', [id, 'repository/tags']);
    return this.fetchJson(url);
  },
  downloadArchive(id, sha, onprogress) {
    if (typeof sha === 'undefined') sha = 'master';
    const url = this.urlOfArchive(id, sha);
    return new Promise((resolve, reject) => {
      this.fetch(url, 'blob', onprogress).then(blob => {
        var fileReader = new FileReader();
        fileReader.onload = function () {
          const buf = Buffer(new Uint8Array(this.result));
          resolve(buf);
        };
        fileReader.onerror = reject;
        fileReader.readAsArrayBuffer(blob);
      });
    });
  }
};
module.exports = gitlab;