urlreply format

This commit is contained in:
Evert Prants 2023-08-04 17:37:51 +03:00
parent 17b80e3acb
commit 04e90fc084
Signed by: evert
GPG Key ID: 1688DA83D222D0B5
3 changed files with 181 additions and 71 deletions

View File

@ -39,7 +39,7 @@
}, },
{ {
"name": "urlreply", "name": "urlreply",
"version": "1.0.9" "version": "1.1.0"
}, },
{ {
"name": "utility", "name": "utility",

View File

@ -2,7 +2,7 @@
"main": "plugin.js", "main": "plugin.js",
"name": "urlreply", "name": "urlreply",
"description": "Fetch titles from web pages, specifically made for IRC", "description": "Fetch titles from web pages, specifically made for IRC",
"version": "1.0.9", "version": "1.1.0",
"tags": ["irc"], "tags": ["irc"],
"dependencies": [], "dependencies": [],
"npmDependencies": ["cheerio@^1.0.0-rc.10"] "npmDependencies": ["cheerio@^1.0.0-rc.10"]

View File

@ -1,10 +1,10 @@
import { httpGET, parseTimeToSeconds, toHHMMSS } from '@squeebot/core/lib/common';
import { logger } from '@squeebot/core/lib/core';
import { import {
Plugin, httpGET,
Configurable, parseTimeToSeconds,
EventListener, toHHMMSS,
} from '@squeebot/core/lib/plugin'; } from '@squeebot/core/lib/common';
import { logger } from '@squeebot/core/lib/core';
import { Plugin, Configurable, EventListener } from '@squeebot/core/lib/plugin';
import { IMessage } from '@squeebot/core/lib/types'; import { IMessage } from '@squeebot/core/lib/types';
import cheerio from 'cheerio'; import cheerio from 'cheerio';
@ -17,7 +17,7 @@ interface URLHandler {
action: ActionFn; action: ActionFn;
} }
let urlHandlers: {[key: string]: URLHandler} = {}; let urlHandlers: { [key: string]: URLHandler } = {};
let htmlHandlers: any[] = []; let htmlHandlers: any[] = [];
const urlRegex = /(((ftp|https?):\/\/)[-\w@:%_+.~#?,&//=]+)/g; const urlRegex = /(((ftp|https?):\/\/)[-\w@:%_+.~#?,&//=]+)/g;
@ -41,7 +41,7 @@ function ytDuration(time: string): string {
let result = 0; let result = 0;
const d: {[key: string]: number} = { H: 3600, M: 60, S: 1 }; const d: { [key: string]: number } = { H: 3600, M: 60, S: 1 };
let num; let num;
let type; let type;
@ -56,7 +56,7 @@ function ytDuration(time: string): string {
} }
async function dailymotionFromId(id: string, msg: IMessage): Promise<boolean> { async function dailymotionFromId(id: string, msg: IMessage): Promise<boolean> {
const url = 'https://api.dailymotion.com/video/' + id + '?fields=id,title,owner,owner.screenname,duration,views_total'; const url = `https://api.dailymotion.com/video/${id}?fields=id,title,owner,owner.screenname,duration,views_total`;
let data = await httpGET(url); let data = await httpGET(url);
@ -70,8 +70,16 @@ async function dailymotionFromId(id: string, msg: IMessage): Promise<boolean> {
keys.push(['field', 'Dailymotion', { type: 'title' }]); keys.push(['field', 'Dailymotion', { type: 'title' }]);
keys.push(['field', data.title, { type: 'description' }]); keys.push(['field', data.title, { type: 'description' }]);
keys.push(['field', data.views_total.toString(), { label: 'Views', type: 'metric' }]); keys.push([
keys.push(['field', data.duration.toString(), { label: 'Duration', type: 'duration' }]); 'field',
data.views_total.toString(),
{ label: 'Views', type: 'metric' },
]);
keys.push([
'field',
data.duration.toString(),
{ label: 'Duration', type: 'duration' },
]);
keys.push(['field', data['owner.screenname'], { label: ['By'] }]); keys.push(['field', data['owner.screenname'], { label: ['By'] }]);
msg.resolve(keys); msg.resolve(keys);
@ -79,13 +87,19 @@ async function dailymotionFromId(id: string, msg: IMessage): Promise<boolean> {
return true; return true;
} }
async function getSoundcloudFromUrl(plugin: URLReplyPlugin, url: string, msg: IMessage): Promise<boolean> { async function getSoundcloudFromUrl(
plugin: URLReplyPlugin,
url: string,
msg: IMessage
): Promise<boolean> {
const token = plugin.config.get('tokens.soundcloud'); const token = plugin.config.get('tokens.soundcloud');
if (!token) { if (!token) {
return false; return false;
} }
const sAPI = 'https://api.soundcloud.com/resolve?url=' + encodeURIComponent(url) + '&client_id=' + token; const sAPI = `https://api.soundcloud.com/resolve?url=${encodeURIComponent(
url
)}&client_id=${token}`;
let data = await httpGET(sAPI); let data = await httpGET(sAPI);
@ -100,17 +114,37 @@ async function getSoundcloudFromUrl(plugin: URLReplyPlugin, url: string, msg: IM
} }
const keys = []; const keys = [];
keys.push(['field', 'SoundCloud' + ((data.kind === 'playlist') ? ' Playlist' : ''), { type: 'title', color: 'gold' }]); keys.push([
'field',
'SoundCloud' + (data.kind === 'playlist' ? ' Playlist' : ''),
{ type: 'title', color: 'gold' },
]);
keys.push(['field', data.title, { type: 'description' }]); keys.push(['field', data.title, { type: 'description' }]);
if (data.kind === 'track') { if (data.kind === 'track') {
keys.push(['field', data.playback_count.toString(), { color: 'green', label: ['▶', 'Plays'], type: 'metric' }]); keys.push([
keys.push(['field', data.favoritings_count.toString(), { color: 'red', label: ['♥', 'Favourites'], type: 'metric' }]); 'field',
data.playback_count.toString(),
{ color: 'green', label: ['▶', 'Plays'], type: 'metric' },
]);
keys.push([
'field',
data.favoritings_count.toString(),
{ color: 'red', label: ['♥', 'Favourites'], type: 'metric' },
]);
} else { } else {
keys.push(['field', data.track_count.toString(), { label: 'Tracks', type: 'metric' }]); keys.push([
'field',
data.track_count.toString(),
{ label: 'Tracks', type: 'metric' },
]);
} }
keys.push(['field', Math.floor(data.duration / 1000).toString(), { label: 'Duration', type: 'duration' }]); keys.push([
'field',
Math.floor(data.duration / 1000).toString(),
{ label: 'Duration', type: 'duration' },
]);
keys.push(['field', data.user.username, { label: ['By'] }]); keys.push(['field', data.user.username, { label: ['By'] }]);
msg.resolve(keys); msg.resolve(keys);
@ -122,7 +156,8 @@ async function getYoutubeFromVideo(
plugin: URLReplyPlugin, plugin: URLReplyPlugin,
id: string, id: string,
full: urllib.URL, full: urllib.URL,
msg: IMessage): Promise<boolean> { msg: IMessage
): Promise<boolean> {
const gtoken = plugin.config.get('tokens.google'); const gtoken = plugin.config.get('tokens.google');
const dislikeAPIBase = plugin.config.get('api.returnyoutubedislike'); const dislikeAPIBase = plugin.config.get('api.returnyoutubedislike');
@ -130,8 +165,7 @@ async function getYoutubeFromVideo(
return false; return false;
} }
const gAPI = 'https://www.googleapis.com/youtube/v3/videos?id=' + id + '&key=' + const gAPI = `https://www.googleapis.com/youtube/v3/videos?id=${id}&key=${gtoken}&part=snippet,contentDetails,statistics`;
gtoken + '&part=snippet,contentDetails,statistics';
let data = await httpGET(gAPI); let data = await httpGET(gAPI);
try { try {
@ -168,26 +202,47 @@ async function getYoutubeFromVideo(
if (vid.snippet.liveBroadcastContent === 'live') { if (vid.snippet.liveBroadcastContent === 'live') {
live = true; live = true;
keys.push(['field', '[LIVE]', {color: 'red'}]); keys.push(['field', '[LIVE]', { color: 'red' }]);
} }
if (time) { if (time) {
let tag = parseInt(time, 10); let tag = parseInt(time, 10);
if (tag != null && !isNaN(tag)) { if (tag != null && !isNaN(tag)) {
if (time.indexOf('s') !== -1 || time.indexOf('m') !== -1 || time.indexOf('h') !== -1) { if (
time.indexOf('s') !== -1 ||
time.indexOf('m') !== -1 ||
time.indexOf('h') !== -1
) {
tag = parseTimeToSeconds(time); tag = parseTimeToSeconds(time);
} }
keys.push(['field', `[${toHHMMSS(tag)}]`, {color: 'red'}]); keys.push(['field', `[${toHHMMSS(tag)}]`, { color: 'red' }]);
} }
} }
keys.push(['field', msg.source.format.color('white', 'You') + msg.source.format.color('brown', 'Tube'), { type: 'title' }]); keys.push([
keys.push(['field', vid.snippet.title, {type: 'description'}]); 'field',
msg.source.format.color('white', 'You') +
msg.source.format.color('brown', 'Tube'),
{ type: 'title' },
]);
keys.push([
'field',
msg.source.format.escape(vid.snippet.title),
{ type: 'description' },
]);
keys.push(['field', vid.statistics.viewCount.toString(), { type: 'metric', label: 'Views' }]); keys.push([
'field',
vid.statistics.viewCount.toString(),
{ type: 'metric', label: 'Views' },
]);
if (!live) { if (!live) {
keys.push(['field', ytDuration(vid.contentDetails.duration.toString()), { label: 'Duration' }]); keys.push([
'field',
ytDuration(vid.contentDetails.duration.toString()),
{ label: 'Duration' },
]);
} }
let likeCount: number | null = null; let likeCount: number | null = null;
@ -204,11 +259,19 @@ async function getYoutubeFromVideo(
} }
if (likeCount !== null) { if (likeCount !== null) {
keys.push(['field', likeCount, { color: 'limegreen', label: ['▲', 'Likes'], type: 'metric' }]); keys.push([
'field',
likeCount,
{ color: 'limegreen', label: ['▲', 'Likes'], type: 'metric' },
]);
} }
if (dislikeCount !== null) { if (dislikeCount !== null) {
keys.push(['field', dislikeCount, { color: 'red', label: ['▼', 'Dislikes'], type: 'metric' }]); keys.push([
'field',
dislikeCount,
{ color: 'red', label: ['▼', 'Dislikes'], type: 'metric' },
]);
} }
keys.push(['field', vid.snippet.channelTitle, { label: ['By'] }]); keys.push(['field', vid.snippet.channelTitle, { label: ['By'] }]);
@ -221,11 +284,11 @@ async function getYoutubeFromVideo(
@Configurable({ @Configurable({
tokens: { tokens: {
google: null, google: null,
soundcloud: null soundcloud: null,
}, },
api: { api: {
returnyoutubedislike: 'https://returnyoutubedislikeapi.com' returnyoutubedislike: 'https://returnyoutubedislikeapi.com',
} },
}) })
class URLReplyPlugin extends Plugin { class URLReplyPlugin extends Plugin {
registerHandler(plugin: string, match: string, handler: ActionFn): void { registerHandler(plugin: string, match: string, handler: ActionFn): void {
@ -241,7 +304,8 @@ class URLReplyPlugin extends Plugin {
htmlHandlers.push([plugin, handler]); htmlHandlers.push([plugin, handler]);
} else { } else {
urlHandlers[match] = { urlHandlers[match] = {
plugin, action: handler plugin,
action: handler,
}; };
} }
} }
@ -251,41 +315,57 @@ class URLReplyPlugin extends Plugin {
htmlHandlers = []; htmlHandlers = [];
// YouTube // YouTube
this.registerHandler(this.name, '/watch\\?v=', async (url: urllib.URL, msg: IMessage, data: any) => { this.registerHandler(
const det = url.searchParams.get('v'); this.name,
'/watch\\?v=',
async (url: urllib.URL, msg: IMessage, data: any) => {
const det = url.searchParams.get('v');
if (!det) { if (!det) {
return false; return false;
}
return getYoutubeFromVideo.apply(this, [this, det, url, msg]);
} }
);
return getYoutubeFromVideo.apply(this, [this, det, url, msg]); this.registerHandler(
}); this.name,
'youtu.be/',
async (url: urllib.URL, msg: IMessage, data: any) => {
const det = url.pathname.substring(1);
this.registerHandler(this.name, 'youtu.be/', async (url: urllib.URL, msg: IMessage, data: any) => { if (!det) {
const det = url.pathname.substring(1); return false;
}
if (!det) { return getYoutubeFromVideo.apply(this, [this, det, url, msg]);
return false;
} }
);
return getYoutubeFromVideo.apply(this, [this, det, url, msg]);
});
// Dailymotion // Dailymotion
this.registerHandler(this.name, 'dailymotion.com/video/', async (url: urllib.URL, msg: IMessage, data: any) => { this.registerHandler(
const det = url.href.match('/video/([^?&#]*)'); this.name,
'dailymotion.com/video/',
async (url: urllib.URL, msg: IMessage, data: any) => {
const det = url.href.match('/video/([^?&#]*)');
if (!det) { if (!det) {
return false; return false;
}
return dailymotionFromId.apply(this, [det[1], msg]);
} }
);
return dailymotionFromId.apply(this, [det[1], msg]);
});
// SoundCloud // SoundCloud
this.registerHandler(this.name, 'soundcloud.com/', async (url: urllib.URL, msg: IMessage, data: any) => { this.registerHandler(
return getSoundcloudFromUrl.apply(this, [this, url.href, msg]); this.name,
}); 'soundcloud.com/',
async (url: urllib.URL, msg: IMessage, data: any) => {
return getSoundcloudFromUrl.apply(this, [this, url.href, msg]);
}
);
} }
@EventListener('pluginUnload') @EventListener('pluginUnload')
@ -329,19 +409,29 @@ class URLReplyPlugin extends Plugin {
// If there were no matches, pull the title of the website // If there were no matches, pull the title of the website
if (!matched) { if (!matched) {
try { try {
const data = await httpGET(url, { const data = await httpGET(
Accept: 'text/html,application/xhtml+xml,application/xml' url,
}, true); {
if (!data) { return; } Accept: 'text/html,application/xhtml+xml,application/xml',
},
true
);
if (!data) {
return;
}
const full = cheerio.load(data); const full = cheerio.load(data);
const head = full('head'); const head = full('head');
if (!head) { return; } if (!head) {
return;
}
const titleEl = head.find('title'); const titleEl = head.find('title');
if (!titleEl || !titleEl.length) { return; } if (!titleEl || !titleEl.length) {
return;
}
let title = titleEl.eq(0).text(); let title = titleEl.eq(0).text();
title = title.replace(/\n/g, ' ').trim(); title = title.replace(/\n/g, ' ').trim();
title = msg.source.format.strip(title); title = msg.source.format.strip(title);
@ -350,21 +440,41 @@ class URLReplyPlugin extends Plugin {
let htmlHandle = false; let htmlHandle = false;
for (const k in htmlHandlers) { for (const k in htmlHandlers) {
const handler = htmlHandlers[k]; const handler = htmlHandlers[k];
if (htmlHandle) { break; } if (htmlHandle) {
break;
}
// Ensure handler is a function // Ensure handler is a function
if (!handler[1] || typeof handler[1] !== 'function') { continue; } if (!handler[1] || typeof handler[1] !== 'function') {
continue;
}
try { try {
htmlHandle = await handler[1].apply(this, [url, msg, title, full]); htmlHandle = await handler[1].apply(this, [
url,
msg,
title,
full,
]);
} catch (e) { } catch (e) {
logger.error(e); logger.error(e);
htmlHandle = false; htmlHandle = false;
} }
} }
if (htmlHandle) { return; } if (htmlHandle) {
if (title.length > 140) { title = title.substring(0, 140) + '…'; } return;
}
msg.resolve(msg.source.format.color('purple', '[ ') + title + msg.source.format.color('purple', ' ]')); if (title.length > 140) {
title = title.substring(0, 140) + '…';
}
msg.resolve(
msg.source.format.color('purple', '[ ') +
title +
msg.source.format.color('purple', ' ]')
);
} catch (e) {} } catch (e) {}
} }
}); });