@microtica/code-repository/js/bitbucket.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const _ = require("lodash");
const request = require("request");
const code_repository_1 = require("./code-repository");
class Bitbucket {
    constructor(credentials) {
        this.credentials = credentials;
        if (credentials.authType !== code_repository_1.RepoCredentialsType.BASIC.toString())
            throw new Error("Only BASIC authorization method is supported at this moment");
        this.baseUrl = `https://${this.credentials.username}:${this.credentials.password}@api.bitbucket.org/2.0`;
    }
    listTeams() {
        return new Promise((resolve, reject) => {
            request({
                url: `${this.baseUrl}/teams?role=member&pagelen=100`,
                json: true
            }, (err, response) => {
                if (err)
                    return reject(err);
                resolve(_.map(response.body.values, (team) => ({
                    name: team.username,
                    displayName: team.display_name
                })));
            });
        });
    }
    listRepositories() {
        return this.listPrivateRepositories().then(privateRepos => {
            return this.listTeams().then(teams => {
                return this.listAllRepositories(_.map(teams, team => team.name), privateRepos);
            });
        });
    }
    listAllRepositories(accounts, repositories = []) {
        const accountPromises = _.map(accounts, account => {
            return new Promise((resolve, reject) => {
                request({
                    url: `${this.baseUrl}/teams/${account}/repositories?pagelen=100`,
                    json: true
                }, (err, response) => {
                    if (err)
                        return reject(err);
                    const repos = _.map(response.body.values, (repo) => ({
                        name: repo.name,
                        fullName: repo.full_name,
                        description: repo.description,
                        downloadUrl: repo.links.downloads.href
                    }));
                    return resolve(repos);
                });
            });
        });
        return Promise.all(accountPromises).then(result => {
            return _.flatten(result);
        });
    }
    listPrivateRepositories() {
        return new Promise((resolve, reject) => {
            request({
                url: `${this.baseUrl}/repositories/${this.credentials.username}`,
                json: true
            }, (err, response) => {
                if (err)
                    return reject(err);
                resolve(_.map(response.body.values, (repo) => ({
                    name: repo.name,
                    fullName: repo.full_name,
                    downloadUrl: repo.links.downloads.href
                })));
            });
        });
    }
    listVersions(repoName) {
        return new Promise((resolve, reject) => {
            request({
                url: `${this.baseUrl}/repositories${repoName}/refs/tags?pagelen=100`,
                json: true
            }, (err, response) => {
                if (err)
                    return reject(err);
                resolve(_.map(response.body.values, (version) => ({
                    name: version.name,
                    message: version.message,
                    date: new Date(version.date),
                    author: {
                        name: version.target.author.user.display_name,
                        username: version.target.author.user.username,
                        avatar: version.target.author.user.links.avatar.href
                    }
                })));
            });
        });
    }
    downloadVersion(repoName, version) {
        return request(`https://${this.credentials.username}:${this.credentials.password}@bitbucket.org${repoName}/get/${version}.zip`);
    }
}
exports.Bitbucket = Bitbucket;
//# sourceMappingURL=bitbucket.js.map