| 
31
 | 
     1  | 
#!/usr/bin/python
  | 
| 
 | 
     2  | 
  | 
| 
 | 
     3  | 
import os
  | 
| 
 | 
     4  | 
import sqlite
  | 
| 
 | 
     5  | 
from ogg.vorbis import VorbisFile
  | 
| 
 | 
     6  | 
import ID3
  | 
| 
 | 
     7  | 
import readline
  | 
| 
 | 
     8  | 
import imms
  | 
| 
 | 
     9  | 
from utils import unique, copy_file, set_file_completer
  | 
| 
 | 
    10  | 
  | 
| 
 | 
    11  | 
  | 
| 
 | 
    12  | 
class CleanupIMMS:
  | 
| 
 | 
    13  | 
    def __init__(self, db_file):
  | 
| 
 | 
    14  | 
        self.db = imms.IMMSDb(db_file)
  | 
| 
 | 
    15  | 
    def check_uid(self, uid):
  | 
| 
 | 
    16  | 
        lib = self.db.get_library_entries(uid = uid)
  | 
| 
 | 
    17  | 
        if len(lib) == 0:
  | 
| 
 | 
    18  | 
            print "Erased uid = ", uid
  | 
| 
 | 
    19  | 
            self.db.erase_uid(uid)
  | 
| 
 | 
    20  | 
    def check_sid(self, sid):
  | 
| 
 | 
    21  | 
        lib = self.db.get_library_entries(sid = sid)
  | 
| 
 | 
    22  | 
        if len(lib) == 0:
  | 
| 
 | 
    23  | 
            print "Erased sid = ", uid
  | 
| 
 | 
    24  | 
            self.db.erase_sid(sid)
  | 
| 
 | 
    25  | 
    def handle_no_file(self, path, uid, sid):
  | 
| 
 | 
    26  | 
        other_paths = self.db.get_library_entries(uid = uid)
  | 
| 
 | 
    27  | 
        other_paths = unique(map(lambda x: x[0], other_paths))
  | 
| 
 | 
    28  | 
        for opath in other_paths:
  | 
| 
 | 
    29  | 
            if os.path.isfile(opath):
  | 
| 
 | 
    30  | 
                return None
  | 
| 
 | 
    31  | 
        other_paths = self.db.get_library_entries(sid = sid)
  | 
| 
 | 
    32  | 
        other_paths = unique(map(lambda x: x[0], other_paths))
  | 
| 
 | 
    33  | 
        for opath in other_paths:
  | 
| 
 | 
    34  | 
            if os.path.isfile(opath):
  | 
| 
 | 
    35  | 
                readline.add_history(opath)
  | 
| 
 | 
    36  | 
        readline.add_history(path)
  | 
| 
 | 
    37  | 
        readline.insert_text('Edit')
 | 
| 
 | 
    38  | 
        while 1:
  | 
| 
 | 
    39  | 
            cmd = raw_input("I can't find '%s'.\n"
 | 
| 
 | 
    40  | 
                            "Edit, Skip or Remove? " % path)
  | 
| 
 | 
    41  | 
            if len(cmd) > 0:
  | 
| 
 | 
    42  | 
                cmd = cmd.lstrip()[0].lower()
  | 
| 
 | 
    43  | 
                if cmd == 'e':
  | 
| 
 | 
    44  | 
                    newpath = raw_input()
  | 
| 
 | 
    45  | 
                    if newpath in other_paths:
  | 
| 
 | 
    46  | 
                        return None
  | 
| 
 | 
    47  | 
                    if os.path.isfile(newpath):
  | 
| 
 | 
    48  | 
                        return newpath
  | 
| 
 | 
    49  | 
                    print "Invalid filename!"
  | 
| 
 | 
    50  | 
                elif cmd == 's':
  | 
| 
 | 
    51  | 
                    return path;
  | 
| 
 | 
    52  | 
                elif cmd == 'r':
  | 
| 
 | 
    53  | 
                    return None
  | 
| 
 | 
    54  | 
    def clean_library(self):
  | 
| 
 | 
    55  | 
        lib = self.db.get_library_entries()
  | 
| 
 | 
    56  | 
        deleted_uids = []
  | 
