Skip to content

Commit 655b7a3

Browse files
author
Evan Roman
committed
test
1 parent bae5c51 commit 655b7a3

File tree

2 files changed

+44
-44
lines changed

2 files changed

+44
-44
lines changed
Lines changed: 26 additions & 26 deletions
Original file line numberDiff line numberDiff line change
@@ -1,31 +1,31 @@
1-
// // Copyright (c) .NET Foundation. All rights reserved.
2-
// // Licensed under the MIT License.
1+
// Copyright (c) .NET Foundation. All rights reserved.
2+
// Licensed under the MIT License.
33

4-
// import { app, InvocationContext, output } from '@azure/functions';
4+
import { app, InvocationContext, output } from '@azure/functions';
55

6-
// // Test for bug https://github.com/Azure/azure-functions-nodejs-library/issues/179
6+
// Test for bug https://github.com/Azure/azure-functions-nodejs-library/issues/179
77

8-
// const queueOutput = output.storageQueue({
9-
// queueName: 'e2e-test-queue-trigger',
10-
// connection: 'AzureWebJobsStorage',
11-
// });
8+
const queueOutput = output.storageQueue({
9+
queueName: 'e2e-test-queue-trigger',
10+
connection: 'AzureWebJobsStorage',
11+
});
1212

13-
// app.storageBlob('storageBlobTriggerReturnOutput', {
14-
// path: 'e2e-test-container/e2e-test-blob-trigger-shared-output-bug',
15-
// connection: 'AzureWebJobsStorage',
16-
// return: queueOutput,
17-
// handler: (blob: Buffer, context: InvocationContext) => {
18-
// context.log(`storageBlobTriggerReturnOutput was triggered`);
19-
// return `${blob.toString()}-returnOutput`;
20-
// },
21-
// });
13+
app.storageBlob('storageBlobTriggerReturnOutput', {
14+
path: 'e2e-test-container/e2e-test-blob-trigger-shared-output-bug',
15+
connection: 'AzureWebJobsStorage',
16+
return: queueOutput,
17+
handler: (blob: Buffer, context: InvocationContext) => {
18+
context.log(`storageBlobTriggerReturnOutput was triggered`);
19+
return `${blob.toString()}-returnOutput`;
20+
},
21+
});
2222

23-
// app.storageBlob('storageBlobTriggerExtraOutput', {
24-
// path: 'e2e-test-container/e2e-test-blob-trigger-shared-output-bug',
25-
// connection: 'AzureWebJobsStorage',
26-
// extraOutputs: [queueOutput],
27-
// handler: (blob: Buffer, context: InvocationContext) => {
28-
// context.log(`storageBlobTriggerExtraOutput was triggered`);
29-
// context.extraOutputs.set(queueOutput, `${blob.toString()}-extraOutput`);
30-
// },
31-
// });
23+
app.storageBlob('storageBlobTriggerExtraOutput', {
24+
path: 'e2e-test-container/e2e-test-blob-trigger-shared-output-bug',
25+
connection: 'AzureWebJobsStorage',
26+
extraOutputs: [queueOutput],
27+
handler: (blob: Buffer, context: InvocationContext) => {
28+
context.log(`storageBlobTriggerExtraOutput was triggered`);
29+
context.extraOutputs.set(queueOutput, `${blob.toString()}-extraOutput`);
30+
},
31+
});

src/storage.test.ts

Lines changed: 18 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ import { ContainerClient } from '@azure/storage-blob';
66
// import { expect } from 'chai';
77
// import { default as fetch } from 'node-fetch';
88
// import { getFuncUrl } from './constants';
9-
import { waitForOutput } from './global.test';
9+
import { model, waitForOutput } from './global.test';
1010
import { getRandomTestData } from './utils/getRandomTestData';
1111
import { storageConnectionString } from './utils/connectionStrings';
1212

@@ -85,23 +85,23 @@ describe('storage', () => {
8585
// });
8686

8787
// Test for bug https://github.com/Azure/azure-functions-nodejs-library/issues/179
88-
// it('Shared output bug', async function (this: Mocha.Context) {
89-
// if (model === 'v3') {
90-
// this.skip();
91-
// }
88+
it('Shared output bug', async function (this: Mocha.Context) {
89+
if (model === 'v3') {
90+
this.skip();
91+
}
9292

93-
// const containerName = 'e2e-test-container';
94-
// const client = new ContainerClient(storageConnectionString, containerName);
95-
// await client.createIfNotExists();
93+
const containerName = 'e2e-test-container';
94+
const client = new ContainerClient(storageConnectionString, containerName);
95+
await client.createIfNotExists();
9696

97-
// const message = getRandomTestData();
98-
// const messageBuffer = Buffer.from(message);
99-
// const blobName = 'e2e-test-blob-trigger-shared-output-bug';
100-
// await client.uploadBlockBlob(blobName, messageBuffer, messageBuffer.byteLength);
101-
102-
// await waitForOutput(`storageBlobTriggerReturnOutput was triggered`);
103-
// await waitForOutput(`storageBlobTriggerExtraOutput was triggered`);
104-
// await waitForOutput(`storageQueueTrigger was triggered by "${message}-returnOutput"`);
105-
// await waitForOutput(`storageQueueTrigger was triggered by "${message}-extraOutput"`);
106-
// });
97+
const message = getRandomTestData();
98+
const messageBuffer = Buffer.from(message);
99+
const blobName = 'e2e-test-blob-trigger-shared-output-bug';
100+
await client.uploadBlockBlob(blobName, messageBuffer, messageBuffer.byteLength);
101+
102+
await waitForOutput(`storageBlobTriggerReturnOutput was triggered`);
103+
await waitForOutput(`storageBlobTriggerExtraOutput was triggered`);
104+
await waitForOutput(`storageQueueTrigger was triggered by "${message}-returnOutput"`);
105+
await waitForOutput(`storageQueueTrigger was triggered by "${message}-extraOutput"`);
106+
});
107107
});

0 commit comments

Comments
 (0)