hub_resource_request.go

package homehub

import (
	"encoding/json"
	"fmt"
	"io/ioutil"
	"net/http"
	"net/http/httputil"
	"net/url"
	"strings"
)

type hubResourceRequest struct {
	authData authData
	URL      string
	prev     request
}

func newHubResourceRequest(authData *authData, URL string, prev request) (req *hubResourceRequest) {
	return &hubResourceRequest{*authData, URL, prev}
}

func (r *hubResourceRequest) send() (re *response, err error) {

	resp, err := r.prev.send()
	if err != nil {
		return nil, err
	}

	filePath := resp.ResponseBody.Reply.ResponseActions[0].ResponseCallbacks[0].Parameters.URI
	if filePath == "" {
		filePath = resp.ResponseBody.Reply.ResponseActions[0].ResponseCallbacks[0].Parameters.Data
	}

	sessionData := newSessionData(&r.authData)
	cj, _ := json.Marshal(sessionData)

	baseURL := strings.Replace(r.URL, "/cgi/json-req", "", 1)
	httpRequest, _ := http.NewRequest("GET", baseURL+"/"+filePath, nil)
	httpRequest.Header.Set("Accept", "application/json, text/plain, */*")
	httpRequest.Header.Set("Accept-Encoding", "gzip, deflate")
	httpRequest.Header.Set("Accept-Language", "en-GB,en-US;q=0.8,en;q=0.6")
	httpRequest.AddCookie(&http.Cookie{Name: "lang", Value: "en"})
	httpRequest.AddCookie(&http.Cookie{Name: "session", Value: url.QueryEscape(string(cj))})

	dump, _ := httputil.DumpRequest(httpRequest, true)
	debug.Println(string(dump))

	httpClient := &http.Client{}
	httpResponse, err := httpClient.Do(httpRequest)
	if err != nil {
		return nil, err
	}

	dump, _ = httputil.DumpResponse(httpResponse, true)
	debug.Println(string(dump))

	if httpResponse.StatusCode >= 400 {
		return nil, fmt.Errorf("Error processing request. Hub returned HTTP response code: %d", httpResponse.StatusCode)
	}

	defer httpResponse.Body.Close()
	response := &response{}
	bodyBytes, err := ioutil.ReadAll(httpResponse.Body)
	if err != nil {
		return nil, err
	}

	response.body = string(bodyBytes[:])

	return response, nil
}