refactor(paged-request): remove unused, untested paged-request

BREAKING CHANGE: PagedRequest no longer exists

Author: mumenthalers

src/dynamo/index.ts

@@ -1,6 +1,5 @@
 export * from './batchget'
 export * from './expression'
-export * from './paged'
 export * from './request'
 export * from './dynamo-rx'
 export * from './dynamo-store'

src/dynamo/paged/index.ts

@@ -20,6 +20,7 @@ export class BatchWriteSingleTableRequest<T> {
     }
     return this.keyFn
   }
+
   private keyFn: any
 
   readonly dynamoRx: DynamoRx
@@ -85,25 +86,23 @@ export class BatchWriteSingleTableRequest<T> {
     )
   }
 
+  // fixme backoff time is resetted for every request.. :/
   /**
    *
    * @param backoffTimer generator for how much timeSlots should be waited before requesting next batch. only used when capacity was exceeded. default randomExponentialBackoffTimer
    * @param throttleTimeSlot defines how long one timeSlot is for throttling, default 1 second
    */
   exec(backoffTimer = randomExponentialBackoffTimer, throttleTimeSlot = 1000): Observable<void> {
     this.logger.debug('starting batchWriteItem')
-    let rBoT = backoffTimer()
-    let backoffTime = 0
+    const rBoT = backoffTimer()
     return this.execNextBatch().pipe(
       mergeMap((r: BatchWriteSingleTableResponse) => {
-        if (!r.capacityExceeded) {
-          rBoT = backoffTimer()
-          backoffTime = 0
-        } else {
-          backoffTime = rBoT.next().value * throttleTimeSlot
+        if (r.capacityExceeded) {
+          const backoffTime = rBoT.next().value * throttleTimeSlot
           this.logger.info(`wait ${backoffTime} ms until next request`, { backoffTime })
+          return of(r).pipe(delay(backoffTime))
         }
-        return of(r).pipe(delay(backoffTime))
+        return of(r)
       }),
       mergeMap((r: BatchWriteSingleTableResponse) => {
         if (r.remainingItems > 0) {

src/dynamo/paged/pageable.ts

@@ -14,12 +14,10 @@ import {
   RequestConditionFunction,
   RequestSortKeyConditionFunction,
 } from '../../expression/type'
-import { Pageable } from '../../paged'
 import { Request } from '../request.model'
 import { QueryResponse } from './query.response'
 
-export class QueryRequest<T> extends Request<T, QueryRequest<T>, QueryInput, QueryResponse<T>>
-  implements Pageable<T, QueryRequest<T>, QueryResponse<T>> {
+export class QueryRequest<T> extends Request<T, QueryRequest<T>, QueryInput, QueryResponse<T>> {
   private readonly logger: Logger
 
   constructor(dynamoRx: DynamoRx, modelClazz: ModelConstructor<T>, tableName: string) {

src/dynamo/paged/paged-data-source.ts

@@ -10,12 +10,10 @@ import { and } from '../../expression'
 import { addExpression } from '../../expression/param-util'
 import { addCondition } from '../../expression/request-expression-builder'
 import { ConditionExpressionDefinitionFunction, RequestConditionFunction } from '../../expression/type'
-import { Pageable } from '../../paged'
 import { Request } from '../request.model'
 import { ScanResponse } from './scan.response'
 
-export class ScanRequest<T> extends Request<T, ScanRequest<T>, ScanInput, ScanResponse<T>>
-  implements Pageable<T, ScanRequest<T>, ScanResponse<T>> {
+export class ScanRequest<T> extends Request<T, ScanRequest<T>, ScanInput, ScanResponse<T>> {
   private readonly logger: Logger
 
   constructor(dynamoRx: DynamoRx, modelClazz: ModelConstructor<T>, tableName: string) {