610 lines
18 KiB
C
610 lines
18 KiB
C
/* MiniDLNA media server
|
|
* Copyright (C) 2008 Justin Maggard
|
|
*
|
|
* 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 program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with this program; if not, write to the Free Software
|
|
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
|
|
*/
|
|
#include <stdio.h>
|
|
#include <string.h>
|
|
#include <stdlib.h>
|
|
#include <unistd.h>
|
|
#include <dirent.h>
|
|
#include <locale.h>
|
|
#include <libgen.h>
|
|
#include <sys/stat.h>
|
|
|
|
#include <sqlite3.h>
|
|
|
|
#include "upnpglobalvars.h"
|
|
#include "metadata.h"
|
|
#include "utils.h"
|
|
#include "sql.h"
|
|
#include "scanner.h"
|
|
|
|
int
|
|
is_video(const char * file)
|
|
{
|
|
return (ends_with(file, ".mpg") || ends_with(file, ".mpeg") ||
|
|
ends_with(file, ".asf") || ends_with(file, ".wmv") ||
|
|
ends_with(file, ".mp4") || ends_with(file, ".m4v") ||
|
|
ends_with(file, ".mts") || ends_with(file, ".m2ts") ||
|
|
ends_with(file, ".vob") || ends_with(file, ".ts") ||
|
|
ends_with(file, ".avi") || ends_with(file, ".xvid"));
|
|
}
|
|
|
|
int
|
|
is_audio(const char * file)
|
|
{
|
|
return (ends_with(file, ".mp3") || ends_with(file, ".flac") ||
|
|
ends_with(file, ".fla") || ends_with(file, ".flc") ||
|
|
ends_with(file, ".m4a") || ends_with(file, ".aac"));
|
|
}
|
|
|
|
int
|
|
is_image(const char * file)
|
|
{
|
|
return (ends_with(file, ".jpg") || ends_with(file, ".jpeg"));
|
|
}
|
|
|
|
long long int
|
|
insert_container(const char * tmpTable, const char * item, const char * rootParent, const char *subParent,
|
|
const char *class, const char *artist, const char *genre, const char *album_art)
|
|
{
|
|
char **result;
|
|
char *sql;
|
|
int cols, rows, ret;
|
|
int parentID = 0, objectID = 0;
|
|
sqlite_int64 detailID;
|
|
|
|
sql = sqlite3_mprintf("SELECT * from %s where ITEM = '%q' and SUBITEM = '%q'", tmpTable, item, subParent);
|
|
ret = sql_get_table(db, sql, &result, &rows, &cols);
|
|
sqlite3_free(sql);
|
|
if( cols )
|
|
{
|
|
sscanf(result[4], "%X", &parentID);
|
|
sqlite3_free_table(result);
|
|
sql = sqlite3_mprintf("SELECT OBJECT_ID, max(ID) from OBJECTS where PARENT_ID = '%s$%X'", rootParent, parentID);
|
|
ret = sql_get_table(db, sql, &result, 0, &cols);
|
|
sqlite3_free(sql);
|
|
if( result[2] && (sscanf(rindex(result[2], '$')+1, "%X", &objectID) == 1) )
|
|
{
|
|
objectID++;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
sqlite3_free_table(result);
|
|
sql = sqlite3_mprintf("SELECT OBJECT_ID, max(ID) from OBJECTS where PARENT_ID = '%s'", rootParent);
|
|
sql_get_table(db, sql, &result, &rows, &cols);
|
|
sqlite3_free(sql);
|
|
if( result[2] && (sscanf(rindex(result[2], '$')+1, "%X", &parentID) == 1) )
|
|
{
|
|
parentID++;
|
|
}
|
|
else
|
|
{
|
|
parentID = 0;
|
|
}
|
|
detailID = GetFolderMetadata(item, artist, genre, album_art);
|
|
sql = sqlite3_mprintf( "INSERT into OBJECTS"
|
|
" (OBJECT_ID, PARENT_ID, DETAIL_ID, CLASS, NAME) "
|
|
"VALUES"
|
|
" ('%s$%X', '%s', %lld, 'container.%s', '%q')",
|
|
rootParent, parentID, rootParent, detailID, class, item);
|
|
ret = sql_exec(db, sql);
|
|
sqlite3_free(sql);
|
|
sql = sqlite3_mprintf("INSERT into %s values ('%q', '%X', '%q')", tmpTable, item, parentID, subParent);
|
|
sql_exec(db, sql);
|
|
sqlite3_free(sql);
|
|
}
|
|
sqlite3_free_table(result);
|
|
|
|
return (long long)parentID<<32|objectID;
|
|
}
|
|
|
|
void
|
|
insert_containers(const char * name, const char *path, const char * refID, const char * class, long unsigned int detailID)
|
|
{
|
|
char sql_buf[128];
|
|
char *sql;
|
|
char **result;
|
|
int ret;
|
|
int cols, row;
|
|
long long int container;
|
|
int parentID;
|
|
int objectID = -1;
|
|
|
|
sprintf(sql_buf, "SELECT * from DETAILS where ID = %lu", detailID);
|
|
ret = sql_get_table(db, sql_buf, &result, &row, &cols);
|
|
|
|
if( strstr(class, "imageItem") )
|
|
{
|
|
char *date = result[13+cols], *cam = result[16+cols];
|
|
char date_taken[11]; date_taken[10] = '\0';
|
|
static int last_all_objectID = 0;
|
|
if( date )
|
|
{
|
|
if( strcmp(date, "0000-00-00") == 0 )
|
|
{
|
|
strcpy(date_taken, "Unknown");
|
|
}
|
|
else
|
|
{
|
|
strncpy(date_taken, date, 10);
|
|
}
|
|
container = insert_container("DATES", date_taken, "3$12", NULL, "album.photoAlbum", NULL, NULL, NULL);
|
|
parentID = container>>32;
|
|
objectID = container;
|
|
sql = sqlite3_mprintf( "INSERT into OBJECTS"
|
|
" (OBJECT_ID, PARENT_ID, REF_ID, CLASS, DETAIL_ID, NAME) "
|
|
"VALUES"
|
|
" ('3$12$%X$%X', '3$12$%X', '%s', '%s', %lu, %Q)",
|
|
parentID, objectID, parentID, refID, class, detailID, name);
|
|
sql_exec(db, sql);
|
|
sqlite3_free(sql);
|
|
}
|
|
if( cam && date )
|
|
{
|
|
container = insert_container("CAMS", cam, "3$13", NULL, "storageFolder", NULL, NULL, NULL);
|
|
parentID = container>>32;
|
|
//objectID = container;
|
|
char parent[64];
|
|
sprintf(parent, "3$13$%X", parentID);
|
|
long long int subcontainer = insert_container("CAMDATE", date_taken, parent, cam, "storageFolder", NULL, NULL, NULL);
|
|
int subParentID = subcontainer>>32;
|
|
int subObjectID = subcontainer;
|
|
sql = sqlite3_mprintf( "INSERT into OBJECTS"
|
|
" (OBJECT_ID, PARENT_ID, REF_ID, CLASS, DETAIL_ID, NAME) "
|
|
"VALUES"
|
|
" ('3$13$%X$%X$%X', '3$13$%X$%X', '%s', '%s', %lu, %Q)",
|
|
parentID, subParentID, subObjectID, parentID, subParentID, refID, class, detailID, name);
|
|
sql_exec(db, sql);
|
|
sqlite3_free(sql);
|
|
}
|
|
/* All Images */
|
|
sql = sqlite3_mprintf( "INSERT into OBJECTS"
|
|
" (OBJECT_ID, PARENT_ID, REF_ID, CLASS, DETAIL_ID, NAME) "
|
|
"VALUES"
|
|
" ('3$11$%X', '3$11', '%s', '%s', %lu, %Q)",
|
|
last_all_objectID++, refID, class, detailID, name);
|
|
sql_exec(db, sql);
|
|
sqlite3_free(sql);
|
|
}
|
|
else if( strstr(class, "audioItem") )
|
|
{
|
|
char *artist = cols ? result[7+cols]:NULL, *album = cols ? result[8+cols]:NULL;
|
|
char *genre = cols ? result[9+cols]:NULL, *album_art = cols ? result[19+cols]:NULL;
|
|
static char last_artist[1024] = "0";
|
|
static int last_artist_parentID, last_artist_objectID;
|
|
static char last_album[1024];
|
|
static int last_album_parentID, last_album_objectID;
|
|
static char last_genre[1024];
|
|
static int last_genre_parentID, last_genre_objectID;
|
|
static int last_all_objectID = 0;
|
|
|
|
if( artist )
|
|
{
|
|
if( strcmp(artist, last_artist) == 0 )
|
|
{
|
|
objectID = ++last_artist_objectID;
|
|
parentID = last_artist_parentID;
|
|
}
|
|
else
|
|
{
|
|
strcpy(last_artist, artist);
|
|
container = insert_container("ARTISTS", artist, "1$6", NULL, "person.musicArtist", NULL, genre, NULL);
|
|
parentID = container>>32;
|
|
objectID = container;
|
|
last_artist_objectID = objectID;
|
|
last_artist_parentID = parentID;
|
|
}
|
|
sql = sqlite3_mprintf( "INSERT into OBJECTS"
|
|
" (OBJECT_ID, PARENT_ID, REF_ID, CLASS, DETAIL_ID, NAME) "
|
|
"VALUES"
|
|
" ('1$6$%X$%X', '1$6$%X', '%s', '%s', %lu, %Q)",
|
|
parentID, objectID, parentID, refID, class, detailID, name);
|
|
sql_exec(db, sql);
|
|
sqlite3_free(sql);
|
|
}
|
|
if( album )
|
|
{
|
|
if( strcmp(album, last_album) == 0 )
|
|
{
|
|
objectID = ++last_album_objectID;
|
|
parentID = last_album_parentID;
|
|
}
|
|
else
|
|
{
|
|
strcpy(last_album, album);
|
|
container = insert_container("ALBUMS", album, "1$7", NULL, "album.musicAlbum", artist, genre, album_art);
|
|
parentID = container>>32;
|
|
objectID = container;
|
|
last_album_objectID = objectID;
|
|
last_album_parentID = parentID;
|
|
}
|
|
sql = sqlite3_mprintf( "INSERT into OBJECTS"
|
|
" (OBJECT_ID, PARENT_ID, REF_ID, CLASS, DETAIL_ID, NAME) "
|
|
"VALUES"
|
|
" ('1$7$%X$%X', '1$7$%X', '%s', '%s', %lu, %Q)",
|
|
parentID, objectID, parentID, refID, class, detailID, name);
|
|
sql_exec(db, sql);
|
|
sqlite3_free(sql);
|
|
}
|
|
if( genre )
|
|
{
|
|
if( strcmp(genre, last_genre) == 0 )
|
|
{
|
|
objectID = ++last_genre_objectID;
|
|
parentID = last_genre_parentID;
|
|
}
|
|
else
|
|
{
|
|
strcpy(last_genre, genre);
|
|
container = insert_container("GENRES", genre, "1$5", NULL, "genre.musicGenre", NULL, NULL, NULL);
|
|
parentID = container>>32;
|
|
objectID = container;
|
|
last_genre_objectID = objectID;
|
|
last_genre_parentID = parentID;
|
|
}
|
|
sql = sqlite3_mprintf( "INSERT into OBJECTS"
|
|
" (OBJECT_ID, PARENT_ID, REF_ID, CLASS, DETAIL_ID, NAME) "
|
|
"VALUES"
|
|
" ('1$5$%X$%X', '1$5$%X', '%s', '%s', %lu, %Q)",
|
|
parentID, objectID, parentID, refID, class, detailID, name);
|
|
sql_exec(db, sql);
|
|
sqlite3_free(sql);
|
|
}
|
|
/* All Music */
|
|
sql = sqlite3_mprintf( "INSERT into OBJECTS"
|
|
" (OBJECT_ID, PARENT_ID, REF_ID, CLASS, DETAIL_ID, NAME) "
|
|
"VALUES"
|
|
" ('1$4$%X', '1$4', '%s', '%s', %lu, %Q)",
|
|
last_all_objectID++, refID, class, detailID, name);
|
|
sql_exec(db, sql);
|
|
sqlite3_free(sql);
|
|
}
|
|
else if( strstr(class, "videoItem") )
|
|
{
|
|
static int last_all_objectID = 0;
|
|
|
|
/* All Music */
|
|
sql = sqlite3_mprintf( "INSERT into OBJECTS"
|
|
" (OBJECT_ID, PARENT_ID, REF_ID, CLASS, DETAIL_ID, NAME) "
|
|
"VALUES"
|
|
" ('2$8$%X', '2$8', '%s', '%s', %lu, %Q)",
|
|
last_all_objectID++, refID, class, detailID, name);
|
|
sql_exec(db, sql);
|
|
sqlite3_free(sql);
|
|
}
|
|
sqlite3_free_table(result);
|
|
}
|
|
|
|
int
|
|
insert_directory(const char * name, const char * path, const char * base, const char * parentID, int objectID)
|
|
{
|
|
char * sql;
|
|
int ret, found = 0;
|
|
sqlite_int64 detailID;
|
|
char * refID = NULL;
|
|
char class[] = "container.storageFolder";
|
|
char * id_buf = NULL;
|
|
char * parent_buf = NULL;
|
|
char **result;
|
|
char *dir = strdup(path);
|
|
|
|
if( strcmp(base, BROWSEDIR_ID) != 0 )
|
|
asprintf(&refID, "%s%s$%X", BROWSEDIR_ID, parentID, objectID);
|
|
|
|
if( refID )
|
|
{
|
|
dir = dirname(dir);
|
|
asprintf(&id_buf, "%s%s$%X", base, parentID, objectID);
|
|
asprintf(&parent_buf, "%s%s", base, parentID);
|
|
while( !found )
|
|
{
|
|
sql = sqlite3_mprintf("SELECT count(OBJECT_ID) from OBJECTS where OBJECT_ID = '%s'", id_buf);
|
|
if( (sql_get_table(db, sql, &result, NULL, NULL) == SQLITE_OK) && atoi(result[1]) )
|
|
break;
|
|
/* Does not exist. Need to create, and may need to create parents also */
|
|
sql = sqlite3_mprintf("SELECT DETAIL_ID from OBJECTS where OBJECT_ID = '%s'", refID);
|
|
if( (sql_get_table(db, sql, &result, NULL, NULL) == SQLITE_OK) && atoi(result[1]) )
|
|
{
|
|
detailID = atoi(result[1]);
|
|
}
|
|
sql = sqlite3_mprintf( "INSERT into OBJECTS"
|
|
" (OBJECT_ID, PARENT_ID, REF_ID, DETAIL_ID, CLASS, NAME) "
|
|
"VALUES"
|
|
" ('%s', '%s', %Q, '%lld', '%s', '%q')",
|
|
id_buf, parent_buf, refID, detailID, class, rindex(dir, '/')+1);
|
|
sql_exec(db, sql);
|
|
if( rindex(id_buf, '$') )
|
|
*rindex(id_buf, '$') = '\0';
|
|
if( rindex(parent_buf, '$') )
|
|
*rindex(parent_buf, '$') = '\0';
|
|
if( rindex(refID, '$') )
|
|
*rindex(refID, '$') = '\0';
|
|
dir = dirname(dir);
|
|
}
|
|
sqlite3_free(sql);
|
|
free(refID);
|
|
return 1;
|
|
}
|
|
|
|
detailID = GetFolderMetadata(name, NULL, NULL, NULL);
|
|
sql = sqlite3_mprintf( "INSERT into OBJECTS"
|
|
" (OBJECT_ID, PARENT_ID, REF_ID, DETAIL_ID, CLASS, NAME) "
|
|
"VALUES"
|
|
" ('%s%s$%X', '%s%s', %Q, '%lld', '%s', '%q')",
|
|
base, parentID, objectID, base, parentID, refID, detailID, class, name);
|
|
//DEBUG printf("SQL: %s\n", sql);
|
|
ret = sql_exec(db, sql);
|
|
sqlite3_free(sql);
|
|
if( refID )
|
|
free(refID);
|
|
|
|
return -1;
|
|
}
|
|
|
|
int
|
|
insert_file(char * name, const char * path, const char * parentID, int object)
|
|
{
|
|
char *sql;
|
|
char class[32];
|
|
char objectID[64];
|
|
unsigned long int detailID = 0;
|
|
char base[8];
|
|
char * typedir_parentID;
|
|
int typedir_objectID;
|
|
|
|
static long unsigned int fileno = 0;
|
|
printf("Scanned %lu files...\r", fileno++); fflush(stdout);
|
|
|
|
sprintf(objectID, "%s%s$%X", BROWSEDIR_ID, parentID, object);
|
|
typedir_parentID = strdup(parentID);
|
|
sscanf(rindex(typedir_parentID, '$')+1, "%X", &typedir_objectID);
|
|
*rindex(typedir_parentID, '$') = '\0';
|
|
|
|
if( is_image(name) )
|
|
{
|
|
strcpy(base, IMAGE_DIR_ID);
|
|
strcpy(class, "item.imageItem");
|
|
detailID = GetImageMetadata(path, name);
|
|
}
|
|
else if( is_audio(name) )
|
|
{
|
|
strcpy(base, MUSIC_DIR_ID);
|
|
strcpy(class, "item.audioItem.musicTrack");
|
|
detailID = GetAudioMetadata(path, name);
|
|
}
|
|
else if( is_video(name) )
|
|
{
|
|
strcpy(base, VIDEO_DIR_ID);
|
|
strcpy(class, "item.videoItem");
|
|
detailID = GetVideoMetadata(path, name);
|
|
}
|
|
//DEBUG printf("Got DetailID %lu!\n", detailID);
|
|
if( !detailID )
|
|
return -1;
|
|
|
|
insert_directory(name, path, base, typedir_parentID, typedir_objectID);
|
|
|
|
sql = sqlite3_mprintf( "INSERT into OBJECTS"
|
|
" (OBJECT_ID, PARENT_ID, CLASS, DETAIL_ID, NAME) "
|
|
"VALUES"
|
|
" ('%s', '%s%s', '%s', %lu, '%q')",
|
|
objectID, BROWSEDIR_ID, parentID, class, detailID, name);
|
|
//DEBUG printf("SQL: %s\n", sql);
|
|
sql_exec(db, sql);
|
|
|
|
sql = sqlite3_mprintf( "INSERT into OBJECTS"
|
|
" (OBJECT_ID, PARENT_ID, REF_ID, CLASS, DETAIL_ID, NAME) "
|
|
"VALUES"
|
|
" ('%s%s$%X', '%s%s', '%s', '%s', %lu, '%q')",
|
|
base, parentID, object, base, parentID, objectID, class, detailID, name);
|
|
//DEBUG printf("SQL: %s\n", sql);
|
|
sql_exec(db, sql);
|
|
sqlite3_free(sql);
|
|
|
|
insert_containers(name, path, objectID, class, detailID);
|
|
return 0;
|
|
}
|
|
|
|
int
|
|
create_database(void)
|
|
{
|
|
int ret, i;
|
|
char sql_buf[512];
|
|
const char * containers[] = { "0","-1", "root",
|
|
"1", "0", "Music",
|
|
"1$4", "1", "All Music",
|
|
"1$5", "1", "Genre",
|
|
"1$6", "1", "Artist",
|
|
"1$7", "1", "Album",
|
|
"1$20", "1", "Folders",
|
|
"2", "0", "Video",
|
|
"2$8", "2", "All Video",
|
|
"2$21", "2", "Folders",
|
|
"3", "0", "Pictures",
|
|
"3$11", "3", "All Pictures",
|
|
"3$12", "3", "Date Taken",
|
|
"3$13", "3", "Camera",
|
|
"3$22", "3", "Folders",
|
|
"64", "0", "Browse Folders",
|
|
0 };
|
|
|
|
sql_exec(db, "pragma temp_store = MEMORY");
|
|
sql_exec(db, "pragma synchronous = OFF;");
|
|
sql_exec(db, "pragma cache_size = 8192;");
|
|
|
|
//JM: Set up a db version number, so we know if we need to rebuild due to a new structure.
|
|
sprintf(sql_buf, "pragma user_version = %d;", DB_VERSION);
|
|
sql_exec(db, sql_buf);
|
|
|
|
ret = sql_exec(db, "CREATE TABLE OBJECTS ( "
|
|
"ID INTEGER PRIMARY KEY AUTOINCREMENT, "
|
|
"OBJECT_ID TEXT NOT NULL, "
|
|
"PARENT_ID TEXT NOT NULL, "
|
|
"REF_ID TEXT DEFAULT NULL, "
|
|
"CLASS TEXT NOT NULL, "
|
|
"DETAIL_ID INTEGER DEFAULT NULL, "
|
|
"NAME TEXT DEFAULT NULL"
|
|
");");
|
|
if( ret != SQLITE_OK )
|
|
goto sql_failed;
|
|
ret = sql_exec(db, "CREATE TABLE DETAILS ( "
|
|
"ID INTEGER PRIMARY KEY AUTOINCREMENT, "
|
|
"PATH TEXT DEFAULT NULL, "
|
|
"SIZE INTEGER, "
|
|
"TITLE TEXT, "
|
|
"DURATION TEXT, "
|
|
"BITRATE INTEGER, "
|
|
"SAMPLERATE INTEGER, "
|
|
"ARTIST TEXT, "
|
|
"ALBUM TEXT, "
|
|
"GENRE TEXT, "
|
|
"COMMENT TEXT, "
|
|
"CHANNELS INTEGER, "
|
|
"TRACK INTEGER, "
|
|
"DATE DATE, "
|
|
"RESOLUTION TEXT, "
|
|
"THUMBNAIL BOOL DEFAULT 0, "
|
|
"CREATOR TEXT, "
|
|
"DLNA_PN TEXT, "
|
|
"MIME TEXT, "
|
|
"ALBUM_ART INTEGER DEFAULT 0"
|
|
");");
|
|
if( ret != SQLITE_OK )
|
|
goto sql_failed;
|
|
ret = sql_exec(db, "CREATE TABLE ALBUM_ART ( "
|
|
"ID INTEGER PRIMARY KEY AUTOINCREMENT, "
|
|
"PATH TEXT NOT NULL, "
|
|
"EMBEDDED BOOL DEFAULT 0"
|
|
");");
|
|
if( ret != SQLITE_OK )
|
|
goto sql_failed;
|
|
for( i=0; containers[i]; i=i+3 )
|
|
{
|
|
sprintf(sql_buf, "INSERT into OBJECTS (OBJECT_ID, PARENT_ID, DETAIL_ID, CLASS, NAME)"
|
|
" values "
|
|
"('%s', '%s', %lld, 'container.storageFolder', '%s')",
|
|
containers[i], containers[i+1], GetFolderMetadata(containers[i+2], NULL, NULL, NULL), containers[i+2]);
|
|
ret = sql_exec(db, sql_buf);
|
|
if( ret != SQLITE_OK )
|
|
goto sql_failed;
|
|
}
|
|
sql_exec(db, "create TEMP TABLE ARTISTS (ITEM TEXT, OBJECT_ID TEXT, SUBITEM TEXT DEFAULT NULL);");
|
|
sql_exec(db, "create TEMP TABLE ALBUMS (ITEM TEXT, OBJECT_ID TEXT, SUBITEM TEXT DEFAULT NULL);");
|
|
sql_exec(db, "create TEMP TABLE GENRES (ITEM TEXT, OBJECT_ID TEXT, SUBITEM TEXT DEFAULT NULL);");
|
|
sql_exec(db, "create TEMP TABLE DATES (ITEM TEXT, OBJECT_ID TEXT, SUBITEM TEXT DEFAULT NULL);");
|
|
sql_exec(db, "create TEMP TABLE CAMS (ITEM TEXT, OBJECT_ID TEXT, SUBITEM TEXT DEFAULT NULL);");
|
|
sql_exec(db, "create TEMP TABLE CAMDATE (ITEM TEXT, OBJECT_ID TEXT, SUBITEM TEXT DEFAULT NULL);");
|
|
|
|
sql_exec(db, "create INDEX IDX_OBJECTS_OBJECT_ID ON OBJECTS(OBJECT_ID);");
|
|
sql_exec(db, "create INDEX IDX_OBJECTS_PARENT_ID ON OBJECTS(PARENT_ID);");
|
|
sql_exec(db, "create INDEX IDX_OBJECTS_DETAIL_ID ON OBJECTS(DETAIL_ID);");
|
|
sql_exec(db, "create INDEX IDX_OBJECTS_CLASS ON OBJECTS(CLASS);");
|
|
sql_exec(db, "create INDEX IDX_DETAILS_PATH ON DETAILS(PATH);");
|
|
sql_exec(db, "create INDEX IDX_DETAILS_ID ON DETAILS(ID);");
|
|
sql_exec(db, "create INDEX IDX_ALBUM_ART ON ALBUM_ART(ID);");
|
|
|
|
|
|
sql_failed:
|
|
if( ret != SQLITE_OK )
|
|
fprintf(stderr, "Error creating SQLite3 database!\n");
|
|
return (ret != SQLITE_OK);
|
|
}
|
|
|
|
int
|
|
filter_media(const struct dirent *d)
|
|
{
|
|
return ( (*d->d_name != '.') &&
|
|
((d->d_type == DT_DIR) ||
|
|
((d->d_type == DT_REG) &&
|
|
(is_image(d->d_name) ||
|
|
is_audio(d->d_name) ||
|
|
is_video(d->d_name)
|
|
)
|
|
)) );
|
|
}
|
|
|
|
void
|
|
ScanDirectory(const char * dir, const char * parent)
|
|
{
|
|
struct dirent **namelist;
|
|
int n, i;
|
|
char parent_id[PATH_MAX];
|
|
char full_path[PATH_MAX];
|
|
char * name;
|
|
#if USE_FORK
|
|
pid_t newpid;
|
|
#endif
|
|
|
|
if( !parent )
|
|
{
|
|
if( create_database() != 0 )
|
|
{
|
|
fprintf(stderr, "Error creating database!\n");
|
|
return;
|
|
}
|
|
#if USE_FORK
|
|
newpid = fork();
|
|
if( newpid )
|
|
return;
|
|
#endif
|
|
}
|
|
|
|
setlocale(LC_COLLATE, "");
|
|
if( chdir(dir) != 0 )
|
|
return;
|
|
printf("\nScanning %s\n", dir);
|
|
n = scandir(".", &namelist, filter_media, alphasort);
|
|
if (n < 0) {
|
|
fprintf(stderr, "Error scanning %s [scandir]\n", dir);
|
|
return;
|
|
}
|
|
for (i=0; i < n; i++) {
|
|
name = NULL;
|
|
sprintf(full_path, "%s/%s", dir, namelist[i]->d_name);
|
|
if( index(namelist[i]->d_name, '&') )
|
|
{
|
|
name = modifyString(strdup(namelist[i]->d_name), "&", "&amp;", 0);
|
|
}
|
|
if( namelist[i]->d_type == DT_DIR )
|
|
{
|
|
insert_directory(name?name:namelist[i]->d_name, full_path, BROWSEDIR_ID, (parent ? parent:""), i);
|
|
sprintf(parent_id, "%s$%X", (parent ? parent:""), i);
|
|
ScanDirectory(full_path, parent_id);
|
|
}
|
|
else
|
|
{
|
|
insert_file(name?name:namelist[i]->d_name, full_path, (parent ? parent:""), i);
|
|
}
|
|
if( name )
|
|
free(name);
|
|
free(namelist[i]);
|
|
}
|
|
free(namelist);
|
|
if( parent )
|
|
{
|
|
chdir(dirname((char*)dir));
|
|
}
|
|
else
|
|
{
|
|
printf("Scanning \"%s\" finished!\n", dir);
|
|
#if USE_FORK
|
|
_exit(0);
|
|
#endif
|
|
}
|
|
}
|