this repo has no description
logging
+8
-6
+8
-6
consumer.go
+8
-6
consumer.go
···
133
133
return fmt.Errorf("get subscribing post parent URI: %w", err)
134
134
}
135
135
136
+
slog.Info("delete parent URI", "parent URI", parentURI, "rkey", event.Commit.RKey)
137
+
136
138
// delete from feeds for the parentURI and the users DID first. This is so that if this fails, it can be tried again and the
137
139
// subscription will be still there
138
-
err = deleteSubscriptionForUser(h.db, event.Did, parentURI)
140
+
err = deleteFeedItemsForParentURIandUserDID(h.db, parentURI, event.Did)
139
141
if err != nil {
140
-
slog.Error("delete subscription for user", "error", err, "parentURI", parentURI, "user DID", event.Did)
141
-
return fmt.Errorf("delete subscription and user: %w", err)
142
+
slog.Error("delete feed items for parentURI and user", "error", err, "parentURI", parentURI, "user DID", event.Did)
143
+
return fmt.Errorf("delete feed items for parentURI and user: %w", err)
142
144
}
143
145
144
146
// delete from subscriptions for the parentURI and the users DID now that we have cleaned up the feeds
145
-
err = deleteFeedItemsForParentURIandUserDID(h.db, parentURI, event.Did)
147
+
err = deleteSubscriptionForUser(h.db, event.Did, parentURI)
146
148
if err != nil {
147
-
slog.Error("delete feed items for parentURI and user", "error", err, "parentURI", parentURI, "user DID", event.Did)
148
-
return fmt.Errorf("delete feed items for parentURI and user: %w", err)
149
+
slog.Error("delete subscription for user", "error", err, "parentURI", parentURI, "user DID", event.Did)
150
+
return fmt.Errorf("delete subscription and user: %w", err)
149
151
}
150
152
151
153
return nil