Compare commits

...

2 Commits

Author SHA1 Message Date
56612f9ac9 1.0.16 2016-07-29 20:41:30 +02:00
2a1fcd8cdb fixed request for change observable 2016-07-29 20:41:27 +02:00
3 changed files with 35 additions and 6 deletions

File diff suppressed because one or more lines are too long

View File

@ -1,6 +1,6 @@
{
"name": "dockersock",
"version": "1.0.15",
"version": "1.0.16",
"description": "easy communication with docker remote api from node, TypeScript ready",
"main": "dist/index.js",
"typings": "dist/index.d.ts",

View File

@ -121,7 +121,21 @@ export class Dockersock {
});
};
getChangeObservable(){
let requestStream = plugins.request.get(this.sockPath + "/events");
let options = {
method:"GET",
url:this.sockPath + "/events",
headers:{
"Content-Type":"application/json",
"Host":"docker.sock"
}
};
let requestStream = plugins.request(options,(err, res, body) => {
if (!err && res.statusCode == 200) {
} else {
console.log(err);
console.log(res);
};
});
requestStream.on("response",(response) => {
if(response.statusCode == 200){
plugins.beautylog.ok("request returned status 200, so we are good!");
@ -130,8 +144,7 @@ export class Dockersock {
}
});
let changeObservable = Observable.fromEvent(requestStream,"data");
requestStream.on("end",()=> {
requestStream.on("end",()=> {
});
return changeObservable;
}