rcscript.js 33 KB

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