mirror of
https://codeberg.org/yeentown/barkey.git
synced 2025-07-08 13:04:34 +00:00
use index when checking visibleUserIds and mentions in generateVisibilityQuery
This commit is contained in:
parent
9dc74f6f33
commit
c76a5467f6
1 changed files with 30 additions and 3 deletions
|
@ -160,15 +160,15 @@ export class QueryService {
|
||||||
// Reply to me
|
// Reply to me
|
||||||
.orWhere(':meId = note.replyUserId')
|
.orWhere(':meId = note.replyUserId')
|
||||||
// DM to me
|
// DM to me
|
||||||
.orWhere(':meId = ANY (note.visibleUserIds)')
|
.orWhere(':meIdAsList <@ note.visibleUserIds')
|
||||||
// Mentions me
|
// Mentions me
|
||||||
.orWhere(':meId = ANY (note.mentions)')
|
.orWhere(':meIdAsList <@ note.mentions')
|
||||||
// Followers-only post
|
// Followers-only post
|
||||||
.orWhere(new Brackets(qb => this
|
.orWhere(new Brackets(qb => this
|
||||||
.andFollowingUser(qb, ':meId', 'note.userId')
|
.andFollowingUser(qb, ':meId', 'note.userId')
|
||||||
.andWhere('note.visibility = \'followers\'')));
|
.andWhere('note.visibility = \'followers\'')));
|
||||||
|
|
||||||
q.setParameters({ meId: me.id });
|
q.setParameters({ meId: me.id, meIdAsList: [me.id] });
|
||||||
}
|
}
|
||||||
}));
|
}));
|
||||||
}
|
}
|
||||||
|
@ -283,6 +283,33 @@ export class QueryService {
|
||||||
return q[join](`EXISTS (${followingQuery.getQuery()})`, followingQuery.getParameters());
|
return q[join](`EXISTS (${followingQuery.getQuery()})`, followingQuery.getParameters());
|
||||||
};
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Adds OR condition that followerProp (user ID) is following followeeProp (channel ID).
|
||||||
|
* Both props should be expressions, not raw values.
|
||||||
|
*/
|
||||||
|
@bindThis
|
||||||
|
public orFollowingChannel<Q extends WhereExpressionBuilder>(q: Q, followerProp: string, followeeProp: string): Q {
|
||||||
|
return this.addFollowingChannel(q, followerProp, followeeProp, 'orWhere');
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Adds AND condition that followerProp (user ID) is following followeeProp (channel ID).
|
||||||
|
* Both props should be expressions, not raw values.
|
||||||
|
*/
|
||||||
|
@bindThis
|
||||||
|
public andFollowingChannel<Q extends WhereExpressionBuilder>(q: Q, followerProp: string, followeeProp: string): Q {
|
||||||
|
return this.addFollowingChannel(q, followerProp, followeeProp, 'andWhere');
|
||||||
|
}
|
||||||
|
|
||||||
|
private addFollowingChannel<Q extends WhereExpressionBuilder>(q: Q, followerProp: string, followeeProp: string, join: 'andWhere' | 'orWhere'): Q {
|
||||||
|
const followingQuery = this.channelFollowingsRepository.createQueryBuilder('following')
|
||||||
|
.select('1')
|
||||||
|
.andWhere(`following.followerId = ${followerProp}`)
|
||||||
|
.andWhere(`following.followeeId = ${followeeProp}`);
|
||||||
|
|
||||||
|
return q[join](`EXISTS (${followingQuery.getQuery()})`, followingQuery.getParameters());
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Adds OR condition that blockerProp (user ID) is not blocking blockeeProp (user ID).
|
* Adds OR condition that blockerProp (user ID) is not blocking blockeeProp (user ID).
|
||||||
* Both props should be expressions, not raw values.
|
* Both props should be expressions, not raw values.
|
||||||
|
|
Loading…
Add table
Reference in a new issue