ReVanced/revanced-bots
1
0
Fork 0
mirror of https://github.com/ReVanced/revanced-bots.git synced 2026-01-24 11:41:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: run bots in one process

Browse Source
This commit is contained in:
GramingFoxTeam
2022-12-25 15:45:40 +03:00
parent 54ec6232ee
commit d26d533174
5 changed files with 140 additions and 115 deletions
Download Patch File Download Diff File Expand all files Collapse all files

140
bots/reddit/index.js
View File

@@ -9,93 +9,95 @@ import HelperClient from '../../client/index.js';
const __filename = fileURLToPath(import.meta.url);
const __dirname = dirname(__filename);
const config = JSON.parse(readFileSync('../config.json', 'utf-8'));
export default async () => {
const config = JSON.parse(readFileSync('./config.json', 'utf-8'));
const client = new Snoowrap(config.reddit);
const helper = new HelperClient(config);
const client = new Snoowrap(config.reddit);
const helper = new HelperClient(config);
helper.connect();
helper.connect();
client.commands = new Map();
client.commands = new Map();
const commandsPath = join(__dirname, 'commands');
const commandFiles = readdirSync(commandsPath).filter((file) =>
file.endsWith('.js')
);
const commandsPath = join(__dirname, 'commands');
const commandFiles = readdirSync(commandsPath).filter((file) =>
file.endsWith('.js')
);
for (const file of commandFiles) {
const filePath = join(commandsPath, file);
const command = (await import(`file://${filePath}`)).default;
if ('command' in command && 'execute' in command) {
client.commands.set(command.command, command);
} else {
console.log(
`[WARNING] The command at ${filePath} is missing a required "data" or "execute" property.`
);
for (const file of commandFiles) {
const filePath = join(commandsPath, file);
const command = (await import(`file://${filePath}`)).default;
if ('command' in command && 'execute' in command) {
client.commands.set(command.command, command);
} else {
console.log(
`[WARNING] The command at ${filePath} is missing a required "data" or "execute" property.`
);
}
}
}
const checkedItems = [];
const checkedItems = [];
const args = {
subreddit: 'revancedapp',
limit: 10,
pollTime: 5000
};
const args = {
subreddit: 'revancedapp',
limit: 10,
pollTime: 5000
};
const comments = new CommentStream(client, args);
const comments = new CommentStream(client, args);
const posts = new SubmissionStream(client, args);
const posts = new SubmissionStream(client, args);
comments.on('item', async (item) => {
await handleItem(item, false);
});
comments.on('item', async (item) => {
await handleItem(item, false);
});
posts.on('item', async (item) => {
await handleItem(item, true);
});
posts.on('item', async (item) => {
await handleItem(item, true);
});
async function handleItem(item, isPost) {
// The "skill issue (refresh)" incident.
if (item.author.name === config.reddit.username) return;
async function handleItem(item, isPost) {
// The "skill issue (refresh)" incident.
if (item.author.name === config.reddit.username) return;
if (checkedItems.includes(item.id)) return;
checkedItems.push(item.id);
if (isPost) {
// It's a post, we have to also send post body.
helper.scanText(item.title.toLowerCase(), `post/${item.id}`);
helper.scanText(item.selftext.toLowerCase(), `post/${item.id}`);
} else {
const body = item.body.toLowerCase();
if (body.startsWith(`u/${config.reddit.username.toLowerCase()}`)) {
const args = body
.replace(`u/${config.reddit.username.toLowerCase()} `, '')
.split(' ');
const command = args[0];
args.shift();
if (checkedItems.includes(item.id)) return;
checkedItems.push(item.id);
if (isPost) {
// It's a post, we have to also send post body.
helper.scanText(item.title.toLowerCase(), `post/${item.id}`);
helper.scanText(item.selftext.toLowerCase(), `post/${item.id}`);
} else {
const body = item.body.toLowerCase();
if (body.startsWith(`u/${config.reddit.username.toLowerCase()}`)) {
const args = body
.replace(`u/${config.reddit.username.toLowerCase()} `, '')
.split(' ');
const command = args[0];
args.shift();
if (!client.commands.get(command)) return;
if (!client.commands.get(command)) return;
await client.commands.get(command).execute(client, helper, item, args);
} else helper.scanText(item.body.toLowerCase(), `comment/${item.id}`);
await client.commands.get(command).execute(client, helper, item, args);
} else helper.scanText(item.body.toLowerCase(), `comment/${item.id}`);
}
}
}
// The ReVanced Helper events.
// The ReVanced Helper events.
const helperEventsPath = join(__dirname, 'events/helper');
const helperEventFiles = readdirSync(helperEventsPath).filter((file) =>
file.endsWith('.js')
);
const helperEventsPath = join(__dirname, 'events/helper');
const helperEventFiles = readdirSync(helperEventsPath).filter((file) =>
file.endsWith('.js')
);
for (const file of helperEventFiles) {
const filePath = join(helperEventsPath, file);
const event = (await import(`file://${filePath}`)).default;
if (event.once) {
helper.once(event.name, (...args) =>
event.execute(client, config, ...args)
);
} else {
helper.on(event.name, (...args) => event.execute(client, config, ...args));
for (const file of helperEventFiles) {
const filePath = join(helperEventsPath, file);
const event = (await import(`file://${filePath}`)).default;
if (event.once) {
helper.once(event.name, (...args) =>
event.execute(client, config, ...args)
);
} else {
helper.on(event.name, (...args) => event.execute(client, config, ...args));
}
}
}
}