@galaxar/feat-db

Datasource features set

Features

• prisma

Prisma

Config

{
    "prisma": { modelPath, ttlCacheService, datasources, log }
}

Usage

const prisma = app.getService('prisma');

Prisma helpers

• $pushQuery - Returns a new where with specified condition merged into where, will merge same keys into an AND array

• $pushOrQuery - Returns a new where with specified condition merged into where, will merge same keys into an OR array

• $model - Returns a business logic model from modelPath

//<modulePath>\User.js
class User {
    constructor(prisma) {
        this.model = prisma.user;
    }

    async upsert_(input) {
        const { email, ...others } = input;

        return this.model.upsert({
            where: { email },
            create: input,
            update: others,
        });
    }
}

export default User;

Usage

const prisma = app.getService('prisma');
const User = prisma.$model('user');

await User.upsert_({
    email: '[email protected]',
    name: 'test999',                
});

• $setupCache(this, entries) - Setup cache (list or map)
  • $setupCache should be called in the Model's constructor after model is assigned
  • entries is a map of cache key to { where, type, [mapByKey] }
  • Model with $setupCache has the following two methods:
    • async cache_(key) - fetch data from cache by key, run query if cache missed
    • resetCache(key)

//<modulePath>\User.js
class User {
    constructor(prisma) {
        this.model = prisma.user;
        prisma.$setupCache(this, {
            'list': { where: {}, type: 'list' },
            'map': { where: {}, type: 'map', mapByKey: 'email' },
        });
    }
}

export default User;

Usage

const prisma = app.getService('prisma');
const User = prisma.$model('UserWithCache');

const map = await User.cache_('map');
const list = await User.cache_('list');

Model helpers

• retryCreate_(createOptions /* the same as prisma */, dataFactory /* if duplicate, the factory will be call to generate new creation data */)

const nanoid = app.getService('nanoid');

const session = await LoginSession.retryCreate_(
    {
        data: {
            id: nanoid.next(),
            userId: user.id,
            expiresAt: new Date(expiresAt),
            lastHeartbeat: nowDate,
        },
    },
    (input) => ({
        ...input,
        data: {
            ...input.data,
            id: nanoid.next(),
        },
    })
);