+ afb_req_fail(request, "Invalid", "Frame object malformed");
+ return;
+ }
+ delete message;
+}
+
+static void write_signal(afb_req_t request, const std::string& name, json_object *json_value, event_filter_t &event_filter)
+{
+ struct canfd_frame cfd;
+ struct utils::signals_found sf;
+ signal_encoder encoder = nullptr;
+ bool send = true;
+
+ ::memset(&cfd, 0, sizeof(cfd));
+
+ openxc_DynamicField search_key = build_DynamicField(name);
+ sf = utils::signals_manager_t::instance().find_signals(search_key);
+ openxc_DynamicField dynafield_value = build_DynamicField(json_value);
+
+ if (sf.signals.empty())
+ {
+ afb_req_fail_f(request, "No signal(s) found for %s. Message not sent.", name.c_str());
+ return;
+ }
+
+ std::shared_ptr<signal_t> sig = sf.signals.front();
+ if(! sig->get_writable())
+ {
+ afb_req_fail_f(request, "%s isn't writable. Message not sent.", sig->get_name().c_str());
+ return;
+ }
+
+ uint64_t value = (encoder = sig->get_encoder()) ?
+ encoder(*sig, dynafield_value, &send) :
+ encoder_t::encode_DynamicField(*sig, dynafield_value, &send);
+
+ uint32_t flags = INVALID_FLAG;
+
+ if(sig->get_message()->is_j1939())
+ {
+ flags = J1939_PROTOCOL;
+ }
+ else if(sig->get_message()->is_isotp())
+ {
+ flags = ISOTP_PROTOCOL;
+ }
+ else
+ {
+ flags = BCM_PROTOCOL;
+ }
+
+// cfd = encoder_t::build_frame(sig, value);
+ message_t *message = encoder_t::build_message(sig,value,false,false);
+
+ if(! send_message(message, sig->get_message()->get_bus_device_name(), flags, event_filter, sig) && send)
+ {
+ afb_req_success(request, nullptr, "Message correctly sent");
+ }
+ else
+ {
+ afb_req_fail(request, "Error", "Sending the message. See the log for more details.");
+ }
+
+ if(sig->get_message()->is_j1939())
+ {
+#ifdef USE_FEATURE_J1939
+ delete (j1939_message_t*) message;
+#endif
+ }
+ else
+ {
+ delete (can_message_t*) message;
+ }
+}
+
+void write(afb_req_t request)
+{
+ struct json_object* args = nullptr, *json_value = nullptr, *name = nullptr;
+ args = afb_req_json(request);
+
+ if(args != NULL)
+ {
+ event_filter_t event_filter = generate_filter(args);
+
+ if(json_object_object_get_ex(args,"bus_name",&name))