Skip to content

Commit b00ce69

Browse files
authored
refactor: remove community in package and driver (#775)
1 parent c419673 commit b00ce69

149 files changed

Lines changed: 516 additions & 519 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

CLAUDE.md

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ This is a multi-module Gradle project using Kotlin DSL.
109109
- Base context contains runner ID and core configuration
110110
- Plugin contexts merged via `PriorityContextResolver`
111111
- External frameworks (Spring Boot) contribute dependency contexts
112-
- **Critical**: Hierarchical context MUST be built before driver initialization
112+
- **Critical**: Hierarchical context MUST be built before AuditStore initialization
113113

114114
**Pipeline Architecture**: Change execution organized in stages:
115115
- `LoadedPipeline` - Executable pipeline with stages and changes
@@ -136,7 +136,7 @@ This is a multi-module Gradle project using Kotlin DSL.
136136
- `flamingock-graalvm` - GraalVM native image support
137137

138138
**Community Modules** (`community/`):
139-
- Database-specific drivers (MongoDB, DynamoDB, Couchbase)
139+
- Database-specific AuditStores (MongoDB, DynamoDB, Couchbase)
140140
- `flamingock-importer` - Import from legacy systems (Mongock)
141141
- Version-specific implementations (e.g., Spring Data v3 legacy)
142142

@@ -202,11 +202,11 @@ When modifying the builder pattern in `AbstractFlamingockBuilder.build()`:
202202
1. Template loading must occur first
203203
2. Base context preparation before plugin initialization
204204
3. Plugin initialization before hierarchical context building
205-
4. Hierarchical context MUST be complete before driver initialization
205+
4. Hierarchical context MUST be complete before AuditStore initialization
206206
5. AuditStore initialization provides auditPersistence for audit writer registration
207207
6. Pipeline building contributes dependencies back to context
208208

209-
Violating this order will cause runtime failures due to missing dependencies during driver initialization.
209+
Violating this order will cause runtime failures due to missing dependencies during AuditStore initialization.
210210

211211
## License Header Management
212212

build.gradle.kts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ plugins {
1616

1717
allprojects {
1818
group = "io.flamingock"
19-
version = "1.0.0-beta.7"
19+
version = "1.0.0-beta.8"
2020

2121
repositories {
2222
mavenCentral()

cli/flamingock-cli/src/main/java/io/flamingock/cli/service/AuditService.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -24,10 +24,10 @@
2424
import io.flamingock.cli.factory.DynamoDBClientFactory;
2525
import io.flamingock.cli.factory.MongoClientFactory;
2626
import io.flamingock.cli.factory.SqlDataSourceFactory;
27-
import io.flamingock.community.couchbase.driver.CouchbaseAuditStore;
28-
import io.flamingock.community.dynamodb.driver.DynamoDBAuditStore;
29-
import io.flamingock.community.mongodb.sync.driver.MongoDBSyncAuditStore;
30-
import io.flamingock.community.sql.driver.SqlAuditStore;
27+
import io.flamingock.store.couchbase.CouchbaseAuditStore;
28+
import io.flamingock.store.dynamodb.DynamoDBAuditStore;
29+
import io.flamingock.store.mongodb.sync.MongoDBSyncAuditStore;
30+
import io.flamingock.store.sql.SqlAuditStore;
3131
import io.flamingock.internal.common.core.audit.AuditEntry;
3232
import io.flamingock.internal.common.core.context.Context;
3333
import io.flamingock.internal.common.core.context.Dependency;

community/flamingock-auditstore-couchbase/src/main/java/io/flamingock/community/couchbase/driver/CouchbaseAuditStore.java renamed to community/flamingock-auditstore-couchbase/src/main/java/io/flamingock/store/couchbase/CouchbaseAuditStore.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -13,12 +13,12 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16-
package io.flamingock.community.couchbase.driver;
16+
package io.flamingock.store.couchbase;
1717

1818
import com.couchbase.client.core.io.CollectionIdentifier;
1919
import com.couchbase.client.java.Bucket;
2020
import com.couchbase.client.java.Cluster;
21-
import io.flamingock.community.couchbase.internal.CouchbaseLockService;
21+
import io.flamingock.store.couchbase.internal.CouchbaseLockService;
2222
import io.flamingock.internal.common.core.error.FlamingockException;
2323
import io.flamingock.internal.util.constants.CommunityPersistenceConstants;
2424
import io.flamingock.internal.core.store.lock.community.CommunityLockService;
@@ -28,7 +28,7 @@
2828
import io.flamingock.internal.core.store.audit.community.CommunityAuditPersistence;
2929
import io.flamingock.internal.core.store.CommunityAuditStore;
3030
import io.flamingock.internal.common.core.context.ContextResolver;
31-
import io.flamingock.community.couchbase.internal.CouchbaseAuditPersistence;
31+
import io.flamingock.store.couchbase.internal.CouchbaseAuditPersistence;
3232
import io.flamingock.targetsystem.couchbase.CouchbaseTargetSystem;
3333

3434
public class CouchbaseAuditStore implements CommunityAuditStore {

community/flamingock-auditstore-couchbase/src/main/java/io/flamingock/community/couchbase/CouchbaseConfiguration.java renamed to community/flamingock-auditstore-couchbase/src/main/java/io/flamingock/store/couchbase/CouchbaseConfiguration.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16-
package io.flamingock.community.couchbase;
16+
package io.flamingock.store.couchbase;
1717

1818
import com.couchbase.client.core.io.CollectionIdentifier;
1919
import io.flamingock.internal.util.constants.CommunityPersistenceConstants;

community/flamingock-auditstore-couchbase/src/main/java/io/flamingock/community/couchbase/internal/CouchbaseAuditPersistence.java renamed to community/flamingock-auditstore-couchbase/src/main/java/io/flamingock/store/couchbase/internal/CouchbaseAuditPersistence.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16-
package io.flamingock.community.couchbase.internal;
16+
package io.flamingock.store.couchbase.internal;
1717

1818
import com.couchbase.client.java.Bucket;
1919
import com.couchbase.client.java.Cluster;

community/flamingock-auditstore-couchbase/src/main/java/io/flamingock/community/couchbase/internal/CouchbaseAuditor.java renamed to community/flamingock-auditstore-couchbase/src/main/java/io/flamingock/store/couchbase/internal/CouchbaseAuditor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16-
package io.flamingock.community.couchbase.internal;
16+
package io.flamingock.store.couchbase.internal;
1717

1818
import com.couchbase.client.core.error.CouchbaseException;
1919
import com.couchbase.client.java.Bucket;

community/flamingock-auditstore-couchbase/src/main/java/io/flamingock/community/couchbase/internal/CouchbaseLockService.java renamed to community/flamingock-auditstore-couchbase/src/main/java/io/flamingock/store/couchbase/internal/CouchbaseLockService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16-
package io.flamingock.community.couchbase.internal;
16+
package io.flamingock.store.couchbase.internal;
1717

1818
import com.couchbase.client.core.error.DocumentNotFoundException;
1919
import com.couchbase.client.java.Bucket;
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
io.flamingock.community.couchbase.driver.CouchbaseAuditStore
1+
io.flamingock.store.couchbase.CouchbaseAuditStore

community/flamingock-auditstore-couchbase/src/test/java/io/flamingock/community/couchbase/CouchbaseAuditStoreTest.java renamed to community/flamingock-auditstore-couchbase/src/test/java/io/flamingock/store/couchbase/CouchbaseAuditStoreTest.java

Lines changed: 13 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -13,18 +13,17 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16-
package io.flamingock.community.couchbase;
16+
package io.flamingock.store.couchbase;
1717

1818
import com.couchbase.client.core.io.CollectionIdentifier;
1919
import com.couchbase.client.java.Bucket;
2020
import com.couchbase.client.java.Cluster;
2121
import com.couchbase.client.java.Collection;
2222
import com.couchbase.client.java.json.JsonObject;
23-
import io.flamingock.community.couchbase.changes.failedWithoutRollback._001__create_index;
24-
import io.flamingock.community.couchbase.changes.failedWithoutRollback._002__insert_document;
25-
import io.flamingock.community.couchbase.changes.failedWithoutRollback._003__execution_with_exception;
26-
import io.flamingock.community.couchbase.changes.happyPath._003__insert_another_document;
27-
import io.flamingock.community.couchbase.driver.CouchbaseAuditStore;
23+
import io.flamingock.store.couchbase.changes.failedWithoutRollback._001__create_index;
24+
import io.flamingock.store.couchbase.changes.failedWithoutRollback._002__insert_document;
25+
import io.flamingock.store.couchbase.changes.failedWithoutRollback._003__execution_with_exception;
26+
import io.flamingock.store.couchbase.changes.happyPath._003__insert_another_document;
2827
import io.flamingock.targetsystem.couchbase.CouchbaseTargetSystem;
2928
import io.flamingock.internal.common.core.util.Deserializer;
3029
import io.flamingock.internal.common.core.audit.AuditEntry;
@@ -83,7 +82,7 @@ void tearDownEach() {
8382

8483

8584
@Test
86-
@DisplayName("When standalone runs the driver should persist the audit logs and the test data")
85+
@DisplayName("When standalone runs the AuditStore should persist the audit logs and the test data")
8786
void happyPath() {
8887
//Given-When
8988
Bucket bucket = cluster.bucket(BUCKET_NAME);
@@ -92,8 +91,8 @@ void happyPath() {
9291

9392
try (MockedStatic<Deserializer> mocked = Mockito.mockStatic(Deserializer.class)) {
9493
mocked.when(Deserializer::readPreviewPipelineFromFile).thenReturn(PipelineTestHelper.getPreviewPipeline(
95-
new Trio<>(io.flamingock.community.couchbase.changes.happyPath._001__create_index.class, Collections.singletonList(Collection.class)),
96-
new Trio<>(io.flamingock.community.couchbase.changes.happyPath._002__insert_document.class, Collections.singletonList(Collection.class)),
94+
new Trio<>(io.flamingock.store.couchbase.changes.happyPath._001__create_index.class, Collections.singletonList(Collection.class)),
95+
new Trio<>(io.flamingock.store.couchbase.changes.happyPath._002__insert_document.class, Collections.singletonList(Collection.class)),
9796
new Trio<>(_003__insert_another_document.class, Collections.singletonList(Collection.class)))
9897
);
9998

@@ -130,7 +129,7 @@ void happyPath() {
130129

131130

132131
@Test
133-
@DisplayName("When standalone runs the driver and execution fails (with rollback method) should persist all the audit logs up to the failed one (ROLLED_BACK)")
132+
@DisplayName("When standalone runs the AuditStore and execution fails (with rollback method) should persist all the audit logs up to the failed one (ROLLED_BACK)")
134133
void failedWithRollback() {
135134
//Given-When
136135
Bucket bucket = cluster.bucket(BUCKET_NAME);
@@ -139,9 +138,9 @@ void failedWithRollback() {
139138

140139
try (MockedStatic<Deserializer> mocked = Mockito.mockStatic(Deserializer.class)) {
141140
mocked.when(Deserializer::readPreviewPipelineFromFile).thenReturn(PipelineTestHelper.getPreviewPipeline(
142-
new Trio<>(io.flamingock.community.couchbase.changes.failedWithRollback._001__create_index.class, Collections.singletonList(Collection.class)),
143-
new Trio<>(io.flamingock.community.couchbase.changes.failedWithRollback._002__insert_document.class, Collections.singletonList(Collection.class)),
144-
new Trio<>(io.flamingock.community.couchbase.changes.failedWithRollback._003__execution_with_exception.class, Collections.singletonList(Collection.class), Collections.singletonList(Collection.class)))
141+
new Trio<>(io.flamingock.store.couchbase.changes.failedWithRollback._001__create_index.class, Collections.singletonList(Collection.class)),
142+
new Trio<>(io.flamingock.store.couchbase.changes.failedWithRollback._002__insert_document.class, Collections.singletonList(Collection.class)),
143+
new Trio<>(io.flamingock.store.couchbase.changes.failedWithRollback._003__execution_with_exception.class, Collections.singletonList(Collection.class), Collections.singletonList(Collection.class)))
145144
);
146145

147146
assertThrows(PipelineExecutionException.class, () -> {
@@ -176,7 +175,7 @@ void failedWithRollback() {
176175
}
177176

178177
@Test
179-
@DisplayName("When standalone runs the driver and execution fails (without rollback method) should persist all the audit logs up to the failed one (FAILED)")
178+
@DisplayName("When standalone runs the AuditStore and execution fails (without rollback method) should persist all the audit logs up to the failed one (FAILED)")
180179
void failedWithoutRollback() {
181180
//Given-When
182181
Bucket bucket = cluster.bucket(BUCKET_NAME);

0 commit comments

Comments
 (0)