<> <> <> <> <<>> DIRECTORY Atom USING [ DottedPairNode, GetPName ], Commander USING [ CommandProc, Register ], Convert USING [ IntFromRope ], GList USING [ DRemove ], IO, LarkPlay USING [ MergeToneSpecs, PlayString, ToneSpec, ToneSpecRec ], LarkSmartsMonitorImpl, MBQueue USING [ QueueClientAction ], NamesGV USING [ GVGetAttribute, GVSetAttribute ], Nice, Process USING [ Detach, SecondsToTicks, SetTimeout ], RefID USING [ ID, Reseal, Unseal ], RefTab USING [ Create, Fetch, Ref, Store ], Rope USING [ Concat, Fetch, Length, ROPE ], ThNet USING [ pd ], ThParty USING [ Advance, ConversationInfo, DescribeParty, GetConversationInfo, GetKeyTable, GetPartyInfo, PartyInfo ], ThPartyPrivate USING [ GetCurrentParty ], Thrush USING [ ActionReport, ConvEvent, ConversationID, PartyID, PartyType, NB, notReallyInConv, nullConvID, nullID, Reason, ROPE, SHHH, SmartsID, StateID, StateInConv ], ThSmartsPrivate USING [ ConvDesc, ConvDescBody, ConvRequest, ConvRequestBody, EnterLarkState, LarkAvailable, LarkState, OpenConversations, ParseState, SmartsInfo ], ThSmartsRpcControl, Triples USING [ Select ], TU, VoiceUtils USING [ MakeAtom, ProblemFR, Report, ReportFR ] ; LarkSmartsSupImpl: CEDAR MONITOR LOCKS root IMPORTS Atom, Commander, Convert, GList, IO, LarkPlay, root: LarkSmartsMonitorImpl, MBQueue, NamesGV, Nice, Process, RefID, RefTab, Rope, ThNet, ThParty, ThPartyPrivate, ThSmartsPrivate, Triples, TU, VoiceUtils EXPORTS ThSmartsPrivate SHARES LarkSmartsMonitorImpl = { OPEN IO; <> ConversationID: TYPE = Thrush.ConversationID; nullConvID: ConversationID=Thrush.nullConvID; ConvDesc: TYPE = ThSmartsPrivate.ConvDesc; ConvEvent: TYPE = Thrush.ConvEvent; Reseal: PROC[r: REF] RETURNS[RefID.ID] = INLINE {RETURN[RefID.Reseal[r]]; }; NB: TYPE = Thrush.NB; OpenConversations: TYPE = ThSmartsPrivate.OpenConversations; PartyID: TYPE = Thrush.PartyID; nullID: RefID.ID = Thrush.nullID; ROPE: TYPE = Thrush.ROPE; SmartsID: TYPE = Thrush.SmartsID; SmartsInfo: TYPE = ThSmartsPrivate.SmartsInfo; StateInConv: TYPE = Thrush.StateInConv; LORA: TYPE = LIST OF REF ANY; PD: TYPE = RECORD [ timeoutNoAction: INTEGER _ 5, doReports: BOOL_FALSE, larkRegistry: ROPE _ ".lark", doNice: BOOL_FALSE ]; pd: REF PD _ NEW[PD_[]]; <> <<>> LarkProgress: PUBLIC ENTRY PROC[ interface: ThSmartsRpcControl.InterfaceRecord, shh: Thrush.SHHH, convEvent: Thrush.ConvEvent ] = { ENABLE UNWIND => NULL; --
RestoreInvariant; <> <> <> <<(For now, when we don't know about that conversation and are already in another)>> <> <<(New conversation and we're idle or it's a conversation we're in already)>> <> convID: ConversationID = convEvent.self.convID; info: SmartsInfo = GetSmartsInfo[smartsID: convEvent.self.smartsID]; cDesc: ConvDesc; nb2: NB; reason: Thrush.Reason; cInfo: ThParty.ConversationInfo; whatNeedsDoing: WhatNeedsDoing; IF info=NIL THEN { Report["No info at Progress", NIL]; RETURN; }; cDesc _ GetConv[ info, convID, TRUE ]; IF convEvent.self.partyID = convEvent.other.partyID THEN { -- own state changed NoteNewState[cDesc, convEvent]; -- Report on existing conv. or notification of new one. RETURN; }; IF convID#info.currentConvID THEN { <> Report["Strange progress report", cDesc.info]; ForgetConv[cDesc]; RETURN; }; <> whatNeedsDoing _ whatNeedsDoingIf[cDesc.situation.self.state][convEvent.other.state]; SELECT whatNeedsDoing FROM $noop, $ntiy => NULL; -- No action is needed, or we don't know what one to take. $imp => ERROR; -- This is supposed to be impossible! $xrep => Report["Didn't expect state change report", info]; <> $frgt => ForgetConv[cDesc]; <> $invl => { <> Report["Invalid state transition", info]; []_ChangeState[cDesc: cDesc, state: $failed, reason: $error, comment: "System Error: Invalid state transition"]; }; $idle => { <> [nb2, cInfo] _ ThParty.GetConversationInfo[convID: convEvent.self.convID]; reason _ IF nb2 # $success THEN $error ELSE IF convEvent.reason # NIL THEN convEvent.reason ELSE $terminating; -- NIL => $terminating IF nb2 # $success OR (cInfo.numParties-cInfo.numIdle) <= 1 THEN []_ChangeState[cDesc, IF reason=$terminating THEN $idle ELSE $failed, reason]; }; $idlerg => { <> [nb2, cInfo] _ ThParty.GetConversationInfo[convID: convEvent.self.convID]; reason _ IF nb2 # $success THEN $error ELSE IF convEvent.reason # NIL THEN convEvent.reason ELSE $terminating; IF nb2 # $success OR cInfo.originator = convEvent.other.partyID THEN []_ChangeState[cDesc, IF reason=$terminating THEN $idle ELSE $failed, reason]; }; $rback => []_ChangeState[cDesc, $ringback]; -- Provide ring-back signal $actv => []_ChangeState[cDesc, $active]; -- Go active $ckrg => CheckRing[cDesc]; -- We're ringing; Some other party that was ringing has now become active; determine if we should continue ringing. $reac => NULL; --
Will be used to reactivate when somebody else leaves inactive $deac => NULL; --
Will be used to deactivate when everybody else leaves active; ENDCASE => ERROR; }; LarkSubstitution: PUBLIC ENTRY PROC[ interface: ThSmartsRpcControl.InterfaceRecord, shh: Thrush.SHHH, convEvent: Thrush.ConvEvent, oldPartyID: Thrush.PartyID, newPartyID: Thrush.PartyID ] = { ENABLE UNWIND => NULL; --
RestoreInvariant; <> <> info: SmartsInfo = GetSmartsInfo[smartsID: convEvent.self.smartsID]; cDesc: ConvDesc; IF info=NIL THEN { Report["No info at Substitution", NIL]; RETURN; }; cDesc _ GetConv[ info, convEvent.self.convID, FALSE ]; IF cDesc=NIL THEN RETURN; NoteNewState[cDesc, convEvent]; }; LarkReportAction: PUBLIC ENTRY PROC[ interface: ThSmartsRpcControl.InterfaceRecord, shh: Thrush.SHHH, report: Thrush.ActionReport ] = { ENABLE UNWIND => NULL; nb: NB; info: SmartsInfo = GetSmartsInfo[smartsID: report.self.smartsID]; cDesc: ConvDesc; IF info=NIL THEN { Report["No info at ReportAction", NIL]; RETURN; }; cDesc _ GetConv[ info, report.self.convID, FALSE ]; IF cDesc = NIL THEN RETURN; SELECT report.actionClass FROM $keyDistribution => { SELECT report.actionType FROM $newKeys => NULL; ENDCASE => RETURN; [nb, cDesc.keyTable] _ ThParty.GetKeyTable[credentials: report.self]; IF nb#$success THEN { cDesc.keyTable _ NIL; RETURN; }; IF cDesc.situation.self.state <= Thrush.notReallyInConv THEN RETURN; SetLarkState[cDesc, LIST[cDesc.keyTable]]; }; $recording, $playback, $synthesizer => <> SELECT report.actionType FROM $scheduled => cDesc.lastActionID _ report.actionID; $started => NULL; -- always follows $scheduled $finished, $flushed => { IF cDesc.lastActionID = report.actionID AND cDesc.situation.self.state > Thrush.notReallyInConv AND (SELECT cDesc.info.larkInfo.switchState FROM speaker, monitor =>TRUE, ENDCASE =>FALSE) THEN [--
nb--] _ ChangeState[cDesc, $idle] }; ENDCASE; ENDCASE; }; <smarts report>> <> <<
The only ones left are those that avoid recursive calls on ThParty.Advance and on NoteNewState. Even those could probably be eliminated with a bit more thought. Like maybe Loop with the resulting ConvEvent. >> <<>> QdNotification: ENTRY PROC [r: REF] ~ { <> ENABLE UNWIND => NULL; --
RestoreInvariant; cDesc: ConvDesc = NARROW[r]; { OPEN now: cDesc.situation.self; dbAtom: ATOM; dbRname: ROPE; val: ROPE; <> IF now.state # $notified THEN RETURN; -- Nothing to do any more?? IF ~ThSmartsPrivate.LarkAvailable[cDesc.info] THEN GOTO Reject; <> <> [dbRname, dbAtom, val] _ DBInfo[now.partyID, $deferanswer]; IF VoiceUtils.MakeAtom[val]=$true THEN TRUSTED { Process.Detach[FORK DeferAnswer[cDesc, dbRname]]; RETURN; }; <> IF cDesc.info.currentConvID#cDesc.situation.self.convID THEN GOTO Reject; []_ChangeState[cDesc, IF VoiceUtils.MakeAtom[DBInfo[now.partyID, $autoanswer, dbAtom].value] = $true THEN $active ELSE $ringing]; IF now.state=$ringing THEN CheckRing[cDesc]; EXITS Reject => DoRejectCall[cDesc, NIL]; -- couldn't accept call, for whatever reason. }; }; DeferAnswer: ENTRY PROC [cDesc: ConvDesc, dbRname: ROPE] ~ TRUSTED { c: CONDITION; Process.SetTimeout[@c, Process.SecondsToTicks[pd.timeoutNoAction]]; WAIT c; IF cDesc.situation.self.state # $notified THEN RETURN; <> NamesGV.GVSetAttribute[dbRname, $deferanswer, NIL]; cDesc.info.requests.QueueClientAction[QdNotification, cDesc]; }; <> <> DoAdvance: INTERNAL PROC[convRequest: ThSmartsPrivate.ConvRequest] RETURNS [nb: NB] = { cDesc: ConvDesc = convRequest.cDesc; DO -- for possible stateMismatch loop OPEN now: cDesc.situation.self, desired: convRequest.desiredSituation.self; convEvent: Thrush.ConvEvent; IF now.state=$idle OR now.state = desired.state THEN RETURN; <<
More comfortable if this were a complete check for reasonable transitions. For now, if the initial request wasn't a transition to $idle and we got a state mismatch, we've given up, assuming that what our other smarts did was as reasonable as what we wanted to do. Later queued actions, and later actions in LarkSmartsImpl (synchronous with user actions) will have to detect any anomalies and deal with them.  >> [nb, convEvent] _ ThParty.Advance[ credentials: now, state: desired.state, reason: convRequest.desiredSituation.reason, comment: convRequest.desiredSituation.comment, reportToAll: shouldReportToAll[desired.state] ]; SELECT nb FROM $success => cDesc.info.NoteNewStateP[cDesc, convEvent]; $stateMismatch => { <> cDesc.info.NoteNewStateP[cDesc, convEvent]; IF desired.state = $idle THEN LOOP; }; $noSuchConv => Report["Conv doesn't exist at Advance", cDesc.info]; <> $partyAlreadyActive => NULL; --
Deal with $canActivate here some time ENDCASE => AssessDamage[nb, cDesc, convEvent]; EXIT; ENDLOOP; }; DoRejectCall: INTERNAL PROC[cDesc: ConvDesc, convEvent: ConvEvent] = { []_ChangeState[cDesc, $idle, $busy]; }; <> <> <<>> NoteNewState: PUBLIC INTERNAL PROC[cDesc: ConvDesc, convEvent: ConvEvent] ~ { OPEN now: cDesc.situation.self; nb: NB; larkStateData: LORA _NIL; state: StateInConv _ convEvent.self.state; previousState: StateInConv = cDesc.situation.self.state; savedCurrentConvID: ConversationID; <> cDesc.situation _ convEvent^; IF state = previousState THEN RETURN; -- No conceivable value in acting. IF cDesc.info.currentConvID=nullConvID THEN cDesc.info.currentConvID _ cDesc.situation.self.convID; <> <<
We're going to have to learn to deal with multiple conversations. Soon. Right now they sail right through under some circumstances. See Poachnotes.>> savedCurrentConvID _ cDesc.info.currentConvID; -- ForgetConv might clear it. IF ~ThSmartsPrivate.LarkAvailable[cDesc.info] THEN <<
Crowbar when back door is not available. Our workstation representative probably launched the call. Called party may hear brief ring in this instance.>> SELECT state FROM $idle, $neverWas => NULL; ENDCASE => { DoRejectCall[cDesc, convEvent]; RETURN; }; SELECT state FROM $notified => { -- Somebody else did the notifying. We have to respond. <<
This is the only time a change in our own state has to be reacted to? Still queued up because otherwise the state-management is confusing. >> cDesc.info.requests.QueueClientAction[QdNotification, cDesc]; }; $ringing, $ringback => larkStateData _ LIST[SetupRingTunes[cDesc]]; $idle, $neverWas => ForgetConv[cDesc]; $active => { value: ROPE; dbAtom: ATOM; larkStateData _ LIST[ComputeConnection[cDesc]]; [, dbAtom, value] _ DBInfo[now.partyID, $audiosource]; larkStateData _ CONS[NEW[Atom.DottedPairNode_[$audioSource, VoiceUtils.MakeAtom[value]]], larkStateData]; --[[$audioSource,audioSource],...] value _ DBInfo[now.partyID, $transmitonly, dbAtom].value; larkStateData _ CONS[NEW[Atom.DottedPairNode_[$transmitOnly, VoiceUtils.MakeAtom[value]]], larkStateData]; }; ENDCASE; IF state > Thrush.notReallyInConv AND cDesc.keyTable=NIL THEN { <> [nb, cDesc.keyTable] _ ThParty.GetKeyTable[credentials: now]; IF nb # $success THEN cDesc.keyTable_NIL; }; IF state> Thrush.notReallyInConv AND cDesc.keyTable#cDesc.info.larkInfo.keyTable AND cDesc.keyTable#NIL THEN larkStateData _ CONS[cDesc.keyTable, larkStateData]; IF now.convID = savedCurrentConvID THEN SetLarkState[cDesc, larkStateData]; <> }; CheckRing: PUBLIC INTERNAL PROC [cDesc: ConvDesc] ~ { nb: NB; cInfo: ThParty.ConversationInfo; [nb, cInfo] _ ThParty.GetConversationInfo[convID: cDesc.situation.self.convID]; IF nb # $success THEN { []_ChangeState[cDesc, $failed, $error, "System Error: can't monitor ringing situation"]; RETURN; }; IF cDesc.ringCheckProcess#NIL OR -- Already handling cInfo.numActive = 0 THEN RETURN; -- Not in the interesting situation yet. <> TRUSTED { Process.Detach[FORK RingProcess[cDesc]]; }; }; RingProcess: ENTRY PROC[cDesc: ConvDesc] = { ENABLE UNWIND => { cDesc.ringCheckProcess _ NIL; }; numWaited: INT_0; numToWait: INT_0; condition: CONDITION; TRUSTED { Process.SetTimeout[@condition, Process.SecondsToTicks[1]]; }; WHILE TRUE DO value: ROPE_NIL; valueAtom: ATOM; IF cDesc.situation.self.state # $ringing THEN EXIT; value _ DBInfo[cDesc.situation.self.partyID, $multiring].value; valueAtom _ VoiceUtils.MakeAtom[value]; SELECT TRUE FROM valueAtom=NIL, value.Length[]=0, valueAtom=$false => numToWait_numWaited; -- quit valueAtom=$true => { numToWait_numWaited+1; }; -- forever value.Fetch[0] IN ['0..'9] => numToWait_Convert.IntFromRope[value]; ENDCASE => numToWait _ numWaited; -- invalid database IF numWaited >= numToWait THEN GOTO Idle; WAIT condition; numWaited _ numWaited+1; REPEAT Idle => []_ChangeState[cDesc, $idle]; -- We're a third wheel. ENDLOOP; cDesc.ringCheckProcess _ NIL; }; AssessDamage: PUBLIC INTERNAL PROC [nb: NB, cDesc: ConvDesc, convEvent: ConvEvent] ~ { <<
nb # $success after a call to ThParty. It was also not one of the failures that one expects in normal discourse. Decide how bad it is.>> <> }; <<>> <> ChangeState: PUBLIC INTERNAL PROC[ cDesc: ConvDesc, state: StateInConv _ $idle, reason: Thrush.Reason _ NIL, -- $wontSay comment: ROPE_NIL ] RETURNS [nb: NB] = { convRequest: ThSmartsPrivate.ConvRequest; IF cDesc = NIL THEN RETURN; IF state=$failed AND cDesc.info.larkInfo.textToSpeech THEN state _ $idle; <> convRequest _ NEW[ThSmartsPrivate.ConvRequestBody _ [cDesc: cDesc]]; convRequest.desiredSituation.self.state _ state; convRequest.desiredSituation.reason _ reason; convRequest.desiredSituation.comment _ comment; nb _ DoAdvance[convRequest]; }; GetConv: PUBLIC INTERNAL PROC[info: SmartsInfo, convID: ConversationID, createOK: BOOL_FALSE ] RETURNS [ cDesc: ConvDesc_NIL ] = --INLINE-- { FOR convs: OpenConversations _ info.conversations, convs.rest WHILE convs#NIL DO IF convs.first.situation.self.convID = convID THEN RETURN[convs.first]; ENDLOOP; IF ~createOK THEN RETURN; cDesc _ NEW[ThSmartsPrivate.ConvDescBody_[]]; cDesc.situation.self _ [ convID: convID, smartsID: info.smartsID, partyID: ThPartyPrivate.GetCurrentParty[smartsID: info.smartsID].partyID ]; --
nb check? cDesc.info _ info; info.conversations _ CONS[cDesc, info.conversations]; IF pd.doReports THEN ReportFR[" ** NewConv %t %g\n", info, time[convID], TU.RefAddr[info] ]; }; ForgetConv: PUBLIC INTERNAL PROC[cDesc: ConvDesc] = { <> info: SmartsInfo = cDesc.info; IF cDesc.situation.self.convID = info.currentConvID THEN info.currentConvID _ nullConvID; info.conversations _ NARROW[GList.DRemove[cDesc, info.conversations]]; }; ComputeConnection: PUBLIC INTERNAL PROC[cDesc: ConvDesc] RETURNS [pInfo: ThParty.PartyInfo _ NIL] = { <> <> <> <> <> <> nb: NB; [nb, pInfo] _ ThParty.GetPartyInfo[credentials: cDesc.situation.self, nameReq: $none, allParties: TRUE]; IF nb # $success OR pInfo[0].partyID=0 THEN { Problem["No conversation info, or incomplete", cDesc.info]; pInfo_NIL; RETURN; }; -- This is really bad! }; <<>> <> GetSmartsInfo: PUBLIC PROC[smartsID: SmartsID] RETURNS [info: SmartsInfo_NIL] = { sd: REF _ RefID.Unseal[smartsID]; IF sd#NIL THEN RETURN[NARROW[Triples.Select[$SmartsData, sd, --info--]]]; }; DBInfo: PUBLIC PROC[partyID: Thrush.PartyID, attribute: ATOM_NIL, prevDbAtom: ATOM_NIL] RETURNS [dbRname: ROPE_NIL, dbAtom: ATOM_NIL, value: ROPE_NIL] = { nb: NB _ $success; rName: ROPE; dbAtom _ prevDbAtom; IF dbAtom#NIL THEN rName _ Atom.GetPName[dbAtom] ELSE IF partyID#nullID THEN [nb, rName] _ ThParty.DescribeParty[partyID: partyID, nameReq: $current]; IF nb # $success OR rName=NIL THEN RETURN; dbRname _ rName.Concat[pd.larkRegistry]; IF dbAtom=NIL THEN dbAtom _ VoiceUtils.MakeAtom[rName: rName, case: FALSE]; IF attribute#NIL THEN value _ NamesGV.GVGetAttribute[dbRname, attribute, NIL]; }; Problem: PROC[comment: ROPE, info: SmartsInfo] = { VoiceUtils.ProblemFR[Rope.Concat["LarkSmarts(%g): ", comment], $Smarts, info, TU.RefAddr[info]]; }; Report: PROC[what: ROPE, info: SmartsInfo] = { IF NOT pd.doReports THEN RETURN; VoiceUtils.Report[what, $Lark, info.larkInfo]; }; ReportFR: PROC[what: ROPE, info: SmartsInfo, a1, a2, a3: IO.Value_rope[NIL]] = { IF NOT pd.doReports THEN RETURN; VoiceUtils.ReportFR[what, $Lark, info.larkInfo, a1, a2, a3]; }; BeNice: PROC[r: REF, d: INT, info: SmartsInfo] = { IF NOT pd.doNice THEN RETURN; Nice.BeNice[r, d, $Lark, info.larkInfo]; }; <> <<>> ringTunes: RefTab.Ref_RefTab.Create[59]; ringTone: LarkPlay.ToneSpec _ NIL; subduedRingTone: LarkPlay.ToneSpec _ NIL; outsideRingTone: LarkPlay.ToneSpec _ NIL; outsideRingTune: PUBLIC LarkPlay.ToneSpec _ NIL; outsideRingTuneRope: ROPE _ "@300;G%>G<%G%>G<%G%>G<%G%>G<%G%>*C"; ringTuneDelay: NAT _ 2400; -- ms. delay between tune starts. SetupRingTunes: PROC[cDesc: ConvDesc] RETURNS [toneSpec: LarkPlay.ToneSpec] = { OPEN self: cDesc.situation.self; partyID: Thrush.PartyID = self.partyID; dbName: ROPE; originatingPartyID: Thrush.PartyID_nullID; otherDbName: ROPE; otherTune: LarkPlay.ToneSpec_NIL; otherType: Thrush.PartyType_$service; -- default value: not telephone, individual, trunk defaultSpec: LarkPlay.ToneSpec; -- outside or inside ringing nb: NB; pInfo: ThParty.PartyInfo; divisor: NAT _ 1; rope: ROPE; now: BasicTime.GMT = BasicTime.Now[]; ringMode: ATOM; ringDo: ATOM; IF ThNet.pd.ringsInvalid THEN MakeDefaultRingTunes[]; IF self.state=$ringing THEN originatingPartyID _ ThParty.GetConversationInfo[convID: self.convID].cInfo.originator; [nb, pInfo] _ ThParty.GetPartyInfo[credentials: [convID: self.convID, partyID: partyID], allParties: TRUE, nameReq: $current]; IF pInfo.numParties=0 THEN RETURN[ringTone]; -- no parties? dbName _ pInfo[0].intendedName.Concat[pd.larkRegistry]; -- self FOR i: NAT IN [1..pInfo.numParties) DO SELECT self.state FROM <> ringback => SELECT pInfo[i].state FROM ringing, notified => { toneSpec _ GetRingTune[pInfo[i].intendedName.Concat[pd.larkRegistry]]; IF toneSpec=NIL THEN RETURN[ringTone]; toneSpec _ NEW[LarkPlay.ToneSpecRec _ toneSpec^]; toneSpec.volume _ ThNet.pd.tonesVolume+2; toneSpec.repeatIndefinitely _ TRUE; RETURN; }; ENDCASE; <> ringing => IF pInfo[i].partyID = originatingPartyID THEN { otherType _ pInfo[i].type; otherDbName _ pInfo[i].intendedName.Concat[pd.larkRegistry]; EXIT; }; ENDCASE=>ERROR; ENDLOOP; IF self.state= ringback THEN RETURN[ringTone]; -- Didn't find another party above. <<>> <> defaultSpec _ SELECT otherType FROM $trunk => outsideRingTone, ENDCASE => ringTone; rope _ NamesGV.GVGetAttribute[dbName, $ringmode, NIL]; ringMode _ IF rope=NIL THEN $r ELSE VoiceUtils.MakeAtom[rName: rope, case: FALSE]; SELECT ringMode FROM -- $o, $s, $r $o => RETURN[NIL]; $s => RETURN[subduedRingTone]; $r => NULL; -- largest case continues below ENDCASE => RETURN[defaultSpec]; -- unknown case; act vanilla <<>> <> rope _ NamesGV.GVGetAttribute[dbName, $dotune, NIL]; ringDo _ IF rope=NIL THEN $standard ELSE VoiceUtils.MakeAtom[rName: rope, case: FALSE]; SELECT ringDo FROM $false, $standard => RETURN[defaultSpec]; $both => { SELECT otherType FROM $individual, $telephone => { divisor _ 2; rope _ NamesGV.GVGetAttribute[otherDbName, $dotune, NIL]; ringDo _ IF rope=NIL THEN $standard ELSE VoiceUtils.MakeAtom[rName: rope, case: FALSE]; IF ringDo=$both THEN otherTune _ GetRingTune[otherDbName]; <> }; $trunk => otherTune _ outsideRingTune; ENDCASE; }; $true, $tune => NULL; -- continue below ENDCASE => RETURN[defaultSpec]; toneSpec _ GetRingTune[dbName]; IF toneSpec=NIL THEN RETURN[defaultSpec]; IF otherTune#NIL THEN toneSpec _ LarkPlay.MergeToneSpecs[toneSpec, otherTune, divisor, ringTuneDelay]; }; GetRingTune: PROC[name: ROPE] RETURNS [ringTune: LarkPlay.ToneSpec_NIL] = { <> nameAtom: ATOM; ringTuneRope: ROPE; IF name=NIL THEN RETURN; ringTuneRope _ NamesGV.GVGetAttribute[name, $ringtune, NIL]; IF ringTuneRope=NIL THEN RETURN; nameAtom _ VoiceUtils.MakeAtom[name]; ringTune _ NARROW[ringTunes.Fetch[nameAtom].val]; IF ringTune#NIL AND ringTune.asRope=ringTuneRope THEN RETURN; ringTune _ LarkPlay.PlayString[music: ringTuneRope, file: FALSE, volume: ThNet.pd.defaultRingVolume]; []_ringTunes.Store[nameAtom, ringTune] }; MakeDefaultRingTunes: PROC = { ringTone _ NEW[LarkPlay.ToneSpecRec _ [ repeatIndefinitely: TRUE, volume: ThNet.pd.defaultRingVolume, tones: LIST[LIST[ [f1: 440, f2: 480, on: 2000, off: 4000], [f1: 440, f2: 480, on: 2000, off: 4000]]]]]; outsideRingTone _ NEW[LarkPlay.ToneSpecRec _ [ repeatIndefinitely: TRUE, volume: ThNet.pd.defaultRingVolume, tones: LIST[LIST[ [f1: 440, f2: 480, on: 500, off: 500], [f1: 440, f2: 480, on: 500, off: 4500]]]]]; subduedRingTone _ NEW[LarkPlay.ToneSpecRec _ [ repeatIndefinitely: FALSE, volume: ThNet.pd.defaultRingVolume+ThNet.pd.subduedVolumeInterval, tones: LIST[LIST[[f1: 440, f2: 480, on: 500, off: 0]]] ]]; outsideRingTune _ LarkPlay.PlayString[outsideRingTuneRope, FALSE, ThNet.pd.defaultRingVolume]; ThNet.pd.ringsInvalid _ FALSE; }; <> larkStateForState: ARRAY StateInConv OF ThSmartsPrivate.LarkState _ [ <> silence, idle, errorTone, dialTone, silence, silence, silence, ringBack, ringing, <> silence, talking, silence ]; SetLarkState: INTERNAL PROC[cDesc: ConvDesc, data: LORA ] = { larkState: ThSmartsPrivate.LarkState _ larkStateForState[cDesc.situation.self.state]; IF larkState # cDesc.info.larkInfo.larkState THEN SELECT larkState FROM $talking => { <> spec: ThParty.PartyInfo; FOR dL: LORA _ data, dL.rest WHILE dL#NIL DO WITH dL.first SELECT FROM pI: ThParty.PartyInfo => spec _ pI; ENDCASE; ENDLOOP; IF spec=NIL THEN ERROR; IF spec.numParties=2 AND spec[0].socket.host = spec[1].socket.host THEN <> larkState _ cDesc.info.larkInfo.larkState; -- don't change }; $errorTone => larkState _ SELECT cDesc.situation.reason FROM $busy, $notImportantEnough => $busyTone, $absent, $noCircuits, $noParticular, $notFound, $error => $errorTone, ENDCASE => $errorTone; ENDCASE; ThSmartsPrivate.EnterLarkState[cDesc.info.larkInfo, larkState, data]; }; <> shouldReportToAll: ARRAY StateInConv OF BOOL = [ <> FALSE, TRUE, FALSE, FALSE, FALSE, FALSE, FALSE, FALSE, TRUE, TRUE, TRUE, TRUE ]; WhatNeedsDoing: TYPE = ATOM; -- { <> <<$noop, $idle, $idlerg, $actv, $rback, $reac, $deac, $ckrg, $frgt, -- cases explained in code>> <<$invl, -- considered an invalid request>> <<$xrep, -- we got a report we feel we shouldn't have got>> <<$ntiy, -- not implemented yet>> <<$imp -- this situation should not arise even in the face of invalid requests>> <<};>> whatNeedsDoingIf: ARRAY StateInConv OF ARRAY StateInConv OF WhatNeedsDoing _ [ <> <<>> << never idle failed resrv pars init notif rback ring canAc activ inact -- _ (other)>> [ $imp, $frgt, $frgt, $frgt, $frgt, $frgt, $frgt, $frgt, $frgt, $frgt, $frgt, $frgt], --neverWas <<(Clip this table to view without these comments.)>> <> [ $imp, $noop, $noop, $noop, $noop, $noop, $noop, $noop, $noop, $noop, $noop, $ntiy ], -- idle [ $imp, $noop, $noop, $noop, $noop, $noop, $noop, $noop, $noop, $noop, $noop, $ntiy ], -- failed [ $imp, $imp, $imp, $imp, $imp, $imp, $imp, $imp, $imp, $imp, $imp, $imp ], -- reserved <> [ $imp, $imp, $imp, $imp, $imp, $imp, $imp, $imp, $imp, $imp, $imp, $imp ], -- parsing <> [ $imp, $idle,$noop, $invl, $invl, $invl, $xrep, $xrep,$rback,$actv, $actv, $actv ], -- initiating <> [ $imp, $idlerg,$noop, $invl, $invl, $invl, $xrep, $noop, $noop, $ntiy, $noop, $ntiy ], -- notified <> [ $imp, $idle,$noop,$invl, $invl, $invl, $noop, $xrep, $noop, $ntiy, $actv, $ntiy ], -- ringback <> [ $imp, $idlerg,$noop, $invl, $invl, $invl, $xrep, $xrep, $noop, $ntiy, $ckrg, $ntiy ], -- ringing <> [ $imp, $idle,$noop, $invl, $invl, $invl, $xrep, $xrep, $noop, $ntiy, $ckrg, $ntiy ], -- canActivate [ $imp, $idle,$noop, $invl, $invl, $invl, $xrep, $xrep, $noop, $ntiy, $reac, $deac ], -- active [ $imp, $idle,$invl, $invl, $invl, $invl, $xrep, $xrep, $noop, $ntiy, $ntiy, $ntiy ] -- inactive (current ^) ]; <> ViewCmd: Commander.CommandProc = TRUSTED { Nice.View[pd, "Lark PD"]; }; Commander.Register["VuLarkSmarts", ViewCmd, "Program Management variables for Lark Smarts"]; }. <> <> <> <> < autoAnswer>> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> <> < ID, H => Reseal, Log => VoiceUtils>> <> <> <> <> <<>> <> <> <> <<>> <<>> <<>>