Skip to content

Commit e1a0f9a

Browse files
StuartFergusonStuartFerguson
committed
:\
1 parent f7683ae commit e1a0f9a

8 files changed

Lines changed: 0 additions & 26 deletions

‎FileProcessor.IntegrationTests/projections/continuous/CallbackHandlerEnricher.js‎

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,3 @@
1-
var fromStreams = fromStreams || require('../../node_modules/@transactionprocessing/esprojection-testing-framework').scope.fromStreams;
2-
var emit = emit || require('../../node_modules/@transactionprocessing/esprojection-testing-framework').scope.emit;
3-
41
fromStreams("$ce-EstateAggregate", "$et-CallbackReceivedEvent")
52
.when({
63
$init: function (s, e)

‎FileProcessor.IntegrationTests/projections/continuous/EstateAggregator.js‎

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,3 @@
1-
var fromAll = fromAll || require("../../node_modules/@transactionprocessing/esprojection-testing-framework").scope.fromAll;
2-
var linkTo = linkTo || require("../../node_modules/@transactionprocessing/esprojection-testing-framework").scope.linkTo;
3-
41
isEstateEvent = (e) => { return (e.data && e.data.estateId); }
52
isAnEstateCreatedEvent = (e) => { return compareEventTypeSafely(e.eventType, 'EstateCreatedEvent') };
63

‎FileProcessor.IntegrationTests/projections/continuous/EstateManagementSubscriptionStreamBuilder.js‎

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,3 @@
1-
var fromAll = fromAll || require("../../node_modules/@transactionprocessing/esprojection-testing-framework").scope.fromAll;
2-
var linkTo = linkTo || require("../../node_modules/@transactionprocessing/esprojection-testing-framework").scope.linkTo;
3-
41
isEstateEvent = (e) => { return (e.data && e.data.estateId); }
52
isAnEstateCreatedEvent = (e) => { return compareEventTypeSafely(e.eventType, 'EstateCreatedEvent') };
63
compareEventTypeSafely = (sourceEventType, targetEventType) => { return (sourceEventType.toUpperCase() === targetEventType.toUpperCase()); }

‎FileProcessor.IntegrationTests/projections/continuous/FileProcessorSubscriptionStreamBuilder.js‎

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,3 @@
1-
var fromAll = fromAll || require("../../node_modules/@transactionprocessing/esprojection-testing-framework").scope.fromAll;
2-
var linkTo = linkTo || require("../../node_modules/@transactionprocessing/esprojection-testing-framework").scope.linkTo;
3-
41
isEstateEvent = (e) => { return (e.data && e.data.estateId); }
52
isAnEstateCreatedEvent = (e) => { return compareEventTypeSafely(e.eventType, 'EstateCreatedEvent') };
63
compareEventTypeSafely = (sourceEventType, targetEventType) => { return (sourceEventType.toUpperCase() === targetEventType.toUpperCase()); }

‎FileProcessor.IntegrationTests/projections/continuous/MerchantAggregator.js‎

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,3 @@
1-
var fromAll = fromAll || require("../../node_modules/@transactionprocessing/esprojection-testing-framework").scope.fromAll;
2-
var linkTo = linkTo || require("../../node_modules/@transactionprocessing/esprojection-testing-framework").scope.linkTo;
3-
41
isValidEvent = function (e) {
52

63
if (e) {

‎FileProcessor.IntegrationTests/projections/continuous/MerchantBalanceCalculator.js‎

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,3 @@
1-
var fromCategory = fromCategory || require('../../node_modules/@transactionprocessing/esprojection-testing-framework').scope.fromCategory;
2-
var partitionBy = partitionBy !== null ? partitionBy : require('../../node_modules/@transactionprocessing/esprojection-testing-framework').scope.partitionBy;
3-
var emit = emit || require('../../node_modules/@transactionprocessing/esprojection-testing-framework').scope.emit;
4-
51
fromCategory('MerchantArchive')
62
.foreachStream()
73
.when({

‎FileProcessor.IntegrationTests/projections/continuous/TransactionEnricher.js‎

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,3 @@
1-
var fromCategory = fromCategory || require('../../node_modules/@transactionprocessing/esprojection-testing-framework').scope.fromCategory;
2-
var emit = emit || require('../../node_modules/@transactionprocessing/esprojection-testing-framework').scope.emit;
3-
var linkTo = linkTo || require("../../node_modules/@transactionprocessing/esprojection-testing-framework").scope.linkTo;
4-
51
fromCategory('TransactionAggregate')
62
.foreachStream()
73
.when({

‎FileProcessor.IntegrationTests/projections/continuous/TransactionProcessorSubscriptionStreamBuilder.js‎

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,3 @@
1-
var fromAll = fromAll || require("../../node_modules/@transactionprocessing/esprojection-testing-framework").scope.fromAll;
2-
var linkTo = linkTo || require("../../node_modules/@transactionprocessing/esprojection-testing-framework").scope.linkTo;
3-
41
isEstateEvent = (e) => { return (e.data && e.data.estateId); }
52
isAnEstateCreatedEvent = (e) => { return compareEventTypeSafely(e.eventType, 'EstateCreatedEvent') };
63
compareEventTypeSafely = (sourceEventType, targetEventType) => { return (sourceEventType.toUpperCase() === targetEventType.toUpperCase()); }

0 commit comments

Comments
 (0)