package.json

@@ -1,6 +1,6 @@
 {
     "name": "@azure/functions",
-    "version": "4.6.1",
+    "version": "4.7.0",
     "description": "Microsoft Azure Functions NodeJS Framework",
     "keywords": [
         "azure",

src/app.ts

@@ -11,13 +11,15 @@ import {
     HttpHandler,
     HttpMethod,
     HttpMethodFunctionOptions,
+    MySqlFunctionOptions,
     ServiceBusQueueFunctionOptions,
     ServiceBusTopicFunctionOptions,
     SqlFunctionOptions,
     StorageBlobFunctionOptions,
     StorageQueueFunctionOptions,
     TimerFunctionOptions,
     WarmupFunctionOptions,
+    WebPubSubFunctionOptions,
 } from '@azure/functions';
 import { FunctionCallback } from '@azure/functions-core';
 import { toCoreFunctionMetadata } from './converters/toCoreFunctionMetadata';
@@ -135,6 +137,14 @@ export function sql(name: string, options: SqlFunctionOptions): void {
     generic(name, convertToGenericOptions(options, trigger.sql));
 }
 
+export function mySql(name: string, options: MySqlFunctionOptions): void {
+    generic(name, convertToGenericOptions(options, trigger.mySql));
+}
+
+export function webPubSub(name: string, options: WebPubSubFunctionOptions): void {
+    generic(name, convertToGenericOptions(options, trigger.webPubSub));
+}
+
 export function generic(name: string, options: GenericFunctionOptions): void {
     if (!hasSetModel) {
         setProgrammingModel();

src/constants.ts

@@ -1,6 +1,6 @@
 // Copyright (c) .NET Foundation. All rights reserved.
 // Licensed under the MIT License.
 
-export const version = '4.6.1';
+export const version = '4.7.0';
 
 export const returnBindingKey = '$return';

src/index.ts

@@ -22,3 +22,7 @@ export enum SqlChangeOperation {
     Update = 1,
     Delete = 2,
 }
+
+export enum MySqlChangeOperation {
+    Update = 0,
+}

src/input.ts

@@ -6,12 +6,18 @@ import {
     CosmosDBInputOptions,
     FunctionInput,
     GenericInputOptions,
+    MySqlInput,
+    MySqlInputOptions,
     SqlInput,
     SqlInputOptions,
     StorageBlobInput,
     StorageBlobInputOptions,
     TableInput,
     TableInputOptions,
+    WebPubSubConnectionInput,
+    WebPubSubConnectionInputOptions,
+    WebPubSubContextInput,
+    WebPubSubContextInputOptions,
 } from '@azure/functions';
 import { addBindingName } from './addBindingName';
 
@@ -43,6 +49,27 @@ export function sql(options: SqlInputOptions): SqlInput {
     });
 }
 
+export function mySql(options: MySqlInputOptions): MySqlInput {
+    return addInputBindingName({
+        ...options,
+        type: 'mysql',
+    });
+}
+
+export function webPubSubConnection(options: WebPubSubConnectionInputOptions): WebPubSubConnectionInput {
+    return addInputBindingName({
+        ...options,
+        type: 'webPubSubConnection',
+    });
+}
+
+export function webPubSubContext(options: WebPubSubContextInputOptions): WebPubSubContextInput {
+    return addInputBindingName({
+        ...options,
+        type: 'webPubSubContext',
+    });
+}
+
 export function generic(options: GenericInputOptions): FunctionInput {
     return addInputBindingName(options);
 }

src/output.ts

@@ -12,6 +12,8 @@ import {
     GenericOutputOptions,
     HttpOutput,
     HttpOutputOptions,
+    MySqlOutput,
+    MySqlOutputOptions,
     ServiceBusQueueOutput,
     ServiceBusQueueOutputOptions,
     ServiceBusTopicOutput,
@@ -24,6 +26,8 @@ import {
     StorageQueueOutputOptions,
     TableOutput,
     TableOutputOptions,
+    WebPubSubOutput,
+    WebPubSubOutputOptions,
 } from '@azure/functions';
 import { addBindingName } from './addBindingName';
 
@@ -97,6 +101,20 @@ export function sql(options: SqlOutputOptions): SqlOutput {
     });
 }
 
+export function mySql(options: MySqlOutputOptions): MySqlOutput {
+    return addOutputBindingName({
+        ...options,
+        type: 'mysql',
+    });
+}
+
+export function webPubSub(options: WebPubSubOutputOptions): WebPubSubOutput {
+    return addOutputBindingName({
+        ...options,
+        type: 'webPubSub',
+    });
+}
+
 export function generic(options: GenericOutputOptions): FunctionOutput {
     return addOutputBindingName(options);
 }

src/trigger.ts

@@ -12,6 +12,8 @@ import {
     GenericTriggerOptions,
     HttpTrigger,
     HttpTriggerOptions,
+    MySqlTrigger,
+    MySqlTriggerOptions,	
     ServiceBusQueueTrigger,
     ServiceBusQueueTriggerOptions,
     ServiceBusTopicTrigger,
@@ -26,6 +28,8 @@ import {
     TimerTriggerOptions,
     WarmupTrigger,
     WarmupTriggerOptions,
+    WebPubSubTrigger,
+    WebPubSubTriggerOptions,
 } from '@azure/functions';
 import { addBindingName } from './addBindingName';
 
@@ -108,6 +112,20 @@ export function sql(options: SqlTriggerOptions): SqlTrigger {
     });
 }
 
