Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- module.exports = {
- schema: false,
- connection: 'redis',
- autoPK: false,
- autoCreatedAt: false,
- autoUpdatedAt: false,
- attributes: {
- ta : 'string',
- // Override toJSON instance method
- toJSON: function() {
- var obj = this.toObject();
- return obj;
- }
- }
- };
- Redis.find()
- .where({ ta: 'MB:400V:TRAF004:EP:MvMoment' })
- .exec(function(err, users) {
- // Do stuff here
- console.log("User: " + users + " - " + err);
- });
- User: - null
- module.exports = {
- schema: false,
- connection: 'redis',
- autoPK: false,
- autoCreatedAt: false,
- autoUpdatedAt: false
- };
- Redis.find()
- .where({ ta: 'MB:400V:TRAF004:EP:MvMoment' })
- .exec(function(err, users) {
- // Do stuff here
- console.log("User: " + users + " - " + err);
- });
- module.exports = {
- schema: false,
- connection: 'redis',
- autoPK: false,
- autoCreatedAt: false,
- autoUpdatedAt: false
- };
- estStream: function(req,res){
- if (req.param('startStream') && req.isSocket){
- var getSocket = req.socket;
- // Start the stream. Pipe it to sockets.
- Redis.stream().pipe(getSocket.emit);
- } else {
- res.view();
- }
- <script type="text/javascript">
- window.onload = function startListening(){
- socket.on('gotUser',function(data){
- console.log(data+' has joined the party');
- });
- };
- </script>
- <div class="addButton" onClick="socket.get('/monweb/testStream/',{startStream:true})">Stream all the Users !</div>
- error: Sending 500 ("Server Error") response:
- TypeError: Object function (ev) {
- if (ev == 'newListener') {
- return this.$emit.apply(this, arguments);
- }
- var args = util.toArray(arguments).slice(1)
- , lastArg = args[args.length - 1]
- , packet = {
- type: 'event'
- , name: ev
- };
- if ('function' == typeof lastArg) {
- packet.id = ++this.ackPackets;
- packet.ack = lastArg.length ? 'data' : true;
- this.acks[packet.id] = lastArg;
- args = args.slice(0, args.length - 1);
- }
- packet.args = args;
- return this.packet(packet);
- } has no method 'on'
- at Stream.pipe (stream.js:65:8)
- at module.exports.testStream (/home/victor/gestamp-PRUEBAS/api/controllers/MonWebController.js:1364:24)
- at routeTargetFnWrapper (/home/victor/gestamp-PRUEBAS/node_modules/sails/lib/router/bind.js:178:5)
- at callbacks (/home/victor/gestamp-PRUEBAS/node_modules/sails/node_modules/express/lib/router/index.js:164:37)
- at param (/home/victor/gestamp-PRUEBAS/node_modules/sails/node_modules/express/lib/router/index.js:138:11)
- at param (/home/victor/gestamp-PRUEBAS/node_modules/sails/node_modules/express/lib/router/index.js:135:11)
- at pass (/home/victor/gestamp-PRUEBAS/node_modules/sails/node_modules/express/lib/router/index.js:145:5)
- at nextRoute (/home/victor/gestamp-PRUEBAS/node_modules/sails/node_modules/express/lib/router/index.js:100:7)
- at callbacks (/home/victor/gestamp-PRUEBAS/node_modules/sails/node_modules/express/lib/router/index.js:167:11)
- at /home/victor/gestamp-PRUEBAS/node_modules/sails/lib/router/bind.js:186:7
- at alwaysAllow (/home/victor/gestamp-PRUEBAS/node_modules/sails/lib/hooks/policies/index.js:209:11)
- at routeTargetFnWrapper (/home/victor/gestamp-PRUEBAS/node_modules/sails/lib/router/bind.js:178:5)
- at callbacks (/home/victor/gestamp-PRUEBAS/node_modules/sails/node_modules/express/lib/router/index.js:164:37)
- at param (/home/victor/gestamp-PRUEBAS/node_modules/sails/node_modules/express/lib/router/index.js:138:11)
- at param (/home/victor/gestamp-PRUEBAS/node_modules/sails/node_modules/express/lib/router/index.js:135:11)
- at pass (/home/victor/gestamp-PRUEBAS/node_modules/sails/node_modules/express/lib/router/index.js:145:5) [TypeError: Object function (ev) {
- if (ev == 'newListener') {
- return this.$emit.apply(this, arguments);
- }
- var args = util.toArray(arguments).slice(1)
- , lastArg = args[args.length - 1]
- , packet = {
- type: 'event'
- , name: ev
- };
- if ('function' == typeof lastArg) {
- packet.id = ++this.ackPackets;
- packet.ack = lastArg.length ? 'data' : true;
- this.acks[packet.id] = lastArg;
- args = args.slice(0, args.length - 1);
- }
- packet.args = args;
- return this.packet(packet);
- } has no method 'on']
- events.js:74
- throw TypeError('Uncaught, unspecified "error" event.');
- ^
- TypeError: Uncaught, unspecified "error" event.
- at TypeError (<anonymous>)
- at emit (events.js:74:15)
- at ModelStream.end (/home/victor/gestamp-PRUEBAS/node_modules/sails/node_modules/waterline/lib/waterline/utils/stream.js:61:10)
- at module.exports.stream (/home/victor/gestamp-PRUEBAS/node_modules/sails/node_modules/waterline/lib/waterline/adapter/stream.js:25:66)
- at /home/victor/gestamp-PRUEBAS/node_modules/sails/node_modules/waterline/lib/waterline/query/stream.js:42:20
- at process._tickDomainCallback (node.js:492:13)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement