···

       
97
       
 
       
	return nil

     

       
98
       
 
       
}

     

       
99
       
 
       


     

       
100
       
-
       
// handles both creates and updates

     

       
101
       
 
       
func (hs *HandlerService) HandleUpsert(ctx context.Context, repo string, rev string, path string, rec *[]byte, cid *cid.Cid, action Action) error {

     

       
102
       
 
       
	uri, err := syntax.ParseATURI(fmt.Sprintf("at://%s/%s", repo, path))

     

       
103
       
 
       
	if err != nil {

     
···

       
108
       
 
       


     

       
109
       
 
       
	switch uri.Collection() {

     

       
110
       
 
       
	case syntax.NSID("app.bsky.actor.profile"):

     

       
111
       
-
       
		profile := models.NewActorProfile(uri, *rec)

     

       
112
       
-
       
		if err := hs.store.Where(models.ActorProfile{ID: string(uri)}).Assign(profile).FirstOrCreate(&models.ActorProfile{}).Error; err != nil {

     

       
113
       
-
       
			return fmt.Errorf("error upserting actor profile: %w", err)

     

       
114
       
-
       
		}

     

       
115
       
 
       


     

       
116
       
 
       
	case syntax.NSID("app.bsky.actor.status"):

     

       
117
       
-
       
		status := models.NewActorStatus(uri, *rec)

     

       
118
       
-
       
		if err := hs.store.Where(models.ActorStatus{ID: string(uri)}).Assign(status).FirstOrCreate(&models.ActorStatus{}).Error; err != nil {

     

       
119
       
-
       
			return fmt.Errorf("error upserting actor status: %w", err)

     

       
120
       
-
       
		}

     

       
121
       
 
       


     

       
122
       
 
       
	case syntax.NSID("app.bsky.feed.generator"):

     

       
123
       
-
       
		feedgen := models.NewFeedGenerator(uri, *rec)

     

       
124
       
-
       
		if err := hs.store.Where(models.FeedGenerator{ID: string(uri)}).Assign(feedgen).FirstOrCreate(&models.FeedGenerator{}).Error; err != nil {

     

       
125
       
-
       
			return fmt.Errorf("error upserting feed generator: %w", err)

     

       
126
       
-
       
		}

     

       
127
       
 
       


     

       
128
       
 
       
	case syntax.NSID("app.bsky.feed.like"):

     

       
129
       
-
       
		like := models.NewFeedLike(uri, *rec)

     

       
130
       
-
       
		if err := hs.store.Where(models.FeedLike{ID: string(uri)}).Assign(like).FirstOrCreate(&models.FeedLike{}).Error; err != nil {

     

       
131
       
-
       
			return fmt.Errorf("error upserting feed like: %w", err)

     

       
132
       
-
       
		}

     

       
133
       
 
       


     

       
134
       
 
       
	case syntax.NSID("app.bsky.feed.post"):

     

       
135
       
-
       
		post := models.NewFeedPost(uri, *rec)

     

       
136
       
-
       
		if err := hs.store.Where(models.FeedPost{ID: string(uri)}).Assign(post).FirstOrCreate(&models.FeedPost{}).Error; err != nil {

     

       
137
       
-
       
			return fmt.Errorf("error upserting feed like: %w", err)

     

       
138
       
-
       
		}

     

       
139
       
 
       


     

       
140
       
 
       
	case syntax.NSID("app.bsky.feed.postgate"):

     

       
141
       
-
       
		postgate := models.NewFeedPostgate(uri, *rec)

     

       
142
       
-
       
		if err := hs.store.Where(models.FeedPostgate{ID: string(uri)}).Assign(postgate).FirstOrCreate(&models.FeedPostgate{}).Error; err != nil {

     

       
143
       
-
       
			return fmt.Errorf("error upserting feed postgate: %w", err)

     

       
144
       
-
       
		}

     

       
145
       
 
       


     

       
146
       
 
       
	case syntax.NSID("app.bsky.feed.repost"):

     

       
147
       
 
       
		return upsertRecord(models.NewFeedRepost, opts)

     

       
148
       
 
       


     

       
149
       
 
       
	case syntax.NSID("app.bsky.feed.threadgate"):

     

       
150
       
-
       
		threadgate := models.NewFeedThreadgate(uri, *rec)

     

       
151
       
-
       
		if err := hs.store.Where(models.FeedThreadgate{ID: string(uri)}).Assign(threadgate).FirstOrCreate(&models.FeedThreadgate{}).Error; err != nil {

     

       
152
       
-
       
			return fmt.Errorf("error upserting feed threadgate: %w", err)

     

       
153
       
-
       
		}

     

       
154
       
 
       


     

       
155
       
 
       
	case syntax.NSID("app.bsky.graph.block"):

     

       
156
       
-
       
		block := models.NewGraphBlock(uri, *rec)

     

       
157
       
-
       
		if err := hs.store.Where(models.GraphBlock{ID: string(uri)}).Assign(block).FirstOrCreate(&models.GraphBlock{}).Error; err != nil {

     

       
158
       
-
       
			return fmt.Errorf("error upserting graph block: %w", err)

     

       
159
       
-
       
		}

     

       
160
       
 
       


     

       
161
       
 
       
	case syntax.NSID("app.bsky.graph.follow"):

     

       
162
       
-
       
		follow := models.NewGraphFollow(uri, *rec)

     

       
163
       
-
       
		if err := hs.store.Where(models.GraphFollow{ID: string(uri)}).Assign(follow).FirstOrCreate(&models.GraphFollow{}).Error; err != nil {

     

       
164
       
-
       
			return fmt.Errorf("error upserting graph follow: %w", err)

     

       
165
       
-
       
		}

     

       
166
       
 
       


     

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

     

       
168
       
-
       
		list := models.NewGraphList(uri, *rec)

     

       
169
       
-
       
		if err := hs.store.Where(models.GraphList{ID: string(uri)}).Assign(list).FirstOrCreate(&models.GraphList{}).Error; err != nil {

     

       
170
       
-
       
			return fmt.Errorf("error upserting graph list: %w", err)

     

       
171
       
-
       
		}

     

       
172
       
 
       


     

       
173
       
 
       
	case syntax.NSID("app.bsky.graph.listblock"):

     

       
174
       
-
       
		listblock := models.NewGraphListblock(uri, *rec)

     

       
175
       
-
       
		if err := hs.store.Where(models.GraphListblock{ID: string(uri)}).Assign(listblock).FirstOrCreate(&models.GraphListblock{}).Error; err != nil {

     

       
176
       
-
       
			return fmt.Errorf("error upserting graph listblock: %w", err)

     

       
177
       
-
       
		}

     

       
178
       
 
       


     

       
179
       
 
       
	case syntax.NSID("app.bsky.graph.listitem"):

     

       
180
       
-
       
		listitem := models.NewGraphListitem(uri, *rec)

     

       
181
       
-
       
		if err := hs.store.Where(models.GraphListitem{ID: string(uri)}).Assign(listitem).FirstOrCreate(&models.GraphListitem{}).Error; err != nil {

     

       
182
       
-
       
			return fmt.Errorf("error upserting graph listitem: %w", err)

     

       
183
       
-
       
		}

     

       
184
       
 
       


     

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

     

       
186
       
-
       
		pack := models.NewGraphStarterpack(uri, *rec)

     

       
187
       
-
       
		if err := hs.store.Where(models.GraphStarterpack{ID: string(uri)}).Assign(pack).FirstOrCreate(&models.GraphStarterpack{}).Error; err != nil {

     

       
188
       
-
       
			return fmt.Errorf("error upserting graph starterpack: %w", err)

     

       
189
       
-
       
		}

     

       
190
       
 
       


     

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

     

       
192
       
-
       
		verification := models.NewGraphVerification(uri, *rec)

     

       
193
       
-
       
		if err := hs.store.Where(models.GraphVerification{ID: string(uri)}).Assign(verification).FirstOrCreate(&models.GraphVerification{}).Error; err != nil {

     

       
194
       
-
       
			return fmt.Errorf("error upserting graph verification: %w", err)

     

       
195
       
-
       
		}

     

       
196
       
 
       


     

       
197
       
 
       
	case syntax.NSID("app.bsky.labeler.service"):

     

       
198
       
-
       
		labeler := models.NewLabelerService(uri, *rec)

     

       
199
       
-
       
		if err := hs.store.Where(models.LabelerService{ID: string(uri)}).Assign(labeler).FirstOrCreate(&models.LabelerService{}).Error; err != nil {

     

       
200
       
-
       
			return fmt.Errorf("error upserting labeler service: %w", err)

     

       
201
       
-
       
		}

     

       
202
       
 
       


     

       
203
       
 
       
	case syntax.NSID("chat.bsky.actor.declaration"):

     

       
204
       
-
       
		declaration := models.NewActorDeclaration(uri, *rec)

     

       
205
       
-
       
		if err := hs.store.Where(models.ActorDeclaration{ID: string(uri)}).Assign(declaration).FirstOrCreate(&models.ActorDeclaration{}).Error; err != nil {

     

       
206
       
-
       
			return fmt.Errorf("error upserting chat actor declaration: %w", err)

     

       
207
       
-
       
		}

     

       
208
       
 
       
	}

     

       
209
       
 
       


     

       
210
       
 
       
	return nil

     

···

       
97
       
 
       
	return nil

     

       
98
       
 
       
}

     

       
99
       
 
       


     

       
0
       
 
       

     

       
100
       
 
       
func (hs *HandlerService) HandleUpsert(ctx context.Context, repo string, rev string, path string, rec *[]byte, cid *cid.Cid, action Action) error {

     

       
101
       
 
       
	uri, err := syntax.ParseATURI(fmt.Sprintf("at://%s/%s", repo, path))

     

       
102
       
 
       
	if err != nil {

     
···

       
107
       
 
       


     

       
108
       
 
       
	switch uri.Collection() {

     

       
109
       
 
       
	case syntax.NSID("app.bsky.actor.profile"):

     

       
110
       
+
       
		return upsertRecord(models.NewActorProfile, opts)

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
111
       
 
       


     

       
112
       
 
       
	case syntax.NSID("app.bsky.actor.status"):

     

       
113
       
+
       
		return upsertRecord(models.NewActorStatus, opts)

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
114
       
 
       


     

       
115
       
 
       
	case syntax.NSID("app.bsky.feed.generator"):

     

       
116
       
+
       
		return upsertRecord(models.NewFeedGenerator, opts)

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
117
       
 
       


     

       
118
       
 
       
	case syntax.NSID("app.bsky.feed.like"):

     

       
119
       
+
       
		return upsertRecord(models.NewFeedLike, opts)

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
120
       
 
       


     

       
121
       
 
       
	case syntax.NSID("app.bsky.feed.post"):

     

       
122
       
+
       
		return upsertRecord(models.NewFeedPost, opts)

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
123
       
 
       


     

       
124
       
 
       
	case syntax.NSID("app.bsky.feed.postgate"):

     

       
125
       
+
       
		return upsertRecord(models.NewFeedPostgate, opts)

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
126
       
 
       


     

       
127
       
 
       
	case syntax.NSID("app.bsky.feed.repost"):

     

       
128
       
 
       
		return upsertRecord(models.NewFeedRepost, opts)

     

       
129
       
 
       


     

       
130
       
 
       
	case syntax.NSID("app.bsky.feed.threadgate"):

     

       
131
       
+
       
		return upsertRecord(models.NewFeedThreadgate, opts)

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
132
       
 
       


     

       
133
       
 
       
	case syntax.NSID("app.bsky.graph.block"):

     

       
134
       
+
       
		return upsertRecord(models.NewGraphBlock, opts)

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
135
       
 
       


     

       
136
       
 
       
	case syntax.NSID("app.bsky.graph.follow"):

     

       
137
       
+
       
		return upsertRecord(models.NewGraphFollow, opts)

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
138
       
 
       


     

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

     

       
140
       
+
       
		return upsertRecord(models.NewGraphList, opts)

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
141
       
 
       


     

       
142
       
 
       
	case syntax.NSID("app.bsky.graph.listblock"):

     

       
143
       
+
       
		return upsertRecord(models.NewGraphListblock, opts)

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
144
       
 
       


     

       
145
       
 
       
	case syntax.NSID("app.bsky.graph.listitem"):

     

       
146
       
+
       
		return upsertRecord(models.NewGraphListitem, opts)

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
147
       
 
       


     

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

     

       
149
       
+
       
		return upsertRecord(models.NewGraphStarterpack, opts)

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
150
       
 
       


     

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

     

       
152
       
+
       
		return upsertRecord(models.NewGraphVerification, opts)

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
153
       
 
       


     

       
154
       
 
       
	case syntax.NSID("app.bsky.labeler.service"):

     

       
155
       
+
       
		return upsertRecord(models.NewLabelerService, opts)

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
156
       
 
       


     

       
157
       
 
       
	case syntax.NSID("chat.bsky.actor.declaration"):

     

       
158
       
+
       
		return upsertRecord(models.NewActorDeclaration, opts)

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
159
       
 
       
	}

     

       
160
       
 
       


     

       
161
       
 
       
	return nil