upstream/opnsense-core
1
0
Fork 0
mirror of https://github.com/opnsense/core.git synced 2026-05-28 04:34:51 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

firewall: live log: update all records on resolve

Browse source
This commit is contained in:
Stephan de Wit 2025-10-23 15:19:50 +02:00
parent f8d9db3510
commit 2ec030e561
1 changed files with 25 additions and 29 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

54
src/opnsense/mvc/app/views/OPNsense/Diagnostics/fw_log.volt
View file

@ -526,8 +526,13 @@
if (!hostnames.get(record.dst)) hostnames.set(record.dst, null);
// make sure the hostname key exists
record['srchostname'] = hostnames.get(record.src) || '<span class="fa fa-spinner fa-pulse"></span>';
record['dsthostname'] = hostnames.get(record.dst) || '<span class="fa fa-spinner fa-pulse"></span>';
['src', 'dst'].forEach(addr => {
if (hostnames.get(record[addr]) !== '<in-flight>') {
record[`${addr}hostname`] = hostnames.get(record.src) || '<span class="fa fa-spinner fa-pulse"></span>';
} else {
record[`${addr}hostname`] = '<span class="fa fa-spinner fa-pulse"></span>';
}
});
}
resolve(data);
@ -948,44 +953,35 @@
});
}
const updateRecords = () => {
lookup().then(() => {
buffer.map((record) => {
if (hostnames.get(record.src) !== '<in-flight>') {
record['srchostname'] = hostnames.get(record.src);
}
if (hostnames.get(record.dst) !== '<in-flight>') {
record['dsthostname'] = hostnames.get(record.dst);
}
return record;
});
filterVM.reset();
});
}
bufferDataUnsubscribe = buffer.subscribe((event) => {
// register to active data feed (all data), apply hostnames as they come
if (event.type === "push" || event.type === "pushMany") {
let records = Array.isArray(event.data) ? event.data : [event.data];
filterVM.updateTable(records);
lookup().then(() => {
records = records.map((record) => {
if (hostnames.get(record.src) !== '<in-flight>') {
record['srchostname'] = hostnames.get(record.src);
}
if (hostnames.get(record.dst) !== '<in-flight>') {
record['dsthostname'] = hostnames.get(record.dst);
}
return record;
});
filterVM.updateTable(records);
})
updateRecords();
}
});
// initial hostname lookup
tableWrapper.bootgrid('setColumns', ['srchostname', 'dsthostname']);
lookup().then(() => {
// operate on entire buffer
buffer.map((record) => {
if (hostnames.get(record.src) !== '<in-flight>') {
record['srchostname'] = hostnames.get(record.src);
}
if (hostnames.get(record.dst) !== '<in-flight>') {
record['dsthostname'] = hostnames.get(record.dst);
}
return record;
});
filterVM.reset();
});
updateRecords();
} else {
if (bufferDataUnsubscribe !== null) {
bufferDataUnsubscribe();