Compare commits
22 Commits
1-create-n
...
v0.0.1-alp
| Author | SHA1 | Date | |
|---|---|---|---|
| db4af29aa6 | |||
| db8d86a2c5 | |||
| 5626d6341e | |||
| 825508ed03 | |||
| b3b119c402 | |||
| b4e2400bcf | |||
| 8974e82e78 | |||
| 01e89ca98d | |||
| f85fe28c53 | |||
| 82702848f9 | |||
| c52743effa | |||
| b079790183 | |||
| bae6a964eb | |||
| bab50ebfc4 | |||
| 8035772f71 | |||
| 92ec48f4e7 | |||
| 6f78447552 | |||
| 898bd842fc | |||
| 4786c4dd6a | |||
| a37a5c45c3 | |||
| 27d358911a | |||
| ab3b625a72 |
49
unifi/firewall_zone.go
Normal file
49
unifi/firewall_zone.go
Normal file
@@ -0,0 +1,49 @@
|
|||||||
|
package unifi
|
||||||
|
|
||||||
|
import (
|
||||||
|
"context"
|
||||||
|
"fmt"
|
||||||
|
)
|
||||||
|
|
||||||
|
type FirewallZone struct {
|
||||||
|
ID string `json:"_id,omitempty"`
|
||||||
|
|
||||||
|
// Hidden bool `json:"attr_hidden,omitempty"`
|
||||||
|
// HiddenID string `json:"attr_hidden_id,omitempty"`
|
||||||
|
// NoDelete bool `json:"attr_no_delete,omitempty"`
|
||||||
|
// NoEdit bool `json:"attr_no_edit,omitempty"`
|
||||||
|
|
||||||
|
Name string `json:"name"`
|
||||||
|
DefaultZone bool `json:"default_zone,omitempty"`
|
||||||
|
NetworkIDs []string `json:"network_ids,omitempty"`
|
||||||
|
ZoneKey string `json:"zone_key,omitempty"`
|
||||||
|
|
||||||
|
// Role string `json:"role"`
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Client) ListFirewallZones(ctx context.Context, site string) ([]FirewallZone, error) {
|
||||||
|
var respBody []FirewallZone
|
||||||
|
|
||||||
|
|
||||||
|
err := c.do(ctx, "GET", fmt.Sprintf("site/%s/firewall/zone", site), nil, &respBody)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
return respBody, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *Client) GetFirewallZone(ctx context.Context, site, id string) (*FirewallZone, error) {
|
||||||
|
firewallzones, err := c.ListFirewallZones(ctx, site)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, z := range firewallzones {
|
||||||
|
if z.ID == id {
|
||||||
|
return &z, nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil, &NotFoundError{}
|
||||||
|
}
|
||||||
@@ -13,6 +13,7 @@ import (
|
|||||||
"path"
|
"path"
|
||||||
"strings"
|
"strings"
|
||||||
"sync"
|
"sync"
|
||||||
|
"log"
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
@@ -213,7 +214,11 @@ func (c *Client) do(ctx context.Context, method, relativeURL string, reqBody int
|
|||||||
return fmt.Errorf("unable to parse URL: %s %s %w", method, relativeURL, err)
|
return fmt.Errorf("unable to parse URL: %s %s %w", method, relativeURL, err)
|
||||||
}
|
}
|
||||||
if !strings.HasPrefix(relativeURL, "/") && !reqURL.IsAbs() {
|
if !strings.HasPrefix(relativeURL, "/") && !reqURL.IsAbs() {
|
||||||
reqURL.Path = path.Join(c.apiPath, reqURL.Path)
|
if strings.Contains(relativeURL, "firewall/zone") {
|
||||||
|
reqURL.Path = path.Join(c.apiV2Path, reqURL.Path)
|
||||||
|
} else {
|
||||||
|
reqURL.Path = path.Join(c.apiPath, reqURL.Path)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
url := c.baseURL.ResolveReference(reqURL)
|
url := c.baseURL.ResolveReference(reqURL)
|
||||||
@@ -269,7 +274,9 @@ func (c *Client) do(ctx context.Context, method, relativeURL string, reqBody int
|
|||||||
}
|
}
|
||||||
|
|
||||||
// TODO: check rc in addition to status code?
|
// TODO: check rc in addition to status code?
|
||||||
|
|
||||||
|
log.Printf("%+v", respBody)
|
||||||
|
log.Printf("%+v", resp.Body)
|
||||||
err = json.NewDecoder(resp.Body).Decode(respBody)
|
err = json.NewDecoder(resp.Body).Decode(respBody)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("unable to decode body: %s %s %w", method, relativeURL, err)
|
return fmt.Errorf("unable to decode body: %s %s %w", method, relativeURL, err)
|
||||||
|
|||||||
Reference in New Issue
Block a user