···

       
57
       
 
       


     

       
58
       
 
       
	switch uri.Collection() {

     

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

     

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

     

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

     

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

     

       
63
       
-
       
		// }

     

       
64
       
-
       
		return nil

     

       
65
       
 
       


     

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

     

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

     
···

       
76
       
 
       
		}

     

       
77
       
 
       


     

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

     

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

     

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

     

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

     

       
82
       
-
       
		// }

     

       
83
       
-
       
		return nil

     

       
84
       
 
       


     

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

     

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

     
···

       
89
       
 
       
		}

     

       
90
       
 
       


     

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

     

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

     

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

     

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

     

       
95
       
-
       
		// }

     

       
96
       
-
       
		return nil

     

       
97
       
 
       


     

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

     

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

     

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

     

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

     

       
102
       
-
       
		// }

     

       
103
       
-
       
		return nil

     

       
104
       
 
       


     

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

     

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

     

···

       
57
       
 
       


     

       
58
       
 
       
	switch uri.Collection() {

     

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

     

       
60
       
+
       
		profile := models.NewActorProfile(uri, *rec)

     

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

     

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

     

       
63
       
+
       
		}

     

       
0
       
 
       

     

       
64
       
 
       


     

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

     

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

     
···

       
75
       
 
       
		}

     

       
76
       
 
       


     

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

     

       
78
       
+
       
		block := models.NewGraphBlock(uri, *rec)

     

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

     

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

     

       
81
       
+
       
		}

     

       
0
       
 
       

     

       
82
       
 
       


     

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

     

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

     
···

       
87
       
 
       
		}

     

       
88
       
 
       


     

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

     

       
90
       
+
       
		listblock := models.NewGraphListblock(uri, *rec)

     

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

     

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

     

       
93
       
+
       
		}

     

       
0
       
 
       

     

       
94
       
 
       


     

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

     

       
96
       
+
       
		listitem := models.NewGraphListitem(uri, *rec)

     

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

     

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

     

       
99
       
+
       
		}

     

       
0
       
 
       

     

       
100
       
 
       


     

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

     

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