Fix date format for serviceBusQueue trigger metadata to ensure ISO8601 compliance

src/converters/fromRpcTriggerMetadata.ts

@@ -20,8 +20,34 @@ export function fromRpcTriggerMetadata(
     } else {
         const result: TriggerMetadata = {};
         for (const [key, value] of Object.entries(triggerMetadata)) {
-            result[toCamelCaseKey(key)] = toCamelCaseValue(fromRpcTypedData(value));
+            const camelCaseKey = toCamelCaseKey(key);
+            const processedValue = toCamelCaseValue(fromRpcTypedData(value));
+            result[camelCaseKey] = fixDateFormatForServiceBus(camelCaseKey, processedValue, triggerType);
         }
         return result;
     }
 }
+
+/**
+ * Fix date format for serviceBus triggers to ensure proper timezone information.
+ * Adds 'Z' suffix to date strings that are missing timezone information.
+ */
+function fixDateFormatForServiceBus(key: string, value: unknown, triggerType: string): unknown {
+    // Only apply to serviceBus triggers
+    if (!triggerType.includes('serviceBus')) {
+        return value;
+    }
+
+    // Only apply to known date fields
+    const dateFields = ['enqueuedTimeUtc', 'expiresAtUtc'];
+    if (!dateFields.includes(key)) {
+        return value;
+    }
+
+    // Only apply to strings that look like dates without timezone
+    if (typeof value === 'string' && /^\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}(\.\d{1,3})?$/.test(value)) {
+        return value + 'Z';
+    }
+
+    return value;
+}

test/converters/fromRpcTriggerMetadata.test.ts

@@ -283,4 +283,67 @@ describe('fromRpcTriggerMetadata', () => {
             },
         });
     });
+
+    it('serviceBusTrigger with date fields missing timezone', () => {
+        const testData: Record<string, RpcTypedDataExtended> = {
+            ExpiresAtUtc: {
+                json: '"2025-06-07T14:46:55.145"', // Missing 'Z' timezone info
+                data: 'json',
+                http: undefined,
+            },
+            EnqueuedTimeUtc: {
+                json: '"2025-06-07T14:46:55.145"', // Missing 'Z' timezone info
+                data: 'json',
+                http: undefined,
+            },
+            MessageId: {
+                string: 'test-message-id',
+                data: 'string',
+                http: undefined,
+            },
+        };
+
+        const result = fromRpcTriggerMetadata(testData, 'serviceBusTrigger');
+        expect(result).to.deep.equal({
+            expiresAtUtc: '2025-06-07T14:46:55.145Z',
+            enqueuedTimeUtc: '2025-06-07T14:46:55.145Z',
+            messageId: 'test-message-id',
+        });
+    });
+
+    it('serviceBusTrigger with date fields already having timezone should not be modified', () => {
+        const testData: Record<string, RpcTypedDataExtended> = {
+            ExpiresAtUtc: {
+                json: '"2025-06-07T14:46:55.145Z"', // Already has 'Z' timezone info
+                data: 'json',
+                http: undefined,
+            },
+            EnqueuedTimeUtc: {
+                json: '"2025-06-07T14:46:55.145Z"', // Already has 'Z' timezone info
+                data: 'json',
+                http: undefined,
+            },
+        };
+
+        const result = fromRpcTriggerMetadata(testData, 'serviceBusTrigger');
+        expect(result).to.deep.equal({
+            expiresAtUtc: '2025-06-07T14:46:55.145Z',
+            enqueuedTimeUtc: '2025-06-07T14:46:55.145Z',
+        });
+    });
+
+    it('non-serviceBus triggers should not have date format fixes applied', () => {
+        const testData: Record<string, RpcTypedDataExtended> = {
+            SomeDate: {
+                json: '"2025-06-07T14:46:55.145"', // Missing 'Z' timezone info
+                data: 'json',
+                http: undefined,
+            },
+        };
+
+        const result = fromRpcTriggerMetadata(testData, 'queueTrigger');
+        expect(result).to.deep.equal({
+            someDate: '2025-06-07T14:46:55.145', // Should remain unchanged
+        });
+    });
 });

types/InvocationContext.d.ts

@@ -129,7 +129,7 @@ export interface InvocationContextExtraInputs {
      * @input the configuration object for this SQL input
      */
     get(input: SqlInput): unknown;
-	
+
     /**
      * Get a secondary MySql items input for this invocation
      * @input the configuration object for this MySql input
@@ -223,7 +223,7 @@ export interface InvocationContextExtraOutputs {
      * @message the output event(s) value
      */
     set(output: EventGridOutput, events: EventGridPartialEvent | EventGridPartialEvent[]): void;
-	
+
     /**
      * Set a secondary MySql items output for this invocation
      * @output the configuration object for this MySql output

types/input.d.ts

@@ -4,10 +4,10 @@
 import { CosmosDBInput, CosmosDBInputOptions } from './cosmosDB';
 import { GenericInputOptions } from './generic';
 import { FunctionInput } from './index';
+import { MySqlInput, MySqlInputOptions } from './mySql';
 import { SqlInput, SqlInputOptions } from './sql';
 import { StorageBlobInput, StorageBlobInputOptions } from './storage';
 import { TableInput, TableInputOptions } from './table';
-import { MySqlInput, MySqlInputOptions } from './mySql';
 import {
     WebPubSubConnectionInput,
     WebPubSubConnectionInputOptions,

types/output.d.ts

@@ -7,6 +7,7 @@ import { EventHubOutput, EventHubOutputOptions } from './eventHub';
 import { GenericOutputOptions } from './generic';
 import { HttpOutput, HttpOutputOptions } from './http';
 import { FunctionOutput } from './index';
+import { MySqlOutput, MySqlOutputOptions } from './mySql';
 import {
     ServiceBusQueueOutput,
     ServiceBusQueueOutputOptions,
@@ -16,7 +17,6 @@ import {
 import { SqlOutput, SqlOutputOptions } from './sql';
 import { StorageBlobOutput, StorageBlobOutputOptions, StorageQueueOutput, StorageQueueOutputOptions } from './storage';
 import { TableOutput, TableOutputOptions } from './table';
-import { MySqlOutput, MySqlOutputOptions } from './mySql';
 import { WebPubSubOutput, WebPubSubOutputOptions } from './webpubsub';
 
 /**