diff --git a/.gx/lastpubver b/.gx/lastpubver index 067d6aa9a0db8c00be120c22ada39a90bc5e18b3..848ddd240e327ed7bf5fc0520595ffa547df73a7 100644 --- a/.gx/lastpubver +++ b/.gx/lastpubver @@ -1 +1 @@ -0.2.7: QmPacwEp6wnpEEsLgEFuVCV2nPJwWPGWkAhvAYMAmUZokn +0.2.8: QmTd4zzRczqDrfGswY49biCg2kofMEJyGUBQjSShk89m4C diff --git a/http/responseemitter.go b/http/responseemitter.go index 9c166bd0ecb735ae3ba42bc6ececdf87a2d6e35c..c703657fe4a03facf54b4fcec53911f4200b3dda 100644 --- a/http/responseemitter.go +++ b/http/responseemitter.go @@ -96,13 +96,16 @@ func (re *responseEmitter) Emit(value interface{}) error { case cmdsutil.Error: re.w.Header().Set(StreamErrHeader, v.Error()) case *cmdsutil.Error: - v.Error() re.w.Header().Set(StreamErrHeader, v.Error()) default: err = re.enc.Encode(value) re.w.(http.Flusher).Flush() } + if err != nil { + log.Error(err) + } + return err } @@ -121,6 +124,7 @@ func (re *responseEmitter) Close() error { func (re *responseEmitter) SetError(v interface{}, errType cmdsutil.ErrorType) { err := re.Emit(&cmdsutil.Error{Message: fmt.Sprint(v), Code: errType}) if err != nil { + log.Debug("http.SetError err=", err) panic(err) } } diff --git a/package.json b/package.json index d26c2ffe68cec52d7839cd2ba0a40049382141b5..6d83b916e1b05a5bc97e61a29a85c41ffba8ab8b 100644 --- a/package.json +++ b/package.json @@ -34,6 +34,6 @@ "language": "go", "license": "MIT", "name": "go-ipfs-cmds", - "version": "0.2.7" + "version": "0.2.8" }