| 
     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  |