neq

crates/cmds-std/node-definitions/postgrest/builder_neq.json

@@ -0,0 +1,101 @@
+{
+  "type": "native",
+  "data": {
+    "node_definition_version": "0.1",
+    "unique_id": "",
+    "node_id": "postgrest_builder_neq",
+    "version": "0.1",
+    "display_name": "DB neq",
+    "description": "https://docs.rs/postgrest/latest/postgrest/struct.Builder.html#method.neq",
+    "tags": ["database", "postgrest", "supabase"],
+    "related_to": [
+      {
+        "id": "",
+        "type": "",
+        "relationship": ""
+      }
+    ],
+    "resources": {
+      "source_code_url": "",
+      "documentation_url": ""
+    },
+    "usage": {
+      "license": "Apache-2.0",
+      "license_url": "",
+      "pricing": {
+        "currency": "USDC",
+        "purchase_price": 0,
+        "price_per_run": 0,
+        "custom": {
+          "unit": "monthly",
+          "value": "0"
+        }
+      }
+    },
+    "authors": [
+      {
+        "name": "Space Operator",
+        "contact": ""
+      }
+    ],
+    "design": {
+      "width": 0,
+      "height": 0,
+      "icon_url": "",
+      "backgroundColorDark": "#000000",
+      "backgroundColor": "#fff"
+    },
+    "options": {}
+  },
+  "targets": [
+    {
+      "name": "query",
+      "type_bounds": ["object"],
+      "required": true,
+      "defaultValue": null,
+      "tooltip": "",
+      "passthrough": false
+    },
+    {
+      "name": "column",
+      "type_bounds": ["string"],
+      "required": true,
+      "defaultValue": null,
+      "tooltip": "",
+      "passthrough": false
+    },
+    {
+      "name": "filter",
+      "type_bounds": ["string"],
+      "required": true,
+      "defaultValue": null,
+      "tooltip": "",
+      "passthrough": false
+    }
+  ],
+  "sources": [
+    {
+      "name": "query",
+      "type": "object",
+      "defaultValue": "",
+      "tooltip": ""
+    }
+  ],
+  "targets_form.json_schema": {
+    "type": "object",
+    "title": "DB neq",
+    "properties": {
+      "column": {
+        "title": "column",
+        "type": "string"
+      },
+      "filter": {
+        "title": "filter",
+        "type": "string"
+      }
+    }
+  },
+  "targets_form.ui_schema": {
+    "ui:order": ["column", "filter"]
+  }
+}

crates/cmds-std/src/postgrest/builder_neq.rs

@@ -0,0 +1,43 @@
+use flow_lib::command::prelude::*;
+
+const NAME: &str = "postgrest_builder_neq";
+
+#[derive(Deserialize, Debug)]
+struct Input {
+    query: postgrest::Query,
+    column: String,
+    filter: String,
+}
+
+#[derive(Serialize, Debug)]
+struct Output {
+    query: postgrest::Query,
+}
+
+async fn run(ctx: Context, input: Input) -> Result<Output, CommandError> {
+    Ok(Output {
+        query: postgrest::Builder::from_query(input.query, ctx.http)
+            .neq(input.column, input.filter)
+            .into(),
+    })
+}
+
+fn build() -> BuildResult {
+    Ok(
+        CmdBuilder::new(flow_lib::node_definition!("postgrest/builder_neq.json"))?
+            .check_name(NAME)?
+            .build(run),
+    )
+}
+
+flow_lib::submit!(CommandDescription::new(NAME, |_| build()));
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn test_build() {
+        build().unwrap();
+    }
+}

crates/cmds-std/src/postgrest/mod.rs

@@ -1,6 +1,7 @@
 pub mod builder_eq;
 pub mod builder_insert;
 pub mod builder_is;
+pub mod builder_neq;
 pub mod builder_order;
 pub mod builder_select;
 pub mod builder_update;