diff options
author | John Wiegley <johnw@newartisans.com> | 2009-02-24 16:08:49 -0400 |
---|---|---|
committer | John Wiegley <johnw@newartisans.com> | 2009-02-24 16:08:49 -0400 |
commit | 1799ed3a2adf1af7ed08b3b3ded3594a4c0e184e (patch) | |
tree | ba0ad178f2ceefa0fad5975f6247e3f20de41344 /src/pyinterp.cc | |
parent | 5ad9bc3951fcbecb5fcf7c1127e8f91e547fd37b (diff) | |
download | fork-ledger-1799ed3a2adf1af7ed08b3b3ded3594a4c0e184e.tar.gz fork-ledger-1799ed3a2adf1af7ed08b3b3ded3594a4c0e184e.tar.bz2 fork-ledger-1799ed3a2adf1af7ed08b3b3ded3594a4c0e184e.zip |
Moved python/*.cc files into src/
This is because soon, I intend to have real Python source files in
python/.
Diffstat (limited to 'src/pyinterp.cc')
-rw-r--r-- | src/pyinterp.cc | 296 |
1 files changed, 296 insertions, 0 deletions
diff --git a/src/pyinterp.cc b/src/pyinterp.cc new file mode 100644 index 00000000..9782f3a0 --- /dev/null +++ b/src/pyinterp.cc @@ -0,0 +1,296 @@ +/* + * Copyright (c) 2003-2009, John Wiegley. All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions are + * met: + * + * - Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * + * - Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * + * - Neither the name of New Artisans LLC nor the names of its + * contributors may be used to endorse or promote products derived from + * this software without specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS + * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT + * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR + * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT + * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, + * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT + * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, + * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY + * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE + * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ + +#include "pyinterp.h" + +namespace ledger { + +using namespace python; + +shared_ptr<python_interpreter_t> python_session; + +void export_amount(); +void export_balance(); +void export_chain(); +void export_commodity(); +void export_xact(); +void export_expr(); +void export_flags(); +void export_format(); +void export_global(); +void export_item(); +void export_journal(); +void export_report(); +void export_scope(); +void export_session(); +void export_timelog(); +void export_times(); +void export_utils(); +void export_value(); +void export_post(); + +void initialize_for_python() +{ + export_amount(); + export_balance(); + export_chain(); + export_commodity(); + export_xact(); + export_expr(); + export_flags(); + export_format(); + export_global(); + export_item(); + export_journal(); + export_report(); + export_scope(); + export_session(); + export_timelog(); + export_times(); + export_utils(); + export_value(); + export_post(); +} + +struct python_run +{ + object result; + + python_run(python_interpreter_t * intepreter, + const string& str, int input_mode) + : result(handle<>(borrowed(PyRun_String(str.c_str(), input_mode, + intepreter->main_nspace.ptr(), + intepreter->main_nspace.ptr())))) {} + operator object() { + return result; + } +}; + +void python_interpreter_t::initialize() +{ + TRACE_START(python_init, 1, "Initialized Python"); + + try { + DEBUG("python.interp", "Initializing Python"); + + Py_Initialize(); + assert(Py_IsInitialized()); + + object main_module = python::import("__main__"); + if (! main_module) + throw_(std::logic_error, "Python failed to initialize"); + + main_nspace = extract<dict>(main_module.attr("__dict__")); + if (! main_nspace) + throw_(std::logic_error, "Python failed to initialize"); + + python::detail::init_module("ledger", &initialize_for_python); + + is_initialized = true; + } + catch (const error_already_set&) { + PyErr_Print(); + throw_(std::logic_error, "Python failed to initialize"); + } + + TRACE_FINISH(python_init, 1); +} + +object python_interpreter_t::import(const string& str) +{ + if (! is_initialized) + initialize(); + + try { + TRACE_START(python_import, 1, "Imported Python module: " << str); + + object mod = python::import(str.c_str()); + if (! mod) + throw_(std::logic_error, "Failed to import Python module " << str); + + // Import all top-level xacts directly into the main namespace + main_nspace.update(mod.attr("__dict__")); + + TRACE_FINISH(python_import, 1); + + return mod; + } + catch (const error_already_set&) { + PyErr_Print(); + } + return object(); +} + +object python_interpreter_t::eval(std::istream& in, py_eval_mode_t mode) +{ + bool first = true; + string buffer; + buffer.reserve(4096); + + while (! in.eof()) { + char buf[256]; + in.getline(buf, 255); + if (buf[0] == '!') + break; + if (first) + first = false; + else + buffer += "\n"; + buffer += buf; + } + + if (! is_initialized) + initialize(); + + try { + int input_mode; + switch (mode) { + case PY_EVAL_EXPR: input_mode = Py_eval_input; break; + case PY_EVAL_STMT: input_mode = Py_single_input; break; + case PY_EVAL_MULTI: input_mode = Py_file_input; break; + } + + return python_run(this, buffer, input_mode); + } + catch (const error_already_set&) { + PyErr_Print(); + throw_(std::logic_error, "Failed to evaluate Python code"); + } + return object(); +} + +object python_interpreter_t::eval(const string& str, py_eval_mode_t mode) +{ + if (! is_initialized) + initialize(); + + try { + int input_mode; + switch (mode) { + case PY_EVAL_EXPR: input_mode = Py_eval_input; break; + case PY_EVAL_STMT: input_mode = Py_single_input; break; + case PY_EVAL_MULTI: input_mode = Py_file_input; break; + } + + return python_run(this, str, input_mode); + } + catch (const error_already_set&) { + PyErr_Print(); + throw_(std::logic_error, "Failed to evaluate Python code"); + } + return object(); +} + +expr_t::ptr_op_t python_interpreter_t::lookup(const string& name) +{ + // Give our superclass first dibs on symbol definitions + if (expr_t::ptr_op_t op = session_t::lookup(name)) + return op; + + const char * p = name.c_str(); + switch (*p) { + case 'o': + if (std::strncmp(p, "opt_", 4) == 0) { + p = p + 4; + switch (*p) { + case 'i': + if (std::strcmp(p, "import_") == 0) + return MAKE_FUNCTOR(python_interpreter_t::option_import_); + else if (std::strcmp(p, "import") == 0) + return expr_t::ptr_op_t(); + break; + } + } + break; + } + + if (is_initialized && main_nspace.has_key(name.c_str())) { + DEBUG("python.interp", "Python lookup: " << name); + + if (python::object obj = main_nspace.get(name.c_str())) + return WRAP_FUNCTOR(functor_t(name, obj)); + } + + return NULL; +} + +value_t python_interpreter_t::functor_t::operator()(call_scope_t& args) +{ + try { + if (! PyCallable_Check(func.ptr())) { + extract<value_t> val(func); + if (val.check()) + return val(); + throw_(calc_error, + "Could not evaluate Python variable '" << name << "'"); + } else { + if (args.size() > 0) { + list arglist; + if (args.value().is_sequence()) + foreach (const value_t& value, args.value().as_sequence()) + arglist.append(value); + else + arglist.append(args.value()); + + if (PyObject * val = + PyObject_CallObject(func.ptr(), python::tuple(arglist).ptr())) { + extract<value_t> xval(val); + value_t result; + if (xval.check()) { + result = xval(); + Py_DECREF(val); + } else { + Py_DECREF(val); + throw_(calc_error, + "Could not evaluate Python variable '" << name << "'"); + } + return result; + } + else if (PyErr_Occurred()) { + PyErr_Print(); + throw_(calc_error, "Failed call to Python function '" << name << "'"); + } else { + assert(false); + } + } else { + return call<value_t>(func.ptr()); + } + } + } + catch (const error_already_set&) { + PyErr_Print(); + throw_(calc_error, + "Failed call to Python function '" << name << "'"); + } + return NULL_VALUE; +} + +} // namespace ledger |