B a[@sdZddlZddlmZddlmZmZddlZdZdZ e eZ dZ dZ d d d d d dddddddddddddZ GdddZGdddZdS)z A Python library for interfacing with SooperLooper. Tracks full state and provides interface to all loop commands. Almost a complete client, just missing saving sessions. N) namedtuple)EventLock) rec_threshfeedbackdrywet input_gainrate scratch_pos delay_triggerquantizeround redo_is_tapsync playback_syncuse_rate fade_samplesuse_feedback_playuse_common_insuse_common_outs relative_syncuse_safety_feedbackpan_1pan_2pan_3pan_4 input_latencyoutput_latencytrigger_latencyautoset_latencymute_quantizedoverdub_quantized pitch_shift stretch_ratio) state next_stateloop_lenloop_pos cycle_len free_time total_time rate_output channel_count in_peak_meterout_peak_meter is_soloedwaiting)recordZoverdubZmultiplyinsertreplacereverseZmuteundoredoZoneshottrigger substituteZundo_allZredo_allZmute_onZmute_offZsolopauseZ solo_nextZ solo_prevZ record_soloZrecord_solo_nextZrecord_solo_prevZ set_sync_posZreset_sync_posscratch) tempoeighth_per_cyclerrr sync_source tap_tempo save_loopauto_disable_latencyselect_next_loopselect_prev_loopselect_all_loopsselected_loop_numunknownOffZ WaitStartZ RecordingZWaitStopZPlayingZ OverdubbingZ MultiplyingZ InsertingZ ReplacingDelayZMutedZ ScratchingZOneShotZ SubstitutePausedz Off and muted)r csFeZdZdZdEddZddZfd d Zd d Zd dZddZ ddZ ddZ ddZ ddZ ddZddZddZdd Zd!d"Zd#d$ZdFd&d'Zd(d)Zd*d+Zd,d-Zed.d/Zejd0d/Zed1d2Zejd3d2Zed4d5Zed6d7Zejd8d7Zd9d:Zd;d<Zd=d>Z d?d@Z!dAdBZ"dCdDZ#Z$S)G LooperThreadz Handles I/O with SooperLooper via OSC. Organizes loops. Uses a threaded liblo server to register for updates and automatically track looper and loop state. See documentation here: http://essej.net/sooperlooper/doc_osc.html &&FcCs\||_||_||_t|j|_t|_d|_g|_ g|_ g|_ g|_ g|_ g|_g|_dS)Nr)portsl_portverboselibloZ ServerThreadserverr ping_flag loop_countloopsloop_callbackslooper_callbacksping_callbacksloop_added_callbacksloop_removed_callbacksmidi_binding_callbacks)selfr\r]r^rk/home/debian/UI/dooper.py__init__szLooperThread.__init__cCsd|j|j|jS)Nz-LooperThread(port={}, sl_port={}, verbose={}))formatr\r]r^)rjrkrkrl__repr__szLooperThread.__repr__cs<|dkrt||n |tkr.|||n ||j|<dS)N)r=r rD)super __setattr__looper_parametersset__dict__)rjnameval) __class__rkrlrqs zLooperThread.__setattr__cCstdg|jdd|j|jdd|j|jdd|j|jdd|j|jdd|j|j | | dS)Nz/usr/bin/sooperlooperz/sl/pingz/sl/loopz /sl/looperz /sl/loop_numz/sl/midi_bindings) subprocessPopenr`Z add_methodping_responderloop_responderlooper_responderloop_num_respondermidi_binding_responderstart initializeregister_updates)rjrkrkrl start_servers  zLooperThread.start_servercCsf|jdd|jdd|jdd|jdd|jdd|d||jdS)Nz/sl/pingz/sl/loopz /sl/looperz /sl/loop_numz/sl/midi_bindingsz/quit)r`Z del_methodsend_oscunregister_updatesstop)rjrkrkrl stop_servers zLooperThread.stop_servercCsd|_g|_d}x(|s8|d}|dkrtddSqWx tD]}|d||jjdq@W|dd|jjd|dd |jjd|jrxLt|jD]4}|j t ||xt D]}|j| |qWqWntd dS) NrrJ2zNo ping reply from SooperLooperz/getz /sl/looperz /sl/0/getr rzLoop count is zero) rbrcpingprintrrrr`urlrangeappendLooploop_parametersget)rjZattemptparamirkrkrlrs$   zLooperThread.initializecGs4|jrtd||t|jtj|f|dS)NzSending OSC message: {} {})r^rrnr_sendr]ZMessage)rjpathargsrkrkrlrszLooperThread.send_osccCsF|jrtd|||d|_|jx|jD] }||q2WdS)Nz ping Received OSC message: {} {}rK)r^rrnrbrarsrf)rjrrfrkrkrlrzs    zLooperThread.ping_responderc Cs|jrtd|||jj|j}|d|_|j|krxt||jD]n}|jt ||x|j D] }||qbWx>t D]6}|j| || dt|d|d|jjdqxWqDWnb|j|kr|j}x|jD] }||qW|jx,t D]$}| dt|d||jjdqWdS) z- Listens for replies from SL about loop countz8loop num responder Received OSC message: {} {} server {}rKz/sl/z/register_auto_updatedz/sl/loopz/unregister_auto_updateN)r^rrnr`rrbrrcrrrgrrrstrrhpop)rjrrZprev_loop_countloop_numrrrkrkrlr}s&     ,     zLooperThread.loop_num_respondercCs|y|j|d}Wntk r&dSX|dd\}}|jrV|dkrVtd||||j|<x|jD] }||qhWdS)zO Listens for replies from SL about loops, then updates loop object accordingly.rNrJr(z*loop responder Received OSC message: {} {})rc IndexErrorr^rrnrtrd)rjrrloopcontrolvaluerrkrkrlr{s  zLooperThread.loop_respondercCsJ|jrtd|||jj|d|j|d<x|jD] }||q6WdS)z6 Listens for replies from SL about looper global statez6looper responder Received OSC message: {} {} server {}rKrJN)r^rrnr`rrtre)rjrrrrkrkrlr|!s  zLooperThread.looper_respondercCsD|jrtd|||jj|ddkr@x|jD] }||q0WdS)z0 Listens for replies from SL about midi bindingszszLooperThread.setc Csx"tD]}|d|d|jjdqW|ddd|jjd|d|jjdx@|jD]6}x0tD](}|dt|jd|d|jjd q^WqTWd S) a Ask SL to updates us on changes to global and loop states. While the documentation indicates that register_update should trigger whenever any client updates an input control, in practice the auto variety seems necessary to catch changes not initiated from SL's frontend. Auto is always necessary for loop states. We pass a polling interval of 100ms, but this is actually fixed on the backend. Updates only fire if the value has been changed. z/register_auto_updaterz /sl/looperz/sl/0/register_auto_updater z /registerz /sl/loop_numz/sl/z/sl/loopN)rrrr`rrcrrnumber)rjrrrkrkrlrAs   zLooperThread.register_updatescCsx tD]}|d||jjdqW|dd|jjd|d|jjdx>|jD]4}x.tD]&}|dt|jd||jjdqZWqPWd S) z Ask SL to stop updating usz/unregister_auto_updatez /sl/looperz/sl/0/unregister_auto_updater z /unregisterz /sl/loop_numz/sl/z/sl/loopN)rrrr`rrcrrr)rjrrrkrkrlrNs   zLooperThread.unregister_updatesrJcCs(|j|d|jjd|j|S)Nz/pingz/sl/ping)raclearrr`rwait)rjtimeoutrkrkrlr[s zLooperThread.pingcCs|d|ddS)Nz /loop_addgE@)r)rj num_channelsrkrkrladd_loop`szLooperThread.add_loopcCs|dddS)Nz /loop_delrI)r)rjrkrkrl remove_loopcszLooperThread.remove_loopcCs ||_dS)N)rD)rjnrkrkrl select_loopfszLooperThread.select_loopcCsdt|jdS)N)offcycle8thrr )intrt)rjrkrkrlr iszLooperThread.quantizecCsd|}|dd|dS)N)rrrrz /sl/0/setr )indexr)rjrvqrkrkrlr ms cCs"|jd}|dkrdSt|SdS)NrDrIall)rtr)rjrrkrkrlrDrs zLooperThread.selected_loop_numcCs"|dkrd}n|}|d|dS)NrrIrD)rs)rjrvrrkrkrlrDzscCs|j}t|tr|j|SdS)N)rD isinstancerrc)rjrrkrkrl selected_loops zLooperThread.selected_loopcCs|jd}t|S)Nr=)rtr)rjsrkrkrlr=s zLooperThread.sync_sourcecCs|}|d|dS)Nr=)rs)rjrvrrkrkrlr=scCs|d|jjddS)Nz/cancel_midi_learnz/sl/midi_bindings)rr`r)rjrkrkrlcancel_midi_learnszLooperThread.cancel_midi_learncCs|d||jjddS)Nz /save_sessionz/error)rr`r)rj target_filerkrkrl save_sessionszLooperThread.save_sessioncCs|d|ddS)Nz/save_midi_bindings)r)rjrrkrkrlsave_midi_bindingsszLooperThread.save_midi_bindingscCs|d||jjddS)Nz /load_sessionz/error)rr`r)rjrrkrkrl load_sessionszLooperThread.load_sessioncCs|d|ddS)Nz/load_midi_bindingsr)r)rjrrkrkrlload_midi_bindingsszLooperThread.load_midi_bindingsc Cs2tddddddddd d g }d }|}d |_d |_d|_||_d|_d|_d|_|dkrld|_d|_d|_n`|dkrd|_d|_nH|dkrd|_d|_d|_n*|dkrd|_d|_d|_n |dkrd|_d|_d|_n|dkrd|_d|_d|_n|d krd |_d!|_n|d"kr0d"|_d!|_n|d#krJd#|_d!|_n|d$krdd%|_d$|_nh|d&krd'|_d(|_d)|_nH|d*krd%|_d*|_d|_d+|_n"|d,krd,|_d%|_n|d-krd-|_d%|_n|d.krd.|_d%|_n|d/kr d/|_d%|_n|d0kr6d|_d1|_d|_d|_d|_n|d2kr`d|_d1|_d|_d3|_d3|_nl|d4krd|_d1|_d|_d5|_d5|_nB|d1kr||_d6|_d7|_n$|d8kr||_nd|_||_d9|_|jdkrd |_ nd:|_ |s.d; |j|j|j |j|j|j|j|j|j }| d<|d=|j j d>dS)?NZ MidiBindingchanneltypercommandrinstancelbounduboundstyleFrccrsgg?Znormr;g4@g q@Ztaptempor>rAZonrBZeighthr<g`@rg@rgainrr rrIrr=gg0@r g@r!r"Zreplace_quantizedZ smart_eighthsZrate_1r Zrate_05g?Zrate_2g@g?g@)rrr rrZnoteixz {} {} {} {} {} {} {} {} {} 0 127z/learn_midi_bindingZ exclusivez/sl/midi_bindings)rrrrrrrrrrrnrr`r)rjrrinfoZ donothingrvZinfo_strrkrkrl midi_learns                             ,zLooperThread.midi_learn)rZr[F)rJ)%__name__ __module__ __qualname____doc__rmrorqrrrrrzr}r{r|r~rrsrrrrrrpropertyr setterrDrr=rrrrrr __classcell__rkrk)rwrlrYsD            rYc@sveZdZdddZddZddZdd Zd d Zd d ZddZ ddZ ddZ ddZ e ddZe ddZdS)rrFcCs||_||_dS)N)looperr)rjrrr%rkrkrlrm0sz Loop.__init__cCsd|j|jS)Nz Loop({}, {}))rnrr%)rjrkrkrlro5sz Loop.__repr__cCsd|j|jS)Nz Loop({}, {}))rnrr%)rjrkrkrl__str__:sz Loop.__str__cstkrfddSdS)Ncs S)N)hitrk)rurjrkrl?z"Loop.__getattr__..) loop_commands)rjrurk)rurjrl __getattr__=szLoop.__getattr__cCs&|tkr|d||n ||j|<dS)Nrs)loop_parameters_settablerrt)rjrurvrkrkrlrqBszLoop.__setattr__cCs td|||jd||dS)Nzsending set valuers)rrr)rjrrrkrkrlrsHs zLoop.setcCs|d||dS)Nrs)r)rjrurvrkrkrlloop_setLsz Loop.loop_setcCs|d||jjjddS)Nrz/sl/loop)rrr`r)rjrrkrkrlrOszLoop.getcGs|jj|j|f|dS)N)rrr)rjactionrrkrkrlrRsz Loop.sendcCs|d|dS)Nr)r)rjrrkrkrlrUszLoop.hitcCstt|jdS)Nr%) state_codesrrt)rjrkrkrlr%Xsz Loop.statecCstt|jdS)Nr&)rrrt)rjrkrkrlr&\szLoop.next_stateN)rF)rrrrmrorrrqrsrrrrrr%r&rkrkrkrlr/s  r)rr_ collectionsr threadingrrrxrZloop_parameters_gettablerrrrrrYrrkrkrkrls> #/