topic-subscription-breakdown.js

const co = require('co');

require('../../app/models/topic');
require('../../app/models/level');
const User = require('../../app/models/user');
const Workout = require('../../app/models/workout');

module.exports = function() {
  co(function*() {

    const topicLevelMap = {};

    const query = {
      createdAt: {
        $gt: new Date('2017-04-25').toISOString(),
      }
    }

    const totalUsersRegistered = yield User.count(query);
    console.log('total', totalUsersRegistered);

    const matchedUsers = yield User.find(query,
        '_id  createdAt')
      // .limit(300)
      .lean();

    //eslint-disable-next-line
    for (const u of matchedUsers) {
      const createdDate = new Date(u.createdAt);
      const nextDate = new Date(createdDate.getTime() + 86400000);
      const initialWorkouts = yield Workout.find({
        userId: u._id,
        hardcoded: true,
        date: {
           $gte: createdDate.toISOString(),
           $lte: nextDate.toISOString(),
        },
      }, 'topic level')
      .populate('topic', 'name')
      .populate('level', 'label')
      .limit(5)
      .lean();


      const onboardingValues = initialWorkouts.map(w => {
        return ({
          topic: w.topic.name,
          level: w.level.label,
        })}).reduce((acc, val) => {
          if (!acc.find(e => e.topic === val.topic)) {
            acc.push(val);
          }
          return acc;
        }, []);

      onboardingValues.forEach(t => {
        if (!topicLevelMap[t.topic]) {
          topicLevelMap[t.topic] = {};
        }

        if(!topicLevelMap[t.topic][t.level]) {
          topicLevelMap[t.topic][t.level] = 0;
        }

        topicLevelMap[t.topic][t.level] += 1;
      })
    }
    // console.log(matchedUsers);
    console.log(topicLevelMap);

    process.exit(0);

  });

}