-
Notifications
You must be signed in to change notification settings - Fork 2k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
[Android] Add initial batch command support
- Loading branch information
1 parent
d899019
commit 6705ea2
Showing
21 changed files
with
1,086 additions
and
2 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
160 changes: 160 additions & 0 deletions
160
.../java/src/com/matter/controller/commands/pairing/PairOnNetworkLongImBatchInvokeCommand.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,160 @@ | ||
| /* | ||
| * Copyright (c) 2024 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. | ||
| * | ||
| */ | ||
| package com.matter.controller.commands.pairing | ||
|
|
||
| import chip.devicecontroller.BatchInvokeCallback | ||
| import chip.devicecontroller.ChipDeviceController | ||
| import chip.devicecontroller.GetConnectedDeviceCallbackJni.GetConnectedDeviceCallback | ||
| import chip.devicecontroller.model.InvokeElement | ||
| import chip.devicecontroller.model.InvokeResponseData | ||
| import chip.devicecontroller.model.NoInvokeResponseData | ||
| import com.matter.controller.commands.common.CredentialsIssuer | ||
| import java.util.logging.Level | ||
| import java.util.logging.Logger | ||
| import kotlin.UShort | ||
| import matter.tlv.AnonymousTag | ||
| import matter.tlv.ContextSpecificTag | ||
| import matter.tlv.TlvWriter | ||
|
|
||
| class PairOnNetworkLongImBatchInvokeCommand( | ||
| controller: ChipDeviceController, | ||
| credsIssue: CredentialsIssuer? | ||
| ) : | ||
| PairingCommand( | ||
| controller, | ||
| "onnetwork-long-im-batch-invoke", | ||
| credsIssue, | ||
| PairingModeType.ON_NETWORK, | ||
| PairingNetworkType.NONE, | ||
| DiscoveryFilterType.LONG_DISCRIMINATOR | ||
| ) { | ||
| private var devicePointer: Long = 0 | ||
|
|
||
| private fun setDevicePointer(devicePointer: Long) { | ||
| this.devicePointer = devicePointer | ||
| } | ||
|
|
||
| private inner class InternalInvokeCallback : BatchInvokeCallback { | ||
| private var responseCount = 0 | ||
|
|
||
| override fun onError(e: Exception) { | ||
| logger.log(Level.INFO, "Invoke receive onError" + e.message) | ||
| setFailure("invoke failure") | ||
| } | ||
|
|
||
| override fun onResponse(invokeResponseData: InvokeResponseData) { | ||
| logger.log(Level.INFO, "Invoke receive OnResponse on $invokeResponseData") | ||
| responseCount++ | ||
| setSuccess() | ||
| } | ||
|
|
||
| override fun onNoResponse(noInvokeResponseData: NoInvokeResponseData) { | ||
| logger.log(Level.INFO, "Invoke receive OnResponse on $noInvokeResponseData") | ||
| responseCount-- | ||
| } | ||
|
|
||
| override fun onDone() { | ||
| if (responseCount == TEST_COMMONDS_NUM) { | ||
| setSuccess() | ||
| } else { | ||
| setFailure("invoke failure") | ||
| } | ||
| } | ||
| } | ||
|
|
||
| private inner class InternalGetConnectedDeviceCallback : GetConnectedDeviceCallback { | ||
| override fun onDeviceConnected(devicePointer: Long) { | ||
| setDevicePointer(devicePointer) | ||
| logger.log(Level.INFO, "onDeviceConnected") | ||
| } | ||
|
|
||
| override fun onConnectionFailure(nodeId: Long, error: Exception) { | ||
| logger.log(Level.INFO, "onConnectionFailure") | ||
| } | ||
| } | ||
|
|
||
| override fun runCommand() { | ||
| val number: UShort = 1u | ||
| val tlvWriter1 = TlvWriter() | ||
| tlvWriter1.startStructure(AnonymousTag) | ||
| tlvWriter1.put(ContextSpecificTag(0), number) | ||
| tlvWriter1.endStructure() | ||
|
|
||
| val element1: InvokeElement = | ||
| InvokeElement.newInstance( | ||
| /* endpointId= */ 0, | ||
| CLUSTER_ID_IDENTIFY, | ||
| IDENTIFY_COMMAND, | ||
| tlvWriter1.getEncoded(), | ||
| null | ||
| ) | ||
|
|
||
| val tlvWriter2 = TlvWriter() | ||
| tlvWriter2.startStructure(AnonymousTag) | ||
| tlvWriter2.put(ContextSpecificTag(0), number) | ||
| tlvWriter2.put(ContextSpecificTag(1), number) | ||
| tlvWriter2.endStructure() | ||
|
|
||
| val element2: InvokeElement = | ||
| InvokeElement.newInstance( | ||
| /* endpointId= */ 1, | ||
| CLUSTER_ID_TEST, | ||
| TEST_ADD_ARGUMENT_COMMAND, | ||
| tlvWriter2.getEncoded(), | ||
| null | ||
| ) | ||
|
|
||
| val element3: InvokeElement = | ||
| InvokeElement.newInstance( | ||
| /* endpointId= */ 1, | ||
| CLUSTER_ID_IDENTIFY, | ||
| IDENTIFY_COMMAND, | ||
| null, | ||
| """{"0:UINT":1}""" | ||
| ) | ||
|
|
||
| val invokeList = listOf(element1, element2, element3) | ||
| currentCommissioner() | ||
| .pairDeviceWithAddress( | ||
| getNodeId(), | ||
| getRemoteAddr().address.hostAddress, | ||
| MATTER_PORT, | ||
| getDiscriminator(), | ||
| getSetupPINCode(), | ||
| null | ||
| ) | ||
| currentCommissioner().setCompletionListener(this) | ||
| waitCompleteMs(getTimeoutMillis()) | ||
| currentCommissioner() | ||
| .getConnectedDevicePointer(getNodeId(), InternalGetConnectedDeviceCallback()) | ||
| clear() | ||
| currentCommissioner().batchInvoke(InternalInvokeCallback(), devicePointer, invokeList, 0, 0) | ||
| waitCompleteMs(getTimeoutMillis()) | ||
| } | ||
|
|
||
| companion object { | ||
| private val logger = Logger.getLogger(PairOnNetworkLongImBatchInvokeCommand::class.java.name) | ||
|
|
||
| private const val MATTER_PORT = 5540 | ||
| private const val CLUSTER_ID_IDENTIFY = 0x0003L | ||
| private const val IDENTIFY_COMMAND = 0L | ||
| private const val CLUSTER_ID_TEST = 0xFFF1FC05L | ||
| private const val TEST_ADD_ARGUMENT_COMMAND = 0X04L | ||
| private const val TEST_COMMONDS_NUM = 3 | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.