Merge pull request #725 from mesg-foundation/feature/deploy-core-serv…

…ice-from-tar

Deploy core services from tar

config/config.go

@@ -21,6 +21,12 @@ var (
 	once     sync.Once
 )
 
+// ServiceConfig contains information related to services that the config knows about
+type ServiceConfig struct {
+	URL string
+	Env map[string]string
+}
+
 // Config contains all the configuration needed.
 type Config struct {
 	Server struct {
@@ -47,6 +53,10 @@ type Config struct {
 		}
 	}
 
+	Service struct {
+		Foo ServiceConfig
+	}
+
 	Docker struct {
 		Socket string
 		Core   struct {
@@ -74,6 +84,7 @@ func New() (*Config, error) {
 	c.Core.Database.ExecutionRelativePath = filepath.Join("database", "executions")
 	c.Docker.Core.Path = "/mesg"
 	c.Docker.Socket = "/var/run/docker.sock"
+	c.Service.Foo = ServiceConfig{"https://github.com/mesg-foundation/service-ethereum-erc20", map[string]string{}}
 	return &c, nil
 }
 
@@ -123,6 +134,13 @@ func (c *Config) Validate() error {
 	return nil
 }
 
+// Services returns all services that the configuration package is aware of
+func (c *Config) Services() []ServiceConfig {
+	return []ServiceConfig{
+		c.Service.Foo,
+	}
+}
+
 // DaemonEnv returns the needed environmental variable for the Daemon.
 func (c *Config) DaemonEnv() map[string]string {
 	return map[string]string{

core/main.go

@@ -33,9 +33,32 @@ func initGRPCServer(c *config.Config) (*grpc.Server, error) {
 		return nil, err
 	}
 
+	// init system services.
+	if err := deployCoreServices(c, a); err != nil {
+		return nil, err
+	}
+
 	return grpc.New(c.Server.Address, a), nil
 }
 
+func deployCoreServices(c *config.Config, api *api.API) error {
+	for _, service := range c.Services() {
+		logrus.Infof("Deploy service from %s", service.URL)
+		s, valid, err := api.DeployServiceFromURL(service.URL, service.Env)
+		if valid != nil {
+			return valid
+		}
+		if err != nil {
+			return err
+		}
+		logrus.Infof("Service %s deployed", s.Name)
+		if err := api.StartService(s.Sid); err != nil {
+			return err
+		}
+	}
+	return nil
+}
+
 func main() {
 	// init configs.
 	c, err := config.Global()