feat: add toRecord() and toTimestreamType()

package.json

@@ -26,7 +26,9 @@
   "license": "BSD-3-Clause",
   "peerDependencies": {
     "@aws-sdk/client-timestream-query": ">= 3 < 4",
-    "@aws-sdk/client-timestream-write": ">= 3 < 4"
+    "@aws-sdk/client-timestream-write": ">= 3 < 4",
+    "@types/uuid": ">= 8 < 9",
+    "uuid": ">= 8 < 9"
   },
   "devDependencies": {
     "@nordicsemiconductor/asset-tracker-cloud-code-style": "11.0.21",

src/index.ts

@@ -1,2 +1,5 @@
-export * from './parseResult'
 export * from './client'
+export * from './index'
+export * from './parseResult'
+export * from './toRecord'
+export * from './toTimestreamType'

src/toRecord.spec.ts

@@ -0,0 +1,37 @@
+import { MeasureValueType } from '@aws-sdk/client-timestream-write'
+import { toRecord } from '.'
+
+describe('toRecord()', () => {
+	it('should convert sensor data to a timestream record', () => {
+		const ts = Date.now()
+		expect(
+			toRecord({
+				name: 'bat',
+				v: 3.3,
+				ts,
+				dimensions: { measureGroup: 'someGroup' },
+			}),
+		).toEqual({
+			Dimensions: [
+				{
+					Name: 'measureGroup',
+					Value: 'someGroup',
+				},
+			],
+			MeasureName: 'bat',
+			MeasureValue: `3.3`,
+			MeasureValueType: MeasureValueType.DOUBLE,
+			Time: ts.toString(),
+		})
+	})
+	it('should ignore sensor data if the value is not defined', () => {
+		expect(
+			toRecord({
+				name: 'bat',
+				v: undefined,
+				ts: Date.now(),
+				dimensions: { measureGroup: 'someGroup' },
+			}),
+		).toEqual(undefined)
+	})
+})

src/toRecord.ts

@@ -0,0 +1,26 @@
+import { _Record } from '@aws-sdk/client-timestream-write'
+import { toTimestreamType } from './toTimestreamType'
+
+export const toRecord = ({
+	name,
+	ts,
+	v,
+	dimensions,
+}: {
+	name: string
+	ts: number
+	v?: { toString: () => string }
+	dimensions?: Record<string, string>
+}): _Record | undefined => {
+	if (v === undefined) return
+	return {
+		Dimensions: Object.entries(dimensions ?? {}).map(([Name, Value]) => ({
+			Name,
+			Value,
+		})),
+		MeasureName: name,
+		MeasureValue: v.toString(),
+		MeasureValueType: toTimestreamType(v),
+		Time: ts.toString(),
+	}
+}

src/toTimestreamType.spec.ts

@@ -0,0 +1,13 @@
+import { toTimestreamType } from './toTimestreamType'
+
+describe('toTimestreamType', () => {
+	it.each([
+		[true, 'BOOLEAN'],
+		[1.1, 'DOUBLE'],
+		[1, 'DOUBLE'],
+		['foo', 'VARCHAR'],
+		['12345678901234567890', 'VARCHAR'],
+	])('should determind %s as %s', (v, expected) => {
+		expect(toTimestreamType(v)).toEqual(expected)
+	})
+})

src/toTimestreamType.ts

@@ -0,0 +1,8 @@
+import { MeasureValueType } from '@aws-sdk/client-timestream-write'
+
+export const toTimestreamType = (v: unknown): MeasureValueType => {
+	if (typeof v === 'string') return MeasureValueType.VARCHAR
+	if (typeof v === 'boolean') return MeasureValueType.BOOLEAN
+	if (Number.isInteger(v)) return MeasureValueType.DOUBLE
+	return MeasureValueType.DOUBLE
+}