From 1b1652c646f5f54c0f20499ef9c3f5d21891adff Mon Sep 17 00:00:00 2001
From: Nicolas Ettlin <nicolas.ettlin@me.com>
Date: Wed, 20 Mar 2024 16:12:35 +0100
Subject: [PATCH] Add a fivetran-import client type (#23679)

This pull request adds a new `fivetran-import` client type.

GitOrigin-RevId: a37045e7c0b001b90cf562f2d1b3ebffa2712c7d
---
 crates/common/src/version.rs         | 6 ++++++
 crates/local_backend/src/subs/mod.rs | 1 +
 2 files changed, 7 insertions(+)

diff --git a/crates/common/src/version.rs b/crates/common/src/version.rs
index 0fd63983..5d7b7063 100644
--- a/crates/common/src/version.rs
+++ b/crates/common/src/version.rs
@@ -104,6 +104,7 @@ pub enum ClientType {
     Rust,
     StreamingImport,
     AirbyteExport,
+    FivetranImport,
     FivetranExport,
     Unrecognized(String),
 }
@@ -137,6 +138,7 @@ impl Display for ClientType {
             Self::Rust => write!(f, "rust"),
             Self::StreamingImport => write!(f, "streaming-import"),
             Self::AirbyteExport => write!(f, "airbyte-export"),
+            Self::FivetranImport => write!(f, "fivetran-import"),
             Self::FivetranExport => write!(f, "fivetran-export"),
             Self::Unrecognized(other_client) => write!(f, "{other_client}"),
         }
@@ -152,6 +154,7 @@ impl ClientType {
             Self::Rust => Some(rust.upgrade_required.clone()),
             Self::StreamingImport
             | Self::AirbyteExport
+            | Self::FivetranImport
             | Self::FivetranExport
             | Self::Unrecognized(_) => None,
         }
@@ -165,6 +168,7 @@ impl ClientType {
             Self::Rust => Some(rust.unsupported.clone()),
             Self::StreamingImport
             | Self::AirbyteExport
+            | Self::FivetranImport
             | Self::FivetranExport
             | Self::Unrecognized(_) => None,
         }
@@ -184,6 +188,7 @@ impl ClientType {
             },
             Self::StreamingImport
             | Self::AirbyteExport
+            | Self::FivetranImport
             | Self::FivetranExport
             | Self::Unrecognized(_) => "",
         }
@@ -285,6 +290,7 @@ impl ClientVersion {
             ClientType::Rust
             | ClientType::StreamingImport
             | ClientType::AirbyteExport
+            | ClientType::FivetranImport
             | ClientType::FivetranExport
             | ClientType::Unrecognized(_) => true,
         }
diff --git a/crates/local_backend/src/subs/mod.rs b/crates/local_backend/src/subs/mod.rs
index bcc3e1a9..c05cdd2c 100644
--- a/crates/local_backend/src/subs/mod.rs
+++ b/crates/local_backend/src/subs/mod.rs
@@ -319,6 +319,7 @@ fn new_sync_worker_config(client_version: ClientVersion) -> anyhow::Result<SyncW
         | ClientType::Python
         | ClientType::StreamingImport
         | ClientType::AirbyteExport
+        | ClientType::FivetranImport
         | ClientType::FivetranExport
         | ClientType::Actions => Err(anyhow::anyhow!(
             "No websocket support for client: {}",