···

       
36
       
36
       
 
       
		return helpers.InputError(e, nil)

     

       
37
       
37
       
 
       
	}

     

       
38
       
38
       
 
       


     

       
39
       
39
       
-
       
	op := req.Operation;

     

       
39
       
39
       
+
       
	op := req.Operation

     

       
40
       
40
       
 
       


     

       
41
       
41
       
 
       
	k, err := atcrypto.ParsePrivateBytesK256(repo.SigningKey)

     

       
42
       
42
       
 
       
	if err != nil {

     
···

       
77
       
77
       
 
       


     

       
78
       
78
       
 
       
	s.evtman.AddEvent(context.TODO(), &events.XRPCStreamEvent{

     

       
79
       
79
       
 
       
		RepoIdentity: &atproto.SyncSubscribeRepos_Identity{

     

       
80
       
80
       
-
       
			Did:    repo.Repo.Did,

     

       
81
       
81
       
-
       
			Seq:    time.Now().UnixMicro(), // TODO: no

     

       
82
       
82
       
-
       
			Time:   time.Now().Format(util.ISO8601),

     

       
80
       
80
       
+
       
			Did:  repo.Repo.Did,

     

       
81
       
81
       
+
       
			Seq:  time.Now().UnixMicro(), // TODO: no

     

       
82
       
82
       
+
       
			Time: time.Now().Format(util.ISO8601),

     

       
83
       
83
       
 
       
		},

     

       
84
       
84
       
 
       
	})

     

       
85
       
85