···

       
4
       
4
       
 
       


     

       
5
       
5
       
 
       
require (

     

       
6
       
6
       
 
       
	github.com/bluesky-social/indigo v0.0.0-20240905024844-a4f38639767f

     

       
7
       
7
       
-
       
	github.com/bluesky-social/jetstream v0.0.0-20240925210745-2cd1b6147279

     

       
7
       
7
       
+
       
	github.com/bluesky-social/jetstream v0.0.0-20241020000921-dcd43344c716

     

       
8
       
8
       
 
       
	github.com/gorilla/websocket v1.5.3

     

       
9
       
9
       
 
       
	github.com/karlseguin/ccache/v3 v3.0.5

     

       
10
       
10
       
 
       
	github.com/labstack/echo/v4 v4.11.3

     

···

       
4
       
4
       
 
       
github.com/bluesky-social/indigo v0.0.0-20240905024844-a4f38639767f/go.mod h1:Zx9nSWgd/FxMenkJW07VKnzspxpHBdPrPmS+Fspl2I0=

     

       
5
       
5
       
 
       
github.com/bluesky-social/jetstream v0.0.0-20240925210745-2cd1b6147279 h1:45wwXL1io7pAcgqFMBHFi2GdF4CRg0/4Sq65JY3PfkM=

     

       
6
       
6
       
 
       
github.com/bluesky-social/jetstream v0.0.0-20240925210745-2cd1b6147279/go.mod h1:/GMZrwKMbAiWU2MVCswH8+Jd3ybrpkHX4qM6tTfyv1k=

     

       
7
       
7
       
+
       
github.com/bluesky-social/jetstream v0.0.0-20241020000921-dcd43344c716 h1:I8+VaZKaNIGCPGXE2/VXzJGlPFEZgiFLjnge+OWFl5w=

     

       
8
       
8
       
+
       
github.com/bluesky-social/jetstream v0.0.0-20241020000921-dcd43344c716/go.mod h1:/dE2dmFell/m4zxgIbH3fkiqZ1obzr/ETj4RpgomgMs=

     

       
7
       
9
       
 
       
github.com/carlmjohnson/versioninfo v0.22.5 h1:O00sjOLUAFxYQjlN/bzYTuZiS0y6fWDQjMRvwtKgwwc=

     

       
8
       
10
       
 
       
github.com/carlmjohnson/versioninfo v0.22.5/go.mod h1:QT9mph3wcVfISUKd0i9sZfVrPviHuSF+cUtLjm2WSf8=

     

       
9
       
11
       
 
       
github.com/cpuguy83/go-md2man/v2 v2.0.0-20190314233015-f79a8a8ca69d/go.mod h1:maD7wRr/U5Z6m/iR4s+kqSMx2CaBsrgA7czyZG/E6dU=

     

···

       
101
       
101
       
 
       
		if err := json.Unmarshal(evt, &event); err != nil {

     

       
102
       
102
       
 
       
			continue

     

       
103
       
103
       
 
       
		}

     

       
104
       
104
       
-
       
		if event.Commit == nil {

     

       
104
       
104
       
+
       
		if event.Kind != jetstream.EventKindCommit {

     

       
105
       
105
       
 
       
			continue

     

       
106
       
106
       
 
       
		}

     

       
107
       
107
       
-
       
		commit := *event.Commit

     

       
108
       
108
       
-
       
		if commit.OpType != "c" {

     

       
107
       
107
       
+
       
		if event.Commit.Operation != jetstream.CommitOperationCreate {

     

       
109
       
108
       
 
       
			continue

     

       
110
       
109
       
 
       
		}

     

       
110
       
110
       
+
       
		commit := *event.Commit

     

       
111
       
111
       
 
       
		if commit.Collection == "app.bsky.feed.post" {

     

       
112
       
112
       
 
       
			var post appbsky.FeedPost

     

       
113
       
113
       
 
       
			postUri := fmt.Sprintf("at://%s/%s/%s", event.Did, commit.Collection, commit.RKey)