Init

Author: zxdong262

.env

@@ -0,0 +1,10 @@
+# server port
+PORT=7837
+
+# server host
+HOST=127.0.0.1
+
+# jwt secret, make sure you change it in production
+JWT_SECRET=54tr456yrtytr45654tr456yrtytr45654tr456yrtytr45654tr456yrtytr45654tr456yrtytr456
+JWT_USERS=username1,username2,xxxx,hhhh
+FILE_STORE_PATH=/Users/home/dev/electerm-sync-server-java/temp/file_store

.gitignore

@@ -22,3 +22,6 @@
 # virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
 hs_err_pid*
 replay_pid*
+/temp/
+.gradle
+build

.vscode/settings.json

@@ -0,0 +1,3 @@
+{
+  "java.configuration.updateBuildConfiguration": "automatic"
+}

README.md

@@ -1,2 +1,43 @@
-# electerm-sync-server-java
-electerm-sync-server-java
+# Java Electerm sync server
+
+[![Build Status](https://img.shields.io/endpoint.svg?url=https%3A%2F%2Factions-badge.atrox.dev%2Fatrox%2Fsync-dotenv%2Fbadge)](https://github.com/electerm/electerm-sync-server-java/actions)
+
+A simple electerm data sync server.
+
+## Use
+
+```bash
+git clone git@github.com:electerm/electerm-sync-server-java.git
+cd electerm-sync-server-java
+
+# create env file, then edit .env
+cp sample.env .env
+
+## run
+gradle run
+
+## build
+gradle build
+
+# would show something like
+# server running at http://127.0.0.1:7837
+
+# in electerm sync settings, set custom sync server with:
+# server url: http://127.0.0.1:7837
+# JWT_SECRET: your JWT_SECRET in .env
+# JWT_USER_NAME: one JWT_USER in .env
+```
+
+## Test
+
+```bash
+npm run test
+```
+
+## Write your own data store
+
+Just take [src/ElectermSync/FileStore.java](src/ElectermSync/FileStore.java) as an example, write your own read/write method
+
+## License
+
+MIT

build.gradle

@@ -0,0 +1,39 @@
+
+plugins {
+    id 'java'
+    id 'application'
+}
+
+repositories {
+    mavenCentral()
+}
+
+java {
+    toolchain {
+        languageVersion.set(JavaLanguageVersion.of(17))
+    }
+}
+
+dependencies {
+    implementation 'com.sparkjava:spark-core:2.9.3'
+    implementation 'io.jsonwebtoken:jjwt-api:0.11.2'
+    implementation 'io.jsonwebtoken:jjwt-impl:0.11.2'
+    implementation 'io.jsonwebtoken:jjwt-jackson:0.11.2'
+    implementation 'com.google.code.gson:gson:2.8.9'
+    implementation 'io.github.cdimascio:java-dotenv:5.2.1'
+    implementation 'org.slf4j:slf4j-api:1.7.32'
+    implementation 'ch.qos.logback:logback-classic:1.2.3'
+    testImplementation 'junit:junit:4.13.2'
+}
+
+application {
+    mainClass.set('ElectermSync.App')
+}
+
+sourceSets {
+    main {
+        java {
+            srcDir 'src'
+        }
+    }
+}

sample.env

@@ -0,0 +1,10 @@
+# server port
+PORT=7837
+
+# server host
+HOST=127.0.0.1
+
+# jwt secret, make sure you change it in production
+JWT_SECRET=283hsdfye@!2@9oijnjSwda09
+JWT_USERS=username1,username2,xxxx,hhhh
+# FILE_STORE_PATH=/home/some/folder

src/ElectermSync/App.java

@@ -0,0 +1,73 @@
+package ElectermSync;
+import static spark.Spark.*;
+import io.jsonwebtoken.*;
+import com.google.gson.Gson;
+import java.util.Map;
+import java.io.File;
+import java.util.Arrays;
+import java.nio.charset.StandardCharsets;
+import java.util.Base64;
+
+public class App {
+
+    public static void main(String[] args) {
+        Gson gson = new Gson();
+
+
+        Config dotenv = new Config();
+        String secretOri = dotenv.getValue("JWT_SECRET");
+        byte[] bytesToEncode = secretOri.getBytes(StandardCharsets.UTF_8);
+        
+        // Encode the bytes using Base64
+        String secret = Base64.getEncoder().encodeToString(bytesToEncode);
+
+        String ids = dotenv.getValue("JWT_USERS");
+        String[] idArrStrings = ids.split(",");
+        Jwts.parserBuilder().setSigningKey(secret).build();
+
+        port(Integer.parseInt((dotenv.getValue("PORT"))));
+
+        ipAddress(dotenv.getValue("HOST"));
+
+        before("/api/sync", (request, response) -> {
+            String authHeader = request.headers("Authorization");
+            try {
+              if (authHeader == null || !authHeader.startsWith("Bearer ")) {
+                throw new JwtException("Missing or invalid token");
+              } else {
+                  String token = authHeader.substring(7);
+                  Jws<Claims> claimsJws = Jwts.parserBuilder().setSigningKey(secret).build().parseClaimsJws(token);
+                  String id = claimsJws.getBody().get("id").toString();
+                  boolean found = Arrays.stream(idArrStrings).anyMatch(element -> element.equals(id));
+                  if (!found) {
+                      throw new JwtException("Unauthorized access");
+                  }
+                  request.attribute("jwtId", id);
+              }
+            } catch (JwtException ex) {
+              halt(401, "Unauthorized: " + ex.getMessage());
+            }
+        });
+
+        get("/api/sync", (request, response) -> {
+            String jwtId = request.attribute("jwtId");
+            ReadResult r = FileStore.read(jwtId, dotenv);
+            response.status(r.statusCode);
+            return gson.toJson(r.fileData);
+        });
+
+        put("/api/sync", (request, response) -> {
+            String requestBody = request.body();
+            String jwtId = request.attribute("jwtId");
+            response.type("application/json");
+            WriteResult r = FileStore.write(requestBody, jwtId, dotenv);
+            response.status(r.statusCode);
+            return r.message;
+        });
+        
+        after((request, response) -> {
+            response.type("application/json");
+            response.header("Content-Encoding", "gzip");
+        });
+    }
+}

src/ElectermSync/Config.java

@@ -0,0 +1,15 @@
+package ElectermSync;
+
+import io.github.cdimascio.dotenv.Dotenv;
+
+public class Config {
+    private Dotenv dotenv;
+
+    public Config() {
+        dotenv = Dotenv.load();
+    }
+
+    public String getValue(String name) {
+        return dotenv.get(name);
+    }
+}

src/ElectermSync/FileStore.java

@@ -0,0 +1,52 @@
+
+package ElectermSync;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.io.IOException;
+import java.io.File;
+import java.util.Map;
+import java.util.HashMap;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+public class FileStore {
+
+    public static void main(String[] args) {
+        // Test code
+    }
+
+    public static Path getFilePath (String userId, Config dotenv) {
+        String storePath = dotenv.getValue("FILE_STORE_PATH");
+        Path folder = storePath != null ? Path.of(storePath) : Path.of(System.getProperty("user.dir"));
+        return folder.resolve(userId + ".json");
+    }
+
+    public static WriteResult write(String jsonBody, String userId, Config dotenv) {
+        Path filePath = getFilePath(userId, dotenv);
+        try {
+            Files.writeString(filePath, jsonBody);
+        } catch (IOException e) {
+            return new WriteResult("Error writing file", 500);
+        }
+
+        return new WriteResult("ok", 200);
+    }
+
+    public static ReadResult read(String userId, Config dotenv) {
+        ObjectMapper objectMapper = new ObjectMapper();
+        Path filePath = getFilePath(userId, dotenv);
+        File file = filePath.toFile();
+
+        if (file.isFile()) {
+            String fileContent;
+            try {
+                fileContent = Files.readString(filePath);
+                Map<String, Object> fileData = objectMapper.readValue(fileContent, HashMap.class);
+                return new ReadResult(fileData, 200);
+            } catch (IOException e) {
+                return new ReadResult("File read error", 500);
+            }
+        } else {
+            return new ReadResult("File not found", 404);
+        }
+    }
+}

src/ElectermSync/ReadResult.java

@@ -0,0 +1,18 @@
+package ElectermSync;
+
+import java.util.Map;
+
+public class ReadResult {
+    public final Map<String, Object> fileData;
+    public final int statusCode;
+
+    ReadResult(Map<String, Object> fileData, int statusCode) {
+        this.fileData = fileData;
+        this.statusCode = statusCode;
+    }
+
+    ReadResult(String errorMessage, int statusCode) {
+        this.fileData = Map.of("error", errorMessage);
+        this.statusCode = statusCode;
+    }
+}