Your achievements

Level 1

0% to

Level 2

Tip /
Sign in

Sign in to Community

to gain points, level up, and earn exciting badges like the new
Bedrock Mission!

Learn more

View all

Sign in to view all badges

AEM - Implement the methods of the interface | AEM Community Blog Seeding

kautuk_sahni
Community Manager
Community Manager

BlogImage.jpg

AEM - Implement the methods of the interface by Adobe Docs

Abstract

Interface implementation
The following is the complete code the class implementing the interface.

This class makes use of 2 utility methods getAccessToken, getJWTToken and static method getContentAnalyserRequest of GetContentAnalyser class.

package com.aemforms.doccloud.core.impl;
import java.io.BufferedInputStream;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.nio.charset.Charset;
import java.security.KeyFactory;
import java.security.interfaces.RSAPrivateKey;
import java.security.spec.KeySpec;
import java.security.spec.PKCS8EncodedKeySpec;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;

import javax.mail.BodyPart;
import javax.mail.internet.MimeMultipart;
import javax.mail.util.ByteArrayDataSource;
import org.apache.http.Consts;
import org.apache.http.HttpEntity;
import org.apache.http.HttpHost;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
import org.apache.http.client.HttpClient;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.mime.HttpMultipartMode;
import org.apache.http.entity.mime.MultipartEntityBuilder;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;
import org.apache.sling.api.resource.Resource;
import org.apache.sling.api.resource.ResourceResolver;
import org.osgi.service.component.annotations.Activate;
import org.osgi.service.component.annotations.Component;
import org.osgi.service.component.annotations.Reference;
import org.osgi.service.metatype.annotations.Designate;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.adobe.aemfd.docmanager.Document;
import com.aemforms.doccloud.core.DocumentCloudConfiguration;

import com.aemforms.doccloud.core.DocumentCloudSDKService;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import com.mergeandfuse.getserviceuserresolver.GetResolver;
import static io.jsonwebtoken.SignatureAlgorithm.RS256;
import io.jsonwebtoken.Jwts;

@Component

