[f0d720b] | 1 | """ |
---|
| 2 | Utilities to manage models |
---|
| 3 | """ |
---|
[a1b8fee] | 4 | from __future__ import print_function |
---|
| 5 | |
---|
[f0d720b] | 6 | import os |
---|
| 7 | import sys |
---|
| 8 | import time |
---|
[7673ecd] | 9 | import datetime |
---|
[f0d720b] | 10 | import logging |
---|
[d3b0c77] | 11 | import traceback |
---|
[f0d720b] | 12 | import py_compile |
---|
| 13 | import shutil |
---|
[65f3930] | 14 | |
---|
| 15 | from sasmodels.sasview_model import load_custom_model, load_standard_models |
---|
[d3b0c77] | 16 | |
---|
[b963b20] | 17 | from sas import get_user_dir |
---|
[65f3930] | 18 | |
---|
[f0d720b] | 19 | # Explicitly import from the pluginmodel module so that py2exe |
---|
| 20 | # places it in the distribution. The Model1DPlugin class is used |
---|
| 21 | # as the base class of plug-in models. |
---|
[65f3930] | 22 | from .pluginmodel import Model1DPlugin |
---|
| 23 | |
---|
[463e7ffc] | 24 | logger = logging.getLogger(__name__) |
---|
[c155a16] | 25 | |
---|
[f66d9d1] | 26 | |
---|
[f0d720b] | 27 | PLUGIN_DIR = 'plugin_models' |
---|
[d3b0c77] | 28 | PLUGIN_LOG = os.path.join(get_user_dir(), PLUGIN_DIR, "plugins.log") |
---|
[0de74af] | 29 | PLUGIN_NAME_BASE = '[plug-in] ' |
---|
[f0d720b] | 30 | |
---|
| 31 | |
---|
[7673ecd] | 32 | def plugin_log(message): |
---|
[f0d720b] | 33 | """ |
---|
[dcdca68] | 34 | Log a message in a file located in the user's home directory |
---|
[f0d720b] | 35 | """ |
---|
[7673ecd] | 36 | out = open(PLUGIN_LOG, 'a') |
---|
| 37 | now = time.time() |
---|
| 38 | stamp = datetime.datetime.fromtimestamp(now).strftime('%Y-%m-%d %H:%M:%S') |
---|
| 39 | out.write("%s: %s\n" % (stamp, message)) |
---|
[f0d720b] | 40 | out.close() |
---|
| 41 | |
---|
| 42 | |
---|
| 43 | def _check_plugin(model, name): |
---|
| 44 | """ |
---|
| 45 | Do some checking before model adding plugins in the list |
---|
| 46 | |
---|
| 47 | :param model: class model to add into the plugin list |
---|
| 48 | :param name:name of the module plugin |
---|
| 49 | |
---|
| 50 | :return model: model if valid model or None if not valid |
---|
| 51 | |
---|
| 52 | """ |
---|
| 53 | #Check if the plugin is of type Model1DPlugin |
---|
| 54 | if not issubclass(model, Model1DPlugin): |
---|
| 55 | msg = "Plugin %s must be of type Model1DPlugin \n" % str(name) |
---|
[7673ecd] | 56 | plugin_log(msg) |
---|
[f0d720b] | 57 | return None |
---|
| 58 | if model.__name__ != "Model": |
---|
| 59 | msg = "Plugin %s class name must be Model \n" % str(name) |
---|
[7673ecd] | 60 | plugin_log(msg) |
---|
[f0d720b] | 61 | return None |
---|
| 62 | try: |
---|
| 63 | new_instance = model() |
---|
[ba8d326] | 64 | except Exception: |
---|
[f0d720b] | 65 | msg = "Plugin %s error in __init__ \n\t: %s %s\n" % (str(name), |
---|
| 66 | str(sys.exc_type), |
---|
| 67 | sys.exc_info()[1]) |
---|
[7673ecd] | 68 | plugin_log(msg) |
---|
[f0d720b] | 69 | return None |
---|
| 70 | |
---|
| 71 | if hasattr(new_instance, "function"): |
---|
| 72 | try: |
---|
| 73 | value = new_instance.function() |
---|
[ba8d326] | 74 | except Exception: |
---|
[f0d720b] | 75 | msg = "Plugin %s: error writing function \n\t :%s %s\n " % \ |
---|
| 76 | (str(name), str(sys.exc_type), sys.exc_info()[1]) |
---|
[7673ecd] | 77 | plugin_log(msg) |
---|
[f0d720b] | 78 | return None |
---|
| 79 | else: |
---|
| 80 | msg = "Plugin %s needs a method called function \n" % str(name) |
---|
[7673ecd] | 81 | plugin_log(msg) |
---|
[f0d720b] | 82 | return None |
---|
| 83 | return model |
---|
| 84 | |
---|
| 85 | |
---|
| 86 | def find_plugins_dir(): |
---|
| 87 | """ |
---|
[dcdca68] | 88 | Find path of the plugins directory. |
---|
| 89 | The plugin directory is located in the user's home directory. |
---|
[f0d720b] | 90 | """ |
---|
[277257f] | 91 | path = os.path.join(os.path.expanduser("~"), '.sasview', PLUGIN_DIR) |
---|
[f0d720b] | 92 | |
---|
[9706d88] | 93 | # TODO: trigger initialization of plugins dir from installer or startup |
---|
[f0d720b] | 94 | # If the plugin directory doesn't exist, create it |
---|
[277257f] | 95 | if not os.path.isdir(path): |
---|
| 96 | os.makedirs(path) |
---|
| 97 | # TODO: should we be checking for new default models every time? |
---|
[9706d88] | 98 | # TODO: restore support for default plugins |
---|
| 99 | #initialize_plugins_dir(path) |
---|
[277257f] | 100 | return path |
---|
| 101 | |
---|
| 102 | |
---|
| 103 | def initialize_plugins_dir(path): |
---|
| 104 | # TODO: There are no default plugins |
---|
[9706d88] | 105 | # TODO: Default plugins directory is in sasgui, but models.py is in sascalc |
---|
[277257f] | 106 | # TODO: Move default plugins beside sample data files |
---|
| 107 | # TODO: Should not look for defaults above the root of the sasview install |
---|
| 108 | |
---|
| 109 | # Walk up the tree looking for default plugin_models directory |
---|
| 110 | base = os.path.abspath(os.path.dirname(__file__)) |
---|
| 111 | for _ in range(12): |
---|
| 112 | default_plugins_path = os.path.join(base, PLUGIN_DIR) |
---|
| 113 | if os.path.isdir(default_plugins_path): |
---|
| 114 | break |
---|
| 115 | base, _ = os.path.split(base) |
---|
| 116 | else: |
---|
| 117 | logger.error("default plugins directory not found") |
---|
| 118 | return |
---|
| 119 | |
---|
| 120 | # Copy files from default plugins to the .sasview directory |
---|
| 121 | # This may include c files, depending on the example. |
---|
| 122 | # Note: files are never replaced, even if the default plugins are updated |
---|
| 123 | for filename in os.listdir(default_plugins_path): |
---|
| 124 | # skip __init__.py and all pyc files |
---|
| 125 | if filename == "__init__.py" or filename.endswith('.pyc'): |
---|
| 126 | continue |
---|
| 127 | source = os.path.join(default_plugins_path, filename) |
---|
| 128 | target = os.path.join(path, filename) |
---|
| 129 | if os.path.isfile(source) and not os.path.isfile(target): |
---|
| 130 | shutil.copy(source, target) |
---|
| 131 | |
---|
| 132 | |
---|
| 133 | class ReportProblem(object): |
---|
[f0d720b] | 134 | """ |
---|
[dcdca68] | 135 | Class to check for problems with specific values |
---|
[f0d720b] | 136 | """ |
---|
| 137 | def __nonzero__(self): |
---|
[7673ecd] | 138 | type, value, tb = sys.exc_info() |
---|
[f0d720b] | 139 | if type is not None and issubclass(type, py_compile.PyCompileError): |
---|
[9c3d784] | 140 | print("Problem with", repr(value)) |
---|
[fa81e94] | 141 | raise (type, value, tb) |
---|
[f0d720b] | 142 | return 1 |
---|
| 143 | |
---|
| 144 | report_problem = ReportProblem() |
---|
| 145 | |
---|
| 146 | |
---|
| 147 | def compile_file(dir): |
---|
| 148 | """ |
---|
| 149 | Compile a py file |
---|
| 150 | """ |
---|
| 151 | try: |
---|
| 152 | import compileall |
---|
[d85b0c7] | 153 | compileall.compile_dir(dir=dir, ddir=dir, force=0, |
---|
[f0d720b] | 154 | quiet=report_problem) |
---|
[ba8d326] | 155 | except Exception: |
---|
[f0d720b] | 156 | return sys.exc_info()[1] |
---|
| 157 | return None |
---|
| 158 | |
---|
| 159 | |
---|
[277257f] | 160 | def find_plugin_models(): |
---|
[7673ecd] | 161 | """ |
---|
| 162 | Find custom models |
---|
| 163 | """ |
---|
[f0d720b] | 164 | # List of plugin objects |
---|
[277257f] | 165 | plugins_dir = find_plugins_dir() |
---|
[f0d720b] | 166 | # Go through files in plug-in directory |
---|
[277257f] | 167 | if not os.path.isdir(plugins_dir): |
---|
| 168 | msg = "SasView couldn't locate Model plugin folder %r." % plugins_dir |
---|
[c155a16] | 169 | logger.warning(msg) |
---|
[7673ecd] | 170 | return {} |
---|
| 171 | |
---|
[277257f] | 172 | plugin_log("looking for models in: %s" % plugins_dir) |
---|
| 173 | # compile_file(plugins_dir) #always recompile the folder plugin |
---|
| 174 | logger.info("plugin model dir: %s", plugins_dir) |
---|
[7673ecd] | 175 | |
---|
| 176 | plugins = {} |
---|
[277257f] | 177 | for filename in os.listdir(plugins_dir): |
---|
[7673ecd] | 178 | name, ext = os.path.splitext(filename) |
---|
| 179 | if ext == '.py' and not name == '__init__': |
---|
[277257f] | 180 | path = os.path.abspath(os.path.join(plugins_dir, filename)) |
---|
[7673ecd] | 181 | try: |
---|
| 182 | model = load_custom_model(path) |
---|
[6fb559d] | 183 | plugins[model.name] = model |
---|
[7673ecd] | 184 | except Exception: |
---|
| 185 | msg = traceback.format_exc() |
---|
| 186 | msg += "\nwhile accessing model in %r" % path |
---|
| 187 | plugin_log(msg) |
---|
[ba8d326] | 188 | logger.warning("Failed to load plugin %r. See %s for details", |
---|
| 189 | path, PLUGIN_LOG) |
---|
[8d891d1] | 190 | |
---|
[f0d720b] | 191 | return plugins |
---|
| 192 | |
---|
| 193 | |
---|
[ba8d326] | 194 | class ModelManagerBase(object): |
---|
[f0d720b] | 195 | """ |
---|
[dcdca68] | 196 | Base class for the model manager |
---|
[f0d720b] | 197 | """ |
---|
[277257f] | 198 | #: mutable dictionary of models, continually updated to reflect the |
---|
| 199 | #: current set of plugins |
---|
| 200 | model_dictionary = None # type: Dict[str, Model] |
---|
| 201 | #: constant list of standard models |
---|
| 202 | standard_models = None # type: Dict[str, Model] |
---|
| 203 | #: list of plugin models reset each time the plugin directory is queried |
---|
| 204 | plugin_models = None # type: Dict[str, Model] |
---|
| 205 | #: timestamp on the plugin directory at the last plugin update |
---|
| 206 | last_time_dir_modified = 0 # type: int |
---|
[f0d720b] | 207 | |
---|
| 208 | def __init__(self): |
---|
[277257f] | 209 | # the model dictionary is allocated at the start and updated to |
---|
| 210 | # reflect the current list of models. Be sure to clear it rather |
---|
| 211 | # than reassign to it. |
---|
[f0d720b] | 212 | self.model_dictionary = {} |
---|
| 213 | |
---|
| 214 | #Build list automagically from sasmodels package |
---|
[277257f] | 215 | self.standard_models = {model.name: model |
---|
| 216 | for model in load_standard_models()} |
---|
| 217 | # Look for plugins |
---|
| 218 | self.plugins_reset() |
---|
[f0d720b] | 219 | |
---|
[277257f] | 220 | def _is_plugin_dir_changed(self): |
---|
[f0d720b] | 221 | """ |
---|
| 222 | check the last time the plugin dir has changed and return true |
---|
[dcdca68] | 223 | is the directory was modified else return false |
---|
[f0d720b] | 224 | """ |
---|
| 225 | is_modified = False |
---|
| 226 | plugin_dir = find_plugins_dir() |
---|
| 227 | if os.path.isdir(plugin_dir): |
---|
[277257f] | 228 | mod_time = os.path.getmtime(plugin_dir) |
---|
| 229 | if self.last_time_dir_modified != mod_time: |
---|
[f0d720b] | 230 | is_modified = True |
---|
[277257f] | 231 | self.last_time_dir_modified = mod_time |
---|
[f0d720b] | 232 | |
---|
| 233 | return is_modified |
---|
| 234 | |
---|
[277257f] | 235 | def composable_models(self): |
---|
| 236 | """ |
---|
| 237 | return list of standard models that can be used in sum/multiply |
---|
| 238 | """ |
---|
| 239 | # TODO: should scan plugin models in addition to standard models |
---|
| 240 | # and update model_editor so that it doesn't add plugins to the list |
---|
| 241 | return [model.name for model in self.standard_models.values() |
---|
| 242 | if not model.is_multiplicity_model] |
---|
| 243 | |
---|
| 244 | def plugins_update(self): |
---|
[f0d720b] | 245 | """ |
---|
| 246 | return a dictionary of model if |
---|
| 247 | new models were added else return empty dictionary |
---|
| 248 | """ |
---|
[277257f] | 249 | return self.plugins_reset() |
---|
| 250 | #if self._is_plugin_dir_changed(): |
---|
| 251 | # return self.plugins_reset() |
---|
| 252 | #else: |
---|
| 253 | # return {} |
---|
[f0d720b] | 254 | |
---|
[f66d9d1] | 255 | def plugins_reset(self): |
---|
[f0d720b] | 256 | """ |
---|
| 257 | return a dictionary of model |
---|
| 258 | """ |
---|
[277257f] | 259 | self.plugin_models = find_plugin_models() |
---|
| 260 | self.model_dictionary.clear() |
---|
| 261 | self.model_dictionary.update(self.standard_models) |
---|
| 262 | self.model_dictionary.update(self.plugin_models) |
---|
| 263 | return self.get_model_list() |
---|
[f0d720b] | 264 | |
---|
| 265 | def get_model_list(self): |
---|
| 266 | """ |
---|
[277257f] | 267 | return dictionary of classified models |
---|
| 268 | |
---|
| 269 | *Structure Factors* are the structure factor models |
---|
| 270 | *Multi-Functions* are the multiplicity models |
---|
| 271 | *Plugin Models* are the plugin models |
---|
[f0d720b] | 272 | |
---|
[277257f] | 273 | Note that a model can be both a plugin and a structure factor or |
---|
| 274 | multiplicity model. |
---|
[f0d720b] | 275 | """ |
---|
| 276 | ## Model_list now only contains attribute lists not category list. |
---|
| 277 | ## Eventually this should be in one master list -- read in category |
---|
| 278 | ## list then pull those models that exist and get attributes then add |
---|
| 279 | ## to list ..and if model does not exist remove from list as now |
---|
| 280 | ## and update json file. |
---|
| 281 | ## |
---|
| 282 | ## -PDB April 26, 2014 |
---|
| 283 | |
---|
| 284 | |
---|
[277257f] | 285 | # Classify models |
---|
| 286 | structure_factors = [] |
---|
[69363c7] | 287 | form_factors = [] |
---|
[277257f] | 288 | multiplicity_models = [] |
---|
| 289 | for model in self.model_dictionary.values(): |
---|
| 290 | # Old style models don't have is_structure_factor attribute |
---|
| 291 | if getattr(model, 'is_structure_factor', False): |
---|
| 292 | structure_factors.append(model) |
---|
[69363c7] | 293 | if getattr(model, 'is_form_factor', False): |
---|
| 294 | form_factors.append(model) |
---|
[277257f] | 295 | if model.is_multiplicity_model: |
---|
| 296 | multiplicity_models.append(model) |
---|
| 297 | plugin_models = list(self.plugin_models.values()) |
---|
| 298 | |
---|
| 299 | return { |
---|
| 300 | "Structure Factors": structure_factors, |
---|
[69363c7] | 301 | "Form Factors": form_factors, |
---|
[277257f] | 302 | "Plugin Models": plugin_models, |
---|
| 303 | "Multi-Functions": multiplicity_models, |
---|
| 304 | } |
---|
[f0d720b] | 305 | |
---|
| 306 | |
---|
| 307 | class ModelManager(object): |
---|
| 308 | """ |
---|
[277257f] | 309 | manage the list of available models |
---|
[f0d720b] | 310 | """ |
---|
[65f3930] | 311 | base = None # type: ModelManagerBase() |
---|
| 312 | |
---|
| 313 | def __init__(self): |
---|
| 314 | if ModelManager.base is None: |
---|
[277257f] | 315 | ModelManager.base = ModelManagerBase() |
---|
[65f3930] | 316 | |
---|
| 317 | def cat_model_list(self): |
---|
[277257f] | 318 | return list(self.base.standard_models.values()) |
---|
[f0d720b] | 319 | |
---|
| 320 | def update(self): |
---|
[277257f] | 321 | return self.base.plugins_update() |
---|
[f0d720b] | 322 | |
---|
[f66d9d1] | 323 | def plugins_reset(self): |
---|
[65f3930] | 324 | return self.base.plugins_reset() |
---|
[f0d720b] | 325 | |
---|
| 326 | def get_model_list(self): |
---|
[65f3930] | 327 | return self.base.get_model_list() |
---|
[f0d720b] | 328 | |
---|
[277257f] | 329 | def composable_models(self): |
---|
| 330 | return self.base.composable_models() |
---|
[f0d720b] | 331 | |
---|
| 332 | def get_model_dictionary(self): |
---|
[277257f] | 333 | return self.base.model_dictionary |
---|