two/internal/vpc/create.go

package vpc

import (
	"git.g3e.fr/syonad/two/internal/netif"
	"git.g3e.fr/syonad/two/internal/netns"
	"git.g3e.fr/syonad/two/pkg/db/kv"

	"github.com/dgraph-io/badger/v4"
)

func CreateVPC(db *badger.DB, name string) error {
	// missing
	// search data in db
	//  change state in db

	// create netns
	if state, err := kv.GetFromDB(db, "vpc/"+name+"/state"); err != nil {
		return err
	} else if state == "creating" {
		if err := netns.Create(name); err != nil {
			return err
		}

		// create veth public for this netns
		if err := netif.CreateVethToNetns("vp-"+name+"-e", "vp-public-i", "/var/run/netns/"+name, 9000); err != nil {
			return err
		}

		// create public bridge in netns
		if err := netns.Call(name, func() error {
			return netif.CreateBridge("br-public", 1500)
		}); err != nil {
			return err
		}

		// set veth to ext public bridge
		if err := netif.BridgeSetMaster("vp-"+name+"-e", "br-public"); err != nil {
			return err
		}

		// set veth to int public bridge
		if err := netns.Call(name, func() error {
			return netif.BridgeSetMaster("vp-public-i", "br-public")
		}); err != nil {
			return err
		}

		// set set ext veth up
		if err := netif.LinkSetUp("vp-" + name + "-e"); err != nil {
			return nil
		}
		// set set int veth up
		if err := netns.Call(name, func() error {
			return netif.LinkSetUp("vp-public-i")
		}); err != nil {
			return err
		}
		kv.AddInDB(db, "vpc/"+name+"/state", "created")
	}
	return nil
}