···

       
204
       
204
       
 
       
        if post.get('reply'):

     

       
205
       
205
       
 
       
            parent_ref = json.dumps(post['reply']['parent'], sort_keys=True)

     

       
206
       
206
       
 
       
            

     

       
207
       
207
       
-
       
        root_id = None

     

       
208
       
208
       
-
       
        parent_id = None

     

       
209
       
209
       
-
       
        if parent_ref:

     

       
210
       
210
       
-
       
            parent_post = database.find_post(self.db, parent_ref, self.user_id, self.service)

     

       
211
       
211
       
-
       
            if not parent_post:

     

       
212
       
212
       
-
       
                LOGGER.info("Skipping '%s' as parent post was not found in db!", post_ref)

     

       
213
       
213
       
-
       
                return

     

       
214
       
214
       
-
       
            

     

       
215
       
215
       
-
       
            root_id = parent_post['id']

     

       
216
       
216
       
-
       
            parent_id = root_id

     

       
217
       
217
       
-
       
            if parent_post['root_id']:

     

       
218
       
218
       
-
       
                root_id = parent_post['root_id']

     

       
207
       
207
       
+
       
        success = database.try_insert_post(self.db, post_ref, parent_ref, self.user_id, self.service)

     

       
208
       
208
       
+
       
        if not success:

     

       
209
       
209
       
+
       
            LOGGER.info("Skipping '%s' as parent post was not found in db!", post_ref)

     

       
210
       
210
       
+
       
            return

     

       
219
       
211
       
 
       
        

     

       
220
       
212
       
 
       
        LOGGER.info("Crossposting '%s'...", post_ref)

     

       
221
       
221
       
-
       
        if root_id and parent_id:

     

       
222
       
222
       
-
       
            database.insert_reply(

     

       
223
       
223
       
-
       
                self.db,

     

       
224
       
224
       
-
       
                post_ref,

     

       
225
       
225
       
-
       
                self.user_id,

     

       
226
       
226
       
-
       
                self.service,

     

       
227
       
227
       
-
       
                parent_id,

     

       
228
       
228
       
-
       
                root_id

     

       
229
       
229
       
-
       
            )

     

       
230
       
230
       
-
       
        else:

     

       
231
       
231
       
-
       
            database.insert_post(

     

       
232
       
232
       
-
       
                self.db,

     

       
233
       
233
       
-
       
                post_ref,

     

       
234
       
234
       
-
       
                self.user_id,

     

       
235
       
235
       
-
       
                self.service

     

       
236
       
236
       
-
       
            )

     

       
237
       
237
       
-
       
        

     

       
238
       
213
       
 
       
        cross_post = BlueskyPost(self.pds, self.user_id, post)

     

       
239
       
214
       
 
       
        for output in outputs:

     

       
240
       
215
       
 
       
            output.accept_post(cross_post)

     

···

       
45
       
45
       
 
       
        with self.lock:

     

       
46
       
46
       
 
       
            self.conn.close()

     

       
47
       
47
       
 
       


     

       
48
       
48
       
+
       
def try_insert_post(

     

       
49
       
49
       
+
       
    db: DataBaseWorker, 

     

       
50
       
50
       
+
       
    post_id: str,

     

       
51
       
51
       
+
       
    in_reply: str | None,

     

       
52
       
52
       
+
       
    input_user: str,

     

       
53
       
53
       
+
       
    input_service: str) -> bool:

     

       
54
       
54
       
+
       
    root_id = None

     

       
55
       
55
       
+
       
    parent_id = None

     

       
56
       
56
       
+
       
    

     

       
57
       
57
       
+
       
    if in_reply:

     

       
58
       
58
       
+
       
        parent_post = find_post(db, in_reply, input_user, input_service)

     

       
59
       
59
       
+
       
        if not parent_post:

     

       
60
       
60
       
+
       
            return False

     

       
61
       
61
       
+
       
    

     

       
62
       
62
       
+
       
        root_id = parent_post['id']

     

       
63
       
63
       
+
       
        parent_id = root_id

     

       
64
       
64
       
+
       
        if parent_post['root_id']:

     

       
65
       
65
       
+
       
            root_id = parent_post['root_id']

     

       
66
       
66
       
+
       
    

     

       
67
       
67
       
+
       
    if root_id and parent_id:

     

       
68
       
68
       
+
       
        insert_reply(db,post_id, input_user, input_service, parent_id, root_id)

     

       
69
       
69
       
+
       
    else:

     

       
70
       
70
       
+
       
        insert_post(db, post_id, input_user, input_service)

     

       
71
       
71
       
+
       
    

     

       
72
       
72
       
+
       
    return True

     

       
73
       
73
       
+
       
    

     

       
74
       
74
       
+
       


     

       
48
       
75
       
 
       
