Skip to content

Commit 1fc9e52

Browse files
ksrichardsdbondi
andauthored
fix(engine): remove flow template (tari-project#1366)
Description --- Removed flow template support. Closes tari-project#1334 Motivation and Context --- Flow templates were not used and outdated. How Has This Been Tested? --- What process can a PR reviewer use to test or verify this change? --- Breaking Changes --- - [ ] None - [x] Requires data directory to be deleted - [ ] Other - Please specify <!-- This is an auto-generated comment: release notes by coderabbit.ai --> ## Summary by CodeRabbit - **Refactor** - Removed support for flow-based templates, with system behavior now focused on WASM and Manifest types for template execution and error handling. - **Chores** - Cleaned up and streamlined internal processing by eliminating obsolete flow components and related worker implementations. <!-- end of auto-generated comment: release notes by coderabbit.ai --> --------- Co-authored-by: Stan Bondi <sdbondi@users.noreply.github.com>
1 parent b2b795d commit 1fc9e52

File tree

34 files changed

+6
-949
lines changed

34 files changed

+6
-949
lines changed

Cargo.lock

Lines changed: 0 additions & 13 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

applications/tari_indexer/src/json_rpc/handlers.rs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -561,9 +561,7 @@ impl JsonRpcHandlers {
561561
.load_template()
562562
.map_err(|e| Self::internal_error(answer_id, format!("Error loading template: {}", e)))?,
563563
// TemplateExecutable::DownloadableWasm is never returned ad there is no DB type for that
564-
TemplateExecutable::DownloadableWasm(_, _) |
565-
TemplateExecutable::Manifest(_) |
566-
TemplateExecutable::Flow(_) => {
564+
TemplateExecutable::DownloadableWasm(_, _) | TemplateExecutable::Manifest(_) => {
567565
return Err(JsonRpcResponse::error(
568566
answer_id,
569567
JsonRpcError::new(

applications/tari_validator_node/src/p2p/rpc/template_sync_task.rs

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -99,13 +99,6 @@ impl TemplateSyncTask {
9999
template_type: TemplateType::Manifest.into(),
100100
template_name: template.metadata.name,
101101
}),
102-
TemplateExecutable::Flow(flow) => Ok(SyncTemplatesResponse {
103-
address: template.metadata.address.to_vec(),
104-
author_public_key: template.metadata.author_public_key.to_vec(),
105-
binary: flow.into_bytes(),
106-
template_type: TemplateType::Flow.into(),
107-
template_name: template.metadata.name,
108-
}),
109102
// this case won't happen as there is no DB type for downloadable WASM
110103
TemplateExecutable::DownloadableWasm(_, _) => {
111104
Err(RpcStatus::not_implemented("Unsupported type!"))

dan_layer/engine/Cargo.toml

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,13 +23,11 @@ tari_transaction = { workspace = true }
2323
anyhow = { workspace = true }
2424
blake2 = { workspace = true }
2525
cargo_toml = { workspace = true }
26-
d3ne = { workspace = true }
2726
log = { workspace = true, features = ["std"] }
2827
rand = { workspace = true }
2928
indexmap = { workspace = true }
3029
semver = { workspace = true }
3130
serde = { workspace = true, default-features = true }
32-
serde_json = { workspace = true }
3331
thiserror = { workspace = true }
3432
tempfile = { workspace = true }
3533
wasmer = { workspace = true, features = ["cranelift"] }

dan_layer/engine/src/flow/error.rs

Lines changed: 0 additions & 14 deletions
This file was deleted.

dan_layer/engine/src/flow/flow_context.rs

Lines changed: 0 additions & 16 deletions
This file was deleted.

dan_layer/engine/src/flow/flow_definition.rs

Lines changed: 0 additions & 4 deletions
This file was deleted.

dan_layer/engine/src/flow/flow_factory.rs

Lines changed: 0 additions & 93 deletions
This file was deleted.

dan_layer/engine/src/flow/flow_instance.rs

Lines changed: 0 additions & 101 deletions
This file was deleted.

dan_layer/engine/src/flow/mod.rs

Lines changed: 0 additions & 34 deletions
This file was deleted.

0 commit comments

Comments
 (0)