Server‑side caching Issue36

.github/workflows/ci.yml

@@ -0,0 +1,32 @@
+name: Java CI with Maven
+
+on:
+  push:
+    branches: [ "main" ]
+  pull_request:
+    branches: [ "main" ]
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+
+    steps:
+      - uses: actions/checkout@v4
+
+      - name: Get Java Version
+        run: |
+          JAVA_VERSION=$(mvn help:evaluate "-Dexpression=maven.compiler.release" -q -DforceStdout)
+          echo "JAVA_VERSION=$JAVA_VERSION" >> $GITHUB_ENV
+
+      - name: Set up JDK ${{ env.JAVA_VERSION }}
+        uses: actions/setup-java@v4
+        with:
+          java-version: ${{ env.JAVA_VERSION }}
+          distribution: 'temurin'
+          cache: maven
+
+      - name: Compile with Maven
+        run: mvn -B compile --file pom.xml
+
+      - name: Test with Maven
+        run: mvn -B test --file pom.xml

.github/workflows/release.yml

@@ -0,0 +1,35 @@
+name: Publish Docker Image to Github Packages on Release
+on:
+  release:
+    types:
+      - published
+jobs:
+  publish:
+    runs-on: ubuntu-latest
+    permissions:
+      contents: read
+      packages: write
+    steps:
+      - uses: actions/checkout@v6.0.2
+      - uses: docker/setup-qemu-action@v3.7.0
+      - uses: docker/setup-buildx-action@v3.12.0
+      - name: Log in to GHCR
+        uses: docker/login-action@v3.7.0
+        with:
+          registry: ghcr.io
+          username: ${{ github.actor }}
+          password: ${{ secrets.GITHUB_TOKEN }}
+      - name: Extract metadata
+        id: meta
+        uses: docker/metadata-action@v5.10.0
+        with:
+          images: ghcr.io/ithsjava25/webserver
+      - name: Build and push
+        uses: docker/build-push-action@v6.18.0
+        with:
+          context: .
+          push: true
+          platforms: linux/amd64, linux/arm64
+          tags:  ${{ steps.meta.outputs.tags }}
+          labels: ${{ steps.meta.outputs.labels }}
+

Dockerfile

@@ -0,0 +1,11 @@
+FROM maven:3-eclipse-temurin-25-alpine AS build
+WORKDIR /build
+COPY src/ src/
+COPY pom.xml pom.xml
+RUN mvn compile
+
+FROM eclipse-temurin:25-jre-alpine
+RUN addgroup -S appgroup && adduser -S appuser -G appgroup
+COPY --from=build /build/target/classes/ /app/
+ENTRYPOINT ["java", "-classpath", "/app", "org.example.App"]
+USER appuser

pom.xml

@@ -9,13 +9,21 @@
     <version>1.0-SNAPSHOT</version>
 
     <properties>
-        <maven.compiler.release>23</maven.compiler.release>
+        <maven.compiler.release>25</maven.compiler.release>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <junit.jupiter.version>6.0.2</junit.jupiter.version>
         <assertj.core.version>3.27.7</assertj.core.version>
         <mockito.version>5.21.0</mockito.version>
+        <bucket4j.version>8.14.0</bucket4j.version>
+
     </properties>
+
     <dependencies>
+        <dependency>
+            <groupId>com.bucket4j</groupId>
+            <artifactId>bucket4j_jdk17-core</artifactId>
+            <version>${bucket4j.version}</version>
+        </dependency>
         <dependency>
             <groupId>org.junit.jupiter</groupId>
             <artifactId>junit-jupiter</artifactId>
@@ -28,12 +36,36 @@
             <version>${assertj.core.version}</version>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.mockito</groupId>
+            <artifactId>mockito-core</artifactId>
+            <version>${mockito.version}</version>
+            <scope>test</scope>
+        </dependency>
         <dependency>
             <groupId>org.mockito</groupId>
             <artifactId>mockito-junit-jupiter</artifactId>
             <version>${mockito.version}</version>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.awaitility</groupId>
+            <artifactId>awaitility</artifactId>
+            <version>4.3.0</version>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>tools.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+            <version>3.0.3</version>
+        </dependency>
+        <dependency>
+            <groupId>tools.jackson.dataformat</groupId>
+            <artifactId>jackson-dataformat-yaml</artifactId>
+            <version>3.0.3</version>
+        </dependency>
+
     </dependencies>
     <build>
         <plugins>
@@ -118,6 +150,39 @@
                     </execution>
                 </executions>
             </plugin>
+            <plugin>
+                <groupId>org.pitest</groupId>
+                <artifactId>pitest-maven</artifactId>
+                <version>1.22.0</version>
+                <dependencies>
+                    <dependency>
+                        <groupId>org.pitest</groupId>
+                        <artifactId>pitest-junit5-plugin</artifactId>
+                        <version>1.2.2</version>
+                    </dependency>
+                </dependencies>
+            </plugin>
+            <plugin>
+                <groupId>com.diffplug.spotless</groupId>
+                <artifactId>spotless-maven-plugin</artifactId>
+                <version>3.2.1</version>
+                <configuration>
+                    <java>
+                        <removeUnusedImports/>
+                        <formatAnnotations/>
+                    </java>
+                </configuration>
+                <executions>
+                    <execution>
+                        <phase>verify</phase>
+                        <goals>
+                            <goal>
+                                check
+                            </goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
         </plugins>
     </build>
 </project>

