Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
71bb3af
commit b2b46da
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,115 +1,113 @@ | ||
| class ArrayOpen { | ||
| open_array(jiff, shares, parties, op_ids) { | ||
| // A base operation id is provided to use for all opens. | ||
| if (typeof op_ids === 'string' || typeof op_ids === 'number') { | ||
| const tmp = { s1: op_ids }; | ||
| for (let i = 1; i <= jiff.party_count; i++) { | ||
| tmp[i] = op_ids; | ||
| } | ||
| op_ids = tmp; | ||
| } | ||
|
|
||
| return open_ND_array(jiff, shares, parties, null, op_ids); | ||
| } | ||
|
|
||
| open_ND_array(jiff, shares, receivers_list, senders_list, op_ids) { | ||
| if (senders_list == null) { | ||
| senders_list = []; | ||
| for (let i = 1; i <= jiff.party_count; i++) { | ||
| senders_list.push(i); | ||
| } | ||
| if (receivers_list == null) { | ||
| receivers_list = Array.from(senders_list); | ||
| } | ||
| } | ||
| const is_sending = senders_list.indexOf(jiff.id) > -1; | ||
|
|
||
| // Compute operation id | ||
| /* | ||
| *if (op_ids == null) { | ||
| * op_ids = jiff.counters.gen_op_id('open_ND_array', receivers_list.concat(senders_list)); | ||
| *} | ||
| */ | ||
|
|
||
| const final_deferred = new jiff.helpers.Deferred(); | ||
| const final_promise = final_deferred.promise; | ||
| function resolve_open(shares) { | ||
| final_deferred.resolve( | ||
| (function __open_ND_array(shares, parties, op_ids) { | ||
| if (typeof shares.length === 'undefined') { | ||
| return jiff.internal_open(shares, parties); | ||
| } else if (shares.length === 0) { | ||
| return Promise.resolve([]); | ||
| } else { | ||
| const promised_array = []; | ||
| for (let i = 0; i < shares.length; i++) { | ||
| promised_array.push(__open_ND_array(shares[i], parties, op_ids + ':' + i)); | ||
| } | ||
| return Promise.all(promised_array); | ||
| } | ||
| })(shares, receivers_list, op_ids) | ||
| ); | ||
| } | ||
|
|
||
| if (is_sending) { | ||
| // Must emit the skeleton for any parties that are not holders but are receiving the open | ||
| const skeleton = (function __unwipe(nd_array, replace) { | ||
| if (!(typeof nd_array.length === 'undefined') || nd_array.length === 0) { | ||
| const unwiped_array = []; | ||
| for (let k = 0; k < nd_array.length; k++) { | ||
| unwiped_array.push(__unwipe(nd_array[k], replace)); | ||
| } | ||
| return unwiped_array; | ||
| } | ||
| return replace; | ||
| })(shares, null); | ||
| jiff.emit(op_ids + 'skeleton', receivers_list, JSON.stringify(skeleton)); | ||
|
|
||
| resolve_open(shares); | ||
| } else { | ||
| // Populate skeleton with imitation shares | ||
| const revive_shares = function (skeleton) { | ||
| const share = new jiff.SecretShare({}, senders_list, senders_list.length, jiff.Zp); | ||
| return (function __unwipe(nd_array, replace) { | ||
| if (nd_array != null && !(typeof nd_array.length === 'undefined' && nd_array.length > 0)) { | ||
| const unwiped_array = []; | ||
| for (let k = 0; k < nd_array.length; k++) { | ||
| unwiped_array.push(__unwipe(nd_array[k], replace)); | ||
| } | ||
| return unwiped_array; | ||
| } | ||
| return replace; | ||
| })(skeleton, share); | ||
| }; | ||
|
|
||
| // If this party is not a sender, then the variable `shares` may be a skeleton | ||
| if (shares != null) { | ||
| // Use existing shares as skeleton to revive | ||
| shares = revive_shares(shares); | ||
| resolve_open(shares); | ||
| } else { | ||
| // Receive skeleton from senders | ||
| jiff.listen(op_ids + 'skeleton', function (sender, skeleton) { | ||
| jiff.remove_listener(op_ids + 'skeleton'); // This doesn't seem to work | ||
|
|
||
| if (typeof skeleton === 'string') { | ||
| skeleton = JSON.parse(skeleton); | ||
| } | ||
|
|
||
| shares = revive_shares(skeleton); | ||
| resolve_open(shares); | ||
| }); | ||
| } | ||
| } | ||
|
|
||
| return final_promise; | ||
| } | ||
|
|
||
| receive_open_ND_array(jiff, receivers_list, senders_list, threshold, Zp, op_ids) { | ||
| return open_ND_array(jiff, null, receivers_list, senders_list, op_ids); | ||
| } | ||
| } | ||
|
|
||
| module.exports = ArrayOpen; | ||