How to use the decentraland-server.Model.db function in decentraland-server
To help you get started, we’ve selected a few decentraland-server examples, based on popular ways it is used in public projects.
Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
decentraland / agora / specs / utils.ts View on Github 
export function mockModelDbOperations(operations: { [key: string]: Function }) {
const log = new Log('Query')
const toJSON = obj => JSON.stringify(obj) // Formatting aid
const _query = Model.db.query
const _count = Model.db.count
operations = {
query: async function(query, args) {
const rows = await _query.call(this, query, args)
log.info(`Executing:\n${query} ${toJSON(args)} => ${rows.length} rows`)
return rows
},
count: async function(tableName, conditions) {
const count = await _count.call(this, tableName, conditions)
log.info(
`Counting: ${toJSON(conditions)} on ${tableName} => ${toJSON(count)}`
)
return count
},
insert: (tableName, row) => {export function mockModelDbOperations(operations: { [key: string]: Function }) {
const log = new Log('Query')
const toJSON = obj => JSON.stringify(obj) // Formatting aid
const _query = Model.db.query
const _count = Model.db.count
operations = {
query: async function(query, args) {
const rows = await _query.call(this, query, args)
log.info(`Executing:\n${query} ${toJSON(args)} => ${rows.length} rows`)
return rows
},
count: async function(tableName, conditions) {
const count = await _count.call(this, tableName, conditions)
log.info(
`Counting: ${toJSON(conditions)} on ${tableName} => ${toJSON(count)}`
)
return count
},
insert: (tableName, row) => {
log.info(`Inserting: ${toJSON(row)} on ${tableName}`)insert: (tableName, row) => {
log.info(`Inserting: ${toJSON(row)} on ${tableName}`)
return { rows: [{}] }
},
update: (tableName, changes, conditions) =>
log.info(
`Updating: ${toJSON(conditions)} with ${toJSON(
changes
)} on ${tableName}`
),
delete: (tableName, conditions) =>
log.info(`Deleting: ${toJSON(conditions)} on ${tableName}`),
...operations
}
Model.db.query = function(...args) {
return operations.query.call(this, ...args)
}
Model.db.count = function(...args) {
return operations.count.call(this, ...args)
}
Model.db.insert = function(...args) {
return operations.insert.call(this, ...args)
}
Model.db.update = function(...args) {
return operations.update.call(this, ...args)
}
Model.db.delete = function(...args) {
return operations.delete.call(this, ...args)
}
}),
delete: (tableName, conditions) =>
log.info(`Deleting: ${toJSON(conditions)} on ${tableName}`),
...operations
}
Model.db.query = function(...args) {
return operations.query.call(this, ...args)
}
Model.db.count = function(...args) {
return operations.count.call(this, ...args)
}
Model.db.insert = function(...args) {
return operations.insert.call(this, ...args)
}
Model.db.update = function(...args) {
return operations.update.call(this, ...args)
}
Model.db.delete = function(...args) {
return operations.delete.call(this, ...args)
}
}},
update: (tableName, changes, conditions) =>
log.info(
`Updating: ${toJSON(conditions)} with ${toJSON(
changes
)} on ${tableName}`
),
delete: (tableName, conditions) =>
log.info(`Deleting: ${toJSON(conditions)} on ${tableName}`),
...operations
}
Model.db.query = function(...args) {
return operations.query.call(this, ...args)
}
Model.db.count = function(...args) {
return operations.count.call(this, ...args)
}
Model.db.insert = function(...args) {
return operations.insert.call(this, ...args)
}
Model.db.update = function(...args) {
return operations.update.call(this, ...args)
}
Model.db.delete = function(...args) {
return operations.delete.call(this, ...args)
}
}...operations
}
Model.db.query = function(...args) {
return operations.query.call(this, ...args)
}
Model.db.count = function(...args) {
return operations.count.call(this, ...args)
}
Model.db.insert = function(...args) {
return operations.insert.call(this, ...args)
}
Model.db.update = function(...args) {
return operations.update.call(this, ...args)
}
Model.db.delete = function(...args) {
return operations.delete.call(this, ...args)
}
}`Updating: ${toJSON(conditions)} with ${toJSON(
changes
)} on ${tableName}`
),
delete: (tableName, conditions) =>
log.info(`Deleting: ${toJSON(conditions)} on ${tableName}`),
...operations
}
Model.db.query = function(...args) {
return operations.query.call(this, ...args)
}
Model.db.count = function(...args) {
return operations.count.call(this, ...args)
}
Model.db.insert = function(...args) {
return operations.insert.call(this, ...args)
}
Model.db.update = function(...args) {
return operations.update.call(this, ...args)
}
Model.db.delete = function(...args) {
return operations.delete.call(this, ...args)
}
}decentraland-server
Set of common functionality across Decentraland projects servers.
