feat(mongodb): add reactive audit store and target systems

.github/workflows/release.yml

@@ -174,6 +174,19 @@ jobs:
       FLAMINGOCK_JRELEASER_GPG_SECRET_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_SECRET_KEY }}
       FLAMINGOCK_JRELEASER_GPG_PASSPHRASE: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PASSPHRASE }}
 
+  flamingock-mongodb-reactive-auditstore:
+    needs: [ build ]
+    uses: ./.github/workflows/module-release-graalvm.yml
+    with:
+      module: flamingock-mongodb-reactive-auditstore
+    secrets:
+      FLAMINGOCK_JRELEASER_GITHUB_TOKEN: ${{ secrets.FLAMINGOCK_JRELEASER_GITHUB_TOKEN }}
+      FLAMINGOCK_JRELEASER_MAVENCENTRAL_USERNAME: ${{ secrets.FLAMINGOCK_JRELEASER_MAVENCENTRAL_USERNAME }}
+      FLAMINGOCK_JRELEASER_MAVENCENTRAL_PASSWORD: ${{ secrets.FLAMINGOCK_JRELEASER_MAVENCENTRAL_PASSWORD }}
+      FLAMINGOCK_JRELEASER_GPG_PUBLIC_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PUBLIC_KEY }}
+      FLAMINGOCK_JRELEASER_GPG_SECRET_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_SECRET_KEY }}
+      FLAMINGOCK_JRELEASER_GPG_PASSPHRASE: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PASSPHRASE }}
+
   flamingock-couchbase-auditstore:
     needs: [ build ]
     uses: ./.github/workflows/module-release-graalvm.yml
@@ -279,6 +292,19 @@ jobs:
       FLAMINGOCK_JRELEASER_GPG_SECRET_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_SECRET_KEY }}
       FLAMINGOCK_JRELEASER_GPG_PASSPHRASE: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PASSPHRASE }}
 
+  flamingock-mongodb-reactive-externalsystem-api:
+    needs: [ build ]
+    uses: ./.github/workflows/module-release-graalvm.yml
+    with:
+      module: flamingock-mongodb-reactive-externalsystem-api
+    secrets:
+      FLAMINGOCK_JRELEASER_GITHUB_TOKEN: ${{ secrets.FLAMINGOCK_JRELEASER_GITHUB_TOKEN }}
+      FLAMINGOCK_JRELEASER_MAVENCENTRAL_USERNAME: ${{ secrets.FLAMINGOCK_JRELEASER_MAVENCENTRAL_USERNAME }}
+      FLAMINGOCK_JRELEASER_MAVENCENTRAL_PASSWORD: ${{ secrets.FLAMINGOCK_JRELEASER_MAVENCENTRAL_PASSWORD }}
+      FLAMINGOCK_JRELEASER_GPG_PUBLIC_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PUBLIC_KEY }}
+      FLAMINGOCK_JRELEASER_GPG_SECRET_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_SECRET_KEY }}
+      FLAMINGOCK_JRELEASER_GPG_PASSPHRASE: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PASSPHRASE }}
+
   flamingock-mongodb-sync-targetsystem:
     needs: [ build ]
     uses: ./.github/workflows/module-release-graalvm.yml
@@ -292,6 +318,19 @@ jobs:
       FLAMINGOCK_JRELEASER_GPG_SECRET_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_SECRET_KEY }}
       FLAMINGOCK_JRELEASER_GPG_PASSPHRASE: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PASSPHRASE }}
 
+  flamingock-mongodb-reactive-targetsystem:
+    needs: [ build ]
+    uses: ./.github/workflows/module-release-graalvm.yml
+    with:
+      module: flamingock-mongodb-reactive-targetsystem
+    secrets:
+      FLAMINGOCK_JRELEASER_GITHUB_TOKEN: ${{ secrets.FLAMINGOCK_JRELEASER_GITHUB_TOKEN }}
+      FLAMINGOCK_JRELEASER_MAVENCENTRAL_USERNAME: ${{ secrets.FLAMINGOCK_JRELEASER_MAVENCENTRAL_USERNAME }}
+      FLAMINGOCK_JRELEASER_MAVENCENTRAL_PASSWORD: ${{ secrets.FLAMINGOCK_JRELEASER_MAVENCENTRAL_PASSWORD }}
+      FLAMINGOCK_JRELEASER_GPG_PUBLIC_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PUBLIC_KEY }}
+      FLAMINGOCK_JRELEASER_GPG_SECRET_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_SECRET_KEY }}
+      FLAMINGOCK_JRELEASER_GPG_PASSPHRASE: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PASSPHRASE }}
+
   flamingock-mongodb-springdata-targetsystem:
     needs: [ build ]
     uses: ./.github/workflows/module-release-graalvm.yml
