···

       
68
       
68
       
 
       


     

       
69
       
69
       
 
       
    op_count = 0

     

       
70
       
70
       
 
       
    async for event in bsky_activity():

     

       
71
       
71
       
-
       
        if event['type'] != 'com':

     

       
71
       
71
       
+
       
        if event['kind'] != 'commit':

     

       
72
       
72
       
 
       
            continue

     

       
73
       
73
       
 
       


     

       
74
       
74
       
 
       
        payload = event.get('commit')

     

       
75
       
75
       
 
       
        if payload is None:

     

       
76
       
76
       
 
       
            continue

     

       
77
       
77
       
 
       


     

       
78
       
78
       
-
       
        if payload['type'] != 'c':

     

       
78
       
78
       
+
       
        if payload['operation'] != 'create':

     

       
79
       
79
       
 
       
            continue

     

       
80
       
80
       
 
       


     

       
81
       
81
       
 
       
        collection = payload['collection']