diff --git a/openpype/modules/sync_server/tray/app.py b/openpype/modules/sync_server/tray/app.py
index 25fbf0e49a..d91ba76335 100644
--- a/openpype/modules/sync_server/tray/app.py
+++ b/openpype/modules/sync_server/tray/app.py
@@ -7,7 +7,7 @@ from openpype import resources
from openpype.modules.sync_server.tray.widgets import (
SyncProjectListWidget,
- SyncRepresentationWidget
+ SyncRepresentationSummaryWidget
)
log = PypeLogger().get_logger("SyncServer")
@@ -47,7 +47,7 @@ class SyncServerWindow(QtWidgets.QDialog):
left_column_layout.addWidget(self.pause_btn)
left_column.setLayout(left_column_layout)
- repres = SyncRepresentationWidget(
+ repres = SyncRepresentationSummaryWidget(
sync_server,
project=self.projects.current_project,
parent=self)
diff --git a/openpype/modules/sync_server/tray/lib.py b/openpype/modules/sync_server/tray/lib.py
index 5e8a3fdd31..04bd1f568e 100644
--- a/openpype/modules/sync_server/tray/lib.py
+++ b/openpype/modules/sync_server/tray/lib.py
@@ -129,6 +129,7 @@ class FilterDefinition:
type = attr.ib()
values = attr.ib(factory=list)
+
def pretty_size(value, suffix='B'):
for unit in ['', 'Ki', 'Mi', 'Gi', 'Ti', 'Pi', 'Ei', 'Zi']:
if abs(value) < 1024.0:
@@ -157,3 +158,9 @@ def translate_provider_for_icon(sync_server, project, site):
if site == sync_server.DEFAULT_SITE:
return sync_server.DEFAULT_SITE
return sync_server.get_provider_for_site(project, site)
+
+
+def get_item_by_id(model, object_id):
+ index = model.get_index(object_id)
+ item = model.data(index, FullItemRole)
+ return item
diff --git a/openpype/modules/sync_server/tray/models.py b/openpype/modules/sync_server/tray/models.py
index 80c6345263..ffd81a1588 100644
--- a/openpype/modules/sync_server/tray/models.py
+++ b/openpype/modules/sync_server/tray/models.py
@@ -908,6 +908,9 @@ class SyncRepresentationDetailModel(_SyncRepresentationModel):
def data(self, index, role):
item = self._data[index.row()]
+ if role == lib.FullItemRole:
+ return item
+
header_value = self._header[index.column()]
if role == lib.ProviderRole:
if header_value == 'local_site':
diff --git a/openpype/modules/sync_server/tray/widgets.py b/openpype/modules/sync_server/tray/widgets.py
index a0c054a67e..c552904244 100644
--- a/openpype/modules/sync_server/tray/widgets.py
+++ b/openpype/modules/sync_server/tray/widgets.py
@@ -135,7 +135,7 @@ class SyncProjectListWidget(ProjectListWidget):
self.refresh()
-class SyncRepresentationWidget(QtWidgets.QWidget):
+class _SyncRepresentationWidget(QtWidgets.QWidget):
"""
Summary dialog with list of representations that matches current
settings 'local_site' and 'remote_site'.
@@ -143,90 +143,7 @@ class SyncRepresentationWidget(QtWidgets.QWidget):
active_changed = QtCore.Signal() # active index changed
message_generated = QtCore.Signal(str)
- default_widths = (
- ("asset", 190),
- ("subset", 170),
- ("version", 60),
- ("representation", 145),
- ("local_site", 160),
- ("remote_site", 160),
- ("files_count", 50),
- ("files_size", 60),
- ("priority", 70),
- ("status", 110)
- )
-
- def __init__(self, sync_server, project=None, parent=None):
- super(SyncRepresentationWidget, self).__init__(parent)
-
- self.sync_server = sync_server
-
- self._selected_ids = [] # keep last selected _id
-
- self.txt_filter = QtWidgets.QLineEdit()
- self.txt_filter.setPlaceholderText("Quick filter representations..")
- self.txt_filter.setClearButtonEnabled(True)
- self.txt_filter.addAction(qtawesome.icon("fa.filter", color="gray"),
- QtWidgets.QLineEdit.LeadingPosition)
-
- self._scrollbar_pos = None
-
- top_bar_layout = QtWidgets.QHBoxLayout()
- top_bar_layout.addWidget(self.txt_filter)
-
- self.table_view = QtWidgets.QTableView()
- headers = [item[0] for item in self.default_widths]
-
- model = SyncRepresentationSummaryModel(sync_server, headers, project)
- self.table_view.setModel(model)
- self.table_view.setContextMenuPolicy(QtCore.Qt.CustomContextMenu)
- self.table_view.setSelectionMode(
- QtWidgets.QAbstractItemView.ExtendedSelection)
- self.table_view.setSelectionBehavior(
- QtWidgets.QAbstractItemView.SelectRows)
- self.table_view.horizontalHeader().setSortIndicator(
- -1, Qt.AscendingOrder)
- self.table_view.setAlternatingRowColors(True)
- self.table_view.verticalHeader().hide()
-
- column = self.table_view.model().get_header_index("local_site")
- delegate = ImageDelegate(self)
- self.table_view.setItemDelegateForColumn(column, delegate)
-
- column = self.table_view.model().get_header_index("remote_site")
- delegate = ImageDelegate(self)
- self.table_view.setItemDelegateForColumn(column, delegate)
-
- layout = QtWidgets.QVBoxLayout(self)
- layout.setContentsMargins(0, 0, 0, 0)
- layout.addLayout(top_bar_layout)
- layout.addWidget(self.table_view)
-
- self.table_view.doubleClicked.connect(self._double_clicked)
- self.txt_filter.textChanged.connect(lambda: model.set_word_filter(
- self.txt_filter.text()))
- self.table_view.customContextMenuRequested.connect(
- self._on_context_menu)
-
- model.refresh_started.connect(self._save_scrollbar)
- model.refresh_finished.connect(self._set_scrollbar)
- model.modelReset.connect(self._set_selection)
-
- self.model = model
-
- self.selection_model = self.table_view.selectionModel()
- self.selection_model.selectionChanged.connect(self._selection_changed)
-
- horizontal_header = HorizontalHeader(self)
-
- self.table_view.setHorizontalHeader(horizontal_header)
- self.table_view.setSortingEnabled(True)
-
- for column_name, width in self.default_widths:
- idx = model.get_header_index(column_name)
- self.table_view.setColumnWidth(idx, width)
-
- def _selection_changed(self, new_selected, all_selected):
+ def _selection_changed(self, _new_selected, _all_selected):
idxs = self.selection_model.selectedRows()
self._selected_ids = []
@@ -273,21 +190,36 @@ class SyncRepresentationWidget(QtWidgets.QWidget):
if is_multi:
index = self.model.get_index(self._selected_ids[0])
- self.item = self.model.data(index, lib.FullItemRole)
+ item = self.model.data(index, lib.FullItemRole)
else:
- self.item = self.model.data(point_index, lib.FullItemRole)
+ item = self.model.data(point_index, lib.FullItemRole)
+ action_kwarg_map, actions_mapping, menu = self._prepare_menu(item,
+ is_multi)
+
+ result = menu.exec_(QtGui.QCursor.pos())
+ if result:
+ to_run = actions_mapping[result]
+ to_run_kwargs = action_kwarg_map.get(result, {})
+ if to_run:
+ to_run(**to_run_kwargs)
+
+ self.model.refresh()
+
+ def _prepare_menu(self, item, is_multi):
menu = QtWidgets.QMenu()
+
actions_mapping = {}
action_kwarg_map = {}
active_site = self.model.active_site
remote_site = self.model.remote_site
- local_progress = self.item.local_progress
- remote_progress = self.item.remote_progress
+ local_progress = item.local_progress
+ remote_progress = item.remote_progress
project = self.model.project
+
for site, progress in {active_site: local_progress,
remote_site: remote_progress}.items():
provider = self.sync_server.get_provider_for_site(project, site)
@@ -303,24 +235,6 @@ class SyncRepresentationWidget(QtWidgets.QWidget):
self._get_action_kwargs(site)
menu.addAction(action)
- if self.item.status in [lib.STATUS[0], lib.STATUS[1]] or is_multi:
- action = QtWidgets.QAction("Pause in queue")
- actions_mapping[action] = self._pause
- # pause handles which site_name it will pause itself
- action_kwarg_map[action] = {"repre_ids": self._selected_ids}
- menu.addAction(action)
-
- if self.item.status == lib.STATUS[3] or is_multi:
- action = QtWidgets.QAction("Unpause in queue")
- actions_mapping[action] = self._unpause
- action_kwarg_map[action] = {"repre_ids": self._selected_ids}
- menu.addAction(action)
-
- # if self.item.status == lib.STATUS[1]:
- # action = QtWidgets.QAction("Open error detail")
- # actions_mapping[action] = self._show_detail
- # menu.addAction(action)
-
if remote_progress == 1.0 or is_multi:
action = QtWidgets.QAction("Re-sync Active site")
action_kwarg_map[action] = self._get_action_kwargs(active_site)
@@ -350,19 +264,12 @@ class SyncRepresentationWidget(QtWidgets.QWidget):
actions_mapping[action] = None
menu.addAction(action)
- result = menu.exec_(QtGui.QCursor.pos())
- if result:
- to_run = actions_mapping[result]
- to_run_kwargs = action_kwarg_map.get(result, {})
- if to_run:
- to_run(**to_run_kwargs)
+ return action_kwarg_map, actions_mapping, menu
- self.model.refresh()
-
- def _pause(self, repre_ids=None):
- log.debug("Pause {}".format(repre_ids))
- for representation_id in repre_ids:
- item = self._get_item_by_repre_id(representation_id)
+ def _pause(self, selected_ids=None):
+ log.debug("Pause {}".format(selected_ids))
+ for representation_id in selected_ids:
+ item = lib.get_item_by_id(self.model, representation_id)
if item.status not in [lib.STATUS[0], lib.STATUS[1]]:
continue
for site_name in [self.model.active_site, self.model.remote_site]:
@@ -374,10 +281,10 @@ class SyncRepresentationWidget(QtWidgets.QWidget):
self.message_generated.emit("Paused {}".format(representation_id))
- def _unpause(self, repre_ids=None):
- log.debug("UnPause {}".format(repre_ids))
- for representation_id in repre_ids:
- item = self._get_item_by_repre_id(representation_id)
+ def _unpause(self, selected_ids=None):
+ log.debug("UnPause {}".format(selected_ids))
+ for representation_id in selected_ids:
+ item = lib.get_item_by_id(self.model, representation_id)
if item.status not in lib.STATUS[3]:
continue
for site_name in [self.model.active_site, self.model.remote_site]:
@@ -391,10 +298,10 @@ class SyncRepresentationWidget(QtWidgets.QWidget):
self.message_generated.emit("Unpause {}".format(representation_id))
# temporary here for testing, will be removed TODO
- def _add_site(self, repre_ids=None, site_name=None):
- log.debug("Add site {}:{}".format(repre_ids, site_name))
- for representation_id in repre_ids:
- item = self._get_item_by_repre_id(representation_id)
+ def _add_site(self, selected_ids=None, site_name=None):
+ log.debug("Add site {}:{}".format(selected_ids, site_name))
+ for representation_id in selected_ids:
+ item = lib.get_item_by_id(self.model, representation_id)
if item.local_site == site_name or item.remote_site == site_name:
# site already exists skip
continue
@@ -411,7 +318,7 @@ class SyncRepresentationWidget(QtWidgets.QWidget):
except ValueError as exp:
self.message_generated.emit("Error {}".format(str(exp)))
- def _remove_site(self, repre_ids=None, site_name=None):
+ def _remove_site(self, selected_ids=None, site_name=None):
"""
Removes site record AND files.
@@ -421,8 +328,8 @@ class SyncRepresentationWidget(QtWidgets.QWidget):
This could only happen when artist work on local machine, not
connected to studio mounted drives.
"""
- log.debug("Remove site {}:{}".format(repre_ids, site_name))
- for representation_id in repre_ids:
+ log.debug("Remove site {}:{}".format(selected_ids, site_name))
+ for representation_id in selected_ids:
log.info("Removing {}".format(representation_id))
try:
self.sync_server.remove_site(
@@ -438,14 +345,14 @@ class SyncRepresentationWidget(QtWidgets.QWidget):
self.model.refresh(
load_records=self.model._rec_loaded)
- def _reset_site(self, repre_ids=None, site_name=None):
+ def _reset_site(self, selected_ids=None, site_name=None):
"""
Removes errors or success metadata for particular file >> forces
redo of upload/download
"""
- log.debug("Reset site {}:{}".format(repre_ids, site_name))
- for representation_id in repre_ids:
- item = self._get_item_by_repre_id(representation_id)
+ log.debug("Reset site {}:{}".format(selected_ids, site_name))
+ for representation_id in selected_ids:
+ item = lib.get_item_by_id(self.model, representation_id)
check_progress = self._get_progress(item, site_name, True)
# do not reset if opposite side is not fully there
@@ -463,10 +370,10 @@ class SyncRepresentationWidget(QtWidgets.QWidget):
self.model.refresh(
load_records=self.model._rec_loaded)
- def _open_in_explorer(self, repre_ids=None, site_name=None):
- log.debug("Open in Explorer {}:{}".format(repre_ids, site_name))
- for representation_id in repre_ids:
- item = self._get_item_by_repre_id(representation_id)
+ def _open_in_explorer(self, selected_ids=None, site_name=None):
+ log.debug("Open in Explorer {}:{}".format(selected_ids, site_name))
+ for selected_id in selected_ids:
+ item = lib.get_item_by_id(self.model, selected_id)
if not item:
return
@@ -500,14 +407,9 @@ class SyncRepresentationWidget(QtWidgets.QWidget):
return progress[side]
- def _get_item_by_repre_id(self, representation_id):
- index = self.model.get_index(representation_id)
- item = self.model.data(index, lib.FullItemRole)
- return item
-
def _get_action_kwargs(self, site_name):
"""Default format of kwargs for action"""
- return {"repre_ids": self._selected_ids, "site_name": site_name}
+ return {"selected_ids": self._selected_ids, "site_name": site_name}
def _save_scrollbar(self):
self._scrollbar_pos = self.table_view.verticalScrollBar().value()
@@ -517,7 +419,155 @@ class SyncRepresentationWidget(QtWidgets.QWidget):
self.table_view.verticalScrollBar().setValue(self._scrollbar_pos)
-class SyncRepresentationDetailWidget(QtWidgets.QWidget):
+class SyncRepresentationSummaryWidget(_SyncRepresentationWidget):
+
+ default_widths = (
+ ("asset", 190),
+ ("subset", 170),
+ ("version", 60),
+ ("representation", 145),
+ ("local_site", 160),
+ ("remote_site", 160),
+ ("files_count", 50),
+ ("files_size", 60),
+ ("priority", 70),
+ ("status", 110)
+ )
+
+ def __init__(self, sync_server, project=None, parent=None):
+ super(SyncRepresentationSummaryWidget, self).__init__(parent)
+
+ self.sync_server = sync_server
+
+ self._selected_ids = [] # keep last selected _id
+
+ txt_filter = QtWidgets.QLineEdit()
+ txt_filter.setPlaceholderText("Quick filter representations..")
+ txt_filter.setClearButtonEnabled(True)
+ txt_filter.addAction(qtawesome.icon("fa.filter", color="gray"),
+ QtWidgets.QLineEdit.LeadingPosition)
+ self.txt_filter = txt_filter
+
+ self._scrollbar_pos = None
+
+ top_bar_layout = QtWidgets.QHBoxLayout()
+ top_bar_layout.addWidget(self.txt_filter)
+
+ table_view = QtWidgets.QTableView()
+ headers = [item[0] for item in self.default_widths]
+
+ model = SyncRepresentationSummaryModel(sync_server, headers, project)
+ table_view.setModel(model)
+ table_view.setContextMenuPolicy(QtCore.Qt.CustomContextMenu)
+ table_view.setSelectionMode(
+ QtWidgets.QAbstractItemView.ExtendedSelection)
+ table_view.setSelectionBehavior(
+ QtWidgets.QAbstractItemView.SelectRows)
+ table_view.horizontalHeader().setSortIndicator(
+ -1, Qt.AscendingOrder)
+ table_view.setAlternatingRowColors(True)
+ table_view.verticalHeader().hide()
+
+ column = table_view.model().get_header_index("local_site")
+ delegate = ImageDelegate(self)
+ table_view.setItemDelegateForColumn(column, delegate)
+
+ column = table_view.model().get_header_index("remote_site")
+ delegate = ImageDelegate(self)
+ table_view.setItemDelegateForColumn(column, delegate)
+
+ layout = QtWidgets.QVBoxLayout(self)
+ layout.setContentsMargins(0, 0, 0, 0)
+ layout.addLayout(top_bar_layout)
+ layout.addWidget(table_view)
+
+ self.table_view = table_view
+ self.model = model
+
+ horizontal_header = HorizontalHeader(self)
+
+ table_view.setHorizontalHeader(horizontal_header)
+ table_view.setSortingEnabled(True)
+
+ for column_name, width in self.default_widths:
+ idx = model.get_header_index(column_name)
+ table_view.setColumnWidth(idx, width)
+
+ table_view.doubleClicked.connect(self._double_clicked)
+ self.txt_filter.textChanged.connect(lambda: model.set_word_filter(
+ self.txt_filter.text()))
+ table_view.customContextMenuRequested.connect(self._on_context_menu)
+
+ model.refresh_started.connect(self._save_scrollbar)
+ model.refresh_finished.connect(self._set_scrollbar)
+ model.modelReset.connect(self._set_selection)
+
+ self.selection_model = self.table_view.selectionModel()
+ self.selection_model.selectionChanged.connect(self._selection_changed)
+
+
+ def _prepare_menu(self, item, is_multi):
+ action_kwarg_map, actions_mapping, menu = \
+ super()._prepare_menu(item, is_multi)
+
+ if item.status in [lib.STATUS[0], lib.STATUS[1]] or is_multi:
+ action = QtWidgets.QAction("Pause in queue")
+ actions_mapping[action] = self._pause
+ # pause handles which site_name it will pause itself
+ action_kwarg_map[action] = {"selected_ids": self._selected_ids}
+ menu.addAction(action)
+
+ if item.status == lib.STATUS[3] or is_multi:
+ action = QtWidgets.QAction("Unpause in queue")
+ actions_mapping[action] = self._unpause
+ action_kwarg_map[action] = {"selected_ids": self._selected_ids}
+ menu.addAction(action)
+
+ return action_kwarg_map, actions_mapping, menu
+
+
+class SyncServerDetailWindow(QtWidgets.QDialog):
+ """Wrapper window for SyncRepresentationDetailWidget
+
+ Creates standalone window with list of files for selected repre_id.
+ """
+ def __init__(self, sync_server, _id, project, parent=None):
+ log.debug(
+ "!!! SyncServerDetailWindow _id:: {}".format(_id))
+ super(SyncServerDetailWindow, self).__init__(parent)
+ self.setWindowFlags(QtCore.Qt.Window)
+ self.setFocusPolicy(QtCore.Qt.StrongFocus)
+
+ self.setStyleSheet(style.load_stylesheet())
+ self.setWindowIcon(QtGui.QIcon(style.app_icon_path()))
+ self.resize(1000, 400)
+
+ body = QtWidgets.QWidget()
+ footer = QtWidgets.QWidget()
+ footer.setFixedHeight(20)
+
+ container = SyncRepresentationDetailWidget(sync_server, _id, project,
+ parent=self)
+ body_layout = QtWidgets.QHBoxLayout(body)
+ body_layout.addWidget(container)
+ body_layout.setContentsMargins(0, 0, 0, 0)
+
+ self.message = QtWidgets.QLabel()
+ self.message.hide()
+
+ footer_layout = QtWidgets.QVBoxLayout(footer)
+ footer_layout.addWidget(self.message)
+ footer_layout.setContentsMargins(0, 0, 0, 0)
+
+ layout = QtWidgets.QVBoxLayout(self)
+ layout.addWidget(body)
+ layout.addWidget(footer)
+
+ self.setLayout(body_layout)
+ self.setWindowTitle("Sync Representation Detail")
+
+
+class SyncRepresentationDetailWidget(_SyncRepresentationWidget):
"""
Widget to display list of synchronizable files for single repre.
@@ -541,13 +591,12 @@ class SyncRepresentationDetailWidget(QtWidgets.QWidget):
super(SyncRepresentationDetailWidget, self).__init__(parent)
log.debug("Representation_id:{}".format(_id))
- self.representation_id = _id
- self.item = None # set to item that mouse was clicked over
self.project = project
self.sync_server = sync_server
- self._selected_id = None
+ self.representation_id = _id
+ self._selected_ids = []
self.txt_filter = QtWidgets.QLineEdit()
self.txt_filter.setPlaceholderText("Quick filter representation..")
@@ -568,7 +617,7 @@ class SyncRepresentationDetailWidget(QtWidgets.QWidget):
table_view.setModel(model)
table_view.setContextMenuPolicy(QtCore.Qt.CustomContextMenu)
table_view.setSelectionMode(
- QtWidgets.QAbstractItemView.SingleSelection)
+ QtWidgets.QAbstractItemView.ExtendedSelection)
table_view.setSelectionBehavior(
QtWidgets.QTableView.SelectRows)
table_view.horizontalHeader().setSortIndicator(-1, Qt.AscendingOrder)
@@ -613,171 +662,118 @@ class SyncRepresentationDetailWidget(QtWidgets.QWidget):
model.refresh_finished.connect(self._set_scrollbar)
model.modelReset.connect(self._set_selection)
- def _selection_changed(self):
- index = self.selection_model.currentIndex()
- self._selected_id = self.model.data(index, Qt.UserRole)
-
- def _set_selection(self):
- """
- Sets selection to 'self._selected_id' if exists.
-
- Keep selection during model refresh.
- """
- if self._selected_id:
- index = self.model.get_index(self._selected_id)
- if index and index.isValid():
- mode = QtCore.QItemSelectionModel.Select | \
- QtCore.QItemSelectionModel.Rows
- self.selection_model.setCurrentIndex(index, mode)
- else:
- self._selected_id = None
-
- def _show_detail(self):
+ def _show_detail(self, selected_ids=None):
"""
Shows windows with error message for failed sync of a file.
"""
- dt = max(self.item.created_dt, self.item.sync_dt)
- detail_window = SyncRepresentationErrorWindow(self.item._id,
- self.project,
- dt,
- self.item.tries,
- self.item.error)
+ detail_window = SyncRepresentationErrorWindow(self.model, selected_ids)
+
detail_window.exec()
- def _on_context_menu(self, point):
- """
- Shows menu with loader actions on Right-click.
- """
- point_index = self.table_view.indexAt(point)
- if not point_index.isValid():
- return
+ def _prepare_menu(self, item, is_multi):
+ """Adds view (and model) dependent actions to default ones"""
+ action_kwarg_map, actions_mapping, menu = \
+ super()._prepare_menu(item, is_multi)
- self.item = self.model._data[point_index.row()]
-
- menu = QtWidgets.QMenu()
- actions_mapping = {}
- action_kwarg_map = {}
-
- local_site = self.item.local_site
- local_progress = self.item.local_progress
- remote_site = self.item.remote_site
- remote_progress = self.item.remote_progress
-
- for site, progress in {local_site: local_progress,
- remote_site: remote_progress}.items():
- project = self.model.project
- provider = self.sync_server.get_provider_for_site(project,
- site)
- if provider == 'local_drive':
- if 'studio' in site:
- txt = " studio version"
- else:
- txt = " local version"
- action = QtWidgets.QAction("Open in explorer" + txt)
- if progress == 1:
- actions_mapping[action] = self._open_in_explorer
- action_kwarg_map[action] = {'site': site}
- menu.addAction(action)
-
- if self.item.status == lib.STATUS[2]:
+ if item.status == lib.STATUS[2] or is_multi:
action = QtWidgets.QAction("Open error detail")
actions_mapping[action] = self._show_detail
+ action_kwarg_map[action] = {"selected_ids": self._selected_ids}
+
menu.addAction(action)
- if float(remote_progress) == 1.0:
- action = QtWidgets.QAction("Re-sync active site")
- actions_mapping[action] = self._reset_local_site
- menu.addAction(action)
-
- if float(local_progress) == 1.0:
- action = QtWidgets.QAction("Re-sync remote site")
- actions_mapping[action] = self._reset_remote_site
- menu.addAction(action)
-
- if not actions_mapping:
- action = QtWidgets.QAction("< No action >")
- actions_mapping[action] = None
- menu.addAction(action)
-
- result = menu.exec_(QtGui.QCursor.pos())
- if result:
- to_run = actions_mapping[result]
- to_run_kwargs = action_kwarg_map.get(result, {})
- if to_run:
- to_run(**to_run_kwargs)
-
- def _reset_local_site(self):
+ return action_kwarg_map, actions_mapping, menu
+
+ def _reset_site(self, selected_ids=None, site_name=None):
"""
Removes errors or success metadata for particular file >> forces
redo of upload/download
"""
- self.sync_server.reset_provider_for_file(
- self.model.project,
- self.representation_id,
- 'local',
- self.item._id)
+ for file_id in selected_ids:
+ item = lib.get_item_by_id(self.model, file_id)
+ check_progress = self._get_progress(item, site_name, True)
+
+ # do not reset if opposite side is not fully there
+ if check_progress != 1:
+ log.debug("Not fully available {} on other side, skipping".
+ format(check_progress))
+ continue
+
+ self.sync_server.reset_provider_for_file(
+ self.model.project,
+ self.representation_id,
+ site_name=site_name,
+ file_id=file_id,
+ force=True)
self.model.refresh(
load_records=self.model._rec_loaded)
- def _reset_remote_site(self):
- """
- Removes errors or success metadata for particular file >> forces
- redo of upload/download
- """
- self.sync_server.reset_provider_for_file(
- self.model.project,
- self.representation_id,
- 'remote',
- self.item._id)
- self.model.refresh(
- load_records=self.model._rec_loaded)
- def _open_in_explorer(self, site):
- if not self.item:
- return
+class SyncRepresentationErrorWindow(QtWidgets.QDialog):
+ """Wrapper window to show errors during sync on file(s)"""
+ def __init__(self, model, selected_ids, parent=None):
+ super(SyncRepresentationErrorWindow, self).__init__(parent)
+ self.setWindowFlags(QtCore.Qt.Window)
+ self.setFocusPolicy(QtCore.Qt.StrongFocus)
- fpath = self.item.path
- project = self.project
- fpath = self.sync_server.get_local_file_path(project, site, fpath)
+ self.setStyleSheet(style.load_stylesheet())
+ self.setWindowIcon(QtGui.QIcon(style.app_icon_path()))
+ self.resize(900, 150)
- fpath = os.path.normpath(os.path.dirname(fpath))
- if os.path.isdir(fpath):
- if 'win' in sys.platform: # windows
- subprocess.Popen('explorer "%s"' % fpath)
- elif sys.platform == 'darwin': # macOS
- subprocess.Popen(['open', fpath])
- else: # linux
- try:
- subprocess.Popen(['xdg-open', fpath])
- except OSError:
- raise OSError('unsupported xdg-open call??')
+ body = QtWidgets.QWidget()
- def _save_scrollbar(self):
- self._scrollbar_pos = self.table_view.verticalScrollBar().value()
+ container = SyncRepresentationErrorWidget(model,
+ selected_ids,
+ parent=self)
+ body_layout = QtWidgets.QHBoxLayout(body)
+ body_layout.addWidget(container)
+ body_layout.setContentsMargins(0, 0, 0, 0)
- def _set_scrollbar(self):
- if self._scrollbar_pos:
- self.table_view.verticalScrollBar().setValue(self._scrollbar_pos)
+ message = QtWidgets.QLabel()
+ message.hide()
+
+ layout = QtWidgets.QVBoxLayout(self)
+ layout.addWidget(body)
+
+ self.setLayout(body_layout)
+ self.setWindowTitle("Sync Representation Error Detail")
class SyncRepresentationErrorWidget(QtWidgets.QWidget):
"""
- Dialog to show when sync error happened, prints error message
+ Dialog to show when sync error happened, prints formatted error message
"""
-
- def __init__(self, _id, dt, tries, msg, parent=None):
+ def __init__(self, model, selected_ids, parent=None):
super(SyncRepresentationErrorWidget, self).__init__(parent)
- layout = QtWidgets.QHBoxLayout(self)
+ layout = QtWidgets.QVBoxLayout(self)
- txts = []
- txts.append("{}: {}".format("Last update date", pretty_timestamp(dt)))
- txts.append("{}: {}".format("Retries", str(tries)))
- txts.append("{}: {}".format("Error message", msg))
+ no_errors = True
+ for file_id in selected_ids:
+ item = lib.get_item_by_id(model, file_id)
+ if not item.created_dt or not item.sync_dt or not item.error:
+ continue
- text_area = QtWidgets.QPlainTextEdit("\n\n".join(txts))
- text_area.setReadOnly(True)
- layout.addWidget(text_area)
+ no_errors = False
+ dt = max(item.created_dt, item.sync_dt)
+
+ txts = []
+ txts.append("{}: {}
".format("Last update date",
+ pretty_timestamp(dt)))
+ txts.append("{}: {}
".format("Retries",
+ str(item.tries)))
+ txts.append("{}: {}
".format("Error message",
+ item.error))
+
+ text_area = QtWidgets.QTextEdit("\n\n".join(txts))
+ text_area.setReadOnly(True)
+ layout.addWidget(text_area)
+
+ if no_errors:
+ text_area = QtWidgets.QTextEdit()
+ text_area.setText("