Add core api

CHANGELOG.md

@@ -19,6 +19,7 @@
 - (#183) Add a `configuration` attribute in the `mesg.yml` file to accept docker configuration for your service
 - (#187) Stop all services when the MESG Core stops
 - (#190) Possibility to `test` or `deploy` a service from a git or GitHub url
+- (#235) Add `ListServices` and `GetService` APIs
 
 #### Removed
 

api/core/api.proto

@@ -13,6 +13,8 @@ service Core {
   rpc StopService (StopServiceRequest) returns (StopServiceReply) {}
   rpc DeployService (DeployServiceRequest) returns (DeployServiceReply) {}
   rpc DeleteService (DeleteServiceRequest) returns (DeleteServiceReply) {}
+  rpc ListServices (ListServicesRequest) returns (ListServicesReply) {}
+  rpc GetService (GetServiceRequest) returns (GetServiceReply) {}
 }
 
 message ListenEventRequest {
@@ -75,4 +77,19 @@ message DeleteServiceRequest {
 }
 
 message DeleteServiceReply {
+}
+
+message ListServicesRequest {
+}
+
+message ListServicesReply {
+  repeated service.Service services = 1;
+}
+
+message GetServiceRequest {
+  string serviceID = 1;
+}
+
+message GetServiceReply {
+  service.Service service = 1;
 }

api/core/get_service.go

@@ -0,0 +1,18 @@
+package core
+
+import (
+	"github.com/mesg-foundation/core/database/services"
+	"golang.org/x/net/context"
+)
+
+// GetService fetch a service in the db and return ot
+func (s *Server) GetService(ctx context.Context, request *GetServiceRequest) (reply *GetServiceReply, err error) {
+	service, err := services.Get(request.ServiceID)
+	if err != nil {
+		return
+	}
+	reply = &GetServiceReply{
+		Service: &service,
+	}
+	return
+}

api/core/get_service_test.go

@@ -0,0 +1,26 @@
+package core
+
+import (
+	"context"
+	"testing"
+
+	"github.com/mesg-foundation/core/database/services"
+
+	"github.com/mesg-foundation/core/service"
+	"github.com/stvp/assert"
+)
+
+var servergetservice = new(Server)
+
+func TestGetService(t *testing.T) {
+	hash, _ := services.Save(&service.Service{
+		Name: "TestGetService",
+	})
+	defer services.Delete(hash)
+	reply, err := servergetservice.GetService(context.Background(), &GetServiceRequest{
+		ServiceID: hash,
+	})
+	assert.Nil(t, err)
+	assert.NotNil(t, reply)
+	assert.Equal(t, reply.Service.Name, "TestGetService")
+}

api/core/list_services.go

@@ -0,0 +1,18 @@
+package core
+
+import (
+	"github.com/mesg-foundation/core/database/services"
+	"golang.org/x/net/context"
+)
+
+// ListServices return all services from the database
+func (s *Server) ListServices(ctx context.Context, request *ListServicesRequest) (reply *ListServicesReply, err error) {
+	services, err := services.All()
+	if err != nil {
+		return
+	}
+	reply = &ListServicesReply{
+		Services: services,
+	}
+	return
+}

api/core/list_services_test.go

@@ -0,0 +1,18 @@
+package core
+
+import (
+	"context"
+	"testing"
+
+	"github.com/mesg-foundation/core/database/services"
+	"github.com/stvp/assert"
+)
+
+var serverlistservices = new(Server)
+
+func TestListServices(t *testing.T) {
+	servicesFromAPI, err := serverlistservices.ListServices(context.Background(), &ListServicesRequest{})
+	servicesFromDB, _ := services.All()
+	assert.Nil(t, err)
+	assert.Equal(t, len(servicesFromAPI.Services), len(servicesFromDB))
+}