Gated database message mapping behind RMASS message sent status

plugins/rmass/actions/getrmassconversation.py

@@ -15,6 +15,10 @@ resolve = {
     "get": {
         "event_id": ["outmessageitem", "event_id"],
         "path": ["lastmessage", 0, "content", "com.loxthelion.rmass_message_id"],
+        #"matrix_sender": ["outmessageitem", "sender"],
+        #"msg_type": ["outmessageitem", "type"],
+        #"echo_tag": ["outmessageitem", "content", "com.loxthelion.rmass_message_id"],
+        "rmass_sent_status": ["rmass_sent_status"],
     },
 }
 
@@ -67,11 +71,18 @@ saverow = {
     ],
 }
 
-#filters = [
+
-#    {
+filters = [
-#        "filterkey": "rmass_sent_status",
+    {
-#        "operator": "==",
+        "filterkey": "rmass_sent_status",
-#        "filtervalue": "fail",
+        "operator": "==",
-#        "print": "Failed to send message to RMASS. Continuing...",
+        "filtervalue": "fail",
-#    },
+        "print": f"Failed to send message to RMASS. Bypassing save during {name}...",
-#]
+    },
+    {
+        "filterkey": "rmass_sent_status",
+        "operator": "==",
+        "filtervalue": "error",
+        "print": f"Failed to send message to RMASS. Bypassing save during {name}...",
+    },
+]

plugins/rmass/actions/synapsegetlastmessage.py

@@ -11,10 +11,14 @@ method = "GET"
 resolve = {
     "get": {
         #"sender": ["room_name"],
-        "event_id": ["outmessageitem", "event_id"],
+        #"event_id": ["outmessageitem", "event_id"],
         #"message_body": ["outmessageitem", "content", "body"],
         "room_id": ["outmessageitem", "room_id"],
         #"timestamp": ["outmessageitem", "origin_server_ts"],
+        #"matrix_sender": ["outmessageitem", "sender"],
+        #"msg_type": ["outmessageitem", "type"],
+        #"echo_tag": ["outmessageitem", "content", "com.loxthelion.rmass_message_id"],
+        "rmass_sent_status": ["rmass_sent_status"],
     },
 }
 
@@ -35,3 +39,18 @@ headers = {
 outputs = {
     "lastmessage": "chunk"
 }
+
+filters = [
+    {
+        "filterkey": "rmass_sent_status",
+        "operator": "==",
+        "filtervalue": "fail",
+        "print": f"Failed to send message to RMASS. Bypassing save during {name}...",
+    },
+    {
+        "filterkey": "rmass_sent_status",
+        "operator": "==",
+        "filtervalue": "error",
+        "print": f"Failed to send message to RMASS. Bypassing save during {name}...",
+    },
+]