Update to match current binding expectations
[src/low-level-can-generator.git] / src / main.cpp
index c001df3..660c347 100644 (file)
 #define EXIT_PROGRAM_ERROR                     3\r
 \r
 \r
-/**\r
+/*\r
  * FLAGS\r
+ *\r
+ * Taken from include/low-can/can-message.hpp in agl-service-can-low-level.\r
+ * The flags values in the generated message_definition_t definitions needs to\r
+ * match usage of these flags in the binding, e.g. in the various member\r
+ * functions in low-can-binding/can/message-definition.cpp.\r
+ *\r
+ * ATM the only flags known to be used are:\r
+ *\r
+ * CAN_PROTOCOL_WITH_FD_FRAME\r
+ * J1939_PROTOCOL\r
+ * ISOTP_PROTOCOL\r
+ * BYTE_FRAME_IS_BIG_ENDIAN\r
+ *\r
+ * Note that for BYTE_FRAME_IS_BIG_ENDIAN, even though it is referenced in\r
+ * message-definition.cpp, the member function that does so seems currently\r
+ * unused, so it is not clear what the intended usage actually is.\r
+ * The JSON parser for CAN messages would likely need an additional field\r
+ * added to allow setting it, for now that is being left for a future update.\r
  */\r
 \r
-#define INVALID_FLAG 0x0001\r
-#define STANDARD_ID 0x0002\r
-#define EXTENDED_ID 0x0004\r
-#define BCM_PROTOCOL 0x0008\r
-#define J1939_PROTOCOL 0x0010\r
-#define J1939_ADDR_CLAIM_PROTOCOL 0x0020\r
-#define ISOTP_PROTOCOL 0x0040\r
-#define FD_FRAME 0x0800\r
+#define CAN_PROTOCOL              0x0001\r
+#define CAN_PROTOCOL_WITH_FD_FRAME 0x0002\r
+#define J1939_ADDR_CLAIM_PROTOCOL  0x0004\r
+#define J1939_PROTOCOL            0x0008\r
+#define ISOTP_PROTOCOL            0x0010\r
+#define ISOTP_SEND                0x0020\r
+#define ISOTP_RECEIVE             0x0040\r
+#define BYTE_FRAME_IS_BIG_ENDIAN   0x0080\r
+#define BIT_POSITION_REVERSED     0x0100\r
+#define CONTINENTAL_BIT_POSITION   0x0200\r
+#define INVALID_FLAG              0x8000\r
+\r
 \r
 #define VERSION_LOW_CAN "2.0"\r
 \r
@@ -128,17 +150,17 @@ std::ostream& operator<<(std::ostream& o, const generator<std::vector<T>>& v)
 template <>\r
 std::ostream& operator<<(std::ostream& o, const generator<openxc::message_set>& v)\r
 {\r
-       o       << v.line_prefix_\r
-               << "{std::make_shared<message_set_t>(message_set_t{"\r
+       o       << "std::shared_ptr<message_set_t> cms = "\r
+               << "std::make_shared<message_set_t>(message_set_t{"\r
                << "0,"\r
                << gen(v.v_.name()) << ",\n"\r
-               << "\t\t\t{ // beginning message_definition_ vector\n"\r
-               << gen(v.v_.messages(), "\t\t\t")\r
-               << "\n\t\t}, // end message_definition vector\n"\r
-               << "\t\t\t{ // beginning diagnostic_messages_ vector\n"\r
-               << gen(v.v_.diagnostic_messages(),"\t\t\t") << "\n"\r
-               << "\t\t\t} // end diagnostic_messages_ vector\n"\r
-               << "\t\t})} // end message_set entry\n";\r
+               << "\t{ // beginning message_definition_ vector\n"\r
+               << gen(v.v_.messages(), "\t")\r
+               << "\t}, // end message_definition vector\n"\r
+               << "\t{ // beginning diagnostic_messages_ vector\n"\r
+               << gen(v.v_.diagnostic_messages(),"\t") << "\n"\r
+               << "\t} // end diagnostic_messages_ vector\n"\r
+               << "}); // end message_set entry\n";\r
        return o;\r
 }\r
 \r
