Produits Entr'ouvert » Passerelle

# -*- coding: utf-8 -*-

from __future__ import unicode_literals

from django.db import models, migrations

class Migration(migrations.Migration):

    dependencies = [

        ('base', '0002_auto_20151009_0326'),

    ]

    operations = [

        migrations.CreateModel(

            name='CmisConnector',

            fields=[

                ('id', models.AutoField(verbose_name='ID', serialize=False, auto_created=True, primary_key=True)),

                ('title', models.CharField(max_length=50)),

                ('slug', models.SlugField()),

                ('description', models.TextField()),

                ('log_level', models.CharField(default=b'NOTSET', max_length=10, verbose_name='Log Level', choices=[(b'NOTSET', b'NOTSET'), (b'DEBUG', b'DEBUG'), (b'INFO', b'INFO'), (b'WARNING', b'WARNING'), (b'ERROR', b'ERROR'), (b'CRITICAL', b'CRITICAL'), (b'FATAL', b'FATAL')])),

                ('cmis_endpoint', models.CharField(help_text='URL of the CMIS endpoint', max_length=250, verbose_name='CMIS endpoint')),

                ('username', models.CharField(help_text='Username on DMS platform', max_length=128, verbose_name='Service username')),

                ('password', models.CharField(help_text='Password on DMS platform', max_length=128, verbose_name='Password')),

                ('users', models.ManyToManyField(to='base.ApiUser', blank=True)),

            ],

            options={

                'abstract': False,

            },

        ),

    ]

from cmislib import CmisClient

from cmislib.model import PermissionDeniedException, ObjectNotFoundException, UpdateConflictException, CmisException as CmisLibException

import json

import base64

import logging

from django.db import models

from passerelle.base.models import BaseResource

from passerelle.utils.api import endpoint

from django.utils.translation import ugettext_lazy as _

from django.http import HttpResponse

class CmisException(Exception):

    http_status = 200

    log_error = False

class CmisConnector(BaseResource):

    cmis_endpoint = models.CharField(max_length=250, verbose_name=_('CMIS endpoint'),

                                     help_text=_('URL of the CMIS endpoint'))

    username = models.CharField(max_length=128, verbose_name=_('Service username'), help_text=_('Username on DMS platform'))

    password = models.CharField(max_length=128,

                                verbose_name=_('Password'), help_text=_('Password on DMS platform'))

    category = _('Business Process Connectors')

    @classmethod

    def get_icon_class(cls):

        return 'ressources'

    @endpoint(serializer_type='json-api', methods=['post'])

    def upload_file(self, request, **kwargs):

        data = json.loads(request.body)

        title = data['filename']

        path = data['path'].encode('utf-8')

        content = base64.b64decode(data['content'])

        content_type = data['contentType']

        repo = self.cmis_connection()

        try:

            folder = repo.getObjectByPath(path)

        except ObjectNotFoundException:

            raise CmisException('Path not found on platform.')

        except Exception as e:

            raise CmisException(str(e))

        try:

            doc = folder.createDocumentFromString(title, contentString=content, contentType=content_type)

        except UpdateConflictException:

            raise CmisException('The document already exists on platform.')

        except Exception as e:

            raise CmisException(str(e))

        return doc.properties

    def cmis_connection(self):

        try:

            cmis_client = CmisClient(self.cmis_endpoint, self.username, self.password)

        except PermissionDeniedException:

            raise CmisException('Wrong username or password to connect to platform.')

        except ObjectNotFoundException:

            raise CmisException('Platform endpoint not found.')

        return cmis_client.defaultRepository

    'cmis',