@@ -305,6 +344,19 @@ jobs:
       FLAMINGOCK_JRELEASER_GPG_SECRET_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_SECRET_KEY }}
       FLAMINGOCK_JRELEASER_GPG_PASSPHRASE: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PASSPHRASE }}
 
+  flamingock-mongodb-springdata-reactive-targetsystem:
+    needs: [ build ]
+    uses: ./.github/workflows/module-release-graalvm.yml
+    with:
+      module: flamingock-mongodb-springdata-reactive-targetsystem
+    secrets:
+      FLAMINGOCK_JRELEASER_GITHUB_TOKEN: ${{ secrets.FLAMINGOCK_JRELEASER_GITHUB_TOKEN }}
+      FLAMINGOCK_JRELEASER_MAVENCENTRAL_USERNAME: ${{ secrets.FLAMINGOCK_JRELEASER_MAVENCENTRAL_USERNAME }}
+      FLAMINGOCK_JRELEASER_MAVENCENTRAL_PASSWORD: ${{ secrets.FLAMINGOCK_JRELEASER_MAVENCENTRAL_PASSWORD }}
+      FLAMINGOCK_JRELEASER_GPG_PUBLIC_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PUBLIC_KEY }}
+      FLAMINGOCK_JRELEASER_GPG_SECRET_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_SECRET_KEY }}
+      FLAMINGOCK_JRELEASER_GPG_PASSPHRASE: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PASSPHRASE }}
+
   flamingock-sql-externalsystem-api:
     needs: [ build ]
     uses: ./.github/workflows/module-release-graalvm.yml
@@ -396,6 +448,19 @@ jobs:
       FLAMINGOCK_JRELEASER_GPG_SECRET_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_SECRET_KEY }}
       FLAMINGOCK_JRELEASER_GPG_PASSPHRASE: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PASSPHRASE }}
 
+  flamingock-reactive-util:
+    needs: [ build ]
+    uses: ./.github/workflows/module-release-graalvm.yml
+    with:
+      module: flamingock-reactive-util
+    secrets:
+      FLAMINGOCK_JRELEASER_GITHUB_TOKEN: ${{ secrets.FLAMINGOCK_JRELEASER_GITHUB_TOKEN }}
+      FLAMINGOCK_JRELEASER_MAVENCENTRAL_USERNAME: ${{ secrets.FLAMINGOCK_JRELEASER_MAVENCENTRAL_USERNAME }}
+      FLAMINGOCK_JRELEASER_MAVENCENTRAL_PASSWORD: ${{ secrets.FLAMINGOCK_JRELEASER_MAVENCENTRAL_PASSWORD }}
+      FLAMINGOCK_JRELEASER_GPG_PUBLIC_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PUBLIC_KEY }}
+      FLAMINGOCK_JRELEASER_GPG_SECRET_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_SECRET_KEY }}
+      FLAMINGOCK_JRELEASER_GPG_PASSPHRASE: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PASSPHRASE }}
+
   mongodb-util:
     needs: [ build ]
     uses: ./.github/workflows/module-release-graalvm.yml
@@ -409,6 +474,32 @@ jobs:
       FLAMINGOCK_JRELEASER_GPG_SECRET_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_SECRET_KEY }}
       FLAMINGOCK_JRELEASER_GPG_PASSPHRASE: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PASSPHRASE }}
 
