Method connect

src/connection.cxx:129–184

}

PyObject*
Connection::connect(PyObject* kwargs)
{
  PyObject* pyObj_connstr = PyDict_GetItemString(kwargs, "connstr");
  PyObject* pyObj_auth = PyDict_GetItemString(kwargs, "auth");
  PyObject* pyObj_options = PyDict_GetItemString(kwargs, "options");
  PyObject* pyObj_callback = PyDict_GetItemString(kwargs, "callback");
  PyObject* pyObj_errback = PyDict_GetItemString(kwargs, "errback");

  if (!validate_and_incref_callbacks(pyObj_callback, pyObj_errback)) {
    return nullptr;
  }

  std::shared_ptr<std::promise<PyObject*>> barrier = nullptr;
  std::future<PyObject*> fut;
  if (nullptr == pyObj_callback && nullptr == pyObj_errback) {
    barrier = std::make_shared<std::promise<PyObject*>>();
    fut = barrier->get_future();
  }

  try {
    std::string conn_str = std::string(PyUnicode_AsUTF8(pyObj_connstr));
    auto connstr = couchbase::core::utils::parse_connection_string(conn_str);
    auto creds = py_to_cbpp<couchbase::core::cluster_credentials>(pyObj_auth);

    update_cluster_options_from_py(connstr.options, pyObj_options, pyObj_auth);
    couchbase::core::origin origin(creds, connstr);

    Py_BEGIN_ALLOW_THREADS
    {
      cluster_.open(
        origin,
        [callback = pyObj_callback, errback = pyObj_errback, barrier, this](std::error_code ec) {
          handle_connection_operation_callback(
            ec, "connect", callback, errback, barrier, connection_state_action::set_connected);
        });
    }
    Py_END_ALLOW_THREADS

      if (barrier)
    {
      PyObject* result = nullptr;
      Py_BEGIN_ALLOW_THREADS result = fut.get();
      Py_END_ALLOW_THREADS return result;
    }
    Py_RETURN_NONE;
  } catch (const std::exception& e) {
    if (barrier) {
      barrier->set_value(nullptr);
    }
    PyErr_SetString(PyExc_RuntimeError, e.what());
    Py_XDECREF(pyObj_callback);
    Py_XDECREF(pyObj_errback);
    return nullptr;
  }
}

PyObject*