Compare commits
13 Commits
f3f348164a
...
api
Author | SHA1 | Date | |
---|---|---|---|
2507f10b59 | |||
900e1939f3 | |||
43a958cdec | |||
5b9862d641 | |||
7ca633d946 | |||
199b3b1f7f | |||
372e92fc41 | |||
2afccc5a0e | |||
3d77209b53 | |||
5ce62bc7de | |||
0e0ab8c653 | |||
3b548e4c85 | |||
9d7db268cc |
10
README.md
10
README.md
@ -16,12 +16,13 @@ Config.Jail_zfs_mountpoint = none
|
||||
|
||||
Create jails
|
||||
------------
|
||||
You need to specify release, and optional configuration:
|
||||
For now, we can't pass config at creation time. We have to define config after creation:
|
||||
<pre><code>
|
||||
gocage create jail1 -r 13.2-RELEASE -p "Config.Ip4_addr='vnet0|192.168.1.91/24',Config.Ip6=none,Config.Boot=1"
|
||||
gocage create jail1 -r 13.2-RELEASE
|
||||
gocage set Config.Ip4_addr="vnet0|192.168.1.91/24" Config.Vnet=1 jail1
|
||||
</code></pre>
|
||||
|
||||
Create basejail. A basejail is a jail based on a release: system will be nullfs read-only mounted from the release directory. Main advantage is that release updates will immediately apply to jails based on this release. Another advantage is that jail system is mounted read-only, a plus from a security perspective:
|
||||
Create basejail (jail based on a release, system will be nullfs read-only mounted from the release directory):
|
||||
<pre><code>
|
||||
gocage create -b -r 14.0-RELEASE basejail1
|
||||
</code></pre>
|
||||
@ -29,6 +30,7 @@ gocage create -b -r 14.0-RELEASE basejail1
|
||||
|
||||
List jails
|
||||
----------
|
||||
Nothing fancy, just use
|
||||
`gocage list`
|
||||
|
||||
### Specify fields to display
|
||||
@ -231,7 +233,7 @@ Fetch
|
||||
Files can be fetched from custom repository, or from local directory with "from" option.
|
||||
For example if you destroyed releases/12.3-RELEASE and still have the downloaded files in /iocage/download/12.3-RELEASE:
|
||||
<pre><code>
|
||||
gocage fetch -r 12.3 -d iocage -f file:/iocage/download
|
||||
gocage fetch -r 12.3 -o iocage --from file:/iocage/download
|
||||
</pre></code>
|
||||
|
||||
|
||||
|
96
cmd/api.go
Normal file
96
cmd/api.go
Normal file
@ -0,0 +1,96 @@
|
||||
package cmd
|
||||
|
||||
import (
|
||||
//"io"
|
||||
"fmt"
|
||||
"strings"
|
||||
"net/http"
|
||||
|
||||
"github.com/gin-gonic/gin"
|
||||
"github.com/gin-contrib/cors"
|
||||
)
|
||||
|
||||
func printJails(jails []string, fields []string) ([]byte, error) {
|
||||
var res []byte
|
||||
|
||||
res = append(res, []byte("[")...)
|
||||
|
||||
// Build a filtered jail list
|
||||
var filteredJails []Jail
|
||||
if (len(jails) >= 1 && len(jails[0]) > 0) {
|
||||
for _, j := range gJails {
|
||||
if isStringInArray(jails, j.Name) {
|
||||
filteredJails = append(filteredJails, j)
|
||||
}
|
||||
}
|
||||
} else {
|
||||
filteredJails = gJails
|
||||
}
|
||||
|
||||
for i, j := range filteredJails {
|
||||
out, err := j.PrintJSON(fields)
|
||||
if err != nil {
|
||||
return res, err
|
||||
}
|
||||
res = append(res, out...)
|
||||
if i < len(filteredJails) - 1 {
|
||||
res = append(res, []byte(",")...)
|
||||
}
|
||||
}
|
||||
res = append(res, []byte("]")...)
|
||||
return res, nil
|
||||
}
|
||||
|
||||
func startApi(address string, port int) {
|
||||
// Initialize gJails.
|
||||
// FIXME: How to update this at running time without doubling the same jails?
|
||||
// core will do this for us in add and delete functions
|
||||
ListJails([]string{""}, false)
|
||||
|
||||
r := gin.Default()
|
||||
|
||||
// Cross Origin Request Support
|
||||
config := cors.DefaultConfig()
|
||||
// DANGER !
|
||||
config.AllowOrigins = []string{"*"}
|
||||
r.Use(cors.New(config))
|
||||
|
||||
r.GET("/jail/list", func(c *gin.Context) {
|
||||
jailstr := c.Query("jail")
|
||||
fields := c.Query("fields")
|
||||
if len(fields) == 0 {
|
||||
// TODO : Put this default value in (user?) configuration
|
||||
fields = "Name,Running,Config.Release,Config.Ip4_addr"
|
||||
}
|
||||
jsout, err := printJails(strings.Split(jailstr, ","), strings.Split(fields, ","))
|
||||
if err != nil {
|
||||
c.JSON(http.StatusInternalServerError, gin.H{"status": 1, "error": err.Error()})
|
||||
} else {
|
||||
c.Data(http.StatusOK, "application/json", jsout)
|
||||
}
|
||||
})
|
||||
|
||||
r.POST("/jail/start/:jail", func(c *gin.Context) {
|
||||
jailstr := c.Params.ByName("jail")
|
||||
// TODO : Capture or redirect output so we can know if jail was started or not
|
||||
StartJail(strings.Split(jailstr, ","))
|
||||
c.JSON(http.StatusOK, gin.H{"status": 0, "error": ""})
|
||||
})
|
||||
r.POST("/jail/stop/:jail", func(c *gin.Context) {
|
||||
jailstr := c.Params.ByName("jail")
|
||||
// TODO : Capture or redirect output so we can know if jail was started or not
|
||||
StopJail(strings.Split(jailstr, ","))
|
||||
c.JSON(http.StatusOK, gin.H{"status": 0, "error": ""})
|
||||
})
|
||||
|
||||
r.GET("/jail/properties", func(c *gin.Context) {
|
||||
props, err := ListJailsProps("json")
|
||||
if err != nil {
|
||||
c.JSON(http.StatusInternalServerError, gin.H{"status": 1, "error": err.Error()})
|
||||
} else {
|
||||
c.Data(http.StatusOK, "application/json", []byte(props))
|
||||
}
|
||||
})
|
||||
|
||||
r.Run(fmt.Sprintf("%s:%d", address, port))
|
||||
}
|
@ -44,7 +44,7 @@ func CreateJail(args []string) {
|
||||
|
||||
var ds *Datastore
|
||||
if len(gCreateArgs.Datastore) > 0 {
|
||||
log.Debugf("Use %s datastore\n", gCreateArgs.Datastore)
|
||||
fmt.Printf("DEBUG: Use %s datastore\n", gCreateArgs.Datastore)
|
||||
ds, err = getDatastoreFromArray(gCreateArgs.Datastore, gDatastores)
|
||||
if err != nil {
|
||||
fmt.Printf("ERROR Getting datastore: %s\n", gCreateArgs.Datastore, err.Error())
|
||||
@ -272,6 +272,7 @@ func CreateJail(args []string) {
|
||||
j.Config.Host_hostname = jname
|
||||
j.Config.Host_hostuuid = jname
|
||||
j.Config.Jailtype = "jail"
|
||||
|
||||
j.WriteConfigToDisk(false)
|
||||
|
||||
///////////////////////////////////////////////////////////////////////
|
||||
@ -284,17 +285,5 @@ func CreateJail(args []string) {
|
||||
defer fstabHandle.Close()
|
||||
fmt.Printf(" > Jail created!\n")
|
||||
}
|
||||
|
||||
var cmdline []string
|
||||
for _, props := range strings.Split(gCreateArgs.Properties, ",") {
|
||||
cmdline = append(cmdline, props)
|
||||
}
|
||||
|
||||
// Reload jail list so SetJailProperties will see it
|
||||
ListJails(nil, false)
|
||||
|
||||
cmdline = append(cmdline, jname)
|
||||
log.Debugf("cmdline: \"%v\"", cmdline)
|
||||
SetJailProperties(cmdline)
|
||||
}
|
||||
}
|
||||
|
153
cmd/init.go
153
cmd/init.go
@ -1,153 +0,0 @@
|
||||
package cmd
|
||||
|
||||
import (
|
||||
"os"
|
||||
"fmt"
|
||||
"strings"
|
||||
|
||||
"github.com/spf13/viper"
|
||||
log "github.com/sirupsen/logrus"
|
||||
)
|
||||
|
||||
/********************************************************************************
|
||||
* Initialize datastore(s) /iocage, /iocage/jails
|
||||
* Put defaults.json,
|
||||
* Update it with hostid, interfaces, and maybe other necessary fields
|
||||
* Initialize bridge
|
||||
*******************************************************************************/
|
||||
func InitGoCage(args []string) {
|
||||
// Create datastores
|
||||
for _, dstore := range viper.GetStringSlice("datastore") {
|
||||
log.Debugf("Ranging over %v\n", dstore)
|
||||
dset, err := zfsGetDatasetByMountpoint(dstore)
|
||||
if err != nil && strings.HasSuffix(err.Error(), "No such file or directory\"") {
|
||||
if len(gZPool) == 0 {
|
||||
log.Errorf("Datastore mountpoint \"%s\" does not exist. Specify a pool if you want to create it.", dstore)
|
||||
return
|
||||
}
|
||||
// Create dataset /iocage
|
||||
rootDSName := fmt.Sprintf("%s%s", gZPool, dstore)
|
||||
log.Debugf("Creating dataset %s mounted on %s\n", rootDSName, dstore)
|
||||
if err = zfsCreateDataset(rootDSName, dstore, ""); err != nil {
|
||||
log.Errorf("Error creating dataset %s: %v\n", rootDSName, err)
|
||||
return
|
||||
}
|
||||
// Create /iocage/jail, releases, templates
|
||||
for _, l := range []string{"jails","releases","templates"} {
|
||||
cds := fmt.Sprintf("%s/%s", rootDSName, l)
|
||||
cmp := fmt.Sprintf("%s/%s", dstore, l)
|
||||
log.Debugf("Creating dataset %s mounted on %s\n", cds, cmp)
|
||||
if err = zfsCreateDataset(cds, cmp, ""); err != nil {
|
||||
log.Errorf("Error creating dataset %s: %v\n", cds, err)
|
||||
return
|
||||
}
|
||||
}
|
||||
|
||||
// Create /iocage/defaults.json
|
||||
exists, err := doFileExist(fmt.Sprintf("%s/defaults.json", dstore))
|
||||
if err != nil {
|
||||
log.Errorf("Error checking defaults.json: %v\n", err)
|
||||
return
|
||||
}
|
||||
if !exists {
|
||||
if err = createDefaultsJson(dstore, gBridge); err != nil {
|
||||
log.Errorf("%v\n", err)
|
||||
}
|
||||
}
|
||||
} else if err != nil {
|
||||
log.Errorf("Error checking datastore existence: %v\n", err)
|
||||
return
|
||||
} else {
|
||||
log.Debugf("Datastore dataset exist: %s\n", dset)
|
||||
}
|
||||
}
|
||||
// Check and create bridge
|
||||
// FIXME: What if bridge name is invalid, as we already wrote it in defaults.json in dstore loop?
|
||||
if len(gBridge) > 0 && len(gInterface) > 0 {
|
||||
if err := initBridge(); err != nil {
|
||||
log.Errorf("%v\n", err)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func createDefaultsJson(rootDirectory string, bridge string) error {
|
||||
hostid, err := os.ReadFile("/etc/hostid")
|
||||
if err != nil {
|
||||
log.Fatalf("Unable to read /etc/hostid: %v\n", err)
|
||||
}
|
||||
json := strings.Replace(gDefaultsJson, "TO-BE-REPLACED-WITH-HOSTID", strings.Trim(string(hostid), "\n"), 1)
|
||||
json = strings.Replace(json, "TO-BE-REPLACED-WITH-BRIDGE", bridge, 1)
|
||||
if err := os.WriteFile(fmt.Sprintf("%s/defaults.json", rootDirectory), []byte(json), 0640); err != nil {
|
||||
log.Fatal(err)
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
func createInterface(iface string) error {
|
||||
log.Debugf("creating interface \"%s\"\n", iface)
|
||||
cmd := fmt.Sprintf("/sbin/ifconfig %s create", iface)
|
||||
_, err := executeCommand(cmd)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func bringUpInterface(iface string) error {
|
||||
log.Debugf("bringing up interface \"%s\"\n", iface)
|
||||
cmd := fmt.Sprintf("/sbin/ifconfig %s up", iface)
|
||||
_, err := executeCommand(cmd)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func addMemberToBridge(bridge string, iface string) error {
|
||||
log.Debugf("adding member interface \"%s\" to bridge \"%s\"\n", iface, bridge)
|
||||
cmd := fmt.Sprintf("/sbin/ifconfig %s addm %s", bridge, iface)
|
||||
_, err := executeCommand(cmd)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func initBridge() error {
|
||||
hostInt, err := gJailHost.GetInterfaces()
|
||||
if err != nil {
|
||||
return fmt.Errorf("Error listing interfaces: %v\n", err)
|
||||
}
|
||||
if !isStringInArray(hostInt, gInterface) {
|
||||
return fmt.Errorf("Interface not found: %s\n", gInterface)
|
||||
}
|
||||
if !isStringInArray(hostInt, gBridge) {
|
||||
if err := createInterface(gBridge); err != nil {
|
||||
return fmt.Errorf("Error creating bridge: %v\n", err)
|
||||
}
|
||||
if err := bringUpInterface(gBridge); err != nil {
|
||||
return fmt.Errorf("Error bringing up bridge: %v\n", err)
|
||||
}
|
||||
log.Infof("bridge was created, but it won't persist reboot. Configure rc.conf to persist. See https://docs.freebsd.org/en/books/handbook/advanced-networking/#network-bridging\n")
|
||||
log.Infof("It is strongly suggested you move interface %s IP to bridge %s\n", gInterface, gBridge)
|
||||
}
|
||||
// FIXME: Need to check if not already member
|
||||
members, err := getBridgeMembers(gBridge)
|
||||
if err != nil {
|
||||
return fmt.Errorf("Error getting bridge members: %v\n", err)
|
||||
}
|
||||
|
||||
// Return if interface already member of the bridge
|
||||
for _, m := range members {
|
||||
log.Debugf("Bridge member: %s\n", m)
|
||||
if strings.EqualFold(m, gInterface) {
|
||||
return nil
|
||||
}
|
||||
}
|
||||
if err := addMemberToBridge(gBridge, gInterface); err != nil {
|
||||
return fmt.Errorf("Error adding interface to bridge: %v\n", err)
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
26
cmd/list.go
26
cmd/list.go
@ -15,23 +15,37 @@ import (
|
||||
* List all properties a jail have, with their internal name
|
||||
* Only print properties name. To get name & values, use GetJailProperties()
|
||||
*******************************************************************************/
|
||||
func ListJailsProps(args []string) {
|
||||
func ListJailsProps(format string) (string, error) {
|
||||
var conf Jail
|
||||
var result []string
|
||||
var props []string
|
||||
var out string
|
||||
// Mandatory constructor to init default values
|
||||
jailconf, err := NewJailConfig()
|
||||
if err != nil {
|
||||
fmt.Printf("Error allocating JailConfig: %s\n", err.Error())
|
||||
return
|
||||
return out, err
|
||||
}
|
||||
|
||||
conf.Config = jailconf
|
||||
|
||||
result = getStructFieldNames(conf, result, "")
|
||||
props = getStructFieldNames(conf, props, "")
|
||||
|
||||
for _, f := range result {
|
||||
fmt.Printf("%s\n", f)
|
||||
if format == "json" {
|
||||
out = "{\"properties\":["
|
||||
for i, p := range props {
|
||||
out += fmt.Sprintf("\"%s\"", p)
|
||||
if i < len(props) - 1 {
|
||||
out += ","
|
||||
}
|
||||
}
|
||||
out += "]}"
|
||||
} else {
|
||||
for _, p := range props {
|
||||
out += fmt.Sprintf("%s\n", p)
|
||||
}
|
||||
}
|
||||
|
||||
return out, nil
|
||||
}
|
||||
|
||||
/********************************************************************************
|
||||
|
29
cmd/root.go
29
cmd/root.go
@ -25,10 +25,12 @@ type createArgs struct {
|
||||
BaseJail bool
|
||||
Datastore string
|
||||
JailType string
|
||||
Properties string
|
||||
}
|
||||
|
||||
var (
|
||||
gApiAddress string
|
||||
gApiPort int
|
||||
|
||||
gJailHost JailHost
|
||||
gJails []Jail
|
||||
gDatastores []Datastore
|
||||
@ -125,7 +127,12 @@ ex: gocage list srv-db srv-web`,
|
||||
Short: "Print jails properties",
|
||||
Long: "Display jails properties. You can use properties to filter, get or set them.",
|
||||
Run: func(cmd *cobra.Command, args []string) {
|
||||
ListJailsProps(args)
|
||||
out, err := ListJailsProps("text")
|
||||
if err != nil {
|
||||
fmt.Printf("Error listing properties : %v\n", err)
|
||||
} else {
|
||||
fmt.Printf("%s\n", out)
|
||||
}
|
||||
},
|
||||
}
|
||||
|
||||
@ -355,6 +362,14 @@ You can specify multiple datastores.`,
|
||||
},
|
||||
}
|
||||
|
||||
apiCmd = &cobra.Command{
|
||||
Use: "startapi",
|
||||
Short: "Run docage as a daemon, exposing API",
|
||||
Run: func(cmd *cobra.Command, args []string) {
|
||||
startApi(gApiAddress, gApiPort)
|
||||
},
|
||||
}
|
||||
|
||||
testCmd = &cobra.Command{
|
||||
Use: "test",
|
||||
Short: "temporary command to test some code snippet",
|
||||
@ -380,7 +395,6 @@ func init() {
|
||||
initCmd.Flags().StringVarP(&gZPool, "pool", "p", "", "ZFS pool to create datastore on")
|
||||
initCmd.Flags().StringVarP(&gBridge, "bridge", "b", "", "bridge to create for jails networking")
|
||||
initCmd.Flags().StringVarP(&gInterface, "interface", "i", "", "interface to add as bridge member. This should be your main interface")
|
||||
initCmd.MarkFlagRequired("bridge")
|
||||
initCmd.MarkFlagsRequiredTogether("bridge", "interface")
|
||||
|
||||
// We reuse these flags in "gocage snapshot list myjail" and 'gocage datastore list" commands
|
||||
@ -414,8 +428,8 @@ func init() {
|
||||
migrateCmd.MarkFlagRequired("datastore")
|
||||
|
||||
fetchCmd.Flags().StringVarP(&gFetchRelease, "release", "r", "", "Release to fetch (e.g.: \"13.1-RELEASE\"")
|
||||
fetchCmd.Flags().StringVarP(&gFetchIntoDS, "datastore", "d", "", "Datastore release will be saved to")
|
||||
fetchCmd.Flags().StringVarP(&gFetchFrom, "from", "f", "", "Repository to download from. Should contain XY.Z-RELEASE. File protocol supported")
|
||||
fetchCmd.Flags().StringVarP(&gFetchIntoDS, "datastore", "o", "", "Datastore release will be saved to")
|
||||
fetchCmd.Flags().StringVarP(&gFetchFrom, "from", "d", "", "Repository to download from. Should contain XY.Z-RELEASE. File protocol supported")
|
||||
fetchCmd.MarkFlagRequired("release")
|
||||
fetchCmd.MarkFlagRequired("datastore")
|
||||
|
||||
@ -425,7 +439,9 @@ func init() {
|
||||
createCmd.Flags().StringVarP(&gCreateArgs.Release, "release", "r", "", "Release for the jail (e.g.: \"13.1-RELEASE\"")
|
||||
createCmd.Flags().BoolVarP(&gCreateArgs.BaseJail, "basejail", "b", false, "Basejail. This will create a jail mounted read only from a release, so every up(date|grade) made to this release will immediately propagate to new jail.\n")
|
||||
createCmd.Flags().StringVarP(&gCreateArgs.Datastore, "datastore", "d", "", "Datastore to create the jail on. Defaults to first declared in config.")
|
||||
createCmd.Flags().StringVarP(&gCreateArgs.Properties, "configuration", "p", "", "Configuration properties with format k1=v1,k2=v2 (Ex: \"Config.Ip4_addr='vnet0|192.168.1.2',Config.Ip6=none\")")
|
||||
|
||||
apiCmd.Flags().StringVarP(&gApiAddress, "listen-addr", "l", "127.0.0.1", "API listening address")
|
||||
apiCmd.Flags().IntVarP(&gApiPort, "listen-port", "p", 1234, "API listening port")
|
||||
|
||||
// Now declare commands
|
||||
rootCmd.AddCommand(initCmd)
|
||||
@ -446,6 +462,7 @@ func init() {
|
||||
rootCmd.AddCommand(updateCmd)
|
||||
rootCmd.AddCommand(upgradeCmd)
|
||||
rootCmd.AddCommand(createCmd)
|
||||
rootCmd.AddCommand(apiCmd)
|
||||
rootCmd.AddCommand(testCmd)
|
||||
|
||||
snapshotCmd.AddCommand(snapshotListCmd)
|
||||
|
19
cmd/start.go
19
cmd/start.go
@ -1421,6 +1421,25 @@ func StartJail(args []string) {
|
||||
}
|
||||
}
|
||||
|
||||
// Get a reference to current jail, to update its properties in RAM so API will get fresh data
|
||||
for i, j := range gJails {
|
||||
if strings.EqualFold(j.Name, cj.Name) && strings.EqualFold(j.Datastore, cj.Datastore) {
|
||||
if err = setStructFieldValue(&gJails[i], "Running", "true"); err != nil {
|
||||
fmt.Printf("ERROR: setting Running property to true: %s\n", err.Error())
|
||||
}
|
||||
if err = setStructFieldValue(&gJails[i], "JID", fmt.Sprintf("%d", cj.JID)); err != nil {
|
||||
fmt.Printf("ERROR: setting JID property to %d: %s\n", cj.JID, err.Error())
|
||||
}
|
||||
if err = setStructFieldValue(&gJails[i], "InternalName", cj.InternalName); err != nil {
|
||||
fmt.Printf("ERROR: Setting InternalName property: %s\n", err.Error())
|
||||
}
|
||||
// FIXME: this value of devfs_ruleset should not go in Config, it should reside in Jail root properties as it is volatile (only valid while jail is running)
|
||||
/*if err = setStructFieldValue(&gJails[i], "Devfs_ruleset", "0"); err != nil {
|
||||
fmt.Printf("ERROR: setting Devfs_ruleset property to 0: %s\n", err.Error())
|
||||
}*/
|
||||
}
|
||||
}
|
||||
|
||||
hostInt, err := gJailHost.GetInterfaces()
|
||||
if err != nil {
|
||||
fmt.Printf("Error listing jail host interfaces: %v\n", err)
|
||||
|
41
cmd/stop.go
41
cmd/stop.go
@ -7,8 +7,8 @@ import (
|
||||
"sync"
|
||||
"errors"
|
||||
"regexp"
|
||||
"slices"
|
||||
"os/exec"
|
||||
//"reflect"
|
||||
"strconv"
|
||||
"strings"
|
||||
|
||||
@ -83,26 +83,39 @@ func umountAndUnjailZFS(jail *Jail) error {
|
||||
}
|
||||
|
||||
func destroyVNetInterfaces(jail *Jail) error {
|
||||
if !strings.EqualFold(jail.Config.Ip4_addr, "none") {
|
||||
for _, i := range strings.Split(jail.Config.Ip4_addr, ",") {
|
||||
// Wherever ipv6/ipv4 is enabled, if interface exist we destroy it
|
||||
var vnetnames []string
|
||||
for _, i := range strings.Split(jail.Config.Ip4_addr, ",") {
|
||||
if len(strings.Split(i, "|")) == 2 {
|
||||
iname := fmt.Sprintf("%s.%d", strings.Split(i, "|")[0], jail.JID)
|
||||
fmt.Printf("%s: ", iname)
|
||||
_, err := executeCommand(fmt.Sprintf("ifconfig %s destroy", iname))
|
||||
//_, err := executeScript(fmt.Sprintf("ifconfig %s destroy >/dev/null 2>&1", iname))
|
||||
if err != nil {
|
||||
return err
|
||||
} else {
|
||||
fmt.Printf("OK\n")
|
||||
if !slices.Contains(vnetnames, iname) {
|
||||
vnetnames = append(vnetnames, iname)
|
||||
}
|
||||
}
|
||||
}
|
||||
if !strings.EqualFold(jail.Config.Ip6_addr, "none") {
|
||||
for _, i := range strings.Split(jail.Config.Ip6_addr, ",") {
|
||||
for _, i := range strings.Split(jail.Config.Ip6_addr, ",") {
|
||||
if len(strings.Split(i, "|")) == 2 {
|
||||
iname := fmt.Sprintf("%s.%d", strings.Split(i, "|")[0], jail.JID)
|
||||
fmt.Printf("%s: ", iname)
|
||||
if !slices.Contains(vnetnames, iname) {
|
||||
vnetnames = append(vnetnames, iname)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
for _, iname := range vnetnames {
|
||||
fmt.Printf(" >%s: ", iname)
|
||||
_, err := executeCommand(fmt.Sprintf("ifconfig %s", iname))
|
||||
if err != nil {
|
||||
if strings.Contains(err.Error(), "does not exist") {
|
||||
fmt.Printf("OK\n")
|
||||
} else {
|
||||
fmt.Printf("ERR: %v\n", err)
|
||||
return err
|
||||
}
|
||||
} else {
|
||||
_, err := executeCommand(fmt.Sprintf("ifconfig %s destroy", iname))
|
||||
//_, err := executeScript(fmt.Sprintf("ifconfig %s destroy >/dev/null 2>&1", iname))
|
||||
if err != nil {
|
||||
fmt.Printf("ERR: %v\n", err)
|
||||
return err
|
||||
} else {
|
||||
fmt.Printf("OK\n")
|
||||
|
@ -1,7 +1,10 @@
|
||||
package cmd
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"sort"
|
||||
"time"
|
||||
"strings"
|
||||
)
|
||||
|
||||
const (
|
||||
@ -561,3 +564,90 @@ type DatastoreSort struct {
|
||||
AvailableDec datastoreLessFunc
|
||||
}
|
||||
|
||||
type Field struct {
|
||||
Name string
|
||||
MaxLen int
|
||||
Value string
|
||||
}
|
||||
|
||||
|
||||
func (j *Jail) PrintJSON(fields []string) ([]byte, error) {
|
||||
return j.PrintJSONWithUpper("", fields)
|
||||
}
|
||||
|
||||
func (j *Jail) PrintJSONWithUpper(upper string, fields []string) ([]byte, error) {
|
||||
var res []byte
|
||||
|
||||
if len(fields) < 1 {
|
||||
return res, nil
|
||||
}
|
||||
|
||||
if len(upper) > 0 {
|
||||
res = append(res, []byte(fmt.Sprintf("\"%s\": {", upper))...)
|
||||
} else {
|
||||
res = append(res, []byte("{")...)
|
||||
}
|
||||
|
||||
// Reorder fields so we got fields of a sub-structure adjacents
|
||||
sort.Strings(fields)
|
||||
|
||||
var ffname string
|
||||
offset := 0
|
||||
for i, _ := range fields {
|
||||
if i + offset >= len(fields) {
|
||||
break
|
||||
}
|
||||
// Is this struct in struct?
|
||||
if strings.Contains(fields[i+offset], ".") {
|
||||
// Count items in this struct
|
||||
var subfields []string
|
||||
var newUpper string
|
||||
for _, sf := range fields[i+offset:] {
|
||||
if strings.Split(sf, ".")[0] == strings.Split(fields[i+offset], ".")[0] {
|
||||
newUpper = strings.Split(sf, ".")[0]
|
||||
sub := strings.Join(strings.Split(string(sf), ".")[1:], ".")
|
||||
subfields = append(subfields, sub)
|
||||
}
|
||||
}
|
||||
out, err := j.PrintJSONWithUpper(newUpper, subfields)
|
||||
if err != nil {
|
||||
return []byte{}, err
|
||||
}
|
||||
res = append(res, out...)
|
||||
offset += len(subfields)-1
|
||||
if i + offset < len(fields) - 1 {
|
||||
res = append(res, []byte(",")...)
|
||||
}
|
||||
continue
|
||||
}
|
||||
|
||||
if len(upper) > 0 {
|
||||
ffname = fmt.Sprintf("%s.%s", upper, fields[i+offset])
|
||||
} else {
|
||||
ffname = fields[i+offset]
|
||||
}
|
||||
val, _, err := getStructFieldValue(j, ffname)
|
||||
if err != nil {
|
||||
return []byte{}, fmt.Errorf("Error accessing field \"%s\" : %v\n", fields[i+offset], err)
|
||||
}
|
||||
|
||||
res = append(res, []byte(fmt.Sprintf("\"%s\": ", fields[i+offset]))...)
|
||||
switch val.Interface().(type) {
|
||||
case string:
|
||||
res = append(res, []byte(fmt.Sprintf("\"%s\"", val.Interface().(string)))...)
|
||||
case int:
|
||||
res = append(res, []byte(fmt.Sprintf("%d", val.Interface().(int)))...)
|
||||
case bool:
|
||||
res = append(res, []byte(fmt.Sprintf("%t", val.Interface().(bool)))...)
|
||||
default:
|
||||
fmt.Printf("ERREUR dans Jail.PrintJSONWithUpper() : Type inconnu : %T\n", val.Interface())
|
||||
}
|
||||
if i + offset < len(fields) - 1 {
|
||||
res = append(res, []byte(",")...)
|
||||
}
|
||||
}
|
||||
|
||||
res = append(res, []byte("}")...)
|
||||
|
||||
return res, nil
|
||||
}
|
||||
|
33
cmd/utils.go
33
cmd/utils.go
@ -228,7 +228,7 @@ CreateBootEnv no
|
||||
"type": "jail",
|
||||
"used": "readonly",
|
||||
"vmemoryuse": "off",
|
||||
"vnet": 1,
|
||||
"vnet": 0,
|
||||
"vnet0_mac": "none",
|
||||
"vnet1_mac": "none",
|
||||
"vnet2_mac": "none",
|
||||
@ -709,10 +709,8 @@ func executeCommandInJail(jail *Jail, cmdline string) (string, error) {
|
||||
// else
|
||||
word = word + string(c)
|
||||
}
|
||||
|
||||
if gDebug {
|
||||
fmt.Printf("DEBUG: executeCommandInJail: prepare to execute \"%s\"\n", cmd)
|
||||
}
|
||||
|
||||
log.Debugf("executeCommandInJail: will execute \"%s\"\n", strings.Join(cmd, " "))
|
||||
|
||||
out, err := exec.Command(cmd[0], cmd[1:]...).CombinedOutput()
|
||||
|
||||
@ -751,30 +749,6 @@ func executeScript(script string) (string, error) {
|
||||
return string(out), err
|
||||
}
|
||||
|
||||
/*****************************************************************************
|
||||
*
|
||||
* Network related operations
|
||||
*
|
||||
*****************************************************************************/
|
||||
func getBridgeMembers(bridge string) ([]string, error) {
|
||||
var members []string
|
||||
cmd := fmt.Sprintf("/sbin/ifconfig %s", bridge)
|
||||
out, err := executeCommand(cmd)
|
||||
if err != nil {
|
||||
return members, errors.New(fmt.Sprintf("%v; command returned \"%s\"", err, out))
|
||||
}
|
||||
|
||||
for _, line := range strings.Split(out, "\n") {
|
||||
if strings.HasPrefix(strings.TrimLeft(line, " \t"), "member:") {
|
||||
m := strings.Split(strings.TrimLeft(strings.Split(line, ":")[1], " "), " ")[0]
|
||||
log.Debugf("%s is member of %s\n", m, bridge)
|
||||
members = append(members, m)
|
||||
}
|
||||
}
|
||||
return members, nil
|
||||
}
|
||||
|
||||
|
||||
/*****************************************************************************
|
||||
*
|
||||
* ZFS datasets/pools operations
|
||||
@ -1057,7 +1031,6 @@ func addRcKeyValue(rcconfpath string, key string, value string) error {
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
/*****************************************************************************
|
||||
* Parse an fstab file, returning an array of Mount
|
||||
*****************************************************************************/
|
||||
|
4
go.mod
4
go.mod
@ -1,10 +1,12 @@
|
||||
module gocage
|
||||
|
||||
go 1.17
|
||||
go 1.21
|
||||
|
||||
require (
|
||||
github.com/c-robinson/iplib v1.0.3
|
||||
github.com/c2h5oh/datasize v0.0.0-20220606134207-859f65c6625b
|
||||
github.com/gin-contrib/cors v1.7.2
|
||||
github.com/gin-gonic/gin v1.10.0
|
||||
github.com/google/shlex v0.0.0-20191202100458-e7afc7fbc510
|
||||
github.com/otiai10/copy v1.12.0
|
||||
github.com/sirupsen/logrus v1.8.1
|
||||
|
Reference in New Issue
Block a user