+export function mySql(options: MySqlTriggerOptions): MySqlTrigger {
+    return addTriggerBindingName({
+        ...options,
+        type: 'mysqlTrigger',
+    });
+}
+
+export function webPubSub(options: WebPubSubTriggerOptions): WebPubSubTrigger {
+    return addTriggerBindingName({
+        ...options,
+        type: 'webPubSubTrigger',
+    });
+}
+
 export function generic(options: GenericTriggerOptions): FunctionTrigger {
     return addTriggerBindingName(options);
 }

types/InvocationContext.d.ts

@@ -6,10 +6,12 @@ import { EventGridOutput, EventGridPartialEvent } from './eventGrid';
 import { EventHubOutput } from './eventHub';
 import { HttpOutput, HttpResponse } from './http';
 import { FunctionInput, FunctionOutput, FunctionTrigger, LogLevel } from './index';
+import { MySqlInput, MySqlOutput } from './mySql';
 import { ServiceBusQueueOutput, ServiceBusTopicOutput } from './serviceBus';
 import { SqlInput, SqlOutput } from './sql';
 import { StorageBlobInput, StorageBlobOutput, StorageQueueOutput } from './storage';
 import { TableInput, TableOutput } from './table';
+import { WebPubSubOutput } from './webpubsub';
 
 /**
  * Contains metadata and helper methods specific to this invocation
@@ -127,6 +129,12 @@ 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
+     */
+    get(input: MySqlInput): unknown;
 
     /**
      * Get a secondary generic input for this invocation
@@ -215,6 +223,20 @@ 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
+     * @documents the output item(s) value
+     */
+    set(output: MySqlOutput, items: unknown): void;
+
+    /**
+     * Set a secondary Web PubSub output for this invocation
+     * @output the configuration object for this Web PubSub output
+     * @message the output message(s) value
+     */
+    set(output: WebPubSubOutput, messages: unknown): void;
 
     /**
      * Set a secondary generic output for this invocation

types/app.d.ts

@@ -6,12 +6,14 @@ import { EventGridFunctionOptions } from './eventGrid';
 import { EventHubFunctionOptions } from './eventHub';
 import { GenericFunctionOptions } from './generic';
 import { HttpFunctionOptions, HttpHandler, HttpMethodFunctionOptions } from './http';
+import { MySqlFunctionOptions } from './mySql';
 import { ServiceBusQueueFunctionOptions, ServiceBusTopicFunctionOptions } from './serviceBus';
 import { SetupOptions } from './setup';
 import { SqlFunctionOptions } from './sql';
 import { StorageBlobFunctionOptions, StorageQueueFunctionOptions } from './storage';
 import { TimerFunctionOptions } from './timer';
 import { WarmupFunctionOptions } from './warmup';
+import { WebPubSubFunctionOptions } from './webpubsub';
 
 /**
  * Optional method to configure the behavior of your app.
@@ -172,6 +174,13 @@ export function warmup(name: string, options: WarmupFunctionOptions): void;
  */
 export function sql(name: string, options: SqlFunctionOptions): void;
 
