Package ca.carleton.gcrc.couch.onUpload.conversion

Examples of ca.carleton.gcrc.couch.onUpload.conversion.AttachmentDescriptor


    FileConversionContext conversionContext =
      new FileConversionContextImpl(work,documentDbDesign,mediaDir);

    DocumentDescriptor docDescriptor = conversionContext.getDocument();

    AttachmentDescriptor attDescription = null;
    if( docDescriptor.isAttachmentDescriptionAvailable(attachmentName) ){
      attDescription = docDescriptor.getAttachmentDescription(attachmentName);
    }

    if( null == attDescription ) {
      logger.info("Approved object not found");

    } else if( false == UploadConstants.UPLOAD_STATUS_ATTACHED.equals( attDescription.getStatus() ) ) {
      logger.info("File not in attached state");

    } else {
      ServerWorkDescriptor serverDescription = attDescription.getServerWorkDescription();
      int orientationLevel = serverDescription.getOrientationLevel();
     
      if( orientationLevel >= UploadConstants.SERVER_ORIENTATION_VALUE ) {
        logger.info("Orientation work already done");
      } else {
        boolean pluginFound = false;
        String fileClass = attDescription.getFileClass();
        for(FileConversionPlugin fcp : this.fileConverters) {
          if( fcp.handlesFileClass(fileClass, FileConversionPlugin.WORK_ORIENT) ) {
            fcp.performWork(FileConversionPlugin.WORK_ORIENT, attDescription);
            pluginFound = true;
            break;
View Full Code Here


    FileConversionContext conversionContext =
      new FileConversionContextImpl(work,documentDbDesign,mediaDir);

    DocumentDescriptor docDescriptor = conversionContext.getDocument();

    AttachmentDescriptor attDescription = null;
    if( docDescriptor.isAttachmentDescriptionAvailable(attachmentName) ){
      attDescription = docDescriptor.getAttachmentDescription(attachmentName);
    }

    if( null == attDescription ) {
      logger.info("Approved object not found");

    } else if( false == UploadConstants.UPLOAD_STATUS_ATTACHED.equals( attDescription.getStatus() ) ) {
      logger.info("File not in attached state");

    } else {
      ServerWorkDescriptor serverDescription = attDescription.getServerWorkDescription();
      String thumbnailReference = attDescription.getThumbnailReference();
      int thumbnailLevel = serverDescription.getThumbnailLevel();
     
      if( thumbnailLevel >= UploadConstants.SERVER_THUMBNAIL_VALUE ) {
        logger.info("Orientation work already done");
 
      } else if( null != thumbnailReference ) {
        // This is an instance where the thumbnail was already
        // created but the server work was not noted. This happens
        // with legacy documents.
        // In this case, update server work and save document.
        serverDescription.setThumbnailLevel(UploadConstants.SERVER_THUMBNAIL_VALUE);
       
        // Update status
        conversionContext.saveDocument();
       
        logger.info("Updated server thumbnail status");

      } else {

        boolean pluginFound = false;
        String fileClass = attDescription.getFileClass();
        for(FileConversionPlugin fcp : this.fileConverters) {
          if( fcp.handlesFileClass(fileClass, FileConversionPlugin.WORK_THUMBNAIL) ) {
            fcp.performWork(FileConversionPlugin.WORK_THUMBNAIL, attDescription);
            pluginFound = true;
           
View Full Code Here

    FileConversionContext conversionContext =
      new FileConversionContextImpl(work,documentDbDesign,mediaDir);

    DocumentDescriptor docDescriptor = conversionContext.getDocument();

    AttachmentDescriptor attDescription = null;
    if( docDescriptor.isAttachmentDescriptionAvailable(attachmentName) ){
      attDescription = docDescriptor.getAttachmentDescription(attachmentName);
    }

    if( null == attDescription ) {
      throw new Exception("Approved object not found");

    } else if( false == UploadConstants.UPLOAD_STATUS_ATTACHED.equals( attDescription.getStatus() ) ) {
      throw new Exception("File not in attached state");

    } else {
      WorkDescriptor workDescription = attDescription.getWorkDescription();

      boolean pluginFound = false;
      String fileClass = attDescription.getFileClass();
      for(FileConversionPlugin fcp : this.fileConverters) {
        if( fcp.handlesFileClass(fileClass, FileConversionPlugin.WORK_UPLOAD_ORIGINAL) ) {
          fcp.performWork(FileConversionPlugin.WORK_UPLOAD_ORIGINAL, attDescription);
          pluginFound = true;
         
View Full Code Here

    FileConversionContext conversionContext =
      new FileConversionContextImpl(work,documentDbDesign,mediaDir);

    DocumentDescriptor docDescriptor = conversionContext.getDocument();

    AttachmentDescriptor attDescription = null;
    if( docDescriptor.isAttachmentDescriptionAvailable(attachmentName) ){
      attDescription = docDescriptor.getAttachmentDescription(attachmentName);
    }

    if( null == attDescription ) {
      throw new Exception("Approved object not found");

    } else if( false == UploadConstants.UPLOAD_STATUS_ATTACHED.equals( attDescription.getStatus() ) ) {
      throw new Exception("File not in attached state");

    } else {
      WorkDescriptor workDescription = attDescription.getWorkDescription();

      boolean pluginFound = false;
      String fileClass = attDescription.getFileClass();
      for(FileConversionPlugin fcp : this.fileConverters) {
        if( fcp.handlesFileClass(fileClass, workType) ) {
          fcp.performWork(workType, attDescription);
          pluginFound = true;
         
View Full Code Here

      new FileConversionContextImpl(work,documentDbDesign,mediaDir);
   
    DocumentDescriptor docDescriptor = conversionContext.getDocument();
   
    String uploadId = work.getUploadId();
    AttachmentDescriptor attDescription = docDescriptor.findAttachmentWithUploadId(uploadId);
   
    String uploadRequestDocId = work.getUploadRequestDocId();
    JSONObject uploadRequestDoc = documentDbDesign.getDatabase().getDocument(uploadRequestDocId);
   
    attDescription.remove();
   
    JSONObject uploadRequest = uploadRequestDoc.getJSONObject("nunaliit_upload_request");
    JSONArray files = uploadRequest.getJSONArray("files");
   
    for(int i=0,e=files.length(); i<e; ++i){
      JSONObject file = files.getJSONObject(i);
     
      String attachmentName = file.getString("attachmentName");
      String originalName = file.getString("originalName");
      String submitter = file.getString("submitter");
      JSONObject original = file.getJSONObject("original");
      JSONObject data = file.getJSONObject("data");
     
      String effectiveAttachmentName = attachmentName;
      if( docDescriptor.isAttachmentDescriptionAvailable(effectiveAttachmentName) ) {
        // Select a different file name
        String prefix = "";
        String suffix = "";
        int pos = attachmentName.indexOf('.', 1);
        if( pos < 0 ) {
          prefix = attachmentName;
        } else {
          prefix = attachmentName.substring(0, pos-1);
          suffix = attachmentName.substring(pos);
        }
        int counter = 0;
        while( docDescriptor.isAttachmentDescriptionAvailable(effectiveAttachmentName) ) {
          attachmentName = prefix + counter + suffix;
          ++counter;
        }
      }
     
      AttachmentDescriptor requestAttachment =
          docDescriptor.getAttachmentDescription(effectiveAttachmentName);
      requestAttachment.setStatus(UploadConstants.UPLOAD_STATUS_SUBMITTED);
      requestAttachment.setOriginalName(originalName);
      requestAttachment.setSubmitterName(submitter);
      requestAttachment.setUploadId(uploadId);
     
      JSONObject jsonAtt = requestAttachment.getJson();
      jsonAtt.put("original", original);
      jsonAtt.put("data", data);
    }
   
    // Save document
View Full Code Here

    FileConversionContext conversionContext =
      new FileConversionContextImpl(work,documentDbDesign,mediaDir);
   
    DocumentDescriptor docDescriptor = conversionContext.getDocument();
   
    AttachmentDescriptor attDescription = null;
    if( docDescriptor.isAttachmentDescriptionAvailable(attachmentName) ){
      attDescription = docDescriptor.getAttachmentDescription(attachmentName);
    }
   
    if( null == attDescription ) {
      logger.info("Submission can not be found");

    } else if( false == UploadConstants.UPLOAD_STATUS_SUBMITTED.equals( attDescription.getStatus() ) ) {
      logger.info("File not in submit state");
     
    } else {
      OriginalFileDescriptor originalObj = attDescription.getOriginalFileDescription();
     
      if( null == originalObj) {
        logger.error("Submission does not contain original");
        throw new Exception("Submission does not contain original");
     

      File file = originalObj.getMediaFile();
      if( null == file ){
        logger.error("No media file reported");
        throw new Exception("No media file reported");
      }
      if( false == file.exists() || false == file.isFile() ){
        logger.error(""+file.getAbsolutePath()+" is not a file.");
        throw new Exception(""+file.getAbsolutePath()+" is not a file.");
      };

      // Set file size
      long fileSize = file.length();
      originalObj.setSize(fileSize);

      // Mime type, encoding type and file class
      boolean pluginFound = false;
      String mimeType = null;
      String mimeEncoding = null;
      String fileClass = null;
      for(FileConversionPlugin fcp : this.fileConverters) {
        FileConversionMetaData md = fcp.getFileMetaData(file);
        if( md.isFileConvertable() ) {
          mimeType = md.getMimeType();
          fileClass = md.getFileClass();
          mimeEncoding = md.getMimeEncoding();
 
          pluginFound = true;
          break;
        }
      }
      if( false == pluginFound ) {
        logger.info("No plugin found for uploaded file");
       
        SystemFile sf = SystemFile.getSystemFile(file);
        mimeType = sf.getMimeType();
        mimeEncoding = sf.getMimeEncoding();
      }
      if( null != mimeType ) {
        originalObj.setContentType(mimeType);
      }
      if( null != mimeEncoding ) {
        originalObj.setEncodingType(mimeEncoding);
      }
      if( null != fileClass ){
        attDescription.setFileClass(fileClass);
      }

      // Update status
      attDescription.setStatus(UploadConstants.UPLOAD_STATUS_ANALYZED);
      conversionContext.saveDocument();
    }
  }
View Full Code Here

    if( request.isThumbnailCreated() ) {
      File thumbFile = request.getThumbnailFile();
      SystemFile thumbSf = SystemFile.getSystemFile(thumbFile);
     
      String thumbnailAttachmentName = computeThumbnailName(attDescription.getAttachmentName(),"jpeg");
      AttachmentDescriptor thumbnailObj = docDescriptor.getAttachmentDescription(thumbnailAttachmentName);

      if( CouchNunaliitUtils.hasVetterRole(submitter, atlasName) ) {
        thumbnailObj.setStatus(UploadConstants.UPLOAD_STATUS_APPROVED);
      } else {
        thumbnailObj.setStatus(UploadConstants.UPLOAD_STATUS_WAITING_FOR_APPROVAL);
      }
      thumbnailObj.setFileClass("image");
      thumbnailObj.setOriginalName(attDescription.getOriginalName());
      thumbnailObj.setMediaFileName(thumbFile.getName());
      thumbnailObj.setSource(attDescription.getAttachmentName());

      thumbnailObj.setSize(thumbFile.length());
      thumbnailObj.setContentType(thumbSf.getMimeType());
      thumbnailObj.setEncodingType(thumbSf.getMimeEncoding());

      if( request.getThumbnailHeight() != 0 && request.getThumbnailWidth() != 0 ) {
        thumbnailObj.setHeight(request.getThumbnailHeight());
        thumbnailObj.setWidth(request.getThumbnailWidth());
      }

      attDescription.setThumbnailReference(thumbnailAttachmentName);
    }
  }
View Full Code Here

    } else if( false == UploadConstants.UPLOAD_STATUS_SUBMITTED.equals( conversionContext.getAttachmentDescription().getStatus() ) ) {
      logger.info("File not in submit state");
     
    } else {
      AttachmentDescriptor attDescription = conversionContext.getAttachmentDescription();
      OriginalFileDescriptor originalObj = attDescription.getOriginalFileDescription();
     
      if( null == originalObj) {
        logger.error("Submission does not contain original");
        throw new Exception("Submission does not contain original");
     

      File file = originalObj.getMediaFile();
      if( null == file ){
        logger.error("No media file reported");
        throw new Exception("No media file reported");
      }
      if( false == file.exists() || false == file.isFile() ){
        logger.error(""+file.getAbsolutePath()+" is not a file.");
        throw new Exception(""+file.getAbsolutePath()+" is not a file.");
      };

      // Set file size
      long fileSize = file.length();
      originalObj.setSize(fileSize);

      // Mime type, encoding type and file class
      boolean pluginFound = false;
      String mimeType = null;
      String mimeEncoding = null;
      String fileClass = null;
      for(FileConversionPlugin fcp : this.fileConverters) {
        FileConversionMetaData md = fcp.getFileMetaData(file);
        if( md.isFileConvertable() ) {
          mimeType = md.getMimeType();
          fileClass = md.getFileClass();
          mimeEncoding = md.getMimeEncoding();
 
          pluginFound = true;
          break;
        }
      }
      if( false == pluginFound ) {
        logger.info("No plugin found for uploaded file");
       
        SystemFile sf = SystemFile.getSystemFile(file);
        mimeType = sf.getMimeType();
        mimeEncoding = sf.getMimeEncoding();
      }
      if( null != mimeType ) {
        originalObj.setContentType(mimeType);
      }
      if( null != mimeEncoding ) {
        originalObj.setEncodingType(mimeEncoding);
      }
      if( null != fileClass ){
        attDescription.setFileClass(fileClass);
      }

      // Update status
      attDescription.setStatus(UploadConstants.UPLOAD_STATUS_ANALYZED);
      conversionContext.saveDocument();
    }
  }
View Full Code Here

      throw new Exception("Plugin does not support work: "+work);
    }
  }

  public void analyzeFile(FileConversionContext conversionContext) throws Exception {
    AttachmentDescriptor attDescription = conversionContext.getAttachmentDescription();
    OriginalFileDescriptor originalObj = attDescription.getOriginalFileDescription();
    CouchUserContext submitter = attDescription.getSubmitter();
   
    // Figure out media file located on disk
    File originalFile = originalObj.getMediaFile();
    String mimeType = originalObj.getContentType();

    // Perform conversion(s)
    MultimediaConversionRequest request = new MultimediaConversionRequest();
    request.setInFile( originalFile );
    request.setThumbnailRequested(true);
    request.setProgress( new UploadProgressAdaptor() );
   
    MultimediaClass mmClass = MimeUtils.getMultimediaClassFromMimeType(mimeType);
    if( MultimediaClass.VIDEO == mmClass ) {
      // For video file, convert to appropriate file type
      mmConverter.convertVideo(request);

    } else if( MultimediaClass.AUDIO == mmClass ) {
      // For audio file, convert to appropriate file type
      mmConverter.convertAudio(request);
     
    } else if( MultimediaClass.IMAGE == mmClass ) {
      // For image file, convert to appropriate file type
      mmConverter.convertImage(request);
     
    } else {
      throw new Exception("Unknown multimedia class: "+mmClass);
    }
   
    // Compute a new name for the attachment, to reflect the conversion
    {
      String expectedExtension = "";
      if( null != request.getOutFile() ){
        File convertedFile = request.getOutFile();
        String name = convertedFile.getName();
        int index = name.lastIndexOf('.');
        if( index > 0 ){
          expectedExtension = name.substring(index+1);
        }
      }
     
      String currentPrefix = attDescription.getAttachmentName();
      String currentExtension = "";
      {
        int index = currentPrefix.lastIndexOf('.');
        if( index > 0 ){
          currentExtension = currentPrefix.substring(index+1);
          currentPrefix = currentPrefix.substring(0, index);
        }
      }
     
      if( false == currentExtension.equals(expectedExtension) ){
        // Must rename
        String newAttachmentName = currentPrefix + "." + expectedExtension;
       
        // Check collision
        int index = 0;
        while( conversionContext.isAttachmentDescriptionAvailable(newAttachmentName) ){
          newAttachmentName = currentPrefix + "_" + index + "." + expectedExtension;
          ++index;
        }
       
        attDescription.renameAttachmentTo(newAttachmentName);
      }
    }
   
    // Report original size
    if( request.getInHeight() != 0 && request.getInWidth() != 0 ) {
      originalObj.setHeight( request.getInHeight() );
      originalObj.setWidth( request.getInWidth() );
    }
   
    // Report EXIF data
    ExifData exifData = request.getExifData();
    if( null != exifData
     && exifData.getSize() > 0 ) {
      ExifDataDescriptor exifDescriptor = attDescription.getExifDataDescription();
      for(String key : exifData.getKeys()){
        String value = exifData.getRawData(key);
        if( null != value ){
          value = value.trim();
          if( false == "".equals(value) ){
            exifDescriptor.addData(key, value);
          }
        }
      }
     
      // Create geometry if one is present in the EXIF
      // data and none is defined in the document
      if( exifData.containsLongLat()
       && false == conversionContext.isGeometryDescriptionAvailable() ) {
       
        Point point = new Point(exifData.computeLong(),exifData.computeLat());
        MultiPoint mp = new MultiPoint();
        mp.addPoint(point);
       
        GeometryDescriptor geomDesc = conversionContext.getGeometryDescription();
        geomDesc.setGeometry(mp);
      }
    }

    // Report converted object
    {
      File convertedFile = request.getOutFile();
      SystemFile convertedSf = SystemFile.getSystemFile(convertedFile);

      if( CouchNunaliitUtils.hasVetterRole(submitter, atlasName) ) {
        attDescription.setStatus(UploadConstants.UPLOAD_STATUS_APPROVED);
      } else {
        attDescription.setStatus(UploadConstants.UPLOAD_STATUS_WAITING_FOR_APPROVAL);
      }
      attDescription.setConversionPerformed(request.isConversionPerformed());
      attDescription.setMediaFileName(convertedFile.getName());
      attDescription.setSize(convertedFile.length());
      attDescription.setContentType(convertedSf.getMimeType());
      attDescription.setEncodingType(convertedSf.getMimeEncoding());
      if( request.getOutHeight() != 0 && request.getOutWidth() != 0 ) {
        attDescription.setHeight(request.getOutHeight());
        attDescription.setWidth(request.getOutWidth());
      }
     
      ServerWorkDescriptor serverWork = attDescription.getServerWorkDescription();
      serverWork.setOrientationLevel(UploadConstants.SERVER_ORIENTATION_VALUE);
    }

    // Report thumbnail object
    if( request.isThumbnailCreated() ) {
      File thumbFile = request.getThumbnailFile();
      SystemFile thumbSf = SystemFile.getSystemFile(thumbFile);
     
      String thumbExtension = "";
      {
        String name = thumbFile.getName();
        int index = name.lastIndexOf('.');
        if( index > 0 ){
          thumbExtension = name.substring(index+1);
        }
      }
     
      String thumbnailAttachmentName = computeThumbnailName(attDescription.getAttachmentName(),thumbExtension);
      AttachmentDescriptor thumbnailObj = conversionContext.getAttachmentDescription(thumbnailAttachmentName);

      if( CouchNunaliitUtils.hasVetterRole(submitter, atlasName) ) {
        thumbnailObj.setStatus(UploadConstants.UPLOAD_STATUS_APPROVED);
      } else {
        thumbnailObj.setStatus(UploadConstants.UPLOAD_STATUS_WAITING_FOR_APPROVAL);
      }
      thumbnailObj.setFileClass("image");
      thumbnailObj.setOriginalName(attDescription.getOriginalName());
      thumbnailObj.setMediaFileName(thumbFile.getName());
      thumbnailObj.setSource(attDescription.getAttachmentName());

      thumbnailObj.setSize(thumbFile.length());
      thumbnailObj.setContentType(thumbSf.getMimeType());
      thumbnailObj.setEncodingType(thumbSf.getMimeEncoding());

      if( request.getThumbnailHeight() != 0 && request.getThumbnailWidth() != 0 ) {
        thumbnailObj.setHeight(request.getThumbnailHeight());
        thumbnailObj.setWidth(request.getThumbnailWidth());
      }

      attDescription.setThumbnailReference(thumbnailAttachmentName);
    }
   
    // Report original file
    if( request.isConversionPerformed() ) {
      // Original is not needed if no conversion performed
     
      String fileClass = attDescription.getFileClass();
      if( "image".equals(fileClass) && uploadOriginalImages ) {
        String originalAttachmentName = computeOriginalName(attDescription.getOriginalName());
        AttachmentDescriptor origDescription = conversionContext.getAttachmentDescription(originalAttachmentName);

        if( CouchNunaliitUtils.hasVetterRole(submitter, atlasName) ) {
          origDescription.setStatus(UploadConstants.UPLOAD_STATUS_APPROVED);
        } else {
          origDescription.setStatus(UploadConstants.UPLOAD_STATUS_WAITING_FOR_APPROVAL);
        }
        origDescription.setContentType(attDescription.getContentType());
        origDescription.setOriginalName(attDescription.getOriginalName());
        origDescription.setMediaFileName(originalFile.getName());
        origDescription.setSource(attDescription.getAttachmentName());

        origDescription.setSize(originalObj.getSize());
        origDescription.setContentType(originalObj.getContentType());
        origDescription.setEncodingType(originalObj.getEncodingType());

        origDescription.setHeight(originalObj.getHeight());
        origDescription.setWidth(originalObj.getWidth());

        ServerWorkDescriptor serverWork = origDescription.getServerWorkDescription();
        serverWork.setOrientationLevel(UploadConstants.SERVER_ORIENTATION_VALUE);

        attDescription.setOriginalAttachment(originalAttachmentName);
      }
    }
View Full Code Here

    } else if( false == UploadConstants.UPLOAD_STATUS_SUBMITTED_INLINE.equals( conversionContext.getAttachmentDescription().getStatus() ) ) {
      logger.info("File not in submit inline state");
     
    } else {
      AttachmentDescriptor attDescription = conversionContext.getAttachmentDescription();

      // Verify that a file is attached to the document
      if( false == attDescription.isFilePresent() ) {
        // Invalid state
        throw new Exception("Invalid state. A file must be present for submitted_inline");
      }
     
      // Download file
      File outputFile = File.createTempFile("inline", "", mediaDir);
      conversionContext.downloadFile(outputFile);
     
      // Create an original structure to point to the file in the
      // media dir. This way, when we go to "submitted" state, we will
      // be ready.
      OriginalFileDescriptor originalDescription = attDescription.getOriginalFileDescription();
      originalDescription.setMediaFileName(outputFile.getName());

      // Delete current attachment
      attDescription.removeFile();

      // Update status
      attDescription.setStatus(UploadConstants.UPLOAD_STATUS_SUBMITTED);
      conversionContext.saveDocument();
    }
  }
View Full Code Here

TOP

Related Classes of ca.carleton.gcrc.couch.onUpload.conversion.AttachmentDescriptor

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.