e-ucm/rage-analytics-backend

'use strict';

var generate = require('adjective-adjective-animal');

/**
 * Manages a collection ('players') with documents for each anonymous player with:
 *
 *      {
 *          name: <String>      - player._id + Math.round(Math.random() * 100000)
 *          type: 'anonymous'
 *      }
 */

module.exports = (function () {
    var Collection = require('easy-collections');
    var players = new Collection(require('./db'), 'players');

    /**
     * Creates or returns a player depending on the value of 'authorization'.
     *
     * This method is invoked when we receive an '/api/collector/start/:trackingCode' request, right after
     * ensuring that the 'trackingCode' is correct. More info. can be found at 'collector.js'@start function.
     *
     * @param authorization - Must have the following format:
     *                             1) 'a:' This will create a new anonymous player.
     *                             2) 'a:<playerName>' This will simply return the anonymous player with that given name.
     * @returns 401 - The 'authorization' format is not valid.
     *          or the found player document.
     */
    players.findByAuthorization = function (body, authorization, username) {

        if (username) {
            var playerData = {
                name: username,
                type: 'identified'
            };
            return players.find(playerData, true).then(function (player) {
                if (!player) {
                    return generate().then(function (animalName) {
                        playerData.animalName = animalName;
                        playerData.activities = [];
                        playerData.versions = [];
                        return players.insert(playerData);
                    });
                }
                return player;
            });
        }

        if (authorization) {
            throw {
                status: 400,
                message: 'Authorization header found but the expected format ' +
                'is \'Bearer JSON Web Token\' obtained by logging in to A2'
            };
        }

        if (body && body.anonymous) {
            var anonymousId = body.anonymous.trim();
            return players.find({
                name: anonymousId,
                type: 'anonymous'
            }, true).then(function (player) {
                if (!player) {
                    throw {
                        status: 404,
                        message: 'No anonymous player found with id ' + anonymousId +
                            '. Start a new anonymous session without providing any body in this request.'
                    };
                }
                return player;
            });
        }

        return players.insert().then(function (player) {

            return generate().then(function (animalName) {
                var set = {
                    name: player._id + Math.round(Math.random() * 100000),
                    type: 'anonymous',
                    animalName: animalName,
                    activities: [],
                    versions: []
                };
                return players.findAndModify(player._id, set);
            });
        });
    };

    return players;
})();