feat: convert functions to v4

Migrate to programming model v4.
Ref: https://learn.microsoft.com/en-us/azure/azure-functions/functions-node-upgrade-v4?tabs=v4

Author: pudkrong

agnssDeviceRequestsHandler/agnssDeviceRequestsHandler.ts

@@ -1,4 +1,4 @@
-import { AzureFunction, Context } from '@azure/functions'
+import type { EventHubHandler } from '@azure/functions'
 import {
 	QueueClient,
 	QueueServiceClient,
@@ -29,21 +29,14 @@ const config = () =>
  *
  * The requests are put in a queue for resolving.
  */
-const agnssDeviceRequestsHandler: AzureFunction = async (
-	context: Context,
-	requests: (
-		| {
-				mcc: number
-				mnc: number
-				cell: number
-				area: number
-				types: number[]
-		  }
-		| Record<string, any>
-	)[],
-): Promise<void> => {
+const agnssDeviceRequestsHandler: EventHubHandler = async (
+	requests,
+	context,
+) => {
 	log(context)({ context, requests })
 
+	if (!Array.isArray(requests)) return
+
 	const timestamp = new Date()
 	let queueClient: QueueClient
 
@@ -63,17 +56,21 @@ const agnssDeviceRequestsHandler: AzureFunction = async (
 
 	// Find A-GNSS requests
 	const agnssRequests = requests
-		.map((request, i) => ({
-			request,
-			deviceId:
-				context.bindingData.systemPropertiesArray[i][
-					'iothub-connection-device-id'
-				],
-			properties: context.bindingData.propertiesArray[i] as Record<
-				string,
-				string
-			>,
-		}))
+		.map((request, i) => {
+			const systemPropertiesArray = Array.isArray(
+				context.triggerMetadata?.systemPropertiesArray,
+			)
+				? context.triggerMetadata?.systemPropertiesArray
+				: []
+			const properties = Array.isArray(context.triggerMetadata?.propertiesArray)
+				? context.triggerMetadata?.propertiesArray
+				: []
+			return {
+				request,
+				deviceId: systemPropertiesArray?.[i]['iothub-connection-device-id'],
+				properties: properties?.[i] as Record<string, string>,
+			}
+		})
 		.filter(({ properties }) => properties.agnss === 'get')
 
 	if (agnssRequests.length === 0) {

agnssDeviceRequestsHandler/function.json

@@ -0,0 +1,10 @@
+import { app } from '@azure/functions'
+import handler from './agnssDeviceRequestsHandler.js'
+
+app.eventHub('agnssDeviceRequestsHandler', {
+	eventHubName: '%IOTHUB_EVENTS_EVENT_HUB_NAME%',
+	connection: 'IOTHUB_EVENTS_CONNECTION_STRING',
+	cardinality: 'many',
+	consumerGroup: '%AGNSS_REQUESTS_IOT_EVENTS_CONSUMER_GROUP_NAME%',
+	handler,
+})

agnssDeviceRequestsHandler/handler.mjs

@@ -1,5 +1,5 @@
 import { Container, CosmosClient } from '@azure/cosmos'
-import { AzureFunction, Context } from '@azure/functions'
+import type { StorageQueueHandler } from '@azure/functions'
 import {
 	QueueClient,
 	QueueServiceClient,
@@ -57,10 +57,12 @@ type QueuedAGNSSRequest = {
  * a DB or kicking off the resoluting via a third-party API (currently only
  * nRF Cloud Assisted GPS Location Service is implemented.)
  */
-const agnssQueuedDeviceRequestsHandler: AzureFunction = async (
-	context: Context,
-	{ deviceId, request, delayInSeconds, timestamp }: QueuedAGNSSRequest,
-): Promise<void> => {
+const agnssQueuedDeviceRequestsHandler: StorageQueueHandler = async (
+	queueEntry,
+	context,
+) => {
+	const { deviceId, request, delayInSeconds, timestamp } =
+		queueEntry as QueuedAGNSSRequest
 	log(context)({ request, deviceId, delayInSeconds, timestamp, context })
 
 	let binHours: number
@@ -205,16 +207,10 @@ const agnssQueuedDeviceRequestsHandler: AzureFunction = async (
 		logError(context)(
 			`Cancelling request because of resolution timeout after ${ageInSeconds} seconds.`,
 		)
-		logError(context)(
-			JSON.stringify(
-				{
-					cancelled: request,
-					maxResolutionTimeInSeconds,
-				},
-				null,
-				2,
-			),
-		)
+		logError(context)({
+			cancelled: request,
+			maxResolutionTimeInSeconds,
+		})
 		return
 	}
 

agnssDeviceRequestsHandler/handler.ts

@@ -0,0 +1,8 @@
+import { app } from '@azure/functions'
+import handler from './agnssQueuedDeviceRequestsHandler.js'
+
+app.storageQueue('agnssQueuedDeviceRequestsHandler', {
+	queueName: '%AGNSS_REQUESTS_QUEUE_NAME%',
+	connection: '',
+	handler,
+})

agnssQueuedDeviceRequestsHandler/agnssQueuedDeviceRequestsHandler.ts

@@ -1,5 +1,5 @@
 import { Container, CosmosClient } from '@azure/cosmos'
-import { AzureFunction, Context } from '@azure/functions'
+import type { StorageQueueHandler } from '@azure/functions'
 import { Static } from '@sinclair/typebox'
 import { URL } from 'url'
 import { cacheKey } from '../agnss/cacheKey.js'
@@ -39,10 +39,11 @@ let nrfCloudServiceKeyPromise: Promise<string>
 /**
  * Resolve A-GNSS requests from nRF Cloud
  */
-const agnssResolveRequestFromNrfCloud: AzureFunction = async (
-	context: Context,
-	request: Static<typeof agnssRequestSchema>,
-): Promise<void> => {
+const agnssResolveRequestFromNrfCloud: StorageQueueHandler = async (
+	queueEntry,
+	context,
+) => {
+	const request = queueEntry as Static<typeof agnssRequestSchema>
 	log(context)({ context, request })
 
 	let resolver: ReturnType<typeof resolveAgnssRequest>