Compare commits

...

2 Commits

Author SHA1 Message Date
7e37641e0b finally use request id 2023-06-04 01:09:24 +02:00
5db37b0e95 handler now creates and disables/enables users 2023-06-04 01:09:24 +02:00
2 changed files with 66 additions and 37 deletions

View File

@ -2,22 +2,23 @@ import { Collection, GuildMember } from "discord.js"
import { filterRolesFromMemberUpdate } from "../helper/roleFilter" import { filterRolesFromMemberUpdate } from "../helper/roleFilter"
import { ChangedRoles, PermissionLevel } from "../interfaces" import { ChangedRoles, PermissionLevel } from "../interfaces"
import { jellyfinHandler } from "../.." import { jellyfinHandler } from "../.."
import { v4 as uuid } from "uuid"
export const name = 'guildMemberUpdate' export const name = 'guildMemberUpdate'
export async function execute(oldMember: GuildMember, newMember: GuildMember) { export async function execute(oldMember: GuildMember, newMember: GuildMember) {
try { try {
const requestId = uuid()
const changedRoles: ChangedRoles = filterRolesFromMemberUpdate(oldMember, newMember) const changedRoles: ChangedRoles = filterRolesFromMemberUpdate(oldMember, newMember)
const triggerRoleIds: Collection<string, PermissionLevel> = getGuildSpecificTriggerRoleId(oldMember.guild.id) const triggerRoleIds: Collection<string, PermissionLevel> = getGuildSpecificTriggerRoleId(oldMember.guild.id)
triggerRoleIds.forEach((level, key) => { triggerRoleIds.forEach((level, key) => {
const addedRoleMatches = changedRoles.addedRoles.find(aRole => aRole.id === key) const addedRoleMatches = changedRoles.addedRoles.find(aRole => aRole.id === key)
if (addedRoleMatches) { if (addedRoleMatches) {
jellyfinHandler.upsertUser(newMember, level) jellyfinHandler.upsertUser(newMember, level, requestId)
} }
const removedRoleMatches = changedRoles.removedRoles.find(rRole => rRole.id === key) const removedRoleMatches = changedRoles.removedRoles.find(rRole => rRole.id === key)
if (removedRoleMatches) { if (removedRoleMatches) {
jellyfinHandler.removeUser(newMember) jellyfinHandler.removeUser(newMember, requestId)
} }
}) })
} catch (error) { } catch (error) {

View File

@ -1,11 +1,13 @@
import { GuildMember } from "discord.js"; import { GuildMember } from "discord.js";
import { CreateUserByNameOperationRequest, SystemApi, UpdateUserPolicyOperationRequest, UserApi } from "./apis"; import { CreateUserByNameOperationRequest, SystemApi, UpdateUserPasswordOperationRequest, UpdateUserPolicyOperationRequest, UserApi } from "./apis";
import { UserDto } from "./models/UserDto"; import { UserDto } from "./models/UserDto";
import { Configuration, ConfigurationParameters } from "./runtime"; import { Configuration, ConfigurationParameters } from "./runtime";
import { CreateUserByNameRequest, UpdateUserPolicyRequest } from "./models"; import { CreateUserByNameRequest, UpdateUserEasyPasswordRequest, UpdateUserPasswordRequest, UpdateUserPolicyRequest } from "./models";
import { Config } from "../configuration"; import { Config } from "../configuration";
import { logger } from "../logger"; import { logger } from "../logger";
import { Maybe } from "../interfaces"; import { Maybe } from "../interfaces";
import { v4 as uuid } from "uuid";
export class JellyfinHandler { export class JellyfinHandler {
@ -52,8 +54,8 @@ export class JellyfinHandler {
throw new Error("Method not implemented."); throw new Error("Method not implemented.");
} }
private generatePasswordForUser(user: GuildMember): string { private generatePasswordForUser(): string {
return user.displayName + user.user.discriminator return (Math.random() * 10000 + 10000).toFixed(0)
} }
public async createUserAccountForDiscordUser(discordUser: GuildMember, guildId?: string, requestId?: string): Promise<UserDto> { public async createUserAccountForDiscordUser(discordUser: GuildMember, guildId?: string, requestId?: string): Promise<UserDto> {
@ -62,39 +64,24 @@ export class JellyfinHandler {
const req: CreateUserByNameOperationRequest = { const req: CreateUserByNameOperationRequest = {
createUserByNameRequest: { createUserByNameRequest: {
name: newUserName, name: newUserName,
password: this.generatePasswordForUser(discordUser), password: this.generatePasswordForUser(),
} }
} }
logger.debug(JSON.stringify(req)) logger.debug(JSON.stringify(req))
const createResult = await this.userApi.createUserByName(req) const createResult = await this.userApi.createUserByName(req)
if (createResult) if (createResult){
(await discordUser.createDM()).send(`Ich hab dir mal nen Account angelegt :)\nDein Username ist ${createResult.name}, dein Password ist "${req.createUserByNameRequest.password}"!` )
return createResult return createResult
}
else throw new Error('Could not create User in Jellyfin') else throw new Error('Could not create User in Jellyfin')
} }
public async disableJfUser(user: UserDto, guildId?: string, requestId?: string): Promise<void> {
if (user.id) {
logger.info(`Trying to disable user: ${user.name}|${user.id}`)
const r: UpdateUserPolicyOperationRequest = {
userId: user.id,
updateUserPolicyRequest: {
isDisabled: true
},
}
await this.userApi.updateUserPolicy(r)
logger.info(`Succeeded with disabling user: ${user.name}`)
}
else {
logger.error(`Can not disable user ${JSON.stringify(user)}, has no id?!`, { requestId, guildId })
}
}
public async isUserAlreadyPresent(discordUser: GuildMember, requestId?: string): Promise<boolean> { public async isUserAlreadyPresent(discordUser: GuildMember, requestId?: string): Promise<boolean> {
const jfuser = await this.getUser(discordUser, requestId) const jfuser = await this.getUser(discordUser, requestId)
logger.debug(`Presence for DiscordUser ${discordUser.id}:${jfuser !== undefined}`) logger.debug(`Presence for DiscordUser ${discordUser.id}:${jfuser !== undefined}`)
return jfuser !== undefined return jfuser !== undefined
} }
public async getCurrentUsers(guildId: string, requestId?: string): Promise<UserDto[]> { public async getCurrentUsers(guildId: string, requestId?: string): Promise<UserDto[]> {
try { try {
logger.info(`Fetching current users from Jellyfin`, { requestId, guildId }) logger.info(`Fetching current users from Jellyfin`, { requestId, guildId })
@ -105,28 +92,72 @@ export class JellyfinHandler {
} }
return [] return []
} }
public async getUser(discordUser: GuildMember, requestId?: string): Promise<Maybe<UserDto>> { public async getUser(discordUser: GuildMember, requestId?: string): Promise<Maybe<UserDto>> {
const jfUsernameFromDiscordUsername = this.generateJFUserName(discordUser) const jfUsernameFromDiscordUsername = this.generateJFUserName(discordUser)
const jfUsers = await this.getCurrentUsers(discordUser.guild.id, requestId) const jfUsers = await this.getCurrentUsers(discordUser.guild.id, requestId)
const foundUser = jfUsers.find(x => x.name === jfUsernameFromDiscordUsername) const foundUser = jfUsers.find(x => x.name === jfUsernameFromDiscordUsername)
return foundUser return foundUser
} }
public async removeUser(newMember: GuildMember, requestId?: string) { public async removeUser(newMember: GuildMember, requestId?: string) {
logger.error(`Trying to remove user ${newMember.displayName}, but method is not implemented`) logger.error(`Trying to remove user ${newMember.displayName}, but method is not implemented`)
const jfuser = await this.getUser(newMember, requestId) const jfuser = await this.getUser(newMember, requestId)
if (jfuser) { if (jfuser) {
await this.disableJfUser(jfuser, newMember.guild.id, requestId) await this.disableUser(jfuser, newMember.guild.id, requestId)
} }
} }
public async enableUser(user: UserDto, guildId?: string, requestId?: string): Promise<void> { public async resetUserPasswort(member: GuildMember, requestId?: string) {
const jfUser = await this.getUser(member, requestId)
if (jfUser && jfUser.id) {
const r: UpdateUserPasswordRequest = {
newPw: this.generatePasswordForUser()
}
const shit: UpdateUserPasswordOperationRequest = {
updateUserPasswordRequest: r,
userId: jfUser.id
}
this.userApi.updateUserPassword(shit)
} else {
(await member.createDM()).send("Ich konnte leider keinen User von dir auf Jellyfin finden. Bitte melde dich bei Markus oder Samantha!")
}
}
public async disableUser(user: UserDto, guildId?: string, requestId?: string): Promise<void> {
if (user.id) { if (user.id) {
logger.info(`Trying to enable user: ${user.name}|${user.id}`) const jfUser = await this.getUser(<GuildMember>{displayName: user.name, guild: {id: guildId}}, requestId)
logger.info(`Trying to disable user: ${user.name}|${user.id}|${JSON.stringify(jfUser, null, 2)}`)
const r: UpdateUserPolicyOperationRequest = { const r: UpdateUserPolicyOperationRequest = {
userId: user.id ?? "", userId: user.id ?? "",
updateUserPolicyRequest: { updateUserPolicyRequest: {
...jfUser?.policy,
isDisabled: true,
}
}
await this.userApi.updateUserPolicy(r)
logger.info(`Succeeded with disabling user: ${user.name}`)
}
else {
logger.error(`Can not disable user ${JSON.stringify(user)}, has no id?!`, { requestId, guildId })
}
}
public async enableUser(user: UserDto, guildId: string, requestId?: string): Promise<void> {
if (user.id) {
const jfUser = await this.getUser(<GuildMember>{displayName: user.name, guild: {id: guildId}}, requestId)
logger.info(`Trying to enable user: ${user.name}|${user.id}|${JSON.stringify(jfUser, null, 2)}`)
const r: UpdateUserPolicyOperationRequest = {
userId: user.id ?? "",
updateUserPolicyRequest: {
...jfUser?.policy,
isDisabled: false,
} }
} }
await this.userApi.updateUserPolicy(r) await this.userApi.updateUserPolicy(r)
@ -142,13 +173,10 @@ export class JellyfinHandler {
const jfuser = await this.getUser(newMember, requestId) const jfuser = await this.getUser(newMember, requestId)
if (jfuser) { if (jfuser) {
logger.info(`User with name ${newMember.displayName} is already present`) logger.info(`User with name ${newMember.displayName} is already present`)
await this.enableUser(jfuser, requestId) await this.enableUser(jfuser, newMember.guild.id, requestId)
} else { } else {
this.createUserAccountForDiscordUser(newMember, newMember.guild.id, requestId) this.createUserAccountForDiscordUser(newMember, newMember.guild.id, requestId)
} }
} }
} }