Support for @transactional for blocking and reactive Transactionmanager.

Closes 1145.

Author: mikereiche

pom.xml

@@ -21,8 +21,11 @@
         <couchbase>3.2.5</couchbase>
         <couchbase.osgi>3.2.5</couchbase.osgi>
         <springdata.commons>2.7.0-SNAPSHOT</springdata.commons>
-        <java-module-name>spring.data.couchbase</java-module-name>
         <couchbase-transactions>1.2.2</couchbase-transactions>
+        <java-module-name>spring.data.couchbase</java-module-name>
+<!--
+        <spring.boot>2.6.0-RC1</spring.boot>
+-->
     </properties>
 
     <dependencyManagement>
@@ -39,13 +42,32 @@
 
     <dependencies>
 
+<!--
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+            <version>${spring.boot}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-aop</artifactId>
+            <version>${spring.boot}</version>
+        </dependency>
+-->
+
+
     <dependency>
         <groupId>com.couchbase.client</groupId>
         <artifactId>couchbase-transactions</artifactId>
         <version>${couchbase-transactions}</version>
+        <exclusions>
+            <exclusion>
+                <groupId>com.couchbase.client</groupId>
+                <artifactId>java-client</artifactId>
+            </exclusion>
+        </exclusions>
     </dependency>
 
-
         <dependency>
             <groupId>org.springframework</groupId>
             <artifactId>spring-context-support</artifactId>
@@ -67,12 +89,6 @@
             <version>${springdata.commons}</version>
         </dependency>
 
-        <dependency>
-            <groupId>com.couchbase.client</groupId>
-            <artifactId>java-client</artifactId>
-            <version>${couchbase}</version>
-        </dependency>
-
         <dependency>
             <groupId>org.springframework</groupId>
             <artifactId>spring-test</artifactId>
@@ -189,7 +205,14 @@
         <dependency>
             <groupId>com.squareup.okhttp3</groupId>
             <artifactId>okhttp</artifactId>
-            <version>4.4.0</version>
+            <version>4.8.1</version>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>com.squareup.okhttp3</groupId>
+            <artifactId>okhttp-tls</artifactId>
+            <version>4.8.1</version>
             <scope>test</scope>
         </dependency>
 
@@ -221,6 +244,36 @@
             <version>4.0.3</version>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>com.couchbase.client</groupId>
+            <artifactId>couchbase-transactions</artifactId>
+            <version>${couchbase-transactions}</version>
+            <scope>compile</scope>
+            <exclusions>
+                <exclusion>
+                    <groupId>com.couchbase.client</groupId>
+                    <artifactId>java-client</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+        <dependency>
+            <groupId>org.testcontainers</groupId>
+            <artifactId>testcontainers</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.couchbase.client</groupId>
+            <artifactId>java-client</artifactId>
+            <version>3.2.5</version>
+        </dependency>
+
+        <dependency>
+            <groupId>ch.qos.logback</groupId>
+            <artifactId>logback-classic</artifactId>
+            <version>1.2.5</version>
+            <scope>compile</scope>
+        </dependency>
+
 
     </dependencies>
 

src/main/java/com/couchbase/transactions/AttemptContextReactiveAccessor.java

@@ -0,0 +1,90 @@
+/*
+/*
+ * Copyright 2021 the original author or authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *        https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.couchbase.transactions;
+
+import com.couchbase.client.core.annotation.Stability;
+import com.couchbase.transactions.config.MergedTransactionConfig;
+import com.couchbase.transactions.config.PerTransactionConfig;
+import com.couchbase.transactions.config.PerTransactionConfigBuilder;
+import com.couchbase.transactions.config.TransactionConfig;
+import com.couchbase.transactions.forwards.Supported;
+import com.couchbase.transactions.log.TransactionLogger;
+
+import java.time.Duration;
+import java.time.temporal.ChronoUnit;
+import java.util.Optional;
+import java.util.UUID;
+
+/**
+ * To access the AttemptContextReactive held by AttemptContext
+ *
+ * @author Michael Reiche
+ */
+public class AttemptContextReactiveAccessor {
+
+  public static AttemptContextReactive getACR(AttemptContext attemptContext) {
+    return attemptContext.ctx();
+  }
+
+  public static AttemptContext from(AttemptContextReactive attemptContextReactive) {
+    return new AttemptContext(attemptContextReactive);
+  }
+
+  public static TransactionLogger getLogger(AttemptContextReactive attemptContextReactive){
+    return attemptContextReactive.LOGGER;
+  }
+  @Stability.Internal
+  public static AttemptContextReactive newAttemptContextReactive(TransactionsReactive transactions){
+    PerTransactionConfig perConfig = PerTransactionConfigBuilder.create().build();
+    MergedTransactionConfig merged = new MergedTransactionConfig(transactions.config(), Optional.of(perConfig));
+
+    TransactionContext overall = new TransactionContext(
+        transactions.cleanup().clusterData().cluster().environment().requestTracer(),
+        transactions.cleanup().clusterData().cluster().environment().eventBus(),
+        UUID.randomUUID().toString(), now(), Duration.ZERO, merged);
+
+    String txnId = UUID.randomUUID().toString();
+    overall.LOGGER.info(configDebug(transactions.config(), perConfig));
+    return transactions.createAttemptContext(overall, merged, txnId);
+  }
+
+  private static Duration now() {
+    return Duration.of(System.nanoTime(), ChronoUnit.NANOS);
+  }
+
+  static private String configDebug(TransactionConfig config, PerTransactionConfig perConfig) {
+    StringBuilder sb = new StringBuilder();
+    sb.append("library version: ");
+    sb.append(TransactionsReactive.class.getPackage().getImplementationVersion());
+    sb.append(" config: ");
+    sb.append("atrs=");
+    sb.append(config.numAtrs());
+    sb.append(", metadataCollection=");
+    sb.append(config.metadataCollection());
+    sb.append(", expiry=");
+    sb.append(perConfig.expirationTime().orElse(config.transactionExpirationTime()).toMillis());
+    sb.append("msecs durability=");
+    sb.append(config.durabilityLevel());
+    sb.append(" per-txn config=");
+    sb.append(" durability=");
+    sb.append(perConfig.durabilityLevel());
+    sb.append(", supported=");
+    sb.append(Supported.SUPPORTED);
+    return sb.toString();
+  }
+
+}