Decentralization of the processes

core/main.go

@@ -10,7 +10,6 @@ import (
 	"github.com/mesg-foundation/engine/config"
 	"github.com/mesg-foundation/engine/container"
 	"github.com/mesg-foundation/engine/cosmos"
-	"github.com/mesg-foundation/engine/database"
 	"github.com/mesg-foundation/engine/hash"
 	"github.com/mesg-foundation/engine/logger"
 	"github.com/mesg-foundation/engine/orchestrator"
@@ -28,11 +27,6 @@ import (
 	db "github.com/tendermint/tm-db"
 )
 
-func initDatabases(cfg *config.Config) (*database.LevelDBProcessDB, error) {
-	// init process db.
-	return database.NewProcessDB(filepath.Join(cfg.Path, cfg.Database.ProcessRelativePath))
-}
-
 func stopRunningServices(sdk *enginesdk.SDK, cfg *config.Config, address string) error {
 	runners, err := sdk.Runner.List(&runnersdk.Filter{Address: address})
 	if err != nil {
@@ -125,12 +119,6 @@ func main() {
 	// init logger.
 	logger.Init(cfg.Log.Format, cfg.Log.Level, cfg.Log.ForceColors)
 
-	// init databases
-	processDB, err := initDatabases(cfg)
-	if err != nil {
-		logrus.WithField("module", "main").Fatalln(err)
-	}
-
 	// init container.
 	container, err := container.New(cfg.Name)
 	if err != nil {
@@ -185,7 +173,7 @@ func main() {
 	client := cosmos.NewClient(node, kb, genesis.ChainID)
 
 	// init sdk
-	sdk := enginesdk.New(client, kb, processDB, container, cfg.Name, strconv.Itoa(port), cfg.IpfsEndpoint)
+	sdk := enginesdk.New(client, kb, container, cfg.Name, strconv.Itoa(port), cfg.IpfsEndpoint)
 
 	// start tendermint node
 	logrus.WithField("module", "main").WithField("seeds", cfg.Tendermint.Config.P2P.Seeds).Info("starting tendermint node")

e2e/api_test.go

@@ -48,7 +48,6 @@ func TestAPI(t *testing.T) {
 	// basic tests
 	t.Run("account", testAccount)
 	t.Run("service", testService)
-	t.Run("ownership", testOwnership)
 	t.Run("runner", testRunner)
 	t.Run("process", testProcess)
 	t.Run("instance", testInstance)

e2e/process_test.go

@@ -5,6 +5,7 @@ import (
 	"testing"
 
 	"github.com/mesg-foundation/engine/hash"
+	"github.com/mesg-foundation/engine/ownership"
 	"github.com/mesg-foundation/engine/process"
 	pb "github.com/mesg-foundation/engine/protobuf/api"
 	"github.com/stretchr/testify/require"
@@ -13,41 +14,45 @@ import (
 var testProcessHash hash.Hash
 
 func testProcess(t *testing.T) {
-	req := &pb.CreateProcessRequest{
-		Name: "test-process",
-		Nodes: []*process.Process_Node{
-			{
-				Key: "n0",
-				Type: &process.Process_Node_Event_{
-					Event: &process.Process_Node_Event{
-						InstanceHash: testInstanceHash,
-						EventKey:     "test_service_ready",
+	var (
+		processHash hash.Hash
+		req         = &pb.CreateProcessRequest{
+			Name: "test-process",
+			Nodes: []*process.Process_Node{
+				{
+					Key: "n0",
+					Type: &process.Process_Node_Event_{
+						Event: &process.Process_Node_Event{
+							InstanceHash: testInstanceHash,
+							EventKey:     "test_service_ready",
+						},
 					},
 				},
-			},
-			{
-				Key: "n1",
-				Type: &process.Process_Node_Task_{
-					Task: &process.Process_Node_Task{
-						InstanceHash: testInstanceHash,
-						TaskKey:      "test_service_ready",
+				{
+					Key: "n1",
+					Type: &process.Process_Node_Task_{
+						Task: &process.Process_Node_Task{
+							InstanceHash: testInstanceHash,
+							TaskKey:      "test_service_ready",
+						},
 					},
 				},
 			},
-		},
-		Edges: []*process.Process_Edge{
-			{
-				Src: "n0",
-				Dst: "n1",
+			Edges: []*process.Process_Edge{
+				{
+					Src: "n0",
+					Dst: "n1",
+				},
 			},
-		},
-	}
+		}
+	)
 
 	t.Run("create", func(t *testing.T) {
 		resp, err := client.ProcessClient.Create(context.Background(), req)
 		require.NoError(t, err)
 		testProcessHash = resp.Hash
 	})
+
 	t.Run("get", func(t *testing.T) {
 		p, err := client.ProcessClient.Get(context.Background(), &pb.GetProcessRequest{Hash: testProcessHash})
 		require.NoError(t, err)
@@ -57,6 +62,20 @@ func testProcess(t *testing.T) {
 			Nodes: req.Nodes,
 			Edges: req.Edges,
 		}))
+		processHash = p.Hash
+	})
+
+	t.Run("check ownership creation", func(t *testing.T) {
+		ownerships, err := client.OwnershipClient.List(context.Background(), &pb.ListOwnershipRequest{})
+		require.NoError(t, err)
+
+		acc, err := client.AccountClient.Get(context.Background(), &pb.GetAccountRequest{Name: "engine"})
+		require.NoError(t, err)
+
+		require.Len(t, ownerships.Ownerships, 2)
+		require.Equal(t, acc.Address, ownerships.Ownerships[0].Owner)
+		require.Equal(t, ownership.Ownership_Process, ownerships.Ownerships[0].Resource)
+		require.Equal(t, processHash, ownerships.Ownerships[0].ResourceHash)
 	})
 
 	t.Run("list", func(t *testing.T) {
@@ -69,4 +88,10 @@ func testProcess(t *testing.T) {
 		_, err := client.ProcessClient.Delete(context.Background(), &pb.DeleteProcessRequest{Hash: testProcessHash})
 		require.NoError(t, err)
 	})
+
+	t.Run("check ownership deletion", func(t *testing.T) {
+		ownerships, err := client.OwnershipClient.List(context.Background(), &pb.ListOwnershipRequest{})
+		require.NoError(t, err)
+		require.Len(t, ownerships.Ownerships, 1)
+	})
 }

e2e/service_test.go

@@ -5,6 +5,7 @@ import (
 	"testing"
 
 	"github.com/mesg-foundation/engine/hash"
+	"github.com/mesg-foundation/engine/ownership"
 	pb "github.com/mesg-foundation/engine/protobuf/api"
 	"github.com/stretchr/testify/require"
 )
@@ -47,4 +48,17 @@ func testService(t *testing.T) {
 		require.NoError(t, err)
 		require.Equal(t, testServiceHash, resp.Hash)
 	})
+
+	t.Run("check ownership creation", func(t *testing.T) {
+		ownerships, err := client.OwnershipClient.List(context.Background(), &pb.ListOwnershipRequest{})
+		require.NoError(t, err)
+
+		acc, err := client.AccountClient.Get(context.Background(), &pb.GetAccountRequest{Name: "engine"})
+		require.NoError(t, err)
+
+		require.Len(t, ownerships.Ownerships, 1)
+		require.Equal(t, acc.Address, ownerships.Ownerships[0].Owner)
+		require.Equal(t, ownership.Ownership_Service, ownerships.Ownerships[0].Resource)
+		require.Equal(t, testServiceHash, ownerships.Ownerships[0].ResourceHash)
+	})
 }