Skip to content

Commit 791a6b9

Browse files
dieppadieppa
authored
feat: NonTransactionalTargetSystem (#381)
1 parent ef9f99d commit 791a6b9

File tree

16 files changed

+97
-92
lines changed

16 files changed

+97
-92
lines changed

‎TestAuthorChangeUnit.java‎

Lines changed: 0 additions & 11 deletions
This file was deleted.

‎cloud/flamingock-cloud/build.gradle.kts‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@ dependencies {
33

44
testAnnotationProcessor(project(":core:flamingock-processor"))
55
testImplementation(project(":utils:test-util"))
6+
testImplementation(project(":core:target-systems:nontransactional-target-system"))
67
}
78

89
description = "${project.name}'s description"

‎cloud/flamingock-cloud/src/test/java/io/flamingock/core/cloud/CloudAuditPersistenceTest.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919
import io.flamingock.api.annotations.Stage;
2020
import io.flamingock.core.cloud.changes.CloudChange1;
2121
import io.flamingock.core.cloud.changes.CloudChange2;
22-
import io.flamingock.internal.core.targets.DefaultTargetSystem;
22+
import io.flamingock.targetsystem.nontransactional.NonTransactionalTargetSystem;
2323
import io.flamingock.common.test.cloud.deprecated.AuditEntryMatcher;
2424
import io.flamingock.common.test.cloud.deprecated.MockRunnerServerOld;
2525
import io.flamingock.internal.util.ThreadSleeper;
@@ -115,7 +115,7 @@ void beforeEach() {
115115
.setHost("http://localhost:" + runnerServerPort)
116116
.setService(serviceName)
117117
.setEnvironment(environmentName)
118-
.addTargetSystem(new DefaultTargetSystem("auth0"))
118+
.addTargetSystem(new NonTransactionalTargetSystem("auth0"))
119119
//.addStage(new Stage("changes")
120120
// .setCodePackages(Collections.singletonList("io.flamingock.core.cloud.changes")))
121121
;

‎community/flamingock-auditstore-dynamodb/build.gradle.kts‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,8 @@ dependencies {
88

99

1010
testImplementation(project(":utils:test-util"))
11+
testImplementation(project(":core:target-systems:nontransactional-target-system"))
12+
1113
testImplementation("software.amazon.awssdk:url-connection-client:2.24.11")
1214
testImplementation("org.testcontainers:junit-jupiter:1.19.0")
1315
testImplementation("org.testcontainers:testcontainers:1.19.0")

‎community/flamingock-auditstore-dynamodb/src/test/java/io/flamingock/community/dynamodb/DynamoDBAuditPersistenceE2ETest.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@
2727
import io.flamingock.internal.common.core.audit.AuditEntry;
2828
import io.flamingock.internal.common.core.audit.AuditTxType;
2929
import io.flamingock.internal.core.builder.FlamingockFactory;
30-
import io.flamingock.internal.core.targets.DefaultTargetSystem;
30+
import io.flamingock.targetsystem.nontransactional.NonTransactionalTargetSystem;
3131
import io.flamingock.targetsystem.dynamodb.DynamoDBTargetSystem;
3232
import org.junit.jupiter.api.AfterEach;
3333
import org.junit.jupiter.api.BeforeEach;
@@ -143,7 +143,7 @@ void testNonTxScenarios() {
143143
FlamingockFactory.getCommunityBuilder()
144144
.setAuditStore(new DynamoDBAuditStore(sharedDynamoDBClient))
145145
.addTargetSystem(new DynamoDBTargetSystem("dynamodb", sharedDynamoDBClient))
146-
.addTargetSystem(new DefaultTargetSystem("non-tx-system")) // Non-transactional target system
146+
.addTargetSystem(new NonTransactionalTargetSystem("non-tx-system")) // Non-transactional target system
147147
.addDependency(sharedDynamoDBClient)
148148
.build()
149149
.run();
@@ -192,7 +192,7 @@ void testNonTxScenariosWithoutDependencies() {
192192
FlamingockFactory.getCommunityBuilder()
193193
.setAuditStore(new DynamoDBAuditStore(sharedDynamoDBClient))
194194
.addTargetSystem(new DynamoDBTargetSystem("dynamodb", sharedDynamoDBClient))
195-
.addTargetSystem(new DefaultTargetSystem("non-tx-system")) // Non-transactional target system
195+
.addTargetSystem(new NonTransactionalTargetSystem("non-tx-system")) // Non-transactional target system
196196
.build()
197197
.run();
198198
});
@@ -349,7 +349,7 @@ void testTargetSystemIdVariations() {
349349
FlamingockFactory.getCommunityBuilder()
350350
.setAuditStore(new DynamoDBAuditStore(sharedDynamoDBClient))
351351
.addTargetSystem(new DynamoDBTargetSystem("dynamodb", sharedDynamoDBClient))
352-
.addTargetSystem(new DefaultTargetSystem("non-tx-system"))
352+
.addTargetSystem(new NonTransactionalTargetSystem("non-tx-system"))
353353
.addTargetSystem(new DynamoDBTargetSystem("mongo-system", separateDynamoDBClient))
354354
.addDependency(sharedDynamoDBClient)
355355
.build()

‎community/flamingock-auditstore-mongodb-sync/build.gradle.kts‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@ dependencies {
1111

1212

1313
testImplementation(project(":utils:test-util"))
14+
testImplementation(project(":core:target-systems:nontransactional-target-system"))
1415
testImplementation(project(":e2e:core-e2e"))
1516
testImplementation("org.testcontainers:mongodb:1.18.3")
1617
testImplementation("org.testcontainers:junit-jupiter:1.18.3")

‎community/flamingock-auditstore-mongodb-sync/src/test/java/io/flamingock/community/mongodb/sync/MongoSyncAuditPersistenceE2ETest.java‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
import io.flamingock.core.kit.audit.AuditTestSupport;
3131
import io.flamingock.internal.common.core.audit.AuditEntry;
3232
import io.flamingock.internal.common.core.audit.AuditTxType;
33-
import io.flamingock.internal.core.targets.DefaultTargetSystem;
33+
import io.flamingock.targetsystem.nontransactional.NonTransactionalTargetSystem;
3434
import io.flamingock.mongodb.kit.MongoDBSyncTestKit;
3535
import io.flamingock.targetystem.mongodb.sync.MongoDBSyncTargetSystem;
3636
import org.junit.jupiter.api.AfterEach;
@@ -135,7 +135,7 @@ void testNonTxScenarios() {
135135
testKit.createBuilder()
136136
.setAuditStore(new MongoDBSyncAuditStore(sharedMongoClient, "test"))
137137
.addTargetSystem(new MongoDBSyncTargetSystem("mongodb", sharedMongoClient, "test"))
138-
.addTargetSystem(new DefaultTargetSystem("non-tx-system")) // Non-transactional target system
138+
.addTargetSystem(new NonTransactionalTargetSystem("non-tx-system")) // Non-transactional target system
139139
.build()
140140
.run();
141141
});
@@ -292,7 +292,7 @@ void testTargetSystemIdVariations() {
292292
testKit.createBuilder()
293293
.setAuditStore(new MongoDBSyncAuditStore(sharedMongoClient, "test"))
294294
.addTargetSystem(new MongoDBSyncTargetSystem("mongodb", sharedMongoClient, "test"))
295-
.addTargetSystem(new DefaultTargetSystem("non-tx-system"))
295+
.addTargetSystem(new NonTransactionalTargetSystem("non-tx-system"))
296296
.addTargetSystem(new MongoDBSyncTargetSystem("tx-separate-system", separateMongoClient, "test"))
297297
.build()
298298
.run();

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@ dependencies {
33
implementation(project(":core:flamingock-core"))
44
api(project(":core:flamingock-core-api"))
55
// target systems
6+
api(project(":core:target-systems:nontransactional-target-system"))
67
api(project(":core:target-systems:couchbase-target-system"))
78
api(project(":core:target-systems:dynamodb-target-system"))
89
api(project(":core:target-systems:mongodb-springdata-target-system"))

‎core/target-systems/nontransactional-target-system/build.gradle.kts‎

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
import org.jetbrains.kotlin.gradle.utils.extendsFrom
2+
3+
dependencies {
4+
//Flamingock
5+
api(project(":core:flamingock-core"))
6+
}
7+
8+
description = "${project.name}'s description"
9+
10+
java {
11+
toolchain {
12+
languageVersion.set(JavaLanguageVersion.of(8))
13+
}
14+
}
15+
16+
configurations.testImplementation {
17+
extendsFrom(configurations.compileOnly.get())
18+
}

core/flamingock-core/src/main/java/io/flamingock/internal/core/targets/DefaultTargetSystem.java renamed to core/target-systems/nontransactional-target-system/src/main/java/io/flamingock/targetsystem/nontransactional/NonTransactionalTargetSystem.java

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -13,21 +13,20 @@
1313
* See the License for the specific language governing permissions and
1414
* limitations under the License.
1515
*/
16-
package io.flamingock.internal.core.targets;
16+
package io.flamingock.targetsystem.nontransactional;
1717

18-
import io.flamingock.internal.core.runtime.ExecutionRuntime;
1918

20-
import java.util.function.Function;
19+
import io.flamingock.internal.core.targets.AbstractTargetSystem;
2120

22-
public class DefaultTargetSystem extends AbstractTargetSystem<DefaultTargetSystem> {
21+
public class NonTransactionalTargetSystem extends AbstractTargetSystem<NonTransactionalTargetSystem> {
2322

2423

25-
public DefaultTargetSystem(String id) {
24+
public NonTransactionalTargetSystem(String id) {
2625
super(id);
2726
}
2827

2928
@Override
30-
protected DefaultTargetSystem getSelf() {
29+
protected NonTransactionalTargetSystem getSelf() {
3130
return this;
3231
}
3332

0 commit comments

Comments
 (0)