diff options
Diffstat (limited to 'digitalocean')
| -rw-r--r-- | digitalocean/api.go | 36 | ||||
| -rw-r--r-- | digitalocean/args.go | 27 | ||||
| -rw-r--r-- | digitalocean/create.go | 293 | ||||
| -rw-r--r-- | digitalocean/droplet.go | 266 | ||||
| -rw-r--r-- | digitalocean/json.go | 24 | ||||
| -rw-r--r-- | digitalocean/listKeys.go | 39 | ||||
| -rw-r--r-- | digitalocean/main.go | 78 | ||||
| -rw-r--r-- | digitalocean/pollDroplets.go | 50 | ||||
| -rw-r--r-- | digitalocean/poweron.go | 82 | ||||
| -rw-r--r-- | digitalocean/structs.go | 91 | ||||
| -rw-r--r-- | digitalocean/xterm.go | 31 |
11 files changed, 0 insertions, 1017 deletions
diff --git a/digitalocean/api.go b/digitalocean/api.go deleted file mode 100644 index b1568b1..0000000 --- a/digitalocean/api.go +++ /dev/null @@ -1,36 +0,0 @@ -package digitalocean - -import ( - "context" - - "golang.org/x/oauth2" - "github.com/digitalocean/godo" - - "go.wit.com/log" -) - -func (d *DigitalOcean) listRegions() []godo.Region { - tokenSource := oauth2.StaticTokenSource(&oauth2.Token{AccessToken: d.token}) - oauthClient := oauth2.NewClient(context.Background(), tokenSource) - client := godo.NewClient(oauthClient) - - ctx := context.TODO() - - // Retrieve all regions. - regions, _, err := client.Regions.List(ctx, &godo.ListOptions{}) - if err != nil { - d.err = err - log.Warn(err, "digitalocean.listRegions() failed") - return nil - } - - /* - // Print details of each region. - fmt.Println("Available Regions:") - for _, region := range regions { - fmt.Printf("Slug: %s, Name: %s, Available: %v\n", region.Slug, region.Name, region.Available) - } - */ - - return regions -} diff --git a/digitalocean/args.go b/digitalocean/args.go deleted file mode 100644 index 246f72d..0000000 --- a/digitalocean/args.go +++ /dev/null @@ -1,27 +0,0 @@ -package digitalocean - -// initializes logging and command line options - -import ( - arg "github.com/alexflint/go-arg" - log "go.wit.com/log" -) - -var INFO log.LogFlag -var argDo ArgsDo - -// This struct can be used with the go-arg package -type ArgsDo struct { - DigitalOceanTimer bool `arg:"--digitalocean-poll-interval" help:"how often to poll droplet status (default 60 seconds)"` -} - -func init() { - arg.Register(&argDo) - - INFO.B = false - INFO.Name = "INFO" - INFO.Subsystem = "digitalocean" - INFO.Desc = "Enable log.Info()" - - INFO.Register() -} diff --git a/digitalocean/create.go b/digitalocean/create.go deleted file mode 100644 index dfd12e3..0000000 --- a/digitalocean/create.go +++ /dev/null @@ -1,293 +0,0 @@ -package digitalocean - -import ( - "context" - "strings" - "golang.org/x/oauth2" - "github.com/digitalocean/godo" - - "go.wit.com/log" - "go.wit.com/gui/gadgets" - // "go.wit.com/gui" -) - -/* -// createDroplet creates a new droplet in the specified region with the given name. -func createDroplet(token, name, region, size, image string) (*godo.Droplet, error) { - // Create an OAuth2 token. - tokenSource := &oauth2.Token{ - AccessToken: token, - } - - // Create an OAuth2 client. - oauthClient := oauth2.NewClient(context.Background(), tokenSource) - - // Create a DigitalOcean client with the OAuth2 client. - client := godo.NewClient(oauthClient) - - // Define the create request. - createRequest := &godo.DropletCreateRequest{ - Name: name, - Region: region, - Size: size, - Image: godo.DropletCreateImage{ - Slug: image, - }, - } - - // Create the droplet. - ctx := context.TODO() - newDroplet, _, err := client.Droplets.Create(ctx, createRequest) - if err != nil { - return nil, err - } - - return newDroplet, nil -} -*/ - -func (d *DigitalOcean) Create(name string, region string, size string, image string) { - // Create a new droplet. - droplet, err := d.createDropletNew(name, region, size, image) - if err != nil { - log.Fatalf("digitalocean.Create() Something went wrong: %s\n", err) - } - - log.Infof("digitalocean.Create() droplet ID %d with name %s\n", droplet.ID, droplet.Name) -} - -// createDroplet creates a new droplet in the specified region with the given name. -func (d *DigitalOcean) createDropletNew(name, region, size, image string) (*godo.Droplet, error) { - log.Infof("digitalocean.createDropletNew() START name =", name) - // Create an OAuth2 token. - tokenSource := oauth2.StaticTokenSource(&oauth2.Token{AccessToken: d.token}) - - // Create an OAuth2 client. - oauthClient := oauth2.NewClient(context.Background(), tokenSource) - - // Create a DigitalOcean client with the OAuth2 client. - client := godo.NewClient(oauthClient) - - var sshKeys []godo.DropletCreateSSHKey - log.Info("digitalocean.createDropletNew() about to get keys. client =", client) - - // Find the key by name. - for i, key := range d.sshKeys { - log.Info("found ssh i =", i, key.Name) - log.Verbose("found ssh key.Name =", key.Name) - log.Verbose("found ssh key.Fingerprint =", key.Fingerprint) - log.Verbose("found ssh key:", key) - /* - sshKeys = []godo.DropletCreateSSHKey{ - {ID: key.ID}, - } - */ - sshKeys = append(sshKeys, godo.DropletCreateSSHKey{ID: key.ID}) - } - - // Define the create request. - createRequest := &godo.DropletCreateRequest{ - Name: name, - Region: region, - Size: size, - Image: godo.DropletCreateImage{ - Slug: image, - }, - IPv6: true, // Enable IPv6 - SSHKeys: sshKeys, // Add SSH key IDs here - } - - // Create the droplet. - ctx := context.TODO() - log.Info("digitalocean.createDropletNew() about to do client.Create(). ctx =", ctx) - newDroplet, _, err := client.Droplets.Create(ctx, createRequest) - log.Infof("digitalocean.createDropletNew() END newDroplet =", newDroplet) - if err != nil { - return nil, err - } - - return newDroplet, nil -} - -var myCreate *windowCreate - -// This is initializes the main DO object -// You can only have one of these -func InitCreateWindow() *windowCreate { - if ! myDo.Ready() {return nil} - if myCreate != nil { - myCreate.Show() - return myCreate - } - myCreate = new(windowCreate) - myCreate.ready = false - - myCreate.window = myDo.parent.NewWindow("Create Droplet") - - // make a group label and a grid - myCreate.group = myCreate.window.NewGroup("droplets:").Pad() - myCreate.grid = myCreate.group.NewGrid("grid", 2, 1).Pad() - - myCreate.name = gadgets.NewBasicEntry(myCreate.grid, "Name").Set("test.wit.com") - - myCreate.region = gadgets.NewBasicDropdown(myCreate.grid, "Region") - - regions := myDo.listRegions() - - // Print details of each region. - log.Info("Available Regions:") - for i, region := range regions { - log.Infof("i: %d, Slug: %s, Name: %s, Available: %v\n", i, region.Slug, region.Name, region.Available) - log.Spew(i, region) - if len(region.Sizes) == 0 { - log.Info("Skipping region. No available sizes region =", region.Name) - } else { - s := region.Name + " (" + region.Slug + ")" - if (myCreate.regionSlug == "") { - myCreate.regionSlug = region.Slug - } - myCreate.region.Add(s) - } - } - - myCreate.region.Custom = func() { - s := myCreate.region.Get() - log.Info("create droplet region changed to:", s) - for _, region := range regions { - if s == region.Name { - log.Info("Found region! slug =", myCreate.regionSlug, region) - myCreate.regionSelected = region - log.Info("Found region! Now update all the sizes count =", len(region.Sizes)) - for _, size := range region.Sizes { - log.Info("Size: ", size) - } - } - } - } - - myCreate.size = gadgets.NewBasicCombobox(myCreate.grid, "Size") - myCreate.size.Add("s-1vcpu-1gb") - myCreate.size.Add("s-1vcpu-1gb-amd") - myCreate.size.Add("s-1vcpu-1gb-intel") - myCreate.size.Add("s-2vcpu-4gb-120gb-intel") - myCreate.size.Set("s-2vcpu-4gb-120gb-intel") - myCreate.size.Custom = func() { - size := myCreate.size.Get() - log.Info("Create() need to verify size exists in region. Digital Ocean size.Slug =", size) - } - - myCreate.memory = gadgets.NewBasicDropdown(myCreate.grid, "Memory") - myCreate.memory.Add("1 GB") - myCreate.memory.Add("2 GB") - myCreate.memory.Add("4 GB") - myCreate.memory.Add("8 GB") - myCreate.memory.Add("16 GB") - myCreate.memory.Add("32 GB") - myCreate.memory.Add("64 GB") - myCreate.memory.Add("96 GB") - myCreate.memory.Add("128 GB") - myCreate.memory.Add("256 GB") - myCreate.memory.Custom = func() { - for _, size := range myCreate.regionSelected.Sizes { - log.Info("Size: ", size) - } - myCreate.UpdateSize() - } - - myCreate.image = gadgets.NewBasicCombobox(myCreate.grid, "Image") - myCreate.image.Add("debian-12-x64") - myCreate.image.Add("ubuntu-20-04-x64") - myCreate.image.Set("debian-12-x64") - - // myCreate.nvme = gadgets.NewBasicCheckbox(myCreate.grid, "NVMe") - - myCreate.group.NewLabel("Create Droplet") - - // box := myCreate.group.NewBox("vBox", false).Pad() - box := myCreate.group.NewBox("hBox", true).Pad() - box.NewButton("Cancel", func () { - myCreate.Hide() - }) - box.NewButton("Create", func () { - name := myCreate.name.Get() - size := myCreate.size.Get() - region := myCreate.regionSlug - image := myCreate.image.Get() - if (region == "") { - log.Info("Create() droplet name =", name, "region =", region, "size =", size, "image", image) - log.Info("Create() region lookup failed") - return - } - log.Info("Create() droplet name =", name, "region =", region, "size =", size, "image", image) - myDo.Create(name, region, size, image) - myCreate.Hide() - }) - - myCreate.ready = true - myDo.create = myCreate - return myCreate -} - -// Find the size -func (d *windowCreate) UpdateSize() { - if ! d.Ready() {return} - log.Info("Now find the size. sizes count =", len(myCreate.regionSelected.Sizes)) - var s string - m := myCreate.memory.Get() - switch m { - case "1 GB": - s = "cpu-1gb-" - case "2 GB": - s = "cpu-2gb-" - case "4 GB": - s = "cpu-4gb-" - case "8 GB": - s = "cpu-8gb-" - case "16 GB": - s = "cpu-16gb-" - case "32 GB": - s = "cpu-32gb-" - case "64 GB": - s = "cpu-64gb-" - case "96 GB": - s = "cpu-96gb-" - case "128 GB": - s = "cpu-128gb-" - case "256 GB": - s = "cpu-256gb-" - default: - s = "cpu-4gb-" - } - for _, size := range myCreate.regionSelected.Sizes { - if strings.Contains(size, s) { - log.Info("Found Size! size.Slug =", size, "contains", s) - myCreate.size.Set(size) - return - } - } - log.Info("memory =", myCreate.memory.Get()) -} - -// Returns true if the status is valid -func (d *windowCreate) Ready() bool { - if d == nil {return false} - return d.ready -} - -func (d *windowCreate) Show() { - if ! d.Ready() {return} - log.Info("digitalocean.Show() window") - if d.hidden { - d.window.Show() - } - d.hidden = false -} - -func (d *windowCreate) Hide() { - if ! d.Ready() {return} - log.Info("digitalocean.Hide() window") - if ! d.hidden { - d.window.Hide() - } - d.hidden = true -} diff --git a/digitalocean/droplet.go b/digitalocean/droplet.go deleted file mode 100644 index ff120a8..0000000 --- a/digitalocean/droplet.go +++ /dev/null @@ -1,266 +0,0 @@ -package digitalocean - -import ( - "errors" - "sort" - "strings" - "strconv" - "github.com/digitalocean/godo" - - "go.wit.com/log" - // "go.wit.com/gui" -) - -func (d *DigitalOcean) NewDroplet(dd *godo.Droplet) *Droplet { - if ! myDo.Ready() {return nil} - - // check if the droplet ID already exists - if (d.dropMap[dd.ID] != nil) { - log.Error(errors.New("droplet.NewDroplet() already exists")) - return d.dropMap[dd.ID] - } - - droplet := new(Droplet) - droplet.ready = false - droplet.poll = dd // the information polled from the digital ocean API - droplet.ID = dd.ID - droplet.image = dd.Image.Name + " (" + dd.Image.Slug + ")" - - if (d.dGrid == nil) { - d.dGrid = d.group.NewGrid("grid", 12, 1).Pad() - } - - droplet.nameN = d.dGrid.NewLabel(dd.Name) - - d.dGrid.NewLabel(dd.Region.Slug) - - var ipv4 []string - var ipv6 []string - for _, network := range dd.Networks.V4 { - if network.Type == "public" { - ipv4 = append(ipv4, network.IPAddress) - } - } - - for _, network := range dd.Networks.V6 { - if network.Type == "public" { - ipv6 = append(ipv6, network.IPAddress) - } - } - sort.Strings(ipv4) - sort.Strings(ipv6) - droplet.ipv4 = d.dGrid.NewLabel(strings.Join(ipv4, "\n")) - droplet.ipv6 = d.dGrid.NewLabel(strings.Join(ipv6, "\n")) - - droplet.sizeSlugN = d.dGrid.NewLabel(dd.SizeSlug) - droplet.imageN = d.dGrid.NewLabel(dd.Image.Slug) - droplet.statusN = d.dGrid.NewLabel(dd.Status) - - droplet.connect = d.dGrid.NewButton("Connect", func () { - droplet.Connect() - }) - - droplet.edit = d.dGrid.NewButton("Edit", func () { - droplet.Show() - }) - - droplet.poweroff = d.dGrid.NewButton("Power Off", func () { - droplet.PowerOff() - }) - - droplet.poweron = d.dGrid.NewButton("Power On", func () { - droplet.PowerOn() - }) - - droplet.destroy = d.dGrid.NewButton("Destroy", func () { - droplet.Destroy() - }) - - droplet.ready = true - return droplet -} - -func (d *Droplet) Active() bool { - if ! d.Ready() {return false} - log.Info("droplet.Active() status: ", d.poll.Status, "d.statusN.GetText() =", d.statusN.GetText()) - if (d.statusN.GetText() == "active") { - return true - } - return false -} - -// Returns true if the droplet is finished installing -func (d *Droplet) Ready() bool { - if d == nil {return false} - return d.ready -} - -// Returns true if the droplet is running -func (d *Droplet) On() bool { - if ! d.Ready() {return false} - return true -} - -func (d *Droplet) HasIPv4() bool { - if ! d.Ready() {return false} - if d.ipv4.GetText() == "" { - return false - } - return true -} -func (d *Droplet) HasIPv6() bool { - if ! d.Ready() {return false} - if d.ipv6.GetText() == "" { - return false - } - return true -} - -func (d *Droplet) GetIPv4() string { - if ! d.Ready() {return ""} - return d.ipv4.GetText() -} - -func (d *Droplet) GetIPv6() string { - if ! d.Ready() {return ""} - log.Info("droplet GetIPv6 has: n.GetText()", d.ipv6.GetText()) - return d.ipv6.GetText() -} - -func (d *Droplet) Connect() { - if ! d.Ready() {return} - if d.HasIPv4() { - ipv4 := d.GetIPv4() - log.Info("droplet has IPv4 =", ipv4) - xterm("ssh root@" + ipv4) - return - } - if d.HasIPv6() { - ipv6 := d.GetIPv6() - log.Info("droplet has IPv6 =", ipv6) - xterm("ssh root@[" + ipv6 + "]") - return - } - log.Info("droplet.Connect() here", d.GetIPv4(), d.GetIPv6()) -} - -func (d *Droplet) Update(dpoll *godo.Droplet) { - if ! d.Exists() {return} - d.poll = dpoll - log.Info("droplet.Update()", dpoll.Name, "dpoll.Status =", dpoll.Status) - log.Spew(dpoll) - d.statusN.SetText(dpoll.Status) - if d.Active() { - d.poweron.Disable() - d.destroy.Disable() - d.connect.Enable() - d.poweroff.Enable() - } else { - d.poweron.Enable() - d.destroy.Enable() - d.poweroff.Disable() - d.connect.Disable() - } -} - -func (d *Droplet) PowerOn() { - if ! d.Exists() {return} - log.Info("droplet.PowerOn() should do it here") - myDo.PowerOn(d.ID) -} - -func (d *Droplet) PowerOff() { - if ! d.Exists() {return} - log.Info("droplet.PowerOff() here") - myDo.PowerOff(d.ID) -} - -func (d *Droplet) Destroy() { - if ! d.Exists() {return} - log.Info("droplet.Destroy() ID =", d.ID, "Name =", d.nameN.GetText()) - myDo.deleteDroplet(d) -} - -/* -type Droplet struct { - ID int `json:"id,float64,omitempty"` - Name string `json:"name,omitempty"` - Memory int `json:"memory,omitempty"` - Vcpus int `json:"vcpus,omitempty"` - Disk int `json:"disk,omitempty"` - Region *Region `json:"region,omitempty"` - Image *Image `json:"image,omitempty"` - Size *Size `json:"size,omitempty"` - SizeSlug string `json:"size_slug,omitempty"` - BackupIDs []int `json:"backup_ids,omitempty"` - NextBackupWindow *BackupWindow `json:"next_backup_window,omitempty"` - SnapshotIDs []int `json:"snapshot_ids,omitempty"` - Features []string `json:"features,omitempty"` - Locked bool `json:"locked,bool,omitempty"` - Status string `json:"status,omitempty"` - Networks *Networks `json:"networks,omitempty"` - Created string `json:"created_at,omitempty"` - Kernel *Kernel `json:"kernel,omitempty"` - Tags []string `json:"tags,omitempty"` - VolumeIDs []string `json:"volume_ids"` - VPCUUID string `json:"vpc_uuid,omitempty"` -} -*/ -func (d *Droplet) Show() { - if ! d.Exists() {return} - log.Info("droplet: ID =", d.ID) - log.Info("droplet: Name =", d.GetName()) - log.Info("droplet: Size =", d.GetSize()) - log.Info("droplet: Memory =", d.GetMemory()) - log.Info("droplet: Disk =", d.GetDisk()) - log.Info("droplet: Image =", d.GetImage()) - log.Info("droplet: Status =", d.GetStatus()) - log.Info("droplet: ", d.poll.Name, d.poll.Image.Slug, d.poll.Region.Slug) - log.Spew(d.poll) -} - -func (d *Droplet) Hide() { - if ! d.Exists() {return} - log.Info("droplet.Hide() window") - if ! d.hidden { - // d.window.Hide() - } - d.hidden = true -} - -func (d *Droplet) Exists() bool { - if ! myDo.Ready() {return false} - if d == nil {return false} - if d.poll == nil {return false} - return d.ready -} - -func (d *Droplet) GetName() string { - if ! d.Ready() {return ""} - return d.nameN.GetText() -} - -func (d *Droplet) GetSize() string { - if ! d.Ready() {return ""} - return d.sizeSlugN.GetText() -} - -func (d *Droplet) GetMemory() string { - if ! d.Ready() {return ""} - return strconv.Itoa(d.memory) -} - -func (d *Droplet) GetDisk() string { - if ! d.Ready() {return ""} - return strconv.Itoa(d.disk) -} - -func (d *Droplet) GetImage() string { - if ! d.Ready() {return ""} - return d.imageN.GetText() -} - -func (d *Droplet) GetStatus() string { - if ! d.Ready() {return ""} - return d.statusN.GetText() -} diff --git a/digitalocean/json.go b/digitalocean/json.go deleted file mode 100644 index c0aa1a8..0000000 --- a/digitalocean/json.go +++ /dev/null @@ -1,24 +0,0 @@ -package digitalocean - -import ( - "encoding/json" -) - -// formatJSON takes an unformatted JSON string and returns a formatted version. -func FormatJSON(unformattedJSON string) (string, error) { - var jsonData interface{} - - // Decode the JSON string into an interface - err := json.Unmarshal([]byte(unformattedJSON), &jsonData) - if err != nil { - return "", err - } - - // Re-encode the JSON with indentation for formatting - formattedJSON, err := json.MarshalIndent(jsonData, "", " ") - if err != nil { - return "", err - } - - return string(formattedJSON), nil -} diff --git a/digitalocean/listKeys.go b/digitalocean/listKeys.go deleted file mode 100644 index 1daa51b..0000000 --- a/digitalocean/listKeys.go +++ /dev/null @@ -1,39 +0,0 @@ -package digitalocean - -import ( - "context" - "golang.org/x/oauth2" - "github.com/digitalocean/godo" - - "go.wit.com/log" -) - -// func (d *DigitalOcean) ListDroplets() bool { -func (d *DigitalOcean) ListSSHKeyID() error { - tokenSource := oauth2.StaticTokenSource(&oauth2.Token{AccessToken: d.token}) - oauthClient := oauth2.NewClient(context.Background(), tokenSource) - client := godo.NewClient(oauthClient) - - // List all keys. - keys, _, err := client.Keys.List(context.Background(), &godo.ListOptions{}) - if err != nil { - return err - } - - d.sshKeys = keys - - // Find the key by name. - for _, key := range keys { - log.Info("found ssh wierd", key.Name) - log.Verbose("found ssh key:", key) - } - /* - sshKeys := []godo.DropletCreateSSHKey{ - {ID: 22994569}, - {ID: 333}, - } - */ - - // return fmt.Errorf("SSH Key not found") - return nil -} diff --git a/digitalocean/main.go b/digitalocean/main.go deleted file mode 100644 index 5c40498..0000000 --- a/digitalocean/main.go +++ /dev/null @@ -1,78 +0,0 @@ -package digitalocean - -import ( - "os" - "go.wit.com/log" - "go.wit.com/gui" -) - -var myDo *DigitalOcean - -// This is initializes the main DO object -// You can only have one of these -func New(p *gui.Node) *DigitalOcean { - if myDo != nil {return myDo} - myDo = new(DigitalOcean) - myDo.ready = false - myDo.parent = p - - myDo.dropMap = make(map[int]*Droplet) - - // Your personal API token from DigitalOcean. - myDo.token = os.Getenv("DIGITALOCEAN_TOKEN") - - myDo.window = p.NewWindow("DigitalOcean Control Panel") - - // make a group label and a grid - myDo.group = myDo.window.NewGroup("droplets:").Pad() - myDo.grid = myDo.group.NewGrid("grid", 2, 1).Pad() - - myDo.ready = true - myDo.Hide() - return myDo -} - -// Returns true if the status is valid -func (d *DigitalOcean) Ready() bool { - if d == nil {return false} - return d.ready -} - -func (d *DigitalOcean) Show() { - if ! d.Ready() {return} - log.Info("digitalocean.Show() window") - if d.hidden { - d.window.Show() - } - d.hidden = false -} - -func (d *DigitalOcean) Hide() { - if ! d.Ready() {return} - log.Info("digitalocean.Hide() window") - if ! d.hidden { - d.window.Hide() - } - d.hidden = true -} - -func (d *DigitalOcean) Update() bool { - if ! d.Ready() {return false} - d.ListSSHKeyID() - if d.ListDroplets() { - for _, droplet := range d.dpolled { - // check if the droplet ID already exists - if (d.dropMap[droplet.ID] == nil) { - d.dropMap[droplet.ID] = d.NewDroplet(&droplet) - } else { - log.Info("droplet.Update()", droplet.ID, droplet.Name, "already exists") - d.dropMap[droplet.ID].Update(&droplet) - continue - } - } - } else { - log.Error(d.err, "Error listing droplets") - return false - } - return true -} diff --git a/digitalocean/pollDroplets.go b/digitalocean/pollDroplets.go deleted file mode 100644 index b150978..0000000 --- a/digitalocean/pollDroplets.go +++ /dev/null @@ -1,50 +0,0 @@ -package digitalocean - -import ( - "context" - - "golang.org/x/oauth2" - - "github.com/digitalocean/godo" -) - -// ListDroplets fetches and prints out the droplets along with their IPv4 and IPv6 addresses. -func (d *DigitalOcean) ListDroplets() bool { - // OAuth token for authentication. - tokenSource := oauth2.StaticTokenSource(&oauth2.Token{AccessToken: d.token}) - - // OAuth2 client. - oauthClient := oauth2.NewClient(context.Background(), tokenSource) - - // DigitalOcean client. - client := godo.NewClient(oauthClient) - - // Context. - ctx := context.TODO() - - // List all droplets. - d.dpolled, _, d.err = client.Droplets.List(ctx, &godo.ListOptions{}) - if d.err != nil { - return false - } - - // Iterate over droplets and print their details. - /* - for _, droplet := range d.polled { - fmt.Printf("Droplet: %s\n", droplet.Name) - for _, network := range droplet.Networks.V4 { - if network.Type == "public" { - fmt.Printf("IPv4: %s\n", network.IPAddress) - } - } - for _, network := range droplet.Networks.V6 { - if network.Type == "public" { - fmt.Printf("IPv6: %s\n", network.IPAddress) - } - } - fmt.Println("-------------------------") - } - */ - - return true -} diff --git a/digitalocean/poweron.go b/digitalocean/poweron.go deleted file mode 100644 index 51f8a24..0000000 --- a/digitalocean/poweron.go +++ /dev/null @@ -1,82 +0,0 @@ -package digitalocean - -import ( - "context" - - "golang.org/x/oauth2" - - "github.com/digitalocean/godo" - - "go.wit.com/log" -) - -func (d *DigitalOcean) PowerOn(dropletID int) error { - tokenSource := oauth2.StaticTokenSource(&oauth2.Token{AccessToken: d.token}) - oauthClient := oauth2.NewClient(context.Background(), tokenSource) - client := godo.NewClient(oauthClient) - - ctx := context.TODO() - - // Create a request to power on the droplet. - _, _, err := client.DropletActions.PowerOn(ctx, dropletID) - if err != nil { - return err - } - - log.Printf("Power-on signal sent to droplet with ID: %d\n", dropletID) - return nil -} - -func (d *DigitalOcean) PowerOff(dropletID int) error { - tokenSource := oauth2.StaticTokenSource(&oauth2.Token{AccessToken: d.token}) - oauthClient := oauth2.NewClient(context.Background(), tokenSource) - client := godo.NewClient(oauthClient) - - ctx := context.TODO() - - // Create a request to power on the droplet. - _, _, err := client.DropletActions.PowerOff(ctx, dropletID) - if err != nil { - return err - } - - log.Printf("Power-off signal sent to droplet with ID: %d\n", dropletID) - return nil -} - -/* -func (d *DigitalOcean) Destroy(dropletID int) error { - tokenSource := oauth2.StaticTokenSource(&oauth2.Token{AccessToken: d.token}) - oauthClient := oauth2.NewClient(context.Background(), tokenSource) - client := godo.NewClient(oauthClient) - - ctx := context.TODO() - - // Create a request to power on the droplet. - _, _, err := client.DropletActions.Delete(ctx, dropletID) - if err != nil { - return err - } - - log.Printf("Destroy sent to droplet with ID: %d\n", dropletID) - return nil -} -*/ - -// createDroplet creates a new droplet in the specified region with the given name. -func (d *DigitalOcean) deleteDroplet(drop *Droplet) error { - // Create an OAuth2 token. - tokenSource := oauth2.StaticTokenSource(&oauth2.Token{AccessToken: d.token}) - - // Create an OAuth2 client. - oauthClient := oauth2.NewClient(context.Background(), tokenSource) - - // Create a DigitalOcean client with the OAuth2 client. - client := godo.NewClient(oauthClient) - - ctx := context.TODO() - log.Warn("deleteDroplet() going to delete ID =", drop.ID, "Name =", drop.GetName()) - response, err := client.Droplets.Delete(ctx, drop.ID) - log.Warn(response) - return err -} diff --git a/digitalocean/structs.go b/digitalocean/structs.go deleted file mode 100644 index a18161a..0000000 --- a/digitalocean/structs.go +++ /dev/null @@ -1,91 +0,0 @@ -/* - The Digital Ocean Struct -*/ - -package digitalocean - -import ( - "github.com/digitalocean/godo" - - "go.wit.com/gui" - "go.wit.com/gui/gadgets" -) - -type DigitalOcean struct { - ready bool - hidden bool - err error - - token string // You're Digital Ocean API key - dpolled []godo.Droplet - sshKeys []godo.Key - - dropMap map[int]*Droplet - create *windowCreate - - parent *gui.Node // should be the root of the 'gui' package binary tree - window *gui.Node // our window for displaying digital ocean droplets - group *gui.Node - grid *gui.Node - - dGrid *gui.Node // the grid for the droplets - - // Primary Directives - status *gadgets.OneLiner - summary *gadgets.OneLiner - statusIPv4 *gadgets.OneLiner - statusIPv6 *gadgets.OneLiner -} - -type windowCreate struct { - ready bool - hidden bool - err error - - parent *gui.Node // should be the root of the 'gui' package binary tree - window *gui.Node // our window for displaying digital ocean droplets - group *gui.Node - grid *gui.Node - - regionSelected godo.Region - regionSlug string - tag *gadgets.OneLiner - name *gadgets.BasicEntry - region *gadgets.BasicDropdown - size *gadgets.BasicCombobox - memory *gadgets.BasicDropdown - image *gadgets.BasicCombobox - // nvme *gadgets.BasicCheckbox -} - -type ipButton struct { - ip *gui.Node - c *gui.Node -} - -type Droplet struct { - ID int - image string - memory int - disk int - - ready bool - hidden bool - err error - - poll *godo.Droplet // store what the digital ocean API returned - - nameN *gui.Node - sizeSlugN *gui.Node - statusN *gui.Node - imageN *gui.Node - - destroy *gui.Node - connect *gui.Node - poweron *gui.Node - poweroff *gui.Node - edit *gui.Node - - ipv4 *gui.Node - ipv6 *gui.Node -} diff --git a/digitalocean/xterm.go b/digitalocean/xterm.go deleted file mode 100644 index 5c94560..0000000 --- a/digitalocean/xterm.go +++ /dev/null @@ -1,31 +0,0 @@ -package digitalocean - -import ( - "os/exec" - "go.wit.com/log" -) - -var geom string = "120x30+500+500" - -func xterm(cmd string) { - var tmp []string - var argsXterm = []string{"nohup", "xterm", "-geometry", geom} - // tmp = append(argsXterm, "-hold", "-e", cmd) - tmp = append(argsXterm, "-e", cmd) - log.Println("xterm cmd=", cmd) - go runCommand(tmp) -} - -func runCommand(cmdArgs []string) { - log.Println("runCommand() START", cmdArgs) - process := exec.Command(cmdArgs[0], cmdArgs[1:len(cmdArgs)]...) - // process := exec.Command("xterm", "-e", "ping localhost") - log.Println("runCommand() process.Start()") - process.Start() - log.Println("runCommand() process.Wait()") - err := process.Wait() - log.Error(err, "on process.Wait") - log.Println("runCommand() NEED TO CHECK THE TIME HERE TO SEE IF THIS WORKED") - log.Println("runCommand() OTHERWISE INFORM THE USER") - log.Println("runCommand() END", cmdArgs) -} |