Connect
+ Sum Numbers under Asynchronous Shares MPC
+ Input Number (between 0 and 100) Sum
+
+
diff --git a/demos/asyncshare/client.js b/demos/asyncshare/client.js
new file mode 100644
index 000000000..abbca673c
--- /dev/null
+++ b/demos/asyncshare/client.js
@@ -0,0 +1,66 @@
+/**
+ * Do not modify this file unless you have to.
+ * This file has UI handlers.
+ */
+
+// eslint-disable-next-line no-unused-vars
+function connect() {
+ $('#connectButton').prop('disabled', true);
+ var computation_id = $('#computation_id').val();
+ var party_count = parseInt($('#count').val());
+ //var receiver_ratios =
+
+ if (isNaN(party_count)) {
+ $('#output').append("Party count must be a valid number!
");
+ $('#connectButton').prop('disabled', false);
+ } else {
+ var options = { party_count: party_count};
+ options.onError = function (error) {
+ $('#output').append(""+error+'
');
+ };
+ options.onConnect = function () {
+ $('#button').attr('disabled', false); $('#output').append('All parties Connected!
');
+ };
+
+ var hostname = window.location.hostname.trim();
+ var port = window.location.port;
+ if (port == null || port === '') {
+ port = '80';
+ }
+ if (!(hostname.startsWith('http://') || hostname.startsWith('https://'))) {
+ hostname = 'http://' + hostname;
+ }
+ if (hostname.endsWith('/')) {
+ hostname = hostname.substring(0, hostname.length-1);
+ }
+ if (hostname.indexOf(':') > -1 && hostname.lastIndexOf(':') > hostname.indexOf(':')) {
+ hostname = hostname.substring(0, hostname.lastIndexOf(':'));
+ }
+
+ hostname = hostname + ':' + port;
+ // eslint-disable-next-line no-undef
+ mpc.connect(hostname, computation_id, options);
+ }
+}
+
+// eslint-disable-next-line no-unused-vars
+function submit() {
+ var input = parseInt($('#number').val());
+
+ if (isNaN(input)) {
+ $('#output').append("Input a valid number!
");
+ } else if (100 < input || input < 0 || input !== Math.floor(input)) {
+ $('#output').append("Input a WHOLE number between 0 and 100!
");
+ } else {
+ $('#button').attr('disabled', true);
+ $('#output').append('Starting...
');
+ // eslint-disable-next-line no-undef
+ var promise = mpc.compute(input);
+ promise.then(handleResult);
+ }
+}
+
+function handleResult(result) {
+ $('#output').append('Result is: ' + result + '
');
+ $('#button').attr('disabled', false);
+}
diff --git a/demos/asyncshare/mpc.js b/demos/asyncshare/mpc.js
new file mode 100644
index 000000000..24714ca0b
--- /dev/null
+++ b/demos/asyncshare/mpc.js
@@ -0,0 +1,43 @@
+(function (exports, node) {
+ var saved_instance;
+
+ /**
+ * Connect to the server and initialize the jiff instance
+ */
+ exports.connect = function (hostname, computation_id, options) {
+ var opt = Object.assign({}, options);
+ opt.warn = false;
+ if (node) {
+ // eslint-disable-next-line no-undef
+ jiff = require('../../lib/jiff-client');
+ jiff_asynchronousshare = require('../../lib/ext/jiff-client-asynchronousshare');
+ }
+
+ opt.autoConnect = false;
+ // eslint-disable-next-line no-undef
+ saved_instance = jiff.make_jiff(hostname, computation_id, opt);
+ saved_instance.apply_extension(jiff_asynchronousshare, opt);
+ saved_instance.connect();
+ return saved_instance;
+ };
+
+ /**
+ * The MPC computation
+ */
+ exports.compute = async function (input, jiff_instance) {
+ if (jiff_instance == null) {
+ jiff_instance = saved_instance;
+ }
+
+ // The MPC implementation should go *HERE*
+ var shares = jiff_instance.share(input, 3, null, null, null, null, {1: 1, 2: 2});
+
+ var sum = shares[1];
+ for (var i = 2; i <= jiff_instance.party_count; i++) {
+ sum = sum.sadd(shares[i]);
+ }
+
+ // Return a promise to the final output(s)
+ return jiff_instance.open(sum, [1,2]);
+ };
+}((typeof exports === 'undefined' ? this.mpc = {} : exports), typeof exports !== 'undefined'));
diff --git a/demos/asyncshare/party.js b/demos/asyncshare/party.js
new file mode 100644
index 000000000..a1d8f7189
--- /dev/null
+++ b/demos/asyncshare/party.js
@@ -0,0 +1,43 @@
+/**
+ * Do not change this unless you have to.
+ * This code parses input command line arguments,
+ * and calls the appropriate initialization and MPC protocol from ./mpc.js
+ */
+
+console.log('Command line arguments: [ []]]]');
+
+var mpc = require('./mpc');
+
+// Read Command line arguments
+var input = parseInt(process.argv[2], 10);
+
+var party_count = process.argv[3];
+if (party_count == null) {
+ party_count = 2;
+} else {
+ party_count = parseInt(party_count);
+}
+
+var computation_id = process.argv[4];
+if (computation_id == null) {
+ computation_id = 'test';
+}
+
+var party_id = process.argv[5];
+if (party_id != null) {
+ party_id = parseInt(party_id, 10);
+}
+
+// JIFF options
+var options = {party_count: party_count, party_id: party_id};
+options.onConnect = function (jiff_instance) {
+ var promise = mpc.compute(input);
+
+ promise.then(function (v) {
+ console.log(v);
+ jiff_instance.disconnect(true);
+ });
+};
+
+// Connect
+mpc.connect('http://localhost:8080', computation_id, options);
diff --git a/demos/asyncshare/server.js b/demos/asyncshare/server.js
new file mode 100644
index 000000000..5a05428b8
--- /dev/null
+++ b/demos/asyncshare/server.js
@@ -0,0 +1,21 @@
+var express = require('express');
+var app = express();
+var http = require('http').Server(app);
+var base_instance = require('../../lib/jiff-server').make_jiff(http, { logs:true });
+var jiffAsyncShareServer = require('../../lib/ext/jiff-server-asyncshare');
+base_instance.apply_extension(jiffAsyncShareServer);
+
+//Serve static files
+//Configure App
+app.use('/demos', express.static('demos'));
+app.use('/lib', express.static('lib'));
+app.use('/lib/ext', express.static('lib/ext'));
+
+// Serve static files.
+http.listen(8080, function () {
+ console.log('listening on *:8080');
+});
+
+console.log('Direct your browser to *:8080/demos/asyncshare/client.html.');
+console.log('To run a node.js based party: node demos/asyncshare/party