Jofthomas's picture
Jofthomas HF staff
Upload 4781 files
5c2ed06 verified
/**
* Youtube room chat-plugin.
* Supports adding channels and selecting a random channel.
* Also supports showing video data on request.
* Written by Mia, with some design concepts from bumbadadabum.
* @author mia-pi-git
*/
import { Utils, FS, Net } from '../../lib';
const ROOT = 'https://www.googleapis.com/youtube/v3/';
const STORAGE_PATH = 'config/chat-plugins/youtube.json';
const GROUPWATCH_ROOMS = [
'youtube', 'pokemongames', 'videogames', 'smashbros', 'pokemongo', 'hindi', 'franais', 'arcade',
];
export const videoDataCache: Map<string, VideoData> = Chat.oldPlugins.youtube?.videoDataCache || new Map();
export const searchDataCache: Map<string, string[]> = Chat.oldPlugins.youtube?.searchDataCache || new Map();
interface ChannelEntry {
name: string;
description: string;
url: string;
icon: string;
videos: number;
subs: number;
views: number;
username?: string;
category?: string;
}
export interface VideoData {
id: string;
title: string;
date: string;
description: string;
channelTitle: string;
channelUrl: string;
views: number;
thumbnail: string;
likes: number;
dislikes: number;
}
interface TwitchChannel {
status: string;
display_name: string;
name: string;
language: string;
created_at: string;
logo: string;
views: number;
followers: number;
video_banner: string;
url: string;
game: string;
description: string;
updated_at: string;
}
interface ChannelData {
channels: { [k: string]: ChannelEntry };
categories: string[];
intervalTime?: number;
}
function loadData() {
const raw: AnyObject = JSON.parse(FS(STORAGE_PATH).readIfExistsSync() || "{}");
if (!(raw.channels && raw.categories)) { // hasn't been converted to new format
const data: Partial<ChannelData> = {};
data.channels = raw;
data.categories = [];
// re-save into new format
FS(STORAGE_PATH).writeUpdate(() => JSON.stringify(data));
return data as ChannelData;
}
return raw as ChannelData;
}
const channelData: ChannelData = loadData();
export class YoutubeInterface {
interval: NodeJS.Timeout | null;
intervalTime: number;
data: ChannelData;
linkRegex = /^(https?:\/\/)?(www\.)?(youtube\.com|youtu\.be)(\/|$)/i;
constructor(data?: ChannelData) {
this.data = data ? data : { categories: [], channels: {} };
this.interval = null;
this.intervalTime = 0;
if (data?.intervalTime) {
this.runInterval(`${data.intervalTime}`);
}
}
async getChannelData(link: string, username?: string) {
if (!Config.youtubeKey) {
throw new Chat.ErrorMessage(`This server does not support YouTube commands. If you're the owner, you can enable them by setting up Config.youtubekey.`);
}
const id = this.getId(link);
const raw = await Net(`${ROOT}channels`).get({
query: { part: 'snippet,statistics', id, key: Config.youtubeKey },
});
const res = JSON.parse(raw);
if (!res?.items || res.items.length < 1) {
throw new Chat.ErrorMessage(`Channel not found.`);
}
const data = res.items[0];
const cache: ChannelEntry = {
name: data.snippet.title,
description: data.snippet.description,
url: data.snippet.customUrl,
icon: data.snippet.thumbnails.medium.url,
videos: Number(data.statistics.videoCount),
subs: Number(data.statistics.subscriberCount),
views: Number(data.statistics.viewCount),
username,
};
this.data.channels[id] = { ...cache };
this.save();
return cache;
}
async generateChannelDisplay(link: string) {
const id = this.getId(link);
const { name, description, icon, videos, subs, views, username } = await this.get(id);
// credits bumbadadabum for most of the html
let buf = `<div class="infobox"><table style="margin:0px;"><tr>`;
buf += `<td style="margin:5px;padding:5px;min-width:175px;max-width:160px;text-align:center;border-bottom:0px;">`;
buf += `<div style="padding:5px;background:white;border:1px solid black;margin:auto;max-width:100px;max-height:100px;">`;
buf += `<a href="${ROOT}channel/${id}"><img src="${icon}" width=100px height=100px/></a>`;
buf += `</div><p style="margin:5px 0px 4px 0px;word-wrap:break-word;">`;
buf += `<a style="font-weight:bold;color:#c70000;font-size:12pt;" href="https://www.youtube.com/channel/${id}">${name}</a>`;
buf += `</p></td><td style="padding: 0px 25px;font-size:10pt;background:rgb(220,20,60);width:100%;border-bottom:0px;vertical-align:top;">`;
buf += `<p style="padding: 5px;border-radius:8px;color:white;font-weight:bold;text-align:center;">`;
buf += `${videos} videos | ${subs} subscribers | ${views} video views</p>`;
buf += `<p style="margin-left: 5px; font-size:9pt;color:white;">`;
buf += `${description.slice(0, 400).replace(/\n/g, ' ')}${description.length > 400 ? '(...)' : ''}</p>`;
if (username) {
buf += `<p style="text-align:left;font-style:italic;color:white;">PS username: ${username}</p></td></tr></table></div>`;
} else {
buf += '</td></tr></table></div>';
}
return buf;
}
randChannel(cat?: string) {
let channels = Object.keys(this.data.channels);
if (channels.length < 1) {
throw new Chat.ErrorMessage(`There are no channels in the database.`);
}
if (cat) {
cat = toID(cat);
const categoryIDs = this.data.categories.map(toID);
if (!categoryIDs.includes(cat as ID)) {
throw new Chat.ErrorMessage(`Invalid category.`);
}
channels = channels.filter(id => {
const channel = this.data.channels[id];
return channel.category && toID(channel.category) === cat;
});
}
const id = Utils.shuffle(channels)[0];
return this.generateChannelDisplay(id);
}
get(id: string, username?: string): Promise<ChannelEntry> {
if (!(id in this.data.channels)) return this.getChannelData(id, username);
return Promise.resolve({ ...this.data.channels[id] });
}
async getVideoData(id: string): Promise<VideoData | null> {
const cached = videoDataCache.get(id);
if (cached) return cached;
let raw;
try {
raw = await Net(`${ROOT}videos`).get({
query: { part: 'snippet,statistics', id, key: Config.youtubeKey },
});
} catch (e: any) {
throw new Chat.ErrorMessage(`Failed to retrieve video data: ${e.message}.`);
}
const res = JSON.parse(raw);
if (!res?.items || res.items.length < 1) return null;
const video = res.items[0];
const data: VideoData = {
title: video.snippet.title,
id,
date: new Date(video.snippet.publishedAt).toString(),
description: video.snippet.description,
channelTitle: video.snippet.channelTitle,
channelUrl: video.snippet.channelId,
views: video.statistics.viewCount,
thumbnail: video.snippet.thumbnails.default.url,
likes: video.statistics.likeCount,
dislikes: video.statistics.dislikeCount,
};
videoDataCache.set(id, data);
return data;
}
channelSearch(search: string) {
let channel;
if (this.data.channels[search]) {
channel = search;
} else {
for (const id of Object.keys(this.data.channels)) {
const name = toID(this.data.channels[id].name);
const username = this.data.channels[id].username;
if (name === toID(search) || username && toID(username) === toID(search)) {
channel = id;
break; // don't iterate through everything once a match is found
}
}
}
return channel;
}
getId(link: string) {
let id = '';
if (!link) throw new Chat.ErrorMessage('You must provide a YouTube link.');
if (this.data.channels[link]) return link;
if (!link.includes('channel/')) {
if (link.includes('youtube')) {
id = link.split('v=')[1] || '';
} else if (link.includes('youtu.be')) {
id = link.split('/')[3] || '';
} else {
throw new Chat.ErrorMessage('Invalid YouTube channel link.');
}
} else {
id = link.split('channel/')[1] || '';
}
if (id.includes('&')) id = id.split('&')[0];
if (id.includes('?')) id = id.split('?')[0];
return id;
}
async generateVideoDisplay(link: string, fullInfo = false) {
if (!Config.youtubeKey) {
throw new Chat.ErrorMessage(`This server does not support YouTube commands. If you're the owner, you can enable them by setting up Config.youtubekey.`);
}
const id = this.getId(link);
const info = await this.getVideoData(id);
if (!info) throw new Chat.ErrorMessage(`Video not found.`);
if (!fullInfo) {
let buf = `<b>${info.title}</b> `;
buf += `(<a class="subtle" href="https://youtube.com/channel/${info.channelUrl}">${info.channelTitle}</a>)<br />`;
buf += `<youtube src="https://www.youtube.com/embed/${id}" />`;
return buf;
}
let buf = `<table style="margin:0px;"><tr>`;
buf += `<td style="margin:5px;padding:5px;min-width:175px;max-width:160px;text-align:center;border-bottom:0px;">`;
buf += `<div style="padding:5px;background:#b0b0b0;border:1px solid black;margin:auto;max-width:100px;max-height:100px;">`;
buf += `<a href="${ROOT}channel/${id}"><img src="${info.thumbnail}" width=100px height=100px/></a>`;
buf += `</div><p style="margin:5px 0px 4px 0px;word-wrap:break-word;">`;
buf += `<a style="font-weight:bold;color:#c70000;font-size:12pt;" href="https://www.youtube.com/watch?v=${id}">${info.title}</a>`;
buf += `</p></td><td style="padding: 0px 25px;font-size:10pt;max-width:100px;background:`;
buf += `#white;width:100%;border-bottom:0px;vertical-align:top;">`;
buf += `<p style="background: #e22828; padding: 5px;border-radius:8px;color:white;font-weight:bold;text-align:center;">`;
buf += `${info.likes} likes | ${info.dislikes} dislikes | ${info.views} video views<br><br>`;
buf += `<small>Published on ${info.date} | ID: ${id}</small><br>Uploaded by: ${info.channelTitle}</p>`;
buf += `<br><details><summary>Video Description</p></summary>`;
buf += `<p style="background: #e22828;max-width:500px;padding: 5px;border-radius:8px;color:white;font-weight:bold;text-align:center;">`;
buf += `<i>${info.description.slice(0, 400).replace(/\n/g, ' ')}${info.description.length > 400 ? '(...)' : ''}</p><i></details></td>`;
return buf;
}
save() {
return FS(STORAGE_PATH).writeUpdate(() => JSON.stringify(this.data));
}
async searchVideo(name: string, limit?: number): Promise<string[] | undefined> {
const cached = searchDataCache.get(toID(name));
if (cached) {
return cached.slice(0, limit);
}
const raw = await Net(`${ROOT}search`).get({
query: {
part: 'snippet', q: name,
key: Config.youtubeKey, order: 'relevance',
},
});
const result = JSON.parse(raw);
const resultArray = result.items?.map((item: AnyObject) => item?.id?.videoId).filter(Boolean);
searchDataCache.set(toID(name), resultArray);
return resultArray.slice(0, limit);
}
async searchChannel(name: string, limit = 10): Promise<string[] | undefined> {
const raw = await Net(`${ROOT}search`).get({
query: {
part: 'snippet', q: name, type: 'channel',
key: Config.youtubeKey, order: 'relevance', maxResults: limit,
},
});
const result = JSON.parse(raw);
return result?.items.map((item: AnyObject) => item?.snippet?.channelId);
}
runInterval(time: string) {
let interval = Number(time);
if (interval < 10) throw new Chat.ErrorMessage(`${interval} is too low - set it above 10 minutes.`);
this.intervalTime = interval;
this.data.intervalTime = interval;
interval = interval * 60 * 1000;
if (this.interval) clearInterval(this.interval);
this.interval = setInterval(() => {
void (async () => {
const room = Rooms.get('youtube');
if (!room) return; // do nothing if the room doesn't exist anymore
const res = await YouTube.randChannel();
room.add(`|html|${res}`).update();
})();
}, interval);
return this.interval;
}
async createGroupWatch(url: string, baseRoom: Room, title: string) {
const videoInfo = await this.getGroupwatchData(url);
const num = baseRoom.nextGameNumber();
baseRoom.saveSettings();
return new GroupWatch(baseRoom, num, url, title, videoInfo);
}
async getGroupwatchData(url: string) {
if (!Chat.isLink(url)) {
throw new Chat.ErrorMessage("Invalid URL: " + url);
}
const urlData = new URL(url);
const host = urlData.hostname;
let videoInfo: GroupwatchData;
if (['youtu.be', 'www.youtube.com'].includes(host)) {
const id = this.getId(url);
const data = await this.getVideoData(id);
if (!data) throw new Chat.ErrorMessage(`Video not found.`);
videoInfo = Object.assign(data, { groupwatchType: 'youtube' }) as GroupwatchData;
} else if (host === 'www.twitch.tv') {
const data = await Twitch.getChannel(urlData.pathname.slice(1));
if (!data) throw new Chat.ErrorMessage(`Channel not found`);
videoInfo = Object.assign(data, { groupwatchType: 'twitch' }) as GroupwatchData;
} else {
throw new Chat.ErrorMessage(`Invalid URL: must be either a Youtube or Twitch link.`);
}
return videoInfo;
}
}
export const Twitch = new class {
linkRegex = /(https?:\/\/)?twitch.tv\/([A-Za-z0-9]+)/i;
async getChannel(channel: string): Promise<TwitchChannel | undefined> {
if (!Config.twitchKey || typeof Config.twitchKey !== 'object') {
throw new Chat.ErrorMessage(`Twitch is not enabled.`);
}
channel = toID(channel);
let res;
try {
res = await Net(`https://api.twitch.tv/helix/search/channels`).get({
headers: {
'Authorization': `Bearer ${Config.twitchKey.key}`,
'Client-Id': Config.twitchKey.id,
'Content-Type': 'application/json',
'Accept': "application/vnd.twitchtv.v5+json",
},
query: { query: channel },
});
} catch (e: any) {
throw new Chat.ErrorMessage(`Error retrieving twitch channel: ${e.message}`);
}
const data = JSON.parse(res);
Utils.sortBy(data.channels as AnyObject[], c => -c.followers);
return data?.channels?.[0] as TwitchChannel | undefined;
}
visualizeChannel(info: TwitchChannel) {
let buf = `<div class="infobox"><table style="margin:0px;"><tr>`;
buf += `<td style="margin:5px;padding:5px;min-width:175px;max-width:160px;text-align:center;border-bottom:0px;">`;
buf += `<div style="padding:5px;background:white;border:1px solid black;margin:auto;max-width:100px;max-height:100px;">`;
buf += `<a href="${info.url}"><img src="${info.logo}" width=100px height=100px/></a>`;
buf += `</div><p style="margin:5px 0px 4px 0px;word-wrap:break-word;">`;
buf += `<a style="font-weight:bold;color:#6441a5;font-size:12pt;" href="${info.logo}">${info.display_name}</a>`;
buf += `</p></td><td style="padding: 0px 25px;font-size:10pt;background:rgb(100, 65, 164);width:100%;border-bottom:0px;vertical-align:top;">`;
buf += `<p style="padding: 5px;border-radius:8px;color:white;font-size:15px;font-weight:bold;text-align:center;">`;
const created = new Date(info.created_at);
buf += `${info.followers} subscribers | ${info.views} stream views | created ${Chat.toTimestamp(created).split(' ')[0]}</p>`;
buf += `<p style="color:white;font-size:10px">Last seen playing ${info.game} (Status: ${info.status})</p>`;
buf += `<hr /><p style="margin-left: 5px; font-size:9pt;color:white;">`;
buf += `${info.description.slice(0, 400).replace(/\n/g, ' ')}${info.description.length > 400 ? '...' : ''}</p>`;
buf += '</td></tr></table></div>';
return buf;
}
};
type GroupwatchData = VideoData & { groupwatchType: 'youtube' } | TwitchChannel & { groupwatchType: 'twitch' };
export class GroupWatch extends Rooms.SimpleRoomGame {
override readonly gameid = 'groupwatch' as ID;
url: string;
info: GroupwatchData;
started: number | null = null;
id: string;
static groupwatches = new Map<string, GroupWatch>();
constructor(room: Room, num: number, url: string, title: string, videoInfo: GroupwatchData) {
super(room);
this.title = title;
this.id = `${room.roomid}-${num}`;
GroupWatch.groupwatches.set(this.id, this);
this.url = url;
this.info = videoInfo;
}
onJoin(user: User) {
const hints = this.hints();
for (const hint of hints) {
user.sendTo(this.room.roomid, `|html|${hint}`);
}
}
start() {
if (this.started) throw new Chat.ErrorMessage(`We've already started.`);
this.started = Date.now();
this.update();
}
hints() {
const title = this.info.groupwatchType === 'youtube' ? this.info.title : this.info.display_name;
const hints = [
`To watch, all you need to do is click play on the video once staff have started it!`,
`We are currently watching: <a href="${this.url}">${title}</a>`,
];
if (this.started && this.info.groupwatchType === 'youtube') {
const diff = Date.now() - this.started;
hints.push(`Video is currently at ${Chat.toDurationString(diff)} (${Math.floor(diff / 1000)} seconds)`);
}
return hints;
}
getStatsDisplay() {
if (this.info.groupwatchType === 'twitch') {
let buf = `<p style="background: #6441a5; padding: 5px;border-radius:8px;color:white;font-weight:bold;text-align:center;">`;
buf += `<strong>Watching <a href="${this.info.url}" class="subtle">${this.info.display_name}</strong><br />`;
buf += `${Chat.count(Object.keys(this.room.users).length, 'users')} watching<br />`;
buf += `<strong>Playing: ${this.info.game}`;
return buf;
}
let controlsHTML = `<h3>${this.info.title}</h3>`;
controlsHTML += `<div class="infobox"><b>Channel:</b> `;
controlsHTML += `<a href="https://www.youtube.com/channel/${this.info.channelUrl}">${this.info.channelTitle}</a><br />`;
controlsHTML += `<b>Likes:</b> ${this.info.likes} | <b>Dislikes:</b> ${this.info.dislikes}<br />`;
controlsHTML += `<b>Uploaded:</b> <time>${new Date(this.info.date).toISOString()}</time><br />`;
controlsHTML += `<details><summary>Description</summary>${this.info.description.replace(/\n/ig, '<br />')}</details>`;
controlsHTML += `</div>`;
return controlsHTML;
}
getVideoDisplay() {
if (this.info.groupwatchType === 'twitch') {
let buf = `<p style="background: #6441a5; padding: 5px;border-radius:8px;color:white;font-weight:bold;text-align:center;">`;
buf += `<twitch src="${this.info.url}" width="600" height="330" />`;
return buf;
}
let buf = `<p style="background: #e22828; padding: 5px;border-radius:8px;color:white;font-weight:bold;text-align:center;">`;
buf += `<br /><br /><b>${this.info.title}</b><br />`;
const id = YouTube.getId(this.url);
const url = `https://youtube.com/watch?v=${id}`;
let addendum = '';
if (this.started) {
const diff = Date.now() - this.started;
addendum = `&start=${Math.floor(diff / 1000)}`;
}
buf += `<youtube src="${url}${addendum}"></youtube>`;
buf += `<br />`.repeat(4);
buf += `</p>`;
return buf;
}
display() {
return (
Utils.html`<center><div class="pad"><strong>${this.room.title} Groupwatch - ${this.title}</strong><br /><br />` +
`<p>${this.started ? this.getVideoDisplay() : ""}</p><hr />` +
`<p>${this.started ? this.getStatsDisplay() : "<i>Waiting to start the video...</i>"}</p>` +
`<p>${this.hints().join('<br />')}</p>`
);
}
update() {
for (const user of Object.values(this.room.users)) {
for (const conn of user.connections) {
if (conn.openPages?.has(`groupwatch-${this.id}`)) {
void Chat.parse(`/j view-groupwatch-${this.id}`, this.room, user, conn);
}
}
}
}
async changeVideo(url: string) {
const info = await YouTube.getGroupwatchData(url);
if (!info) throw new Chat.ErrorMessage(`Could not retrieve data for URL ${url}`);
this.url = url;
this.started = Date.now();
this.info = info;
this.update();
}
destroy() {
GroupWatch.groupwatches.delete(this.id);
this.room.game = null;
this.room = null!;
}
}
export const YouTube = new YoutubeInterface(channelData);
export function destroy() {
if (YouTube.interval) clearInterval(YouTube.interval);
}
export const commands: Chat.ChatCommands = {
async randchannel(target, room, user) {
room = this.requireRoom('youtube' as RoomID);
if (Object.keys(YouTube.data.channels).length < 1) return this.errorReply(`No channels in the database.`);
target = toID(target);
this.runBroadcast();
const data = await YouTube.randChannel(target);
return this.sendReply(`|html|${data}`);
},
randchannelhelp: [`/randchannel - View data of a random channel from the YouTube database.`],
yt: 'youtube',
youtube: {
async addchannel(target, room, user) {
room = this.requireRoom('youtube' as RoomID);
this.checkCan('mute', null, room);
const [id, name] = target.split(',').map(t => t.trim());
if (!id) return this.errorReply('Specify a channel ID.');
await YouTube.getChannelData(id, name);
this.modlog('ADDCHANNEL', null, `${id} ${name ? `username: ${name}` : ''}`);
return this.privateModAction(
`${user.name} added channel with id ${id} ${name ? `and username (${name}) ` : ''} to the random channel pool.`
);
},
addchannelhelp: [`/addchannel - Add channel data to the YouTube database. Requires: % @ #`],
removechannel(target, room, user) {
room = this.requireRoom('youtube' as RoomID);
this.checkCan('mute', null, room);
const id = YouTube.channelSearch(target);
if (!id) return this.errorReply(`Channel with ID or name ${target} not found.`);
delete YouTube.data.channels[id];
YouTube.save();
this.privateModAction(`${user.name} deleted channel with ID or name ${target}.`);
return this.modlog(`REMOVECHANNEL`, null, id);
},
removechannelhelp: [`/youtube removechannel - Delete channel data from the YouTube database. Requires: % @ #`],
async channel(target, room, user) {
room = this.requireRoom('youtube' as RoomID);
const channel = YouTube.channelSearch(target);
if (!channel) return this.errorReply(`No channels with ID or name ${target} found.`);
const data = await YouTube.generateChannelDisplay(channel);
this.runBroadcast();
return this.sendReply(`|html|${data}`);
},
channelhelp: [
'/youtube channel - View the data of a specified channel. Can be either channel ID or channel name.',
],
async video(target, room, user) {
room = this.requireRoom('youtube' as RoomID);
this.checkCan('mute', null, room);
const buffer = await YouTube.generateVideoDisplay(target, true);
this.runBroadcast();
this.sendReplyBox(buffer);
},
channels(target, room, user) {
target = toID(target);
return this.parse(`/j view-channels${target ? `-${target}` : ''}`);
},
help(target, room, user) {
return this.parse('/help youtube');
},
categories() {
return this.parse(`/j view-channels-categories`);
},
update(target, room, user) {
room = this.requireRoom('youtube' as RoomID);
this.checkCan('mute', null, room);
const [channel, name] = target.split(',');
const id = YouTube.channelSearch(channel);
if (!id) return this.errorReply(`Channel ${channel} is not in the database.`);
YouTube.data.channels[id].username = name;
this.modlog(`UPDATECHANNEL`, null, name);
this.privateModAction(`${user.name} updated channel ${id}'s username to ${name}.`);
YouTube.save();
},
interval: 'repeat',
repeat(target, room, user) {
room = this.requireRoom('youtube' as RoomID);
this.checkCan('declare', null, room);
if (!target) {
if (!YouTube.interval) return this.errorReply(`The YouTube plugin is not currently running an interval.`);
return this.sendReply(`Interval is currently set to ${Chat.toDurationString(YouTube.intervalTime * 60 * 1000)}.`);
}
if (this.meansNo(target)) {
if (!YouTube.interval) return this.errorReply(`The interval is not currently running`);
clearInterval(YouTube.interval);
delete YouTube.data.intervalTime;
YouTube.save();
this.privateModAction(`${user.name} turned off the YouTube interval`);
return this.modlog(`YOUTUBE INTERVAL`, null, 'OFF');
}
if (Object.keys(channelData).length < 1) return this.errorReply(`No channels in the database.`);
if (isNaN(parseInt(target))) return this.errorReply(`Specify a number (in minutes) for the interval.`);
YouTube.runInterval(target);
YouTube.save();
this.privateModAction(`${user.name} set a randchannel interval to ${target} minutes`);
return this.modlog(`CHANNELINTERVAL`, null, `${target} minutes`);
},
addcategory(target, room, user) {
room = this.requireRoom('youtube' as RoomID);
this.checkCan('mute', null, room);
const categoryID = toID(target);
if (!categoryID) return this.parse(`/help youtube`);
if (YouTube.data.categories.map(toID).includes(categoryID)) {
return this.errorReply(`This category is already added. To change it, remove it and re-add it.`);
}
YouTube.data.categories.push(target);
this.modlog(`YOUTUBE ADDCATEGORY`, null, target);
this.privateModAction(`${user.name} added category '${target}' to the categories list.`);
YouTube.save();
},
removecategory(target, room, user) {
room = this.requireRoom('youtube' as RoomID);
this.checkCan('mute', null, room);
const categoryID = toID(target);
if (!categoryID) return this.parse(`/help youtube`);
const index = YouTube.data.categories.indexOf(target);
if (index < 0) {
return this.errorReply(`${target} is not a valid category.`);
}
for (const id in YouTube.data.channels) {
const channel = YouTube.data.channels[id];
if (channel.category === target) delete YouTube.data.channels[id].category;
}
YouTube.save();
this.privateModAction(`${user.name} removed the category '${target}' from the category list.`);
this.modlog(`YOUTUBE REMOVECATEGORY`, null, target);
},
setcategory(target, room, user) {
room = this.requireRoom('youtube' as RoomID);
this.checkCan('mute', null, room);
target = target.trim();
const [category, id] = Utils.splitFirst(target, ',').map(item => item.trim());
if (!target || !category || !id) {
return this.parse('/help youtube');
}
if (!YouTube.data.categories.includes(category)) {
return this.errorReply(`Invalid category.`);
}
const name = YouTube.channelSearch(id);
if (!name) return this.errorReply(`Invalid channel.`);
const channel = YouTube.data.channels[name];
YouTube.data.channels[name].category = category;
YouTube.save();
this.modlog(`YOUTUBE SETCATEGORY`, null, `${id}: to category ${category}`);
this.privateModAction(`${user.name} set the channel ${channel.name}'s category to '${category}'.`);
},
decategorize(target, room, user) {
room = this.requireRoom('youtube' as RoomID);
this.checkCan('mute', null, room);
target = target.trim();
if (!target) {
return this.parse('/help youtube');
}
const name = YouTube.channelSearch(target);
if (!name) return this.errorReply(`Invalid channel.`);
const channel = YouTube.data.channels[name];
const category = channel.category;
if (!category) return this.errorReply(`That channel does not have a category.`);
delete channel.category;
YouTube.save();
this.modlog(`YOUTUBE DECATEGORIZE`, null, target);
this.privateModAction(`${user.name} removed the channel ${channel.name} from the category ${category}.`);
},
},
youtubehelp: [
`YouTube commands:`,
`/randchannel [optional category]- View data of a random channel from the YouTube database.` +
` If a category is given, the random channel will be in the given category.`,
`/youtube addchannel [channel] - Add channel data to the YouTube database. Requires: % @ #`,
`/youtube removechannel [channel]- Delete channel data from the YouTube database. Requires: % @ #`,
`/youtube channel [channel] - View the data of a specified channel. Can be either channel ID or channel name.`,
`/youtube video [video] - View data of a specified video. Can be either channel ID or channel name.`,
`/youtube update [channel], [name] - sets a channel's PS username to [name]. Requires: % @ #`,
`/youtube repeat [time] - Sets an interval for [time] minutes, showing a random channel each time. Requires: # ~`,
`/youtube addcategory [name] - Adds the [category] to the channel category list. Requires: @ # ~`,
`/youtube removecategory [name] - Removes the [category] from the channel category list. Requires: @ # ~`,
`/youtube setcategory [category], [channel name] - Sets the category for [channel] to [category]. Requires: @ # ~`,
`/youtube decategorize [channel name] - Removes the category for the [channel], if there is one. Requires: @ # ~`,
`/youtube categores - View all channels sorted by category.`,
],
groupwatch: {
async create(target, room, user) {
room = this.requireRoom();
if (!GROUPWATCH_ROOMS.includes(room.roomid)) {
return this.errorReply(`This room is not allowed to use the groupwatch function.`);
}
this.checkCan('mute', null, room);
const [url, title] = Utils.splitFirst(target, ',').map(p => p.trim());
if (!url || !title) return this.errorReply(`You must specify a video to watch and a title for the group watch.`);
const game = await YouTube.createGroupWatch(url, room, title);
this.modlog(`YOUTUBE GROUPWATCH`, null, `${url} (${title})`);
room.add(
`|uhtml|${game.id}|` +
`<button class="button" name="send" value="/j view-groupwatch-${game.id}">Join the ongoing group watch!</button>`
);
room.send(`|tempnotify|youtube|New groupwatch - ${title}!`);
this.update();
},
end(target, room, user) {
room = this.requireRoom();
this.checkCan('mute', null, room);
const game = this.requireGame(GroupWatch);
this.modlog(`GROUPWATCH END`);
this.add(`|uhtmlchange|${game.id}|`);
game.destroy();
},
start(target, room, user) {
room = this.requireRoom();
this.checkCan('mute', null, room);
const game = this.requireGame(GroupWatch);
game.start();
game.update();
},
async edit(target, room, user) {
room = this.requireRoom();
this.checkCan('mute', null, room);
const game = this.requireGame(GroupWatch);
await game.changeVideo(target);
},
list() {
let buf = `<strong>Ongoing groupwatches:</strong><br />`;
for (const curRoom of Rooms.rooms.values()) {
if (!curRoom.getGame(GroupWatch)) continue;
buf += `<button class="button" name="send" value="/j ${curRoom.roomid}">${curRoom.title}</button>`;
}
this.runBroadcast();
this.sendReplyBox(buf);
},
},
groupwatchhelp: [
`/groupwatch create [link],[title] - create a groupwatch for the given Youtube or Twitch [link] with the [title]. Requires: % @ ~ #`,
`/groupwatch end - End the current room's groupwatch, if one exists. Requires: % @ ~ #`,
`/groupwatch start - Begin playback for the current groupwatch. Requires: % @ ~ #`,
`/groupwatch edit [link] - Change the current groupwatch, if one exists, to be viewing the given [link]. Requires: % @ ~ #`,
],
twitch: {
async channel(target, room, user) {
room = this.requireRoom('youtube' as RoomID);
if (!Config.twitchKey) return this.errorReply(`Twitch is not configured`);
const data = await Twitch.getChannel(target);
if (!data) return this.errorReply(`Channel not found`);
const html = Twitch.visualizeChannel(data);
this.runBroadcast();
return this.sendReplyBox(html);
},
},
};
export const pages: Chat.PageTable = {
async channels(args, user) {
const [type] = args;
if (!Config.youtubeKey) return `<h2>Youtube is not configured.</h2>`;
const titles: { [k: string]: string } = {
all: 'All channels',
categories: 'by category',
};
const title = titles[type] || 'Usernames only';
this.title = `[Channels] ${title}`;
let buffer = `<div class="pad"><h4>Channels in the YouTube database: (${title})`;
buffer += ` <button class="button" name="send" value="/join view-channels-${type}" style="float: right">Refresh</button>`;
buffer += `</h4><hr />`;
switch (toID(type)) {
case 'categories':
if (!YouTube.data.categories.length) {
return this.errorReply(`There are currently no categories in the Youtube channel database.`);
}
const sorted: { [k: string]: string[] } = {};
const channels = YouTube.data.channels;
for (const [id, channel] of Object.entries(channels)) {
const category = channel.category || "No category";
if (!sorted[category]) {
sorted[category] = [];
}
sorted[category].push(id);
}
for (const cat in sorted) {
buffer += `<h3>${cat}:</h3>`;
for (const id of sorted[cat]) {
const channel = channels[id];
buffer += `<details><summary>${channel.name}</summary>`;
buffer += await YouTube.generateChannelDisplay(id);
buffer += `</details><br />`;
}
}
break;
default:
for (const id of Utils.shuffle(Object.keys(YouTube.data.channels))) {
const { name, username } = await YouTube.get(id);
if (toID(type) !== 'all' && !username) continue;
buffer += `<details><summary>${name}`;
buffer += `<small><i> (Channel ID: ${id})</i></small>`;
if (username) buffer += ` <small>(PS name: ${username})</small>`;
buffer += `</summary>`;
buffer += await YouTube.generateChannelDisplay(id);
buffer += `</details><hr/ >`;
}
break;
}
buffer += `</div>`;
return buffer;
},
groupwatch(query, user, connection) {
if (!user.named) return Rooms.RETRY_AFTER_LOGIN;
const [roomid, num] = query;
const watch = GroupWatch.groupwatches.get(`${roomid}-${num}`);
if (!watch) return this.errorReply(`Groupwatch ${roomid}-${num} not found.`);
this.title = `[Groupwatch] ${watch.title}`;
return watch.display();
},
};