mirror of
https://github.com/openziti/ziti.git
synced 2026-10-13 15:51:21 +00:00
Paul Lorenz
37 lines
975 B
Go
37 lines
975 B
Go
package actions
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
"github.com/openziti/fablab/kernel/lib"
|
|
"github.com/openziti/fablab/kernel/model"
|
|
"github.com/sirupsen/logrus"
|
|
)
|
|
|
|
type echoServerStart struct {
|
|
componentSpec string
|
|
}
|
|
|
|
func StartEchoServers(componentSpec string) model.Action {
|
|
return &echoServerStart{
|
|
componentSpec: componentSpec,
|
|
}
|
|
}
|
|
|
|
func (esi *echoServerStart) Execute(m *model.Model) error {
|
|
return m.ForEachComponent(esi.componentSpec, 1, func(c *model.Component) error {
|
|
ssh := lib.NewSshConfigFactory(c.GetHost())
|
|
remoteConfigFile := "/home/ubuntu/fablab/cfg/" + c.PublicIdentity + ".json"
|
|
|
|
echoServerCmd := fmt.Sprintf("nohup /home/%s/fablab/bin/ziti-echo server --identity %s > /home/ubuntu/logs/ziti-echo.log 2>&1 &",
|
|
ssh.User(), remoteConfigFile)
|
|
|
|
if output, err := lib.RemoteExec(ssh, echoServerCmd); err != nil {
|
|
logrus.Errorf("error starting echo server [%s] (%v)", output, err)
|
|
return err
|
|
}
|
|
logrus.Info("echo server started")
|
|
return nil
|
|
})
|
|
}
|