diff --git a/src/index.ts b/src/index.ts index 2552e70..e60f08a 100644 --- a/src/index.ts +++ b/src/index.ts @@ -33,11 +33,13 @@ async function main(evt: string, src: string, dest: string, value: Buffer) { const dpt: DPTAndAddressID = (await getDPTforAddress(dest)) + + const newLocal = (dpt.dpt.decoder(value) === 1) ? true : false; const document: MetricDocument = { address_id: dpt.addressId, dpt: dpt.id, timestamp: new Date().getTime(), - value: dpt.id.startsWith('DPT1.') ? (dpt.dpt.decoder(value) === 1) ? true : false : dpt.dpt.decoder(value) + value: dpt.id.startsWith('DPT1.') ? newLocal : dpt.dpt.decoder(value) } upsert(document)