package dbapi import ( "basic.com/pubsub/protomsg.git" "encoding/json" "strconv" ) type RuleTemplateApi struct{ Ip string Port int } func (api RuleTemplateApi) getBasicUrl() string { if api.Ip == "" { return BASIC_URL } if api.Ip == "" { api.Ip = DEFAULT_IP } if api.Port == 0 { api.Port = DEFAULT_PORT } return "http://"+api.Ip+":"+strconv.Itoa(api.Port) } func (api RuleTemplateApi) Save(reqBody map[string]interface{}) bool { url := api.getBasicUrl() + DATA_URL_PREFIX + "/template/rule/save" client := NewClient() body, err := client.DoPostRequest(url,CONTENT_TYPE_JSON, reqBody,nil,nil) if err != nil { return false } var res Result if err = json.Unmarshal(body, &res); err != nil { return false } return res.Success } func (api RuleTemplateApi) Show(id string) (bool,interface{}) { url := api.getBasicUrl() + DATA_URL_PREFIX + "/template/rule/"+id client := NewClient() body, err := client.DoGetRequest(url, nil,nil) if err != nil { return false,nil } var res Result if err = json.Unmarshal(body, &res); err != nil { return false,nil } return res.Success, res.Data } func (api RuleTemplateApi) Delete(id string) bool { url := api.getBasicUrl() + DATA_URL_PREFIX + "/template/rule/"+id client := NewClient() body, err := client.DoDeleteRequest(url,CONTENT_TYPE_JSON, nil,nil) if err != nil { return false } var res Result if err = json.Unmarshal(body, &res); err != nil { return false } return res.Success } func (api RuleTemplateApi) FindAll() (b bool,templates []protomsg.RuleTemplate) { url := api.getBasicUrl() + DATA_URL_PREFIX + "/template/rule" client := NewClient() body, err := client.DoGetRequest(url,nil,nil) if err != nil { logPrint(err) return false,nil } var res Result if err = json.Unmarshal(body, &res); err != nil { logPrint(err) return false,nil } if !res.Success { logPrint(err) return false,nil } bytes,err := json.Marshal(res.Data) if err != nil { logPrint(err) return false, nil } err = json.Unmarshal(bytes, &templates) if err != nil { logPrint(err) return false, nil } return true, templates }