@Designate(ocd = DocumentCloudConfiguration.class)
public class DocumentCloudServiceImpl implements DocumentCloudSDKService {
private final Logger log = LoggerFactory.getLogger(getClass());
private static final String AUTH_ENDPOINT = "/ims/exchange/jwt/";
private static final String imsHost = "ims-na1.adobelogin.com";
private static final String CREATE_PDF_URL = "https://cpf-ue1.adobe.io/ops/:create?respondWith=%7B%22reltype%22%3A%20%22http%3A%2F%2Fns.adobe.com%2Frel%2Fprimary%22%7D";

private DocumentCloudConfiguration config;
@Reference
GetResolver getResolver;
@Activate
protected void activate(DocumentCloudConfiguration config) {
log.debug("####In my DocumentCloudServiceImpl activate method");
log.debug("clientID:" + config.getClientID() + "Tech ID: " + config.getTechnicalAccount());
this.config = config;

}
@Override
public Document getPDF(String location, String accessToken, String fileName) {
log.debug("In getting the converted pdf from " + location);
HttpGet httpGet = new HttpGet(location);
httpGet.addHeader("Authorization", "Bearer " + accessToken);
httpGet.addHeader("X-Api-Key", config.getClientID());
CloseableHttpClient httpclient = HttpClients.createDefault();
try {
HttpResponse response = httpclient.execute(httpGet);
System.out.println("$$$$ The response I got in Poll is " + response.getStatusLine().getStatusCode());
InputStream in = new BufferedInputStream(response.getEntity().getContent());
ByteArrayDataSource datasource = new ByteArrayDataSource( in , "multipart/form-data");
MimeMultipart multipart = new MimeMultipart(datasource);
int count = multipart.getCount();
log.debug("count " + count);
for (int i = 0; i<count; i++) {
BodyPart bodyPart = multipart.getBodyPart(i);
if (bodyPart.isMimeType("application/octet-stream")) {
System.out.println("The mime type is " + bodyPart.getContentType());
InputStream is = bodyPart.getInputStream();
Document convertedPDF = new Document(is);
if (log.isDebugEnabled()) {
String[] fileNameParts = fileName.split("\\.(?=[^\\.]+$)");
convertedPDF.copyToFile(new File(fileNameParts[0] + ".pdf"));
}
return convertedPDF;
}
}

} catch (Exception e) {

log.debug(e.getMessage());
}
return null;
}
@Override
public Document createPDFFromInputStream(InputStream is, String fileName) {
HttpPost httpPost = new HttpPost(CREATE_PDF_URL);
String accessToken = getAccessToken();
log.debug("The Access Token I got was " + accessToken);
httpPost.addHeader("Authorization", "Bearer " + getAccessToken());
httpPost.addHeader("X-Api-Key", config.getClientID());
log.debug("Got document to convert");
MultipartEntityBuilder builder = MultipartEntityBuilder.create();
ContentType strContent = ContentType.create("text/plain", Charset.forName("UTF-8"));
builder.setMode(HttpMultipartMode.BROWSER_COMPATIBLE);
builder.addBinaryBody("InputFile0", is);
builder.addTextBody("contentAnalyzerRequests", GetContentAnalyser.getContentAnalyserRequest(fileName), strContent);
try {
HttpEntity entity = builder.build();
httpPost.setEntity(entity);
CloseableHttpClient httpclient = HttpClients.createDefault();
HttpResponse response = httpclient.execute(httpPost);
log.debug("The response after sending document for conversion... was " + response.getStatusLine().getStatusCode());
log.debug("The location is " + response.getFirstHeader("location").getValue());
return getPDF(response.getFirstHeader("location").getValue(), accessToken, fileName);
} catch (IOException e) {

log.debug(e.getMessage());
}
return null;
}

private String getJWTToken() {
String CLIENT_ID = config.getClientID();

String METASCOPE_ID = config.getMetascope();
String TECH_ACCT = config.getTechnicalAccount();
String ORG_ID = config.getOrganizationID();

try {
ResourceResolver rr = getResolver.getServiceResolver();
Resource privateKeyRes = rr.getResource("/etc/key/documentcloud/private.key");
System.out.println("Got resource private key");
InputStream is = privateKeyRes.adaptTo(InputStream.class);
BufferedInputStream bis = new BufferedInputStream(is);
ByteArrayOutputStream buf = new ByteArrayOutputStream();
int result = bis.read();
while (result != -1) {
byte b = (byte) result;
buf.write(b);
result = bis.read();
}
String privatekeyString = buf.toString();
privatekeyString = privatekeyString.replaceAll("\\n", "").replace("-----BEGIN PRIVATE KEY-----", "").replace("-----END PRIVATE KEY-----", "");
log.debug("The sanitized private key string is " + privatekeyString);
KeyFactory keyFactory = KeyFactory.getInstance("RSA");
log.debug("The key factory algorithm is " + keyFactory.getAlgorithm());
byte[] byteArray = privatekeyString.getBytes();
log.debug("The array length is " + byteArray.length);
byte[] encodedBytes = javax.xml.bind.DatatypeConverter.parseBase64Binary(privatekeyString);
KeySpec ks = new PKCS8EncodedKeySpec(encodedBytes);
String metascopes[] = new String[] {
METASCOPE_ID
};
RSAPrivateKey privateKey = (RSAPrivateKey) keyFactory.generatePrivate(ks);
HashMap<String, Object> jwtClaims = new HashMap<>();
jwtClaims.put("iss", ORG_ID);
jwtClaims.put("sub", TECH_ACCT);
Long expirationTime = System.currentTimeMillis() / 1000 + 86400 L;
jwtClaims.put("exp", expirationTime);
jwtClaims.put("aud", "https://" + imsHost + "/c/" + CLIENT_ID);
for (String metascope: metascopes) {
jwtClaims.put("https://" + imsHost + "/s/" + metascope, java.lang.Boolean.TRUE);
}
String jwtToken = Jwts.builder().setClaims(jwtClaims).signWith(RS256, privateKey).compact();
return jwtToken;
} catch (Exception e) {
log.debug("Error in creating JWT Token " + e.getMessage());
}
return null;

}

public String getAccessToken() {

HttpClient httpClient = HttpClientBuilder.create().build();
HttpHost authServer = new HttpHost(imsHost, 443, "https");
HttpPost authPostRequest = new HttpPost(AUTH_ENDPOINT);
authPostRequest.addHeader("Cache-Control", "no-cache");
List params = new ArrayList ();
params.add(new BasicNameValuePair("client_id", config.getClientID()));
params.add(new BasicNameValuePair("client_secret", config.getClientSecret()));
params.add(new BasicNameValuePair("jwt_token", getJWTToken()));
authPostRequest.setEntity(new UrlEncodedFormEntity(params, Consts.UTF_8));
HttpResponse response;
try {
response = httpClient.execute(authServer, authPostRequest);
log.debug("$$$$$ " + response.getStatusLine().getStatusCode());
HttpEntity entity = response.getEntity();
JsonObject jsonResponse = new JsonParser().parse(EntityUtils.toString(entity)).getAsJsonObject();
log.debug("Returning access_token " + jsonResponse.get("access_token").getAsString());
return jsonResponse.get("access_token").getAsString();

} catch (IOException e) {
log.debug("Error in generating access token " + e.getMessage());
}
return null;

}

}

Read Full Blog

AEM - Implement the methods of the interface

Q&A

Please use this thread to ask the related questions.

Topics

Topics help categorize Community content and increase your ability to discover relevant content.

0 Replies