Browse Source

Update callbacks for pylinphone interface

pylinphone
klonfish 4 years ago
parent
commit
7e3d5a0b9d
  1. 4
      fetapd.py
  2. 74
      phoneinterface.py

4
fetapd.py

@ -74,6 +74,10 @@ if __name__ == '__main__':
feap = FeApUserInterface(cfg.pinconfig) feap = FeApUserInterface(cfg.pinconfig)
controller = statemachine.StateMachineController(phone, feap, cfg.dialconfig) controller = statemachine.StateMachineController(phone, feap, cfg.dialconfig)
# TODO: Use real events from daemon
controller.queue_event('registration_in_progress')
controller.queue_event('registration_successful')
feap.add_gabelschalter_callback(gabelschalter_cb) feap.add_gabelschalter_callback(gabelschalter_cb)
feap.add_nummernschalter_active_callback(nummernschalter_active_cb) feap.add_nummernschalter_active_callback(nummernschalter_active_cb)
feap.add_nummernschalter_done_callback(nummernschalter_done_cb) feap.add_nummernschalter_done_callback(nummernschalter_done_cb)

74
phoneinterface.py

@ -47,17 +47,16 @@ class PhoneEvent(object):
class PhoneInterface(object): class PhoneInterface(object):
def __init__(self, config): def __init__(self, config):
cbs = {
'global_state_changed': self.__global_state_changed,
'registration_state_changed': self.__registration_state_changed,
'call_state_changed': self.__call_state_changed
}
self.__event_cbs = [] self.__event_cbs = []
self.__config = config self.__config = config
self.__core = LinphoneCommunicationSocket("/var/tmp/debian-sid/tmp/linphone") self.__core = LinphoneCommunicationSocket("/var/tmp/debian-sid/tmp/linphone")
self.__core.onLinphoneCallIncomingReceived = self.on_LinphoneCallIncomingReceived
self.__core.onLinphoneCallOutgoingRinging = self.on_LinphoneCallOutgoingRinging
self.__core.onLinphoneCallConnected = self.on_LinphoneCallConnected
self.__core.onLinphoneCallEnd = self.on_LinphoneCallEnd
# Create and add all proxy configs # Create and add all proxy configs
for p in config.proxies: for p in config.proxies:
aid = self.__core.register(p.identity, p.proxy, p.password, p.username) # sip:XXXX@hg.eventphone.de, hg.eventphone.de, MySecretPassword, XXXX aid = self.__core.register(p.identity, p.proxy, p.password, p.username) # sip:XXXX@hg.eventphone.de, hg.eventphone.de, MySecretPassword, XXXX
@ -82,52 +81,23 @@ class PhoneInterface(object):
#self.__core.video_capture_enabled = False #self.__core.video_capture_enabled = False
#self.__core.video_display_enabled = False #self.__core.video_display_enabled = False
def __global_state_changed(self, core, state, msg):
print('Global state changed:', state, msg) def run_callbacks(self, evt):
# TODO: Do we need events emitted here? print(PhoneEvent.string(evt))
pass for cb in self.__event_cbs:
cb(evt)
def __registration_state_changed(self, core, proxyconf, state, msg):
print('Registration state changed:', proxyconf, state, msg) def on_LinphoneCallIncomingReceived(self, event):
evt = None self.run_callbacks(PhoneEvent.CallIncoming)
if state == linphone.RegistrationState.Progress:
evt = PhoneEvent.RegInProgress def on_LinphoneCallOutgoingRinging(self, event):
elif state == linphone.RegistrationState.Ok: self.run_callbacks(PhoneEvent.CallRinging)
evt = PhoneEvent.RegSuccessfull
elif state == linphone.RegistrationState.None: def on_LinphoneCallConnected(self, event):
evt = PhoneEvent.RegLost self.run_callbacks(PhoneEvent.CallAccepted)
if evt is not None: def on_LinphoneCallEnd(self, event):
for cb in self.__event_cbs: self.run_callbacks(PhoneEvent.CallEnded)
cb(evt)
else:
print('Unhandled registration state:', linphone.RegistrationState.string(state))
def __call_state_changed(self, core, call, state, msg):
print('Call state changed:', call, state, msg)
evt = None
if state == linphone.CallState.IncomingReceived:
evt = PhoneEvent.CallIncoming
elif state == linphone.CallState.OutgoingRinging:
evt = PhoneEvent.CallRinging
elif state == linphone.CallState.Connected:
evt = PhoneEvent.CallAccepted
elif state == linphone.CallState.End:
evt = PhoneEvent.CallEnded
elif state == linphone.CallState.Error:
error = call.error_info.reason
if error == linphone.Reason.Busy:
evt = PhoneEvent.CallBusy
elif error == linphone.Reason.NotFound:
evt = PhoneEvent.CallInvalidNumber
else:
evt = PhoneEvent.CallEnded
if evt is not None:
for cb in self.__event_cbs:
cb(evt)
else:
print('Unhandled call state:', linphone.CallState.string(state))
def __pollthread(self): def __pollthread(self):
while self.__running: while self.__running:

Loading…
Cancel
Save