/* * * Copyright (c) 2021 Project CHIP Authors * All rights reserved. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ #if defined(PW_RPC_BUTTON_SERVICE) && PW_RPC_BUTTON_SERVICE #include "AppTask.h" #endif // defined(PW_RPC_BUTTON_SERVICE) && PW_RPC_BUTTON_SERVICE #include "PigweedLoggerMutex.h" #include "pigweed/RpcService.h" #include "pw_sys_io_nrfconnect/init.h" #include #include LOG_MODULE_DECLARE(app, CONFIG_CHIP_APP_LOG_LEVEL); #if defined(PW_RPC_ACTIONS_SERVICE) && PW_RPC_ACTIONS_SERVICE #include "pigweed/rpc_services/Actions.h" #endif // defined(PW_RPC_ACTIONS_SERVICE) && PW_RPC_ACTIONS_SERVICE #if defined(PW_RPC_ATTRIBUTE_SERVICE) && PW_RPC_ATTRIBUTE_SERVICE #include "pigweed/rpc_services/Attributes.h" #endif // defined(PW_RPC_ATTRIBUTE_SERVICE) && PW_RPC_ATTRIBUTE_SERVICE #if defined(PW_RPC_BOOLEAN_STATE_SERVICE) && PW_RPC_BOOLEAN_STATE_SERVICE #include "pigweed/rpc_services/BooleanState.h" #endif // defined(PW_RPC_BOOLEAN_STATE_SERVICE) && PW_RPC_BOOLEAN_STATE_SERVICE #if defined(PW_RPC_BUTTON_SERVICE) && PW_RPC_BUTTON_SERVICE #include "pigweed/rpc_services/Button.h" #endif // defined(PW_RPC_BUTTON_SERVICE) && PW_RPC_BUTTON_SERVICE #if defined(PW_RPC_DESCRIPTOR_SERVICE) && PW_RPC_DESCRIPTOR_SERVICE #include "pigweed/rpc_services/Descriptor.h" #endif // defined(PW_RPC_DESCRIPTOR_SERVICE) && PW_RPC_DESCRIPTOR_SERVICE #if defined(PW_RPC_DEVICE_SERVICE) && PW_RPC_DEVICE_SERVICE #include "pigweed/rpc_services/Device.h" #endif // defined(PW_RPC_DEVICE_SERVICE) && PW_RPC_DEVICE_SERVICE #if defined(PW_RPC_EVENT_SERVICE) && PW_RPC_EVENT_SERVICE #include "pigweed/rpc_services/Event.h" #endif // defined(PW_RPC_EVENT_SERVICE) && PW_RPC_EVENT_SERVICE #if defined(PW_RPC_LIGHTING_SERVICE) && PW_RPC_LIGHTING_SERVICE #include "pigweed/rpc_services/Lighting.h" #endif // defined(PW_RPC_LIGHTING_SERVICE) && PW_RPC_LIGHTING_SERVICE #if defined(PW_RPC_LOCKING_SERVICE) && PW_RPC_LOCKING_SERVICE #include "pigweed/rpc_services/Locking.h" #endif // defined(PW_RPC_LOCKING_SERVICE) && PW_RPC_LOCKING_SERVICE #if defined(PW_RPC_OTCLI_SERVICE) && PW_RPC_OTCLI_SERVICE #include "pigweed/rpc_services/OtCli.h" #endif // defined(PW_RPC_OTCLI_SERVICE) && PW_RPC_OTCLI_SERVICE #if defined(PW_RPC_THREAD_SERVICE) && PW_RPC_THREAD_SERVICE #include "pigweed/rpc_services/Thread.h" #endif // defined(PW_RPC_THREAD_SERVICE) && PW_RPC_THREAD_SERVICE #if defined(PW_RPC_TRACING_SERVICE) && PW_RPC_TRACING_SERVICE #define PW_TRACE_BUFFER_SIZE_BYTES 1024 #include "pw_trace/trace.h" #include "pw_trace_tokenized/trace_rpc_service_nanopb.h" // Define trace time for pw_trace PW_TRACE_TIME_TYPE pw_trace_GetTraceTime() { return (PW_TRACE_TIME_TYPE) chip::System::SystemClock().GetMonotonicMicroseconds64().count(); } // Microsecond time source size_t pw_trace_GetTraceTimeTicksPerSecond() { return 1000000; } #endif // defined(PW_RPC_TRACING_SERVICE) && PW_RPC_TRACING_SERVICE namespace chip { namespace rpc { #if defined(PW_RPC_ACTIONS_SERVICE) && PW_RPC_ACTIONS_SERVICE Actions actions_service; #endif // defined(PW_RPC_ACTIONS_SERVICE) && PW_RPC_ACTIONS_SERVICE #if defined(PW_RPC_DEVICE_SERVICE) && PW_RPC_DEVICE_SERVICE namespace { void reboot_timer_handler(struct k_timer * dummy) { NVIC_SystemReset(); } K_TIMER_DEFINE(reboot_timer, reboot_timer_handler, NULL); } // namespace class NrfDevice final : public Device { public: pw::Status Reboot(const chip_rpc_RebootRequest & request, pw_protobuf_Empty & response) override { k_timeout_t delay; if (request.delay_ms != 0) { delay = K_MSEC(request.delay_ms); } else { ChipLogProgress(NotSpecified, "Did not receive a reboot delay. Defaulting to 1s"); delay = K_SECONDS(1); } k_timer_start(&reboot_timer, delay, K_FOREVER); return pw::OkStatus(); } }; #endif // defined(PW_RPC_DEVICE_SERVICE) && PW_RPC_DEVICE_SERVICE #if defined(PW_RPC_BUTTON_SERVICE) && PW_RPC_BUTTON_SERVICE class NrfButton final : public Button { public: pw::Status Event(const chip_rpc_ButtonEvent & request, pw_protobuf_Empty & response) override { AppTask::Instance().ButtonEventHandler(request.pushed << request.idx /* button_state */, 1 << request.idx /* has_changed */); return pw::OkStatus(); } }; #endif // defined(PW_RPC_BUTTON_SERVICE) && PW_RPC_BUTTON_SERVICE namespace { constexpr size_t kRpcTaskSize = 5120; constexpr int kRpcPriority = 5; K_THREAD_STACK_DEFINE(rpc_stack_area, kRpcTaskSize); struct k_thread rpc_thread_data; #if defined(PW_RPC_ATTRIBUTE_SERVICE) && PW_RPC_ATTRIBUTE_SERVICE Attributes attributes_service; #endif // defined(PW_RPC_ATTRIBUTE_SERVICE) && PW_RPC_ATTRIBUTE_SERVICE #if defined(PW_RPC_BOOLEAN_STATE_SERVICE) && PW_RPC_BOOLEAN_STATE_SERVICE BooleanState boolean_state_service; #endif // defined(PW_RPC_BOOLEAN_STATE_SERVICE) && PW_RPC_BOOLEAN_STATE_SERVICE #if defined(PW_RPC_BUTTON_SERVICE) && PW_RPC_BUTTON_SERVICE NrfButton button_service; #endif // defined(PW_RPC_BUTTON_SERVICE) && PW_RPC_BUTTON_SERVICE #if defined(PW_RPC_DESCRIPTOR_SERVICE) && PW_RPC_DESCRIPTOR_SERVICE Descriptor descriptor_service; #endif // defined(PW_RPC_DESCRIPTOR_SERVICE) && PW_RPC_DESCRIPTOR_SERVICE #if defined(PW_RPC_DEVICE_SERVICE) && PW_RPC_DEVICE_SERVICE NrfDevice device_service; #endif // defined(PW_RPC_DEVICE_SERVICE) && PW_RPC_DEVICE_SERVICE #if defined(PW_RPC_EVENT_SERVICE) && PW_RPC_EVENT_SERVICE Event event_service; #endif // defined(PW_RPC_EVENT_SERVICE) && PW_RPC_EVENT_SERVICE #if defined(PW_RPC_LIGHTING_SERVICE) && PW_RPC_LIGHTING_SERVICE Lighting lighting_service; #endif // defined(PW_RPC_LIGHTING_SERVICE) && PW_RPC_LIGHTING_SERVICE #if defined(PW_RPC_LOCKING_SERVICE) && PW_RPC_LOCKING_SERVICE Locking locking; #endif // defined(PW_RPC_LOCKING_SERVICE) && PW_RPC_LOCKING_SERVICE #if defined(PW_RPC_OTCLI_SERVICE) && PW_RPC_OTCLI_SERVICE OtCli ot_cli_service; #endif // defined(PW_RPC_OTCLI_SERVICE) && PW_RPC_OTCLI_SERVICE #if defined(PW_RPC_THREAD_SERVICE) && PW_RPC_THREAD_SERVICE Thread thread; #endif // defined(PW_RPC_THREAD_SERVICE) && PW_RPC_THREAD_SERVICE #if defined(PW_RPC_TRACING_SERVICE) && PW_RPC_TRACING_SERVICE pw::trace::TraceService trace_service(pw::trace::GetTokenizedTracer()); #endif // defined(PW_RPC_TRACING_SERVICE) && PW_RPC_TRACING_SERVICE void RegisterServices(pw::rpc::Server & server) { #if defined(PW_RPC_ACTIONS_SERVICE) && PW_RPC_ACTIONS_SERVICE server.RegisterService(actions_service); #endif // defined(PW_RPC_ACTIONS_SERVICE) && PW_RPC_ACTIONS_SERVICE #if defined(PW_RPC_ATTRIBUTE_SERVICE) && PW_RPC_ATTRIBUTE_SERVICE server.RegisterService(attributes_service); #endif // defined(PW_RPC_ATTRIBUTE_SERVICE) && PW_RPC_ATTRIBUTE_SERVICE #if defined(PW_RPC_BOOLEAN_STATE_SERVICE) && PW_RPC_BOOLEAN_STATE_SERVICE server.RegisterService(boolean_state_service); #endif // defined(PW_RPC_BOOLEAN_STATE_SERVICE) && PW_RPC_BOOLEAN_STATE_SERVICE #if defined(PW_RPC_BUTTON_SERVICE) && PW_RPC_BUTTON_SERVICE server.RegisterService(button_service); #endif // defined(PW_RPC_BUTTON_SERVICE) && PW_RPC_BUTTON_SERVICE #if defined(PW_RPC_DESCRIPTOR_SERVICE) && PW_RPC_DESCRIPTOR_SERVICE server.RegisterService(descriptor_service); #endif // defined(PW_RPC_DESCRIPTOR_SERVICE) && PW_RPC_DESCRIPTOR_SERVICE #if defined(PW_RPC_DEVICE_SERVICE) && PW_RPC_DEVICE_SERVICE server.RegisterService(device_service); #endif // defined(PW_RPC_DEVICE_SERVICE) && PW_RPC_DEVICE_SERVICE #if defined(PW_RPC_EVENT_SERVICE) && PW_RPC_EVENT_SERVICE server.RegisterService(event_service); #endif // defined(PW_RPC_EVENT_SERVICE) && PW_RPC_EVENT_SERVICE #if defined(PW_RPC_LIGHTING_SERVICE) && PW_RPC_LIGHTING_SERVICE server.RegisterService(lighting_service); #endif // defined(PW_RPC_LIGHTING_SERVICE) && PW_RPC_LIGHTING_SERVICE #if defined(PW_RPC_LOCKING_SERVICE) && PW_RPC_LOCKING_SERVICE server.RegisterService(locking); #endif // defined(PW_RPC_LOCKING_SERVICE) && PW_RPC_LOCKING_SERVICE #if defined(PW_RPC_OTCLI_SERVICE) && PW_RPC_OTCLI_SERVICE server.RegisterService(ot_cli_service); #endif // defined(PW_RPC_OTCLI_SERVICE) && PW_RPC_OTCLI_SERVICE #if defined(PW_RPC_THREAD_SERVICE) && PW_RPC_THREAD_SERVICE server.RegisterService(thread); #endif // defined(PW_RPC_THREAD_SERVICE) && PW_RPC_THREAD_SERVICE #if defined(PW_RPC_TRACING_SERVICE) && PW_RPC_TRACING_SERVICE server.RegisterService(trace_service); PW_TRACE_SET_ENABLED(true); #endif // defined(PW_RPC_TRACING_SERVICE) && PW_RPC_TRACING_SERVICE } } // namespace #if defined(PW_RPC_ACTIONS_SERVICE) && PW_RPC_ACTIONS_SERVICE void SubscribeActions(RpcActionsSubscribeCallback subscriber) { actions_service.SubscribeActions(subscriber); } #endif // defined(PW_RPC_ACTIONS_SERVICE) && PW_RPC_ACTIONS_SERVICE void RunRpcService(void *, void *, void *) { Start(RegisterServices, &logger_mutex); } k_tid_t Init() { pw_sys_io_Init(); k_tid_t tid = k_thread_create(&rpc_thread_data, rpc_stack_area, K_THREAD_STACK_SIZEOF(rpc_stack_area), RunRpcService, NULL, NULL, NULL, kRpcPriority, 0, K_NO_WAIT); return tid; } } // namespace rpc } // namespace chip