def find_mapped_thread(

     

       
49
       
76
       
 
       
    db: DataBaseWorker, 

     

       
50
       
77
       
 
       
    parent_id: str,

     

···

       
204
       
204
       
 
       
            LOGGER.info("Skipping '%s'! '%s' visibility..", status['id'], status.get('visibility'))

     

       
205
       
205
       
 
       
            return

     

       
206
       
206
       
 
       
        

     

       
207
       
207
       
-
       
        root_id = None

     

       
208
       
208
       
-
       
        parent_id = None

     

       
209
       
209
       
-
       
        if in_reply:

     

       
210
       
210
       
-
       
            parent_post = database.find_post(self.db, in_reply, self.user_id, self.service)

     

       
211
       
211
       
-
       
            if not parent_post:

     

       
212
       
212
       
-
       
                LOGGER.info("Skipping '%s' as parent post was not found in db!", status['id'])

     

       
213
       
213
       
-
       
                return

     

       
214
       
214
       
-
       
            

     

       
215
       
215
       
-
       
            root_id = parent_post['id']

     

       
216
       
216
       
-
       
            parent_id = root_id

     

       
217
       
217
       
-
       
            if parent_post['root_id']:

     

       
218
       
218
       
-
       
                root_id = parent_post['root_id']

     

       
207
       
207
       
+
       
        success = database.try_insert_post(self.db, status['id'], in_reply, self.user_id, self.service)

     

       
208
       
208
       
+
       
        if not success:

     

       
209
       
209
       
+
       
            LOGGER.info("Skipping '%s' as parent post was not found in db!", status['id'])

     

       
210
       
210
       
+
       
            return

     

       
219
       
211
       
 
       
        

     

       
220
       
212
       
 
       
        LOGGER.info("Crossposting '%s'...", status['id'])

     

       
221
       
221
       
-
       
        if root_id and parent_id:

     

       
222
       
222
       
-
       
            database.insert_reply(

     

       
223
       
223
       
-
       
                self.db,

     

       
224
       
224
       
-
       
                status['id'],

     

       
225
       
225
       
-
       
                self.user_id,

     

       
226
       
226
       
-
       
                self.service,

     

       
227
       
227
       
-
       
                parent_id,

     

       
228
       
228
       
-
       
                root_id

     

       
229
       
229
       
-
       
            )

     

       
230
       
230
       
-
       
        else:

     

       
231
       
231
       
-
       
            database.insert_post(

     

       
232
       
232
       
-
       
                self.db,

     

       
233
       
233
       
-
       
                status['id'],

     

       
234
       
234
       
-
       
                self.user_id,

     

       
235
       
235
       
-
       
                self.service

     

       
236
       
236
       
-
       
            )

     

       
237
       
237
       
-
       
        

     

       
238
       
213
       
 
       
        cross_post = MastodonPost(status)

     

       
239
       
214
       
 
       
        for output in outputs:

     

       
240
       
215
       
 
       
            output.accept_post(cross_post)

     

···

       
204
       
204
       
 
       
            LOGGER.info("Skipping '%s'! '%s' visibility..", note['id'], note.get('visibility'))

     

       
205
       
205
       
 
       
            return

     

       
206
       
206
       
 
       
        

     

       
207
       
207
       
-
       
        root_id = None

     

       
208
       
208
       
-
       
        parent_id = None

     

       
209
       
209
       
-
       
        if reply_id:

     

       
210
       
210
       
-
       
            parent_post = database.find_post(self.db, reply_id, self.user_id, self.service)

     

       
211
       
211
       
-
       
            if not parent_post:

     

       
212
       
212
       
-
       
                LOGGER.info("Skipping '%s' as parent post was not found in db!", note['id'])

     

       
213
       
213
       
-
       
                return

     

       
214
       
214
       
-
       
            

     

       
215
       
215
       
-
       
            root_id = parent_post['id']

     

       
216
       
216
       
-
       
            parent_id = root_id

     

       
217
       
217
       
-
       
            if parent_post['root_id']:

     

       
218
       
218
       
-
       
                root_id = parent_post['root_id']

     

       
207
       
207
       
+
       
        success = database.try_insert_post(self.db, note['id'], reply_id, self.user_id, self.service)

     

       
208
       
208
       
+
       
        if not success:

     

       
209
       
209
       
+
       
            LOGGER.info("Skipping '%s' as parent note was not found in db!", note['id'])

     

       
210
       
210
       
+
       
            return

     

       
219
       
211
       
 
       
        

     

       
220
       
212
       
 
       
        LOGGER.info("Crossposting '%s'...", note['id'])

     

       
221
       
221
       
-
       
        if root_id and parent_id:

     

       
222
       
222
       
-
       
            database.insert_reply(

     

       
223
       
223
       
-
       
                self.db,

     

       
224
       
224
       
-
       
                note['id'],

     

       
225
       
225
       
-
       
                self.user_id,

     

       
226
       
226
       
-
       
                self.service,

     

       
227
       
227
       
-
       
                parent_id,

     

       
228
       
228
       
-
       
                root_id

     

       
229
       
229
       
-
       
            )

     

       
230
       
230
       
-
       
        else:

     

       
231
       
231
       
-
       
            database.insert_post(

     

       
232
       
232
       
-
       
                self.db,

     

       
233
       
233
       
-
       
                note['id'],

     

       
234
       
234
       
-
       
                self.user_id,

     

       
235
       
235
       
-
       
                self.service

     

       
236
       
236
       
-
       
            )

     

       
237
       
237
       
-
       
            

     

       
238
       
213
       
 
       
        cross_post = MisskeyPost(note)

     

       
239
       
214
       
 
       
        for output in outputs:

     

       
240
       
215
       
 
       
            output.accept_post(cross_post)