From 5cf1e9108ee916f405d84e7a9122fa9f988ab3d4 Mon Sep 17 00:00:00 2001
From: deuce <>
Date: Thu, 14 Jan 2016 21:00:03 +0000
Subject: [PATCH] Start of an "Advanced BinkleyTerm Style Outbound" mailer
using binkp/1.1 Most if it is still TODO.
---
exec/binkit.js | 186 +++++++++++++++++++++++++++++++++++++++++++++++++
1 file changed, 186 insertions(+)
create mode 100644 exec/binkit.js
diff --git a/exec/binkit.js b/exec/binkit.js
new file mode 100644
index 0000000000..3e59a5f76b
--- /dev/null
+++ b/exec/binkit.js
@@ -0,0 +1,186 @@
+/*
+ * Intentionally simple "Advanced BinkleyTerm Style Outbound"
+ * mailer.
+ *
+ * See FTS-5005 for details.
+ */
+
+load("binkp.js");
+load("fidocfg.js");
+
+function addr_from_path(path)
+{
+ // Convert a path into a 4D fidonet address
+ // TODO: 5D based on root outbound name.
+
+}
+
+function insense(str)
+{
+ if (system.platform !== 'Win32')
+ return str.replace(/[a-zA-Z]/g, function(c) {
+ return '['+c.toUpperCase()+c.toLowerCase()+']';
+ });
+ return str;
+}
+
+function lock_flow(file, csy)
+{
+ var ret = {
+ bsy:new File(file.replace(/\.*?$/, '.bsy')),
+ cst:new File(file.replace(/\.*?$/, '.csy'))
+ };
+
+ if (!ret.bsy.open("web")) {
+ // TODO: The suggested check if it's stale introduces a race condition.
+ return undefined;
+ }
+ if (csy) {
+ if (!ret.csy.open("web")) {
+ bsy.close();
+ bsy.remove();
+ return undefined;
+ }
+ }
+ ret.bsy.writeln("BinkIT");
+ if (csy)
+ ret.csy.writeln("BinkIT");
+ return ret;
+}
+
+function unlock_flow(locks)
+{
+ if (locks.csy !== undefined) {
+ locks.csy.close();
+ locks.csy.remove();
+ }
+ if (locks.bsy !== undefined) {
+ locks.bsy.close();
+ locks.bsy.remove();
+ }
+}
+
+function callout_rx_callback(fname)
+{
+ // TODO: Handle received files.
+}
+
+function callout_want_callback(fobj, fsize, fdate, offset)
+{
+ /*
+ * 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.
+ */
+
+ // 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;
+ // Skip existing files.
+ if (file_exists(fobj.name))
+ return this.file.SKIP;
+ // Accept everything else
+ return this.file.ACCEPT;
+}
+
+function callout(file, scfg)
+{
+ /*
+ * TODO: We can force 5D stuff here by adding a "fidonet" argument
+ * in parse_addr()
+ */
+ var myaddr = FIDO.parse_addr(system.fido_addr_list[0], 1);
+ var bp = new BinkP('BinkIT/'+("$Revision$".split(' ')[1]), undefined, callout_rx_callback);
+
+ // Force debug mode for now...
+ bp.debug = true;
+ bp.default_zone = myaddr.zone;
+ bp.default_domain = maddr.domain;
+ bp.want_callback = callout_want_callback;
+ bp.rx_callback = callout_rx_callback;
+
+ // We won't add files until the auth finishes...
+ /*
+ * TODO: We're currently using the packet password... this is not
+ * only not a good idea, it's a BAD idea since the session password
+ * is not transmitted in the clear but packet passwords are.
+ */
+}
+
+function run_one_outbound_dir(dir, scfg)
+{
+ var flow_files;
+ var lock_files;
+ var i;
+
+ log(LOG_DEBUG, "Running outbound dir "+dir);
+
+ // First, look for any node with pending netmail and handle that node.
+ while (!js.terminated) {
+ flow_files = directory(dir+insense('*.?ut'));
+ if (flow_files.length == 0)
+ break;
+ for (i=0; i<flow_files.length; i++) {
+ // Find one we can create a .bsy and .csy file for...
+ if (file_getext(flow_files[i]).substr(0,2).search(/^\.[icdo]$/i) !== 0)
+ continue;
+ if ((lock_files = lock_flow(flow_files[i], true))!==undefined)
+ break;
+ }
+ if (i<flow_files.length) {
+ log(LOG_DEBUG, "Attempting callout for file "+flow_files[i]);
+ // Use a try/catch to ensure we clean up the lock files.
+ try {
+ callout(flow_files[i], scfg);
+ }
+ catch(e) {
+ unlock_flow(lock_files);
+ throw(e);
+ }
+ unlock_flow(lock_files);
+ }
+ else
+ break;
+ }
+}
+
+function run_outbound()
+{
+ var scfg;
+ var outbound_base;
+ var outbound_dirs=[];
+ var tmp;
+
+ log(LOG_DEBUG, "Running outbound");
+ scfg = new SBBSEchoCfg();
+
+ if (!scfg.is_flo) {
+ log(LOG_ERROR, "sbbsecho not configured for FLO-style mailers.");
+ return false;
+ }
+ outbound_dirs = [];
+ if (file_isdir(scfg.outbound))
+ outbound_dirs.push(scfg.outbound);
+ tmp = directory(scfg.outbound.replace(/[\\\/]$/,'')+'.*', 0);
+ tmp.forEach(function(dir) {
+ var pnts;
+
+ if (file_getext(dir).search(/^\.[0-9a-fA-F]+$/) == 0) {
+ if (file_isdir(dir)) {
+ outbound_dirs.push(backslash(dir));
+ pnts = directory(backslash(dir)+insense(".pnt"), false);
+ pnts.forEach(function(pdir) {
+ if (pdir.search(/[0-9a-zA-Z]{8}.[Pp][Nn][Tt]$/) >= 0 && file_isdir(pdir))
+ outbound_dirs.push(backslash(pdir));
+ });
+ }
+ }
+ });
+ outbound_dirs.forEach(function(dir) {
+ run_one_outbound_dir(dir, scfg);
+ });
+}
+
+run_outbound();
--
GitLab