getStateDataAdapter.ts

import { BaseContext } from "rs-core/ServiceContext.ts";
import { adapterConfigFromInfra, assertInfraAvailableForTenant, config } from "./config.ts";
import { IDataAdapter } from "rs-core/adapter/IDataAdapter.ts";
import { IFileAdapter } from "rs-core/adapter/IFileAdapter.ts";
import { fileToDataAdapter } from "./adapter/fileToDataAdapter.ts";

export const getStateDataAdapter = async (context: BaseContext) => {
    if (!config.server.stateStore || !config.server.infra[config.server.stateStore]) {
        return undefined;
    }
    const stateStoreInfra = config.server.infra[config.server.stateStore];
    assertInfraAvailableForTenant(config.server.stateStore, stateStoreInfra, context.tenant);
    const stateStoreAdapterSpec = adapterConfigFromInfra(stateStoreInfra) as Record<string, unknown> & { basePath: string };
    stateStoreAdapterSpec.basePath = "/_state";
    let stateAdapter = await config.modules.getAdapter<IDataAdapter | IFileAdapter>(stateStoreInfra.adapterSource, context, stateStoreAdapterSpec);
    if ((stateAdapter as IFileAdapter).read) {
        // in this case, build a dataadapter from the fileadapter
        const fileAdapter = stateAdapter as IFileAdapter;
        const fileAdapterConstructor = fileAdapter.constructor as new (...args: any[]) => IFileAdapter;
        const stateAdapterConstructor = fileToDataAdapter(fileAdapterConstructor);
        stateAdapter = new stateAdapterConstructor(context, stateStoreAdapterSpec);
    }
    return stateAdapter as IDataAdapter;
}