diff --git a/src/main/java/fr/istic/grpc/todo/TodoServeur.java b/src/main/java/fr/istic/grpc/todo/TodoServeur.java index 611205a..5391990 100644 --- a/src/main/java/fr/istic/grpc/todo/TodoServeur.java +++ b/src/main/java/fr/istic/grpc/todo/TodoServeur.java @@ -4,6 +4,12 @@ import io.grpc.*; import java.io.*; -public class TodoServeur { +import fr.istic.grpc.echo.EchoService; +public class TodoServeur { + public static void main(String[] args) throws IOException, InterruptedException { + Server server = ServerBuilder.forPort(8080).addService(new TodoServiceImpl()).build().start(); + System.out.println("Serveur started"); + server.awaitTermination(); + } } diff --git a/src/main/java/fr/istic/grpc/todo/TodoServiceImpl.java b/src/main/java/fr/istic/grpc/todo/TodoServiceImpl.java index 3d5478c..c1d3103 100644 --- a/src/main/java/fr/istic/grpc/todo/TodoServiceImpl.java +++ b/src/main/java/fr/istic/grpc/todo/TodoServiceImpl.java @@ -2,6 +2,8 @@ package fr.istic.grpc.todo; import java.util.concurrent.*; import java.util.concurrent.atomic.*; +import io.grpc.stub.*; +import io.grpc.stub.StreamObserver; public class TodoServiceImpl extends TodoServiceGrpc.TodoServiceImplBase { @@ -13,10 +15,11 @@ public class TodoServiceImpl extends TodoServiceGrpc.TodoServiceImplBase { } - /* + @Override public void createTask(Todo.CreateTaskRequest request, StreamObserver responseObserver) { // Créer une tâche en générant un identifiant + } @Override @@ -27,8 +30,8 @@ public class TodoServiceImpl extends TodoServiceGrpc.TodoServiceImplBase { @Override public void deleteTask(Todo.DeleteTaskRequest request, StreamObserver responseObserver) { // si la tâche existe, on efface, sinon on indique que l'opération est un echec + this.tasks.remove(request.id); } - */ }