@atomist/automation-client/lib/project/support/AbstractProject.js

"use strict";
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
    return new (P || (P = Promise))(function (resolve, reject) {
        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
        step((generator = generator.apply(thisArg, _arguments || [])).next());
    });
};
Object.defineProperty(exports, "__esModule", { value: true });
const AbstractScriptedFlushable_1 = require("../../internal/common/AbstractScriptedFlushable");
const logger_1 = require("../../util/logger");
const fileGlobs_1 = require("../fileGlobs");
/**
 * Support for implementations of Project interface
 */
class AbstractProject extends AbstractScriptedFlushable_1.AbstractScriptedFlushable {
    constructor(id) {
        super();
        this.id = id;
    }
    get name() {
        return !!this.id ? this.id.repo : undefined;
    }
    hasFile(path) {
        return __awaiter(this, void 0, void 0, function* () {
            return !!(yield this.getFile(path));
        });
    }
    streamFiles(...globPatterns) {
        const globsToUse = globPatterns.length > 0 ? globPatterns.concat(fileGlobs_1.DefaultExcludes) : fileGlobs_1.DefaultFiles;
        return this.streamFilesRaw(globsToUse, {});
    }
    totalFileCount() {
        return new Promise((resolve, reject) => {
            let count = 0;
            this.streamFiles()
                .on("data", f => count++)
                .on("error", reject)
                .on("end", _ => resolve(count));
        });
    }
    trackFile(f) {
        logger_1.logger.debug(`Project is tracking '${f.path}'`);
        return this.recordAction(p => {
            return f.flush().then(_ => p);
        });
    }
    moveFile(oldPath, newPath) {
        return this.findFile(oldPath)
            .then(f => f.setPath(newPath).then(() => this))
            // Not an error if no such file
            .catch(err => this);
    }
    recordAddFile(path, content) {
        return this.recordAction(p => p.addFile(path, content));
    }
    recordDeleteFile(path) {
        return this.recordAction(p => p.deleteFile(path));
    }
    // TODO set permissions
    add(f) {
        return f.getContent()
            .then(content => this.addFile(f.path, content));
    }
}
exports.AbstractProject = AbstractProject;
//# sourceMappingURL=AbstractProject.js.map