···

       
22
       
 
       
}

     

       
23
       
 
       


     

       
24
       
 
       
func (cs *CursorService) SetHostCursor(host string, cursor string) error {

     

       
25
       
-
       
	if err := cs.store.Where(hostCursor{

     

       
26
       
 
       
		Host: host,

     

       
27
       
 
       
	}).Update("cursor", cursor).Error; err != nil {

     

       
28
       
 
       
		return err

     

···

       
22
       
 
       
}

     

       
23
       
 
       


     

       
24
       
 
       
func (cs *CursorService) SetHostCursor(host string, cursor string) error {

     

       
25
       
+
       
	if err := cs.store.Model(&hostCursor{}).Where(hostCursor{

     

       
26
       
 
       
		Host: host,

     

       
27
       
 
       
	}).Update("cursor", cursor).Error; err != nil {

     

       
28
       
 
       
		return err

     

···

       
5
       
 
       
	"context"

     

       
6
       
 
       
	"encoding/json"

     

       
7
       
 
       
	"fmt"

     

       
0
       
 
       

     

       
8
       
 
       


     

       
9
       
 
       
	appbsky "github.com/bluesky-social/indigo/api/bsky"

     

       
10
       
 
       
	"github.com/bluesky-social/indigo/atproto/syntax"

     
···

       
75
       
 
       
		var out appbsky.LabelerService

     

       
76
       
 
       
		out.UnmarshalCBOR(bytes.NewReader(*rec))

     

       
77
       
 
       
		body, err = json.Marshal(out)

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
78
       
 
       
	}

     

       
79
       
 
       


     

       
80
       
 
       
	switch action {

     

···

       
5
       
 
       
	"context"

     

       
6
       
 
       
	"encoding/json"

     

       
7
       
 
       
	"fmt"

     

       
8
       
+
       
	"log/slog"

     

       
9
       
 
       


     

       
10
       
 
       
	appbsky "github.com/bluesky-social/indigo/api/bsky"

     

       
11
       
 
       
	"github.com/bluesky-social/indigo/atproto/syntax"

     
···

       
76
       
 
       
		var out appbsky.LabelerService

     

       
77
       
 
       
		out.UnmarshalCBOR(bytes.NewReader(*rec))

     

       
78
       
 
       
		body, err = json.Marshal(out)

     

       
79
       
+
       


     

       
80
       
+
       
	case syntax.NSID("app.bsky.graph.list"):

     

       
81
       
+
       
		var out appbsky.GraphList

     

       
82
       
+
       
		out.UnmarshalCBOR(bytes.NewReader(*rec))

     

       
83
       
+
       
		body, err = json.Marshal(out)

     

       
84
       
+
       


     

       
85
       
+
       
	case syntax.NSID("app.bsky.graph.verification"):

     

       
86
       
+
       
		var out appbsky.GraphVerification

     

       
87
       
+
       
		out.UnmarshalCBOR(bytes.NewReader(*rec))

     

       
88
       
+
       
		body, err = json.Marshal(out)

     

       
89
       
+
       


     

       
90
       
+
       
	case syntax.NSID("app.bsky.graph.starterpack"):

     

       
91
       
+
       
		var out appbsky.GraphStarterpack

     

       
92
       
+
       
		out.UnmarshalCBOR(bytes.NewReader(*rec))

     

       
93
       
+
       
		body, err = json.Marshal(out)

     

       
94
       
+
       


     

       
95
       
+
       
	default:

     

       
96
       
+
       
		slog.Error("tracked collection missing handler", "collection", uri.Collection())

     

       
97
       
+
       
		return nil

     

       
98
       
 
       
	}

     

       
99
       
 
       


     

       
100
       
 
       
	switch action {

     

···

       
10
       
 
       
		ParallelBackfills:     cctx.Int("backfill-workers"),

     

       
11
       
 
       
		ParallelRecordCreates: cctx.Int("backfill-consumers"),

     

       
12
       
 
       
		NSIDFilter:            "",

     

       
13
       
-
       
		SyncRequestsPerSecond: 10,

     

       
14
       
 
       
		RelayHost:             "https://" + cctx.String("relay-host"),

     

       
15
       
 
       
	}

     

       
16
       
 
       


     

···

       
10
       
 
       
		ParallelBackfills:     cctx.Int("backfill-workers"),

     

       
11
       
 
       
		ParallelRecordCreates: cctx.Int("backfill-consumers"),

     

       
12
       
 
       
		NSIDFilter:            "",

     

       
13
       
+
       
		SyncRequestsPerSecond: cctx.Int("sync-requests-limit"),

     

       
14
       
 
       
		RelayHost:             "https://" + cctx.String("relay-host"),

     

       
15
       
 
       
	}

     

       
16