Correction à l'API

[auf_rh_dae.git] / project / recrutement / api.py

# -*- encoding: utf-8 -*
from django.http import HttpResponse
from django.template import RequestContext, Template
from django.shortcuts import render_to_response, redirect, get_object_or_404
from django.utils import simplejson
from django.contrib import messages

from auf.django.emploi import models as emploi
from auf.django.emploi import forms as emploiForms

STATUS_OK = 200

STATUS_ERROR = 400
STATUS_ERROR_NOT_FOUND = 404
STATUS_ERROR_PERMISSIONS = 403
STATUS_ERROR_BADMETHOD = 405

def api(request, method):
    # TODO: Sécurité : 
    #       L'échange d'information doit être possible qu'avec les HOST désirés.

    #if request.method != 'POST':
    #    return api_return(STATUS_ERROR_BADMETHOD)
    
    api = API(request)
    if hasattr(api, 'api_%s' % method):
        return getattr(api, 'api_%s' % method)()
    
    return api_return(STATUS_ERROR)

def api_return(status, text='', json=False):
    content_type = 'text/html'
    if status == STATUS_OK and json:
        content_type = 'text/json'
    if text is None:
        if status == STATUS_ERROR:
            text = 'Error'
        elif status == STATUS_ERROR_NOT_FOUND:
            text = 'Resource Not Found'
        elif status == STATUS_ERROR_PERMISSIONS:
            text = 'Invalid username or password'
        elif status == STATUS_ERROR_BADMETHOD:
            text = 'Invalid request method'
        elif status == STATUS_OK:
            text = 'OK'

    r = HttpResponse(status=status, content=text, content_type=content_type)

    if status == STATUS_ERROR_BADMETHOD:
        r.Allow = 'POST'

    return r


class API:
    def __init__(self, request):
        self.request = request

    def api_candidat_add(self):
        vars = dict()
        offre_emploi = get_object_or_404(emploi.OffreEmploi, id=self.request.GET.get('id'))
        cand = emploi.Candidat()
        cand.offre_emploi = offre_emploi

        if self.request.method == "POST":
            form = emploiForms.PostulerOffreEmploiForm(self.request.POST,
                     instance=cand, offre_emploi=offre_emploi)
            piecesForm = emploiForms.CandidatPieceForm(self.request.POST, self.request.FILES,
                        instance=cand)
            if form.is_valid() and piecesForm.is_valid():
                offre = form.save()
                piecesForm.instance = offre
                piecesForm.save() 
         
                """courriel_template = CourrielTemplate.objects.\
                            get(nom_modele='Confirmation postulation (automatique)')
                send_templated_email(candidat, courriel_template)
                """
                return api_return(STATUS_OK)
            else:
                messages.add_message(self.request, messages.ERROR,
                            'Il y a des erreurs dans le formulaire.')
        else:
            form = emploiForms.PostulerOffreEmploiForm(instance=cand,
                    offre_emploi=offre_emploi)
            piecesForm = emploiForms.CandidatPieceForm(instance=cand)

        vars.update(dict(form=form, candidat=cand, piecesForm=piecesForm, ))
     
        return render_to_response('recrutement/postuler_appel_offre.html', vars, 
                RequestContext(self.request))


    def api_offre_emploi_liste(self):
        return api_return(STATUS_OK, simplejson.dumps(
                            [{"id": "%s" % offre.id, 
                            "est_affiche": "%s" % offre.est_affiche,
                            "statut": "%s" % offre.statut,
                            "nom": "%s" % offre.nom, 
                            "resume": "%s" % offre.resume,
                            "description": "%s" % offre.description,
                            # "poste": "%s [%s]" % 
                            "region": "%s" % offre.region.id,
                            "bureau": "%s" % offre.bureau.id,
                            "date_limite": "%s" % offre.date_limite,
                            "duree_affectation": "%s" % offre.duree_affectation,
                            "renumeration": "%s" % offre.renumeration,
                            "debut_affectation": "%s" % offre.debut_affectation,
                            "lieu_affectation": "%s" % offre.lieu_affectation.id} 
                            for offre in emploi.OffreEmploi.objects.all()]), json=True)
        
    def api_offre_emploi(self):
        try:
            offre = emploi.OffreEmploi.objects.get(id=self.request.GET.get('id'))
        except emploi.OffreEmploi.DoesNotExist:
            return api_return(STATUS_ERROR, "ID d'offre d'emploi invalide")
        return api_return(STATUS_OK, simplejson.dumps(
            {"id": "%s" % offre.id,
            "est_affiche": "%s" % offre.est_affiche,
            "statut": "%s" % offre.statut,
            "nom": "%s" % offre.nom, 
            "resume": "%s" % offre.resume,
            "description": "%s" % offre.description,
            "region": "%s" % offre.region.id,
            "bureau": "%s" % offre.bureau.id,
            "date_limite": "%s" % offre.date_limite,
            "duree_affectation": "%s" % offre.duree_affectation,
            "renumeration": "%s" % offre.renumeration,
            "debut_affectation": "%s" % offre.debut_affectation,
            "lieu_affectation": "%s" % offre.lieu_affectation.id} ), json=True)