modified internal/cluster/scoring.go +1 -0
| @@ -255,6 +255,7 @@ func (e *Engine) ComputePeopleRecommendationsOnDemand(ctx context.Context, userD |
| 255 | 255 | ) sim |
| 256 | 256 | JOIN users u ON u.did = sim.peer_did |
| 257 | 257 | WHERE u.handle IS NOT NULL AND u.handle != '' |
| 258 | + AND EXISTS (SELECT 1 FROM subscriptions s JOIN feeds f ON s.feed_url = f.feed_url WHERE s.user_did = u.did AND f.subscriber_count > 0) |
| 258 | 259 | ORDER BY sim.jaccard DESC |
| 259 | 260 | LIMIT ? |
| 260 | 261 | `, userDID, userDID, limit) |
| @@ -255,6 +255,7 @@ func (e *Engine) ComputePeopleRecommendationsOnDemand(ctx context.Context, userD |
| 255 | ) sim | 255 | ) sim |
| 256 | JOIN users u ON u.did = sim.peer_did | 256 | JOIN users u ON u.did = sim.peer_did |
| 257 | WHERE u.handle IS NOT NULL AND u.handle != '' | 257 | WHERE u.handle IS NOT NULL AND u.handle != '' |
| | 258 | + AND EXISTS (SELECT 1 FROM subscriptions s JOIN feeds f ON s.feed_url = f.feed_url WHERE s.user_did = u.did AND f.subscriber_count > 0) |
| 258 | ORDER BY sim.jaccard DESC | 259 | ORDER BY sim.jaccard DESC |
| 259 | LIMIT ? | 260 | LIMIT ? |
| 260 | `, userDID, userDID, limit) | 261 | `, userDID, userDID, limit) |