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')),

                ('login', models.CharField(help_text='Login for user on platform', max_length=128, verbose_name='Service login')),

                ('password', models.CharField(help_text='Password for user on plateform', max_length=128, verbose_name='Password')),

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

            ],

            options={

                'abstract': False,

            },

        ),

    ]

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

from __future__ import unicode_literals

from django.db import models, migrations

import datetime

from django.utils.timezone import utc

class Migration(migrations.Migration):

    dependencies = [

        ('cmis', '0001_initial'),

    ]

    operations = [

        migrations.RemoveField(

            model_name='cmisconnector',

            name='login',

        ),

        migrations.AddField(

            model_name='cmisconnector',

            name='username',

            field=models.CharField(default=datetime.datetime(2016, 8, 24, 8, 14, 37, 83586, tzinfo=utc), help_text='Username on DMS platform', max_length=128, verbose_name='Service username'),

            preserve_default=False,

        ),

        migrations.AlterField(

            model_name='cmisconnector',

            name='password',

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

        ),

    ]

from cmislib import CmisClient

from cmislib.model import PermissionDeniedException, ObjectNotFoundException, 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

logger = logging.getLogger(__file__)

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')

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

        data = json.loads(request.body)

        title = data['filename']

        path = data['path']

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

        content_type = data['contentType']

        repo = self.cmis_connection()

        try:

            folder = repo.getObjectByPath(path)

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

        except ObjectNotFoundException:

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

        except Exception as e:

            raise CmisException(e.strerror)

    @endpoint(serializer_type='json-api')

    def download_file(self, request, path, **kwargs):

        repo = self.cmis_connection()

        try:

            doc = repo.getObjectByPath(path.encode('utf-8'))

            content_stream = doc.getContentStream()

        except ObjectNotFoundException:

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

        except CmisLibException:

            raise CmisException('Can\'t get the document stream content.')

        content = content_stream.read()

        contenttype = doc.properties['cmis:contentStreamMimeType']

        filename = doc.name

        response = HttpResponse(content, content_type=contenttype)

        response['Content-Disposition'] = 'attachment; filename="%s"' % filename

        return response

    def cmis_connection(self):

        try:

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

            repo = cmis_client.defaultRepository

        except PermissionDeniedException:

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

        except ObjectNotFoundException:

            raise CmisException('Platform endpoint not found.')

        return repo

    'cmis',