mirror of
https://github.com/Goldenkrew3000/OSSP_OpenSource.git
synced 2026-02-16 12:15:17 +10:00
Compare commits
5 Commits
ba554dc716
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
| 2853898145 | |||
| 9ae53e0824 | |||
| 1f814fff6e | |||
| 26df10f8fb | |||
| 66aa616286 |
@@ -12,6 +12,8 @@ find_package(OpenGL REQUIRED)
|
|||||||
find_package(SDL2 REQUIRED)
|
find_package(SDL2 REQUIRED)
|
||||||
find_package(PkgConfig REQUIRED)
|
find_package(PkgConfig REQUIRED)
|
||||||
pkg_check_modules(GSTREAMER REQUIRED gstreamer-1.0)
|
pkg_check_modules(GSTREAMER REQUIRED gstreamer-1.0)
|
||||||
|
pkg_check_modules(AVFORMAT REQUIRED libavformat)
|
||||||
|
pkg_check_modules(AVUTIL REQUIRED libavutil)
|
||||||
|
|
||||||
add_subdirectory(external/discord-rpc)
|
add_subdirectory(external/discord-rpc)
|
||||||
|
|
||||||
@@ -25,6 +27,8 @@ add_executable(ossp MACOSX_BUNDLE
|
|||||||
configHandler.c
|
configHandler.c
|
||||||
discordrpc.c
|
discordrpc.c
|
||||||
localRadioDBHandler.c
|
localRadioDBHandler.c
|
||||||
|
localMusicHandler.cpp
|
||||||
|
socket.c
|
||||||
gui/gui_entry.cpp
|
gui/gui_entry.cpp
|
||||||
player/player.c
|
player/player.c
|
||||||
player/playQueue.cpp
|
player/playQueue.cpp
|
||||||
@@ -65,6 +69,6 @@ set_target_properties(ossp PROPERTIES
|
|||||||
MACOSX_BUNDLE_GUI_IDENTIFIER "org.hojuix.ossp"
|
MACOSX_BUNDLE_GUI_IDENTIFIER "org.hojuix.ossp"
|
||||||
)
|
)
|
||||||
|
|
||||||
include_directories(${GSTREAMER_INCLUDE_DIRS})
|
include_directories(${GSTREAMER_INCLUDE_DIRS} ${AVFORMAT_INCLUDE_DIR} ${AVUTIL_INCLUDE_DIRS})
|
||||||
|
|
||||||
target_link_libraries(ossp PRIVATE OpenSSL::SSL OpenSSL::Crypto CURL::libcurl SDL2::SDL2 ${OPENGL_LIBRARIES} discord-rpc ${GSTREAMER_LIBRARIES})
|
target_link_libraries(ossp PRIVATE OpenSSL::SSL OpenSSL::Crypto CURL::libcurl SDL2::SDL2 ${OPENGL_LIBRARIES} discord-rpc ${GSTREAMER_LIBRARIES} ${AVFORMAT_LIBRARIES} ${AVUTIL_LIBRARIES})
|
||||||
|
|||||||
@@ -68,6 +68,7 @@ int configHandler_Read(configHandler_config_t** configObj) {
|
|||||||
(*configObj)->lv2_parax32_frequency_left = NULL;
|
(*configObj)->lv2_parax32_frequency_left = NULL;
|
||||||
(*configObj)->lv2_parax32_frequency_right = NULL;
|
(*configObj)->lv2_parax32_frequency_right = NULL;
|
||||||
(*configObj)->lv2_reverb_filter_name = NULL;
|
(*configObj)->lv2_reverb_filter_name = NULL;
|
||||||
|
(*configObj)->local_rootdir = NULL;
|
||||||
|
|
||||||
// Set internal configuration values
|
// Set internal configuration values
|
||||||
(*configObj)->internal_opensubsonic_version = strdup("1.8.0");
|
(*configObj)->internal_opensubsonic_version = strdup("1.8.0");
|
||||||
@@ -465,6 +466,19 @@ int configHandler_Read(configHandler_config_t** configObj) {
|
|||||||
(*configObj)->lv2_reverb_filter_name = strdup(calf_reverb_filter_name->valuestring);
|
(*configObj)->lv2_reverb_filter_name = strdup(calf_reverb_filter_name->valuestring);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Make an object from local
|
||||||
|
cJSON* local_root = cJSON_GetObjectItemCaseSensitive(root, "local");
|
||||||
|
if (local_root == NULL) {
|
||||||
|
logger_log_error(__func__, "Error parsing JSON - local does not exist.");
|
||||||
|
cJSON_Delete(root);
|
||||||
|
return 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
cJSON* local_root_directory = cJSON_GetObjectItemCaseSensitive(local_root, "rootDirectory");
|
||||||
|
if (cJSON_IsString(local_root_directory) && local_root_directory->valuestring != NULL) {
|
||||||
|
(*configObj)->local_rootdir = strdup(local_root_directory->valuestring);
|
||||||
|
}
|
||||||
|
|
||||||
cJSON_Delete(root);
|
cJSON_Delete(root);
|
||||||
logger_log_general(__func__, "Successfully read configuration file.");
|
logger_log_general(__func__, "Successfully read configuration file.");
|
||||||
return 0;
|
return 0;
|
||||||
@@ -497,5 +511,6 @@ void configHandler_Free(configHandler_config_t** configObj) {
|
|||||||
if ((*configObj)->lv2_parax32_frequency_left != NULL) { free((*configObj)->lv2_parax32_frequency_left); }
|
if ((*configObj)->lv2_parax32_frequency_left != NULL) { free((*configObj)->lv2_parax32_frequency_left); }
|
||||||
if ((*configObj)->lv2_parax32_frequency_right != NULL) { free((*configObj)->lv2_parax32_frequency_right); }
|
if ((*configObj)->lv2_parax32_frequency_right != NULL) { free((*configObj)->lv2_parax32_frequency_right); }
|
||||||
if ((*configObj)->lv2_reverb_filter_name != NULL) { free((*configObj)->lv2_reverb_filter_name); }
|
if ((*configObj)->lv2_reverb_filter_name != NULL) { free((*configObj)->lv2_reverb_filter_name); }
|
||||||
|
if ((*configObj)->local_rootdir != NULL) { free((*configObj)->local_rootdir); }
|
||||||
if (*configObj != NULL) { free(*configObj); }
|
if (*configObj != NULL) { free(*configObj); }
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -65,6 +65,9 @@ typedef struct {
|
|||||||
char* lv2_parax32_frequency_left;
|
char* lv2_parax32_frequency_left;
|
||||||
char* lv2_parax32_frequency_right;
|
char* lv2_parax32_frequency_right;
|
||||||
char* lv2_reverb_filter_name; // LV2 Calf Reverb LV2 Name
|
char* lv2_reverb_filter_name; // LV2 Calf Reverb LV2 Name
|
||||||
|
|
||||||
|
// Local Settings
|
||||||
|
char* local_rootdir; // Local Music Root Directory
|
||||||
} configHandler_config_t;
|
} configHandler_config_t;
|
||||||
|
|
||||||
int configHandler_Read(configHandler_config_t** config);
|
int configHandler_Read(configHandler_config_t** config);
|
||||||
|
|||||||
@@ -40,31 +40,11 @@ void discordrpc_struct_deinit(discordrpc_data** discordrpc_struct) {
|
|||||||
if (*discordrpc_struct != NULL) { free(*discordrpc_struct); }
|
if (*discordrpc_struct != NULL) { free(*discordrpc_struct); }
|
||||||
}
|
}
|
||||||
|
|
||||||
static void handleDiscordReady(const DiscordUser* connectedUser)
|
|
||||||
{
|
|
||||||
printf("\nDiscord: connected to user %s#%s - %s\n",
|
|
||||||
connectedUser->username,
|
|
||||||
connectedUser->discriminator,
|
|
||||||
connectedUser->userId);
|
|
||||||
}
|
|
||||||
|
|
||||||
static void handleDiscordDisconnected(int errcode, const char* message)
|
|
||||||
{
|
|
||||||
printf("\nDiscord: disconnected (%d: %s)\n", errcode, message);
|
|
||||||
}
|
|
||||||
|
|
||||||
static void handleDiscordError(int errcode, const char* message)
|
|
||||||
{
|
|
||||||
printf("\nDiscord: error (%d: %s)\n", errcode, message);
|
|
||||||
}
|
|
||||||
|
|
||||||
int discordrpc_init() {
|
int discordrpc_init() {
|
||||||
printf("[DiscordRPC] Initializing.\n");
|
printf("[DiscordRPC] Initializing.\n");
|
||||||
|
// TODO Can I just not deal with the handler callbacks at all?
|
||||||
DiscordEventHandlers handlers;
|
DiscordEventHandlers handlers;
|
||||||
memset(&handlers, 0, sizeof(handlers));
|
memset(&handlers, 0, sizeof(handlers));
|
||||||
handlers.ready = handleDiscordReady;
|
|
||||||
handlers.disconnected = handleDiscordDisconnected;
|
|
||||||
handlers.errored = handleDiscordError;
|
|
||||||
Discord_Initialize(discordrpc_appid, &handlers, 1, NULL);
|
Discord_Initialize(discordrpc_appid, &handlers, 1, NULL);
|
||||||
|
|
||||||
// Fetch OS String for RPC (Heap-allocated)
|
// Fetch OS String for RPC (Heap-allocated)
|
||||||
@@ -86,7 +66,7 @@ void discordrpc_update(discordrpc_data** discordrpc_struct) {
|
|||||||
if ((*discordrpc_struct)->state == DISCORDRPC_STATE_IDLE) {
|
if ((*discordrpc_struct)->state == DISCORDRPC_STATE_IDLE) {
|
||||||
asprintf(&detailsString, "Idle");
|
asprintf(&detailsString, "Idle");
|
||||||
presence.details = detailsString;
|
presence.details = detailsString;
|
||||||
} else if ((*discordrpc_struct)->state == DISCORDRPC_STATE_PLAYING_SONG) {
|
} else if ((*discordrpc_struct)->state == DISCORDRPC_STATE_PLAYING_OPENSUBSONIC) {
|
||||||
// Playing a song
|
// Playing a song
|
||||||
time_t currentTime = time(NULL);
|
time_t currentTime = time(NULL);
|
||||||
asprintf(&detailsString, "%s", (*discordrpc_struct)->songTitle);
|
asprintf(&detailsString, "%s", (*discordrpc_struct)->songTitle);
|
||||||
@@ -99,7 +79,9 @@ void discordrpc_update(discordrpc_data** discordrpc_struct) {
|
|||||||
if (configObj->discordrpc_showSysDetails) {
|
if (configObj->discordrpc_showSysDetails) {
|
||||||
presence.largeImageText = discordrpc_osString;
|
presence.largeImageText = discordrpc_osString;
|
||||||
}
|
}
|
||||||
} else if ((*discordrpc_struct)->state == DISCORDRPC_STATE_PLAYING_RADIO) {
|
} else if ((*discordrpc_struct)->state == DISCORDRPC_STATE_PLAYING_LOCALFILE) {
|
||||||
|
//
|
||||||
|
} else if ((*discordrpc_struct)->state == DISCORDRPC_STATE_PLAYING_INTERNETRADIO) {
|
||||||
// Playing an internet radio station
|
// Playing an internet radio station
|
||||||
time_t currentTime = time(NULL);
|
time_t currentTime = time(NULL);
|
||||||
asprintf(&detailsString, "%s", (*discordrpc_struct)->songTitle);
|
asprintf(&detailsString, "%s", (*discordrpc_struct)->songTitle);
|
||||||
|
|||||||
@@ -8,8 +8,9 @@
|
|||||||
#define _DISCORDRPC_H
|
#define _DISCORDRPC_H
|
||||||
|
|
||||||
#define DISCORDRPC_STATE_IDLE 0
|
#define DISCORDRPC_STATE_IDLE 0
|
||||||
#define DISCORDRPC_STATE_PLAYING_SONG 1
|
#define DISCORDRPC_STATE_PLAYING_OPENSUBSONIC 1
|
||||||
#define DISCORDRPC_STATE_PLAYING_RADIO 2
|
#define DISCORDRPC_STATE_PLAYING_LOCALFILE 2
|
||||||
|
#define DISCORDRPC_STATE_PLAYING_INTERNETRADIO 3
|
||||||
#define DISCORDRPC_STATE_PAUSED 4
|
#define DISCORDRPC_STATE_PAUSED 4
|
||||||
|
|
||||||
typedef struct {
|
typedef struct {
|
||||||
|
|||||||
257
src/localMusicHandler.cpp
Normal file
257
src/localMusicHandler.cpp
Normal file
@@ -0,0 +1,257 @@
|
|||||||
|
/*
|
||||||
|
* OpenSubsonicPlayer
|
||||||
|
* Goldenkrew3000 2025
|
||||||
|
* License: GNU General Public License 3.0
|
||||||
|
* Info: Local Music File Handler
|
||||||
|
*/
|
||||||
|
|
||||||
|
#include <stdio.h>
|
||||||
|
#include <stdlib.h>
|
||||||
|
#include <string.h>
|
||||||
|
#include <stdint.h>
|
||||||
|
#include <dirent.h>
|
||||||
|
#include <errno.h>
|
||||||
|
#include <sys/stat.h>
|
||||||
|
extern "C" {
|
||||||
|
#include <libavformat/avformat.h>
|
||||||
|
#include <libavutil/dict.h>
|
||||||
|
#include <libavformat/avio.h>
|
||||||
|
#include "external/sqlite3/sqlite3.h"
|
||||||
|
}
|
||||||
|
#include <iostream>
|
||||||
|
#include <regex>
|
||||||
|
#include <vector>
|
||||||
|
#include <deque>
|
||||||
|
#include "configHandler.h"
|
||||||
|
#include "localMusicHandler.hpp"
|
||||||
|
|
||||||
|
/*
|
||||||
|
* I'm sorry for this messy and probably unreliable code
|
||||||
|
* This is the first time I have ever written something like this
|
||||||
|
* And why C++? Easy to store all of the temporary data without a ton of boilerplate
|
||||||
|
*/
|
||||||
|
|
||||||
|
extern configHandler_config_t* configObj;
|
||||||
|
std::vector<std::string> localMusicHandler_allFiles;
|
||||||
|
class localMusicHandler_AudioObject {
|
||||||
|
public:
|
||||||
|
std::string path;
|
||||||
|
std::string songTitle;
|
||||||
|
std::string albumTitle;
|
||||||
|
std::string artistTitle;
|
||||||
|
std::string track;
|
||||||
|
std::string totalTracks;
|
||||||
|
uint64_t filesize;
|
||||||
|
std::string uid;
|
||||||
|
};
|
||||||
|
std::deque<localMusicHandler_AudioObject> localMusicHandler_audioItems;
|
||||||
|
static sqlite3* sqlite_db = NULL;
|
||||||
|
static char* sqlite_errorMsg = NULL;
|
||||||
|
|
||||||
|
void localMusicHandler_scan() {
|
||||||
|
static int rc = 0;
|
||||||
|
printf("[LocalMusicHandler] Scanning local music directory recursively for files.\n");
|
||||||
|
|
||||||
|
// TODO clear all vectors
|
||||||
|
|
||||||
|
// Scan music directory (defined in config file) for all files
|
||||||
|
localMusicHandler_scanDirectory(configObj->local_rootdir);
|
||||||
|
printf("[LocalMusicHandler] Found %d files.\n", localMusicHandler_allFiles.size());
|
||||||
|
|
||||||
|
// Scan each file to find only music files, and pull ID3 tags
|
||||||
|
for (int i = 0; i < localMusicHandler_allFiles.size(); i++) {
|
||||||
|
localMusicHandler_scanFile(i);
|
||||||
|
}
|
||||||
|
printf("[LocalMusicHandler] Found %d songs.\n", localMusicHandler_audioItems.size());
|
||||||
|
|
||||||
|
// Generate a unique ID for each music file
|
||||||
|
printf("[LocalMusicHandler] Generating unique IDs for each song.\n");
|
||||||
|
for (int i = 0; i < localMusicHandler_audioItems.size(); i++) {
|
||||||
|
// TODO: Technically there is a VERY SMALL chance that 2 id's repeat in the DB
|
||||||
|
// Figure out what to do about that later
|
||||||
|
localMusicHandler_generateUid(i);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Store in database
|
||||||
|
rc = localMusicHandler_initDatabase();
|
||||||
|
if (rc == -1) {
|
||||||
|
// ERROR
|
||||||
|
} else if (rc == 0) {
|
||||||
|
// Table just made, songs not loaded in yet
|
||||||
|
for (int i = 0; i < localMusicHandler_audioItems.size(); i++) {
|
||||||
|
localMusicHandler_moveSongsToDatabase(i);
|
||||||
|
}
|
||||||
|
} else if (rc == 1) {
|
||||||
|
// Table was already made, assume songs were loaded in before
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
void localMusicHandler_scanDirectory(char* directory) {
|
||||||
|
struct dirent* dp;
|
||||||
|
DIR* dir = opendir(directory);
|
||||||
|
char path[1000]; // TODO Prevent potential buffer overflow
|
||||||
|
|
||||||
|
while ((dp = readdir(dir)) != NULL) {
|
||||||
|
if (strcmp(dp->d_name, ".") != 0 && strcmp(dp->d_name, "..") != 0) {
|
||||||
|
sprintf(path, "%s/%s", directory, dp->d_name);
|
||||||
|
|
||||||
|
struct stat statbuf;
|
||||||
|
stat(path, &statbuf);
|
||||||
|
|
||||||
|
if (S_ISDIR(statbuf.st_mode)) {
|
||||||
|
localMusicHandler_scanDirectory(path);
|
||||||
|
} else if (S_ISREG(statbuf.st_mode)) {
|
||||||
|
localMusicHandler_allFiles.push_back(path);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
closedir(dir);
|
||||||
|
}
|
||||||
|
|
||||||
|
void localMusicHandler_scanFile(int idx) {
|
||||||
|
AVFormatContext* ctx = NULL;
|
||||||
|
AVDictionaryEntry* tag = NULL;
|
||||||
|
static int rc = -1;
|
||||||
|
|
||||||
|
rc = avformat_open_input(&ctx, localMusicHandler_allFiles[idx].c_str(), NULL, NULL);
|
||||||
|
if (rc < 0) {
|
||||||
|
printf("[LocalMusicHandler] avformat_open_input() failed on idx %d (%s).\n", idx, localMusicHandler_allFiles[idx].c_str());
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Ignore files that aren't audio
|
||||||
|
if (
|
||||||
|
strcmp(ctx->iformat->name, "lrc") == 0 || // .lrc files
|
||||||
|
strcmp(ctx->iformat->name, "image2") == 0 || // Pictures
|
||||||
|
strcmp(ctx->iformat->name, "mov,mp4,m4a,3gp,3g2,mj2") == 0 // .mp4 files
|
||||||
|
) {
|
||||||
|
avformat_close_input(&ctx);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
localMusicHandler_AudioObject audioObject;
|
||||||
|
audioObject.path = localMusicHandler_allFiles[idx].c_str();
|
||||||
|
|
||||||
|
// Get file size (Using libav for this since the file is already opened using it)
|
||||||
|
audioObject.filesize = 0; // If the following fetch fails, set it to a known value beforehand
|
||||||
|
if (ctx->pb) {
|
||||||
|
uint64_t fsize = avio_size(ctx->pb);
|
||||||
|
if (fsize > 0) {
|
||||||
|
audioObject.filesize = fsize;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Set all strings to known good values before fetching tags that possible don't exist
|
||||||
|
// NOTE: Honestly don't know if C++ does this by default, but I am not trusting it either way
|
||||||
|
audioObject.songTitle = "";
|
||||||
|
audioObject.albumTitle = "";
|
||||||
|
audioObject.artistTitle = "";
|
||||||
|
audioObject.track = "";
|
||||||
|
audioObject.totalTracks = "";
|
||||||
|
|
||||||
|
while ((tag = av_dict_get(ctx->metadata, "", tag, AV_DICT_IGNORE_SUFFIX))) {
|
||||||
|
if (strcmp(tag->key, "title") == 0) {
|
||||||
|
audioObject.songTitle = tag->value;
|
||||||
|
} else if (strcmp(tag->key, "album") == 0) {
|
||||||
|
audioObject.albumTitle = tag->value;
|
||||||
|
} else if (strcmp(tag->key, "artist") == 0) {
|
||||||
|
// In ID3, multiple artists are stored as 'Artist A;Artist B'. Replace ';' with ', '
|
||||||
|
audioObject.artistTitle = std::regex_replace(tag->value, std::regex(";"), ", ");
|
||||||
|
} else if (strcmp(tag->key, "track") == 0) {
|
||||||
|
audioObject.track = tag->value;
|
||||||
|
} else if (strcmp(tag->key, "totaltracks") == 0) {
|
||||||
|
audioObject.totalTracks = tag->value;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
localMusicHandler_audioItems.push_back(audioObject);
|
||||||
|
avformat_close_input(&ctx);
|
||||||
|
}
|
||||||
|
|
||||||
|
void localMusicHandler_generateUid(int idx) {
|
||||||
|
// TODO: Add other operating support here, such as in libopensubsonic/crypto.c
|
||||||
|
char uuidBytes[20];
|
||||||
|
char uuidString[40];
|
||||||
|
for (int i = 0; i < 20; i++) {
|
||||||
|
uuidBytes[i] = arc4random() & 0xFF;
|
||||||
|
}
|
||||||
|
snprintf(uuidString, 40, "%.2x%.2x%.2x%.2x%.2x%.2x%.2x%.2x%.2x%.2x%.2x%.2x%.2x%.2x%.2x%.2x%.2x%.2x%.2x%.2x",
|
||||||
|
uuidBytes[0], uuidBytes[1], uuidBytes[2], uuidBytes[3], uuidBytes[4],
|
||||||
|
uuidBytes[5], uuidBytes[6], uuidBytes[7], uuidBytes[8], uuidBytes[9],
|
||||||
|
uuidBytes[10], uuidBytes[11], uuidBytes[12], uuidBytes[13], uuidBytes[14],
|
||||||
|
uuidBytes[15], uuidBytes[16], uuidBytes[17], uuidBytes[18], uuidBytes[19]
|
||||||
|
);
|
||||||
|
localMusicHandler_audioItems[idx].uid = uuidString;
|
||||||
|
}
|
||||||
|
|
||||||
|
int localMusicHandler_initDatabase() {
|
||||||
|
// Code returns: -1 -> Error, 0 -> No songs in table, 1 -> Songs already in table (Table already existed)
|
||||||
|
static int createTable = 0;
|
||||||
|
static int rc = 0;
|
||||||
|
char* dbPath = NULL;
|
||||||
|
rc = asprintf(&dbPath, "%s/.config/ossp/local.db", getenv("HOME"));
|
||||||
|
if (rc == -1) {
|
||||||
|
printf("[LocalMusicHandler] asprintf() failed.\n");
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
|
||||||
|
struct stat st;
|
||||||
|
if (stat(dbPath, &st) == 0) {
|
||||||
|
printf("[LocalMusicHandler] Database found, is %ld bytes.\n", st.st_size);
|
||||||
|
} else {
|
||||||
|
printf("[LocalMusicHandler] Database does not exist, creating.\n");
|
||||||
|
createTable = 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
rc = sqlite3_open(dbPath, &sqlite_db);
|
||||||
|
if (rc) {
|
||||||
|
printf("[LocalMusicHandler] Could not create database: %s\n", sqlite3_errmsg(sqlite_db));
|
||||||
|
free(dbPath);
|
||||||
|
return -1;
|
||||||
|
} else {
|
||||||
|
printf("[LocalMusicHandler] Created/Opened database.\n");
|
||||||
|
}
|
||||||
|
|
||||||
|
if (createTable == 1) {
|
||||||
|
const char* sqlQuery = "CREATE TABLE local_songs(uid TEXT, songTitle TEXT, albumTitle TEXT, artistTitle TEXT, track TEXT, totalTracks TEXT, path TEXT, filesize INT)";
|
||||||
|
rc = sqlite3_exec(sqlite_db, sqlQuery, NULL, 0, &sqlite_errorMsg);
|
||||||
|
if (rc != SQLITE_OK) {
|
||||||
|
printf("[LocalMusicHandler] Could not make table: %s\n", sqlite_errorMsg);
|
||||||
|
sqlite3_free(sqlite_errorMsg);
|
||||||
|
free(dbPath);
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
printf("[LocalMusicHandler] Made table.\n");
|
||||||
|
free(dbPath);
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
free(dbPath);
|
||||||
|
return 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
void localMusicHandler_moveSongsToDatabase(int idx) {
|
||||||
|
sqlite3_stmt* sqlite_stmt;
|
||||||
|
const char* sqlQuery = "INSERT INTO local_songs VALUES(?, ?, ?, ?, ?, ?, ?, ?)";
|
||||||
|
|
||||||
|
if (sqlite3_prepare_v2(sqlite_db, sqlQuery, -1, &sqlite_stmt, NULL) != SQLITE_OK) {
|
||||||
|
printf("[LocalMusicHandler] Prepare error: %s\n", sqlite3_errmsg(sqlite_db));
|
||||||
|
return; // TODO
|
||||||
|
}
|
||||||
|
|
||||||
|
sqlite3_bind_text(sqlite_stmt, 1, localMusicHandler_audioItems[idx].uid.c_str(), -1, SQLITE_TRANSIENT);
|
||||||
|
sqlite3_bind_text(sqlite_stmt, 2, localMusicHandler_audioItems[idx].songTitle.c_str(), -1, SQLITE_TRANSIENT);
|
||||||
|
sqlite3_bind_text(sqlite_stmt, 3, localMusicHandler_audioItems[idx].albumTitle.c_str(), -1, SQLITE_TRANSIENT);
|
||||||
|
sqlite3_bind_text(sqlite_stmt, 4, localMusicHandler_audioItems[idx].artistTitle.c_str(), -1, SQLITE_TRANSIENT);
|
||||||
|
sqlite3_bind_text(sqlite_stmt, 5, localMusicHandler_audioItems[idx].track.c_str(), -1, SQLITE_TRANSIENT);
|
||||||
|
sqlite3_bind_text(sqlite_stmt, 6, localMusicHandler_audioItems[idx].totalTracks.c_str(), -1, SQLITE_TRANSIENT);
|
||||||
|
sqlite3_bind_text(sqlite_stmt, 7, localMusicHandler_audioItems[idx].path.c_str(), -1, SQLITE_TRANSIENT);
|
||||||
|
sqlite3_bind_int64(sqlite_stmt, 8, localMusicHandler_audioItems[idx].filesize);
|
||||||
|
|
||||||
|
if (sqlite3_step(sqlite_stmt) != SQLITE_DONE) {
|
||||||
|
printf("[LocalMusicHandler] Execution error: %s\n", sqlite3_errmsg(sqlite_db));
|
||||||
|
}
|
||||||
|
|
||||||
|
sqlite3_finalize(sqlite_stmt);
|
||||||
|
}
|
||||||
26
src/localMusicHandler.hpp
Normal file
26
src/localMusicHandler.hpp
Normal file
@@ -0,0 +1,26 @@
|
|||||||
|
/*
|
||||||
|
* OpenSubsonicPlayer
|
||||||
|
* Goldenkrew3000 2025
|
||||||
|
* License: GNU General Public License 3.0
|
||||||
|
*/
|
||||||
|
|
||||||
|
#ifndef _LOCALMUSICHANDLER_H
|
||||||
|
#define _LOCALMUSICHANDLER_H
|
||||||
|
|
||||||
|
#ifdef __cplusplus
|
||||||
|
extern "C" {
|
||||||
|
#endif // __cplusplus
|
||||||
|
|
||||||
|
void localMusicHandler_scan();
|
||||||
|
void localMusicHandler_scanDirectory(char* directory);
|
||||||
|
void localMusicHandler_scanFile(int idx);
|
||||||
|
void localMusicHandler_generateUid(int idx);
|
||||||
|
|
||||||
|
int localMusicHandler_initDatabase();
|
||||||
|
void localMusicHandler_moveSongsToDatabase(int idx);
|
||||||
|
|
||||||
|
#ifdef __cplusplus
|
||||||
|
}
|
||||||
|
#endif // __cplusplus
|
||||||
|
|
||||||
|
#endif // _LOCALMUSICHANDLER_H
|
||||||
@@ -20,69 +20,105 @@
|
|||||||
#include "playQueue.hpp"
|
#include "playQueue.hpp"
|
||||||
|
|
||||||
// C++ interface for storing song queue data (C interface is in the header)
|
// C++ interface for storing song queue data (C interface is in the header)
|
||||||
class SongObject {
|
class OSSPQ_SongObject {
|
||||||
public:
|
public:
|
||||||
std::string title;
|
std::string title;
|
||||||
|
std::string album;
|
||||||
std::string artist;
|
std::string artist;
|
||||||
std::string id;
|
std::string id;
|
||||||
|
std::string streamUrl;
|
||||||
|
std::string coverArtUrl;
|
||||||
long duration;
|
long duration;
|
||||||
|
int mode;
|
||||||
};
|
};
|
||||||
|
|
||||||
// NOTE: Acronym is OpenSubsonicPlayerQueue
|
// NOTE: Acronym is OpenSubsonicPlayerQueue
|
||||||
std::deque<SongObject> OSSPQ_Items;
|
std::deque<OSSPQ_SongObject> OSSPQ_SongQueue;
|
||||||
|
|
||||||
int internal_OSSPQ_AppendToEnd(char* title, char* artist, char* id, long duration) {
|
int OSSPQ_AppendToEnd(char* title, char* album, char* artist, char* id, char* streamUrl, char* coverArtUrl, long duration, int mode) {
|
||||||
// Append a new song to the end of the queue
|
OSSPQ_SongObject songObject;
|
||||||
printf("Title: %s\nArtist: %s\nID: %s\nDuration: %ld\n", title, artist, id, duration);
|
|
||||||
// TODO: Find a neater way of converting a C string to a C++ string??
|
if (mode == OSSPQ_MODE_OPENSUBSONIC || mode == OSSPQ_MODE_LOCALFILE) {
|
||||||
std::string cpp_title(title);
|
// Both Local File and OpenSubsonic playback both take the same arguments
|
||||||
std::string cpp_artist(artist);
|
if (mode == OSSPQ_MODE_OPENSUBSONIC) {
|
||||||
std::string cpp_id(id);
|
printf("[OSSPQ] Appending OpenSubsonic Song: %s by %s.\n", title, artist);
|
||||||
SongObject songObject;
|
} else if (mode == OSSPQ_MODE_LOCALFILE) {
|
||||||
songObject.title = cpp_title;
|
printf("[OSSPQ] Appending Local Song: %s by %s.\n", title, artist);
|
||||||
songObject.artist = cpp_artist;
|
}
|
||||||
songObject.id = cpp_id;
|
|
||||||
|
songObject.title = title;
|
||||||
|
songObject.album = album;
|
||||||
|
songObject.artist = artist;
|
||||||
|
songObject.id = id;
|
||||||
|
songObject.streamUrl = streamUrl;
|
||||||
|
songObject.coverArtUrl = coverArtUrl;
|
||||||
songObject.duration = duration;
|
songObject.duration = duration;
|
||||||
OSSPQ_Items.push_back(songObject);
|
songObject.mode = mode;
|
||||||
|
} else if (mode == OSSPQ_MODE_INTERNETRADIO) {
|
||||||
|
printf("[OSSPQ] Appending Internet Radio Station: %s.\n", title);
|
||||||
|
|
||||||
|
songObject.title = title;
|
||||||
|
songObject.id = id;
|
||||||
|
songObject.streamUrl = streamUrl;
|
||||||
|
}
|
||||||
|
|
||||||
|
OSSPQ_SongQueue.push_back(songObject);
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
OSSPQ_SongStruct* internal_OSSPQ_PopFromFront() {
|
OSSPQ_SongStruct* OSSPQ_PopFromFront() {
|
||||||
if (OSSPQ_Items.empty()) {
|
// Check if song queue is empty, if not, then pop oldest
|
||||||
// No items in play queue
|
if (OSSPQ_SongQueue.empty()) {
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
OSSPQ_SongObject songObject = OSSPQ_SongQueue.front();
|
||||||
|
OSSPQ_SongQueue.pop_front();
|
||||||
|
|
||||||
// Pull the first song off the song queue
|
// Allocate, initialize, and fill C compatible song object
|
||||||
SongObject songObject = OSSPQ_Items.front();
|
OSSPQ_SongStruct* songObjectC = (OSSPQ_SongStruct*)malloc(sizeof(OSSPQ_SongStruct));
|
||||||
OSSPQ_Items.pop_front();
|
songObjectC->title = NULL;
|
||||||
|
songObjectC->album = NULL;
|
||||||
|
songObjectC->artist = NULL;
|
||||||
|
songObjectC->id = NULL;
|
||||||
|
songObjectC->streamUrl = NULL;
|
||||||
|
songObjectC->coverArtUrl = NULL;
|
||||||
|
songObjectC->duration = 0;
|
||||||
|
songObjectC->mode = 0;
|
||||||
|
|
||||||
// Move song data into a C readable format
|
if (songObject.mode == OSSPQ_MODE_OPENSUBSONIC || songObject.mode == OSSPQ_MODE_LOCALFILE) {
|
||||||
// NOTE: I am initializing the variables to a known value just in case there is missing information in songObject
|
songObjectC->title = strdup(songObject.title.c_str());
|
||||||
OSSPQ_SongStruct* playQueueObject = (OSSPQ_SongStruct*)malloc(sizeof(OSSPQ_SongStruct));
|
songObjectC->album = strdup(songObject.album.c_str());
|
||||||
playQueueObject->title = NULL;
|
songObjectC->artist = strdup(songObject.artist.c_str());
|
||||||
playQueueObject->artist = NULL;
|
songObjectC->id = strdup(songObject.id.c_str());
|
||||||
playQueueObject->id = NULL;
|
songObjectC->streamUrl = strdup(songObject.streamUrl.c_str());
|
||||||
playQueueObject->duration = 0;
|
songObjectC->coverArtUrl = strdup(songObject.coverArtUrl.c_str());
|
||||||
|
songObjectC->duration = songObject.duration;
|
||||||
|
songObjectC->mode = songObject.mode;
|
||||||
|
} else if (songObject.mode == OSSPQ_MODE_INTERNETRADIO) {
|
||||||
|
songObjectC->title = strdup(songObject.title.c_str());
|
||||||
|
songObjectC->id = strdup(songObject.id.c_str());
|
||||||
|
songObjectC->streamUrl = strdup(songObject.streamUrl.c_str());
|
||||||
|
}
|
||||||
|
|
||||||
playQueueObject->title = strdup(songObject.title.c_str());
|
return songObjectC;
|
||||||
playQueueObject->artist = strdup(songObject.artist.c_str());
|
|
||||||
playQueueObject->id = strdup(songObject.id.c_str());
|
|
||||||
playQueueObject->duration = songObject.duration;
|
|
||||||
return playQueueObject;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
void internal_OSSPQ_FreeSongObject(OSSPQ_SongStruct* songObject) {
|
void OSSPQ_FreeSongObjectC(OSSPQ_SongStruct* songObjectC) {
|
||||||
if (songObject->title != NULL) { free(songObject->title); }
|
printf("[OSSPQ] Freeing SongObjectC.\n");
|
||||||
if (songObject->artist != NULL) { free(songObject->artist); }
|
if (songObjectC->title != NULL) { free(songObjectC->title); }
|
||||||
if (songObject->id != NULL) { free(songObject->id); }
|
if (songObjectC->album != NULL) { free(songObjectC->album); }
|
||||||
if (songObject != NULL) { free(songObject); }
|
if (songObjectC->artist != NULL) { free(songObjectC->artist); }
|
||||||
|
if (songObjectC->id != NULL) { free(songObjectC->id); }
|
||||||
|
if (songObjectC->streamUrl != NULL) { free(songObjectC->streamUrl); }
|
||||||
|
if (songObjectC->coverArtUrl != NULL) { free(songObjectC->coverArtUrl); }
|
||||||
|
if (songObjectC != NULL) { free(songObjectC); }
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// TODO Bullshit functions for dealing with Imgui
|
||||||
char* internal_OSSPQ_GetTitleAtIndex(int idx) {
|
char* internal_OSSPQ_GetTitleAtIndex(int idx) {
|
||||||
return (char*)OSSPQ_Items[idx].title.c_str();
|
return (char*)OSSPQ_SongQueue[idx].title.c_str();
|
||||||
}
|
}
|
||||||
|
|
||||||
int internal_OSSPQ_GetItemCount() {
|
int internal_OSSPQ_GetItemCount() {
|
||||||
return OSSPQ_Items.size();
|
return OSSPQ_SongQueue.size();
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -7,6 +7,10 @@
|
|||||||
#ifndef _PLAYQUEUE_H
|
#ifndef _PLAYQUEUE_H
|
||||||
#define _PLAYQUEUE_H
|
#define _PLAYQUEUE_H
|
||||||
|
|
||||||
|
#define OSSPQ_MODE_OPENSUBSONIC 101
|
||||||
|
#define OSSPQ_MODE_LOCALFILE 102
|
||||||
|
#define OSSPQ_MODE_INTERNETRADIO 103
|
||||||
|
|
||||||
#ifdef __cplusplus
|
#ifdef __cplusplus
|
||||||
extern "C" {
|
extern "C" {
|
||||||
#endif // __cplusplus
|
#endif // __cplusplus
|
||||||
@@ -14,14 +18,20 @@ extern "C" {
|
|||||||
// C interface for sending song queue data (C++ interface is in the C++ file)
|
// C interface for sending song queue data (C++ interface is in the C++ file)
|
||||||
typedef struct {
|
typedef struct {
|
||||||
char* title;
|
char* title;
|
||||||
|
char* album;
|
||||||
char* artist;
|
char* artist;
|
||||||
char* id;
|
char* id;
|
||||||
|
char* streamUrl;
|
||||||
|
char* coverArtUrl;
|
||||||
long duration;
|
long duration;
|
||||||
|
int mode;
|
||||||
} OSSPQ_SongStruct;
|
} OSSPQ_SongStruct;
|
||||||
|
|
||||||
int internal_OSSPQ_AppendToEnd(char* title, char* artist, char* id, long duration);
|
int OSSPQ_AppendToEnd(char* title, char* album, char* artist, char* id, char* streamUrl, char* coverArtUrl, long duration, int mode);
|
||||||
OSSPQ_SongStruct* internal_OSSPQ_PopFromFront();
|
OSSPQ_SongStruct* OSSPQ_PopFromFront();
|
||||||
void internal_OSSPQ_FreeSongObject(OSSPQ_SongStruct* songObject);
|
void OSSPQ_FreeSongObjectC(OSSPQ_SongStruct* songObjectC);
|
||||||
|
|
||||||
|
// TODO
|
||||||
char* internal_OSSPQ_GetTitleAtIndex(int idx);
|
char* internal_OSSPQ_GetTitleAtIndex(int idx);
|
||||||
int internal_OSSPQ_GetItemCount();
|
int internal_OSSPQ_GetItemCount();
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user