DIRECTORY
Atom USING [ GetPName, MakeAtom ],
Commander	USING [ CommandProc, Register ],
CommandTool USING [ NextArgument ],
ExplicitExport USING [ ExportExplicitly ],
IO,
LupineRuntime USING [ BindingError ],
NamesGV USING [ GVGetAttribute ],
NamesRPC USING [ StartConversation ],
Nice,
RefID USING [ ID, Release, Reseal, Seal ],
Rope USING [ Concat, Cat, Length, Substr ],
RPC USING [ AuthenticateFailed, EncryptionKey, ExportFailed, ImportFailed ],
ThNet USING [ CloseWhitePagesDatabase, HowToDial, InitWhitePagesDatabase, WhitePagesEntry, WPListing, WPState ],
ThParty USING [ Credentials, NameReq, SmartsInterfaceName, SmartsInterfaceRecord, SmartsProperties ],
ThPartyPrivate USING [ PartyBody, PartyData, SmartsBody, SmartsData, UnsealParty, UnsealSmarts ],
ThPartyRpcControl,
ThPartyRpcServerImpl,
ThPartyMonitorImpl,
Thrush USING [
ConversationID, NB, PartyID, PartyType, nullID, Machine, ROPE, SHHH, SmartsID, unencrypted ],
ThSmartsRpcControl USING [ ImportNewInterface ],
ThVersions USING [ ThrushVR ],
Triples USING [ Any, Erase, Item, Make, Select ],
TU USING [ MakeUnique, RefAddr ],
VoiceUtils USING [ CmdOrToken, CurrentPasskey, InstanceFromNetAddress, MakeAtom, Registrize, FindWhere, Problem, RegisterWhereToReport, Report, ReportFR, WhereProc ]
;

ThPartyInitImpl: CEDAR MONITOR LOCKS root
IMPORTS Atom,
IO,
Commander,
CommandTool,
ExplicitExport,
LupineRuntime,
NamesGV,
NamesRPC,
Nice,
root: ThPartyMonitorImpl,
RefID,
Rope,
RPC,
SmartsRpc: ThSmartsRpcControl,
ThNet,
ThPartyPrivate,
ThPartyRpcControl,
ThPartyRpcServerImpl,
ThVersions,
Triples,
TU,
VoiceUtils
EXPORTS ThParty, ThPartyPrivate
SHARES ThPartyMonitorImpl, ThPartyRpcServerImpl = {
OPEN IO;

NB: TYPE = Thrush.NB;
PartyData: TYPE = ThPartyPrivate.PartyData;	-- REF Concrete
PartyID: TYPE = Thrush.PartyID;	-- ID
nullID: PartyID = Thrush.nullID;
ROPE: TYPE = Thrush.ROPE;
SmartsData: TYPE = ThPartyPrivate.SmartsData;	-- REF Concrete
SmartsID: TYPE = Thrush.SmartsID;	-- ID
SHHH: TYPE = Thrush.SHHH;
none: SHHH = Thrush.unencrypted;
Reseal: PROC[r: REF] RETURNS[RefID.ID] = INLINE {RETURN[RefID.Reseal[r]]; };
Any: Triples.Item = Triples.Any;

larkRegistry: ROPE=".Lark";

thPartyExported: BOOL_FALSE;
wpState: ThNet.WPState;


GetParty: PUBLIC ENTRY PROC[shh: SHHH_NIL, partyID: PartyID,
rName: Thrush.ROPE, type: Thrush.PartyType_NIL]
RETURNS [nb: NB, newPartyID: PartyID] = {
ENABLE UNWIND=>NULL;
newParty: PartyData;
[nb, newParty] _ GetActiveParty[partyID, rName, type];
newPartyID _ Reseal[newParty];
};

GetPartyFromFeepNum: PUBLIC ENTRY PROC[
shh: SHHH_none, partyID: PartyID, feepNum: Thrush.ROPE_NIL]
RETURNS [nb: NB_$success, newPartyID: PartyID_nullID] = {
ENABLE UNWIND=>NULL;
party: PartyData _ NIL;
rName: ROPE;
rName _ ThNet.WhitePagesEntry [
wpState: wpState, name: feepNum, feep: TRUE, key: $officeNumber].fullRName;
IF rName=NIL THEN RETURN[nb: $noEntryFound];
[nb, party] _ GetActiveParty[partyID, rName, NIL];
newPartyID _ Reseal[party];
};

GetPartyFromNumber: PUBLIC ENTRY PROC[
shh: SHHH, partyID: PartyID, phoneNumber: Thrush.ROPE,
description: ROPE]
RETURNS [nb: NB, newPartyID: PartyID] = {
ENABLE UNWIND => NULL;
[nb, newPartyID] _ GetPartyFromNumberInt[partyID, phoneNumber, description, FALSE];
};

GetNumbersForRName: PUBLIC PROC[shh: SHHH_none, rName: Thrush.ROPE]
RETURNS [fullRName: ROPE, number: ROPE, homeNumber: ROPE] = {
listing: ThNet.WPListing;
[fullRName, number, listing] _ ThNet.WhitePagesEntry[
wpState: wpState, name: rName, key: $officeNumber];
IF listing#NIL THEN homeNumber _ ThNet.WhitePagesEntry[
wpState: wpState, key: $outsideNumber, listing: listing].entry;
};
GetRname: PUBLIC PROC[shh: SHHH_none, partyID: PartyID] 
RETURNS [nb: NB, Rname: Thrush.ROPE_NIL] = {
[nb, Rname,] _ GetRnameFromParty[ThPartyPrivate.UnsealParty[partyID]];
};

GetActiveParty: INTERNAL PROC[partyID: PartyID, rName: Thrush.ROPE,
type: Thrush.PartyType]
RETURNS [nb: NB_$success, newParty: PartyData_NIL] = {
number: ROPE;
listing: ThNet.WPListing;
wpRname: ROPE;
IF rName=NIL THEN RETURN[$noIdentSupplied, NIL];
IF type = NIL THEN { -- request for $individual or $telephone
[nb, newParty] _ GetActiveParty[partyID, rName, $individual];
IF nb # $success THEN [nb, newParty] _ GetActiveParty[partyID, rName, $telephone];
RETURN;
};
SELECT type FROM
$service => { [nb, newParty] _ GetIdleParty[partyID, rName]; RETURN; };
$individual, $telephone => NULL; -- go on
$trunk => ERROR; -- until further notice
ENDCASE => ERROR;
newParty _ NARROW[
Triples.Select[type, VoiceUtils.MakeAtom[VoiceUtils.Registrize[rName]], --party-- ] ];
IF newParty#NIL AND newParty.enabled THEN { SetPoaching[newParty]; RETURN; };
IF type # $telephone THEN RETURN[nb: $noSuchParty2];
[wpRname, number, listing] _ ThNet.WhitePagesEntry [
wpState: wpState, name: rName, key: $officeNumber];
IF wpRname=NIL OR listing=NIL THEN RETURN[nb: $noSuchParty2];
IF number=NIL THEN number _ ThNet.WhitePagesEntry [
wpState: wpState, name: rName, key: $homeNumber, listing: listing].entry;
IF number=NIL THEN RETURN[nb: $noSuchParty2];
[nb, partyID] _ GetPartyFromNumberInt[partyID, number, rName, TRUE];
IF nb=$success THEN newParty _ ThPartyPrivate.UnsealParty[partyID];
};

GetIdleParty: INTERNAL PROC[partyID: PartyID, serviceName: ROPE]
RETURNS [nb: NB_$success, newParty: PartyData _ NIL] = {
ENABLE UNWIND=>NULL;
party: PartyData_ ThPartyPrivate.UnsealParty[partyID];
myName: ROPE;
rAtom: ATOM;
serviceNameAtom: ATOM = MakeServiceRname[serviceName].serviceRnameAtom;
IF party = NIL THEN RETURN[nb: $noSuchParty];
[nb, myName,] _ GetRnameFromParty[party];
IF nb # $success THEN RETURN[nb: nb, newParty: NIL];
rAtom _ VoiceUtils.MakeAtom[Rope.Cat[myName, ".", serviceName]];
newParty _ NARROW[Triples.Select[$service, serviceNameAtom, --party--]];
IF newParty = NIL OR ~newParty.enabled THEN nb_$noSuchParty2 -- e.g., all channels busy
ELSE TU.MakeUnique[$service, rAtom, newParty]; -- $service[$"myself.pa.t..."] = <party>
};

GetPartyFromNumberInt: INTERNAL PROC[
partyID: PartyID, phoneNumber: Thrush.ROPE,
description: ROPE, trunkRequired: BOOL]
RETURNS [nb: NB_$success, newPartyID: PartyID_nullID] = {
isExt: BOOLEAN _ FALSE;
num: ROPE _ NIL;
party: PartyData _ ThPartyPrivate.UnsealParty[partyID];
trunkParty: PartyData;
myExtAtom: ATOM;
myExt: ROPE;
IF party=NIL THEN RETURN[$noSuchParty, nullID];
myExtAtom _ GetRnameFromParty[party, $current].rAtom; -- rName for party.
myExtAtom _  IF myExtAtom=NIL THEN NIL
ELSE NARROW[Triples.Select[$Extension, myExtAtom, -- extension --]];
myExt _ IF myExtAtom=NIL THEN NIL ELSE Atom.GetPName[myExtAtom];
[num, isExt] _ ThNet.HowToDial[phoneNumber, myExt];
IF isExt AND ~trunkRequired THEN {
atom: ATOM_Atom.MakeAtom[num]; -- phone extension
IF atom #NIL THEN atom _ NARROW[Triples.Select[$Extension, --party--, atom]];
IF atom#NIL THEN {
newParty: PartyData;
[nb, newParty]_ GetActiveParty[partyID, Atom.GetPName[atom], NIL];
IF nb=$success THEN RETURN[newPartyID: Reseal[newParty]];
};
};
[nb, trunkParty] _ GetRelatedParty[party]; -- trunk if telephone/individual, or vice/versa
IF nb # $success THEN {
party _ NARROW[Triples.Select[$Poaching, party, -- poachee--]];
IF party#NIL THEN [nb, trunkParty] _ GetRelatedParty[party];
};
IF nb # $success THEN RETURN;
trunkParty.outgoing _ num;
trunkParty.reservedBy _ partyID;
trunkParty.name _ description; -- starts out as name of trunk owner, changes on first use
newPartyID _ Reseal[trunkParty];
};

GetRelatedParty: INTERNAL PROC[party: PartyData]
RETURNS [nb: NB, relatedParty: PartyData_NIL] = {
rAtom: ATOM;
[nb,,rAtom]_GetRnameFromParty[party];
IF nb # $success THEN RETURN; -- VERY strange
SELECT party.type FROM
$individual, $telephone =>
relatedParty _ NARROW[Triples.Select[$trunk, rAtom, -- trunk party --]];
ENDCASE; -- 
$trunk case will be added as needed for incoming calls.
IF relatedParty = NIL THEN nb _ $noTrunkParty
ELSE IF relatedParty.numConvs#0 THEN nb _ $convStillActive -- busy
ELSE IF ~relatedParty.enabled THEN nb _ $noSuchParty2; -- not available yet
IF nb # $success THEN relatedParty _ NIL;
};

Register: PUBLIC PROC[
shh: SHHH_none,
rName: ROPE_NIL, -- party identification
type: Thrush.PartyType _ $individual,
clonePartyID: PartyID,
interface: ThParty.SmartsInterfaceName, -- interface
properties: ThParty.SmartsProperties
] RETURNS [
nb: NB, credentials: ThParty.Credentials_[] ] = {
[nb, credentials] _ DoRegister[rName, type, clonePartyID, interface, NIL, properties];
};

RegisterLocal: PUBLIC PROC[
shh: SHHH_none,
rName: ROPE_NIL, -- party identification
type: Thrush.PartyType _ $individual,
clonePartyID: PartyID,
interfaceRecord: ThParty.SmartsInterfaceRecord _ NIL,
properties: ThParty.SmartsProperties
] RETURNS [
nb: NB, credentials: ThParty.Credentials_[] ] = {
[nb, credentials] _ DoRegister[rName, type, clonePartyID, [ ], interfaceRecord, properties];
};

DoRegister: PROC[
rName: ROPE_NIL, -- party identification
type: Thrush.PartyType _ $individual,
clonePartyID: PartyID,
interface: ThParty.SmartsInterfaceName, -- interface
interfaceRecord: ThParty.SmartsInterfaceRecord,
properties: ThParty.SmartsProperties
] RETURNS [
nb: NB, credentials: ThParty.Credentials_[] ] = {
hostAtom: ATOM = VoiceUtils.MakeAtom[
VoiceUtils.InstanceFromNetAddress[properties.machine, Atom.GetPName[type]]];
smarts: SmartsData_NARROW[Triples.Select[$SmartsForHost, hostAtom, -- smarts --]];
party: PartyData;
partyToSmartsShh: SHHH _ none;
IF clonePartyID#nullID THEN [nb, credentials] _ RegisterClone[clonePartyID];
IF smarts#NIL THEN {
nb_Deregister[none, Reseal[smarts]];
IF nb # $success THEN RETURN;
};
IF rName=NIL THEN RETURN[nb: $noIdentSupplied];
IF interfaceRecord=NIL THEN {
partyToSmartsShh _ NamesRPC.StartConversation[
caller: serverInterfaceName.instance,
callee: rName,
key: serverPassword,
level: --<<ECB>>--CBCCheck ! RPC.AuthenticateFailed =>
{ VoiceUtils.Problem["Authenticate failed", $System]; CONTINUE}];
IF partyToSmartsShh=NIL THEN RETURN[nb: $couldntAuthenticate];
interfaceRecord _ SmartsRpc.ImportNewInterface[
interfaceName: interface ! RPC.ImportFailed =>
{ VoiceUtils.Problem["Import failed", $System]; CONTINUE}];
IF interfaceRecord=NIL THEN RETURN[nb: $couldntConnect];
};
{ RegisterEntry: ENTRY PROC={
[nb, party] _ CreateParty[rName, type];
IF nb#$success THEN RETURN;
smarts_NEW[ThPartyPrivate.SmartsBody_[
properties: properties, 
type: type,
interface: interfaceRecord,
shh: partyToSmartsShh
]];
TU.MakeUnique[$Smarts, party, smarts];
TU.MakeUnique[$SmartsForHost, hostAtom, smarts];
credentials.partyID _ RefID.Reseal[party];
credentials.smartsID _ RefID.Seal[smarts];
SetPoaching[party];  -- This is recomputed on every GetParty, included here for debugging ease.
}; RegisterEntry[]; };
VoiceUtils.Report[IO.PutFR["Register[%g, %g, %g] -> [%g, %g]",
rope[rName], atom[type], TU.RefAddr[ThPartyPrivate.UnsealParty[clonePartyID]],
TU.RefAddr[party], TU.RefAddr[smarts]]];
};

CreateParty: INTERNAL PROC[rName: Thrush.ROPE, type: Thrush.PartyType]
RETURNS [nb: NB_$success, party: PartyData_NIL] = {
partyRname: Thrush.ROPE = IF type # $service THEN rName ELSE MakeServiceRname[rName].serviceRname;
partyID: PartyID_nullID;
rAtom: ATOM=VoiceUtils.MakeAtom[partyRname];
extension: ATOM_NIL;
IF partyRname=NIL THEN RETURN[nb: $noIdentSupplied];
IF type # $service THEN party_ NARROW[Triples.Select[type, rAtom, --party--]];
IF party#NIL THEN RETURN[$success, party];
party _ NEW[ThPartyPrivate.PartyBody _ [type: type, name: rName]];
SELECT type FROM
$individual, $telephone, $service => { -- Local telephone number
num: ROPE_GetNumbersForRName[rName: partyRname].number;
party.outgoing _ num;
IF num#NIL AND ~(([num,]_ThNet.HowToDial[num]).isLocalExtension) THEN num_NIL;
IF num#NIL THEN extension _ VoiceUtils.MakeAtom[num];
};
ENDCASE;
partyID _ RefID.Seal[party];
TU.MakeUnique[type, rAtom, party];
IF extension#NIL THEN TU.MakeUnique[$Extension, rAtom, extension];
};

SetPoaching: INTERNAL PROC[party: PartyData, callingParty: PartyData_NIL] = {
poacher, poachee: PartyData_NIL;
rName: ROPE _ party.name;
smarts: REF;
workstation: ATOM;
wsName: ROPE;
nb: NB;
{SELECT party.type FROM
$individual => {
poacheeID: PartyID;
poacher_party;
IF (smarts _ Triples.Select[$Smarts, poacher, -- smarts --]) = NIL THEN {
VoiceUtils.Problem["No smarts connection?"]; RETURN; };
IF (workstation _ NARROW[Triples.Select[$SmartsForHost,-- host--,smarts]]) = NIL THEN {
VoiceUtils.Problem["No SmartsForHost?"]; RETURN; };
wsName _ Atom.GetPName[workstation]; -- $"3#456#individual" =>
wsName _ wsName.Substr[len: wsName.Length[]-Rope.Length["individual"]];
wsName _ wsName.Concat[larkRegistry]; 		-- "3#456#.lark"
IF (rName _ NamesGV.GVGetAttribute[wsName, $owner, NIL]) = NIL THEN RETURN;
poachee _ NARROW[Triples.Select[$telephone, VoiceUtils.MakeAtom[rName], --party--]];
IF poachee#NIL THEN GOTO Done ELSE IF callingParty=NIL THEN RETURN;
IF party.outgoing = NIL THEN RETURN; -- 
No phone number?
[nb, poacheeID] _ GetPartyFromNumberInt[
partyID: Reseal[callingParty],
phoneNumber: party.outgoing,
description: rName,
trunkRequired: TRUE
];
IF nb#$success OR poacheeID=nullID THEN RETURN;
poachee _ ThPartyPrivate.UnsealParty[poacheeID];
};
$telephone => {
wsRope: ROPE _
NamesGV.GVGetAttribute[rName.Concat[larkRegistry], $workstationhost, NIL];
workstation _ VoiceUtils.MakeAtom[wsRope.Concat["individual"]];
IF workstation = NIL THEN RETURN;
poachee_party;
IF (smarts _ Triples.Select[$SmartsForHost, workstation,-- smarts--])= NIL THEN RETURN;
poacher _ NARROW[Triples.Select[$Smarts, -- party --, smarts]];
IF poacher = NIL THEN { VoiceUtils.Problem["No smarts connection?"]; RETURN; };
};
ENDCASE=>RETURN;
EXITS Done => NULL; };
Triples.Erase[$Poaching, Any, poachee];
Triples.Erase[$Poaching, poacher, Any];
Triples.Make[$Poaching, poacher, poachee];
};

RegisterClone: ENTRY PROC[clonePartyID: PartyID]
RETURNS [nb: NB, credentials: ThParty.Credentials_[]] = {
cloneParty: PartyData_ThPartyPrivate.UnsealParty[clonePartyID];
party: PartyData _
NEW[ThPartyPrivate.PartyBody _ [type: cloneParty.type, name: cloneParty.name]];
cloneSmarts, smarts: SmartsData;
IF cloneParty=NIL THEN RETURN[nb: $noSuchParty];
cloneSmarts _ NARROW[Triples.Select[$Smarts, cloneParty, -- Smarts --]];
IF cloneSmarts=NIL THEN {
VoiceUtils.Problem["No Smarts for party?"]; RETURN[nb: $noSuchSmarts]; };
smarts_NEW[ ThPartyPrivate.SmartsBody _ [
properties: cloneSmarts.properties, 
type: cloneSmarts.type,
interface: cloneSmarts.interface,
shh: cloneSmarts.shh
]];
Triples.Make[$Smarts, party, smarts];
credentials.partyID _ RefID.Seal[party];
credentials.smartsID _ RefID.Seal[smarts];
VoiceUtils.Report[IO.PutFR["RegisterClone[%g, %g] -> [%g, %g]",
TU.RefAddr[party], TU.RefAddr[cloneParty], card[credentials.smartsID], TU.RefAddr[smarts]    ],  $Party, party];
};

Enable: PUBLIC ENTRY PROC[shh: SHHH_none, smartsID: SmartsID]
RETURNS [nb: Thrush.NB] = { RETURN[Able[smartsID, TRUE]]; };
Disable: PUBLIC ENTRY PROC[shh: SHHH_none, smartsID: SmartsID]
RETURNS [nb: Thrush.NB] = { RETURN[Able[smartsID, FALSE]]; };

Able: INTERNAL PROC[smartsID: SmartsID, enabling: BOOL]
RETURNS[nb: Thrush.NB_$success] = {
smarts: SmartsData=ThPartyPrivate.UnsealSmarts[smartsID];
party: PartyData;
IF smarts=NIL THEN RETURN[$noSuchSmarts];
IF (party_NARROW[Triples.Select[$Smarts, --party--, smarts]])=NIL
THEN RETURN[$noSuchParty];
party.enabled_ smarts.enablesParty_ enabling;
};

Deregister: PUBLIC ENTRY PROC[shh: SHHH, smartsID: SmartsID]
RETURNS [nb: NB _ $success] = {
ENABLE UNWIND => NULL;
party: PartyData;
smarts: SmartsData _ ThPartyPrivate.UnsealSmarts[smartsID];
IF smarts=NIL THEN RETURN[$noSuchSmarts];
party _ NARROW[Triples.Select[$Smarts, --party--, smarts]];
IF party#NIL THEN {
IdleConversationsForParty[party];
EraseAsObj[party,
LIST[ $Smarts, $AssumedParty, $AuthenticatedParty, $TrunkParty, $Poaching ] ];
Triples.Erase[$Poaching, Any, party];
VoiceUtils.ReportFR[
"DeleteParty[%g, %g]", $System, NIL, card[Reseal[party]], TU.RefAddr[party]];
IF ~RefID.Release[Reseal[party]] THEN nb _ $noSuchParty; -- ??
}
ELSE nb _ $noSuchParty;
Triples.Erase[$SmartsForHost, Any, smarts];
smarts.failed _ TRUE;
VoiceUtils.ReportFR[
"UnregisterSmarts[%g, %g]", $System, NIL, card[smartsID], TU.RefAddr[smarts]];
IF ~RefID.Release[smartsID] THEN ERROR; -- Having successfully dehandled above!
};

IdleConversationsForParty: INTERNAL PROC[party: PartyData] = {
};

DescribeParty: PUBLIC PROC[partyID: Thrush.PartyID, nameReq: ThParty.NameReq]
RETURNS[nb: NB, description: Thrush.ROPE] = {
a: ATOM;
[nb, description, a] _ GetRnameFromParty[ThPartyPrivate.UnsealParty[partyID], nameReq];
};

DoDescribeParty: PUBLIC PROC[ party: PartyData, nameReq: ThParty.NameReq ]
RETURNS[ description: Thrush.ROPE_NIL] = {
type: Thrush.PartyType _ party.type;
DescribeTrunk: PROC RETURNS[des: ROPE] = INLINE {
more: ROPE=IF party.outgoing#NIL THEN party.outgoing ELSE "outside line";
des _ IF description=NIL THEN more
ELSE IO.PutFR["%s (%s)", IO.rope[description], IO.rope[more]];
};
Sel: PROC[type: Thrush.PartyType, party: PartyData] RETURNS [name: Thrush.ROPE] = {
a: ATOM _ NARROW[Triples.Select[$trunk, -- owner --, party]];
RETURN[IF a=NIL THEN NIL ELSE Atom.GetPName[a]];
};
IF nameReq=$none THEN RETURN;
description _ SELECT type FROM
$individual, $telephone => party.name,
$trunk => (SELECT nameReq FROM
$owner => Sel[$trunk, party],
$description => DescribeTrunk[],
$current => party.name,
$address => party.outgoing,
ENDCASE=>ERROR),
$service => (SELECT nameReq FROM
$owner => party.name.Concat[larkRegistry],
$description => IO.PutFR["%g service", rope[party.name]],
$current, $address => Sel[$service, party],
ENDCASE=>ERROR),
ENDCASE => ERROR;
};
GetRnameFromParty: PROC[party: PartyData, nameReq: ThParty.NameReq_$current]
RETURNS [nb: NB_$success, rName: Thrush.ROPE_NIL, rAtom: ATOM_NIL] = {
IF party=NIL THEN RETURN[nb: $noSuchParty];
rName _ DoDescribeParty[party, nameReq];
IF rName=NIL THEN nb _ $noNameAvailable
ELSE rAtom _ VoiceUtils.MakeAtom[rName];
};

MakeServiceRname: PUBLIC PROC[serviceName: Thrush.ROPE]
RETURNS [serviceRname: Thrush.ROPE, serviceRnameAtom: ATOM] = {
serviceRname _ Rope.Cat[serviceName, larkRegistry];
serviceRnameAtom _ VoiceUtils.MakeAtom[serviceRname];
};