src/main/java/org/example/App.java

@@ -2,6 +2,6 @@
 
 public class App {
     public static void main(String[] args) {
-        System.out.println("Hello There!");
+        new TcpServer(8080).start();
     }
-}
+}

src/main/java/org/example/ConnectionHandler.java

@@ -0,0 +1,42 @@
+package org.example;
+
+import org.example.httpparser.HttpParser;
+
+import java.io.IOException;
+import java.net.Socket;
+
+public class ConnectionHandler implements AutoCloseable {
+
+    Socket client;
+    String uri;
+
+    public ConnectionHandler(Socket client) {
+        this.client = client;
+    }
+
+    public void runConnectionHandler() throws IOException {
+        StaticFileHandler sfh = new StaticFileHandler();
+        HttpParser parser = new HttpParser();
+        parser.setReader(client.getInputStream());
+        parser.parseRequest();
+        parser.parseHttp();
+        resolveTargetFile(parser.getUri());
+        sfh.sendGetRequest(client.getOutputStream(), uri);
+    }
+
+    private void resolveTargetFile(String uri) {
+        if (uri.matches("/$")) { //matches(/)
+            this.uri = "index.html";
+        } else if (uri.matches("^(?!.*\\.html$).*$")) {
+            this.uri = uri.concat(".html");
+        } else {
+            this.uri = uri;
+        }
+
+    }
+
+    @Override
+    public void close() throws Exception {
+        client.close();
+    }
+}

src/main/java/org/example/FileCache.java

@@ -0,0 +1,28 @@
+package org.example;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class FileCache {
+    private final Map<String, byte []> cache = new HashMap<>();
+
+    public boolean contains (String key) {
+        return cache.containsKey(key);
+    }
+
+    public byte[] get(String key) {
+        return cache.get(key);
+    }
+
+    public void put(String key, byte[] value){
+        cache.put(key, value);
+    }
+    public void clear() {
+        cache.clear();
+    }
+
+    public int size() {
+        return cache.size();
+    }
+
+}

src/main/java/org/example/StaticFileHandler.java

@@ -0,0 +1,42 @@
+package org.example;
+
+import org.example.http.HttpResponseBuilder;
+
+import java.io.File;
+import java.io.IOException;
+import java.io.OutputStream;
+import java.io.PrintWriter;
+import java.nio.file.Files;
+import java.util.Map;
+
+public class StaticFileHandler {
+    private static final String WEB_ROOT = "www";
+    private byte[] fileBytes;
+    private final FileCache cache = new FileCache();
+
+    public StaticFileHandler(){}
+
+    private void handleGetRequest(String uri) throws IOException {
+        if (cache.contains(uri)) {
+            System.out.println("✓ Cache hit for: " + uri);
+            fileBytes = cache.get(uri);
+            return;
+        }
+        System.out.println("✗ Cache miss for: " + uri);
+        File file = new File(WEB_ROOT, uri);
+        fileBytes = Files.readAllBytes(file.toPath());
+
+        cache.put(uri, fileBytes);
+    }
+
+    public void sendGetRequest(OutputStream outputStream, String uri) throws IOException{
+        handleGetRequest(uri);
+        HttpResponseBuilder response = new HttpResponseBuilder();
+        response.setHeaders(Map.of("Content-Type", "text/html; charset=utf-8"));
+        response.setBody(fileBytes);
+        PrintWriter writer = new PrintWriter(outputStream, true);
+        writer.println(response.build());
+
+    }
+
+}

src/main/java/org/example/TcpServer.java

@@ -0,0 +1,36 @@
+package org.example;
+
+import java.io.IOException;
+import java.net.ServerSocket;
+import java.net.Socket;
+
+public class TcpServer {
+
+    private final int port;
+
+    public TcpServer(int port) {
+        this.port = port;
+    }
+
+    public void start() {
+        System.out.println("Starting TCP server on port " + port);
+
+        try (ServerSocket serverSocket = new ServerSocket(port)) {
+            while (true) {
+                Socket clientSocket = serverSocket.accept(); // block
+                System.out.println("Client connected: " + clientSocket.getRemoteSocketAddress());
+                Thread.ofVirtual().start(() -> handleClient(clientSocket));
+            }
+        } catch (IOException e) {
+            throw new RuntimeException("Failed to start TCP server", e);
+        }
+    }
+
+    private void handleClient(Socket client) {
+        try (ConnectionHandler connectionHandler = new ConnectionHandler(client)) {
+            connectionHandler.runConnectionHandler();
+        } catch (Exception e) {
+            throw new RuntimeException("Error handling client connection " + e);
+        }
+    }
+}