feathers-waterline-aggregate-aggregate



A database adapter for the Waterline ORM, the ORM used by SailsJS. For detailed Waterline documentation, see the waterline-docs repository. Currently Waterline supports the following data stores:

NOTE: Work In Progress. This fork intends to provide some aggregate function support not found in feathers-waterline.

- PostgreSQL - 0.9+ compatible
- MySQL - 0.9+ compatible
- MongoDB - 0.9+ compatible
- Memory - 0.9+ compatible
- Disk - 0.9+ compatible
- Microsoft SQL Server
- Redis
- Riak
- IRC
- Twitter
- JSDom
- Neo4j
- OrientDB
- ArangoDB
- Apache Cassandra
- GraphQL
- Solr

Status

This module will continue to work as is but needs a maintainer for future feature and dependency updates. Create an issue if you are interested.

Installation

``bash
npm install feathers-waterline-aggregate --save
`

> ProTip: You also need to install the waterline database adapter for the DB you want to use.

Getting Started

feathers-waterline-aggregate hooks a Waterline Model up to a configured data store as a feathers service.

`js
const Message = require('./models/message');
const config = require('./config/waterline');
const Waterline = require('waterline');
const service = require('feathers-waterline-aggregate');

const ORM = new Waterline();

ORM.loadCollection(Message);
ORM.initialize(config, function(error, data) {
app.use('/messages', waterlineService({
Model: data.collections.message
}));
});
`

Options

Creating a new Waterline service currently offers the following options:

- Model (required) - The Waterline model definition
- id (default: id) [optional] - The name of the id property
- paginate [optional] - A pagination object containing a default and max page size (see the Pagination chapter)

Complete Example

Here is an example of a Feathers server with a messages Waterline Model using the Disk store:

`
$ npm install feathers feathers-rest feathers-socketio body-parser waterline sails-disk feathers-waterline-aggregate
`

`js
const feathers = require('feathers');
const rest = require('feathers-rest');
const socketio = require('feathers-socketio');
const bodyParser = require('body-parser');
const Waterline = require('waterline');
const diskAdapter = require('sails-disk');
const service = require('feathers-waterline-aggregate');

const ORM = new Waterline();
const config = {
adapters: {
'default': diskAdapter,
disk: diskAdapter
},
connections: {
myLocalDisk: {
adapter: 'disk'
}
},
defaults: {
migrate: 'alter'
}
};
const Message = Waterline.Collection.extend({
identity: 'message',
schema: true,
connection: 'myLocalDisk',
attributes: {
text: {
type: 'string',
required: true
},

complete: {
type: 'boolean'
}
}
});

// Create a feathers instance.
const app = feathers()
// Enable REST services
.configure(rest())
// Enable Socket.io services
.configure(socketio())
// Turn on JSON parser for REST services
.use(bodyParser.json())
// Turn on URL-encoded parser for REST services
.use(bodyParser.urlencoded({ extended: true }));

ORM.loadCollection(Message);
ORM.initialize(config, (error, data) => {
if (error) {
console.error(error);
}

// Create a Waterline Feathers service with a default page size of 2 items
// and a maximum size of 4
app.use('/messages', service({
Model: data.collections.message,
paginate: {
default: 2,
max: 4
}
}));

app.use(function(error, req, res, next){
res.json(error);
});

// Create a dummy Message
app.service('messages').create({
text: 'Server message',
complete: false
}).then(function(message) {
console.log('Created message', message.toJSON());
});

// Start the server
const server = app.listen(3030);
server.on('listening', function() {
console.log('Feathers Message waterline service running on 127.0.0.1:3030');
resolve(server);
});
});
``

License

Copyright (c) 2016

Licensed under the MIT license.