try bump cpp client to 3.4.1 c1

.github/workflows/ci-pr-validation.yml

@@ -139,7 +139,13 @@ jobs:
       - name: Package Node binaries lib
         run: |
           npx node-pre-gyp package --target_arch=${{ matrix.arch }}
-
+          
+      - name: Upload artifacts
+        uses: actions/upload-artifact@v3
+        with:
+          name: macos-${{matrix.nodejs}}-${{matrix.arch}}
+          path: build/stage/*/*.tar.gz
+
   linux-napi:
     name: Build NAPI ${{matrix.image}} - Node ${{matrix.nodejs}} - ${{matrix.cpu.platform}}
     runs-on: ubuntu-22.04

pkg/mac/build-cpp-deps-lib.sh

@@ -105,10 +105,11 @@ if [ ! -f protobuf-${PROTOBUF_VERSION}.done ]; then
     curl -O -L  https://github.com/google/protobuf/releases/download/v${PROTOBUF_VERSION}/protobuf-cpp-${PROTOBUF_VERSION}.tar.gz
     tar xfz protobuf-cpp-${PROTOBUF_VERSION}.tar.gz
     pushd protobuf-${PROTOBUF_VERSION}
-      CXXFLAGS="-fPIC -arch arm64 -arch x86_64 -mmacosx-version-min=${MACOSX_DEPLOYMENT_TARGET}" \
-            ./configure --prefix=$PREFIX
-      make -j16 V=1
-      make install
+     pushd cmake/
+       cmake -B build -DCMAKE_CXX_FLAGS="-fPIC -arch arm64 -arch x86_64 -mmacosx-version-min=${MACOSX_DEPLOYMENT_TARGET}" \
+           -DCMAKE_INSTALL_PREFIX=$PREFIX
+       cmake --build build -j16 --target install
+     popd
     popd
 
     pushd install/lib

pulsar-client-cpp.txt

@@ -1,2 +1,2 @@
-CPP_CLIENT_BASE_URL=https://archive.apache.org/dist/pulsar/pulsar-client-cpp-3.2.0
-CPP_CLIENT_VERSION=3.2.0
+CPP_CLIENT_BASE_URL=https://dist.apache.org/repos/dist/dev/pulsar/pulsar-client-cpp/pulsar-client-cpp-3.4.1-candidate-1/
+CPP_CLIENT_VERSION=3.4.1

src/Producer.cc

@@ -138,7 +138,12 @@ Napi::Value Producer::Flush(const Napi::CallbackInfo &info) {
       [](pulsar_result result, void *ctx) {
         auto deferredContext = static_cast<ExtDeferredContext *>(ctx);
         auto deferred = deferredContext->deferred;
-        delete deferredContext;
+
+        deferredContext->callnum++;
+        if (deferredContext ->callnum == 2) {
+          delete deferredContext;
+          return;
+        }
 
         if (result != pulsar_result_Ok) {
           deferred->Reject(std::string("Failed to flush producer: ") + pulsar_result_str(result));

src/ThreadSafeDeferred.h

@@ -80,6 +80,7 @@ class ThreadSafeDeferred : public Napi::Promise::Deferred {
 struct ExtDeferredContext {
   ExtDeferredContext(std::shared_ptr<ThreadSafeDeferred> deferred) : deferred(deferred){};
   std::shared_ptr<ThreadSafeDeferred> deferred;
+  int callnum = 0;
 };
 
 #endif /* __THREADSAFE_DEFERRED_HPP */