class StorageRouter
@route: (query, callback) ->
query.graph.debug('StorageRouter> CRUD:', {
action: query.action,
schema: query.current_router.configuration,
data: query.data,
search: query.search_query
})
db = query.graph.storage_manager.database
query.schema = query.current_router.configuration
query.data = JSON.parse(query.data) if query.data and (typeof query.data is 'string')
if query.action in ['create', 'read', 'update', 'delete']
db[query.action](query, (result) ->
query.data = result
callback(query))
else
callback(null)
module.exports = StorageRouter