uploader.py

import ckan.logic as logic
from ckan.lib.uploader import ResourceUpload
from odsh_icap_client import ODSHICAPRequest

#import logging

#log = logging.getLogger(__name__)


class ODSHResourceUpload(ResourceUpload):

    def __init__(self, resource):
        #log.info("Resource({}) uploaded.".format(resource))
        super(ODSHResourceUpload, self).__init__(resource)
        if self._icap_virus_found():
            #log.info("Found Virus!")
            raise logic.ValidationError({'upload': ['Virus gefunden']})
        
    def _icap_virus_found(self):
        if self.filename and self.upload_file:
            response_object = ODSHICAPRequest(self.filename, self.upload_file).send()
            return response_object.virus_found()