Update C++ core to 1.0.0

Change-Id: I268e0b4146ce1aa20c5ec1a1c29ef74b245b971a
Reviewed-on: https://review.couchbase.org/c/couchbase-python-client/+/211682
Tested-by: Build Bot <build@couchbase.com>
Reviewed-by: Sergey Avseyev <sergey.avseyev@gmail.com>

Author: thejcfactor

deps/couchbase-cxx-client

@@ -198,7 +198,7 @@ retry_reason_to_string(couchbase::retry_reason reason)
 }
 
 PyObject*
-build_kv_error_map_info(couchbase::key_value_error_map_info error_info)
+build_kv_error_map_info(couchbase::core::key_value_error_map_info error_info)
 {
   PyObject* err_info = PyDict_New();
   PyObject* pyObj_tmp = PyLong_FromLong(static_cast<uint16_t>(error_info.code()));
@@ -244,7 +244,8 @@ build_kv_error_map_info(couchbase::key_value_error_map_info error_info)
 }
 
 void
-build_kv_error_context(const couchbase::key_value_error_context& ctx, PyObject* pyObj_error_ctx)
+build_kv_error_context(const couchbase::core::key_value_error_context& ctx,
+                       PyObject* pyObj_error_ctx)
 {
   PyObject* pyObj_tmp = nullptr;
   pyObj_tmp = PyUnicode_FromString(ctx.id().c_str());

src/exceptions.cxx

@@ -112,10 +112,10 @@ make_error_code(PycbcError ec);
 // end - needed for Pycbc error code
 
 PyObject*
-build_kv_error_map_info(couchbase::key_value_error_map_info error_info);
+build_kv_error_map_info(couchbase::core::key_value_error_map_info error_info);
 
 void
-build_kv_error_context(const couchbase::key_value_error_context& ctx, PyObject* pyObj_ctx);
+build_kv_error_context(const couchbase::core::key_value_error_context& ctx, PyObject* pyObj_ctx);
 
 /*
 
@@ -288,7 +288,7 @@ build_exception_from_context(const T& ctx,
 
 template<>
 inline PyObject*
-build_exception_from_context(const couchbase::key_value_error_context& ctx,
+build_exception_from_context(const couchbase::core::key_value_error_context& ctx,
                              const char* file,
                              int line,
                              std::string error_msg,
@@ -335,7 +335,7 @@ build_exception_from_context(const couchbase::key_value_error_context& ctx,
 
 template<>
 inline PyObject*
-build_exception_from_context(const couchbase::subdocument_error_context& ctx,
+build_exception_from_context(const couchbase::core::subdocument_error_context& ctx,
                              const char* file,
                              int line,
                              std::string error_msg,

src/exceptions.hxx

@@ -987,7 +987,7 @@ pycbc_txns::transaction_query_op([[maybe_unused]] PyObject* self, PyObject* args
   Py_XINCREF(pyObj_options);
   auto barrier = std::make_shared<std::promise<PyObject*>>();
   auto f = barrier->get_future();
-  Py_BEGIN_ALLOW_THREADS ctx->ctx.query(
+  Py_BEGIN_ALLOW_THREADS ctx->ctx->query(
     statement,
     *opt->opts,
     [pyObj_options, pyObj_callback, pyObj_errback, barrier](
@@ -1115,7 +1115,7 @@ pycbc_txns::transaction_op([[maybe_unused]] PyObject* self, PyObject* args, PyOb
         Py_RETURN_NONE;
       }
       couchbase::core::document_id id{ bucket, scope, collection, key };
-      Py_BEGIN_ALLOW_THREADS ctx->ctx.get_optional(
+      Py_BEGIN_ALLOW_THREADS ctx->ctx->get_optional(
         id,
         [barrier, pyObj_callback, pyObj_errback](
           std::exception_ptr err, std::optional<tx_core::transaction_get_result> res) {
@@ -1134,7 +1134,7 @@ pycbc_txns::transaction_op([[maybe_unused]] PyObject* self, PyObject* args, PyOb
                         fmt::format("no value given for an insert of key {}", id.key()).c_str());
         Py_RETURN_NONE;
       }
-      Py_BEGIN_ALLOW_THREADS ctx->ctx.insert(
+      Py_BEGIN_ALLOW_THREADS ctx->ctx->insert(
         id,
         value,
         [barrier, pyObj_callback, pyObj_errback](
@@ -1155,7 +1155,7 @@ pycbc_txns::transaction_op([[maybe_unused]] PyObject* self, PyObject* args, PyOb
       }
       auto tx_get_result =
         reinterpret_cast<pycbc_txns::transaction_get_result*>(pyObj_txn_get_result);
-      Py_BEGIN_ALLOW_THREADS ctx->ctx.replace(
+      Py_BEGIN_ALLOW_THREADS ctx->ctx->replace(
         *tx_get_result->res,
         value,
         [pyObj_callback, pyObj_errback, barrier](
@@ -1172,7 +1172,7 @@ pycbc_txns::transaction_op([[maybe_unused]] PyObject* self, PyObject* args, PyOb
       }
       auto tx_get_result =
         reinterpret_cast<pycbc_txns::transaction_get_result*>(pyObj_txn_get_result);
-      Py_BEGIN_ALLOW_THREADS ctx->ctx.remove(
+      Py_BEGIN_ALLOW_THREADS ctx->ctx->remove(
         *tx_get_result->res, [pyObj_callback, pyObj_errback, barrier](std::exception_ptr err) {
           handle_returning_void(pyObj_callback, pyObj_errback, barrier, err);
         });
@@ -1265,7 +1265,7 @@ pycbc_txns::run_transactions([[maybe_unused]] PyObject* self, PyObject* args, Py
   Py_INCREF(pyObj_inner_exc);
   auto barrier = std::make_shared<std::promise<PyObject*>>();
   auto f = barrier->get_future();
-  auto logic = [pyObj_logic, pyObj_inner_exc](tx_core::async_attempt_context& ctx) {
+  auto logic = [pyObj_logic, pyObj_inner_exc](std::shared_ptr<tx_core::async_attempt_context> ctx) {
     auto state = PyGILState_Ensure();
     auto py_ctx = new pycbc_txns::attempt_context(ctx);
     PyObject* pyObj_ctx = PyCapsule_New(py_ctx, "ctx_", dealloc_attempt_context);

src/transactions/transactions.cxx

@@ -118,10 +118,10 @@ struct transactions {
 };
 
 struct attempt_context {
-  tx_core::async_attempt_context& ctx;
+  std::shared_ptr<tx_core::async_attempt_context> ctx;
 
-  explicit attempt_context(tx_core::async_attempt_context& ctx)
-    : ctx(ctx)
+  explicit attempt_context(std::shared_ptr<tx_core::async_attempt_context> ctx)
+    : ctx(std::move(ctx))
   {
   }
 };