Merge branch 'v4.x' into ej/httpStream

package.json

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

src/InvocationModel.ts

@@ -20,6 +20,7 @@ import { fromRpcTypedData } from './converters/fromRpcTypedData';
 import { toCamelCaseValue } from './converters/toCamelCase';
 import { toRpcHttp } from './converters/toRpcHttp';
 import { toRpcTypedData } from './converters/toRpcTypedData';
+import { AzFuncSystemError } from './errors';
 import { waitForProxyRequest } from './http/httpProxy';
 import { HttpRequest } from './http/HttpRequest';
 import { InvocationContext } from './InvocationContext';
@@ -64,7 +65,15 @@ export class InvocationModel implements coreTypes.InvocationModel {
             for (const binding of req.inputData) {
                 const bindingName = nonNullProp(binding, 'name');
 
-                const bindingType = nonNullProp(this.#bindings, bindingName).type;
+                const rpcBinding = this.#bindings[bindingName];
+                if (!rpcBinding) {
+                    throw new AzFuncSystemError(
+                        `Failed to find binding "${bindingName}" in bindings "${Object.keys(this.#bindings).join(
+                            ', '
+                        )}".`
+                    );
+                }
+                const bindingType = rpcBinding.type;
 
                 let input: unknown;
                 if (isHttpTrigger(bindingType) && isHttpStreamEnabled()) {

src/constants.ts

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

test/InvocationModel.test.ts

@@ -79,5 +79,36 @@ describe('InvocationModel', () => {
             const response = await model.getResponse(context, undefined);
             expect(response).to.deep.equal({ invocationId: 'testInvocId', outputData: [], returnValue: undefined });
         });
+
+        // https://github.com/Azure/azure-functions-nodejs-library/issues/210
+        it('Missing binding', async () => {
+            const model = new InvocationModel({
+                invocationId: 'testInvocId',
+                metadata: {
+                    name: 'testFuncName',
+                    bindings: {
+                        httpTrigger1: {
+                            type: 'httpTrigger',
+                            direction: 'in',
+                        },
+                        $return: {
+                            type: 'http',
+                            direction: 'out',
+                        },
+                    },
+                },
+                request: {
+                    inputData: [
+                        {
+                            name: 'httpTriggerMissing',
+                        },
+                    ],
+                },
+                log: testLog,
+            });
+            await expect(model.getArguments()).to.be.rejectedWith(
+                'Failed to find binding "httpTriggerMissing" in bindings "httpTrigger1, $return".'
+            );
+        });
     });
 });