fix: backward compatibility for SmartModuleKind (#3036)

Fixes #3035
infinyon · Mar 1, 2023 · fd6fb06 · fd6fb06 · github-actions · Mar 1, 2023
1 parent ed17bb1
commit fd6fb06
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/crates/fluvio-spu-schema/src/server/smartmodule.rs b/crates/fluvio-spu-schema/src/server/smartmodule.rs
@@ -94,6 +94,13 @@ pub enum SmartModuleKind {
     },
     #[fluvio(min_version = ARRAY_MAP_WASM_API)]
     FilterMap,
+    #[fluvio(min_version = SMART_MODULE_API, max_version = CHAIN_SMARTMODULE_API)]
+    Join(String),
+    #[fluvio(min_version = SMART_MODULE_API, max_version = CHAIN_SMARTMODULE_API)]
+    JoinStream {
+        topic: String,
+        derivedstream: String,
+    },
     #[fluvio(min_version = GENERIC_SMARTMODULE_API)]
     Generic(SmartModuleContextData),
 }
@@ -106,6 +113,8 @@ impl std::fmt::Display for SmartModuleKind {
             SmartModuleKind::ArrayMap => "array_map",
             SmartModuleKind::Aggregate { .. } => "aggregate",
             SmartModuleKind::FilterMap => "filter_map",
+            SmartModuleKind::Join(..) => "join",
+            SmartModuleKind::JoinStream { .. } => "join_stream",
             SmartModuleKind::Generic(..) => "smartmodule",
         };
         out.write_str(name)