mirror of
https://github.com/kairos-io/provider-kairos.git
synced 2025-08-17 23:16:39 +00:00
1d074c4fda
With the upgrade of the cli pkg, making flags required is very simple, it just needs an attribute `required: true` Fixes https://github.com/kairos-io/kairos/issues/375 ⚠️ breaking UX change > In v2 flags must come before args. This is more POSIX-compliant. You may need to update scripts, user documentation, etc. This means that ``` provier-kairos command ARG FLAG ``` is no longer valid, but I still think the change is worth it because like the documentation says, the CLI will be more POSIX-compliant Signed-off-by: Mauro Morales <mauro.morales@spectrocloud.com> Signed-off-by: GitHub <noreply@github.com> Co-authored-by: ci-robbot [bot] <105103991+ci-robbot@users.noreply.github.com> Co-authored-by: mudler <mudler@users.noreply.github.com>
118 lines
2.9 KiB
Go
118 lines
2.9 KiB
Go
package cli
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"net"
|
|
"time"
|
|
|
|
"github.com/ipfs/go-log"
|
|
"github.com/kairos-io/kairos/pkg/utils"
|
|
"github.com/mudler/edgevpn/api"
|
|
"github.com/mudler/edgevpn/pkg/logger"
|
|
"github.com/mudler/edgevpn/pkg/node"
|
|
"github.com/mudler/edgevpn/pkg/services"
|
|
"github.com/mudler/edgevpn/pkg/vpn"
|
|
qr "github.com/mudler/go-nodepair/qrcode"
|
|
"github.com/urfave/cli/v2"
|
|
)
|
|
|
|
// bridge is just starting a VPN with edgevpn to the given network token.
|
|
func bridge(c *cli.Context) error {
|
|
qrCodePath := ""
|
|
fromQRCode := false
|
|
var serviceUUID, sshPassword string
|
|
|
|
if c.String("qr-code-image") != "" {
|
|
qrCodePath = c.String("qr-code-image")
|
|
fromQRCode = true
|
|
}
|
|
if c.Bool("qr-code-snapshot") {
|
|
qrCodePath = ""
|
|
fromQRCode = true
|
|
}
|
|
|
|
token := c.String("network-token")
|
|
|
|
if fromQRCode {
|
|
recoveryToken := qr.Reader(qrCodePath)
|
|
data := utils.DecodeRecoveryToken(recoveryToken)
|
|
if len(data) != 3 {
|
|
fmt.Println("Token not decoded correctly")
|
|
return fmt.Errorf("invalid token")
|
|
}
|
|
token = data[0]
|
|
serviceUUID = data[1]
|
|
sshPassword = data[2]
|
|
if serviceUUID == "" || sshPassword == "" || token == "" {
|
|
return fmt.Errorf("decoded invalid values")
|
|
}
|
|
}
|
|
|
|
ctx := context.Background()
|
|
|
|
nc := networkConfig(token, c.String("address"), c.String("log-level"), "kairos0")
|
|
|
|
lvl, err := log.LevelFromString(nc.LogLevel)
|
|
if err != nil {
|
|
lvl = log.LevelError
|
|
}
|
|
llger := logger.New(lvl)
|
|
|
|
o, vpnOpts, err := nc.ToOpts(llger)
|
|
if err != nil {
|
|
llger.Fatal(err.Error())
|
|
}
|
|
|
|
opts := []node.Option{}
|
|
|
|
if !fromQRCode {
|
|
// We just connect to a VPN token
|
|
o = append(o,
|
|
services.Alive(
|
|
time.Duration(20)*time.Second,
|
|
time.Duration(10)*time.Second,
|
|
time.Duration(10)*time.Second)...)
|
|
|
|
if c.Bool("dhcp") {
|
|
// Adds DHCP server
|
|
address, _, err := net.ParseCIDR(c.String("address"))
|
|
if err != nil {
|
|
return err
|
|
}
|
|
nodeOpts, vO := vpn.DHCP(llger, 15*time.Minute, c.String("lease-dir"), address.String())
|
|
o = append(o, nodeOpts...)
|
|
vpnOpts = append(vpnOpts, vO...)
|
|
}
|
|
|
|
opts, err = vpn.Register(vpnOpts...)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
} else {
|
|
// We hook into a service
|
|
llger.Info("Connecting to service", serviceUUID)
|
|
llger.Info("SSH access password is", sshPassword)
|
|
llger.Info("SSH server reachable at 127.0.0.1:2200")
|
|
opts = append(opts, node.WithNetworkService(
|
|
services.ConnectNetworkService(
|
|
30*time.Second,
|
|
serviceUUID,
|
|
"127.0.0.1:2200",
|
|
),
|
|
))
|
|
llger.Info("To connect, keep this terminal open and run in another terminal 'ssh 127.0.0.1 -p 2200' the password is ", sshPassword)
|
|
llger.Info("Note: the connection might not be available instantly and first attempts will likely fail.")
|
|
llger.Info(" Few attempts might be required before establishing a tunnel to the host.")
|
|
}
|
|
|
|
e, err := node.New(append(o, opts...)...)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
go api.API(ctx, c.String("api"), 5*time.Second, 20*time.Second, e, nil, false) //nolint:errcheck
|
|
|
|
return e.Start(ctx)
|
|
}
|