Compare commits
2 Commits
2a03cd7589
...
7e37641e0b
Author | SHA1 | Date | |
---|---|---|---|
7e37641e0b | |||
5db37b0e95 |
@ -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) {
|
||||||
|
@ -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)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user