Select Git revision
binkit.js 34.13 KiB
// $Id$
/*
* Intentionally simple "Advanced BinkleyTerm Style Outbound"
* mailer.
*
* Known limitations:
* 1) Does NOT support upper-case filenames in derived files/paths.
* This means that all .flo files must be in lower-case, all hex
* filename/path components must be in lower-case, and the ".pnt"
* directory extension must be in lower case.
* 2) Will not check in a zone-specified directory for the default
* zone. That is, if the default zone is zone 1, and the outbound
* is "/path/to/outbound", it will not correctly handle the case
* where there is a "/path/to/outbound.001" directory.
*
* See FTS-5005 for details.
*/
load('fido.js');
load('fidocfg.js');
load('binkp.js');
load('freqit_common.js');
var REVISION = "$Revision$".split(' ')[1];
var version_notice = "BinkIT/" + REVISION;
var semaphores = [];
FREQIT.add_file = function(filename, bp, cfg)
{
if (filename === undefined)
return;
if (FREQIT.files >= cfg.maxfiles)
return;
if (FREQIT.added[filename] !== undefined)
return;
bp.addFile(filename);
FREQIT.files++;
FREQIT.added[filename]='';
};
function lock_flow(file)
{
var ret = {
bsy:new File(file.replace(/\.[^\.]*?$/, '.bsy')),
};
// Takes ownership of a lockfile if it's more than six hours old.
/*
* Race-safe version...
* 1) If date is "too old", pick a random time in the future.
* 2) Set the file date to that random time.
* 3) Wait one second (there's still an unlikely race here)
* 4) If the file date is the random time you chose, set the date
* to now and take "ownership" of the file.
*/
function take_lockfile(f)
{
var orig_date;
var future;
var remain;
var now = time();
if (!f.exists)
return false;
// TODO: This is hacked for a signed 32-bit time_t... watch out in 2038!
orig_date = f.date;
if (orig_date > (now - 60*60*6)) {
log(LOG_INFO, format("Lock is too recent to override now (%ld) > six hours ago (%ld)", orig_date, now-60*60*6));
return false; }
remain = 0x80000000 - now;
future = now + random(remain);
f.date = future;
mswait(1000);
if (f.date != future) {
log(LOG_WARNING, format("Failed to set date in the future fdate (%ld) != future (%ld)", f.date, future));
return false;
}
if (!f.open("wb")) {
f.date = orig_date;
log(LOG_WARNING, "Error " + f.error + " opening " + f.name);
return false;
}
f.date = now;
return true;
}
log(LOG_DEBUG, "Locking "+ret.bsy.name);
if (!ret.bsy.open("wb")) { // Used to include 'e' mode flag (which never worked)
log(LOG_WARNING, "Error " + ret.bsy.error + " creating " + ret.bsy.name);
if (!take_lockfile(ret.bsy)) {
log(LOG_NOTICE, "Lock on "+ret.bsy.name+" failed.");
return undefined;
}
}
ret.bsy.writeln("BinkIT");
ret.bsy.flush();
log(LOG_DEBUG, "Lock successful.");
return ret;
}
function unlock_flow(locks)
{
log(LOG_DEBUG, "Unlocking "+locks.bsy.name+".");
if (locks.bsy !== undefined) {
locks.bsy.close();
locks.bsy.remove();
}
}
function outbound_root(addr, scfg)
{
if (FIDO.FTNDomains.outboundMap[addr.domain] === undefined)
return scfg.outbound.replace(/[\\\/]$/, '');
return FIDO.FTNDomains.outboundMap[addr.domain];
}
/*
* Given a list of addresses to rescan, calls
* bp.addFile() for any pending file transfers.
*
* TODO: Call this after sending a M_EOB to rescan per FSP-1024? We
* hold the lock files, so nothing should be changing the flow
* files (per FTS-5005) though. This is mostly for REQ handling,
* so if we do integrate freqit.js, we should be fine to ignore
* the spec on this point.
*/
function add_outbound_files(addrs, bp)
{
function has_lock(addr) {
var bsy = outbound_root(addr, bp.cb_data.binkit_scfg)+addr.flo_outbound(bp.default_zone, bp.default_domain)+'bsy';
var i;
for (i=0; i<bp.cb_data.binkit_locks.length; i++) {
if (bp.cb_data.binkit_locks[i].bsy.name === bsy)
return true;
}
return false;
}
addrs.forEach(function(addr) {
var lock_files;
log(LOG_DEBUG, "Adding outbound files for "+addr);
// Find all possible flow files for the remote.
var allfiles = directory(outbound_root(addr, bp.cb_data.binkit_scfg)+addr.flo_outbound(bp.default_zone, bp.default_domain)+'*');
// Parse flow files and call addFile() tracking what to do on success.
if (allfiles.length > 0) {
if (!has_lock(addr)) {
lock_files = lock_flow(outbound_root(addr, bp.cb_data.binkit_scfg)+addr.flo_outbound(bp.default_zone, bp.default_domain));
if (lock_files === undefined)
return;
bp.cb_data.binkit_locks.push(lock_files);
}
allfiles.forEach(function(file) {
var flo;
var line;
var action;
var i;
var fnchars = '0123456789abcdefghijklmnopqrstuvwxyz';
var fname;
switch(file_getext(file).toLowerCase()) {
case '.clo':
case '.dlo':
case '.flo':
case '.hlo':
case '.ilo':
flo = new File(file);
if (!flo.open("r")) {
log(LOG_ERROR, "Unable to open FLO file '"+flo.name+"'.");
break;
}
if (bp.cb_data.binkit_flow_contents[flo.name] === undefined)
bp.cb_data.binkit_flow_contents[flo.name] = [];
while((line = flo.readln(2048))) {
switch(line.charAt(0)) {
case '#':
if (bp.addFile(line.substr(1)))
bp.cb_data.binkit_file_actions[line.substr(1)] = 'TRUNCATE';
bp.cb_data.binkit_flow_contents[flo.name].push(line.substr(1));
break;
case '^':
case '-':
if (bp.addFile(line.substr(1)))
bp.cb_data.binkit_file_actions[line.substr(1)] = 'DELETE';
bp.cb_data.binkit_flow_contents[flo.name].push(line.substr(1));
break;
case '~':
case '!':
break;
case '@':
bp.addFile(line.substr(1));
bp.cb_data.binkit_flow_contents[flo.name].push(line.substr(1));
break;
default:
bp.addFile(line);
bp.cb_data.binkit_flow_contents[flo.name].push(line);
break;
}
}
flo.close();
break;
case '.cut':
case '.dut':
case '.hut':
case '.iut':
case '.out':
fname = ''; for (i=0; i<8; i++)
fname += fnchars[random(fnchars.length)];
fname += '.pkt';
if (bp.addFile(file, fname))
bp.cb_data.binkit_file_actions[file] = 'DELETE';
break;
case '.req':
fname = '';
for (i=0; i<8; i++)
fname += fnchars[random(fnchars.length)];
fname += '.req';
if (bp.addFile(file, fname))
bp.cb_data.binkit_file_actions[file] = 'DELETE';
break;
case '.bsy':
break;
default:
log(LOG_WARNING, "Unsupported flow file type '"+file+"'.");
break;
}
});
}
});
}
function callout_auth_cb(mode, bp)
{
/*
* Loop through remote addresses, building a list of the ones with
* the same password (if we used an empty password, no other nodes
* are allowed)
*/
var addrs = [];
if (bp.cb_data.binkitpw === undefined || bp.cb_data.binkitpw === '-')
addrs.push(bp.cb_data.binkit_to_addr);
else {
bp.remote_addrs.forEach(function(addr) {
if (bp.cb_data.binkitcfg.node[addr] !== undefined) {
if (bp.cb_data.binkitcfg.node[addr].pass === bp.cb_data.binkitpw)
addrs.push(addr);
}
else
log(LOG_DEBUG, "Unconfigured address "+addr);
});
}
add_outbound_files(addrs, bp);
}
/*
* Delete completed flo files.
*/
function tx_callback(fname, bp)
{
var j;
// Remove flow files that have been completely processed.
Object.keys(bp.cb_data.binkit_flow_contents).forEach(function(flo) {
if (file_exists(flo)) {
while ((j = bp.cb_data.binkit_flow_contents[flo].indexOf(fname)) !== -1)
bp.cb_data.binkit_flow_contents[flo].splice(j, 1);
if (bp.cb_data.binkit_flow_contents[flo].length == 0)
file_remove(flo);
}
});
}
function handle_freq(reqfname, bp)
{ var req=new File(reqfname);
var m;
var fname;
var pw;
var cfg = new FREQITCfg();
if (!req.open("r"))
return;
FREQIT.reset();
next_file:
while((fname=req.readln())) {
if ((m=fname.match(/^(.*) !(.*?)$/))!==null) {
pw=m[2];
fname=m[1];
}
// First, check for magic!
for (m in cfg.magic) {
if (m == fname.toLowerCase()) {
FREQIT.handle_magic(cfg.magic[m], bp, bp.authenticated === 'secure', pw, cfg);
continue next_file;
}
}
// Now, check for the file...
FREQIT.handle_regular(fname, bp, bp.authenticated === 'secure', pw, cfg);
}
}
function rename_or_move(src, dst)
{
var sf;
var df;
var buf;
var remain;
if (file_rename(src, dst))
return true;
sf = new File(src);
if (!sf.open("rb"))
return false;
df = new File(dst);
if (!df.open("wb")) { // Used to include 'e' mode flag (which never worked)
sf.close();
return false;
}
while (!sf.eof) {
// Read 2MB at a time...
remain = sf.length - sf.position;
if (remain === 0)
break;
if (remain > 0x200000)
remain = 0x200000;
buf = sf.read(remain);
if (!df.write(buf)) {
df.close();
df.remove();
sf.close();
return false;
}
}
df.close();
sf.close();
df.date = sf.date;
sf.remove();
return true;
}
function rx_callback(fname, bp)
{ var semname;
var secure_inbound = bp.cb_data.binkit_scfg.secure_inbound;
var inbound = bp.cb_data.binkit_scfg.inbound;
if (secure_inbound == undefined)
secure_inbound = inbound;
log(LOG_INFO, "Received file: " + fname + format(" (%1.1fKB)", file_size(fname) / 1024.0));
if (fname.search(/\.(?:pkt|su.|mo.|tu.|we.|th.|fr.|sa.)$/i) !== -1) {
semname = system.data_dir + 'fidoin.now';
if (semaphores.indexOf(semname) == -1)
semaphores.push(semname);
}
else if (fname.search(/\.tic$/i) !== -1) {
semname = system.data_dir + 'tickit.now';
if (semaphores.indexOf(semname) == -1)
semaphores.push(semname);
}
if (fname.search(/\.req$/i) !== -1) {
handle_freq(fname, bp);
file_remove(fname);
}
else {
if (bp.authenticated === 'secure') {
if (secure_inbound === undefined)
log(LOG_ERROR, "No secure inbound configured in sbbsecho! Leaving secure file as '"+fname+"'.");
else {
log(LOG_INFO, "Moving '"+fname+"' to '"+secure_inbound+file_getname(fname)+"'.");
if (!rename_or_move(fname, secure_inbound+file_getname(fname)))
return false;
}
}
else {
log(LOG_WARNING, "Non-secure session type: " + format("'%s'", bp.authenticated));
if (inbound === undefined)
log(LOG_ERROR, "No inbound configured in sbbsecho! Leaving insecure file as '"+fname+"'.");
else {
log(LOG_INFO, "Moving '"+fname+"' to '"+inbound+file_getname(fname)+"'.");
if (!rename_or_move(fname, inbound+file_getname(fname)))
return false;
}
}
}
return true;
}
function callout_want_callback(fobj, fsize, fdate, offset, bp)
{
/*
* TODO: Currently a copy/paste from binkp.js...
* Likely we'll want magical handling for control files (*.TIC,
* *.REQ, and *.PKT, Bundle Files, and the default handling for the
* rest.
*
* We should lower-case incoming filenames here too...
*
* Also, for partial files, we can cancel the remote and do an M_GET resume.
*
* Ok, so put active transfers into a temp directory somewhere with some way
* of tying it back to a set of address (we don't actually know which address it
* comes from, just a list of addresses it may come from) and store enough
* info to resume it. This means the partially transferred file and some sort
* of bookkeeping info file need to be tied together somewhere... maybe resume
* support is simply "too hard" to bother with?
*
* Once the file is completely received, move it to the final resting place
* (in rx_callback) and do any required processing then.
*/
// Reject duplicate filenames... a more robust callback would rename them. // Or process the old ones first.
if (this.received_files.indexOf(fobj.name) != -1)
return this.file.REJECT;
// Reject or skip existing files.
if (file_exists(fobj.name)) {
// If the size and date are the same, reject it.
if (fsize == file_size(fobj.name) && fdate == file_date(fobj.name))
return this.file.REJECT;
// Otherwise, skip it.
return this.file.SKIP;
}
// Accept everything else
return this.file.ACCEPT;
}
function callout_done(bp)
{
var f;
var lines;
var semname;
bp.sent_files.forEach(function(file) {
if (bp.cb_data.binkit_file_actions[file] !== undefined) {
switch(bp.cb_data.binkit_file_actions[file]) {
case 'TRUNCATE':
f = new File(file);
if (f.truncate())
log(LOG_INFO, "Truncated '"+f.name+"'.");
else
log(LOG_ERROR, "Unable to truncate '"+f.name+"'.");
break;
case 'DELETE':
if (file_remove(file))
log(LOG_INFO, "Removed '"+file+"'.");
else
log(LOG_ERROR, "Unable to remove '"+file+"'.");
}
}
});
Object.keys(bp.cb_data.binkit_flow_contents).forEach(function(key) {
if (bp.cb_data.binkit_flow_contents[key].length > 0) {
// We have some unsent files in here... re-write the flo file...
f = new File(key);
if (!f.open("r+")) {
log(LOG_ERROR, "Unable to update flow file '"+key+"'.");
return;
}
lines = f.readAll(2048);
f.truncate(0);
lines.forEach(function(line) {
switch(line[0]) {
case '#':
case '^':
case '-':
case '@':
if (bp.cb_data.binkit_flow_contents[key].indexOf(line.substr(1)) == -1)
f.writeln('~'+line.substr(1));
else
f.writeln(line);
break;
// Already skipped...
case '~':
case '!':
f.writeln(line);
break;
default:
if (bp.cb_data.binkit_flow_contents[key].indexOf(line) == -1)
f.writeln('~'+line);
else f.writeln(line);
break;
}
});
}
});
// Remove flow files that have been completely processed.
Object.keys(bp.cb_data.binkit_flow_contents).forEach(function(flo) {
if (file_exists(flo)) {
if (bp.cb_data.binkit_flow_contents[flo].length == 0)
file_remove(flo);
}
});
}
function callout(addr, scfg, locks, bicfg)
{
var myaddr = FIDO.parse_addr(system.fido_addr_list[0], 1, 'fidonet');
var bp = new BinkP(version_notice, undefined, rx_callback, tx_callback);
var port;
var host;
var f;
var success = false;
var src_addr;
log(LOG_INFO, format("%s callout to %s started", bp.revision, addr));
if (bicfg === undefined)
bicfg = new BinkITCfg();
bp.system_operator = bicfg.sysop;
bp.cb_data = {
binkitcfg:bicfg,
binkit_to_addr:addr,
binkit_scfg:scfg,
binkit_file_actions:{},
binkit_flow_contents:{},
binkit_locks:locks
};
if (bp.cb_data.binkitcfg.node[addr] !== undefined) {
bp.cb_data.binkitpw = bp.cb_data.binkitcfg.node[addr].pass;
port = bp.cb_data.binkitcfg.node[addr].port;
host = bp.cb_data.binkitcfg.node[addr].host;
bp.require_md5 = !(bp.cb_data.binkitcfg.node[addr].nomd5);
bp.require_crypt = !(bp.cb_data.binkitcfg.node[addr].nocrypt);
}
// TODO: Force debug mode for now...
bp.debug = true;
bp.default_zone = myaddr.zone;
bp.default_domain = myaddr.domain;
bp.want_callback = callout_want_callback;
if (bp.cb_data.binkitcfg.caps !== undefined)
bp.capabilities = bp.cb_data.binkitcfg.caps;
/*
* We can't use the defaults since the defaults are only 4D addresses,
* and the address we're calling from needs to be first...
*/
bp.addr_list = [];
system.fido_addr_list.forEach(function(faddr){
bp.addr_list.push(FIDO.parse_addr(faddr, this.default_zone));
}, this);
/*
* Set src_addr to the node we want first in our list. If
* SourceAddress is set for this node, use that. Otherwise, use the
* address we are contacting.
*/
if (bp.cb_data.binkitcfg.node[addr] !== undefined && bp.cb_data.binkitcfg.node[addr].src !== undefined)
src_addr = FIDO.parse_addr(bp.cb_data.binkitcfg.node[addr].src, 1);
else
src_addr = addr; // Sort by "distance" from src_addr address.
bp.addr_list.sort(function(addr1, addr2) {
var dist1;
var dist2;
if (addr1.str === src_addr.str)
return -1;
if (addr2.str === src_addr.str)
return 1;
if (addr1.domain !== addr2.domain) {
if (addr1.domain === src_addr.domain)
return -1;
if (addr2.domain === src_addr.domain)
return 1;
if (addr1.domain < addr2.domain)
return -1;
return 1;
}
if (addr1.zone !== addr2.zone) {
dist1 = Math.abs(addr1.zone - src_addr.zone);
dist2 = Math.abs(addr2.zone - src_addr.zone);
return dist1-dist2;
}
if (addr1.net !== addr2.net) {
dist1 = Math.abs(addr1.net - src_addr.net);
dist2 = Math.abs(addr2.net - src_addr.net);
return dist1-dist2;
}
if (addr1.node !== addr2.node) {
dist1 = Math.abs(addr1.node - src_addr.node);
dist2 = Math.abs(addr2.node - src_addr.node);
return dist1-dist2;
}
if (addr1.point !== addr2.point) {
dist1 = Math.abs(addr1.point - src_addr.point);
dist2 = Math.abs(addr2.point - src_addr.point);
return dist1-dist2;
}
return 0;
});
// We won't add files until the auth finishes...
success = bp.connect(addr, bp.cb_data.binkitpw, callout_auth_cb, port, host);
callout_done(bp);
}
function check_held(addr, scfg, myaddr)
{
var until;
var f = new File(outbound_root(addr, scfg)+addr.flo_outbound(myaddr.zone)+'.hld');
if (!f.exists)
return false;
if (!f.open("r")) {
log(LOG_ERROR, "Unable to open hold file '"+f.name+"'");
return true;
}
until = f.readln();
if (until.search(/^[0-9]+$/) !== 0) {
log(LOG_WARNING, "First line of '"+f.name+"' invalid ("+until+"). Should be a positive integer.");
return false;
}
f.close();
until = parseInt(until, 10);
if (until < time()) {
f.remove();
log(LOG_INFO, "Removed stale ("+system.timestr(until)+") hold file '"+f.name+"'.");
return false;
}
log(LOG_INFO, addr+" held until "+system.timestr(until)+"."); return true;
}
function run_one_outbound_dir(dir, scfg, ran)
{
var myaddr = FIDO.parse_addr(system.fido_addr_list[0], 1, 'fidonet');
var locks = [];
var addr;
var lock_files;
var ext;
var i;
var flow_files;
log(LOG_DEBUG, "Running outbound dir "+dir);
flow_files = directory(dir+'*.?ut').concat(directory(dir+'*.?lo'));
function flow_order(a, b) {
var flavour_order=['i','c','d','o','f','h'];
var type_order=['ut', 'lo'];
var aext = flavour_order.indexOf(a.substr(-3, 1).toLowerCase());
var bext = flavour_order.indexOf(b.substr(-3, 1).toLowerCase());
if (aext !== bext)
return aext - bext;
aext = type_order.indexOf(a.substr(-2, 2).toLowerCase());
bext = type_order.indexOf(b.substr(-2, 2).toLowerCase());
if (aext !== bext)
return aext - bext;
if (a < b)
return -1;
if (b < a)
return 1;
return 0;
}
while (!js.terminated) {
if (flow_files.length == 0)
break;
flow_files.sort(flow_order);
flow_file_loop:
for (i=0; i<flow_files.length; i++) {
try {
addr = FIDO.parse_flo_file_path(flow_files[i], myaddr.zone);
}
catch(addr_e) {
log(LOG_WARNING, addr_e+" when checking '"+flow_files[i]+"' (default zone: "+myaddr.zone+")");
continue;
}
if (ran[addr] !== undefined)
continue;
ext = file_getext(flow_files[i]);
// Ensure this is the "right" outbound (file case, etc)
if (flow_files[i] !== outbound_root(addr, scfg)+addr.flo_outbound(myaddr.zone)+ext.substr(1)) {
log(LOG_WARNING, "Unexpected file path '"+flow_files[i]+"' expected '"+outbound_root(addr, scfg)+addr.flo_outbound(myaddr.zone)+ext.substr(1)+"' (skipped)");
continue;
}
switch(ext.substr(0, 2)) {
case '.h':
log(LOG_DEBUG, "Skipping hold flavoured flow file '"+flow_files[i]+"'.");
continue;
case '.c':
case '.d':
case '.i': break;
case '.f':
if (ext === '.flo')
break;
log(LOG_WARNING, "Unknown flow file flavour '"+flow_files[i]+"'.");
continue;
case '.o':
if (ext === '.out')
break;
log(LOG_WARNING, "Unknown flow file flavour '"+flow_files[i]+"'.");
continue;
default:
log(LOG_WARNING, "Unknown flow file flavour '"+flow_files[i]+"'.");
continue;
}
if ((lock_files = lock_flow(flow_files[i]))!==undefined) {
if (check_held(addr, scfg, myaddr)) {
unlock_flow(lock_files);
continue;
}
break;
}
}
if (i<flow_files.length) {
log(LOG_INFO, "Attempting callout for " + addr + ", file: " + flow_files[i]);
locks.push(lock_files);
// Use a try/catch to ensure we clean up the lock files.
callout(addr, scfg, locks);
ran[addr] = true;
locks.forEach(unlock_flow);
}
else {
log(LOG_DEBUG, "No flow files to be processed.");
break;
}
}
log(LOG_DEBUG, "Done checking in "+dir+".");
}
function touch_semaphores()
{
semaphores.forEach(function(semname) {
log(LOG_DEBUG, "Touching semaphore file: " + semname);
file_touch(semname);
});
}
function run_outbound(ran)
{
var scfg;
var outbound_dirs=[];
var outbound_roots=[];
var scfg_ob;
log(LOG_DEBUG, "Running outbound");
scfg = new SBBSEchoCfg();
if (!scfg.is_flo) {
log(LOG_ERROR, "sbbsecho not configured for FLO-style mailers.");
return false;
}
Object.keys(FIDO.FTNDomains.outboundMap).forEach(function(key) {
outbound_roots.push(FIDO.FTNDomains.outboundMap[key]);
});
scfg_ob = scfg.outbound.replace(/[\\\/]$/, '');
if (outbound_roots.indexOf(scfg_ob) == -1)
outbound_roots.push(scfg_ob);
log(LOG_DEBUG, "Outbound roots: " + JSON.stringify(outbound_roots, null, 0)); outbound_roots.forEach(function(oroot) {
var dirs;
function addDir(dir) {
var bdir = backslash(dir);
if (outbound_dirs.indexOf(bdir) == -1)
outbound_dirs.push(bdir);
}
if (file_isdir(oroot))
addDir(oroot);
else {
log(LOG_NOTICE, "Skipping non-existent outbound directory: " + oroot);
return;
}
dirs = directory(oroot+'.*', 0);
dirs.forEach(function(dir) {
var pnts;
var ext = file_getext(dir);
if (ext === undefined)
return;
if (ext.search(/^\.[0-9a-f]+$/) == 0) {
if (file_isdir(dir)) {
addDir(dir);
pnts = directory(backslash(dir)+'.pnt', false);
pnts.forEach(function(pdir) {
if (pdir.search(/[\\\/][0-9a-z]{8}.pnt$/) >= 0 && file_isdir(pdir))
addDir(pdir);
else
log(LOG_WARNING, "Unhandled/Unexpected point path '"+pdir+"'.");
});
}
else
log(LOG_WARNING, "Unexpected file in outbound '"+dir+"'.");
}
else
log(LOG_WARNING, "Unhandled outbound '"+dir+"'.");
});
});
log(LOG_DEBUG, "Outbound dirs: " + JSON.stringify(outbound_dirs, null, 0));
outbound_dirs.forEach(function(dir) {
run_one_outbound_dir(dir, scfg, ran);
});
}
/*
* MysticBBS v1.12A39 at least has an issue when the CRYPT
* option is included after the CRAM-MD5 challenge. It appends
* three NULs to the end of the challenge data. If the remote told
* us it was Mystic, see if that matches.
*/
function mystic_broken_cram(bp)
{
var dot;
var min;
var ver;
if (bp.remote_ver === undefined)
return false;
if (bp.remote_ver.substr(0, 7) !== 'Mystic/')
return false;
if (bp.wont_crypt)
return false;
/*
* TODO: This is in case Mystic/1.12A39 has both a working and
* non-working build. Hopefully, this is not the case, and this
* block can be removed.
*/
if (bp.remote_ver === 'Mystic/1.12A39') return false;
ver = bp.remote_ver.substr(7);
for (dot = 0; dot < ver.length; dot++) {
if (ver[dot] == '.')
break;
}
if (parseInt(ver.substr(0, dot), 10) < 1)
return true;
if (parseInt(ver.substr(0, dot), 10) > 1)
return false;
for (min = dot + 1; min < ver.length; min++) {
if (ver[min] < '0' || ver[min] > '9')
break;
}
if (parseInt(ver.substr(dot+1, min-1), 10) < 12)
return true;
if (parseInt(ver.substr(dot+1, min-1), 10) > 12)
return false;
if (min > ver.length)
return false;
if (ver[min] != 'A')
return false;
if (parseInt(ver.substr(min+1), 10) <= 39)
return true;
return false;
}
function inbound_auth_cb(pwd, bp)
{
/*
* Loop through remote addresses, building a list of the ones with
* the same password that we can send mail for.
*/
var addrs = [];
var ret = '-';
var nocrypt;
var invalid=false;
function check_nocrypt(node) {
if (node) {
if (nocrypt === undefined)
nocrypt = true;
}
else {
nocrypt = false;
}
}
bp.remote_addrs.forEach(function(addr) {
var cpw;
if (bp.cb_data.binkitcfg.node[addr] !== undefined) {
log(LOG_INFO, "Inbound session for: " + addr);
cpw = bp.cb_data.binkitcfg.node[addr].pass;
if (cpw === undefined)
cpw = '-';
if (pwd[0].substr(0, 9) === 'CRAM-MD5-') {
if (mystic_broken_cram(bp))
bp.cram.challenge += '\x00\x00\x00';
var expected = bp.getCRAM('MD5', cpw);
if (expected === pwd[0]) {
log(LOG_INFO, "CRAM-MD5 password match for " + addr);
addrs.push(addr);
check_nocrypt(bp.cb_data.binkitcfg.node[addr]);
ret = cpw;
} else {
log(LOG_WARNING, "CRAM-MD5 password mismatch for " + addr
+ format(" (expected: %s, received: %s)", expected, pwd[0]));
/* * TODO: This is in case Mystic/1.12A39 has both a working and
* non-working build. Hopefully, this is not the case, and this
* block can be removed.
*/
if (bp.remote_ver !== undefined && bp.remote_ver === 'Mystic/1.12A39') {
log(LOG_INFO, "Checking Mystic pass...");
bp.cram.challenge += '\x00\x00\x00';
expected = bp.getCRAM('MD5', cpw);
if (expected === pwd[0]) {
log(LOG_INFO, "Mystic CRAM-MD5 password match for " + addr);
addrs.push(addr);
check_nocrypt(bp.cb_data.binkitcfg.node[addr]);
ret = cpw;
}
else
invalid = true;
}
else
invalid = true;
}
}
else {
// TODO: Deal with arrays of passwords?
if (!bp.cb_data.binkitcfg.node[addr].nomd5) // AllowPlainPasswords=false
log(LOG_WARNING, "CRAM-MD5 required (and not provided) by " + addr);
else if (bp.cb_data.binkitcfg.node[addr].pass === pwd[0]) {
log(LOG_INFO, "Plain-text password match for " + addr);
addrs.push(addr);
check_nocrypt(bp.cb_data.binkitcfg.node[addr]);
ret = cpw;
}
else {
log(LOG_WARNING, "Plain-text password mismatch for " + addr);
invalid = true;
}
}
}
else
log(LOG_DEBUG, "Unconfigured address "+addr);
});
if (addrs.length === 0) {
if (invalid) {
bp.sendCmd(bp.command.M_ERR, "Password mismatch");
}
else {
// If we have NONE of their nodes configured, we can send them files for ALL of them.
addrs = bp.remote_addrs;
// And allow unencrypted sessions.
nocrypt = true;
}
}
else {
// If we have SOME of their nodes configured, only send them files for authenticated ones.
bp.remote_addrs = addrs;
// Require encryption unless all configured nodes say otherwise.
if (nocrypt === undefined)
nocrypt = false;
}
bp.require_crypt = !nocrypt;
add_outbound_files(addrs, bp);
return ret;
}
function run_inbound(sock)
{
var myaddr = FIDO.parse_addr(system.fido_addr_list[0], 1, 'fidonet');
var bp = new BinkP(version_notice, undefined, rx_callback, tx_callback);
var port;
var f; var success = false;
var locks = [];
log(LOG_INFO, bp.revision + " inbound connection from " +sock.remote_ip_address+":"+sock.remote_port);
bp.cb_data = {
binkitcfg:new BinkITCfg(),
binkit_scfg:new SBBSEchoCfg(),
binkit_file_actions:{},
binkit_flow_contents:{},
binkit_locks:locks
};
bp.system_operator = bp.cb_data.binkitcfg.sysop;
// TODO: Force debug mode for now...
bp.debug = true;
bp.default_zone = myaddr.zone;
bp.default_domain = myaddr.domain;
bp.want_callback = callout_want_callback;
if (bp.cb_data.binkitcfg.caps !== undefined)
bp.capabilities = bp.cb_data.binkitcfg.caps;
// We can't use the defaults since the defaults are only 4D addresses.
bp.addr_list = [];
system.fido_addr_list.forEach(function(faddr){bp.addr_list.push(FIDO.parse_addr(faddr, this.default_zone));}, this);
// We won't add files until the auth finishes...
success = bp.accept(sock, inbound_auth_cb);
callout_done(bp);
locks.forEach(function(lock) {
unlock_flow(lock);
});
}
function poll_node(addr_str, scfg, bicfg, myaddr)
{
var lock_files;
var locks = [];
if (scfg === undefined)
scfg = new SBBSEchoCfg();
if (myaddr === undefined)
myaddr = FIDO.parse_addr(system.fido_addr_list[0], 1, 'fidonet');
var addr = FIDO.parse_addr(addr_str, 1, 'fidonet');
var outbound_dir = outbound_root(addr, scfg);
log(LOG_DEBUG, "poll_node " + addr_str + ", outbound_dir: " + outbound_dir);
if(file_isdir(outbound_dir)) {
if ((lock_files = lock_flow(outbound_dir + addr.flo_outbound(myaddr.zone))) === undefined)
return;
else {
if (check_held(addr, scfg, myaddr)) {
unlock_flow(lock_files);
return;
}
}
}
log(LOG_INFO, "Attempting poll for node "+addr);
if(lock_files !== undefined)
locks.push(lock_files);
// Use a try/catch to ensure we clean up the lock files.
callout(addr, scfg, locks, bicfg);
locks.forEach(unlock_flow);
}
function run_polls(ran)
{ var scfg;
var bicfg;
var myaddr;
var locks = [];
log(LOG_DEBUG, "Running polls");
scfg = new SBBSEchoCfg();
bicfg = new BinkITCfg();
myaddr = FIDO.parse_addr(system.fido_addr_list[0], 1, 'fidonet');
Object.keys(bicfg.node).forEach(function(addr_str) {
if (!bicfg.node[addr_str].poll)
return;
var addr = FIDO.parse_addr(addr_str, 1, 'fidonet');
if (ran[addr] !== undefined)
return;
poll_node(addr_str, scfg, bicfg, myaddr);
ran[addr] = true;
});
}
// First-time installation routine (only)
function install()
{
var cnflib = load({}, "cnflib.js");
var xtrn_cnf = cnflib.read("xtrn.cnf");
if (!xtrn_cnf)
return "Failed to read xtrn.cnf";
var changed = false;
if (!xtrn_area.event["binkout"]) {
printf("Adding timed event: BINKOUT\r\n");
xtrn_cnf.event.push( {
"code": "BINKOUT",
"cmd": "?binkit",
"days": 255,
"time": 0,
"node_num": 1,
"settings": 0,
"startup_dir": "",
"freq": 0,
"mdays": 0,
"months": 0
});
changed = true;
}
if (!xtrn_area.event["binkpoll"]) {
printf("Adding timed event: BINKPOLL\r\n");
xtrn_cnf.event.push( {
"code": "BINKPOLL",
"cmd": "?binkit -p",
"days": 255,
"time": 0,
"node_num": 1,
"settings": 0,
"startup_dir": "",
"freq": 60,
"mdays": 0,
"months": 0
});
changed = true;
}
if (changed && !cnflib.write("xtrn.cnf", undefined, xtrn_cnf))
return "Failed to write xtrn.cnf";
var ini = new File(file_cfgname(system.ctrl_dir, "sbbsecho.ini")); if (!ini.open(file_exists(ini.name) ? 'r+':'w+'))
return ini.name + " open error " + ini.error;
printf("Updating %s\r\n", ini.name);
ini.iniSetValue(null, "BinkleyStyleOutbound", true);
ini.iniSetValue(null, "OutgoingSemaphore", "../data/binkout.now");
var links = ini.iniGetAllObjects("addr", "node:");
for (var i in links) {
if (links[i].addr.toUpperCase().indexOf('ALL') >= 0) // Don't include wildcard links
continue;
var password = links[i].PacketPwd ? links[i].PacketPwd : links[i].AreaFixPwd;
ini.iniSetValue("node:"+links[i].addr, "SessionPwd", password === undefined ? '' : password);
ini.iniSetValue("node:"+links[i].addr, "Poll", links[i].GroupHub ? true : false);
}
ini.close();
ini = new File(file_cfgname(system.ctrl_dir, "services.ini"));
if (!ini.open(file_exists(ini.name) ? 'r+':'w+'))
return ini.name + " open error " + ini.error;
if(!ini.iniGetObject("BINKP") && !ini.iniGetObject("BINKIT")) {
printf("Updating %s\r\n", ini.name);
var section = "BINKP";
ini.iniSetValue(section, "Enabled", true);
ini.iniSetValue(section, "Command", "binkit.js");
ini.iniSetValue(section, "Port", 24554);
}
ini.close();
return true;
}
// Upgrade from separate binkit.ini/sbbsecho.ini/ftn_domains.ini to a combined sbbsecho.ini
function upgrade()
{
var sbbsecho_ini = new File(file_cfgname(system.ctrl_dir, "sbbsecho.ini"));
if (!sbbsecho_ini.open('r+'))
return sbbsecho_ini.name + " open error " + sbbsecho_ini.error;
printf("Updating %s\r\n", sbbsecho_ini.name);
var binkit_ini = new File(file_cfgname(system.ctrl_dir, "binkit.ini"));
if(binkit_ini.open("r")) {
sbbsecho_ini.iniSetValue("BinkP", "Capabilities", binkit_ini.iniGetValue(null, "Capabilities", ""));
sbbsecho_ini.iniSetValue("BinkP", "Sysop", binkit_ini.iniGetValue(null, "Sysop", ""));
var nodes = sbbsecho_ini.iniGetSections("node:");
var links = binkit_ini.iniGetSections();
for(var i in links) {
var section = "node:" + links[i];
for(var n in nodes) {
if(nodes[n] + '@' == section.substr(0, nodes[n].length + 1)) {
section = nodes[n];
break;
}
}
var obj = sbbsecho_ini.iniGetObject(section);
if(obj == null)
obj = {};
sbbsecho_ini.iniRemoveSection(section);
obj.SessionPwd = binkit_ini.iniGetValue(links[i], "Password", "");
obj.BinkpHost = binkit_ini.iniGetValue(links[i], "host", "");
obj.BinkpPort = binkit_ini.iniGetValue(links[i], "port", 24554);
obj.BinkpPoll = binkit_ini.iniGetValue(links[i], "poll", false);
obj.BinkpAllowPlainAuth = binkit_ini.iniGetValue(links[i], "AllowPlainPassword", false);
obj.BinkpAllowPlainText = binkit_ini.iniGetValue(links[i], "AllowUnencrypted", false);
obj.BinkpSourceAddress = binkit_ini.iniGetValue(links[i], "SourceAddress", "");
print("Writing");
print(JSON.stringify(obj, null, 4));
sbbsecho_ini.iniSetObject("node:" + links[i], obj);
}
binkit_ini.close();
file_rename(binkit_ini.name, binkit_ini.name + ".old");
}
/* Merge ftn_domains.ini -> sbbsecho.ini */
var domains_ini = new File(file_cfgname(system.ctrl_dir, "ftn_domains.ini"));
if(domains_ini.open("r")) {
var domains = domains_ini.iniGetAllObjects("name");
for(var d in domains) {
var section = "domain:" + domains[d].name;
delete domains[d].name;
sbbsecho_ini.iniSetObject(section, domains[d]);
}
domains_ini.close();
file_rename(domains_ini.name, domains_ini.name + ".old");
}
sbbsecho_ini.close();
return true;
}
var sock;
try {
sock = client.socket;
}
catch(e) {}
var ran = {};
var i;
var addr;
log(LOG_INFO, version_notice + " invoked with options: " + argv.join(' '));
// If we're running as a service, call run_inbound().
if (sock !== undefined && sock.descriptor !== -1)
run_inbound(sock);
else {
if (argv.indexOf('install') !== -1) {
var result = install();
if (result != true) {
alert(result);
exit(1);
}
exit(0);
}
if (argv.indexOf('upgrade') !== -1) {
var result = upgrade();
if (result != true) {
alert(result);
exit(1);
}
exit(0);
}
if (argv.indexOf('-l') !== -1) {
for (i=0; i<argv.length; i++) {
if (argv[i] === '-l') {
i++;
if (argv[i] === undefined) {
log(LOG_ERROR, 'No link specified with -l');
continue;
}
try {
FIDO.parse_addr(argv[i]);
}
catch(e_addr) {
log(LOG_ERROR, "Error parsing address '"+argv[i]+"'.");
continue;
}
poll_node(argv[i]);
}
} }
else {
if (argv.indexOf('-P') !== -1)
run_polls(ran);
else {
run_outbound(ran);
if (argv.indexOf('-p') !== -1)
run_polls(ran);
}
}
}
touch_semaphores();