feat(search): update benthos with payments pools

formancehq · Dec 7, 2023 · 1949c28 · 1949c28
1 parent 3868646
commit 1949c28
Show file tree

Hide file tree

Showing 2 changed files with 50 additions and 0 deletions.
diff --git a/ee/search/benthos/streams/payments/v0.0.0/payments_deletion.yaml b/ee/search/benthos/streams/payments/v0.0.0/payments_deletion.yaml
@@ -22,6 +22,11 @@ pipeline:
                               "kind": "PAYMENT"
                             }
                           },
+                          {
+                            "match": {
+                              "kind": "PAYMENT_POOL"
+                            }
+                          },
                           {
                             "match": {
                               "kind": "PAYMENT_ACCOUNT"
@@ -60,6 +65,33 @@ pipeline:
               }
             }
 
+      - label: DELETED_POOL
+        processors:
+        - bloblang: |
+            root = {
+              "query": {
+                "bool": {
+                  "must": [
+                    {
+                      "match": {
+                        "kind": "PAYMENT_POOL"
+                      }
+                    },
+                    {
+                      "match": {
+                        "indexed.id": this.payload.id
+                      } 
+                    },
+                    {
+                      "match": {
+                        "stack": env("STACK")
+                      }
+                    }
+                  ]
+                }
+              }
+            }
+
       - label: DELETED_TRANSFER_INITIATION
         processors:
         - bloblang: |

diff --git a/ee/search/benthos/streams/payments/v0.0.0/payments_ingestion.yaml b/ee/search/benthos/streams/payments/v0.0.0/payments_ingestion.yaml
@@ -98,6 +98,24 @@ pipeline:
                 "action": "index",
                 "id": "PAYMENT-BANK-ACCOUNT-%s".format(this.payload.id)
               }
+      - label: SAVED_POOL
+        processors:
+        - bloblang: |
+              root = {
+                "document": {
+                    "data": this.payload,
+                    "indexed": {
+                        "id": this.payload.id,
+                        "createdAt": this.payload.createdAt,
+                        "name": this.payload.name,
+                        "accountIDs": this.payload.accountIDs,
+                    },
+                    "kind": "PAYMENT_POOL",
+                    "when": this.date
+                },
+                "action": "index",
+                "id": "PAYMENT-POOL-%s".format(this.payload.id)
+              }
       - label: SAVED_TRANSFER_INITIATION
         processors:
         - bloblang: |