/tmp/testudisks.py

tmptestudisks.py

import threading
import time

from dbus import SystemBus, Interface
from dbus.mainloop.glib import DBusGMainLoop, threads_init
from gi.repository import GLib

UDISKS2_SERVICE = 'org.freedesktop.UDisks2'
BLOCK_INTERFACE = f'{UDISKS2_SERVICE}.Block'
FILESYSTEM_INTERFACE = f'{UDISKS2_SERVICE}.Filesystem'

bus = SystemBus(mainloop=DBusGMainLoop())


def on_interface_added(path, interfaces):
    if FILESYSTEM_INTERFACE not in interfaces:
        return

    device = bytes(interfaces[BLOCK_INTERFACE]['Device']).decode('utf8')
    print('Abount to mount block device:', device)

    filesystem = Interface(
        bus.get_object(UDISKS2_SERVICE, path),
        FILESYSTEM_INTERFACE
    )
    mountpoint = filesystem.Mount({})
    print('Mounted block device at:', mountpoint)


def dbus_thread():
    bus.add_signal_receiver(on_interface_added, 'InterfacesAdded')
    loop = GLib.MainLoop()
    loop.run()


threads_init()
threading.Thread(
    target=dbus_thread,
    daemon=True,
).start()


while True:
    time.sleep(1)