Init: input/output/trigger

Author: phanthaiduong22

src/input.ts

@@ -12,6 +12,10 @@ import {
     StorageBlobInputOptions,
     TableInput,
     TableInputOptions,
+    WebPubSubConnectionInput,
+    WebPubSubConnectionInputOptions,
+    WebPubSubContextInput,
+    WebPubSubContextInputOptions,
 } from '@azure/functions';
 import { addBindingName } from './addBindingName';
 
@@ -43,6 +47,20 @@ export function sql(options: SqlInputOptions): SqlInput {
     });
 }
 
+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

@@ -24,6 +24,8 @@ import {
     StorageQueueOutputOptions,
     TableOutput,
     TableOutputOptions,
+    WebPubSubOutput,
+    WebPubSubOutputOptions,
 } from '@azure/functions';
 import { addBindingName } from './addBindingName';
 
@@ -97,6 +99,13 @@ export function sql(options: SqlOutputOptions): SqlOutput {
     });
 }
 
+export function webPubSub(options: WebPubSubOutputOptions): WebPubSubOutput {
+    return addOutputBindingName({
+        ...options,
+        type: 'webPubSub',
+    });
+}
+
 export function generic(options: GenericOutputOptions): FunctionOutput {
     return addOutputBindingName(options);
 }

src/trigger.ts

@@ -26,6 +26,8 @@ import {
     TimerTriggerOptions,
     WarmupTrigger,
     WarmupTriggerOptions,
+    WebPubSubTrigger,
+    WebPubSubTriggerOptions,
 } from '@azure/functions';
 import { addBindingName } from './addBindingName';
 
@@ -108,6 +110,13 @@ export function sql(options: SqlTriggerOptions): SqlTrigger {
     });
 }
 
+export function webPubSub(options: WebPubSubTriggerOptions): WebPubSubTrigger {
+    return addTriggerBindingName({
+        ...options,
+        type: 'webPubSubTrigger',
+    });
+}
+
 export function generic(options: GenericTriggerOptions): FunctionTrigger {
     return addTriggerBindingName(options);
 }

types/index.d.ts

@@ -26,6 +26,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,12 @@ import { FunctionInput } from './index';
 import { SqlInput, SqlInputOptions } from './sql';
 import { StorageBlobInput, StorageBlobInputOptions } from './storage';
 import { TableInput, TableInputOptions } from './table';
+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 +34,16 @@ export function cosmosDB(options: CosmosDBInputOptions): CosmosDBInput;
  */
 export function sql(options: SqlInputOptions): SqlInput;
 
+/**
+ * [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

types/output.d.ts

@@ -16,6 +16,7 @@ import {
 import { SqlOutput, SqlOutputOptions } from './sql';
 import { StorageBlobOutput, StorageBlobOutputOptions, StorageQueueOutput, StorageQueueOutputOptions } from './storage';
 import { TableOutput, TableOutputOptions } from './table';
+import { WebPubSubOutput, WebPubSubOutputOptions } from './webpubsub';
 
 /**
  * [Link to docs and examples](https://docs.microsoft.com/azure/azure-functions/functions-bindings-http-webhook-output?&pivots=programming-language-javascript)
@@ -67,6 +68,11 @@ export function cosmosDB(options: CosmosDBOutputOptions): CosmosDBOutput;
  */
 export function sql(options: SqlOutputOptions): SqlOutput;
 
+/**
+ * [Link to docs and examples](https://docs.microsoft.com/azure/azure-functions/functions-bindings-web-pubsub-output?pivots=programming-language-javascript)
+ */
+export function webPubSub(options: WebPubSubOutputOptions): WebPubSubOutput;
+
 /**
  * A generic option that can be used for any output type
  * Use this method if your desired output type does not already have its own method

types/trigger.d.ts

@@ -22,7 +22,7 @@ import {
 } from './storage';
 import { TimerTrigger, TimerTriggerOptions } from './timer';
 import { WarmupTrigger, WarmupTriggerOptions } from './warmup';
-
+import { WebPubSubTrigger, WebPubSubTriggerOptions } from './webpubsub';
 /**
  * [Link to docs and examples](https://docs.microsoft.com/azure/azure-functions/functions-bindings-http-webhook-trigger?&pivots=programming-language-javascript)
  */