+  mongodb-sync-util:
+    needs: [ build ]
+    uses: ./.github/workflows/module-release-graalvm.yml
+    with:
+      module: mongodb-sync-util
+    secrets:
+      FLAMINGOCK_JRELEASER_GITHUB_TOKEN: ${{ secrets.FLAMINGOCK_JRELEASER_GITHUB_TOKEN }}
+      FLAMINGOCK_JRELEASER_MAVENCENTRAL_USERNAME: ${{ secrets.FLAMINGOCK_JRELEASER_MAVENCENTRAL_USERNAME }}
+      FLAMINGOCK_JRELEASER_MAVENCENTRAL_PASSWORD: ${{ secrets.FLAMINGOCK_JRELEASER_MAVENCENTRAL_PASSWORD }}
+      FLAMINGOCK_JRELEASER_GPG_PUBLIC_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PUBLIC_KEY }}
+      FLAMINGOCK_JRELEASER_GPG_SECRET_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_SECRET_KEY }}
+      FLAMINGOCK_JRELEASER_GPG_PASSPHRASE: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PASSPHRASE }}
+
+  mongodb-reactive-util:
+    needs: [ build ]
+    uses: ./.github/workflows/module-release-graalvm.yml
+    with:
+      module: mongodb-reactive-util
+    secrets:
+      FLAMINGOCK_JRELEASER_GITHUB_TOKEN: ${{ secrets.FLAMINGOCK_JRELEASER_GITHUB_TOKEN }}
+      FLAMINGOCK_JRELEASER_MAVENCENTRAL_USERNAME: ${{ secrets.FLAMINGOCK_JRELEASER_MAVENCENTRAL_USERNAME }}
+      FLAMINGOCK_JRELEASER_MAVENCENTRAL_PASSWORD: ${{ secrets.FLAMINGOCK_JRELEASER_MAVENCENTRAL_PASSWORD }}
+      FLAMINGOCK_JRELEASER_GPG_PUBLIC_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PUBLIC_KEY }}
+      FLAMINGOCK_JRELEASER_GPG_SECRET_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_SECRET_KEY }}
+      FLAMINGOCK_JRELEASER_GPG_PASSPHRASE: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PASSPHRASE }}
+
   mongodb-test-kit:
     needs: [ build ]
     uses: ./.github/workflows/module-release-graalvm.yml
@@ -422,6 +513,19 @@ jobs:
       FLAMINGOCK_JRELEASER_GPG_SECRET_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_SECRET_KEY }}
       FLAMINGOCK_JRELEASER_GPG_PASSPHRASE: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PASSPHRASE }}
 
+  mongodb-reactive-test-kit:
+    needs: [ build ]
+    uses: ./.github/workflows/module-release-graalvm.yml
+    with:
+      module: mongodb-reactive-test-kit
+    secrets:
+      FLAMINGOCK_JRELEASER_GITHUB_TOKEN: ${{ secrets.FLAMINGOCK_JRELEASER_GITHUB_TOKEN }}
+      FLAMINGOCK_JRELEASER_MAVENCENTRAL_USERNAME: ${{ secrets.FLAMINGOCK_JRELEASER_MAVENCENTRAL_USERNAME }}
+      FLAMINGOCK_JRELEASER_MAVENCENTRAL_PASSWORD: ${{ secrets.FLAMINGOCK_JRELEASER_MAVENCENTRAL_PASSWORD }}
+      FLAMINGOCK_JRELEASER_GPG_PUBLIC_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PUBLIC_KEY }}
+      FLAMINGOCK_JRELEASER_GPG_SECRET_KEY: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_SECRET_KEY }}
+      FLAMINGOCK_JRELEASER_GPG_PASSPHRASE: ${{ secrets.FLAMINGOCK_JRELEASER_GPG_PASSPHRASE }}
+
   dynamodb-util:
     needs: [ build ]
     uses: ./.github/workflows/module-release-graalvm.yml
@@ -585,23 +689,31 @@ jobs:
       flamingock-community,
       flamingock-community-bom,
       flamingock-mongodb-sync-auditstore,
+      flamingock-mongodb-reactive-auditstore,
       flamingock-couchbase-auditstore,
       flamingock-dynamodb-auditstore,
       flamingock-importer,
       flamingock-springboot-integration,
       flamingock-nontransactional-targetsystem,
       flamingock-mongodb-externalsystem-api,
+      flamingock-mongodb-reactive-externalsystem-api,
       flamingock-mongodb-sync-targetsystem,
