Rewrite local converting

consumer.py

@@ -28,35 +28,18 @@ def configure_file_logger(name, filename='logs/converter.log', filemode='w+',
     logger.setLevel(logging_level)
     return logger
 
-def local_convert_book(filename, locker):
-    logger = configure_file_logger('consumer')
-    logger.info(f'Start processing book-{filename}.')
-
-    folder_path = os.path.dirname(os.path.abspath("__file__"))
-    output_path = Path(os.path.join(folder_path, f'json/{filename}.json'))
-    try:
-        book = DocxBook(book_id=filename,
-                        main_logger=logger,
-                        libra_locker=locker)
-        book.test_conversion()
-
-    except Exception as exc:
-        raise exc
-
-    logger.info(f'Book-{filename} has been proceeded.')
-
-def convert_book(book_type: [DocxBook, EpubBook], params: dict, logger, book_id):
+def convert_book(book_type: [DocxBook, EpubBook], book_id, logger, params: dict,):
     logger.info(f'Start processing book-{book_id}.')
 
     try:
         book = book_type(book_id=book_id, main_logger=logger, **params)
+        book.conversion_local('9781641051217')
         book.conversion()
     except Exception as exc:
         raise exc
 
     logger.info(f'Book-{book_id} has been proceeded.')
 
-
 def callback(ch, method, properties, body, logger, libra_locker):
     print(f'Message: {body}.')
     logger.info(f'Message: {body}.')
@@ -92,18 +75,6 @@ def callback(ch, method, properties, body, logger, libra_locker):
     finally:
         pass
 
-def local_run(books):
-    locker = Event()
-    locker.set()
-
-    threads = []
-    for book_name in books:
-        logging.info("Main    : create and start thread %d.", book_name)
-        x = Thread(target=local_convert_book, args=(book_name, locker))
-        threads.append(x)
-
-    [x.start() for x in threads]
-
 def server_run():
     logger = configure_file_logger('consumer')