Merge pull request #55 from seashell/dev

dev

Author: edufschmidt

.gitignore

@@ -27,8 +27,10 @@ Godeps/
 # End of https://www.gitignore.io/api/go
 ui/node_modules/*
 ui/.eslintcache
-ui/build
+ui/build/*
 vendor/*
 
+!*.keep
+
 tmp
 dist/

.goreleaser.yml

@@ -22,12 +22,13 @@ archives:
       windows: Windows
       386: i386
       amd64: x86_64
+    name_template: "{{ .ProjectName }}_v{{ .Version }}_{{ .Os }}_{{ .Arch }}{{ if .Arm }}v{{ .Arm }}{{ end }}"
 checksum:
-  name_template: '{{ .ProjectName }}_v{{ .Version }}_checksums.txt'
+  name_template: "{{ .ProjectName }}_v{{ .Version }}_checksums.txt"
 snapshot:
   name_template: "{{ .Tag }}-next"
 release:
-  name_template: "{{ .ProjectName }}-v{{ .Version }}"
+  name_template: "v{{ .Version }}"
 changelog:
   sort: asc
   filters:

README.md

@@ -71,7 +71,7 @@ Drago is meant to be simple, and provide a solid foundation for higher-level fun
 
 ## Usage
 ```
-Usage: drago [--version] [--help] <command> [<args>]
+Usage: drago [--version] [--help] <command> [options]
 
 Available commands:
     acl           Interact with ACL policies and tokens

api/acl_policy.go

@@ -1,7 +1,6 @@
 package api
 
 import (
-	"fmt"
 	"path"
 
 	"github.com/seashell/drago/drago/structs"
@@ -22,8 +21,15 @@ func (c *Client) ACLPolicies() *ACLPolicies {
 }
 
 // Create :
-func (p *ACLPolicies) Upsert(policy *structs.ACLPolicy) error {
-	return fmt.Errorf("not implemented")
+func (p *ACLPolicies) Upsert(policy *structs.ACLPolicy) (*structs.ACLPolicy, error) {
+
+	var rcvPolicy *structs.ACLPolicy
+	err := p.client.createResource(aclPoliciesPath, policy, &rcvPolicy)
+	if err != nil {
+		return nil, err
+	}
+
+	return policy, nil
 }
 
 // Delete :
@@ -40,13 +46,13 @@ func (p *ACLPolicies) Delete(name string) error {
 // Get :
 func (p *ACLPolicies) Get(name string) (*structs.ACLPolicy, error) {
 
-	var policy *structs.ACLPolicy
-	err := p.client.getResource(aclPoliciesPath, name, &policy)
+	out := &structs.ACLPolicy{}
+	err := p.client.getResource(aclPoliciesPath, name, out)
 	if err != nil {
 		return nil, err
 	}
 
-	return policy, nil
+	return out, nil
 }
 
 // List :

api/acl_token.go

@@ -23,14 +23,14 @@ func (c *Client) ACLTokens() *ACLTokens {
 // Create :
 func (t *ACLTokens) Create(token *structs.ACLToken) (*structs.ACLToken, error) {
 
-	out := structs.ACLToken{}
+	out := &structs.ACLToken{}
 
-	err := t.client.createResource(aclTokensPath, token, &out)
+	err := t.client.createResource(aclTokensPath, token, out)
 	if err != nil {
 		return nil, err
 	}
 
-	return &out, nil
+	return out, nil
 }
 
 // Delete :

api/connection.go

@@ -43,3 +43,34 @@ func (n *Connections) List() ([]*structs.ConnectionListStub, error) {
 
 	return items, nil
 }
+
+func (n *Connections) Create(connection *structs.Connection) error {
+
+	err := n.client.createResource(connectionsPath, connection, nil)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (n *Connections) Update(conn *structs.Connection) (*structs.Connection, error) {
+
+	out := &structs.Connection{}
+	err := n.client.createResource(connectionsPath, conn, out)
+	if err != nil {
+		return nil, err
+	}
+
+	return out, nil
+}
+
+func (n *Connections) Delete(id string) error {
+
+	err := n.client.deleteResource(id, connectionsPath, nil)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}

api/interface.go

@@ -45,30 +45,32 @@ func (n *Interfaces) List(filters map[string][]string) ([]*structs.InterfaceList
 }
 
 // Create :
-func (n *Interfaces) Create(nodeID, networkID string) error {
+func (n *Interfaces) Create(nodeID, networkID string) (*structs.Interface, error) {
 
 	iface := &structs.Interface{
 		NodeID:    nodeID,
 		NetworkID: networkID,
 	}
 
-	err := n.client.createResource(interfacesPath, iface, nil)
+	out := &structs.Interface{}
+	err := n.client.createResource(interfacesPath, iface, out)
 	if err != nil {
-		return err
+		return nil, err
 	}
 
-	return nil
+	return out, nil
 }
 
 // Update :
-func (n *Interfaces) Update(iface *structs.Interface) error {
+func (n *Interfaces) Update(iface *structs.Interface) (*structs.Interface, error) {
 
-	err := n.client.createResource(interfacesPath, iface, nil)
+	out := &structs.Interface{}
+	err := n.client.createResource(interfacesPath, iface, out)
 	if err != nil {
-		return err
+		return nil, err
 	}
 
-	return nil
+	return out, err
 }
 
 // Delete :

api/network.go

@@ -28,7 +28,7 @@ func (n *Networks) Create(network *structs.Network) error {
 		return err
 	}
 
-	return nil
+	return err
 }
 
 // Delete :

client/nic/controller.go

@@ -167,7 +167,6 @@ func (c *Controller) createLink(name string, alias string) error {
 		}
 
 	} else {
-		fmt.Println("USING KERNELSPACE WIREGUARD")
 		if err := netlink.LinkAdd(&netlink.Wireguard{LinkAttrs: attrs}); err != nil {
 			return fmt.Errorf("can't create network interface : %s", err.Error())
 		}

command/acl_policy_apply.go

@@ -0,0 +1,94 @@
+package command
+
+import (
+	"context"
+	"fmt"
+	"strings"
+
+	"github.com/seashell/drago/drago/structs"
+	cli "github.com/seashell/drago/pkg/cli"
+	"github.com/spf13/pflag"
+)
+
+// ACLPolicyApplyCommand :
+type ACLPolicyApplyCommand struct {
+	UI cli.UI
+	Command
+
+	// Parsed flags
+	description string
+}
+
+func (c *ACLPolicyApplyCommand) FlagSet() *pflag.FlagSet {
+
+	flags := c.Command.FlagSet(c.Name())
+	flags.Usage = func() { c.UI.Output("\n" + c.Help() + "\n") }
+
+	return flags
+}
+
+// Name :
+func (c *ACLPolicyApplyCommand) Name() string {
+	return "acl policy apply"
+}
+
+// Synopsis :
+func (c *ACLPolicyApplyCommand) Synopsis() string {
+	return "Apply ACL policy"
+}
+
+// Run :
+func (c *ACLPolicyApplyCommand) Run(ctx context.Context, args []string) int {
+
+	flags := c.FlagSet()
+
+	if err := flags.Parse(args); err != nil {
+		return 1
+	}
+
+	args = flags.Args()
+	if len(args) != 1 {
+		c.UI.Error("This command takes one argument: <name>")
+		c.UI.Error(`For additional help, try 'drago acl policy apply --help'`)
+		return 1
+	}
+
+	name := args[0]
+
+	// Get the HTTP client
+	api, err := c.Command.APIClient()
+	if err != nil {
+		c.UI.Error(fmt.Sprintf("Error setting up API client: %s", err))
+		return 1
+	}
+
+	p := &structs.ACLPolicy{
+		Name:        name,
+		Description: c.description,
+	}
+	if _, err := api.ACLPolicies().Upsert(p); err != nil {
+		c.UI.Error(fmt.Sprintf("Error applying ACL policy: %s", err))
+		return 1
+	}
+
+	return 0
+}
+
+// Help :
+func (c *ACLPolicyApplyCommand) Help() string {
+	h := `
+Usage: drago acl policy apply <name> [options]
+
+  Create or update an ACL policy.
+
+General Options:
+` + GlobalOptions() + `
+
+ACL Policy Apply Options:
+
+  --description=<description>
+    Sets the description for the ACL policy.
+
+`
+	return strings.TrimSpace(h)
+}