Marketplace publish service raw data

commands/marketplace_publish.go

@@ -4,7 +4,7 @@ import (
 	"fmt"
 
 	"github.com/mesg-foundation/core/commands/provider"
-	"github.com/mesg-foundation/core/service/importer"
+	"github.com/mesg-foundation/core/protobuf/coreapi"
 	"github.com/mesg-foundation/core/utils/pretty"
 	"github.com/mesg-foundation/core/utils/readme"
 	"github.com/spf13/cobra"
@@ -19,9 +19,8 @@ const (
 type marketplacePublishCmd struct {
 	baseMarketplaceCmd
 
-	path string
-	sid  string
-	hash string
+	path    string
+	service *coreapi.Service
 
 	e Executor
 }
@@ -48,15 +47,19 @@ func (c *marketplacePublishCmd) preRunE(cmd *cobra.Command, args []string) error
 	c.path = getFirstOrCurrentPath(args)
 
 	var err error
-	c.sid, c.hash, err = deployService(c.e, c.path, map[string]string{})
+	_, hash, err := deployService(c.e, c.path, map[string]string{})
 	if err != nil {
 		return err
 	}
-	fmt.Printf("%s Service deployed with sid %s and hash %s\n", pretty.SuccessSign, pretty.Success(c.sid), pretty.Success(c.hash))
+	c.service, err = c.e.ServiceByID(hash)
+	if err != nil {
+		return err
+	}
+	fmt.Printf("%s Service deployed with sid %s and hash %s\n", pretty.SuccessSign, pretty.Success(c.service.Definition.Sid), pretty.Success(c.service.Definition.Hash))
 
 	var confirmed bool
 	if err := survey.AskOne(&survey.Confirm{
-		Message: fmt.Sprintf("Are you sure to publish a new version of service %q from path %q using account %q?", c.sid, c.path, c.account),
+		Message: fmt.Sprintf("Are you sure to publish a new version of service %q from path %q using account %q?", c.service.Definition.Sid, c.path, c.account),
 	}, &confirmed, nil); err != nil {
 		return err
 	}
@@ -83,18 +86,14 @@ func (c *marketplacePublishCmd) runE(cmd *cobra.Command, args []string) error {
 	if err != nil {
 		return err
 	}
-	definition, err := importer.From(c.path)
-	if err != nil {
-		return err
-	}
 	readme, err := readme.Lookup(c.path)
 	if err != nil {
 		return err
 	}
 	pretty.Progress("Publishing service on the marketplace...", func() {
 		if tx, err = c.e.PreparePublishServiceVersion(provider.MarketplaceManifestServiceData{
-			Definition:  *definition,
-			Hash:        c.hash,
+			Definition:  c.service.Definition,
+			Hash:        c.service.Definition.Hash,
 			HashVersion: marketplaceServiceHashVersion,
 			Readme:      readme,
 			Deployment:  deployment,

commands/provider/marketplace_types.go

@@ -4,7 +4,7 @@ import (
 	"encoding/json"
 	"time"
 
-	"github.com/mesg-foundation/core/service/importer"
+	"github.com/mesg-foundation/core/protobuf/definition"
 )
 
 const (
@@ -55,11 +55,11 @@ type MarketplaceDeployedSource struct {
 
 // MarketplaceManifestServiceData is the data present to the manifest and sent to create a new service's version
 type MarketplaceManifestServiceData struct {
-	Definition  importer.ServiceDefinition `json:"definition"`
-	Readme      string                     `json:"readme,omitempty"`
-	Hash        string                     `json:"hash"`
-	HashVersion string                     `json:"hashVersion"`
-	Deployment  MarketplaceDeployedSource  `json:"deployment"`
+	Definition  *definition.Service       `json:"definition"`
+	Readme      string                    `json:"readme,omitempty"`
+	Hash        string                    `json:"hash"`
+	HashVersion string                    `json:"hashVersion"`
+	Deployment  MarketplaceDeployedSource `json:"deployment"`
 }
 
 // MarketplaceManifestData struct {

xxx-service/.dockerignore

@@ -0,0 +1 @@
+node_modules

xxx-service/.gitignore

@@ -0,0 +1 @@
+node_modules

xxx-service/Dockerfile

@@ -0,0 +1,6 @@
+FROM node:10.15
+WORKDIR /app
+COPY ./package* ./
+RUN npm install
+COPY . .
+CMD [ "node", "index.js" ]

xxx-service/index.js

@@ -0,0 +1,11 @@
+const mesg = require('mesg-js').service()
+
+mesg.listenTask({
+  taskX: require('./tasks/taskX')
+})
+  .on('error', (error) => console.error(error))
+
+mesg.emitEvent('started', { x: true })
+  .catch((error) => console.error(error))
+
+console.log('gnarf gnarf')

xxx-service/mesg.yml

@@ -0,0 +1,24 @@
+name: myservice
+sid: myservice
+description: "Description of my service"
+tasks:
+  taskX:
+    inputs:
+      foo:
+        type: String
+      bar:
+        type: String
+    outputs:
+      success:
+        data:
+          message:
+            type: String
+      error:
+        data:
+          error:
+            type: String
+events:
+  started:
+    data:
+      x:
+        type: Boolean

xxx-service/package.json

@@ -0,0 +1,8 @@
+{
+  "name": "your-package-name",
+  "version": "1.0.0",
+  "main": "index.js",
+  "dependencies": {
+    "mesg-js": "^2.0.0"
+  }
+}

xxx-service/tasks/taskX.js

@@ -0,0 +1,7 @@
+module.exports = ({ foo, bar }, { success, error }) => {
+  if (foo === 'hello' && bar === 'world') {
+    success({ message: 'Hello world is valid' })
+  } else {
+    error({ error: 'invalid inputs' })
+  }
+}