add: JF handler to take care of JF interactions
This commit is contained in:
parent
901daa4f10
commit
a80ccb6bfd
64
jellyfin/handler.ts
Normal file
64
jellyfin/handler.ts
Normal file
@ -0,0 +1,64 @@
|
|||||||
|
import { User } from "discord.js";
|
||||||
|
import { UserDto } from "./model/userDto";
|
||||||
|
import { Config } from "../server/configuration";
|
||||||
|
import { UserApi } from "./api/userApi";
|
||||||
|
import { logger } from "../server/logger";
|
||||||
|
import { SystemApi } from "./api/systemApi";
|
||||||
|
|
||||||
|
export class JellyfinHandler {
|
||||||
|
|
||||||
|
private userApi: UserApi
|
||||||
|
private systemApi: SystemApi
|
||||||
|
private token: string
|
||||||
|
private authHeader: { headers: { 'X-MediaBrowser-Token': string } }
|
||||||
|
private config: Config
|
||||||
|
private serverName: string = "";
|
||||||
|
|
||||||
|
public async ServerName(): Promise<string> {
|
||||||
|
if (this.serverName === "") {
|
||||||
|
const info = await this.systemApi.getSystemInfo(this.authHeader)
|
||||||
|
this.serverName = info.body.serverName ?? this.config.bot.jellyfin_url
|
||||||
|
}
|
||||||
|
return this.serverName
|
||||||
|
}
|
||||||
|
constructor(_config: Config, _userApi?: UserApi, _systemApi?: SystemApi) {
|
||||||
|
this.config = _config
|
||||||
|
this.userApi = _userApi ?? new UserApi(this.config.bot.jellyfin_url)
|
||||||
|
this.systemApi = _systemApi ?? new SystemApi(this.config.bot.jellyfin_url)
|
||||||
|
this.token = this.config.bot.jellfin_token
|
||||||
|
this.authHeader = {
|
||||||
|
headers: {
|
||||||
|
"X-MediaBrowser-Token": this.token
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private generateJFUserName(discordUser: User): string {
|
||||||
|
return discordUser.username + discordUser.discriminator
|
||||||
|
}
|
||||||
|
|
||||||
|
public async addPermissionsToUserAccount(jfUserAccount: UserDto, guildId: string, requestId: string): Promise<UserDto> {
|
||||||
|
throw new Error("Method not implemented.");
|
||||||
|
}
|
||||||
|
public async createUserAccountForDiscordUser(discordUser: User, guildId: string, requestId: string): Promise<UserDto> {
|
||||||
|
const newUserName = this.generateJFUserName(discordUser)
|
||||||
|
logger.info(`New Username for ${discordUser.username}: ${newUserName}`, { guildId, requestId })
|
||||||
|
throw new Error("Method not implemented.");
|
||||||
|
}
|
||||||
|
public async isUserAlreadyPresent(discordUser: User, guildId: string, requestId: string): Promise<boolean> {
|
||||||
|
const jfUsernameFromDiscordUsername = this.generateJFUserName(discordUser)
|
||||||
|
const jfUsers = await this.getCurrentUsers(guildId, requestId)
|
||||||
|
const currentJfUserNames = jfUsers.map(x => x.name)
|
||||||
|
const presence = currentJfUserNames.find(x => x === jfUsernameFromDiscordUsername)
|
||||||
|
return presence !== undefined
|
||||||
|
}
|
||||||
|
public async getCurrentUsers(guildId: string, requestId: string): Promise<UserDto[]> {
|
||||||
|
try {
|
||||||
|
const result = await this.userApi.getUsers(undefined, undefined, this.authHeader)
|
||||||
|
return result.body
|
||||||
|
} catch (error) {
|
||||||
|
logger.error(`Could not fetch current users from jellyfin`, { guildId, requestId })
|
||||||
|
}
|
||||||
|
return []
|
||||||
|
}
|
||||||
|
}
|
Loading…
Reference in New Issue
Block a user