1 |
|
2 |
|
3 |
|
4 |
|
5 |
|
6 | function removeEventStreamOperations(model) {
|
7 | var modifiedModel = false;
|
8 |
|
9 | var operations = model.operations;
|
10 | var operationNames = Object.keys(operations);
|
11 | for (var i = 0; i < operationNames.length; i++) {
|
12 | var operationName = operationNames[i];
|
13 | var operation = operations[operationName];
|
14 |
|
15 | var inputShapeName = operation.input && operation.input.shape;
|
16 | var outputShapeName = operation.output && operation.output.shape;
|
17 |
|
18 | var requiresEventStream = false;
|
19 | if (inputShapeName && hasEventStream(model.shapes[inputShapeName], model)) {
|
20 | requiresEventStream = true;
|
21 | }
|
22 |
|
23 | if (requiresEventStream) {
|
24 | modifiedModel = true;
|
25 |
|
26 | console.log('Removing ' + operationName + ' because it depends on event streams on input.');
|
27 | delete model.operations[operationName];
|
28 | }
|
29 | }
|
30 | return modifiedModel;
|
31 | }
|
32 |
|
33 | function hasEventStream(shape, model) {
|
34 | if (shape.eventstream) {
|
35 | return true;
|
36 | } else {
|
37 |
|
38 | var memberNames = Object.keys(shape.members);
|
39 | for (var i = 0; i < memberNames.length; i++) {
|
40 | var member = shape.members[memberNames[i]];
|
41 | if (member.eventstream) {
|
42 | return true;
|
43 | }
|
44 | var memberShape = model.shapes[member.shape];
|
45 | if (memberShape.eventstream) {
|
46 | return true;
|
47 | }
|
48 | }
|
49 | }
|
50 | }
|
51 |
|
52 | module.exports = {
|
53 | removeEventStreamOperations: removeEventStreamOperations
|
54 | }; |
\ | No newline at end of file |