proxifying-mongo
v1.0.2
Published
server to be used as proxy to mongodb
Downloads
22
Readme
proxifying-mongo
mongo proxy to wrap mongoDB
Config
|Variable|Mean|Default| |---|---|---| |NUM_DOC_BY_PAGE|doc's number to return in a query|100| |PORT|port where start the server|8080|
API
Expond a object with :
{
ProxyError -> Object,
startServer([dbUrl, port, getters, options]) -> Promise,
getServer([dbUrl, getters, options]) -> Promise,
getMiddleware([dbUrl, getters, options]) -> Promise
}
Because of async behavior of DB connections every function return a promise. In another hand dbUlrl default value is 'mongodb://localhost:27017/test' port default value is '8080'.
Options object is:
{
baseUrl: '/path/where/mount/the/api'
}
default value to baseUrl is '/'.
With this options, then the request url is
localhost:8080/path/where/mount/the/api/collectionName[/ID?query]
if ID is given the query is replaced with {_id:ID}, how you can guess, the collectionName is required. The data to POST and PUT must travel in body request field.
Response
{
error, // if is present other fields will be missing
records, // array of items altered
next // path to next request to do pagination
}
Errors
Promise rejected will be considered as API errors. The object returned by a promise rejected need to be:
{
message: string() // error property returned in response,
code: number() // http code to return in response, default 500
}
Class ProxyError(httpCode, message)
Extends of Error class.
Getters
For getMiddleware:
{
getDatabase(dbUrl)-> DataBaseConnection,
getUserModel(DataBaseConnection) -> userModel,
getSchemaModel(DataBaseConnection) -> schemaModel,
getCollection(DataBaseConnection) -> collectionModel,
getCredentialsFromReq(req) -> Promise.resolve({pass, name})
}
For getServer:
{
getDatabase(dbUrl)-> DataBaseConnection,
getUserModel(DataBaseConnection) -> userModel,
getSchemaModel(DataBaseConnection) -> schemaModel,
getCollection(DataBaseConnection) -> collectionModel,
getCredentialsFromReq(req) -> Promise.resolve({pass, name}),
getMiddleware(dbUrl, getters) -> middleware(req, res)
}
For startServer:
{
getServer(dbUrl, getters) -> ServerInstance,
getDatabase(dbUrl)-> DataBaseConnection,
getUserModel(DataBaseConnection) -> userModel,
getSchemaModel(DataBaseConnection) -> schemaModel,
getCollection(DataBaseConnection) -> collectionModel,
getCredentialsFromReq(req) -> Promise.resolve({pass, name}),
getMiddleware(dbUrl, getters) -> middleware(req, res)
}
userModel
{
FindOne(query)-> Promise.resolve(resultQuery)
}
schemaModel
{
FindOne(query)-> Promise.resolve(resultQuery)
}
collectionModel
{
find(query)-> Promise.resolve(resultQuery),
create(data)-> Promise.resolve(dataCreated),
delete(query)-> Promise.resolve(docRemoved),
update(query, dataToUpdate)-> Promise.resolve(docUpdated),
count(query) -> Promise.resolve(NumberOfDocMatchingQuery)
}
Users Collection
Default proxifying-mongo try to get info of user from __users collection. The proxifying-mongo looking for name and pass fields, the pass must be base64 coded. In this doc the [collectionName] field is a json with:
{
name:'userName',
pass:'base64codingPass',
someCollectionName:{
someField:{
__$remove:false,
__$get:false,
__$create:true,
__$update:false,
},
otherField:'__$all',
...otherfields
_id:{
__$remove:false,
__$get:false,
}
},
otherCollectionName:{
fieldOne:'__$all',
fieldTwo:'__$all',
...otherfields
_id:{
__$remove:false,
__$get:false,
}
},
actions: {
PUT:false,
GET: true,
DELETE: false,
POST:false
}
}
actions could be '__$all' on that case all actions to this user are allowed.
Schema Model
Default proxifying-mongo try to get the schema to collectionName given from __schemas collection, the schema must a json schema like joison module, the json object returned by findOne method in schemaModel is passed to joison and the joi schema returned by joison is used to validate the data.
{
__schema: joisonSchema,
__collection:'collectionName'
}
Example of doc in __schemas collection
{
__schema: {
__$type:'object',
__$properties:{
someField:{
__$type:'object',
__$properties:{
nested:{
__$type:'string'
}
}
},
otherField:{
__$type:'string'
}
},
__$required:[]
},
__collection:'collectionName'
}
actions could be '__$all' on that case all actions to this user are allowed.
Client
If you install globally you get a monprox command with next options:
Options:
--version Show version number [boolean]
--gd, --get-db Path to get-database [string]
--gum, --get-user-model Path to get-user-model [string]
--gsm, --get-schema-model Path to get-schema-model
--gc, --get-collection Path to get-collection-model-thunk [string]
--help Show help [boolean]
-h, --host Host'url with basic auth to use
[string] [default: "mongodb://localhost:27017/test"]
-s, --start Start the server [boolean]
-p, --port Host'port [string] [default: "8080"]
Here the difference is that get-collection file must export a thunk what receive the database instance returned by get-database module and must return a function what is called with collectionName and return the collection object with find, create, delete and update methods.
getCollection(DBinstance) -> function(collectionName) -> {
find(query)-> Promise.resolve(resultQuery),
create(data)-> Promise.resolve(dataCreated),
delete(query)-> Promise.resolve(docRemoved),
update(query, dataToUpdate)-> Promise.resolve(docUpdated)
}
example:
monprox -s --gd ./lib/get-database --gum ./lib/get-getter-user/get-model-user --gsm ./lib/get-getter-schema/get-model-schema --gc ./lib/get-getter-collection