| 
 | 
    57  | 
        deleted_sids = []
  | 
| 
 | 
    58  | 
        for entry in lib:
  | 
| 
 | 
    59  | 
            path, uid, sid = entry
  | 
| 
 | 
    60  | 
            if not os.path.isfile(path):
  | 
| 
 | 
    61  | 
                uid = int(uid)
  | 
| 
 | 
    62  | 
                sid = int(sid)
  | 
| 
 | 
    63  | 
                newfile = self.handle_no_file(path, uid, sid)
  | 
| 
 | 
    64  | 
                if not newfile:
  | 
| 
 | 
    65  | 
                    print "Erasing ", path
  | 
| 
 | 
    66  | 
                    self.db.erase_filename(path)
  | 
| 
 | 
    67  | 
                    deleted_uids.append(uid)
  | 
| 
 | 
    68  | 
                    deleted_sids.append(sid)
  | 
| 
 | 
    69  | 
                elif newfile != path:
  | 
| 
 | 
    70  | 
                    print "Renaming ", path, " into ", newfile
  | 
| 
 | 
    71  | 
                    self.db.update_filename(path, newfile)
  | 
| 
 | 
    72  | 
                else:
  | 
| 
 | 
    73  | 
                    print "Skipping ", path
  | 
| 
 | 
    74  | 
        map(self.check_uid, unique(deleted_uids))
  | 
| 
 | 
    75  | 
        map(self.check_sid, unique(deleted_sids))
  | 
| 
 | 
    76  | 
    def clean_rating(self):
  | 
| 
 | 
    77  | 
        rates = self.db.get_ratings()
  | 
| 
 | 
    78  | 
        rates = unique(map(lambda x: x[0], rates))
  | 
| 
 | 
    79  | 
        map(self.check_uid, rates)
  | 
| 
 | 
    80  | 
    def clean_acoustic(self):
  | 
| 
 | 
    81  | 
        uids = map(lambda x: x[0], self.db.get_acoustics())
  | 
| 
 | 
    82  | 
        map(self.check_uid, uids)
  | 
| 
 | 
    83  | 
    def clean_info(self):
  | 
| 
 | 
    84  | 
        sids = map(lambda x: x[0], self.db.get_infos())
  | 
| 
 | 
    85  | 
        map(self.check_sid, sids)
  | 
| 
 | 
    86  | 
    def clean_last(self):
  | 
| 
 | 
    87  | 
        sids = map(lambda x: x[0], self.db.get_last())
  | 
| 
 | 
    88  | 
        map(self.check_sid, sids)
  | 
| 
 | 
    89  | 
    def clean_all(self):
  | 
| 
 | 
    90  | 
        self.clean_library()
  | 
| 
 | 
    91  | 
        self.clean_rating()
  | 
| 
 | 
    92  | 
        self.clean_acoustic()
  | 
| 
 | 
    93  | 
        self.clean_info()
  | 
| 
 | 
    94  | 
        self.clean_last()
  | 
| 
 | 
    95  | 
  | 
| 
 | 
    96  | 
if __name__ == '__main__':
  | 
| 
 | 
    97  | 
    set_file_completer()
  | 
| 
 | 
    98  | 
    readline.parse_and_bind('tab: complete')
 | 
| 
 | 
    99  | 
    db_file = os.environ['HOME'] + '/.imms/imms.db'
  | 
| 
 | 
   100  | 
    db_backup = db_file + '.bak'
  | 
| 
 | 
   101  | 
    copy_file(db_file, db_backup).close()
  | 
| 
 | 
   102  | 
    try:
  | 
| 
 | 
   103  | 
        clean_up = CleanupIMMS(db_file)
  | 
| 
 | 
   104  | 
    except Exception, inst:
  | 
| 
 | 
   105  | 
        print inst
  | 
| 
 | 
   106  | 
        ans = raw_input('Do you want to get back the backup file? ')
 | 
| 
 | 
   107  | 
        if len(ans) > 0:
  | 
| 
 | 
   108  | 
            if ans.lstrip()[0].lower() == 'y':
  | 
| 
 | 
   109  | 
                copy_file(db_backup, db_file)
  | 
| 
 | 
   110  | 
    print "backup file preserved: %s." % db_backup
  |