From 50cf58da9aa60d8f2a61682badba52f38f83297b Mon Sep 17 00:00:00 2001
From: "Edward M. Kagan" <pagan@tabor.one>
Date: Sat, 30 Jan 2021 20:24:32 +0300
Subject: [PATCH] [Closes #3] Crypto added to core

---
 .dev/docker/dev-env.yml                       |  13 +++
 dev-env-persistent                            |   2 +
 pom.xml                                       |  10 +-
 .../two/pm/traqtor/CayenneRuntimeFactory.java |  86 +++++++++++-------
 src/main/java/two/pm/traqtor/TraQtor.java     |  33 -------
 .../pm/traqtor/api/test/HelloResource.java    |  26 ++----
 .../java/two/pm/traqtor/db/SystemUser.java    |  30 ++++++
 src/main/java/two/pm/traqtor/db/User.java     |  21 -----
 .../db/auto/{_User.java => _SystemUser.java}  |  23 ++++-
 src/main/resources/db/cayenne-traqtor.xml     |   4 +-
 src/main/resources/db/datamap.map.xml         |  12 ++-
 src/main/resources/db/traqtor.graph.xml       |   2 +-
 src/main/resources/db/traqtor.keystore        | Bin 0 -> 998 bytes
 13 files changed, 142 insertions(+), 120 deletions(-)
 create mode 100644 .dev/docker/dev-env.yml
 create mode 100755 dev-env-persistent
 create mode 100644 src/main/java/two/pm/traqtor/db/SystemUser.java
 delete mode 100644 src/main/java/two/pm/traqtor/db/User.java
 rename src/main/java/two/pm/traqtor/db/auto/{_User.java => _SystemUser.java} (74%)
 create mode 100644 src/main/resources/db/traqtor.keystore

diff --git a/.dev/docker/dev-env.yml b/.dev/docker/dev-env.yml
new file mode 100644
index 0000000..3b0d256
--- /dev/null
+++ b/.dev/docker/dev-env.yml
@@ -0,0 +1,13 @@
+version: "3"
+
+services:
+  postgres:
+    image: postgres:13-alpine
+    volumes:
+      - ../postgres/:/var/lib/postgresql/data
+    environment:
+      - POSTGRES_INITDB_ARGS=--encoding=UTF8 --locale=en_US.UTF-8 --lc-collate=en_US.UTF-8 --lc-ctype=en_US.UTF-8 --lc-messages=en_US.UTF-8 --lc-monetary=en_US.UTF-8 --lc-numeric=en_US.UTF-8 --lc-time=en_US.UTF-8
+      - POSTGRES_USER=traqtor
+      - POSTGRES_PASSWORD=traqtor
+    ports:
+      - 10240:5432
\ No newline at end of file
diff --git a/dev-env-persistent b/dev-env-persistent
new file mode 100755
index 0000000..947f68e
--- /dev/null
+++ b/dev-env-persistent
@@ -0,0 +1,2 @@
+#!/bin/bash
+CURRENT_UID=$(id -u):$(id -g) docker-compose -f ./.dev/docker/dev-env.yml -p traqtor --compatibility up
diff --git a/pom.xml b/pom.xml
index 6e6fcd9..6d3edae 100644
--- a/pom.xml
+++ b/pom.xml
@@ -55,11 +55,17 @@
       <artifactId>cayenne-server</artifactId>
       <version>4.1</version>
     </dependency>
-    <!-- <dependency>
+    <dependency>
       <groupId>org.apache.cayenne</groupId>
       <artifactId>cayenne-crypto</artifactId>
       <version>4.1</version>
-    </dependency> -->
+    </dependency>
+    <dependency>
+      <groupId>org.postgresql</groupId>
+      <artifactId>postgresql</artifactId>
+      <version>42.2.18</version>
+    </dependency>
+
 
     <!-- <dependency>
       <groupId>io.quarkus</groupId>
diff --git a/src/main/java/two/pm/traqtor/CayenneRuntimeFactory.java b/src/main/java/two/pm/traqtor/CayenneRuntimeFactory.java
index 0e1ff73..9e3fd42 100644
--- a/src/main/java/two/pm/traqtor/CayenneRuntimeFactory.java
+++ b/src/main/java/two/pm/traqtor/CayenneRuntimeFactory.java
@@ -1,53 +1,69 @@
 package two.pm.traqtor;
 
+import java.io.File;
+import java.net.MalformedURLException;
+import java.net.URL;
+
 import javax.enterprise.context.ApplicationScoped;
 import javax.inject.Singleton;
 
 import org.apache.cayenne.ObjectContext;
 import org.apache.cayenne.configuration.Constants;
 import org.apache.cayenne.configuration.server.ServerRuntime;
+import org.apache.cayenne.crypto.CryptoModule;
 import org.apache.cayenne.di.Key;
-import org.apache.cayenne.log.JdbcEventLogger;
-import org.apache.cayenne.log.NoopJdbcEventLogger;
 import org.apache.cayenne.query.SQLExec;
 import org.apache.cayenne.resource.ResourceLocator;
 
 @ApplicationScoped
 public class CayenneRuntimeFactory {
 
-    private static ServerRuntime runtime;
-
-    @Singleton
-    public ServerRuntime cayenneRuntime() {
-        if (runtime == null) {
-            runtime = ServerRuntime.builder().addConfig("db/cayenne-traqtor.xml")
-                    .addModule(binder -> binder.bind(JdbcEventLogger.class).to(NoopJdbcEventLogger.class))
-                    .addModule(binder -> {
-                        binder.bind(ResourceLocator.class).to(ClassLoaderResourceLocatorFix.class);
-                        binder.bind(Key.get(ResourceLocator.class, Constants.SERVER_RESOURCE_LOCATOR))
-                                .to(ClassLoaderResourceLocatorFix.class);
-                    }).build();
-
-            ObjectContext context = runtime.newContext();
-            SQLExec.query(
-                    "CREATE TABLE IF NOT EXISTS user (email VARCHAR(36) NULL, id VARBINARY(36) NOT NULL, PRIMARY KEY (id));")
-                    .execute(context);
-            SQLExec.query(
-                    "CREATE SEQUENCE IF NOT EXISTS pk_user START WITH -9223372036854775808 INCREMENT BY 20 CACHE 1;")
-                    .execute(context);
-            context.commitChanges();
-        }
+        private static ServerRuntime runtime;
+
+        @Singleton
+        public ServerRuntime cayenneRuntime() {
+                if (runtime == null) {
+
+                        // ClassLoader classLoader = ;
+                        // File file = new File(classLoader.getFile());
+                        // System.out.println(file.getAbsolutePath());
 
-        return runtime;
-        // return
-        // ServerRuntime.builder().dataSource(dataSource).addConfig("db/cayenne-test.xml").addModule(binder
-        // -> {
-        // //
-        // binder.bind(ResourceLocator.class).to(ClassLoaderResourceLocatorFix.class);
-        // // binder.bind(Key.get(ResourceLocator.class,
-        // Constants.SERVER_RESOURCE_LOCATOR))
-        // // .to(ClassLoaderResourceLocatorFix.class);
-        // }).build();
-    }
+                        runtime = ServerRuntime.builder().addConfig("db/cayenne-traqtor.xml")
+                                        // .addModule(binder ->
+                                        // binder.bind(JdbcEventLogger.class).to(NoopJdbcEventLogger.class))
+                                        .addModule(binder -> {
+                                                binder.bind(ResourceLocator.class)
+                                                                .to(ClassLoaderResourceLocatorFix.class);
+                                                binder.bind(Key.get(ResourceLocator.class,
+                                                                Constants.SERVER_RESOURCE_LOCATOR))
+                                                                .to(ClassLoaderResourceLocatorFix.class);
+                                        })
+                                        .addModule(CryptoModule.extend()
+                                                        .keyStore(this.getClass().getClassLoader()
+                                                                        .getResource("db/traqtor.keystore"),
+                                                                        "secret".toCharArray(), "key0")
+                                                        .compress()
+                                                        // .useHMAC()
+                                                        .module())
+                                        .build();
+
+                        ObjectContext context = runtime.newContext();
+
+                        SQLExec.query("CREATE TABLE IF NOT EXISTS system_user (id bigint NOT NULL, CRYPTO_password varchar(2048) NOT NULL, CRYPTO_email varchar(2048) NOT NULL, PRIMARY KEY (id));"
+                                        + "CREATE SEQUENCE IF NOT EXISTS pk_system_user INCREMENT 20 MINVALUE -9223372036854775807;")
+                                        .execute(context);
+                        context.commitChanges();
+                }
+                return runtime;
+                // return
+                // ServerRuntime.builder().dataSource(dataSource).addConfig("db/cayenne-test.xml").addModule(binder
+                // -> {
+                // //
+                // binder.bind(ResourceLocator.class).to(ClassLoaderResourceLocatorFix.class);
+                // // binder.bind(Key.get(ResourceLocator.class,
+                // Constants.SERVER_RESOURCE_LOCATOR))
+                // // .to(ClassLoaderResourceLocatorFix.class);
+                // }).build();
+        }
 
 }
\ No newline at end of file
diff --git a/src/main/java/two/pm/traqtor/TraQtor.java b/src/main/java/two/pm/traqtor/TraQtor.java
index 5e32cf8..2c26803 100644
--- a/src/main/java/two/pm/traqtor/TraQtor.java
+++ b/src/main/java/two/pm/traqtor/TraQtor.java
@@ -1,45 +1,12 @@
 package two.pm.traqtor;
 
 import io.quarkus.runtime.annotations.QuarkusMain;
-
-import javax.inject.Inject;
-
-import org.apache.cayenne.ObjectContext;
-import org.apache.cayenne.configuration.server.ServerRuntime;
-import org.apache.cayenne.log.JdbcEventLogger;
-import org.apache.cayenne.log.NoopJdbcEventLogger;
-import org.apache.cayenne.query.SQLExec;
 import io.quarkus.runtime.Quarkus;
 
 @QuarkusMain
 public class TraQtor {
-    // public static ServerRuntime cayenneRuntime;
 
     public static void main(String... args) {
-        // if (cayenneRuntime == null) {
-
-        // .performInTransaction(() -> {
-        // // ... do some changes
-        // context.commitChanges();
-
-        // // ... do more changes
-        // context.commitChanges();
-
-        // return true;
-        // });
-
-        // Module cryptoExtensions = CryptoModule.extend()
-        // .keyStore("file:///mykeystore", "keystorepassword".toCharArray(), "keyalias")
-        // .compress()
-        // .module();
-
-        // cayenneRuntime =
-        // ServerRuntime.builder().addConfig("cayenne/cayenne-traqtor.xml")
-        // .addModule(binder ->
-        // binder.bind(JdbcEventLogger.class).to(NoopJdbcEventLogger.class)).build();
-
-        // }
-
         System.out.println("Running main method");
         Quarkus.run(args);
     }
diff --git a/src/main/java/two/pm/traqtor/api/test/HelloResource.java b/src/main/java/two/pm/traqtor/api/test/HelloResource.java
index 8b0ecdc..1416f99 100644
--- a/src/main/java/two/pm/traqtor/api/test/HelloResource.java
+++ b/src/main/java/two/pm/traqtor/api/test/HelloResource.java
@@ -1,47 +1,34 @@
 package two.pm.traqtor.api.test;
 
 import java.util.List;
-import java.util.UUID;
-import java.util.stream.Collector;
 import java.util.stream.Collectors;
-
 import javax.ws.rs.GET;
 import javax.ws.rs.Path;
 import javax.ws.rs.PathParam;
 import javax.ws.rs.Produces;
 import javax.ws.rs.core.MediaType;
-
 import org.apache.cayenne.BaseContext;
-import org.apache.cayenne.Cayenne;
 import org.apache.cayenne.ObjectContext;
-import org.apache.cayenne.ObjectId;
 import org.apache.cayenne.query.ObjectSelect;
-
-import two.pm.traqtor.TraQtor;
-import two.pm.traqtor.db.User;
-import two.pm.traqtor.db.User.DTO;
+import two.pm.traqtor.db.SystemUser;
 
 @Path("/hello")
 public class HelloResource {
 
-    private List<DTO> result;
-
     @GET
     @Produces(MediaType.TEXT_PLAIN)
     public String hello() {
         ObjectContext context = BaseContext.getThreadObjectContext();
-        // ObjectContext context = TraQtor.cayenneRuntime.newContext();
-        return String.valueOf(ObjectSelect.query(User.class).selectCount(context));
+        return String.valueOf(ObjectSelect.query(SystemUser.class).selectCount(context));
     }
 
     @GET
     @Path("/list")
     @Produces(MediaType.APPLICATION_JSON)
-    public List<User.DTO> list() {
+    public List<SystemUser.DTO> list() {
         ObjectContext context = BaseContext.getThreadObjectContext();
-        List<User> users = ObjectSelect.query(User.class).select(context);
-        return users.stream().map(user -> new User.DTO(Cayenne.pkForObject(user).toString(), user.getEmail()))
-                .collect(Collectors.toList());
+        List<SystemUser> users = ObjectSelect.query(SystemUser.class).select(context);
+        return users.stream().map(user -> user.dto()).collect(Collectors.toList());
     }
 
     @GET
@@ -49,8 +36,9 @@ public class HelloResource {
     @Produces(MediaType.TEXT_PLAIN)
     public String add(@PathParam("email") String email) {
         ObjectContext context = BaseContext.getThreadObjectContext();
-        User user = context.newObject(User.class);
+        SystemUser user = context.newObject(SystemUser.class);
         user.setEmail(email);
+        user.setPassword("test");
         context.commitChanges();
         return hello();
     }
diff --git a/src/main/java/two/pm/traqtor/db/SystemUser.java b/src/main/java/two/pm/traqtor/db/SystemUser.java
new file mode 100644
index 0000000..342ca12
--- /dev/null
+++ b/src/main/java/two/pm/traqtor/db/SystemUser.java
@@ -0,0 +1,30 @@
+package two.pm.traqtor.db;
+
+import java.nio.charset.StandardCharsets;
+
+import org.apache.cayenne.Cayenne;
+
+import two.pm.traqtor.db.auto._SystemUser;
+
+public class SystemUser extends _SystemUser {
+
+    private static final long serialVersionUID = 1L;
+
+    public DTO dto() {
+        return new DTO(Cayenne.longPKForObject(this), email, password);
+    }
+
+    public final class DTO {
+
+        public String email;
+        public String password;
+        public String id;
+
+        public DTO(long id, String email, String password) {
+            this.id = Long.toHexString(id);
+            this.email = email;
+            this.password = password;
+        }
+
+    }
+}
diff --git a/src/main/java/two/pm/traqtor/db/User.java b/src/main/java/two/pm/traqtor/db/User.java
deleted file mode 100644
index 27ad033..0000000
--- a/src/main/java/two/pm/traqtor/db/User.java
+++ /dev/null
@@ -1,21 +0,0 @@
-package two.pm.traqtor.db;
-
-import two.pm.traqtor.db.auto._User;
-
-public class User extends _User {
-
-    private static final long serialVersionUID = 1L;
-
-    public static class DTO {
-
-        public String email;
-        public String id;
-
-        public DTO(String id, String email) {
-            this.id = id;
-            this.email = email;
-        }
-
-    }
-
-}
diff --git a/src/main/java/two/pm/traqtor/db/auto/_User.java b/src/main/java/two/pm/traqtor/db/auto/_SystemUser.java
similarity index 74%
rename from src/main/java/two/pm/traqtor/db/auto/_User.java
rename to src/main/java/two/pm/traqtor/db/auto/_SystemUser.java
index 1316322..96534fd 100644
--- a/src/main/java/two/pm/traqtor/db/auto/_User.java
+++ b/src/main/java/two/pm/traqtor/db/auto/_SystemUser.java
@@ -8,20 +8,22 @@ import org.apache.cayenne.BaseDataObject;
 import org.apache.cayenne.exp.Property;
 
 /**
- * Class _User was generated by Cayenne.
+ * Class _SystemUser was generated by Cayenne.
  * It is probably a good idea to avoid changing this class manually,
  * since it may be overwritten next time code is regenerated.
  * If you need to make any customizations, please use subclass.
  */
-public abstract class _User extends BaseDataObject {
+public abstract class _SystemUser extends BaseDataObject {
 
     private static final long serialVersionUID = 1L; 
 
     public static final String ID_PK_COLUMN = "id";
 
     public static final Property<String> EMAIL = Property.create("email", String.class);
+    public static final Property<String> PASSWORD = Property.create("password", String.class);
 
     protected String email;
+    protected String password;
 
 
     public void setEmail(String email) {
@@ -34,6 +36,16 @@ public abstract class _User extends BaseDataObject {
         return this.email;
     }
 
+    public void setPassword(String password) {
+        beforePropertyWrite("password", this.password, password);
+        this.password = password;
+    }
+
+    public String getPassword() {
+        beforePropertyRead("password");
+        return this.password;
+    }
+
     @Override
     public Object readPropertyDirectly(String propName) {
         if(propName == null) {
@@ -43,6 +55,8 @@ public abstract class _User extends BaseDataObject {
         switch(propName) {
             case "email":
                 return this.email;
+            case "password":
+                return this.password;
             default:
                 return super.readPropertyDirectly(propName);
         }
@@ -58,6 +72,9 @@ public abstract class _User extends BaseDataObject {
             case "email":
                 this.email = (String)val;
                 break;
+            case "password":
+                this.password = (String)val;
+                break;
             default:
                 super.writePropertyDirectly(propName, val);
         }
@@ -75,12 +92,14 @@ public abstract class _User extends BaseDataObject {
     protected void writeState(ObjectOutputStream out) throws IOException {
         super.writeState(out);
         out.writeObject(this.email);
+        out.writeObject(this.password);
     }
 
     @Override
     protected void readState(ObjectInputStream in) throws IOException, ClassNotFoundException {
         super.readState(in);
         this.email = (String)in.readObject();
+        this.password = (String)in.readObject();
     }
 
 }
diff --git a/src/main/resources/db/cayenne-traqtor.xml b/src/main/resources/db/cayenne-traqtor.xml
index 6de97d7..690a293 100644
--- a/src/main/resources/db/cayenne-traqtor.xml
+++ b/src/main/resources/db/cayenne-traqtor.xml
@@ -9,8 +9,8 @@
 		 schema-update-strategy="org.apache.cayenne.access.dbsync.SkipSchemaUpdateStrategy">
 		<map-ref name="datamap"/>
 		<data-source>
-			<driver value="org.h2.Driver"/>
-			<url value="jdbc:h2:mem:traqtor;MVCC=TRUE"/>
+			<driver value="org.postgresql.Driver"/>
+			<url value="jdbc:postgresql://localhost:10240/traqtor"/>
 			<connectionPool min="1" max="1"/>
 			<login userName="traqtor" password="traqtor"/>
 		</data-source>
diff --git a/src/main/resources/db/datamap.map.xml b/src/main/resources/db/datamap.map.xml
index b05f5b7..7e270a0 100644
--- a/src/main/resources/db/datamap.map.xml
+++ b/src/main/resources/db/datamap.map.xml
@@ -4,12 +4,14 @@
 	 xsi:schemaLocation="http://cayenne.apache.org/schema/10/modelMap https://cayenne.apache.org/schema/10/modelMap.xsd"
 	 project-version="10">
 	<property name="defaultPackage" value="two.pm.traqtor.db"/>
-	<db-entity name="user">
-		<db-attribute name="email" type="VARCHAR" length="36"/>
-		<db-attribute name="id" type="BIGINT" isPrimaryKey="true" isMandatory="true" length="36"/>
+	<db-entity name="system_user">
+		<db-attribute name="CRYPTO_email" type="VARCHAR" isMandatory="true" length="2048"/>
+		<db-attribute name="CRYPTO_password" type="VARCHAR" isMandatory="true" length="2048"/>
+		<db-attribute name="id" type="BIGINT" isPrimaryKey="true" isMandatory="true"/>
 	</db-entity>
-	<obj-entity name="User" className="two.pm.traqtor.db.User" dbEntityName="user">
-		<obj-attribute name="email" type="java.lang.String" db-attribute-path="email"/>
+	<obj-entity name="SystemUser" className="two.pm.traqtor.db.SystemUser" dbEntityName="system_user">
+		<obj-attribute name="email" type="java.lang.String" db-attribute-path="CRYPTO_email"/>
+		<obj-attribute name="password" type="java.lang.String" db-attribute-path="CRYPTO_password"/>
 	</obj-entity>
 	<cgen xmlns="http://cayenne.apache.org/schema/10/cgen">
 		<destDir>../../java</destDir>
diff --git a/src/main/resources/db/traqtor.graph.xml b/src/main/resources/db/traqtor.graph.xml
index 6dc981e..6323e68 100644
--- a/src/main/resources/db/traqtor.graph.xml
+++ b/src/main/resources/db/traqtor.graph.xml
@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="utf-8"?>
 <graphs xmlns="http://cayenne.apache.org/schema/10/graph">
 	<graph type="ER" scale="1.0">
-		<entity name="user" x="23.0" y="20.0" width="35.0" height="62.0"/>
+		<entity name="system_user" x="23.0" y="20.0" width="115.0" height="77.0"/>
 	</graph>
 </graphs>
diff --git a/src/main/resources/db/traqtor.keystore b/src/main/resources/db/traqtor.keystore
new file mode 100644
index 0000000000000000000000000000000000000000..d3810e736122e69831f94868eb7b6b9d8a91f36f
GIT binary patch
literal 998
zcmX?i?%X*B1_mZ5W@cc?POUU#U|=i{-Wv9H&07Z6;vxp)<osN{;?g|5<f6)gl6<{_
zqWrSVl++@<;MByN)D-`utkmQZxBMdS)XIRO{1PB1zvyiEsmSLByMuuyR}?WwW+j#-
zR>1TlYqK-6U3PeTNC6WAOEd#-YF=`FN@_|#Vo_plaR~!cv{N*L08kKQZ)%EjeqKpx
zUP&QC9RrgO17`tPm19nN34@Ri$O8SG#JqI<;F6-uymV_H2KHj0^MKMI^~@Cor9~j~
z)_fNK!Nw8t0OYO$psxiD_*po9Z7T}3`xc?g#LUd=PzqAd3Y1!~XqwBUl9G6?<$QfP
zGiA1}U(7A;U>zHJK#ZkJ<c{K8347&>FE_JDu?A;Jzkb;#+bQ~6!|M5|EuRywwQXz-
zjK8W<%=<avq43jq0nzm(POo`nyYJWO#7)!*{3Pb~ZehsG+T#r$f9zl=b^5wHV`}O%
z`PNSoGnrZ+6)3jch&1{<$C58+ap>|}ipHIvwkO>^^}(h60b{}4qKlWhR{3X5{&0G8
z34>UGlWTZpNrtbBsbgMBNKs}%PO6J*Fir`euOLxu0EuD=-;ol<dA_~hlREASqebyM
z){8Sc9cI7tSRm9`dOq5}NiIj@MUc~st>T;2L`9fyix;fXyyPz?CCwhJ#P7<MBp}e#
z?au#|fhVr?--e1OZqMItikWkgqwOx6(vt4x)Qti{zDpQa97;ZL_;isrS6-T;>%0%{
zj<%tNZbh=)*;6gsu4J@HfBgRVZT{oiEWHbUMSfh!o@Dyc^K15Ht@f+W_~uN!lyWrh
o{$6XhdWjnA$ErAE5~swpzDt###9j0!NWZNyPwdMKjk&xR0Ft$L9smFU

literal 0
HcmV?d00001