44 lines
1.3 KiB
TypeScript
44 lines
1.3 KiB
TypeScript
|
import { BaseGuildRepository } from "./BaseGuildRepository";
|
||
|
|
import { Repository, getRepository } from "typeorm";
|
||
|
|
import { StarboardReaction } from "./entities/StarboardReaction";
|
||
|
|
|
||
|
|
export class GuildStarboardReactions extends BaseGuildRepository {
|
||
|
|
private allStarboardReactions: Repository<StarboardReaction>;
|
||
|
|
|
||
|
|
constructor(guildId) {
|
||
|
|
super(guildId);
|
||
|
|
this.allStarboardReactions = getRepository(StarboardReaction);
|
||
|
|
}
|
||
|
|
|
||
|
|
async getAllReactionsForMessageId(messageId: string) {
|
||
|
|
return this.allStarboardReactions
|
||
|
|
.createQueryBuilder()
|
||
|
|
.where("guild_id = :gid", { gid: this.guildId })
|
||
|
|
.andWhere("message_id = :msgid", { msgid: messageId })
|
||
|
|
.getMany();
|
||
|
|
}
|
||
|
|
|
||
|
|
async createStarboardReaction(messageId: string, reactorId: string) {
|
||
|
|
await this.allStarboardReactions.insert({
|
||
|
|
message_id: messageId,
|
||
|
|
reactor_id: reactorId,
|
||
|
|
guild_id: this.guildId,
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
async deleteAllStarboardReactionsForMessageId(messageId: string) {
|
||
|
|
await this.allStarboardReactions.delete({
|
||
|
|
guild_id: this.guildId,
|
||
|
|
message_id: messageId,
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
async deleteStarboardReaction(messageId: string, reactorId: string) {
|
||
|
|
await this.allStarboardReactions.delete({
|
||
|
|
guild_id: this.guildId,
|
||
|
|
reactor_id: reactorId,
|
||
|
|
message_id: messageId,
|
||
|
|
});
|
||
|
|
}
|
||
|
|
}
|