dataflow-rs 3.2.0

A lightweight rules engine for building IFTTT-style automation and data processing pipelines in Rust. Define rules with JSONLogic conditions, execute actions, and chain workflows.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135

[package]
name = "dataflow-rs"
version = "3.2.0"
edition = "2024"
rust-version = "1.85"
# Allowlist of what ships in the published .crate: the library, its examples
# and tests, and the user-facing root docs. An allowlist fails safe — future
# repo-root additions (CI config, tooling, the npm-published ui/, the GitHub
# Pages docs/) stay out without anyone remembering to add an exclude entry.
include = [
    "/src",
    "/examples",
    "/tests",
    "/README.md",
    "/CHANGELOG.md",
    "/CONTRIBUTING.md",
    "/SECURITY.md",
    "/LICENSE",
]
authors = ["Plasmatic Engineering <shankar@goplasmatic.io>"]
license = "Apache-2.0"
description = "A lightweight rules engine for building IFTTT-style automation and data processing pipelines in Rust. Define rules with JSONLogic conditions, execute actions, and chain workflows."
readme = "README.md"
homepage = "https://github.com/GoPlasmatic/dataflow-rs"
repository = "https://github.com/GoPlasmatic/dataflow-rs"
keywords = ["rules-engine", "ifttt", "automation", "jsonlogic", "workflow"]
categories = ["data-structures", "development-tools", "config"]

# docs.rs renders the operator families so their operator docs resolve.
# `wasm-web` is deliberately excluded — it is a platform switch, not API
# surface — which is why this is an explicit list rather than `all-features`.
[package.metadata.docs.rs]
features = ["all-operators"]

[features]
default = []

# Optional `datalogic-rs` operator families, each forwarding to the identically
# named feature there. The names deliberately mirror datalogic's so they need no
# translation when reading its documentation.
#
# NOTE `error-handling` here means the JSONLogic `try`/`throw` *operators*. It
# has nothing to do with dataflow-rs's own error handling (`DataflowError`,
# `continue_on_error`, `message.errors()`), which is unconditional.
#
#   datetime        datetime, timestamp, parse_date, format_date, date_diff, now
#   ext-string      length, starts_with, ends_with, upper, lower, trim, split
#   ext-array       sort, slice
#   ext-math        abs, ceil, floor
#   ext-control     exists, ??, switch (alias match), type
#   error-handling  try, throw
#
# Off by default, and enabling one is *not* a no-op for existing workflows: this
# crate always runs datalogic in templating mode, where an unknown operator name
# passes through as literal data. A `{"length": ...}` value that used to survive
# a `map` mapping intact starts evaluating instead. `datetime` goes further and
# changes `==` and the ordering operators on plain date-shaped strings. Enable
# only the families your rules actually use.
datetime = ["datalogic-rs/datetime"]
ext-string = ["datalogic-rs/ext-string"]
ext-array = ["datalogic-rs/ext-array"]
ext-math = ["datalogic-rs/ext-math"]
ext-control = ["datalogic-rs/ext-control"]
error-handling = ["datalogic-rs/error-handling"]

# Every family this crate exposes. Deliberately not datalogic's `flagd`
# (`fractional`, `sem_ver`): it is feature-flag-evaluation specific, and it is
# the only family that pulls an extra dependency. Adding a family here later is
# a semver-minor change.
all-operators = [
    "datetime",
    "ext-string",
    "ext-array",
    "ext-math",
    "ext-control",
    "error-handling",
]

# `uuid/js` is what supplies randomness on wasm32-unknown-unknown: uuid's own
# `getrandom` dependency is target-gated *off* for that triple, and its `js`
# feature routes through wasm-bindgen/js-sys instead.
#
# `datalogic-rs/wasm-clock` forwards `chrono?/wasmbind` — weak, so it is a no-op
# unless `datetime` turned datalogic's optional chrono on. It is redundant today
# with `chrono/wasmbind` above (both dependents resolve to one chrono unit and
# cargo unions their feature sets), but it states the requirement at the crate
# that actually has it, so datalogic's `now` keeps working on wasm32 even if
# this crate's own chrono edge later changes shape.
wasm-web = ["chrono/wasmbind", "uuid/js", "datalogic-rs/wasm-clock"]

[dependencies]
serde = { version = "1.0", features = ["derive", "rc"] }
serde_json = "1.0"
datalogic-rs = { version = "5.1", features = ["serde_json", "templating"] }
datavalue = { package = "datavalue-rs", version = "0.2.3", features = ["serde", "serde_json"] }
bumpalo = "3.20"
uuid = { version = "1.24", default-features = false, features = ["v7", "std"] }
chrono = { version = "0.4", default-features = false, features = ["clock", "std", "serde"] }
thiserror = "2.0"
log = "0.4"
tokio = { version = "1", features = ["rt", "macros"] }
async-trait = "0.1"
quick-xml = { version = "0.41", features = ["serialize"] }

[dev-dependencies]
tokio = { version = "1", features = ["full", "test-util"] }
env_logger = "0.11"
axum = "0.8"
futures = "0.3"
num_cpus = "1.17"

[workspace]
members = [".", "wasm", "docs-tests"]

[target.'cfg(not(target_arch = "wasm32"))'.dependencies]
tokio = { version = "1", features = ["rt-multi-thread"] }
# `fast-rng`: thread-local PRNG seeded once from the OS instead of one
# `getrandom` syscall per `Uuid::now_v7()` — appropriate for v7 ids
# (uniqueness, not secrecy). Native-only; features are additive per-target,
# so the wasm build keeps the lean `v7`+`std` set from the main table.
uuid = { version = "1.24", default-features = false, features = ["fast-rng"] }

# Native release profile: maximize throughput. `lto = "fat"` plus
# `codegen-units = 1` lets the compiler propagate inlining across crate
# boundaries — load-bearing for the JSONLogic eval hot path.
[profile.release]
opt-level = 3
lto = "fat"
codegen-units = 1

# WASM-specific override: keep the size-optimized build for `dataflow-wasm`
# (the cdylib produces a smaller `.wasm` artifact with `opt-level = "s"`).
# Native consumers of `dataflow-rs` get `opt-level = 3` above.
[profile.release.package.dataflow-wasm]
opt-level = "s"