/* * * Copyright (c) 2021 Project CHIP Authors * Copyright (c) 2019 Google LLC. * Copyright 2021, Cypress Semiconductor Corporation (an Infineon company) * 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. */ #include "AppTask.h" #include "AppConfig.h" #include "AppEvent.h" #include "ButtonHandler.h" #include "CHIPDeviceManager.h" #include "DeviceCallbacks.h" #include "LEDWidget.h" #include "qrcodegen.h" #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include "init_Matter.h" #include "lega_rtos_api.h" using namespace ::chip; using namespace ::chip::Credentials; using namespace ::chip::DeviceManager; using namespace ::chip::DeviceLayer; using namespace ::chip::System; LEDWidget sLightLED; namespace { TaskHandle_t sAppTaskHandle; QueueHandle_t sAppEventQueue; constexpr EndpointId kNetworkCommissioningEndpointMain = 0; constexpr EndpointId kNetworkCommissioningEndpointSecondary = 0xFFFE; app::Clusters::ModeSelect::StaticSupportedModesManager sStaticSupportedModesManager; app::Clusters::NetworkCommissioning::Instance sWiFiNetworkCommissioningInstance(kNetworkCommissioningEndpointMain /* Endpoint Id */, &(NetworkCommissioning::ASRWiFiDriver::GetInstance())); } // namespace AppTask AppTask::sAppTask; void NetWorkCommissioningInstInit() { sWiFiNetworkCommissioningInstance.Init(); // We only have network commissioning on endpoint 0. emberAfEndpointEnableDisable(kNetworkCommissioningEndpointSecondary, false); } static DeviceCallbacks EchoCallbacks; CHIP_ERROR AppTask::StartAppTask() { sAppEventQueue = xQueueCreate(APP_EVENT_QUEUE_SIZE, sizeof(AppEvent)); if (sAppEventQueue == NULL) { ASR_LOG("Failed to allocate app event queue"); appError(APP_ERROR_EVENT_QUEUE_FAILED); } // Start App task. xTaskCreate(AppTaskMain, APP_TASK_NAME, APP_TASK_STACK_SIZE, 0, 2, &sAppTaskHandle); return (sAppTaskHandle == nullptr) ? APP_ERROR_CREATE_TASK_FAILED : CHIP_NO_ERROR; } CHIP_ERROR AppTask::Init() { ASR_LOG("App Task started"); if (MatterInitializer::Init_Matter_Stack(MATTER_DEVICE_NAME) != CHIP_NO_ERROR) return CHIP_ERROR_INTERNAL; CHIPDeviceManager & deviceMgr = CHIPDeviceManager::GetInstance(); if (deviceMgr.Init(&EchoCallbacks) != CHIP_NO_ERROR) return CHIP_ERROR_INTERNAL; if (MatterInitializer::Init_Matter_Server() != CHIP_NO_ERROR) appError(CHIP_ERROR_INTERNAL); NetWorkCommissioningInstInit(); ASR_LOG("Current Software Version: %s", CHIP_DEVICE_CONFIG_DEVICE_SOFTWARE_VERSION_STRING); ConfigurationMgr().LogDeviceConfig(); // Print setup info #if CONFIG_NETWORK_LAYER_BLE PrintOnboardingCodes(chip::RendezvousInformationFlag(chip::RendezvousInformationFlag::kBLE)); #else PrintOnboardingCodes(chip::RendezvousInformationFlag(chip::RendezvousInformationFlag::kOnNetwork)); #endif /* CONFIG_NETWORK_LAYER_BLE */ sLightLED.Init(LIGHT_LED); app::Clusters::ModeSelect::setSupportedModesManager(&sStaticSupportedModesManager); return CHIP_NO_ERROR; } void AppTask::AppTaskMain(void * pvParameter) { AppEvent event; CHIP_ERROR err = sAppTask.Init(); if (err != CHIP_NO_ERROR) { ASR_LOG("AppTask.Init() failed"); appError(err); } while (true) { BaseType_t eventReceived = xQueueReceive(sAppEventQueue, &event, pdMS_TO_TICKS(10)); while (eventReceived == pdTRUE) { sAppTask.DispatchEvent(&event); eventReceived = xQueueReceive(sAppEventQueue, &event, 0); } } } void AppTask::LightActionEventHandler(AppEvent * aEvent) { /* ON/OFF Light Led based on Button interrupt */ sLightLED.Invert(); /* Update OnOff Cluster state */ sAppTask.OnOffUpdateClusterState(); } void AppTask::ButtonEventHandler(uint8_t btnIdx, uint8_t btnAction) { if (btnIdx != SWITCH1_BUTTON) { return; } AppEvent button_event = {}; button_event.Type = AppEvent::kEventType_Button; button_event.ButtonEvent.ButtonIdx = btnIdx; button_event.ButtonEvent.Action = btnAction; if (btnAction == BUTTON_RELEASED) { button_event.Handler = LightActionEventHandler; sAppTask.PostEvent(&button_event); } } void AppTask::PostEvent(const AppEvent * aEvent) { if (sAppEventQueue != NULL) { BaseType_t status; if (lega_rtos_is_in_interrupt_context()) { BaseType_t higherPrioTaskWoken = pdFALSE; status = xQueueSendFromISR(sAppEventQueue, aEvent, &higherPrioTaskWoken); #ifdef portYIELD_FROM_ISR portYIELD_FROM_ISR(higherPrioTaskWoken); #elif portEND_SWITCHING_ISR // portYIELD_FROM_ISR or portEND_SWITCHING_ISR portEND_SWITCHING_ISR(higherPrioTaskWoken); #else // portYIELD_FROM_ISR or portEND_SWITCHING_ISR #error "Must have portYIELD_FROM_ISR or portEND_SWITCHING_ISR" #endif // portYIELD_FROM_ISR or portEND_SWITCHING_ISR } else { status = xQueueSend(sAppEventQueue, aEvent, 1); } if (!status) ASR_LOG("Failed to post event to app task event queue"); } else { ASR_LOG("Event Queue is NULL should never happen"); } } void AppTask::DispatchEvent(AppEvent * aEvent) { if (aEvent->Handler) { aEvent->Handler(aEvent); } else { ASR_LOG("Event received with no handler. Dropping event."); } } void AppTask::OnOffUpdateClusterState(void) { uint8_t onoff = sLightLED.Get(); // write the new on/off value Protocols::InteractionModel::Status status = app::Clusters::OnOff::Attributes::OnOff::Set(2, onoff); if (status != Protocols::InteractionModel::Status::Success) { ASR_LOG("ERR: updating on/off %x", to_underlying(status)); } } bool lowPowerClusterSleep() { return true; }