Skip to content

Commit

Permalink
Wrap FilenetWebServiceClient send method with Try/Catch and throw e
Browse files Browse the repository at this point in the history 
Co-authored-by: Ben Calegari <bcalegari@codeforamerica.org>
Co-authored-by: Will Prew <william.prew@state.mn.us>
Co-authored-by: Andrew Edstrom <aedstrom@codeforamerica.org>
  • Loading branch information
@spokenbird @bencalegari
@williamprew @andrewedstrom
4 people committed Dec 8, 2021
1 parent 1fad64c commit ac95123
Showing 1 changed file with 65 additions and 52 deletions.
117 changes: 65 additions & 52 deletions src/main/java/org/codeforamerica/shiba/mnit/FilenetWebServiceClient.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -87,68 +87,81 @@ public FilenetWebServiceClient(
public void send(ApplicationFile applicationFile, RoutingDestination routingDestination,
String applicationNumber,
Document applicationDocument, FlowType flowType) {
MDC.put("applicationFile", applicationFile.getFileName());
CreateDocument createDocument = new CreateDocument();
createDocument.setRepositoryId("Programs");
setPropertiesOnDocument(applicationFile, routingDestination, applicationNumber,
applicationDocument, flowType, createDocument);
setContentStreamOnDocument(applicationFile, createDocument);
try {
MDC.put("applicationFile", applicationFile.getFileName());
CreateDocument createDocument = new CreateDocument();
createDocument.setRepositoryId("Programs");
setPropertiesOnDocument(applicationFile, routingDestination, applicationNumber,
applicationDocument, flowType, createDocument);
setContentStreamOnDocument(applicationFile, createDocument);

// Create the document in Filenet
CreateDocumentResponse response = (CreateDocumentResponse) filenetWebServiceTemplate.marshalSendAndReceive(createDocument, message -> {
SOAPMessage soapMessage = ((SaajSoapMessage) message).getSaajMessage();
try {
SOAPHeader soapHeader = soapMessage.getSOAPHeader();
QName securityQName = new QName(
"http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-secext-1.0.xsd",
"Security", "wsse");
QName timestampQName = new QName(
"http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-utility-1.0.xsd",
"Timestamp", "wsu");
SOAPHeaderElement securityElement = soapHeader.addHeaderElement(securityQName);
// Create the document in Filenet
CreateDocumentResponse response = (CreateDocumentResponse) filenetWebServiceTemplate
.marshalSendAndReceive(createDocument, message -> {
SOAPMessage soapMessage = ((SaajSoapMessage) message).getSaajMessage();
try {
SOAPHeader soapHeader = soapMessage.getSOAPHeader();
QName securityQName = new QName(
"http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-secext-1.0.xsd",
"Security", "wsse");
QName timestampQName = new QName(
"http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-utility-1.0.xsd",
"Timestamp", "wsu");
SOAPHeaderElement securityElement = soapHeader.addHeaderElement(securityQName);

SOAPElement timestampElement = securityElement.addChildElement(timestampQName);
SOAPElement createdElement = timestampElement.addChildElement("Created", "wsu");
ZonedDateTime createdTimestamp = ZonedDateTime.now(clock);
createdElement.setTextContent(createdTimestamp.format(DateTimeFormatter.ISO_INSTANT));
SOAPElement expiresElement = timestampElement.addChildElement("Expires", "wsu");
expiresElement
.setTextContent(createdTimestamp.plusMinutes(5).format(DateTimeFormatter.ISO_INSTANT));
SOAPElement timestampElement = securityElement.addChildElement(timestampQName);
SOAPElement createdElement = timestampElement.addChildElement("Created", "wsu");
ZonedDateTime createdTimestamp = ZonedDateTime.now(clock);
createdElement.setTextContent(createdTimestamp.format(DateTimeFormatter.ISO_INSTANT));
SOAPElement expiresElement = timestampElement.addChildElement("Expires", "wsu");
expiresElement
.setTextContent(
createdTimestamp.plusMinutes(5).format(DateTimeFormatter.ISO_INSTANT));

SOAPElement usernameTokenElement = securityElement.addChildElement("UsernameToken", "wsse");
SOAPElement usernameElement = usernameTokenElement.addChildElement("Username", "wsse");
usernameElement.setTextContent(username);
SOAPElement passwordElement = usernameTokenElement.addChildElement("Password", "wsse");
passwordElement.addAttribute(NameImpl.createFromUnqualifiedName("Type"),
"http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-username-token-profile-1.0#PasswordText");
passwordElement.setTextContent(password);
} catch (SOAPException e) {
SOAPElement usernameTokenElement = securityElement
.addChildElement("UsernameToken", "wsse");
SOAPElement usernameElement = usernameTokenElement
.addChildElement("Username", "wsse");
usernameElement.setTextContent(username);
SOAPElement passwordElement = usernameTokenElement
.addChildElement("Password", "wsse");
passwordElement.addAttribute(NameImpl.createFromUnqualifiedName("Type"),
"http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-username-token-profile-1.0#PasswordText");
passwordElement.setTextContent(password);
} catch (SOAPException e) {
logErrorToSentry(e, applicationFile, routingDestination, applicationNumber,
applicationDocument,
flowType);
}
});

// Now route a copy of the document from Filenet to SFTP
String idd = response.getObjectId();
log.info("response from FileNet createDocument: " + idd);
String routerRequest = String.format("%s/%s", routerUrl, idd);
try {
String routerResponse = restTemplate.getForObject(routerRequest, String.class);
JsonObject jsonObject = new Gson().fromJson(routerResponse, JsonObject.class);
JsonElement messageElement = jsonObject.get("message");
if (messageElement.isJsonNull()
|| messageElement.getAsString().compareToIgnoreCase("Success") != 0) {
String eMessage = String
.format("The MNIT Router did not respond with a \"Success\" message for %s", idd);
throw new Exception(eMessage);
}
} catch (Exception e) {
logErrorToSentry(e, applicationFile, routingDestination, applicationNumber,
applicationDocument,
flowType);
}
});

// Now route a copy of the document from Filenet to SFTP
String idd = response.getObjectId();
log.info("response from FileNet createDocument: " + idd);
String routerRequest = String.format("%s/%s", routerUrl, idd);
try {
String routerResponse = restTemplate.getForObject(routerRequest, String.class);
JsonObject jsonObject = new Gson().fromJson(routerResponse, JsonObject.class);
JsonElement messageElement = jsonObject.get("message");
if (messageElement.isJsonNull() || messageElement.getAsString().compareToIgnoreCase("Success") != 0) {
String eMessage = String.format("The MNIT Router did not respond with a \"Success\" message for %s", idd);
throw new Exception(eMessage);
}
applicationRepository.updateStatus(applicationNumber, applicationDocument, routingDestination,
DELIVERED);
} catch (Exception e) {
logErrorToSentry(e, applicationFile, routingDestination, applicationNumber,
applicationDocument,
flowType);
logErrorToSentry(e, applicationFile, routingDestination, applicationNumber,
applicationDocument, flowType);
throw e;
}

applicationRepository.updateStatus(applicationNumber, applicationDocument, routingDestination,
DELIVERED);
}

@Recover
Expand Down

0 comments on commit ac95123

Please sign in to comment.