basic irc plugin

src/IrcPlugin.cpp

@@ -0,0 +1,118 @@
+#include "IrcPlugin.h"
+
+IrcPlugin::IrcPlugin(IrcConfig cfg)
+{
+    applyConfig(cfg);
+}
+
+void IrcPlugin::applyConfig(IrcConfig cfg)
+{
+    server = String(cfg.server);
+    port = cfg.port;
+    nick = String(cfg.nickname);
+    user = String(cfg.user);
+}
+
+void IrcPlugin::applyConfigFromFile(const char *fileName)
+{
+    IrcConfigJson configFile;
+    configFile.fromFile(fileName);
+    if (configFile.valid)
+    {
+        PRINT_MSG(Serial, "MQTT", "apply config from file");
+        applyConfig(configFile);
+    }
+}
+
+void IrcPlugin::activate(Scheduler *scheduler)
+{
+    applyConfigFromFile("/ircConfig.json");
+    client = new IRCClient(server.c_str(), port, wifiClient);
+    client->setCallback(bind(&IrcPlugin::callback, this, _1));
+    client->setSentCallback(bind(&IrcPlugin::debugSentCallback, this, _1));
+
+    String channel = "#illucat";
+
+    subscribe("irc/connect", bind(&IrcPlugin::connect, this));
+    subscribe("irc/join", bind(&IrcPlugin::join, this, _1));
+    subscribe("irc/sendMessage", bind(&IrcPlugin::sendMessage, this, channel, _1));
+
+    //enableConnectTask(scheduler);
+    enableProcessTask(scheduler);
+    PRINT_MSG(Serial, "MQTT", "plugin activated");
+}
+
+void IrcPlugin::enableConnectTask(Scheduler *scheduler)
+{
+    connectTask.set(TASK_SECOND * 5, TASK_FOREVER, bind(&IrcPlugin::connect, this));
+    scheduler->addTask(connectTask);
+    connectTask.enable();
+}
+
+void IrcPlugin::enableProcessTask(Scheduler *scheduler)
+{
+    processTask.set(TASK_MILLISECOND * 5, TASK_FOREVER, bind(&IRCClient::loop, client));
+    scheduler->addTask(processTask);
+    processTask.enable();
+}
+
+void IrcPlugin::connect()
+{
+    if (!client->connected())
+    {
+        PRINT_MSG(Serial, "IRC", String("Attempting connection to " + server).c_str());
+        if (client->connect(nick.c_str(), user.c_str()))
+        {
+            PRINT_MSG(Serial, "IRC", "connected");
+        }
+        else
+        {
+            PRINT_MSG(Serial, "IRC", "failed... ");
+        }
+        return;
+    }
+}
+
+void IrcPlugin::join(String channel)
+{
+    if (client->connected())
+    {
+
+        String joinCmd = "JOIN :" + channel + "\r\n";
+        wifiClient.print(joinCmd.c_str());
+        PRINT_MSG(Serial, "IRC", joinCmd.c_str());
+    }
+}
+
+void IrcPlugin::sendMessage(String to, String msg)
+{
+    client->sendMessage(to, msg);
+}
+
+void IrcPlugin::callback(IRCMessage ircMessage)
+{
+
+    String message("<" + ircMessage.nick + "> " + ircMessage.text);
+    publish("irc/log", message);
+    PRINT_MSG(Serial, "IRC", message.c_str());
+
+    // PRIVMSG ignoring CTCP messages
+    /* if (ircMessage.command == "PRIVMSG" && ircMessage.text[0] != '\001')
+    {
+        String message("<" + ircMessage.nick + "> " + ircMessage.text);
+        PRINT_MSG(Serial, "IRC", message.c_str());
+
+        if (ircMessage.nick == REPLY_TO)
+        {
+            client->sendMessage(ircMessage.nick, "Hi " + ircMessage.nick + "! I'm your IRC bot.");
+        }
+
+        return;
+    } */
+    PRINT_MSG(Serial, "IRC", ircMessage.original.c_str());
+}
+
+void IrcPlugin::debugSentCallback(String data)
+{
+    PRINT_MSG(Serial, "IRC", data.c_str());
+}