hax

cmd/main.go

@@ -1,8 +1,6 @@
 package main
 
 import (
-	"fmt"
-
 	client "github.com/highstead/catwalk-client"
 	log "github.com/sirupsen/logrus"
 )
@@ -11,9 +9,12 @@ func main() {
 	log.SetLevel(log.DebugLevel)
 	svc := client.NewCatwalkClient()
 
-	result, err := svc.GetModel("sales_rollup_v7")
+	//models := []string{"sales_rollup_v7", "orders_rollup_v7"}
+	//models := []string{"sales_rollup_v7"}
+	models := []string{"marketing_activity_daily_v3"}
+	result, err := svc.GetModels(models)
 	if err == nil {
-		fmt.Println("**Result**\n", result)
+		log.Println("**Result**\n", result)
 		return
 	}
 	log.WithError(err).Errorln("failed to make request")

service.go

@@ -17,7 +17,7 @@ type Service struct {
 }
 
 func NewCatwalkClient() *Service {
-	log.WithField("secretToken", secretToken).Debugln("starting catwalk client")
+	//log.WithField("secretToken", secretToken).Debugln("starting catwalk client")
 	return &Service{secretToken: secretToken, bearerToken: &BearerToken{}}
 }
 
@@ -107,20 +107,29 @@ func (b *BearerToken) Valid() bool {
 type CatwalkTimeseriesPayload struct {
 	Grain string   `json:"grain"`
 	Model []string `json:"model"`
+	Span  string   `json:"span"`
 	Id    int      `json:"id"`
 	Tz    string   `json:"tz"`
+	Start string   `json:"start"`
 }
 
 func NewCatwalkTimeseriesRequest(model []string) (*http.Request, error) {
 	payload := &CatwalkTimeseriesPayload{
-		Grain: "daily",
+		Grain: "aggregate",
 		Model: model,
-		Id:    2085268,
+		Span:  "alltime",
+		//Id:    1035665473,
+		Id:    100949655599,
 		Tz:    time.UTC.String(),
+		Start: "2020-12-20T00:00:00Z",
 	}
-	url := fmt.Sprintf("%s?id=%d&tz=%s&grain=%s", tsEndpoint, payload.Id, payload.Tz, payload.Grain)
+	// start - staging
+	//url := fmt.Sprintf("%s?id=%d&span=%s&tz=%s&grain=%s&start=%s", tsEndpoint, payload.Id, payload.Span, payload.Tz, payload.Grain, payload.Start)
+	url := fmt.Sprintf("%s?id=%d&span=%s&tz=%s&grain=%s", tsEndpoint, payload.Id, payload.Span, payload.Tz, payload.Grain)
+	//url := fmt.Sprintf("%s?id=%d&tz=%s&grain=hourly", tsEndpoint, payload.Id, payload.Tz)
 	for _, v := range model {
 		url = url + "&model=" + v
 	}
+	log.WithField("ReqUri", url).Debugln("created request")
 	return http.NewRequest("GET", url, nil)
 }