discovery.cc

Go to the documentation of this file.

#include "discovery.h"
 
#include <fstream>
#include <iostream>
#include <streambuf>
#include <vector>
 
#include <boost/filesystem.hpp>
#include <boost/foreach.hpp>
#include <boost/algorithm/string.hpp>
#include <boost/algorithm/string/predicate.hpp>
 
#include "agent.h"
#include "context.h"
#include "dynamic_module.h"
#include "env.h"
#include "platform.h"
#include "recorder.h"
#include "timer.h"
 
namespace cyclus {
 
std::set<std::string> DiscoverArchetypes(const std::string s) {
  // Note that 9 is the length of the word "Construct"
  using std::string;
  std::set<string> archs;
  size_t offset = 0;
  size_t end_offset = 0;
  const string words =
      "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ_"
      "abcdefghijklmnopqrstuvwxyz";
  string construct = "Construct";
  if (SUFFIX == ".dylib") construct = "_Construct";
  size_t lenconstruct = construct.length();
  while ((offset = s.find(construct, offset)) != string::npos) {
    end_offset = s.find_first_not_of(words, offset + lenconstruct);
    if (words.find(s[offset - 1]) != string::npos ||
        offset + lenconstruct == end_offset) {
      // make sure construct starts the word
      offset += lenconstruct;
      continue;
    }
    archs.insert(
        string(s, offset + lenconstruct, end_offset - offset - lenconstruct));
    offset = end_offset;
  }
  return archs;
}
 
std::set<std::string> DiscoverSpecs(std::string p, std::string lib) {
  using std::set;
  using std::string;
  namespace fs = boost::filesystem;
  // find file
  string libpath = (fs::path(p) / fs::path("lib" + lib + SUFFIX)).string();
  libpath = Env::FindModule(libpath);
 
  // read in file, pre-allocates space
  std::ifstream f(libpath.c_str());
  std::string s;
  f.seekg(0, std::ios::end);
  s.reserve(f.tellg());
  f.seekg(0, std::ios::beg);
  s.assign((std::istreambuf_iterator<char>(f)),
           std::istreambuf_iterator<char>());
 
  // find specs
  set<string> archs = DiscoverArchetypes(s);
  set<string> specs;
  string spec;
  AgentSpec agentspec;
  for (set<string>::iterator it = archs.begin(); it != archs.end(); ++it) {
    spec = p + ":" + lib + ":" + (*it);
    agentspec = AgentSpec(spec);
    if (DynamicModule::Exists(agentspec)) {
      specs.insert(spec);
    }
  }
  return specs;
}
 
std::set<std::string> DiscoverSpecsInDir(std::string d) {
  using std::set;
  using std::string;
  namespace fs = boost::filesystem;
  set<string> specs;
  set<string> libspecs;
  fs::path pth;
  boost::system::error_code errc;
  boost::system::error_code no_err;
  pth = d;
  fs::recursive_directory_iterator it(pth, errc);
  fs::recursive_directory_iterator last;
  for (; it != last; it.increment(errc)) {
    if (errc != no_err) {
      if (it.depth() > 0) {
        it.pop();
      }
      continue;
    }
    pth = it->path();
    string pthstr = pth.string();
    bool irf = fs::is_regular_file(pth, errc);
    if (errc != no_err || !irf) {
      it.disable_recursion_pending();
      if (it.depth() > 0) {
        it.pop();
      }
      continue;
    } else if (fs::is_directory(pth, errc)) {
      continue;
    } else if (!boost::algorithm::ends_with(pthstr, SUFFIX)) {
      continue;
    }
    string p = pth.parent_path().string();
    string lib = pth.filename().string();
    if (d.length() < p.length())
      p = p.substr(d.length() + 1, string::npos);
    else
      p = "";
    lib = lib.substr(3, lib.rfind(".") - 3);  // remove 'lib' prefix and suffix
    try {
      libspecs = DiscoverSpecs(p, lib);
    } catch (cyclus::IOError& e) {
    }
    for (set<string>::iterator ls = libspecs.begin(); ls != libspecs.end();
         ++ls) {
      specs.insert(*ls);
    }
  }
  return specs;
}
 
std::set<std::string> DiscoverSpecsInCyclusPath() {
  using std::set;
  using std::string;
  using std::vector;
  set<string> specs;
  set<string> dirspecs;
  vector<string> cycpath = Env::cyclus_path();
  for (vector<string>::iterator it = cycpath.begin(); it != cycpath.end();
       ++it) {
    dirspecs = DiscoverSpecsInDir((*it).length() == 0 ? "." : (*it));
    for (set<string>::iterator ds = dirspecs.begin(); ds != dirspecs.end();
         ++ds) {
      specs.insert(*ds);
    }
  }
  return specs;
}
 
Json::Value DiscoverMetadataInCyclusPath() {
  std::set<std::string> specs = cyclus::DiscoverSpecsInCyclusPath();
  Json::Value root(Json::objectValue);
  Json::Value spec(Json::arrayValue);
  Json::Value anno(Json::objectValue);
  Json::Value schm(Json::objectValue);
  Recorder rec;
  Timer ti;
  Context* ctx = new Context(&ti, &rec);
  std::string s;
  std::set<std::string>::iterator it;
 
  for (it = specs.begin(); it != specs.end(); ++it) {
    s = *it;
    Agent* m = DynamicModule::Make(ctx, s);
    spec.append(s);
    anno[s] = m->annotations();
    schm[s] = m->schema();
    ctx->DelAgent(m);
  }
  delete ctx;
 
  root["specs"] = spec;
  root["annotations"] = anno;
  root["schema"] = schm;
 
  return root;
}
 
}  // namespace cyclus