Skip to content
Snippets Groups Projects
Verified Commit af8c7f8b authored by Timm Fitschen's avatar Timm Fitschen
Browse files

WIP

parent c6445cd9
No related branches found
No related tags found
2 merge requests!44Release 0.6,!43Merge f-GRPC-main to dev
package org.caosdb.server.grpc; package org.caosdb.server.grpc;
import io.grpc.stub.StreamObserver; import java.util.UUID;
import org.apache.shiro.SecurityUtils;
import org.caosdb.grpc.Entity; import org.caosdb.grpc.Entity;
import org.caosdb.grpc.EntityTransactionServiceGrpc.EntityTransactionServiceImplBase; import org.caosdb.grpc.EntityTransactionServiceGrpc.EntityTransactionServiceImplBase;
import org.caosdb.server.entity.EntityInterface;
import org.caosdb.server.entity.container.RetrieveContainer;
import org.caosdb.server.transaction.Retrieve;
import org.caosdb.server.utils.EntityStatus;
import io.grpc.stub.StreamObserver;
public class EntityTransactionImpl extends EntityTransactionServiceImplBase { public class EntityTransactionImpl extends EntityTransactionServiceImplBase {
@Override @Override
public void retrieve(Entity request, StreamObserver<Entity> responseObserver) { public void retrieve(Entity request, StreamObserver<Entity> responseObserver) {
Entity response = String requested_entity_id = request.getEid();
Entity.newBuilder(request)
.setName("EntityName") RetrieveContainer container = new RetrieveContainer(SecurityUtils.getSubject(), System.currentTimeMillis(), UUID.randomUUID().toString(), null);
.setDescription("EntityDescription") container.add(Integer.parseInt(requested_entity_id));
.build(); Retrieve retrieve = new Retrieve(container);
try {
retrieve.execute();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
EntityInterface retrieved_entity = retrieve.getContainer().get(0);
Entity response;
if (retrieved_entity.getEntityStatus() == EntityStatus.VALID) {
response =
Entity.newBuilder(request)
.setName(retrieved_entity.getName())
.setDescription(retrieved_entity.getDescription())
.build();
} else {
response = Entity.newBuilder(request).setDescription("DOES NOT EXIST").build();
}
responseObserver.onNext(response); responseObserver.onNext(response);
responseObserver.onCompleted(); responseObserver.onCompleted();
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment