exp_portal/users.py

from django.shortcuts import render, redirect
from op_tasks.models import UserProfile, Product, Dataset, OpTask, TaskListItem, Experiment
from django.contrib.auth.decorators import login_required
from django.contrib.auth import get_user_model

from django.http import JsonResponse, HttpResponseForbidden

from op_tasks import tasksUtil

from op_tasks import mechanicalTurk

from op_tasks.surveyMongoUpdate import SM_EXPERIMENT_NAME

from base import ALE_URL
from elasticsearch import Elasticsearch

@login_required(login_url='/tasking/login')
def view_users(request):
	userprofiles = UserProfile.objects.all().order_by('-user__last_login')
	return render(request, 'users.html', {'userprofiles': userprofiles})


@login_required(login_url='/tasking/login')
def manage_users(request):
	userprofiles = UserProfile.objects.all().order_by('-user__last_login')
	return render(request, 'users.html', {'userprofiles': userprofiles})


@login_required(login_url='/tasking/login')
def edit_user(request, userprofilepk):
	userprofile = UserProfile.objects.get(id=userprofilepk)
	experiment = Experiment.objects.get(name=request.POST['experiment_name'])
	userprofile.experiment = experiment
	userprofile.save()

	return redirect('exp_portal:view_users')


@login_required(login_url='/tasking/login')
def add_user(request):
	experiments = Experiment.objects.all()
	products = Product.objects.all()
	return render(request, 'add_user.html', {'experiments': experiments, 'products':products})


@login_required(login_url='/tasking/login')
def delete_user(request, userprofilepk):
	userprofile = UserProfile.objects.get(id=userprofilepk)
	user = userprofile.user
	usertasks = userprofile.tasklistitem_set.all()

	for tasklistitem in usertasks:
		tasklistitem.delete()

	user.delete()
	userprofile.delete()

	return redirect('exp_portal:view_users')


@login_required(login_url='/tasking/login')
def new_user(request):
    user = get_user_model()(email=request.POST['email'])
    user.set_password(request.POST['password_1'])
    user.last_login = '1970-01-01 00:00'
    user.save()

    userprofile = UserProfile()
    userprofile.user = user
    experiment = Experiment.objects.get(name=request.POST['experiment_name'])
    userprofile.experiment = experiment
    userprofile.save()

    # logic for assigning tasks
    if request.POST['product_name'] == 'all':
        # all products all tasks buffet style
		tasksUtil.appendAllTasks(user)
    else:
		# single product - task ordering assumed
		product = Product.objects.get(name=request.POST['product_name'])
		if str(request.POST['taskorder']) == 'b':
			print 'true'
			tasks = product.dataset.optask_set.all().order_by('id').reverse()
		else:
			tasks = product.dataset.optask_set.all().order_by('id')

		tasks = tasks.filter(is_active=True)

		index = 0
		for task in tasks:
			newtasklistitem = TaskListItem()
			newtasklistitem.userprofile = userprofile
			newtasklistitem.op_task = task
			newtasklistitem.product = product
			newtasklistitem.index = index
			# if index == 0 or experiment.sequential_tasks == False:
			# 	newtasklistitem.task_active = True
			# else:
			# 	newtasklistitem.task_active = False
			index = index + 1
			newtasklistitem.save()

    return redirect('exp_portal:view_users')


@login_required(login_url='/tasking/login')
def user_added(request):
	return render(request, 'user_added.html')


@login_required(login_url='/tasking/login')
def view_user_tasks(request, profile):
	userprofile = UserProfile.objects.all().filter(user_hash=profile)[0]
	usertasks = userprofile.tasklistitem_set.all()
	experiments = Experiment.objects.all()
	
	datasets = Dataset.objects.all()
	count = 0
	tasklistitems = []
	for dataset in datasets:
		for product in dataset.product_set.all():
			for task in dataset.optask_set.all():
				count = count + 1

	return render(request, 'user_tasks.html', {'userprofile': userprofile, 'experiments':experiments})