GetCurrentParty: PUBLIC ENTRY PROC[shh: Thrush.SHHH_none, smartsID: Thrush.SmartsID]
RETURNS [nb: NB_$success, partyID: Thrush.PartyID_Thrush.nullID] = {
smarts: REF _ ThPartyPrivate.UnsealSmarts[smartsID];
party: PartyData;
p: PartyData;
IF smarts=NIL THEN RETURN[nb: $noSuchSmarts];
party _ NARROW[Triples.Select[$Smarts, --party--, smarts]];
IF party#NIL AND ~party.enabled THEN RETURN[nb: $noSuchParty];
IF party=NIL THEN { VoiceUtils.Problem["No party?"]; RETURN[nb: $noSuchParty]; };
SetPoaching[party]; -- make sure $Poaching link is correct
IF (p_NARROW[Triples.Select[$Poaching, -- poacher --, party]])#NIL
AND p.enabled THEN party _ p;
partyID _ Reseal[party];
};

EraseAsObj: INTERNAL PROC[obj: REF, attributes: LIST OF ATOM] = {
FOR attr: LIST OF ATOM _ attributes, attr.rest WHILE attr#NIL DO
Triples.Erase[attr.first, obj, Any];
ENDLOOP;
};

ReportSystem: VoiceUtils.WhereProc = { s_NIL; };

ReportParty: VoiceUtils.WhereProc = {
party: PartyData = NARROW[whereData];
smarts: SmartsData;
IF party=NIL OR
( smarts _ NARROW[Triples.Select[$VoiceTerminal, party, Any]] ) = NIL THEN RETURN;
SELECT smarts.properties.role FROM
$voiceTerminal => s_Nice.LarkConLogStream[smarts.properties.machine]; ENDCASE;
IF s=NIL OR s=Nice.LarkConLogStream[[[0],[0]]] THEN s_VoiceUtils.FindWhere[$System, NIL];
};

WhitePagesInit: Commander.CommandProc = {
treeName, intExtName: ROPE;
IF wpState#NIL AND ThNet.CloseWhitePagesDatabase[wpState] THEN wpState_NIL;
treeName _ CommandTool.NextArgument[cmd];
intExtName _ CommandTool.NextArgument[cmd];
IF wpState=NIL THEN wpState _ ThNet.InitWhitePagesDatabase[
treeName, -- Optional, defaults supplied by WP impl.,
intExtName, --  so NILs are OK here
$write];
};

serverInterfaceName: ThPartyRpcControl.InterfaceName;
serverPassword: RPC.EncryptionKey;

ThPartyInit: Commander.CommandProc = {
ENABLE
RPC.ExportFailed => { VoiceUtils.Problem["ThParty export failed", $System]; GOTO Failed; };
serverInterfaceName _ [
type: "ThParty.Lark",
instance: VoiceUtils.CmdOrToken[cmd: cmd, key: "ThrushServerInstance", default: "Morley.Lark"],
version: ThVersions.ThrushVR];
serverPassword _ VoiceUtils.CurrentPasskey[VoiceUtils.CmdOrToken[
cmd: cmd, key: "ThrushServerPassword", default: "MFLFLX"]];
IF thPartyExported THEN RETURN;
VoiceUtils.RegisterWhereToReport[ReportSystem, $System];
VoiceUtils.RegisterWhereToReport[ReportParty, $Party];
ThPartyRpcControl.ExportInterface[
interfaceName: serverInterfaceName,
user: serverInterfaceName.instance,
password: serverPassword];
ExplicitExport.ExportExplicitly["ThParty.Lark", serverInterfaceName.instance, ThVersions.ThrushVR, ThPartyRpcControl.LupineProtocolVersion, ThPartyRpcServerImpl.ServerDispatcher];
VoiceUtils.ReportFR["Export[ThParty.Lark, %s]", $System, NIL, rope[serverInterfaceName.instance]];
thPartyExported _ TRUE;
EXITS
Failed => ThPartyRpcControl.UnexportInterface[!LupineRuntime.BindingError=>CONTINUE];
};

Commander.Register["WhitePages", WhitePagesInit, "WhitePages <TreeName (opt.) <IntExtMapFileName (opt)>> -- Initialize and Open White Pages Database"];
Commander.Register["ThParty", ThPartyInit,
"ThParty <ExportInstance(opt.) <ServerPassword (opt)>> -- Initialize and Export ThParty"];
}.
®ThPartyInitImpl.mesa
Copyright c 1985 by Xerox Corporation.  All rights reserved.
Last modified by D. Swinehart, December 26, 1985 10:51:47 am PST
Definitions	
Functions for obtaining existing parties, or phone numbers

Obtains a $service, $individual, or $telephone party, if available
No active party; try to get a trunk line for that individual
Locates an idle $service party, if available
<<This still needs some work.>>
e.g., $"text-to-speech.lark"
e.g., $"myself.pa"
e.g., $"myself.pa.text-to-speech"
Party description has not yielded a party, so phone number will have to do.  Perhaps the phone number is an extension of an active $individual; if not, try to find an idle outgoing trunk.
myExt is used as Intelnet authorization code.
IF phoneNumber = NIL THEN RETURN[$noIdentSupplied, nullID];
A null phoneNumber is a request for a direct outside line connection.
Get Trunk Party
Making new parties and smartses

Deregister any previous smarts from this machine.  When cloning to produce multiple smarts and parties for a multi-channel service, obviously don't want to do this.
Multi-channel services must deregister explicitly, since this won't handle it.
Includes setting RName access, poaching and visiting designations.
rName is a misnomer; it's the name of a service, without registry, if type is service.
There's no voice path for this individual.  Try to create one using calling party's trunk.
No HostForSmarts entry is made for clones.  What should happen here anyhow?

Deregister Smarts from Party, destroy both

