You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
47 lines
2.0 KiB
47 lines
2.0 KiB
"use strict";
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
|
exports.release = void 0;
|
|
const queue_1 = require("../../throttler/queue");
|
|
const tasks = require("./tasks");
|
|
const planner = require("./planner");
|
|
const error_1 = require("../../error");
|
|
const errors_1 = require("./errors");
|
|
const projectUtils_1 = require("../../projectUtils");
|
|
const etags_1 = require("../../extensions/etags");
|
|
async function release(context, options, payload) {
|
|
var _a, _b, _c, _d;
|
|
const projectId = (0, projectUtils_1.needProjectId)(options);
|
|
const errorHandler = new errors_1.ErrorHandler();
|
|
const deploymentQueue = new queue_1.default({
|
|
retries: 5,
|
|
concurrency: 5,
|
|
handler: tasks.extensionsDeploymentHandler(errorHandler),
|
|
});
|
|
for (const creation of (_a = payload.instancesToCreate) !== null && _a !== void 0 ? _a : []) {
|
|
const task = tasks.createExtensionInstanceTask(projectId, creation);
|
|
void deploymentQueue.run(task);
|
|
}
|
|
for (const update of (_b = payload.instancesToUpdate) !== null && _b !== void 0 ? _b : []) {
|
|
const task = tasks.updateExtensionInstanceTask(projectId, update);
|
|
void deploymentQueue.run(task);
|
|
}
|
|
for (const update of (_c = payload.instancesToConfigure) !== null && _c !== void 0 ? _c : []) {
|
|
const task = tasks.configureExtensionInstanceTask(projectId, update);
|
|
void deploymentQueue.run(task);
|
|
}
|
|
for (const deletion of (_d = payload.instancesToDelete) !== null && _d !== void 0 ? _d : []) {
|
|
const task = tasks.deleteExtensionInstanceTask(projectId, deletion);
|
|
void deploymentQueue.run(task);
|
|
}
|
|
const deploymentPromise = deploymentQueue.wait();
|
|
deploymentQueue.process();
|
|
deploymentQueue.close();
|
|
await deploymentPromise;
|
|
const newHave = await planner.have(projectId);
|
|
(0, etags_1.saveEtags)(options.rc, projectId, newHave);
|
|
if (errorHandler.hasErrors()) {
|
|
errorHandler.print();
|
|
throw new error_1.FirebaseError(`Extensions deployment failed.`);
|
|
}
|
|
}
|
|
exports.release = release;
|