feature: buerokratt#47 csa can see end user typed text before send (buerokratt#145)

* feature: buerokratt#47 add post message preview

* feature buerokratt#47 get message preview stream

* feature: buerokratt#47

* feature buerokratt#47

* remove step

* refactor

Author: helemand

DSL.DMapper/reflect_message_preview.hbs

@@ -0,0 +1,4 @@
+{
+    "chatId": "{{chatId}}",
+    "content": "{{{escape_special_chars content}}}"
+}

DSL.Liquibase/changelog/20230208124800_create_temporary_messages_table.xml

@@ -0,0 +1,18 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<databaseChangeLog xmlns="http://www.liquibase.org/xml/ns/dbchangelog"
+                   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+                   xmlns:pro="http://www.liquibase.org/xml/ns/pro"
+                   xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog
+http://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-4.1.xsd
+http://www.liquibase.org/xml/ns/pro http://www.liquibase.org/xml/ns/pro/liquibase-pro-4.1.xsd">
+
+    <changeSet id="20230208124800" author="Net Group">
+        <createTable tableName="message_preview">
+            <column name="chat_base_id" type="varchar(36)">
+                <constraints unique="true" nullable="false"/>
+            </column>
+            <column name="content" type="varchar(3000)">
+            </column>
+        </createTable>
+    </changeSet>
+</databaseChangeLog>

DSL.Resql/delete-message-preview.sql

@@ -0,0 +1 @@
+DELETE FROM message_preview WHERE chat_base_id = :chatId;

DSL.Resql/get-chat-messages-updated-after-time.sql

@@ -10,10 +10,12 @@ SELECT m.base_id      AS id,
        m.forwarded_by_user,
        m.forwarded_from_csa,
        m.forwarded_to_csa,
+       mp.content AS preview,
        rating,
        created,
        updated
 FROM message m
+INNER JOIN message_preview mp ON m.chat_base_id = mp.chat_base_id
 WHERE id IN (SELECT max(id) FROM message WHERE chat_base_id = :chatId GROUP BY base_id)
   AND :timeRangeBegin::timestamp
     with time zone < m.updated

DSL.Resql/insert-message-preview.sql

@@ -0,0 +1,3 @@
+INSERT INTO message_preview(chat_base_id, content)
+VALUES (:chatId, :content)
+ON CONFLICT(chat_base_id) DO UPDATE SET content = :content;

DSL.Ruuter-v1.private/chat/cs-end-chat.json

@@ -113,6 +113,27 @@
         }
       }
     },
+    {
+      "delete_message_previews": {
+        "verify": {
+          "response": {
+            "ok": "proceed",
+            "nok": "stop"
+          }
+        },
+        "proceed": {
+          "method": "post",
+          "endpoint": "{resql_url}/delete-message-preview",
+          "post_body_struct": {
+            "chatId": "{#.reflect_input#.chatId}"
+          }
+        },
+        "response": {
+          "ok": "proceed",
+          "nok": "stop"
+        }
+      }
+    },
     {
       "get_allowed_statuses": {
         "verify": {
@@ -132,7 +153,8 @@
         }
       }
     },
-    {"formatted_allowed_statuses": {
+    {
+      "formatted_allowed_statuses": {
         "verify": {
           "response": {
             "ok": "proceed",

DSL.Ruuter-v1.public/chat/end-chat.json

@@ -50,6 +50,27 @@
         }
       }
     },
+    {
+      "delete_message_previews": {
+        "verify": {
+          "response": {
+            "ok": "proceed",
+            "nok": "stop"
+          }
+        },
+        "proceed": {
+          "method": "post",
+          "endpoint": "{resql_url}/delete-message-preview",
+          "post_body_struct": {
+            "chatId": "{#.reflect_input#.chatId}"
+          }
+        },
+        "response": {
+          "ok": "proceed",
+          "nok": "stop"
+        }
+      }
+    },
     {
       "forwarding_validation": {
         "verify": {

DSL.Ruuter-v1.public/message/post-message-preview.json

@@ -0,0 +1,45 @@
+{
+  "action_type": "BLOGIC",
+  "destination": [
+    {
+      "reflect_input": {
+        "verify": {
+          "response": {
+            "ok": "proceed",
+            "nok": "stop"
+          }
+        },
+        "proceed": {
+          "method": "post",
+          "endpoint": "{dmapper_url}/json/v2/reflect_message_preview",
+          "post_body_struct": {
+            "chatId": "{#.chatId}",
+            "content": "{#.content}"
+          }
+        }
+      }
+    },
+    {
+      "post_message_preview": {
+        "verify": {
+          "response": {
+            "ok": "proceed",
+            "nok": "stop"
+          }
+        },
+        "proceed": {
+          "method": "post",
+          "endpoint": "{resql_url}/insert-message-preview",
+          "post_body_struct": {
+            "chatId": "{#.reflect_input#.chatId}",
+            "content": "{#.reflect_input#.content}"
+          },
+          "response": {
+            "ok": "proceed",
+            "nok": "stop"
+          }
+        }
+      }
+    }
+  ]
+}