mirror
/
gridtracker
kopia lustrzana https://gitlab.com/gridtracker.org/gridtracker
1
0
Forkuj 0
Kod Zgłoszenia Projekty Wydania Wiki Aktywność
gridtracker/package.nw/lib/adifWorker.js

655 wiersze
18 KiB
JavaScript
Czysty Wina Historia

var GT = {};
importScripts("protos.js");
importScripts("gtCommon.js");
GT.workerFunctions =
{
init: initGlobals,
clear: clearQSO,
parse: onAdiLoadComplete
};
onmessage = (event) =>
{
if ("type" in event.data)
{
if (event.data.type in GT.workerFunctions)
{
GT.workerFunctions[event.data.type](event.data);
}
else console.log("adifWorker: unknown event type : " + event.data.type);
}
else console.log("adifWorker: no event type");
};
function initGlobals(task)
{
GT.dxccInfo = task.dxccInfo; // null geo
for (const key in GT.dxccInfo)
{
GT.dxccInfo[key].geo = null;
}
GT.dxccToCountryCode = task.dxccToCountryCode;
GT.directCallToDXCC = task.directCallToDXCC;
GT.directCallToITUzone = task.directCallToITUzone;
GT.directCallToCQzone = task.directCallToCQzone;
GT.prefixToITUzone = task.prefixToITUzone;
GT.prefixToCQzone = task.prefixToCQzone;
GT.prefixToMap = task.prefixToMap;
GT.gridToState = task.gridToState;
GT.modes = task.modes;
GT.modes_phone = task.modes_phone;
GT.QSOhash = task.QSOhash;
var returnTask = {};
returnTask.type = "loaded";
postMessage(returnTask);
}
function clearQSO(task)
{
GT.QSOhash = {};
var returnTask = {};
returnTask.type = "cleared"
returnTask.clearFiles = task.clearFiles;
returnTask.nextFunc = task.nextFunc;
postMessage(returnTask);
}
const myTextEncoder = new TextEncoder();
const myTextDecoder = new TextDecoder();
function onAdiLoadComplete(task)
{
GT.appSettings = task.appSettings;
GT.myQsoCalls = {};
GT.myQsoGrids = {};
var liveLog = task.liveLog;
var confirmed = false;
var rows = 0;
var lastHash = null;
var validAdifFile = true;
var eQSLfile = false;
var clublogFile = false;
var lotwTimestampUpdated = false;
if (task.rawAdiBuffer.indexOf("PSKReporter") > -1) validAdifFile = false;
if (task.rawAdiBuffer.indexOf("Received eQSLs") > -1) eQSLfile = true;
if (task.rawAdiBuffer.indexOf("clublog.adif") > -1 || task.rawAdiBuffer.indexOf("ADIF export from Club Log") > -1) clublogFile = true;
var eorRegEx = new RegExp("<EOR>", "i");
if (validAdifFile == true && task.rawAdiBuffer.length > 1)
{
var startPos = 0;
var endPos = task.rawAdiBuffer.length;
while (startPos != endPos)
{
let eor = task.rawAdiBuffer.substring(startPos).search(eorRegEx);
if (eor != -1)
{
let row = task.rawAdiBuffer.substring(startPos, startPos + eor);
startPos += eor + 5; // skip <EOR>
let object = parseADIFRecordStrict(row);
let confSource = null;
let lotwConfirmed = false;
confirmed = false;
if (object.APP_LOTW_RXQSO)
{
var dRXQSO = Date.parse(object.APP_LOTW_RXQSO);
if ((isNaN(dRXQSO) == false) && dRXQSO > 0 && dRXQSO > task.lotw_qso)
{
// add a second
dRXQSO += 1000;
task.lotw_qso = dRXQSO;
lotwTimestampUpdated = true;
}
}
if (object.APP_LOTW_RXQSL)
{
var dRXQSL = Date.parse(object.APP_LOTW_RXQSL);
if ((isNaN(dRXQSL) == false) && dRXQSL > 0 && dRXQSL > task.lotw_qsl)
{
// add a second
dRXQSL += 1000;
task.lotw_qsl = dRXQSL;
lotwTimestampUpdated = true;
}
lotwConfirmed = true;
}
var finalDEcall = "";
if (object.STATION_CALLSIGN)
{
finalDEcall = object.STATION_CALLSIGN.replace("_", "/");
}
if (finalDEcall == "")
{
finalDEcall = GT.appSettings.myCall;
}
GT.myQsoCalls[finalDEcall] = true;
if (GT.appSettings.workingCallsignEnable && !(finalDEcall in GT.appSettings.workingCallsigns))
{
// not in the working callsigns, move to next
continue;
}
var finalTime = 0;
if (object.QSO_DATE && object.TIME_ON)
{
var dateTime = new Date(
Date.UTC(
object.QSO_DATE.substr(0, 4),
parseInt(object.QSO_DATE.substr(4, 2)) - 1,
object.QSO_DATE.substr(6, 2),
object.TIME_ON.substr(0, 2),
object.TIME_ON.substr(2, 2),
object.TIME_ON.substr(4, 2)
)
);
finalTime = parseInt(dateTime.getTime() / 1000);
}
if (GT.appSettings.workingDateEnable && finalTime < GT.appSettings.workingDate)
{
// Not after our working date
continue;
}
var myGrid = (object.MY_GRIDSQUARE || "").toUpperCase();
if (myGrid.length > 3)
{
let finalMyGrid = myGrid.substr(0, 4);
GT.myQsoGrids[finalMyGrid] = true;
if (GT.appSettings.workingGridEnable && !(finalMyGrid in GT.appSettings.workingGrids))
{
// not in the working grids, move to next
continue;
}
}
var finalDXcall = (object.CALL || "").replace("_", "/");
var finalGrid = (object.GRIDSQUARE || "").toUpperCase();
var vuccGrids = (object.VUCC_GRIDS || "").toUpperCase();
var finalVucc = [];
var finalRSTsent = (object.RST_SENT || "");
var finalRSTrecv = (object.RST_RCVD || "");
var finalBand = (object.BAND || "").toLowerCase();
if (finalBand == "" || finalBand == "oob")
{
finalBand = formatBand(Number(object.FREQ || 0));
}
var finalPropMode = (object.PROP_MODE || "").toUpperCase();
var finalSatName = (object.SAT_NAME || "").toUpperCase();
var finalCont = (object.CONT || "").toUpperCase();
if (finalCont.length == 0)
{
finalCont = null;
}
var finalCnty = (object.CNTY || "").toUpperCase();
if (finalCnty.length == 0)
{
finalCnty = null;
}
else
{
// GT references internally with NO spaces, this is important
finalCnty = replaceAll(finalCnty, " ", "");
}
var finalMode = (object.MODE || "").toUpperCase();
var subMode = (object.SUBMODE || "").toUpperCase();
if (subMode == "FT4" && (finalMode == "MFSK" || finalMode == "DATA"))
{
// Internal assigment only
finalMode = "FT4"
}
if (subMode == "Q65" && (finalMode == "MFSK" || finalMode == "DATA"))
{
// Internal assigment only
finalMode = "Q65"
}
if (subMode == "JS8" && finalMode == "MFSK")
{
// Internal assigment only
finalMode = "JS8";
}
var finalMsg = (object.COMMENT || "");
var finalQslMsg = (object.QSLMSG || "");
var finalQslMsgIntl = (object.QSLMSG_INTL || "");
if (finalQslMsg.length > 1)
{
finalMsg = finalQslMsg;
}
if (finalQslMsgIntl.length > 1 && finalMsg == "")
{
finalMsg = finalQslMsgIntl;
}
var finalDxcc = Number(object.DXCC || 0);
if (finalDxcc == 0)
{
finalDxcc = Number(callsignToDxcc(finalDXcall));
}
if (!(finalDxcc in GT.dxccInfo))
{
finalDxcc = Number(callsignToDxcc(finalDXcall));
}
var finalState = (object.STATE || "").toUpperCase();
if (finalState.length == 0) finalState = null;
else if (finalDxcc > 0)
{
finalState = GT.dxccToCountryCode[finalDxcc] + "-" + finalState;
}
var finalCqZone = (object.CQZ || "");
if (finalCqZone.length == 1)
{
finalCqZone = "0" + finalCqZone;
}
if (parseInt(finalCqZone) < 1 || parseInt(finalCqZone) > 40)
{
finalCqZone = "";
}
finalCqZone = String(finalCqZone);
var finalItuZone = (object.ITUZ || "");
if (finalItuZone.length == 1) finalItuZone = "0" + finalItuZone;
if (parseInt(finalItuZone) < 1 || parseInt(finalItuZone) > 90)
{
finalItuZone = "";
}
finalItuZone = String(finalItuZone);
var finalIOTA = (object.IOTA || "").toUpperCase();
var qrzConfirmed = (object.APP_QRZLOG_STATUS || "").toUpperCase();
var lotwConfirmed1 = (object.QSL_RCVD || "").toUpperCase();
var lotw_qsl_rcvd = (object.LOTW_QSL_RCVD || "").toUpperCase();
var eqsl_qsl_rcvd = (object.EQSL_QSL_RCVD || "").toUpperCase();
if (qrzConfirmed == "C" || lotw_qsl_rcvd == "Y" || lotw_qsl_rcvd == "V" || lotwConfirmed1 == "Y" || eqsl_qsl_rcvd == "Y" || eqsl_qsl_rcvd == "V" || eQSLfile == true)
{
confirmed = true;
if (qrzConfirmed == "C")
{
confSource = "Q";
}
else if (eQSLfile == true)
{
confSource = "e";
}
else if (lotwConfirmed == true)
{
confSource = "L";
}
else if (clublogFile == true)
{
confSource = "C";
}
else
{
confSource = "O";
}
}
finalGrid = finalGrid.substr(0, 6);
if (!validateGridFromString(finalGrid)) finalGrid = "";
if (finalGrid == "" && vuccGrids != "")
{
finalVucc = vuccGrids.split(",");
finalGrid = finalVucc[0];
finalVucc.shift();
}
var isDigital = false;
var isPhone = false;
if (finalMode in GT.modes)
{
isDigital = GT.modes[finalMode];
}
if (finalMode in GT.modes_phone)
{
isPhone = GT.modes_phone[finalMode];
}
// TODO: Revisit when we support more than one park ID
var finalPOTA = (object.POTA || "").toUpperCase();
if (finalPOTA.length == 0)
{
finalPOTA = null;
}
if (finalDXcall != "")
{
lastHash = addQSO(
finalGrid,
finalDXcall,
finalDEcall,
finalRSTsent,
finalTime,
finalMsg,
finalMode,
finalBand,
confirmed,
finalRSTrecv,
finalDxcc,
finalState,
finalCont,
finalCnty,
finalCqZone,
finalItuZone,
finalVucc,
finalPropMode,
isDigital,
isPhone,
finalIOTA,
finalSatName,
finalPOTA,
confSource
);
}
rows++;
}
else
{
break; // we're done
}
}
}
// Cam from a live event, we handly differently
if (liveLog == true && rows == 1 && lastHash != null && confirmed == false)
{
var returnTask = {};
returnTask.type = "parsedLive";
returnTask.details = GT.QSOhash[lastHash];
}
else
{
var returnTask = {};
returnTask.type = "parsed";
returnTask.QSOhash = GT.QSOhash;
returnTask.myQsoCalls = GT.myQsoCalls;
returnTask.myQsoGrids = GT.myQsoGrids;
returnTask.lotw_qso = task.lotw_qso;
returnTask.lotw_qsl = task.lotw_qsl;
returnTask.lotwTimestampUpdated = lotwTimestampUpdated;
returnTask.nextFunc = task.nextFunc;
}
postMessage(returnTask);
}
function addQSO(
finalGrid,
finalDXcall,
finalDEcall,
finalRSTsent,
finalTime,
ifinalMsg,
mode,
band,
confirmed,
finalRSTrecv,
finalDxcc,
finalState,
finalCont,
finalCnty,
finalCqZone,
finalItuZone,
finalVucc = [],
finalPropMode = "",
finalDigital = false,
finalPhone = false,
finalIOTA = "",
finalSatName = "",
finalPOTA = null,
confSource = null
)
{
let hash = "";
let finalMsg = ifinalMsg.trim();
if (finalMsg.length > 40) finalMsg = finalMsg.substring(0, 40) + "...";
let details = null;
let timeMod = finalTime - ((finalTime % 60) + 30);
hash = unique(mode + band + finalDXcall + timeMod);
if (hash in GT.QSOhash)
{
details = GT.QSOhash[hash];
let canWrite = (details.confirmed == false || GT.appSettings.qslAuthority == "0" || GT.appSettings.qslAuthority == confSource || !(GT.appSettings.qslAuthority in details.confSrcs));
if (GT.appSettings.qslAuthority == "1" && confirmed == true)
{
// Only unconfirmed can change the grid, state, county
// This is for DO9KW
canWrite = false;
}
if (finalGrid.length > 0 && finalGrid != details.grid)
{
// only touch the grid if it's larger than the last grid && the 4wide is the same
if (details.grid.length < 6 && (details.grid.substr(0, 4) == finalGrid.substr(0, 4) || details.grid.length == 0))
{
details.grid = finalGrid;
details.fieild = finalGrid.substring(0,2);
}
else if (details.grid.length != 0 && confirmed == true && canWrite == true)
{
details.grid = finalGrid;
details.fieild = finalGrid.substring(0,2);
}
}
if (finalRSTsent.length > 0) details.RSTsent = finalRSTsent;
if (finalRSTrecv.length > 0) details.RSTrecv = finalRSTrecv;
if (finalCqZone.length > 0) details.cqz = finalCqZone;
if (finalItuZone.length > 0) details.ituz = finalItuZone;
if (details.state != null && finalState != null && details.state != finalState && confirmed == true && canWrite == true)
{
details.state = finalState;
}
else if (details.state == null && finalState != null)
{
details.state = finalState;
}
if (confirmed == true && finalDxcc > 0) details.dxcc = finalDxcc;
if (finalDxcc < 1 && details.dxcc > 0) finalDxcc = details.dxcc;
if (finalCont == null && details.cont) finalCont = details.cont;
if (details.cnty != null && finalCnty != null && details.cnty != finalCnty && confirmed == true && canWrite == true)
{
details.cnty = finalCnty;
}
else if (details.cnty == null && finalCnty != null)
{
details.cnty = finalCnty;
}
if (finalPropMode.length > 0) details.propMode = finalPropMode;
if (finalVucc.length > 0) details.vucc_grids = finalVucc;
if (finalIOTA.length > 0) details.IOTA = finalIOTA;
if (finalSatName.length > 0) details.satName = finalSatName;
if (finalPOTA) details.pota = finalPOTA;
if (confirmed == true)
{
details.confirmed = true;
details.confSrcs[confSource] = true;
}
}
else
{
details = {};
details.grid = finalGrid;
details.fieild = finalGrid.substring(0,2);
details.RSTsent = finalRSTsent;
details.RSTrecv = finalRSTrecv;
details.msg = "-";
details.band = band;
details.mode = mode;
details.DEcall = finalDXcall;
details.DXcall = finalDEcall;
details.cqz = finalCqZone;
details.ituz = finalItuZone;
details.delta = -1;
details.time = finalTime;
details.state = finalState;
details.zipcode = null;
details.qso = true;
details.px = null;
details.zone = null;
details.cont = null;
details.cnty = finalCnty;
details.vucc_grids = finalVucc;
details.propMode = finalPropMode;
details.digital = finalDigital;
details.phone = finalPhone;
details.IOTA = finalIOTA;
details.satName = finalSatName;
details.pota = finalPOTA;
details.worked = true;
details.confirmed = confirmed;
details.confSrcs = {};
if (confirmed == true)
{
details.confSrcs[confSource] = true;
}
}
if (finalDxcc < 1) finalDxcc = callsignToDxcc(finalDXcall);
details.dxcc = finalDxcc;
if (details.dxcc > 0 && details.px == null)
{
details.px = getWpx(finalDXcall);
if (details.px) { details.zone = Number(details.px.charAt(details.px.length - 1)); }
}
var fourGrid = details.grid.substr(0, 4);
details.cont = finalCont;
if (finalDxcc > 0)
{
details.cont = GT.dxccInfo[finalDxcc].continent;
if (details.dxcc == 390 && details.zone == 1) details.cont = "EU";
}
if (details.cnty && confirmed == true)
{
details.qual = true;
}
if (details.state == null && fourGrid.length > 0)
{
if (fourGrid in GT.gridToState && GT.gridToState[fourGrid].length == 1)
{
details.state = GT.gridToState[fourGrid][0];
}
}
if (!details.cqz || details.cqz.length == 0)
{
details.cqz = cqZoneFromCallsign(finalDXcall, details.dxcc);
}
if (!details.ituz || details.ituz.length == 0)
{
details.ituz = ituZoneFromCallsign(finalDXcall, details.dxcc);
}
if (finalMsg.length > 0) details.msg = finalMsg;
details.hash = hash;
GT.QSOhash[hash] = details;
return hash;
}
GT.strictAdif = {
APP_LOTW_RXQSO: false,
APP_LOTW_RXQSL: false,
STATION_CALLSIGN: false,
QSO_DATE: false,
TIME_ON: false,
MY_GRIDSQUARE: false,
CALL: false,
GRIDSQUARE: false,
VUCC_GRIDS: false,
RST_SENT: false,
RST_RCVD: false,
BAND: false,
FREQ: false,
PROP_MODE: false,
SAT_NAME: false,
CONT: false,
CNTY: false,
MODE: false,
SUBMODE: false,
COMMENT: true,
QSLMSG: true,
QSLMSG_INTL: true,
DXCC: false,
STATE: false,
CQZ: false,
ITUZ: false,
IOTA: false,
APP_QRZLOG_STATUS: false,
QSL_RCVD: false,
LOTW_QSL_RCVD: false,
EQSL_QSL_RCVD: false,
POTA: false,
OPERATOR: false,
APP_PSKREP_SNR: false
};
function parseADIFRecordStrict(line)
{
var record = {};
while (line.length > 0)
{
while (line.charAt(0) != "<" && line.length > 0)
{
line = line.substr(1);
}
if (line.length > 0)
{
line = line.substr(1);
var where = line.indexOf(":");
var nextChev = line.indexOf(">");
if (where != -1 && nextChev > where)
{
var fieldName = line.substr(0, where).toUpperCase();
line = line.substr(fieldName.length + 1);
var fieldLength = parseInt(line);
var end = line.indexOf(">");
if (end > 0 && fieldName in GT.strictAdif)
{
line = line.substr(end + 1);
var fieldValue;
if (GT.strictAdif[fieldName] == true)
{
fieldValue = myTextDecoder.decode(myTextEncoder.encode(line.substr(0)).slice(0, fieldLength));
}
else
{
fieldValue = line.substr(0, fieldLength);
}
line = line.substr(fieldValue.length);
record[fieldName] = fieldValue;
}
}
}
}
return record;
}
Reference in New Issue View Git Blame Kopiuj bezpośredni odnośnik