mirror of https://github.com/embarklabs/embark.git
rm old embark/_node.js files
This commit is contained in:
Michael Bradley, Jr
parent
b89211bd45
commit
be38eb6a89
437
js/embark.js
437
js/embark.js
|
|
@ -1,437 +0,0 @@
|
||||||
import {detectSeries} from 'async';
|
|
||||||
|
|
||||||
var EmbarkJS = {
|
|
||||||
onReady: function (cb) {
|
|
||||||
if (typeof (__embarkContext) === 'undefined') {
|
|
||||||
return cb();
|
|
||||||
}
|
|
||||||
return __embarkContext.execWhenReady(cb);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.isNewWeb3 = function (web3Obj) {
|
|
||||||
var _web3 = web3Obj || (new Web3());
|
|
||||||
if (typeof(_web3.version) === "string") {
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
return parseInt(_web3.version.api.split('.')[0], 10) >= 1;
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Contract = function (options) {
|
|
||||||
var self = this;
|
|
||||||
var i, abiElement;
|
|
||||||
var ContractClass;
|
|
||||||
|
|
||||||
this.abi = options.abi;
|
|
||||||
this.address = options.address;
|
|
||||||
this.gas = options.gas;
|
|
||||||
this.code = '0x' + options.code;
|
|
||||||
//this.web3 = options.web3 || web3;
|
|
||||||
this.web3 = options.web3;
|
|
||||||
if (!this.web3 && typeof (web3) !== 'undefined') {
|
|
||||||
this.web3 = web3;
|
|
||||||
} else if (!this.web3) {
|
|
||||||
this.web3 = window.web3;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (EmbarkJS.isNewWeb3(this.web3)) {
|
|
||||||
ContractClass = new this.web3.eth.Contract(this.abi, this.address);
|
|
||||||
ContractClass.setProvider(this.web3.currentProvider);
|
|
||||||
ContractClass.options.data = this.code;
|
|
||||||
ContractClass.options.from = this.from || this.web3.eth.defaultAccount;
|
|
||||||
ContractClass.abi = ContractClass.options.abi;
|
|
||||||
ContractClass.address = this.address;
|
|
||||||
ContractClass.gas = this.gas;
|
|
||||||
|
|
||||||
let originalMethods = Object.keys(ContractClass);
|
|
||||||
|
|
||||||
ContractClass._jsonInterface.forEach((abi) => {
|
|
||||||
if (originalMethods.indexOf(abi.name) >= 0) {
|
|
||||||
console.log(abi.name + " is a reserved word and cannot be used as a contract method, property or event");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!abi.inputs) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
let numExpectedInputs = abi.inputs.length;
|
|
||||||
|
|
||||||
if (abi.type === 'function' && abi.constant) {
|
|
||||||
ContractClass[abi.name] = function () {
|
|
||||||
let options = {}, cb = null, args = Array.from(arguments || []).slice(0, numExpectedInputs);
|
|
||||||
if (typeof (arguments[numExpectedInputs]) === 'function') {
|
|
||||||
cb = arguments[numExpectedInputs];
|
|
||||||
} else if (typeof (arguments[numExpectedInputs]) === 'object') {
|
|
||||||
options = arguments[numExpectedInputs];
|
|
||||||
cb = arguments[numExpectedInputs + 1];
|
|
||||||
}
|
|
||||||
|
|
||||||
let ref = ContractClass.methods[abi.name];
|
|
||||||
let call = ref.apply(ref, ...arguments).call;
|
|
||||||
return call.apply(call, []);
|
|
||||||
};
|
|
||||||
} else if (abi.type === 'function') {
|
|
||||||
ContractClass[abi.name] = function () {
|
|
||||||
let options = {}, cb = null, args = Array.from(arguments || []).slice(0, numExpectedInputs);
|
|
||||||
if (typeof (arguments[numExpectedInputs]) === 'function') {
|
|
||||||
cb = arguments[numExpectedInputs];
|
|
||||||
} else if (typeof (arguments[numExpectedInputs]) === 'object') {
|
|
||||||
options = arguments[numExpectedInputs];
|
|
||||||
cb = arguments[numExpectedInputs + 1];
|
|
||||||
}
|
|
||||||
|
|
||||||
let ref = ContractClass.methods[abi.name];
|
|
||||||
let send = ref.apply(ref, args).send;
|
|
||||||
return send.apply(send, [options, cb]);
|
|
||||||
};
|
|
||||||
} else if (abi.type === 'event') {
|
|
||||||
ContractClass[abi.name] = function (options, cb) {
|
|
||||||
let ref = ContractClass.events[abi.name];
|
|
||||||
return ref.apply(ref, [options, cb]);
|
|
||||||
};
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
return ContractClass;
|
|
||||||
} else {
|
|
||||||
ContractClass = this.web3.eth.contract(this.abi);
|
|
||||||
|
|
||||||
this.eventList = [];
|
|
||||||
|
|
||||||
if (this.abi) {
|
|
||||||
for (i = 0; i < this.abi.length; i++) {
|
|
||||||
abiElement = this.abi[i];
|
|
||||||
if (abiElement.type === 'event') {
|
|
||||||
this.eventList.push(abiElement.name);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
var messageEvents = function () {
|
|
||||||
this.cb = function () {
|
|
||||||
};
|
|
||||||
};
|
|
||||||
|
|
||||||
messageEvents.prototype.then = function (cb) {
|
|
||||||
this.cb = cb;
|
|
||||||
};
|
|
||||||
|
|
||||||
messageEvents.prototype.error = function (err) {
|
|
||||||
return err;
|
|
||||||
};
|
|
||||||
|
|
||||||
this._originalContractObject = ContractClass.at(this.address);
|
|
||||||
this._methods = Object.getOwnPropertyNames(this._originalContractObject).filter(function (p) {
|
|
||||||
// TODO: check for forbidden properties
|
|
||||||
if (self.eventList.indexOf(p) >= 0) {
|
|
||||||
|
|
||||||
self[p] = function () {
|
|
||||||
var promise = new messageEvents();
|
|
||||||
var args = Array.prototype.slice.call(arguments);
|
|
||||||
args.push(function (err, result) {
|
|
||||||
if (err) {
|
|
||||||
promise.error(err);
|
|
||||||
} else {
|
|
||||||
promise.cb(result);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
self._originalContractObject[p].apply(self._originalContractObject[p], args);
|
|
||||||
return promise;
|
|
||||||
};
|
|
||||||
return true;
|
|
||||||
} else if (typeof self._originalContractObject[p] === 'function') {
|
|
||||||
self[p] = function (_args) {
|
|
||||||
var args = Array.prototype.slice.call(arguments);
|
|
||||||
var fn = self._originalContractObject[p];
|
|
||||||
var props = self.abi.find((x) => x.name == p);
|
|
||||||
|
|
||||||
var promise = new Promise(function (resolve, reject) {
|
|
||||||
args.push(function (err, transaction) {
|
|
||||||
promise.tx = transaction;
|
|
||||||
if (err) {
|
|
||||||
return reject(err);
|
|
||||||
}
|
|
||||||
|
|
||||||
var getConfirmation = function () {
|
|
||||||
self.web3.eth.getTransactionReceipt(transaction, function (err, receipt) {
|
|
||||||
if (err) {
|
|
||||||
return reject(err);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (receipt !== null) {
|
|
||||||
return resolve(receipt);
|
|
||||||
}
|
|
||||||
|
|
||||||
setTimeout(getConfirmation, 1000);
|
|
||||||
});
|
|
||||||
};
|
|
||||||
|
|
||||||
if (typeof transaction !== "string" || props.constant) {
|
|
||||||
resolve(transaction);
|
|
||||||
} else {
|
|
||||||
getConfirmation();
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
fn.apply(fn, args);
|
|
||||||
});
|
|
||||||
|
|
||||||
return promise;
|
|
||||||
};
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
return false;
|
|
||||||
});
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Contract.prototype.deploy = function (args, _options) {
|
|
||||||
var self = this;
|
|
||||||
var contractParams;
|
|
||||||
var options = _options || {};
|
|
||||||
|
|
||||||
contractParams = args || [];
|
|
||||||
|
|
||||||
contractParams.push({
|
|
||||||
from: this.web3.eth.accounts[0],
|
|
||||||
data: this.code,
|
|
||||||
gas: options.gas || 800000
|
|
||||||
});
|
|
||||||
|
|
||||||
var contractObject = this.web3.eth.contract(this.abi);
|
|
||||||
|
|
||||||
var promise = new Promise(function (resolve, reject) {
|
|
||||||
contractParams.push(function (err, transaction) {
|
|
||||||
if (err) {
|
|
||||||
reject(err);
|
|
||||||
} else if (transaction.address !== undefined) {
|
|
||||||
resolve(new EmbarkJS.Contract({
|
|
||||||
abi: self.abi,
|
|
||||||
code: self.code,
|
|
||||||
address: transaction.address
|
|
||||||
}));
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
// returns promise
|
|
||||||
// deploys contract
|
|
||||||
// wraps it around EmbarkJS.Contract
|
|
||||||
contractObject["new"].apply(contractObject, contractParams);
|
|
||||||
});
|
|
||||||
|
|
||||||
|
|
||||||
return promise;
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Contract.prototype.new = EmbarkJS.Contract.prototype.deploy;
|
|
||||||
|
|
||||||
EmbarkJS.Contract.prototype.at = function (address) {
|
|
||||||
return new EmbarkJS.Contract({abi: this.abi, code: this.code, address: address});
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Contract.prototype.send = function (value, unit, _options) {
|
|
||||||
var options, wei;
|
|
||||||
if (typeof unit === 'object') {
|
|
||||||
options = unit;
|
|
||||||
wei = value;
|
|
||||||
} else {
|
|
||||||
options = _options || {};
|
|
||||||
wei = this.web3.toWei(value, unit);
|
|
||||||
}
|
|
||||||
|
|
||||||
options.to = this.address;
|
|
||||||
options.value = wei;
|
|
||||||
|
|
||||||
this.web3.eth.sendTransaction(options);
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Storage = {};
|
|
||||||
|
|
||||||
EmbarkJS.Storage.Providers = {};
|
|
||||||
|
|
||||||
EmbarkJS.Storage.saveText = function (text) {
|
|
||||||
if (!this.currentStorage) {
|
|
||||||
throw new Error('Storage provider not set; e.g EmbarkJS.Storage.setProvider("ipfs")');
|
|
||||||
}
|
|
||||||
return this.currentStorage.saveText(text);
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Storage.get = function (hash) {
|
|
||||||
if (!this.currentStorage) {
|
|
||||||
throw new Error('Storage provider not set; e.g EmbarkJS.Storage.setProvider("ipfs")');
|
|
||||||
}
|
|
||||||
return this.currentStorage.get(hash);
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Storage.uploadFile = function (inputSelector) {
|
|
||||||
if (!this.currentStorage) {
|
|
||||||
throw new Error('Storage provider not set; e.g EmbarkJS.Storage.setProvider("ipfs")');
|
|
||||||
}
|
|
||||||
return this.currentStorage.uploadFile(inputSelector);
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Storage.getUrl = function (hash) {
|
|
||||||
if (!this.currentStorage) {
|
|
||||||
throw new Error('Storage provider not set; e.g EmbarkJS.Storage.setProvider("ipfs")');
|
|
||||||
}
|
|
||||||
return this.currentStorage.getUrl(hash);
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Storage.registerProvider = function (providerName, obj) {
|
|
||||||
EmbarkJS.Storage.Providers[providerName] = obj;
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Storage.setProvider = function (provider, options) {
|
|
||||||
let providerObj = this.Providers[provider];
|
|
||||||
|
|
||||||
if (!providerObj) {
|
|
||||||
throw new Error('Unknown storage provider');
|
|
||||||
}
|
|
||||||
|
|
||||||
this.currentStorage = providerObj;
|
|
||||||
|
|
||||||
return providerObj.setProvider(options);
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Storage.isAvailable = function () {
|
|
||||||
if (!this.currentStorage) {
|
|
||||||
throw new Error('Storage provider not set; e.g EmbarkJS.Storage.setProvider("ipfs")');
|
|
||||||
}
|
|
||||||
return this.currentStorage.isAvailable();
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Storage.setProviders = async function (dappConnOptions) {
|
|
||||||
try {
|
|
||||||
await detectSeries(dappConnOptions, async (dappConn, callback) => {
|
|
||||||
if(dappConn === '$BZZ' || dappConn.provider === 'swarm'){
|
|
||||||
let options = dappConn;
|
|
||||||
if(dappConn === '$BZZ') options = {"useOnlyGivenProvider": true};
|
|
||||||
try{
|
|
||||||
await EmbarkJS.Storage.setProvider('swarm', options);
|
|
||||||
let isAvailable = await EmbarkJS.Storage.isAvailable();
|
|
||||||
callback(null, isAvailable);
|
|
||||||
}catch(err){
|
|
||||||
callback(null, false); // catch errors for when bzz object not initialised but config has requested it to be used
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else if(dappConn.provider === 'ipfs') {
|
|
||||||
// set the provider then check the connection, if true, use that provider, else, check next provider
|
|
||||||
try{
|
|
||||||
await EmbarkJS.Storage.setProvider('ipfs', dappConn);
|
|
||||||
let isAvailable = await EmbarkJS.Storage.isAvailable();
|
|
||||||
callback(null, isAvailable);
|
|
||||||
} catch(err) {
|
|
||||||
callback(null, false); // catch but keep looping by not passing err to callback
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}, function(err, result){
|
|
||||||
if(!result) throw new Error('Could not connect to a storage provider using any of the dappConnections in the storage config');
|
|
||||||
});
|
|
||||||
} catch (err) {
|
|
||||||
throw new Error('Failed to connect to a storage provider: ' + err.message);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Messages = {};
|
|
||||||
|
|
||||||
EmbarkJS.Messages.Providers = {};
|
|
||||||
|
|
||||||
EmbarkJS.Messages.registerProvider = function (providerName, obj) {
|
|
||||||
EmbarkJS.Messages.Providers[providerName] = obj;
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Messages.setProvider = function (provider, options) {
|
|
||||||
let providerObj = this.Providers[provider];
|
|
||||||
|
|
||||||
if (!providerObj) {
|
|
||||||
throw new Error('Unknown messages provider');
|
|
||||||
}
|
|
||||||
|
|
||||||
this.currentMessages = providerObj;
|
|
||||||
|
|
||||||
return providerObj.setProvider(options);
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Messages.isAvailable = function () {
|
|
||||||
return this.currentMessages.isAvailable();
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Messages.sendMessage = function (options) {
|
|
||||||
if (!this.currentMessages) {
|
|
||||||
throw new Error('Messages provider not set; e.g EmbarkJS.Messages.setProvider("whisper")');
|
|
||||||
}
|
|
||||||
return this.currentMessages.sendMessage(options);
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Messages.listenTo = function (options, callback) {
|
|
||||||
if (!this.currentMessages) {
|
|
||||||
throw new Error('Messages provider not set; e.g EmbarkJS.Messages.setProvider("whisper")');
|
|
||||||
}
|
|
||||||
return this.currentMessages.listenTo(options, callback);
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Names = {};
|
|
||||||
|
|
||||||
EmbarkJS.Names.Providers = {};
|
|
||||||
|
|
||||||
EmbarkJS.Names.registerProvider = function (providerName, obj) {
|
|
||||||
EmbarkJS.Names.Providers[providerName] = obj;
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Names.setProvider = function (provider, options) {
|
|
||||||
let providerObj = this.Providers[provider];
|
|
||||||
|
|
||||||
if (!providerObj) {
|
|
||||||
throw new Error('Unknown name system provider');
|
|
||||||
}
|
|
||||||
|
|
||||||
this.currentNameSystems = providerObj;
|
|
||||||
|
|
||||||
return providerObj.setProvider(options);
|
|
||||||
};
|
|
||||||
|
|
||||||
// resolve resolves a name into an identifier of some kind
|
|
||||||
EmbarkJS.Names.resolve = function (name, callback) {
|
|
||||||
if (!this.currentNameSystems) {
|
|
||||||
throw new Error('Name system provider not set; e.g EmbarkJS.Names.setProvider("ens")');
|
|
||||||
}
|
|
||||||
return this.currentNameSystems.resolve(name, callback);
|
|
||||||
};
|
|
||||||
|
|
||||||
// the reverse of resolve, resolves using an identifier to get to a name
|
|
||||||
EmbarkJS.Names.lookup = function (identifier, callback) {
|
|
||||||
if (!this.currentNameSystems) {
|
|
||||||
throw new Error('Name system provider not set; e.g EmbarkJS.Names.setProvider("ens")');
|
|
||||||
}
|
|
||||||
return this.currentNameSystems.lookup(identifier, callback);
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Names.isAvailable = function () {
|
|
||||||
return this.currentNameSystems.isAvailable();
|
|
||||||
};
|
|
||||||
|
|
||||||
// To Implement
|
|
||||||
|
|
||||||
|
|
||||||
// register a name
|
|
||||||
EmbarkJS.Names.register = function(name, options) {
|
|
||||||
if (!this.currentNameSystems) {
|
|
||||||
throw new Error('Name system provider not set; e.g EmbarkJS.Names.setProvider("ens")');
|
|
||||||
}
|
|
||||||
return this.currentNameSystems.register(name, options);
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Utils = {
|
|
||||||
fromAscii: function (str) {
|
|
||||||
var _web3 = new Web3();
|
|
||||||
return _web3.utils ? _web3.utils.fromAscii(str) : _web3.fromAscii(str);
|
|
||||||
},
|
|
||||||
toAscii: function (str) {
|
|
||||||
var _web3 = new Web3();
|
|
||||||
return _web3.utils.toAscii(str);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
export default EmbarkJS;
|
|
||||||
|
|
@ -1,395 +0,0 @@
|
||||||
var EmbarkJS = {
|
|
||||||
onReady: function(cb) {
|
|
||||||
if (typeof (__embarkContext) === 'undefined') {
|
|
||||||
return cb();
|
|
||||||
}
|
|
||||||
return __embarkContext.execWhenReady(cb);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.isNewWeb3 = function(web3Obj) {
|
|
||||||
var _web3 = web3Obj || (new Web3());
|
|
||||||
if (typeof(_web3.version) === "string") {
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
return parseInt(_web3.version.api.split('.')[0], 10) >= 1;
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Contract = function(options) {
|
|
||||||
var self = this;
|
|
||||||
var i, abiElement;
|
|
||||||
var ContractClass;
|
|
||||||
|
|
||||||
this.abi = options.abi;
|
|
||||||
this.address = options.address;
|
|
||||||
this.gas = options.gas;
|
|
||||||
this.code = '0x' + options.code;
|
|
||||||
//this.web3 = options.web3 || web3;
|
|
||||||
this.web3 = options.web3;
|
|
||||||
if (!this.web3 && typeof (web3) !== 'undefined') {
|
|
||||||
this.web3 = web3;
|
|
||||||
} else if (!this.web3) {
|
|
||||||
this.web3 = window.web3;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (EmbarkJS.isNewWeb3(this.web3)) {
|
|
||||||
ContractClass = new this.web3.eth.Contract(this.abi, this.address);
|
|
||||||
ContractClass.options.data = this.code;
|
|
||||||
ContractClass.options.from = this.from || this.web3.eth.defaultAccount;
|
|
||||||
ContractClass.abi = ContractClass.options.abi;
|
|
||||||
ContractClass.address = this.address;
|
|
||||||
ContractClass.gas = this.gas;
|
|
||||||
|
|
||||||
let originalMethods = Object.keys(ContractClass);
|
|
||||||
|
|
||||||
ContractClass._jsonInterface.forEach((abi) => {
|
|
||||||
if (originalMethods.indexOf(abi.name) >= 0) {
|
|
||||||
console.log(abi.name + " is a reserved word and cannot be used as a contract method, property or event");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!abi.inputs) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
let numExpectedInputs = abi.inputs.length;
|
|
||||||
|
|
||||||
if (abi.type === 'function' && abi.constant) {
|
|
||||||
ContractClass[abi.name] = function() {
|
|
||||||
let options = {}, cb = null, args = Array.from(arguments || []).slice(0, numExpectedInputs);
|
|
||||||
if (typeof (arguments[numExpectedInputs]) === 'function') {
|
|
||||||
cb = arguments[numExpectedInputs];
|
|
||||||
} else if (typeof (arguments[numExpectedInputs]) === 'object') {
|
|
||||||
options = arguments[numExpectedInputs];
|
|
||||||
cb = arguments[numExpectedInputs + 1];
|
|
||||||
}
|
|
||||||
|
|
||||||
let ref = ContractClass.methods[abi.name];
|
|
||||||
let call = ref.apply(ref, ...arguments).call;
|
|
||||||
return call.apply(call, []);
|
|
||||||
};
|
|
||||||
} else if (abi.type === 'function') {
|
|
||||||
ContractClass[abi.name] = function() {
|
|
||||||
let options = {}, cb = null, args = Array.from(arguments || []).slice(0, numExpectedInputs);
|
|
||||||
if (typeof (arguments[numExpectedInputs]) === 'function') {
|
|
||||||
cb = arguments[numExpectedInputs];
|
|
||||||
} else if (typeof (arguments[numExpectedInputs]) === 'object') {
|
|
||||||
options = arguments[numExpectedInputs];
|
|
||||||
cb = arguments[numExpectedInputs + 1];
|
|
||||||
}
|
|
||||||
|
|
||||||
let ref = ContractClass.methods[abi.name];
|
|
||||||
let send = ref.apply(ref, args).send;
|
|
||||||
return send.apply(send, [options, cb]);
|
|
||||||
};
|
|
||||||
} else if (abi.type === 'event') {
|
|
||||||
ContractClass[abi.name] = function(options, cb) {
|
|
||||||
let ref = ContractClass.events[abi.name];
|
|
||||||
return ref.apply(ref, [options, cb]);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
return ContractClass;
|
|
||||||
} else {
|
|
||||||
ContractClass = this.web3.eth.contract(this.abi);
|
|
||||||
|
|
||||||
this.eventList = [];
|
|
||||||
|
|
||||||
if (this.abi) {
|
|
||||||
for (i = 0; i < this.abi.length; i++) {
|
|
||||||
abiElement = this.abi[i];
|
|
||||||
if (abiElement.type === 'event') {
|
|
||||||
this.eventList.push(abiElement.name);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
var messageEvents = function() {
|
|
||||||
this.cb = function() {};
|
|
||||||
};
|
|
||||||
|
|
||||||
messageEvents.prototype.then = function(cb) {
|
|
||||||
this.cb = cb;
|
|
||||||
};
|
|
||||||
|
|
||||||
messageEvents.prototype.error = function(err) {
|
|
||||||
return err;
|
|
||||||
};
|
|
||||||
|
|
||||||
this._originalContractObject = ContractClass.at(this.address);
|
|
||||||
this._methods = Object.getOwnPropertyNames(this._originalContractObject).filter(function(p) {
|
|
||||||
// TODO: check for forbidden properties
|
|
||||||
if (self.eventList.indexOf(p) >= 0) {
|
|
||||||
|
|
||||||
self[p] = function() {
|
|
||||||
var promise = new messageEvents();
|
|
||||||
var args = Array.prototype.slice.call(arguments);
|
|
||||||
args.push(function(err, result) {
|
|
||||||
if (err) {
|
|
||||||
promise.error(err);
|
|
||||||
} else {
|
|
||||||
promise.cb(result);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
self._originalContractObject[p].apply(self._originalContractObject[p], args);
|
|
||||||
return promise;
|
|
||||||
};
|
|
||||||
return true;
|
|
||||||
} else if (typeof self._originalContractObject[p] === 'function') {
|
|
||||||
self[p] = function(_args) {
|
|
||||||
var args = Array.prototype.slice.call(arguments);
|
|
||||||
var fn = self._originalContractObject[p];
|
|
||||||
var props = self.abi.find((x) => x.name == p);
|
|
||||||
|
|
||||||
var promise = new Promise(function(resolve, reject) {
|
|
||||||
args.push(function(err, transaction) {
|
|
||||||
promise.tx = transaction;
|
|
||||||
if (err) {
|
|
||||||
return reject(err);
|
|
||||||
}
|
|
||||||
|
|
||||||
var getConfirmation = function() {
|
|
||||||
self.web3.eth.getTransactionReceipt(transaction, function(err, receipt) {
|
|
||||||
if (err) {
|
|
||||||
return reject(err);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (receipt !== null) {
|
|
||||||
return resolve(receipt);
|
|
||||||
}
|
|
||||||
|
|
||||||
setTimeout(getConfirmation, 1000);
|
|
||||||
});
|
|
||||||
};
|
|
||||||
|
|
||||||
if (typeof(transaction) !== "string" || props.constant) {
|
|
||||||
resolve(transaction);
|
|
||||||
} else {
|
|
||||||
getConfirmation();
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
fn.apply(fn, args);
|
|
||||||
});
|
|
||||||
|
|
||||||
return promise;
|
|
||||||
};
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
return false;
|
|
||||||
});
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Contract.prototype.deploy = function(args, _options) {
|
|
||||||
var self = this;
|
|
||||||
var contractParams;
|
|
||||||
var options = _options || {};
|
|
||||||
|
|
||||||
contractParams = args || [];
|
|
||||||
|
|
||||||
contractParams.push({
|
|
||||||
from: this.web3.eth.accounts[0],
|
|
||||||
data: this.code,
|
|
||||||
gas: options.gas || 800000
|
|
||||||
});
|
|
||||||
|
|
||||||
var contractObject = this.web3.eth.contract(this.abi);
|
|
||||||
|
|
||||||
var promise = new Promise(function(resolve, reject) {
|
|
||||||
contractParams.push(function(err, transaction) {
|
|
||||||
if (err) {
|
|
||||||
reject(err);
|
|
||||||
} else if (transaction.address !== undefined) {
|
|
||||||
resolve(new EmbarkJS.Contract({
|
|
||||||
abi: self.abi,
|
|
||||||
code: self.code,
|
|
||||||
address: transaction.address
|
|
||||||
}));
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
// returns promise
|
|
||||||
// deploys contract
|
|
||||||
// wraps it around EmbarkJS.Contract
|
|
||||||
contractObject["new"].apply(contractObject, contractParams);
|
|
||||||
});
|
|
||||||
|
|
||||||
|
|
||||||
return promise;
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Contract.prototype.new = EmbarkJS.Contract.prototype.deploy;
|
|
||||||
|
|
||||||
EmbarkJS.Contract.prototype.at = function(address) {
|
|
||||||
return new EmbarkJS.Contract({ abi: this.abi, code: this.code, address: address });
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Contract.prototype.send = function(value, unit, _options) {
|
|
||||||
var options, wei;
|
|
||||||
if (typeof unit === 'object') {
|
|
||||||
options = unit;
|
|
||||||
wei = value;
|
|
||||||
} else {
|
|
||||||
options = _options || {};
|
|
||||||
wei = this.web3.toWei(value, unit);
|
|
||||||
}
|
|
||||||
|
|
||||||
options.to = this.address;
|
|
||||||
options.value = wei;
|
|
||||||
|
|
||||||
this.web3.eth.sendTransaction(options);
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Storage = {};
|
|
||||||
|
|
||||||
EmbarkJS.Storage.Providers = {};
|
|
||||||
|
|
||||||
EmbarkJS.Storage.saveText = function(text) {
|
|
||||||
if (!this.currentStorage) {
|
|
||||||
throw new Error('Storage provider not set; e.g EmbarkJS.Storage.setProvider("ipfs")');
|
|
||||||
}
|
|
||||||
return this.currentStorage.saveText(text);
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Storage.get = function(hash) {
|
|
||||||
if (!this.currentStorage) {
|
|
||||||
throw new Error('Storage provider not set; e.g EmbarkJS.Storage.setProvider("ipfs")');
|
|
||||||
}
|
|
||||||
return this.currentStorage.get(hash);
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Storage.uploadFile = function(inputSelector) {
|
|
||||||
if (!this.currentStorage) {
|
|
||||||
throw new Error('Storage provider not set; e.g EmbarkJS.Storage.setProvider("ipfs")');
|
|
||||||
}
|
|
||||||
return this.currentStorage.uploadFile(inputSelector);
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Storage.getUrl = function(hash) {
|
|
||||||
if (!this.currentStorage) {
|
|
||||||
throw new Error('Storage provider not set; e.g EmbarkJS.Storage.setProvider("ipfs")');
|
|
||||||
}
|
|
||||||
return this.currentStorage.getUrl(hash);
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Storage.registerProvider = function(providerName, obj) {
|
|
||||||
EmbarkJS.Storage.Providers[providerName] = obj;
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Storage.setProvider = function(provider, options) {
|
|
||||||
let providerObj = this.Providers[provider];
|
|
||||||
|
|
||||||
if (!providerObj) {
|
|
||||||
throw new Error('Unknown storage provider');
|
|
||||||
}
|
|
||||||
|
|
||||||
this.currentStorage = providerObj;
|
|
||||||
|
|
||||||
return providerObj.setProvider(options);
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Storage.isAvailable = function(){
|
|
||||||
if (!this.currentStorage) {
|
|
||||||
throw new Error('Storage provider not set; e.g EmbarkJS.Storage.setProvider("ipfs")');
|
|
||||||
}
|
|
||||||
return this.currentStorage.isAvailable();
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Messages = {};
|
|
||||||
|
|
||||||
EmbarkJS.Messages.Providers = {};
|
|
||||||
|
|
||||||
EmbarkJS.Messages.registerProvider = function(providerName, obj) {
|
|
||||||
EmbarkJS.Messages.Providers[providerName] = obj;
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Messages.setProvider = function(provider, options) {
|
|
||||||
let providerObj = this.Providers[provider];
|
|
||||||
|
|
||||||
if (!providerObj) {
|
|
||||||
throw new Error('Unknown messages provider');
|
|
||||||
}
|
|
||||||
|
|
||||||
this.currentMessages = providerObj;
|
|
||||||
|
|
||||||
return providerObj.setProvider(options);
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Messages.isAvailable = function(){
|
|
||||||
return this.currentMessages.isAvailable();
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Messages.sendMessage = function(options) {
|
|
||||||
if (!this.currentMessages) {
|
|
||||||
throw new Error('Messages provider not set; e.g EmbarkJS.Messages.setProvider("whisper")');
|
|
||||||
}
|
|
||||||
return this.currentMessages.sendMessage(options);
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Messages.listenTo = function(options, callback) {
|
|
||||||
if (!this.currentMessages) {
|
|
||||||
throw new Error('Messages provider not set; e.g EmbarkJS.Messages.setProvider("whisper")');
|
|
||||||
}
|
|
||||||
return this.currentMessages.listenTo(options, callback);
|
|
||||||
};
|
|
||||||
|
|
||||||
EmbarkJS.Names = {};
|
|
||||||
|
|
||||||
EmbarkJS.Names.Providers = {};
|
|
||||||
|
|
||||||
EmbarkJS.Names.registerProvider = function(providerName, obj) {
|
|
||||||
EmbarkJS.Names.Providers[providerName] = obj;
|
|
||||||
}
|
|
||||||
|
|
||||||
EmbarkJS.Names.setProvider = function(provider, options) {
|
|
||||||
let providerObj = this.Providers[provider];
|
|
||||||
|
|
||||||
if (!providerObj) {
|
|
||||||
throw new Error('Unknown name system provider');
|
|
||||||
}
|
|
||||||
|
|
||||||
this.currentNameSystems = providerObj;
|
|
||||||
|
|
||||||
return providerObj.setProvider(options);
|
|
||||||
};
|
|
||||||
|
|
||||||
// resolve resolves a name into an identifier of some kind
|
|
||||||
EmbarkJS.Names.resolve = function(name) {
|
|
||||||
if (!this.currentNameSystems) {
|
|
||||||
throw new Error('Name system provider not set; e.g EmbarkJS.Names.setProvider("ens")');
|
|
||||||
}
|
|
||||||
return this.currentNameSystems.resolve(name);
|
|
||||||
}
|
|
||||||
|
|
||||||
// the reverse of resolve, resolves using an identifier to get to a name
|
|
||||||
EmbarkJS.Names.lookup = function(identifier) {
|
|
||||||
if (!this.currentNameSystems) {
|
|
||||||
throw new Error('Name system provider not set; e.g EmbarkJS.Names.setProvider("ens")');
|
|
||||||
}
|
|
||||||
return this.currentNameSystems.lookup(identifier);
|
|
||||||
}
|
|
||||||
|
|
||||||
// To Implement
|
|
||||||
|
|
||||||
/*
|
|
||||||
// register a name
|
|
||||||
EmbarkJS.Names.register = function(name, options) {
|
|
||||||
|
|
||||||
}
|
|
||||||
*/
|
|
||||||
|
|
||||||
EmbarkJS.Utils = {
|
|
||||||
fromAscii: function(str) {
|
|
||||||
var _web3 = new Web3();
|
|
||||||
return _web3.utils ? _web3.utils.fromAscii(str) : _web3.fromAscii(str);
|
|
||||||
},
|
|
||||||
toAscii: function(str) {
|
|
||||||
var _web3 = new Web3();
|
|
||||||
return _web3.utils.toAscii(str);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
module.exports = EmbarkJS;
|
|
||||||
Loading…
Reference in New Issue