feat(api): add route to fetch device

getDevice/function.json

@@ -0,0 +1,18 @@
+{
+  "bindings": [
+    {
+      "authLevel": "anonymous",
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "req",
+      "methods": ["get"],
+      "route": "device/{id}"
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "res"
+    }
+  ],
+  "scriptFile": "../dist/getDevice/index.js"
+}

getDevice/index.ts

@@ -0,0 +1,35 @@
+import { AzureFunction, Context, HttpRequest } from '@azure/functions'
+import { Registry } from 'azure-iothub'
+import { r } from '../lib/http'
+import { ErrorInfo, ErrorType, toStatusCode } from '../lib/ErrorInfo'
+
+const connectionString = process.env.IOT_HUB_CONNECTION_STRING || ''
+
+const getDevice: AzureFunction = async (
+	context: Context,
+	req: HttpRequest,
+): Promise<void> => {
+	context.log({ req: JSON.stringify(req) })
+	try {
+		const registry = Registry.fromConnectionString(connectionString)
+		const devices = registry.createQuery(
+			`SELECT * FROM devices WHERE deviceId='${req.params.id}'`,
+		)
+		const res = await devices.nextAsTwin()
+		if (res.result.length === 0) {
+			context.res = r(
+				{
+					type: ErrorType.EntityNotFound,
+					message: `Device ${req.params.id} not found!`,
+				} as ErrorInfo,
+				toStatusCode[ErrorType.EntityNotFound],
+			)
+		} else {
+			context.res = r(res.result[0])
+		}
+	} catch (error) {
+		context.res = r(error, 500)
+	}
+}
+
+export default getDevice

lib/ErrorInfo.ts

@@ -0,0 +1,21 @@
+export enum ErrorType {
+	EntityNotFound = 'EntityNotFound',
+	BadRequest = 'BadRequest',
+	AccessDenied = 'AccessDenied',
+	InternalError = 'InternalError',
+	Conflict = 'Conflict',
+}
+
+export type ErrorInfo = {
+	type: ErrorType
+	message: string
+	detail?: any
+}
+
+export const toStatusCode = {
+	[ErrorType.BadRequest]: 400,
+	[ErrorType.AccessDenied]: 403,
+	[ErrorType.EntityNotFound]: 404,
+	[ErrorType.InternalError]: 500,
+	[ErrorType.Conflict]: 409,
+}

lib/http.ts

@@ -0,0 +1,8 @@
+export const r = (result: any, status = 200) => ({
+	headers: {
+		'Content-Type': 'application/json; charset=uft-8',
+	},
+	status,
+	isRaw: true,
+	body: JSON.stringify(result),
+})

listDevices/function.json

@@ -5,7 +5,8 @@
       "type": "httpTrigger",
       "direction": "in",
       "name": "req",
-      "methods": ["get", "post"]
+      "methods": ["get"],
+      "route": "devices"
     },
     {
       "type": "http",

listDevices/index.ts

@@ -1,25 +1,17 @@
 import { AzureFunction, Context, HttpRequest } from '@azure/functions'
 import { Registry } from 'azure-iothub'
+import { r } from '../lib/http'
 
 const connectionString = process.env.IOT_HUB_CONNECTION_STRING || ''
 
-const r = (result: any, status = 200) => ({
-	headers: {
-		'Content-Type': 'application/json; charset=uft-8',
-	},
-	status,
-	isRaw: true,
-	body: JSON.stringify(result),
-})
-
 const listDevices: AzureFunction = async (
 	context: Context,
 	req: HttpRequest,
 ): Promise<void> => {
 	context.log({ req })
 	try {
 		const registry = Registry.fromConnectionString(connectionString)
-		const devices = registry.createQuery('SELECT * FROM devices')
+		const devices = registry.createQuery('SELECT deviceId FROM devices')
 		const res = await devices.nextAsTwin()
 		context.res = r(res.result)
 	} catch (error) {