onlyoffice / docs-integration-sdk-java Goto Github PK

private void transformWithSDK(final String sourceMimetype, final String targetMimetype, final Map<String, String> parameters,
    		final File sourceFile, final File targetFile, TransformManager transformManager) throws Exception
    {
    	logger.info("START TRANSFORMER SDK '"+this.getClass().getSimpleName());
    	String extensionSource = FilenameUtils.getExtension(sourceFile.getName());
    	String extensionTarget = FilenameUtils.getExtension(targetFile.getName());
    	String srcType = extensionSource;
    	String outType = extensionTarget;

    	String url = urlManager.getInnerDocumentServerUrl();
    	Security security = Security.builder()
    			.key(settingsManager.getSecurityKey())
    			.header(settingsManager.getSecurityHeader())
    			.prefix(settingsManager.getSecurityPrefix())
    			.build();

    	HttpClientSettings httpClientSettings = HttpClientSettings.builder()
    			.ignoreSSLCertificate(settingsManager.isIgnoreSSLCertificate())
    			.build();

    	String convertServiceUrl = settingsManager.getDocsIntegrationSdkProperties()
    			.getDocumentServer()
    			.getConvertService()
    			.getUrl();

    	ConvertRequest convertRequest = ConvertRequest.builder()
    			.async(false)
    			.filetype(srcType) // txt
    			.outputtype(outType) // docx
    			.key(new SimpleDateFormat("MMddyyyyHHmmss").format(new Date()))
    			.url(sourceFile.toURI().toURL().toString()) // ????? I MUS CREATE A GET SERVICE FOR ONLYOFFICE ???
    			.build();

    	requestManager.executePostRequest(
    			urlManager.sanitizeUrl(url) + convertServiceUrl,
    			convertRequest,
    			security,
    			httpClientSettings,
    			new RequestManager.Callback< ValidationResult>() {
    				public ValidationResult doWork(final Object response) throws Exception {
    					String content = IOUtils.toString(((HttpEntity) response).getContent(), "utf-8").trim();
    					JSONObject result = new JSONObject(content);

    					if (result.has("error")) {
    						Integer errorCode = result.getInt("error");

    						return ValidationResult.builder()
    								.status(Status.FAILED)
    								.error(ConvertResponse.Error.valueOfCode(errorCode))
    								.build();
    					}

    					String fileUrl = result.getString("fileUrl");

    					return requestManager.executeGetRequest(
    							fileUrl,
    							httpClientSettings,
    							new RequestManager.Callback<ValidationResult>() {
    								@Override
    								public ValidationResult doWork(final Object response) throws IOException {
    									byte[] bytes = EntityUtils.toByteArray((HttpEntity) response);
    									if (bytes.length > 0) {
    										
    										FileUtils.writeByteArrayToFile(targetFile, bytes);
    										
    										return ValidationResult.builder()
    												.status(Status.SUCCESS)
    												.build();
    									} else {
    										return ValidationResult.builder()
    												.status(Status.FAILED)
    												.error(CommonResponse.Error.DOWNLOAD_RESULT)
    												.build();
    									}
    								}
    							});

    				}
    			});

    	logger.info("END TRANSFORMER SDK '"+this.getClass().getSimpleName());
    }