Feature/restructure

packages/observables/package.json

@@ -17,6 +17,9 @@
   "scripts": {
     "release": "npx semantic-release"
   },
+  "imports": {
+    "#mocks/*": "../mocks/*"
+  },
   "dependencies": {
     "@rxjs-collection/operators": "*",
     "rxjs": "7.8.1"

packages/observables/src/dom/window.test.js

@@ -1,8 +1,8 @@
+import { mockOffline, mockOnline, mockReset } from '#mocks/network.js';
 import { tap } from 'rxjs';
 import { TestScheduler } from 'rxjs/testing';
 import { beforeEach, test, expect, describe, afterEach } from 'vitest';
 
-import { mockOffline, mockOnline, mockReset } from '../../../mock/network.js';
 import { connectionObservable } from './window.js';
 
 // HINT: https://betterprogramming.pub/rxjs-testing-write-unit-tests-for-observables-603af959e251

packages/operators/CHANGELOG.md

@@ -1,5 +1,12 @@
 # Project Changelog
 
+# [@rxjs-collection/operators-v1.0.9](https://github.com/basics/rxjs-collection/compare/@rxjs-collection/operators-v1.0.8...@rxjs-collection/operators-v1.0.9) (2024-11-24)
+
+
+### Bug Fixes
+
+* **operators:** remove skips from coverage ([62652b1](https://github.com/basics/rxjs-collection/commit/62652b13635e35a348d9ae134e389a3a1f39aa59))
+
 # [@rxjs-collection/operators-v1.0.9-beta.1](https://github.com/basics/rxjs-collection/compare/@rxjs-collection/operators-v1.0.8...@rxjs-collection/operators-v1.0.9-beta.1) (2024-11-24)
 
 

packages/operators/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@rxjs-collection/operators",
-  "version": "1.0.9-beta.1",
+  "version": "1.0.9",
   "description": "rxjs operators",
   "license": "MIT",
   "contributors": [
@@ -17,6 +17,10 @@
   "scripts": {
     "release": "npx semantic-release"
   },
+  "imports": {
+    "#observables/*": "../observables/src/*",
+    "#mocks/*": "../mocks/*"
+  },
   "dependencies": {
     "@rxjs-collection/observables": "*",
     "ansi-colors": "4.1.3",

packages/operators/src/index.js

@@ -0,0 +1,14 @@
+export { autoPagination } from './request/autoPagination';
+export { cache } from './request/cache';
+export { concurrentRequest } from './request/concurrentRequest';
+export { lazyPagination } from './request/lazyPagination';
+export { polling } from './request/polling';
+export { request, requestJSON, requestText, requestBlob } from './request/request';
+export {
+  resolve,
+  resolveJSON,
+  resolveText,
+  resolveBlob,
+  distinctUntilResponseChanged
+} from './request/response';
+export { retryWhenError } from './request/retry';

packages/operators/src/request/autoPagination.test.js

@@ -1,9 +1,9 @@
+import { mockAsync } from '#mocks/async';
+import { mockResponse } from '#mocks/response';
 import { concatAll, delay, from, map, of } from 'rxjs';
 import { TestScheduler } from 'rxjs/testing';
 import { afterAll, beforeAll, beforeEach, describe, expect, test, vi } from 'vitest';
 
-import { mockAsync } from '../../../mock/async';
-import { mockResponse } from '../../../mock/response';
 import { log, logResult } from '../log';
 import { resolveJSON } from './response';
 

packages/operators/src/request/concurrentRequest.test.js

@@ -1,9 +1,9 @@
+import { mockAsync } from '#mocks/async';
+import { mockResponse } from '#mocks/response';
 import { concatAll, delay, map, of } from 'rxjs';
 import { TestScheduler } from 'rxjs/testing';
 import { afterAll, beforeAll, beforeEach, describe, expect, test, vi } from 'vitest';
 
-import { mockAsync } from '../../../mock/async';
-import { mockResponse } from '../../../mock/response';
 import { log, logResult } from '../log';
 import { resolveJSON, resolveText } from './response';
 

packages/operators/src/request/lazyPagination.test.js

@@ -1,9 +1,9 @@
+import { mockAsync } from '#mocks/async';
+import { mockResponse } from '#mocks/response';
 import { concatAll, delay, map, of, Subject, tap } from 'rxjs';
 import { TestScheduler } from 'rxjs/testing';
 import { afterAll, beforeAll, beforeEach, describe, expect, test, vi } from 'vitest';
 
-import { mockAsync } from '../../../mock/async';
-import { mockResponse } from '../../../mock/response';
 import { log, logResult } from '../log';
 import { resolveJSON } from './response';
 

packages/operators/src/request/polling.test.js

@@ -1,10 +1,9 @@
+import { mockAsync } from '#mocks/async';
+import { mockResponse } from '#mocks/response';
 import { concatMap } from 'rxjs';
 import { TestScheduler } from 'rxjs/testing';
 import { afterAll, beforeAll, beforeEach, describe, expect, test, vi } from 'vitest';
 
-import { mockAsync } from '../../../mock/async';
-import { mockResponse } from '../../../mock/response';
-
 describe('polling', () => {
   let testScheduler;
 

packages/operators/src/request/request.test.js

@@ -1,10 +1,10 @@
+import { mockAsync } from '#mocks/async.js';
+import { mockResponse } from '#mocks/response.js';
 import { readFile } from 'node:fs/promises';
 import { of } from 'rxjs';
 import { TestScheduler } from 'rxjs/testing';
 import { test, describe, beforeEach, expect, vi, afterAll, beforeAll } from 'vitest';
 
-import { mockAsync } from '../../../mock/async.js';
-import { mockResponse } from '../../../mock/response.js';
 import { log, logResult } from '../log.js';
 import { resolveJSON } from './response.js';
 

packages/operators/src/request/response.test.js

@@ -1,8 +1,8 @@
+import { mockResponse } from '#mocks/response';
 import { concatMap } from 'rxjs';
 import { TestScheduler } from 'rxjs/testing';
 import { afterEach, test, describe, beforeEach, expect, vi, beforeAll } from 'vitest';
 
-import { mockResponse } from '../../../mock/response';
 import { log } from '../log';
 import { distinctUntilResponseChanged, resolveJSON, resolveText } from './response';
 

packages/operators/src/request/retry.js

@@ -1,3 +1,4 @@
+import { connectionObservable } from '#observables/dom/window.js';
 import {
   combineLatest,
   concatMap,
@@ -12,8 +13,6 @@
   throwError
 } from 'rxjs';
 
-import { connectionObservable } from '../../../observables/src/dom/window.js';
-
 const defaultTimeout = count => Math.min(60000, Math.pow(count, 2) * 1000);
 
 export const retryWhenError = ({ timeout = defaultTimeout, count } = {}) => {
@@ -44,7 +43,7 @@
     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)}ms`)),
     delay(timeout(counter))
   );
 };