NuKVM/xen-orchestra
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(CollectionRedis): do not fail when entry does not exist (#590)

Browse Source
This commit is contained in:
Julien Fontanet 2017-07-31 14:35:31 +02:00 committed by GitHub
parent 2a6c476189
commit 76357fb918
1 changed files with 16 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
src/collection/redis.js
View File

@ -95,24 +95,23 @@ export default class Redis extends Collection {
}
const { id } = model
const success = await redis.sadd(prefix + '_ids', id)
const newEntry = await redis.sadd(prefix + '_ids', id)
// The entry already exists an we are not in replace mode.
if (!success && !replace) {
throw new ModelAlreadyExists(id)
}
if (!newEntry) {
if (!replace) {
throw new ModelAlreadyExists(id)
}
// TODO: Remove existing fields.
// remove the previous values from indexes
if (replace && indexes.length !== 0) {
const previous = await redis.hgetall(`${prefix}:${id}`)
await asyncMap(indexes, index => {
const value = previous[index]
if (value !== undefined) {
return redis.srem(`${prefix}_${index}:${value}`, id)
}
})
// remove the previous values from indexes
if (indexes.length !== 0) {
const previous = await redis.hgetall(`${prefix}:${id}`)
await asyncMap(indexes, index => {
const value = previous[index]
if (value !== undefined) {
return redis.srem(`${prefix}_${index}:${value}`, id)
}
})
}
}
const params = []
@ -192,7 +191,7 @@ export default class Redis extends Collection {
if (indexes.length !== 0) {
promise = Promise.all([ promise, asyncMap(ids, id =>
redis.hgetall(`${prefix}:${id}`).then(values =>
asyncMap(indexes, index => {
values != null && asyncMap(indexes, index => {
const value = values[index]
if (value !== undefined) {
return redis.srem(`${prefix}_${index}:${value}`, id)