deprecated-db.js

const r = require('rethinkdb');

module.exports = class Model {
  
  constructor(cb) {
    this.conn = null;
    const p = r.connect({db: 'wodmeup'});
    p.then((conn) => {
      this.conn = conn;
      cb();
    }).error(function(err) {
      if (err) {
        console.error(err);
      }
      cb(err);
    });
  }
  
  getMovements(cb) {
    let query = r.db('wodmeup').table('movements').orderBy('name').pluck(['id', 'name']);
    query.run(this.conn, (err, cursor) => {
      if (err) throw err;
      cursor.toArray((err, result) => {
        cb(result);
      });
    });
  }

  getWorkouts(cb) {
    let query = r.db('wodmeup').table('workouts')
    // Cache movements
    .map(function(workout) {
      return workout.merge(function(workout) {
        return {'clusters': workout('clusters').map(function(cluster) {
          return cluster.merge(function(cluster) {
            return {'units': cluster('units').map(function(unit) {
              return unit.merge({
                movement: r.db('wodmeup').table('movements').get(unit('movementID'))
                .merge(function(movement) {
                  return {
                    equipment:movement('equipment').map(function(eqID) {
                      return eqID;
                    })
                  };
                })
                , rx:{},
              });
            })};
          },
          function(cluster) {
            return r.expr({timing: {type: 'NoTiming'}}).merge(cluster);
          });
        })};
      });
    })
    // Cache equipments
    .map(function(workout) {
      return workout.merge({
        'movements': workout('clusters').concatMap(function(cluster) {
          return cluster('units').map(function(unit) {
            return unit('movementID');
          });
        }),
        'equipments': workout('clusters').concatMap(function(cluster) {
          return cluster('units').concatMap(function(unit) {
            return unit('movement')('equipment');
          });
        }).distinct()
      });
    })
    .orderBy('name');

    query.run(this.conn, (err, cursor) => {
      if (err) throw err;
      cursor.toArray((err, result) => {
        cb(result);
      });
    });
  }
};