+      flamingock-mongodb-reactive-targetsystem,
       flamingock-mongodb-springdata-targetsystem,
+      flamingock-mongodb-springdata-reactive-targetsystem,
       flamingock-sql-externalsystem-api,
       flamingock-sql-targetsystem,
       flamingock-dynamodb-externalsystem-api,
       flamingock-dynamodb-targetsystem,
       flamingock-couchbase-externalsystem-api,
       flamingock-couchbase-targetsystem,
       test-util,
+      flamingock-reactive-util,
       mongodb-util,
+      mongodb-sync-util,
+      mongodb-reactive-util,
       mongodb-test-kit,
+      mongodb-reactive-test-kit,
       dynamodb-util,
       dynamodb-test-kit,
       couchbase-util,

buildSrc/src/main/kotlin/flamingock.project-structure.gradle.kts

@@ -24,6 +24,7 @@ val communityProjects = setOf(
     "flamingock-community-bom",
     "flamingock-community",
     "flamingock-mongodb-sync-auditstore",
+    "flamingock-mongodb-reactive-auditstore",
     "flamingock-couchbase-auditstore",
     "flamingock-dynamodb-auditstore",
     "flamingock-sql-auditstore",
@@ -38,14 +39,17 @@ val pluginProjects = setOf(
 val targetSystemProjects = setOf(
     "flamingock-nontransactional-targetsystem",
     "flamingock-mongodb-sync-targetsystem",
+    "flamingock-mongodb-reactive-targetsystem",
     "flamingock-mongodb-springdata-targetsystem",
+    "flamingock-mongodb-springdata-reactive-targetsystem",
     "flamingock-sql-targetsystem",
     "flamingock-dynamodb-targetsystem",
     "flamingock-couchbase-targetsystem"
 )
 
 val externalSystemProjects = setOf(
     "flamingock-mongodb-externalsystem-api",
+    "flamingock-mongodb-reactive-externalsystem-api",
     "flamingock-couchbase-externalsystem-api",
     "flamingock-dynamodb-externalsystem-api",
     "flamingock-sql-externalsystem-api"
@@ -55,6 +59,9 @@ val utilProjects = setOf(
     "general-util",
     "test-util",
     "mongodb-util",
+    "mongodb-sync-util",
+    "mongodb-reactive-util",
+    "flamingock-reactive-util",
     "dynamodb-util",
     "couchbase-util"
 )
@@ -68,6 +75,7 @@ val legacyProjects = setOf(
 
 val testKitsProjects = setOf(
     "mongodb-test-kit",
+    "mongodb-reactive-test-kit",
     "dynamodb-test-kit",
     "sql-test-kit",
     "couchbase-test-kit"

cloud/flamingock-cloud/build.gradle.kts

@@ -9,12 +9,16 @@ dependencies {
     api(project(":core:target-systems:flamingock-couchbase-targetsystem"))
     api(project(":core:target-systems:flamingock-dynamodb-targetsystem"))
     api(project(":core:target-systems:flamingock-mongodb-externalsystem-api"))
+    api(project(":core:target-systems:flamingock-mongodb-reactive-externalsystem-api"))
+    api(project(":core:target-systems:flamingock-mongodb-reactive-targetsystem"))
     api(project(":core:target-systems:flamingock-mongodb-springdata-targetsystem"))
+    api(project(":core:target-systems:flamingock-mongodb-springdata-reactive-targetsystem"))
     api(project(":core:target-systems:flamingock-mongodb-sync-targetsystem"))
     api(project(":core:target-systems:flamingock-sql-targetsystem"))
 // Community
     api(project(":community:flamingock-couchbase-auditstore"))
     api(project(":community:flamingock-dynamodb-auditstore"))
+    api(project(":community:flamingock-mongodb-reactive-auditstore"))
     api(project(":community:flamingock-mongodb-sync-auditstore"))
     api(project(":community:flamingock-sql-auditstore"))
 
@@ -41,4 +45,4 @@ java {
     toolchain {
         languageVersion.set(JavaLanguageVersion.of(8))
     }
-}
+}

community/flamingock-community-bom/build.gradle.kts

@@ -8,7 +8,9 @@ plugins {
 dependencies {
     constraints {
         // Add constraints for BOM managed modules
+        api("io.flamingock:flamingock-reactive-util:${version}")
         api("io.flamingock:flamingock-community:${version}")
+        api("io.flamingock:flamingock-mongodb-reactive-auditstore:$version")
         api("io.flamingock:flamingock-mongodb-sync-auditstore:$version")
         api("io.flamingock:flamingock-mongodb-springdata-auditstore:${version}")
         api("io.flamingock:flamingock-couchbase-auditstore:$version")
@@ -35,6 +37,9 @@ dependencies {
         //mongodb
         api("io.flamingock:flamingock-mongodb-sync-template:${mongodbTemplateVersion}")
         api("io.flamingock:flamingock-mongodb-externalsystem-api:${version}")
+        api("io.flamingock:flamingock-mongodb-reactive-externalsystem-api:${version}")
+        api("io.flamingock:flamingock-mongodb-reactive-targetsystem:${version}")
+        api("io.flamingock:flamingock-mongodb-springdata-reactive-targetsystem:${version}")
         api("io.flamingock:flamingock-mongodb-sync-targetsystem:${version}")
         api("io.flamingock:flamingock-mongodb-springdata-targetsystem:${version}")
 

community/flamingock-community/build.gradle.kts

@@ -8,12 +8,16 @@ dependencies {
     api(project(":core:target-systems:flamingock-couchbase-targetsystem"))
     api(project(":core:target-systems:flamingock-dynamodb-targetsystem"))
     api(project(":core:target-systems:flamingock-mongodb-externalsystem-api"))
+    api(project(":core:target-systems:flamingock-mongodb-reactive-externalsystem-api"))
+    api(project(":core:target-systems:flamingock-mongodb-reactive-targetsystem"))
+    api(project(":core:target-systems:flamingock-mongodb-springdata-reactive-targetsystem"))
     api(project(":core:target-systems:flamingock-mongodb-springdata-targetsystem"))
     api(project(":core:target-systems:flamingock-mongodb-sync-targetsystem"))
     api(project(":core:target-systems:flamingock-sql-targetsystem"))
 // Community
     api(project(":community:flamingock-couchbase-auditstore"))
     api(project(":community:flamingock-dynamodb-auditstore"))
+    api(project(":community:flamingock-mongodb-reactive-auditstore"))
     api(project(":community:flamingock-mongodb-sync-auditstore"))
     api(project(":community:flamingock-sql-auditstore"))
 }
@@ -24,4 +28,4 @@ java {
     toolchain {
         languageVersion.set(JavaLanguageVersion.of(8))
     }
-}
+}

community/flamingock-mongodb-reactive-auditstore/build.gradle.kts

@@ -0,0 +1,33 @@
+import org.jetbrains.kotlin.gradle.utils.extendsFrom
+
+dependencies {
+    implementation(project(":utils:mongodb-util"))
+    implementation(project(":utils:mongodb-reactive-util"))
+    implementation(project(":utils:flamingock-reactive-util"))
+    implementation(project(":core:flamingock-core"))
+
+    api(project(":core:target-systems:flamingock-mongodb-reactive-externalsystem-api"))
+
+    compileOnly("org.mongodb:mongodb-driver-reactivestreams:4.0.0")
+
+    testImplementation(project(":utils:test-util"))
+    testImplementation(project(":utils:mongodb-reactive-test-kit"))
+    testImplementation(project(":core:target-systems:flamingock-nontransactional-targetsystem"))
+    testImplementation(project(":core:target-systems:flamingock-mongodb-reactive-targetsystem"))
+    testImplementation("org.testcontainers:testcontainers-mongodb:2.0.2")
+    testImplementation("org.testcontainers:testcontainers-junit-jupiter:2.0.2")
+    testImplementation("org.mockito:mockito-inline:4.11.0")
+    testImplementation("io.mongock:mongock-standalone:5.5.0")
+}
+
+description = "MongoDB audit store implementation using reactive streams MongoDB driver"
+
+java {
+    toolchain {
+        languageVersion.set(JavaLanguageVersion.of(8))
+    }
+}
+
+configurations.testImplementation {
+    extendsFrom(configurations.compileOnly.get())
+}