mqtt events

src/classes/Aliases.ts

@@ -1,16 +1,25 @@
 import type DynamicaAlias from './Alias';
+import MQTT from './MQTT';
 
 export default class Aliases {
   private static aliases: DynamicaAlias[] = [];
 
+  public static mqtt = MQTT.getInstance();
+
   public static add(alias: DynamicaAlias) {
     this.aliases.push(alias);
+    if (this.mqtt) {
+      this.mqtt.publish('dynamica/aliases', this.aliases.length.toString());
+    }
   }
 
   public static remove(activity: string, guildId: string) {
     this.aliases = this.aliases.filter(
       (alias) => !(alias.activity === activity && alias.guildId === guildId)
     );
+    if (this.mqtt) {
+      this.mqtt.publish('dynamica/aliases', this.aliases.length.toString());
+    }
   }
 
   public static get(activity: string, guildId: string) {

src/classes/Events.ts

@@ -1,11 +1,17 @@
 import { Client, ClientEvents } from 'discord.js';
 import type Event from './Event';
+import MQTT from './MQTT';
 
 export default class Events {
   public static events: Event<keyof ClientEvents>[] = [];
 
+  public static mqtt = MQTT.getInstance();
+
   public static register(event: Event<keyof ClientEvents>): void {
     this.events.push(event);
+    if (this.mqtt) {
+      this.mqtt.publish('dynamica/events', this.events.length.toString());
+    }
   }
 
   public static registerListeners(client: Client<false>): void {

src/classes/Guilds.ts

@@ -1,18 +1,27 @@
 import type DynamicaGuild from './Guild';
+import MQTT from './MQTT';
 
 export default class Guilds {
   private static guilds: DynamicaGuild[] = [];
 
+  public static mqtt = MQTT.getInstance();
+
   public static getGuilds(): DynamicaGuild[] {
     return this.guilds;
   }
 
   public static add(guild: DynamicaGuild) {
     this.guilds.push(guild);
+    if (this.mqtt) {
+      this.mqtt.publish('dynamica/guilds', this.guilds.length.toString());
+    }
   }
 
   public static remove(guildId: string) {
     this.guilds = this.guilds.filter((guild) => guild.id !== guildId);
+    if (this.mqtt) {
+      this.mqtt.publish('dynamica/guilds', this.guilds.length.toString());
+    }
   }
 
   public static get(guildId: string) {

src/classes/Primaries.ts

@@ -1,14 +1,23 @@
+import MQTT from './MQTT';
 import type DynamicaPrimary from './Primary';
 
 export default class Primaries {
   public static primaries: DynamicaPrimary[] = [];
 
+  public static mqtt = MQTT.getInstance();
+
   public static add(primary: DynamicaPrimary) {
     this.primaries.push(primary);
+    if (this.mqtt) {
+      this.mqtt.publish('dynamica/primaries', this.primaries.length.toString());
+    }
   }
 
   public static remove(id: string) {
     this.primaries = this.primaries.filter((primary) => primary.id !== id);
+    if (this.mqtt) {
+      this.mqtt.publish('dynamica/primaries', this.primaries.length.toString());
+    }
   }
 
   public static get(id: string | undefined) {

src/classes/Secondaries.ts

@@ -1,16 +1,31 @@
+import MQTT from './MQTT';
 import type DynamicaSecondary from './Secondary';
 
 export default class Secondaries {
   public static secondaries: DynamicaSecondary[] = [];
 
+  public static mqtt = MQTT.getInstance();
+
   public static add(secondary: DynamicaSecondary) {
     this.secondaries.push(secondary);
+    if (this.mqtt) {
+      this.mqtt.publish(
+        'dynamica/secondaries',
+        this.secondaries.length.toString()
+      );
+    }
   }
 
   public static remove(id: string) {
     this.secondaries = this.secondaries.filter(
       (secondary) => secondary.id !== id
     );
+    if (this.mqtt) {
+      this.mqtt.publish(
+        'dynamica/secondaries',
+        this.secondaries.length.toString()
+      );
+    }
   }
 
   public static get(id: string) {

src/commands/AliasCommand.ts

@@ -74,6 +74,7 @@ export default class AliasCommand extends Command {
         )
     );
 
+  // eslint-disable-next-line class-methods-use-this
   response = async (interaction: ChatInputCommandInteraction<CacheType>) => {
     const subcommand = interaction.options.getSubcommand(true);
     // console.log({ subcommand });

src/commands/BitrateCommand.ts

@@ -29,6 +29,7 @@ export default class BitrateCommand extends Command {
         .setName('bitrate')
     );
 
+  // eslint-disable-next-line class-methods-use-this
   response = async (interaction: ChatInputCommandInteraction<CacheType>) => {
     const bitrate = interaction.options.getInteger('bitrate');
     const guildMember = await interaction.guild.members.cache.get(

src/commands/CreateCommand.ts

@@ -31,6 +31,7 @@ export default class CreateCommand extends Command {
         .setRequired(false)
     );
 
+  // eslint-disable-next-line class-methods-use-this
   response = async (interaction: ChatInputCommandInteraction<CacheType>) => {
     const section = interaction.options.getChannel(
       'section'

src/commands/GeneralCommand.ts

@@ -34,6 +34,7 @@ export default class GeneralCommand extends Command {
         .setRequired(true)
     );
 
+  // eslint-disable-next-line class-methods-use-this
   response = async (interaction: ChatInputCommandInteraction<CacheType>) => {
     const name = interaction.options.getString('name', true);
     const channel = interaction.options.getString('primary', true);