Compare commits

..

8 Commits

Author SHA1 Message Date
42d7f4131b Support firewall zones 2025-04-14 12:38:46 +02:00
be515d2e6f Merge pull request #13 from vegardengen/12-support-v2-network-api
Add do_versioned and make do wrap do_versioned
2025-04-14 12:35:44 +02:00
ec43083868 Add do_versioned and make do wrap do_versioned 2025-04-14 12:32:13 +02:00
babe9757a6 Merge pull request #11 from vegardengen/10-fix-module-name
Switch to my branch
2025-04-14 12:19:20 +02:00
225c79703f Switch to my branch 2025-04-14 12:17:32 +02:00
b0d58766fc Merge pull request #9 from vegardengen/8-fix-ipsec-lifetimes
Change ipsec lifetimes to int
2025-04-14 12:08:32 +02:00
8721daf90a Change ipsec lifetimes to int 2025-04-14 12:08:08 +02:00
14f0897119 Merge pull request #7 from vegardengen/6-update-to-90114
Update to network version 9.0.114
2025-04-14 12:04:17 +02:00
5 changed files with 64 additions and 4 deletions

2
go.mod
View File

@@ -1,4 +1,4 @@
module github.com/ubiquiti-community/go-unifi
module github.com/vegardengen/go-unifi
go 1.21

View File

@@ -5,7 +5,7 @@ import (
"testing"
"github.com/tj/assert"
"github.com/ubiquiti-community/go-unifi/unifi"
"github.com/vegardengen/go-unifi/unifi"
)
func TestAccountMarshalJSON(t *testing.T) {

48
unifi/firewall_zone.go Normal file
View File

@@ -0,0 +1,48 @@
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_versioned(ctx, "V2", "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{}
}

View File

@@ -5,7 +5,7 @@ import (
"reflect"
"testing"
"github.com/ubiquiti-community/go-unifi/unifi"
"github.com/vegardengen/go-unifi/unifi"
)
func TestNetworkUnmarshalJSON(t *testing.T) {

View File

@@ -191,10 +191,22 @@ func (c *Client) Login(ctx context.Context, user, pass string) error {
}
func (c *Client) do(ctx context.Context, method, relativeURL string, reqBody any, respBody any) error {
return c.do_versioned(ctx, "V1", method, relativeURL, reqBody, respBody)
}
func (c *Client) do_versioned(ctx context.Context, version, method, relativeURL string, reqBody any, respBody any) error {
// single threading requests, this is mostly to assist in CSRF token propagation
c.Lock()
defer c.Unlock()
var apiPath string
if version == "V2" {
apiPath = c.apiV2Path
} else {
apiPath = c.apiPath
}
var (
reqReader io.Reader
err error
@@ -213,7 +225,7 @@ func (c *Client) do(ctx context.Context, method, relativeURL string, reqBody any
return fmt.Errorf("unable to parse URL: %s %s %w", method, relativeURL, err)
}
if !strings.HasPrefix(relativeURL, "/") && !reqURL.IsAbs() {
reqURL.Path = path.Join(c.apiPath, reqURL.Path)
reqURL.Path = path.Join(apiPath, reqURL.Path)
}
url := c.baseURL.ResolveReference(reqURL)