rcscript.js 34 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632
  1. const cheerio = require('cheerio');
  2. const help_setup = require('../functions/helpsetup.js');
  3. const {limit: {rcgcdw: rcgcdwLimit}, defaultSettings} = require('../util/default.json');
  4. const Lang = require('../util/i18n.js');
  5. const allLangs = Lang.allLangs(true);
  6. const Wiki = require('../util/wiki.js');
  7. var db = require('../util/database.js');
  8. const fs = require('fs');
  9. const rcscriptExists = fs.existsSync('./RcGcDb/start.py');
  10. const display_types = [
  11. 'compact',
  12. 'embed',
  13. 'image',
  14. 'diff'
  15. ];
  16. /**
  17. * Processes the "rcscript" command.
  18. * @param {Lang} lang - The user language.
  19. * @param {import('discord.js').Message} msg - The Discord message.
  20. * @param {String[]} args - The command arguments.
  21. * @param {String} line - The command as plain text.
  22. * @param {Wiki} wiki - The wiki for the message.
  23. */
  24. function cmd_rcscript(lang, msg, args, line, wiki) {
  25. if ( args[0] === 'block' && msg.isOwner() ) return blocklist(msg, args.slice(1));
  26. if ( !msg.isAdmin() ) return msg.reactEmoji('❌');
  27. if ( msg.defaultSettings ) return help_setup(lang, msg);
  28. db.all( 'SELECT configid, webhook, wiki, lang, display, wikiid, rcid FROM rcgcdw WHERE guild = ? ORDER BY configid ASC', [msg.guild.id], (dberror, rows) => {
  29. if ( dberror || !rows ) {
  30. console.log( '- Error while getting the RcGcDw: ' + dberror );
  31. msg.reactEmoji('error', true);
  32. return dberror;
  33. }
  34. var prefix = process.env.prefix;
  35. var limit = rcgcdwLimit.default;
  36. var display = display_types.slice(0, rcgcdwLimit.display + 1);
  37. if ( msg.guild.id in patreons ) {
  38. prefix = patreons[msg.guild.id];
  39. limit = rcgcdwLimit.patreon;
  40. display = display_types.slice();
  41. }
  42. if ( args[0] === 'add' ) {
  43. if ( !msg.channel.permissionsFor(msg.client.user).has('MANAGE_WEBHOOKS') ) {
  44. console.log( msg.guild.id + ': Missing permissions - MANAGE_WEBHOOKS' );
  45. return msg.replyMsg( lang.get('general.missingperm') + ' `MANAGE_WEBHOOKS`' );
  46. }
  47. if ( !( msg.channel.permissionsFor(msg.member).has('MANAGE_WEBHOOKS') || ( msg.isOwner() && msg.evalUsed ) ) ) {
  48. return msg.replyMsg( lang.get('rcscript.noadmin') );
  49. }
  50. if ( rows.length >= limit ) return msg.replyMsg( lang.get('rcscript.max_entries'), {}, true );
  51. if ( process.env.READONLY ) return msg.replyMsg( lang.get('general.readonly') + '\n' + process.env.invite, {}, true );
  52. var wikiinvalid = lang.get('settings.wikiinvalid') + '\n`' + prefix + 'rcscript add ' + lang.get('rcscript.new_wiki') + '`\n' + lang.get('rcscript.help_wiki');
  53. var input = args.slice(1).join(' ').toLowerCase().trim().replace( /^<\s*(.*?)\s*>$/, '$1' );
  54. var wikinew = new Wiki(wiki);
  55. if ( input ) {
  56. wikinew = Wiki.fromInput(input);
  57. if ( !wikinew ) return msg.replyMsg( wikiinvalid, {}, true );
  58. }
  59. return msg.reactEmoji('⏳', true).then( reaction => got.get( wikinew + 'api.php?&action=query&meta=allmessages|siteinfo&ammessages=custom-RcGcDw|recentchanges&amenableparser=true&siprop=general' + ( wiki.isFandom() ? '|variables' : '' ) + '&titles=Special:RecentChanges&format=json' ).then( response => {
  60. if ( response.statusCode === 404 && typeof response.body === 'string' ) {
  61. let api = cheerio.load(response.body)('head link[rel="EditURI"]').prop('href');
  62. if ( api ) {
  63. wikinew = new Wiki(api.split('api.php?')[0], wikinew);
  64. return got.get( wikinew + 'api.php?action=query&meta=allmessages|siteinfo&ammessages=custom-RcGcDw|recentchanges&amenableparser=true&siprop=general' + ( wiki.isFandom() ? '|variables' : '' ) + '&titles=Special:RecentChanges&format=json' );
  65. }
  66. }
  67. return response;
  68. } ).then( response => {
  69. var body = response.body;
  70. if ( response.statusCode !== 200 || !body?.query?.allmessages || !body?.query?.general || !body?.query?.pages?.['-1'] ) {
  71. console.log( '- ' + response.statusCode + ': Error while testing the wiki: ' + body?.error?.info );
  72. if ( reaction ) reaction.removeEmoji();
  73. msg.reactEmoji('nowiki', true);
  74. return msg.replyMsg( wikiinvalid, {}, true );
  75. }
  76. wikinew.updateWiki(body.query.general);
  77. if ( body.query.general.generator.replace( /^MediaWiki 1\.(\d\d).*$/, '$1' ) < 30 ) {
  78. if ( reaction ) reaction.removeEmoji();
  79. return msg.replyMsg( lang.get('test.MediaWiki', 'MediaWiki 1.30', body.query.general.generator) + '\nhttps://www.mediawiki.org/wiki/MediaWiki_1.30', {}, true );
  80. }
  81. if ( body.query.allmessages[0]['*'] !== msg.guild.id ) {
  82. if ( reaction ) reaction.removeEmoji();
  83. return msg.replyMsg( lang.get('rcscript.sysmessage', 'MediaWiki:Custom-RcGcDw', msg.guild.id) + '\n<' + wikinew.toLink('MediaWiki:Custom-RcGcDw', 'action=edit') + '>', {}, true );
  84. }
  85. return db.get( 'SELECT reason FROM blocklist WHERE wiki = ?', [wikinew.href], (blerror, block) => {
  86. if ( blerror ) {
  87. console.log( '- Error while getting the blocklist: ' + blerror );
  88. if ( reaction ) reaction.removeEmoji();
  89. msg.reactEmoji('error', true);
  90. return blerror;
  91. }
  92. if ( block ) {
  93. console.log( '- This wiki is blocked: ' + block.reason );
  94. if ( reaction ) reaction.removeEmoji();
  95. return msg.replyMsg( ( block.reason ? lang.get('rcscript.blocked_reason', block.reason) : lang.get('rcscript.blocked') ), {}, true );
  96. }
  97. var wikiid = body.query.variables?.find?.( variable => variable?.id === 'wgCityId' )?.['*'];
  98. if ( wikinew.isFandom(false) && wikiid ) return got.get( 'https://services.fandom.com/discussion/' + wikiid + '/posts?limit=1&format=json&cache=' + Date.now(), {
  99. headers: {
  100. Accept: 'application/hal+json'
  101. }
  102. } ).then( dsresponse => {
  103. var dsbody = dsresponse.body;
  104. if ( dsresponse.statusCode !== 200 || !dsbody || dsbody.title ) {
  105. if ( dsbody?.title !== 'site doesn\'t exists' ) console.log( '- ' + dsresponse.statusCode + ': Error while checking for discussions: ' + dsbody?.title );
  106. return createWebhook();
  107. }
  108. return createWebhook(parseInt(wikiid, 10));
  109. }, error => {
  110. console.log( '- Error while checking for discussions: ' + error );
  111. return createWebhook();
  112. } );
  113. return createWebhook();
  114. /**
  115. * Creates the webhook.
  116. * @param {Number} wikiid - The ID of the wiki.
  117. */
  118. function createWebhook(wikiid = null) {
  119. msg.channel.createWebhook( ( body.query.allmessages[1]['*'] || 'Recent changes' ), {
  120. avatar: msg.client.user.displayAvatarURL({format:'png',size:4096}),
  121. reason: lang.get('rcscript.audit_reason', wikinew.href)
  122. } ).then( webhook => {
  123. console.log( '- Webhook successfully created.' );
  124. var webhook_lang = new Lang(( allLangs.map[lang.lang] || allLangs.map[body.query.general.lang] || defaultSettings.lang ), 'rcscript.webhook');
  125. webhook.send( webhook_lang.get('created', body.query.general.sitename) + '\n<' + wikinew.toLink(body.query.pages['-1'].title) + ( wikiid ? '>\n<' + wikinew + 'f' : '' ) + '>' ).catch(log_error);
  126. var new_configid = 1;
  127. for ( let i of rows.map( row => row.configid ) ) {
  128. if ( new_configid === i ) new_configid++;
  129. else break;
  130. }
  131. db.run( 'INSERT INTO rcgcdw(guild, configid, webhook, wiki, lang, display, wikiid) VALUES(?, ?, ?, ?, ?, ?, ?)', [msg.guild.id, new_configid, webhook.id + '/' + webhook.token, wikinew.href, webhook_lang.lang, ( msg.showEmbed() ? 1 : 0 ), wikiid], function (error) {
  132. if ( error ) {
  133. console.log( '- Error while adding the RcGcDw: ' + error );
  134. if ( reaction ) reaction.removeEmoji();
  135. msg.replyMsg( lang.get('settings.save_failed'), {}, true );
  136. return error;
  137. }
  138. console.log( '- RcGcDw successfully added.' );
  139. if ( reaction ) reaction.removeEmoji();
  140. msg.replyMsg( lang.get('rcscript.added') + ' <' + wikinew + '>\n`' + prefix + 'rcscript' + ( rows.length ? ' ' + new_configid : '' ) + '`', {}, true );
  141. } );
  142. }, error => {
  143. console.log( '- Error while creating the webhook: ' + error );
  144. if ( reaction ) reaction.removeEmoji();
  145. msg.replyMsg( lang.get('rcscript.webhook_failed'), {}, true );
  146. } );
  147. }
  148. } );
  149. }, error => {
  150. console.log( '- Error while testing the wiki: ' + error );
  151. if ( reaction ) reaction.removeEmoji();
  152. msg.reactEmoji('nowiki', true);
  153. return msg.replyMsg( wikiinvalid, {}, true );
  154. } ) );
  155. }
  156. var selected_row = rows.find( row => row.configid.toString() === args[0] );
  157. if ( selected_row ) {
  158. args[0] = args[1];
  159. args[1] = args.slice(2).join(' ').toLowerCase().trim().replace( /^<\s*(.*)\s*>$/, '$1' );
  160. }
  161. else {
  162. args[1] = args.slice(1).join(' ').toLowerCase().trim().replace( /^<\s*(.*)\s*>$/, '$1' );
  163. if ( rows.length === 1 ) selected_row = rows[0];
  164. }
  165. if ( args[0] ) args[0] = args[0].toLowerCase();
  166. if ( selected_row ) {
  167. let webhook_lang = new Lang(selected_row.lang, 'rcscript.webhook');
  168. let cmd = prefix + 'rcscript' + ( rows.length === 1 ? '' : ' ' + selected_row.configid );
  169. if ( args[0] === 'delete' && !args[1] ) {
  170. if ( process.env.READONLY ) return msg.replyMsg( lang.get('general.readonly') + '\n' + process.env.invite, {}, true );
  171. return msg.client.fetchWebhook(...selected_row.webhook.split('/')).then( webhook => {
  172. var channel = msg.guild.channels.cache.get(webhook.channelID);
  173. if ( !channel || !channel.permissionsFor(msg.member).has('MANAGE_WEBHOOKS') ) {
  174. return msg.replyMsg( lang.get('rcscript.noadmin') );
  175. }
  176. db.run( 'DELETE FROM rcgcdw WHERE webhook = ?', [selected_row.webhook], function (delerror) {
  177. if ( delerror ) {
  178. console.log( '- Error while removing the RcGcDw: ' + delerror );
  179. msg.replyMsg( lang.get('settings.save_failed'), {}, true );
  180. return delerror;
  181. }
  182. console.log( '- RcGcDw successfully removed.' );
  183. webhook.send( webhook_lang.get('deleted') ).catch(log_error).finally( () => {
  184. webhook.delete(lang.get('rcscript.audit_reason_delete')).catch(log_error);
  185. } );
  186. msg.replyMsg( lang.get('rcscript.deleted'), {}, true );
  187. } );
  188. }, error => {
  189. log_error(error);
  190. if ( error.name === 'DiscordAPIError' && ['Unknown Webhook', 'Invalid Webhook Token'].includes( error.message ) ) {
  191. return msg.replyMsg( lang.get('settings.save_failed'), {}, true );
  192. }
  193. db.run( 'DELETE FROM rcgcdw WHERE webhook = ?', [selected_row.webhook], function (delerror) {
  194. if ( delerror ) {
  195. console.log( '- Error while removing the RcGcDw: ' + delerror );
  196. msg.replyMsg( lang.get('settings.save_failed'), {}, true );
  197. return delerror;
  198. }
  199. console.log( '- RcGcDw successfully removed.' );
  200. msg.replyMsg( lang.get('rcscript.deleted'), {}, true );
  201. } );
  202. } );
  203. }
  204. if ( args[0] === 'wiki' ) {
  205. if ( !args[1] ) {
  206. return msg.replyMsg( lang.get('rcscript.current_wiki') + ' <' + selected_row.wiki + '>\n`' + cmd + ' wiki ' + lang.get('rcscript.new_wiki') + '`\n' + lang.get('rcscript.help_wiki'), {}, true );
  207. }
  208. if ( process.env.READONLY ) return msg.replyMsg( lang.get('general.readonly') + '\n' + process.env.invite, {}, true );
  209. var wikiinvalid = lang.get('settings.wikiinvalid') + '\n`' + cmd + ' wiki ' + lang.get('rcscript.new_wiki') + '`\n' + lang.get('rcscript.help_wiki');
  210. var wikinew = Wiki.fromInput(args[1]);
  211. if ( !wikinew ) return msg.replyMsg( wikiinvalid, {}, true );
  212. return msg.reactEmoji('⏳', true).then( reaction => got.get( wikinew + 'api.php?&action=query&meta=allmessages|siteinfo&ammessages=custom-RcGcDw&amenableparser=true&siprop=general' + ( wiki.isFandom() ? '|variables' : '' ) + '&titles=Special:RecentChanges&format=json' ).then( response => {
  213. if ( response.statusCode === 404 && typeof response.body === 'string' ) {
  214. let api = cheerio.load(response.body)('head link[rel="EditURI"]').prop('href');
  215. if ( api ) {
  216. wikinew = new Wiki(api.split('api.php?')[0], wikinew);
  217. return got.get( wikinew + 'api.php?action=query&meta=allmessages|siteinfo&ammessages=custom-RcGcDw&amenableparser=true&siprop=general' + ( wiki.isFandom() ? '|variables' : '' ) + '&titles=Special:RecentChanges&format=json' );
  218. }
  219. }
  220. return response;
  221. } ).then( response => {
  222. var body = response.body;
  223. if ( response.statusCode !== 200 || !body?.query?.allmessages || !body?.query?.general || !body?.query?.pages?.['-1'] ) {
  224. console.log( '- ' + response.statusCode + ': Error while testing the wiki: ' + body?.error?.info );
  225. if ( reaction ) reaction.removeEmoji();
  226. msg.reactEmoji('nowiki', true);
  227. return msg.replyMsg( wikiinvalid, {}, true );
  228. }
  229. wikinew.updateWiki(body.query.general);
  230. if ( body.query.general.generator.replace( /^MediaWiki 1\.(\d\d).*$/, '$1' ) <= 30 ) {
  231. console.log( '- This wiki is using ' + body.query.general.generator + '.' );
  232. if ( reaction ) reaction.removeEmoji();
  233. return msg.replyMsg( lang.get('test.MediaWiki', 'MediaWiki 1.30', body.query.general.generator) + '\nhttps://www.mediawiki.org/wiki/MediaWiki_1.30', {}, true );
  234. }
  235. if ( body.query.allmessages[0]['*'] !== msg.guild.id ) {
  236. if ( reaction ) reaction.removeEmoji();
  237. return msg.replyMsg( lang.get('rcscript.sysmessage', 'MediaWiki:Custom-RcGcDw', msg.guild.id) + '\n<' + wikinew.toLink('MediaWiki:Custom-RcGcDw', 'action=edit') + '>', {}, true );
  238. }
  239. return db.get( 'SELECT reason FROM blocklist WHERE wiki = ?', [wikinew.href], (blerror, block) => {
  240. if ( blerror ) {
  241. console.log( '- Error while getting the blocklist: ' + blerror );
  242. if ( reaction ) reaction.removeEmoji();
  243. msg.reactEmoji('error', true);
  244. return blerror;
  245. }
  246. if ( block ) {
  247. console.log( '- This wiki is blocked: ' + block.reason );
  248. if ( reaction ) reaction.removeEmoji();
  249. return msg.replyMsg( ( block.reason ? lang.get('rcscript.blocked_reason', block.reason) : lang.get('rcscript.blocked') ), {}, true );
  250. }
  251. var wikiid = body.query.variables?.find?.( variable => variable?.id === 'wgCityId' )?.['*'];
  252. if ( wikinew.isFandom(false) && wikiid ) return got.get( 'https://services.fandom.com/discussion/' + wikiid + '/posts?limit=1&format=json&cache=' + Date.now(), {
  253. headers: {
  254. Accept: 'application/hal+json'
  255. }
  256. } ).then( dsresponse => {
  257. var dsbody = dsresponse.body;
  258. if ( dsresponse.statusCode !== 200 || !dsbody || dsbody.title ) {
  259. if ( dsbody?.title !== 'site doesn\'t exists' ) console.log( '- ' + dsresponse.statusCode + ': Error while checking for discussions: ' + dsbody?.title );
  260. return updateWiki();
  261. }
  262. return updateWiki(parseInt(wikiid, 10));
  263. }, error => {
  264. console.log( '- Error while checking for discussions: ' + error );
  265. return updateWiki();
  266. } );
  267. return updateWiki();
  268. /**
  269. * Changes the wiki.
  270. * @param {Number} wikiid - The ID of the wiki.
  271. */
  272. function updateWiki(wikiid = null) {
  273. msg.client.fetchWebhook(...selected_row.webhook.split('/')).then( webhook => {
  274. webhook.send( webhook_lang.get('updated_wiki', body.query.general.sitename) + '\n<' + wikinew.toLink(body.query.pages['-1'].title) + ( wikiid ? '>\n<' + wikinew + 'f' : '' ) + '>' ).catch(log_error);
  275. }, log_error );
  276. db.run( 'UPDATE rcgcdw SET wiki = ?, wikiid = ?, rcid = ?, postid = ? WHERE webhook = ?', [wikinew.href, wikiid, null, null, selected_row.webhook], function (error) {
  277. if ( error ) {
  278. console.log( '- Error while updating the RcGcDw: ' + error );
  279. if ( reaction ) reaction.removeEmoji();
  280. msg.replyMsg( lang.get('settings.save_failed'), {}, true );
  281. return error;
  282. }
  283. console.log( '- RcGcDw successfully updated.' );
  284. if ( reaction ) reaction.removeEmoji();
  285. msg.replyMsg( lang.get('rcscript.updated_wiki') + ' <' + wikinew + '>\n`' + cmd + '`', {}, true );
  286. } );
  287. }
  288. } );
  289. }, error => {
  290. console.log( '- Error while testing the wiki: ' + error );
  291. if ( reaction ) reaction.removeEmoji();
  292. msg.reactEmoji('nowiki', true);
  293. return msg.replyMsg( wikiinvalid, {}, true );
  294. } ) );
  295. }
  296. if ( args[0] === 'lang' ) {
  297. if ( !args[1] ) {
  298. return msg.replyMsg( lang.get('rcscript.current_lang') + ' `' + allLangs.names[selected_row.lang] + '`\n`' + cmd + ' lang ' + lang.get('rcscript.new_lang') + '`\n' + lang.get('rcscript.help_lang') + ' `' + Object.values(allLangs.names).join('`, `') + '`', {files:( msg.uploadFiles() ? [`./RcGcDb/locale/widgets/${selected_row.lang}.png`] : [] )}, true );
  299. }
  300. if ( process.env.READONLY ) return msg.replyMsg( lang.get('general.readonly') + '\n' + process.env.invite, {}, true );
  301. if ( !( args[1] in allLangs.map ) ) {
  302. return msg.replyMsg( lang.get('settings.langinvalid') + '\n`' + cmd + ' lang ' + lang.get('rcscript.new_lang') + '`\n' + lang.get('rcscript.help_lang') + ' `' + Object.values(allLangs.names).join('`, `') + '`', {}, true );
  303. }
  304. msg.client.fetchWebhook(...selected_row.webhook.split('/')).then( webhook => {
  305. webhook.send( new Lang(allLangs.map[args[1]], 'rcscript.webhook').get('updated_lang', allLangs.names[allLangs.map[args[1]]]), {files:[`./RcGcDb/locale/widgets/${allLangs.map[args[1]]}.png`]} ).catch(log_error);
  306. }, log_error );
  307. return db.run( 'UPDATE rcgcdw SET lang = ? WHERE webhook = ?', [allLangs.map[args[1]], selected_row.webhook], function (error) {
  308. if ( error ) {
  309. console.log( '- Error while updating the RcGcDw: ' + error );
  310. msg.replyMsg( lang.get('settings.save_failed'), {}, true );
  311. return error;
  312. }
  313. console.log( '- RcGcDw successfully updated.' );
  314. msg.replyMsg( lang.get('rcscript.updated_lang') + ' `' + allLangs.names[allLangs.map[args[1]]] + '`\n`' + cmd + '`', {files:( msg.uploadFiles() ? [`./RcGcDb/locale/widgets/${allLangs.map[args[1]]}.png`] : [] )}, true );
  315. } );
  316. }
  317. if ( args[0] === 'display' ) {
  318. if ( !args[1] || !display_types.includes( args[1] ) ) {
  319. return msg.replyMsg( lang.get('rcscript.current_display') + ' `' + display_types[selected_row.display] + '`\n`' + cmd + ' display (' + display.join('|') + ')`\n' + display.map( display_type => '`' + display_type + '`: ' + lang.get('rcscript.help_display_' + display_type) ).join('\n'), {}, true );
  320. }
  321. if ( process.env.READONLY ) return msg.replyMsg( lang.get('general.readonly') + '\n' + process.env.invite, {}, true );
  322. if ( !display.includes( args[1] ) ) {
  323. return msg.replyMsg( lang.get('general.patreon') + '\n<' + process.env.patreon + '>', {}, true );
  324. }
  325. msg.client.fetchWebhook(...selected_row.webhook.split('/')).then( webhook => {
  326. webhook.send( webhook_lang.get('updated_display_' + args[1]) ).catch(log_error);
  327. }, log_error );
  328. return db.run( 'UPDATE rcgcdw SET display = ? WHERE webhook = ?', [display_types.indexOf(args[1]), selected_row.webhook], function (error) {
  329. if ( error ) {
  330. console.log( '- Error while updating the RcGcDw: ' + error );
  331. msg.replyMsg( lang.get('settings.save_failed'), {}, true );
  332. return error;
  333. }
  334. console.log( '- RcGcDw successfully updated.' );
  335. msg.replyMsg( lang.get('rcscript.updated_display') + ' `' + args[1] + '`\n`' + cmd + '`', {}, true );
  336. } );
  337. }
  338. if ( new Wiki(selected_row.wiki).isFandom(false) && args[0] === 'feeds' ) {
  339. if ( process.env.READONLY ) return msg.replyMsg( lang.get('general.readonly') + '\n' + process.env.invite, {}, true );
  340. if ( args[1] === 'only' ) {
  341. if ( selected_row.rcid === -1 ) {
  342. msg.client.fetchWebhook(...selected_row.webhook.split('/')).then( webhook => {
  343. webhook.send( webhook_lang.get('enabled_rc') ).catch(log_error);
  344. }, log_error );
  345. return db.run( 'UPDATE rcgcdw SET rcid = ? WHERE webhook = ?', [null, selected_row.webhook], function (error) {
  346. if ( error ) {
  347. console.log( '- Error while updating the RcGcDw: ' + error );
  348. msg.replyMsg( lang.get('settings.save_failed'), {}, true );
  349. return error;
  350. }
  351. console.log( '- RcGcDw successfully updated.' );
  352. msg.replyMsg( lang.get('rcscript.enabled_rc') + '\n`' + cmd + '`', {}, true );
  353. } );
  354. }
  355. if ( !selected_row.wikiid ) {
  356. return msg.replyMsg( lang.get('rcscript.all_inactive') + '\n\n' + lang.get('rcscript.delete') + '\n`' + cmd + ' delete`', {}, true );
  357. }
  358. msg.client.fetchWebhook(...selected_row.webhook.split('/')).then( webhook => {
  359. webhook.send( webhook_lang.get('disabled_rc') ).catch(log_error);
  360. }, log_error );
  361. return db.run( 'UPDATE rcgcdw SET rcid = ? WHERE webhook = ?', [-1, selected_row.webhook], function (error) {
  362. if ( error ) {
  363. console.log( '- Error while updating the RcGcDw: ' + error );
  364. msg.replyMsg( lang.get('settings.save_failed'), {}, true );
  365. return error;
  366. }
  367. console.log( '- RcGcDw successfully updated.' );
  368. msg.replyMsg( lang.get('rcscript.disabled_rc') + '\n`' + cmd + '`', {}, true );
  369. } );
  370. }
  371. if ( selected_row.wikiid ) {
  372. if ( selected_row.rcid === -1 ) {
  373. return msg.replyMsg( lang.get('rcscript.all_inactive') + '\n\n' + lang.get('rcscript.delete') + '\n`' + cmd + ' delete`', {}, true );
  374. }
  375. msg.client.fetchWebhook(...selected_row.webhook.split('/')).then( webhook => {
  376. webhook.send( webhook_lang.get('disabled_feeds') ).catch(log_error);
  377. }, log_error );
  378. return db.run( 'UPDATE rcgcdw SET wikiid = ?, postid = ? WHERE webhook = ?', [null, null, selected_row.webhook], function (error) {
  379. if ( error ) {
  380. console.log( '- Error while updating the RcGcDw: ' + error );
  381. msg.replyMsg( lang.get('settings.save_failed'), {}, true );
  382. return error;
  383. }
  384. console.log( '- RcGcDw successfully updated.' );
  385. msg.replyMsg( lang.get('rcscript.disabled_feeds') + '\n`' + cmd + '`', {}, true );
  386. } );
  387. }
  388. return msg.reactEmoji('⏳', true).then( reaction => got.get( selected_row.wiki + 'api.php?action=query&meta=siteinfo&siprop=general|variables&format=json' ).then( wiresponse => {
  389. var wibody = wiresponse.body;
  390. if ( wiresponse.statusCode !== 200 || !wibody?.query?.variables?.some?.( variable => variable?.id === 'wgCityId' )?.['*'] ) {
  391. console.log( '- ' + wiresponse.statusCode + ': Error while getting the wiki id: ' + wibody?.error?.info );
  392. if ( reaction ) reaction.removeEmoji();
  393. return msg.replyMsg( lang.get('rcscript.no_feeds'), {}, true );
  394. }
  395. var wikiid = wibody.query.variables.find( variable => variable.id === 'wgCityId' )['*'];
  396. return got.get( 'https://services.fandom.com/discussion/' + wikiid + '/posts?limit=1&format=json&cache=' + Date.now(), {
  397. headers: {
  398. Accept: 'application/hal+json'
  399. }
  400. } ).then( dsresponse => {
  401. var dsbody = dsresponse.body;
  402. if ( dsresponse.statusCode !== 200 || !dsbody || dsbody.title ) {
  403. if ( dsbody?.title !== 'site doesn\'t exists' ) console.log( '- ' + dsresponse.statusCode + ': Error while checking for discussions: ' + dsbody?.title );
  404. if ( reaction ) reaction.removeEmoji();
  405. return msg.replyMsg( lang.get('rcscript.no_feeds'), {}, true );
  406. }
  407. msg.client.fetchWebhook(...selected_row.webhook.split('/')).then( webhook => {
  408. webhook.send( webhook_lang.get('enabled_feeds', body.query.general.sitename) + '\n<' + selected_row.wiki + 'f>' ).catch(log_error);
  409. }, log_error );
  410. db.run( 'UPDATE rcgcdw SET wikiid = ?, postid = ? WHERE webhook = ?', [parseInt(wikiid, 10), null, selected_row.webhook], function (error) {
  411. if ( error ) {
  412. console.log( '- Error while updating the RcGcDw: ' + error );
  413. if ( reaction ) reaction.removeEmoji();
  414. msg.replyMsg( lang.get('settings.save_failed'), {}, true );
  415. return error;
  416. }
  417. console.log( '- RcGcDw successfully updated.' );
  418. if ( reaction ) reaction.removeEmoji();
  419. msg.replyMsg( lang.get('rcscript.enabled_feeds') + '\n`' + cmd + '`', {}, true );
  420. } );
  421. }, error => {
  422. console.log( '- Error while checking for discussions: ' + error );
  423. if ( reaction ) reaction.removeEmoji();
  424. return msg.replyMsg( lang.get('rcscript.no_feeds'), {}, true );
  425. } );
  426. }, error => {
  427. console.log( '- Error while getting the wiki id: ' + error );
  428. if ( reaction ) reaction.removeEmoji();
  429. return msg.replyMsg( lang.get('rcscript.no_feeds'), {}, true );
  430. } ) );
  431. }
  432. if ( rows.length > 1 ) return msg.client.fetchWebhook(...selected_row.webhook.split('/')).then( webhook => {
  433. return webhook.channelID;
  434. }, error => {
  435. log_error(error);
  436. if ( error.name === 'DiscordAPIError' && ['Unknown Webhook', 'Invalid Webhook Token'].includes( error.message ) ) {
  437. db.run( 'DELETE FROM rcgcdw WHERE webhook = ?', [selected_row.webhook], function (delerror) {
  438. if ( delerror ) {
  439. console.log( '- Error while removing the RcGcDw: ' + delerror );
  440. return delerror;
  441. }
  442. console.log( '- RcGcDw successfully removed.' );
  443. } );
  444. Promise.reject();
  445. }
  446. return;
  447. } ).then( channel => {
  448. var text = lang.get('rcscript.current_selected') + '\n';
  449. text += '\n' + lang.get('rcscript.channel') + ' <#' + channel + '>\n';
  450. text += '\n' + lang.get('rcscript.wiki') + ' <' + selected_row.wiki + '>';
  451. text += '\n`' + cmd + ' wiki ' + lang.get('rcscript.new_wiki') + '`\n';
  452. text += '\n' + lang.get('rcscript.lang') + ' `' + allLangs.names[selected_row.lang] + '`';
  453. text += '\n`' + cmd + ' lang ' + lang.get('rcscript.new_lang') + '`\n';
  454. text += '\n' + lang.get('rcscript.display') + ' `' + display_types[selected_row.display] + '`';
  455. text += '\n`' + cmd + ' display (' + display.join('|') + ')`\n';
  456. if ( selected_row.rcid === -1 ) {
  457. text += '\n' + lang.get('rcscript.rc') + ' *`' + lang.get('rcscript.disabled') + '`*';
  458. text += '\n`' + cmd + ' feeds only` ' + lang.get('rcscript.toggle') + '\n';
  459. }
  460. if ( new Wiki(selected_row.wiki).isFandom(false) ) {
  461. text += '\n' + lang.get('rcscript.feeds') + ' *`' + lang.get('rcscript.' + ( selected_row.wikiid ? 'enabled' : 'disabled' )) + '`*';
  462. text += '\n' + lang.get('rcscript.help_feeds') + '\n`' + cmd + ' feeds` ' + lang.get('rcscript.toggle') + '\n';
  463. }
  464. text += '\n' + lang.get('rcscript.delete') + '\n`' + cmd + ' delete`\n';
  465. msg.replyMsg( text, {}, true );
  466. }, () => msg.replyMsg( lang.get('rcscript.deleted'), {}, true ) );
  467. }
  468. Promise.all(rows.map( row => msg.client.fetchWebhook(...row.webhook.split('/')).then( webhook => {
  469. return webhook.channelID;
  470. }, error => {
  471. log_error(error);
  472. if ( error.name === 'DiscordAPIError' && ['Unknown Webhook', 'Invalid Webhook Token'].includes( error.message ) ) {
  473. db.run( 'DELETE FROM rcgcdw WHERE webhook = ?', [row.webhook], function (delerror) {
  474. if ( delerror ) {
  475. console.log( '- Error while removing the RcGcDw: ' + delerror );
  476. return delerror;
  477. }
  478. console.log( '- RcGcDw successfully removed.' );
  479. } );
  480. return;
  481. }
  482. return 'undefined';
  483. } ) )).then( webhooks => {
  484. rows.forEach( (row, i) => {
  485. if ( webhooks[i] ) row.channel = webhooks[i];
  486. } );
  487. rows = rows.filter( row => row.channel );
  488. var only = ( rows.length === 1 );
  489. var text = '';
  490. if ( rows.length ) text += lang.get('rcscript.current') + rows.map( row => {
  491. var cmd = prefix + 'rcscript' + ( only ? '' : ' ' + row.configid );
  492. var row_text = '\n';
  493. if ( !only ) row_text += '\n`' + cmd + '`';
  494. row_text += '\n' + lang.get('rcscript.channel') + ' <#' + row.channel + '>';
  495. if ( only ) row_text += '\n';
  496. row_text += '\n' + lang.get('rcscript.wiki') + ' <' + row.wiki + '>';
  497. if ( only ) row_text += '\n`' + cmd + ' wiki ' + lang.get('rcscript.new_wiki') + '`\n';
  498. row_text += '\n' + lang.get('rcscript.lang') + ' `' + allLangs.names[row.lang] + '`';
  499. if ( only ) row_text += '\n`' + cmd + ' lang ' + lang.get('rcscript.new_lang') + '`\n';
  500. row_text += '\n' + lang.get('rcscript.display') + ' `' + display_types[row.display] + '`';
  501. if ( only ) row_text += '\n`' + cmd + ' display (' + display.join('|') + ')`\n';
  502. if ( row.rcid === -1 ) {
  503. row_text += '\n' + lang.get('rcscript.rc') + ' *`' + lang.get('rcscript.disabled' ) + '`*';
  504. if ( only ) row_text += '\n`' + cmd + ' feeds only` ' + lang.get('rcscript.toggle') + '\n';
  505. }
  506. if ( new Wiki(row.wiki).isFandom(false) ) {
  507. row_text += '\n' + lang.get('rcscript.feeds') + ' *`' + lang.get('rcscript.' + ( row.wikiid ? 'enabled' : 'disabled' )) + '`*';
  508. if ( only ) row_text += '\n' + lang.get('rcscript.help_feeds') + '\n`' + cmd + ' feeds` ' + lang.get('rcscript.toggle') + '\n';
  509. }
  510. if ( only ) row_text += '\n' + lang.get('rcscript.delete') + '\n`' + cmd + ' delete`\n';
  511. return row_text;
  512. } ).join('');
  513. else text += lang.get('rcscript.missing');
  514. if ( rows.length < limit ) text += '\n\n' + lang.get('rcscript.add_more') + '\n`' + prefix + 'rcscript add ' + lang.get('rcscript.new_wiki') + '`';
  515. msg.replyMsg( text, {split:true}, true );
  516. } );
  517. } );
  518. }
  519. /**
  520. * Processes the blocklist.
  521. * @param {import('discord.js').Message} msg - The Discord message.
  522. * @param {String[]} args - The command arguments.
  523. */
  524. function blocklist(msg, args) {
  525. var prefix = ( patreons[msg?.guild?.id] || process.env.prefix );
  526. if ( args[0] === 'add' ) {
  527. if ( !args[1] ) return msg.replyMsg( '`' + prefix + 'rcscript block add <wiki> [<reason>]`', {}, true );
  528. if ( process.env.READONLY ) return msg.replyMsg( lang.get('general.readonly') + '\n' + process.env.invite, {}, true );
  529. let input = args[1].toLowerCase().replace( /^<(.*?)>$/, '$1' );
  530. let wiki = Wiki.fromInput(input);
  531. if ( !wiki ) return msg.replyMsg( '`' + prefix + 'rcscript block add <wiki> [<reason>]`', {}, true );
  532. let reason = ( args.slice(2).join(' ').trim() || null );
  533. return db.run( 'INSERT INTO blocklist(wiki, reason) VALUES(?, ?)', [wiki.href, reason], function (error) {
  534. if ( error ) {
  535. if ( error.message === 'SQLITE_CONSTRAINT: UNIQUE constraint failed: blocklist.wiki' ) {
  536. return msg.replyMsg( '`' + wiki + '` is already on the blocklist.\n`' + prefix + 'rcscript block <' + wiki + '>`', {}, true );
  537. }
  538. console.log( '- Error while adding to the blocklist: ' + error );
  539. msg.replyMsg( 'I got an error while adding to the blocklist: ' + error, {}, true );
  540. return error;
  541. }
  542. console.log( '- Successfully added to the blocklist.' );
  543. db.each( 'SELECT webhook, lang FROM rcgcdw WHERE wiki = ?', [wiki.href], (dberror, row) => {
  544. if ( dberror ) return dberror;
  545. msg.client.fetchWebhook(...row.webhook.split('/')).then( webhook => {
  546. var lang = new Lang(row.lang, 'rcscript.webhook');
  547. webhook.send( '**' + ( reason ? lang.get('blocked_reason', reason) : lang.get('blocked') ) + '**' ).catch(log_error).finally( () => {
  548. webhook.delete().catch(log_error);
  549. } );
  550. }, log_error );
  551. }, (dberror, count) => {
  552. if ( dberror ) console.log( '- Error while deleting the webhooks: ' + dberror );
  553. db.run( 'DELETE FROM rcgcdw WHERE wiki = ?', [wiki.href], function (delerror) {
  554. if ( delerror ) {
  555. console.log( '- Error while removing the webhooks: ' + delerror );
  556. msg.replyMsg( 'I added `' + wiki + '` to the blocklist for `' + reason + '` but got an error while removing the webhooks: ' + delerror, {}, true );
  557. return delerror;
  558. }
  559. console.log( '- Successfully removed ' + count + ' webhooks.' );
  560. msg.replyMsg( 'I added `' + wiki + '` to the blocklist for `' + reason + '` and removed ' + count + ' webhooks.', {}, true );
  561. } );
  562. } );
  563. } );
  564. }
  565. if ( args[0] === 'remove' ) {
  566. let input = args.slice(1).join(' ').toLowerCase().trim().replace( /^<\s*(.*?)\s*>$/, '$1' );
  567. let wiki = Wiki.fromInput(input);
  568. if ( !wiki ) return msg.replyMsg( '`' + prefix + 'rcscript block remove <wiki>`', {}, true );
  569. if ( process.env.READONLY ) return msg.replyMsg( lang.get('general.readonly') + '\n' + process.env.invite, {}, true );
  570. return db.run( 'DELETE FROM blocklist WHERE wiki = ?', [wiki.href], function (error) {
  571. if ( error ) {
  572. console.log( '- Error while removing from the blocklist: ' + error );
  573. msg.replyMsg( 'I got an error while removing from the blocklist: ' + error, {}, true );
  574. return error;
  575. }
  576. console.log( '- Successfully removed from the blocklist.' );
  577. msg.replyMsg( 'I removed `' + wiki + '` from the blocklist.', {}, true );
  578. } );
  579. }
  580. if ( args.length ) {
  581. let input = args.join(' ').toLowerCase().trim().replace( /^<\s*(.*?)\s*>$/, '$1' );
  582. let wiki = Wiki.fromInput(input);
  583. if ( !wiki ) return msg.replyMsg( '`' + prefix + 'rcscript block <wiki>`\n`' + prefix + 'rcscript block add <wiki> [<reason>]`\n`' + prefix + 'rcscript block remove <wiki>`', {}, true );
  584. return db.get( 'SELECT reason FROM blocklist WHERE wiki = ?', [wiki.href], function (error, row) {
  585. if ( error ) {
  586. console.log( '- Error while checking the blocklist: ' + error );
  587. msg.replyMsg( 'I got an error while checking the blocklist: ' + error, {}, true );
  588. return error;
  589. }
  590. if ( !row ) return msg.replyMsg( '`' + wiki + '` is currently not on the blocklist.\n`' + prefix + 'rcscript block add <' + wiki + '> [<reason>]`', {}, true );
  591. msg.replyMsg( '`' + wiki + '` is currently on the blocklist ' + ( row.reason ? 'for `' + row.reason + '`' : 'with no reason provided' ) + '.\n`' + prefix + 'rcscript block remove <' + wiki + '>`', {}, true );
  592. } );
  593. }
  594. db.all( 'SELECT wiki, reason FROM blocklist', [], function (error, rows) {
  595. if ( error ) {
  596. console.log( '- Error while checking the blocklist: ' + error );
  597. msg.replyMsg( 'I got an error while checking the blocklist: ' + error, {}, true );
  598. return error;
  599. }
  600. if ( !rows.length ) return msg.replyMsg( 'there are currently no wikis on the blocklist.\n`' + prefix + 'rcscript block add <wiki> [<reason>]`', {}, true );
  601. msg.replyMsg( 'there are currently ' + row.length + ' wikis the blocklist:\n' + rows.map( row => '`' + row.wiki + '` – ' + ( row.reason ? '`' + row.reason + '`' : 'No reason provided.' ) ).join('\n') + '\n`' + prefix + 'rcscript block remove <wiki>`', {split:true}, true );
  602. } );
  603. }
  604. module.exports = {
  605. name: 'rcscript',
  606. everyone: rcscriptExists,
  607. pause: rcscriptExists,
  608. owner: false,
  609. run: cmd_rcscript
  610. };