Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 7a99de96 authored by William Escande's avatar William Escande
Browse files

Hap: add relevant preset test 

Bug: 371636624
Bug: 362424892
Test: atest avatar:HapTest
Flag: TEST_ONLY
Change-Id: Ida5ef4cb03fb93c783ac7451d1fe1504ff0be511
parent eeea0338

android/pandora/server/src/Hap.kt

+26 −0
Original line number Diff line number Diff line
@@ -232,6 +232,32 @@ class Hap(val context: Context) : HAPImplBase(), Closeable { 
        }

    }



    override fun getActivePresetRecord(

        request: GetActivePresetRecordRequest,

        responseObserver: StreamObserver<GetActivePresetRecordResponse>,

    ) {

        grpcUnary<GetActivePresetRecordResponse>(scope, responseObserver) {

            val device = request.connection.toBluetoothDevice(bluetoothAdapter)

            Log.i(TAG, "GetActivePresetRecord($device)")



            val presetInfo: BluetoothHapPresetInfo? = bluetoothHapClient.getActivePresetInfo(device)



            if (presetInfo != null) {

                GetActivePresetRecordResponse.newBuilder()

                    .setPresetRecord(

                        PresetRecord.newBuilder()

                            .setIndex(presetInfo.getIndex())

                            .setName(presetInfo.getName())

                            .setIsWritable(presetInfo.isWritable())

                            .setIsAvailable(presetInfo.isAvailable())

                    )

                    .build()

            } else {

                GetActivePresetRecordResponse.getDefaultInstance()

            }

        }

    }



    override fun setNextPreset(

        request: SetNextPresetRequest,

        responseObserver: StreamObserver<Empty>,

android/pandora/test/hap_test.py

+60 −2
Original line number Diff line number Diff line
@@ -16,7 +16,7 @@ import asyncio 
from avatar import BumblePandoraDevice, PandoraDevice, PandoraDevices, asynchronous

from bumble.gatt import GATT_HEARING_ACCESS_SERVICE, GATT_AUDIO_STREAM_CONTROL_SERVICE, GATT_PUBLISHED_AUDIO_CAPABILITIES_SERVICE

from bumble.profiles import hap

from bumble.profiles.hap import DynamicPresets, HearingAccessService, HearingAidFeatures, HearingAidType, IndependentPresets, PresetRecord, PresetSynchronizationSupport, WritablePresetsSupport

from bumble.profiles.hap import DynamicPresets, HearingAccessService, HearingAidFeatures, HearingAidType, IndependentPresets, PresetChangedOperation, PresetChangedOperationAvailable, PresetRecord, PresetSynchronizationSupport, WritablePresetsSupport



from pandora_experimental.os_grpc_aio import Os as OsAio

from pandora_experimental.gatt_grpc_aio import GATT
@@ -157,12 +157,18 @@ class HapTest(base_test.BaseTestClass): 


        return dut_connection_to_ref



    async def assertIdenticalPreset(self, dut_connection_to_ref: Connection):

    async def assertIdenticalPreset(self, dut_connection_to_ref: Connection) -> None:

        remote_preset = toBumblePresetList(

            (await self.hap_grpc.GetAllPresetRecords(connection=dut_connection_to_ref)).preset_record_list)

        AssertThat(remote_preset).ContainsExactlyElementsIn(  # type: ignore

            get_server_preset_sorted(self.has)).InOrder()  # type: ignore



    async def verify_no_crash(self, dut_connection_to_ref: Connection) -> None:

        ''' Periodically check that there is no android crash '''

        for __i__ in range(10):

            await asyncio.sleep(.3)

            await self.assertIdenticalPreset(dut_connection_to_ref)



    @asynchronous

    async def test_get_features(self) -> None:

        await self.logcat.Log("test_get_features")
@@ -191,3 +197,55 @@ class HapTest(base_test.BaseTestClass): 
        await asyncio.sleep(1)  # wait event



        await self.assertIdenticalPreset(dut_connection_to_ref)



    @asynchronous

    async def test__add_preset__verify_dut_is_updated(self) -> None:

        await self.logcat.Log("test__add_preset__verify_dut_is_updated")

        dut_connection_to_ref = await self.setupHapConnection()



        await self.assertIdenticalPreset(dut_connection_to_ref)



        added_preset = PresetRecord(bar_preset.index + 3, "added_preset")

        self.has.preset_records[added_preset.index] = added_preset



        await self.logcat.Log("Preset added in server. Notify now")

        await self.has.generic_update(

            PresetChangedOperation(PresetChangedOperation.ChangeId.GENERIC_UPDATE,

                                   PresetChangedOperation.Generic(bar_preset.index, added_preset)))

        await asyncio.sleep(1)  # wait event



        await self.assertIdenticalPreset(dut_connection_to_ref)



    @asynchronous

    async def test__set_non_existing_preset_as_active__verify_no_crash_and_no_update(self) -> None:

        await self.logcat.Log("test__set_non_existing_preset_as_active__verify_no_crash_and_no_update")

        non_existing_preset_index = 79

        AssertThat(non_existing_preset_index).IsNotIn(self.has.preset_records.keys())  # type: ignore

        dut_connection_to_ref = await self.setupHapConnection()

        AssertThat(

            toBumblePreset(  # type: ignore

                (await self.hap_grpc.GetActivePresetRecord(connection=dut_connection_to_ref

                                                          )).preset_record)).IsEqualTo(foo_preset)



        await self.logcat.Log("Notify active update to non existing index")

        # bypass the set_active_preset checks by sending an invalid index on purpose

        self.has.active_preset_index = non_existing_preset_index

        await self.has.notify_active_preset()



        await self.verify_no_crash(dut_connection_to_ref)

        AssertThat(

            toBumblePreset(  # type: ignore

                (await self.hap_grpc.GetActivePresetRecord(connection=dut_connection_to_ref

                                                          )).preset_record)).IsEqualTo(foo_preset)



    @asynchronous

    async def test__set_non_existing_preset_as_available__verify_no_crash_and_no_update(self) -> None:

        await self.logcat.Log("test__set_non_existing_preset_as_available__verify_no_crash_and_no_update")

        non_existing_preset_index = 79

        AssertThat(non_existing_preset_index).IsNotIn(self.has.preset_records.keys())  # type: ignore

        dut_connection_to_ref = await self.setupHapConnection()



        await self.logcat.Log("Notify available preset to non existing index")

        await self.has.generic_update(PresetChangedOperationAvailable(non_existing_preset_index))



        await self.verify_no_crash(dut_connection_to_ref)

pandora/interfaces/pandora_experimental/hap.proto

+12 −0
Original line number Diff line number Diff line
@@ -22,6 +22,8 @@ service HAP { 
  rpc GetFeatures(GetFeaturesRequest) returns (GetFeaturesResponse);

  // Set active preset by index

  rpc SetActivePreset(SetActivePresetRequest) returns (google.protobuf.Empty);

  // Get active preset record

  rpc GetActivePresetRecord(GetActivePresetRecordRequest) returns (GetActivePresetRecordResponse);

  // Set next preset

  rpc SetNextPreset(SetNextPresetRequest) returns (google.protobuf.Empty);

  // Set next preset
@@ -66,6 +68,16 @@ message SetActivePresetRequest { 
    uint32 index = 2;

}



message GetActivePresetRecordRequest {

    // Connection crafted by grpc server

    Connection connection = 1;

}



message GetActivePresetRecordResponse {

    // Received Preset Record

    PresetRecord preset_record = 1;

}



// Request of the `SetNextPreset` method.

message SetNextPresetRequest {

    // Connection crafted by grpc server