Received-SPF: pass (google.com: domain of linux-bluetooth+bounces-4403-linux.lists.archive=gmail.com@vger.kernel.org designates 147.75.48.161 as permitted sender) client-ip=147.75.48.161;
Precedence: bulk
MIME-Version: 1.0
References: <20240508154604.276763-1-arun@asymptotic.io> <20240508154604.276763-4-arun@asymptotic.io>
In-Reply-To: <20240508154604.276763-4-arun@asymptotic.io>
From: Luiz Augusto von Dentz <luiz.dentz@gmail.com>
Date: Wed, 8 May 2024 12:34:24 -0400
Message-ID: <CABBYNZKzCe-c-JivKC5gT0P0ZKGwXX9DQeEeZmeDvQS3CpyNTw@mail.gmail.com>
Subject: Re: [PATCH BlueZ 3/5] test: Add a script to test ASHA
To: Arun Raghavan <arun@asymptotic.io>
Cc: linux-bluetooth@vger.kernel.org
Content-Type: text/plain; charset="UTF-8"
Content-Transfer-Encoding: quoted-printable

Hi Arun,

On Wed, May 8, 2024 at 11:48=E2=80=AFAM Arun Raghavan <arun@asymptotic.io> =
wrote:
>
> Plays out an audio file to the device. Depends on GStreamer for media
> file reading and decoding (specifically, gstreamer core,
> gst-plugins-base, gst-ffmpeg, and gst-python, or equivalent packages).
> ---
>  test/simple-asha | 158 +++++++++++++++++++++++++++++++++++++++++++++++
>  1 file changed, 158 insertions(+)
>  create mode 100755 test/simple-asha
>
> diff --git a/test/simple-asha b/test/simple-asha
> new file mode 100755
> index 000000000..feff9d29c
> --- /dev/null
> +++ b/test/simple-asha
> @@ -0,0 +1,158 @@
> +#!/usr/bin/env python3
> +# SPDX-License-Identifier: LGPL-2.1-or-later
> +
> +import os
> +import signal
> +import sys
> +
> +import dbus
> +import dbus.service
> +import dbus.mainloop.glib
> +
> +import gi
> +
> +gi.require_version("Gst", "1.0")
> +gi.require_version("GLib", "2.0")
> +from gi.repository import GLib, Gst
> +
> +import bluezutils
> +
> +mainloop =3D None
> +pipeline =3D None
> +seqnum: int =3D 0
> +
> +
> +def signal_handler(_sig, _frame):
> +    print("Got interrupt")
> +    mainloop.quit()
> +
> +
> +signal.signal(signal.SIGINT, signal_handler)
> +
> +
> +def usage():
> +    print(f"Usage: simple-asha <remote addr> <audio file name> (optional=
 volume 0-127)")
> +
> +
> +def start_playback(fd: int):
> +    global mainloop, pipeline
> +
> +    outdata =3D bytearray(161)
> +
> +    Gst.init(None)
> +
> +    pipeline =3D Gst.parse_launch(
> +        f"""
> +          filesrc location=3D"{sys.argv[2]}" ! decodebin !
> +          audioconvert ! audioresample !
> +          audiobuffersplit output-buffer-duration=3D"20/1000" ! avenc_g7=
22 !
> +          appsink name=3Dsink emit-signals=3Dtrue
> +    """
> +    )
> +
> +    def on_new_sample(sink):
> +        global seqnum
> +
> +        sample =3D sink.emit("pull-sample")
> +        buf =3D sample.get_buffer()
> +
> +        with buf.map(Gst.MapFlags.READ) as info:
> +            pos =3D 0
> +
> +            if info.size !=3D 160:
> +                print("Unexpected buffer size: ", info.size)
> +
> +            outdata[pos] =3D seqnum % 256
> +            pos +=3D 1
> +
> +            for byte in info.data:
> +                outdata[pos] =3D byte
> +                pos +=3D 1
> +
> +            try:
> +                n =3D os.write(fd, outdata)
> +                if n !=3D 161:
> +                    print("Wrote less than expected: ", n)
> +            except:
> +                return Gst.FlowReturn.ERROR
> +
> +        seqnum +=3D 1
> +
> +        return Gst.FlowReturn.OK
> +
> +    sink =3D pipeline.get_by_name("sink")
> +    sink.connect("new-sample", on_new_sample)
> +
> +    pipeline.set_state(Gst.State.PLAYING)
> +
> +    def bus_message(_bus, message, _data) -> bool:
> +        typ =3D message.type
> +
> +        if typ =3D=3D Gst.MessageType.EOS:
> +            print("End of stream")
> +            mainloop.quit()
> +        elif typ =3D=3D Gst.MessageType.ERROR:
> +            err, debug =3D message.parse_error()
> +            print(f"Pipeline error: {err} ({debug})")
> +            mainloop.quit()
> +
> +    bus =3D pipeline.get_bus()
> +    bus.add_watch(GLib.PRIORITY_DEFAULT, bus_message, None)
> +
> +
> +if __name__ =3D=3D "__main__":
> +    dbus.mainloop.glib.DBusGMainLoop(set_as_default=3DTrue)
> +
> +    mainloop =3D GLib.MainLoop()
> +    bus =3D dbus.SystemBus()
> +
> +    if (len(sys.argv) =3D=3D 3) or (len(sys.argv) =3D=3D 4):
> +        device =3D bluezutils.find_device(sys.argv[1])
> +        if device is None:
> +            print("Could not find device: ", sys.argv[1])
> +            exit(255)
> +    else:
> +        usage()
> +        sys.exit(255)
> +
> +    asha =3D bus.get_object("org.bluez", device.object_path + "/asha")
> +    media =3D dbus.Interface(
> +        bus.get_object("org.bluez", device.object_path + "/asha"),
> +        "org.bluez.MediaEndpoint1",
> +    )
> +
> +    props =3D asha.GetAll(
> +        "org.bluez.MediaEndpoint1",
> +        dbus_interface=3D"org.freedesktop.DBus.Properties",
> +    )
> +    path =3D props["Transport"]
> +
> +    print("Trying to acquire", path)
> +
> +    transport =3D dbus.Interface(
> +        bus.get_object("org.bluez", path),
> +        "org.bluez.MediaTransport1",
> +    )
> +
> +    # Keep default volume at 25%
> +    volume =3D 32
> +    if len(sys.argv) =3D=3D 4:
> +        volume =3D int(sys.argv[3])
> +        if volume < 0 or volume > 127:
> +            print("Volume must be between 0 (mute) and 127 (max)")
> +
> +    transport.Set(
> +        "org.bluez.MediaTransport1",
> +        "Volume",
> +        dbus.UInt16(volume, variant_level=3D1),
> +        dbus_interface=3D"org.freedesktop.DBus.Properties",
> +    )
> +
> +    (fd, imtu, omtu) =3D transport.Acquire()
> +
> +    start_playback(fd.take())
> +
> +    mainloop.run()
> +
> +    pipeline.set_state(Gst.State.NULL)
> +    transport.Release()
> --
> 2.45.0

While I don't mind having a python example I think we are much better
of adding such support in bluetoothctl, most should already work with
transport submenu but perhaps we want to add support for gstreamer
pipeline instead of just a file which would be useful for creating
A2DP sbc and BAP lc3 streams.

>


--=20
Luiz Augusto von Dentz