test: add mdtp connect test (#8)

Signed-off-by: ZhangJian He <[email protected]>

Author: ZhangJian He

.github/workflows/java_unit_tests.yml

@@ -18,7 +18,7 @@ jobs:
           java-version: '17'
           distribution: 'temurin'
       - name: unit tests
-        run: mvn -B clean test
+        run: mvn -B clean test; mvn -B validate
       - name: Upload coverage to Codecov
         uses: codecov/codecov-action@v4
         env:

mdtp-server/pom.xml

@@ -17,6 +17,11 @@
             <artifactId>mdtp-common</artifactId>
             <version>${project.version}</version>
         </dependency>
+        <dependency>
+            <groupId>io.github.protocol-laboratory</groupId>
+            <artifactId>mdtp-client</artifactId>
+            <version>${project.version}</version>
+        </dependency>
         <dependency>
             <groupId>io.netty</groupId>
             <artifactId>netty-handler</artifactId>

mdtp-server/src/main/java/io/github/protocol/mdtp/server/MdtpServer.java

@@ -1,6 +1,7 @@
 package io.github.protocol.mdtp.server;
 
 import io.netty.bootstrap.ServerBootstrap;
+import io.netty.channel.Channel;
 import io.netty.channel.ChannelFuture;
 import io.netty.channel.ChannelInitializer;
 import io.netty.channel.EventLoopGroup;
@@ -21,6 +22,8 @@ public class MdtpServer implements Closeable {
 
     private EventLoopGroup ioGroup;
 
+    private Channel channel;
+
     public MdtpServer(MdtpServerConfig config) {
         this.config = config;
     }
@@ -44,13 +47,21 @@ protected void initChannel(SocketChannel socketChannel) throws Exception {
         });
         ChannelFuture channelFuture = serverBootstrap.bind().sync();
         if (channelFuture.isSuccess()) {
+            this.channel = channelFuture.channel();
             log.info("mdtp server started");
         } else {
             log.error("mdtp server start failed", channelFuture.cause());
             throw new Exception("mdtp server start failed", channelFuture.cause());
         }
     }
 
+    public int listenPort() {
+        if (this.channel != null && this.channel.localAddress() instanceof InetSocketAddress) {
+            return ((InetSocketAddress) this.channel.localAddress()).getPort();
+        }
+        return -1;
+    }
+
     @Override
     public void close() throws IOException {
         if (this.acceptorGroup != null) {

mdtp-server/src/test/java/io/github/protocol/mdtp/server/MdtpConnectTest.java

@@ -0,0 +1,19 @@
+package io.github.protocol.mdtp.server;
+
+import io.github.protocol.mdtp.client.MdtpClient;
+import io.github.protocol.mdtp.client.MdtpClientConfig;
+import org.junit.jupiter.api.Test;
+
+public class MdtpConnectTest {
+    @Test
+    public void mdtpConnect() throws Exception {
+        MdtpServerConfig mdtpServerConfig  = new MdtpServerConfig().host("localhost").port(0);
+        MdtpServer mdtpServer = new MdtpServer(mdtpServerConfig);
+        mdtpServer.start();
+        MdtpClientConfig mdtpClientConfig = new MdtpClientConfig().host("localhost").port(mdtpServer.listenPort());
+        MdtpClient mdtpClient = new MdtpClient(mdtpClientConfig);
+        mdtpClient.start();
+        mdtpClient.close();
+        mdtpServer.close();
+    }
+}

pom.xml

@@ -21,6 +21,7 @@
         <maven.compiler.target>17</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <src.dir>src/main/java</src.dir>
+        <jacoco.overall.exec>${maven.multiModuleProjectDirectory}/target/jacoco/jacoco.exec</jacoco.overall.exec>
         <!-- dependency -->
         <junit.version>5.11.0</junit.version>
         <log4j.version>2.20.0</log4j.version>
@@ -99,16 +100,23 @@
                 <groupId>org.jacoco</groupId>
                 <artifactId>jacoco-maven-plugin</artifactId>
                 <version>${jacoco-maven-plugin.version}</version>
+                <configuration>
+                    <destFile>${jacoco.overall.exec}</destFile>
+                    <dataFile>${jacoco.overall.exec}</dataFile>
+                </configuration>
                 <executions>
                     <execution>
                         <id>prepare-agent</id>
+                        <configuration>
+                            <append>true</append>
+                        </configuration>
                         <goals>
                             <goal>prepare-agent</goal>
                         </goals>
                     </execution>
                     <execution>
                         <id>report</id>
-                        <phase>test</phase>
+                        <phase>validate</phase>
                         <goals>
                             <goal>report</goal>
                         </goals>