@@ -192,8 +214,8 @@ std::ostream& operator<<(std::ostream& o, const generator<openxc::signal>& v)
                }\r
                std::string multi = "std::make_pair<bool, int>(" + multi_first + ", " + std::to_string(v.v_.multiplex().second) + ")";\r
        o       << v.line_prefix_ << '\t' << multi << ",// multiplex\n"\r
-               << v.line_prefix_ << '\t' << gen(v.v_.is_big_endian()) << ",// is_big_endian\n"\r
-               << v.line_prefix_ << '\t' << gen(v.v_.is_signed()) << ",// is_signed\n"\r
+               << v.line_prefix_ << "\tstatic_cast<sign_t>(" << gen(v.v_.sign()) << "),// signed\n"\r
+               << v.line_prefix_ << '\t' << gen(v.v_.bit_sign_position()) << ",// bit_sign_position\n"\r
                << v.line_prefix_ << "\t" << gen(v.v_.unit()) << "// unit\n"\r
                << v.line_prefix_ << "})}";\r
        return o;\r
@@ -207,11 +229,11 @@ std::ostream& operator<<(std::ostream& o, const generator<openxc::can_message>&
                << gen(v.v_.bus()) << ","\r
                << v.v_.id() << ","\r
                << "\"" << v.v_.name() << "\","\r
-               << v.v_.length() << ",";\r
+               << (v.v_.length() != 0 ? v.v_.length() : 8) << ",";\r
                uint32_t flags = 0;\r
                if(v.v_.is_fd())\r
                {\r
-                       flags = flags|FD_FRAME;\r
+                       flags = flags|CAN_PROTOCOL_WITH_FD_FRAME;\r
                }\r
 \r
                if(v.v_.is_j1939())\r
@@ -224,37 +246,22 @@ std::ostream& operator<<(std::ostream& o, const generator<openxc::can_message>&
                        flags = flags|ISOTP_PROTOCOL;\r
                }\r
 \r
-               if(v.v_.is_extended())\r
-               {\r
-                       flags = flags|EXTENDED_ID;\r
-               }\r
-               else\r
-               {\r
-                       flags = flags|STANDARD_ID;\r
-               }\r
-\r
-\r
-               if(v.v_.is_fd())\r
-               {\r
-                       flags = flags|FD_FRAME;\r
-               }\r
-\r
                o << gen(flags) << ",";\r
 \r
        o       << "frequency_clock_t(" << gen(v.v_.max_frequency()) << "),"\r
                << gen(v.v_.force_send_changed()) << ",";\r
                std::uint32_t index = 0;\r
-       o       << "\n\t\t\t\t\t{ // beginning signals vector\n";\r
+       o       << "\n\t\t\t{ // beginning signals vector\n";\r
                        std::uint32_t signal_count = (uint32_t)v.v_.signals().size();\r
                        for(const openxc::signal& s : v.v_.signals())\r
                        {\r
-       o                       << gen(s, index,"\t\t\t\t\t\t");\r
+       o                       << gen(s, index,"\t\t\t\t");\r
                                if (signal_count > 1) o << ',';\r
                                --signal_count;\r
        o                       << '\n';\r
                        }\r
-       o       << "\t\t\t\t\t} // end signals vector\n"\r
-               << "\t\t\t\t})} // end message_definition entry\n";\r
+       o       << "\t\t\t} // end signals vector\n"\r
+               << "\t\t})} // end message_definition entry\n";\r
        return o;\r
 }\r
 \r
