#include #include #include #include #include #include #include #include "export.hpp" namespace { using system_clock = std::chrono::system_clock; /* timezones - the stuff that make you wonder why didn't do social science in university. The situation here is as follows: 1. In the C++ code Eclipse style string literals like "20. NOV 2017" are converted to time_t values using the utc based function timegm() which does not take timezones into account. 2. Here we use the function gmtime( ) to convert back from a time_t value to a broken down struct tm representation. 3. The broken down representation is then converted to a time_t value using the timezone aware function mktime(). 4. The time_t value is converted to a std::chrono::system_clock value. Finally std::chrono::system_clock value is automatically converted to a python datetime object as part of the pybind11 process. This latter conversion *is* timezone aware, that is the reason we must go through these hoops. */ system_clock::time_point datetime( std::time_t utc_time) { struct tm utc_tm; time_t local_time; gmtime_r(&utc_time, &utc_tm); local_time = mktime(&utc_tm); return system_clock::from_time_t(local_time); } const Well& get_well( const Schedule& sch, const std::string& name, const size_t& timestep ) try { return sch.getWell( name, timestep ); } catch( const std::invalid_argument& e ) { throw py::key_error( name ); } system_clock::time_point get_start_time( const Schedule& s ) { return datetime(s.posixStartTime()); } system_clock::time_point get_end_time( const Schedule& s ) { return datetime(s.posixEndTime()); } std::vector get_timesteps( const Schedule& s ) { std::vector< system_clock::time_point > v; for( size_t i = 0; i < s.size(); ++i ) v.push_back( datetime( std::chrono::system_clock::to_time_t(s[i].start_time() ))); return v; } std::vector get_groups( const Schedule& sch, size_t timestep ) { std::vector< Group > groups; for( const auto& group_name : sch.groupNames()) groups.push_back( sch.getGroup(group_name, timestep) ); return groups; } bool has_well( const Schedule& sch, const std::string& wellName) { return sch.hasWell( wellName ); } const Group& get_group(const ScheduleState& st, const std::string& group_name) { return st.groups.get(group_name); } const RestartConfig& restart(const Schedule& sch) { return sch.restart(); } const ScheduleState& getitem(const Schedule& sch, std::size_t index) { return sch[index]; } } void python::common::export_Schedule(py::module& module) { py::class_(module, "ScheduleState") .def_property_readonly("nupcol", py::overload_cast<>(&ScheduleState::nupcol, py::const_)) .def("group", &get_group, ref_internal); py::class_< Schedule >( module, "Schedule") .def(py::init()) .def("_groups", &get_groups ) .def_property_readonly( "start", &get_start_time ) .def_property_readonly( "end", &get_end_time ) .def_property_readonly( "timesteps", &get_timesteps ) .def_property_readonly("restart", &restart) .def("__len__", &Schedule::size) .def("__getitem__", &getitem) .def( "shut_well", &Schedule::shut_well) .def( "open_well", &Schedule::open_well) .def( "stop_well", &Schedule::stop_well) .def( "get_wells", &Schedule::getWells) .def("well_names", py::overload_cast(&Schedule::wellNames, py::const_)) .def( "get_well", &get_well) .def( "__contains__", &has_well ); py::class_< RestartConfig >( module, "RestartConfig") .def( "getKeyword", &RestartConfig::getKeyword ) .def( "getFirstRestartStep", &RestartConfig::getFirstRestartStep ) .def( "getWriteRestartFile", &RestartConfig::getWriteRestartFile, py::arg("reportStep"), py::arg("log") = true); }