add User.sent_dms to track the DMs we've sent to a user

for #1205, #1148, #966, #1024

models.py

@@ -83,6 +83,13 @@
 )
 OBJECT_EXPIRE_AGE = timedelta(days=90)
 
+# Types of DMs that we send
+DMS = (
+    'follow_request_from_bridged_user',
+    'replied_to_bridged_user',
+    'welcome',
+)
+
 logger = logging.getLogger(__name__)
 
 
@@ -190,6 +197,9 @@ class User(StringIdModel, metaclass=ProtocolUserMeta):
     # reset_protocol_properties.
     enabled_protocols = ndb.StringProperty(repeated=True, choices=list(PROTOCOLS.keys()))
 
+    # DMs that we've attempted to send to this user
+    sent_dms = ndb.StringProperty(repeated=True, choices=DMS)
+
     created = ndb.DateTimeProperty(auto_now_add=True)
     updated = ndb.DateTimeProperty(auto_now=True)
 
@@ -495,6 +505,7 @@ def enable():
             user = self.key.get()
             if to_proto.LABEL not in user.enabled_protocols:
                 user.enabled_protocols.append(to_proto.LABEL)
+                add(user.sent_dms, 'welcome')
                 user.put()
                 nonlocal added
                 added = True

tests/test_integrations.py

@@ -380,6 +380,7 @@ def test_activitypub_follow_bsky_bot_user_enables_protocol(self, mock_get, mock_
         # check results
         user = ActivityPub.get_by_id('https://inst/alice')
         self.assertTrue(user.is_enabled(ATProto))
+        self.assertEqual(['welcome'], user.sent_dms)
 
         self.assertEqual(1, len(user.copies))
         self.assertEqual('atproto', user.copies[0].protocol)
@@ -504,6 +505,7 @@ def test_atproto_follow_ap_bot_user_enables_protocol(self, mock_get, mock_post):
 
         user = ATProto.get_by_id('did:plc:alice')
         self.assertTrue(user.is_enabled(ActivityPub))
+        self.assertEqual(['welcome'], user.sent_dms)
 
         headers = {
             'Content-Type': 'application/json',