feat: implement delete device

deleteDevice/deleteDevice.ts

@@ -0,0 +1,41 @@
+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 deleteDevice: 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 {
+			await registry.delete(req.params.id)
+			context.res = r({ success: true })
+		}
+	} catch (error) {
+		context.log(
+			JSON.stringify({
+				error: error.message,
+			}),
+		)
+		context.res = r(error, 500)
+	}
+}
+
+export default deleteDevice

deleteDevice/function.json

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

getDevice/getDevice.ts

@@ -28,6 +28,11 @@ const getDevice: AzureFunction = async (
 			context.res = r(res.result[0])
 		}
 	} catch (error) {
+		context.log(
+			JSON.stringify({
+				error: error.message,
+			}),
+		)
 		context.res = r(error, 500)
 	}
 }

listDevices/listDevices.ts

@@ -17,6 +17,11 @@ const listDevices: AzureFunction = async (
 		const res = await devices.nextAsTwin()
 		context.res = r(res.result)
 	} catch (error) {
+		context.log(
+			JSON.stringify({
+				error: error.message,
+			}),
+		)
 		context.res = r(error, 500)
 	}
 }

updateDevice/updateDevice.ts

@@ -35,6 +35,11 @@ const updateDevice: AzureFunction = async (
 			context.res = r(true)
 		}
 	} catch (error) {
+		context.log(
+			JSON.stringify({
+				error: error.message,
+			}),
+		)
 		context.res = r(error, 500)
 	}
 }