Function fromPrisma

packages/core/fumadb/src/adapters/prisma/query.ts:136–348

(
  schema: AnySchema,
  config: PrismaConfig & {
    isTransaction?: boolean;
  },
)

}

export function fromPrisma(
  schema: AnySchema,
  config: PrismaConfig & {
    isTransaction?: boolean;
  },
): AbstractQuery<AnySchema> {
  const {
    provider,
    prisma,
    relationMode = provider === "mongodb" ? "prisma" : "foreign-keys",
    db: internalClient,
    isTransaction = false,
  } = config;

  // replace index with partial index to ignore null values
  // see https://github.com/prisma/prisma/issues/3387
  async function initMongoDB() {
    if (!internalClient || isTransaction) return;
    const db = internalClient.db();

    async function initCollection(table: AnyTable) {
      const collection = db.collection(table.names.mongodb);
      const indexes = await collection.indexes();

      for (const index of indexes) {
        if (!index.unique || !index.name || index.sparse) continue;

        await collection.dropIndex(index.name);
        await collection.createIndex(index.key, {
          name: index.name,
          unique: true,
          sparse: true,
        });
      }
    }

    await Promise.all(Object.values(schema.tables).map(initCollection));
  }

  let mapped: Map<string, string> | undefined;

  function getPrismaModel(table: AnyTable) {
    if (!mapped) {
      mapped = new Map();
      for (const key in prisma) {
        mapped.set(key.toLowerCase(), key);
      }
    }

    const modelName = mapped.get(table.names.prisma.toLowerCase());

    if (!modelName) {
      throw new Error(
        `Prisma client is missing model delegate "${table.names.prisma}" for table "${table.ormName}".`,
      );
    }

    return prisma[modelName]!;