Made avatar retrieval optional by introducing the allow action gate.

plugins/rmass/actions/getrmassuseravatar.py

@@ -1,9 +1,13 @@
+import os
+
 name = "Get User Avatar"
 
 kind = "action"
 
 alias = "getavatar"
 
+allowaction = bool(os.environ.get("UPDATE_AVATARS", True))
+
 showstatus = True
 
 isrequest = True

plugins/rmass/actions/rmassavatartosynapse.py

@@ -1,9 +1,13 @@
+import os
+
 name = "Upload Avatar to Synapse"
 
 kind = "action"
 
 alias = "uploadavatar"
 
+allowaction = os.environ.get("UPDATE_AVATARS", True)
+
 showstatus = True
 
 resolve = {

plugins/rmass/actions/synapseassignavatar.py

@@ -6,6 +6,8 @@ kind = "action"
 
 showstatus = True
 
+allowaction = os.environ.get("UPDATE_AVATARS", True)
+
 resolve = {
     "get": {
         "sender": ["messageheaders", "userCard", "id"],
@@ -69,18 +71,18 @@ headers = {
 #}
 
 filters = [
-#    {
-#        "filterkey": "avatar_hash",
-#        "operator": "==",
-#        "filtervalue": {"outputs": "db_avatar_hash"},
-#        "print": f"User avatar up to date. Skipping {name}...",
-#    },
     {
-        "filterkey": "uploadimage",
+        "filterkey": "avatar_hash",
-        "operator": "is",
+        "operator": "==",
-        "filtervalue": None,
+        "filtervalue": {"outputs": "db_avatar_hash"},
-        "print": f"No avatar for upload. Skipping {name}...",
+        "print": f"User avatar up to date. Skipping {name}...",
     },
+#    {
+#        "filterkey": "uploadimage",
+#        "operator": "is",
+#        "filtervalue": None,
+#        "print": f"No avatar for upload. Skipping {name}...",
+#    },
 ]
 
 #saverow = {

plugins/rmass/actions/synapseassigndmavatar.py

@@ -6,6 +6,8 @@ kind = "action"
 
 showstatus = True
 
+allowaction = os.environ.get("UPDATE_AVATARS", True)
+
 resolve = {
     "get": {
         "sender": ["messageheaders", "userCard", "id"],
@@ -43,8 +45,8 @@ path = [
     {"resolved": "room_id"},
     "/state/m.room.avatar",
     #{"resolved": "matrixuser"},
-    #"/avatar_url?user_id=",
+    "?user_id=",
-    #{"resolved": "matrixuser"},
+    {"resolved": "matrixuser"},
 ]
 
 headers = {
@@ -66,27 +68,27 @@ filters = [
 ]
 
 
-saverow = {
+#saverow = {
-    "table": "user_profiles",
+#    "table": "user_profiles",
-    "columns": [
+#    "columns": [
-        {"rmass_user_id": "INTEGER PRIMARY KEY"},
+#        {"rmass_user_id": "INTEGER PRIMARY KEY"},
-        {"rmass_username": "TEXT NOT NULL UNIQUE"},
+#        {"rmass_username": "TEXT NOT NULL UNIQUE"},
-        {"rmass_dm_room": "TEXT NOT NULL UNIQUE"},
+#        {"rmass_dm_room": "TEXT NOT NULL UNIQUE"},
-        {"rmass_avatar_hash": "TEXT"},
+#        {"rmass_avatar_hash": "TEXT"},
-    ],
+#    ],
-    "rowitems": [
+#    "rowitems": [
-        {"resolved": "sender"},
+#        {"resolved": "sender"},
-        {"resolved": "username"},
+#        {"resolved": "username"},
-        {"resolved": "matrixdm"},
+#        {"resolved": "matrixdm"},
-        {"outputs": "useravatar_hash"},
+#        {"outputs": "useravatar_hash"},
-    ],
+#    ],
-    "onconflict": {
+#    "onconflict": {
-        "target": "rmass_user_id",
+#        "target": "rmass_user_id",
-        "update": [
+#        "update": [
-            "rmass_username",
+#            "rmass_username",
-            "rmass_dm_room",
+#            "rmass_dm_room",
-            "rmass_avatar_hash",
+#            "rmass_avatar_hash",
-        ],
+#        ],
-        "preservenull": True,
+#        "preservenull": True,
-    },
+#    },
-}
+#}