getEmbeddings: protectedProcedure.query(async ({ ctx }) => {
        const embeddings = await ctx.prisma.$queryRawUnsafe(
            `SELECT embedding::text FROM "User" where id = ${ctx.session.user.id}`
        );
        return embeddings;
    }),

 getEmbeddings: protectedProcedure.query(async ({ ctx }) => {
        const embeddings = await ctx.prisma.$queryRawUnsafe(
            `SELECT embedding::text FROM "User" where id = ${ctx.session.user.id}`
        );
        return embeddings;
    }),

...other routers
 deleteUser: protectedProcedure.mutation(async ({ ctx }) => {
        await ctx.prisma.image.deleteMany({
            where: { userId: ctx.session.user.id },
        });
        const deletedUser = await ctx.prisma.user.delete({
            where: { id: ctx.session.user.id },
        });
        return deletedUser;
    }),

    getEmbeddings: protectedProcedure.query(async ({ ctx }) => {
        await ctx.prisma.user <-- No getUserEmbedding?
    }),

...other routers
 deleteUser: protectedProcedure.mutation(async ({ ctx }) => {
        await ctx.prisma.image.deleteMany({
            where: { userId: ctx.session.user.id },
        });
        const deletedUser = await ctx.prisma.user.delete({
            where: { id: ctx.session.user.id },
        });
        return deletedUser;
    }),

    getEmbeddings: protectedProcedure.query(async ({ ctx }) => {
        await ctx.prisma.user <-- No getUserEmbedding?
    }),

import { PrismaClient, Prisma } from "@prisma/client";
import { env } from "~/env.mjs";

const prismaClientSingleton = () => {
    return new PrismaClient();
};

type Embedding = number[];

declare global {
    var prisma: undefined | ReturnType<typeof prismaClientSingleton>;
}

export const prisma = globalThis.prisma ?? prismaClientSingleton();

const getUserEmbedding = async (userId: number): Promise<Embedding> => {
    const embedding: Embedding = await prisma.$queryRaw`
        SELECT embedding
        FROM "User"
        WHERE id = ${userId}
    `;
    return embedding;
};

prisma.$extends({
    model: {
        user: {
            async getEmbedding(userId: number) {
                return getUserEmbedding(userId);
            },
        },
    },
});
if (process.env.NODE_ENV !== "production") globalThis.prisma = prisma;

export default prisma;

import { PrismaClient, Prisma } from "@prisma/client";
import { env } from "~/env.mjs";

const prismaClientSingleton = () => {
    return new PrismaClient();
};

type Embedding = number[];

declare global {
    var prisma: undefined | ReturnType<typeof prismaClientSingleton>;
}

export const prisma = globalThis.prisma ?? prismaClientSingleton();

const getUserEmbedding = async (userId: number): Promise<Embedding> => {
    const embedding: Embedding = await prisma.$queryRaw`
        SELECT embedding
        FROM "User"
        WHERE id = ${userId}
    `;
    return embedding;
};

prisma.$extends({
    model: {
        user: {
            async getEmbedding(userId: number) {
                return getUserEmbedding(userId);
            },
        },
    },
});
if (process.env.NODE_ENV !== "production") globalThis.prisma = prisma;

export default prisma;