Merge pull request #72 from basics/beta

Beta

Author: StephanGerbeth

packages/operators/CHANGELOG.md

@@ -1,5 +1,12 @@
 # Project Changelog
 
+# [@rxjs-collection/operators-v1.0.5-beta.1](https://github.com/basics/rxjs-collection/compare/@rxjs-collection/operators-v1.0.4...@rxjs-collection/operators-v1.0.5-beta.1) (2024-10-25)
+
+
+### Bug Fixes
+
+* **fetch:** implemented sonar optimizations ([9063f6e](https://github.com/basics/rxjs-collection/commit/9063f6e9fc85f5d544af4e6d92d1d60e32cccf94))
+
 # [@rxjs-collection/operators-v1.0.4](https://github.com/basics/rxjs-collection/compare/@rxjs-collection/operators-v1.0.3...@rxjs-collection/operators-v1.0.4) (2024-10-25)
 
 

packages/operators/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@rxjs-collection/operators",
-  "version": "1.0.4",
+  "version": "1.0.5-beta.1",
   "description": "rxjs operators",
   "license": "MIT",
   "contributors": [

packages/operators/src/fetch/autoPagination.js

@@ -5,17 +5,19 @@ import { request } from './request';
 export const autoPagination = ({ resolveRoute }) => {
   return source =>
     source.pipe(
-      concatMap(({ url }) => {
-        return from(resolveRoute(url)).pipe(
-          request(),
-          expand(resp =>
-            from(resolveRoute(url, resp)).pipe(
-              filter(url => !!url),
-              request()
-            )
-          )
-        );
-      }),
+      concatMap(({ url }) => from(resolveRoute(url)).pipe(request(), getNext(resolveRoute, url))),
       map(resp => resp.clone())
     );
 };
+
+const getNext = (resolveRoute, url) => {
+  return source =>
+    source.pipe(
+      expand(resp =>
+        from(resolveRoute(url, resp)).pipe(
+          filter(url => !!url),
+          request()
+        )
+      )
+    );
+};

packages/operators/src/fetch/retry.js

@@ -23,19 +23,22 @@ export const networkRetry = ({ timeout = defaultTimeout, count } = {}) => {
       concatMap(resp => (!resp.ok && throwError(() => new Error('invalid request'))) || of(resp)),
       retry({
         count,
-        delay: () =>
-          combineLatest([connectionObservable]).pipe(
-            // all defined observables have to be valid
-            map(values => values.every(v => v === true)),
-            // reset counter if one observable is invalid
-            tap(valid => (counter = counter * valid)),
-            // continue only if all observables are valid
-            filter(valid => valid),
-            tap(() => console.log(`retry: request - next: ${counter} in ${timeout(counter)}s`)),
-            delay(timeout(counter++) || timeout)
-          )
+        delay: () => determineDelayWhenOnline(timeout, ++counter)
       }),
       catchError(e => console.error(e))
     );
   };
 };
+
+const determineDelayWhenOnline = (timeout, counter) => {
+  return combineLatest([connectionObservable]).pipe(
+    // all defined observables have to be valid
+    map(values => values.every(v => v === true)),
+    // reset counter if one observable is invalid
+    tap(valid => (counter = counter * valid)),
+    // continue only if all observables are valid
+    filter(valid => valid),
+    tap(() => console.log(`retry: request - next: ${counter} in ${timeout(counter)}s`)),
+    delay(timeout(counter) || timeout)
+  );
+};

packages/operators/src/fetch/retry.test.js

@@ -17,7 +17,7 @@ describe('request retry', function () {
     let counter = 0;
 
     const mockObservable = of(null).pipe(
-      map(() => ({ ok: !(++counter < 3) })),
+      map(() => ({ ok: ++counter >= 3 })),
       networkRetry({ timeout: () => 1000 })
     );
 

packages/operators/src/log.js

@@ -1,8 +1,8 @@
 import { Observable } from 'rxjs';
 
 export const log = (active = true) => {
-  return source => {
-    if (active) {
+  if (active) {
+    return source => {
       return new Observable(observer => {
         return source.subscribe(
           val => {
@@ -19,8 +19,8 @@ export const log = (active = true) => {
           }
         );
       });
-    } else {
-      return source;
-    }
-  };
+    };
+  } else {
+    return source => source;
+  }
 };

packages/operators/vitest.config.js

@@ -3,6 +3,7 @@ import { defineProject } from 'vitest/config';
 export default defineProject({
   test: {
     setupFiles: ['../../setup.js'],
+    testTimeout: 10000,
     environment: 'happy-dom'
   }
 });