92 lines
2.6 KiB
Go
92 lines
2.6 KiB
Go
package main
|
|
|
|
import "net/http"
|
|
import "io/ioutil"
|
|
import "log"
|
|
import "bytes"
|
|
|
|
import "github.com/tidwall/gjson"
|
|
import pb "git.wit.com/wit/witProtobuf"
|
|
|
|
func fetchGET(tok string, a string) []byte {
|
|
return fetchJSON("GET", tok, a)
|
|
}
|
|
|
|
func fetchPOST(tok string, a string) []byte {
|
|
return fetchJSON("POST", tok, a)
|
|
}
|
|
|
|
func fetchJSON(GETorPOST string, token string, a string) []byte {
|
|
log.Println("GOT HERE: fetchJSON(): ", GETorPOST + ": " + API + a)
|
|
req, err := http.NewRequest(token, API + a, nil)
|
|
if err != nil { log.Fatal("can't make new req") }
|
|
// always set X-Wit-Auth even on token request
|
|
if (token == "") {
|
|
token = "badtoken"
|
|
}
|
|
|
|
req.Header.Set("Access-Control-Allow-Origin", "*")
|
|
req.Header.Set("Access-Control-Allow-Methods", "POST, GET, OPTIONS, PUT, DELETE")
|
|
req.Header.Set("Access-Control-Allow-Headers", "Accept, Content-Type, Content-Length, Accept-Encoding, X-CSRF-Token, Authorization")
|
|
|
|
log.Println("GOT HERE: fetchJSON(): token =", token)
|
|
|
|
req.Header.Set("X-Wit-Auth", token)
|
|
client := &http.Client{}
|
|
resp, err := client.Do(req)
|
|
if err != nil { log.Println("Can't exec the req to list networks: %s", err) }
|
|
body, err := ioutil.ReadAll(resp.Body)
|
|
if err != nil { log.Fatal("can't read resp") }
|
|
log.Println("GOT HERE: fetchJSON() body =", string(body))
|
|
return body
|
|
}
|
|
|
|
func updateToken(ge *pb.Event) bool {
|
|
if ge == nil {
|
|
log.Println("updateToken() has ge = nil")
|
|
ge.Comment = "updateToken() has ge = nil"
|
|
return false
|
|
}
|
|
if ge.Account == nil {
|
|
log.Println("updateToken() has ge.Account = nil")
|
|
ge.Comment = "updateToken() has ge.Account = nil"
|
|
return false
|
|
}
|
|
|
|
url := ge.Account.URL + "/auth/login" + "?email=" + ge.Account.Email + "&password=" + ge.Account.Password
|
|
log.Println("updateToken() URL =", url)
|
|
|
|
var jsonStr = []byte(`{}`)
|
|
req, err := http.NewRequest("POST", url, bytes.NewBuffer(jsonStr))
|
|
req.Header.Set("Content-Type", "application/json")
|
|
req.Header.Set("X-Wit-Auth", "tokenrequest")
|
|
|
|
client := &http.Client{}
|
|
resp, err := client.Do(req)
|
|
if err != nil {
|
|
log.Println(err)
|
|
ge.Comment = err.Error()
|
|
return false
|
|
}
|
|
defer resp.Body.Close()
|
|
|
|
body, _ := ioutil.ReadAll(resp.Body)
|
|
log.Println("updateToken() response Body:", string(body))
|
|
log.Println("updateToken() response Status:", resp.Status)
|
|
log.Println("updateToken() response Headers:", resp.Header)
|
|
|
|
json := string(body)
|
|
jwt := gjson.Get(json, "jwt")
|
|
if (jwt.String() == "") {
|
|
log.Println("updateToken() GOT TOKEN == nil")
|
|
ge.Comment = string(body)
|
|
return false
|
|
}
|
|
if (jwt.String() != ge.Account.Token) {
|
|
log.Println("updateToken() GOT NEW TOKEN", jwt)
|
|
ge.Account.Token = jwt.String()
|
|
}
|
|
log.Println("updateToken() END")
|
|
return true
|
|
}
|