Python opp obex服务器使用Bluez-obex和pydbus?

Question

对于我的项目，我需要通过蓝牙下载.zip文件。我使用python和obex。我有一个工作python opp客户端实现(大声呼叫ukBaz的帮助)，但我仍然使用os启动服务器，所以我的服务器程序的其余部分不知道何时收到文件。程序的其余部分已经完成，但是没有服务器的输出，我无法触发unzip函数运行。我已经阅读了bluez-obex API文档，似乎没有任何关于启动服务器的内容。还有别的办法吗?我的代码如下:

os.system("sudo obexpushd -B -o /home/pi/Desktop/ -n")

Answer 1

我不熟悉obexpushd，也不知道它给了你什么，而不是使用obexd的功能。

我的理解是，您需要创建一个obex-agent来接受/拒绝蓝牙对象推送请求与obexd。

监视InterfacesAddedDBus信号应该为您提供您需要知道的传输何时开始的信息。当状态发生变化时，您可以监视PropertiesChanged信号。

我能够将照片从我的手机推送到Raspberry Pi上，并在RPi上运行以下程序(我的手机和RPi已经配对):

from gi.repository import GLib
import pydbus
BUS_NAME = 'org.bluez.obex'
PATH = '/org/bluez/obex'
AGENT_MANAGER_INTERFACE = 'org.bluez.obex.AgentManager1'
AGENT_INTERFACE = 'org.bluez.obex.Agent1'
SESSION_INTERFACE = 'org.bluez.obex.Session1'
TRANSFER_INTERFACE = 'org.bluez.obex.Transfer1'
ses_bus = pydbus.SessionBus()

def transfer_status_handler(iface, props_changed, props_removed):
if iface == TRANSFER_INTERFACE:
status = props_changed.get('Status')
if status == 'complete':
print('Transfer complete')
elif status == 'queued':
print('Still queued')
elif status == 'active':
print('transferring')
elif status == 'suspended':
print('Suspended')
elif status == 'error':
print('error')
def iface_added_handler(dbus_path, interfaces):
if SESSION_INTERFACE in interfaces and 'server' in dbus_path:
print('Server session added')
elif TRANSFER_INTERFACE in interfaces and 'server' in dbus_path:
print('Transfer started')
transfer = ses_bus.get(BUS_NAME, dbus_path)
transfer.onPropertiesChanged = transfer_status_handler

class Agent:
"""
<node>
<interface name='org.bluez.obex.Agent1'>
<method name='Release'>
</method>
<method name='AuthorizePush'>
<arg type='s' name='path' direction='out'/>
<arg type='o' name='transfer' direction='in'/>
</method>
<method name='Cancel'>
</method>
</interface>
</node>
"""
def AuthorizePush(self, path):
print('Authorize Push', path)
transfer = ses_bus.get(BUS_NAME, path)
props = transfer.GetAll(TRANSFER_INTERFACE)
print(props)
return props.get('Name')
def Cancel(self):
print('Authorization Cancelled')
def Release(self):
pass

if __name__ == '__main__':
obex_mngr = ses_bus.get('org.bluez.obex', '/')
obex_mngr.onInterfacesAdded = iface_added_handler
mainloop = GLib.MainLoop()
ses_bus.register_object('/test/agent', Agent(), None)
print('Agent created')
agnt_mngr = ses_bus.get(BUS_NAME, PATH)
agnt_mngr.RegisterAgent('/test/agent')
print('Agent registered')
try:
mainloop.run()
except KeyboardInterrupt:
mainloop.quit()

这段代码只接受由它发出的任何请求。这可能是一件不好的事情，如果文件应该被接受，人们可能想要添加一些检查(或提示用户)。