Add queue system and improvements

ThePedroo · ThePedroo · commit 456f2130b1d8 · 2022-10-17T19:46:27.000-03:00
This commits adds the new queue system and the new PR/issue template md file.
diff --git a/.github/ISSUE_TEMPLATE/bug-report-template.md b/.github/ISSUE_TEMPLATE/bug-report-template.md
@@ -0,0 +1,35 @@
+---
+name: Bug report
+about: Help the project be more stable reporting bugs
+title: '[bug]: '
+labels: bug
+assignees: ''
+---
+
+## What's wrong?
+
+Inform here what happened.
+
+## Reproducing
+
+Let us know how to reproduce this bug.
+
+## Crashes (debug)
+
+If the bot crashed, please debug it with gdb, following the example below:
+
+```console
+$ gdb ./ConcordBot
+```
+
+Then, press `c` and `enter`, and now that you are on GDB's shell, please use the command `run`.
+
+You will need to reproduce the crash, and when you successfully reproduce it and crashes the bot, please use the command `bt` and send what you got from the response here.
+
+## Screenshots
+
+If possible, let a screenshot here, if not, please remove this section.
+
+## Final
+
+- [ ] I confirm that I've tried reproducing this bug on the latest release and I'm still able to reproduce
diff --git a/.github/PULL_REQUEST_TEMPLATE.md b/.github/PULL_REQUEST_TEMPLATE.md
@@ -0,0 +1,15 @@
+## Changes
+
+Here explain what changes have you made in the bot.
+
+## Why?
+
+Why have you made this PR?
+
+## Tested?
+
+If you agree that you have tested all systems that your changes affected, please type "I agree that I tested all systems that my changes affected.": `Type here`
+
+## Testing
+
+Please explain here how you made the testing, please be as specific as possible.
diff --git a/README.md b/README.md
@@ -11,7 +11,7 @@ There are currently two ways of using it. Compiling the source code and using it
 * 1 - Use `git clone https://github.com/ThePedroo/C-Music-Discord-Bot.git` to get the bot files.
 * 2 - Install clang / GCC.
 * 3 - Install and build [Concord](https://github.com/Cogmasters/concord).
-* Info. Dont't have a [Lavalink](https://github.com/freyacodes/Lavalink) node? Setup it on [replit.com](https://replit.com/).
+* Info. Don't have a [Lavalink](https://github.com/freyacodes/Lavalink) node? Setup it on [replit.com](https://replit.com/).
 * 4 - Install sqlite3: `sudo apt install sqlite3`
 
 If you did everything correct, use: 
@@ -23,7 +23,7 @@ Done, now you will have a compiled version of the music bot for your architectur
 
 ## Pre-compiled 
 
-* 1 - Go to Github releases and download the `Concord-x86_64` file, after it run it.
+* 1 - Go to Github releases and download the pre-compiled file that matches your CPU architecute, after it runs it.
 
 Done! Yeah, it's that simple to use it. ^^
 
diff --git a/lavalink.c b/lavalink.c
@@ -32,7 +32,8 @@ void on_cycle(struct discord *client) {
 }
 
 void on_text(void *data, struct websockets *ws, struct ws_info *info, const char *text, size_t len) {
-  (void) ws; (void) info;
+  (void)ws; (void)info;
+  printf("%s\n", text);
 
   jsmn_parser parser;
   jsmntok_t tokens[1024];
@@ -106,39 +107,224 @@ void on_text(void *data, struct websockets *ws, struct ws_info *info, const char
         }
         return;
       } else {
-        struct discord_embed embed[] = {
-          {
-            .description = "The music has ended.",
-            .image =
-              &(struct discord_embed_image){
-                .url = "https://raw.githubusercontent.com/Cogmasters/concord/master/docs/static/social-preview.png",
-              },
-            .footer =
-              &(struct discord_embed_footer){
-                .text = "Powered by Concord",
-                .icon_url = "https://raw.githubusercontent.com/Cogmasters/concord/master/docs/static/concord-small.png",
+        long long channelID = sqlite3_column_int64(stmt, 0);
+
+        if (sqlite3_finalize(stmt) != SQLITE_OK) {
+          log_fatal("[SQLITE] Error while executing function sqlite3_finalize.");
+          return;
+        }
+
+        query = sqlite3_mprintf("SELECT array FROM guild_queue WHERE guild_id = %.*s;", (int)guildId->v.len, text + guildId->v.pos);
+        rc = sqlite3_prepare_v2(db, query, -1, &stmt, NULL);
+
+        sqlite3_free(query);
+
+        (rc = sqlite3_step(stmt));
+
+        log_warn("%s\n", sqlite3_column_text(stmt, 0));
+
+        if (rc == SQLITE_ROW) {
+          char json[1024];
+          snprintf(json, sizeof(json), "%s", sqlite3_column_text(stmt, 0));
+
+          jsmn_parser parser;
+          jsmntok_t tokens[1024];
+
+          jsmn_init(&parser);
+          int r = jsmn_parse(&parser, json, sizeof(json), tokens, sizeof(tokens));
+
+          if (r < 0) {
+            log_error("[JSMNF] Failed to parse JSON.");
+            return;
+          }
+
+          jsmnf_loader loader;
+          jsmnf_pair pairs[1024];
+
+          jsmnf_init(&loader);
+          r = jsmnf_load(&loader, json, tokens, parser.toknext, pairs, 1024);
+
+          if (r < 0) {
+            log_error("[JSMNF] Failed to load JSMNF.");
+            return;
+          }
+
+          if (sqlite3_finalize(stmt) != SQLITE_OK) {
+            log_fatal("[SQLITE] Error while executing function sqlite3_finalize.");
+            return;
+          }
+
+          jsmnf_pair *nTrack = &pairs->fields[1];
+
+          char pJ[1024];
+          snprintf(pJ, sizeof(pJ), "{\"op\":\"play\",\"guildId\":\"%.*s\",\"track\":\"%.*s\",\"noReplace\":false,\"pause\":false}", (int)guildId->v.len, text + guildId->v.pos, (int)nTrack->v.len, json + nTrack->v.pos);
+
+          sendPayload(pJ, "play");
+
+          jsonb b;
+          char qbuf[1024];
+
+          jsonb_init(&b);
+          jsonb_array(&b, qbuf, sizeof(qbuf));
+
+          if (pairs->size == 1) {
+            char *msgErr = NULL;
+
+            query = sqlite3_mprintf("DELETE FROM guild_queue WHERE guild_id = %.*s;", (int)guildId->v.len, text + guildId->v.pos);
+            rc = sqlite3_exec(db, query, NULL, NULL, &msgErr);
+
+            sqlite3_free(query);
+
+            if (rc != SQLITE_OK) {
+              log_fatal("[SYSTEM] Something went wrong while deleting guild_queue table from guild_id. [%s]", msgErr);
+              if (sqlite3_close(db) != SQLITE_OK) {
+                log_fatal("[SQLITE] Failed to close sqlite db. [%s]", sqlite3_errmsg(db));
+              }
+              return;
+            } else {
+              log_debug("[SYSTEM] Deleted guild_queue where guild_id = %.*s.", (int)guildId->v.len, text + guildId->v.pos);
+            }
+
+            if (sqlite3_close(db) != SQLITE_OK) {
+              log_fatal("[SQLITE] Failed to close sqlite db. [%s]", sqlite3_errmsg(db));
+            }
+
+            struct discord_embed embed[] = {
+              {
+                .description = "The music has ended.",
+                .image =
+                  &(struct discord_embed_image){
+                    .url = "https://raw.githubusercontent.com/Cogmasters/concord/master/docs/static/social-preview.png",
+                  },
+                .footer =
+                  &(struct discord_embed_footer){
+                    .text = "Powered by Concord",
+                    .icon_url = "https://raw.githubusercontent.com/Cogmasters/concord/master/docs/static/concord-small.png",
+                  },
+                .timestamp = discord_timestamp(data),
+                .color = 15615
+              }
+            };
+
+            struct discord_create_message params = {
+              .flags = 0,
+              .embeds =
+                &(struct discord_embeds){
+                  .size = 1,
+                  .array = embed,
+                },
+            };
+
+            discord_create_message(data, channelID, &params, NULL);
+            return;
+          }
+
+          jsmnf_pair *f;
+
+          for (int i = 1; i < pairs->size; ++i) {
+            f = &pairs->fields[i];
+            char arrayTrack[256];
+            snprintf(arrayTrack, sizeof(arrayTrack), "%.*s", (int)f->v.len, json + f->v.pos);
+            jsonb_string(&b, qbuf, sizeof(qbuf), arrayTrack, strlen(arrayTrack));
+          }
+
+          jsonb_array_pop(&b, qbuf, sizeof(qbuf));
+
+          char *msgErr = NULL;
+
+          char *query = sqlite3_mprintf("DELETE FROM guild_queue WHERE guild_id = %.*s;", (int)guildId->v.len, text + guildId->v.pos);
+          rc = sqlite3_exec(db, query, NULL, NULL, &msgErr);
+
+          sqlite3_free(query);
+
+          if (rc != SQLITE_OK) {
+            log_fatal("[SYSTEM] Something went wrong while deleting guild_queue table from guild_id. [%s]", msgErr);
+            if (sqlite3_close(db) != SQLITE_OK) {
+              log_fatal("[SQLITE] Failed to close sqlite db. [%s]", sqlite3_errmsg(db));
+            }
+            return;
+          } else {
+            log_debug("[SYSTEM] Deleted guild_queue where guild_id = %.*s.", (int)guildId->v.len, text + guildId->v.pos);
+          }
+
+          query = sqlite3_mprintf("INSERT INTO guild_queue(guild_id, array) values(%.*s, '%s');", (int)guildId->v.len, text + guildId->v.pos, qbuf);
+          rc = sqlite3_exec(db, query, NULL, NULL, &msgErr);
+
+          sqlite3_free(query);
+
+          if (rc != SQLITE_OK) {
+            log_fatal("[SQLITE] Something went wrong while inserting values into guild_queue table. [%s]", msgErr);
+            if (sqlite3_close(db) != SQLITE_OK) {
+              log_fatal("[SQLITE] Failed to close sqlite db. [%s]", sqlite3_errmsg(db));
+            }
+            return;
+          } else {
+            log_debug("[SQLITE] Inserted into guild_queue table the values: guild_id: %.*s, array: %s.", (int)guildId->v.len, text + guildId->v.pos, qbuf);
+          }
+
+          struct discord_embed embed[] = {
+            {
+              .description = "Now, going to play next music from queue.",
+              .image =
+                &(struct discord_embed_image){
+                  .url = "https://raw.githubusercontent.com/Cogmasters/concord/master/docs/static/social-preview.png",
+                },
+              .footer =
+                &(struct discord_embed_footer){
+                  .text = "Powered by Concord",
+                  .icon_url = "https://raw.githubusercontent.com/Cogmasters/concord/master/docs/static/concord-small.png",
+                },
+              .timestamp = discord_timestamp(data),
+              .color = 15615
+            }
+          };
+
+          struct discord_create_message params = {
+            .flags = 0,
+            .embeds =
+              &(struct discord_embeds){
+                .size = 1,
+                .array = embed,
               },
-            .timestamp = discord_timestamp(data),
-            .color = 15615
+          };
+
+          discord_create_message(data, channelID, &params, NULL);
+        } else {
+          if (sqlite3_finalize(stmt) != SQLITE_OK) {
+            log_fatal("[SQLITE] Error while executing function sqlite3_finalize.");
+            return;
           }
-        };
-
-        struct discord_create_message params = {
-          .flags = 0,
-          .embeds =
-            &(struct discord_embeds){
-              .size = 1,
-              .array = embed,
-            },
-        };
-
-        discord_create_message(data, sqlite3_column_int64(stmt, 0), &params, NULL);
-      }
-      
-      if (sqlite3_finalize(stmt) != SQLITE_OK) {
-        log_fatal("[SQLITE] Error while executing function sqlite3_finalize.");
-        return;
+
+          struct discord_embed embed[] = {
+            {
+              .description = "<a:Noo:757568484086382622> | Some wild error happened, this should be reported.",
+              .image =
+                &(struct discord_embed_image){
+                 .url = "https://raw.githubusercontent.com/Cogmasters/concord/master/docs/static/social-preview.png",
+                },
+              .footer =
+                &(struct discord_embed_footer){
+                  .text = "Powered by Concord",
+                  .icon_url = "https://raw.githubusercontent.com/Cogmasters/concord/master/docs/static/concord-small.png",
+                },
+              .timestamp = discord_timestamp(data),
+              .color = 16711680
+            }
+          };
+
+          struct discord_create_message params = {
+            .flags = 0,
+            .embeds =
+              &(struct discord_embeds){
+                .size = 1,
+                .array = embed,
+              },
+          };
+
+          discord_create_message(data, channelID, &params, NULL);
+        }
       }
+
       if (sqlite3_close(db) != SQLITE_OK) {
         log_fatal("[SQLITE] Failed to close sqlite db. [%s]", sqlite3_errmsg(db));
       }
diff --git a/main.c b/main.c
