From 929e7837cd8433d2e265d982e31b6ddd765cf5d1 Mon Sep 17 00:00:00 2001
From: Michiel Van Der Kolk <not.valid@email.address>
Date: Tue, 26 Apr 2005 21:37:44 +0000
Subject: Restructurizing database code, seperating database code from dbtree
 code, wrote the first basic functions to manipulate fileentries.

git-svn-id: svn://svn.rockbox.org/rockbox/trunk@6359 a1c6a512-1295-4272-9138-f99709370657
---
 apps/database.c | 195 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 195 insertions(+)
 create mode 100644 apps/database.c

(limited to 'apps/database.c')

diff --git a/apps/database.c b/apps/database.c
new file mode 100644
index 0000000..1258b94
--- /dev/null
+++ b/apps/database.c
@@ -0,0 +1,195 @@
+/***************************************************************************
+ *             __________               __   ___.
+ *   Open      \______   \ ____   ____ |  | _\_ |__   _______  ___
+ *   Source     |       _//  _ \_/ ___\|  |/ /| __ \ /  _ \  \/  /
+ *   Jukebox    |    |   (  <_> )  \___|    < | \_\ (  <_> > <  <
+ *   Firmware   |____|_  /\____/ \___  >__|_ \|___  /\____/__/\_ \
+ *                     \/            \/     \/    \/            \/
+ * $Id
+ *
+ * Copyright (C) 2005 by Michiel van der Kolk
+ *
+ * All files in this archive are subject to the GNU General Public License.
+ * See the file COPYING in the source tree root for full license agreement.
+ *
+ * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
+ * KIND, either express or implied.
+ *
+ ****************************************************************************/
+#define _GNU_SOURCE
+#include <stdio.h>
+#include <string.h>
+#include "file.h"
+#include "screens.h"
+#include "kernel.h"
+#include "tree.h"
+#include "lcd.h"
+#include "font.h"
+#include "settings.h"
+#include "icons.h"
+#include "status.h"
+#include "debug.h"
+#include "button.h"
+#include "menu.h"
+#include "main_menu.h"
+#include "mpeg.h"
+#include "misc.h"
+#include "ata.h"
+#include "wps.h"
+#include "filetypes.h"
+#include "applimits.h"
+#include "icons.h"
+#include "lang.h"
+#include "keyboard.h"
+#include "database.h"
+
+#undef NEW_DB_CODE
+
+#ifdef NEW_DB_CODE
+static char sbuf[1024];
+static struct file_entry fe;
+static int currentferecord;
+#endif
+
+int tagdb_fd = -1;
+int tagdb_initialized = 0;
+struct tagdb_header tagdbheader;
+
+int tagdb_init(void)
+{
+    unsigned char* ptr = (char*)&tagdbheader.version;
+#ifdef LITTLE_ENDIAN
+    int i, *p;
+#endif
+
+    tagdb_fd = open(ROCKBOX_DIR "/rockbox.id3db", O_RDONLY);
+    if (tagdb_fd < 0) {
+        DEBUGF("Failed opening database\n");
+        return -1;
+    }
+    read(tagdb_fd, &tagdbheader, 68);
+
+    if (ptr[0] != 'R' ||
+        ptr[1] != 'D' ||
+        ptr[2] != 'B')
+    {
+        splash(HZ,true,"Not a rockbox ID3 database!");
+        return -1;
+    }
+#ifdef LITTLE_ENDIAN
+    p=(int *)&tagdbheader;
+    for(i=0;i<17;i++) {
+        *p=BE32(p);
+        p++;
+    }
+#endif
+    if ( (tagdbheader.version&0xFF) != TAGDB_VERSION)
+    {
+        splash(HZ,true,"Unsupported database version %d!", tagdbheader.version&0xFF);
+        return -1;
+    }
+
+    if (tagdbheader.songstart > tagdbheader.filestart ||
+        tagdbheader.albumstart > tagdbheader.songstart ||
+        tagdbheader.artiststart > tagdbheader.albumstart)
+    {
+        splash(HZ,true,"Corrupt ID3 database!");
+        return -1;
+    }
+
+    tagdb_initialized = 1;
+    return 0;
+}
+
+void tagdb_shutdown(void)
+{
+    if (tagdb_fd >= 0)
+        close(tagdb_fd);
+    tagdb_initialized = 0;
+}
+
+/* NOTE: All these functions below are yet untested. */
+
+#ifdef NEW_DB_CODE
+void writetagdbheader() {
+        lseek(tagdb_fd,0,SEEK_SET);
+        write(tagdb_fd, &tagdbheader, 68);
+}
+
+void getfentrybyoffset(int offset) {
+        lseek(tagdb_fd,offset,SEEK_SET);
+        fread(tagdb_fd,sbuf,tagdbheader.filelen);
+        fread(tagdb_fd,&fe+sizeof(char *),12);
+        fe.name=sbuf;
+        currentferecord=(offset-tagdbheader.filestart)/FILEENTRY_SIZE;
+}
+
+void getfentrybyrecord(int record) {
+        getfentrybyoffset(FILERECORD2OFFSET(record));
+}
+
+int getfentrybyfilename(char *fname) {
+        int min=0;
+        int max=tagdbheader.filecount;
+        while(min<max) {
+          int mid=(min+max)/2;
+          int compare;
+          getfentrybyrecord(mid);
+          compare=strcasecmp(fname,fe.name));
+          if(compare==0)
+            return 1;
+          else if(compare<0)
+            max=mid;
+          else
+            min=mid+1;
+        }
+        return 0;
+}
+
+int shiftdown(int targetoffset, int startingoffset) {
+        int amount;
+        if(targetoffset>=startingoffset) {
+                splash(HZ*2,"Woah. no beeping way. (shiftdown)");
+                return 0;
+        }
+        lseek(tagdb_fd,startingoffset,SEEK_SET);
+        while(amount=read(tagdb_fd,sbuf,1024)) {
+                int written;
+                startingoffset+=amount;
+                lseek(tagdb_fd,targetoffset,SEEK_SET);
+                written=write(tagdb_fd,sbuf,amount);
+                targetoffset+=written;
+                if(amount!=written) {
+                        splash(HZ*2,"Something went very wrong. expect database corruption.");
+                        return 0;
+                }
+                lseek(tagdb_fd,startingoffset,SEEK_SET);
+        }
+        ftruncate(tagdb_fd,lseek(tagdb_fd,0,SEEK_END) - (startingoffset-targetoffset));
+        return 1;
+}
+
+int deletefentry(char *fname) {
+        if(!getfentrybyfilename(fname))
+           return 0;
+        int restrecord = currentferecord+1; 
+        if(currentferecord==tagdbheader.filecount) /* file is last entry */
+           ftruncate(tagdb_fd,lseek(tagdb_fd,0,SEEK_END)-FILEENTRY_SIZE);
+        else 
+           shiftdown(FILERECORD2OFFSET(currentferecord),FILERECORD2OFFSET(restrecord));
+        tagdbheader.filecount--;
+        writetagdbheader();
+        return 1;
+}
+
+int getfentrybyhash(int hash) {
+        int min=0;
+        for(min=0;min<tagdbheader.filecount;min++) {
+          getfentrybyrecord(min);
+          if(hash==fe.hash)
+             return 1;
+        }
+        return 0;
+}
+
+#endif
-- 
cgit v1.1