Compare commits
70 Commits
Author | SHA1 | Date |
---|---|---|
Pedro de Oliveira Guedes | 07c484d31d | |
Pedro de Oliveira Guedes | cdf0c422a3 | |
Paulo Simão | 18801a7b94 | |
Paulo Simão | 03930d5821 | |
Paulo Simão | 60128fb729 | |
Leonardo Domingues | c032f74806 | |
Paulo Simão | 98605a3f9b | |
Leonardo Domingues | fa69db55c8 | |
Pedro de Oliveira Guedes | 62ad6dcb51 | |
Leonardo Domingues | 0dff7d0d6a | |
Leonardo Domingues | dea0595735 | |
Leonardo Domingues | eb9f833027 | |
Pedro de Oliveira Guedes | 13626dcde9 | |
Pedro de Oliveira Guedes | d5c986df8e | |
Leonardo Domingues | 58fbb932aa | |
Leonardo Domingues | c9f9a37bc3 | |
Pedro de Oliveira Guedes | 216d2a0851 | |
Leonardo Domingues | 18173ed486 | |
Leonardo Domingues | 7d1b743b27 | |
Pedro de Oliveira Guedes | adeb3ae60d | |
Pedro de Oliveira Guedes | cc26a118a4 | |
Leonardo Domingues | 2e48c5b2a6 | |
Leonardo Domingues | f951956db5 | |
Pedro de Oliveira Guedes | 0b006b8243 | |
Pedro de Oliveira Guedes | 2257f3f349 | |
Leonardo Domingues | b727ad8d39 | |
Leonardo Domingues | f5f555936b | |
Leonardo Domingues | bd3bcefcc2 | |
Pedro de Oliveira Guedes | 05f2b34703 | |
Pedro de Oliveira Guedes | f6853bc03c | |
Leonardo Domingues | f54514a87a | |
Leonardo Domingues | b8e5810103 | |
Pedro de Oliveira Guedes | d84ad7763c | |
Leonardo Domingues | 59e4b137c5 | |
Leonardo Domingues | 7771f50e1b | |
Leonardo Domingues | 126ef1e289 | |
Leonardo Domingues | 6bc18cedef | |
Leonardo Domingues | 048c8e0b4e | |
Leonardo Domingues | 64d94b13f7 | |
Leonardo Domingues | 69d0bdf3e8 | |
Leonardo Domingues | ade994dac8 | |
Leonardo Domingues | 6c1c483496 | |
Leonardo Domingues | c03689b9fc | |
Leonardo Domingues | 6c981f4196 | |
Leonardo Domingues | 393154a0ac | |
Leonardo Domingues | 4cfbe8f072 | |
Leonardo Domingues | 9877e1819c | |
Leonardo Domingues | 0363cfc1bc | |
Pe-Guedss | 992fe90efb | |
Pe-Guedss | ed392fd245 | |
Leonardo Domingues | 44f39c7c16 | |
Leonardo Domingues | e0f1a0ddd4 | |
Leonardo Domingues | ee65505e8f | |
Leonardo Domingues | f3f5e80160 | |
Paulo Simão | 571810c476 | |
Paulo Simão | befca816d5 | |
Paulo Simão | bca0854a85 | |
Paulo Simão | d80a2568ac | |
Paulo Simão | aee712a88a | |
Leonardo Domingues | 17d68433dc | |
Leonardo Domingues | 59f6b2578a | |
Leonardo Domingues | 3504facc2e | |
Paulo Simão | ccae321dc9 | |
Paulo Simão | 990ac72c52 | |
Leonardo Domingues | eaaa1a6224 | |
Leonardo Domingues | 0b6a1179a1 | |
Leonardo Domingues | a8daeabffb | |
Paulo Simão | 2543c4bf9a | |
Leonardo Domingues | f8acbf0c03 | |
Leonardo Domingues | 6ef42d1ccb |
|
@ -17,7 +17,7 @@ type Cli struct {
|
||||||
type Req struct {
|
type Req struct {
|
||||||
Site string `json:"site"`
|
Site string `json:"site"`
|
||||||
Data string `json:"data"`
|
Data string `json:"data"`
|
||||||
Img []byte `json:"img"`
|
Img string `json:"img"`
|
||||||
To int `json:"to"`
|
To int `json:"to"`
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -26,14 +26,26 @@ func (c *Cli) Recaptchav2(site string, data string) (string, error) {
|
||||||
req := &Req{
|
req := &Req{
|
||||||
Site: site,
|
Site: site,
|
||||||
Data: data,
|
Data: data,
|
||||||
Img: nil,
|
Img: "",
|
||||||
To: 300,
|
To: 300,
|
||||||
}
|
}
|
||||||
err := c.HttpCli().JsonPost("/ipc/anticaptcha/recaptchav2", req, &ret)
|
err := c.HttpCli().JsonPost("/ipc/anticaptcha/recaptchav2", req, &ret)
|
||||||
return ret, err
|
return ret, err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *Cli) Image2text(site string, data []byte) (string, error) {
|
func (c *Cli) Hcaptcha(site string, data string) (string, error) {
|
||||||
|
ret := ""
|
||||||
|
req := &Req{
|
||||||
|
Site: site,
|
||||||
|
Data: data,
|
||||||
|
Img: "",
|
||||||
|
To: 300,
|
||||||
|
}
|
||||||
|
err := c.HttpCli().JsonPost("/ipc/anticaptcha/hcaptcha", req, &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) Image2text(site string, data string) (string, error) {
|
||||||
ret := ""
|
ret := ""
|
||||||
req := &Req{
|
req := &Req{
|
||||||
Site: site,
|
Site: site,
|
||||||
|
|
|
@ -0,0 +1,34 @@
|
||||||
|
package apiproxy
|
||||||
|
|
||||||
|
import "go.digitalcircle.com.br/open/replaycli-go/api"
|
||||||
|
|
||||||
|
type APIProxyRequest struct {
|
||||||
|
Name string `json:"name,omitempty"`
|
||||||
|
Method string `json:"method,omitempty"`
|
||||||
|
Url string `json:"url,omitempty"`
|
||||||
|
Header map[string]string `json:"header,omitempty"`
|
||||||
|
Body []byte `json:"body,omitempty"`
|
||||||
|
Readonly bool `json:"readonly"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type APIProxyResponse struct {
|
||||||
|
Status string `json:"status"`
|
||||||
|
StatusCode int `json:"status_code"`
|
||||||
|
Header map[string]string `json:"header,omitempty"`
|
||||||
|
Body []byte `json:"body,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type Cli struct {
|
||||||
|
*api.ApiCli
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) Do(req *APIProxyRequest) (*APIProxyResponse, error) {
|
||||||
|
res := &APIProxyResponse{}
|
||||||
|
err := c.HttpCli().JsonPost("/ipc/apiproxy/do", req, res)
|
||||||
|
return res, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func NewCli() *Cli {
|
||||||
|
ret := &Cli{ApiCli: api.NewApiCli()}
|
||||||
|
return ret
|
||||||
|
}
|
|
@ -0,0 +1,22 @@
|
||||||
|
package apiproxy
|
||||||
|
|
||||||
|
import (
|
||||||
|
"log"
|
||||||
|
"os"
|
||||||
|
"testing"
|
||||||
|
)
|
||||||
|
|
||||||
|
func TestCli_Do(t *testing.T) {
|
||||||
|
os.Setenv("REPLAY_APIKEY", "DONTBOTHER")
|
||||||
|
os.Setenv("REPLAY_ADDR", "https://localhost:8443")
|
||||||
|
c := NewCli()
|
||||||
|
|
||||||
|
res, err := c.Do(&APIProxyRequest{
|
||||||
|
Method: "GET",
|
||||||
|
Url: "https://www.slashdot.org",
|
||||||
|
})
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err.Error())
|
||||||
|
}
|
||||||
|
log.Printf("%#v", res)
|
||||||
|
}
|
|
@ -0,0 +1,25 @@
|
||||||
|
package autohotkey
|
||||||
|
|
||||||
|
import (
|
||||||
|
"go.digitalcircle.com.br/open/replaycli-go/api"
|
||||||
|
)
|
||||||
|
|
||||||
|
type Cli struct {
|
||||||
|
*api.ApiCli
|
||||||
|
}
|
||||||
|
|
||||||
|
func NewCli() *Cli {
|
||||||
|
ret := &Cli{ApiCli: api.NewApiCli()}
|
||||||
|
return ret
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) Test() (ret []byte, err error) {
|
||||||
|
ret, err = c.HttpCli().RawPost("/ipc/ahk/test", nil)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) Do(data string) (ret []byte, err error) {
|
||||||
|
i := []byte(data)
|
||||||
|
ret, err = c.HttpCli().RawPost("/ipc/ahk/do", i)
|
||||||
|
return ret, err
|
||||||
|
}
|
|
@ -0,0 +1,25 @@
|
||||||
|
package autoit
|
||||||
|
|
||||||
|
import (
|
||||||
|
"go.digitalcircle.com.br/open/replaycli-go/api"
|
||||||
|
)
|
||||||
|
|
||||||
|
type Cli struct {
|
||||||
|
*api.ApiCli
|
||||||
|
}
|
||||||
|
|
||||||
|
func NewCli() *Cli {
|
||||||
|
ret := &Cli{ApiCli: api.NewApiCli()}
|
||||||
|
return ret
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) Test() (ret []byte, err error) {
|
||||||
|
ret, err = c.HttpCli().RawPost("/ipc/autoit/test", nil)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) Do(data string) (ret []byte, err error) {
|
||||||
|
i := []byte(data)
|
||||||
|
ret, err = c.HttpCli().RawPost("/ipc/autoit/do", i)
|
||||||
|
return ret, err
|
||||||
|
}
|
|
@ -3,6 +3,7 @@ package chrome
|
||||||
import (
|
import (
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
"go.digitalcircle.com.br/open/replaycli-go/api"
|
"go.digitalcircle.com.br/open/replaycli-go/api"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -10,11 +11,18 @@ type Cli struct {
|
||||||
*api.ApiCli
|
*api.ApiCli
|
||||||
}
|
}
|
||||||
|
|
||||||
//func (c *Cli) HttpCli() *httpcli.Cli {
|
type TabMetadata struct {
|
||||||
// return c.ApiCli.HttpCli()
|
Description string `json:"description"`
|
||||||
//}
|
DevtoolsFrontendUrl string `json:"devtoolsFrontendUrl"`
|
||||||
|
Id string `json:"id"`
|
||||||
|
Title string `json:"title"`
|
||||||
|
Type string `json:"type"`
|
||||||
|
Url string `json:"url"`
|
||||||
|
WebSocketDebuggerUrl string `json:"webSocketDebuggerUrl"`
|
||||||
|
}
|
||||||
|
|
||||||
func (c *Cli) Start(to int) error {
|
func (c *Cli) Start(to int) error {
|
||||||
|
// to -> Time out para a conexão com o Chrome. Dado em segundos.
|
||||||
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/chrome/start?to=%d", to), nil)
|
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/chrome/start?to=%d", to), nil)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
@ -27,39 +35,76 @@ func (c *Cli) Stop() error {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
func (c *Cli) New(url string) (string, error) {
|
func (c *Cli) New(url string) (string, error) {
|
||||||
|
// url -> Site no qual se quer iniciar uma nova aba.
|
||||||
ret := ""
|
ret := ""
|
||||||
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/chrome/new?url=%s", url), &ret)
|
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/chrome/new?url=%s", url), &ret)
|
||||||
return ret, err
|
return ret, err
|
||||||
|
// ret -> ID do Websocket criado para navegação na "url" informada.
|
||||||
}
|
}
|
||||||
func (c *Cli) Close(id string) error {
|
func (c *Cli) Close(id string) error {
|
||||||
|
// id -> ID do websocket ativo. É o primeiro retorno do método "New".
|
||||||
err := c.HttpCli().JsonGet("/ipc/chrome/close/"+id, nil)
|
err := c.HttpCli().JsonGet("/ipc/chrome/close/"+id, nil)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
func (c *Cli) Eval(id string, s string) (map[string]interface{}, error) {
|
func (c *Cli) Eval(id string, s string) (map[string]interface{}, error) {
|
||||||
|
// id -> ID do websocket no qual se quer fazer um comando JavaScript.
|
||||||
|
// s -> Comando JavaScript a ser executado no terminal web do WebSocket informado.
|
||||||
ret := make(map[string]interface{})
|
ret := make(map[string]interface{})
|
||||||
bs, err := c.HttpCli().RawPost("/ipc/chrome/eval/"+id, []byte(s))
|
bs, err := c.HttpCli().RawPost("/ipc/chrome/eval/"+id, []byte(s))
|
||||||
json.Unmarshal(bs, &ret)
|
json.Unmarshal(bs, &ret)
|
||||||
return ret, err
|
return ret, err
|
||||||
|
// ret -> O valor retornado pelo comando JavaScript executado.
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *Cli) Wait(id string, s string, to int) (string, error) {
|
func (c *Cli) Wait(id string, s string, to int) (string, error) {
|
||||||
|
// id -> ID do websocket no qual se quer fazer um comando JavaScript.
|
||||||
|
// s -> Comando JavaScript a ser executado no terminal web do WebSocket informado. Deve ser uma expressão que retorne um valor booleano para, por exemplo, verificar se um elemento já foi carregado.
|
||||||
|
// to -> TimeOut de espera para retorno "true" da expressão JavaScript informada. Informado em segundos.
|
||||||
ret := ""
|
ret := ""
|
||||||
bs, err := c.HttpCli().RawPost(fmt.Sprintf("/ipc/chrome/wait/%s?to=%d", id, to), []byte(s))
|
bs, err := c.HttpCli().RawPost(fmt.Sprintf("/ipc/chrome/wait/%s?to=%d", id, to), []byte(s))
|
||||||
json.Unmarshal(bs, &ret)
|
json.Unmarshal(bs, &ret)
|
||||||
return ret, err
|
return ret, err
|
||||||
}
|
}
|
||||||
|
func (c *Cli) Send(id string, m string, ps map[string]interface{}) (interface{}, error) {
|
||||||
func (c *Cli) Send(id string, m string, ps map[string]interface{}) (string, error) {
|
// id -> ID do Websocket no qual se deseja realizar a alteração.
|
||||||
ret := ""
|
var ret interface{}
|
||||||
in := map[string]interface{}{
|
in := map[string]interface{}{
|
||||||
"method": m,
|
"method": m,
|
||||||
"params": ps,
|
"params": ps,
|
||||||
}
|
}
|
||||||
err := c.HttpCli().JsonPost("/ipc/chrome/eval/"+id, in, &ret)
|
err := c.HttpCli().JsonPost("/ipc/chrome/send/"+id, in, &ret)
|
||||||
return ret, err
|
return ret, err
|
||||||
|
// ret -> Retorno do comando (Referência em: https://chromedevtools.github.io/devtools-protocol/)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) OpenTabs() (ret []map[string]string, err error) {
|
||||||
|
err = c.HttpCli().JsonGet("/ipc/chrome/opentabs", &ret)
|
||||||
|
return ret, err
|
||||||
|
// ret -> Array contendo as abas abertas e metadados sobre as mesmas.
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) FindTabByUrl(url string) (ret string, err error) {
|
||||||
|
// url -> URL ativa em uma das abas abertas.
|
||||||
|
err = c.HttpCli().JsonGet("/ipc/chrome/findtabbyurl/"+url, &ret)
|
||||||
|
return ret, err
|
||||||
|
// ret -> ID do WebSocket contendo a aba encontrada.
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) FindUrlById(id string) (ret string, err error) {
|
||||||
|
// url -> URL ativa em uma das abas abertas.
|
||||||
|
err = c.HttpCli().JsonGet("/ipc/chrome/findurlbyid/"+id, &ret)
|
||||||
|
return ret, err
|
||||||
|
// ret -> Url da aba encontrada.
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) FindTabByTitle(title string) (ret string, err error) {
|
||||||
|
// title -> Título de uma das abas abertas.
|
||||||
|
err = c.HttpCli().JsonGet("/ipc/chrome/findtabbytitle/"+title, &ret)
|
||||||
|
return ret, err
|
||||||
|
// ret -> ID do WebSocket contendo a aba encontrada.
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewCli() *Cli {
|
func NewCli() *Cli {
|
||||||
ret := &Cli{ApiCli: api.NewApiCli()}
|
ret := &Cli{ApiCli: api.NewApiCli()}
|
||||||
return ret
|
return ret
|
||||||
|
// ret -> Nova instância do Chrome para utilização.
|
||||||
}
|
}
|
||||||
|
|
|
@ -1,6 +1,9 @@
|
||||||
package dataapi
|
package dataapi
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"strconv"
|
||||||
|
"time"
|
||||||
|
|
||||||
"go.digitalcircle.com.br/open/httpcli"
|
"go.digitalcircle.com.br/open/httpcli"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -43,3 +46,86 @@ func NewCli(apikey string) *Cli {
|
||||||
ret.Httpcli.SetBasePath("https://dataapi.digitalcircle.com.br")
|
ret.Httpcli.SetBasePath("https://dataapi.digitalcircle.com.br")
|
||||||
return ret
|
return ret
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func RegistrarExec(table, apikey string, check bool, checkC bool) {
|
||||||
|
//Para robôs, age como contador e registra cada repetição no mês
|
||||||
|
c := NewCli(apikey)
|
||||||
|
var registros int
|
||||||
|
var erro int
|
||||||
|
captReg := 0
|
||||||
|
current := time.Now().Format("2006-01")
|
||||||
|
res, err := c.Do(&DataAPIRequest{
|
||||||
|
Col: table,
|
||||||
|
Op: RETRIEVE,
|
||||||
|
Q: "@[?date=='" + current + "']",
|
||||||
|
})
|
||||||
|
if err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
if len(res.Data) > 0 {
|
||||||
|
if check {
|
||||||
|
result := res.Data[0].(map[string]interface{})
|
||||||
|
registros = int(result["exec"].(float64))
|
||||||
|
registros = registros + 1
|
||||||
|
captReg = int(result["capt"].(float64))
|
||||||
|
if checkC {
|
||||||
|
captReg = captReg + 1
|
||||||
|
}
|
||||||
|
ident := strconv.Itoa(int(result["ID"].(float64)))
|
||||||
|
|
||||||
|
_, err = c.Do(&DataAPIRequest{
|
||||||
|
Col: table,
|
||||||
|
Op: UPDATE,
|
||||||
|
Id: ident,
|
||||||
|
Data: map[string]interface{}{
|
||||||
|
"exec": registros,
|
||||||
|
"capt": captReg,
|
||||||
|
},
|
||||||
|
})
|
||||||
|
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(&DataAPIRequest{
|
||||||
|
Col: table,
|
||||||
|
Op: UPDATE,
|
||||||
|
Id: ident,
|
||||||
|
Data: map[string]interface{}{
|
||||||
|
"err": registros,
|
||||||
|
},
|
||||||
|
})
|
||||||
|
if err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
if check {
|
||||||
|
registros = 1
|
||||||
|
erro = 0
|
||||||
|
if checkC {
|
||||||
|
captReg = 1
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
registros = 0
|
||||||
|
erro = 1
|
||||||
|
}
|
||||||
|
_, err = c.Do(&DataAPIRequest{
|
||||||
|
Col: table,
|
||||||
|
Op: CREATE,
|
||||||
|
Data: map[string]interface{}{
|
||||||
|
"date": current,
|
||||||
|
"exec": registros,
|
||||||
|
"err": erro,
|
||||||
|
"capt": captReg,
|
||||||
|
},
|
||||||
|
})
|
||||||
|
if err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
|
@ -1,15 +1,18 @@
|
||||||
package dataapi_test
|
package dataapi_test
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"go.digitalcircle.com.br/open/replaycli-go/api/dataapi"
|
|
||||||
"log"
|
"log"
|
||||||
|
"strconv"
|
||||||
"testing"
|
"testing"
|
||||||
|
"time"
|
||||||
|
|
||||||
|
"go.digitalcircle.com.br/open/replaycli-go/api/dataapi"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestAPIRetrieve(t *testing.T) {
|
func TestAPIRetrieve(t *testing.T) {
|
||||||
c := dataapi.NewCli("RnJpIDA1IE5vdiAyMDIxIDExOjE1OjIyIEFNIFVUQwo")
|
c := dataapi.NewCli()
|
||||||
res, err := c.Do(&dataapi.DataAPIRequest{
|
res, err := c.Do(&dataapi.DataAPIRequest{
|
||||||
Col: "C1",
|
Col: "teste3",
|
||||||
Op: dataapi.RETRIEVE,
|
Op: dataapi.RETRIEVE,
|
||||||
})
|
})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -20,7 +23,7 @@ func TestAPIRetrieve(t *testing.T) {
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestAPIRetrieveWQuery(t *testing.T) {
|
func TestAPIRetrieveWQuery(t *testing.T) {
|
||||||
c := dataapi.NewCli("RnJpIDA1IE5vdiAyMDIxIDExOjE1OjIyIEFNIFVUQwo")
|
c := dataapi.NewCli()
|
||||||
res, err := c.Do(&dataapi.DataAPIRequest{
|
res, err := c.Do(&dataapi.DataAPIRequest{
|
||||||
Col: "C1",
|
Col: "C1",
|
||||||
Op: dataapi.RETRIEVE,
|
Op: dataapi.RETRIEVE,
|
||||||
|
@ -34,7 +37,7 @@ func TestAPIRetrieveWQuery(t *testing.T) {
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestAPIUpdate(t *testing.T) {
|
func TestAPIUpdate(t *testing.T) {
|
||||||
c := dataapi.NewCli("RnJpIDA1IE5vdiAyMDIxIDExOjE1OjIyIEFNIFVUQwo")
|
c := dataapi.NewCli()
|
||||||
res, err := c.Do(&dataapi.DataAPIRequest{
|
res, err := c.Do(&dataapi.DataAPIRequest{
|
||||||
Col: "C1",
|
Col: "C1",
|
||||||
Op: dataapi.UPDATE,
|
Op: dataapi.UPDATE,
|
||||||
|
@ -51,7 +54,7 @@ func TestAPIUpdate(t *testing.T) {
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestAPIDelete(t *testing.T) {
|
func TestAPIDelete(t *testing.T) {
|
||||||
c := dataapi.NewCli("RnJpIDA1IE5vdiAyMDIxIDExOjE1OjIyIEFNIFVUQwo")
|
c := dataapi.NewCli()
|
||||||
res, err := c.Do(&dataapi.DataAPIRequest{
|
res, err := c.Do(&dataapi.DataAPIRequest{
|
||||||
Col: "C1",
|
Col: "C1",
|
||||||
Op: dataapi.DELETE,
|
Op: dataapi.DELETE,
|
||||||
|
@ -65,18 +68,78 @@ func TestAPIDelete(t *testing.T) {
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestAPICreate(t *testing.T) {
|
func TestAPICreate(t *testing.T) {
|
||||||
c := dataapi.NewCli("RnJpIDA1IE5vdiAyMDIxIDExOjE1OjIyIEFNIFVUQwo")
|
if true {
|
||||||
|
print("a")
|
||||||
|
print("b")
|
||||||
|
}
|
||||||
|
c := dataapi.NewCli()
|
||||||
|
var registros int
|
||||||
|
var erro int
|
||||||
|
current := time.Now().Format("2006-01")
|
||||||
res, err := c.Do(&dataapi.DataAPIRequest{
|
res, err := c.Do(&dataapi.DataAPIRequest{
|
||||||
Col: "C1",
|
Col: "teste3",
|
||||||
Op: dataapi.CREATE,
|
Op: dataapi.RETRIEVE,
|
||||||
Data: map[string]interface{}{
|
Q: "@[?date=='" + current + "']",
|
||||||
"MSG": "OI LEO",
|
|
||||||
},
|
|
||||||
})
|
})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatal(err.Error())
|
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)))
|
||||||
|
|
||||||
log.Printf("%#v", res)
|
_, 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)
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -43,7 +43,6 @@ func (c *Cli) Write(fname string, sheet string, cell string, val string, celtype
|
||||||
err := c.HttpCli().JsonPost("/ipc/excel/write", req, &res)
|
err := c.HttpCli().JsonPost("/ipc/excel/write", req, &res)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *Cli) New(fname string, sheet string) (string, error) {
|
func (c *Cli) New(fname string, sheet string) (string, error) {
|
||||||
req := &Req{
|
req := &Req{
|
||||||
File: fname,
|
File: fname,
|
||||||
|
|
|
@ -16,11 +16,15 @@ type Cli struct {
|
||||||
*api.ApiCli
|
*api.ApiCli
|
||||||
}
|
}
|
||||||
|
|
||||||
|
//Log saves log to database after populated
|
||||||
func (c *Cli) Log(l *types.Log) error {
|
func (c *Cli) Log(l *types.Log) error {
|
||||||
l.Alias = c.ReplayEnvAlias()
|
l.Alias = c.ReplayEnvAlias()
|
||||||
l.Dtlogend = time.Now()
|
l.Dtlogend = time.Now()
|
||||||
return c.HttpCli().JsonPost("/api/v1/log/add", l, nil)
|
return c.HttpCli().JsonPost("/api/v1/log/add", l, nil)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
//NewLog creates a new log instance in the client, capable of collecting data in memory for later saving it to the
|
||||||
|
//database by calling Log
|
||||||
func (c *Cli) NewLog() *types.Log {
|
func (c *Cli) NewLog() *types.Log {
|
||||||
ret := &types.Log{}
|
ret := &types.Log{}
|
||||||
ret.Alias = c.ReplayEnvAlias()
|
ret.Alias = c.ReplayEnvAlias()
|
||||||
|
@ -46,6 +50,11 @@ func (c *Cli) ReplayEnvAddr() string {
|
||||||
func (c *Cli) ReplayEnvHomeDir() string {
|
func (c *Cli) ReplayEnvHomeDir() string {
|
||||||
return os.Getenv("REPLAY_HOMEDIR")
|
return os.Getenv("REPLAY_HOMEDIR")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (c *Cli) ReplayPort() string {
|
||||||
|
return os.Getenv("REPLAY_PORT")
|
||||||
|
}
|
||||||
|
|
||||||
func (c *Cli) ReplayEnvRepo() string {
|
func (c *Cli) ReplayEnvRepo() string {
|
||||||
return os.Getenv("REPLAY_REPO")
|
return os.Getenv("REPLAY_REPO")
|
||||||
}
|
}
|
||||||
|
@ -118,15 +127,20 @@ func (c *Cli) QueueGetData(id string) (ret []byte, err error) {
|
||||||
ret, err = c.HttpCli().RawGet("/api/v1/queue/getrequest/" + id)
|
ret, err = c.HttpCli().RawGet("/api/v1/queue/getrequest/" + id)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (c *Cli) QueueGetDataBody(id string) (ret []byte, err error) {
|
||||||
|
ret, err = c.HttpCli().RawGet("/api/v1/queue/getrequestbody/" + id)
|
||||||
|
return
|
||||||
|
}
|
||||||
func (c *Cli) QueueGetMyData() ([]byte, error) {
|
func (c *Cli) QueueGetMyData() ([]byte, error) {
|
||||||
return c.QueueGetData(os.Getenv("REPLAY_QUEUEID"))
|
return c.QueueGetData(os.Getenv("REPLAY_QUEUEID"))
|
||||||
}
|
}
|
||||||
func (c *Cli) QueueGetMyJson(i interface{}) error {
|
func (c *Cli) QueueGetMyJson(i *interface{}) error {
|
||||||
bs, err := c.QueueGetData(os.Getenv("REPLAY_QUEUEID"))
|
bs, err := c.QueueGetData(os.Getenv("REPLAY_QUEUEID"))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
err = json.Unmarshal(bs, i)
|
err = json.Unmarshal(bs, &i)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
func (c *Cli) QueueAbort() error {
|
func (c *Cli) QueueAbort() error {
|
||||||
|
@ -136,6 +150,14 @@ func (c *Cli) QueueEnqueue(id uint) error {
|
||||||
return c.HttpCli().JsonGet(fmt.Sprintf("/api/v1/robots/op/enqueue/%d", id), nil)
|
return c.HttpCli().JsonGet(fmt.Sprintf("/api/v1/robots/op/enqueue/%d", id), nil)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (c *Cli) QueueEnqueueWData(id string, bs []byte) ([]byte, error) {
|
||||||
|
return c.HttpCli().RawPost(fmt.Sprintf("api/v1/queue/add/%s", id), bs)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) QueueEnqueueWDataWait(id string, bs []byte) ([]byte, error) {
|
||||||
|
return c.HttpCli().RawPost(fmt.Sprintf("api/v1/queue/addwait?job=%s", id), bs)
|
||||||
|
}
|
||||||
|
|
||||||
func (c *Cli) ServiceStopAll() error {
|
func (c *Cli) ServiceStopAll() error {
|
||||||
return c.HttpCli().JsonGet("/api/v1/service/op/stopall", nil)
|
return c.HttpCli().JsonGet("/api/v1/service/op/stopall", nil)
|
||||||
}
|
}
|
||||||
|
|
|
@ -10,14 +10,59 @@ type Cli struct {
|
||||||
*api.ApiCli
|
*api.ApiCli
|
||||||
}
|
}
|
||||||
|
|
||||||
//func (c *Cli) HttpCli() *api.Cli {
|
const (
|
||||||
// return c.cli
|
CCHDEVICENAME = 32
|
||||||
//}
|
CCHFORMNAME = 32
|
||||||
|
ENUM_CURRENT_SETTINGS uint32 = 0xFFFFFFFF
|
||||||
|
ENUM_REGISTRY_SETTINGS uint32 = 0xFFFFFFFE
|
||||||
|
DISP_CHANGE_SUCCESSFUL uint32 = 0
|
||||||
|
DISP_CHANGE_RESTART uint32 = 1
|
||||||
|
DISP_CHANGE_FAILED uint32 = 0xFFFFFFFF
|
||||||
|
DISP_CHANGE_BADMODE uint32 = 0xFFFFFFFE
|
||||||
|
)
|
||||||
|
|
||||||
|
type DEVMODE struct {
|
||||||
|
DmDeviceName [CCHDEVICENAME]uint16
|
||||||
|
DmSpecVersion uint16
|
||||||
|
DmDriverVersion uint16
|
||||||
|
DmSize uint16
|
||||||
|
DmDriverExtra uint16
|
||||||
|
DmFields uint32
|
||||||
|
DmOrientation int16
|
||||||
|
DmPaperSize int16
|
||||||
|
DmPaperLength int16
|
||||||
|
DmPaperWidth int16
|
||||||
|
DmScale int16
|
||||||
|
DmCopies int16
|
||||||
|
DmDefaultSource int16
|
||||||
|
DmPrintQuality int16
|
||||||
|
DmColor int16
|
||||||
|
DmDuplex int16
|
||||||
|
DmYResolution int16
|
||||||
|
DmTTOption int16
|
||||||
|
DmCollate int16
|
||||||
|
DmFormName [CCHFORMNAME]uint16
|
||||||
|
DmLogPixels uint16
|
||||||
|
DmBitsPerPel uint32
|
||||||
|
DmPelsWidth uint32
|
||||||
|
DmPelsHeight uint32
|
||||||
|
DmDisplayFlags uint32
|
||||||
|
DmDisplayFrequency uint32
|
||||||
|
DmICMMethod uint32
|
||||||
|
DmICMIntent uint32
|
||||||
|
DmMediaType uint32
|
||||||
|
DmDitherType uint32
|
||||||
|
DmReserved1 uint32
|
||||||
|
DmReserved2 uint32
|
||||||
|
DmPanningWidth uint32
|
||||||
|
DmPanningHeight uint32
|
||||||
|
}
|
||||||
|
|
||||||
|
/***************** Clip Functions *****************/
|
||||||
|
|
||||||
func (c *Cli) ClipRead() (string, error) {
|
func (c *Cli) ClipRead() (string, error) {
|
||||||
ret := ""
|
bs, err := c.HttpCli().RawGet("/ipc/wingui/clip/read")
|
||||||
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/clip/read"), &ret)
|
return string(bs), err
|
||||||
return ret, err
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *Cli) ClipWrite(site string) error {
|
func (c *Cli) ClipWrite(site string) error {
|
||||||
|
@ -25,39 +70,39 @@ func (c *Cli) ClipWrite(site string) error {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/***************** Mouse Functions *****************/
|
||||||
|
|
||||||
func (c *Cli) MouseClick() error {
|
func (c *Cli) MouseClick() error {
|
||||||
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/mouse/click"), nil)
|
err := c.HttpCli().JsonGet("/ipc/wingui/mouse/click", nil)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *Cli) MouseMove(x, y int) error {
|
func (c *Cli) MouseMove(x, y int) error {
|
||||||
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/mouse/move?x=%d&y=%d", x, y), nil)
|
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/mouse/move?x=%d&y=%d", x, y), nil)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *Cli) MouseMoveRelative(x, y int) error {
|
func (c *Cli) MouseMoveRelative(x, y int) error {
|
||||||
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/mouse/moverelative?x=%d&y=%d", x, y), nil)
|
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/mouse/moverelative?x=%d&y=%d", x, y), nil)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *Cli) MouseClickRelative(x, y int) error {
|
func (c *Cli) MouseClickRelative(x, y int) error {
|
||||||
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/mouse/clickatrelative?x=%d&y=%d", x, y), nil)
|
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/mouse/clickatrelative?x=%d&y=%d", x, y), nil)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *Cli) MouseClickAt(x, y int) error {
|
func (c *Cli) MouseClickAt(x, y int) error {
|
||||||
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/mouse/clickat?x=%d&y=%d", x, y), nil)
|
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/mouse/clickat?x=%d&y=%d", x, y), nil)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
func (c *Cli) ScreenClick(f string) error {
|
|
||||||
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/screen/click?f=%s", f), nil)
|
func (c *Cli) MouseDrag(x, y int, btn string) error {
|
||||||
|
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/mouse/drag?x=%d&y=%d&btn=%s", x, y, btn), nil)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
func (c *Cli) ScreenClickCenter(f string) error {
|
|
||||||
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/screen/clickcenter?f=%s", f), nil)
|
/***************** KB Functions *****************/
|
||||||
return err
|
|
||||||
}
|
|
||||||
func (c *Cli) ScreenFind(f string) (ret map[string]interface{}, err error) {
|
|
||||||
ret = make(map[string]interface{})
|
|
||||||
err = c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/screen/find?f=%s", f), &ret)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
func (c *Cli) KBTap(t string) (map[string]interface{}, error) {
|
func (c *Cli) KBTap(t string) (map[string]interface{}, error) {
|
||||||
/*Envia uma tecla ou teclas para serem clicadas no componente com foco onde o robo é executado
|
/*Envia uma tecla ou teclas para serem clicadas no componente com foco onde o robo é executado
|
||||||
|
@ -168,6 +213,147 @@ func (c *Cli) KBType(t string) (map[string]interface{}, error) {
|
||||||
return ret, err
|
return ret, err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (c *Cli) KBToggle(str string) error {
|
||||||
|
err := c.HttpCli().JsonGet("/ipc/wingui/kb/toggle?str="+str, nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
/***************** Display Functions *****************/
|
||||||
|
|
||||||
|
func (c *Cli) DisplayRes() (*DEVMODE, error) {
|
||||||
|
ret := &DEVMODE{}
|
||||||
|
err := c.HttpCli().JsonGet("/ipc/wingui/display/res", ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) DisplaySetRes(d *DEVMODE) error {
|
||||||
|
err := c.HttpCli().JsonPost("/ipc/wingui/display/setres", d, nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
/***************** Draw Functions *****************/
|
||||||
|
|
||||||
|
func (c *Cli) DrawCLear() error {
|
||||||
|
err := c.HttpCli().JsonGet("/ipc/draw/clear", nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) DrawBox(x, y, w, h, t int) error {
|
||||||
|
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/draw/addbox?x=%d&y=%d&w=%d&h=%d&t=%d", x, y, w, h, t), nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) DrawRect(x, y, w, h int) error {
|
||||||
|
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/draw/addrect?x=%d&y=%d&w=%d&h=%d", x, y, w, h), nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) DrawAddText(t string, x, y int) error {
|
||||||
|
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/draw/addtext?t=%s&x=%d&y=%d", t, x, y), nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
/***************** Notify Functions *****************/
|
||||||
|
|
||||||
|
func (c *Cli) NotifyAlert(msg, title string) error {
|
||||||
|
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/notify/alert?msg=%s&title=%s", msg, title), nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) NotifyBeep(msg, title string) error {
|
||||||
|
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/notify/notify?msg=%s&title=%s", msg, title), nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
/***************** Window Functions *****************/
|
||||||
|
|
||||||
|
func (c *Cli) WindowList(s string) (ret []map[string]interface{}, err error) {
|
||||||
|
err = c.HttpCli().JsonGet("/ipc/wingui/window/list?s="+s, &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) WindowHwnd(s string) (ret []int, err error) {
|
||||||
|
err = c.HttpCli().JsonGet("/ipc/wingui/window/hwnd?s="+s, &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) WindowActivate(Hwnd string) error {
|
||||||
|
err := c.HttpCli().JsonGet("/ipc/wingui/window/activate?Hwnd="+Hwnd, nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) WindowClose(Hwnd string) error {
|
||||||
|
err := c.HttpCli().JsonGet("/ipc/wingui/window/close?Hwnd="+Hwnd, nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) WindowMax(Hwnd string) error {
|
||||||
|
err := c.HttpCli().JsonGet("/ipc/wingui/window/max?Hwnd="+Hwnd, nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) WindowMin(Hwnd string) error {
|
||||||
|
err := c.HttpCli().JsonGet("/ipc/wingui/window/min?Hwnd="+Hwnd, nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) WindowActiveHwnd() (ret int, err error) {
|
||||||
|
err = c.HttpCli().JsonGet("/ipc/wingui/window/activehwnd", &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) WindowWaitActiveTitle(t string, m int) (ret map[string]interface{}, err error) {
|
||||||
|
err = c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/window/waitactivetitle?t=%s&m=%d", t, m), &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) WindowActiveTitle() (ret string, err error) {
|
||||||
|
err = c.HttpCli().JsonGet("/ipc/wingui/window/activetitle", &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
/*func (c *Cli) WindowWinfo(w int) (ret interface{}, err error) {
|
||||||
|
err = c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/window/winfo?w=%d", w), &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) WindowSendMsg(w, m string) error {
|
||||||
|
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/window/sendmsg?w=%s&m=%s", w, m), nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) WindowPostMsg(w, m string) error {
|
||||||
|
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/window/postmsg?w=%s&m=%s", w, m), nil)
|
||||||
|
return err
|
||||||
|
}*/
|
||||||
|
|
||||||
|
/***************** Screen Functions *****************/
|
||||||
|
|
||||||
|
func (c *Cli) ScreenCapture(x, y, w, h int, f string) (ret interface{}, err error) {
|
||||||
|
err = c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/screen/capture?x=%d&y=%d&w=%d&h=%d&f=%s", x, y, w, h, f), &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) ScreenFindAll(f string) (ret map[string]int, err error) {
|
||||||
|
err = c.HttpCli().JsonGet("/ipc/wingui/screen/findall?f="+f, &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) ScreenClick(f string) error {
|
||||||
|
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/screen/click?f=%s", f), nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) ScreenClickCenter(f string) error {
|
||||||
|
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/screen/clickcenter?f=%s", f), nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) ScreenFind(f string) (ret []interface{}, err error) {
|
||||||
|
err = c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/screen/find?f=%s", f), &ret)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
func (c *Cli) ScreenWait(f string, m int) ([]byte, error) {
|
func (c *Cli) ScreenWait(f string, m int) ([]byte, error) {
|
||||||
url := fmt.Sprintf("/ipc/wingui/screen/wait?f=%s&m=%d", f, m)
|
url := fmt.Sprintf("/ipc/wingui/screen/wait?f=%s&m=%d", f, m)
|
||||||
|
|
||||||
|
@ -178,6 +364,7 @@ func (c *Cli) ScreenWait(f string, m int) ([]byte, error) {
|
||||||
fmt.Println(ret)
|
fmt.Println(ret)
|
||||||
return ret, err
|
return ret, err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *Cli) ScreenWaitClick(f string, m int) ([]byte, error) {
|
func (c *Cli) ScreenWaitClick(f string, m int) ([]byte, error) {
|
||||||
url := fmt.Sprintf("/ipc/wingui/screen/waitclick?f=%s&m=%d", f, m)
|
url := fmt.Sprintf("/ipc/wingui/screen/waitclick?f=%s&m=%d", f, m)
|
||||||
|
|
||||||
|
@ -188,6 +375,7 @@ func (c *Cli) ScreenWaitClick(f string, m int) ([]byte, error) {
|
||||||
fmt.Println(ret)
|
fmt.Println(ret)
|
||||||
return ret, err
|
return ret, err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *Cli) ScreenWaitClickCenter(f string, m int) ([]byte, error) {
|
func (c *Cli) ScreenWaitClickCenter(f string, m int) ([]byte, error) {
|
||||||
url := fmt.Sprintf("/ipc/wingui/screen/waitclickcenter?f=%s&m=%d", f, m)
|
url := fmt.Sprintf("/ipc/wingui/screen/waitclickcenter?f=%s&m=%d", f, m)
|
||||||
|
|
||||||
|
@ -200,7 +388,7 @@ func (c *Cli) ScreenWaitClickCenter(f string, m int) ([]byte, error) {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *Cli) ScreenRes() ([]byte, error) {
|
func (c *Cli) ScreenRes() ([]byte, error) {
|
||||||
url := fmt.Sprintf("/ipc/wingui/screen/res")
|
url := "/ipc/wingui/screen/res"
|
||||||
|
|
||||||
ret, err := c.HttpCli().RawGet(url)
|
ret, err := c.HttpCli().RawGet(url)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -208,11 +396,146 @@ func (c *Cli) ScreenRes() ([]byte, error) {
|
||||||
}
|
}
|
||||||
return ret, err
|
return ret, err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *Cli) ScreenSetRes(x, y, cor int) error {
|
func (c *Cli) ScreenSetRes(x, y, cor int) error {
|
||||||
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/screen/setres?x=%d&y=%d&c=%d", x, y, cor), nil)
|
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/screen/setres?x=%d&y=%d&c=%d", x, y, cor), nil)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (c *Cli) ScreenScale() (ret []int, err error) {
|
||||||
|
err = c.HttpCli().JsonGet("/ipc/wingui/screen/scale", &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) ScreenSize() (ret []int, err error) {
|
||||||
|
err = c.HttpCli().JsonGet("/ipc/wingui/screen/size", &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) ScreenShot(frmt string) (ret []byte, err error) {
|
||||||
|
url := fmt.Sprintf("/ipc/wingui/screen/shot?fmt=%s", frmt)
|
||||||
|
|
||||||
|
ret, err = c.HttpCli().RawGet(url)
|
||||||
|
if err != nil {
|
||||||
|
fmt.Print(err.Error())
|
||||||
|
}
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) ScreenDsInternal() error {
|
||||||
|
err := c.HttpCli().JsonGet("/ipc/wingui/screen/dsinternal", nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) ScreenDsExternal() error {
|
||||||
|
err := c.HttpCli().JsonGet("/ipc/wingui/screen/dsexternal", nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) ScreenDsClone() error {
|
||||||
|
err := c.HttpCli().JsonGet("/ipc/wingui/screen/dsclone", nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) ScreenDsExtend() error {
|
||||||
|
err := c.HttpCli().JsonGet("/ipc/wingui/screen/dsextend", nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
/***************** Dialog Functions *****************/
|
||||||
|
|
||||||
|
func (c *Cli) DialogColor(t, d string) (ret map[string]int, err error) {
|
||||||
|
err = c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/dialog/color?t=%s&d=%s", t, d), &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) DialogDate(t, m, d, f string) (ret string, err error) {
|
||||||
|
err = c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/dialog/date?t=%s&m=%s&d=%s&f=%s", t, m, d, f), &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) DialogEntry(t, m, d string) (ret string, err error) {
|
||||||
|
err = c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/dialog/entry?t=%s&m=%s&d=%s", t, m, d), &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) DialogError(t, m string) error {
|
||||||
|
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/dialog/error?t=%s&m=%s", t, m), nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) DialogFile(t, f, d string) (ret string, err error) {
|
||||||
|
err = c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/dialog/file?t=%s&f=%s&d=%s", t, f, d), &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) DialogFileMulti(t, f string) (ret []string, err error) {
|
||||||
|
err = c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/dialog/filemulti?t=%s&f=%s", t, f), &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) DialogInfo(t, m string) error {
|
||||||
|
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/dialog/info?t=%s&m=%s", t, m), nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) DialogList(t, m, f string) (ret string, err error) {
|
||||||
|
err = c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/dialog/list?t=%s&m=%s&f=%s", t, m, f), &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) DialogListMulti(t, m, f string) (ret []string, err error) {
|
||||||
|
err = c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/dialog/listmulti?t=%s&m=%s&f=%s", t, m, f), &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) DialogPassword(t, m string) (ret string, err error) {
|
||||||
|
err = c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/dialog/password?t=%s&m=%s", t, m), &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) DialogQuestion(t, m string) (ret bool, err error) {
|
||||||
|
err = c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/dialog/question?t=%s&m=%s", t, m), &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) DialogWarn(t, m string) error {
|
||||||
|
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/dialog/warn?t=%s&m=%s", t, m), nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
/***************** Process Functions *****************/
|
||||||
|
|
||||||
|
func (c *Cli) ProcAll() (ret []map[string]interface{}, err error) {
|
||||||
|
err = c.HttpCli().JsonGet("/ipc/wingui/proc/all", &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) ProcPids() (ret []int, err error) {
|
||||||
|
err = c.HttpCli().JsonGet("/ipc/wingui/proc/pids", &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) ProcKill(cmd int) (ret string, err error) {
|
||||||
|
err = c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/proc/kill?cmd=%d", cmd), &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) ProcExec(cmd string) error {
|
||||||
|
err := c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/proc/exec?cmd=%s", cmd), nil)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) ProcName(pid int) (ret string, err error) {
|
||||||
|
err = c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/proc/name?pid=%d", pid), &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Cli) ProcPath(pid int) (ret string, err error) {
|
||||||
|
err = c.HttpCli().JsonGet(fmt.Sprintf("/ipc/wingui/proc/path?pid=%d", pid), &ret)
|
||||||
|
return ret, err
|
||||||
|
}
|
||||||
|
|
||||||
func NewCli() *Cli {
|
func NewCli() *Cli {
|
||||||
ret := &Cli{ApiCli: api.NewApiCli()}
|
ret := &Cli{ApiCli: api.NewApiCli()}
|
||||||
return ret
|
return ret
|
||||||
|
|
4
go.mod
4
go.mod
|
@ -6,9 +6,9 @@ go 1.17
|
||||||
// go.digitalcircle.com.br/open/httpcli => ../httpcli
|
// go.digitalcircle.com.br/open/httpcli => ../httpcli
|
||||||
//)
|
//)
|
||||||
require (
|
require (
|
||||||
github.com/Microsoft/go-winio v0.5.1
|
github.com/Microsoft/go-winio v0.5.2
|
||||||
github.com/gorilla/websocket v1.4.2
|
github.com/gorilla/websocket v1.4.2
|
||||||
github.com/mitchellh/go-ps v1.0.0
|
github.com/mitchellh/go-ps v1.0.0
|
||||||
go.digitalcircle.com.br/open/httpcli v0.0.0-20211031093505-ecf33aed8afb
|
go.digitalcircle.com.br/open/httpcli v0.0.0-20211031093505-ecf33aed8afb
|
||||||
golang.org/x/sys v0.0.0-20211031064116-611d5d643895 // indirect
|
golang.org/x/sys v0.0.0-20220227234510-4e6760a101f9 // indirect
|
||||||
)
|
)
|
||||||
|
|
6
go.sum
6
go.sum
|
@ -2,6 +2,8 @@ github.com/Microsoft/go-winio v0.5.0 h1:Elr9Wn+sGKPlkaBvwu4mTrxtmOp3F3yV9qhaHbXG
|
||||||
github.com/Microsoft/go-winio v0.5.0/go.mod h1:JPGBdM1cNvN/6ISo+n8V5iA4v8pBzdOpzfwIujj1a84=
|
github.com/Microsoft/go-winio v0.5.0/go.mod h1:JPGBdM1cNvN/6ISo+n8V5iA4v8pBzdOpzfwIujj1a84=
|
||||||
github.com/Microsoft/go-winio v0.5.1 h1:aPJp2QD7OOrhO5tQXqQoGSJc+DjDtWTGLOmNyAm6FgY=
|
github.com/Microsoft/go-winio v0.5.1 h1:aPJp2QD7OOrhO5tQXqQoGSJc+DjDtWTGLOmNyAm6FgY=
|
||||||
github.com/Microsoft/go-winio v0.5.1/go.mod h1:JPGBdM1cNvN/6ISo+n8V5iA4v8pBzdOpzfwIujj1a84=
|
github.com/Microsoft/go-winio v0.5.1/go.mod h1:JPGBdM1cNvN/6ISo+n8V5iA4v8pBzdOpzfwIujj1a84=
|
||||||
|
github.com/Microsoft/go-winio v0.5.2 h1:a9IhgEQBCUEk6QCdml9CiJGhAws+YwffDHEMp1VMrpA=
|
||||||
|
github.com/Microsoft/go-winio v0.5.2/go.mod h1:WpS1mjBmmwHBEWmogvA2mj8546UReBk4v8QkMxJ6pZY=
|
||||||
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
||||||
github.com/gorilla/websocket v1.4.2 h1:+/TMaTYc4QFitKJxsQ7Yye35DkWvkdLcvGKqM+x0Ufc=
|
github.com/gorilla/websocket v1.4.2 h1:+/TMaTYc4QFitKJxsQ7Yye35DkWvkdLcvGKqM+x0Ufc=
|
||||||
github.com/gorilla/websocket v1.4.2/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
|
github.com/gorilla/websocket v1.4.2/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
|
||||||
|
@ -21,3 +23,7 @@ golang.org/x/sys v0.0.0-20211007075335-d3039528d8ac h1:oN6lz7iLW/YC7un8pq+9bOLyX
|
||||||
golang.org/x/sys v0.0.0-20211007075335-d3039528d8ac/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
golang.org/x/sys v0.0.0-20211007075335-d3039528d8ac/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
||||||
golang.org/x/sys v0.0.0-20211031064116-611d5d643895 h1:iaNpwpnrgL5jzWS0vCNnfa8HqzxveCFpFx3uC/X4Tps=
|
golang.org/x/sys v0.0.0-20211031064116-611d5d643895 h1:iaNpwpnrgL5jzWS0vCNnfa8HqzxveCFpFx3uC/X4Tps=
|
||||||
golang.org/x/sys v0.0.0-20211031064116-611d5d643895/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
golang.org/x/sys v0.0.0-20211031064116-611d5d643895/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
||||||
|
golang.org/x/sys v0.0.0-20211106132015-ebca88c72f68 h1:Ywe/f3fNleF8I6F6qv3MeFoSZ6CTf2zBMMa/7qVML8M=
|
||||||
|
golang.org/x/sys v0.0.0-20211106132015-ebca88c72f68/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
||||||
|
golang.org/x/sys v0.0.0-20220227234510-4e6760a101f9 h1:nhht2DYV/Sn3qOayu8lM+cU1ii9sTLUeBQwQQfUHtrs=
|
||||||
|
golang.org/x/sys v0.0.0-20220227234510-4e6760a101f9/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
|
||||||
|
|
13
types/lib.go
13
types/lib.go
|
@ -214,7 +214,11 @@ type Log struct {
|
||||||
}
|
}
|
||||||
|
|
||||||
func (l *Log) Write(p []byte) (n int, err error) {
|
func (l *Log) Write(p []byte) (n int, err error) {
|
||||||
os.Stdout.Write([]byte(fmt.Sprintf("- %s\n", string(p))))
|
_, err = os.Stdout.Write([]byte(fmt.Sprintf("- %s\n", string(p))))
|
||||||
|
if err != nil {
|
||||||
|
println(fmt.Sprintf("Log.Write:: Error writing log: %s", err.Error()))
|
||||||
|
return 0, err
|
||||||
|
}
|
||||||
l.AddHistory(string(p))
|
l.AddHistory(string(p))
|
||||||
return len(p), nil
|
return len(p), nil
|
||||||
}
|
}
|
||||||
|
@ -228,6 +232,11 @@ func (l *Log) AddHistory(s string) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (l *Log) Printf(s string, i ...interface{}) {
|
||||||
|
l.AddHistory(fmt.Sprintf(s, i...))
|
||||||
|
s = fmt.Sprintf("* %s: %s", time.Now().Format("02/01/06 - 15:04:05"), s)
|
||||||
|
}
|
||||||
|
|
||||||
type LogQuery struct {
|
type LogQuery struct {
|
||||||
From time.Time `json:"from"`
|
From time.Time `json:"from"`
|
||||||
Until time.Time `json:"until"`
|
Until time.Time `json:"until"`
|
||||||
|
@ -303,9 +312,11 @@ type Cron struct {
|
||||||
Model
|
Model
|
||||||
Cron string `json:"cron"`
|
Cron string `json:"cron"`
|
||||||
JobCode uint `json:"job"`
|
JobCode uint `json:"job"`
|
||||||
|
JobAlias string `json:"jobalias" gorm:"-"`
|
||||||
Enabled *bool `json:"enabled"`
|
Enabled *bool `json:"enabled"`
|
||||||
Data string `json:"data"`
|
Data string `json:"data"`
|
||||||
Comments string `json:"comments"`
|
Comments string `json:"comments"`
|
||||||
|
Once bool `json:"once"`
|
||||||
}
|
}
|
||||||
|
|
||||||
//type Resource struct {
|
//type Resource struct {
|
||||||
|
|
Loading…
Reference in New Issue