summaryrefslogtreecommitdiff
path: root/src/modules
diff options
context:
space:
mode:
Diffstat (limited to 'src/modules')
-rw-r--r--src/modules/custom_command.hpp96
-rw-r--r--src/modules/event.hpp145
-rw-r--r--src/modules/help.hpp31
-rw-r--r--src/modules/join.hpp91
-rw-r--r--src/modules/massping.hpp62
-rw-r--r--src/modules/notify.hpp131
-rw-r--r--src/modules/ping.hpp59
-rw-r--r--src/modules/timer.hpp112
8 files changed, 0 insertions, 727 deletions
diff --git a/src/modules/custom_command.hpp b/src/modules/custom_command.hpp
deleted file mode 100644
index 50b3692..0000000
--- a/src/modules/custom_command.hpp
+++ /dev/null
@@ -1,96 +0,0 @@
-#pragma once
-
-#include <string>
-#include <variant>
-#include <vector>
-
-#include "../bundle.hpp"
-#include "../commands/command.hpp"
-#include "../commands/response_error.hpp"
-
-namespace bot {
- namespace mod {
- class CustomCommand : public command::Command {
- std::string get_name() const override { return "scmd"; }
-
- schemas::PermissionLevel get_permission_level() const override {
- return schemas::PermissionLevel::MODERATOR;
- }
-
- std::vector<std::string> get_subcommand_ids() const override {
- return {"new", "remove"};
- }
-
- std::variant<std::vector<std::string>, std::string> run(
- const InstanceBundle &bundle,
- const command::Request &request) const override {
- if (!request.subcommand_id.has_value()) {
- throw ResponseException<NOT_ENOUGH_ARGUMENTS>(
- request, bundle.localization, command::SUBCOMMAND);
- }
-
- const std::string &subcommand_id = request.subcommand_id.value();
-
- if (!request.message.has_value()) {
- throw ResponseException<ResponseError::NOT_ENOUGH_ARGUMENTS>(
- request, bundle.localization, command::CommandArgument::NAME);
- }
-
- const std::string &message = request.message.value();
- std::vector<std::string> s = utils::string::split_text(message, ' ');
-
- std::string name = s[0];
- s.erase(s.begin());
-
- pqxx::work work(request.conn);
- pqxx::result cmds = work.exec(
- "SELECT id FROM custom_commands WHERE name = '" + name +
- "' AND channel_id = " + std::to_string(request.channel.get_id()));
-
- if (subcommand_id == "new") {
- if (!cmds.empty()) {
- throw ResponseException<ResponseError::NAMESAKE_CREATION>(
- request, bundle.localization, name);
- }
-
- if (s.empty()) {
- throw ResponseException<ResponseError::NOT_ENOUGH_ARGUMENTS>(
- request, bundle.localization,
- command::CommandArgument::MESSAGE);
- }
-
- std::string m = utils::string::str(s.begin(), s.end(), ' ');
-
- work.exec(
- "INSERT INTO custom_commands(channel_id, name, message) VALUES "
- "(" +
- std::to_string(request.channel.get_id()) + ", '" + name +
- "', '" + m + "')");
- work.commit();
-
- return bundle.localization
- .get_formatted_line(request, loc::LineId::CustomcommandNew,
- {name})
- .value();
- } else if (subcommand_id == "remove") {
- if (cmds.empty()) {
- throw ResponseException<ResponseError::NOT_FOUND>(
- request, bundle.localization, name);
- }
-
- work.exec("DELETE FROM custom_commands WHERE id = " +
- std::to_string(cmds[0][0].as<int>()));
- work.commit();
-
- return bundle.localization
- .get_formatted_line(request, loc::LineId::CustomcommandDelete,
- {name})
- .value();
- }
-
- throw ResponseException<ResponseError::SOMETHING_WENT_WRONG>(
- request, bundle.localization);
- }
- };
- }
-}
diff --git a/src/modules/event.hpp b/src/modules/event.hpp
deleted file mode 100644
index 4242f07..0000000
--- a/src/modules/event.hpp
+++ /dev/null
@@ -1,145 +0,0 @@
-#pragma once
-
-#include <string>
-#include <variant>
-#include <vector>
-
-#include "../bundle.hpp"
-#include "../commands/command.hpp"
-#include "../commands/response_error.hpp"
-#include "../schemas/stream.hpp"
-
-namespace bot {
- namespace mod {
- class Event : public command::Command {
- std::string get_name() const override { return "event"; }
-
- schemas::PermissionLevel get_permission_level() const override {
- return schemas::PermissionLevel::MODERATOR;
- }
-
- std::vector<std::string> get_subcommand_ids() const override {
- return {"on", "off"};
- }
-
- std::variant<std::vector<std::string>, std::string> run(
- const InstanceBundle &bundle,
- const command::Request &request) const override {
- if (!request.subcommand_id.has_value()) {
- throw ResponseException<NOT_ENOUGH_ARGUMENTS>(
- request, bundle.localization, command::SUBCOMMAND);
- }
-
- const std::string &subcommand_id = request.subcommand_id.value();
-
- if (!request.message.has_value()) {
- throw ResponseException<ResponseError::NOT_ENOUGH_ARGUMENTS>(
- request, bundle.localization, command::CommandArgument::TARGET);
- }
-
- const std::string &message = request.message.value();
- std::vector<std::string> s = utils::string::split_text(message, ' ');
-
- std::string target;
- schemas::EventType type;
-
- std::vector<std::string> target_and_type =
- utils::string::split_text(s[0], ':');
-
- if (target_and_type.size() != 2) {
- throw ResponseException<ResponseError::INCORRECT_ARGUMENT>(
- request, bundle.localization, s[0]);
- }
-
- s.erase(s.begin());
-
- target = target_and_type[0];
- type = schemas::string_to_event_type(target_and_type[1]);
-
- std::string t = target_and_type[0] + ":" + target_and_type[1];
-
- auto channels = bundle.helix_client.get_users({target});
- api::twitch::schemas::User channel;
-
- if (channels.empty() && type != schemas::EventType::CUSTOM) {
- throw ResponseException<ResponseError::NOT_FOUND>(
- request, bundle.localization, t);
- }
-
- pqxx::work work(request.conn);
- std::string query;
-
- if (type != schemas::CUSTOM) {
- channel = channels[0];
-
- query = "SELECT id FROM events WHERE channel_id = " +
- std::to_string(request.channel.get_id()) +
- " AND target_alias_id = " + std::to_string(channel.id) +
- " AND event_type = " + std::to_string(type);
- } else {
- query = "SELECT id FROM events WHERE channel_id = " +
- std::to_string(request.channel.get_id()) +
- " AND custom_alias_id = '" + target +
- "' AND event_type = " + std::to_string(type);
- }
-
- pqxx::result event = work.exec(query);
-
- if (subcommand_id == "on") {
- if (!event.empty()) {
- throw ResponseException<ResponseError::NAMESAKE_CREATION>(
- request, bundle.localization, t);
- }
-
- if (s.empty()) {
- throw ResponseException<ResponseError::NOT_ENOUGH_ARGUMENTS>(
- request, bundle.localization,
- command::CommandArgument::MESSAGE);
- }
-
- std::string m = utils::string::str(s.begin(), s.end(), ' ');
-
- if (type != schemas::CUSTOM) {
- query =
- "INSERT INTO events (channel_id, target_alias_id, "
- "event_type, "
- "message) VALUES (" +
- std::to_string(request.channel.get_id()) + ", " +
- std::to_string(channel.id) + ", " + std::to_string(type) +
- ", '" + m + "')";
- } else {
- query =
- "INSERT INTO events (channel_id, custom_alias_id, "
- "event_type, "
- "message) VALUES (" +
- std::to_string(request.channel.get_id()) + ", '" + target +
- "', " + std::to_string(type) + ", '" + m + "')";
- }
-
- work.exec(query);
- work.commit();
-
- return bundle.localization
- .get_formatted_line(request, loc::LineId::EventOn, {t})
- .value();
- } else if (subcommand_id == "off") {
- if (event.empty()) {
- throw ResponseException<ResponseError::NOT_FOUND>(
- request, bundle.localization, t);
- }
-
- work.exec("DELETE FROM events WHERE id = " +
- std::to_string(event[0][0].as<int>()));
- work.commit();
-
- return bundle.localization
- .get_formatted_line(request, loc::LineId::EventOff, {t})
- .value();
- }
-
- throw ResponseException<ResponseError::SOMETHING_WENT_WRONG>(
- request, bundle.localization);
- }
- };
- }
-}
diff --git a/src/modules/help.hpp b/src/modules/help.hpp
deleted file mode 100644
index 13af228..0000000
--- a/src/modules/help.hpp
+++ /dev/null
@@ -1,31 +0,0 @@
-#pragma once
-
-#include <string>
-#include <variant>
-#include <vector>
-
-#include "../bundle.hpp"
-#include "../commands/command.hpp"
-#include "../commands/response_error.hpp"
-
-namespace bot {
- namespace mod {
- class Help : public command::Command {
- std::string get_name() const override { return "help"; }
-
- std::variant<std::vector<std::string>, std::string> run(
- const InstanceBundle &bundle,
- const command::Request &request) const override {
- if (!bundle.configuration.url.help.has_value()) {
- throw ResponseException<ResponseError::ILLEGAL_COMMAND>(
- request, bundle.localization);
- }
-
- return bundle.localization
- .get_formatted_line(request, loc::LineId::HelpResponse,
- {*bundle.configuration.url.help})
- .value();
- }
- };
- }
-}
diff --git a/src/modules/join.hpp b/src/modules/join.hpp
deleted file mode 100644
index 16e8b4a..0000000
--- a/src/modules/join.hpp
+++ /dev/null
@@ -1,91 +0,0 @@
-#pragma once
-
-#include <pqxx/pqxx>
-#include <string>
-#include <variant>
-#include <vector>
-
-#include "../bundle.hpp"
-#include "../commands/command.hpp"
-#include "../schemas/channel.hpp"
-
-namespace bot {
- namespace mod {
- class Join : public command::Command {
- std::string get_name() const override { return "join"; }
-
- std::variant<std::vector<std::string>, std::string> run(
- const InstanceBundle &bundle,
- const command::Request &request) const override {
- if (!bundle.configuration.commands.join_allowed) {
- std::string owner = "";
-
- if (bundle.configuration.owner.name.has_value()) {
- owner = " " + bundle.localization
- .get_formatted_line(
- request, loc::LineId::MsgOwner,
- {*bundle.configuration.owner.name})
- .value();
- }
-
- return bundle.localization
- .get_formatted_line(request, loc::LineId::JoinNotAllowed,
- {owner})
- .value();
- }
-
- if (!bundle.configuration.commands.join_allow_from_other_chats &&
- request.channel.get_alias_name() !=
- bundle.irc_client.get_bot_username()) {
- return bundle.localization
- .get_formatted_line(request, loc::LineId::JoinFromOtherChat,
- {bundle.irc_client.get_bot_username()})
- .value();
- }
-
- pqxx::work work(request.conn);
-
- pqxx::result channels =
- work.exec("SELECT * FROM channels WHERE alias_id = " +
- std::to_string(request.user.get_alias_id()));
-
- if (!channels.empty()) {
- schemas::Channel channel(channels[0]);
-
- if (channel.get_opted_out_at().has_value()) {
- work.exec("UPDATE channels SET opted_out_at = null WHERE id = " +
- std::to_string(channel.get_id()));
- work.commit();
-
- bundle.irc_client.join(channel.get_alias_name());
-
- return bundle.localization
- .get_formatted_line(request, loc::LineId::JoinRejoined, {})
- .value();
- }
-
- return bundle.localization
- .get_formatted_line(request, loc::LineId::JoinAlreadyIn, {})
- .value();
- }
-
- work.exec("INSERT INTO channels(alias_id, alias_name) VALUES (" +
- std::to_string(request.user.get_alias_id()) + ", '" +
- request.user.get_alias_name() + "')");
- work.commit();
-
- bundle.irc_client.join(request.user.get_alias_name());
- bundle.irc_client.say(
- request.user.get_alias_name(),
- bundle.localization
- .get_formatted_line(request, loc::LineId::JoinResponseInChat,
- {})
- .value());
-
- return bundle.localization
- .get_formatted_line(request, loc::LineId::JoinResponse, {})
- .value();
- }
- };
- }
-}
diff --git a/src/modules/massping.hpp b/src/modules/massping.hpp
deleted file mode 100644
index 2957e34..0000000
--- a/src/modules/massping.hpp
+++ /dev/null
@@ -1,62 +0,0 @@
-#pragma once
-
-#include <string>
-#include <variant>
-#include <vector>
-
-#include "../bundle.hpp"
-#include "../commands/command.hpp"
-
-namespace bot {
- namespace mod {
- class Massping : public command::Command {
- std::string get_name() const override { return "massping"; }
-
- schemas::PermissionLevel get_permission_level() const override {
- return schemas::PermissionLevel::MODERATOR;
- }
-
- int get_delay_seconds() const override { return 1; }
-
- std::variant<std::vector<std::string>, std::string> run(
- const InstanceBundle &bundle,
- const command::Request &request) const override {
- auto chatters = bundle.helix_client.get_chatters(
- request.channel.get_alias_id(), bundle.irc_client.get_bot_id());
-
- std::string m;
-
- if (request.message.has_value()) {
- m = request.message.value() + " ·";
- }
-
- std::string base = "📣 " + m + " ";
- std::vector<std::string> msgs = {""};
- int index = 0;
-
- for (const auto &chatter : chatters) {
- const std::string &current_msg = msgs.at(index);
- std::string x = "@" + chatter.login;
-
- if (base.length() + current_msg.length() + 1 + x.length() >= 500) {
- index += 1;
- }
-
- if (index > msgs.size() - 1) {
- msgs.push_back(x);
- } else {
- msgs[index] = current_msg + " " + x;
- }
- }
-
- std::vector<std::string> msgs2;
-
- for (const auto &m : msgs) {
- msgs2.push_back(base + m);
- }
-
- return msgs2;
- }
- };
- }
-}
diff --git a/src/modules/notify.hpp b/src/modules/notify.hpp
deleted file mode 100644
index 3587e73..0000000
--- a/src/modules/notify.hpp
+++ /dev/null
@@ -1,131 +0,0 @@
-#pragma once
-
-#include <string>
-#include <variant>
-#include <vector>
-
-#include "../bundle.hpp"
-#include "../commands/command.hpp"
-#include "../commands/response_error.hpp"
-#include "../schemas/stream.hpp"
-
-namespace bot {
- namespace mod {
- class Notify : public command::Command {
- std::string get_name() const override { return "notify"; }
-
- std::vector<std::string> get_subcommand_ids() const override {
- return {"sub", "unsub"};
- }
-
- std::variant<std::vector<std::string>, std::string> run(
- const InstanceBundle &bundle,
- const command::Request &request) const override {
- if (!request.subcommand_id.has_value()) {
- throw ResponseException<NOT_ENOUGH_ARGUMENTS>(
- request, bundle.localization, command::SUBCOMMAND);
- }
-
- const std::string &subcommand_id = request.subcommand_id.value();
-
- if (!request.message.has_value()) {
- throw ResponseException<ResponseError::NOT_ENOUGH_ARGUMENTS>(
- request, bundle.localization, command::CommandArgument::TARGET);
- }
-
- const std::string &message = request.message.value();
- std::vector<std::string> s = utils::string::split_text(message, ' ');
-
- std::string target;
- schemas::EventType type;
-
- std::vector<std::string> target_and_type =
- utils::string::split_text(s[0], ':');
-
- if (target_and_type.size() != 2) {
- throw ResponseException<ResponseError::INCORRECT_ARGUMENT>(
- request, bundle.localization, s[0]);
- }
-
- s.erase(s.begin());
-
- target = target_and_type[0];
- type = schemas::string_to_event_type(target_and_type[1]);
-
- std::string t = target_and_type[0] + ":" + target_and_type[1];
-
- auto channels = bundle.helix_client.get_users({target});
- api::twitch::schemas::User channel;
-
- if (channels.empty() && type != schemas::EventType::CUSTOM) {
- throw ResponseException<ResponseError::NOT_FOUND>(
- request, bundle.localization, t);
- }
-
- pqxx::work work(request.conn);
- std::string query;
-
- if (type != schemas::CUSTOM) {
- channel = channels[0];
-
- query = "SELECT id FROM events WHERE channel_id = " +
- std::to_string(request.channel.get_id()) +
- " AND target_alias_id = " + std::to_string(channel.id) +
- " AND event_type = " + std::to_string(type);
- } else {
- query = "SELECT id FROM events WHERE channel_id = " +
- std::to_string(request.channel.get_id()) +
- " AND custom_alias_id = '" + target +
- "' AND event_type = " + std::to_string(type);
- }
-
- pqxx::result events = work.exec(query);
-
- if (events.empty()) {
- throw ResponseException<ResponseError::NOT_FOUND>(
- request, bundle.localization, t);
- }
-
- pqxx::row event = events[0];
-
- pqxx::result subs =
- work.exec("SELECT id FROM event_subscriptions WHERE event_id = " +
- std::to_string(event[0].as<int>()) + " AND user_id = " +
- std::to_string(request.user.get_id()));
-
- if (subcommand_id == "sub") {
- if (!subs.empty()) {
- throw ResponseException<ResponseError::NAMESAKE_CREATION>(
- request, bundle.localization, t);
- }
-
- work.exec(
- "INSERT INTO event_subscriptions(event_id, user_id) VALUES (" +
- std::to_string(event[0].as<int>()) + ", " +
- std::to_string(request.user.get_id()));
- work.commit();
-
- return bundle.localization
- .get_formatted_line(request, loc::LineId::NotifySub, {t})
- .value();
- } else if (subcommand_id == "unsub") {
- if (subs.empty()) {
- throw ResponseException<ResponseError::NOT_FOUND>(
- request, bundle.localization, t);
- }
-
- work.exec("DELETE FROM event_subscriptions WHERE id = " +
- std::to_string(subs[0][0].as<int>()));
- work.commit();
-
- return bundle.localization
- .get_formatted_line(request, loc::LineId::NotifyUnsub, {t})
- .value();
- }
-
- throw ResponseException<ResponseError::SOMETHING_WENT_WRONG>(
- request, bundle.localization);
- }
- };
- }
-}
diff --git a/src/modules/ping.hpp b/src/modules/ping.hpp
deleted file mode 100644
index 836917d..0000000
--- a/src/modules/ping.hpp
+++ /dev/null
@@ -1,59 +0,0 @@
-#pragma once
-
-#include <sys/resource.h>
-#include <sys/types.h>
-#include <unistd.h>
-
-#include <chrono>
-#include <string>
-#include <variant>
-#include <vector>
-
-#include "../bundle.hpp"
-#include "../commands/command.hpp"
-#include "../utils/chrono.hpp"
-
-namespace bot {
- namespace mod {
- class Ping : public command::Command {
- std::string get_name() const override { return "ping"; }
-
- std::variant<std::vector<std::string>, std::string> run(
- const InstanceBundle &bundle,
- const command::Request &request) const override {
- auto now = std::chrono::steady_clock::now();
- auto duration = now - START_TIME;
- auto seconds =
- std::chrono::duration_cast<std::chrono::seconds>(duration);
- std::string uptime = utils::chrono::format_timestamp(seconds.count());
-
- struct rusage usage;
- getrusage(RUSAGE_SELF, &usage);
-
- int used_memory = usage.ru_maxrss / 1024;
-
- std::string cpp_info;
-
-#ifdef __cplusplus
- cpp_info.append("C++" + std::to_string(__cplusplus).substr(2, 2));
-#endif
-
-#ifdef __VERSION__
- cpp_info.append(" (gcc " +
- bot::utils::string::split_text(__VERSION__, ' ')[0] +
- ")");
-#endif
-
- if (!cpp_info.empty()) {
- cpp_info.append(" · ");
- }
-
- return bundle.localization
- .get_formatted_line(
- request, loc::LineId::PingResponse,
- {cpp_info, uptime, std::to_string(used_memory)})
- .value();
- }
- };
- }
-}
diff --git a/src/modules/timer.hpp b/src/modules/timer.hpp
deleted file mode 100644
index 36c3982..0000000
--- a/src/modules/timer.hpp
+++ /dev/null
@@ -1,112 +0,0 @@
-#pragma once
-
-#include <string>
-#include <variant>
-#include <vector>
-
-#include "../bundle.hpp"
-#include "../commands/command.hpp"
-#include "../commands/response_error.hpp"
-
-namespace bot {
- namespace mod {
- class Timer : public command::Command {
- std::string get_name() const override { return "timer"; }
-
- schemas::PermissionLevel get_permission_level() const override {
- return schemas::PermissionLevel::MODERATOR;
- }
-
- std::vector<std::string> get_subcommand_ids() const override {
- return {"new", "remove"};
- }
-
- std::variant<std::vector<std::string>, std::string> run(
- const InstanceBundle &bundle,
- const command::Request &request) const override {
- if (!request.subcommand_id.has_value()) {
- throw ResponseException<NOT_ENOUGH_ARGUMENTS>(
- request, bundle.localization, command::SUBCOMMAND);
- }
-
- const std::string &subcommand_id = request.subcommand_id.value();
-
- if (!request.message.has_value()) {
- throw ResponseException<ResponseError::NOT_ENOUGH_ARGUMENTS>(
- request, bundle.localization, command::CommandArgument::NAME);
- }
-
- const std::string &message = request.message.value();
- std::vector<std::string> s = utils::string::split_text(message, ' ');
-
- std::string name = s[0];
- s.erase(s.begin());
-
- pqxx::work work(request.conn);
- pqxx::result timers = work.exec(
- "SELECT id FROM timers WHERE name = '" + name +
- "' AND channel_id = " + std::to_string(request.channel.get_id()));
-
- if (subcommand_id == "new") {
- if (!timers.empty()) {
- throw ResponseException<ResponseError::NAMESAKE_CREATION>(
- request, bundle.localization, name);
- }
-
- if (s.empty()) {
- throw ResponseException<ResponseError::NOT_ENOUGH_ARGUMENTS>(
- request, bundle.localization,
- command::CommandArgument::INTERVAL);
- }
-
- int interval_s;
-
- try {
- interval_s = std::stoi(s[0]);
- } catch (std::exception e) {
- throw ResponseException<ResponseError::INCORRECT_ARGUMENT>(
- request, bundle.localization, s[0]);
- }
-
- s.erase(s.begin());
-
- if (s.empty()) {
- throw ResponseException<ResponseError::NOT_ENOUGH_ARGUMENTS>(
- request, bundle.localization,
- command::CommandArgument::MESSAGE);
- }
-
- std::string m = utils::string::str(s.begin(), s.end(), ' ');
-
- work.exec(
- "INSERT INTO timers(channel_id, name, message, interval_sec) "
- "VALUES "
- "(" +
- std::to_string(request.channel.get_id()) + ", '" + name +
- "', '" + m + "', " + std::to_string(interval_s) + ")");
- work.commit();
-
- return bundle.localization
- .get_formatted_line(request, loc::LineId::TimerNew, {name})
- .value();
- } else if (subcommand_id == "remove") {
- if (timers.empty()) {
- throw ResponseException<ResponseError::NOT_FOUND>(
- request, bundle.localization, name);
- }
-
- work.exec("DELETE FROM timers WHERE id = " +
- std::to_string(timers[0][0].as<int>()));
- work.commit();
-
- return bundle.localization
- .get_formatted_line(request, loc::LineId::TimerDelete, {name})
- .value();
- }
-
- throw ResponseException<ResponseError::SOMETHING_WENT_WRONG>(
- request, bundle.localization);
- }
- };
- }
-}
generated by cgit v1.2.3 (git 2.39.1) at 2025-12-13 22:56:18 +0000