Created new "Inter-BBS Instant Message" module.

exec/sbbsimsg.js

+// sbbsimsg.js
+
+load("sbbsdefs.js");
+load("nodedefs.js");
+
+// Global vars
+var imsg_user;
+var last_user=0;
+
+print("\1n\1hSynchronet \1cInstant Message \1wModule \1nv1.00 Alpha\r\n");
+
+// Parse arguments
+for(i=0;i<argc;i++)
+	if(argv[i].toLowerCase()=="-l") {
+		list_users(true);
+		exit();
+	}
+
+// Truncate space off end of string
+function truncsp(str)
+{
+	var len;
+
+	while((len=str.length)!=0 && str.charAt(len-1)==' ')
+		str=str.slice(0,-1);
+
+	return(str);
+}
+
+function list_users(show)
+{
+	imsg_user = new Array();
+
+	fname = system.ctrl_dir + "sbbsimsg.lst";
+
+	f = new File(fname);
+	if(!f.open("r")) {
+		alert("Error opening " + fname);
+		exit();
+	}
+
+	text = f.readAll();
+	f.close();
+
+	for(line in text) {
+		while(text[line].charAt(0)==' ')	// skip prepended spaces
+			text[line]=text[line].slice(1);
+		if(text[line].charAt(0)==';')		// comment
+			continue;
+		if(text[line]==system.inetaddr)
+			continue;
+		sock = new Socket();
+		if(!sock.connect(text[line],79)) {
+			log(format("!Finger connection to %s FAILED with error %d"
+				,text[line],sock.last_error));
+			continue;
+		}
+		sock.send("\r\n");	// Get list of active users
+		var response=new Array();
+		while(bbs.online && sock.is_connected) 
+			response.push(truncsp(sock.readline()));
+		sock.close();
+
+		// Skip header
+		while(response.length && response[0].charAt(0)!='-')
+			response.shift();
+		response.shift();
+		if(!response.length)
+			continue;
+
+		for(i in response) {
+			if(response[i]=="")
+				continue;
+			if(show && !imsg_user.length) // first user, show hostname
+				print(format("\1n\1h%s\1n",text[line]));
+
+			if(show)
+				print(format("\1h\1y%.25s\1n\1g %.48s"
+					,response[i],response[i].slice(26)));
+			var u = new Object;
+			u.host = text[line];
+			u.name = format("%.25s",response[i]);
+			u.name = truncsp(u.name);
+			imsg_user.push(u);
+		}
+	}
+}
+
+function send_msg(dest, msg)
+{
+
+	if((hp = dest.indexOf('@'))==-1) {
+		alert("Invalid user");
+		exit();
+	}
+	host = dest.slice(hp+1);
+
+	sock = new Socket();
+	//sock.debug = true;
+	do {
+		if(!sock.connect(host,25)) {
+			alert("Connection to " + host + " failed with error " + sock.last_error);
+			break;
+		}
+
+		if(Number((rsp=sock.recvline()).slice(0,3))!=220) {
+			alert("Invalid connection response:\r\n" + rsp);
+			break;
+		}
+		sock.send("HELO "+system.inetaddr+"\r\n");
+		if(Number((rsp=sock.recvline()).slice(0,3))!=250) {
+			alert("Invalid HELO response: " + rsp);
+			break;
+		}
+		sock.send("SOML FROM: "+user.email+"\r\n");
+		if(Number((rsp=sock.recvline()).slice(0,3))!=250) {
+			alert("Invalid SOML response: " + rsp);
+			break;
+		}
+		sock.send("RCPT TO: "+dest+"\r\n");
+		if(Number((rsp=sock.recvline()).slice(0,3))!=250) {
+			alert("Invalid RCPT TO response: " + rsp);
+			break;
+		}
+		sock.send("DATA\r\n");
+		if(Number((rsp=sock.recvline()).slice(0,3))!=354) {
+			alert("Invalid DATA response: " + rsp);
+			break;
+		}
+		sock.send(msg);
+		sock.send("\r\n.\r\n");
+		if(Number((rsp=sock.recvline()).slice(0,3))!=250) {
+			alert("Invalid end of message response: " + rsp);
+			break;
+		}
+		sock.send("QUIT\r\n");
+		print("Message delivered successfully.");
+
+	} while(0);
+
+	sock.close();
+}
+
+function getmsg()
+{
+	var lines=0;
+	var msg="";
+
+	while(bbs.online && lines<5) {
+		console.print("\1n: \1h");
+		str=console.getstr(76,K_WRAP);
+		if(str=="")
+			break;
+		msg+=str;
+		msg+="\r\n";
+		lines++;
+	}
+
+	if(!lines || !bbs.online || bbs.sys_status&SS_ABORT)
+		return("");
+
+	return(msg);
+}
+
+list_users(true);	// Needed to initialize user[]
+console.crlf();
+
+var key;
+while(bbs.online) {
+	console.line_counter=0;	// defeat pause
+	console.print("\1n\1h\1bInter-BBS: ");
+	console.mnemonics("~Telegram, ~Message, ~List, or ~Quit: ");
+	bbs.sys_status&=~SS_ABORT;
+	while(bbs.online && !(bbs.sys_status&SS_ABORT)) {
+		key=console.inkey(K_UPPER);
+		if(key=='Q' || key=='L' || key=='T' || key=='M' || key=='\r')
+			break;
+		if(system.node_list[bbs.node_num-1].misc&(NODE_MSGW|NODE_NMSG)) {
+			console.line_counter=0;	// defeat pause
+			console.saveline();
+			console.crlf();
+			bbs.nodesync();
+			console.crlf();
+			console.restoreline();
+		}
+	}
+//	printf("key=%s\r\n",key);
+	switch(key) {
+		case 'L':
+			print("\1h\1cList\r\n");
+			list_users(true);
+			console.crlf();
+			break;
+		case 'T':
+			printf("\1h\1cTelegram\r\n\r\n");
+			printf("\1n\1h\1y(user@hostname): \1w");
+			if(imsg_user.length)
+				dest=format("%s@%s",imsg_user[last_user].name,imsg_user[last_user].host);
+			else
+				dest="";
+			dest=console.getstr(dest,64,K_EDIT);
+			if(dest==null || dest=='' || bbs.sys_status&SS_ABORT)
+				break;
+			if((msg=getmsg())=='')
+				break;
+			send_msg(dest,msg);
+			console.crlf();
+			break;
+		case 'M':
+			print("\1h\1cMessage\r\n");
+			if(!imsg_user.length) {
+				alert("No users!\r\n");
+				break;
+			}
+			done=false;
+			while(bbs.online && !done) {
+				printf("\r\1n\1h<> \1y%-25s \1c%s\1>"
+					,imsg_user[last_user].name,imsg_user[last_user].host);
+				switch(console.getkey(K_UPPER|K_NOECHO)) {
+					case '+':
+					case '>':
+					case ']':
+					case '\x06':	/* right arrow */
+					case 'N':
+					case '\n':		/* dn arrrow */
+						last_user++;
+						if(last_user>=imsg_user.length)
+							last_user=0;
+						break;
+
+					case '-':
+					case '<':
+					case '[':
+					case '\x1d':	/* left arrow */
+					case 'P':
+					case '\x1e':	/* up arrow */
+						last_user--;
+						if(last_user<0)
+							last_user=imsg_user.length-1;
+						break;
+					case '\x1b':	/* ESC */
+					case 'Q':
+						printf("\r\1>");
+						done=true;
+						break;
+					case '\r':
+						done=true;
+						console.crlf();
+						if((msg=getmsg())=='')
+							break;
+						send_msg(format("%s@%s"
+							,imsg_user[last_user].name,imsg_user[last_user].host),msg);
+						console.crlf();
+						break;
+				}
+			}
+			break;
+		default:
+			print("\1h\1cQuit");
+			exit();
+			break;
+	}
+}
\ No newline at end of file