path: root/cgi-bin/fetch_milestone.py

#!/usr/bin/python

import os, sys, subprocess
from sugar.activity import activity
import cgi, cgitb
from path import path

DATAPATH = path(activity.get_activity_root())/ 'data'
WORKPATH = DATAPATH / 'work'
USB = path('/media/CW/content')
MOODLE_ENGLISH = [0,20,21,9,10,11,22]
MOODLE_ENGLISH11 = [0,23,24,25,26,27,28,29,30,31]
MOODLE_MATHEMATICS = [0,13,14,15,16,17,18]
MOODLE_MATHEMATICS11 = [0,32,33,34,35,36,37,38,39,40]

#executes sftp command contained in scrpt
#note scrpt must be written to disk and read by sftp command
def sftp(script, folder = None):
    flog = open('/tmp/flog','w')
    pth = WORKPATH / 'script'
    subprocess.call('rm -rf ' + pth, shell=True)
    fout = open(pth, 'w')
    fout.write(script)
    fout.close()
    print >> flog, 'script', script
    authpth = '/home/olpc/.sugar/default/owner.key'
    auth = ' -oIdentityFile=' + authpth
    scrpt = ' -b ' + pth
    fin = open('/ofw/serial-number','r')
    serial_number = fin.read()
    fin.close()
    srvr = serial_number[:-1] + '@schoolserver'
    cmd = 'sftp ' + auth + scrpt + ' ' + srvr
    print >>flog, 'cmd=',cmd
    if folder:
        pid= subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, cwd=folder, shell=True)
        pid.wait()
        if pid.returncode == 0:
            result = pid.communicate()[0]
        else:
            result = pid.returncode
    else:
        pid = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True)
        pid.wait()
        if pid.returncode == 0:
            result = pid.communicate()[0]
        else:
            result = pid.returncode
    print >> flog, pid.returncode
    flog.close()
    return result

def remove(year, milestone):
    if str(milestone[:2]) == 'en':
        if year == 0:
            subject = 'English'
        else:
            subject = 'English11'
    else:
        if year == 0:
            subject = 'Mathematics'
        else:
            subject = 'Mathematics11'
    if year == 0:
        subprocess.call('rm -rf content/' + subject + '/' + milestone, shell=True)

def get_from_usb(milestone):
    if str(milestone)[:2] == 'en':
        subject = 'English'
    else:
        subject = 'Mathematics'
    pth = '/media/' + str(2011) + '/' + subject + '/' + milestone
    cwd = 'content/' + subject + '11' 
    subprocess.call('cp -r ' + pth + ' .', shell=True, cwd=cwd)

def get_from_ss(year, course, milestone):
    #use sftp, need to know Moodle course number
    script = 'cd /var/lib/moodle/' + str(course) + '\nget ' + milestone + '*.msxo'
    folder = 'content/' + subject
    result = sftp(script, folder)
    cmd = 'unzip ' + milestone + '*.msxo'
    subprocess.call(cmd, shell = True, cwd=folder)
    subprocess.call('rm -rf ' + folder + '/*.msxo', shell=True)

def save_to_usb(milestone):
    if str(milestone)[:2] == 'en':
        subject = 'English'
    else:
        subject = 'Mathematics'
    pth	= '/media/' + 2011 + '/' + subject
    cwd = 'content/' + subject + '11'
    subprocess.call('cp -r ' + cwd + '/' + milestone +  ' ' + pth, shell=True)

def get_course(year, milestone):        
    ms = str(milestone)
    grde = int(ms[3])
    if ms[:2] == 'en':
        if year == '2011':
            term = int(ms[5])
            idx = term + 3*(grde-4)
            course = str(MOODLE_ENGLISH11[idx])
        else:
            idx = int(grde)
            course = MOODLE_ENGLISH[idx]
    else:
        if year == '2011':
            term = int(ms[4])
            idx = term + 3*(grde-4)
            course = str(MOODLE_MATHEMATICS11[idx])
        else:
            idx = int(grde)
            course = str(MOODLE_MATHEMATICS[idx])
    return course, grde

def update_color():
    # 
    # update color in .js for grade
    #
    pth = path('content') / subject
    fullpth = pth / 'p' + str(grde) + '.js'
    #read p*.js
    fin = open(pth / 'p' + str(grde) + '.js','r')
    txt = fin.read()
    fin.close()
    lines = txt.split('\n')
    newlines = []
    for line in lines:
        if line.find('Blue')<0 and line.find('Cyan')<0:
            newlines.append(line)
            continue
        entry = eval(line)[0]
        if entry[4] == milestone:
            if operation == 'download':
                entry[5] = 'Blue'
            else:
                entry[5] = 'Cyan'
        newlines.append(str(entry)+',')
    txtout = ""
    for line in newlines:
        txtout = txtout + line + '\n'
    fout = open(fullpth,'w')
    fout.write(txtout)
    fout.close()

