Ftrack: Trigger custom ftrack events on project creation and preparation

openpype/modules/ftrack/event_handlers_server/action_prepare_project.py

@@ -1,4 +1,5 @@
 import json
+import copy
 
 from openpype.client import get_project
 from openpype.api import ProjectSettings
@@ -373,6 +374,10 @@ def launch(self, session, entities, event):
  project_name, project_code
  ))
  create_project(project_name, project_code)
+ self.trigger_event(
+ "openpype.project.created",
+ {"project_name": project_name}
+ )
 
  project_settings = ProjectSettings(project_name)
  project_anatomy_settings = project_settings["project_anatomy"]
@@ -400,6 +405,10 @@ def launch(self, session, entities, event):
  self.log.debug("- Key \"{}\" set to \"{}\"".format(key, value))
  session.commit()
 
+ event_data = copy.deepcopy(in_data)
+ event_data["project_name"] = project_name
+ self.trigger_event("openpype.project.prepared", event_data)
+
  return True
 
 

openpype/modules/ftrack/event_handlers_server/action_sync_to_avalon.py

@@ -1,7 +1,8 @@
 import time
 import sys
 import json
-import traceback
+
+import ftrack_api
 
 from openpype_modules.ftrack.lib import ServerAction
 from openpype_modules.ftrack.lib.avalon_sync import SyncEntitiesFactory
@@ -180,6 +181,13 @@ def synchronization(self, event, project_name):
  "* Total time: {}".format(time_7 - time_start)
  )
 
+ if self.entities_factory.project_created:
+ event = ftrack_api.event.base.Event(
+ topic="openpype.project.created",
+ data={"project_name": project_name}
+ )
+ self.session.event_hub.publish(event)
+
  report = self.entities_factory.report()
  if report and report.get("items"):
  default_title = "Synchronization report ({}):".format(

openpype/modules/ftrack/event_handlers_user/action_prepare_project.py

@@ -1,4 +1,5 @@
 import json
+import copy
 
 from openpype.client import get_project
 from openpype.api import ProjectSettings
@@ -399,6 +400,10 @@ def launch(self, session, entities, event):
  project_name, project_code
  ))
  create_project(project_name, project_code)
+ self.trigger_event(
+ "openpype.project.created",
+ {"project_name": project_name}
+ )
 
  project_settings = ProjectSettings(project_name)
  project_anatomy_settings = project_settings["project_anatomy"]
@@ -433,6 +438,10 @@ def launch(self, session, entities, event):
  self.process_identifier()
  )
  self.trigger_action(trigger_identifier, event)
+
+ event_data = copy.deepcopy(in_data)
+ event_data["project_name"] = project_name
+ self.trigger_event("openpype.project.prepared", event_data)
  return True
 
 

openpype/modules/ftrack/event_handlers_user/action_sync_to_avalon.py

@@ -1,7 +1,8 @@
 import time
 import sys
 import json
-import traceback
+
+import ftrack_api
 
 from openpype_modules.ftrack.lib import BaseAction, statics_icon
 from openpype_modules.ftrack.lib.avalon_sync import SyncEntitiesFactory
@@ -184,6 +185,13 @@ def synchronization(self, event, project_name):
  "* Total time: {}".format(time_7 - time_start)
  )
 
+ if self.entities_factory.project_created:
+ event = ftrack_api.event.base.Event(
+ topic="openpype.project.created",
+ data={"project_name": project_name}
+ )
+ self.session.event_hub.publish(event)
+
  report = self.entities_factory.report()
  if report and report.get("items"):
  default_title = "Synchronization report ({}):".format(

openpype/modules/ftrack/lib/avalon_sync.py

@@ -443,6 +443,7 @@ def launch_setup(self, project_full_name):
  }
 
  self.create_list = []
+ self.project_created = False
  self.unarchive_list = []
  self.updates = collections.defaultdict(dict)
 
@@ -2214,6 +2215,7 @@ def create_avalon_project(self):
  self._avalon_ents_by_name[project_item["name"]] = str(new_id)
 
  self.create_list.append(project_item)
+ self.project_created = True
 
  # store mongo id to ftrack entity
  entity = self.entities_dict[self.ft_project_id]["entity"]

openpype/modules/ftrack/lib/ftrack_base_handler.py

@@ -535,14 +535,17 @@ def trigger_action(
  )
 
  def trigger_event(
- self, topic, event_data={}, session=None, source=None,
+ self, topic, event_data=None, session=None, source=None,
  event=None, on_error="ignore"
  ):
  if session is None:
  session = self.session
 
  if not source and event:
  source = event.get("source")
+
+ if event_data is None:
+ event_data = {}
  # Create and trigger event
  event = ftrack_api.event.base.Event(
  topic=topic,