mirror of https://github.com/seald/nedb
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
108 lines
3.8 KiB
108 lines
3.8 KiB
/* eslint-env jest */
|
|
// Forked from https://github.com/antoniopresto/react-native-local-mongodb/blob/93acbc8a9aaca86aed1d632855cd8b984501147b/test/persistence.test.js
|
|
const { promisify } = require('util')
|
|
const AsyncStorage = require('@react-native-async-storage/async-storage')
|
|
const DataStore = require('../../')
|
|
|
|
const getDb = async () => {
|
|
await AsyncStorage.clear()
|
|
const db = new DataStore({ filename: 'foo' })
|
|
await promisify(db.loadDatabase.bind(db))()
|
|
return db
|
|
}
|
|
it('update', async () => {
|
|
const db = await getDb()
|
|
const items0 = await promisify(db.find.bind(db))({})
|
|
expect(AsyncStorage.getItem).toHaveBeenCalled()
|
|
|
|
await promisify(db.insert.bind(db))({ name: 'Maggie' })
|
|
await promisify(db.insert.bind(db))({ name: 'Bob' })
|
|
expect(AsyncStorage.setItem).toHaveBeenCalled()
|
|
|
|
const items = await promisify(db.find.bind(db))({})
|
|
|
|
const maggie1 = await promisify(db.findOne.bind(db))({ name: 'Maggie' })
|
|
const bob1 = await promisify(db.findOne.bind(db))({ name: 'Bob' })
|
|
|
|
const res = await promisify(db.update.bind(db))({ name: { $in: ['Maggie', 'Bob'] } }, { $set: { age: 1 } }, { multi: true })
|
|
const maggie2 = await promisify(db.findOne.bind(db))({ name: 'Maggie' })
|
|
const bob2 = await promisify(db.findOne.bind(db))({ name: 'Bob' })
|
|
|
|
expect(res).toEqual(2)
|
|
expect(items0).toHaveLength(0)
|
|
expect(items).toHaveLength(2)
|
|
expect(maggie1.age).toBeUndefined()
|
|
expect(bob1.age).toBeUndefined()
|
|
expect(bob2.age).toEqual(1)
|
|
expect(maggie2.age).toEqual(1)
|
|
})
|
|
|
|
it('remove', async () => {
|
|
const db = await getDb()
|
|
const items0 = await promisify(db.find.bind(db))({})
|
|
expect(AsyncStorage.getItem).toHaveBeenCalled()
|
|
|
|
await promisify(db.insert.bind(db))({ name: 'Maggie' })
|
|
await promisify(db.insert.bind(db))({ name: 'Bob' })
|
|
expect(AsyncStorage.setItem).toHaveBeenCalled()
|
|
|
|
const items = await promisify(db.find.bind(db))({})
|
|
|
|
const res = await promisify(db.remove.bind(db))({ name: { $in: ['Bob'] } }, { multi: true })
|
|
const bob2 = await promisify(db.findOne.bind(db))({ name: 'Bob' })
|
|
|
|
expect(res).toEqual(1)
|
|
expect(items0).toHaveLength(0)
|
|
expect(items).toHaveLength(2)
|
|
expect(bob2).toBeNull()
|
|
})
|
|
|
|
it('resolve remove nonexistent', async () => {
|
|
const db = await getDb()
|
|
const items0 = await promisify(db.find.bind(db))({})
|
|
expect(AsyncStorage.getItem).toHaveBeenCalled()
|
|
|
|
await promisify(db.insert.bind(db))({ name: 'Maggie' })
|
|
await promisify(db.insert.bind(db))({ name: 'Bob' })
|
|
expect(AsyncStorage.setItem).toHaveBeenCalled()
|
|
|
|
const items = await promisify(db.find.bind(db))({})
|
|
|
|
const res = await promisify(db.remove.bind(db))({ name: 'nonexistent' }, { multi: true })
|
|
const nonexistent = await promisify(db.findOne.bind(db))({ name: 'nonexistent' })
|
|
|
|
expect(res).toEqual(0)
|
|
expect(items0).toHaveLength(0)
|
|
expect(items).toHaveLength(2)
|
|
expect(nonexistent).toBeNull()
|
|
})
|
|
|
|
it('resolve findOne nonexistent', async () => {
|
|
const db = await getDb()
|
|
|
|
await promisify(db.insert.bind(db))({ name: 'Maggie' })
|
|
await promisify(db.insert.bind(db))({ name: 'Bob' })
|
|
expect(AsyncStorage.setItem).toHaveBeenCalled()
|
|
|
|
const items = await promisify(db.find.bind(db))({ name: 'nonexistent' })
|
|
|
|
const item = await promisify(db.findOne.bind(db))({ name: 'nonexistent' })
|
|
|
|
expect(item).toBeNull()
|
|
expect(items.length).toEqual(0)
|
|
})
|
|
|
|
it('should limit', async () => {
|
|
const db = await getDb()
|
|
await promisify(db.insert.bind(db))({ name: 'A' })
|
|
await promisify(db.insert.bind(db))({ name: 'B' })
|
|
await promisify(db.insert.bind(db))({ name: 'C' })
|
|
await promisify(db.insert.bind(db))({ name: 'D' })
|
|
expect(AsyncStorage.setItem).toHaveBeenCalled()
|
|
|
|
const cursor = db.find({}).sort({ name: 1 }).skip(1).limit(2)
|
|
|
|
const docs = await promisify(cursor.exec.bind(cursor))()
|
|
expect(docs.length).toEqual(2)
|
|
expect(docs[1].name).toEqual('C')
|
|
})
|
|
|