Something went wrong. Try again.
A modern, network-enabled music player platform built on Rockbox technology. rockboxd.tsiry-sandratraina.com
rust deno navidrome airplay libadwaita zig mpris snapcast mpd rockbox audio subsonic
Something went wrong. Try again.
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543/*************************************************************************** * __________ __ ___. * Open \______ \ ____ ____ | | _\_ |__ _______ ___ * Source | _// __ \_/ ___\| |/ /| __ \ / __ \ \/ / * Jukebox | | ( (__) ) \___| ( | \_\ ( (__) ) ( * Firmware |____|_ /\____/ \___ >__|_ \|___ /\____/__/\_ \ * \/ \/ \/ \/ \/ * * Copyright (C) 2020 William Wilgus * * This program is free software; you can redistribute it and/or * modify it under the terms of the GNU General Public License * as published by the Free Software Foundation; either version 2 * of the License, or (at your option) any later version. * * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY * KIND, either express or implied. * ****************************************************************************/
/* open_plugins.rock interfaces with the open_plugin core * * When opened directly it acts as a viewer for the plugin.dat file * this allows you to edit the paths and parameters for * core shortcuts as well as your added plugins * * If a plugin is supplied to the viewer it is added to the dat file * * If instead the plugin has previously been added then it is run * with the parameters previously supplied */
#if defined(DEBUG) || defined(SIMULATOR) #define logf(...) rb->debugf(__VA_ARGS__); rb->debugf("\n")#elif defined(ROCKBOX_HAS_LOGF) #define logf rb->logf#else #define logf(...) do { } while(0)#endif
#include "plugin.h"#include "lang_enum.h"#include "../open_plugin.h"
#define ROCK_EXT "rock"#define ROCK_LEN 5
#define OP_EXT "opx"#define OP_LEN 4
#define OP_PLUGIN_RESTART (PLUGIN_GOTO_PLUGIN | 0x8000)
#define MENU_ID_MAIN "0"#define MENU_ID_EDIT "1"
#define MAX_ENTRIES 128
static int fd_dat = -1;static struct gui_synclist lists;static struct open_plugin_entry_t op_entry;static const uint32_t open_plugin_csum = OPEN_PLUGIN_CHECKSUM;static const off_t op_entry_sz = sizeof(struct open_plugin_entry_t);
/* we only need the names for the first menu so don't bother reading paths yet */const off_t op_name_sz = OPEN_PLUGIN_NAMESZ + (op_entry.name - (char*)&op_entry);/*static char op_names[MAX_ENTRIES][OPEN_PLUGIN_NAMESZ + 1] = {0};*/
/* Forward declarations*/static uint32_t op_entry_add_path(const char *key, const char *plugin, const char *parameter, bool use_key);static int import_from_config(const char* cfgfile);static int export_to_config(const char* cfgfile);
static bool hash_exists(uint32_t hash, bool remove){ /* keeps track of hash entries * supply hash = 0, remove = true to erase all entries * supply hash = 0, remove = false; returns true if empty entries are available * supply a hash, remove = false; returns false if the hash does not exist & adds hash to the db * supply a hash, remove = true; returns true and removes the hash from the db * returns false if hash is unique */ static uint32_t seen_hashes[MAX_ENTRIES] = {0}; int i; if (hash == 0) { if (remove) { logf("removing all hashes"); for(i = 0; i < MAX_ENTRIES; i++) seen_hashes[i] = 0; } return seen_hashes[MAX_ENTRIES - 1] == 0; /* true if empty entries exist */ } for(i = 0; i < MAX_ENTRIES; i++) { uint32_t current_hash = seen_hashes[i]; if (current_hash == 0 && !remove) { logf("(%d) added new hash: %x", i, hash); seen_hashes[i] = hash; break; } if (current_hash == hash) { if (remove) { logf("(%d) remove hash: %x", i, hash); for (int j = i + 1; j < MAX_ENTRIES; j++, i++) { /* move everything above down 1*/ uint32_t next_hash = seen_hashes[j]; seen_hashes[i] = next_hash; if (next_hash == 0) break; } if (i + 1 == MAX_ENTRIES) /* handle last entry */ { seen_hashes[i] = 0; } } return true; } } return false; /* hash is unique */}
static bool _yesno_pop(const char* text){ const char *lines[]={text}; const struct text_message message={lines, 1}; bool ret = (rb->gui_syncyesno_run(&message,NULL,NULL)== YESNO_YES); FOR_NB_SCREENS(i) rb->screens[i]->clear_viewport(); return ret;}
static size_t pathbasename(const char *name, const char **nameptr){ const char *p = name; const char *q = p; const char *r = q;
while (*(p = GOBBLE_PATH_SEPCH(p))) { q = p; p = GOBBLE_PATH_COMP(++p); r = p; }
if (r == name && p > name) q = p, r = q--; /* root - return last slash */ /* else path is an empty string */
*nameptr = q; return r - q;}
static int op_entry_checksum(void){ if (op_entry.checksum != open_plugin_csum + (op_entry.lang_id <= OPEN_PLUGIN_LANG_INVALID ? 0 : LANG_LAST_INDEX_IN_ARRAY)) { return 0; } return 1;}
static bool op_entry_read(int fd, int selected_item, off_t data_sz){ rb->memset(&op_entry, 0, op_entry_sz); op_entry.lang_id = -1; return ((selected_item >= 0) && (fd >= 0) && (rb->lseek(fd, selected_item * op_entry_sz, SEEK_SET) >= 0) && (rb->read(fd, &op_entry, data_sz) == data_sz) && op_entry_checksum() > 0);}
static bool op_entry_read_name(int fd, int selected_item){ return op_entry_read(fd, selected_item, op_name_sz);}
static int op_entry_read_opx(const char *path){ int ret = -1; off_t filesize; int fd_opx;
if(rb->filetype_get_attr(path) == FILE_ATTR_OPX) { fd_opx = rb->open(path, O_RDONLY); if (fd_opx >= 0) { filesize = rb->ffilesize(fd_opx); ret = filesize; if (filesize == op_entry_sz && !op_entry_read(fd_opx, 0, op_entry_sz)) ret = 0; else if (op_entry_checksum() <= 0) ret = 0; rb->close(fd_opx); } } return ret;}
static void op_entry_config_export(void){ int i = 0; int len; char buf[MAX_PATH + 1];
do { i++; rb->snprintf(buf, sizeof(buf), "%s/%s%d%s", ROCKBOX_DIR, "open_plugins", i, ".cfg"); } while (i < 100 && rb->file_exists(buf));
if( rb->kbd_input(buf, MAX_PATH, NULL ) == 0 ) { len = rb->strlen(buf); if(len > 4 && buf[len] != PATH_SEPCH && rb->strcasecmp(&((buf)[len-4]), ".cfg") != 0) { rb->strcat(buf, ".cfg"); }
if (export_to_config(buf) > 0) return; }
rb->splashf( 2*HZ, "Save Failed (%s)", buf );
}
static void op_entry_export_opx(int selection){ int len; int fd = -1; char filename [MAX_PATH + 1];
if (!op_entry_read(fd_dat, selection, op_entry_sz) || op_entry_checksum() <= 0) goto failure;
rb->snprintf(filename, MAX_PATH, "%s/%s", PLUGIN_APPS_DIR, op_entry.name);
if( !rb->kbd_input( filename, MAX_PATH, NULL ) ) { len = rb->strlen(filename); if(len > OP_LEN && filename[len] != PATH_SEPCH && rb->strcasecmp(&((filename)[len-OP_LEN]), "." OP_EXT) != 0) { rb->strcat(filename, "." OP_EXT); }
fd = rb->open(filename, O_WRONLY | O_CREAT | O_TRUNC, 0666);
if (fd >= 0 && rb->write(fd, &op_entry, op_entry_sz) == op_entry_sz) { rb->close(fd); rb->splashf( 1*HZ, "File Saved (%s)", filename ); return; } rb->close(fd); }
failure: rb->splashf( 2*HZ, "Save Failed (%s)", filename );
}
static void op_entry_set_checksum(void){ op_entry.checksum = open_plugin_csum + (op_entry.lang_id <= OPEN_PLUGIN_LANG_INVALID ? 0 : LANG_LAST_INDEX_IN_ARRAY);}
static bool op_entry_set_name(void){ char tmp_buf[OPEN_PLUGIN_NAMESZ+1]; rb->strlcpy(tmp_buf, op_entry.name, OPEN_PLUGIN_NAMESZ); uint32_t crc = rb->crc_32(tmp_buf, sizeof(tmp_buf), 0xffffffff);
if (rb->kbd_input(tmp_buf, OPEN_PLUGIN_NAMESZ, NULL) >= 0) { rb->strlcpy(op_entry.name, tmp_buf, OPEN_PLUGIN_NAMESZ); return crc != rb->crc_32(tmp_buf, sizeof(tmp_buf), 0xffffffff); } return false;}
static int op_entry_set_path(void){ int ret = 0; char tmp_buf[OPEN_PLUGIN_BUFSZ+1];
if (op_entry.path[0] == '\0') rb->strcpy(op_entry.path, PLUGIN_DIR"/");
struct browse_context browse = { .dirfilter = SHOW_ALL, .flags = BROWSE_SELECTONLY | BROWSE_DIRFILTER, .title = rb->str(LANG_ADD), .icon = Icon_Plugin, .root = op_entry.path, .buf = tmp_buf, .bufsize = sizeof(tmp_buf), };
if (rb->rockbox_browse(&browse) == GO_TO_PREVIOUS) { ret = rb->strlcpy(op_entry.path, tmp_buf, OPEN_PLUGIN_BUFSZ); if (ret > OPEN_PLUGIN_BUFSZ) ret = 0; } return ret;}
static int op_entry_set_param_path(void){ int ret = 0; char tmp_buf[OPEN_PLUGIN_BUFSZ+1];
if (op_entry.param[0] == '\0') rb->strcpy(tmp_buf, "/"); else rb->strcpy(tmp_buf, op_entry.param);
struct browse_context browse = { .dirfilter = SHOW_ALL, .flags = BROWSE_SELECTONLY | BROWSE_DIRFILTER, .title = rb->str(LANG_PARAMETER), .icon = Icon_Plugin, .root = tmp_buf, .buf = tmp_buf, .bufsize = sizeof(tmp_buf), };
if (rb->rockbox_browse(&browse) == GO_TO_PREVIOUS) { ret = rb->strlcpy(op_entry.param, tmp_buf, OPEN_PLUGIN_BUFSZ); if (ret > OPEN_PLUGIN_BUFSZ) ret = 0; } return ret;}
static void op_entry_set_param(void){ if (_yesno_pop(ID2P(LANG_BROWSE))) op_entry_set_param_path();
char tmp_buf[OPEN_PLUGIN_BUFSZ+1]; rb->strlcpy(tmp_buf, op_entry.param, OPEN_PLUGIN_BUFSZ); if (rb->kbd_input(tmp_buf, OPEN_PLUGIN_BUFSZ, NULL) >= 0) rb->strlcpy(op_entry.param, tmp_buf, OPEN_PLUGIN_BUFSZ);}
static int op_et_exclude_invalid(struct open_plugin_entry_t *op_entry, int item, void *data){ (void)item; (void)data; if (op_entry->hash == 0 || op_entry->name[0] == '\0') { logf("Exclude entry %d - Bad hash", item); return 0; } if (op_entry->checksum != open_plugin_csum + (op_entry->lang_id <= OPEN_PLUGIN_LANG_INVALID ? 0 : LANG_LAST_INDEX_IN_ARRAY)) { logf("Exclude entry %d - Bad csum", item); return 0; } if (!rb->file_exists(op_entry->path)) { logf("Exclude entry %d - Bad path '%s'", item, op_entry->path); return 0; } logf("%s Include entry %d %s - hash %x", __func__, item, (op_entry->lang_id >= 0 ? "[Builtin]" : "[User]"), op_entry->hash); return 1;}
static int op_et_exclude_hash(struct open_plugin_entry_t *op_entry, int item, void *data){ (void)item;
if (data) { uint32_t *hash = data;
if (op_entry->hash != *hash) return op_et_exclude_invalid(op_entry, item, data); } logf("Exclude entry %d - hash %x", item, op_entry->hash); return 0;}
static int op_et_exclude_builtin(struct open_plugin_entry_t *op_entry, int item, void *data){ (void)item; (void)data;
if (op_entry->lang_id >= 0) { logf("Exclude entry %d - Builtin", item); return 0; }
return op_et_exclude_invalid(op_entry, item, data);}
static int op_et_exclude_user(struct open_plugin_entry_t *op_entry, int item, void *data){ (void)item; (void)data;
if (op_entry->lang_id < 0) { logf("Exclude entry %d - User", item); return 0; } return op_et_exclude_invalid(op_entry, item, data);}
static int op_entry_transfer(int fd, int fd_tmp, int(*compfn)(struct open_plugin_entry_t*, int, void*), void *data){ int entries = -1; int skipped = 0; if (fd_tmp >= 0 && fd >= 0 && rb->lseek(fd, 0, SEEK_SET) == 0) { entries = 0; while (rb->read(fd, &op_entry, op_entry_sz) == op_entry_sz) { if (compfn && compfn(&op_entry, entries + skipped, data) > 0 && op_entry_checksum() > 0) { rb->write(fd_tmp, &op_entry, op_entry_sz); entries++; } else skipped++; } logf("%s %d entries %d skipped", __func__, entries, skipped); } else { logf("%s Error: fd %d, fd_tmp %d, seekfd: %d", __func__, fd, fd_tmp, (int) rb->lseek(fd, 0, SEEK_SET)); } return entries + 1;}
#if 0static int op_entry_exists(int fd){ logf("%s? %s - %s", __func__, op_entry.name, op_entry.path); /* returns index of the entry that already exists if not found returns -1 */ static struct open_plugin_entry_t op_entry_rd; int entries = 0; if (fd >= 0 && rb->lseek(fd, 0, SEEK_SET) == 0) { while (rb->read(fd, &op_entry_rd, op_entry_sz) == op_entry_sz) { logf("rd: %s - %s", op_entry_rd.name, op_entry_rd.path); if (rb->memcmp(&op_entry_rd, &op_entry, op_entry_sz) == 0) { logf("%s entry exists @ %d", op_entry_rd.name, entries); return entries; } entries++; } } logf("%s is unique in %d entries", op_entry.name, entries); return -1;}#endif
static bool browse_configs(void){ int entries = 0; char tmp_buf[MAX_PATH+1];
struct browse_context browse = { .dirfilter = SHOW_CFG, .flags = BROWSE_SELECTONLY | BROWSE_DIRFILTER, .title = rb->str(LANG_CUSTOM_CFG), .icon = Icon_Plugin, .root = ROCKBOX_DIR, .buf = tmp_buf, .bufsize = sizeof(tmp_buf), };
if (rb->rockbox_browse(&browse) == GO_TO_PREVIOUS) { logf("import from %s\n", tmp_buf); if(rb->filetype_get_attr(tmp_buf) == FILE_ATTR_CFG) { entries = import_from_config(tmp_buf); rb->splashf(HZ *2, "Imported %d entries", entries); } } return (entries > 0);}
static uint32_t op_entry_add_path(const char *key, const char *plugin, const char *parameter, bool use_key){ char buf[MAX_PATH]; uint32_t hash; uint32_t newhash; char *pos = "";; int fd_tmp = -1; use_key = (use_key == true && key != NULL);
if (key) { open_plugin_get_hash(key, &hash); op_entry.hash = hash; } else if (op_entry.lang_id < 0 && plugin) { /* need to keep the old hash so we can remove the old entry */ hash = op_entry.hash; open_plugin_get_hash(plugin, &newhash); op_entry.hash = newhash; } else hash = op_entry.hash;
if (plugin) { int fattr = rb->filetype_get_attr(plugin); /* name */ if (use_key) { op_entry.lang_id = -1; rb->strlcpy(op_entry.name, key, OPEN_PLUGIN_NAMESZ); }
if (pathbasename(plugin, (const char **)&pos) == 0) pos = "\0"; if (op_entry.name[0] == '\0' || op_entry.lang_id >= 0) rb->strlcpy(op_entry.name, pos, OPEN_PLUGIN_NAMESZ);
if ((!parameter || parameter[0] == '\0') && fattr != FILE_ATTR_ROCK && fattr != FILE_ATTR_OPX) { rb->strlcpy(op_entry.param, plugin, OPEN_PLUGIN_BUFSZ); parameter = op_entry.param; plugin = rb->filetype_get_plugin(fattr, buf, sizeof(buf)); if (!plugin) { rb->splashf(HZ * 2, ID2P(LANG_OPEN_PLUGIN_NOT_A_PLUGIN), pos); return 0; } }
if(fattr == FILE_ATTR_ROCK) { fd_tmp = rb->open(OPEN_PLUGIN_DAT ".tmp", O_WRONLY | O_CREAT | O_TRUNC, 0666); if (fd_tmp < 0) return 0;
/* path */ if (plugin != op_entry.path) rb->strlcpy(op_entry.path, plugin, OPEN_PLUGIN_BUFSZ);
if(parameter || rb->strncmp(plugin, VIEWERS_DIR, sizeof(VIEWERS_DIR) -1) == 0) { if (!parameter) parameter = ""; /* param matches lang_id so we want to set parameter */ bool needs_param = op_entry.lang_id >= 0 && (rb->strcmp(parameter, rb->str(op_entry.lang_id)) == 0); if (needs_param || (parameter[0] == '\0' && _yesno_pop(ID2P(LANG_PARAMETER)))) { if (needs_param) op_entry.param[0] = '\0'; op_entry_set_param(); if (!use_key && pathbasename(op_entry.param, (const char **)&pos) != 0) rb->strlcpy(op_entry.name, pos, OPEN_PLUGIN_NAMESZ);
} else if (parameter != op_entry.param) rb->strlcpy(op_entry.param, parameter, OPEN_PLUGIN_BUFSZ); }
op_entry_set_checksum();
if (!use_key) { if (op_entry.lang_id <0) { open_plugin_get_hash(op_entry.name, &hash); op_entry.hash = hash; } if (hash_exists(op_entry.hash, false) && _yesno_pop(ID2P(LANG_REALLY_OVERWRITE)) == false) { logf("%s error: duplicate key exists: '%s' lang id: %d hash: %x", __func__, key, op_entry.lang_id, op_entry.hash); rb->close(fd_tmp); rb->remove(OPEN_PLUGIN_DAT ".tmp"); return op_entry.hash; } }
rb->write(fd_tmp, &op_entry, op_entry_sz); /* add new entry first */ } else if(op_entry_read_opx(plugin) == op_entry_sz) { fd_tmp = rb->open(OPEN_PLUGIN_DAT ".tmp", O_WRONLY | O_CREAT | O_TRUNC, 0666); if (fd_tmp < 0) return 0;
if (op_entry.lang_id <0) { open_plugin_get_hash(op_entry.name, &hash); }
op_entry.hash = hash; op_entry_set_checksum();
if (hash_exists(op_entry.hash, false)) { logf("%s error: duplicate key exists: '%s' lang id: %d hash: %x", __func__, key, op_entry.lang_id, op_entry.hash); rb->close(fd_tmp); rb->remove(OPEN_PLUGIN_DAT ".tmp"); return op_entry.hash; }
rb->write(fd_tmp, &op_entry, op_entry_sz); /* add new entry first */ } else { if (op_entry.lang_id != LANG_SHORTCUTS) rb->splashf(HZ * 2, ID2P(LANG_OPEN_PLUGIN_NOT_A_PLUGIN), pos); return 0; } }
/*logf("OP add key: '%s' lang id: %d hash: %x", op_entry.name, op_entry.lang_id, op_entry.hash);*/ if (op_entry_transfer(fd_dat, fd_tmp, op_et_exclude_hash, &hash) > 0) { rb->close(fd_tmp); rb->close(fd_dat); fd_dat = -1; rb->remove(OPEN_PLUGIN_DAT); rb->rename(OPEN_PLUGIN_DAT ".tmp", OPEN_PLUGIN_DAT); } else { rb->close(fd_tmp); rb->remove(OPEN_PLUGIN_DAT ".tmp"); hash = 0; }
return hash;}
void op_entry_browse_add(int selection){ logf("%s", __func__); char* key; op_entry_read(fd_dat, selection, op_entry_sz); if (op_entry_set_path() > 0) { if (op_entry.lang_id >= 0) key = rb->str(op_entry.lang_id); else key = op_entry.path;
op_entry_add_path(key, op_entry.path, NULL, false); }}
static void op_entry_remove(int selection){ int entries = rb->lseek(fd_dat, 0, SEEK_END) / op_entry_sz; int32_t hash = 0; int lang_id = -1;
if (entries > 0 && _yesno_pop(ID2P(LANG_REMOVE))) { op_entry_read(fd_dat, selection, op_entry_sz); if (rb->lseek(fd_dat, selection * op_entry_sz, SEEK_SET) >= 0) { if (op_entry.lang_id >= 0) { lang_id = op_entry.lang_id; hash = op_entry.hash; if(lang_id == LANG_START_SCREEN && rb->global_settings->start_in_screen == GO_TO_PLUGIN +2) { rb->global_settings->start_in_screen = GO_TO_ROOT + 2; /* default */ } } hash_exists(op_entry.hash, true); rb->memset(&op_entry, 0, op_entry_sz); op_entry.lang_id = lang_id; op_entry.hash = hash; rb->write(fd_dat, &op_entry, op_entry_sz); } }}
static void op_entry_remove_empty(void){ bool resave = false; if (fd_dat >= 0 && rb->lseek(fd_dat, 0, SEEK_SET) == 0) { while (resave == false && rb->read(fd_dat, &op_entry, op_entry_sz) == op_entry_sz) { if (op_entry.hash == 0 || !op_entry_checksum()) resave = true; } }
if (resave) { int fd_tmp = rb->open(OPEN_PLUGIN_DAT ".tmp", O_WRONLY | O_CREAT | O_TRUNC, 0666); if (fd_tmp < 0) return;
if ((op_entry_transfer(fd_dat, fd_tmp, &op_et_exclude_user, NULL) + op_entry_transfer(fd_dat, fd_tmp, &op_et_exclude_builtin, NULL)) > 0) { rb->close(fd_tmp); rb->close(fd_dat); fd_dat = -1; rb->remove(OPEN_PLUGIN_DAT); rb->rename(OPEN_PLUGIN_DAT ".tmp", OPEN_PLUGIN_DAT); } else { rb->close(fd_tmp); rb->remove(OPEN_PLUGIN_DAT ".tmp"); } }
}
static int op_entry_run(void){ int ret = PLUGIN_ERROR; char* path; char* param; if (op_entry.hash != 0 && op_entry.path[0] != '\0') { //rb->splash(1, ID2P(LANG_OPEN_PLUGIN)); path = op_entry.path; param = op_entry.param; if (param[0] == '\0') param = NULL;
ret = rb->plugin_open(path, param); } return ret;}
static const char* list_get_name_cb(int selected_item, void* data, char* buf, size_t buf_len){ /*TODO memoize names so we don't keep reading the disk when not necessary */ if (data == (void*) &MENU_ID_MAIN) /* check address */ { if (selected_item == rb->gui_synclist_get_nb_items(&lists) - 1) rb->snprintf(buf, buf_len, "[%s]", rb->str(LANG_ADD)); else if (op_entry_read_name(fd_dat, selected_item)) { if (op_entry.lang_id >= 0) rb->snprintf(buf, buf_len, "%s [%s] ", rb->str(op_entry.lang_id), op_entry.name); else if (rb->strlcpy(buf, op_entry.name, buf_len) >= buf_len) rb->strcpy(&buf[buf_len-10], " ..."); } else return "?"; } else /* op_entry should already be loaded */ { switch(selected_item) { case 0: return ID2P(LANG_NAME); case 1: if (op_entry.lang_id >= 0) rb->snprintf(buf, buf_len, "%s [%s] ", rb->str(op_entry.lang_id), op_entry.name); else if (rb->strlcpy(buf, op_entry.name, buf_len) >= buf_len) rb->strcpy(&buf[buf_len-10], " ..."); break; case 2: return ID2P(LANG_DISPLAY_FULL_PATH); case 3: if (rb->strlcpy(buf, op_entry.path, buf_len) >= buf_len) rb->strcpy(&buf[buf_len-10], " ..."); break; case 4: return ID2P(LANG_PARAMETER); case 5: if (op_entry.param[0] == '\0') return "[NULL]"; else if (rb->strlcpy(buf, op_entry.param, buf_len) >= buf_len) rb->strcpy(&buf[buf_len-10], " ..."); break; case 6: return ""; case 7: return ID2P(LANG_BACK); default: return "?"; } }
return buf;}
static int list_voice_cb(int list_index, void* data){ if (data == (void*) &MENU_ID_MAIN) /* check address */ { if (list_index == rb->gui_synclist_get_nb_items(&lists) - 1) { static const long langids[] = {LANG_ADD, VOICE_EXT_ROCK, TALK_FINAL_ID}; rb->talk_idarray(langids, false); } else if (op_entry_read_name(fd_dat, list_index)) { if (op_entry.lang_id >= 0) { rb->talk_id(op_entry.lang_id, false); rb->talk_id(VOICE_PAUSE, true); rb->talk_force_enqueue_next(); } return rb->talk_spell(op_entry.name, false); } } else { switch(list_index) { case 0: rb->talk_id(LANG_NAME, false); rb->talk_id(VOICE_PAUSE, true);
if (op_entry.lang_id >= 0) { rb->talk_id(op_entry.lang_id, true); rb->talk_id(VOICE_PAUSE, true); rb->talk_force_enqueue_next(); } return rb->talk_spell(op_entry.name, false); case 2: rb->talk_id(LANG_DISPLAY_FULL_PATH, false); return rb->talk_fullpath(op_entry.path, true); case 4: rb->talk_id(LANG_PARAMETER, false); if (op_entry.param[0] == '\0') return rb->talk_id(VOICE_BLANK, true); if (rb->file_exists(op_entry.param)) return rb->talk_fullpath(op_entry.param, true); return rb->talk_spell(op_entry.param, true); case 6: return rb->talk_id(LANG_BACK, false); default: return 0; } }
return 0;}
static void synclist_set(char* menu_id, int selection, int items, int sel_size){ if (selection < 0) selection = 0;
rb->gui_synclist_init(&lists,list_get_name_cb, menu_id, false, sel_size, NULL);
if (menu_id == (void*) &MENU_ID_MAIN) rb->gui_synclist_set_title(&lists, rb->str(LANG_OPEN_PLUGIN), Icon_Plugin); rb->gui_synclist_set_voice_callback(&lists, list_voice_cb); rb->gui_synclist_set_nb_items(&lists,items); rb->gui_synclist_select_item(&lists, selection); list_voice_cb(selection, menu_id);}
static int context_menu_cb(int action, const struct menu_item_ex *this_item, struct gui_synclist *this_list){ (void)this_item;
int selection = rb->gui_synclist_get_sel_pos(this_list);
if(action == ACTION_ENTER_MENUITEM) { if (selection == 0 && op_entry.lang_id >= 0 && op_entry.lang_id != LANG_OPEN_PLUGIN) { rb->gui_synclist_set_title(this_list, rb->str(op_entry.lang_id), 0); } } else if ((action == ACTION_STD_OK)) { /*Run, Edit, Remove, Export, Blank, Import, Add, Back*/ switch(selection) { case 0:case 1:case 2:case 3:case 4:case 5:case 7: return ACTION_STD_OK; case 6: /*blank*/ break; default: return ACTION_STD_CANCEL; } rb->gui_synclist_draw(this_list); /* redraw */ return 0; }
return action;}
static void edit_menu(int selection){ int selected_item; bool exit = false; bool name_set = false; int action = 0;
if (!op_entry_read(fd_dat, selection, op_entry_sz)) return;
if (op_entry.hash != 0) /* remove old hash */ hash_exists(op_entry.hash, true);
uint32_t crc = rb->crc_32(&op_entry, op_entry_sz, 0xffffffff);
synclist_set(MENU_ID_EDIT, 2, 8, 2); rb->gui_synclist_draw(&lists);
while (!exit) { action = rb->get_action(CONTEXT_LIST,TIMEOUT_BLOCK);
if (rb->gui_synclist_do_button(&lists, &action)) continue; selected_item = rb->gui_synclist_get_sel_pos(&lists); switch (action) { case ACTION_STD_OK: if (selected_item == 0) { name_set = op_entry_set_name(); } else if (selected_item == 2) op_entry_set_path(); else if (selected_item == 4) { op_entry_set_param(); /* if user already set the name they probably don't want us to change it */ if (!name_set && op_entry.lang_id < 0 && rb->file_exists(op_entry.param)) { char *slash = rb->strrchr(op_entry.param, '/'); if(slash) rb->strlcpy(op_entry.name, slash+1, OPEN_PLUGIN_NAMESZ); } } else exit = true;
rb->gui_synclist_draw(&lists); break; case ACTION_STD_CANCEL: exit = true; break; } }
if (crc != rb->crc_32(&op_entry, op_entry_sz, 0xffffffff) && _yesno_pop(ID2P(LANG_SAVE)) == true) { char *param = op_entry.param; if (param[0] == '\0') param = NULL;
op_entry_add_path(NULL, op_entry.path, param, false); fd_dat = rb->open(OPEN_PLUGIN_DAT, O_RDWR, 0666); } else hash_exists(op_entry.hash, false);}
static int context_menu(int selection){ int selected_item; if (selection == rb->gui_synclist_get_nb_items(&lists) -1) { op_entry_browse_add(-1); rb->plugin_open(rb->plugin_get_current_filename(), "\0"); return OP_PLUGIN_RESTART; } if (op_entry_read(fd_dat, selection, op_entry_sz)) { MENUITEM_STRINGLIST(menu, op_entry.name, context_menu_cb, ID2P(LANG_RUN), ID2P(LANG_EDIT), ID2P(LANG_REMOVE), ID2P(LANG_EXPORT), ID2P(LANG_SAVE_SETTINGS), ID2P(LANG_CUSTOM_CFG), ID2P(VOICE_BLANK), ID2P(LANG_ADD), ID2P(LANG_BACK));
selected_item = rb->do_menu(&menu, 0, NULL, false); logf("%s %d", __func__, selected_item); switch (selected_item) { case 0: /*run*/ return PLUGIN_GOTO_PLUGIN; case 1: /*edit*/ edit_menu(selection); break; case 2: /*remove*/ op_entry_remove(selection); break; case 3: /*export*/ op_entry_export_opx(selection); break; case 4: /* export to cfg */ op_entry_config_export(); case 5: /*import from cfg*/ if (browse_configs()) { rb->plugin_open(rb->plugin_get_current_filename(), "\0"); return OP_PLUGIN_RESTART; } break; case 6: /*blank*/ break; case 7: /*add*/ op_entry_browse_add(-1); rb->plugin_open(rb->plugin_get_current_filename(), "\0"); return OP_PLUGIN_RESTART; default: break;
} return PLUGIN_OK; } return PLUGIN_ERROR;}
/* Read up to buffer_size chars from a quoted string * within fd into buffer and return number of bytes read. * A string starts with a quote character (single or double quote) * and ends with a matching closing quote. Neither opening or closing quotes * are stored in buffer. Too small buf or no opening and closing quote is an error. * If an error occurs, -1 is returned (and buffer is cleared). * If buffer too small file will still be advanced to the closing quote/LF/EOF */static int read_quoted_string(int fd, char* buffer, int buffer_size){ int pos = 0; char ch; char quote = '\0'; /*logf("%s fd: %d bufsz: %d", __func__, fd, buffer_size);*/ while (rb->read(fd, &ch, 1) == 1) { if (ch == '\n') /*LF marks end of line*/ { rb->lseek(fd, -1, SEEK_CUR);/*back up cursor to LF so calling fn sees it*/ break; /* fail */ } if (quote == '\0' && (ch == '\'' || ch == '"')) /*handle single or double quotes*/ { quote = ch; } else if (quote != '\0') { if (ch == quote) { if (pos < buffer_size) { buffer[pos] = '\0'; /*end quote*/ return pos + 1; } break; /*fail*/ } if (pos < buffer_size) { buffer[pos] = ch; /*inside quote*/ pos++; } } }
/*fail*/ /*logf("Error %s", __func__);*/ buffer[0] = '\0'; return -1;}
static int lang_english_to_id(const char *english){ int i; unsigned char *ptr; size_t ptrlen, len = rb->strlen(english); for (i = 0; i < LANG_LAST_INDEX_IN_ARRAY; i++) { ptr = rb->language_strings[i]; ptrlen = rb->strlen((char *)ptr); if ((ptrlen == len) && rb->memcmp(ptr, english, ptrlen) == 0) return i; } return -1;}
static bool op_entry_config_import(int cfg_fd, int fd_tmp){ /* NOTE: assumes cfg_fd is valid */ /*"key", "name", "path", "param"*/ /*"Start Screen", "logo.rock", "/.rockbox/rocks/demos/logo.rock", ""*/ /*"[USER]", "text_viewer.rock", "/.rockbox/rocks/viewers/text_viewer.rock", "/text.txt"*/ rb->memset(&op_entry, 0, op_entry_sz);
static char errmsg[MAX_PATH]; static char keybuf[MAX_PATH]; int32_t lang_id; uint32_t hash;
if (read_quoted_string(cfg_fd, keybuf, sizeof(keybuf)) < 0) { logf("%s error: importing key entry @ %d", __func__, 0); rb->snprintf(errmsg, sizeof(errmsg), "importing key entry @ %d", 1); rb->splashf(HZ*2, ID2P(LANG_ERROR_FORMATSTR), errmsg); return false; /* fail */ }
lang_id = lang_english_to_id(keybuf); if (lang_id < 0) { int rd = read_quoted_string(cfg_fd, keybuf, sizeof(keybuf)); /* grab name field */ if(rd < 0) { logf("%s error: importing key entry @ %d", __func__, 1); rb->snprintf(errmsg, sizeof(errmsg), "importing key entry @ %d", 1); rb->splashf(HZ*2, ID2P(LANG_ERROR_FORMATSTR), errmsg); return false; /* fail */ } rb->lseek(cfg_fd, -(rd+2), SEEK_CUR); /* restore position to read name again */ }
int i, bufsz; char *field[3] = {op_entry.name, op_entry.path, op_entry.param}; for (i = 0, bufsz = OPEN_PLUGIN_NAMESZ; i < (int)ARRAYLEN(field); i++) { if (read_quoted_string(cfg_fd, field[i], bufsz) < 0) { logf("%s error: importing entry @ %d", __func__, i); logf("OP import key: '%s' name: '%s' '%s' '%s'", keybuf, op_entry.name, op_entry.path, op_entry.param); rb->memset(&op_entry, 0, op_entry_sz); rb->snprintf(errmsg, sizeof(errmsg), "importing entry %s @ %d", keybuf, i); rb->splashf(HZ*2, ID2P(LANG_ERROR_FORMATSTR), errmsg); return false; /* fail */ } bufsz = OPEN_PLUGIN_BUFSZ; }
if (!rb->file_exists(op_entry.path)) { logf("%s error: '%s' '%s' does not exist", __func__, keybuf, op_entry.path); rb->splashf(HZ*2, ID2P(LANG_PLUGIN_CANT_OPEN), op_entry.path); return false; /* fail */ }
if (lang_id <0) { open_plugin_get_hash(op_entry.name, &hash);
} else { open_plugin_get_hash(keybuf, &hash); }
op_entry.hash = hash; op_entry.lang_id = lang_id;
/*logf("OP import key: '%s' name: '%s' '%s' '%s'", keybuf, op_entry.name, op_entry.path, op_entry.param);*/
op_entry_set_checksum();
if (fd_tmp >= 0 && fd_dat >= 0) { if (hash_exists(op_entry.hash, false)) { logf("%s error: duplicate key exists: '%s' lang id: %d hash: %x", __func__, keybuf, lang_id, hash); return false; }
logf("writing to tmp: %s - %s", op_entry.name, op_entry.path);
if (rb->write(fd_tmp, &op_entry, op_entry_sz) != op_entry_sz)/* add new entry */ return false; } else { logf("%s error: bad fd dat: %d tmp: %d", __func__, fd_dat, fd_tmp); return false; }
return true;}
static int import_from_config(const char* cfgfile){ logf("%s() %s\r\n", __func__, cfgfile); int fd; char ch; int entries = 0; static char line[sizeof("openplugin:")];
fd = rb->open_utf8(cfgfile, O_RDONLY); if (fd < 0) return -1;
int fd_tmp = rb->open(OPEN_PLUGIN_DAT ".tmp", O_WRONLY | O_CREAT | O_TRUNC, 0666); if (fd_tmp < 0) { logf("%s error: can not open '%s'", __func__, OPEN_PLUGIN_DAT ".tmp"); return -1; }
while ((rb->read(fd, line, sizeof line) - 1) == sizeof(line) - 1) { if (rb->strncasecmp(line, "openplugin:", sizeof("openplugin:") -1) == 0) { if (op_entry_config_import(fd, fd_tmp)) entries++; }
while (rb->read(fd, &ch, 1) == 1) /* continue reading till EOL */ { if (ch == '\n') break; } } /* while(...) */
rb->close(fd);#if 1 if (entries > 0 && op_entry_transfer(fd_dat, fd_tmp, &op_et_exclude_user, NULL) > 0 && op_entry_transfer(fd_dat, fd_tmp, &op_et_exclude_builtin, NULL) > 0)#else if (entries > 0 && op_entry_transfer(fd_dat, fd_tmp, op_et_exclude_invalid, 0) >= 0)#endif { logf("%s imported %d entries", __func__, entries); rb->close(fd_tmp); rb->close(fd_dat); fd_dat = -1; rb->remove(OPEN_PLUGIN_DAT); rb->rename(OPEN_PLUGIN_DAT ".tmp", OPEN_PLUGIN_DAT); } else { logf("%s error: can not transfer entries", __func__); if (entries > 0) { logf("%s error: can not transfer entries to '%s'", __func__, OPEN_PLUGIN_DAT ".tmp"); entries = -1; } rb->close(fd_tmp); rb->remove(OPEN_PLUGIN_DAT ".tmp"); }
return entries;}
static int export_to_config(const char* cfgfile){ logf("%s() %s\r\n", __func__, cfgfile); int cfg_fd; char *lang_name; int fd; int index = 0;
cfg_fd = rb->open_utf8(cfgfile, O_WRONLY | O_CREAT | O_TRUNC); if (cfg_fd < 0) return index;
fd = rb->open_utf8(OPEN_PLUGIN_DAT, O_RDONLY);
if (fd < 0) { logf("%s error: opening %s", __func__, OPEN_PLUGIN_DAT); rb->close(cfg_fd); rb->remove(cfgfile); return index; /* OPEN_PLUGIN_NOT_FOUND */ } while (op_entry_read(fd, index, op_entry_sz)) { index++; /* don't save the LANG_OPEN_PLUGIN entry -- it is for internal use */ if (op_entry.lang_id == LANG_OPEN_PLUGIN) { continue; } if (op_entry.lang_id >=0) lang_name = rb->str(op_entry.lang_id); else lang_name = "[USER]"; /* needs to be an invalid lang string */ bool dblquote = rb->strchr(op_entry.name, '"') != NULL || rb->strchr(op_entry.param, '"') != NULL;
const char* fmtstr = "%s: \"%s\", \"%s\", \"%s\", \"%s\"\n";
if (dblquote) /* if using double quotes export with single quotes */ { fmtstr = "%s: '%s', '%s', '%s', '%s'\n"; } rb->fdprintf(cfg_fd,fmtstr, OPEN_PLUGIN_CFGNAME, lang_name, op_entry.name, op_entry.path, op_entry.param);
logf("openplugin[%d]: \"%s\", \"%s\", \"%s\", \"%s\"\n lang id: %d hash: %x, csum: %x\n", index, lang_name, op_entry.name, op_entry.path, op_entry.param, op_entry.lang_id, op_entry.hash, op_entry.checksum); } rb->close(fd); rb->close(cfg_fd); logf("%s exported %d entries", __func__, index); if (index == 0) { /* Nothing to export */ rb->remove(cfgfile); }
return index;}
enum plugin_status plugin_start(const void* parameter){ int ret = PLUGIN_OK; uint32_t hash = 0; int item = -1; int selection = -1; int action; int items; int res; char *path; bool exit = false;
const int creat_flags = O_RDWR | O_CREAT;
reopen_datfile:
fd_dat = rb->open(OPEN_PLUGIN_DAT, creat_flags, 0666);
hash_exists(0, true); while (rb->read(fd_dat, &op_entry, op_entry_sz) == op_entry_sz) { hash_exists(op_entry.hash, false); }
if (fd_dat < 0) exit = true;
items = rb->lseek(fd_dat, 0, SEEK_END) / op_entry_sz;
if (parameter) { path = (char*)parameter; while (path[0] == ' ') path++;
if (rb->strncasecmp(path, "-add", 4) == 0) { parameter = NULL; op_entry_browse_add(-1); rb->close(fd_dat); fd_dat = -1; goto reopen_datfile; } if(rb->filetype_get_attr(path) == FILE_ATTR_CFG) { int ret = import_from_config(path); rb->close(fd_dat); if (ret >= 0) return PLUGIN_OK; return PLUGIN_ERROR; }
res = op_entry_read_opx(path); if (res >= 0) { if (res == op_entry_sz) { exit = true; ret = op_entry_run(); } } else { open_plugin_get_hash(parameter, &hash); rb->lseek(fd_dat, 0, SEEK_SET); while (rb->read(fd_dat, &op_entry, op_entry_sz) == op_entry_sz) { item++; if (op_entry.hash == hash) { selection = item; break; } }
if (selection >= 0) { if (op_entry_read(fd_dat, selection, op_entry_sz)) { /* param matches lang_id so we want to set the parameter */ if (op_entry.lang_id >= 0 && rb->strcmp(op_entry.param, rb->str(op_entry.lang_id)) == 0) { op_entry_add_path(NULL, op_entry.path, op_entry.param, false); exit = true; } else { ret = op_entry_run(); if (ret == PLUGIN_GOTO_PLUGIN) exit = true; } } } else { op_entry_read(fd_dat, selection, op_entry_sz); if (op_entry_add_path(parameter, parameter, "\0", false) > 0) { selection = 0; items++; fd_dat = rb->open(OPEN_PLUGIN_DAT, creat_flags, 0666); if (!fd_dat) exit = true; } } }/* OP_EXT */ }
for (int i = items - 1; i > 0 && !exit; i--) { if (!op_entry_read(fd_dat, i, op_entry_sz)) items--; }# if 0 if (items < 1 && !exit) { char* cur_filename = rb->plugin_get_current_filename();
if (op_entry_add_path(rb->str(LANG_ADD), cur_filename, "-add", true)) { rb->close(fd_dat); fd_dat = -1; parameter = NULL; goto reopen_datfile; } rb->close(fd_dat); return PLUGIN_ERROR; }#endif if (!exit) { synclist_set(MENU_ID_MAIN, selection, items + 1, 1); rb->gui_synclist_draw(&lists);
while (!exit && fd_dat >= 0) { action = rb->get_action(CONTEXT_LIST,TIMEOUT_BLOCK);
if (rb->gui_synclist_do_button(&lists, &action)) continue; selection = rb->gui_synclist_get_sel_pos(&lists); switch (action) { case ACTION_STD_CONTEXT: ret = context_menu(selection); if (ret == OP_PLUGIN_RESTART) { ret = PLUGIN_GOTO_PLUGIN; exit = true; break; } else if (ret != PLUGIN_GOTO_PLUGIN) { synclist_set(MENU_ID_MAIN, selection, items + 1, 1); rb->gui_synclist_draw(&lists); break; } /* fallthrough */ case ACTION_STD_OK: if (selection == items) { op_entry_browse_add(-1); rb->plugin_open(rb->plugin_get_current_filename(), "\0"); ret = PLUGIN_GOTO_PLUGIN; exit = true; } else if (op_entry_read(fd_dat, selection, op_entry_sz)) { ret = op_entry_run(); exit = true; } break; case ACTION_STD_CANCEL: case ACTION_STD_MENU: { selection = -2; exit = true; break; } default: if (rb->default_event_handler(action) == SYS_USB_CONNECTED) { op_entry_remove_empty(); rb->close(fd_dat); return PLUGIN_USB_CONNECTED; } break; } } op_entry_remove_empty(); rb->gui_synclist_scroll_stop(&lists); }
rb->close(fd_dat); if (ret != PLUGIN_OK) return ret; else return PLUGIN_OK;}