Coverage for GuiBulkImport.py: 0%
79 statements
« prev ^ index » next coverage.py v7.6.3, created at 2024-10-14 11:07 +0000
« prev ^ index » next coverage.py v7.6.3, created at 2024-10-14 11:07 +0000
1#!/usr/bin/env python
2# -*- coding: utf-8 -*-
4# Copyright 2008-2011 Steffen Schaumburg
5# This program is free software: you can redistribute it and/or modify
6# it under the terms of the GNU Affero General Public License as published by
7# the Free Software Foundation, version 3 of the License.
8#
9# This program is distributed in the hope that it will be useful,
10# but WITHOUT ANY WARRANTY; without even the implied warranty of
11# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12# GNU General Public License for more details.
13#
14# You should have received a copy of the GNU Affero General Public License
15# along with this program. If not, see <http://www.gnu.org/licenses/>.
16# In the "official" distribution you can find the license in agpl-3.0.txt.
18from __future__ import print_function
19from __future__ import division
20from past.utils import old_div
22# import L10n
23# _ = L10n.get_translation()
24# Standard Library modules
25import os
26import sys
27from time import time
29from PyQt5.QtWidgets import QWidget, QVBoxLayout, QHBoxLayout, QLineEdit, QPushButton, QFileDialog
31# fpdb/FreePokerTools modules
34import Importer
36import Configuration
39import logging
41if __name__ == "__main__":
42 Configuration.set_logfile("fpdb-log.txt")
43# logging has been set up in fpdb.py or HUD_main.py, use their settings:
44log = logging.getLogger("importer")
47class GuiBulkImport(QWidget):
48 # CONFIGURATION - update these as preferred:
49 allowThreads = False # set to True to try out the threads field
51 def load_clicked(self):
52 stored = None
53 dups = None
54 partial = None
55 skipped = None
56 errs = None
57 ttime = None
58 # Does the lock acquisition need to be more sophisticated for multiple dirs?
59 # (see comment above about what to do if pipe already open)
60 if self.settings["global_lock"].acquire(
61 wait=False, source="GuiBulkImport"
62 ): # returns false immediately if lock not acquired
63 # try:
64 # get the dir to import from the chooser
65 selected = self.importDir.text()
67 # get the import settings from the gui and save in the importer
69 self.importer.setHandsInDB(self.n_hands_in_db)
70 self.importer.setMode("bulk")
72 self.importer.addBulkImportImportFileOrDir(selected, site="auto")
73 self.importer.setCallHud(False)
75 starttime = time()
77 (stored, dups, partial, skipped, errs, ttime) = self.importer.runImport()
79 ttime = time() - starttime
80 if ttime == 0:
81 ttime = 1
83 completionMessage = (
84 "Bulk import done: Stored: %d, Duplicates: %d, Partial: %d, Skipped: %d, Errors: %d, Time: %s seconds, Stored/second: %.0f"
85 ) % (stored, dups, partial, skipped, errs, ttime, old_div((stored + 0.0), ttime))
86 print(completionMessage)
87 log.info(completionMessage)
89 self.importer.clearFileList()
91 self.settings["global_lock"].release()
92 else:
93 print(("bulk import aborted - global lock not available"))
95 def get_vbox(self):
96 """returns the vbox of this thread"""
97 return self.layout()
99 def __init__(self, settings, config, sql=None, parent=None):
100 QWidget.__init__(self, parent)
101 self.settings = settings
102 self.config = config
104 self.importer = Importer.Importer(self, self.settings, config, sql, self)
106 self.setLayout(QVBoxLayout())
108 self.importDir = QLineEdit(self.settings["bulkImport-defaultPath"])
109 hbox = QHBoxLayout()
110 hbox.addWidget(self.importDir)
111 self.chooseButton = QPushButton("Browse...")
112 self.chooseButton.clicked.connect(self.browseClicked)
113 hbox.addWidget(self.chooseButton)
114 self.layout().addLayout(hbox)
116 self.load_button = QPushButton(("Bulk Import"))
117 self.load_button.clicked.connect(self.load_clicked)
118 self.layout().addWidget(self.load_button)
120 # see how many hands are in the db and adjust accordingly
121 tcursor = self.importer.database.cursor
122 tcursor.execute("Select count(1) from Hands")
123 row = tcursor.fetchone()
124 tcursor.close()
125 self.importer.database.rollback()
126 self.n_hands_in_db = row[0]
128 def browseClicked(self):
129 newdir = QFileDialog.getExistingDirectory(
130 self, caption=("Please choose the path that you want to Auto Import"), directory=self.importDir.text()
131 )
132 if newdir:
133 self.importDir.setText(newdir)
136if __name__ == "__main__":
137 config = Configuration.Config()
138 settings = {}
139 if os.name == "nt":
140 settings["os"] = "windows"
141 else:
142 settings["os"] = "linuxmac"
144 settings.update(config.get_db_parameters())
145 settings.update(config.get_import_parameters())
146 settings.update(config.get_default_paths())
147 import interlocks
149 settings["global_lock"] = interlocks.InterProcessLock(name="fpdb_global_lock")
150 settings["cl_options"] = ".".join(sys.argv[1:])
152 # from PyQt5.QtWidgets import QApplication, QMainWindow
153 # app = QApplication(sys.argv)
154 # main_window = QMainWindow()
155 # main_window.setCentralWidget(GuiBulkImport(settings, config))
156 # main_window.show()
157 # main_window.resize(600, 100)
158 # app.exec_()