This commit is contained in:
2017-03-26 13:02:20 +02:00
parent 14b2105a49
commit 526bb5bbd0
12 changed files with 2001 additions and 86 deletions

View File

@ -2,9 +2,12 @@ import "typings-global"
import * as plugins from "./dockersock.plugins";
import { Observable } from "rxjs";
// interfaces
import { Objectmap } from 'lik'
export class Dockersock {
sockPath: string;
requestObjectmap: plugins.lik.Objectmap = new plugins.lik.Objectmap();
requestObjectmap = new plugins.lik.Objectmap<plugins.request.Request>();
constructor(pathArg: string = "http://unix:/var/run/docker.sock:") {
this.sockPath = pathArg;
}
@ -138,7 +141,7 @@ export class Dockersock {
};
});
requestStream.on("response", (response) => {
this.requestObjectmap.add(response);
this.requestObjectmap.add(requestStream);
if (response.statusCode == 200) {
plugins.beautylog.ok("request returned status 200, so we are good!");
} else {
@ -201,7 +204,7 @@ export class Dockersock {
};
});
requestStream.on("response", (response) => {
this.requestObjectmap.add(response);
this.requestObjectmap.add(requestStream);
if (response.statusCode == 200) {
plugins.beautylog.ok("request returned status 200, so we are good!");
} else {