@@ -283,56 +290,33 @@ std::ostream& operator<<(std::ostream& o, const generator<openxc::diagnostic_mes
 /// @param[in] out Stream to write on.\r
 void generate(const std::string& header, const std::string& footer, const openxc::message_set& message_set, std::ostream& out)\r
 {\r
-       out << "#include \"application.hpp\"\n"\r
-               << "#include \"../can/can-decoder.hpp\"\n"\r
-               << "#include \"../can/can-encoder.hpp\"\n\n";\r
+       // Derive CAPI name from message set name\r
+       // (the name is lowercased and spaces are converted to dashes ('-')\r
+       std::string capi_name(message_set.name());\r
+       std::transform(capi_name.begin(), capi_name.end(), capi_name.begin(),\r
+                      [](unsigned char c){ return (c == ' ' ? '-' : std::tolower(c)); });\r
+\r
+       out << "#include <binding/application.hpp>\n"\r
+               << "#include <can/can-decoder.hpp>\n"\r
+               << "#include <can/can-encoder.hpp>\n\n";\r
 \r
        if (header.size()) out << header << "\n";\r
 \r
-       out     << "application_t::application_t()\n"\r
-               << "    : can_bus_manager_{utils::config_parser_t{\"/etc/dev-mapping.conf\"}}\n"\r
-               << "    , message_set_{\n"\r
+       out     << "extern \"C\" {\n"\r
+               << "CTLP_CAPI_REGISTER(\"" << capi_name << "\");\n"\r
+               << "\n"\r
                << gen(message_set, "\t\t")\r
-               << "\t} // end message_set vector\n"\r
-               << "{\n"\r
-               << "    for(std::shared_ptr<message_set_t> cms: message_set_)\n"\r
-               << "    {\n"\r
-               << "            std::vector<std::shared_ptr<message_definition_t>> messages_definition = cms->get_messages_definition();\n"\r
-               << "            for(std::shared_ptr<message_definition_t> cmd : messages_definition)\n"\r
-               << "            {\n"\r
-               << "                    cmd->set_parent(cms);\n"\r
-               << "                    std::vector<std::shared_ptr<signal_t>> signals = cmd->get_signals();\n"\r
-               << "                    for(std::shared_ptr<signal_t> sig: signals)\n"\r
-               << "                    {\n"\r
-               << "                            sig->set_parent(cmd);\n"\r
-               << "                    }\n"\r
-               << "            }\n\n"\r
-               << "            std::vector<std::shared_ptr<diagnostic_message_t>> diagnostic_messages = cms->get_diagnostic_messages();\n"\r
-               << "            for(std::shared_ptr<diagnostic_message_t> dm : diagnostic_messages)\n"\r
-               << "            {\n"\r
-               << "                    dm->set_parent(cms);\n"\r
-               << "            }\n"\r
-               << "    }\n"\r
-               << "            }\n\n"\r
-               << "const std::string application_t::get_diagnostic_bus() const\n"\r
-               << "{\n";\r
-\r
-               std::string active_bus = "";\r
-               for (const auto& d : message_set.diagnostic_messages())\r
-               {\r
-                       if (d.bus().size() == 0) std::cerr << "ERROR: The bus name should be set for each diagnostic message." << std::endl;\r
-                       if (active_bus.size() == 0) active_bus = d.bus();\r
-                       if (active_bus != d.bus()) std::cerr << "ERROR: The bus name should be the same for each diagnostic message." << std::endl;\r
-               }\r
-\r
-       out     << "\treturn " << gen(active_bus) << ";\n"\r
-               << "}\n\n";\r
-\r
+               << "\n"\r
+               << "CTLP_ONLOAD(plugin, handle) {\n"\r
+               << "\tafb_api_t api = (afb_api_t) plugin->api;\n"\r
+               << "\tCtlConfigT* CtlConfig = (CtlConfigT*) afb_api_get_userdata(api);\n"\r
+               << "\tapplication_t* app = (application_t*) getExternalData(CtlConfig);\n"\r
+               << "\n"\r
+               << "\treturn app->add_message_set(cms);\n"\r
+               << "}\n\n\n}\n";\r
 \r
        out << decoder_t::apply_patch();\r
 \r
-\r
-\r
        out     << footer << std::endl;\r
 }\r
 \r