32ee9f3dcc
* feat: add object base64 hash method * chore: add script to add package * feat: add request-handler package * wip: add request handlers for all jobs and widget api procedures * wip: remove errors shown in logs, add missing decryption for secrets in cached-request-job-handler * wip: highly improve request handler, add request handlers for calendar, media-server, indexer-manager and more, add support for multiple inputs from job handler creator * refactor: move media-server requests to request-handler, add invalidation logic for dns-hole and media requests * refactor: remove unused integration item middleware * feat: add invalidation to switch entity action of smart-home * fix: lint issues * chore: use integration-kind-by-category instead of union for request-handlers * fix: build not working for tasks and websocket * refactor: add more logs * refactor: readd timestamp logic for diconnect status * fix: lint and typecheck issue * chore: address pull request feedback
43 lines
1.6 KiB
TypeScript
43 lines
1.6 KiB
TypeScript
import type { Duration } from "dayjs/plugin/duration";
|
|
|
|
import type { Modify } from "@homarr/common/types";
|
|
import type { Integration, IntegrationSecret } from "@homarr/db/schema/sqlite";
|
|
import type { IntegrationKind } from "@homarr/definitions";
|
|
import { createIntegrationOptionsChannel } from "@homarr/redis";
|
|
|
|
import { createCachedRequestHandler } from "./cached-request-handler";
|
|
|
|
type IntegrationOfKind<TKind extends IntegrationKind> = Omit<Integration, "kind"> & {
|
|
kind: TKind;
|
|
decryptedSecrets: Modify<Pick<IntegrationSecret, "kind" | "value">, { value: string }>[];
|
|
};
|
|
|
|
interface Options<TData, TKind extends IntegrationKind, TInput extends Record<string, unknown>> {
|
|
// Unique key for this request handler
|
|
queryKey: string;
|
|
requestAsync: (integration: IntegrationOfKind<TKind>, input: TInput) => Promise<TData>;
|
|
cacheDuration: Duration;
|
|
}
|
|
|
|
export const createCachedIntegrationRequestHandler = <
|
|
TData,
|
|
TKind extends IntegrationKind,
|
|
TInput extends Record<string, unknown>,
|
|
>(
|
|
options: Options<TData, TKind, TInput>,
|
|
) => {
|
|
return {
|
|
handler: (integration: IntegrationOfKind<TKind>, itemOptions: TInput) =>
|
|
createCachedRequestHandler({
|
|
queryKey: options.queryKey,
|
|
requestAsync: async (input: { options: TInput; integration: IntegrationOfKind<TKind> }) => {
|
|
return await options.requestAsync(input.integration, input.options);
|
|
},
|
|
cacheDuration: options.cacheDuration,
|
|
createRedisChannel(input, options) {
|
|
return createIntegrationOptionsChannel<TData>(input.integration.id, options.queryKey, input.options);
|
|
},
|
|
}).handler({ options: itemOptions, integration }),
|
|
};
|
|
};
|