CorDapp Token-To-Friend

+ + +

In this example CorDapp, you will be able to issue your friend a token that carries a secret message. + You will receive the information of the tokenID and where the token is stored. Your friend would need these + information to retrieve the token and reveal the secret message.

If you are retrieving a token, please click the Retrieve Token button above to continue. ↗️

+ + +

Retrieve the Secret Message:

+ + Storage Node + + +

+ Token ID + +

+ + Recipient's Email Address + + +

+
+

+ +

+ + + + {this.state.callback != '' && +

Here is your query result:

{this.state.callback}

+ } + + + +

+ ); + } + } + + export default retrieveToken; diff --git a/Tokens/tokentofriend/clients/src/main/webapp/src/component/santaGameCreated.js b/Tokens/tokentofriend/clients/src/main/webapp/src/component/santaGameCreated.js new file mode 100644 index 00000000..b9041f24 --- /dev/null +++ b/Tokens/tokentofriend/clients/src/main/webapp/src/component/santaGameCreated.js @@ -0,0 +1,17 @@ +import 'bootstrap/dist/css/bootstrap.min.css'; + +import React from 'react'; +import Container from 'react-bootstrap/Container' + + +class santaGameCreated extends React.Component { + render(){ + return ( + + The Game is on! + + + ); + } +} +export default santaGameCreated; \ No newline at end of file diff --git a/Tokens/tokentofriend/clients/src/main/webapp/src/css/App.css b/Tokens/tokentofriend/clients/src/main/webapp/src/css/App.css new file mode 100644 index 00000000..30e84ac2 --- /dev/null +++ b/Tokens/tokentofriend/clients/src/main/webapp/src/css/App.css @@ -0,0 +1,19 @@ + +.App-header { + min-height: 100vh; + display: flex; + flex-direction: column; +} + +.App-link { + color: #61dafb; +} + +@keyframes App-logo-spin { + from { + transform: rotate(0deg); + } + to { + transform: rotate(360deg); + } +} diff --git a/Tokens/tokentofriend/clients/src/main/webapp/src/img/logo.svg b/Tokens/tokentofriend/clients/src/main/webapp/src/img/logo.svg new file mode 100644 index 00000000..6b60c104 --- /dev/null +++ b/Tokens/tokentofriend/clients/src/main/webapp/src/img/logo.svg @@ -0,0 +1,7 @@ + diff --git a/Tokens/tokentofriend/clients/src/main/webapp/src/index.css b/Tokens/tokentofriend/clients/src/main/webapp/src/index.css new file mode 100644 index 00000000..ec2585e8 --- /dev/null +++ b/Tokens/tokentofriend/clients/src/main/webapp/src/index.css @@ -0,0 +1,13 @@ +body { + margin: 0; + font-family: -apple-system, BlinkMacSystemFont, 'Segoe UI', 'Roboto', 'Oxygen', + 'Ubuntu', 'Cantarell', 'Fira Sans', 'Droid Sans', 'Helvetica Neue', + sans-serif; + -webkit-font-smoothing: antialiased; + -moz-osx-font-smoothing: grayscale; +} + +code { + font-family: source-code-pro, Menlo, Monaco, Consolas, 'Courier New', + monospace; +} diff --git a/Tokens/tokentofriend/clients/src/main/webapp/src/index.js b/Tokens/tokentofriend/clients/src/main/webapp/src/index.js new file mode 100644 index 00000000..758c5cfe --- /dev/null +++ b/Tokens/tokentofriend/clients/src/main/webapp/src/index.js @@ -0,0 +1,25 @@ +import React from 'react'; +import ReactDOM from 'react-dom'; +import './index.css'; +import retrieveToken from './component/retrieveToken'; +import App from './component/App'; +import reportWebVitals from './reportWebVitals'; +import { BrowserRouter as Router, Switch, Route, Link} from "react-router-dom"; +import santaGameCreated from './component/santaGameCreated' +// Importing the Bootstrap CSS +import 'bootstrap/dist/css/bootstrap.min.css'; + +ReactDOM.render( + + + + + + , + document.getElementById('root') +); + +// If you want to start measuring performance in your app, pass a function +// to log results (for example: reportWebVitals(console.log)) +// or send to an analytics endpoint. Learn more: https://bit.ly/CRA-vitals +reportWebVitals(); diff --git a/Tokens/tokentofriend/clients/src/main/webapp/src/reportWebVitals.js b/Tokens/tokentofriend/clients/src/main/webapp/src/reportWebVitals.js new file mode 100644 index 00000000..5253d3ad --- /dev/null +++ b/Tokens/tokentofriend/clients/src/main/webapp/src/reportWebVitals.js @@ -0,0 +1,13 @@ +const reportWebVitals = onPerfEntry => { + if (onPerfEntry && onPerfEntry instanceof Function) { + import('web-vitals').then(({ getCLS, getFID, getFCP, getLCP, getTTFB }) => { + getCLS(onPerfEntry); + getFID(onPerfEntry); + getFCP(onPerfEntry); + getLCP(onPerfEntry); + getTTFB(onPerfEntry); + }); + } +}; + +export default reportWebVitals; diff --git a/Tokens/tokentofriend/clients/src/main/webapp/src/setupTests.js b/Tokens/tokentofriend/clients/src/main/webapp/src/setupTests.js new file mode 100644 index 00000000..8f2609b7 --- /dev/null +++ b/Tokens/tokentofriend/clients/src/main/webapp/src/setupTests.js @@ -0,0 +1,5 @@ +// jest-dom adds custom jest matchers for asserting on DOM nodes. +// allows you to do things like: +// expect(element).toHaveTextContent(/react/i) +// learn more: https://github.com/testing-library/jest-dom +import '@testing-library/jest-dom'; diff --git a/Tokens/tokentofriend/config/dev/log4j2.xml b/Tokens/tokentofriend/config/dev/log4j2.xml new file mode 100644 index 00000000..34ba4d45 --- /dev/null +++ b/Tokens/tokentofriend/config/dev/log4j2.xml @@ -0,0 +1,59 @@ + + + + + logs + node-${hostName} + ${log-path}/archive + + + + + + + + + %highlight{%level{length=1} %d{HH:mm:ss} %T %c{1}.%M - %msg%n}{INFO=white,WARN=red,FATAL=bright red blink} + > + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/Tokens/tokentofriend/config/test/log4j2.xml b/Tokens/tokentofriend/config/test/log4j2.xml new file mode 100644 index 00000000..cd9926ca --- /dev/null +++ b/Tokens/tokentofriend/config/test/log4j2.xml @@ -0,0 +1,20 @@ + + + + + + + [%-5level] %d{HH:mm:ss.SSS} [%t] %c{1}.%M - %msg%n + > + + + + + + + + + + + + diff --git a/Tokens/tokentofriend/contracts/build.gradle b/Tokens/tokentofriend/contracts/build.gradle new file mode 100644 index 00000000..6078640d --- /dev/null +++ b/Tokens/tokentofriend/contracts/build.gradle @@ -0,0 +1,37 @@ +apply plugin: 'net.corda.plugins.cordapp' +apply plugin: 'net.corda.plugins.cordformation' + +cordapp { + targetPlatformVersion corda_platform_version + minimumPlatformVersion corda_platform_version + contract { + name "tokentofriend Contracts" + vendor "Corda Open Source" + licence "Apache License, Version 2.0" + versionId 1 + } +} + +sourceSets { + main{ + java { + srcDir 'src/main/java' + java.outputDir = file('bin/main') + } + } + test{ + java{ + srcDir 'src/test/java' + java.outputDir = file('bin/test') + } + } +} + +dependencies { + // Corda dependencies. + cordaCompile "$corda_core_release_group:corda-core:$corda_core_release_version" + cordaRuntime "$corda_release_group:corda:$corda_release_version" + testCompile "$corda_release_group:corda-node-driver:$corda_release_version" + // Token SDK dependencies. + cordaCompile "$tokens_release_group:tokens-contracts:$tokens_release_version" +} \ No newline at end of file diff --git a/Tokens/tokentofriend/contracts/src/main/java/net/corda/samples/tokentofriend/contracts/CustomTokenContract.java b/Tokens/tokentofriend/contracts/src/main/java/net/corda/samples/tokentofriend/contracts/CustomTokenContract.java new file mode 100644 index 00000000..f6a35346 --- /dev/null +++ b/Tokens/tokentofriend/contracts/src/main/java/net/corda/samples/tokentofriend/contracts/CustomTokenContract.java @@ -0,0 +1,31 @@ +package net.corda.samples.tokentofriend.contracts; + +import com.r3.corda.lib.tokens.contracts.EvolvableTokenContract; +import net.corda.samples.tokentofriend.states.CustomTokenState; +import net.corda.core.contracts.Contract; +import net.corda.core.transactions.LedgerTransaction; +import org.jetbrains.annotations.NotNull; +import static net.corda.core.contracts.ContractsDSL.requireThat; + +public class CustomTokenContract extends EvolvableTokenContract implements Contract { + + public static final String CONTRACT_ID = "net.corda.samples.tokentofriend.contracts.CustomTokenContract"; + + + @Override + public void additionalCreateChecks(@NotNull LedgerTransaction tx) { + CustomTokenState newToken = (CustomTokenState) tx.getOutputStates().get(0); + requireThat( require -> { + require.using("Recipient Email cannot be empty",(!newToken.getReceipient().equals(""))); + require.using("Token Issuer Email and token recipient Email cannot be the same", + (!newToken.getReceipient().equals(newToken.getIssuer()))); + return null; + }); + } + + @Override + public void additionalUpdateChecks(@NotNull LedgerTransaction tx) { + /*This additional check does not apply to this use case. + *This sample does not allow token update */ + } +} diff --git a/Tokens/tokentofriend/contracts/src/main/java/net/corda/samples/tokentofriend/states/CustomTokenState.java b/Tokens/tokentofriend/contracts/src/main/java/net/corda/samples/tokentofriend/states/CustomTokenState.java new file mode 100644 index 00000000..21c2c304 --- /dev/null +++ b/Tokens/tokentofriend/contracts/src/main/java/net/corda/samples/tokentofriend/states/CustomTokenState.java @@ -0,0 +1,98 @@ +package net.corda.samples.tokentofriend.states; + +import com.r3.corda.lib.tokens.contracts.types.TokenPointer; +import net.corda.samples.tokentofriend.contracts.CustomTokenContract; +import net.corda.core.contracts.BelongsToContract; +import net.corda.core.contracts.LinearPointer; +import net.corda.core.contracts.UniqueIdentifier; +import net.corda.core.identity.Party; +import com.r3.corda.lib.tokens.contracts.states.EvolvableTokenType; +import org.jetbrains.annotations.NotNull; + +import java.util.ArrayList; +import java.util.List; + +@BelongsToContract(CustomTokenContract.class) +public class CustomTokenState extends EvolvableTokenType { + + private String issuer; + private String receipient; + private String message; + private Party maintainer; + private int fractionDigits; + private UniqueIdentifier linearId; + + public CustomTokenState(String issuer, String receipient, String message, Party maintainer, int fractionDigits, UniqueIdentifier linearId) { + this.issuer = issuer; + this.receipient = receipient; + this.message = message; + this.maintainer = maintainer; + this.fractionDigits = fractionDigits; + this.linearId = linearId; + } + + public String getIssuer() { + return issuer; + } + + public String getReceipient() { + return receipient; + } + + public String getMessage() { + return message; + } + + public Party getMaintainer() { + return maintainer; + } + + @Override + public int getFractionDigits() { + return fractionDigits; + } + + @NotNull + @Override + public UniqueIdentifier getLinearId() { + return linearId; + } + + public void setIssuer(String issuer) { + this.issuer = issuer; + } + + public void setReceipient(String receipient) { + this.receipient = receipient; + } + + public void setMessage(String message) { + this.message = message; + } + + public void setMaintainer(Party maintainer) { + this.maintainer = maintainer; + } + + public void setFractionDigits(int fractionDigits) { + this.fractionDigits = fractionDigits; + } + + public void setLinearId(UniqueIdentifier linearId) { + this.linearId = linearId; + } + + @NotNull + @Override + public List getMaintainers() { + List maintainers = new ArrayList(); + maintainers.add(this.maintainer); + return maintainers; + } + + /* This method returns a TokenPointer by using the linear Id of the evolvable state */ + public TokenPointer toPointer(){ + LinearPointer linearPointer = new LinearPointer<>(linearId, CustomTokenState.class); + return new TokenPointer<>(linearPointer, fractionDigits); + } +} diff --git a/Tokens/tokentofriend/contracts/src/test/java/net/corda/samples/tokentofriend/contracts/ContractTests.java b/Tokens/tokentofriend/contracts/src/test/java/net/corda/samples/tokentofriend/contracts/ContractTests.java new file mode 100644 index 00000000..3bb2f09d --- /dev/null +++ b/Tokens/tokentofriend/contracts/src/test/java/net/corda/samples/tokentofriend/contracts/ContractTests.java @@ -0,0 +1,51 @@ +package net.corda.samples.tokentofriend.contracts; + +import net.corda.samples.tokentofriend.states.CustomTokenState; +import net.corda.core.contracts.UniqueIdentifier; +import net.corda.core.identity.CordaX500Name; +import net.corda.testing.core.TestIdentity; +import net.corda.testing.node.MockServices; +import org.junit.Test; +import static net.corda.testing.node.NodeTestUtils.ledger; + +public class ContractTests { + private final MockServices ledgerServices = new MockServices(); + TestIdentity Operator = new TestIdentity(new CordaX500Name("Alice", "TestLand", "US")); + + @Test + public void issuerAndRecipientCannotHaveSameEmail() { + CustomTokenState tokenPass = new CustomTokenState("Peter@gmail.com","David@gmail.com","Corda Number 1!", Operator.getParty(),0,new UniqueIdentifier()); + CustomTokenState tokenfail = new CustomTokenState("Peter@gmail.com","Peter@gmail.com","Corda Number 1!", Operator.getParty(),0,new UniqueIdentifier()); + ledger(ledgerServices, l -> { + l.transaction(tx -> { + tx.output(CustomTokenContract.CONTRACT_ID, tokenfail); + tx.command(Operator.getPublicKey(), new com.r3.corda.lib.tokens.contracts.commands.Create()); // Wrong type. + return tx.fails(); + }); + l.transaction(tx -> { + tx.output(CustomTokenContract.CONTRACT_ID, tokenPass); + tx.command(Operator.getPublicKey(), new com.r3.corda.lib.tokens.contracts.commands.Create()); // Wrong type. + return tx.verifies(); + }); + return null; + }); + } + @Test + public void recipientEmailCannotBeEmpty() { + CustomTokenState tokenPass = new CustomTokenState("Peter@gmail.com","David@gmail.com","Corda Number 1!", Operator.getParty(),0,new UniqueIdentifier()); + CustomTokenState tokenfail = new CustomTokenState("Peter@gmail.com","","Corda Number 1!", Operator.getParty(),0,new UniqueIdentifier()); + ledger(ledgerServices, l -> { + l.transaction(tx -> { + tx.output(CustomTokenContract.CONTRACT_ID, tokenfail); + tx.command(Operator.getPublicKey(), new com.r3.corda.lib.tokens.contracts.commands.Create()); // Wrong type. + return tx.fails(); + }); + l.transaction(tx -> { + tx.output(CustomTokenContract.CONTRACT_ID, tokenPass); + tx.command(Operator.getPublicKey(), new com.r3.corda.lib.tokens.contracts.commands.Create()); // Wrong type. + return tx.verifies(); + }); + return null; + }); + } +} \ No newline at end of file diff --git a/Tokens/tokentofriend/contracts/src/test/java/net/corda/samples/tokentofriend/contracts/StateTests.java b/Tokens/tokentofriend/contracts/src/test/java/net/corda/samples/tokentofriend/contracts/StateTests.java new file mode 100644 index 00000000..ddfa207b --- /dev/null +++ b/Tokens/tokentofriend/contracts/src/test/java/net/corda/samples/tokentofriend/contracts/StateTests.java @@ -0,0 +1,17 @@ +package net.corda.samples.tokentofriend.contracts; + +import net.corda.samples.tokentofriend.states.CustomTokenState; +import net.corda.testing.node.MockServices; +import org.junit.Test; + +public class StateTests { + private final MockServices ledgerServices = new MockServices(); + + @Test + public void hasMessageFieldOfCorrectType() throws NoSuchFieldException { + // Does the message field exist? + CustomTokenState.class.getDeclaredField("message"); + // Is the message field of the correct type? + assert(CustomTokenState.class.getDeclaredField("message").getType().equals(String.class)); + } +} \ No newline at end of file diff --git a/Tokens/tokentofriend/diagram.png b/Tokens/tokentofriend/diagram.png new file mode 100644 index 00000000..d6b29241 Binary files /dev/null and b/Tokens/tokentofriend/diagram.png differ diff --git a/Tokens/tokentofriend/gradle.properties b/Tokens/tokentofriend/gradle.properties new file mode 100644 index 00000000..b73be200 --- /dev/null +++ b/Tokens/tokentofriend/gradle.properties @@ -0,0 +1,3 @@ +name=Tokentofriend Cordapp +group=com.tokentofriend +version=1.0 \ No newline at end of file diff --git a/Tokens/tokentofriend/gradle/wrapper/gradle-wrapper.jar b/Tokens/tokentofriend/gradle/wrapper/gradle-wrapper.jar new file mode 100644 index 00000000..99340b4a Binary files /dev/null and b/Tokens/tokentofriend/gradle/wrapper/gradle-wrapper.jar differ diff --git a/Tokens/tokentofriend/gradle/wrapper/gradle-wrapper.properties b/Tokens/tokentofriend/gradle/wrapper/gradle-wrapper.properties new file mode 100644 index 00000000..0188225a --- /dev/null +++ b/Tokens/tokentofriend/gradle/wrapper/gradle-wrapper.properties @@ -0,0 +1,7 @@ +#Fri Aug 25 12:50:39 BST 2017 +distributionBase=GRADLE_USER_HOME +distributionPath=wrapper/dists +zipStoreBase=GRADLE_USER_HOME +zipStorePath=wrapper/dists +distributionUrl=https\://services.gradle.org/distributions/gradle-5.6.4-all.zip + diff --git a/Tokens/tokentofriend/gradlew b/Tokens/tokentofriend/gradlew new file mode 100755 index 00000000..cccdd3d5 --- /dev/null +++ b/Tokens/tokentofriend/gradlew @@ -0,0 +1,172 @@ +#!/usr/bin/env sh + +############################################################################## +## +## Gradle start up script for UN*X +## +############################################################################## + +# Attempt to set APP_HOME +# Resolve links: $0 may be a link +PRG="$0" +# Need this for relative symlinks. +while [ -h "$PRG" ] ; do + ls=`ls -ld "$PRG"` + link=`expr "$ls" : '.*-> $.*$$'` + if expr "$link" : '/.*' > /dev/null; then + PRG="$link" + else + PRG=`dirname "$PRG"`"/$link" + fi +done +SAVED="`pwd`" +cd "`dirname \"$PRG\"`/" >/dev/null +APP_HOME="`pwd -P`" +cd "$SAVED" >/dev/null + +APP_NAME="Gradle" +APP_BASE_NAME=`basename "$0"` + +# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script. +DEFAULT_JVM_OPTS="" + +# Use the maximum available, or set MAX_FD != -1 to use that value. +MAX_FD="maximum" + +warn () { + echo "$*" +} + +die () { + echo + echo "$*" + echo + exit 1 +} + +# OS specific support (must be 'true' or 'false'). +cygwin=false +msys=false +darwin=false +nonstop=false +case "`uname`" in + CYGWIN* ) + cygwin=true + ;; + Darwin* ) + darwin=true + ;; + MINGW* ) + msys=true + ;; + NONSTOP* ) + nonstop=true + ;; +esac + +CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar + +# Determine the Java command to use to start the JVM. +if [ -n "$JAVA_HOME" ] ; then + if [ -x "$JAVA_HOME/jre/sh/java" ] ; then + # IBM's JDK on AIX uses strange locations for the executables + JAVACMD="$JAVA_HOME/jre/sh/java" + else + JAVACMD="$JAVA_HOME/bin/java" + fi + if [ ! -x "$JAVACMD" ] ; then + die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME + +Please set the JAVA_HOME variable in your environment to match the +location of your Java installation." + fi +else + JAVACMD="java" + which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. + +Please set the JAVA_HOME variable in your environment to match the +location of your Java installation." +fi + +# Increase the maximum file descriptors if we can. +if [ "$cygwin" = "false" -a "$darwin" = "false" -a "$nonstop" = "false" ] ; then + MAX_FD_LIMIT=`ulimit -H -n` + if [ $? -eq 0 ] ; then + if [ "$MAX_FD" = "maximum" -o "$MAX_FD" = "max" ] ; then + MAX_FD="$MAX_FD_LIMIT" + fi + ulimit -n $MAX_FD + if [ $? -ne 0 ] ; then + warn "Could not set maximum file descriptor limit: $MAX_FD" + fi + else + warn "Could not query maximum file descriptor limit: $MAX_FD_LIMIT" + fi +fi + +# For Darwin, add options to specify how the application appears in the dock +if $darwin; then + GRADLE_OPTS="$GRADLE_OPTS \"-Xdock:name=$APP_NAME\" \"-Xdock:icon=$APP_HOME/media/gradle.icns\"" +fi + +# For Cygwin, switch paths to Windows format before running java +if $cygwin ; then + APP_HOME=`cygpath --path --mixed "$APP_HOME"` + CLASSPATH=`cygpath --path --mixed "$CLASSPATH"` + JAVACMD=`cygpath --unix "$JAVACMD"` + + # We build the pattern for arguments to be converted via cygpath + ROOTDIRSRAW=`find -L / -maxdepth 1 -mindepth 1 -type d 2>/dev/null` + SEP="" + for dir in $ROOTDIRSRAW ; do + ROOTDIRS="$ROOTDIRS$SEP$dir" + SEP="|" + done + OURCYGPATTERN="(^($ROOTDIRS))" + # Add a user-defined pattern to the cygpath arguments + if [ "$GRADLE_CYGPATTERN" != "" ] ; then + OURCYGPATTERN="$OURCYGPATTERN|($GRADLE_CYGPATTERN)" + fi + # Now convert the arguments - kludge to limit ourselves to /bin/sh + i=0 + for arg in "$@" ; do + CHECK=`echo "$arg"|egrep -c "$OURCYGPATTERN" -` + CHECK2=`echo "$arg"|egrep -c "^-"` ### Determine if an option + + if [ $CHECK -ne 0 ] && [ $CHECK2 -eq 0 ] ; then ### Added a condition + eval `echo args$i`=`cygpath --path --ignore --mixed "$arg"` + else + eval `echo args$i`="\"$arg\"" + fi + i=$((i+1)) + done + case $i in + (0) set -- ;; + (1) set -- "$args0" ;; + (2) set -- "$args0" "$args1" ;; + (3) set -- "$args0" "$args1" "$args2" ;; + (4) set -- "$args0" "$args1" "$args2" "$args3" ;; + (5) set -- "$args0" "$args1" "$args2" "$args3" "$args4" ;; + (6) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" ;; + (7) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" ;; + (8) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" ;; + (9) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" "$args8" ;; + esac +fi + +# Escape application args +save () { + for i do printf %s\\n "$i" | sed "s/'/'\\\\''/g;1s/^/'/;\$s/\$/' \\\\/" ; done + echo " " +} +APP_ARGS=$(save "$@") + +# Collect all arguments for the java command, following the shell quoting and substitution rules +eval set -- $DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS "\"-Dorg.gradle.appname=$APP_BASE_NAME\"" -classpath "\"$CLASSPATH\"" org.gradle.wrapper.GradleWrapperMain "$APP_ARGS" + +# by default we should be in the correct project dir, but when run from Finder on Mac, the cwd is wrong +if [ "$(uname)" = "Darwin" ] && [ "$HOME" = "$PWD" ]; then + cd "$(dirname "$0")" +fi + +exec "$JAVACMD" "$@" diff --git a/Tokens/tokentofriend/gradlew.bat b/Tokens/tokentofriend/gradlew.bat new file mode 100644 index 00000000..f9553162 --- /dev/null +++ b/Tokens/tokentofriend/gradlew.bat @@ -0,0 +1,84 @@ +@if "%DEBUG%" == "" @echo off +@rem ########################################################################## +@rem +@rem Gradle startup script for Windows +@rem +@rem ########################################################################## + +@rem Set local scope for the variables with windows NT shell +if "%OS%"=="Windows_NT" setlocal + +set DIRNAME=%~dp0 +if "%DIRNAME%" == "" set DIRNAME=. +set APP_BASE_NAME=%~n0 +set APP_HOME=%DIRNAME% + +@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script. +set DEFAULT_JVM_OPTS= + +@rem Find java.exe +if defined JAVA_HOME goto findJavaFromJavaHome + +set JAVA_EXE=java.exe +%JAVA_EXE% -version >NUL 2>&1 +if "%ERRORLEVEL%" == "0" goto init + +echo. +echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. +echo. +echo Please set the JAVA_HOME variable in your environment to match the +echo location of your Java installation. + +goto fail + +:findJavaFromJavaHome +set JAVA_HOME=%JAVA_HOME:"=% +set JAVA_EXE=%JAVA_HOME%/bin/java.exe + +if exist "%JAVA_EXE%" goto init + +echo. +echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME% +echo. +echo Please set the JAVA_HOME variable in your environment to match the +echo location of your Java installation. + +goto fail + +:init +@rem Get command-line arguments, handling Windows variants + +if not "%OS%" == "Windows_NT" goto win9xME_args + +:win9xME_args +@rem Slurp the command line arguments. +set CMD_LINE_ARGS= +set _SKIP=2 + +:win9xME_args_slurp +if "x%~1" == "x" goto execute + +set CMD_LINE_ARGS=%* + +:execute +@rem Setup the command line + +set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar + +@rem Execute Gradle +"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %CMD_LINE_ARGS% + +:end +@rem End local scope for the variables with windows NT shell +if "%ERRORLEVEL%"=="0" goto mainEnd + +:fail +rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of +rem the _cmd.exe /c_ return code! +if not "" == "%GRADLE_EXIT_CONSOLE%" exit 1 +exit /b 1 + +:mainEnd +if "%OS%"=="Windows_NT" endlocal + +:omega diff --git a/Tokens/tokentofriend/repositories.gradle b/Tokens/tokentofriend/repositories.gradle new file mode 100644 index 00000000..8be7b630 --- /dev/null +++ b/Tokens/tokentofriend/repositories.gradle @@ -0,0 +1,8 @@ +repositories { + mavenLocal() + mavenCentral() + + maven { url 'https://jitpack.io' } + maven { url 'https://download.corda.net/maven/corda-dependencies' } + maven { url 'https://repo.gradle.org/gradle/libs-releases' } +} diff --git a/Tokens/tokentofriend/runServers.sh b/Tokens/tokentofriend/runServers.sh new file mode 100644 index 00000000..b54da2c4 --- /dev/null +++ b/Tokens/tokentofriend/runServers.sh @@ -0,0 +1,3 @@ +#!/bin/sh +./gradlew runOperatoreServer & +./gradlew runUSWest1Server diff --git a/Tokens/tokentofriend/settings.gradle b/Tokens/tokentofriend/settings.gradle new file mode 100644 index 00000000..2514aca2 --- /dev/null +++ b/Tokens/tokentofriend/settings.gradle @@ -0,0 +1,3 @@ +include 'workflows' +include 'contracts' +include 'clients' \ No newline at end of file diff --git a/Tokens/tokentofriend/workflows/build.gradle b/Tokens/tokentofriend/workflows/build.gradle new file mode 100644 index 00000000..4446f000 --- /dev/null +++ b/Tokens/tokentofriend/workflows/build.gradle @@ -0,0 +1,66 @@ +apply plugin: 'net.corda.plugins.cordapp' +apply plugin: 'net.corda.plugins.cordformation' +apply plugin: 'net.corda.plugins.quasar-utils' + +cordapp { + targetPlatformVersion corda_platform_version + minimumPlatformVersion corda_platform_version + workflow { + name "tokentofriend Flows" + vendor "Corda Open Source" + licence "Apache License, Version 2.0" + versionId 1 + } +} + +sourceSets { + main { + java { + srcDir 'src/main/java' + java.outputDir = file('bin/main') + } + resources { + srcDir rootProject.file("config/dev") + } + } + test { + java { + srcDir 'src/test/java' + java.outputDir = file('bin/main') + } + resources { + srcDir rootProject.file("config/test") + } + } + integrationTest { + java { + compileClasspath += main.output + test.output + runtimeClasspath += main.output + test.output + srcDir file('src/integrationTest/java') + } + } +} + +configurations { + integrationTestCompile.extendsFrom testCompile + integrationTestRuntime.extendsFrom testRuntime +} + +dependencies { + testCompile "junit:junit:$junit_version" + + // Corda dependencies. + cordaCompile "$corda_core_release_group:corda-core:$corda_core_release_version" + cordaRuntime "$corda_release_group:corda:$corda_release_version" + testCompile "$corda_release_group:corda-node-driver:$corda_release_version" + + // CorDapp dependencies. + cordapp project(":contracts") + // Token SDK dependencies. + cordaCompile "$tokens_release_group:tokens-workflows:$tokens_release_version" +} + +task integrationTest(type: Test, dependsOn: []) { + testClassesDirs = sourceSets.integrationTest.output.classesDirs + classpath = sourceSets.integrationTest.runtimeClasspath +} \ No newline at end of file diff --git a/Tokens/tokentofriend/workflows/src/integrationTest/java/net/corda/samples/tokentofriend/DriverBasedTest.java b/Tokens/tokentofriend/workflows/src/integrationTest/java/net/corda/samples/tokentofriend/DriverBasedTest.java new file mode 100644 index 00000000..e225f04c --- /dev/null +++ b/Tokens/tokentofriend/workflows/src/integrationTest/java/net/corda/samples/tokentofriend/DriverBasedTest.java @@ -0,0 +1,48 @@ +package net.corda.samples.tokentofriend; + +import com.google.common.collect.ImmutableList; +import net.corda.core.concurrent.CordaFuture; +import net.corda.core.identity.CordaX500Name; +import net.corda.testing.core.TestIdentity; +import net.corda.testing.driver.DriverParameters; +import net.corda.testing.driver.NodeHandle; +import net.corda.testing.driver.NodeParameters; +import org.junit.Test; + +import java.util.List; + +import static net.corda.testing.driver.Driver.driver; +import static org.junit.Assert.assertEquals; + +public class DriverBasedTest { + private final TestIdentity bankA = new TestIdentity(new CordaX500Name("BankA", "", "GB")); + private final TestIdentity bankB = new TestIdentity(new CordaX500Name("BankB", "", "US")); + + @Test + public void nodeTest() { + driver(new DriverParameters().withIsDebug(true).withStartNodesInProcess(true), dsl -> { + // Start a pair of nodes and wait for them both to be ready. + List> handleFutures = ImmutableList.of( + dsl.startNode(new NodeParameters().withProvidedName(bankA.getName())), + dsl.startNode(new NodeParameters().withProvidedName(bankB.getName())) + ); + + try { + NodeHandle partyAHandle = handleFutures.get(0).get(); + NodeHandle partyBHandle = handleFutures.get(1).get(); + + // From each node, make an RPC call to retrieve another node's name from the network map, to verify that the + // nodes have started and can communicate. + + // This is a very basic test: in practice tests would be starting flows, and verifying the states in the vault + // and other important metrics to ensure that your CorDapp is working as intended. + assertEquals(partyAHandle.getRpc().wellKnownPartyFromX500Name(bankB.getName()).getName(), bankB.getName()); + assertEquals(partyBHandle.getRpc().wellKnownPartyFromX500Name(bankA.getName()).getName(), bankA.getName()); + } catch (Exception e) { + throw new RuntimeException("Caught exception during test: ", e); + } + + return null; + }); + } +} \ No newline at end of file diff --git a/Tokens/tokentofriend/workflows/src/main/java/net/corda/samples/tokentofriend/flows/CreateMyToken.java b/Tokens/tokentofriend/workflows/src/main/java/net/corda/samples/tokentofriend/flows/CreateMyToken.java new file mode 100644 index 00000000..64162063 --- /dev/null +++ b/Tokens/tokentofriend/workflows/src/main/java/net/corda/samples/tokentofriend/flows/CreateMyToken.java @@ -0,0 +1,45 @@ +package net.corda.samples.tokentofriend.flows; + +import co.paralleluniverse.fibers.Suspendable; +import com.r3.corda.lib.tokens.workflows.flows.rpc.CreateEvolvableTokens; +import net.corda.core.identity.CordaX500Name; +import net.corda.samples.tokentofriend.states.CustomTokenState; +import net.corda.core.contracts.TransactionState; +import net.corda.core.contracts.UniqueIdentifier; +import net.corda.core.flows.FlowException; +import net.corda.core.flows.FlowLogic; +import net.corda.core.flows.StartableByRPC; +import net.corda.core.identity.Party; + +@StartableByRPC +public class CreateMyToken extends FlowLogic{ + + private String myEmail; + private String recipients; + private String msg; + + public CreateMyToken(String myEmail, String recipients, String msg) { + this.myEmail = myEmail; + this.recipients = recipients; + this.msg = msg; + } + + + @Override + @Suspendable + public UniqueIdentifier call() throws FlowException { + + // Obtain a reference to a notary we wish to use. + /** Explicit selection of notary by CordaX500Name - argument can by coded in flows or parsed from config (Preferred)*/ + final Party notary = getServiceHub().getNetworkMapCache().getNotary(CordaX500Name.parse("O=Notary,L=London,C=GB")); + + UniqueIdentifier uuid = new UniqueIdentifier(); + CustomTokenState tokenState = new CustomTokenState(myEmail,recipients,msg,getOurIdentity(),0,uuid); + + //warp it with transaction state specifying the notary + TransactionState transactionState = new TransactionState<>(tokenState,notary); + + subFlow(new CreateEvolvableTokens(transactionState)); + return uuid; + } +} diff --git a/Tokens/tokentofriend/workflows/src/main/java/net/corda/samples/tokentofriend/flows/IssueToken.java b/Tokens/tokentofriend/workflows/src/main/java/net/corda/samples/tokentofriend/flows/IssueToken.java new file mode 100644 index 00000000..4eb145c9 --- /dev/null +++ b/Tokens/tokentofriend/workflows/src/main/java/net/corda/samples/tokentofriend/flows/IssueToken.java @@ -0,0 +1,74 @@ +package net.corda.samples.tokentofriend.flows; + +import co.paralleluniverse.fibers.Suspendable; +import com.r3.corda.lib.tokens.contracts.states.NonFungibleToken; +import com.r3.corda.lib.tokens.contracts.types.IssuedTokenType; +import com.r3.corda.lib.tokens.workflows.flows.rpc.IssueTokens; +import com.r3.corda.lib.tokens.workflows.utilities.NonFungibleTokenBuilder; +import net.corda.samples.tokentofriend.states.CustomTokenState; +import net.corda.core.contracts.UniqueIdentifier; +import net.corda.core.flows.FlowException; +import net.corda.core.flows.FlowLogic; +import net.corda.core.flows.StartableByRPC; +import net.corda.core.identity.AbstractParty; +import net.corda.core.identity.Party; +import net.corda.core.node.NodeInfo; +import net.corda.core.node.services.Vault; +import net.corda.core.node.services.vault.QueryCriteria; + +import java.util.*; +import java.util.stream.Collectors; + +@StartableByRPC +public class IssueToken extends FlowLogic{ + + private String uuid; + + public IssueToken(String uuid) { + this.uuid = uuid; + } + + @Override + @Suspendable + public String call() throws FlowException { + /* Get a reference of own identity */ + Party issuer = getOurIdentity(); + + /* Fetch the house state from the vault using the vault query */ + + QueryCriteria inputCriteria = new QueryCriteria.LinearStateQueryCriteria() + .withUuid(Arrays.asList(UUID.fromString(uuid))).withStatus(Vault.StateStatus.UNCONSUMED); + CustomTokenState customTokenState = getServiceHub().getVaultService().queryBy(CustomTokenState.class,inputCriteria) + .getStates().get(0).getState().getData(); + + /* + * Create an instance of IssuedTokenType, it is used by our Non-Fungible token which would be issued to the owner. Note that the IssuedTokenType takes + * a TokenPointer as an input, since EvolvableTokenType is not TokenType, but is a LinearState. This is done to separate the state info from the token + * so that the state can evolve independently. + * IssuedTokenType is a wrapper around the TokenType and the issuer. + * */ + IssuedTokenType issuedToken = new NonFungibleTokenBuilder() + .issuedBy(getOurIdentity()) + .ofTokenType(customTokenState.toPointer()) + .buildIssuedTokenType(); + + /* Create an instance of the non-fungible house token with the owner as the token holder. The last paramter is a hash of the jar containing the TokenType, use the helper function to fetch it. */ + AbstractParty storageNode = storageSelector(); + UniqueIdentifier tokenId = new UniqueIdentifier(); + NonFungibleToken token = new NonFungibleToken(issuedToken,storageNode,tokenId); + + subFlow(new IssueTokens(Arrays.asList(token))); + + return "\nMessage: "+ customTokenState.getMessage() + "\nToken Id is: "+tokenId+"\nStorage Node is: "+storageNode; + } + + public AbstractParty storageSelector(){ + Party notary = getServiceHub().getNetworkMapCache().getNotaryIdentities().get(0); + List allOtherNodes = getServiceHub().getNetworkMapCache().getAllNodes().stream().filter( it -> + (!it.getLegalIdentities().get(0).equals(getOurIdentity())) && (!it.getLegalIdentities().get(0).equals(notary)) + ).collect(Collectors.toList()); + int pick = (int) (Math.random()*(allOtherNodes.size()*10)/10); + return allOtherNodes.get(pick).getLegalIdentities().get(0); + } + +} diff --git a/Tokens/tokentofriend/workflows/src/main/java/net/corda/samples/tokentofriend/flows/QueryToken.java b/Tokens/tokentofriend/workflows/src/main/java/net/corda/samples/tokentofriend/flows/QueryToken.java new file mode 100644 index 00000000..3ec0a958 --- /dev/null +++ b/Tokens/tokentofriend/workflows/src/main/java/net/corda/samples/tokentofriend/flows/QueryToken.java @@ -0,0 +1,54 @@ +package net.corda.samples.tokentofriend.flows; + +import co.paralleluniverse.fibers.Suspendable; +import com.r3.corda.lib.tokens.contracts.states.NonFungibleToken; +import net.corda.samples.tokentofriend.states.CustomTokenState; +import net.corda.core.flows.FlowException; +import net.corda.core.flows.FlowLogic; +import net.corda.core.flows.StartableByRPC; +import net.corda.core.node.services.Vault; +import net.corda.core.node.services.vault.QueryCriteria; + +import java.util.*; + +@StartableByRPC +public class QueryToken extends FlowLogic{ + + private String uuid; + private String recipientEmail; + + public QueryToken(String uuid, String recipientEmail) { + this.uuid = uuid; + this.recipientEmail = recipientEmail; + } + + @Override + @Suspendable + public String call() throws FlowException { + + NonFungibleToken receivedToken = null; + try { + QueryCriteria inputCriteria = new QueryCriteria.LinearStateQueryCriteria().withUuid(Arrays.asList(UUID.fromString(uuid))) + .withStatus(Vault.StateStatus.UNCONSUMED); + receivedToken = getServiceHub().getVaultService().queryBy(NonFungibleToken.class,inputCriteria).getStates().get(0).getState().getData(); + }catch (NoSuchElementException e){ + return "\nERROR: Your Token ID Cannot Be Found In The System"; + } + String tokenTypeStateId = receivedToken.getToken().getTokenIdentifier(); + + CustomTokenState underlineState = null; + try { + QueryCriteria inputCriteria = new QueryCriteria.LinearStateQueryCriteria().withUuid(Arrays.asList(UUID.fromString(tokenTypeStateId))) + .withStatus(Vault.StateStatus.UNCONSUMED); + underlineState = getServiceHub().getVaultService().queryBy(CustomTokenState.class,inputCriteria).getStates().get(0).getState().getData(); + }catch(NoSuchElementException e){ + return "\nERROR: Internal Error"; + } + if(underlineState.getReceipient().equals(this.recipientEmail)){ + return "\nCreator of the Token: " + underlineState.getIssuer() + + "\nMessage: " + underlineState.getMessage(); + }else{ + return "\nToken found, but the recipient email is not matched. Please try again"; + } + } +} diff --git a/Tokens/tokentofriend/workflows/src/test/java/net/corda/samples/tokentofriend/FlowTests.java b/Tokens/tokentofriend/workflows/src/test/java/net/corda/samples/tokentofriend/FlowTests.java new file mode 100644 index 00000000..24cbb673 --- /dev/null +++ b/Tokens/tokentofriend/workflows/src/test/java/net/corda/samples/tokentofriend/FlowTests.java @@ -0,0 +1,96 @@ +package net.corda.samples.tokentofriend; + +import com.google.common.collect.ImmutableList; +import com.r3.corda.lib.tokens.contracts.states.NonFungibleToken; +import net.corda.core.identity.CordaX500Name; +import net.corda.samples.tokentofriend.flows.IssueToken; +import net.corda.samples.tokentofriend.states.CustomTokenState; +import net.corda.samples.tokentofriend.flows.CreateMyToken; +import net.corda.core.contracts.StateAndRef; +import net.corda.core.contracts.UniqueIdentifier; +import net.corda.core.node.NetworkParameters; +import net.corda.core.node.services.Vault; +import net.corda.core.node.services.vault.QueryCriteria; +import net.corda.testing.node.*; +import org.junit.After; +import org.junit.Before; +import org.junit.Test; + +import java.util.*; +import java.time.Instant; +import java.util.concurrent.ExecutionException; +import java.util.concurrent.Future; +import java.util.stream.Collectors; + +public class FlowTests { + private MockNetwork network; + private StartedMockNode a; + private StartedMockNode b; + private StartedMockNode c; + private StartedMockNode d; + private StartedMockNode e; + + private NetworkParameters testNetworkParameters = + new NetworkParameters(4, Arrays.asList(), 10485760, (10485760 * 5), Instant.now(),1, new LinkedHashMap<>()); + + @Before + public void setup() { + + network = new MockNetwork(new MockNetworkParameters().withCordappsForAllNodes(ImmutableList.of( + TestCordapp.findCordapp("net.corda.samples.tokentofriend.contracts"), + TestCordapp.findCordapp("net.corda.samples.tokentofriend.flows"), + TestCordapp.findCordapp("com.r3.corda.lib.tokens.contracts"), + TestCordapp.findCordapp("com.r3.corda.lib.tokens.workflows"))).withNetworkParameters(testNetworkParameters) + .withNotarySpecs(ImmutableList.of(new MockNetworkNotarySpec(CordaX500Name.parse("O=Notary,L=London,C=GB")))) + ); + a = network.createPartyNode(null); + b = network.createPartyNode(null); + c = network.createPartyNode(null); + d = network.createPartyNode(null); + e = network.createPartyNode(null); + network.runNetwork(); + } + + @After + public void tearDown() { + network.stopNodes(); + } + + @Test + public void CheckTheCorrectMessageIsStored() throws ExecutionException, InterruptedException { + String msg = "Test message"; + CreateMyToken flow = new CreateMyToken("1@gmail.com","2@gmail.com",msg); + Future future = a.startFlow(flow); + network.runNetwork(); + UniqueIdentifier tokenStateID = future.get(); + CustomTokenState storedState = a.getServices().getVaultService().queryBy(CustomTokenState.class).getStates().get(0).getState().getData(); + assert (storedState.getMessage().equals(msg)); + } + + @Test + public void CheckIfNonFungibleTokenCorrectlyCreated() throws ExecutionException, InterruptedException{ + String msg = "Test message"; + CreateMyToken flow = new CreateMyToken("1@gmail.com","2@gmail.com",msg); + Future future = a.startFlow(flow); + network.runNetwork(); + UniqueIdentifier tokenStateID = future.get(); + IssueToken issueTokenflow = new IssueToken(tokenStateID.getId().toString()); + Future future2 = a.startFlow(issueTokenflow); + network.runNetwork(); + String resultString = future2.get(); + System.out.println(resultString); + int subString = resultString.indexOf("Token Id is: "); + String nonfungibleTokenId = resultString.substring(subString+13,resultString.indexOf("Storage Node is:")-1); + System.out.println("-"+ nonfungibleTokenId+"-"); + List> storedNonFungibleTokenb = b.getServices().getVaultService().queryBy(NonFungibleToken.class).getStates(); + List> storedNonFungibleTokenc = c.getServices().getVaultService().queryBy(NonFungibleToken.class).getStates(); + List> storedNonFungibleTokend = d.getServices().getVaultService().queryBy(NonFungibleToken.class).getStates(); + List> storedNonFungibleTokene = e.getServices().getVaultService().queryBy(NonFungibleToken.class).getStates(); + NonFungibleToken storedToken = Arrays.asList(storedNonFungibleTokenb,storedNonFungibleTokenc,storedNonFungibleTokend,storedNonFungibleTokene).stream().filter(it -> + 0 != it.size() + ).collect(Collectors.toList()).get(0).get(0).getState().getData(); + System.out.println("-"+ storedToken.getLinearId().toString()+"-"); + assert (storedToken.getLinearId().toString().equals(nonfungibleTokenId)); + } + +}

Here is your Token Information:

CorDapp Token-To-Friend

Retrieve the Secret Message:

Here is your query result: