[draft] convert premiere to pype2

.gitignore

@@ -33,3 +33,5 @@ coverage.xml
 ##################
 node_modules/
 package-lock.json
+
+pype/premiere/ppro/js/debug.log

pype/avalon_apps/rest_api.py

@@ -23,7 +23,9 @@ def get_project(self, request):
  if not project_name:
  output = {}
  for project_name in self.dbcon.tables():
- project = self.dbcon[project_name].find_one({"type": "project"})
+ project = self.dbcon[project_name].find_one({
+ "type": "project"
+ })
  output[project_name] = project
 
  return CallbackResult(data=self.result_to_json(output))
@@ -44,7 +46,7 @@ def get_assets(self, request):
 
  if not self.dbcon.exist_table(_project_name):
  abort(404, "Project \"{}\" was not found in database".format(
- project_name
+ _project_name
  ))
 
  if not _asset:
@@ -65,9 +67,26 @@ def get_assets(self, request):
  return asset
 
  abort(404, "Asset \"{}\" with {} was not found in project {}".format(
- _asset, identificator, project_name
+ _asset, identificator, _project_name
  ))
 
+ @RestApi.route("/publish/<asset_name>", url_prefix="/premiere", methods="GET")
+ def publish(self, request):
+ """
+ http://localhost:8021/premiere/publish/shot021?json_in=this/path/file_in.json&json_out=this/path/file_out.json
+ """
+ asset_name = request.url_data["asset_name"]
+ query = request.query
+ data = request.request_data
+
+ output = {
+ "message": "Got your data. Thanks.",
+ "your_data": data,
+ "your_query": query,
+ "your_asset_is": asset_name
+ }
+ return CallbackResult(data=self.result_to_json(output))
+
  def result_to_json(self, result):
  """ Converts result of MongoDB query to dict without $oid (ObjectId)
  keys with help of regex matching.

pype/hooks/premiere/prelaunch.py

@@ -0,0 +1,45 @@
+import os
+import traceback
+from pype.lib import PypeHook
+from pypeapp import Logger
+import importlib
+import avalon.api
+import pype.premiere
+from pype.premiere import lib as prlib
+
+
+class PremierePrelaunch(PypeHook):
+ """
+ This hook will check if current workfile path has Adobe Premiere
+ project inside. IF not, it initialize it and finally it pass
+ path to the project by environment variable to Premiere launcher
+ shell script.
+ """
+
+ def __init__(self, logger=None):
+ if not logger:
+ self.log = Logger().get_logger(self.__class__.__name__)
+ else:
+ self.log = logger
+
+ self.signature = "( {} )".format(self.__class__.__name__)
+
+ def execute(self, *args, env: dict = None) -> bool:
+
+ if not env:
+ env = os.environ
+
+ try:
+ __import__("pype.premiere")
+ __import__("pyblish")
+
+ except ImportError as e:
+ print(traceback.format_exc())
+ print("pyblish: Could not load integration: %s " % e)
+
+ else:
+ # Premiere Setup integration
+ importlib.reload(prlib)
+ prlib.setup(env)
+
+ return True

pype/plugins/adobecommunicator/publish/collect_context.py

@@ -0,0 +1,91 @@
+import os
+import pyblish.api
+from avalon import (
+ io,
+ api as avalon
+)
+import json
+from pathlib import Path
+
+
+class CollectContextDataFromAport(pyblish.api.ContextPlugin):
+ """
+ Collecting temp json data sent from a host context
+ and path for returning json data back to hostself.
+
+ Setting avalon session into correct context
+
+ Args:
+ context (obj): pyblish context session
+
+ """
+
+ label = "AdobeCommunicator Collect Context"
+ order = pyblish.api.CollectorOrder - 0.49
+
+ def process(self, context):
+ self.log.info("registred_hosts: `{}`".format(pyblish.api.registered_hosts()))
+ io.install()
+ # get json paths from data
+ input_json_path = os.environ.get("AC_PUBLISH_INPATH")
+ output_json_path = os.environ.get("AC_PUBLISH_OUTPATH")
+
+ rqst_json_data_path = Path(input_json_path)
+ post_json_data_path = Path(output_json_path)
+
+ context.data['post_json_data_path'] = str(post_json_data_path)
+
+ # get avalon session data and convert \ to /
+ _S = avalon.session
+
+ projects = Path(_S["AVALON_PROJECTS"]).resolve()
+ asset = _S["AVALON_ASSET"]
+ workdir = Path(_S["AVALON_WORKDIR"]).resolve()
+ _S["AVALON_PROJECTS"] = str(projects)
+ _S["AVALON_WORKDIR"] = str(workdir)
+
+ context.data["avalonSession"] = _S
+ self.log.info(f"__ avalonSession: `{_S}`")
+
+ # get stagin directory from recieved path to json
+ context.data["stagingDir"] = post_json_data_path.parent
+
+ # get data from json file recieved
+ with rqst_json_data_path.open(mode='r') as f:
+ context.data["jsonData"] = json_data = json.load(f)
+ assert json_data, "No `data` in json file"
+
+ # get and check host type
+ host = json_data.get("host", None)
+ host_version = json_data.get("hostVersion", None)
+ assert host, "No `host` data in json file"
+ assert host_version, "No `hostVersion` data in json file"
+ context.data["host"] = _S["AVALON_APP"] = host
+ context.data["hostVersion"] = \
+ _S["AVALON_APP_VERSION"] = host_version
+
+ # get current file
+ current_file = json_data.get("currentFile", None)
+ assert current_file, "No `currentFile` data in json file"
+ context.data["currentFile"] = Path(current_file).resolve()
+
+ # get project data from avalon
+ project_data = io.find_one({'type': 'project'})
+ assert project_data, "No `project_data` data in avalon db"
+ context.data["projectData"] = project_data
+ self.log.debug("project_data: {}".format(project_data))
+
+ # get asset data from avalon and fix all paths
+ asset_data = io.find_one({
+ "type": 'asset',
+ "name": asset
+ })["data"]
+ assert asset_data, "No `asset_data` data in avalon db"
+
+ context.data["assetData"] = asset_data
+
+ self.log.debug("asset_data: {}".format(asset_data))
+ self.log.info("rqst_json_data_path is: {}".format(rqst_json_data_path))
+ self.log.info("post_json_data_path is: {}".format(post_json_data_path))
+
+ # self.log.info("avalon.session is: {}".format(avalon.session))