From e9c518ce403405443a9c8c6377226bfa82a6337a Mon Sep 17 00:00:00 2001
From: Vu Tuan Minh <tuan-minh.vu@etudiant.univ-rennes.fr>
Date: Tue, 1 Apr 2025 16:18:51 +0200
Subject: [PATCH] push

---
 src/main/java/fr/istic/grpc/echo/EchoClient.java  |  3 ++-
 src/main/java/fr/istic/grpc/echo/EchoServeur.java | 11 ++++-------
 src/main/java/fr/istic/grpc/echo/EchoService.java |  7 ++++++-
 3 files changed, 12 insertions(+), 9 deletions(-)

diff --git a/src/main/java/fr/istic/grpc/echo/EchoClient.java b/src/main/java/fr/istic/grpc/echo/EchoClient.java
index 1f3d795..f3f7940 100644
--- a/src/main/java/fr/istic/grpc/echo/EchoClient.java
+++ b/src/main/java/fr/istic/grpc/echo/EchoClient.java
@@ -2,9 +2,10 @@ package fr.istic.grpc.echo;
 
 import com.google.rpc.context.AttributeContext.*;
 import fr.istic.grpc.echo.Echo.*;
-import fr.istic.grpc.echo.EchoServiceGrpc.*;
+
 import io.grpc.*;
 
+
 public class EchoClient {
 
     public static void main(String[] args) throws Exception {
diff --git a/src/main/java/fr/istic/grpc/echo/EchoServeur.java b/src/main/java/fr/istic/grpc/echo/EchoServeur.java
index 5cf9d10..75f004b 100644
--- a/src/main/java/fr/istic/grpc/echo/EchoServeur.java
+++ b/src/main/java/fr/istic/grpc/echo/EchoServeur.java
@@ -1,17 +1,14 @@
 package fr.istic.grpc.echo;
 
-import fr.istic.grpc.echo.Echo.MessageReceive;
-import fr.istic.grpc.echo.Echo.MessageSent;
 import fr.istic.grpc.todo.*;
 import io.grpc.*;
-import io.grpc.stub.StreamObserver;
 
 import java.io.*;
 
 public class EchoServeur {
-    public void echo(MessageSent min, StreamObserver<MessageReceive> responseObserver) {
-        MessageReceive reply = MessageReceive.newBuilder().setMessage(min.getMessage().toUpperCase()).build();
-        responseObserver.onNext(reply);
-        responseObserver.onCompleted();
+    public static void main(String[] args) throws IOException, InterruptedException {
+        Server server = ServerBuilder.forPort(8080).addService(new EchoService()).build().start();
+        System.out.println("Serveur started");
+        server.awaitTermination();
     }
 }
diff --git a/src/main/java/fr/istic/grpc/echo/EchoService.java b/src/main/java/fr/istic/grpc/echo/EchoService.java
index 4a38622..181b627 100644
--- a/src/main/java/fr/istic/grpc/echo/EchoService.java
+++ b/src/main/java/fr/istic/grpc/echo/EchoService.java
@@ -6,5 +6,10 @@ import fr.istic.grpc.echo.EchoServiceGrpc.*;
 import io.grpc.stub.*;
 
 public class EchoService extends EchoServiceImplBase {
-
+    public void echo(MessageSent min, StreamObserver<MessageReceive> responseObserver) {
+        MessageReceive reply = MessageReceive.newBuilder().setMessage(min.getMessage().toUpperCase()).build();
+        responseObserver.onNext(reply);
+        responseObserver.onCompleted();
+    }
 }
+