There's but one party per smarts, these days.  When the Smarts goes, so goes the party.  For the most part, we can (after idling all the conversations in which the party participates) merely erase all the interconnections between the party and smarts and other objects, and release their ID's.
$Visiting implementations and hints for implementations are only suggestions, for now.
Transfer $Visitors from authenticated to assumed.
This is now bogus.  Fix it a bit later.
IdleOneConv: Triples.ForeachProc -- [trip: TripleRec]
-- RETURNS [continue: BOOLEAN _ TRUE] --  ={
WITH trip.att SELECT FROM r: ThPartyPrivate.ConvState => cfRef _ r; ENDCASE => RETURN[TRUE];
IF cfRef.event.state=idle THEN RETURN[FALSE];
[] _ ThPartyPrivate.DoAdvance[ 
smartsID: smartsID,
party: party,
conv: NARROW[trip.obj],
cfRef: cfRef,
state: $idle,
reason: $terminating]; -- Idle party in conversation!!
RETURN[FALSE];
};
IdleRelated: Triples.ForeachProc -- [trip: TripleRec]
-- RETURNS [continue: BOOLEAN _ TRUE] --  = { 
IdleConversationsForParty[NARROW[trip.obj]];
};
Idle any conversations in which the party is involved.  Outside loop avoids Foreach/Erase conflicts.
DO
cfRef_NIL;
Foreach[Any, Any, party, IdleOneConv];
IF cfRef = NIL THEN EXIT;
ENDLOOP;
Apply the process recursively to poachers and visitors: if a poacher is in a conversation, the poachee is not recorded as being in the same one; similarly for visitors, at least at present.  But the poachee or visitee is always vital to the conversation's existence, so out it goes.
Triples.Foreach[$Poaching, Any, party, IdleRelated];
Triples.Foreach[$Visiting, Any, party, IdleRelated];
ThPartyPrivate Implementations


Returns (bogus) service name if type = $service
Which party should we be when initiating calls?
Initialization


Log
Swinehart, May 15, 1985 10:24:49 am PDT
Cedar 6.0
changes to: larkRegistry, GetParty, GetActiveParty, GeIdleParty, CreateParty, NewParty
Swinehart, May 16, 1985 9:18:28 am PDT
CommandToolExtras zapped.
Swinehart, May 22, 1985 12:01:41 pm PDT
ServiceName changes
recording => service
Jay => serviceName, to generalize
individual and service treated similarly in places
changes to: GetIdleParty, CreateParty, NewParty, DoDescribeParty, MakeServiceRname
changes to: CreateParty, ExistingParty, NewParty, DoDescribeParty
changes to: GetIdleParty
changes to: CreateParty, ExistingParty, NewParty
Swinehart, October 25, 1985 6:45:23 pm PDT
Handle => ID, NamesAndLog => VoiceUtils
changes to: DIRECTORY, ThPartyInitImpl, GetActiveParty, GetIdleParty, CreateParty, ExistingParty, DoRegister, RegisterClone, Deregister, EnterSmarts, MakeServiceRname, GetStdRingInfo, ReportSystem, ReportParty, ThPartyInit, ConversationID, PartyID, SmartsID, nullID, Reseal, GetParty, GetPartyFromFeepNum, GetPartyFromNumber, GetPartyFromNumberInt, GetTrunkParty, GetRname, Register, RegisterLocal, EnterSmartsE (local of EnterSmarts), Enable, Disable, DescribeParty, DoDescribeParty, GetCurrentParty, GetPartySmarts, SetStdRingInfo, SetRingEnable, NewParty


Swinehart, October 29, 1985 5:55:37 pm PST
Major revisions for visiting and poaching.  See design document.
changes to: CreateParty, Register, RegisterLocal, DoRegister, EnterSmarts, Able, Deregister, PrepareRingTune, GetPartyFromNumber, GetRname, DescribeParty, GetActiveParty, GetIdleParty, GetPartyFromNumberInt, GetTrunkParty, Deregister, Deregister, EraseAsObj, Deregister



Swinehart, December 11, 1985 3:29:30 pm PST
Just improve comments
changes to: GetRelatedParty, SetPoaching


�ÊX˜Jš
œ™šœ
Ïm
œ1™<Jš
œ@™@J˜—š
Ïk	˜	Jšœžœ˜"Jšœ
žœ˜*Jšœžœ˜#Jšœžœ˜*J˜Jšœžœ˜%Jšœžœ˜!Jšœ	žœ˜%J˜Jšœžœžœ˜*Jšœžœ!˜+Jšžœ
žœC˜LJšœžœž
œb˜pJš
œe˜eJšœžœM˜aJš
œ˜J˜J˜šœžœ˜Jšœžœ'žœžœ˜]—Jšœžœ˜0J˜Jšœžœ$˜1Jšžœ
žœ˜!Jšœžœ•
˜¥
J˜
J˜—šœž
œ
žœ˜)šžœ˜
J˜Jš
œ
˜
Jš
œ˜J˜J˜J˜Jš
œ	˜	J˜J˜J˜J˜Jšžœ
˜J˜J˜J˜J˜J˜J˜J˜Jšžœ
˜J˜
—Jšžœ˜šžœ-˜3Jšžœ
žœ
˜—J˜—š
œ™Jšžœžœ
žœ
˜JšœžœÏc˜;šœ	žœŸ˜%J˜ —Jšžœžœ
žœ
˜JšœžœŸ˜=Jšœ
žœŸ˜'šžœžœ
žœ
˜Jšœžœ˜ —JšÏnœžœžœžœžœžœžœ˜LJ˜ J˜Jšœžœ	˜J˜Jšœžœ
žœ
˜J˜J˜—™:J˜š
 œžœ
ž
œžœ
žœ˜<Jšœžœžœ
˜/Jšžœžœ˜)Jšžœ
žœžœ
˜J˜Jš
œ6˜6J˜Jš
œ˜J˜—š œžœ
ž
œ
˜'Jšœžœ)žœ
žœ
˜;Jšžœžœ*˜9Jšžœ
žœžœ
˜Jšœžœ
˜Jšœžœ
˜š
œ˜Jšœ'žœ ˜K—Jšžœžœ
žœ
žœ˜,Jšœ-žœ˜2J˜Jš
œ˜J˜—š œžœ
žœ
žœ
˜&Jšœžœ(žœ
˜6Jšœ
žœ
˜Jšžœžœ˜)Jšžœ
žœžœ
˜JšœLžœ˜SJ˜J˜—š
 œžœ
