| /* |
| * |
| * Copyright (c) 2020-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. |
| */ |
| |
| /** |
| * @file |
| * This file defines Base class for a CHIP IM Command |
| * |
| */ |
| |
| #pragma once |
| |
| #include <app/CommandPathParams.h> |
| #include <app/InteractionModelDelegate.h> |
| #include <app/MessageDef/CommandDataElement.h> |
| #include <app/MessageDef/CommandList.h> |
| #include <app/MessageDef/InvokeCommand.h> |
| #include <lib/core/CHIPCore.h> |
| #include <lib/support/BitFlags.h> |
| #include <lib/support/CodeUtils.h> |
| #include <lib/support/DLLUtil.h> |
| #include <lib/support/logging/CHIPLogging.h> |
| #include <messaging/ExchangeContext.h> |
| #include <messaging/ExchangeMgr.h> |
| #include <messaging/Flags.h> |
| #include <protocols/Protocols.h> |
| #include <system/SystemPacketBuffer.h> |
| #include <system/TLVPacketBufferBackingStore.h> |
| |
| namespace chip { |
| namespace app { |
| |
| class Command |
| { |
| public: |
| enum class CommandRoleId |
| { |
| SenderId = 0, |
| HandlerId = 1, |
| }; |
| |
| enum class CommandState |
| { |
| Uninitialized = 0, ///< The invoke command message has not been initialized |
| Initialized, ///< The invoke command message has been initialized and is ready |
| AddCommand, ///< The invoke command message has added Command |
| Sending, ///< The invoke command message has sent out the invoke command |
| }; |
| |
| /** |
| * Initialize the Command object. Within the lifetime |
| * of this instance, this method is invoked once after object |
| * construction until a call to Shutdown is made to terminate the |
| * instance. |
| * |
| * @param[in] apExchangeMgr A pointer to the ExchangeManager object. |
| * @param[in] apDelegate InteractionModelDelegate set by application. |
| * |
| * @retval #CHIP_ERROR_INCORRECT_STATE If the state is not equal to |
| * CommandState::NotInitialized. |
| * @retval #CHIP_NO_ERROR On success. |
| * |
| */ |
| CHIP_ERROR Init(Messaging::ExchangeManager * apExchangeMgr, InteractionModelDelegate * apDelegate); |
| |
| /** |
| * Shutdown the Command. This terminates this instance |
| * of the object and releases all held resources. |
| */ |
| void Shutdown(); |
| |
| /** |
| * Finalize Command Message TLV Builder and finalize command message |
| * |
| * @return CHIP_ERROR |
| * |
| */ |
| CHIP_ERROR FinalizeCommandsMessage(System::PacketBufferHandle & commandPacket); |
| |
| CHIP_ERROR PrepareCommand(const CommandPathParams & aCommandPathParams, bool aIsStatus = false); |
| TLV::TLVWriter * GetCommandDataElementTLVWriter(); |
| CHIP_ERROR FinishCommand(bool aIsStatus = false); |
| virtual CHIP_ERROR AddStatusCode(const CommandPathParams & aCommandPathParams, |
| const Protocols::SecureChannel::GeneralStatusCode aGeneralCode, |
| const Protocols::Id aProtocolId, const Protocols::InteractionModel::Status aStatus) |
| { |
| return CHIP_ERROR_NOT_IMPLEMENTED; |
| }; |
| |
| /** |
| * Gets the inner exchange context object, without ownership. |
| * |
| * @return The inner exchange context, might be nullptr if no |
| * exchange context has been assigned or the context |
| * has been released. |
| */ |
| Messaging::ExchangeContext * GetExchangeContext() const { return mpExchangeCtx; } |
| |
| CHIP_ERROR Reset(); |
| |
| virtual ~Command() = default; |
| |
| bool IsFree() const { return mState == CommandState::Uninitialized; }; |
| virtual CHIP_ERROR ProcessCommandDataElement(CommandDataElement::Parser & aCommandElement) = 0; |
| |
| protected: |
| CHIP_ERROR AbortExistingExchangeContext(); |
| void MoveToState(const CommandState aTargetState); |
| CHIP_ERROR ProcessCommandMessage(System::PacketBufferHandle && payload, CommandRoleId aCommandRoleId); |
| CHIP_ERROR ConstructCommandPath(const CommandPathParams & aCommandPathParams, CommandDataElement::Builder aCommandDataElement); |
| void ClearState(); |
| const char * GetStateStr() const; |
| |
| /** |
| * Internal shutdown method that we use when we know what's going on with |
| * our exchange and don't need to manually close it. |
| */ |
| void ShutdownInternal(); |
| |
| InvokeCommand::Builder mInvokeCommandBuilder; |
| Messaging::ExchangeManager * mpExchangeMgr = nullptr; |
| Messaging::ExchangeContext * mpExchangeCtx = nullptr; |
| InteractionModelDelegate * mpDelegate = nullptr; |
| uint8_t mCommandIndex = 0; |
| CommandState mState = CommandState::Uninitialized; |
| |
| private: |
| friend class TestCommandInteraction; |
| TLV::TLVType mDataElementContainerType = TLV::kTLVType_NotSpecified; |
| chip::System::PacketBufferTLVWriter mCommandMessageWriter; |
| }; |
| } // namespace app |
| } // namespace chip |