tellform/app/sockets/analytics_service.js

'use strict';

/**
 * Module dependencies.
 */
var mongoose = require('mongoose'),
	errorHandler = require('../controllers/errors.server.controller'),
	Form = mongoose.model('Form'),
	request = require('request');

// Create the chat configuration
module.exports = function (io, socket) {
	var visitorsData = {};

	var saveVisitorData = function (data, socket, cb){
		Form.findById(data.formId, function(err, form) {
			if (err) {
				console.error(err);
				throw new Error(errorHandler.getErrorMessage(err));
			}

			var newVisitor = {
				socketId: data.socketId,
				referrer: data.referrer,
				lastActiveField: data.lastActiveField,
				timeElapsed: data.timeElapsed,
				isSubmitted: data.isSubmitted,
				language: data.language,
				ipAddr: data.ipAddr,
				deviceType: data.deviceType
			};

			form.analytics.visitors.push(newVisitor);

				form.save(function (formSaveErr) {
					if (err) {
						console.error(err);
						throw new Error(errorHandler.getErrorMessage(formSaveErr));
					}

				form.form_fields = form.form_fields.map(v => Object.assign({}, v, { fieldValue: null }));

				form.save(function (formSaveErr) {
					if (err) {
						console.error(err);
						throw new Error(errorHandler.getErrorMessage(formSaveErr));
					}

					if(cb){
						return cb();
					}
				});
		});
	};

	io.on('connection', function(current_socket) {
		// a user has visited our page - add them to the visitorsData object
		current_socket.on('form-visitor-data', function(data) {
			visitorsData[current_socket.id] = data;
			visitorsData[current_socket.id].socketId = current_socket.id;
			visitorsData[current_socket.id].isSaved = false;

			visitorsData[current_socket.id].ipAddr = current_socket.conn.transport.socket._socket.remoteAddress;

			if (data.isSubmitted && !data.isSaved) {
				visitorsData[current_socket.id].isSaved = true;
				saveVisitorData(data, function() {
					current_socket.disconnect(true);
				});
			}
		});

		current_socket.on('disconnect', function() {
			var data = visitorsData[current_socket.id];
			if(data && !data.isSubmitted && !data.isSaved) {
				data.isSaved = true;
				saveVisitorData(data, function() {
					delete visitorsData[current_socket.id];
				});
			} else {
				delete visitorsData[current_socket.id];
			}
		});
	});
};