1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859 |
- package main
- import (
- "surdeus.su/core/amo"
- "surdeus.su/core/amo/api"
- //"surdeus.su/core/amo/webhooks"
- "surdeus.su/core/amo/events"
- //"surdeus.su/core/ss"
- //"surdeus.su/core/ss/statuses"
- //"os"
- "fmt"
- //"io"
- //"encoding/json"
- "time"
- )
- func main() {
- //fmt.Println(opts)
- client, err := amo.NewAmoClient("secret.json")
- if err != nil {
- panic(err)
- }
- client.Api.Debug = true
- company, err := client.GetCompany(80828925, "")
- if err != nil && err != api.NoContentErr {
- panic(err)
- }
- fmt.Printf("company: %+v\n", company)
- interval := time.Second * 10
- now := time.Now()
- lastChanged := now
- for {
- time.Sleep(interval)
- req := events.EventsRequest{}
- req.Limit = 10
- req.Filter.Entity = []string{"company", "contact"}
- req.Filter.Type = events.CustomFieldValueChanged(
- 2192301,
- 2678095,
- )
- req.With = []string{"company_name"}
- req.Filter.CreatedAt.From = lastChanged
- events, err := client.GetEvents(req)
- if err != nil {
- fmt.Printf("Error: %s", err)
- continue
- }
- if len(events) == 0 {
- fmt.Printf("nothing changed")
- continue
- }
- lastChanged = time.Now()
- for i, event := range events {
- fmt.Printf("event %d: %v\n", i, event)
- }
- }
- }
|