@@ -78,6 +78,11 @@ export function warmup(options: WarmupTriggerOptions): WarmupTrigger;
  */
 export function sql(options: SqlTriggerOptions): SqlTrigger;
 
+/**
+ * [Link to docs and examples](https://docs.microsoft.com/azure/azure-functions/functions-bindings-web-pubsub-trigger?pivots=programming-language-javascript)
+ */
+export function webPubSub(options: WebPubSubTriggerOptions): WebPubSubTrigger;
+
 /**
  * A generic option that can be used for any trigger type
  * Use this method if your desired trigger type does not already have its own method

types/webpubsub.d.ts

@@ -0,0 +1,114 @@
+// Copyright (c) .NET Foundation. All rights reserved.
+// Licensed under the MIT License.
+
+import { FunctionInput, FunctionOutput, FunctionTrigger } from './index';
+
+export interface WebPubSubTriggerOptions {
+    /**
+     * Required - The variable name used in function code for the parameter that receives the event data
+     */
+    name: string;
+
+    /**
+     * Required - The name of the hub to which the function is bound
+     */
+    hub: string;
+
+    /**
+     * Required - The type of event to which the function should respond
+     * Must be either 'user' or 'system'
+     */
+    eventType: 'user' | 'system';
+
+    /**
+     * Required - The name of the event to which the function should respond
+     * For system event type: 'connect', 'connected', or 'disconnected'
+     * For user-defined subprotocols: 'message'
+     * For system supported subprotocol json.webpubsub.azure.v1: user-defined event name
+     */
+    eventName: string;
+
+    /**
+     * Optional - Specifies which client protocol can trigger the Web PubSub trigger functions
+     * Default is 'all'
+     */
+    clientProtocols?: 'all' | 'webPubSub' | 'mqtt';
+
+    /**
+     * Optional - The name of an app setting or setting collection that specifies the upstream Azure Web PubSub service
+     * Used for signature validation
+     * Defaults to "WebPubSubConnectionString" if not specified
+     * Set to null to disable validation
+     */
+    connection?: string | null;
+}
+export type WebPubSubTrigger = FunctionTrigger & WebPubSubTriggerOptions;
+
+export interface WebPubSubConnectionInputOptions {
+    /**
+     * Required - Variable name used in function code for input connection binding object.
+     */
+    name?: string;
+
+    /**
+     * Required - The name of the Web PubSub hub for the function to be triggered.
+     * Can be set in the attribute (higher priority) or in app settings as a global value.
+     */
+    hub: string;
+
+    /**
+     * Optional - The value of the user identifier claim to be set in the access key token.
+     */
+    userId?: string;
+
+    /**
+     * Optional - The client protocol type.
+     * Valid values are 'default' and 'mqtt'.
+     * For MQTT clients, you must set it to 'mqtt'.
+     * For other clients, you can omit the property or set it to 'default'.
+     */
+    clientProtocol?: 'default' | 'mqtt';
+
+    /**
+     * Optional - The name of the app setting that contains the Web PubSub Service connection string.
+     * Defaults to "WebPubSubConnectionString".
+     */
+    connection?: string;
+}
+export type WebPubSubConnectionInput = FunctionInput & WebPubSubConnectionInputOptions;
+
+export interface WebPubSubContextInputOptions {
+    /**
+     * Required - Variable name used in function code for input Web PubSub request.
+     */
+    name: string;
+
+    /**
+     * Optional - The name of an app settings or setting collection that specifies the upstream Azure Web PubSub service.
+     * The value is used for Abuse Protection and Signature validation.
+     * The value is auto resolved with "WebPubSubConnectionString" by default.
+     * Null means the validation isn't needed and always succeeds.
+     */
+    connection?: string;
+}
+export type WebPubSubContextInput = FunctionInput & WebPubSubContextInputOptions;
+
+export interface WebPubSubOutputOptions {
+    /**
+     * Required - Variable name used in function code for output binding object.
+     */
+    name: string;
+
+    /**
+     * Required - The name of the hub to which the function is bound.
+     * Can be set in the attribute (higher priority) or in app settings as a global value.
+     */
+    hub: string;
+
+    /**
+     * Optional - The name of the app setting that contains the Web PubSub Service connection string.
+     * Defaults to "WebPubSubConnectionString".
+     */
+    connection?: string;
+}
+export type WebPubSubOutput = FunctionOutput & WebPubSubOutputOptions;