def update_activities_js():
    #
    # update activities.js
    # 
    #let's create a new activities.js file based on installed milestones
    entry = ['0','0','milestone','m','x','color']
    #we add a line for each milestone that is installed
    pth = path('content') / subject
    temp = pth.dirs()
    milestones = []
    for item in temp:
        milestones.append(str(item.namebase))
    milestones.remove('karma')
    txtout = 'var activities = [\n'
    for milestone in milestones:
        newentry = entry
        newentry[3] = milestone.namebase[:4]
        newentry[4] = milestone.namebase
        newentry[5] = 'Blue'
        txtout = txtout + str(newentry) + ',\n'
    txtout = txtout + '];\nvar assetlist = [];\nvar logos = [];\n'
    #write activities.js
    fout = open(pth / 'activities.js','w')
    fout.write(txtout)
    fout.close()

def process_cw_mode(year, milestone):
    course, grde = get_course(year,milestone)
    if milestone[:2] == 'en':
        subject = 'English'
    else:
        subject = 'Mathematics'
    if year == '2011':
        subject = subject + '11'
    pth = path('content') / subject / milestone
    if pth.exists():
        operation = 'remove'
    else:
        operation = 'download'
    #process request
    if operation == 'download':
        get_from_ss(year, course, milestone)
    else:
        #for now, do not remove 2011 milestones
        if year == '2010':
            pth = path('content') / subject / milestone
            subprocess.call('rm -rf ' + pth, shell=True)
    update_color()
    update_activities_js()

def getInstalled(subject):
    pth = path('content') / subject
    temp = pth.dirs()
    milestones = []
    for item in temp:
        milestones.append(str(item.namebase))
    milestones.remove('karma')
    return milestones

def getMilestone(subject, milestone):
    #only from /media/CW/content for now
    print >>log, 'getMilestone', subject, milestone
    if(not USB.exists()):
        print >> log, 'no usb drive installed'
        return
    pth = USB / subject 
    cmd = 'cp -r ' + pth / milestone + ' ' + 'content/'+ subject
    subprocess.call(cmd,shell=True)

def get_student_record(student, classe):
    known = False
    #read student record
    try:
        fin = open(DATAPATH / student,'r')
        txt = fin.read()
        fin.close()
        student_record = eval(txt)
    except:
        student_record = {}
    #student is known if there is a student record and the class is the same
    try:
        grade = student_record['grade']
    except:
        grade = 'unknown'
    if not grade == 'unknown':
        if classe == 'unknown' or classe == grade:
            known = True
            try:
                milestones = student_record['milestones']
            except:
                student_record['milestones'] = ['1.1','1.1']
    else:
        if classe == 'unknown': 
            grade = 'P4'
        else:
            grade = classe
    if not known:
        #create new student record
        student_record = {}
        student_record['grade'] = grade
        student_record['milestones'] = ['1.1','1.1']
        student_record['progress'] = {}
        txtout = str(student_record)
        fout = open(DATAPATH / student,'w')
        fout.write(txtout)
        fout.close()
    print >> log, 'student_record known',known
    return student_record

def process_milestones(subject, grade, current_ms):
    next_ms = str(int(current_ms)+1)
    if len(current_ms)<2:
        current_ms = '0'+current_ms
    if len(current_ms)<2:
        current_ms = '0'+current_ms
    if len(next_ms)<2:
        next_ms = '0'+next_ms
    if subject == 'English':
        sbj = 'en'
    else:
        sbj = 'ma'
    current_milestone = (sbj+grade+'m'+current_ms).lower()
    next_milestone = (sbj+grade+'m'+next_ms).lower()
    print >> log, 'process_student_mode',grade,current_milestone,next_milestone
    installed = getInstalled(subject)
    print >> log, 'installed',subject,installed
    if not current_milestone in installed:
        getMilestone(subject, current_milestone);
    if not next_milestone in installed:
        getMilestone(subject, next_milestone)

def process_student(student,student_record):
    grade = student_record['grade']
    en_milestone = student_record['milestones'][0]
    ma_milestone = student_record['milestones'][1]
    print>>log, grade, en_milestone, ma_milestone
    #English
    current_ms = en_milestone.split('.')[0]
    process_milestones('English',grade, current_ms)
    #Mathematics
    current_ms = ma_milestone.split('.')[1]
    process_milestones('Mathematics',grade, current_ms)

#main
#
#get paramters: mode, year, milestone, student name
#
cgitb.enable(display=True)
print 'Content-Type:text/html\n\n'
log = open('/tmp/logfm','w')
form = cgi.FieldStorage()
mode = form.getfirst('mode', default='CW')
print >> log, 'mode', mode
if mode == 'CW':
    year = form.getfirst('year', default='2010')
    milestone = form.getfirst('milestone', default='enp4m1')
    process_cw_mode(year, milestone)
else:
    student = form.getfirst('student', default='student')
    student = student.lower()
    #log student in
    fout = open('/tmp/learner','w')
    fout.write(student)
    fout.close()
    classe = form.getfirst('class',default = 'unknown')
    print >> log, 'student', student, 'grade', classe
    student_record = get_student_record(student, classe)
    print >> log, 'student_record returned',student, student_record
    try:
        process_student(student,student_record)
    except:
        print >> log, 'process_student failed', sys.exc_info()[:2]
        log3.close()
log.close()