
DIRECTORY
BasicTime USING [GMT, minutesPerHour, MonthOfYear, nullGMT, OutOfRange, Period, TimeParametersNotKnown, Unpack, Unpacked, unspecifiedZone, Zone],
Commander USING [CommandProc, CommandProcHandle, Register],
Convert USING [Base, CardFromRope],
IO,
List USING [AList, PutAssoc],
PFS USING [AbsoluteName, Attach, Copy, Delete, EnumerateForInfo, EnumerateForNames, Error, ErrorDesc, ErrorGroup, FileInfo, FileType, GetWDir, InfoProc, NameProc, NameConfirmProc, nullUniqueID, PathFromRope, Rename, Retrieve, RetrieveConfirmProc, RopeFromPath, StreamOpen, tDirectory, tText, tUnspecified, UniqueID],
PFSNames USING [Cat,  Compare, ComponentCount, ComponentProc, ComponentRope, Equal, IsADirectory, Map, NarrowPath, Parent, PATH, SeparatorProc, SetVersionNumber, ShortName, StripVersionNumber, SubName, VersionKind],
PFSPrefixMap USING [Delete, Entry, EntryList, GetMap, Insert, Lookup, Translate],
PriorityQueue USING [Create, Insert, Item, Ref, Remove, Size, SortPred],
Process USING [CheckForAbort],
ProcessProps USING [AddPropList, GetProp],
Rope USING [Cat, Concat, Equal, Fetch, Find, Length, Match, ROPE, Substr],
RuntimeError USING [UNCAUGHT];

PFSCommandsImpl: CEDAR MONITOR
IMPORTS BasicTime, Commander, Convert, IO, List, PFS, PFSNames, PFSPrefixMap, PriorityQueue, Process, ProcessProps, Rope, RuntimeError
= BEGIN

GMT: TYPE = BasicTime.GMT;
LORA: TYPE = LIST OF REF ANY;
ROPE: TYPE = Rope.ROPE;
PATH: TYPE = PFSNames.PATH;
STREAM: TYPE = IO.STREAM;

QuotedStringError: ERROR = CODE;

CmdTokenBreak: PROC [char: CHAR] RETURNS [IO.CharClass] = {
IF char = '" THEN RETURN [break];
IF char = '  OR char = '\t OR char = ', OR char = '\l OR char = '\r THEN RETURN [sepr];
RETURN [other];
};

