Message base configuration now stored in page 99999 of zone
This commit is contained in:
parent
8cd978f76e
commit
018ee63853
129
load/msgbases.js
129
load/msgbases.js
@ -12,6 +12,7 @@ function MsgAreas() {
|
|||||||
var zone_id;
|
var zone_id;
|
||||||
var zone_name;
|
var zone_name;
|
||||||
var ma;
|
var ma;
|
||||||
|
var cfg = [];
|
||||||
|
|
||||||
// Load the message areas
|
// Load the message areas
|
||||||
for (var g in msg_area.grp_list) {
|
for (var g in msg_area.grp_list) {
|
||||||
@ -22,6 +23,7 @@ function MsgAreas() {
|
|||||||
ma.group_id = g;
|
ma.group_id = g;
|
||||||
ma.sub_id = a;
|
ma.sub_id = a;
|
||||||
|
|
||||||
|
// Work out the zone by the FTN address of the area
|
||||||
if (msg_area.grp_list[g].name.indexOf(':') === -1) {
|
if (msg_area.grp_list[g].name.indexOf(':') === -1) {
|
||||||
// If the sub is enabled for FTN, and the zone < 9999, then we'll us that if zone_id is undefined
|
// If the sub is enabled for FTN, and the zone < 9999, then we'll us that if zone_id is undefined
|
||||||
if ((msg_area.grp_list[g].sub_list[a].settings & SUB_FIDO) && msg_area.grp_list[g].sub_list[a].fidonet_addr) {
|
if ((msg_area.grp_list[g].sub_list[a].settings & SUB_FIDO) && msg_area.grp_list[g].sub_list[a].fidonet_addr) {
|
||||||
@ -29,22 +31,49 @@ function MsgAreas() {
|
|||||||
if ((x > 0) && (x < 9999)) {
|
if ((x > 0) && (x < 9999)) {
|
||||||
zone_id = x.padStart(4,'0');
|
zone_id = x.padStart(4,'0');
|
||||||
zone_name = msg_area.grp_list[g].name;
|
zone_name = msg_area.grp_list[g].name;
|
||||||
}
|
|
||||||
|
} else {
|
||||||
|
zone_id = undefined;
|
||||||
|
zone_name = undefined;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
} else {
|
||||||
|
zone_id = undefined;
|
||||||
|
zone_name = undefined;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Work out the zone by the name, where name is zone_id:name
|
||||||
} else {
|
} else {
|
||||||
zone_id = msg_area.grp_list[g].name.split(':')[0];
|
zone_id = msg_area.grp_list[g].name.split(':')[0];
|
||||||
zone_name = msg_area.grp_list[g].name.split(':')[1];
|
zone_name = msg_area.grp_list[g].name.split(':')[1];
|
||||||
}
|
}
|
||||||
|
|
||||||
if (zone_id) {
|
if (zone_id) {
|
||||||
|
if (cfg[zone_id] === undefined) {
|
||||||
|
log(LOG_DEBUG,'Opening internal:'+FRAMES_MSG_BASE+' to work out subs for zone: '+zone_id);
|
||||||
|
var internal = new MsgArea();
|
||||||
|
internal.code = FRAMES_MSG_BASE;
|
||||||
|
|
||||||
|
var conf = internal.get('1'+zone_id+'99999a');
|
||||||
|
|
||||||
|
// @todo Quick hack for scripts
|
||||||
|
if (SESSION_EXT === undefined)
|
||||||
|
var SESSION_EXT = 'tex';
|
||||||
|
|
||||||
|
if (conf !== undefined)
|
||||||
|
cfg[zone_id] = conf.content[SESSION_EXT].content.map(function(item) { return item.toLowerCase(); });
|
||||||
|
else
|
||||||
|
cfg[zone_id] = [];
|
||||||
|
}
|
||||||
|
|
||||||
ma.zone_id = zone_id;
|
ma.zone_id = zone_id;
|
||||||
ma.zone_name = zone_name;
|
ma.zone_name = zone_name;
|
||||||
|
ma.code = msg_area.grp_list[g].sub_list[a].code;
|
||||||
|
|
||||||
|
// Our area_id can be embedded in the name of the area
|
||||||
if (msg_area.grp_list[g].sub_list[a].name.indexOf(':') !== -1) {
|
if (msg_area.grp_list[g].sub_list[a].name.indexOf(':') !== -1) {
|
||||||
var sublist = msg_area.grp_list[g].sub_list[a].name.split(':');
|
var sublist = msg_area.grp_list[g].sub_list[a].name.split(':');
|
||||||
ma.area_id = sublist[0];
|
ma.area_id = sublist[0];
|
||||||
ma.area_name = sublist[1];
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
writeln(' code:'+ma.code);
|
writeln(' code:'+ma.code);
|
||||||
@ -52,12 +81,28 @@ function MsgAreas() {
|
|||||||
writeln(' pageprefix:'+ma.page_prefix)
|
writeln(' pageprefix:'+ma.page_prefix)
|
||||||
writeln();
|
writeln();
|
||||||
*/
|
*/
|
||||||
|
log(LOG_DEBUG,'Hard set index to ['+ma.area_id+'] for: '+ma.code);
|
||||||
|
|
||||||
|
// Otherwise we get our area_id from the configuration - page 999 of the zone
|
||||||
|
} else {
|
||||||
|
var index = (cfg[zone_id].indexOf(msg_area.grp_list[g].sub_list[a].code)+1).toString().padStart(2,'0');
|
||||||
|
|
||||||
|
// Make sure that index isnt already defined
|
||||||
|
if (this.areas.filter(function(item) { return (item.zone_id === zone_id) && (item.area_id === index); }).length) {
|
||||||
|
log(LOG_ERROR,'! ERROR: Prefix ['+index+'] already defined in ['+zone_id+'], ignoring ['+ma.code+']');
|
||||||
|
|
||||||
|
} else if ((cfg[zone_id] !== undefined) && cfg[zone_id].length) {
|
||||||
|
if (index === '00')
|
||||||
|
ma.area_id = undefined;
|
||||||
|
else
|
||||||
|
ma.area_id = index;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
this.areas.push(ma);
|
this.areas.push(ma);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/* List areas that we do and dont manage */
|
/* List areas that we do and dont manage */
|
||||||
Object.defineProperty(this,'list',{
|
Object.defineProperty(this,'list',{
|
||||||
@ -98,14 +143,14 @@ function MsgAreas() {
|
|||||||
if (area === undefined)
|
if (area === undefined)
|
||||||
return undefined;
|
return undefined;
|
||||||
|
|
||||||
return this.areas.filter(function(x) {
|
return (((area.length === 6) && (NUMERIC_REGEX.test(area)))
|
||||||
// If the area is a 6 digits, then its a page prefix, otherwise its an area code name
|
? this.areas.filter(function(x) {
|
||||||
if ((area.length === 6) && (NUMERIC_REGEX.test(area)))
|
|
||||||
return x.page_prefix === area;
|
return x.page_prefix === area;
|
||||||
|
})
|
||||||
|
|
||||||
else
|
: this.areas.filter(function(x) {
|
||||||
return x.code === area;
|
return x.code === area;
|
||||||
}).pop();
|
})).pop();
|
||||||
}
|
}
|
||||||
|
|
||||||
// @todo review
|
// @todo review
|
||||||
@ -130,13 +175,18 @@ function MsgArea() {
|
|||||||
this.area_id = undefined; // Sub Area ID for this message area, eg: 01
|
this.area_id = undefined; // Sub Area ID for this message area, eg: 01
|
||||||
this.area_name = undefined; // Sub Area Name for this message area, eg: CHAT
|
this.area_name = undefined; // Sub Area Name for this message area, eg: CHAT
|
||||||
this.group_id = undefined; // SBBS Message Group ID
|
this.group_id = undefined; // SBBS Message Group ID
|
||||||
this.sub_id = undefined; // SBBS Message Sub ID
|
this.__properties__ = {
|
||||||
|
code: undefined, // SBBS Message Sub Internal Code
|
||||||
|
};
|
||||||
|
|
||||||
// MSG Base Code
|
// MSG Base Code
|
||||||
Object.defineProperty(this,'code',{
|
Object.defineProperty(this,'code',{
|
||||||
get: function() {
|
get: function() {
|
||||||
//writeln('group_id:'+this.group_id+' sub_id:'+this.sub_id);
|
return this.__properties__.code;
|
||||||
return msg_area.grp_list[this.group_id].sub_list[this.sub_id].code;
|
},
|
||||||
|
|
||||||
|
set: function(code) {
|
||||||
|
this.__properties__.code = code;
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
@ -150,7 +200,7 @@ function MsgArea() {
|
|||||||
msgbase = this.msgbase;
|
msgbase = this.msgbase;
|
||||||
|
|
||||||
} else if (this.managed) {
|
} else if (this.managed) {
|
||||||
msgbase = new MsgAreas().getArea(FRAMES_MSG_BASE).msgbase;
|
msgbase = new MsgBase(FRAMES_MSG_BASE);
|
||||||
regex = this.page_prefix_regex;
|
regex = this.page_prefix_regex;
|
||||||
|
|
||||||
} else
|
} else
|
||||||
@ -220,16 +270,15 @@ function MsgArea() {
|
|||||||
Object.defineProperty(this,'last_tagged_message',{
|
Object.defineProperty(this,'last_tagged_message',{
|
||||||
get: function() {
|
get: function() {
|
||||||
var last_tag = this.frames.sort(function(a,b) {
|
var last_tag = this.frames.sort(function(a,b) {
|
||||||
if (a.when_imported_time === b.when_imported_time)
|
return (a.when_imported_time !== b.when_imported_time)
|
||||||
return a.number > b.number
|
? a.when_imported_time > b.when_imported_time
|
||||||
else
|
: a.number > b.number;
|
||||||
return (a.when_imported_time > b.when_imported_time);
|
|
||||||
}).pop();
|
}).pop();
|
||||||
|
|
||||||
if (last_tag === undefined)
|
if (last_tag === undefined)
|
||||||
return undefined;
|
return undefined;
|
||||||
|
|
||||||
var msgbase = new MsgAreas().getArea(FRAMES_MSG_BASE).msgbase;
|
var msgbase = new MsgBase(FRAMES_MSG_BASE);
|
||||||
|
|
||||||
try {
|
try {
|
||||||
if (msgbase.open()) {
|
if (msgbase.open()) {
|
||||||
@ -413,6 +462,48 @@ function MsgArea() {
|
|||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
|
// Get message header for page
|
||||||
|
MsgArea.prototype.get = function(page) {
|
||||||
|
if (this.code !== FRAMES_MSG_BASE)
|
||||||
|
return undefined;
|
||||||
|
|
||||||
|
var msgbase = this.msgbase;
|
||||||
|
var msgs = [];
|
||||||
|
|
||||||
|
try {
|
||||||
|
if (msgbase.open()) {
|
||||||
|
log(LOG_DEBUG,'Looking for ['+page+'] in ['+this.code+']');
|
||||||
|
|
||||||
|
var index = msgbase
|
||||||
|
.get_all_msg_headers();
|
||||||
|
|
||||||
|
for (var x in index)
|
||||||
|
if ((index[x].from === 'SYSTEM') && (index[x].to === page))
|
||||||
|
msgs.push(index[x]);
|
||||||
|
|
||||||
|
if (msgs.length) {
|
||||||
|
var msg = msgs.sort(function(a,b) {
|
||||||
|
return (a.when_imported_time !== b.when_imported_time)
|
||||||
|
? a.when_imported_time > b.when_imported_time
|
||||||
|
: a.number > b.number;
|
||||||
|
}).pop();
|
||||||
|
|
||||||
|
return this.getContent(msg.number);
|
||||||
|
|
||||||
|
} else {
|
||||||
|
return undefined;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
} catch (e) {
|
||||||
|
log(LOG_ERROR,this.code+' cannot be opened (frames):'+e.message);
|
||||||
|
|
||||||
|
return undefined;
|
||||||
|
}
|
||||||
|
|
||||||
|
return content;
|
||||||
|
}
|
||||||
|
|
||||||
// Get frame content
|
// Get frame content
|
||||||
MsgArea.prototype.getContent = function(id) {
|
MsgArea.prototype.getContent = function(id) {
|
||||||
// @todo If this is for a echomail/netmail content, then we need to switch message bases
|
// @todo If this is for a echomail/netmail content, then we need to switch message bases
|
||||||
@ -429,8 +520,10 @@ function MsgArea() {
|
|||||||
// Our messages are terminated with FRAMES_EOF_MARKER
|
// Our messages are terminated with FRAMES_EOF_MARKER
|
||||||
var regex = new RegExp('^(.*)'+FRAMES_EOF_MARKER);
|
var regex = new RegExp('^(.*)'+FRAMES_EOF_MARKER);
|
||||||
//log(LOG_DEBUG,'MARKER:'+regex.test(raw));
|
//log(LOG_DEBUG,'MARKER:'+regex.test(raw));
|
||||||
if (! regex.test(raw))
|
if (! regex.test(raw)) {
|
||||||
|
msgbase.close();
|
||||||
return undefined;
|
return undefined;
|
||||||
|
}
|
||||||
|
|
||||||
var regex = new RegExp(FRAMES_EOF_MARKER+'[.\\s\\S]*$');
|
var regex = new RegExp(FRAMES_EOF_MARKER+'[.\\s\\S]*$');
|
||||||
|
|
||||||
@ -640,7 +733,7 @@ function MsgArea() {
|
|||||||
*/
|
*/
|
||||||
MsgArea.prototype.tag_msgs = function() {
|
MsgArea.prototype.tag_msgs = function() {
|
||||||
var msgs = this.untagged;
|
var msgs = this.untagged;
|
||||||
var msgbase = new MsgAreas().getArea(FRAMES_MSG_BASE).msgbase;
|
var msgbase = new MsgBase(FRAMES_MSG_BASE);
|
||||||
var page_next = this.page_next;
|
var page_next = this.page_next;
|
||||||
|
|
||||||
writeln('* We have '+msgs.length+' messages to tag, starting at '+page_next);
|
writeln('* We have '+msgs.length+' messages to tag, starting at '+page_next);
|
||||||
|
@ -288,7 +288,7 @@ function Page(debug) {
|
|||||||
Object.defineProperty(this,'date',{
|
Object.defineProperty(this,'date',{
|
||||||
get: function() {
|
get: function() {
|
||||||
if (this.__properties__.date !== undefined)
|
if (this.__properties__.date !== undefined)
|
||||||
return strftime("%a, %d %b %Y %I:%M:%S %z",this.__properties__.date);
|
return strftime("%a, %d %b %Y %H:%M:%S %z",this.__properties__.date);
|
||||||
},
|
},
|
||||||
|
|
||||||
set: function(int) {
|
set: function(int) {
|
||||||
@ -375,7 +375,7 @@ function Page(debug) {
|
|||||||
this.__properties__.name = object;
|
this.__properties__.name = object;
|
||||||
|
|
||||||
if ((''+this.__properties__.name.frame).length > FRAME_PAGE_LENGTH-1-FRAME_ATTR_LENGTH)
|
if ((''+this.__properties__.name.frame).length > FRAME_PAGE_LENGTH-1-FRAME_ATTR_LENGTH)
|
||||||
throw new Error('Pagenum too large');
|
throw new Error('Pagenum too large - '+(''+this.__properties__.name.frame).length+'|'+(FRAME_PAGE_LENGTH-1-FRAME_ATTR_LENGTH));
|
||||||
|
|
||||||
switch (SESSION_EXT) {
|
switch (SESSION_EXT) {
|
||||||
case 'tex':
|
case 'tex':
|
||||||
@ -1319,7 +1319,7 @@ function Page(debug) {
|
|||||||
* Save the frame to the message base
|
* Save the frame to the message base
|
||||||
*/
|
*/
|
||||||
this.save = function() {
|
this.save = function() {
|
||||||
var msgbase = new MsgAreas().getArea(FRAMES_MSG_BASE).msgbase;
|
var msgbase = new MsgBase(FRAMES_MSG_BASE);
|
||||||
|
|
||||||
if (! msgbase.open()) {
|
if (! msgbase.open()) {
|
||||||
log(LOG_ERROR,'! Message Base cannot be opened (save): ['+msgbase.error+']');
|
log(LOG_ERROR,'! Message Base cannot be opened (save): ['+msgbase.error+']');
|
||||||
@ -1344,9 +1344,8 @@ function Page(debug) {
|
|||||||
|
|
||||||
var body = LZString.compressToBase64(JSON.stringify(page))+FRAMES_EOF_MARKER;
|
var body = LZString.compressToBase64(JSON.stringify(page))+FRAMES_EOF_MARKER;
|
||||||
|
|
||||||
if (! msgbase.save_msg(hdr,body)) {
|
if (! msgbase.save_msg(hdr,body))
|
||||||
log(LOG_ERROR,' ! Error saving frame: ['+this.name.toString()+']');
|
log(LOG_ERROR,' ! Error saving frame: ['+this.name.toString()+']');
|
||||||
}
|
|
||||||
|
|
||||||
msgbase.close();
|
msgbase.close();
|
||||||
return true;
|
return true;
|
||||||
|
@ -12,6 +12,9 @@ if (argv.length !== 1) {
|
|||||||
var ma = new MsgAreas();
|
var ma = new MsgAreas();
|
||||||
var area = ma.getArea(argv[0]);
|
var area = ma.getArea(argv[0]);
|
||||||
|
|
||||||
|
if (area === undefined)
|
||||||
|
throw Error('Area:'+argv[0]+' is not defined.');
|
||||||
|
|
||||||
writeln('Opening ['+argv[0]+'] - ('+area.code+')');
|
writeln('Opening ['+argv[0]+'] - ('+area.code+')');
|
||||||
|
|
||||||
var msgbase = area.msgbase;
|
var msgbase = area.msgbase;
|
||||||
|
Loading…
Reference in New Issue
Block a user