From bb83ccb15feb4854c7bdb4821fbcf90b89f36163 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=C5=81ukasz=20Magiera?= <magik6k@gmail.com>
Date: Mon, 4 Feb 2019 19:44:48 +0100
Subject: [PATCH] response: read trailing error headers

This commit was moved from ipfs/go-ipfs-http-client@83dfd84ba8bf2341478bb98d437ae1f14fe29e18
---
 client/httpapi/response.go | 24 ++++++++++++++++++++----
 1 file changed, 20 insertions(+), 4 deletions(-)

diff --git a/client/httpapi/response.go b/client/httpapi/response.go
index f6e7f3ab7..745c9a2a9 100644
--- a/client/httpapi/response.go
+++ b/client/httpapi/response.go
@@ -2,6 +2,7 @@ package httpapi
 
 import (
 	"encoding/json"
+	"errors"
 	"fmt"
 	"io"
 	"io/ioutil"
@@ -13,6 +14,24 @@ import (
 	files "github.com/ipfs/go-ipfs-files"
 )
 
+type trailerReader struct {
+	resp *http.Response
+}
+
+func (r *trailerReader) Read(b []byte) (int, error) {
+	n, err := r.resp.Body.Read(b)
+	if err != nil {
+		if e := r.resp.Trailer.Get("X-Stream-Error"); e != "" {
+			err = errors.New(e)
+		}
+	}
+	return n, err
+}
+
+func (r *trailerReader) Close() error {
+	return r.resp.Body.Close()
+}
+
 type Response struct {
 	Output io.ReadCloser
 	Error  *Error
@@ -56,9 +75,6 @@ type Error struct {
 
 func (e *Error) Error() string {
 	var out string
-	if e.Command != "" {
-		out = e.Command + ": "
-	}
 	if e.Code != 0 {
 		out = fmt.Sprintf("%s%d: ", out, e.Code)
 	}
@@ -93,7 +109,7 @@ func (r *Request) Send(c *http.Client) (*Response, error) {
 
 	nresp := new(Response)
 
-	nresp.Output = resp.Body
+	nresp.Output = &trailerReader{resp}
 	if resp.StatusCode >= http.StatusBadRequest {
 		e := &Error{
 			Command: r.Command,