WIP: retrieve simple entity

caosdb-proto @ dd9abe34

-Subproject commit b0cade5e02daff99eaa46e1201f2786ac873114b
+Subproject commit dd9abe3499367c4eded4774ade1acbc90ef048b3

pom.xml

@@ -25,7 +25,7 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>org.caosdb</groupId>
   <artifactId>caosdb-server</artifactId>
-  <version>0.5.0-GRPC003</version>
+  <version>0.5.0-GRPC004</version>
   <packaging>jar</packaging>
   <name>CaosDB Server</name>
   <scm>

src/main/java/org/caosdb/server/grpc/EntityTransactionServiceImpl.java

+package org.caosdb.server.grpc;
+
+import io.grpc.stub.StreamObserver;
+import org.caosdb.api.entity.v1alpha1.Entity;
+import org.caosdb.api.entity.v1alpha1.EntityTransactionServiceGrpc.EntityTransactionServiceImplBase;
+import org.caosdb.api.entity.v1alpha1.RetrieveRequest;
+import org.caosdb.api.entity.v1alpha1.RetrieveResponse;
+
+public class EntityTransactionServiceImpl extends EntityTransactionServiceImplBase {
+
+  @Override
+  public void retrieve(
+      final RetrieveRequest request, final StreamObserver<RetrieveResponse> responseObserver) {
+    final Entity entity = Entity.newBuilder().setDescription("This is an entity").build();
+    final RetrieveResponse response = RetrieveResponse.newBuilder().setEntity(entity).build();
+
+    responseObserver.onNext(response);
+    responseObserver.onCompleted();
+  }
+}

src/main/java/org/caosdb/server/grpc/GRPCServer.java

@@ -114,10 +114,12 @@ public class GRPCServer {
   private List<ServerServiceDefinition> getEnabledServices() {
     final List<ServerServiceDefinition> services = new LinkedList<>();
 
-    final GeneralInfoServiceImpl gIS = new GeneralInfoServiceImpl();
-    final ServerServiceDefinition serviceDefinition =
-        ServerInterceptors.intercept(gIS, authInterceptor);
-    services.add(serviceDefinition);
+    final GeneralInfoServiceImpl generalInfoService = new GeneralInfoServiceImpl();
+    services.add(ServerInterceptors.intercept(generalInfoService, authInterceptor));
+
+    final EntityTransactionServiceImpl entityTransactionService =
+        new EntityTransactionServiceImpl();
+    services.add(ServerInterceptors.intercept(entityTransactionService, authInterceptor));
 
     return services;
   }