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

from django.shortcuts import render_to_response
from django.http import HttpResponse
from django.template import RequestContext
from paramiko import SSHClient, AutoAddPolicy

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

"""
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(request, ip, port, user, password):
    client = SSHClient()
    client.set_missing_host_key_policy(AutoAddPolicy())
    client.connect(ip, int(port), user, password)
    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 x | grep nodeBooter')
    processes = stdout.readlines()
    for proc in processes:
        if 'dev/nodes' in proc and 'DeviceManager.dcd' in proc:
            runningNodebooter = 1
            break
        else:
            runningNodebooter = 0
#    runningNodebooter = 'dev/nodes/' in processes
    return runningNodebooter

'''
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(request, ip, port, user, password)
    stdin, stdout, stderr = client.exec_command('cd /sdr; nodeBooter -D -d dev/nodes/default_GPP_node/DeviceManager.dcd.xml')
    return render_to_response('DomainMan/console.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(request, ip, port, user, password)
    stdin, stdout, stderr = client.exec_command('killall nodeBooter')
    return render_to_response('DomainMan/console.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):
    client = connect(request, ip, port, user, password)
    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))

def ajax_example(request):
    if not request.method == 'POST':
        name = "did not work"
        print request.POST
        return render_to_response('DomainMan/ajax_example.html', locals(), context_instance=RequestContext(request))
    response_dict = {}
    name = request.POST.get('name', False)
    total = request.POST.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))