Project init

modules/pathit-storage-postgres/runtime/pom.xml

@@ -0,0 +1,107 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://maven.apache.org/POM/4.0.0"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+
+  <artifactId>pathit-storage-postgres</artifactId>
+  <name>Pathit Storage Postgres - Runtime</name>
+  <parent>
+    <groupId>fr.codeanddata.pathit</groupId>
+    <artifactId>pathit-storage-postgres-parent</artifactId>
+    <version>1.0-SNAPSHOT</version>
+    <relativePath>../pom.xml</relativePath>
+  </parent>
+
+  <dependencies>
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-arc</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-hibernate-reactive-panache</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-reactive-pg-client</artifactId>
+    </dependency>
+
+    <!-- Flyway part -->
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-flyway</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-jdbc-postgresql</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.flywaydb</groupId>
+      <artifactId>flyway-database-postgresql</artifactId>
+    </dependency>
+
+    <dependency>
+      <groupId>fr.codeanddata.pathit</groupId>
+      <artifactId>pathit-core</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.projectlombok</groupId>
+      <artifactId>lombok</artifactId>
+      <version>${lombok.version}</version>
+      <scope>provided</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.mapstruct</groupId>
+      <artifactId>mapstruct</artifactId>
+      <version>${mapstruct.version}</version>
+    </dependency>
+  </dependencies>
+
+  <build>
+    <plugins>
+      <plugin>
+        <groupId>io.quarkus</groupId>
+        <artifactId>quarkus-extension-maven-plugin</artifactId>
+        <version>${quarkus.version}</version>
+        <executions>
+          <execution>
+            <phase>compile</phase>
+            <goals>
+              <goal>extension-descriptor</goal>
+            </goals>
+            <configuration>
+              <deployment>${project.groupId}:${project.artifactId}-deployment:${project.version}</deployment>
+            </configuration>
+          </execution>
+        </executions>
+      </plugin>
+      <plugin>
+        <artifactId>maven-compiler-plugin</artifactId>
+        <executions>
+          <execution>
+            <id>default-compile</id>
+            <configuration>
+              <annotationProcessorPaths>
+                <path>
+                  <groupId>org.projectlombok</groupId>
+                  <artifactId>lombok</artifactId>
+                  <version>${lombok.version}</version>
+                </path>
+                <path>
+                  <groupId>org.mapstruct</groupId>
+                  <artifactId>mapstruct-processor</artifactId>
+                  <version>${mapstruct.version}</version>
+                </path>
+                <path>
+                  <groupId>io.quarkus</groupId>
+                  <artifactId>quarkus-extension-processor</artifactId>
+                  <version>${quarkus.version}</version>
+                </path>
+              </annotationProcessorPaths>
+            </configuration>
+          </execution>
+        </executions>
+      </plugin>
+    </plugins>
+  </build>
+</project>

modules/pathit-storage-postgres/runtime/src/main/java/fr/codeanddata/pathit/storage/postgres/entity/PathMapEntity.java

@@ -0,0 +1,28 @@
+package fr.codeanddata.pathit.storage.postgres.entity;
+
+import io.quarkus.hibernate.reactive.panache.PanacheEntity;
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Table;
+import lombok.*;
+
+import java.time.LocalDateTime;
+
+@Entity(name = "PathMap")
+@Table(name = "path_map")
+@Getter
+@Setter
+@Builder
+@AllArgsConstructor
+@NoArgsConstructor
+public class PathMapEntity extends PanacheEntity {
+
+  @Column(name="hash", unique = true)
+  String hash;
+
+  @Column(name = "destination")
+  String destination;
+
+  @Column(name = "creation_date")
+  LocalDateTime creationDate;
+}

modules/pathit-storage-postgres/runtime/src/main/java/fr/codeanddata/pathit/storage/postgres/mappers/PathMapEntityMapper.java

@@ -0,0 +1,12 @@
+package fr.codeanddata.pathit.storage.postgres.mappers;
+
+import fr.codeanddata.pathit.core.models.PathMap;
+import fr.codeanddata.pathit.storage.postgres.entity.PathMapEntity;
+import org.mapstruct.Mapper;
+import org.mapstruct.MappingConstants;
+
+@Mapper(componentModel = MappingConstants.ComponentModel.CDI)
+public interface PathMapEntityMapper {
+  PathMap toModel(PathMapEntity pathMapEntity);
+  PathMapEntity toEntity(PathMap model);
+}

modules/pathit-storage-postgres/runtime/src/main/java/fr/codeanddata/pathit/storage/postgres/repository/PathMapJpaRepository.java

@@ -0,0 +1,34 @@
+package fr.codeanddata.pathit.storage.postgres.repository;
+
+import fr.codeanddata.pathit.core.PathMapRepository;
+import fr.codeanddata.pathit.core.models.PathMap;
+import fr.codeanddata.pathit.storage.postgres.entity.PathMapEntity;
+import fr.codeanddata.pathit.storage.postgres.mappers.PathMapEntityMapper;
+import io.quarkus.hibernate.reactive.panache.PanacheRepository;
+import io.quarkus.hibernate.reactive.panache.common.WithSession;
+import io.quarkus.hibernate.reactive.panache.common.WithTransaction;
+import io.smallrye.mutiny.Uni;
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.inject.Inject;
+
+@ApplicationScoped
+public class PathMapJpaRepository implements PathMapRepository, PanacheRepository<PathMapEntity> {
+
+  @Inject
+  PathMapEntityMapper mapper;
+
+  @WithTransaction
+  public Uni<PathMap> create(PathMap pathMap) {
+    final PathMapEntity entity = mapper.toEntity(pathMap);
+    return entity.persist()
+      .map(o -> (PathMapEntity) o)
+      .map(mapper::toModel);
+  }
+
+  @WithSession
+  public Uni<PathMap> getByHash(String hash) {
+    return find("hash = ?1", hash)
+      .singleResult()
+      .map(e -> mapper.toModel(e));
+  }
+}

modules/pathit-storage-postgres/runtime/src/main/resources/META-INF/quarkus-extension.yaml

@@ -0,0 +1,9 @@
+name: Pathit Storage Postgres
+#description: Do something useful.
+metadata:
+#  keywords:
+#    - pathit-storage-postgres
+#  guide: ... # To create and publish this guide, see https://github.com/quarkiverse/quarkiverse/wiki#documenting-your-extension
+#  categories:
+#    - "miscellaneous"
+#  status: "preview"

modules/pathit-storage-postgres/runtime/src/main/resources/application.properties

@@ -0,0 +1,11 @@
+quarkus.datasource.db-kind=postgresql
+
+quarkus.flyway.enabled=true
+quarkus.flyway.active=false
+quarkus.flyway.migrate-at-start=true
+quarkus.flyway.baseline-on-migrate=true
+quarkus.flyway.baseline-version=0.9
+quarkus.flyway.baseline-description=Initial version
+
+quarkus.native.resources.includes=src/main/resources/db/migration/**
+

modules/pathit-storage-postgres/runtime/src/main/resources/db/migration/V1.0.0__Base.sql

@@ -0,0 +1,11 @@
+create sequence path_map_SEQ start with 1 increment by 50;
+
+create table path_map
+(
+  id            bigint not null,
+  creation_date timestamp(6),
+  destination   varchar(255),
+  hash          varchar(255) unique,
+  primary key (id)
+);
+