;
+export type TransformParamsFn = (params: P) => P | void;
+
+export type DispatchOption = boolean | 'both';
diff --git a/src/utils/calling-params/calling-params.ts b/src/utils/calling-params/calling-params.ts
index 08ee037e..8a1e08b8 100755
--- a/src/utils/calling-params/calling-params.ts
+++ b/src/utils/calling-params/calling-params.ts
@@ -58,14 +58,15 @@ export function callingParamsDefaults(propNames: string[], newProps?: any): void
* Build params for a service call. (Utility function.)
* @see https://hooks-common.feathersjs.com/utilities.html#callingparams
*/
-export function callingParams({
- query,
- propNames = [],
- newProps = {},
- hooksToDisable = [],
- ignoreDefaults,
-}: CallingParamsOptions = {}) {
- return (context: H) => {
+export const callingParams =
+ ({
+ query,
+ propNames = [],
+ newProps = {},
+ hooksToDisable = [],
+ ignoreDefaults,
+ }: CallingParamsOptions = {}) =>
+ (context: H) => {
propNames = Array.isArray(propNames) ? propNames : [propNames];
hooksToDisable = Array.isArray(hooksToDisable) ? hooksToDisable : [hooksToDisable];
@@ -113,7 +114,6 @@ export function callingParams({
return newParams;
};
-}
/**
* You should prefer using the callingParams utility to makeCallingParams.
diff --git a/src/utils/check-context/check-context.test.ts b/src/utils/check-context/check-context.test.ts
index aaa50cdc..52388ba3 100755
--- a/src/utils/check-context/check-context.test.ts
+++ b/src/utils/check-context/check-context.test.ts
@@ -1,101 +1,77 @@
-import { assert } from 'vitest';
+import { assert, expect } from 'vitest';
import { checkContext } from './check-context';
+import { HookContext } from '@feathersjs/feathers';
-describe('util checkContext', () => {
- var hook: any; // eslint-disable-line no-var
-
- beforeEach(() => {
- hook = { type: 'before', method: 'create' };
- });
+const make = (type: any, method: any) => ({ type, method }) as HookContext;
+describe('util checkContext', () => {
it('handles "any" type and method', () => {
- assert.equal(checkContext(hook), undefined);
+ expect(() => checkContext(make('before', 'create'))).not.toThrow();
});
it('handles expected type', () => {
- hook.type = 'before';
- assert.equal(checkContext(hook, 'before'), undefined);
+ expect(() => checkContext(make('before', 'create'), 'before')).not.toThrow();
});
it('handles unexpected type', () => {
- hook.type = 'after';
- assert.throws(() => {
- checkContext(hook, 'before');
- });
+ expect(() => checkContext(make('after', 'create'), 'before')).toThrow();
});
it('handles undefined type', () => {
- hook.type = 'after';
- assert.equal(checkContext(hook), undefined);
+ expect(() => checkContext(make('after', 'create'), undefined, 'create')).not.toThrow();
});
it('handles null type', () => {
- hook.type = 'after';
- assert.equal(checkContext(hook, null), undefined);
+ expect(() => checkContext(make('after', 'create'), null, 'create')).not.toThrow();
});
it('handles expected type as array', () => {
- hook.type = 'before';
- assert.equal(checkContext(hook, ['before', 'after']), undefined);
+ expect(() => checkContext(make('before', 'create'), ['before', 'after'])).not.toThrow();
});
it('handles unexpected type as array', () => {
- hook.type = 'error';
- assert.throws(() => {
- checkContext(hook, ['before', 'after']);
- });
+ expect(() => checkContext(make('error', 'create'), ['before', 'after'])).toThrow();
});
it('handles expected method as string', () => {
- hook.method = 'create';
- assert.equal(checkContext(hook, null, 'create'), undefined);
+ expect(() => checkContext(make('before', 'create'), null, 'create')).not.toThrow();
});
it('handles unexpected method as string', () => {
- hook.method = 'patch';
- assert.throws(() => {
- checkContext(hook, null, 'create');
- });
+ expect(() => checkContext(make('before', 'patch'), null, 'create')).toThrow();
});
it('handles expected method as array', () => {
- hook.method = 'create';
- assert.equal(checkContext(hook, null, ['create']), undefined);
- assert.equal(checkContext(hook, null, ['create', 'update', 'remove']), undefined);
+ expect(() =>
+ checkContext(make('before', 'create'), null, ['create', 'update', 'remove']),
+ ).not.toThrow();
});
it('handles unexpected method as array', () => {
- hook.method = 'patch';
- assert.throws(() => {
- checkContext(hook, null, ['create']);
- });
- assert.throws(() => {
- checkContext(hook, null, ['create', 'update', 'remove']);
- });
+ expect(() =>
+ checkContext(make('before', 'patch'), null, ['create', 'update', 'remove']),
+ ).toThrow();
});
it('handles undefined method', () => {
- hook.method = 'patch';
- assert.equal(checkContext(hook, null), undefined);
+ expect(() => checkContext(make('before', 'patch'), null, undefined)).not.toThrow();
});
it('handles null method', () => {
- hook.method = 'patch';
- assert.equal(checkContext(hook, null, null), undefined);
+ expect(() => checkContext(make('before', 'patch'), null, null)).not.toThrow();
});
it('handles expected type and method as array', () => {
- hook.type = 'before';
- hook.method = 'create';
- assert.equal(checkContext(hook, 'before', ['create']), undefined);
- assert.equal(checkContext(hook, 'before', ['create', 'update', 'remove']), undefined);
+ expect(() =>
+ checkContext(make('before', 'create'), ['before', 'after'], ['create', 'update', 'remove']),
+ ).not.toThrow();
});
it('allows custom methods', () => {
- hook.type = 'before';
- hook.method = 'custom';
- assert.equal(checkContext(hook, 'before', ['create']), undefined);
- assert.equal(checkContext(hook, 'before', ['create', 'update', 'remove']), undefined);
+ expect(() => checkContext(make('before', 'custom'), 'before', 'create')).toThrow();
+ expect(() =>
+ checkContext(make('before', 'custom'), 'before', ['create', 'custom']),
+ ).not.toThrow();
});
});
diff --git a/src/utils/check-context/check-context.ts b/src/utils/check-context/check-context.ts
index 26df7c5f..4dbe6b14 100755
--- a/src/utils/check-context/check-context.ts
+++ b/src/utils/check-context/check-context.ts
@@ -1,6 +1,6 @@
import type { HookContext } from '@feathersjs/feathers';
-import { methodNames } from '../../types';
import type { HookType, MethodName } from '../../types';
+import { isContext } from '../../predicates/is-context/is-context';
/**
* Restrict a hook to run for certain methods and method types. (Utility function.)
@@ -12,24 +12,12 @@ export function checkContext(
methods?: MethodName | MethodName[] | null,
label = 'anonymous',
): void {
- if (type) {
- const types = Array.isArray(type) ? type : [type]; // safe enough for allowed values
- if (!types.includes(context.type)) {
- throw new Error(`The '${label}' hook can only be used as a '${type}' hook.`);
- }
- }
-
- if (!methods) {
- return;
- }
- if (!methodNames.includes(context.method as any)) {
- return;
- } // allow custom methods
-
- const methodsArr = Array.isArray(methods) ? methods : [methods]; // safe enough for allowed values
-
- if (methodsArr.length > 0 && !methodsArr.includes(context.method as any)) {
- const msg = JSON.stringify(methodsArr);
- throw new Error(`The '${label}' hook can only be used on the '${msg}' service method(s).`);
+ if (
+ !isContext({
+ method: methods ?? undefined,
+ type: type ?? undefined,
+ })(context)
+ ) {
+ throw new Error(`The '${label}' hook has invalid context.`);
}
}
diff --git a/src/utils/combine/combine.ts b/src/utils/combine/combine.ts
index 5b2d3fc6..8a75aca4 100755
--- a/src/utils/combine/combine.ts
+++ b/src/utils/combine/combine.ts
@@ -2,7 +2,7 @@ import type { HookContext } from '@feathersjs/feathers';
import type { HookFunction } from '../../types';
/**
- * Sequentially execute multiple sync or async hooks.
+ * Sequentially execute multiple hooks.
* @see https://hooks-common.feathersjs.com/utilities.html#combine
*/
export function combine(...serviceHooks: HookFunction[]) {
diff --git a/src/utils/every/every.ts b/src/utils/every/every.ts
deleted file mode 100755
index ef46016a..00000000
--- a/src/utils/every/every.ts
+++ /dev/null
@@ -1,18 +0,0 @@
-import type { HookContext } from '@feathersjs/feathers';
-import type { AsyncPredicateFn, PredicateFn } from '../../types';
-
-/**
- * Return the and of a series of sync or async predicate functions.
- * @see https://hooks-common.feathersjs.com/utilities.html#every
- */
-export function every(
- ...predicates: PredicateFn[]
-): AsyncPredicateFn {
- return async function (this: any, ...fnArgs: any[]) {
- // @ts-expect-error TODO
- const promises = predicates.map(fn => fn.apply(this, fnArgs));
-
- const results = await Promise.all(promises);
- return await Promise.resolve(results.every(result => !!result));
- };
-}
diff --git a/src/utils/get-result-is-array/get-result-is-array.test.ts b/src/utils/get-result-is-array/get-result-is-array.test.ts
index 41f890c0..01cf0c7d 100644
--- a/src/utils/get-result-is-array/get-result-is-array.test.ts
+++ b/src/utils/get-result-is-array/get-result-is-array.test.ts
@@ -56,4 +56,84 @@ describe('getResultIsArray', () => {
key: 'result',
});
});
+
+ it('dispatch', () => {
+ const result = { a: 1, b: 2 };
+ const dispatch = { c: 3, d: 4 };
+ expect(getResultIsArray({ result, dispatch } as any, { dispatch: true })).toEqual({
+ isArray: false,
+ result: [dispatch],
+ key: 'dispatch',
+ });
+
+ expect(
+ getResultIsArray({ method: 'find', result, dispatch } as any, { dispatch: true }),
+ ).toEqual({
+ isArray: false,
+ result: [dispatch],
+ key: 'dispatch',
+ });
+
+ expect(
+ getResultIsArray({ method: 'find', result: { data: result }, dispatch } as any, {
+ dispatch: true,
+ }),
+ ).toEqual({
+ isArray: false,
+ result: [dispatch],
+ key: 'dispatch',
+ });
+ });
+
+ it('returns dispatch if is missing with single result', () => {
+ const result = { a: 1, b: 2 };
+ const context = { result } as any;
+ expect(getResultIsArray(context, { dispatch: true })).toEqual({
+ isArray: false,
+ result: [result],
+ key: 'result',
+ });
+ expect(context.dispatch).toEqual(undefined);
+ });
+
+ it("doesn't set dispatch if is missing with array result", () => {
+ const result = [{ a: 1, b: 2 }];
+ const context = { method: 'create', result } as any;
+
+ expect(getResultIsArray(context, { dispatch: true })).toEqual({
+ isArray: true,
+ result: result,
+ key: 'result',
+ });
+ expect(context.dispatch).toEqual(undefined);
+ });
+
+ it("doesn't set dispatch if is missing with find array", () => {
+ const result = [{ a: 1, b: 2 }];
+ const dispatch = undefined;
+ const context = { method: 'find', result, dispatch } as any;
+
+ expect(getResultIsArray(context, { dispatch: true })).toEqual({
+ isArray: true,
+ result,
+ key: 'result',
+ });
+ });
+
+ it('sets dispatch if is missing with paginated result', () => {
+ const result = [{ a: 1, b: 2 }];
+ const dispatch = undefined;
+ const context = { method: 'find', result: { data: result, total: 3 }, dispatch } as any;
+
+ expect(
+ getResultIsArray(context, {
+ dispatch: true,
+ }),
+ ).toEqual({
+ isArray: true,
+ result,
+ key: 'result',
+ });
+ expect(context.dispatch).toEqual(undefined);
+ });
});
diff --git a/src/utils/get-result-is-array/get-result-is-array.ts b/src/utils/get-result-is-array/get-result-is-array.ts
index dc44570e..1c2b261d 100644
--- a/src/utils/get-result-is-array/get-result-is-array.ts
+++ b/src/utils/get-result-is-array/get-result-is-array.ts
@@ -1,16 +1,25 @@
import { HookContext } from '@feathersjs/feathers';
+import copy from 'fast-copy';
+
+type GetResultIsArrayOptions = {
+ dispatch?: boolean;
+};
export function getResultIsArray(
context: H,
- dispatch?: boolean,
+ options?: GetResultIsArrayOptions,
): { isArray: boolean; result: any[]; key: 'dispatch' | 'result' } {
- const result = dispatch ? context.dispatch : context.result;
+ const { dispatch = false } = options || {};
+
+ const isDispatch: boolean = dispatch && context.dispatch !== undefined;
+
+ const result = dispatch ? (isDispatch ? context.dispatch : copy(context.result)) : context.result;
if (!result) {
return {
isArray: false,
result: [],
- key: dispatch ? 'dispatch' : 'result',
+ key: isDispatch ? 'dispatch' : 'result',
};
}
@@ -21,6 +30,6 @@ export function getResultIsArray(
return {
isArray,
result: isArray ? items : items ? [items] : [],
- key: dispatch ? 'dispatch' : 'result',
+ key: isDispatch ? 'dispatch' : 'result',
};
}
diff --git a/src/utils/index.ts b/src/utils/index.ts
index 23fa7083..0008a25e 100644
--- a/src/utils/index.ts
+++ b/src/utils/index.ts
@@ -2,24 +2,20 @@ export * from './calling-params/calling-params';
export * from './check-context/check-context';
export * from './check-context-if';
export * from './combine/combine';
-export * from './every/every';
export * from './get-items/get-items';
export * from './get-data-is-array/get-data-is-array';
export * from './get-result-is-array/get-result-is-array';
-export * from './is-not/is-not';
-export * from './is-provider/is-provider';
export * from './params-for-server/params-for-server';
export * from './replace-items/replace-items';
export * from './replace-items/replace-data';
export * from './replace-items/replace-result';
-export * from './some/some';
export * from './run-hook/run-hook';
export * from './get-paginate/get-paginate';
-export * from './is-multi/is-multi';
-export * from './is-paginated/is-paginated';
+export * from '../predicates/is-multi/is-multi';
+export * from '../predicates/is-paginated/is-paginated';
export * from './skip-result/skip-result';
diff --git a/src/utils/params-for-server/params-for-server.ts b/src/utils/params-for-server/params-for-server.ts
index eeec4eb1..db86fdcb 100755
--- a/src/utils/params-for-server/params-for-server.ts
+++ b/src/utils/params-for-server/params-for-server.ts
@@ -4,6 +4,8 @@ import type { Params } from '@feathersjs/feathers';
* Pass an explicit context.params from client to server. Client-side. (Utility function.)
*
* @see https://hooks-common.feathersjs.com/utilities.html#paramsforserver
+ *
+ * @deprecated use the hook `paramsForServer2` instead
*/
export function paramsForServer(params?: Params, ...whitelist: string[]): Params {
const ifWhitelist = !!whitelist.length;
diff --git a/src/utils/replace-items/replace-data.ts b/src/utils/replace-items/replace-data.ts
index a6155de4..881164e2 100644
--- a/src/utils/replace-items/replace-data.ts
+++ b/src/utils/replace-items/replace-data.ts
@@ -1,7 +1,7 @@
import { HookContext } from '@feathersjs/feathers';
import { getDataIsArray } from '../get-data-is-array/get-data-is-array';
import { isPromise } from '../../common';
-import { Promisable } from '../../types';
+import { Promisable } from '../../internal.utils';
export function replaceData(
context: H,
diff --git a/src/utils/replace-items/replace-result.test.ts b/src/utils/replace-items/replace-result.test.ts
new file mode 100644
index 00000000..30fbf894
--- /dev/null
+++ b/src/utils/replace-items/replace-result.test.ts
@@ -0,0 +1,169 @@
+import { expect } from 'vitest';
+import { replaceResult } from './replace-result';
+
+// Tests when context.params._actOn === 'dispatch' are in act-on.test.ts
+describe('replaceResult', () => {
+ it("replaces context.result on paginated 'find'", async () => {
+ const context = {
+ method: 'find',
+ result: { total: 2, data: [{ id: 1 }, { id: 2 }] },
+ };
+
+ await replaceResult(context as any, item => ({ id: item.id + 1 }));
+
+ expect(context.result).toStrictEqual({ total: 2, data: [{ id: 2 }, { id: 3 }] });
+ });
+
+ it("replaces context.result on array 'find'", async () => {
+ const context = {
+ method: 'find',
+ result: [{ id: 1 }, { id: 2 }],
+ };
+
+ await replaceResult(context as any, item => ({ id: item.id + 1 }));
+
+ expect(context.result).toStrictEqual([{ id: 2 }, { id: 3 }]);
+ });
+
+ it("replaces context.result on 'get'", async () => {
+ const context = {
+ method: 'find',
+ id: 1,
+ result: { id: 1 },
+ };
+
+ await replaceResult(context as any, item => ({ id: item.id + 1 }));
+
+ expect(context.result).toStrictEqual({ id: 2 });
+ });
+
+ it("replaces context.result on 'create'", async () => {
+ const context = {
+ method: 'create',
+ result: { id: 1 },
+ };
+
+ await replaceResult(context as any, item => ({ id: item.id + 1 }));
+
+ expect(context.result).toStrictEqual({ id: 2 });
+ });
+
+ it("replaces context.result on multi:'create'", async () => {
+ const context = {
+ method: 'create',
+ result: [{ id: 1 }, { id: 2 }],
+ };
+
+ await replaceResult(context as any, item => ({ id: item.id + 1 }));
+
+ expect(context.result).toStrictEqual([{ id: 2 }, { id: 3 }]);
+ });
+
+ it('replaces context.result on update', async () => {
+ const context = {
+ method: 'update',
+ id: 1,
+ result: { id: 1 },
+ };
+
+ await replaceResult(context as any, item => ({ id: item.id + 1 }));
+
+ expect(context.result).toStrictEqual({ id: 2 });
+ });
+
+ it('replaces context.result on patch', async () => {
+ const context = {
+ method: 'patch',
+ id: 1,
+ result: { id: 1 },
+ };
+
+ await replaceResult(context as any, item => ({ id: item.id + 1 }));
+
+ expect(context.result).toStrictEqual({ id: 2 });
+ });
+
+ it('replaces context.result on multi patch', async () => {
+ const context = {
+ method: 'patch',
+ id: null,
+ result: [{ id: 1 }, { id: 2 }],
+ };
+
+ await replaceResult(context as any, item => ({ id: item.id + 1 }));
+
+ expect(context.result).toStrictEqual([{ id: 2 }, { id: 3 }]);
+ });
+
+ it('replaces context.result on remove', async () => {
+ const context = {
+ method: 'remove',
+ id: 1,
+ result: { id: 1 },
+ };
+
+ await replaceResult(context as any, item => ({ id: item.id + 1 }));
+
+ expect(context.result).toStrictEqual({ id: 2 });
+ });
+
+ it('replaces context.result on multi remove', async () => {
+ const context = {
+ method: 'remove',
+ id: null,
+ result: [{ id: 1 }, { id: 2 }],
+ };
+
+ await replaceResult(context as any, item => ({ id: item.id + 1 }));
+
+ expect(context.result).toStrictEqual([{ id: 2 }, { id: 3 }]);
+ });
+
+ it("replaces context.dispatch on 'get'", async () => {
+ const context = {
+ method: 'find',
+ id: 1,
+ result: { result: true },
+ dispatch: { dispatch: true },
+ };
+
+ await replaceResult(context as any, item => ({ ...item, test: true }), { dispatch: true });
+
+ expect(context.result).toStrictEqual({ result: true });
+ expect(context.dispatch).toStrictEqual({ dispatch: true, test: true });
+ });
+
+ it("replaces both context.result & context.dispatch on 'get'", async () => {
+ const context = {
+ method: 'find',
+ id: 1,
+ result: { result: true },
+ dispatch: { dispatch: true },
+ };
+
+ await replaceResult(context as any, item => ({ ...item, test: true }), { dispatch: 'both' });
+
+ expect(context.result).toStrictEqual({ result: true, test: true });
+ expect(context.dispatch).toStrictEqual({ dispatch: true, test: true });
+ });
+
+ it("replaces context.dispatch even though it was not there before on 'get'", async () => {
+ const context = {
+ method: 'find',
+ id: 1,
+ result: { result: true },
+ } as any;
+
+ await replaceResult(
+ context as any,
+ item => {
+ item.test = true;
+ return item;
+ },
+ { dispatch: true },
+ );
+
+ expect(context.result).toStrictEqual({ result: true });
+ expect(context.dispatch).toStrictEqual({ result: true, test: true });
+ });
+});
diff --git a/src/utils/replace-items/replace-result.ts b/src/utils/replace-items/replace-result.ts
index 43a8fa2c..2c4478e0 100644
--- a/src/utils/replace-items/replace-result.ts
+++ b/src/utils/replace-items/replace-result.ts
@@ -1,60 +1,74 @@
import { HookContext, NextFunction } from '@feathersjs/feathers';
import { getResultIsArray } from '../get-result-is-array/get-result-is-array';
import { isPromise } from '../../common';
+import copy from 'fast-copy';
+import { DispatchOption } from '../../types';
+
+export type ReplaceResultOptions = {
+ next?: NextFunction;
+ transform?: (items: any[]) => any[];
+ dispatch?: DispatchOption;
+};
export async function replaceResult(
context: H,
cb: (item: any) => any,
- options?: {
- next?: NextFunction;
- transform?: (items: any[]) => any[];
- },
+ options?: ReplaceResultOptions,
): Promise {
if (options?.next) {
await options.next();
}
- if (!context.result) {
- return context;
+ if (!!options?.dispatch && !context.dispatch) {
+ context.dispatch = copy(context.result);
}
- const { result, isArray, key } = getResultIsArray(context);
+ async function forResult(dispatch: boolean) {
+ const { result, isArray, key } = getResultIsArray(context, { dispatch });
- if (!result.length) {
- return context;
- }
+ if (!result.length) {
+ return context;
+ }
- let hasPromises = false;
+ let hasPromises = false;
- const results = result.map(item => {
- const result = cb(item);
+ const results = result.map(item => {
+ const result = cb(item);
- if (!hasPromises && isPromise(result)) {
- hasPromises = true;
- }
+ if (!hasPromises && isPromise(result)) {
+ hasPromises = true;
+ }
+
+ return result;
+ });
+
+ function replace(r: any) {
+ if (options?.transform) {
+ r = options.transform(r);
+ }
- return result;
- });
+ if (!isArray) {
+ context[key] = r[0];
+ } else if (isArray && !Array.isArray(context[key]) && context[key].data) {
+ context[key].data = r;
+ } else {
+ context[key] = r;
+ }
- function replace(r: any) {
- if (options?.transform) {
- r = options.transform(r);
+ return context;
}
- if (!isArray) {
- context[key] = r[0];
- } else if (isArray && !Array.isArray(context[key]) && context[key].data) {
- context[key].data = r;
+ if (hasPromises) {
+ return await Promise.all(results).then(replace);
} else {
- context[key] = r;
+ return replace(results);
}
+ }
+ if (options?.dispatch === 'both') {
+ await Promise.all([forResult(true), forResult(false)]);
return context;
}
- if (hasPromises) {
- return await Promise.all(results).then(replace);
- } else {
- return replace(results);
- }
+ return await forResult(options?.dispatch ?? false);
}
diff --git a/src/utils/skip-result/skip-result.ts b/src/utils/skip-result/skip-result.ts
index 7fee1476..afdc8565 100644
--- a/src/utils/skip-result/skip-result.ts
+++ b/src/utils/skip-result/skip-result.ts
@@ -1,6 +1,5 @@
import type { HookContext } from '@feathersjs/feathers';
-import { isMulti } from '../is-multi/is-multi';
-import { isPaginated } from '../is-paginated/is-paginated';
+import { isMulti, isPaginated } from '../../predicates';
/**
* util to set `context.result` to an empty array or object, depending on the hook type
diff --git a/src/utils/some/some.test.ts b/src/utils/some/some.test.ts
deleted file mode 100755
index 2abfeb80..00000000
--- a/src/utils/some/some.test.ts
+++ /dev/null
@@ -1,138 +0,0 @@
-import { assert } from 'vitest';
-import { feathers } from '@feathersjs/feathers';
-import { MemoryService } from '@feathersjs/memory';
-import { some } from './some';
-import { iff } from '../../hooks/iff/iff';
-import { isNot } from '../is-not/is-not';
-
-describe('util some', () => {
- let app: any;
-
- beforeEach(() => {
- app = feathers().use('/users', new MemoryService());
- });
-
- describe('when at least 1 hook is truthy', () => {
- beforeEach(() => {
- app.service('users').hooks({
- before: {
- all: [
- iff(
- some(
- (_hook: any) => false,
- (_hook: any) => Promise.resolve(false),
- (_hook: any) => Promise.resolve(true),
- (_hook: any) => true,
- // @ts-ignore
- (_hook: any) => 1,
- (_hook: any) => {},
- ),
- (hook: any) => Promise.resolve(hook),
- ),
- ],
- },
- });
- });
-
- it('returns true', () => {
- return app
- .service('users')
- .find()
- .then((result: any) => {
- assert.deepEqual(result, []);
- });
- });
- });
-
- describe('when a hook throws an error', () => {
- beforeEach(() => {
- app.service('users').hooks({
- before: {
- all: [
- iff(
- some(
- (_hook: any) => true,
- (_hook: any) => {
- throw new Error('Hook 2 errored');
- },
- (_hook: any) => true,
- ),
- (hook: any) => Promise.resolve(hook),
- ),
- ],
- },
- });
- });
-
- it('rejects with the error', () => {
- return app
- .service('users')
- .find()
- .catch((error: any) => {
- assert.equal(error.message, 'Hook 2 errored');
- });
- });
- });
-
- describe('when a hook rejects with an error', () => {
- beforeEach(() => {
- app.service('users').hooks({
- before: {
- all: [
- iff(
- some(
- (_hook: any) => true,
- (_hook: any) => Promise.reject(Error('Hook 2 errored')),
- (_hook: any) => true,
- ),
- (hook: any) => Promise.resolve(hook),
- ),
- ],
- },
- });
- });
-
- it('rejects with the error', () => {
- return app
- .service('users')
- .find()
- .catch((error: any) => {
- assert.equal(error.message, 'Hook 2 errored');
- });
- });
- });
-
- describe('when all hooks are falsey', () => {
- beforeEach(() => {
- app.service('users').hooks({
- before: {
- all: [
- iff(
- isNot(
- some(
- (_hook: any) => false,
- (_hook: any) => Promise.resolve(false),
- // @ts-ignore
- (_hook: any) => null,
- (_hook: any) => undefined,
- // @ts-ignore
- (_hook: any) => 0,
- ),
- ),
- () => Promise.reject(new Error('All hooks returned false')),
- ),
- ],
- },
- });
- });
-
- it('returns false', () => {
- return app
- .service('users')
- .find()
- .catch((error: any) => {
- assert.equal(error.message, 'All hooks returned false');
- });
- });
- });
-});
diff --git a/src/utils/some/some.ts b/src/utils/some/some.ts
deleted file mode 100755
index 2d4d3404..00000000
--- a/src/utils/some/some.ts
+++ /dev/null
@@ -1,17 +0,0 @@
-import type { HookContext } from '@feathersjs/feathers';
-import type { AsyncPredicateFn, PredicateFn } from '../../types';
-
-/**
- * Return the or of a series of sync or async predicate functions.
- * @see https://hooks-common.feathersjs.com/utilities.html#some
- */
-export function some(
- ...predicates: PredicateFn[]
-): AsyncPredicateFn {
- return async function (this: any, context: H) {
- const promises = predicates.map(fn => fn.apply(this, [context]));
-
- const results = await Promise.all(promises);
- return await Promise.resolve(results.some((result: any) => !!result));
- };
-}
diff --git a/src/utils/transform-params/transform-params.ts b/src/utils/transform-params/transform-params.ts
new file mode 100644
index 00000000..17d17ebe
--- /dev/null
+++ b/src/utils/transform-params/transform-params.ts
@@ -0,0 +1,18 @@
+import { Params } from '@feathersjs/feathers';
+import { TransformParamsFn } from '../../types';
+
+/**
+ * Safely use a transformParams function to modify params.
+ */
+export const transformParams = (
+ params: P,
+ fn: TransformParamsFn
| undefined,
+): P => {
+ if (!fn) {
+ return params;
+ }
+
+ const result = fn({ ...params });
+
+ return result ?? params;
+};
diff --git a/test/index.test.ts b/test/index.test.ts
index de9f42a6..67d80b94 100755
--- a/test/index.test.ts
+++ b/test/index.test.ts
@@ -72,6 +72,7 @@ const members = [
'replaceData',
'replaceResult',
+ 'checkRequired',
'required',
'runHook',
'runParallel',
@@ -96,13 +97,17 @@ const members = [
'iff',
'when',
'unless',
+
+ // predicates
'some',
'every',
'isNot',
-
- 'getPaginate',
+ 'not',
'isMulti',
'isPaginated',
+ 'isContext',
+
+ 'getPaginate',
'skipResult',
].sort();
From e6bb8c02d5ca1b22da936506dee17c2df9820d8c Mon Sep 17 00:00:00 2001
From: fratzinger <22286818+fratzinger@users.noreply.github.com>
Date: Tue, 18 Feb 2025 23:07:36 +0100
Subject: [PATCH 5/5] WIP
---
README.md | 15 +++++----------
src/predicates/not/not.ts | 1 -
src/utils/index.ts | 2 --
3 files changed, 5 insertions(+), 13 deletions(-)
diff --git a/README.md b/README.md
index b9035ba5..07226b81 100755
--- a/README.md
+++ b/README.md
@@ -23,6 +23,10 @@
- added 'onDelete' & 'createRelated'
+- stashBefore multi
+
+- softDelete: added 'transformParams' & added 'key' option
+
- rm support for spread argument
#### predicates
@@ -37,16 +41,7 @@
- added getDataIsArray, getResultIsArray, deprecated getItems
- added replaceData, replaceResult, deprecated replaceItems
- added util getPaginate
-- added util setResultEmpty
-
-- add onDelete
-
-- stashBefore multi
-
-- new: createRelated
-- new: onDelete
-
-- softDelete: added 'transformParams' & added 'key' option
+- added util skipResult
### Hooks to discuss
diff --git a/src/predicates/not/not.ts b/src/predicates/not/not.ts
index 14709db2..6de6a03f 100755
--- a/src/predicates/not/not.ts
+++ b/src/predicates/not/not.ts
@@ -1,4 +1,3 @@
-import { MethodNotAllowed } from '@feathersjs/errors';
import type { HookContext } from '@feathersjs/feathers';
import { isPromise } from '../../common';
import type { PredicateFn } from '../../types';
diff --git a/src/utils/index.ts b/src/utils/index.ts
index 0008a25e..7d39e7f6 100644
--- a/src/utils/index.ts
+++ b/src/utils/index.ts
@@ -16,6 +16,4 @@ export * from './replace-items/replace-result';
export * from './run-hook/run-hook';
export * from './get-paginate/get-paginate';
-export * from '../predicates/is-multi/is-multi';
-export * from '../predicates/is-paginated/is-paginated';
export * from './skip-result/skip-result';
