From 6ccf647e773dcc0301d3a6d55cb4329a77b3a70b Mon Sep 17 00:00:00 2001
From: NV4RE <tosbodesz@gmail.com>
Date: Mon, 23 Mar 2020 19:20:08 +0700
Subject: [PATCH] add taskPath to mapping

---
 src/store/elasticsearch/event.ts            |   4 +
 src/store/elasticsearch/upgradeMapping.http | 178 ++++++++++++++++++++
 2 files changed, 182 insertions(+)
 create mode 100644 src/store/elasticsearch/upgradeMapping.http

diff --git a/src/store/elasticsearch/event.ts b/src/store/elasticsearch/event.ts
index a0bb5de..5d87949 100644
--- a/src/store/elasticsearch/event.ts
+++ b/src/store/elasticsearch/event.ts
@@ -169,6 +169,10 @@ const ES_EVENTS_MAPPING = {
           workflowId: {
             type: 'keyword',
           },
+          taskPath: {
+            type: 'object',
+            enabled: false,
+          },
         },
       },
       isError: {
diff --git a/src/store/elasticsearch/upgradeMapping.http b/src/store/elasticsearch/upgradeMapping.http
new file mode 100644
index 0000000..49d5813
--- /dev/null
+++ b/src/store/elasticsearch/upgradeMapping.http
@@ -0,0 +1,178 @@
+POST http://localhost:9200/melonade-docker-compose-event/event/_mapping HTTP/1.1
+Content-Type: application/json
+
+{
+  "event": {
+    "properties": {
+      "details": {
+        "properties": {
+          "ackTimeout": {
+            "type": "date"
+          },
+          "createTime": {
+            "type": "date"
+          },
+          "endTime": {
+            "type": "date"
+          },
+          "input": {
+            "type": "object",
+            "enabled": false
+          },
+          "isRetried": {
+            "type": "boolean"
+          },
+          "logs": {
+            "type": "text"
+          },
+          "output": {
+            "type": "object",
+            "enabled": false
+          },
+          "parallelTasks": {
+            "type": "object",
+            "enabled": false
+          },
+          "retries": {
+            "type": "long"
+          },
+          "retryDelay": {
+            "type": "long"
+          },
+          "startTime": {
+            "type": "date"
+          },
+          "status": {
+            "type": "keyword"
+          },
+          "tags": {
+            "type": "keyword"
+          },
+          "taskId": {
+            "type": "keyword"
+          },
+          "taskName": {
+            "type": "keyword"
+          },
+          "taskReferenceName": {
+            "type": "keyword"
+          },
+          "timeout": {
+            "type": "long"
+          },
+          "transactionId": {
+            "type": "keyword"
+          },
+          "type": {
+            "type": "keyword"
+          },
+          "workflowDefinition": {
+            "properties": {
+              "description": {
+                "type": "text"
+              },
+              "failureStrategy": {
+                "type": "keyword"
+              },
+              "name": {
+                "type": "keyword"
+              },
+              "outputParameters": {
+                "type": "object",
+                "enabled": false
+              },
+              "rev": {
+                "type": "keyword"
+              },
+              "tasks": {
+                "properties": {
+                  "ackTimeout": {
+                    "type": "long"
+                  },
+                  "inputParameters": {
+                    "type": "object",
+                    "enabled": false
+                  },
+                  "name": {
+                    "type": "keyword"
+                  },
+                  "parallelTasks": {
+                    "properties": {
+                      "ackTimeout": {
+                        "type": "long"
+                      },
+                      "inputParameters": {
+                        "type": "object",
+                        "enabled": false
+                      },
+                      "name": {
+                        "type": "keyword"
+                      },
+                      "retry": {
+                        "properties": {
+                          "delay": {
+                            "type": "long"
+                          },
+                          "limit": {
+                            "type": "long"
+                          }
+                        }
+                      },
+                      "taskReferenceName": {
+                        "type": "keyword"
+                      },
+                      "timeout": {
+                        "type": "long"
+                      },
+                      "type": {
+                        "type": "keyword"
+                      }
+                    }
+                  },
+                  "retry": {
+                    "properties": {
+                      "delay": {
+                        "type": "long"
+                      },
+                      "limit": {
+                        "type": "long"
+                      }
+                    }
+                  },
+                  "taskReferenceName": {
+                    "type": "keyword"
+                  },
+                  "timeout": {
+                    "type": "long"
+                  },
+                  "type": {
+                    "type": "keyword"
+                  }
+                }
+              }
+            }
+          },
+          "workflowId": {
+            "type": "keyword"
+          },
+          "taskPath": {
+            "type": "object",
+            "enabled": false
+          }
+        }
+      },
+      "isError": {
+        "type": "boolean"
+      },
+      "timestamp": {
+        "type": "date"
+      },
+      "transactionId": {
+        "type": "keyword"
+      },
+      "type": {
+        "type": "keyword"
+      }
+    }
+  }
+}