Compare commits
12 Commits
016bb243cc
...
feat/20-re
Author | SHA1 | Date | |
---|---|---|---|
a60fc2db7e | |||
a50ac1716f | |||
ef39c6315d | |||
1f372b0aac | |||
d1aacbb3d3 | |||
1ae8278fb8 | |||
417b24d408 | |||
88061c361c | |||
f83f54749d | |||
90b0b07080 | |||
6d0eaed426 | |||
8f320cee5c |
@ -82,41 +82,5 @@ Für eine Erklärung wie das alles funktioniert mach einfach /mitgucken für ein
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
export async function manageAnnouncementRoles(guild: Guild, reaction: MessageReaction, requestId: string) {
|
|
||||||
const guildId = guild.id
|
|
||||||
logger.info("Managing roles", { guildId, requestId })
|
|
||||||
|
|
||||||
const announcementRole: Role | undefined = (await guild.roles.fetch()).find(role => role.id === config.bot.announcement_role)
|
|
||||||
if (!announcementRole) {
|
|
||||||
logger.error(`Could not find announcement role! Aborting! Was looking for role with id: ${config.bot.announcement_role}`, { guildId, requestId })
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
const usersWhoWantRole: User[] = (await reaction.users.fetch()).filter(user => !user.bot).map(user => user)
|
|
||||||
|
|
||||||
const allUsers = (await guild.members.fetch())
|
|
||||||
|
|
||||||
const usersWhoHaveRole: GuildMember[] = allUsers
|
|
||||||
.filter(member => member.roles.cache
|
|
||||||
.find(role => role.id === config.bot.announcement_role) !== undefined)
|
|
||||||
.map(member => member)
|
|
||||||
|
|
||||||
const usersWhoNeedRoleRevoked: GuildMember[] = usersWhoHaveRole
|
|
||||||
.filter(userWhoHas => !usersWhoWantRole.map(wanter => wanter.id).includes(userWhoHas.id))
|
|
||||||
|
|
||||||
const usersWhoDontHaveRole: GuildMember[] = allUsers
|
|
||||||
.filter(member => member.roles.cache
|
|
||||||
.find(role => role.id === config.bot.announcement_role) === undefined)
|
|
||||||
.map(member => member)
|
|
||||||
|
|
||||||
const usersWhoNeedRole: GuildMember[] = usersWhoDontHaveRole
|
|
||||||
.filter(userWhoNeeds => usersWhoWantRole.map(wanter => wanter.id).includes(userWhoNeeds.id))
|
|
||||||
|
|
||||||
|
|
||||||
logger.debug(`Theses users will get the role removed: ${JSON.stringify(usersWhoNeedRoleRevoked)}`, { guildId, requestId })
|
|
||||||
logger.debug(`Theses users will get the role added: ${JSON.stringify(usersWhoNeedRole)}`, { guildId, requestId })
|
|
||||||
|
|
||||||
usersWhoNeedRoleRevoked.forEach(user => user.roles.remove(announcementRole))
|
|
||||||
usersWhoNeedRole.forEach(user => user.roles.add(announcementRole))
|
|
||||||
}
|
|
||||||
|
|
||||||
|
@ -39,7 +39,7 @@ export async function execute(messageReaction: MessageReaction, user: User) {
|
|||||||
else if (isInitialAnnouncement(reactedUponMessage)) {
|
else if (isInitialAnnouncement(reactedUponMessage)) {
|
||||||
if (messageReaction.emoji.toString() === Emoji.ticket) {
|
if (messageReaction.emoji.toString() === Emoji.ticket) {
|
||||||
logger.error(`Got a role emoji. ${reactedUponMessage.id}`)
|
logger.error(`Got a role emoji. ${reactedUponMessage.id}`)
|
||||||
return client.roleController.addMediaRoleToUser(user, guildId, requestId)
|
return client.roleController.addMediaRoleToUser(user, messageReaction.message.guild, requestId)
|
||||||
}
|
}
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
@ -27,7 +27,7 @@ export async function execute(messageReaction: MessageReaction, user: User) {
|
|||||||
if (isInitialAnnouncement(reactedUponMessage)) {
|
if (isInitialAnnouncement(reactedUponMessage)) {
|
||||||
if (messageReaction.emoji.toString() === Emoji.ticket) {
|
if (messageReaction.emoji.toString() === Emoji.ticket) {
|
||||||
logger.info(`User: ${user.id}, ${user.username} has removed a ticket reaction. Starting role management`, { requestId, guildId })
|
logger.info(`User: ${user.id}, ${user.username} has removed a ticket reaction. Starting role management`, { requestId, guildId })
|
||||||
return client.roleController.removeMediaRoleFromUser(user, guildId, requestId)
|
return client.roleController.removeMediaRoleFromUser(user, messageReaction.message.guild, requestId)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -1,25 +1,83 @@
|
|||||||
import { Role, User } from "discord.js";
|
import { Guild, MessageReaction, Role, User } from "discord.js";
|
||||||
import { ExtendedClient } from "../structures/client";
|
import { GuildMember } from "discord.js";
|
||||||
|
import { logger } from "../logger";
|
||||||
|
import { config } from "../configuration";
|
||||||
|
import { Maybe } from "../interfaces";
|
||||||
|
|
||||||
export default class RoleController {
|
export default class RoleController {
|
||||||
|
|
||||||
constructor(private client: ExtendedClient) { }
|
constructor() { }
|
||||||
private getMediaRoleForGuild(guildId: string): Role {
|
private getAnnounceRoleIdForGuild(guildId: string): string {
|
||||||
throw new Error("Method not implemented.");
|
const role = config.bot.announcement_role
|
||||||
|
if (!role) throw new Error(`No announcementRole defined for guild ${guildId}`)
|
||||||
|
return role
|
||||||
}
|
}
|
||||||
public addRoleToUser(user: User, role: Role, guildId: string, requestId: string) {
|
public async addRoleToUser(member: GuildMember, role: Role, guildId: string, requestId: string) {
|
||||||
throw new Error("Method not implemented.");
|
logger.info(`Adding Role ${role.id} to user ${member.id}|${member.user.username}`, { requestId, guildId })
|
||||||
|
return await member.roles.add(role)
|
||||||
}
|
}
|
||||||
private removeRoleFromUser(user: User, roleToAdd: any, guildId: string, requestId: string) {
|
private async removeRoleFromUser(member: GuildMember, role: Role, guildId: string, requestId: string) {
|
||||||
throw new Error("Method not implemented.");
|
logger.info(`Removing Role ${role.id} from user ${member.id}|${member.user.username}`, { requestId, guildId })
|
||||||
|
return await member.roles.remove(role)
|
||||||
}
|
}
|
||||||
|
|
||||||
public addMediaRoleToUser(user: User, guildId: string, requestId: string) {
|
public async addMediaRoleToUser(user: User, guild: Guild, requestId: string) {
|
||||||
const roleToAdd: Role = this.getMediaRoleForGuild(guildId)
|
const roleToAdd = await this.getAnnouncementRoleForGuild(guild, requestId)
|
||||||
return this.addRoleToUser(user, roleToAdd, guildId, requestId)
|
if (!roleToAdd) throw new Error(`No announcementRole found to add to user`)
|
||||||
|
const guildMember = await guild.members.fetch(user)
|
||||||
|
return this.addRoleToUser(guildMember, roleToAdd, guild.id, requestId)
|
||||||
}
|
}
|
||||||
public removeMediaRoleFromUser(user: User, guildId: string, requestId: string) {
|
public async removeMediaRoleFromUser(user: User, guild: Guild, requestId: string) {
|
||||||
const roleToRemove: Role = this.getMediaRoleForGuild(guildId)
|
const roleToRemove = await this.getAnnouncementRoleForGuild(guild, requestId)
|
||||||
return this.removeRoleFromUser(user, roleToRemove, guildId, requestId)
|
if (!roleToRemove) throw new Error(`No announcementRole found to remove from user`)
|
||||||
|
const guildMember = await guild.members.fetch(user)
|
||||||
|
return this.removeRoleFromUser(guildMember, roleToRemove, guild.id, requestId)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public async getAnnouncementRoleForGuild(guild: Guild, requestId: string): Promise<Role> {
|
||||||
|
const mediaRole = this.getAnnounceRoleIdForGuild(guild.id)
|
||||||
|
const announcement_role = await guild.roles.fetch()
|
||||||
|
.then(fetchedRoles => fetchedRoles.find(role => role.id === mediaRole))
|
||||||
|
.catch(error => {
|
||||||
|
logger.error(`Could not find announcement_role with id ${config.bot.announcement_role}. Error: ${error}`, { requestId, guildId: guild.id })
|
||||||
|
throw error
|
||||||
|
})
|
||||||
|
if (!announcement_role) throw new Error(`Could not find announcement_role with id ${config.bot.announcement_role}.`)
|
||||||
|
return announcement_role
|
||||||
|
}
|
||||||
|
|
||||||
|
public async assignAnnouncementRolesFromReaction(guild: Guild, reaction: MessageReaction, requestId: string) {
|
||||||
|
const guildId = guild.id
|
||||||
|
logger.info("Managing roles", { guildId, requestId })
|
||||||
|
|
||||||
|
const announcementRole = await this.getAnnouncementRoleForGuild(guild, requestId)
|
||||||
|
|
||||||
|
const usersWhoWantRole: User[] = (await reaction.users.fetch()).filter(user => !user.bot).map(user => user)
|
||||||
|
|
||||||
|
const allUsers = await guild.members.fetch()
|
||||||
|
|
||||||
|
const usersWhoHaveRole: GuildMember[] = allUsers
|
||||||
|
.filter(member => member.roles.cache
|
||||||
|
.find(role => role.id === announcementRole.id) !== undefined)
|
||||||
|
.map(member => member)
|
||||||
|
|
||||||
|
const usersWhoNeedRoleRevoked: GuildMember[] = usersWhoHaveRole
|
||||||
|
.filter(userWhoHas => !usersWhoWantRole.map(wanter => wanter.id).includes(userWhoHas.id))
|
||||||
|
|
||||||
|
const usersWhoDontHaveRole: GuildMember[] = allUsers
|
||||||
|
.filter(member => member.roles.cache
|
||||||
|
.find(role => role.id === announcementRole.id) === undefined)
|
||||||
|
.map(member => member)
|
||||||
|
|
||||||
|
const usersWhoNeedRole: GuildMember[] = usersWhoDontHaveRole
|
||||||
|
.filter(userWhoNeeds => usersWhoWantRole.map(wanter => wanter.id).includes(userWhoNeeds.id))
|
||||||
|
|
||||||
|
|
||||||
|
logger.debug(`Theses users will get the role removed: ${JSON.stringify(usersWhoNeedRoleRevoked)}`, { guildId, requestId })
|
||||||
|
logger.debug(`Theses users will get the role added: ${JSON.stringify(usersWhoNeedRole)}`, { guildId, requestId })
|
||||||
|
|
||||||
|
usersWhoNeedRoleRevoked.forEach(user => this.removeRoleFromUser(user, announcementRole, guild.id, requestId))
|
||||||
|
usersWhoNeedRole.forEach(user => this.addRoleToUser(user, announcementRole, guild.id, requestId))
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@ -5,7 +5,7 @@ import { getMembersWithRoleFromGuild } from "./roleFilter"
|
|||||||
import { config } from "../configuration"
|
import { config } from "../configuration"
|
||||||
import { VoteMessage, isVoteEndedMessage, isVoteMessage } from "./messageIdentifiers"
|
import { VoteMessage, isVoteEndedMessage, isVoteMessage } from "./messageIdentifiers"
|
||||||
import { createDateStringFromEvent } from "./dateHelper"
|
import { createDateStringFromEvent } from "./dateHelper"
|
||||||
import { Maybe, voteMessageInputInformation as prepareVoteMessageInput } from "../interfaces"
|
import { Maybe, prepareVoteMessageInput } from "../interfaces"
|
||||||
import format from "date-fns/format"
|
import format from "date-fns/format"
|
||||||
import toDate from "date-fns/toDate"
|
import toDate from "date-fns/toDate"
|
||||||
import differenceInDays from "date-fns/differenceInDays"
|
import differenceInDays from "date-fns/differenceInDays"
|
||||||
|
@ -39,7 +39,7 @@ export interface JellyfinConfig {
|
|||||||
collectionUser: string
|
collectionUser: string
|
||||||
}
|
}
|
||||||
export type PermissionLevel = "VIEWER" | "ADMIN" | "TEMPORARY"
|
export type PermissionLevel = "VIEWER" | "ADMIN" | "TEMPORARY"
|
||||||
export interface voteMessageInputInformation {
|
export interface prepareVoteMessageInput {
|
||||||
movies: string[],
|
movies: string[],
|
||||||
startDate: Date,
|
startDate: Date,
|
||||||
event: GuildScheduledEvent,
|
event: GuildScheduledEvent,
|
||||||
|
@ -2,7 +2,6 @@ import { ApplicationCommandDataResolvable, Client, ClientOptions, Collection, Gu
|
|||||||
import fs from 'fs';
|
import fs from 'fs';
|
||||||
import { ScheduledTask, schedule } from "node-cron";
|
import { ScheduledTask, schedule } from "node-cron";
|
||||||
import { v4 as uuid } from 'uuid';
|
import { v4 as uuid } from 'uuid';
|
||||||
import { manageAnnouncementRoles } from "../commands/announce";
|
|
||||||
import { config } from "../configuration";
|
import { config } from "../configuration";
|
||||||
import { Maybe } from "../interfaces";
|
import { Maybe } from "../interfaces";
|
||||||
import { JellyfinHandler } from "../jellyfin/handler";
|
import { JellyfinHandler } from "../jellyfin/handler";
|
||||||
@ -20,7 +19,7 @@ export class ExtendedClient extends Client {
|
|||||||
private commandFilePath = `${__dirname}/../commands`
|
private commandFilePath = `${__dirname}/../commands`
|
||||||
private jellyfin: JellyfinHandler
|
private jellyfin: JellyfinHandler
|
||||||
public voteController: VoteController = new VoteController(this, yavinJellyfinHandler)
|
public voteController: VoteController = new VoteController(this, yavinJellyfinHandler)
|
||||||
public roleController: RoleController = new RoleController(this)
|
public roleController: RoleController = new RoleController()
|
||||||
public commands: Collection<string, CommandType> = new Collection()
|
public commands: Collection<string, CommandType> = new Collection()
|
||||||
private announcementChannels: Collection<string, TextChannel> = new Collection() //guildId to TextChannel
|
private announcementChannels: Collection<string, TextChannel> = new Collection() //guildId to TextChannel
|
||||||
private announcementRoleHandlerTask: Collection<string, ScheduledTask> = new Collection() //one task per guild
|
private announcementRoleHandlerTask: Collection<string, ScheduledTask> = new Collection() //one task per guild
|
||||||
@ -174,10 +173,10 @@ export class ExtendedClient extends Client {
|
|||||||
}
|
}
|
||||||
//logger.debug(`Message: ${JSON.stringify(message, null, 2)}`, { guildId: guild.id, requestId })
|
//logger.debug(`Message: ${JSON.stringify(message, null, 2)}`, { guildId: guild.id, requestId })
|
||||||
|
|
||||||
const reactions = message.reactions.resolve("🎫")
|
const ticketReaction = message.reactions.resolve("🎫")
|
||||||
//logger.debug(`reactions: ${JSON.stringify(reactions, null, 2)}`, { guildId: guild.id, requestId })
|
//logger.debug(`reactions: ${JSON.stringify(reactions, null, 2)}`, { guildId: guild.id, requestId })
|
||||||
if (reactions) {
|
if (ticketReaction) {
|
||||||
manageAnnouncementRoles(message.guild, reactions, requestId)
|
this.roleController.assignAnnouncementRolesFromReaction(message.guild, ticketReaction, requestId)
|
||||||
} else {
|
} else {
|
||||||
logger.error("Did not get reactions! Aborting!", { guildId: guild.id, requestId })
|
logger.error("Did not get reactions! Aborting!", { guildId: guild.id, requestId })
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user