@login_required(login_url='/tasking/login')
def add_user_task(request, userpk):
	userprofile = UserProfile.objects.get(id=userpk)
	datasets = Dataset.objects.all()
	products = Product.objects.all()
	tasks = OpTask.objects.all()
	return render(request, 'add_user_task.html', {'userprofile':userprofile, 
		'datasets': datasets, 'products': products, 'tasks': tasks})


@login_required(login_url='/tasking/login')
def update_user_tasks(request, userpk, datasetpk, productpk, taskpk):
	dataset = Dataset.objects.get(id=datasetpk)
	userprofile = UserProfile.objects.get(id=userpk)
	index = userprofile.tasklistitem_set.count()

	newtasklistitem = TaskListItem()
	newtasklistitem.userprofile = userprofile
	newtasklistitem.op_task = OpTask.objects.get(id=taskpk)
	newtasklistitem.product = Product.objects.get(id=productpk)
	newtasklistitem.index = index
	newtasklistitem.task_active = True
	newtasklistitem.save()

	return redirect('exp_portal:add_user_task', userpk)

def view_users_experiment(request, experiment_name):
        print "Experiment User Request From: ", request.META['REMOTE_ADDR']
        if request.META['REMOTE_ADDR'] != '127.0.0.1':
            return HttpResponseForbidden()

	experiment = Experiment.objects.get(name=experiment_name)
	userprofiles = experiment.userprofile_set.all()
	user_hashes = {}
	for userprofile in userprofiles:
               tasklistitems = userprofile.tasklistitem_set.all()
               completedTasks = [task for task in tasklistitems if task.task_complete is True]
               for task in completedTasks:
                        #unique identifier for user::task
                        session_id = str(userprofile.user_hash)+'::'+str(task.pk)
                        #TEST VALUE
                        #session_id = "49bacc695d39a2f23cf44f949409e7::1104"

                        #Mechanical Turk task completion payment code
			mtcode = mechanicalTurk.generateCode(userprofile.user.id,userprofile.user_hash)

                        #ALE logged survey start time
                        XDATA_INDEX="xdata_v3"
                        es = Elasticsearch(ALE_URL)
                        queryData = {}
                        fieldFilter = ["timestamp", "sessionID", "elementId"]
                        sMatch = {"match" : {"sessionID" : session_id}}
                        eMatch = {"match" : {"elementId" : "open_task_button"}}
                        mustField = [sMatch, eMatch]
                        queryData["query"] = { "bool": { "must" : mustField } }
                        results = es.search(index=XDATA_INDEX, body=queryData, fields=fieldFilter, size=1000)['hits']
                        timestamps = [d['fields']['timestamp'] for d in results['hits']]

                        #ES WILL BE BLOCKED SOON.  INSTEAD:
                        #results = requests.get(ALE_URL + "/" + XDATA_INDEX + "/select?q=sessionID:" + sessionID + "&q=elementID:open_task_button&fl=timestamp,sessionID,elementID&size=1000")

                        if len(timestamps) > 1:
                            print "Warning, more than 1 timestamp from Elastic"
                        if len(timestamps) < 1:
                            print "Warning, no timestamp from Elastic"
                            timestamps = [["NA"]]
                        print "Elastic result: ", timestamps
			#print "Timestamp: ", timestamps[0][0], "; Type: ", type(timestamps[0][0])

			stoutVars = {'SYS.FIL.DAT.':task.op_task.dataset.name,
                                     'SYS.FIL.EXP.':SM_EXPERIMENT_NAME,
                                     'SYS.FIL.APP.':task.product.name,
                                     'SYS.FIL.TSK.':task.op_task.name,
                                     'SYS.FIL.ORD.':str(task.index),
                                     'SYS.FIL.STD.':timestamps[0][0]}
			user_hashes[session_id]={'mtcode':mtcode,'vars':stoutVars}	

	response = JsonResponse(user_hashes, safe=False)
	return response