Token: TYPE = RECORD [value, literal: ROPE];
GetCmdToken: PROC [stream: IO.STREAM] RETURNS [token: Token Ź [NIL, NIL]] = {
token.value Ź token.literal Ź IO.GetTokenRope[stream, CmdTokenBreak ! IO.EndOfStream => CONTINUE].token;
IF Rope.Equal[token.literal, "\""] THEN {
ref: REF;
IO.Backup[self: stream, char: '"];
ref Ź IO.GetRefAny[stream ! IO.Error, IO.EndOfStream => ERROR QuotedStringError];
WITH ref SELECT FROM
rope: ROPE => token.value Ź rope;
ENDCASE => ERROR QuotedStringError;
};
};

GetPath: PROC [stream: IO.STREAM] RETURNS [PATH] = {
RETURN [PFS.PathFromRope[GetCmdToken[stream].value]]
};

PrefixMapAdd: Commander.CommandProc ~ TRUSTED {
ENABLE QuotedStringError => {msg _ "Mismatched quotes"; GO TO failed};
translateFirst, checkPrev: BOOL Ź FALSE;
argStream: IO.STREAM ~ IO.RIS[cmd.commandLine];
prefix, translation: PATH;
first: ROPE Ź GetCmdToken[argStream].value;
DO
IF first = NIL THEN EXIT;
IF Rope.Fetch[first, 0] # '- THEN { prefix Ź PFS.PathFromRope[first]; EXIT };
FOR i: INT IN [1..Rope.Length[first]-1] DO
SELECT Rope.Fetch[first, i] FROM
'c, 'C => checkPrev Ź TRUE;
't, 'T => translateFirst Ź TRUE;
ENDCASE => {
cmd.out.PutF1["Unknown switch %g; quitting\n", [character[Rope.Fetch[first, i]]] ];
RETURN;
};
ENDLOOP;
first Ź GetCmdToken[argStream].value;
ENDLOOP;
translation _ GetPath[argStream];
SELECT TRUE FROM
prefix=NIL => {
cmd.out.PutF1["%g \n", [rope[prefixMapAddDoc]]];
RETURN;
};
translation=NIL => {
[] _ PFSPrefixMap.Delete[prefix];
};
ENDCASE => {
IF translateFirst THEN translation Ź PFSPrefixMap.Translate[translation];
IF checkPrev THEN {
prev: PATH Ź PFSPrefixMap.Lookup[prefix];
IF prev # NIL AND NOT PFSNames.Equal[prev, translation] THEN
cmd.out.PutF1["Redefining previous translation (%g)\n", [rope[PFS.RopeFromPath[prev]]] ];
};
[] Ź PFSPrefixMap.Insert[prefix, translation];
};
EXITS
failed=> result _ $Failure;
};

PrefixMapPrint: Commander.CommandProc ~ TRUSTED {
ENABLE QuotedStringError => {msg Ź "Mismatched quotes"; GO TO failed};
argStream: IO.STREAM ~ IO.RIS[cmd.commandLine];
prefix: PATH Ź GetPath[argStream];
SELECT TRUE FROM
prefix=NIL => {
list: PFSPrefixMap.EntryList ~ PFSPrefixMap.GetMap[];
FOR l: PFSPrefixMap.EntryList Ź list, l.rest UNTIL l=NIL DO
cmd.out.PutF[ "\t%g\t\t%g\n", [rope[PFS.RopeFromPath[l.first.prefix]]], [rope[PFS.RopeFromPath[l.first.translation]]] ];
ENDLOOP;
};
ENDCASE => { 
translation: PATH ~ PFSPrefixMap.Lookup[prefix];
cmd.out.PutF[ "\t%g\t\t%g\n", [rope[PFS.RopeFromPath[prefix]]], [rope[PFS.RopeFromPath[translation]]] ]; 
};
EXITS
failed=> result Ź $Failure;
};

PrefixMapTranslate: Commander.CommandProc ~ TRUSTED {
ENABLE QuotedStringError => {msg Ź "Mismatched quotes"; GO TO failed};
argStream: IO.STREAM ~ IO.RIS[cmd.commandLine];
path: PATH Ź GetPath[argStream];
SELECT TRUE FROM
path=NIL => {
cmd.out.PutF1[ "%g\n", [rope[prefixMapTranslateDoc]] ];
};
ENDCASE => { 
translation: PATH ~ PFSPrefixMap.Translate[path];
cmd.out.PutF[ "\t%g\t\t%g\n", [rope[PFS.RopeFromPath[path]]], [rope[PFS.RopeFromPath[translation]]] ]; 
};
EXITS
failed=> result Ź $Failure;
};

NameCommandProc: Commander.CommandProc ~ TRUSTED {
ENABLE QuotedStringError => {msg Ź "Mismatched quotes"; GO TO failed};
argStream: IO.STREAM ~ IO.RIS[cmd.commandLine];
val: REF ANY Ź LOOPHOLE[ Convert.CardFromRope[GetCmdToken[argStream].value !
RuntimeError.UNCAUGHT => {msg Ź "conversion error"; GO TO failed}] ];
name: PATH Ź PFSNames.NarrowPath[val !
RuntimeError.UNCAUGHT => { msg Ź "narrow failed"; GO TO failed}];
nameRope: ROPE Ź PFS.RopeFromPath[name];
cmd.out.PutF[ "  %g:  %g\n", [cardinal[LOOPHOLE[val]]], [rope[nameRope]] ];
EXITS
failed=> result Ź $Failure;
};

DeleteCommandProc: Commander.CommandProc = {
argStream: IO.STREAM ~ IO.RIS[cmd.commandLine];
out: STREAM = cmd.out;
exactLevelMatch: BOOL Ź FALSE;
componentsRequired: INT Ź 0;
deleteIt: PFS.NameProc = {
ok: PFS.NameConfirmProc ~ {
IO.PutRope[out, "  deleting "];
IO.PutRope[out, PFS.RopeFromPath[fullName]];
RETURN[TRUE];
};
Process.CheckForAbort[];
continue Ź TRUE;
IF exactLevelMatch AND componentsRequired # name.ComponentCount[] THEN RETURN;
PFS.Delete[name~name, confirmProc~ok ! PFS.Error =>
IF error.group # bug THEN { IO.PutRope[cmd.err, PFSErrorMsg1[error]]; CONTINUE } ];
IO.PutRope[out, "\n"];
};
DO
pattern: ROPE Ź GetCmdToken[argStream ! QuotedStringError => {msg Ź "Mismatched quotes"; GO TO Die}].value;
IF pattern = NIL THEN EXIT;
IF Rope.Match["-*", pattern] THEN {
sense: BOOL Ź TRUE;
FOR i: INT IN [1..Rope.Length[pattern]) DO
c: CHAR = Rope.Fetch[pattern, i];
SELECT c FROM
'~ => {sense Ź NOT sense; LOOP};
'x, 'X => exactLevelMatch Ź sense;
ENDCASE;
sense Ź TRUE;
ENDLOOP;
LOOP;
};
{ENABLE PFS.Error => IF error.group # $bug
THEN {msg Ź PFSErrorMsg[error]; GO TO Die};
path: PATH Ź PFS.PathFromRope[pattern];
path Ź PFS.AbsoluteName[path];
IF path.ComponentCount[] = 0 THEN LOOP;
IF exactLevelMatch THEN componentsRequired Ź path.ComponentCount[];
IF path.ShortName[].version = [none] THEN path Ź path.SetVersionNumber[[lowest]];
IF Rope.Find[pattern, "*"] = -1
THEN [] Ź deleteIt[path]
ELSE PFS.EnumerateForNames[path, deleteIt];
};
Process.CheckForAbort[];
ENDLOOP;
EXITS
Die => result Ź $Failure;
};

PFSErrorMsg: PROC [error: PFS.ErrorDesc] RETURNS [ROPE] = {
IF error.code = $unknownFile
THEN RETURN ["  -- not found!\n"]
ELSE RETURN[Rope.Cat[" -- PFS.Error: ", error.explanation, "\n"]];
};

PFSErrorMsg1: PROC [error: PFS.ErrorDesc] RETURNS [ROPE] = {
IF error.code = $unknownFile
THEN RETURN ["  -- not found!"]
ELSE RETURN[Rope.Concat["\n  -- PFS.Error: ", error.explanation]];
};


CopyAndRename: Commander.CommandProc = {
destinationDirectory: PATH Ź NIL;
leftArrowExists: BOOL Ź FALSE;
useRetrieve: BOOL Ź cmd.procData.clientData = $Retrieve;
doACopy: BOOL Ź cmd.procData.clientData = $Copy;
doStore: BOOL Ź cmd.procData.clientData = $Store;
compsBeforeStar: INT Ź 0;
forceCopy: BOOL Ź TRUE;
retainStructure: BOOL Ź FALSE;
updateOnly: BOOL Ź FALSE;
exactLevelMatch: BOOL Ź FALSE;
componentsRequired: INT Ź 0;

HandleAFile: PROC [to, from: PATH] = {
Process.CheckForAbort[];
cmd.out.PutF["  %g _ %g", [rope[PFS.RopeFromPath[to]]], [rope[PFS.RopeFromPath[from]]]];
{ENABLE
PFS.Error =>
IF error.group # bug THEN {msg Ź PFSErrorMsg1[error]; GO TO skipIt};
IF updateOnly THEN {
sourceID: PFS.UniqueID Ź PFS.nullUniqueID;
destID: PFS.UniqueID Ź PFS.nullUniqueID;
sourceID Ź PFS.FileInfo[from].uniqueID;
destID Ź PFS.FileInfo[to ! PFS.Error => IF error.group # bug THEN CONTINUE].uniqueID;
IF sourceID = destID AND sourceID # PFS.nullUniqueID THEN {
cmd.out.PutRope["\n  -- not copied, create dates match"];
GO TO skipIt;
};
};
SELECT TRUE FROM
doACopy => {
IF forceCopy
THEN PFS.Copy[from: from, to: to, confirmProc: NIL]
ELSE [] Ź PFS.Attach[attachedFile: from, attachment: to];
};
useRetrieve => {
toStrm: STREAM Ź PFS.StreamOpen[to, $create, PFS.FileInfo[from].uniqueID];
Rcp: PFS.RetrieveConfirmProc ~ { RETURN[toStrm] };
PFS.Retrieve[name: from, proc: Rcp];
toStrm.Close[];
};
ENDCASE => PFS.Rename[from: from, to: to];

EXITS
skipIt => {};
};
cmd.out.PutRope["\n"];
};

argStream: IO.STREAM ~ IO.RIS[cmd.commandLine];
head: LIST OF ROPE ~ LIST[NIL];
last: LIST OF ROPE Ź head;
nArgs: NAT Ź 0;
args: LIST OF ROPE Ź NIL;
sources: LIST OF ROPE Ź NIL;
DO
arg: Token ~ GetCmdToken[argStream];
length: INT ~ Rope.Length[arg.value];
SELECT TRUE FROM
(arg.value = NIL) => EXIT;
(length = 0) => NULL;
(Rope.Fetch[arg.literal, 0] = '-) => {
sense: BOOL Ź TRUE;
FOR j: INT IN [1..length) DO
SELECT arg.literal.Fetch[j] FROM
'~ => {sense Ź NOT sense; LOOP };
'c, 'C => forceCopy Ź sense;
'r, 'R => retainStructure Ź sense;
'u, 'U => updateOnly Ź sense;
'x, 'X => exactLevelMatch Ź sense;
ENDCASE => {
msg Ź Rope.Cat["Unknown switch: ", arg.literal.Substr[0, j], " ", arg.literal.Substr[j]];
GOTO Die;
};
sense Ź TRUE;
ENDLOOP;
};
(nArgs = 1 AND (Rope.Equal[arg.literal, "_"] OR Rope.Equal[arg.literal, "Ź"])) => {
leftArrowExists Ź TRUE;
};
ENDCASE => { nArgs Ź nArgs + 1; last Ź last.rest Ź LIST[arg.value] };
ENDLOOP;
args Ź head.rest;
IF leftArrowExists
THEN {
target: PATH Ź PFS.PathFromRope[args.first];
sources Ź args.rest;
IF target.IsADirectory[]
THEN destinationDirectory Ź target
ELSE {
IF nArgs # 2 OR Rope.Find[args.first, "*"] >= 0 OR Rope.Find[args.rest.first, "*"] >= 0
THEN RETURN[$Failure, "Bad syntax for copying a file"];
HandleAFile[from: PFS.PathFromRope[args.rest.first], to: target];
RETURN[IF msg # NIL THEN $Failure ELSE NIL, msg];
};
}
ELSE {
destinationDirectory Ź PFS.GetWDir[];
sources Ź args;
};

FOR tail: LIST OF ROPE Ź sources, tail.rest UNTIL tail = NIL DO
source: PATH Ź PFS.PathFromRope[tail.first];
IF source.IsADirectory[] THEN {
msg Ź Rope.Concat["Cannot copy a directory: ", tail.first];
GO TO Die;
};
IF Rope.Find[tail.first, "*"] >= 0
THEN {
pattern: PATH Ź source;
handleIt: PFS.NameProc = {
to: PATH;
short: ROPE Ź NIL;
continue Ź TRUE;
IF exactLevelMatch AND componentsRequired # name.ComponentCount[] THEN RETURN [TRUE];
IF retainStructure
THEN to Ź name.SubName[compsBeforeStar]
ELSE to Ź name.SubName[start~name.ComponentCount[]-1, count~1];
to Ź to.StripVersionNumber[];
to Ź PFSNames.Cat[destinationDirectory, to];
HandleAFile[from: name, to: to];
RETURN[msg = NIL];
};
IF pattern.ShortName[].version = [none] THEN pattern Ź pattern.SetVersionNumber[[highest]];
pattern Ź PFS.AbsoluteName[pattern];
IF exactLevelMatch THEN componentsRequired Ź PFSNames.ComponentCount[pattern];
IF retainStructure THEN {
goOn: BOOL Ź TRUE;
findStar: PFSNames.ComponentProc ~ {
IF goOn AND Rope.Find[comp.ComponentRope[], "*"] >= 0 THEN goOn Ź FALSE ELSE compsBeforeStar  Ź compsBeforeStar+1;
};
dummySeparatorProc: PFSNames.SeparatorProc ~ {};
PFSNames.Map[pattern, findStar, dummySeparatorProc, NIL];
};
PFS.EnumerateForNames[pattern, handleIt
! PFS.Error => IF error.group # $bug THEN {msg Ź PFSErrorMsg[error]; GO TO Die}];
}
ELSE {
from: PATH Ź source;
to: PATH Ź PFSNames.StripVersionNumber[from.SubName[from.ComponentCount[]-1]];
to Ź PFSNames.Cat[destinationDirectory, to];
HandleAFile[from: from, to: to];
IF msg # NIL THEN GO TO Die;
};
Process.CheckForAbort[];
ENDLOOP;
EXITS
Die =>  result Ź $Failure;
};
ListCommandProc: Commander.CommandProc = {
EachFileName: PFS.NameProc = {
attachedTo: PATH Ź NIL;
created: BasicTime.GMT Ź BasicTime.nullGMT;
bytes: INT Ź -1;
fileType: PFS.FileType Ź PFS.tUnspecified;
uniqueID: PFS.UniqueID;
item: FileItem Ź NIL;
continue Ź TRUE;
Process.CheckForAbort[];
IF xactLevelMatch AND componentsRequired # PFSNames.ComponentCount[name] THEN RETURN;
IF NOT prefixOnly THEN {
[attachedTo: attachedTo, bytes: bytes, uniqueID: uniqueID, fileType: fileType] Ź PFS.FileInfo[name: name];
};
IF bytes > 0 AND lostFilesOnly THEN RETURN;
IF attachedTo#NIL AND unattachedOnly THEN RETURN;
item Ź NEW[FileItemRep Ź [name, attachedTo, uniqueID.egmt.gmt, bytes, PFS.tUnspecified]];
filesSeen Ź filesSeen + 1;
IF bytes > 0 THEN bytesTotal Ź bytesTotal + bytes;
SELECT TRUE FROM
prefixOnly => {
oldLag: PATH Ź lagPrefix;
SetLagPrefix[name];
IF oldLag # lagPrefix THEN {
item.fullUName Ź lagPrefix;
PriorityQueue.Insert[pq, item];
};
};
complexSorting => PriorityQueue.Insert[pq, item];
ENDCASE => PrintOneFile[item];
};

EachFileInfo: PFS.InfoProc = {
item: FileItem Ź NIL;
continue Ź TRUE;
Process.CheckForAbort[];
IF xactLevelMatch AND componentsRequired # PFSNames.ComponentCount[fullFName] THEN RETURN;
IF bytes > 0 AND lostFilesOnly THEN RETURN;
IF attachedTo#NIL AND unattachedOnly THEN RETURN;
item Ź NEW[FileItemRep Ź [fullFName, attachedTo, uniqueID.egmt.gmt, bytes, fileType]];
filesSeen Ź filesSeen + 1;
IF bytes > 0 THEN bytesTotal Ź bytesTotal + bytes;
SELECT TRUE FROM
prefixOnly => {
oldLag: PATH Ź lagPrefix;
SetLagPrefix[fullFName];
IF oldLag # lagPrefix THEN {
item.fullUName Ź lagPrefix;
PriorityQueue.Insert[pq, item];
};
};
complexSorting => PriorityQueue.Insert[pq, item];
ENDCASE => PrintOneFile[item];
};

PrintOneFile: PROC [item: FileItem] = {
oldLag: PATH Ź lagPrefix;
printName: ROPE Ź PFS.RopeFromPath[item.fullUName];
Process.CheckForAbort[];
IF NOT fullPrint AND NOT prefixOnly THEN {
SetLagPrefix[item.fullUName];
IF oldLag # lagPrefix THEN {
IO.PutRope[out, PFS.RopeFromPath[lagPrefix]];
IO.PutChar[out, IF oneLine THEN '  ELSE '\n];
};
printName Ź PFS.RopeFromPath[PFSNames.SubName[item.fullUName, lagPrefixLen]];
IF NOT oneLine THEN IO.PutRope[out, "  "];
};
SELECT TRUE FROM
prefixOnly => IO.PutRope[out, printName];
briefPrint => {
IO.PutRope[out, printName];
};
ENDCASE => {
form: ROPE = IF narrowPrint THEN "%g\n%12g  " ELSE "%-24g %6g ";
IO.PutF[out, form, [rope[printName]], [integer[item.bytes]] ];
IF item.created = BasicTime.nullGMT
THEN IO.PutRope[out, "??"]
ELSE DateToStream[out, [explicit, item.created] ];
IF typePrint THEN {
r: ROPE ~ SELECT item.fileType FROM
PFS.tUnspecified => " tUnspec",
PFS.tDirectory => " tDir",
PFS.tText => " tText",
ENDCASE => IO.PutFR1[" t%g", [integer[item.fileType]]];
IO.PutRope[out, r];
};
IF attachPrint AND item.attachedTo#NIL THEN IO.PutF[out, "%g=> %g", [rope[IF oneLine THEN " " ELSE "\n  "]], [rope[PFS.RopeFromPath[item.attachedTo]]]];
};
IO.PutChar[out, IF oneLine THEN '  ELSE '\n];
};
TryPattern: PROC [pattern: PATH, allVersions: BOOLŹFALSE] = {
Do: PROC [] ~ {
ENABLE PFS.Error => IF error.group # $bug THEN {
IO.PutRope[cmd.err, "  -- "];
IO.PutRope[cmd.err, error.explanation];
IO.PutRope[cmd.err, "\n"];
GO TO err};
patternsTried Ź patternsTried + 1;
IF allVersions THEN {
pattern Ź PFSNames.SetVersionNumber[pattern, [all]];
highestPrint Ź FALSE;
};
IF highestPrint THEN
pattern Ź PFSNames.SetVersionNumber[pattern, [highest]];
IF xactLevelMatch THEN {
pattern Ź PFS.AbsoluteName[pattern];
componentsRequired Ź PFSNames.ComponentCount[pattern];
};
complexSorting Ź sortData # NIL;
SELECT TRUE FROM
prefixOnly => pq Ź PriorityQueue.Create[SortPred, NIL];
complexSorting => pq Ź PriorityQueue.Create[SortPred, sortData];
ENDCASE => pq Ź NIL;
SetLagPrefix[NIL];
IF prefixOnly OR xactLevelMatch
THEN PFS.EnumerateForNames[pattern, EachFileName]
ELSE PFS.EnumerateForInfo[pattern, EachFileInfo];
SetLagPrefix[NIL];
IF pq # NIL THEN {
lagName: PATH Ź NIL;
THROUGH [0..PriorityQueue.Size[pq]) DO
item: FileItem = NARROW[PriorityQueue.Remove[pq]];
IF prefixOnly THEN {
IF PFSNames.Equal[item.fullUName, lagName] THEN LOOP;
lagName Ź item.fullUName;
};
PrintOneFile[item];
ENDLOOP;
};
EXITS
err => {IO.PutRope[cmd.err, "\n"]; RETURN};
};
wDir: ROPE ~ NARROW[ProcessProps.GetProp[$WorkingDirectory]];
newProp: List.AList ~ List.PutAssoc[$WDir, PFS.PathFromRope[wDir], NIL];
ProcessProps.AddPropList[newProp, Do];
};
SetLagPrefix: PROC [fileName: PATH] = {
newPrefix: PATH Ź IF fileName# NIL THEN PFSNames.Parent[fileName] ELSE NIL;
IF lagPrefix # NIL THEN {
IF PFSNames.Equal[lagPrefix, newPrefix] THEN RETURN;
};
lagPrefix Ź newPrefix;
lagPrefixLen Ź PFSNames.ComponentCount[newPrefix];
};
AddSortOption: PROC [option: ATOM] = {
new: LORA Ź LIST[option];
IF sortDataTail = NIL THEN sortData Ź new ELSE sortDataTail.rest Ź new;
sortDataTail Ź new;
};
RemSortOption: PROC [option: ATOM] = {
lag: LORA Ź sortData;
IF lag = NIL THEN RETURN;
IF lag.first = option THEN {
sortData Ź sortData.rest;
RETURN};
FOR each: LORA Ź lag.rest, each.rest WHILE each # NIL DO
IF each.first = option THEN {lag.rest Ź each.rest; EXIT};
lag Ź each;
ENDLOOP;
};
gHost, gDir: ROPE Ź NIL;
out: STREAM = cmd.out;
lagPrefix: PATH Ź NIL;
lagPrefixLen: INT Ź 0;
patternsTried, filesSeen, bytesTotal: INT Ź 0;
briefPrint, complexSorting, fullPrint, attachPrint, keepPrint, lostFilesOnly, narrowPrint, oneLine, prefixOnly, typePrint, unattachedOnly, xactLevelMatch: BOOL Ź FALSE;
highestPrint: BOOL Ź cmd.procData.clientData = $Highest;
componentsRequired: INT Ź 0;
sortData: LORA Ź NIL;
sortDataTail: LORA Ź NIL;
pq: PriorityQueue.Ref Ź NIL;
argStream: IO.STREAM ~ IO.RIS[cmd.commandLine];
ProcessSwitches: PROC [arg: ROPE] = {
sense: BOOL Ź TRUE;
direction: {up, down} Ź down;
FOR index: INT IN [1..Rope.Length[arg]) DO
SELECT Rope.Fetch[arg, index] FROM
'~ => {sense Ź NOT sense; LOOP};
'> => direction Ź down;
'< => direction Ź up;
'a, 'A => attachPrint Ź sense;
'b, 'B => briefPrint Ź sense;
'd, 'D => {
RemSortOption[$MoreRecent];
RemSortOption[$LessRecent];
IF sense THEN
AddSortOption[IF direction = up THEN $LessRecent ELSE $MoreRecent];
};
'f, 'F => fullPrint Ź sense;
'h, 'H => highestPrint Ź sense;
'k, 'K => keepPrint Ź sense;
'n, 'N => narrowPrint Ź sense;
'o, 'O => oneLine Ź sense;
'p, 'P => prefixOnly Ź sense;
'r, 'R => {
};
's, 'S => {
RemSortOption[$Larger];
RemSortOption[$Smaller];
IF sense THEN
AddSortOption[IF direction = up THEN $Smaller ELSE $Larger];
};
't, 'T => typePrint Ź sense;
'u, 'U => unattachedOnly Ź sense;
'x, 'X => xactLevelMatch Ź sense;
'z, 'Z => lostFilesOnly Ź sense;
ENDCASE => {
result Ź $Failure; 
msg Ź Rope.Cat["Unknown switch: ", arg.Substr[0, index], " ", arg.Substr[index]];
RETURN;
};
sense Ź TRUE;
ENDLOOP;
};

