quentin/nuage
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Working destroyer

Browse source
This commit is contained in:
Quentin 2021-09-23 08:23:54 +02:00
parent 5476ba20d1
commit 80ed8bca6c
1 changed files with 30 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

46
main.go
View file

@ -87,13 +87,13 @@ func passInstanceTo(r io.Reader, d instanceReceiver) error {
count += 1 count += 1
} }
fmt.Fprintf(os.Stdout, "ℹ️ Waiting for %v servers\n", count)
for count > 0 { for count > 0 {
err := <- com err := <- com
count -= 1 count -= 1
if err != nil { if err != nil {
failed += 1 failed += 1
} }
fmt.Fprintf(os.Stdout, "ℹ️ Waiting for %v more servers\n", count)
} }
if failed > 0 { if failed > 0 {
@ -106,18 +106,19 @@ func passInstanceTo(r io.Reader, d instanceReceiver) error {
* instance wrapper * instance wrapper
*/ */
type instance struct { type action struct {
api *instance.API api *instance.API
} }
func (i *instance) init() error { func (i *action) init() error {
client, err := getClient() client, err := getClient()
if err != nil { if err != nil {
return err return err
} }
i.api = instance.NewAPI(client), i.api = instance.NewAPI(client)
return nil
} }
func (i *instance) getInstanceByName(zone scw.Zone, name string) (*instance.Server, error) { func (i *action) getInstanceByName(zone scw.Zone, name string) (*instance.Server, error) {
lr, err := i.api.ListServers(&instance.ListServersRequest{ lr, err := i.api.ListServers(&instance.ListServersRequest{
Zone: zone, Zone: zone,
Name: &name, Name: &name,
@ -143,7 +144,7 @@ func parseIP(s *instance.Server) string {
ip += " (dynamic)" ip += " (dynamic)"
} }
} else if s.PrivateIP != nil { } else if s.PrivateIP != nil {
ip = fmt.Sprintf("%v %v", s.PrivateIP, "(private)") ip = fmt.Sprintf("%s %s", *s.PrivateIP, "(private)")
} }
return ip return ip
} }
@ -152,11 +153,7 @@ func parseIP(s *instance.Server) string {
/** /**
* Spawner * Spawner
*/ */
type spawner instance type spawner struct { action }
func newSpawner() (spawner, error) {
return newInstance()
}
func (sp *spawner) onInstance(zone, machine, image, name string) error { func (sp *spawner) onInstance(zone, machine, image, name string) error {
z, err := scw.ParseZone(zone) z, err := scw.ParseZone(zone)
if err != nil { if err != nil {
@ -212,7 +209,7 @@ func (sp *spawner) onInstance(zone, machine, image, name string) error {
/** /**
* Destroyer * Destroyer
*/ */
type destroyer instance type destroyer struct { action }
func (dt *destroyer) onInstance(zone, machine, image, name string) error { func (dt *destroyer) onInstance(zone, machine, image, name string) error {
z, err := scw.ParseZone(zone) z, err := scw.ParseZone(zone)
@ -220,17 +217,34 @@ func (dt *destroyer) onInstance(zone, machine, image, name string) error {
return err return err
} }
targetServer, err := dt.inst.getInstanceByName(z, name) targetServer, err := dt.getInstanceByName(z, name)
if err == instanceNotFound {
fmt.Fprintf(os.Stdout, "🟣 %v is already destroyed\n", name)
return nil
} else if err != nil {
return err
}
err = dt.api.ServerActionAndWait(&instance.ServerActionAndWaitRequest{
Zone: z,
ServerID: targetServer.ID,
Action: instance.ServerActionPoweroff,
})
if err != nil { if err != nil {
return err return err
} }
err = dt.inst.api.DeleteServer(&instance.DeleteServerRequest{ err = dt.api.DeleteServer(&instance.DeleteServerRequest{
Zone: z, Zone: z,
ServerID: targetServer.ID ServerID: targetServer.ID,
}) })
if err != nil {
return err return err
}
ip := parseIP(targetServer)
fmt.Fprintf(os.Stdout, "✅ Destroyed %v on zone %v with ip %v\n", targetServer.Name, targetServer.Zone, ip)
return nil
} }