mirror of
https://github.com/alicevision/Meshroom.git
synced 2025-04-29 02:08:08 +02:00
126 lines
3.8 KiB
Python
126 lines
3.8 KiB
Python
from __future__ import print_function
|
|
|
|
from contextlib import contextmanager
|
|
import importlib
|
|
import inspect
|
|
import os
|
|
import re
|
|
import tempfile
|
|
import uuid
|
|
import logging
|
|
import pkgutil
|
|
|
|
from meshroom.core.submitter import BaseSubmitter
|
|
from . import desc
|
|
|
|
# Setup logging
|
|
logging.basicConfig(format='[%(asctime)s][%(levelname)s] %(message)s', level=logging.INFO)
|
|
|
|
# make a UUID based on the host ID and current time
|
|
sessionUid = str(uuid.uuid1())
|
|
|
|
cacheFolderName = 'MeshroomCache'
|
|
defaultCacheFolder = os.environ.get('MESHROOM_CACHE', os.path.join(tempfile.gettempdir(), cacheFolderName))
|
|
defaultCacheFolder = defaultCacheFolder.replace("\\", "/")
|
|
nodesDesc = {}
|
|
submitters = {}
|
|
|
|
|
|
@contextmanager
|
|
def add_to_path(p):
|
|
import sys
|
|
old_path = sys.path
|
|
sys.path = sys.path[:]
|
|
sys.path.insert(0, p)
|
|
try:
|
|
yield
|
|
finally:
|
|
sys.path = old_path
|
|
|
|
|
|
def loadPlugins(folder, packageName, classType):
|
|
"""
|
|
"""
|
|
|
|
nodeTypes = []
|
|
errors = []
|
|
|
|
# temporarily add folder to python path
|
|
with add_to_path(folder):
|
|
# import node package
|
|
package = importlib.import_module(packageName)
|
|
packageName = package.packageName if hasattr(package, 'packageName') else package.__name__
|
|
packageVersion = getattr(package, "__version__", None)
|
|
|
|
for importer, pluginName, ispkg in pkgutil.iter_modules(package.__path__):
|
|
pluginModule = '.' + pluginName
|
|
|
|
try:
|
|
pMod = importlib.import_module(pluginModule, package=package.__name__)
|
|
p = [m for name, m in inspect.getmembers(pMod, inspect.isclass)
|
|
if m.__module__ == '{}.{}'.format(package.__name__, pluginName) and issubclass(m, classType)]
|
|
if not p:
|
|
raise RuntimeError('No class defined in plugin: %s' % pluginModule)
|
|
for a in p:
|
|
a.packageName = packageName
|
|
a.packageVersion = packageVersion
|
|
nodeTypes.extend(p)
|
|
except Exception as e:
|
|
errors.append(' * {}: {}'.format(pluginName, str(e)))
|
|
|
|
if errors:
|
|
logging.warning('== Error while loading the following plugins ==\n'
|
|
'{}\n'
|
|
.format('\n'.join(errors)))
|
|
return nodeTypes
|
|
|
|
|
|
def registerNodeType(nodeType):
|
|
""" Register a Node Type based on a Node Description class.
|
|
|
|
After registration, nodes of this type can be instantiated in a Graph.
|
|
"""
|
|
global nodesDesc
|
|
if nodeType.__name__ in nodesDesc:
|
|
raise RuntimeError("Node Desc {} is already registered.".format(nodeType.__name__))
|
|
nodesDesc[nodeType.__name__] = nodeType
|
|
|
|
|
|
def loadNodes(folder, packageName):
|
|
return loadPlugins(folder, packageName, desc.Node)
|
|
|
|
|
|
def loadAllNodes(folder):
|
|
global nodesDesc
|
|
for importer, package, ispkg in pkgutil.walk_packages([folder]):
|
|
if ispkg:
|
|
nodeTypes = loadNodes(folder, package)
|
|
for nodeType in nodeTypes:
|
|
registerNodeType(nodeType)
|
|
print('Plugins loaded: ', ', '.join([nodeType.__name__ for nodeType in nodeTypes]))
|
|
|
|
|
|
def registerSubmitter(s):
|
|
global submitters
|
|
if s.name in submitters:
|
|
raise RuntimeError("Submitter {} is already registered.".format(s.name))
|
|
submitters[s.name] = s
|
|
|
|
|
|
def loadSubmitters(folder, packageName):
|
|
return loadPlugins(folder, packageName, BaseSubmitter)
|
|
|
|
|
|
meshroomFolder = os.path.dirname(os.path.dirname(__file__))
|
|
|
|
# Load plugins:
|
|
# - Nodes
|
|
loadAllNodes(folder=os.path.join(meshroomFolder, 'nodes'))
|
|
# - Submitters
|
|
subs = loadSubmitters(meshroomFolder, 'submitters')
|
|
# - additional 3rd party submitters
|
|
if "MESHROOM_SUBMITTERS_PATH" in os.environ:
|
|
subs += loadSubmitters(os.environ["MESHROOM_SUBMITTERS_PATH"], 'submitters')
|
|
|
|
for sub in subs:
|
|
registerSubmitter(sub())
|