Eliminação do lib_test e atualização da key
parent
59f6b2578a
commit
17d68433dc
|
@ -5,6 +5,7 @@ import (
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"go.digitalcircle.com.br/open/httpcli"
|
"go.digitalcircle.com.br/open/httpcli"
|
||||||
|
"go.digitalcircle.com.br/open/replaycli-go/api/replay"
|
||||||
)
|
)
|
||||||
|
|
||||||
type DataApiOp string
|
type DataApiOp string
|
||||||
|
@ -40,8 +41,13 @@ func (c *Cli) Do(request *DataAPIRequest) (response *DataAPIResponse, err error)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewCli(apikey string) *Cli {
|
func NewCli() *Cli {
|
||||||
ret := &Cli{Httpcli: httpcli.NewCli()}
|
ret := &Cli{Httpcli: httpcli.NewCli()}
|
||||||
|
rcon := replay.NewCli()
|
||||||
|
apikey, err := rcon.ConfigGet("API_KEY")
|
||||||
|
if err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
ret.Httpcli.AddHeader("X-API-KEY", apikey)
|
ret.Httpcli.AddHeader("X-API-KEY", apikey)
|
||||||
ret.Httpcli.SetBasePath("https://dataapi.digitalcircle.com.br")
|
ret.Httpcli.SetBasePath("https://dataapi.digitalcircle.com.br")
|
||||||
return ret
|
return ret
|
||||||
|
@ -49,7 +55,7 @@ func NewCli(apikey string) *Cli {
|
||||||
|
|
||||||
func RegistrarExec(table string, check bool) {
|
func RegistrarExec(table string, check bool) {
|
||||||
//Para robôs, age como contador e registra cada repetição no mês
|
//Para robôs, age como contador e registra cada repetição no mês
|
||||||
c := NewCli("RnJpIDA1IE5vdiAyMDIxIDExOjE1OjIyIEFNIFVUQwo")
|
c := NewCli()
|
||||||
var registros int
|
var registros int
|
||||||
var erro int
|
var erro int
|
||||||
current := time.Now().Format("2006-01")
|
current := time.Now().Format("2006-01")
|
||||||
|
|
|
@ -1,145 +0,0 @@
|
||||||
package dataapi_test
|
|
||||||
|
|
||||||
import (
|
|
||||||
"log"
|
|
||||||
"strconv"
|
|
||||||
"testing"
|
|
||||||
"time"
|
|
||||||
|
|
||||||
"go.digitalcircle.com.br/open/replaycli-go/api/dataapi"
|
|
||||||
)
|
|
||||||
|
|
||||||
func TestAPIRetrieve(t *testing.T) {
|
|
||||||
c := dataapi.NewCli("RnJpIDA1IE5vdiAyMDIxIDExOjE1OjIyIEFNIFVUQwo")
|
|
||||||
res, err := c.Do(&dataapi.DataAPIRequest{
|
|
||||||
Col: "teste3",
|
|
||||||
Op: dataapi.RETRIEVE,
|
|
||||||
})
|
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err.Error())
|
|
||||||
}
|
|
||||||
|
|
||||||
log.Printf("%#v", res)
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestAPIRetrieveWQuery(t *testing.T) {
|
|
||||||
c := dataapi.NewCli("RnJpIDA1IE5vdiAyMDIxIDExOjE1OjIyIEFNIFVUQwo")
|
|
||||||
res, err := c.Do(&dataapi.DataAPIRequest{
|
|
||||||
Col: "C1",
|
|
||||||
Op: dataapi.RETRIEVE,
|
|
||||||
Q: "@[?ID==`2`]",
|
|
||||||
})
|
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err.Error())
|
|
||||||
}
|
|
||||||
|
|
||||||
log.Printf("%#v", res)
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestAPIUpdate(t *testing.T) {
|
|
||||||
c := dataapi.NewCli("RnJpIDA1IE5vdiAyMDIxIDExOjE1OjIyIEFNIFVUQwo")
|
|
||||||
res, err := c.Do(&dataapi.DataAPIRequest{
|
|
||||||
Col: "C1",
|
|
||||||
Op: dataapi.UPDATE,
|
|
||||||
Id: "2",
|
|
||||||
Data: map[string]interface{}{
|
|
||||||
"F2": "Novo Campo",
|
|
||||||
},
|
|
||||||
})
|
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err.Error())
|
|
||||||
}
|
|
||||||
|
|
||||||
log.Printf("%#v", res)
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestAPIDelete(t *testing.T) {
|
|
||||||
c := dataapi.NewCli("RnJpIDA1IE5vdiAyMDIxIDExOjE1OjIyIEFNIFVUQwo")
|
|
||||||
res, err := c.Do(&dataapi.DataAPIRequest{
|
|
||||||
Col: "C1",
|
|
||||||
Op: dataapi.DELETE,
|
|
||||||
Id: "2",
|
|
||||||
})
|
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err.Error())
|
|
||||||
}
|
|
||||||
|
|
||||||
log.Printf("%#v", res)
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestAPICreate(t *testing.T) {
|
|
||||||
if true {
|
|
||||||
print("a")
|
|
||||||
print("b")
|
|
||||||
}
|
|
||||||
c := dataapi.NewCli("RnJpIDA1IE5vdiAyMDIxIDExOjE1OjIyIEFNIFVUQwo")
|
|
||||||
var registros int
|
|
||||||
var erro int
|
|
||||||
current := time.Now().Format("2006-01")
|
|
||||||
res, err := c.Do(&dataapi.DataAPIRequest{
|
|
||||||
Col: "teste3",
|
|
||||||
Op: dataapi.RETRIEVE,
|
|
||||||
Q: "@[?date=='" + current + "']",
|
|
||||||
})
|
|
||||||
if err != nil {
|
|
||||||
panic(err)
|
|
||||||
}
|
|
||||||
check := false
|
|
||||||
if len(res.Data) > 0 {
|
|
||||||
if check {
|
|
||||||
result := res.Data[0].(map[string]interface{})
|
|
||||||
registros = int(result["exec"].(float64))
|
|
||||||
registros = registros + 1
|
|
||||||
ident := strconv.Itoa(int(result["ID"].(float64)))
|
|
||||||
|
|
||||||
_, err = c.Do(&dataapi.DataAPIRequest{
|
|
||||||
Col: "teste3",
|
|
||||||
Op: dataapi.UPDATE,
|
|
||||||
Id: ident,
|
|
||||||
Data: map[string]interface{}{
|
|
||||||
"exec": registros,
|
|
||||||
},
|
|
||||||
})
|
|
||||||
if err != nil {
|
|
||||||
panic(err)
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
result := res.Data[0].(map[string]interface{})
|
|
||||||
registros = int(result["err"].(float64))
|
|
||||||
registros = registros + 1
|
|
||||||
ident := strconv.Itoa(int(result["ID"].(float64)))
|
|
||||||
|
|
||||||
_, err = c.Do(&dataapi.DataAPIRequest{
|
|
||||||
Col: "teste3",
|
|
||||||
Op: dataapi.UPDATE,
|
|
||||||
Id: ident,
|
|
||||||
Data: map[string]interface{}{
|
|
||||||
"err": registros,
|
|
||||||
},
|
|
||||||
})
|
|
||||||
if err != nil {
|
|
||||||
panic(err)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
if check {
|
|
||||||
registros = 1
|
|
||||||
erro = 0
|
|
||||||
} else {
|
|
||||||
registros = 0
|
|
||||||
erro = 1
|
|
||||||
}
|
|
||||||
_, err = c.Do(&dataapi.DataAPIRequest{
|
|
||||||
Col: "teste3",
|
|
||||||
Op: dataapi.CREATE,
|
|
||||||
Data: map[string]interface{}{
|
|
||||||
"date": current,
|
|
||||||
"exec": registros,
|
|
||||||
"err": erro,
|
|
||||||
},
|
|
||||||
})
|
|
||||||
if err != nil {
|
|
||||||
panic(err)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
Loading…
Reference in New Issue