From b405299e92fe718993591892c71d59f76a604b5d Mon Sep 17 00:00:00 2001
From: Petr Kalis <petr.kalis@gmail.com>
Date: Thu, 15 Sep 2022 15:33:57 +0200
Subject: [PATCH] OP-3940 - added collector for remote publishes

In Webpublisher uploaded workfile name is not relieable, use last published + 1 instead.
---
 .../publish/collect_published_version.py      | 55 +++++++++++++++++++
 1 file changed, 55 insertions(+)
 create mode 100644 openpype/hosts/photoshop/plugins/publish/collect_published_version.py

diff --git a/openpype/hosts/photoshop/plugins/publish/collect_published_version.py b/openpype/hosts/photoshop/plugins/publish/collect_published_version.py
new file mode 100644
index 0000000000..2502689e4b
--- /dev/null
+++ b/openpype/hosts/photoshop/plugins/publish/collect_published_version.py
@@ -0,0 +1,55 @@
+"""Collects published version of workfile and increments it.
+
+For synchronization of published image and workfile version it is required
+to store workfile version from workfile file name in context.data["version"].
+In remote publishing this name is unreliable (artist might not follow naming
+convention etc.), last published workfile version for particular workfile
+subset is used instead.
+
+This plugin runs only in remote publishing (eg. Webpublisher).
+
+Requires:
+    context.data["assetEntity"]
+
+Provides:
+    context["version"] - incremented latest published workfile version
+"""
+
+import pyblish.api
+
+from openpype.client import get_last_version_by_subset_name
+
+
+class CollectPublishedVersion(pyblish.api.ContextPlugin):
+    """Collects published version of workfile and increments it."""
+
+    order = pyblish.api.CollectorOrder + 0.190
+    label = "Collect published version"
+    hosts = ["photoshop"]
+    targets = ["remotepublish"]
+
+    def process(self, context):
+        workfile_subset_name = None
+        for instance in context:
+            if instance.data["family"] == "workfile":
+                workfile_subset_name = instance.data["subset"]
+                break
+
+        if not workfile_subset_name:
+            self.log.warning("No workfile instance found, "
+                             "synchronization of version will not work.")
+            return
+
+        project_name = context.data["projectName"]
+        asset_doc = context.data["assetEntity"]
+        asset_id = asset_doc["_id"]
+
+        version_doc = get_last_version_by_subset_name(project_name,
+                                                      workfile_subset_name,
+                                                      asset_id)
+        version_int = 1
+        if version_doc:
+            version_int += int(version_doc["name"])
+
+        self.log.debug(f"Setting {version_int} to context.")
+        context.data["version"] = version_int