From 43f57778f69b9ec7ea6fc3ba1b75c3ad26c35586 Mon Sep 17 00:00:00 2001
From: Ben Irvin <ben@innerdvations.com>
Date: Mon, 12 Dec 2022 15:36:04 +0100
Subject: [PATCH] add skip stage

---
 packages/core/data-transfer/lib/engine/index.ts | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

diff --git a/packages/core/data-transfer/lib/engine/index.ts b/packages/core/data-transfer/lib/engine/index.ts
index 29055e82b9..6abcd8445d 100644
--- a/packages/core/data-transfer/lib/engine/index.ts
+++ b/packages/core/data-transfer/lib/engine/index.ts
@@ -125,7 +125,7 @@ class TransferEngine<
     this.progress.stream.emit(type, payload);
   }
 
-  #emitStageUpdate(type: 'start' | 'finish' | 'progress', transferStage: TransferStage) {
+  #emitStageUpdate(type: 'start' | 'finish' | 'progress' | 'skip', transferStage: TransferStage) {
     this.progress.stream.emit(`stage::${type}`, {
       data: this.progress.data,
       stage: transferStage,
@@ -312,11 +312,13 @@ class TransferEngine<
 
     const inStream = await this.sourceProvider.streamSchemas?.();
     if (!inStream) {
+      this.#emitStageUpdate('skip', stageName);
       return;
     }
 
     const outStream = await this.destinationProvider.getSchemasStream?.();
     if (!outStream) {
+      this.#emitStageUpdate('skip', stageName);
       return;
     }
 
@@ -346,11 +348,13 @@ class TransferEngine<
 
     const inStream = await this.sourceProvider.streamEntities?.();
     if (!inStream) {
+      this.#emitStageUpdate('skip', stageName);
       return;
     }
 
     const outStream = await this.destinationProvider.getEntitiesStream?.();
     if (!outStream) {
+      this.#emitStageUpdate('skip', stageName);
       return;
     }
 
@@ -385,11 +389,13 @@ class TransferEngine<
 
     const inStream = await this.sourceProvider.streamLinks?.();
     if (!inStream) {
+      this.#emitStageUpdate('skip', stageName);
       return;
     }
 
     const outStream = await this.destinationProvider.getLinksStream?.();
     if (!outStream) {
+      this.#emitStageUpdate('skip', stageName);
       return;
     }
 
@@ -417,11 +423,13 @@ class TransferEngine<
     const stageName: TransferStage = 'assets';
     const inStream = await this.sourceProvider.streamAssets?.();
     if (!inStream) {
+      this.#emitStageUpdate('skip', stageName);
       return;
     }
 
     const outStream = await this.destinationProvider.getAssetsStream?.();
     if (!outStream) {
+      this.#emitStageUpdate('skip', stageName);
       return;
     }
 
@@ -457,11 +465,13 @@ class TransferEngine<
 
     const inStream = await this.sourceProvider.streamConfiguration?.();
     if (!inStream) {
+      this.#emitStageUpdate('skip', stageName);
       return;
     }
 
     const outStream = await this.destinationProvider.getConfigurationStream?.();
     if (!outStream) {
+      this.#emitStageUpdate('skip', stageName);
       return;
     }