kairos-agent/internal/agent/agent.go

package agent

import (
	"fmt"
	"io/ioutil"
	"os"
	"path/filepath"

	"github.com/c3os-io/c3os/internal/bus"
	machine "github.com/c3os-io/c3os/internal/machine"
	events "github.com/c3os-io/c3os/pkg/bus"
	config "github.com/c3os-io/c3os/pkg/config"
	"github.com/nxadm/tail"
)

// setup needs edgevpn and k3s installed locally
// (both k3s and k3s-agent systemd services)
func Run(apiAddress string, dir []string, force bool) error {

	os.MkdirAll("/usr/local/.c3os", 0600)

	// Reads config
	c, err := config.Scan(config.Directories(dir...))
	if err != nil {
		return err
	}

	os.MkdirAll("/var/log/c3os", 0600)
	fileName := filepath.Join("/var/log/c3os", "agent-provider.log")
	err = ioutil.WriteFile(fileName, []byte{}, os.ModePerm)
	if err != nil {
		return err
	}

	t, err := tail.TailFile(fileName, tail.Config{Follow: true})
	if err != nil {
		return err
	}

	go func() {
		for line := range t.Lines {
			fmt.Println(line.Text)
		}
	}()

	if !machine.SentinelExist("bundles") {
		opts := c.Bundles.Options()
		err := machine.RunBundles(opts...)
		if !c.IgnoreBundleErrors && err != nil {
			return err
		}

		machine.CreateSentinel("bundles")
	}

	_, err = bus.Manager.Publish(events.EventBootstrap, events.BootstrapPayload{APIAddress: apiAddress, Config: c.String(), Logfile: fileName})
	return err
}