mirror of
https://github.com/hoverkraft-tech/compose-action.git
synced 2026-01-12 15:43:06 +08:00
0645acf21a
* upgrade: docker-compose - user docker compose instead * remove: yarn and clean format js file
1414 lines
60 KiB
JavaScript
1414 lines
60 KiB
JavaScript
"use strict";
|
|
var __assign = (this && this.__assign) || function () {
|
|
__assign = Object.assign || function(t) {
|
|
for (var s, i = 1, n = arguments.length; i < n; i++) {
|
|
s = arguments[i];
|
|
for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
|
|
t[p] = s[p];
|
|
}
|
|
return t;
|
|
};
|
|
return __assign.apply(this, arguments);
|
|
};
|
|
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
|
|
if (k2 === undefined) k2 = k;
|
|
var desc = Object.getOwnPropertyDescriptor(m, k);
|
|
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
|
|
desc = { enumerable: true, get: function() { return m[k]; } };
|
|
}
|
|
Object.defineProperty(o, k2, desc);
|
|
}) : (function(o, m, k, k2) {
|
|
if (k2 === undefined) k2 = k;
|
|
o[k2] = m[k];
|
|
}));
|
|
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
|
|
Object.defineProperty(o, "default", { enumerable: true, value: v });
|
|
}) : function(o, v) {
|
|
o["default"] = v;
|
|
});
|
|
var __importStar = (this && this.__importStar) || function (mod) {
|
|
if (mod && mod.__esModule) return mod;
|
|
var result = {};
|
|
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
|
|
__setModuleDefault(result, mod);
|
|
return result;
|
|
};
|
|
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
|
|
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
|
|
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) : adopt(result.value).then(fulfilled, rejected); }
|
|
step((generator = generator.apply(thisArg, _arguments || [])).next());
|
|
});
|
|
};
|
|
var __generator = (this && this.__generator) || function (thisArg, body) {
|
|
var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
|
|
return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
|
|
function verb(n) { return function (v) { return step([n, v]); }; }
|
|
function step(op) {
|
|
if (f) throw new TypeError("Generator is already executing.");
|
|
while (g && (g = 0, op[0] && (_ = 0)), _) try {
|
|
if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
|
|
if (y = 0, t) op = [op[0] & 2, t.value];
|
|
switch (op[0]) {
|
|
case 0: case 1: t = op; break;
|
|
case 4: _.label++; return { value: op[1], done: false };
|
|
case 5: _.label++; y = op[1]; op = [0]; continue;
|
|
case 7: op = _.ops.pop(); _.trys.pop(); continue;
|
|
default:
|
|
if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
|
|
if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
|
|
if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
|
|
if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
|
|
if (t[2]) _.ops.pop();
|
|
_.trys.pop(); continue;
|
|
}
|
|
op = body.call(thisArg, _);
|
|
} catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
|
|
if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
|
|
}
|
|
};
|
|
var __importDefault = (this && this.__importDefault) || function (mod) {
|
|
return (mod && mod.__esModule) ? mod : { "default": mod };
|
|
};
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
|
var dockerode_1 = __importDefault(require("dockerode"));
|
|
var compose = __importStar(require("../../src/index"));
|
|
var path = __importStar(require("path"));
|
|
var fs_1 = require("fs");
|
|
var index_1 = require("../../src/index");
|
|
var docker = new dockerode_1.default();
|
|
// Docker commands, especially builds, can take some time. This makes sure that they can take the time they need.
|
|
jest.setTimeout(25000);
|
|
// Set to true if you need to diagnose using output
|
|
var logOutput = false;
|
|
var isContainerRunning = function (name) { return __awaiter(void 0, void 0, void 0, function () {
|
|
return __generator(this, function (_a) {
|
|
return [2 /*return*/, new Promise(function (resolve, reject) {
|
|
docker.listContainers(function (err, containers) {
|
|
if (err) {
|
|
reject(err);
|
|
}
|
|
var running = (containers || []).filter(function (container) {
|
|
return container.Names.includes(name);
|
|
});
|
|
resolve(running.length > 0);
|
|
});
|
|
})];
|
|
});
|
|
}); };
|
|
var repoTags = function (imageInfo) { return imageInfo.RepoTags || []; };
|
|
var imageExists = function (name) { return __awaiter(void 0, void 0, void 0, function () {
|
|
var images, foundImage;
|
|
return __generator(this, function (_a) {
|
|
switch (_a.label) {
|
|
case 0: return [4 /*yield*/, docker.listImages()];
|
|
case 1:
|
|
images = _a.sent();
|
|
foundImage = images.findIndex(function (imageInfo) {
|
|
return repoTags(imageInfo).includes(name);
|
|
});
|
|
return [2 /*return*/, foundImage > -1];
|
|
}
|
|
});
|
|
}); };
|
|
var removeImagesStartingWith = function (searchString) { return __awaiter(void 0, void 0, void 0, function () {
|
|
var images, _i, images_1, image, _a, _b, repoTag, dockerImage;
|
|
return __generator(this, function (_c) {
|
|
switch (_c.label) {
|
|
case 0: return [4 /*yield*/, docker.listImages()];
|
|
case 1:
|
|
images = _c.sent();
|
|
_i = 0, images_1 = images;
|
|
_c.label = 2;
|
|
case 2:
|
|
if (!(_i < images_1.length)) return [3 /*break*/, 7];
|
|
image = images_1[_i];
|
|
_a = 0, _b = repoTags(image);
|
|
_c.label = 3;
|
|
case 3:
|
|
if (!(_a < _b.length)) return [3 /*break*/, 6];
|
|
repoTag = _b[_a];
|
|
if (!repoTag.startsWith(searchString)) return [3 /*break*/, 5];
|
|
dockerImage = docker.getImage(repoTag);
|
|
if (logOutput) {
|
|
process.stdout.write("removing image ".concat(repoTag, " ").concat(dockerImage.id || ''));
|
|
}
|
|
return [4 /*yield*/, dockerImage.remove()];
|
|
case 4:
|
|
_c.sent();
|
|
_c.label = 5;
|
|
case 5:
|
|
_a++;
|
|
return [3 /*break*/, 3];
|
|
case 6:
|
|
_i++;
|
|
return [3 /*break*/, 2];
|
|
case 7: return [2 /*return*/];
|
|
}
|
|
});
|
|
}); };
|
|
test('ensure container gets started', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var _a, _b;
|
|
return __generator(this, function (_c) {
|
|
switch (_c.label) {
|
|
case 0: return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 1:
|
|
_c.sent();
|
|
return [4 /*yield*/, compose.upAll({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 2:
|
|
_c.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 3:
|
|
_a.apply(void 0, [_c.sent()]).toBeTruthy();
|
|
_b = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 4:
|
|
_b.apply(void 0, [_c.sent()]).toBeTruthy();
|
|
return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 5:
|
|
_c.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('ensure exit code is returned correctly', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var result, failedResult, error_1;
|
|
return __generator(this, function (_a) {
|
|
switch (_a.label) {
|
|
case 0: return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 1:
|
|
result = _a.sent();
|
|
expect(result).toMatchObject({
|
|
exitCode: 0
|
|
});
|
|
return [4 /*yield*/, compose.upAll({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 2:
|
|
result = _a.sent();
|
|
expect(result).toMatchObject({
|
|
exitCode: 0
|
|
});
|
|
failedResult = 0;
|
|
_a.label = 3;
|
|
case 3:
|
|
_a.trys.push([3, 5, , 6]);
|
|
return [4 /*yield*/, compose.logs('non_existent_service', {
|
|
cwd: path.join(__dirname)
|
|
})];
|
|
case 4:
|
|
_a.sent();
|
|
return [3 /*break*/, 6];
|
|
case 5:
|
|
error_1 = _a.sent();
|
|
failedResult = error_1.exitCode;
|
|
return [3 /*break*/, 6];
|
|
case 6:
|
|
expect(failedResult).toBe(1);
|
|
return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 7:
|
|
_a.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
describe('starts containers properly with --build and --timeout options', function () {
|
|
beforeEach(function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
return __generator(this, function (_a) {
|
|
switch (_a.label) {
|
|
case 0: return [4 /*yield*/, compose.down({
|
|
cwd: path.join(__dirname),
|
|
log: logOutput,
|
|
config: 'docker-compose-build.yml'
|
|
})];
|
|
case 1:
|
|
_a.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
afterEach(function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
return __generator(this, function (_a) {
|
|
switch (_a.label) {
|
|
case 0: return [4 /*yield*/, compose.down({
|
|
cwd: path.join(__dirname),
|
|
log: logOutput,
|
|
config: 'docker-compose-build.yml'
|
|
})];
|
|
case 1:
|
|
_a.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('ensure container gets started with --build option', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var _a;
|
|
return __generator(this, function (_b) {
|
|
switch (_b.label) {
|
|
case 0: return [4 /*yield*/, compose.upAll({
|
|
cwd: path.join(__dirname),
|
|
log: logOutput,
|
|
config: 'docker-compose-build.yml',
|
|
commandOptions: ['--build']
|
|
})];
|
|
case 1:
|
|
_b.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_nginx')];
|
|
case 2:
|
|
_a.apply(void 0, [_b.sent()]).toBeTruthy();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('ensure container gets started with --build and --timeout option', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var _a;
|
|
return __generator(this, function (_b) {
|
|
switch (_b.label) {
|
|
case 0: return [4 /*yield*/, compose.upAll({
|
|
cwd: path.join(__dirname),
|
|
log: logOutput,
|
|
config: 'docker-compose-build.yml',
|
|
commandOptions: [['--build'], ['--timeout', '5']]
|
|
})];
|
|
case 1:
|
|
_b.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_nginx')];
|
|
case 2:
|
|
_a.apply(void 0, [_b.sent()]).toBeTruthy();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('ensure container gets started with --build and --timeout option with different command style', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var _a;
|
|
return __generator(this, function (_b) {
|
|
switch (_b.label) {
|
|
case 0: return [4 /*yield*/, compose.upAll({
|
|
cwd: path.join(__dirname),
|
|
log: logOutput,
|
|
config: 'docker-compose-build.yml',
|
|
commandOptions: ['--build', ['--timeout', '5']]
|
|
})];
|
|
case 1:
|
|
_b.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_nginx')];
|
|
case 2:
|
|
_a.apply(void 0, [_b.sent()]).toBeTruthy();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
});
|
|
test('ensure container command executed with --workdir command option', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var result;
|
|
return __generator(this, function (_a) {
|
|
switch (_a.label) {
|
|
case 0: return [4 /*yield*/, compose.down({
|
|
cwd: path.join(__dirname),
|
|
log: logOutput,
|
|
config: 'docker-compose-42.yml'
|
|
})];
|
|
case 1:
|
|
_a.sent();
|
|
return [4 /*yield*/, compose.run('some-service', 'pwd', {
|
|
cwd: path.join(__dirname),
|
|
log: true,
|
|
config: 'docker-compose-42.yml',
|
|
composeOptions: ['--verbose'],
|
|
// Alpine has "/" as default
|
|
commandOptions: ['--workdir', '/home/root']
|
|
})];
|
|
case 2:
|
|
result = _a.sent();
|
|
expect(result.out).toBe('/home/root\n');
|
|
return [4 /*yield*/, compose.down({
|
|
cwd: path.join(__dirname),
|
|
log: logOutput,
|
|
config: 'docker-compose-42.yml'
|
|
})];
|
|
case 3:
|
|
_a.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('ensure only single container gets started', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var _a, _b;
|
|
return __generator(this, function (_c) {
|
|
switch (_c.label) {
|
|
case 0: return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 1:
|
|
_c.sent();
|
|
return [4 /*yield*/, compose.upOne('web', { cwd: path.join(__dirname), log: logOutput })];
|
|
case 2:
|
|
_c.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 3:
|
|
_a.apply(void 0, [_c.sent()]).toBeTruthy();
|
|
_b = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 4:
|
|
_b.apply(void 0, [_c.sent()]).toBeFalsy();
|
|
return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 5:
|
|
_c.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('ensure only multiple containers get started', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var _a, _b;
|
|
return __generator(this, function (_c) {
|
|
switch (_c.label) {
|
|
case 0: return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 1:
|
|
_c.sent();
|
|
return [4 /*yield*/, compose.upMany(['web'], { cwd: path.join(__dirname), log: logOutput })];
|
|
case 2:
|
|
_c.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 3:
|
|
_a.apply(void 0, [_c.sent()]).toBeTruthy();
|
|
_b = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 4:
|
|
_b.apply(void 0, [_c.sent()]).toBeFalsy();
|
|
return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 5:
|
|
_c.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('ensure container gets down', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var _a, _b, _c, _d;
|
|
return __generator(this, function (_e) {
|
|
switch (_e.label) {
|
|
case 0: return [4 /*yield*/, compose.upAll({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 1:
|
|
_e.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 2:
|
|
_a.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
_b = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 3:
|
|
_b.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 4:
|
|
_e.sent();
|
|
_c = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 5:
|
|
_c.apply(void 0, [_e.sent()]).toBeFalsy();
|
|
_d = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 6:
|
|
_d.apply(void 0, [_e.sent()]).toBeFalsy();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('ensure container gets stopped', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var _a, _b, _c, _d;
|
|
return __generator(this, function (_e) {
|
|
switch (_e.label) {
|
|
case 0: return [4 /*yield*/, compose.upAll({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 1:
|
|
_e.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 2:
|
|
_a.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
_b = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 3:
|
|
_b.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
return [4 /*yield*/, compose.stop({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 4:
|
|
_e.sent();
|
|
_c = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 5:
|
|
_c.apply(void 0, [_e.sent()]).toBeFalsy();
|
|
_d = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 6:
|
|
_d.apply(void 0, [_e.sent()]).toBeFalsy();
|
|
return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 7:
|
|
_e.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('ensure only single container gets stopped', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var _a, _b, _c, _d;
|
|
return __generator(this, function (_e) {
|
|
switch (_e.label) {
|
|
case 0: return [4 /*yield*/, compose.upAll({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 1:
|
|
_e.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 2:
|
|
_a.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
_b = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 3:
|
|
_b.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
return [4 /*yield*/, compose.stopOne('proxy', { cwd: path.join(__dirname), log: logOutput })];
|
|
case 4:
|
|
_e.sent();
|
|
_c = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 5:
|
|
_c.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
_d = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 6:
|
|
_d.apply(void 0, [_e.sent()]).toBeFalsy();
|
|
return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 7:
|
|
_e.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('ensure multiple containers gets stopped', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var _a, _b, _c, _d;
|
|
return __generator(this, function (_e) {
|
|
switch (_e.label) {
|
|
case 0: return [4 /*yield*/, compose.upAll({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 1:
|
|
_e.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 2:
|
|
_a.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
_b = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 3:
|
|
_b.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
return [4 /*yield*/, compose.stopMany({ cwd: path.join(__dirname), log: logOutput }, 'proxy', 'web')];
|
|
case 4:
|
|
_e.sent();
|
|
_c = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 5:
|
|
_c.apply(void 0, [_e.sent()]).toBeFalsy();
|
|
_d = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 6:
|
|
_d.apply(void 0, [_e.sent()]).toBeFalsy();
|
|
return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 7:
|
|
_e.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('ensure only single container gets paused then resumed', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var opts, _a, _b, _c, _d, errMsg, err_1, _e, _f, std;
|
|
return __generator(this, function (_g) {
|
|
switch (_g.label) {
|
|
case 0:
|
|
opts = { cwd: path.join(__dirname), log: logOutput };
|
|
return [4 /*yield*/, compose.upAll(opts)];
|
|
case 1:
|
|
_g.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 2:
|
|
_a.apply(void 0, [_g.sent()]).toBeTruthy();
|
|
_b = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 3:
|
|
_b.apply(void 0, [_g.sent()]).toBeTruthy();
|
|
return [4 /*yield*/, compose.pauseOne('proxy', opts)];
|
|
case 4:
|
|
_g.sent();
|
|
_c = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 5:
|
|
_c.apply(void 0, [_g.sent()]).toBeTruthy();
|
|
_d = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 6:
|
|
_d.apply(void 0, [_g.sent()]).toBeTruthy();
|
|
_g.label = 7;
|
|
case 7:
|
|
_g.trys.push([7, 9, , 10]);
|
|
return [4 /*yield*/, compose.exec('proxy', 'cat /etc/os-release', opts)];
|
|
case 8:
|
|
_g.sent();
|
|
return [3 /*break*/, 10];
|
|
case 9:
|
|
err_1 = _g.sent();
|
|
errMsg = err_1.err;
|
|
return [3 /*break*/, 10];
|
|
case 10:
|
|
expect(errMsg).toContain('is paused');
|
|
return [4 /*yield*/, compose.unpauseOne('proxy', opts)];
|
|
case 11:
|
|
_g.sent();
|
|
_e = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 12:
|
|
_e.apply(void 0, [_g.sent()]).toBeTruthy();
|
|
_f = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 13:
|
|
_f.apply(void 0, [_g.sent()]).toBeTruthy();
|
|
return [4 /*yield*/, compose.exec('proxy', 'cat /etc/os-release', opts)];
|
|
case 14:
|
|
std = _g.sent();
|
|
expect(std.out).toContain('Alpine Linux');
|
|
return [4 /*yield*/, compose.down(opts)];
|
|
case 15:
|
|
_g.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('ensure container gets started with --abort-on-container-exit option', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var result, _a, _b;
|
|
return __generator(this, function (_c) {
|
|
switch (_c.label) {
|
|
case 0: return [4 /*yield*/, compose.upAll({
|
|
cwd: path.join(__dirname),
|
|
log: logOutput,
|
|
commandOptions: ['--abort-on-container-exit']
|
|
})];
|
|
case 1:
|
|
result = _c.sent();
|
|
expect(result).toMatchObject({
|
|
exitCode: 0
|
|
});
|
|
_a = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 2:
|
|
_a.apply(void 0, [_c.sent()]).toBeFalsy();
|
|
_b = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 3:
|
|
_b.apply(void 0, [_c.sent()]).toBeFalsy();
|
|
return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 4:
|
|
_c.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('ensure container gets started with --abort-on-container-exit option correctly aborts all services when a container exits', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var result, _a, _b;
|
|
return __generator(this, function (_c) {
|
|
switch (_c.label) {
|
|
case 0: return [4 /*yield*/, compose.upAll({
|
|
cwd: path.join(__dirname),
|
|
log: logOutput,
|
|
commandOptions: ['--abort-on-container-exit']
|
|
})];
|
|
case 1:
|
|
result = _c.sent();
|
|
expect(result.out).toMatch(/Aborting on container exit/);
|
|
_a = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 2:
|
|
_a.apply(void 0, [_c.sent()]).toBeFalsy();
|
|
_b = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 3:
|
|
_b.apply(void 0, [_c.sent()]).toBeFalsy();
|
|
return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 4:
|
|
_c.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('ensure container gets killed', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var _a, _b, _c, _d;
|
|
return __generator(this, function (_e) {
|
|
switch (_e.label) {
|
|
case 0: return [4 /*yield*/, compose.upAll({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 1:
|
|
_e.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 2:
|
|
_a.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
_b = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 3:
|
|
_b.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
return [4 /*yield*/, compose.kill({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 4:
|
|
_e.sent();
|
|
_c = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 5:
|
|
_c.apply(void 0, [_e.sent()]).toBeFalsy();
|
|
_d = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 6:
|
|
_d.apply(void 0, [_e.sent()]).toBeFalsy();
|
|
return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 7:
|
|
_e.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('ensure custom ymls are working', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var config, cwd, _a, _b;
|
|
return __generator(this, function (_c) {
|
|
switch (_c.label) {
|
|
case 0:
|
|
config = './docker-compose-2.yml';
|
|
cwd = path.join(__dirname);
|
|
return [4 /*yield*/, compose.upAll({ cwd: cwd, log: logOutput, config: config })];
|
|
case 1:
|
|
_c.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web_2')];
|
|
case 2:
|
|
_a.apply(void 0, [_c.sent()]).toBeTruthy();
|
|
// config & [config] are the same thing, ensures that multiple configs are handled properly
|
|
return [4 /*yield*/, compose.kill({ cwd: cwd, log: logOutput, config: [config] })];
|
|
case 3:
|
|
// config & [config] are the same thing, ensures that multiple configs are handled properly
|
|
_c.sent();
|
|
_b = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web_2')];
|
|
case 4:
|
|
_b.apply(void 0, [_c.sent()]).toBeFalsy();
|
|
return [4 /*yield*/, compose.down({ cwd: cwd, log: logOutput, config: config })];
|
|
case 5:
|
|
_c.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('ensure run and exec are working', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var checkOSID, opts, _a, std;
|
|
return __generator(this, function (_b) {
|
|
switch (_b.label) {
|
|
case 0:
|
|
checkOSID = function (out, id) {
|
|
// parse /etc/os-release contents
|
|
var re = /([\w,_]+)=(.*)/g;
|
|
var match;
|
|
var os = {};
|
|
while ((match = re.exec(out)) !== null) {
|
|
// eslint-disable-line no-cond-assign
|
|
os[match[1]] = match[2];
|
|
}
|
|
expect(os.ID).toBe(id);
|
|
};
|
|
opts = { cwd: path.join(__dirname), log: logOutput };
|
|
return [4 /*yield*/, compose.upAll(opts)];
|
|
case 1:
|
|
_b.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 2:
|
|
_a.apply(void 0, [_b.sent()]).toBeTruthy();
|
|
return [4 /*yield*/, compose.exec('web', 'cat /etc/os-release', opts)];
|
|
case 3:
|
|
std = _b.sent();
|
|
checkOSID(std.out, 'debian');
|
|
return [4 /*yield*/, compose.run('proxy', 'cat /etc/os-release', opts)];
|
|
case 4:
|
|
std = _b.sent();
|
|
checkOSID(std.out, 'alpine');
|
|
return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 5:
|
|
_b.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('ensure run and exec with command defined as array are working', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var checkOSID, opts, _a, std;
|
|
return __generator(this, function (_b) {
|
|
switch (_b.label) {
|
|
case 0:
|
|
checkOSID = function (out, id) {
|
|
// parse /etc/os-release contents
|
|
var re = /([\w,_]+)=(.*)/g;
|
|
var match;
|
|
var os = {};
|
|
while ((match = re.exec(out)) !== null) {
|
|
// eslint-disable-line no-cond-assign
|
|
os[match[1]] = match[2];
|
|
}
|
|
expect(os.ID).toBe(id);
|
|
};
|
|
opts = { cwd: path.join(__dirname), log: false };
|
|
return [4 /*yield*/, compose.upAll(opts)];
|
|
case 1:
|
|
_b.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 2:
|
|
_a.apply(void 0, [_b.sent()]).toBe(true);
|
|
return [4 /*yield*/, compose.exec('web', ['/bin/sh', '-c', 'cat /etc/os-release'], opts)];
|
|
case 3:
|
|
std = _b.sent();
|
|
checkOSID(std.out, 'debian');
|
|
return [4 /*yield*/, compose.run('proxy', ['/bin/sh', '-c', 'cat /etc/os-release'], opts)];
|
|
case 4:
|
|
std = _b.sent();
|
|
checkOSID(std.out, 'alpine');
|
|
return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 5:
|
|
_b.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('build accepts config as string', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var configuration, config, result;
|
|
return __generator(this, function (_a) {
|
|
switch (_a.label) {
|
|
case 0: return [4 /*yield*/, new Promise(function (resolve, reject) {
|
|
(0, fs_1.readFile)(path.join(__dirname, 'docker-compose-2.yml'), function (err, content) {
|
|
if (err) {
|
|
reject(err);
|
|
return;
|
|
}
|
|
resolve(content.toString());
|
|
});
|
|
})];
|
|
case 1:
|
|
configuration = _a.sent();
|
|
config = {
|
|
configAsString: configuration,
|
|
log: logOutput
|
|
};
|
|
return [4 /*yield*/, compose.upAll(config)];
|
|
case 2:
|
|
_a.sent();
|
|
return [4 /*yield*/, compose.port('web', 8888, config)];
|
|
case 3:
|
|
result = _a.sent();
|
|
expect(result.data.address).toBe('0.0.0.0');
|
|
expect(result.data.port).toBe(8888);
|
|
return [4 /*yield*/, compose.down(config)];
|
|
case 4:
|
|
_a.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('build single service', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var opts, _a, _b, _c, _d;
|
|
return __generator(this, function (_e) {
|
|
switch (_e.label) {
|
|
case 0:
|
|
opts = {
|
|
cwd: path.join(__dirname),
|
|
log: logOutput,
|
|
config: 'docker-compose-build.yml'
|
|
};
|
|
return [4 /*yield*/, removeImagesStartingWith('compose-test-build-image')];
|
|
case 1:
|
|
_e.sent();
|
|
return [4 /*yield*/, compose.buildOne('build_test_1', opts)];
|
|
case 2:
|
|
_e.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, imageExists('compose-test-build-image-1:test')];
|
|
case 3:
|
|
_a.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
_b = expect;
|
|
return [4 /*yield*/, imageExists('compose-test-build-image-2:test')];
|
|
case 4:
|
|
_b.apply(void 0, [_e.sent()]).toBeFalsy();
|
|
_c = expect;
|
|
return [4 /*yield*/, imageExists('compose-test-build-image-3:test')];
|
|
case 5:
|
|
_c.apply(void 0, [_e.sent()]).toBeFalsy();
|
|
_d = expect;
|
|
return [4 /*yield*/, imageExists('compose-test-build-image-4:test')];
|
|
case 6:
|
|
_d.apply(void 0, [_e.sent()]).toBeFalsy();
|
|
return [4 /*yield*/, removeImagesStartingWith('compose-test-build-image')];
|
|
case 7:
|
|
_e.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('build multiple services', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var opts, _a, _b, _c, _d;
|
|
return __generator(this, function (_e) {
|
|
switch (_e.label) {
|
|
case 0:
|
|
opts = {
|
|
cwd: path.join(__dirname),
|
|
log: logOutput,
|
|
config: 'docker-compose-build.yml'
|
|
};
|
|
return [4 /*yield*/, compose.buildMany(['build_test_2', 'build_test_3'], opts)];
|
|
case 1:
|
|
_e.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, imageExists('compose-test-build-image-1:test')];
|
|
case 2:
|
|
_a.apply(void 0, [_e.sent()]).toBeFalsy();
|
|
_b = expect;
|
|
return [4 /*yield*/, imageExists('compose-test-build-image-2:test')];
|
|
case 3:
|
|
_b.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
_c = expect;
|
|
return [4 /*yield*/, imageExists('compose-test-build-image-3:test')];
|
|
case 4:
|
|
_c.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
_d = expect;
|
|
return [4 /*yield*/, imageExists('compose-test-build-image-4:test')];
|
|
case 5:
|
|
_d.apply(void 0, [_e.sent()]).toBeFalsy();
|
|
return [4 /*yield*/, removeImagesStartingWith('compose-test-build-image')];
|
|
case 6:
|
|
_e.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('build all services', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var opts, _a, _b, _c, _d;
|
|
return __generator(this, function (_e) {
|
|
switch (_e.label) {
|
|
case 0:
|
|
opts = {
|
|
cwd: path.join(__dirname),
|
|
log: logOutput,
|
|
config: 'docker-compose-build.yml'
|
|
};
|
|
return [4 /*yield*/, compose.buildAll(opts)];
|
|
case 1:
|
|
_e.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, imageExists('compose-test-build-image-1:test')];
|
|
case 2:
|
|
_a.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
_b = expect;
|
|
return [4 /*yield*/, imageExists('compose-test-build-image-2:test')];
|
|
case 3:
|
|
_b.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
_c = expect;
|
|
return [4 /*yield*/, imageExists('compose-test-build-image-3:test')];
|
|
case 4:
|
|
_c.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
_d = expect;
|
|
return [4 /*yield*/, imageExists('compose-test-build-image-4:test')];
|
|
case 5:
|
|
_d.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
return [4 /*yield*/, removeImagesStartingWith('compose-test-build-image')];
|
|
case 6:
|
|
_e.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('pull single service', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var opts, _a, _b;
|
|
return __generator(this, function (_c) {
|
|
switch (_c.label) {
|
|
case 0:
|
|
opts = {
|
|
cwd: path.join(__dirname),
|
|
log: logOutput,
|
|
config: 'docker-compose.yml'
|
|
};
|
|
return [4 /*yield*/, removeImagesStartingWith('nginx:1.19.9-alpine')];
|
|
case 1:
|
|
_c.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, imageExists('nginx:1.19.9-alpine')];
|
|
case 2:
|
|
_a.apply(void 0, [_c.sent()]).toBeFalsy();
|
|
return [4 /*yield*/, compose.pullOne('proxy', opts)];
|
|
case 3:
|
|
_c.sent();
|
|
_b = expect;
|
|
return [4 /*yield*/, imageExists('nginx:1.19.9-alpine')];
|
|
case 4:
|
|
_b.apply(void 0, [_c.sent()]).toBeTruthy();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('pull multiple services', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var opts, _a, _b, _c, _d;
|
|
return __generator(this, function (_e) {
|
|
switch (_e.label) {
|
|
case 0:
|
|
opts = {
|
|
cwd: path.join(__dirname),
|
|
log: logOutput,
|
|
config: 'docker-compose.yml'
|
|
};
|
|
return [4 /*yield*/, removeImagesStartingWith('nginx:1.16.0')];
|
|
case 1:
|
|
_e.sent();
|
|
return [4 /*yield*/, removeImagesStartingWith('nginx:1.19.9-alpine')];
|
|
case 2:
|
|
_e.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, imageExists('nginx:1.16.0')];
|
|
case 3:
|
|
_a.apply(void 0, [_e.sent()]).toBeFalsy();
|
|
_b = expect;
|
|
return [4 /*yield*/, imageExists('nginx:1.19.9-alpine')];
|
|
case 4:
|
|
_b.apply(void 0, [_e.sent()]).toBeFalsy();
|
|
return [4 /*yield*/, compose.pullMany(['web', 'proxy'], opts)];
|
|
case 5:
|
|
_e.sent();
|
|
_c = expect;
|
|
return [4 /*yield*/, imageExists('nginx:1.16.0')];
|
|
case 6:
|
|
_c.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
_d = expect;
|
|
return [4 /*yield*/, imageExists('nginx:1.19.9-alpine')];
|
|
case 7:
|
|
_d.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('pull all services', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var opts, _a, _b, _c, _d;
|
|
return __generator(this, function (_e) {
|
|
switch (_e.label) {
|
|
case 0:
|
|
opts = {
|
|
cwd: path.join(__dirname),
|
|
log: logOutput,
|
|
config: 'docker-compose.yml'
|
|
};
|
|
return [4 /*yield*/, removeImagesStartingWith('nginx:1.16.0')];
|
|
case 1:
|
|
_e.sent();
|
|
return [4 /*yield*/, removeImagesStartingWith('nginx:1.19.9-alpine')];
|
|
case 2:
|
|
_e.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, imageExists('nginx:1.16.0')];
|
|
case 3:
|
|
_a.apply(void 0, [_e.sent()]).toBeFalsy();
|
|
_b = expect;
|
|
return [4 /*yield*/, imageExists('nginx:1.19.9-alpine')];
|
|
case 4:
|
|
_b.apply(void 0, [_e.sent()]).toBeFalsy();
|
|
return [4 /*yield*/, compose.pullAll(opts)];
|
|
case 5:
|
|
_e.sent();
|
|
_c = expect;
|
|
return [4 /*yield*/, imageExists('nginx:1.16.0')];
|
|
case 6:
|
|
_c.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
_d = expect;
|
|
return [4 /*yield*/, imageExists('nginx:1.19.9-alpine')];
|
|
case 7:
|
|
_d.apply(void 0, [_e.sent()]).toBeTruthy();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('teardown', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
return __generator(this, function (_a) {
|
|
switch (_a.label) {
|
|
case 0:
|
|
docker.listContainers(function (err, containers) {
|
|
if (err) {
|
|
throw err;
|
|
}
|
|
containers.forEach(function (container) {
|
|
container.Names.forEach(function (name) {
|
|
if (name.startsWith('/compose_test_')) {
|
|
console.log("stopping ".concat(container.Id, " ").concat(container.Names));
|
|
docker.getContainer(container.Id).stop();
|
|
}
|
|
});
|
|
});
|
|
});
|
|
return [4 /*yield*/, removeImagesStartingWith('compose-test-build-image')];
|
|
case 1:
|
|
_a.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('config show data for docker-compose files', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var std;
|
|
return __generator(this, function (_a) {
|
|
switch (_a.label) {
|
|
case 0: return [4 /*yield*/, compose.config({
|
|
cwd: path.join(__dirname),
|
|
log: logOutput,
|
|
config: 'docker-compose-42.yml'
|
|
})];
|
|
case 1:
|
|
std = _a.sent();
|
|
expect(std.data.config.version).toBe('3');
|
|
expect(std.data.config.services['some-service']['image']).toBe('nginx:1.19.9-alpine');
|
|
expect(std.data.config.volumes['db-data']).toEqual({});
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('config show data for docker-compose files (services)', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var std;
|
|
return __generator(this, function (_a) {
|
|
switch (_a.label) {
|
|
case 0: return [4 /*yield*/, compose.configServices({
|
|
cwd: path.join(__dirname),
|
|
log: logOutput,
|
|
config: 'docker-compose-build.yml'
|
|
})];
|
|
case 1:
|
|
std = _a.sent();
|
|
expect(std.data.services.length).toBe(5);
|
|
expect(std.data.services[0]).toContain('build_test_1');
|
|
expect(std.err).toBeFalsy();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('config show data for docker-compose files (volumes)', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var std;
|
|
return __generator(this, function (_a) {
|
|
switch (_a.label) {
|
|
case 0: return [4 /*yield*/, compose.configVolumes({
|
|
cwd: path.join(__dirname),
|
|
log: logOutput,
|
|
config: 'docker-compose-42.yml'
|
|
})];
|
|
case 1:
|
|
std = _a.sent();
|
|
expect(std.data.volumes.length).toBe(1);
|
|
expect(std.data.volumes[0]).toContain('db-data');
|
|
expect(std.err).toBeFalsy();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('ps shows status data for started containers', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var std, web;
|
|
var _a, _b;
|
|
return __generator(this, function (_c) {
|
|
switch (_c.label) {
|
|
case 0: return [4 /*yield*/, compose.upAll({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 1:
|
|
_c.sent();
|
|
return [4 /*yield*/, compose.ps({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 2:
|
|
std = _c.sent();
|
|
expect(std.err).toBeFalsy();
|
|
expect(std.data.services.length).toBe(3);
|
|
web = std.data.services.find(function (service) { return service.name === 'compose_test_web'; });
|
|
expect(std.data.services.length).toBe(3);
|
|
expect(web === null || web === void 0 ? void 0 : web.ports.length).toBe(2);
|
|
expect(web === null || web === void 0 ? void 0 : web.ports[0].exposed.port).toBe(443);
|
|
expect(web === null || web === void 0 ? void 0 : web.ports[0].exposed.protocol).toBe('tcp');
|
|
expect((_a = web === null || web === void 0 ? void 0 : web.ports[0].mapped) === null || _a === void 0 ? void 0 : _a.port).toBe(443);
|
|
expect((_b = web === null || web === void 0 ? void 0 : web.ports[0].mapped) === null || _b === void 0 ? void 0 : _b.address).toBe('0.0.0.0');
|
|
return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 3:
|
|
_c.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('ps does not show status data for stopped containers', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var std, web, proxy;
|
|
return __generator(this, function (_a) {
|
|
switch (_a.label) {
|
|
case 0: return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 1:
|
|
_a.sent();
|
|
return [4 /*yield*/, compose.upOne('web', { cwd: path.join(__dirname), log: logOutput })];
|
|
case 2:
|
|
_a.sent();
|
|
return [4 /*yield*/, compose.ps({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 3:
|
|
std = _a.sent();
|
|
expect(std.err).toBeFalsy();
|
|
web = std.data.services.find(function (service) { return service.name === 'compose_test_web'; });
|
|
proxy = std.data.services.find(function (service) { return service.name === 'compose_test_proxy'; });
|
|
expect(web === null || web === void 0 ? void 0 : web.name).toBe('compose_test_web');
|
|
expect(proxy).toBeFalsy();
|
|
return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 4:
|
|
_a.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('restartAll does restart all containers', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var _a, _b;
|
|
return __generator(this, function (_c) {
|
|
switch (_c.label) {
|
|
case 0: return [4 /*yield*/, compose.upAll({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 1:
|
|
_c.sent();
|
|
return [4 /*yield*/, compose.restartAll({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 2:
|
|
_c.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 3:
|
|
_a.apply(void 0, [_c.sent()]).toBeTruthy();
|
|
_b = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 4:
|
|
_b.apply(void 0, [_c.sent()]).toBeTruthy();
|
|
return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 5:
|
|
_c.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('restartMany does restart selected containers', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var _a;
|
|
return __generator(this, function (_b) {
|
|
switch (_b.label) {
|
|
case 0: return [4 /*yield*/, compose.upAll({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 1:
|
|
_b.sent();
|
|
return [4 /*yield*/, compose.restartMany(['web', 'proxy'], {
|
|
cwd: path.join(__dirname),
|
|
log: logOutput
|
|
})];
|
|
case 2:
|
|
_b.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 3:
|
|
_a.apply(void 0, [_b.sent()]).toBeTruthy();
|
|
return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 4:
|
|
_b.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('restartOne does restart container', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var _a;
|
|
return __generator(this, function (_b) {
|
|
switch (_b.label) {
|
|
case 0: return [4 /*yield*/, compose.upAll({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 1:
|
|
_b.sent();
|
|
return [4 /*yield*/, compose.restartOne('proxy', {
|
|
cwd: path.join(__dirname),
|
|
log: logOutput
|
|
})];
|
|
case 2:
|
|
_b.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 3:
|
|
_a.apply(void 0, [_b.sent()]).toBeTruthy();
|
|
return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 4:
|
|
_b.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('logs does follow service logs', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var std;
|
|
return __generator(this, function (_a) {
|
|
switch (_a.label) {
|
|
case 0: return [4 /*yield*/, compose.upAll({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 1:
|
|
_a.sent();
|
|
return [4 /*yield*/, compose.logs('proxy', {
|
|
cwd: path.join(__dirname),
|
|
log: logOutput
|
|
})];
|
|
case 2:
|
|
std = _a.sent();
|
|
expect(std.out.includes('compose_test_proxy')).toBeTruthy();
|
|
return [4 /*yield*/, compose.down({ cwd: path.join(__dirname), log: logOutput })];
|
|
case 3:
|
|
_a.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('returns the port for a started service', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var config, port;
|
|
return __generator(this, function (_a) {
|
|
switch (_a.label) {
|
|
case 0:
|
|
config = {
|
|
cwd: path.join(__dirname),
|
|
config: './docker-compose-2.yml',
|
|
log: logOutput
|
|
};
|
|
return [4 /*yield*/, compose.upAll(config)];
|
|
case 1:
|
|
_a.sent();
|
|
return [4 /*yield*/, compose.port('web', 8888, config)];
|
|
case 2:
|
|
port = _a.sent();
|
|
expect(port.out).toMatch(/.*:[0-9]{1,5}/);
|
|
return [4 /*yield*/, compose.down(config)];
|
|
case 3:
|
|
_a.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('removes container', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var config, _a, _b, _c, _d, _e, _f;
|
|
return __generator(this, function (_g) {
|
|
switch (_g.label) {
|
|
case 0:
|
|
config = {
|
|
cwd: path.join(__dirname),
|
|
config: './docker-compose.yml',
|
|
log: logOutput
|
|
};
|
|
return [4 /*yield*/, compose.upAll(config)];
|
|
case 1:
|
|
_g.sent();
|
|
_a = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 2:
|
|
_a.apply(void 0, [_g.sent()]).toBeTruthy();
|
|
_b = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 3:
|
|
_b.apply(void 0, [_g.sent()]).toBeTruthy();
|
|
return [4 /*yield*/, compose.rm(__assign(__assign({}, config), { commandOptions: ['-s'] }), 'proxy')];
|
|
case 4:
|
|
_g.sent();
|
|
_c = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 5:
|
|
_c.apply(void 0, [_g.sent()]).toBeTruthy();
|
|
_d = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 6:
|
|
_d.apply(void 0, [_g.sent()]).toBeFalsy();
|
|
return [4 /*yield*/, compose.rm(__assign(__assign({}, config), { commandOptions: ['-s'] }), 'proxy', 'web')];
|
|
case 7:
|
|
_g.sent();
|
|
_e = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_web')];
|
|
case 8:
|
|
_e.apply(void 0, [_g.sent()]).toBeFalsy();
|
|
_f = expect;
|
|
return [4 /*yield*/, isContainerRunning('/compose_test_proxy')];
|
|
case 9:
|
|
_f.apply(void 0, [_g.sent()]).toBeFalsy();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('returns version information', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var version;
|
|
return __generator(this, function (_a) {
|
|
switch (_a.label) {
|
|
case 0: return [4 /*yield*/, compose.version()];
|
|
case 1:
|
|
version = (_a.sent()).data.version;
|
|
expect(version).toMatch(/^(\d+\.)?(\d+\.)?(\*|\d+)$/);
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|
|
test('parse ps output', function () {
|
|
var output = " Name Command State Ports \n-------------------------------------------------------------------------------------------------------\ncompose_test_hello /hello Exit 0 \ncompose_test_proxy /docker-entrypoint.sh ngin ... Up 80/tcp \ncompose_test_web nginx -g daemon off; Up 0.0.0.0:443->443/tcp, 0.0.0.0:80->80/tcp\n";
|
|
var psOut = (0, index_1.mapPsOutput)(output);
|
|
expect(psOut.services[0]).toEqual({
|
|
command: '/hello',
|
|
name: 'compose_test_hello',
|
|
state: 'Exit 0',
|
|
ports: []
|
|
});
|
|
expect(psOut.services[1]).toEqual({
|
|
command: '/docker-entrypoint.sh ngin ...',
|
|
name: 'compose_test_proxy',
|
|
state: 'Up',
|
|
ports: [{ exposed: { port: 80, protocol: 'tcp' } }]
|
|
});
|
|
expect(psOut.services[2]).toEqual({
|
|
command: 'nginx -g daemon off;',
|
|
name: 'compose_test_web',
|
|
state: 'Up',
|
|
ports: [
|
|
{
|
|
exposed: { port: 443, protocol: 'tcp' },
|
|
mapped: { port: 443, address: '0.0.0.0' }
|
|
},
|
|
{
|
|
exposed: { port: 80, protocol: 'tcp' },
|
|
mapped: { port: 80, address: '0.0.0.0' }
|
|
}
|
|
]
|
|
});
|
|
});
|
|
test('ps returns container ids when quiet', function () {
|
|
var output = "64848fc721dfeff435edc7d4bb42e2f0e0a10d0c7602b73729a7fd7b09b7586f\naed60ce17575e69c56cc4cb07eeba89b5d7b7b2b307c8b87f3363db6af850719\nf49548fa0b1f88846b78c65c6ea7f802bcbdfb2cf10204497eb89ba622d7715b\n";
|
|
var psOut = (0, index_1.mapPsOutput)(output, { commandOptions: ['-q'] });
|
|
expect(psOut.services[0]).toEqual(expect.objectContaining({
|
|
name: '64848fc721dfeff435edc7d4bb42e2f0e0a10d0c7602b73729a7fd7b09b7586f'
|
|
}));
|
|
expect(psOut.services[1]).toEqual(expect.objectContaining({
|
|
name: 'aed60ce17575e69c56cc4cb07eeba89b5d7b7b2b307c8b87f3363db6af850719'
|
|
}));
|
|
expect(psOut.services[2]).toEqual(expect.objectContaining({
|
|
name: 'f49548fa0b1f88846b78c65c6ea7f802bcbdfb2cf10204497eb89ba622d7715b'
|
|
}));
|
|
});
|
|
test('ps returns container names when --services is passed in options', function () {
|
|
var output = "web\nproxy\nhello\n";
|
|
var psOut = (0, index_1.mapPsOutput)(output, { commandOptions: ['--services'] });
|
|
expect(psOut.services[0]).toEqual(expect.objectContaining({
|
|
name: 'web'
|
|
}));
|
|
expect(psOut.services[1]).toEqual(expect.objectContaining({
|
|
name: 'proxy'
|
|
}));
|
|
expect(psOut.services[2]).toEqual(expect.objectContaining({
|
|
name: 'hello'
|
|
}));
|
|
});
|
|
test('ensure progress callback is called', function () { return __awaiter(void 0, void 0, void 0, function () {
|
|
var config;
|
|
return __generator(this, function (_a) {
|
|
switch (_a.label) {
|
|
case 0:
|
|
config = {
|
|
cwd: path.join(__dirname),
|
|
config: './docker-compose.yml',
|
|
callback: jest.fn()
|
|
};
|
|
return [4 /*yield*/, compose.upAll(config)];
|
|
case 1:
|
|
_a.sent();
|
|
expect(config.callback).toBeCalled();
|
|
return [4 /*yield*/, compose.down(config)];
|
|
case 2:
|
|
_a.sent();
|
|
return [2 /*return*/];
|
|
}
|
|
});
|
|
}); });
|