Stop instance

sdk/instance/start.go

@@ -50,7 +50,7 @@ func (i *Instance) start(inst *instance.Instance) (serviceIDs []string, err erro
 				"mesg.service": srv.Name,
 				"mesg.hash":    inst.Hash,
 				"mesg.sid":     srv.Sid,
-				"mesg.core":    conf.Name,
+				"mesg.engine":  conf.Name,
 			},
 			Image:   d.Image,
 			Args:    d.Args,

sdk/instance/stop.go

@@ -1,10 +1,42 @@
 package instancesdk
 
 import (
+	"sync"
+
 	"github.com/mesg-foundation/core/instance"
+	"github.com/mesg-foundation/core/service"
+	"github.com/mesg-foundation/core/x/xerrors"
 )
 
 // Stop stops an instance.
 func (i *Instance) stop(inst *instance.Instance) error {
-	return nil
+	srv, err := i.serviceDB.Get(inst.ServiceHash)
+	if err != nil {
+		return err
+	}
+
+	var (
+		wg         sync.WaitGroup
+		errs       xerrors.SyncErrors
+		sNamespace = instanceNamespace(inst.Hash)
+	)
+	for _, d := range append([]*service.Dependency{srv.Configuration}, srv.Dependencies...) {
+		// Service.Configuration can be nil so, here is a check for it.
+		if d == nil {
+			continue
+		}
+		wg.Add(1)
+		go func(namespace []string) {
+			defer wg.Done()
+			if err := i.container.StopService(namespace); err != nil {
+				errs.Append(err)
+			}
+		}(dependencyNamespace(sNamespace, d.Key))
+	}
+	wg.Wait()
+	if err := errs.ErrorOrNil(); err != nil {
+		return err
+	}
+
+	return i.container.DeleteNetwork(sNamespace)
 }