žœžœžœ
˜CJšžœ
žœ
žœžœ˜=J˜š
œ5˜5Jš
œ3˜3—šžœ	žœ
žœ$˜7J˜?—J˜J™—š œžœ
žœžœ˜8Jšžœžœžœ
žœ˜,Jš
œF˜FJš
œ˜J˜—š œžœ
žœ!žœ
˜CJš
œ˜Jšžœžœžœ˜6J™BJšœžœ
˜
J˜Jšœ	žœ
˜Jš
žœžœ
žœ
žœžœ˜0šžœžœ
žœ+˜=J˜=Jšžœžœ=˜RJšžœ
˜J˜—šžœž˜Jšœ=žœ˜GJšœžœŸ˜)Jšœ
žœŸ˜(Jšžœžœ
˜—šœžœ
˜JšœŸ
œ2Ÿœ˜V—Jš
žœ
žœ
žœžœžœ˜MJšžœžœ
žœ˜4J™<š
œ4˜4Jš
œ3˜3—Jšžœ	žœ
žœ	žœ
žœ
žœ˜=šžœžœ
žœ!˜3Jš
œI˜I—Jšžœžœ
žœ
žœ˜-Jšœ>žœ˜DJšžœ
žœ0˜CJ˜J˜—š œžœ
žœ žœ
˜@Jšžœžœ!žœ˜8J™,J™Jšžœ
žœžœ
˜Jš
œ6˜6Jšœžœ
˜
Jšœžœ
˜šœžœ2˜GJ™—Jšžœ	žœ
žœ
žœ˜-š
œ)˜)J™—Jšžœžœ
žœžœ˜4š
œ@˜@J™!—Jšœžœ+Ÿ	œ˜HJš	žœžœ
žœžœŸ˜WJšžœ
žœ(Ÿ(˜WJš
œ˜J˜—š œž
œ
˜%Jšœ&žœ
˜+Jšœ
žœžœ
˜'Jšžœžœ*˜9J™»
Jšœžœžœ
˜Jšœžœžœ
˜J˜7J˜Jšœžœ
˜Jšœžœ
˜J™-Jšžœžœ
žœ
žœ˜/J˜Išœ
žœžœ
žœ
ž˜&Jšžœ
žœ'Ÿœ˜D—Jšœžœžœ
žœ
žœ
žœ˜@šžœžœ
žœ
žœ™;J™E—Jš
œ3˜3šžœžœžœ˜"JšœžœŸ˜1Jš
žœžœ
žœžœŸ	œ	˜Mšžœžœ
žœ˜J˜Jšœ=žœ˜BJšžœ
žœ
žœ˜9Jš
œ˜—Jš
œ˜—J™Jšœ+Ÿ/˜Zšžœžœ˜Jšœžœ"Ÿœ˜?Jšžœžœ
žœ+˜<J˜—Jšžœžœ
žœ
˜Jš
œ˜Jš
œ ˜ JšœŸ:˜YJš
œ ˜ J˜J˜—š œžœ
žœ˜0Jšžœžœžœ˜1Jšœžœ
˜Jš
œ%˜%Jšžœžœ
žœŸ˜-šžœž˜š
œ˜JšœžœŸœ˜H—JšžœŸ<˜E—Jšžœžœ
žœ˜-Jšžœ
žœžœŸ˜BJšžœ
žœžœŸ˜KJšžœžœžœ
˜)Jš
œ˜J˜——™J™š œžœ
žœ
˜Jšœžœ˜Jšœžœ
žœŸ˜(J˜%J˜Jšœ(Ÿ˜4J˜$Jšœžœ˜Jšœžœ+˜1JšœEžœ˜VJ˜J˜—š 
œžœ
žœ
˜Jšœžœ˜Jšœžœ
žœŸ˜(J˜%J˜Jšœ1žœ
˜5J˜$Jšœžœ˜Jšœžœ+˜1Jš
œ\˜\J˜J˜—š 
œžœ
˜Jšœžœ
žœŸ˜(J˜%J˜Jšœ(Ÿ˜4Jš
œ/˜/J˜$Jšœžœ˜Jšœžœ+˜1šœ
žœ˜%Jš
œL˜L—Jšœžœ*Ÿœ˜RJ˜Jšœžœ˜Jšžœžœ1˜Lšžœžœ
žœ˜J™¤
J™NJš
œ$˜$Jšžœžœ
žœ
˜J˜—Jšžœžœ
žœ
žœ˜/šžœžœ
žœ˜š
œ.˜.Jš
œ%˜%Jš
œ˜Jš
œ˜JšœŸœžœ˜6Jšœ6žœ˜A—Jšžœžœ
žœ
žœ˜>š
œ/˜/Jšœžœ˜.Jšœ0žœ˜;—Jšžœžœ
žœ
žœ˜8J˜—JšÏbÐbn
¡Ðbk¡
£¡˜Jš
œ'˜'šžœ
žœ
žœ
˜Jš
œB™B—šœžœ˜&Jš
œ˜Jš
œ˜Jš
œ˜Jš
œ˜Jš
œ˜—Jšžœ$˜&Jšžœ.˜0J˜*J˜*JšœŸJ˜_Jš
¡˜š
œ>˜>J˜NJ˜(—J˜J˜—š œžœ
žœžœ˜FJšžœžœžœ˜3J™VJš	œžœžœžœžœ&˜bJ˜Jšœžœ!˜,Jšœžœ
žœ
˜Jšžœžœ
žœ
žœ˜4JšžœžœžœŸ	œ˜NJšžœžœ
žœ
žœ˜*Jšœžœ7˜Bšžœž˜šœ'Ÿ˜@Jšœžœ.˜7Jš
œ˜Jš
žœžœ
žœ3žœžœ
˜NJšžœžœ
žœ&˜5J˜—Jšžœ
˜—J˜Jšžœ ˜"Jšžœžœ
žœ
žœ*˜BJš
œ˜J˜—š œžœ
žœ+žœ˜MJšœžœ
˜ Jšœžœ˜Jšœžœ
˜Jšœ
žœ
˜Jšœžœ
˜
Jšœžœ
˜š¡
žœž˜˜J˜J˜šžœ,Ÿœžœ
žœ˜IJšœ-žœ˜7—š
žœžœŸ	œ
žœ
žœ˜WJšœ)žœ˜3—Jšœ%Ÿ˜>J˜GJšœ(Ÿ˜8Jš
žœ1žœžœ
žœ
žœ
˜KJšœ
žœ8Ÿ	œ˜TJšžœ	žœ
žœ
žœžœ
žœžœ
žœ
žœ
˜CJš
ÏtZ™ZJš	žœžœ
žœ
žœŸ˜:˜(J˜J˜J˜Jšœž˜Jš
œ˜—Jšžœ
žœžœ
žœ
˜/J˜0J˜—˜š
œ˜JšœEžœ˜J—J˜?Jšžœžœ
žœ
žœ
˜!J˜Jš
žœ6Ÿœžœ
žœ
žœ
˜WJšœ
žœ/˜?Jšžœžœ
žœ0žœ˜OJ˜—Jšžœžœ
˜—Jšžœ
¡œžœ¡
œ
˜J˜'J˜'J˜*J˜J˜—š 
œžœ
žœ˜0Jšžœžœ*˜9Jš
œ?˜?š
œ˜JšžœL˜O—J˜ Jšžœžœ
žœ
žœ˜0Jšœžœ%Ÿœ˜Hšžœ
žœ
žœ˜Jšœ,žœ˜I—šœžœ˜)J˜$J˜J˜!J˜J˜—Jš
œ%˜%J˜(J˜*J™Kš
œ?˜?Jšžœžœ2žœ'˜p—Jš
œ˜J˜—š
 œžœ
žœ
žœžœ˜=Jšžœ
žœžœžœ˜<J™—š
 œžœ
žœ
žœžœ˜>Jšžœ
žœžœžœ˜=—J˜š œžœ
žœžœ
˜7Jšžœžœ˜#J˜9J˜Jšžœžœ
žœ
žœ˜)šžœžœŸ	œž˜AJšžœ
žœ˜—Jš
œ-˜-J˜J˜——™*J™š
 
œžœ
žœ
žœžœ˜<Jšžœžœ˜J™¥J™VJšžœ
žœžœ
˜J˜J˜;Jšžœžœ
žœ
žœ˜)JšœžœŸ	œ˜;šžœžœ
žœ˜J˜!J™1˜JšžœJ˜N—J˜%š
œ˜Jšœ žœžœ˜M—JšžœžœŸ˜>J˜
—Jšžœ˜J˜+Jšœžœ
˜š
œ˜Jšœ%žœžœ˜N—Jšžœžœ
žœŸ'˜OJ˜J˜—š œžœ
žœ˜>J™'š œÐck™5Jš¥(œ™,Jšžœ
žœ
žœ+žœžœ
žœ™\Jšžœžœ
žœ
žœ™-š
œ™Jš
œ™Jš
œ
™
Jšœžœ™Jš
œ
™
J™
JšœŸ™6—Jšžœ
žœ™J™—š œ¥™5Jš¥(œ™.Jšœžœ™,J™—J™dš
ž™Jšœžœ
™
J™&Jšžœ	žœ
žœ
žœ
™Jšžœ
™—J™šJš
œ4™4Jš
œ4™4J˜J˜—š 
œžœ3˜MJšžœžœžœ˜-Jšœžœ
˜J˜WJ˜J˜——™J™š œžœ
žœ.˜JJšžœžœ
žœ˜*J˜$š
 
œžœ
žœžœžœ˜1Jšœžœ
žœžœ
žœžœ˜Išœžœ
žœ
žœ˜"Jšžœ
žœžœžœ
˜>—J˜—š œžœ+žœžœ˜SJšœžœžœŸœ
˜=Jšžœ
žœžœ
žœ
žœ
žœ˜0J˜—Jšžœžœ
žœ
˜šœžœž˜J˜&šœžœ	ž˜Jš
œ˜J˜ Jš
œ˜J˜Jšžœžœ˜—šœ
žœ	ž˜ J˜*Jšœžœ'˜9Jš
œ+˜+Jšžœžœ˜—Jšžœžœ
˜—J˜J™—š œžœ5˜LJšžœžœžœ
žœ	žœ
žœ˜FJ™/Jšžœžœ
žœ
žœ˜+J˜(Jšžœžœ
žœ˜'Jšžœ$˜(Jš
œ˜—J˜š œžœ
žœžœ
˜7Jšžœžœžœ˜?Jš
œ3˜3Jš
œ5˜5Jš
œ˜—J˜J™/š œžœ
ž
œ
žœ!˜TJšžœžœ5˜DJšœžœ)˜4J˜Jš
œ
˜
Jšžœžœ
žœ
žœ˜-JšœžœŸ	œ˜;Jš
žœžœ
žœžœ
žœ˜>Jšžœžœ
žœ$žœ˜QJšœŸ&˜:šžœžœŸ
œž˜BJšžœžœ˜—J˜J˜—J˜š 
œžœ
žœžœžœ
žœ
žœ˜Aš
žœžœ
žœ
žœžœžœ
ž˜@J˜$Jšžœ
˜—J˜J˜——™J™š œžœ˜0J˜—š œ˜%Jšœžœ˜%Jš
œ˜šžœžœ
ž˜Jš	œžœ1žœ
žœ
žœ
˜R—šžœž˜"JšœEžœ
˜N—Jš
žœžœ
žœ$žœ!žœ˜YJ˜—J˜š œ˜)Jšœžœ
˜Jš
žœ	žœ
žœ(žœ	žœ
˜KJš
œ)˜)Jš
œ+˜+šžœ	žœ
žœ(˜;Jšœ
Ÿ+˜5JšœŸ˜#J˜—J˜—J˜Jš
œ5˜5Jšœžœ˜"J˜š œ˜&š
ž˜JšžœIžœ˜[—š
œ˜J˜Jš
œ_˜_J˜—š
œA˜AJ˜;—Jšžœžœ
žœ
˜Jš
œ8˜8Jš
œ6˜6˜"Jš
œ#˜#Jš
œ#˜#J˜—Jš
œ³
˜³
Jšœ9žœ&˜bJšœžœ
˜š
ž˜JšœKžœ˜U—J˜—J˜Jš
œ—
˜—
š
œ*˜*Jš
œZ˜Z—J˜Icode™—™™'K™	KšœÏrJ™V—™&K™—™'K™K™K™!K™2Kšœ¦F™RKšœ¦5™AKšœ¦™Kšœ¦$™0—™*K™'Kšœ¦�œ¦{™­K™K™—™*K™@Kšœ¦�™�—K™K™—K™™+K™Kšœ¦™(—K™K™—…—S>€D