root/ossiedev/branches/jsnyder/trunk/tools/cornetApps/DomainMan/views.py @ 11091

from django.shortcuts import render_to_response
from django.http import HttpResponse, Http404
from django.template import RequestContext
from paramiko import SSHClient, AutoAddPolicy
from models import *
import time

"""Views for DomainMan application
Starts and stops nodeBooter/naming service through paramiko
"""

"""
Testing login
"""
def cornet_login(request):
    user = request.user
    return render_to_response('DomainMan/cornet_login.html', locals(), context_instance=RequestContext(request))

"""
Connects to a server through a given ip, port and associated username and password 
Returns the SSHClient connected to the server
"""
def connect(ip, port, user, password):
    client = SSHClient()
    client.set_missing_host_key_policy(AutoAddPolicy())
    try:
        client.connect(ip, int(port), user, password)
    except:
        raise Http404(u'Incorrect username and password combination')
    return client

'''
Tests if nodebooter is running.
@param client: The SSHClient connected to a server/node
@return: A boolean indicating if nodebooter is running
'''
def nodeBooter_running(client):
    stdin, stdout, stderr = client.exec_command('ps -aux | grep GPP')
    processes = stdout.readlines()
    
    #processes = processes.split()
    
    for proc in processes:
        #print 'proc: ' + str(proc)
        #if '/usr/local/bin/nodeBooter' in proc or '/usr/bin/nodeBooter' in proc or 'nodeBooter' in proc:
        if 'dev/bin/GPP' in proc:
            return 1
    #print 'runningNodebooter: ' + str(runningNodebooter)
#    runningNodebooter = 'dev/nodes/' in processes
    return 0

'''
Starts nodeBooter at a given ip and port
@param ip: The ip address of the server for the nodes
@param port: The port, typically 22
@param user: The user's username with access to the node
@param password: The user's password
'''
def startNodebooter(request, ip, port, user, password):
    client = connect(ip, port, user, password)
    #stdin, stdout, stderr = client.exec_command('cd /sdr; nodeBooter -D -d dev/nodes/default_GPP_node/DeviceManager.dcd.xml')
    client.exec_command('cd /sdr ; nodeBooter -D -d dev/nodes/default_GPP_node/DeviceManager.dcd.xml')
    runningNodebooter = nodeBooter_running(client)
    return render_to_response('DomainMan/runningNodebooter.html', locals(), context_instance=RequestContext(request))

"""Start nodebooter with premade client from client list
"""
#def startNodebooter(request, floor, number):
#    clientID = str(postFloor).__add__("-").__add__(str(postNum))
#    client = SSHClientList.getClient(clientID)
#    #stdin, stdout, stderr = client.exec_command('cd /sdr; nodeBooter -D -d dev/nodes/default_GPP_node/DeviceManager.dcd.xml')
#    client.exec_command('cd /sdr; nodeBooter -D -d dev/nodes/default_GPP_node/DeviceManager.dcd.xml')
#    runningNodebooter = nodeBooter_running(client)
#    return render_to_response('DomainMan/runningNodebooter.html', locals(), context_instance=RequestContext(request))

'''
Kills all nodeBooter processes at a given ip and port
@param ip: The ip address of the server for the nodes
@param port: The port, typically 22
@param user: The user's username with access to the node
@param password: The user's password
'''
def stopNodebooter(request, ip, port, user, password):
    client = connect(ip, port, user, password)
    stdin, stdout, stderr = client.exec_command('killall nodeBooter && killall GPP')
    runningNodebooter = nodeBooter_running(client)
    return render_to_response('DomainMan/runningNodebooter.html', locals(), context_instance=RequestContext(request))

'''
Testing view to check if nodebooter is running.
Checks if nodeBooter is running, if not, starts it.
@param ip: The ip address of the server for the nodes
@param port: The port, typically 22
@param user: The user's username with access to the node
@param password: The user's password
'''
def nodeBooter_page(request, ip, port, user, password):
    if 'ip' in request.POST and 'port' in request.POST and 'user' in request.POST and 'pass' in request.POST:
        client = connect(ip, port, user, password)
    else:
        raise Exception('client could not connect with POST variables')
    if not nodeBooter_running(client):
        stdin, stdout, stderr = client.exec_command('cd /sdr; nodeBooter -D -d dev/nodes/default_GPP_node/DeviceManager.dcd.xml')
    runningNodebooter = nodeBooter_running(client)
    return render_to_response('DomainMan/console.html', locals(), context_instance=RequestContext(request))

"""Connect to a nodebooter through a form
"""
def connect_to_node(request):
    if 'floor' in request.POST and 'number' in request.POST and 'user' in request.POST and 'pass' in request.POST:
        postFloor = int(request.POST['floor'])
        postNum = int(request.POST['number'])
        user = str(request.POST['user'])
        password = str(request.POST['pass'])
        
        thisNode = Node(postFloor, postNum)
        ip = thisNode.ip
        port = thisNode.port
        #thisNode.save()
        #thisNode.setClient(user, password)
        #node = Node.objects.get(floor=4, num=1)
        client = connect(ip, port, user, password)
        #stdin, stdout, stderr = client.exec_command('ls')
        print 'calling runningNodebooter'
        runningNodebooter = nodeBooter_running(client)
    else:
        message = 'Missing ssh connection parameters'
        print message
    return render_to_response('DomainMan/runningNodebooter.html', locals(), context_instance=RequestContext(request))

"""Returns connection form
"""
def connect_to_node_view(request):
    number_of_floors = range(1,5)
    number_of_nodes = range(1,13)
    return render_to_response('DomainMan/connect.html', locals(), RequestContext(request))

def ajax_example(request):
    if not request.method == 'GET':
        name = "did not work"
        print request.GET
        return render_to_response('DomainMan/ajax_example.html', locals(), context_instance=RequestContext(request))
    response_dict = {}
    name = request.GET.get('name', False)
    total = request.GET.get('total', False)
    response_dict.update({'name': name, 'total': total})
    if total:
        try:
            total = int(total)
        except:
            total = False
    if name and total and int(total) == 10:
        response_dict.update({'success': True })
    else:
        response_dict.update({'errors': {}})
        if not name:
            response_dict['errors'].update({'name': 'This field is required'})
        if not total and total is not False:
            response_dict['errors'].update({'total': 'This field is required'})
        elif int(total) != 10:
            response_dict['errors'].update({'total': 'Incorrect total'})
    return render_to_response('DomainMan/ajax_example.html', response_dict, context_instance=RequestContext(request))