122 lines
2.9 KiB
Go
122 lines
2.9 KiB
Go
package vm
|
|
|
|
import (
|
|
"fmt"
|
|
"strconv"
|
|
"strings"
|
|
|
|
"git.g3e.fr/syonad/two/internal/iptables"
|
|
"git.g3e.fr/syonad/two/internal/metadata"
|
|
"git.g3e.fr/syonad/two/internal/netif"
|
|
"git.g3e.fr/syonad/two/internal/netns"
|
|
"git.g3e.fr/syonad/two/internal/qemu"
|
|
"git.g3e.fr/syonad/two/pkg/db/kv"
|
|
|
|
"github.com/dgraph-io/badger/v4"
|
|
)
|
|
|
|
func StartVM(db *badger.DB, name string) error {
|
|
state, err := kv.GetFromDB(db, "vm/"+name+"/state")
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if state != "starting" {
|
|
return nil
|
|
}
|
|
|
|
subnetName, err := kv.GetFromDB(db, "vm/"+name+"/subnet")
|
|
if err != nil {
|
|
return fmt.Errorf("get subnet: %w", err)
|
|
}
|
|
|
|
vpcName, err := kv.GetFromDB(db, "subnet/"+subnetName+"/vpc")
|
|
if err != nil {
|
|
return fmt.Errorf("get vpc: %w", err)
|
|
}
|
|
|
|
gatewayIP, err := kv.GetFromDB(db, "subnet/"+subnetName+"/gateway_ip")
|
|
if err != nil {
|
|
return fmt.Errorf("get gateway_ip: %w", err)
|
|
}
|
|
|
|
bridge := "br-" + strings.SplitN(subnetName, "-", 2)[1]
|
|
|
|
tapIDStr, err := kv.GetFromDB(db, "vm/"+name+"/tap_id")
|
|
if err != nil {
|
|
return fmt.Errorf("get tap_id: %w", err)
|
|
}
|
|
tapID, err := strconv.Atoi(tapIDStr)
|
|
if err != nil {
|
|
return fmt.Errorf("parse tap_id: %w", err)
|
|
}
|
|
|
|
vmIP, err := kv.GetFromDB(db, "vm/"+name+"/ip")
|
|
if err != nil {
|
|
return fmt.Errorf("get ip: %w", err)
|
|
}
|
|
|
|
metadataPort, err := kv.GetFromDB(db, "vm/"+name+"/metadata_port")
|
|
if err != nil {
|
|
return fmt.Errorf("get metadata_port: %w", err)
|
|
}
|
|
|
|
mac, err := kv.GetFromDB(db, "vm/"+name+"/mac")
|
|
if err != nil {
|
|
return fmt.Errorf("get mac: %w", err)
|
|
}
|
|
|
|
volumePath, err := kv.GetFromDB(db, "vm/"+name+"/volume_path")
|
|
if err != nil {
|
|
return fmt.Errorf("get volume_path: %w", err)
|
|
}
|
|
|
|
memoryStr, err := kv.GetFromDB(db, "vm/"+name+"/memory")
|
|
if err != nil {
|
|
return fmt.Errorf("get memory: %w", err)
|
|
}
|
|
memory, _ := strconv.Atoi(memoryStr)
|
|
|
|
cpusStr, err := kv.GetFromDB(db, "vm/"+name+"/cpus")
|
|
if err != nil {
|
|
return fmt.Errorf("get cpus: %w", err)
|
|
}
|
|
cpus, _ := strconv.Atoi(cpusStr)
|
|
|
|
password, _ := kv.GetFromDB(db, "vm/"+name+"/password")
|
|
sshkey, _ := kv.GetFromDB(db, "vm/"+name+"/sshkey")
|
|
|
|
if err := netif.CreateTap(tapID, bridge, vpcName); err != nil {
|
|
return fmt.Errorf("create tap: %w", err)
|
|
}
|
|
|
|
if err := netns.Call(vpcName, func() error {
|
|
return iptables.AddMetadataRedirect(vmIP, gatewayIP, metadataPort)
|
|
}); err != nil {
|
|
return fmt.Errorf("add metadata redirect: %w", err)
|
|
}
|
|
|
|
if err := metadata.StartMetadata(metadata.NoCloudConfig{
|
|
Name: name,
|
|
VpcName: vpcName,
|
|
BindIP: gatewayIP,
|
|
BindPort: metadataPort,
|
|
Password: password,
|
|
SSHKEY: sshkey,
|
|
}, db, false); err != nil {
|
|
return fmt.Errorf("start metadata: %w", err)
|
|
}
|
|
|
|
if err := qemu.Start(qemu.Config{
|
|
Name: name,
|
|
VpcName: vpcName,
|
|
TapID: tapID,
|
|
Mac: mac,
|
|
VolumePath: volumePath,
|
|
Memory: memory,
|
|
CPUs: cpus,
|
|
}); err != nil {
|
|
return fmt.Errorf("start qemu: %w", err)
|
|
}
|
|
|
|
return kv.AddInDB(db, "vm/"+name+"/state", "started")
|
|
}
|