6ba293c0f8
## Description
Adds option to override default database operations for a collection
```ts
import { CollectionConfig } from 'payload/types';
export const Collection: CollectionConfig = {
slug: 'example-collection',
// Database operations for this collection
db: {
create: () => {},
deleteMany: () => {},
deleteOne: () => {},
find: () => {},
findOne: () => {},
updateOne: () => {}
},
fields: [
{
name: 'someField',
type: 'text',
},
],
}
```
Co-authored-by: Dan Ribbens <dan.ribbens@gmail.com>
111 lines
2.7 KiB
TypeScript
111 lines
2.7 KiB
TypeScript
import payload from '../../packages/payload/src'
|
|
import { devUser } from '../credentials'
|
|
import { initPayloadTest } from '../helpers/configHelpers'
|
|
import { collectionSlug } from './config'
|
|
import { doc } from './config'
|
|
|
|
require('isomorphic-fetch')
|
|
|
|
let apiUrl
|
|
let jwt
|
|
|
|
const headers = {
|
|
'Content-Type': 'application/json',
|
|
}
|
|
const { email, password } = devUser
|
|
|
|
describe('Collection Database Operations', () => {
|
|
// --__--__--__--__--__--__--__--__--__
|
|
// Boilerplate test setup/teardown
|
|
// --__--__--__--__--__--__--__--__--__
|
|
beforeAll(async () => {
|
|
const { serverURL } = await initPayloadTest({ __dirname, init: { local: false } })
|
|
apiUrl = `${serverURL}/api`
|
|
|
|
const response = await fetch(`${apiUrl}/users/login`, {
|
|
body: JSON.stringify({
|
|
email,
|
|
password,
|
|
}),
|
|
headers,
|
|
method: 'POST',
|
|
})
|
|
|
|
const data = await response.json()
|
|
jwt = data.token
|
|
})
|
|
|
|
afterAll(async () => {
|
|
if (typeof payload.db.destroy === 'function') {
|
|
await payload.db.destroy(payload)
|
|
}
|
|
})
|
|
|
|
// --__--__--__--__--__--__--__--__--__
|
|
// Local API
|
|
// --__--__--__--__--__--__--__--__--__
|
|
|
|
it('collection DB Create', async () => {
|
|
const result = await payload.create({
|
|
collection: collectionSlug,
|
|
data: {
|
|
id: doc.id,
|
|
},
|
|
})
|
|
|
|
expect(result.id).toEqual(doc.id)
|
|
expect(result.customData).toEqual(doc.customData)
|
|
})
|
|
|
|
it('collection DB Update', async () => {
|
|
const where = { id: { equals: doc.id } }
|
|
const result = await payload.update({
|
|
collection: collectionSlug,
|
|
where,
|
|
data: {
|
|
id: doc.id,
|
|
},
|
|
})
|
|
|
|
expect(result.docs[0].id).toEqual(doc.id)
|
|
expect(result.docs[0].customData).toEqual(doc.customData)
|
|
expect(result.docs[0].updated).toEqual(true)
|
|
})
|
|
|
|
it('collection DB Find', async () => {
|
|
const where = { id: { equals: doc.id } }
|
|
const result = await payload.find({
|
|
collection: collectionSlug,
|
|
where,
|
|
})
|
|
|
|
expect(result.docs[0].id).toEqual(doc.id)
|
|
expect(result.docs[0].customData).toEqual(doc.customData)
|
|
})
|
|
|
|
it('collection DB Find One', async () => {
|
|
const result = await payload.findByID({
|
|
collection: collectionSlug,
|
|
id: doc.id,
|
|
})
|
|
|
|
expect(result.id).toEqual(doc.id)
|
|
expect(result.customData).toEqual(doc.customData)
|
|
})
|
|
|
|
it('collection DB Delete', async () => {
|
|
const where = { id: { equals: doc.id } }
|
|
|
|
const result = await payload.delete({
|
|
collection: collectionSlug,
|
|
depth: 0,
|
|
user: devUser,
|
|
where,
|
|
})
|
|
|
|
expect(result.docs[0].id).toEqual(doc.id)
|
|
expect(result.docs[0].customData).toEqual(doc.customData)
|
|
expect(result.errors).toHaveLength(0)
|
|
})
|
|
})
|