diff --git a/src/poller/poller.test.ts b/src/poller/poller.test.ts index 81cfc43..9edf6ae 100644 --- a/src/poller/poller.test.ts +++ b/src/poller/poller.test.ts @@ -12,7 +12,7 @@ function makeEvent(overrides: Partial = {}): NbEvent { initiator_id: "init-1", initiator_name: "admin", target_id: "peer-1", - meta: { setup_key: "drone-key", name: "drone-01" }, + meta: { setup_key_name: "drone-key", name: "drone-01" }, ...overrides, }; } @@ -66,7 +66,7 @@ Deno.test("processEnrollmentEvents filters by lastTimestamp", () => { Deno.test("processEnrollmentEvents ignores unknown keys", () => { const events: NbEvent[] = [ makeEvent({ - meta: { setup_key: "rogue-key", name: "rogue-host" }, + meta: { setup_key_name: "rogue-key", name: "rogue-host" }, target_id: "peer-x", }), ]; diff --git a/src/poller/poller.ts b/src/poller/poller.ts index 639577d..fa43b2c 100644 --- a/src/poller/poller.ts +++ b/src/poller/poller.ts @@ -21,10 +21,10 @@ export function processEnrollmentEvents( .filter((e) => { if (e.activity_code !== "peer.setupkey.add") return false; if (lastTimestamp && e.timestamp <= lastTimestamp) return false; - if (!knownKeyNames.has(e.meta.setup_key)) { + if (!knownKeyNames.has(e.meta.setup_key_name)) { console.log(JSON.stringify({ msg: "unknown_enrollment", - setup_key: e.meta.setup_key, + setup_key_name: e.meta.setup_key_name, peer_id: e.target_id, })); return false; @@ -32,7 +32,7 @@ export function processEnrollmentEvents( return true; }) .map((e) => ({ - setupKeyName: e.meta.setup_key, + setupKeyName: e.meta.setup_key_name, peerId: e.target_id, peerHostname: e.meta.name, timestamp: e.timestamp,