Correlation function for mapping.

How to make corelation using LOKI DB.

output_function:

const returnData = []; for (let dt of data) { let arrayRet = { id: 0, sid: 'unknown', protocol_header: { captureId: 2001, capturePass: 'myHep', payloadType: 100, timeSeconds: 1548839273, timeUseconds: 649, protocolFamily: 2, method: 'LOKI' }, data_header: { protocol: 17, dstIp: '127.0.0.1', srcIp: '127.0.0.1', dstPort: 0, srcPort: 0 }, raw: '', create_date: 0 }; arrayRet.id = dt.id; arrayRet.protocol_header.timeSeconds = new Date(dt.micro_ts).getTime() / 1000; arrayRet.protocol_header.timeUseconds = new Date(dt.micro_ts).getTime() % 1000; arrayRet.data_header.sid = 'unknown'; arrayRet.data_header.srcPort = 1; arrayRet.data_header.dstPort = 2; arrayRet.data_header.srcIp = '127.0.0.2'; arrayRet.data_header.payloadType = 200; arrayRet.data_header.create_date = dt.micro_ts; arrayRet.raw = dt.custom_1 + '\\r\\nTags:' + dt.custom_2; arrayRet.tag = dt.custom_2; arrayRet.create_date = new Date(dt.micro_ts).getTime(); var n = dt.custom_1.search(' SrcIP='); if (n) { var ipData = dt.custom_1.substring(n + 1, dt.custom_1.length); /* split data */ var entry = {}; ipData.split(' ').forEach(function(pair) { var kv = pair.split('='); if (!kv[0] || !kv[1]) return; entry[kv[0]] = kv[1]; }); arrayRet.data_header.srcIp = entry['SrcIP']; arrayRet.data_header.srcPort = entry['SrcPort']; arrayRet.data_header.dstIp = entry['DstIP']; arrayRet.data_header.dstPort = entry['DstPort']; arrayRet.sid = entry['CID']; arrayRet.data_header.sid = entry['CID']; } var tagData = dt.custom_2.substring(1, dt.custom_2.length - 1); var tagArray = {}; tagData.split(', ').forEach(function(pair) { var kv = pair.split('='); if (!kv[0] || !kv[1]) return; tagArray[kv[0]] = kv[1].replace(/\"/g, ''); }); if (tagArray.type) { arrayRet.protocol_header.method = 'LOKI-' + tagArray.type; if (tagArray.type == 'sip' && tagArray.method) arrayRet.protocol_header.method = 'LOKI-SIP-M-' + tagArray.method; else if (tagArray.type == 'sip' && tagArray.response) arrayRet.protocol_header.method = 'LOKI-SIP-R-' + tagArray.response; arrayRet.protocol_header.captureId = tagArray.node_id; } returnData.push(arrayRet); }; return returnData