Javacryptolibilp

pom.xml

@@ -1,4 +1,4 @@
-<?xml version="1.0" encoding="UTF-8"?>
+<?xml version="1.0" encoding="UTF-8" standalone="no"?>
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
 
 	<modelVersion>4.0.0</modelVersion>
@@ -21,7 +21,8 @@
 
 	<properties>
 		<interop-domain.version>0.1.32</interop-domain.version>
-	</properties>
+	<mule.version>3.8.0</mule.version>
+    </properties>
 
 	<dependencies>
 		<dependency>
@@ -78,6 +79,14 @@
 			<version>1.3</version>
 			<scope>test</scope>
 		</dependency> 
+
+		<dependency>
+            <groupId>org.interledger</groupId>
+            <artifactId>java-ilp-core</artifactId>
+            <version>0.5.0-SNAPSHOT</version>
+        </dependency>
+
+
 	</dependencies>
 
 </project>

src/main/app/scheme-adapter.xml

@@ -17,6 +17,9 @@ http://www.springframework.org/schema/beans http://www.springframework.org/schem
 		doc:name="ILP-Service HTTP Request Configuration" responseTimeout="30000" />
 	<http:request-config name="dfsp-api-http-config" host="${dfsp-host}" port="${dfsp-api.port}"
 		doc:name="DFSP API Config" responseTimeout="30000" />
+    <spring:beans>
+        <spring:bean id="ilpCryptoLib" name="IlpCryptoLibBean" class="com.l1p.interop.scheme.adapter.IlpCryptoLib"/>
+    </spring:beans>
 
 	<!-- <spring:beans> <spring:bean id="sideCarClient" class="com.l1p.interop.scheme.adapter.SideCarClient"> 
 		<spring:constructor-arg value="${sidecar-server.host}" /> <spring:constructor-arg value="${sidecar-server.port}" 
@@ -93,7 +96,7 @@ http://www.springframework.org/schema/beans http://www.springframework.org/schem
 						<set-session-variable variableName="payeeUrl" value="#[payload.payee.url]"
 							doc:name="Save Input Receiver URL" />
 						<json:object-to-json-transformer doc:name="Object to JSON" />
-						<set-property propertyName="initiator" value="PROXY"></set-property>
+						<set-property propertyName="initiator" value="PROXY" doc:name="Property"></set-property>
 						<logger level="INFO"
 							message="Posting request to scheme-adapter /quotes to http://#[sessionVars.payeeUrl]/quotes, method=POST, Payload: #[payload]"
 							category="com.l1p.interop.scheme.adapter.quote" doc:name="logger" />
@@ -216,7 +219,7 @@ http://www.springframework.org/schema/beans http://www.springframework.org/schem
 											expression="#[sessionVars.originalQuoteRequestMap.get(&quot;amount&quot;).put(&quot;amount&quot;,sessionVars.destinationAmount);  sessionVars.originalQuoteRequestMap]"
 											doc:name="Update dfsp request with destination amount from ilp-service /quoteSourceAmount" />
 										<json:object-to-json-transformer doc:name="Object to JSON" />
-										<set-property propertyName="initiator" value="PROXY"></set-property>
+										<set-property propertyName="initiator" value="PROXY" doc:name="Property"></set-property>
 										<logger level="INFO"
 											message="Posting request to scheme-adapter /quotes http://#[sessionVars.payeeUrl]/quotes, method=POST Payload: #[payload]"
 											category="com.l1p.interop.scheme.adapter.quote" doc:name="logger" />
@@ -342,6 +345,9 @@ http://www.springframework.org/schema/beans http://www.springframework.org/schem
 				<logger level="INFO"
 					message="Posting ILP Service request for L1p-Trace-Id=#[sessionVars.'L1p-Trace-Id'] to http://${ilp-host}:${ilp-service.port}/createIPR, method=post Payload: #[payload]"
 					category="com.l1p.interop.scheme.adapter.quote" doc:name="logger" />
+                <set-variable variableName="tmpVar" value="#[payload]" doc:name="TmpVar"/>
+                <expression-component doc:name="IlpCryptoLibExpression"><![CDATA[flowVars.tmpVar = app.registry.ilpCryptoLib.cryptoEncode(sessionVars.payeeLedgerAccount, sessionVars.destinationAmount)]]></expression-component>
+                <logger message="TmpVar: #[flowVars.tmpVar]" level="INFO" doc:name="Logger"/>
 				<http:request config-ref="ilp-service-http-config" path="/createIPR" method="POST"
 					doc:name="Call ilp-service /createIPR">
 					<http:success-status-code-validator values="200..599" />

src/main/java/com/l1p/interop/scheme/adapter/IlpCryptoLib.java

@@ -0,0 +1,57 @@
+package com.l1p.interop.scheme.adapter;
+
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.time.ZonedDateTime;
+import java.util.Base64;
+import java.util.UUID;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+
+import org.interledger.InterledgerAddress;
+import org.interledger.InterledgerAddressBuilder;
+import org.interledger.codecs.CodecContext;
+import org.interledger.codecs.CodecContextFactory;
+import org.interledger.ipr.InterledgerPaymentRequest;
+import org.interledger.ipr.InterledgerPaymentRequestBuilder;
+
+public class IlpCryptoLib {
+
+	private static Logger log = LogManager.getLogger(IlpCryptoLib.class);
+
+	public String cryptoEncode (String destAddr, String destAmnt){
+
+		log.info("received destination address: " + destAddr + " and destination amount: " + destAmnt);
+
+		InterledgerAddress destinationAddress = InterledgerAddressBuilder.builder().value(destAddr).build();
+	    long destinationAmount = Long.parseLong(destAmnt);
+	    ZonedDateTime expiresAt = ZonedDateTime.now().plusMinutes(1);
+	    byte[] receiverSecret = new byte[32];
+	    String paymentId = UUID.randomUUID().toString();
+
+	    InterledgerPaymentRequestBuilder builder = new InterledgerPaymentRequestBuilder(
+	        destinationAddress,
+	        destinationAmount,
+	        expiresAt,
+	        receiverSecret);
+
+	    builder.setEncrypted(false);
+	    builder.getPskMessageBuilder().addPublicHeader("Payment-Id", paymentId);
+
+	    CodecContext context = CodecContextFactory.interledger();
+	    ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
+
+	    try {
+	      context.write(InterledgerPaymentRequest.class, builder.getIpr(), outputStream);
+	    } catch (IOException e) {
+	      throw new RuntimeException("Error encoding Interledger Packet Request.", e);
+	    }
+
+	    String cryptoEncode = Base64.getUrlEncoder().encodeToString(outputStream.toByteArray());
+
+	    log.info("returning the following crypto encode value: " + cryptoEncode);
+
+	    return cryptoEncode;
+	}
+
+}