Method popManifest

src/brpc/couchbase.cpp:1557–1618

}

bool CouchbaseOperations::CouchbaseResponse::popManifest(
    std::string* manifest_json) {
  const size_t n = _buf.size();
  policy::CouchbaseResponseHeader header;
  if (n < sizeof(header)) {
    butil::string_printf(&_err, "buffer is too small to contain a header");
    return false;
  }
  _buf.copy_to(&header, sizeof(header));

  if (header.command != policy::CB_GET_COLLECTIONS_MANIFEST) {
    butil::string_printf(&_err, "Not a get collections manifest response");
    return false;
  }

  // Making sure buffer has the whole body (extras + key + value)
  if (n < sizeof(header) + header.total_body_length) {
    butil::string_printf(&_err, "Not enough data");
    return false;
  }

  if (header.status != 0) {
    // handle error case
    if (header.extras_length != 0) {
      DEBUG_PRINT("Get Collections Manifest response must not have extras");
    }
    if (header.key_length != 0) {
      DEBUG_PRINT("Get Collections Manifest response must not have key");
    }
    _buf.pop_front(sizeof(header) + header.extras_length + header.key_length);
    // Possibly read error message from value if present
    size_t value_size =
        header.total_body_length - header.extras_length - header.key_length;
    if (value_size > 0) {
      std::string err_msg;
      _buf.cutn(&err_msg, value_size);
      _err = formatErrorMessage(header.status, "Get Collections Manifest",
                                err_msg);
    } else {
      _err = formatErrorMessage(header.status, "Get Collections Manifest");
    }
    return false;
  }

  // Success case: the manifest should be in the value section
  size_t value_size =
      header.total_body_length - header.extras_length - header.key_length;
  if (value_size == 0) {
    butil::string_printf(&_err, "No manifest data in response");
    _buf.pop_front(sizeof(header) + header.total_body_length);
    return false;
  }

  // Skip header and any extras/key
  _buf.pop_front(sizeof(header) + header.extras_length + header.key_length);

  // Read the manifest JSON from the value section
  _buf.cutn(manifest_json, value_size);