more work on importing

Signed-off-by: Jeff Carr <jcarr@wit.com>
This commit is contained in:
Jeff Carr 2024-11-01 08:51:25 -05:00
parent 0a28c45a6c
commit 173520b42e
4 changed files with 16 additions and 10 deletions

View File

@ -3,19 +3,16 @@ package main
import ( import (
"errors" "errors"
"fmt" "fmt"
"io/ioutil"
"math/rand" "math/rand"
"net/http"
"time" "time"
"github.com/google/uuid"
pb "go.wit.com/lib/protobuf/virtbuf" pb "go.wit.com/lib/protobuf/virtbuf"
"go.wit.com/log"
) )
// attempts to create a new virtual machine // attempts to create a new virtual machine
func create(w http.ResponseWriter, r *http.Request) (string, error) { /*
func oldcreate(w http.ResponseWriter, r *http.Request) (string, error) {
msg, err := ioutil.ReadAll(r.Body) // Read the body as []byte msg, err := ioutil.ReadAll(r.Body) // Read the body as []byte
if err != nil { if err != nil {
result := fmt.Sprintf("ReadAll() error =", err) result := fmt.Sprintf("ReadAll() error =", err)
@ -84,6 +81,7 @@ func create(w http.ResponseWriter, r *http.Request) (string, error) {
fmt.Fprintln(w, "START=OK") fmt.Fprintln(w, "START=OK")
return result, nil return result, nil
} }
*/
// for now, because sometimes this should write to stdout and // for now, because sometimes this should write to stdout and
// sometimes to http socket, it returns a string // sometimes to http socket, it returns a string

View File

@ -98,10 +98,21 @@ func importDomain(w http.ResponseWriter, r *http.Request) (string, error) {
me.cluster.AddEvent(e) me.cluster.AddEvent(e)
} }
log.Warn("Everything worked")
result := fmt.Sprintln("importDomain() worked") result := fmt.Sprintln("importDomain() worked")
// remote LocalOnly flag
d.LocalOnly = ""
// probably be safe and don't let this move around the cluster
d.PreferredHypervisor = d.Current.Hypervisor
log.Log(WARN, result) log.Log(WARN, result)
fmt.Fprintln(w, result) fmt.Fprintln(w, result)
log.Warn("Everything worked. Saving config files")
if err := me.cluster.ConfigSave(); err != nil {
log.Warn("configsave error", err)
os.Exit(-1)
}
return result, nil return result, nil
} }

View File

@ -126,9 +126,6 @@ func main() {
log.Info(i, "Event:", e.Droplet, e.FieldName, "orig:", e.OrigVal, "new:", e.NewVal) log.Info(i, "Event:", e.Droplet, e.FieldName, "orig:", e.OrigVal, "new:", e.NewVal)
me.changed = true me.changed = true
} }
// if err := me.cluster.ConfigSave(); err != nil {
// log.Info("configsave error", err)
// }
if me.changed { if me.changed {
if err := me.cluster.ConfigSave(); err != nil { if err := me.cluster.ConfigSave(); err != nil {

View File

@ -157,7 +157,7 @@ func ValidateDiskFilenames() ([]*pb.Event, error) {
} }
if !found { if !found {
log.Info("droplet", d.Hostname, d.Disks) log.Info("droplet", d.Hostname, d.Disks)
return nil, errors.New("droplet " + d.Hostname + " has nonstandard disk names") log.Warn("droplet " + d.Hostname + " has nonstandard disk names")
} }
} }
return alle, nil return alle, nil