diff options
author | Austin Schaffer <austin.schaffer@ryansg.com> | 2019-12-26 15:28:40 -0500 |
---|---|---|
committer | Austin Schaffer <austin.schaffer@ryansg.com> | 2019-12-26 15:28:46 -0500 |
commit | 3fbe9b31ff9b0e4700332fa23168ecc7ad0a09cc (patch) | |
tree | 80678b8771af1920b966ed477c2215100ddc2a90 | |
parent | 8ae6e236e988f4e3b59d7c2d2af0293fdce0f02d (diff) | |
download | liza-3fbe9b31ff9b0e4700332fa23168ecc7ad0a09cc.tar.gz liza-3fbe9b31ff9b0e4700332fa23168ecc7ad0a09cc.tar.bz2 liza-3fbe9b31ff9b0e4700332fa23168ecc7ad0a09cc.zip |
[DEV-6763] Include ratedata in data deltas
-rw-r--r-- | src/system/DeltaProcessor.ts | 2 | ||||
-rw-r--r-- | test/system/DeltaProcessorTest.ts | 25 |
2 files changed, 21 insertions, 6 deletions
diff --git a/src/system/DeltaProcessor.ts b/src/system/DeltaProcessor.ts index 41b9a01..89ef16b 100644 --- a/src/system/DeltaProcessor.ts +++ b/src/system/DeltaProcessor.ts @@ -189,7 +189,7 @@ export class DeltaProcessor pairs[ i ] = [ delta, bucket_state, - ( delta.type === this.DELTA_RATEDATA ) ? ratedata_state : {}, + ratedata_state, ]; // Don't apply the final delta, since we won't use it diff --git a/test/system/DeltaProcessorTest.ts b/test/system/DeltaProcessorTest.ts index e204165..e4a54d4 100644 --- a/test/system/DeltaProcessorTest.ts +++ b/test/system/DeltaProcessorTest.ts @@ -131,7 +131,10 @@ describe( 'system.DeltaProcessor', () => foo: [ 'first' ], state: [ 'a', 'b' ], }, - ratedata: {}, + ratedata: { + prem: [ '' ], + state: [ 'i' ], + }, }, // rate @@ -164,7 +167,10 @@ describe( 'system.DeltaProcessor', () => foo: [ 'second' ], state: [ 'a', 'b', 'c' ], }, - ratedata: {}, + ratedata: { + prem: [ 'rate_first' ], + state: [ 'i', 'ii' ], + }, }, // rate @@ -197,7 +203,10 @@ describe( 'system.DeltaProcessor', () => foo: [ 'third' ], state: [ 'a', 'b', 'c', 'd' ], }, - ratedata: {}, + ratedata: { + prem: [ 'rate_second' ], + state: [ 'i', 'ii', 'iii' ], + }, }, ], }, @@ -296,7 +305,10 @@ describe( 'system.DeltaProcessor', () => foo: [ 'first' ], state: [ 'a', 'b' ], }, - ratedata: {}, + ratedata: { + prem: [ '' ], + state: [ 'i' ], + }, }, // rate @@ -327,7 +339,10 @@ describe( 'system.DeltaProcessor', () => foo2: [ 'first' ], state: [ 'a', 'b' ], }, - ratedata: {}, + ratedata: { + prem2: [ '' ], + state: [ 'i' ], + }, }, // rate |