From 374bb34695b67d12dcf8c5c4b7dd46b1a9d0a7dc Mon Sep 17 00:00:00 2001
From: GnomeZworc <nicolas.boufidjeline@g3e.fr>
Date: Sun, 19 Apr 2026 21:02:54 +0200
Subject: [PATCH] f-21: code: add dispatch command for subnet

Signed-off-by: GnomeZworc <nicolas.boufidjeline@g3e.fr>
---
 internal/dispatcher/subnet_commands.go | 31 ++++++++++++++++++++++----
 1 file changed, 27 insertions(+), 4 deletions(-)

diff --git a/internal/dispatcher/subnet_commands.go b/internal/dispatcher/subnet_commands.go
index d8ef8e3..b23949e 100644
--- a/internal/dispatcher/subnet_commands.go
+++ b/internal/dispatcher/subnet_commands.go
@@ -1,6 +1,14 @@
 package dispatcher
 
-import "github.com/dgraph-io/badger/v4"
+import (
+	"fmt"
+	"os"
+	"strconv"
+
+	"git.g3e.fr/syonad/two/internal/subnet"
+	"git.g3e.fr/syonad/two/pkg/db/kv"
+	"github.com/dgraph-io/badger/v4"
+)
 
 type CreateSubnetCommand struct {
 	Name      string
@@ -12,8 +20,13 @@ type CreateSubnetCommand struct {
 }
 
 func (c CreateSubnetCommand) Execute(db *badger.DB) error {
-	// TODO: brancher internal/subnet/create.go
-	return nil
+	kv.AddInDB(db, "subnet/"+c.Name+"/state", "creating")
+	kv.AddInDB(db, "subnet/"+c.Name+"/vpc", c.VPC)
+	kv.AddInDB(db, "subnet/"+c.Name+"/vxlan_id", strconv.Itoa(c.VxlanID))
+	kv.AddInDB(db, "subnet/"+c.Name+"/local_ip", c.LocalIP)
+	kv.AddInDB(db, "subnet/"+c.Name+"/gateway_ip", c.GatewayIP)
+	kv.AddInDB(db, "subnet/"+c.Name+"/cidr", c.CIDR)
+	return subnet.CreateSubnet(db, c.Name)
 }
 
 type DeleteSubnetCommand struct {
@@ -21,6 +34,16 @@ type DeleteSubnetCommand struct {
 }
 
 func (c DeleteSubnetCommand) Execute(db *badger.DB) error {
-	// TODO: brancher internal/subnet/delete.go
+	kv.AddInDB(db, "subnet/"+c.Name+"/state", "deleting")
+	if err := subnet.DeleteSubnet(db, c.Name); err != nil {
+		fmt.Println(err)
+		os.Exit(1)
+	}
+	if state, err := kv.GetFromDB(db, "subnet/"+c.Name+"/state"); err != nil {
+		fmt.Println(err)
+		os.Exit(1)
+	} else if state == "deleted" {
+		kv.DeleteInDB(db, "subnet/"+c.Name)
+	}
 	return nil
 }