ref: 44ce0097b612a1fefd754065bdf8d9d2e5ef60c8
dir: /appl/lib/fsproto.b/
implement FSproto;
include "sys.m";
sys: Sys;
Dir: import Sys;
include "draw.m";
include "bufio.m";
bufio: Bufio;
Iobuf: import bufio;
include "string.m";
str: String;
include "readdir.m";
readdir: Readdir;
include "fsproto.m";
File: adt {
new: string;
elem: string;
old: string;
uid: string;
gid: string;
mode: int;
};
Proto: adt {
b: ref Iobuf;
doquote: int;
indent: int;
lineno: int;
newfile: string;
oldfile: string;
oldroot: string;
ec: chan of Direntry;
wc: chan of (string, string);
walk: fn(w: self ref Proto, f: ref File, level: int);
entry: fn(w: self ref Proto, old: string, new: string, d: ref Sys->Dir);
warn: fn(w: self ref Proto, s: string);
fatal: fn(w: self ref Proto, s: string);
};
init(): string
{
sys = load Sys Sys->PATH;
bufio = load Bufio Bufio->PATH;
if(bufio == nil)
return sys->sprint("%r");
str = load String String->PATH;
if(str == nil)
return sys->sprint("%r");
readdir = load Readdir Readdir->PATH;
if(readdir == nil)
return sys->sprint("%r");
return nil;
}
readprotofile(proto: string, root: string, entries: chan of Direntry, warnings: chan of (string, string)): string
{
b := bufio->open(proto, Sys->OREAD);
if(b == nil)
return sys->sprint("%r");
rdproto(b, root, entries, warnings);
return nil;
}
readprotostring(proto: string, root: string, entries: chan of Direntry, warnings: chan of (string, string))
{
rdproto(bufio->sopen(proto), root, entries, warnings);
}
rdproto(b: ref Iobuf, root: string, entries: chan of Direntry, warnings: chan of (string, string)): string
{
w := ref Proto;
w.b = b;
w.doquote = 1;
w.ec = entries;
w.wc = warnings;
w.oldroot = root;
w.lineno = 0;
w.indent = 0;
file := ref File;
file.mode = 0;
spawn walker(w, file);
return nil;
}
walker(w: ref Proto, file: ref File)
{
w.walk(file, -1);
w.entry(nil, nil, nil);
}
Proto.entry(w: self ref Proto, old: string, new: string, d: ref Sys->Dir)
{
if(w.ec != nil)
w.ec <-= (old, new, d);
}
Proto.warn(w: self ref Proto, s: string)
{
if(w.wc != nil)
w.wc <-= (w.oldfile, s);
else
sys->fprint(sys->fildes(2), "warning: %s\n", s);
}
Proto.fatal(w: self ref Proto, s: string)
{
if(w.wc != nil)
w.wc <-= (w.oldfile, s);
else
sys->fprint(sys->fildes(2), "fatal error: %s\n", s);
w.ec <-= (nil, nil, nil);
exit;
}
Proto.walk(w: self ref Proto, me: ref File, level: int)
{
(child, fp) := getfile(w, me);
if(child == nil)
return;
if(child.elem == "+" || child.elem == "*" || child.elem == "%"){
rec := child.elem[0] == '+';
filesonly := child.elem[0] == '%';
child.new = me.new;
setnames(w, child);
mktree(w, child, rec, filesonly);
(child, fp) = getfile(w, me);
}
while(child != nil && w.indent > level){
if(mkfile(w, child))
w.walk(child, w.indent);
(child, fp) = getfile(w, me);
}
if(child != nil){
w.b.seek(big fp, 0);
w.lineno--;
}
}
mktree(w: ref Proto, me: ref File, rec: int, filesonly: int)
{
fd := sys->open(w.oldfile, Sys->OREAD);
if(fd == nil){
w.warn(sys->sprint("can't open %s: %r", w.oldfile));
return;
}
child := ref *me;
(d, n) := readdir->init(w.oldfile, Readdir->NAME|Readdir->COMPACT);
for(i := 0; i < n; i++) {
if(filesonly && (d[i].mode & Sys->DMDIR))
continue;
child.new = mkpath(me.new, d[i].name);
if(me.old != nil)
child.old = mkpath(me.old, d[i].name);
child.elem = d[i].name;
setnames(w, child);
if(copyfile(w, child, d[i]) && rec)
mktree(w, child, rec, filesonly);
}
}
mkfile(w: ref Proto, f: ref File): int
{
(i, dir) := sys->stat(w.oldfile);
if(i < 0){
w.warn(sys->sprint("can't stat file %s: %r", w.oldfile));
skipdir(w);
return 0;
}
return copyfile(w, f, ref dir);
}
copyfile(w: ref Proto, f: ref File, d: ref Dir): int
{
d.name = f.elem;
if(f.mode != ~0){
if((d.mode&Sys->DMDIR) != (f.mode&Sys->DMDIR))
w.warn(sys->sprint("inconsistent mode for %s", f.new));
else
d.mode = f.mode;
}
w.entry(w.oldfile, w.newfile, d);
return (d.mode & Sys->DMDIR) != 0;
}
setnames(w: ref Proto, f: ref File)
{
w.newfile = f.new;
if(f.old != nil){
if(f.old[0] == '/')
w.oldfile = mkpath(w.oldroot, f.old);
else
w.oldfile = f.old;
}else
w.oldfile = mkpath(w.oldroot, f.new);
}
#
# skip all files in the proto that
# could be in the current dir
#
skipdir(w: ref Proto)
{
if(w.indent < 0)
return;
b := w.b;
level := w.indent;
for(;;){
w.indent = 0;
fp := b.offset();
p := b.gets('\n');
if(p != nil && p[len p - 1] != '\n')
p += "\n";
w.lineno++;
if(p == nil){
w.indent = -1;
return;
}
for(j := 0; (c := p[j++]) != '\n';)
if(c == ' ')
w.indent++;
else if(c == '\t')
w.indent += 8;
else
break;
if(w.indent <= level){
b.seek(fp, 0);
w.lineno--;
return;
}
}
}
getfile(w: ref Proto, old: ref File): (ref File, int)
{
p, elem: string;
c: int;
if(w.indent < 0)
return (nil, 0);
b := w.b;
fp := int b.offset();
do {
w.indent = 0;
p = b.gets('\n');
if(p != nil && p[len p - 1] != '\n')
p += "\n";
w.lineno++;
if(p == nil){
w.indent = -1;
return (nil, 0);
}
for(; (c = p[0]) != '\n'; p = p[1:])
if(c == ' ')
w.indent++;
else if(c == '\t')
w.indent += 8;
else
break;
} while(c == '\n' || c == '#');
(elem, p) = getname(w, p);
if(p == nil)
return (nil, 0);
f := ref File;
f.new = mkpath(old.new, elem);
(nil, f.elem) = str->splitr(f.new, "/");
if(f.elem == nil)
w.fatal(sys->sprint("can't find file name component of %s", f.new));
(f.mode, p) = getmode(w, p);
if(p == nil)
return (nil, 0);
(f.uid, p) = getname(w, p);
if(p == nil)
return (nil, 0);
if(f.uid == nil)
f.uid = "-";
(f.gid, p) = getname(w, p);
if(p == nil)
return (nil, 0);
if(f.gid == nil)
f.gid = "-";
f.old = getpath(p);
if(f.old == "-")
f.old = nil;
if(f.old == nil && old.old != nil)
f.old = mkpath(old.old, elem);
setnames(w, f);
return (f, fp);
}
getpath(p: string): string
{
for(; (c := p[0]) == ' ' || c == '\t'; p = p[1:])
;
for(n := 0; (c = p[n]) != '\n' && c != ' ' && c != '\t'; n++)
;
return p[0:n];
}
getname(w: ref Proto, p: string): (string, string)
{
for(; (c := p[0]) == ' ' || c == '\t'; p = p[1:])
;
i := 0;
s := "";
quoted := 0;
for(; (c = p[0]) != '\n' && (c != ' ' && c != '\t' || quoted); p = p[1:]){
if(quoted && c == '\'' && p[1] == '\'')
p = p[1:];
else if(c == '\'' && w.doquote){
quoted = !quoted;
continue;
}
s[i++] = c;
}
if(len s > 0 && s[0] == '$'){
s = getenv(s[1:]);
if(s == nil)
w.warn(sys->sprint("can't read environment variable %s", s));
}
return (s, p);
}
getenv(s: string): string
{
if(s == "user")
return readfile("/dev/user"); # more accurate?
return readfile("/env/"+s);
}
readfile(f: string): string
{
fd := sys->open(f, Sys->OREAD);
if(fd != nil){
a := array[256] of byte;
n := sys->read(fd, a, len a);
if(n > 0)
return string a[0:n];
}
return nil;
}
getmode(w: ref Proto, p: string): (int, string)
{
s: string;
(s, p) = getname(w, p);
if(s == nil || s == "-")
return (~0, p);
m := 0;
if(s[0] == 'd'){
m |= Sys->DMDIR;
s = s[1:];
}
if(s[0] == 'a'){
m |= Sys->DMAPPEND;
s = s[1:];
}
if(s[0] == 'l'){
m |= Sys->DMEXCL;
s = s[1:];
}
for(i:=0; i<len s || i < 3; i++)
if(i >= len s || !(s[i]>='0' && s[i]<='7')){
w.warn(sys->sprint("bad mode specification %s", s));
return (~0, p);
}
(v, nil) := str->toint(s, 8);
return (m|v, p);
}
mkpath(prefix, elem: string): string
{
slash1 := slash2 := 0;
if(len prefix > 0)
slash1 = prefix[len prefix - 1] == '/';
if(len elem > 0)
slash2 = elem[0] == '/';
if(slash1 && slash2)
return prefix+elem[1:];
if(!slash1 && !slash2)
return prefix+"/"+elem;
return prefix+elem;
}