Compare commits
34 Commits
Author | SHA1 | Date | |
---|---|---|---|
57594728df | |||
8430a4d6e0 | |||
7f38868510 | |||
7a80718d27 | |||
1d0c4c3cf9 | |||
a037cba454 | |||
7009e07ecc | |||
7b8ef33e21 | |||
3011e599e8 | |||
8adb636db3 | |||
dd35e5d7d2 | |||
91d7f583e2 | |||
a77ed42e9f | |||
499c6cc3b7 | |||
19283fb695 | |||
b2d84b1399 | |||
7cc2374130 | |||
526bb5bbd0 | |||
14b2105a49 | |||
37efeffe69 | |||
943f46d620 | |||
cfb7c1ce06 | |||
489a47b9bf | |||
28fa5349d7 | |||
cc82b3af04 | |||
6a8751afd2 | |||
56612f9ac9 | |||
2a1fcd8cdb | |||
09911328b2 | |||
548e32419e | |||
2b2b06b48b | |||
37028a9b1f | |||
3cba5844d8 | |||
a3ceb68eab |
5
.gitignore
vendored
5
.gitignore
vendored
@ -1,3 +1,4 @@
|
|||||||
docs/
|
.yarn/
|
||||||
coverage/
|
|
||||||
node_modules/
|
node_modules/
|
||||||
|
coverage/
|
||||||
|
public/
|
||||||
|
@ -1,38 +1,31 @@
|
|||||||
image: hosttoday/ht-docker-dbase
|
image: hosttoday/ht-docker-dbase:npmci
|
||||||
services:
|
services:
|
||||||
- docker:dind
|
- docker:dind
|
||||||
|
|
||||||
|
cache:
|
||||||
|
paths:
|
||||||
|
- .yarn/
|
||||||
|
key: "$CI_BUILD_STAGE"
|
||||||
|
|
||||||
stages:
|
stages:
|
||||||
- build
|
|
||||||
- test
|
- test
|
||||||
- release
|
- release
|
||||||
- trigger
|
- trigger
|
||||||
|
- pages
|
||||||
|
|
||||||
before_script:
|
before_script:
|
||||||
- npmci prepare docker-gitlab
|
- npmci prepare docker-gitlab
|
||||||
|
|
||||||
|
|
||||||
build:
|
|
||||||
stage: build
|
|
||||||
script:
|
|
||||||
- npm install
|
|
||||||
- npm test
|
|
||||||
- npmci build docker
|
|
||||||
tags:
|
|
||||||
- lossless
|
|
||||||
- priv
|
|
||||||
|
|
||||||
|
|
||||||
test:
|
test:
|
||||||
stage: test
|
stage: test
|
||||||
script:
|
script:
|
||||||
- npmci test docker
|
- npmci test stable
|
||||||
tags:
|
tags:
|
||||||
- lossless
|
- lossless
|
||||||
- priv
|
- priv
|
||||||
|
|
||||||
release:
|
release:
|
||||||
image: hosttoday/ht-docker-node:npmts
|
image: hosttoday/ht-docker-node:npmci
|
||||||
stage: release
|
stage: release
|
||||||
script:
|
script:
|
||||||
- npmci publish npm
|
- npmci publish npm
|
||||||
@ -43,6 +36,7 @@ release:
|
|||||||
- priv
|
- priv
|
||||||
|
|
||||||
trigger:
|
trigger:
|
||||||
|
image: hosttoday/ht-docker-node:npmci
|
||||||
stage: trigger
|
stage: trigger
|
||||||
script:
|
script:
|
||||||
- npmci trigger
|
- npmci trigger
|
||||||
@ -51,3 +45,18 @@ trigger:
|
|||||||
tags:
|
tags:
|
||||||
- lossless
|
- lossless
|
||||||
- priv
|
- priv
|
||||||
|
|
||||||
|
pages:
|
||||||
|
image: hosttoday/ht-docker-node:npmci
|
||||||
|
stage: pages
|
||||||
|
script:
|
||||||
|
- npmci command yarn global add npmpage
|
||||||
|
- npmci command npmpage --publish gitlab
|
||||||
|
tags:
|
||||||
|
- docker
|
||||||
|
only:
|
||||||
|
- tags
|
||||||
|
artifacts:
|
||||||
|
expire_in: 1 week
|
||||||
|
paths:
|
||||||
|
- public
|
@ -1,6 +0,0 @@
|
|||||||
FROM hosttoday/ht-docker-node:npmts
|
|
||||||
RUN mkdir app-node
|
|
||||||
COPY ./ /app-node/
|
|
||||||
WORKDIR /app-node
|
|
||||||
ENV CI true
|
|
||||||
CMD ["npmts"]
|
|
36
README.md
36
README.md
@ -1,11 +1,29 @@
|
|||||||
# dockersock
|
# @mojoio/dockersock
|
||||||
easy communication with docker from node, TypeScript ready
|
|
||||||
|
|
||||||
## Status
|
easy communication with docker remote api from node, TypeScript ready
|
||||||
[](https://gitlab.com/pushrocks/dockersock/commits/master)
|
|
||||||
|
## Availabililty
|
||||||
|
|
||||||
|
[](https://www.npmjs.com/package/dockersock)
|
||||||
|
[](https://GitLab.com/mojoio/dockersock)
|
||||||
|
[](https://github.com/mojoio/dockersock)
|
||||||
|
[](https://mojoio.gitlab.io/dockersock/)
|
||||||
|
|
||||||
|
## Status for master
|
||||||
|
|
||||||
|
[](https://GitLab.com/mojoio/dockersock/commits/master)
|
||||||
|
[](https://GitLab.com/mojoio/dockersock/commits/master)
|
||||||
|
[](https://www.npmjs.com/package/dockersock)
|
||||||
|
[](https://david-dm.org/mojoio/dockersock)
|
||||||
|
[](https://www.bithound.io/github/mojoio/dockersock/master/dependencies/npm)
|
||||||
|
[](https://www.bithound.io/github/mojoio/dockersock)
|
||||||
|
[](https://nodejs.org/dist/latest-v6.x/docs/api/)
|
||||||
|
[](https://nodejs.org/dist/latest-v6.x/docs/api/)
|
||||||
|
[](http://standardjs.com/)
|
||||||
|
|
||||||
## Usage
|
## Usage
|
||||||
We recommend the use of TypeScript for best Intellisense.
|
|
||||||
|
Use TypeScript for best in class instellisense.
|
||||||
|
|
||||||
```TypeScript
|
```TypeScript
|
||||||
import {Dockersock} from "dockersock"; // require Dockersock class
|
import {Dockersock} from "dockersock"; // require Dockersock class
|
||||||
@ -24,5 +42,11 @@ myDockersock.startContainer({ // starts a already present container
|
|||||||
myDockersock.newContainer({ // start new Container, equals "docker run" shell command
|
myDockersock.newContainer({ // start new Container, equals "docker run" shell command
|
||||||
image: "someimagetag"
|
image: "someimagetag"
|
||||||
})
|
})
|
||||||
|
|
||||||
```
|
```
|
||||||
|
|
||||||
|
For further information read the linked docs at the top of this README.
|
||||||
|
|
||||||
|
> MIT licensed | **©** [Lossless GmbH](https://lossless.gmbh)
|
||||||
|
> | By using this npm module you agree to our [privacy policy](https://lossless.gmbH/privacy.html)
|
||||||
|
|
||||||
|
[](https://mojo.io)
|
||||||
|
26
dist/dockersock.classes.dockersock.d.ts
vendored
26
dist/dockersock.classes.dockersock.d.ts
vendored
@ -1,26 +0,0 @@
|
|||||||
/// <reference types="q" />
|
|
||||||
import "typings-global";
|
|
||||||
import * as plugins from "./dockersock.plugins";
|
|
||||||
import { Observable } from "rxjs";
|
|
||||||
export declare class Dockersock {
|
|
||||||
sockPath: string;
|
|
||||||
constructor(pathArg?: string);
|
|
||||||
auth(userArg: string, passArg: string): plugins.q.Promise<{}>;
|
|
||||||
listContainers(): plugins.q.Promise<{}>;
|
|
||||||
listContainersDetailed(): plugins.q.Promise<{}>;
|
|
||||||
listContainersRunning(): plugins.q.Promise<{}>;
|
|
||||||
listContainersStopped(): plugins.q.Promise<{}>;
|
|
||||||
listImages(): plugins.q.Promise<{}>;
|
|
||||||
listImagesDangling(): plugins.q.Promise<{}>;
|
|
||||||
pullImage(imageLabelArg: string): plugins.q.Promise<{}>;
|
|
||||||
createContainer(optionsArg: any, pullFirstArg?: boolean): plugins.q.Promise<{}>;
|
|
||||||
getContainerId(): void;
|
|
||||||
startContainer(containerNameArg: any): plugins.q.Promise<{}>;
|
|
||||||
stopContainer(containerNameArg: any): plugins.q.Promise<{}>;
|
|
||||||
removeContainer(containerNameArg: any): plugins.q.Promise<{}>;
|
|
||||||
clean(): plugins.q.Promise<{}>;
|
|
||||||
callOnChange(cb: Function): void;
|
|
||||||
getChangeObservable(): Observable<{}>;
|
|
||||||
request(methodArg: string, routeArg: string, queryArg?: string, dataArg?: {}): plugins.q.Promise<{}>;
|
|
||||||
requestStream(methodArg: string, routeArg: string, queryArg?: string, dataArg?: {}): plugins.q.Promise<{}>;
|
|
||||||
}
|
|
220
dist/dockersock.classes.dockersock.js
vendored
220
dist/dockersock.classes.dockersock.js
vendored
File diff suppressed because one or more lines are too long
5
dist/dockersock.plugins.d.ts
vendored
5
dist/dockersock.plugins.d.ts
vendored
@ -1,5 +0,0 @@
|
|||||||
import "typings-global";
|
|
||||||
export import beautylog = require("beautylog");
|
|
||||||
export import q = require("q");
|
|
||||||
export import request = require("request");
|
|
||||||
export import rxjs = require("rxjs");
|
|
7
dist/dockersock.plugins.js
vendored
7
dist/dockersock.plugins.js
vendored
@ -1,7 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
require("typings-global");
|
|
||||||
exports.beautylog = require("beautylog");
|
|
||||||
exports.q = require("q");
|
|
||||||
exports.request = require("request");
|
|
||||||
exports.rxjs = require("rxjs");
|
|
||||||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiZG9ja2Vyc29jay5wbHVnaW5zLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vdHMvZG9ja2Vyc29jay5wbHVnaW5zLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7QUFBQSxRQUFPLGdCQUFnQixDQUFDLENBQUE7QUFDVixpQkFBUyxXQUFXLFdBQVcsQ0FBQyxDQUFDO0FBQ2pDLFNBQUMsV0FBVyxHQUFHLENBQUMsQ0FBQztBQUNqQixlQUFPLFdBQVcsU0FBUyxDQUFDLENBQUM7QUFDN0IsWUFBSSxXQUFXLE1BQU0sQ0FBQyxDQUFDIn0=
|
|
2
dist/index.d.ts
vendored
2
dist/index.d.ts
vendored
@ -1,2 +0,0 @@
|
|||||||
import "typings-global";
|
|
||||||
export { Dockersock } from "./dockersock.classes.dockersock";
|
|
5
dist/index.js
vendored
5
dist/index.js
vendored
@ -1,5 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
require("typings-global");
|
|
||||||
var dockersock_classes_dockersock_1 = require("./dockersock.classes.dockersock");
|
|
||||||
exports.Dockersock = dockersock_classes_dockersock_1.Dockersock;
|
|
||||||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsUUFBTyxnQkFBZ0IsQ0FBQyxDQUFBO0FBQ3hCLDhDQUF5QixpQ0FBaUMsQ0FBQztBQUFuRCxnRUFBbUQifQ==
|
|
@ -1,18 +1,18 @@
|
|||||||
nginx1 :
|
nginx1 :
|
||||||
image: "nginx"
|
image: "nginx"
|
||||||
environment:
|
environment:
|
||||||
VIRTUAL_HOST: "test100.labkomp.de"
|
VIRTUAL_HOST: "test100.bleu.de"
|
||||||
restart: always
|
restart: always
|
||||||
container_name: nginx1
|
container_name: nginx1
|
||||||
nginx2:
|
nginx2:
|
||||||
image: nginx
|
image: nginx
|
||||||
environment:
|
environment:
|
||||||
VIRTUAL_HOST: "test101.labkomp.de"
|
VIRTUAL_HOST: "test101.bleu.de"
|
||||||
restart: always
|
restart: always
|
||||||
container_name: nginx2
|
container_name: nginx2
|
||||||
npmts-test-container:
|
nginx3:
|
||||||
image: "npmts-test-image"
|
image: nginx
|
||||||
volumes:
|
environment:
|
||||||
- "/var/run/docker.sock:/var/run/docker.sock"
|
VIRTUAL_HOST: "test101.bleu.de"
|
||||||
restart: always
|
restart: always
|
||||||
container_name: npmts-test-container
|
container_name: nginx3
|
@ -2,5 +2,14 @@
|
|||||||
"npmts": {
|
"npmts": {
|
||||||
"mode": "default",
|
"mode": "default",
|
||||||
"coverageTreshold": 10
|
"coverageTreshold": 10
|
||||||
|
},
|
||||||
|
"npmdocker": {
|
||||||
|
"baseImage": "hosttoday/ht-docker-node:npmci",
|
||||||
|
"command":
|
||||||
|
"(ls -a && rm -r node_modules && yarn global add npmts && yarn install && npmts)",
|
||||||
|
"dockerSock": true
|
||||||
|
},
|
||||||
|
"npmci": {
|
||||||
|
"globalNpmTools": ["npmts", "npmdocker"]
|
||||||
}
|
}
|
||||||
}
|
}
|
1527
package-lock.json
generated
Normal file
1527
package-lock.json
generated
Normal file
File diff suppressed because it is too large
Load Diff
34
package.json
34
package.json
@ -1,14 +1,12 @@
|
|||||||
{
|
{
|
||||||
"name": "dockersock",
|
"name": "@mojoio/docker",
|
||||||
"version": "1.0.14",
|
"version": "1.0.26",
|
||||||
"description": "easy communication with docker from node, TypeScript ready",
|
"description": "easy communication with docker remote api from node, TypeScript ready",
|
||||||
"main": "dist/index.js",
|
"main": "dist/index.js",
|
||||||
"typings": "dist/index.d.ts",
|
"typings": "dist/index.d.ts",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"test": "npmts --notest && npm run build && npm run startdocker && npm run cleanup",
|
"test": "tsrun test/test.ts",
|
||||||
"build": "docker build -t npmts-test-image .",
|
"build": "(npmts --notest && npmdocker)"
|
||||||
"startdocker": "docker run -v /var/run/docker.sock:/var/run/docker.sock --name npmts-test-container npmts-test-image",
|
|
||||||
"cleanup": "docker rm npmts-test-container && docker rmi npmts-test-image"
|
|
||||||
},
|
},
|
||||||
"repository": {
|
"repository": {
|
||||||
"type": "git",
|
"type": "git",
|
||||||
@ -28,16 +26,18 @@
|
|||||||
},
|
},
|
||||||
"homepage": "https://gitlab.com/pushrocks/dockersock#README",
|
"homepage": "https://gitlab.com/pushrocks/dockersock#README",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@types/q": "*",
|
"@pushrocks/lik": "^3.0.4",
|
||||||
"beautylog": "^5.0.14",
|
"@pushrocks/smartlog": "^2.0.9",
|
||||||
"q": "^1.4.1",
|
"@pushrocks/smartpromise": "^2.0.5",
|
||||||
"request": "^2.73.0",
|
"@pushrocks/smartrequest": "^1.1.14",
|
||||||
"rxjs": "^5.0.0-beta.10",
|
"rxjs": "^6.3.3"
|
||||||
"typings-global": "^1.0.6"
|
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"npmts-g": "^5.2.6",
|
"@gitzone/tsrun": "^1.1.17",
|
||||||
"should": "^9.0.2",
|
"@pushrocks/tapbundle": "^3.0.7",
|
||||||
"typings-test": "^1.0.1"
|
"@types/node": "^10.12.18",
|
||||||
}
|
"tslint": "^5.12.0",
|
||||||
|
"tslint-config-prettier": "^1.17.0"
|
||||||
|
},
|
||||||
|
"private": false
|
||||||
}
|
}
|
||||||
|
2
test/test.d.ts
vendored
2
test/test.d.ts
vendored
@ -1,2 +0,0 @@
|
|||||||
import "typings-test";
|
|
||||||
import "should";
|
|
36
test/test.js
36
test/test.js
@ -1,36 +0,0 @@
|
|||||||
"use strict";
|
|
||||||
require("typings-test");
|
|
||||||
require("should");
|
|
||||||
const index_1 = require("../dist/index");
|
|
||||||
describe("dockersock", function () {
|
|
||||||
describe(".Dockersock()", function () {
|
|
||||||
let testDockersock;
|
|
||||||
it("should create a new Dockersock instance", function () {
|
|
||||||
testDockersock = new index_1.Dockersock();
|
|
||||||
testDockersock.should.be.instanceof(index_1.Dockersock);
|
|
||||||
});
|
|
||||||
it("should list containers", function (done) {
|
|
||||||
testDockersock.listContainers()
|
|
||||||
.then((dataArg) => {
|
|
||||||
console.log(dataArg);
|
|
||||||
done();
|
|
||||||
});
|
|
||||||
});
|
|
||||||
it("should list detailed containers", function (done) {
|
|
||||||
this.timeout(5000);
|
|
||||||
testDockersock.listContainersDetailed()
|
|
||||||
.then((dataArg) => {
|
|
||||||
console.log(dataArg);
|
|
||||||
done();
|
|
||||||
});
|
|
||||||
});
|
|
||||||
it("should pull an image from imagetag", function (done) {
|
|
||||||
this.timeout(60000);
|
|
||||||
testDockersock.pullImage("hosttoday/ht-docker-dbase")
|
|
||||||
.then((dataArg) => {
|
|
||||||
done();
|
|
||||||
}, done);
|
|
||||||
});
|
|
||||||
});
|
|
||||||
});
|
|
||||||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGVzdC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbInRlc3QudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLFFBQU8sY0FBYyxDQUFDLENBQUE7QUFDdEIsUUFBTyxRQUFRLENBQUMsQ0FBQTtBQUVoQix3QkFBeUIsZUFFekIsQ0FBQyxDQUZ1QztBQUV4QyxRQUFRLENBQUMsWUFBWSxFQUFDO0lBQ2xCLFFBQVEsQ0FBQyxlQUFlLEVBQUM7UUFDckIsSUFBSSxjQUF5QixDQUFDO1FBQzlCLEVBQUUsQ0FBQyx5Q0FBeUMsRUFBQztZQUN6QyxjQUFjLEdBQUcsSUFBSSxrQkFBVSxFQUFFLENBQUM7WUFDbEMsY0FBYyxDQUFDLE1BQU0sQ0FBQyxFQUFFLENBQUMsVUFBVSxDQUFDLGtCQUFVLENBQUMsQ0FBQztRQUNwRCxDQUFDLENBQUMsQ0FBQztRQUNILEVBQUUsQ0FBQyx3QkFBd0IsRUFBQyxVQUFTLElBQUk7WUFDckMsY0FBYyxDQUFDLGNBQWMsRUFBRTtpQkFDMUIsSUFBSSxDQUFDLENBQUMsT0FBTztnQkFDVixPQUFPLENBQUMsR0FBRyxDQUFDLE9BQU8sQ0FBQyxDQUFDO2dCQUNyQixJQUFJLEVBQUUsQ0FBQztZQUNYLENBQUMsQ0FBQyxDQUFDO1FBQ1gsQ0FBQyxDQUFDLENBQUM7UUFDSCxFQUFFLENBQUMsaUNBQWlDLEVBQUMsVUFBUyxJQUFJO1lBQzlDLElBQUksQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLENBQUM7WUFDbkIsY0FBYyxDQUFDLHNCQUFzQixFQUFFO2lCQUNsQyxJQUFJLENBQUMsQ0FBQyxPQUFPO2dCQUNWLE9BQU8sQ0FBQyxHQUFHLENBQUMsT0FBTyxDQUFDLENBQUM7Z0JBQ3JCLElBQUksRUFBRSxDQUFDO1lBQ1gsQ0FBQyxDQUFDLENBQUM7UUFDWCxDQUFDLENBQUMsQ0FBQztRQUNILEVBQUUsQ0FBQyxvQ0FBb0MsRUFBQyxVQUFTLElBQUk7WUFDakQsSUFBSSxDQUFDLE9BQU8sQ0FBQyxLQUFLLENBQUMsQ0FBQztZQUNwQixjQUFjLENBQUMsU0FBUyxDQUFDLDJCQUEyQixDQUFDO2lCQUNoRCxJQUFJLENBQUMsQ0FBQyxPQUFPO2dCQUNWLElBQUksRUFBRSxDQUFDO1lBQ1gsQ0FBQyxFQUFDLElBQUksQ0FBQyxDQUFDO1FBQ2hCLENBQUMsQ0FBQyxDQUFBO0lBQ04sQ0FBQyxDQUFDLENBQUM7QUFDUCxDQUFDLENBQUMsQ0FBQyJ9
|
|
52
test/test.ts
52
test/test.ts
@ -1,36 +1,30 @@
|
|||||||
import "typings-test";
|
import { expect, tap } from '@pushrocks/tapbundle';
|
||||||
import "should";
|
import { DockerHost } from '../ts/index';
|
||||||
|
|
||||||
import {Dockersock} from "../dist/index"
|
let testDockerHost: DockerHost;
|
||||||
|
|
||||||
describe("dockersock",function(){
|
tap.test('should create a new Dockersock instance', async () => {
|
||||||
describe(".Dockersock()",function(){
|
testDockerHost = new DockerHost();
|
||||||
let testDockersock:Dockersock;
|
return expect(testDockerHost).to.be.instanceof(DockerHost);
|
||||||
it("should create a new Dockersock instance",function(){
|
|
||||||
testDockersock = new Dockersock();
|
|
||||||
testDockersock.should.be.instanceof(Dockersock);
|
|
||||||
});
|
});
|
||||||
it("should list containers",function(done){
|
|
||||||
testDockersock.listContainers()
|
tap.test('should list containers', async () => {
|
||||||
.then((dataArg)=>{
|
const containers = await testDockerHost.getContainers();
|
||||||
console.log(dataArg);
|
console.log(containers);
|
||||||
done();
|
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|
||||||
|
tap.skip.test('should pull an image from imagetag', async () => {
|
||||||
|
// await testDockerHost.pullImage('hosttoday/ht-docker-node:npmci');
|
||||||
});
|
});
|
||||||
it("should list detailed containers",function(done){
|
|
||||||
this.timeout(5000);
|
tap.test('should return a change Objservable', async (tools) => {
|
||||||
testDockersock.listContainersDetailed()
|
const testObservable = await testDockerHost.getEventObservable();
|
||||||
.then((dataArg)=>{
|
const subscription = testObservable.subscribe(changeObject => {
|
||||||
console.log(dataArg);
|
console.log(changeObject);
|
||||||
done();
|
|
||||||
});
|
|
||||||
});
|
|
||||||
it("should pull an image from imagetag",function(done){
|
|
||||||
this.timeout(60000);
|
|
||||||
testDockersock.pullImage("hosttoday/ht-docker-dbase")
|
|
||||||
.then((dataArg)=>{
|
|
||||||
done();
|
|
||||||
},done);
|
|
||||||
})
|
|
||||||
});
|
});
|
||||||
|
await tools.delayFor(2000);
|
||||||
|
subscription.unsubscribe();
|
||||||
});
|
});
|
||||||
|
|
||||||
|
tap.start();
|
||||||
|
1
ts/docker.changes.ts
Normal file
1
ts/docker.changes.ts
Normal file
@ -0,0 +1 @@
|
|||||||
|
import * as plugins from './dockersock.plugins';
|
73
ts/docker.classes.container.ts
Normal file
73
ts/docker.classes.container.ts
Normal file
@ -0,0 +1,73 @@
|
|||||||
|
import * as plugins from './dockersock.plugins';
|
||||||
|
import * as interfaces from './interfaces';
|
||||||
|
|
||||||
|
import { DockerHost } from './docker.classes.host';
|
||||||
|
|
||||||
|
export class DockerContainer {
|
||||||
|
// ======
|
||||||
|
// STATIC
|
||||||
|
// ======
|
||||||
|
|
||||||
|
/**
|
||||||
|
* get all containers
|
||||||
|
*/
|
||||||
|
static async getContainers(dockerHostArg: DockerHost): Promise<DockerContainer[]> {
|
||||||
|
const result: DockerContainer[] = [];
|
||||||
|
const response = await dockerHostArg.request('GET', '/containers/json');
|
||||||
|
for (const containerResult of response.body) {
|
||||||
|
result.push(new DockerContainer(containerResult));
|
||||||
|
}
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
*
|
||||||
|
* @param containerId
|
||||||
|
*/
|
||||||
|
static async getContainerById(containerId: string) {
|
||||||
|
|
||||||
|
}
|
||||||
|
static async create() {}
|
||||||
|
|
||||||
|
// ========
|
||||||
|
// INSTANCE
|
||||||
|
// ========
|
||||||
|
|
||||||
|
constructor(dockerContainerObjectArg: any) {
|
||||||
|
Object.keys(dockerContainerObjectArg).forEach(keyArg => {
|
||||||
|
this[keyArg] = dockerContainerObjectArg[keyArg];
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
Id: string;
|
||||||
|
Names: string[];
|
||||||
|
Image: string;
|
||||||
|
ImageID: string;
|
||||||
|
Command: string;
|
||||||
|
Created: number;
|
||||||
|
Ports: interfaces.TPorts;
|
||||||
|
Labels: interfaces.TLabels;
|
||||||
|
State: string;
|
||||||
|
Status: string;
|
||||||
|
HostConfig: any;
|
||||||
|
NetworkSettings: {
|
||||||
|
Networks: {
|
||||||
|
[key: string]: {
|
||||||
|
IPAMConfig: any;
|
||||||
|
Links: any;
|
||||||
|
Aliases: any;
|
||||||
|
NetworkID: string;
|
||||||
|
EndpointID: string;
|
||||||
|
Gateway: string;
|
||||||
|
IPAddress: string;
|
||||||
|
IPPrefixLen: number;
|
||||||
|
IPv6Gateway: string;
|
||||||
|
GlobalIPv6Address: string;
|
||||||
|
GlobalIPv6PrefixLen: number;
|
||||||
|
MacAddress: string;
|
||||||
|
DriverOpts: any;
|
||||||
|
};
|
||||||
|
};
|
||||||
|
};
|
||||||
|
Mounts: any;
|
||||||
|
}
|
87
ts/docker.classes.host.ts
Normal file
87
ts/docker.classes.host.ts
Normal file
@ -0,0 +1,87 @@
|
|||||||
|
import * as plugins from './dockersock.plugins';
|
||||||
|
import { DockerContainer } from './docker.classes.container';
|
||||||
|
|
||||||
|
export class DockerHost {
|
||||||
|
/**
|
||||||
|
* the path where the docker sock can be found
|
||||||
|
*/
|
||||||
|
sockPath: string;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* keeping track of currently active requests to safely end this module at any time
|
||||||
|
*/
|
||||||
|
requestObjectmap = new plugins.lik.Objectmap<any>();
|
||||||
|
|
||||||
|
/**
|
||||||
|
* the constructor to instantiate a new docker sock instance
|
||||||
|
* @param pathArg
|
||||||
|
*/
|
||||||
|
constructor(pathArg: string = 'http://unix:/var/run/docker.sock:') {
|
||||||
|
this.sockPath = pathArg;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* authenticate against a registry
|
||||||
|
* @param userArg
|
||||||
|
* @param passArg
|
||||||
|
*/
|
||||||
|
auth(registryArg: string, userArg: string, passArg: string) {
|
||||||
|
let done = plugins.smartpromise.defer();
|
||||||
|
this.request('POST', '');
|
||||||
|
return done.promise;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
async getContainers() {
|
||||||
|
const containerArray = await DockerContainer.getContainers(this);
|
||||||
|
return containerArray;
|
||||||
|
};
|
||||||
|
|
||||||
|
async getEventObservable(): Promise<plugins.rxjs.Observable<any>> {
|
||||||
|
const response = await this.requestStreaming('GET', '/events');
|
||||||
|
return plugins.rxjs.Observable.create(observer => {
|
||||||
|
response.on('data', data => {
|
||||||
|
observer.next(data.toString());
|
||||||
|
});
|
||||||
|
return () => {
|
||||||
|
response.emit('end');
|
||||||
|
};
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* fire a request
|
||||||
|
*/
|
||||||
|
async request(methodArg: string, routeArg: string, dataArg = {}) {
|
||||||
|
const requestUrl = `${this.sockPath}${routeArg}`;
|
||||||
|
const response = await plugins.smartrequest.request(requestUrl, {
|
||||||
|
method: methodArg,
|
||||||
|
headers: {
|
||||||
|
'Content-Type': 'application/json',
|
||||||
|
Host: 'docker.sock'
|
||||||
|
},
|
||||||
|
requestBody: dataArg
|
||||||
|
});
|
||||||
|
return response;
|
||||||
|
}
|
||||||
|
|
||||||
|
async requestStreaming(methodArg: string, routeArg: string, dataArg = {}) {
|
||||||
|
const requestUrl = `${this.sockPath}${routeArg}`;
|
||||||
|
const response = await plugins.smartrequest.request(
|
||||||
|
requestUrl, {
|
||||||
|
method: methodArg,
|
||||||
|
headers: {
|
||||||
|
// 'Content-Type': 'application/json',
|
||||||
|
Host: 'docker.sock'
|
||||||
|
},
|
||||||
|
requestBody: null
|
||||||
|
},
|
||||||
|
true
|
||||||
|
);
|
||||||
|
console.log(response.statusCode);
|
||||||
|
console.log(response.body);
|
||||||
|
return response;
|
||||||
|
}
|
||||||
|
}
|
14
ts/docker.classes.image.ts
Normal file
14
ts/docker.classes.image.ts
Normal file
@ -0,0 +1,14 @@
|
|||||||
|
import * as plugins from './dockersock.plugins';
|
||||||
|
import { DockerHost } from './docker.classes.host';
|
||||||
|
|
||||||
|
export class DockerImage {
|
||||||
|
/**
|
||||||
|
* the tags for an image
|
||||||
|
*/
|
||||||
|
tags: string[] = [];
|
||||||
|
|
||||||
|
static async createFromRegsitry(dockerHostArg: DockerHost): Promise<DockerImage> {
|
||||||
|
const resultingImage = new DockerImage();
|
||||||
|
return resultingImage;
|
||||||
|
}
|
||||||
|
}
|
0
ts/docker.classes.network.ts
Normal file
0
ts/docker.classes.network.ts
Normal file
0
ts/docker.classes.service.ts
Normal file
0
ts/docker.classes.service.ts
Normal file
@ -1,202 +0,0 @@
|
|||||||
import "typings-global"
|
|
||||||
import * as plugins from "./dockersock.plugins";
|
|
||||||
import {Observable} from "rxjs";
|
|
||||||
|
|
||||||
export class Dockersock {
|
|
||||||
sockPath:string;
|
|
||||||
constructor(pathArg:string = "http://unix:/var/run/docker.sock:"){
|
|
||||||
this.sockPath = pathArg;
|
|
||||||
}
|
|
||||||
|
|
||||||
// methods
|
|
||||||
auth(userArg:string,passArg:string){
|
|
||||||
let done = plugins.q.defer();
|
|
||||||
this.request("POST","");
|
|
||||||
return done.promise;
|
|
||||||
}
|
|
||||||
listContainers() {
|
|
||||||
let done = plugins.q.defer();
|
|
||||||
this.request("GET","/containers")
|
|
||||||
.then(done.resolve);
|
|
||||||
return done.promise;
|
|
||||||
};
|
|
||||||
listContainersDetailed() {
|
|
||||||
let done = plugins.q.defer();
|
|
||||||
let detailedDataObject = [];
|
|
||||||
this.listContainers()
|
|
||||||
.then((dataArg) => {
|
|
||||||
let recursiveCounter = 0;
|
|
||||||
let makeDetailed = () => {
|
|
||||||
if(typeof dataArg[recursiveCounter] != "undefined"){
|
|
||||||
this.request("GET","/containers/" + dataArg[recursiveCounter].Id)
|
|
||||||
.then((dataArg2) => {
|
|
||||||
detailedDataObject.push(dataArg2);
|
|
||||||
recursiveCounter++;
|
|
||||||
// recursive call
|
|
||||||
makeDetailed();
|
|
||||||
});
|
|
||||||
} else {
|
|
||||||
done.resolve(detailedDataObject);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
makeDetailed();
|
|
||||||
});
|
|
||||||
return done.promise;
|
|
||||||
};
|
|
||||||
listContainersRunning() {
|
|
||||||
let done = plugins.q.defer();
|
|
||||||
return done.promise;
|
|
||||||
}
|
|
||||||
listContainersStopped() {
|
|
||||||
let done = plugins.q.defer();
|
|
||||||
return done.promise;
|
|
||||||
}
|
|
||||||
listImages() {
|
|
||||||
return this.request("GET","/images","?all=true");
|
|
||||||
}
|
|
||||||
listImagesDangling(){
|
|
||||||
return this.request("GET","/images","?dangling=true");
|
|
||||||
}
|
|
||||||
pullImage(imageLabelArg:string){
|
|
||||||
let imageLabel = encodeURI(imageLabelArg);
|
|
||||||
return this.requestStream("POST","/images/create?fromImage=" + imageLabel);
|
|
||||||
};
|
|
||||||
createContainer(optionsArg,pullFirstArg:boolean = true){
|
|
||||||
let done = plugins.q.defer();
|
|
||||||
let create = () => {
|
|
||||||
return this.request("POST","/containers/create","",optionsArg);
|
|
||||||
}
|
|
||||||
if(pullFirstArg){
|
|
||||||
this.pullImage(optionsArg.Image)
|
|
||||||
.then(create)
|
|
||||||
.then(done.resolve);
|
|
||||||
} else {
|
|
||||||
create()
|
|
||||||
.then(done.resolve)
|
|
||||||
}
|
|
||||||
return done.promise;
|
|
||||||
};
|
|
||||||
getContainerId(){
|
|
||||||
|
|
||||||
};
|
|
||||||
startContainer(containerNameArg){
|
|
||||||
return this.request("POST","/containers/"+ containerNameArg +"/start");
|
|
||||||
};
|
|
||||||
stopContainer(containerNameArg){
|
|
||||||
return this.request("POST","/containers/"+ containerNameArg +"/stop");
|
|
||||||
};
|
|
||||||
removeContainer(containerNameArg){
|
|
||||||
return this.request("DELETE","/containers/" + containerNameArg + "?v=1");
|
|
||||||
};
|
|
||||||
clean() {
|
|
||||||
let done = plugins.q.defer();
|
|
||||||
return done.promise;
|
|
||||||
};
|
|
||||||
callOnChange(cb:Function){
|
|
||||||
let cbPromise;
|
|
||||||
let changeBuffered:boolean = false; // when cb is running then buffer any consequent change
|
|
||||||
let requestStream = plugins.request.get(this.sockPath + "/events");
|
|
||||||
requestStream.on("response",(response) => {
|
|
||||||
if(response.statusCode == 200){
|
|
||||||
plugins.beautylog.ok("request returned status 200, so we are good!");
|
|
||||||
} else {
|
|
||||||
plugins.beautylog.error("request returned error: " + response.statusCode);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
requestStream.on("data",(data:Buffer) => {
|
|
||||||
let status = JSON.parse(data.toString()).status;
|
|
||||||
plugins.beautylog.logReduced(status);
|
|
||||||
if(typeof cbPromise == "undefined" || cbPromise.state == "pending"){
|
|
||||||
cbPromise = cb();
|
|
||||||
} else if (changeBuffered) {
|
|
||||||
changeBuffered = true;
|
|
||||||
cbPromise.then(() => {
|
|
||||||
changeBuffered = false;
|
|
||||||
cbPromise = cb();
|
|
||||||
});
|
|
||||||
}
|
|
||||||
});
|
|
||||||
requestStream.on("end",()=> {
|
|
||||||
|
|
||||||
});
|
|
||||||
};
|
|
||||||
getChangeObservable(){
|
|
||||||
let requestStream = plugins.request.get(this.sockPath + "/events");
|
|
||||||
requestStream.on("response",(response) => {
|
|
||||||
if(response.statusCode == 200){
|
|
||||||
plugins.beautylog.ok("request returned status 200, so we are good!");
|
|
||||||
} else {
|
|
||||||
plugins.beautylog.error("request returned error: " + response.statusCode);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
let changeObservable = Observable.fromEvent(requestStream,"data");
|
|
||||||
requestStream.on("end",()=> {
|
|
||||||
|
|
||||||
});
|
|
||||||
return changeObservable;
|
|
||||||
}
|
|
||||||
request(methodArg:string,routeArg:string,queryArg:string = "", dataArg = {}){
|
|
||||||
let done = plugins.q.defer();
|
|
||||||
let jsonArg:string = JSON.stringify(dataArg);
|
|
||||||
let suffix:string = "";
|
|
||||||
if(methodArg == "GET") suffix = "/json";
|
|
||||||
let options = {
|
|
||||||
method:methodArg,
|
|
||||||
url:this.sockPath + routeArg + suffix + queryArg,
|
|
||||||
headers:{
|
|
||||||
"Content-Type":"application/json",
|
|
||||||
"Host":"docker.sock"
|
|
||||||
},
|
|
||||||
body:jsonArg
|
|
||||||
};
|
|
||||||
//console.log(options);
|
|
||||||
plugins.request(options,(err, res, body) => {
|
|
||||||
if (!err && res.statusCode == 200) {
|
|
||||||
var responseObj = JSON.parse(body);
|
|
||||||
done.resolve(responseObj);
|
|
||||||
} else {
|
|
||||||
console.log(err);
|
|
||||||
console.log(res);
|
|
||||||
done.reject(err);
|
|
||||||
};
|
|
||||||
});
|
|
||||||
return done.promise;
|
|
||||||
}
|
|
||||||
requestStream(methodArg:string,routeArg:string,queryArg:string = "", dataArg = {}){
|
|
||||||
let done = plugins.q.defer();
|
|
||||||
let jsonArg:string = JSON.stringify(dataArg);
|
|
||||||
let suffix:string = "";
|
|
||||||
let options = {
|
|
||||||
method:methodArg,
|
|
||||||
url:this.sockPath + routeArg + suffix + queryArg,
|
|
||||||
headers:{
|
|
||||||
"Content-Type":"application/json",
|
|
||||||
"Host":"docker.sock"
|
|
||||||
},
|
|
||||||
body:jsonArg
|
|
||||||
};
|
|
||||||
let requestStream = plugins.request(options,(err, res, body) => {
|
|
||||||
if (!err && res.statusCode == 200) {
|
|
||||||
done.resolve();
|
|
||||||
} else {
|
|
||||||
console.log(err);
|
|
||||||
console.log(res);
|
|
||||||
done.reject(err);
|
|
||||||
};
|
|
||||||
});
|
|
||||||
requestStream.on("response",(response) => {
|
|
||||||
if(response.statusCode == 200){
|
|
||||||
plugins.beautylog.ok("request returned status 200, so we are good!");
|
|
||||||
} else {
|
|
||||||
plugins.beautylog.error("request returned error: " + response.statusCode);
|
|
||||||
done.reject(response);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
requestStream.on("data",(data:Buffer) => {
|
|
||||||
let status;
|
|
||||||
status = JSON.parse(data.toString()).status;
|
|
||||||
plugins.beautylog.logReduced(status);
|
|
||||||
});
|
|
||||||
return done.promise;
|
|
||||||
}
|
|
||||||
}
|
|
@ -1,5 +1,19 @@
|
|||||||
import "typings-global";
|
// @pushrocks scope
|
||||||
export import beautylog = require("beautylog");
|
import * as lik from '@pushrocks/lik';
|
||||||
export import q = require("q");
|
import * as smartlog from '@pushrocks/smartlog';
|
||||||
export import request = require("request");
|
import * as smartpromise from '@pushrocks/smartpromise';
|
||||||
export import rxjs = require("rxjs");
|
import * as smartrequest from '@pushrocks/smartrequest';
|
||||||
|
|
||||||
|
export {
|
||||||
|
lik,
|
||||||
|
smartlog,
|
||||||
|
smartpromise,
|
||||||
|
smartrequest
|
||||||
|
};
|
||||||
|
|
||||||
|
// third party
|
||||||
|
import * as rxjs from 'rxjs';
|
||||||
|
|
||||||
|
export {
|
||||||
|
rxjs
|
||||||
|
};
|
||||||
|
@ -1,2 +1 @@
|
|||||||
import "typings-global";
|
export { DockerHost } from './docker.classes.host';
|
||||||
export {Dockersock} from "./dockersock.classes.dockersock";
|
|
||||||
|
2
ts/interfaces/index.ts
Normal file
2
ts/interfaces/index.ts
Normal file
@ -0,0 +1,2 @@
|
|||||||
|
export * from './label';
|
||||||
|
export * from './port';
|
2
ts/interfaces/label.ts
Normal file
2
ts/interfaces/label.ts
Normal file
@ -0,0 +1,2 @@
|
|||||||
|
// tslint:disable-next-line: interface-over-type-literal
|
||||||
|
export type TLabels = {[key: string]: string };
|
6
ts/interfaces/port.ts
Normal file
6
ts/interfaces/port.ts
Normal file
@ -0,0 +1,6 @@
|
|||||||
|
export interface IPort {
|
||||||
|
PrivatePort: 80;
|
||||||
|
Type: 'tcp';
|
||||||
|
}
|
||||||
|
|
||||||
|
export type TPorts = IPort[];
|
17
tslint.json
Normal file
17
tslint.json
Normal file
@ -0,0 +1,17 @@
|
|||||||
|
{
|
||||||
|
"extends": ["tslint:latest", "tslint-config-prettier"],
|
||||||
|
"rules": {
|
||||||
|
"semicolon": [true, "always"],
|
||||||
|
"no-console": false,
|
||||||
|
"ordered-imports": false,
|
||||||
|
"object-literal-sort-keys": false,
|
||||||
|
"member-ordering": {
|
||||||
|
"options":{
|
||||||
|
"order": [
|
||||||
|
"static-method"
|
||||||
|
]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
},
|
||||||
|
"defaultSeverity": "warning"
|
||||||
|
}
|
Reference in New Issue
Block a user