+/**
+ * Registers a MySql function in your app that will be triggered when a row is created or updated
+ * @param name The name of the function. The name must be unique within your app and will mostly be used for your own tracking purposes
+ * @param options Configuration options describing the inputs, outputs, and handler for this function
+ */
+export function mySql(name: string, options: MySqlFunctionOptions): void;
+
 /**
  * Registers a generic function in your app that will be triggered based on the type specified in `options.trigger.type`
  * Use this method if your desired trigger type does not already have its own method
@@ -180,4 +189,11 @@ export function sql(name: string, options: SqlFunctionOptions): void;
  */
 export function generic(name: string, options: GenericFunctionOptions): void;
 
+/**
+ * Registers a WebPubSub function in your app that will be triggered by WebPubSub events
+ * @param name The name of the function. The name must be unique within your app and will mostly be used for your own tracking purposes
+ * @param options Configuration options describing the inputs, outputs, and handler for this function
+ */
+export function webPubSub(name: string, options: WebPubSubFunctionOptions): void;
+
 export * as hook from './hooks/registerHook';

types/index.d.ts

@@ -17,6 +17,7 @@ export * from './hooks/logHooks';
 export * from './http';
 export * as input from './input';
 export * from './InvocationContext';
+export * from './mySql';
 export * as output from './output';
 export * from './serviceBus';
 export * from './setup';
@@ -26,6 +27,7 @@ export * from './table';
 export * from './timer';
 export * as trigger from './trigger';
 export * from './warmup';
+export * from './webpubsub';
 
 /**
  * Void if no `return` output is registered

types/input.d.ts

@@ -7,6 +7,13 @@ import { FunctionInput } from './index';
 import { SqlInput, SqlInputOptions } from './sql';
 import { StorageBlobInput, StorageBlobInputOptions } from './storage';
 import { TableInput, TableInputOptions } from './table';
+import { MySqlInput, MySqlInputOptions } from './mySql';
+import {
+    WebPubSubConnectionInput,
+    WebPubSubConnectionInputOptions,
+    WebPubSubContextInput,
+    WebPubSubContextInputOptions,
+} from './webpubsub';
 
 /**
  * [Link to docs and examples](https://docs.microsoft.com/azure/azure-functions/functions-bindings-storage-blob-input?pivots=programming-language-javascript)
@@ -28,6 +35,21 @@ export function cosmosDB(options: CosmosDBInputOptions): CosmosDBInput;
  */
 export function sql(options: SqlInputOptions): SqlInput;
 
+/**
+ * [Link to docs and examples](https://learn.microsoft.com/en-us/azure/azure-functions/functions-bindings-azure-mysql-input?pivots=programming-language-javascript)
+ */
+export function mySql(options: MySqlInputOptions): MySqlInput;
+
+/**
+ * [Link to docs and examples](https://docs.microsoft.com/azure/azure-functions/functions-bindings-web-pubsub-input?pivots=programming-language-javascript)
+ */
+export function webPubSubConnection(options: WebPubSubConnectionInputOptions): WebPubSubConnectionInput;
+
+/**
+ * [Link to docs and examples](https://docs.microsoft.com/azure/azure-functions/functions-bindings-web-pubsub-input?pivots=programming-language-javascript)
+ */
+export function webPubSubContext(options: WebPubSubContextInputOptions): WebPubSubContextInput;
+
 /**
  * A generic option that can be used for any input type
  * Use this method if your desired input type does not already have its own method