···

       
5
       
5
       
 
       
require (

     

       
6
       
6
       
 
       
	github.com/Azure/go-autorest/autorest/to v0.4.1

     

       
7
       
7
       
 
       
	github.com/aws/aws-sdk-go v1.55.7

     

       
8
       
8
       
-
       
	github.com/bluesky-social/indigo v0.0.0-20250414202759-826fcdeaa36b

     

       
8
       
8
       
+
       
	github.com/bluesky-social/indigo v0.0.0-20250924132341-b4dd6383c76f

     

       
9
       
9
       
 
       
	github.com/btcsuite/websocket v0.0.0-20150119174127-31079b680792

     

       
10
       
10
       
 
       
	github.com/domodwyer/mailyak/v3 v3.6.2

     

       
11
       
11
       
 
       
	github.com/go-pkgz/expirable-cache/v3 v3.0.0

     

···

       
18
       
18
       
 
       
github.com/bitly/go-hostpool v0.0.0-20171023180738-a3a6125de932/go.mod h1:NOuUCSz6Q9T7+igc/hlvDOUdtWKryOrtFyIVABv/p7k=

     

       
19
       
19
       
 
       
github.com/bluesky-social/indigo v0.0.0-20250414202759-826fcdeaa36b h1:elwfbe+W7GkUmPKFX1h7HaeHvC/kC0XJWfiEHC62xPg=

     

       
20
       
20
       
 
       
github.com/bluesky-social/indigo v0.0.0-20250414202759-826fcdeaa36b/go.mod h1:yjdhLA1LkK8VDS/WPUoYPo25/Hq/8rX38Ftr67EsqKY=

     

       
21
       
21
       
+
       
github.com/bluesky-social/indigo v0.0.0-20250924132341-b4dd6383c76f h1:DJufFBQBXlekAk1aZF9MgmmBmk1zBQNQOs0AZl2uUos=

     

       
22
       
22
       
+
       
github.com/bluesky-social/indigo v0.0.0-20250924132341-b4dd6383c76f/go.mod h1:n6QE1NDPFoi7PRbMUZmc2y7FibCqiVU4ePpsvhHUBR8=

     

       
21
       
23
       
 
       
github.com/bmizerany/assert v0.0.0-20160611221934-b7ed37b82869 h1:DDGfHa7BWjL4YnC6+E63dPcxHo2sUxDIu8g3QgEJdRY=

     

       
22
       
24
       
 
       
github.com/bmizerany/assert v0.0.0-20160611221934-b7ed37b82869/go.mod h1:Ekp36dRnpXw/yCqJaO+ZrUyxD+3VXMFFr56k5XYrpB4=

     

       
23
       
25
       
 
       
github.com/btcsuite/websocket v0.0.0-20150119174127-31079b680792 h1:R8vQdOQdZ9Y3SkEwmHoWBmX1DNXhXZqlTpq6s4tyJGc=

     

···

       
86
       
86
       
 
       
	}

     

       
87
       
87
       
 
       


     

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

     

       
89
       
89
       
-
       
		RepoHandle: &atproto.SyncSubscribeRepos_Handle{

     

       
90
       
90
       
-
       
			Did:    repo.Repo.Did,

     

       
91
       
91
       
-
       
			Handle: req.Handle,

     

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

     

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

     

       
94
       
94
       
-
       
		},

     

       
95
       
95
       
-
       
	})

     

       
96
       
96
       
-
       


     

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

     

       
98
       
89
       
 
       
		RepoIdentity: &atproto.SyncSubscribeRepos_Identity{

     

       
99
       
90
       
 
       
			Did:    repo.Repo.Did,

     

       
100
       
91
       
 
       
			Handle: to.StringPtr(req.Handle),

     

···

       
191
       
191
       
 
       
		}

     

       
192
       
192
       
 
       


     

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

     

       
194
       
194
       
-
       
			RepoHandle: &atproto.SyncSubscribeRepos_Handle{

     

       
195
       
195
       
-
       
				Did:    urepo.Did,

     

       
196
       
196
       
-
       
				Handle: request.Handle,

     

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

     

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

     

       
199
       
199
       
-
       
			},

     

       
200
       
200
       
-
       
		})

     

       
201
       
201
       
-
       


     

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

     

       
203
       
194
       
 
       
			RepoIdentity: &atproto.SyncSubscribeRepos_Identity{

     

       
204
       
195
       
 
       
				Did:    urepo.Did,

     

       
205
       
196
       
 
       
				Handle: to.StringPtr(request.Handle),

     

···

       
2
       
2
       
 
       


     

       
3
       
3
       
 
       
import (

     

       
4
       
4
       
 
       
	"fmt"

     

       
5
       
5
       
-
       
	"net/http"

     

       
6
       
5
       
 
       


     

       
7
       
6
       
 
       
	"github.com/bluesky-social/indigo/events"

     

       
8
       
7
       
 
       
	"github.com/bluesky-social/indigo/lex/util"

     

       
9
       
8
       
 
       
	"github.com/btcsuite/websocket"

     

       
10
       
9
       
 
       
	"github.com/labstack/echo/v4"

     

       
11
       
10
       
 
       
)

     

       
12
       
12
       
-
       


     

       
13
       
13
       
-
       
var upgrader = websocket.Upgrader{

     

       
14
       
14
       
-
       
	ReadBufferSize:  1024,

     

       
15
       
15
       
-
       
	WriteBufferSize: 1024,

     

       
16
       
16
       
-
       
	CheckOrigin: func(r *http.Request) bool {

     

       
17
       
17
       
-
       
		return true

     

       
18
       
18
       
-
       
	},

     

       
19
       
19
       
-
       
}

     

       
20
       
11
       
 
       


     

       
21
       
12
       
 
       
func (s *Server) handleSyncSubscribeRepos(e echo.Context) error {

     

       
22
       
13
       
 
       
	conn, err := websocket.Upgrade(e.Response().Writer, e.Request(), e.Response().Header(), 1<<10, 1<<10)

     
···

       
54
       
45
       
 
       
		case evt.RepoCommit != nil:

     

       
55
       
46
       
 
       
			header.MsgType = "#commit"

     

       
56
       
47
       
 
       
			obj = evt.RepoCommit

     

       
57
       
57
       
-
       
		case evt.RepoHandle != nil:

     

       
58
       
58
       
-
       
			header.MsgType = "#handle"

     

       
59
       
59
       
-
       
			obj = evt.RepoHandle

     

       
60
       
48
       
 
       
		case evt.RepoIdentity != nil:

     

       
61
       
49
       
 
       
			header.MsgType = "#identity"

     

       
62
       
50
       
 
       
			obj = evt.RepoIdentity

     
···

       
66
       
54
       
 
       
		case evt.RepoInfo != nil:

     

       
67
       
55
       
 
       
			header.MsgType = "#info"

     

       
68
       
56
       
 
       
			obj = evt.RepoInfo

     

       
69
       
69
       
-
       
		case evt.RepoMigrate != nil:

     

       
70
       
70
       
-
       
			header.MsgType = "#migrate"

     

       
71
       
71
       
-
       
			obj = evt.RepoMigrate

     

       
72
       
72
       
-
       
		case evt.RepoTombstone != nil:

     

       
73
       
73
       
-
       
			header.MsgType = "#tombstone"

     

       
74
       
74
       
-
       
			obj = evt.RepoTombstone

     

       
75
       
57
       
 
       
		default:

     

       
76
       
58
       
 
       
			return fmt.Errorf("unrecognized event kind")

     

       
77
       
59
       
 
       
		}