diff --git a/services/backup/docker-server/contents/server/src/Reactors/server/PullBackupReactor.h b/services/backup/docker-server/contents/server/src/Reactors/server/PullBackupReactor.h
--- a/services/backup/docker-server/contents/server/src/Reactors/server/PullBackupReactor.h
+++ b/services/backup/docker-server/contents/server/src/Reactors/server/PullBackupReactor.h
@@ -1,33 +1,76 @@
 #pragma once
 
-#include "ServerBidiReactorBase.h"
+#include "BlobGetClientReactor.h"
+#include "DatabaseManager.h"
+#include "ServerWriteReactorBase.h"
+#include "ServiceBlobClient.h"
 
 #include "../_generated/backup.grpc.pb.h"
 #include "../_generated/backup.pb.h"
 
+#include <folly/MPMCQueue.h>
+
 #include <iostream>
 #include <memory>
+#include <mutex>
 #include <string>
 
 namespace comm {
 namespace network {
 namespace reactor {
 
-class PullBackupReactor : public ServerBidiReactorBase<
+class PullBackupReactor : public ServerWriteReactorBase<
                               backup::PullBackupRequest,
                               backup::PullBackupResponse> {
+
+  enum class State {
+    COMPACTION = 1,
+    LOGS = 2,
+  };
+
+  std::shared_ptr<database::BackupItem> backupItem;
+  std::shared_ptr<reactor::BlobGetClientReactor> getReactor;
+  std::shared_ptr<folly::MPMCQueue<std::string>> dataChunks;
+  ServiceBlobClient blobClient;
+  State state = State::COMPACTION;
+
+  void initializeGetReactor(const std::string &holder);
+
 public:
-  std::unique_ptr<ServerBidiReactorStatus> handleRequest(
-      backup::PullBackupRequest request,
-      backup::PullBackupResponse *response) override;
+  PullBackupReactor(const backup::PullBackupRequest *request);
+
+  void initialize() override;
+
+  std::unique_ptr<grpc::Status>
+  writeResponse(backup::PullBackupResponse *response) override;
 };
 
-std::unique_ptr<ServerBidiReactorStatus> PullBackupReactor::handleRequest(
-    backup::PullBackupRequest request,
-    backup::PullBackupResponse *response) {
-  // TODO handle request
-  return std::make_unique<ServerBidiReactorStatus>(
-      grpc::Status(grpc::StatusCode::UNIMPLEMENTED, "unimplemented"));
+PullBackupReactor::PullBackupReactor(const backup::PullBackupRequest *request)
+    : ServerWriteReactorBase<
+          backup::PullBackupRequest,
+          backup::PullBackupResponse>(request),
+      dataChunks(std::make_shared<folly::MPMCQueue<std::string>>(100)) {
+}
+
+void PullBackupReactor::initializeGetReactor(const std::string &holder) {
+  if (this->backupItem == nullptr) {
+    throw std::runtime_error("not enough data to initialize get reactor");
+  }
+  if (this->getReactor == nullptr) {
+    this->getReactor = std::make_shared<reactor::BlobGetClientReactor>(
+        holder, this->dataChunks);
+    this->getReactor->request.set_holder(holder);
+    this->blobClient.get(this->getReactor);
+  }
+}
+
+void PullBackupReactor::initialize() {
+  throw std::runtime_error("unimplemented");
+}
+
+std::unique_ptr<grpc::Status>
+PullBackupReactor::writeResponse(backup::PullBackupResponse *response) {
+  throw std::runtime_error("unimplemented");
 }
 
 } // namespace reactor