DO
arg: Token = GetCmdToken[argStream ! QuotedStringError => {msg Ź "Mismatched quotes"; GO TO failed}];
IF arg.value = NIL THEN EXIT;
IF Rope.Length[arg.value] = 0 THEN LOOP;
IF Rope.Fetch[arg.literal, 0] = '- THEN {
ProcessSwitches[arg.literal];
IF result = $Failure THEN RETURN;
LOOP;
};
TryPattern[PFS.PathFromRope[arg.value ! PFS.Error => IF error.group # $bug THEN {
IO.PutRope[cmd.err, "  -- "];
IO.PutRope[cmd.err, error.explanation];
IO.PutRope[cmd.err, "\n"];
GO TO failed}]];
ENDLOOP;
IF patternsTried = 0 THEN TryPattern[PFS.PathFromRope["*" ! PFS.Error => IF error.group # $bug THEN {
IO.PutRope[cmd.err, "  -- "];
IO.PutRope[cmd.err, error.explanation];
IO.PutRope[cmd.err, "\n"];
GO TO failed}]];
IF oneLine THEN IO.PutChar[out, '\n];
IF filesSeen > 0 THEN {
out: IO.STREAM ~ IO.ROS[];
IO.PutF1[out, "-- %g files", [integer[filesSeen]] ];
IF bytesTotal > 0 THEN IO.PutF1[out, ", %g total bytes", [integer[bytesTotal]] ];
IO.PutChar[out, '\n];
msg Ź IO.RopeFromROS[out];
};
EXITS
failed => {result Ź $Failure};
};

FileItem: TYPE = REF FileItemRep;
FileItemRep: TYPE = RECORD [fullUName, attachedTo: PATH, created: GMT, bytes: INT, fileType: PFS.FileType];

SortPred: PriorityQueue.SortPred = {
xx: FileItem = NARROW[x];
yy: FileItem = NARROW[y];
options: LORA = NARROW[data];
FOR each: LORA Ź options, each.rest WHILE each # NIL DO
SELECT each.first FROM
$MoreRecent => {
IF xx.created = yy.created THEN LOOP;
RETURN [BasicTime.Period[xx.created, yy.created] < 0];
};
$LessRecent => {
IF xx.created = yy.created THEN LOOP;
RETURN [BasicTime.Period[xx.created, yy.created] > 0];
};
$Larger => {
IF xx.bytes = yy.bytes THEN LOOP;
RETURN [xx.bytes > yy.bytes];
};
$Smaller => {
IF xx.bytes = yy.bytes THEN LOOP;
RETURN [xx.bytes < yy.bytes];
};
ENDCASE;
ENDLOOP;
RETURN [PFSNames.Compare[xx.fullUName, yy.fullUName, FALSE] = less];
};


-- Stolen from DFUtilitiesImpl
DateFormat: TYPE = {explicit, omitted, greaterThan, notEqual};
Date: TYPE = RECORD [
format: DateFormat Ź $omitted,
gmt: GMT Ź BasicTime.nullGMT
];

DateToStream: PROC [s: STREAM, date: Date] = {
SELECT date.format FROM
$explicit => {
months: ROPE = "JanFebMarAprMayJunJulAugSepOctNovDec";
up: BasicTime.Unpacked = BasicTime.Unpack[date.gmt
! BasicTime.OutOfRange, BasicTime.TimeParametersNotKnown => GO TO noDate];
ConvertZone: PROC = {
dst: BOOL = up.dst = yes;
SELECT up.zone FROM
0 => IF ~dst THEN s.PutRope["GMT"];
NAT[5*BasicTime.minutesPerHour] => s.PutRope[IF dst THEN "EDT" ELSE "EST"];
NAT[6*BasicTime.minutesPerHour] => s.PutRope[IF dst THEN "CDT" ELSE "CST"];
NAT[7*BasicTime.minutesPerHour] => s.PutRope[IF dst THEN "MDT" ELSE "MST"];
NAT[8*BasicTime.minutesPerHour] => s.PutRope[IF dst THEN "PDT" ELSE "PST"];
ENDCASE =>
s.PutF["%g%02d%02d",
[character[IF up.zone < 0 THEN '- ELSE '+]],
[cardinal[up.zone.ABS/BasicTime.minutesPerHour]],
[cardinal[up.zone.ABS MOD BasicTime.minutesPerHour]]
]
};
s.PutF["%02d-%g-%02d ",
[cardinal[up.day]],
[rope[months.Substr[start: up.month.ORD*3, len: 3]]],
[cardinal[up.year MOD 100]]
];
s.PutF["%02d:%02d:%02d ",
[cardinal[up.hour]], [cardinal[up.minute]], [cardinal[up.second]]];
ConvertZone[];
};
$notEqual => s.PutRope["~="];
$greaterThan => s.PutChar['>];
ENDCASE;
EXITS
noDate => NULL;
};


deleteDoc: ROPE = "{switch | pattern}*
Deletes files matching pattern.
  -x	exact level match";

listDoc: ROPE = "{switch | pattern}*
Lists files matching pattern.
  -a	print attachments
  -b	brief format
  -d	date sort
  -f	full name print
  -h	highest version
  -k	keep print
  -n	narrow print
  -o	one line
  -p	prefixes only
  -s	size sort
  -t	file type print
  -x	exact level match
  -u	unattached files only
  -z	0-length files only
  ->	sort decreasing
  -<	sort increasing";

nameDoc: ROPE = "PFSName <positive decimal address> -- ";

prefixMapAddDoc: ROPE = "{-c|t} <prefix> <translation>
Adds a prefix map translation; omit <translation> to remove; -c means check if redefining and print out prev; -t means translate translation first.";

prefixMapPrintDoc: ROPE = "<prefix>
Prints a prefix map translation; omit <prefix> to print them all.";

prefixMapTranslateDoc: ROPE = "<path>
Translates <path> through the prefix map and prints the result.";

copyDoc: ROPE = "newFile _ oldFile  |  directory _ {pattern}*
Copies a file or files.
  -c	force copy
  -r	retain structure
  -u	update only
  -x	exact level match";

retrieveDoc: ROPE = "newFile _ oldFile  |  directory _ {pattern}*
Uses retrieve to copy a file or files (necessary for large xns files).
  -r	retain structure
  -u	update only
  -x	exact level match";

renameDoc: ROPE = "newFile _ oldFile  |  directory _ {pattern}*
Renames a file or files.
  -r	retain structure
  -u	update only
  -x	exact level match";


Init: PROC = {

Commander.Register["Delete", DeleteCommandProc, deleteDoc];
Commander.Register["Del", DeleteCommandProc, deleteDoc];

Commander.Register["LS", ListCommandProc, listDoc];
Commander.Register["LSH", ListCommandProc, listDoc, $Highest];
Commander.Register["List", ListCommandProc, listDoc];
Commander.Register["ListH", ListCommandProc, listDoc, $Highest];

Commander.Register["PFSPATH", NameCommandProc, nameDoc];

Commander.Register["PrefixMapAdd", PrefixMapAdd, prefixMapAddDoc];
Commander.Register["PMA", PrefixMapAdd, prefixMapAddDoc];
Commander.Register["PrefixMapPrint", PrefixMapPrint, prefixMapPrintDoc];
Commander.Register["PMP", PrefixMapPrint, prefixMapPrintDoc];
Commander.Register["PrefixMapTranslate", PrefixMapTranslate, prefixMapTranslateDoc];
Commander.Register["PMT", PrefixMapTranslate, prefixMapTranslateDoc];

Commander.Register["Copy", CopyAndRename, copyDoc, $Copy];
Commander.Register["Rename", CopyAndRename, renameDoc];
Commander.Register["Retrieve", CopyAndRename, retrieveDoc, $Retrieve];
};

Init[];

END.
   
Ŕ  
PFSCommandsImpl.mesa
Copyright Ó 1989, 1990, 1991 by Xerox Corporation.  All rights reserved.
Carl Hauser, August 24, 1989 4:43:16 pm PDT
Michael Plass, November 25, 1991 1:19 pm PST
Doug Wyatt, April 15, 1992 12:28 pm PDT
Last tweaked by Mike Spreitzer on February 7, 1990 12:12:30 pm PST
Chauser, September 28, 1990 11:16 am PDT
Willie-s, August 14, 1992 3:10 pm PDT
[cmd: Handle] RETURNS [result: REF _ NIL, msg: ROPE _ NIL]
CommandObject = [in, out, err: STREAM, commandLine, command: ROPE, ...]
[cmd: Handle] RETURNS [result: REF _ NIL, msg: ROPE _ NIL]
CommandObject = [in, out, err: STREAM, commandLine, command: ROPE, ...]
[cmd: Handle] RETURNS [result: REF _ NIL, msg: ROPE _ NIL]
CommandObject = [in, out, err: STREAM, commandLine, command: ROPE, ...]
[cmd: Handle] RETURNS [result: REF _ NIL, msg: ROPE _ NIL]
CommandObject = [in, out, err: STREAM, commandLine, command: ROPE, ...]
Delete Files
This is a switch, not a file name
Copying and Renaming
This file does not need a copy, since it has the same ID as the destination file.  We have been instructed to trust the ID.
If we get here, then for each of the filenames and patterns, copy the file to the destination directory.
[name: PATH] RETURNS [continue: BOOL]

List Command
[cmd: Handle] RETURNS [result: REF _ NIL, msg: ROPE _ NIL]
CommandObject = [in, out, err: STREAM, commandLine, command: ROPE, ...]
[name: PATH] RETURNS [continue: BOOL]
We may need the info
item: REF [fullUName, attachedTo: PATH, created: GMT, bytes: INT, keep: CARDINAL, PFS.FileType]
Factor out the directories
In these cases it is better to enumerate the names, then get the info
In these cases it is better to enumerate for info, to reduce server traffic
... sets the lagging prefix from the given file name, which is presumed to be syntactically correct, although it need not be complete.  A file name without a prefix will set the lagPrefix to NIL.  We also enforce lagPrefixLen = Rope.Length[lagPrefix] at exit, assuming that no other routine sets lagPrefix.
do we have a new prefix?
We have a new lagging prefix, so scan backwards for the LAST directory
-- remoteCheck _ sense;
This argument sets switches for the remaining patterns
Now the argument is assumed to be a file pattern.
[x: Item, y: Item, data: REF] RETURNS [BOOL]
Utilities

'gmt' is valid only if dateFormat = $explicit.  (We don't use a variant record because it complicates the client's life too much (i.e., the compiler is unnecessarily picky about assignments involving variant records that aren't REF-containing).)
Note:  Dates returned by ParseFromStream are guaranteed to have `gmt' = nullGMT if `format' ~= $explicit.  The other procedures of this interface ignore the 'gmt' field if 'format' ~= $explicit.
Initialization
Ę!  NewlineDelimiter
(cedarcode) style codeK
Ďe=HK+K,K'KBK(K%K Ďk		K
}K
,;K#KKKłźK	mX×K?QK5HKK*K2
JKK ĐlnK RKK KKKKK Ďn K 
 ;K	!KWK	KK K, 
MK&hStartOfExpansion6[pattern: ROPE, object: ROPE, case: BOOL _ TRUE]!)K	K[self: STREAM, char: CHAR] "K	QK!K#KKK  
4K)4KK K /
:KGK2	FK(K	/KK +K	KM* KK KSKKKK%KK!!K0KKK!!KK3IK)	#<K>YKK..KKKK K 1
:KGK2	FK	/K"K55*;K$''xKKK0K$ iKKKK K 5
:KGK2	FK	/K K7KK 1K$ gKKKK K 2
:KGK2	FK	/5LKE&K
AK
(K'KKKK head ,K	/KKK
KK*,KKKKK,NK$
(KKK	LkK#K!!K*K!K K"KKKKK
VK'KK'K,CK#(QK#dKKKKKK 
 	;K!K7BKK 
 	<KK7BKK L  (K!KK'8K	#0K	$1KKKKKKK  &KKXX	K	DK
*K(K'K	
U;K{{K99KKK
'3K,9KKJK 2K!$KK*K KKKKK K	/KKKK	K		K$$K%KK&&K K!KK""KK""KYYK	KKKK$SKKK,EKKK,KK"!%WK,7KAAK
1KKK%KKK Kh?K,K;;K
K "K	

K%K	KKK
,UK#'K;?KK,,K  KKK&/[K$$K7NK$$K
+&rKK00K49K$'K
QKK
KFNK,,K  K
KKKKKK  *
:KG. -- [fullFName: ROPE] RETURNS [continue: BOOL] K%KK+KK
*K

KKKK4UKKQjKK+K
1K<YKK!2KKKKKKK11KKK  KKKK9ZK+K
1KLVKK!2KKKKKKK11KKK  'K	
_KK3K
*KKK-K	-KK>MK	*KK)KKK	@K<>!#KK.2#KKKK*7KKK	"KK	-K 

= 
0KK%'KKK"K44KKK88K
$K66KK K27K@@K	K)1KE)1KKKK	&K2K)5KKKKKK+KK*=K+HK&&K 'Kżp˛KKKK&4KK8
FKK22K 
&K	KGKK 
&KKKK	8K9KKKKKKKK&.K¨K&8KK
KKK	/ %KK*"K KKKKKKKCKKKKKKKKKKKK

<KKK!K!!K  KKQQKKKKKK KV
eKK(!)K66KK!KKK11'QKK%'KKK
!eKK%'KKK	%K	K24K8QKKKKKK K
!	kK  $K,KKK		7K%K06KK%K06KK!KKK!KKKKK/
DKK 	 K KK.>KKKőőKKÂK  .K*62K<	J K	K#K*KK*KK*KK*K
K,K1K4KKKK$5KKKCCKKKKKK
KK  K  P_K 	őK 	,9K ˇĚK PgK LgK 	ĽK ˇČK K K  K K;;88K K33K>>K55K@@K K8K KBK9KHK=KTTKEEK K::K77KFFKK KK K     ^ú  Ç  