Compare commits
5 Commits
Author | SHA1 | Date | |
---|---|---|---|
be659a2dbd | |||
144f963d8a | |||
0c7cd35448 | |||
4e3446cb2f | |||
cec9555908 |
4
dist/dockersock.classes.dockersock.d.ts
vendored
4
dist/dockersock.classes.dockersock.d.ts
vendored
@ -12,7 +12,7 @@ export declare class Dockersock {
|
|||||||
listContainersStopped(): plugins.q.Promise<{}>;
|
listContainersStopped(): plugins.q.Promise<{}>;
|
||||||
listImages(): plugins.q.Promise<{}>;
|
listImages(): plugins.q.Promise<{}>;
|
||||||
listImagesDangling(): plugins.q.Promise<{}>;
|
listImagesDangling(): plugins.q.Promise<{}>;
|
||||||
pullImage(imageLabel: string): plugins.q.Promise<{}>;
|
pullImage(imageLabelArg: string): plugins.q.Promise<{}>;
|
||||||
createContainer(optionsArg: any, pullFirstArg?: boolean): plugins.q.Promise<{}>;
|
createContainer(optionsArg: any, pullFirstArg?: boolean): plugins.q.Promise<{}>;
|
||||||
getContainerId(): void;
|
getContainerId(): void;
|
||||||
startContainer(containerNameArg: any): plugins.q.Promise<{}>;
|
startContainer(containerNameArg: any): plugins.q.Promise<{}>;
|
||||||
@ -22,5 +22,5 @@ export declare class Dockersock {
|
|||||||
callOnChange(cb: Function): void;
|
callOnChange(cb: Function): void;
|
||||||
getChangeObservable(): Observable<{}>;
|
getChangeObservable(): Observable<{}>;
|
||||||
request(methodArg: string, routeArg: string, queryArg?: string, dataArg?: {}): plugins.q.Promise<{}>;
|
request(methodArg: string, routeArg: string, queryArg?: string, dataArg?: {}): plugins.q.Promise<{}>;
|
||||||
requestStream(methodArg: any, routeArg: any, endArg?: boolean): plugins.q.Promise<{}>;
|
requestStream(methodArg: string, routeArg: string, queryArg?: string, dataArg?: {}): plugins.q.Promise<{}>;
|
||||||
}
|
}
|
||||||
|
64
dist/dockersock.classes.dockersock.js
vendored
64
dist/dockersock.classes.dockersock.js
vendored
File diff suppressed because one or more lines are too long
2
dist/dockersock.plugins.d.ts
vendored
2
dist/dockersock.plugins.d.ts
vendored
@ -1,5 +1,5 @@
|
|||||||
import "typings-global";
|
import "typings-global";
|
||||||
export import beautylog = require("beautylog");
|
export import beautylog = require("beautylog");
|
||||||
export import q = require("q");
|
export import q = require("q");
|
||||||
export declare let request: any;
|
export import request = require("request");
|
||||||
export import rxjs = require("rxjs");
|
export import rxjs = require("rxjs");
|
||||||
|
2
dist/dockersock.plugins.js
vendored
2
dist/dockersock.plugins.js
vendored
@ -4,4 +4,4 @@ exports.beautylog = require("beautylog");
|
|||||||
exports.q = require("q");
|
exports.q = require("q");
|
||||||
exports.request = require("request");
|
exports.request = require("request");
|
||||||
exports.rxjs = require("rxjs");
|
exports.rxjs = require("rxjs");
|
||||||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiZG9ja2Vyc29jay5wbHVnaW5zLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vdHMvZG9ja2Vyc29jay5wbHVnaW5zLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7QUFBQSxRQUFPLGdCQUFnQixDQUFDLENBQUE7QUFDVixpQkFBUyxXQUFXLFdBQVcsQ0FBQyxDQUFDO0FBQ2pDLFNBQUMsV0FBVyxHQUFHLENBQUMsQ0FBQztBQUNwQixlQUFPLEdBQUcsT0FBTyxDQUFDLFNBQVMsQ0FBQyxDQUFDO0FBQzFCLFlBQUksV0FBVyxNQUFNLENBQUMsQ0FBQyJ9
|
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiZG9ja2Vyc29jay5wbHVnaW5zLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vdHMvZG9ja2Vyc29jay5wbHVnaW5zLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7QUFBQSxRQUFPLGdCQUFnQixDQUFDLENBQUE7QUFDVixpQkFBUyxXQUFXLFdBQVcsQ0FBQyxDQUFDO0FBQ2pDLFNBQUMsV0FBVyxHQUFHLENBQUMsQ0FBQztBQUNqQixlQUFPLFdBQVcsU0FBUyxDQUFDLENBQUM7QUFDN0IsWUFBSSxXQUFXLE1BQU0sQ0FBQyxDQUFDIn0=
|
2
dist/index.js
vendored
2
dist/index.js
vendored
@ -2,4 +2,4 @@
|
|||||||
require("typings-global");
|
require("typings-global");
|
||||||
var dockersock_classes_dockersock_1 = require("./dockersock.classes.dockersock");
|
var dockersock_classes_dockersock_1 = require("./dockersock.classes.dockersock");
|
||||||
exports.Dockersock = dockersock_classes_dockersock_1.Dockersock;
|
exports.Dockersock = dockersock_classes_dockersock_1.Dockersock;
|
||||||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsUUFBTyxnQkFBZ0IsQ0FBQyxDQUFBO0FBQ3hCLDhDQUF5QixpQ0FBaUMsQ0FBQztBQUFuRCxnRUFBa0QifQ==
|
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsUUFBTyxnQkFBZ0IsQ0FBQyxDQUFBO0FBQ3hCLDhDQUF5QixpQ0FBaUMsQ0FBQztBQUFuRCxnRUFBbUQifQ==
|
6
npmextra.json
Normal file
6
npmextra.json
Normal file
@ -0,0 +1,6 @@
|
|||||||
|
{
|
||||||
|
"npmts":{
|
||||||
|
"mode":"default",
|
||||||
|
"coverageTreshold":10
|
||||||
|
}
|
||||||
|
}
|
@ -1,4 +0,0 @@
|
|||||||
{
|
|
||||||
"mode":"default",
|
|
||||||
"coverageTreshold":10
|
|
||||||
}
|
|
@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "dockersock",
|
"name": "dockersock",
|
||||||
"version": "1.0.13",
|
"version": "1.0.14",
|
||||||
"description": "easy communication with docker from node, TypeScript ready",
|
"description": "easy communication with docker from node, TypeScript ready",
|
||||||
"main": "dist/index.js",
|
"main": "dist/index.js",
|
||||||
"typings": "dist/index.d.ts",
|
"typings": "dist/index.d.ts",
|
||||||
|
@ -26,11 +26,11 @@ describe("dockersock", function () {
|
|||||||
});
|
});
|
||||||
it("should pull an image from imagetag", function (done) {
|
it("should pull an image from imagetag", function (done) {
|
||||||
this.timeout(60000);
|
this.timeout(60000);
|
||||||
testDockersock.pullImage("hosttoday%2Fht-docker-dbase")
|
testDockersock.pullImage("hosttoday/ht-docker-dbase")
|
||||||
.then((dataArg) => {
|
.then((dataArg) => {
|
||||||
done();
|
done();
|
||||||
}, done);
|
}, done);
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGVzdC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbInRlc3QudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLFFBQU8sY0FBYyxDQUFDLENBQUE7QUFDdEIsUUFBTyxRQUFRLENBQUMsQ0FBQTtBQUVoQix3QkFBeUIsZUFFekIsQ0FBQyxDQUZ1QztBQUV4QyxRQUFRLENBQUMsWUFBWSxFQUFDO0lBQ2xCLFFBQVEsQ0FBQyxlQUFlLEVBQUM7UUFDckIsSUFBSSxjQUF5QixDQUFDO1FBQzlCLEVBQUUsQ0FBQyx5Q0FBeUMsRUFBQztZQUN6QyxjQUFjLEdBQUcsSUFBSSxrQkFBVSxFQUFFLENBQUM7WUFDbEMsY0FBYyxDQUFDLE1BQU0sQ0FBQyxFQUFFLENBQUMsVUFBVSxDQUFDLGtCQUFVLENBQUMsQ0FBQztRQUNwRCxDQUFDLENBQUMsQ0FBQztRQUNILEVBQUUsQ0FBQyx3QkFBd0IsRUFBQyxVQUFTLElBQUk7WUFDckMsY0FBYyxDQUFDLGNBQWMsRUFBRTtpQkFDMUIsSUFBSSxDQUFDLENBQUMsT0FBTztnQkFDVixPQUFPLENBQUMsR0FBRyxDQUFDLE9BQU8sQ0FBQyxDQUFDO2dCQUNyQixJQUFJLEVBQUUsQ0FBQztZQUNYLENBQUMsQ0FBQyxDQUFDO1FBQ1gsQ0FBQyxDQUFDLENBQUM7UUFDSCxFQUFFLENBQUMsaUNBQWlDLEVBQUMsVUFBUyxJQUFJO1lBQzlDLElBQUksQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLENBQUM7WUFDbkIsY0FBYyxDQUFDLHNCQUFzQixFQUFFO2lCQUNsQyxJQUFJLENBQUMsQ0FBQyxPQUFPO2dCQUNWLE9BQU8sQ0FBQyxHQUFHLENBQUMsT0FBTyxDQUFDLENBQUM7Z0JBQ3JCLElBQUksRUFBRSxDQUFDO1lBQ1gsQ0FBQyxDQUFDLENBQUM7UUFDWCxDQUFDLENBQUMsQ0FBQztRQUNILEVBQUUsQ0FBQyxvQ0FBb0MsRUFBQyxVQUFTLElBQUk7WUFDakQsSUFBSSxDQUFDLE9BQU8sQ0FBQyxLQUFLLENBQUMsQ0FBQztZQUNwQixjQUFjLENBQUMsU0FBUyxDQUFDLDZCQUE2QixDQUFDO2lCQUNsRCxJQUFJLENBQUMsQ0FBQyxPQUFPO2dCQUNWLElBQUksRUFBRSxDQUFDO1lBQ1gsQ0FBQyxFQUFDLElBQUksQ0FBQyxDQUFDO1FBQ2hCLENBQUMsQ0FBQyxDQUFBO0lBQ04sQ0FBQyxDQUFDLENBQUM7QUFDUCxDQUFDLENBQUMsQ0FBQyJ9
|
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGVzdC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbInRlc3QudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLFFBQU8sY0FBYyxDQUFDLENBQUE7QUFDdEIsUUFBTyxRQUFRLENBQUMsQ0FBQTtBQUVoQix3QkFBeUIsZUFFekIsQ0FBQyxDQUZ1QztBQUV4QyxRQUFRLENBQUMsWUFBWSxFQUFDO0lBQ2xCLFFBQVEsQ0FBQyxlQUFlLEVBQUM7UUFDckIsSUFBSSxjQUF5QixDQUFDO1FBQzlCLEVBQUUsQ0FBQyx5Q0FBeUMsRUFBQztZQUN6QyxjQUFjLEdBQUcsSUFBSSxrQkFBVSxFQUFFLENBQUM7WUFDbEMsY0FBYyxDQUFDLE1BQU0sQ0FBQyxFQUFFLENBQUMsVUFBVSxDQUFDLGtCQUFVLENBQUMsQ0FBQztRQUNwRCxDQUFDLENBQUMsQ0FBQztRQUNILEVBQUUsQ0FBQyx3QkFBd0IsRUFBQyxVQUFTLElBQUk7WUFDckMsY0FBYyxDQUFDLGNBQWMsRUFBRTtpQkFDMUIsSUFBSSxDQUFDLENBQUMsT0FBTztnQkFDVixPQUFPLENBQUMsR0FBRyxDQUFDLE9BQU8sQ0FBQyxDQUFDO2dCQUNyQixJQUFJLEVBQUUsQ0FBQztZQUNYLENBQUMsQ0FBQyxDQUFDO1FBQ1gsQ0FBQyxDQUFDLENBQUM7UUFDSCxFQUFFLENBQUMsaUNBQWlDLEVBQUMsVUFBUyxJQUFJO1lBQzlDLElBQUksQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLENBQUM7WUFDbkIsY0FBYyxDQUFDLHNCQUFzQixFQUFFO2lCQUNsQyxJQUFJLENBQUMsQ0FBQyxPQUFPO2dCQUNWLE9BQU8sQ0FBQyxHQUFHLENBQUMsT0FBTyxDQUFDLENBQUM7Z0JBQ3JCLElBQUksRUFBRSxDQUFDO1lBQ1gsQ0FBQyxDQUFDLENBQUM7UUFDWCxDQUFDLENBQUMsQ0FBQztRQUNILEVBQUUsQ0FBQyxvQ0FBb0MsRUFBQyxVQUFTLElBQUk7WUFDakQsSUFBSSxDQUFDLE9BQU8sQ0FBQyxLQUFLLENBQUMsQ0FBQztZQUNwQixjQUFjLENBQUMsU0FBUyxDQUFDLDJCQUEyQixDQUFDO2lCQUNoRCxJQUFJLENBQUMsQ0FBQyxPQUFPO2dCQUNWLElBQUksRUFBRSxDQUFDO1lBQ1gsQ0FBQyxFQUFDLElBQUksQ0FBQyxDQUFDO1FBQ2hCLENBQUMsQ0FBQyxDQUFBO0lBQ04sQ0FBQyxDQUFDLENBQUM7QUFDUCxDQUFDLENBQUMsQ0FBQyJ9
|
@ -27,7 +27,7 @@ describe("dockersock",function(){
|
|||||||
});
|
});
|
||||||
it("should pull an image from imagetag",function(done){
|
it("should pull an image from imagetag",function(done){
|
||||||
this.timeout(60000);
|
this.timeout(60000);
|
||||||
testDockersock.pullImage("hosttoday%2Fht-docker-dbase")
|
testDockersock.pullImage("hosttoday/ht-docker-dbase")
|
||||||
.then((dataArg)=>{
|
.then((dataArg)=>{
|
||||||
done();
|
done();
|
||||||
},done);
|
},done);
|
||||||
|
@ -57,7 +57,8 @@ export class Dockersock {
|
|||||||
listImagesDangling(){
|
listImagesDangling(){
|
||||||
return this.request("GET","/images","?dangling=true");
|
return this.request("GET","/images","?dangling=true");
|
||||||
}
|
}
|
||||||
pullImage(imageLabel:string){
|
pullImage(imageLabelArg:string){
|
||||||
|
let imageLabel = encodeURI(imageLabelArg);
|
||||||
return this.requestStream("POST","/images/create?fromImage=" + imageLabel);
|
return this.requestStream("POST","/images/create?fromImage=" + imageLabel);
|
||||||
};
|
};
|
||||||
createContainer(optionsArg,pullFirstArg:boolean = true){
|
createContainer(optionsArg,pullFirstArg:boolean = true){
|
||||||
@ -143,10 +144,12 @@ export class Dockersock {
|
|||||||
method:methodArg,
|
method:methodArg,
|
||||||
url:this.sockPath + routeArg + suffix + queryArg,
|
url:this.sockPath + routeArg + suffix + queryArg,
|
||||||
headers:{
|
headers:{
|
||||||
"Content-Type":"application/json"
|
"Content-Type":"application/json",
|
||||||
|
"Host":"docker.sock"
|
||||||
},
|
},
|
||||||
body:jsonArg
|
body:jsonArg
|
||||||
};
|
};
|
||||||
|
//console.log(options);
|
||||||
plugins.request(options,(err, res, body) => {
|
plugins.request(options,(err, res, body) => {
|
||||||
if (!err && res.statusCode == 200) {
|
if (!err && res.statusCode == 200) {
|
||||||
var responseObj = JSON.parse(body);
|
var responseObj = JSON.parse(body);
|
||||||
@ -159,26 +162,41 @@ export class Dockersock {
|
|||||||
});
|
});
|
||||||
return done.promise;
|
return done.promise;
|
||||||
}
|
}
|
||||||
requestStream(methodArg,routeArg,endArg:boolean = true){
|
requestStream(methodArg:string,routeArg:string,queryArg:string = "", dataArg = {}){
|
||||||
let done = plugins.q.defer();
|
let done = plugins.q.defer();
|
||||||
if(methodArg == "POST"){
|
let jsonArg:string = JSON.stringify(dataArg);
|
||||||
let requestStream = plugins.request.post(this.sockPath + routeArg);
|
let suffix:string = "";
|
||||||
requestStream.on("response",(response) => {
|
let options = {
|
||||||
if(response.statusCode == 200){
|
method:methodArg,
|
||||||
plugins.beautylog.ok("request returned status 200, so we are good!");
|
url:this.sockPath + routeArg + suffix + queryArg,
|
||||||
} else {
|
headers:{
|
||||||
plugins.beautylog.error("request returned error: " + response.statusCode);
|
"Content-Type":"application/json",
|
||||||
done.reject(response);
|
"Host":"docker.sock"
|
||||||
}
|
},
|
||||||
});
|
body:jsonArg
|
||||||
requestStream.on("data",(data:Buffer) => {
|
};
|
||||||
let status = JSON.parse(data.toString()).status;
|
let requestStream = plugins.request(options,(err, res, body) => {
|
||||||
plugins.beautylog.logReduced(status);
|
if (!err && res.statusCode == 200) {
|
||||||
});
|
|
||||||
requestStream.on("end",()=> {
|
|
||||||
done.resolve();
|
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;
|
return done.promise;
|
||||||
}
|
}
|
||||||
}
|
}
|
@ -1,5 +1,5 @@
|
|||||||
import "typings-global";
|
import "typings-global";
|
||||||
export import beautylog = require("beautylog");
|
export import beautylog = require("beautylog");
|
||||||
export import q = require("q");
|
export import q = require("q");
|
||||||
export let request = require("request");
|
export import request = require("request");
|
||||||
export import rxjs = require("rxjs");
|
export import rxjs = require("rxjs");
|
@ -1,2 +1,2 @@
|
|||||||
import "typings-global";
|
import "typings-global";
|
||||||
export {Dockersock} from "./dockersock.classes.dockersock"
|
export {Dockersock} from "./dockersock.classes.dockersock";
|
||||||
|
Reference in New Issue
Block a user