model_group.js

var assert = require('assert');
var model = require('./model');

exports.create = function(group, cb) {
  model.db.collection('groups').insert(
    group,
    function(err) {
      model.db.close();
      if (err) return cb(err); 
      cb();
    }
  );  
};

exports.getByIds = function(group_ids, cb){
  model.db.collection('groups').find({'_id' : {$in: group_ids} }).toArray(function(err, groups){
    model.db.close();
    if (err) return cb(err);
    console.log('model_group getByIds groups array = '+ JSON.stringify(groups));  
    cb(groups);
  });
};

exports.getAll = function(cb){
  model.db.collection('groups').find().toArray(function(err, groups){
    model.db.close();
    if (err) return cb(err);
    console.log('model_group getByIds groups array = '+ JSON.stringify(groups));  
    cb(groups);
  });
};

exports.readGroupMembers = function(group, cb) {
  model.db.collection('group_member_links',{'uid' : true}).find(group).toArray(function(err, group_member_links){
    if (err) {model.db.close(); return cb(err);}
    console.log('model_group readGroupMembers group_member_links = '+ JSON.stringify(group_member_links));
    
    var member_ids = group_member_links.map(function(group_member_link) {return group_member_link.gid;});
    model.db.collection('users').find({'_id' : {$in: member_ids} }).toArray(function(err, members){
      model.db.close();
      if (err) return cb(err);
      console.log('model_group readGroupMembers members array = '+ JSON.stringify(members));  
      group.members = members;
      cb();
    });
    
  });    
};