@solana/web3.js - npm Package Compare versions

Comparing version 0.6.11 to 0.6.12

lib/index.cjs.js

@@ -1,1 +0,1 @@
-"use strict";function _interopDefault(e){return e&&"object"==typeof e&&"default"in e?e.default:e}Object.defineProperty(exports,"__esModule",{value:!0});var _classCallCheck=_interopDefault(require("babel-runtime/helpers/classCallCheck")),_createClass=_interopDefault(require("babel-runtime/helpers/createClass")),BN=_interopDefault(require("bn.js")),bs58=_interopDefault(require("bs58")),nacl=_interopDefault(require("tweetnacl")),BufferLayout=require("buffer-layout"),_toConsumableArray=_interopDefault(require("babel-runtime/helpers/toConsumableArray")),_Object$assign=_interopDefault(require("babel-runtime/core-js/object/assign")),assert=_interopDefault(require("assert")),_getIterator=_interopDefault(require("babel-runtime/core-js/get-iterator")),_Promise=_interopDefault(require("babel-runtime/core-js/promise")),_regeneratorRuntime=_interopDefault(require("babel-runtime/regenerator")),_asyncToGenerator=_interopDefault(require("babel-runtime/helpers/asyncToGenerator")),fetch=_interopDefault(require("node-fetch")),jayson=_interopDefault(require("jayson/lib/client/browser")),superstruct=require("superstruct"),_JSON$stringify=_interopDefault(require("babel-runtime/core-js/json/stringify")),_Object$getPrototypeOf=_interopDefault(require("babel-runtime/core-js/object/get-prototype-of")),_possibleConstructorReturn=_interopDefault(require("babel-runtime/helpers/possibleConstructorReturn")),_get=_interopDefault(require("babel-runtime/helpers/get")),_inherits=_interopDefault(require("babel-runtime/helpers/inherits")),PublicKey=function(){function e(r){for(_classCallCheck(this,e);;){if("string"==typeof r){if(/^[1-9A-HJ-NP-Za-km-z]{43,44}$/.test(r)){this._bn=new BN(bs58.decode(r));break}if(r.startsWith("0x")){this._bn=new BN(r.substring(2),16);break}}this._bn=new BN(r);break}if(this._bn.byteLength()>32)throw Error("Invalid public key input")}return _createClass(e,[{key:"equals",value:function(e){return this._bn.eq(e._bn)}},{key:"toBase58",value:function(){return bs58.encode(this.toBuffer())}},{key:"toBuffer",value:function(){var e=this._bn.toArrayLike(Buffer);if(32===e.length)return e;var r=Buffer.alloc(32);return e.copy(r,32-e.length),r}},{key:"toString",value:function(){return this.toBase58()}}],[{key:"isPublicKey",value:function(r){return r instanceof e}}]),e}(),Account=function(){function e(){var r=arguments.length>0&&void 0!==arguments[0]?arguments[0]:null;_classCallCheck(this,e),this._keypair=r?nacl.sign.keyPair.fromSecretKey(r):nacl.sign.keyPair()}return _createClass(e,[{key:"publicKey",get:function(){return new PublicKey(this._keypair.publicKey)}},{key:"secretKey",get:function(){return this._keypair.secretKey}}]),e}(),publicKey=function(){return BufferLayout.blob(32,arguments.length>0&&void 0!==arguments[0]?arguments[0]:"publicKey")},uint64=function(){return BufferLayout.blob(8,arguments.length>0&&void 0!==arguments[0]?arguments[0]:"uint64")},rustString=function(){var e=arguments.length>0&&void 0!==arguments[0]?arguments[0]:"string",r=BufferLayout.struct([BufferLayout.u32("length"),BufferLayout.u32("lengthPadding"),BufferLayout.blob(BufferLayout.offset(BufferLayout.u32(),-8),"chars")],e),t=r.decode.bind(r),n=r.encode.bind(r);return r.decode=function(e,r){return t(e,r).chars.toString("utf8")},r.encode=function(e,r,t){var a={chars:Buffer.from(e,"utf8")};return n(a,r,t)},r},Transaction=function(){function e(r){_classCallCheck(this,e),this.keys=[],this.fee=0,this.userdata=Buffer.alloc(0),r&&_Object$assign(this,r)}return _createClass(e,[{key:"_getSignData",value:function(){var e=this.lastId,r=this.keys,t=this.programId,n=this.userdata;if(!e)throw Error("Transaction lastId required");var a=[t],u=[{programId:0,accountsLength:r.length,accounts:[].concat(_toConsumableArray(r.keys())),userdataLength:n.length,userdata:n}],o=BufferLayout.struct([BufferLayout.u8("programId"),BufferLayout.u32("accountsLength"),BufferLayout.u32("accountsLengthPadding"),BufferLayout.seq(BufferLayout.u8("account"),BufferLayout.offset(BufferLayout.u32(),-8),"accounts"),BufferLayout.ns64("userdataLength"),BufferLayout.blob(n.length,"userdata")]),s=BufferLayout.struct([BufferLayout.u32("accountKeysLength"),BufferLayout.u32("accountKeysLengthPadding"),BufferLayout.seq(publicKey("accountKey"),BufferLayout.offset(BufferLayout.u32(),-8),"accountKeys"),publicKey("lastId"),BufferLayout.ns64("fee"),BufferLayout.u32("programIdsLength"),BufferLayout.u32("programIdsLengthPadding"),BufferLayout.seq(publicKey("programId"),BufferLayout.offset(BufferLayout.u32(),-8),"programIds"),BufferLayout.u32("instructionsLength"),BufferLayout.u32("instructionsLengthPadding"),BufferLayout.seq(o,BufferLayout.offset(BufferLayout.u32(),-8),"instructions")]),i={accountKeys:r.map(function(e){return e.toBuffer()}),lastId:Buffer.from(bs58.decode(e)),fee:0,programIds:a.map(function(e){return e.toBuffer()}),instructions:u},c=Buffer.alloc(2048),f=s.encode(i,c);return c=c.slice(0,f)}},{key:"sign",value:function(e){var r=this._getSignData();this.signature=nacl.sign.detached(r,e.secretKey),assert(64===this.signature.length)}},{key:"serialize",value:function(){var e=this.signature;if(!e)throw Error("Transaction has not been signed");var r=this._getSignData(),t=Buffer.alloc(e.length+r.length);return Buffer.from(e).copy(t,0),r.copy(t,e.length),t}}]),e}();function serializePayment(e){var r=e.to.toBuffer(),t=Buffer.alloc(8+r.length);return t.writeUInt32LE(e.amount,0),r.copy(t,8),t}function serializeDate(e){var r=Buffer.alloc(28);return r.writeUInt32LE(20,0),r.write(function(e){function r(e){return 10>e?"0"+e:e}return e.getUTCFullYear()+"-"+r(e.getUTCMonth()+1)+"-"+r(e.getUTCDate())+"T"+r(e.getUTCHours())+":"+r(e.getUTCMinutes())+":"+r(e.getUTCSeconds())+"Z"}(e),8),r}function serializeCondition(e){switch(e.type){case"timestamp":var r=serializeDate(e.when),t=e.from.toBuffer(),n=Buffer.alloc(4+r.length+t.length);return n.writeUInt32LE(0,0),r.copy(n,4),t.copy(n,4+r.length),n;case"signature":var a=BufferLayout.struct([BufferLayout.u32("condition"),publicKey("from")]),u=e.from.toBuffer(),o=Buffer.alloc(4+u.length);return a.encode({instruction:1,from:u},o),o;default:throw Error("Unknown condition type: "+e.type)}}var BudgetProgram=function(){function e(){_classCallCheck(this,e)}return _createClass(e,null,[{key:"timestampCondition",value:function(e,r){return{type:"timestamp",from:e,when:r}}},{key:"signatureCondition",value:function(e){return{type:"signature",from:e}}},{key:"pay",value:function(e,r,t,n){var a=Buffer.alloc(1024),u=0;a.writeUInt32LE(0,u),a.writeUInt32LE(n,u+=4),u+=8;for(var o=arguments.length,s=Array(o>4?o-4:0),i=4;o>i;i++)s[i-4]=arguments[i];switch(s.length){case 0:a.writeUInt32LE(0,u),u+=4;var c=serializePayment({amount:n,to:t});return c.copy(a,u),new Transaction({fee:0,keys:[e,t],programId:this.programId,userdata:a.slice(0,u+=c.length)});case 1:a.writeUInt32LE(1,u),u+=4;var f=serializeCondition(s[0]);f.copy(a,u),u+=f.length;var l=serializePayment({amount:n,to:t});return l.copy(a,u),new Transaction({fee:0,keys:[e,r,t],programId:this.programId,userdata:a.slice(0,u+=l.length)});case 2:a.writeUInt32LE(2,u),u+=4;var p=!0,y=!1,d=void 0;try{for(var g,m=_getIterator(s);!(p=(g=m.next()).done);p=!0){var h=serializeCondition(g.value);h.copy(a,u),u+=h.length;var b=serializePayment({amount:n,to:t});b.copy(a,u),u+=b.length}}catch(e){y=!0,d=e}finally{try{!p&&m.return&&m.return()}finally{if(y)throw d}}return new Transaction({fee:0,keys:[e,r,t],programId:this.programId,userdata:a.slice(0,u)});default:throw Error("A maximum of two conditions are support: "+s.length+" provided")}}},{key:"payOnBoth",value:function(e,r,t,n,a,u){var o=Buffer.alloc(1024),s=0;o.writeUInt32LE(0,s),o.writeUInt32LE(n,s+=4),o.writeUInt32LE(3,s+=8),s+=4;for(var i=[a,u],c=0;i.length>c;c++){var f=serializeCondition(i[c]);f.copy(o,s),s+=f.length}var l=serializePayment({amount:n,to:t});return l.copy(o,s),new Transaction({fee:0,keys:[e,r,t],programId:this.programId,userdata:o.slice(0,s+=l.length)})}},{key:"applyTimestamp",value:function(e,r,t,n){var a=serializeDate(n),u=Buffer.alloc(4+a.length);return u.writeUInt32LE(1,0),a.copy(u,4),new Transaction({fee:0,keys:[e,r,t],programId:this.programId,userdata:u})}},{key:"applySignature",value:function(e,r,t){var n=BufferLayout.struct([BufferLayout.u32("instruction")]),a=Buffer.alloc(n.span);return n.encode({instruction:2},a),new Transaction({fee:0,keys:[e,r,t],programId:this.programId,userdata:a})}},{key:"programId",get:function(){return new PublicKey("0x100000000000000000000000000000000000000000000000000000000000000")}},{key:"space",get:function(){return 128}}]),e}();function sleep(e){return new _Promise(function(r){return setTimeout(r,e)})}function createRpcRequest(e){var r,t=this,n=jayson((r=_asyncToGenerator(_regeneratorRuntime.mark(function r(n,a){var u,o;return _regeneratorRuntime.wrap(function(r){for(;;)switch(r.prev=r.next){case 0:return u={method:"POST",body:n,headers:{"Content-Type":"application/json"}},r.prev=1,r.next=4,fetch(e,u);case 4:return o=r.sent,r.next=7,o.text();case 7:a(null,r.sent),r.next=14;break;case 11:r.prev=11,r.t0=r.catch(1),a(r.t0);case 14:case"end":return r.stop()}},r,t,[[1,11]])})),function(e,t){return r.apply(this,arguments)}));return function(e,r){return new _Promise(function(t,a){n.request(e,r,function(e,r){e?a(e):t(r)})})}}var GetBalanceRpcResult=superstruct.struct({jsonrpc:superstruct.struct.literal("2.0"),id:"string",error:"any?",result:"number?"});function jsonRpcResult(e){var r=superstruct.struct.literal("2.0");return superstruct.struct.union([superstruct.struct({jsonrpc:r,id:"string",error:"any"}),superstruct.struct({jsonrpc:r,id:"string",error:"null?",result:e})])}var GetAccountInfoRpcResult=jsonRpcResult({executable:"boolean",loader_program_id:"array",program_id:"array",tokens:"number",userdata:"array"}),ConfirmTransactionRpcResult=jsonRpcResult("boolean"),GetSignatureStatusRpcResult=jsonRpcResult(superstruct.struct.enum(["Confirmed","SignatureNotFound","ProgramRuntimeError","GenericFailure"])),GetTransactionCountRpcResult=jsonRpcResult("number"),GetLastId=jsonRpcResult("string"),GetFinalityRpcResult=jsonRpcResult("number"),RequestAirdropRpcResult=jsonRpcResult("string"),SendTokensRpcResult=jsonRpcResult("string"),Connection=function(){function e(r){if(_classCallCheck(this,e),this._disableLastIdCaching=!1,"string"!=typeof r)throw Error("Connection endpoint not specified");this._rpcRequest=createRpcRequest(r),this._lastIdInfo={lastId:null,seconds:-1,transactionSignatures:[]}}return _createClass(e,[{key:"getBalance",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getBalance",[r.toBase58()]);case 2:if(!(t=GetBalanceRpcResult(e.sent)).error){e.next=6;break}throw Error(t.error.message);case 6:return assert(void 0!==t.result),e.abrupt("return",t.result);case 8:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"getAccountInfo",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t,n;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getAccountInfo",[r.toBase58()]);case 2:if(!(t=GetAccountInfoRpcResult(e.sent)).error){e.next=6;break}throw Error(t.error.message);case 6:return assert(void 0!==(n=t.result)),e.abrupt("return",{executable:n.executable,tokens:n.tokens,programId:new PublicKey(n.program_id),loaderProgramId:new PublicKey(n.loader_program_id),userdata:Buffer.from(n.userdata)});case 9:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"confirmTransaction",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("confirmTransaction",[r]);case 2:if(!(t=ConfirmTransactionRpcResult(e.sent)).error){e.next=6;break}throw Error(t.error.message);case 6:return assert(void 0!==t.result),e.abrupt("return",t.result);case 8:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"getSignatureStatus",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getSignatureStatus",[r]);case 2:if(!(t=GetSignatureStatusRpcResult(e.sent)).error){e.next=6;break}throw Error(t.error.message);case 6:return assert(void 0!==t.result),e.abrupt("return",t.result);case 8:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"getTransactionCount",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(){var r;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getTransactionCount",[]);case 2:if(!(r=GetTransactionCountRpcResult(e.sent)).error){e.next=6;break}throw Error(r.error.message);case 6:return assert(void 0!==r.result),e.abrupt("return",+r.result);case 8:case"end":return e.stop()}},e,this)}));return function(){return e.apply(this,arguments)}}()},{key:"getLastId",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(){var r;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getLastId",[]);case 2:if(!(r=GetLastId(e.sent)).error){e.next=6;break}throw Error(r.error.message);case 6:return assert(void 0!==r.result),e.abrupt("return",r.result);case 8:case"end":return e.stop()}},e,this)}));return function(){return e.apply(this,arguments)}}()},{key:"getFinality",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(){var r;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getFinality",[]);case 2:if(!(r=GetFinalityRpcResult(e.sent)).error){e.next=6;break}throw Error(r.error.message);case 6:return assert(void 0!==r.result),e.abrupt("return",+r.result);case 8:case"end":return e.stop()}},e,this)}));return function(){return e.apply(this,arguments)}}()},{key:"requestAirdrop",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t){var n;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("requestAirdrop",[r.toBase58(),t]);case 2:if(!(n=RequestAirdropRpcResult(e.sent)).error){e.next=6;break}throw Error(n.error.message);case 6:return assert(void 0!==n.result),e.abrupt("return",n.result);case 8:case"end":return e.stop()}},e,this)}));return function(r,t){return e.apply(this,arguments)}}()},{key:"sendTransaction",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t){var n,a,u,o,s,i;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:if(n=(new Date).getSeconds(),null==this._lastIdInfo.lastId||this._lastIdInfo.seconds!==n){e.next=11;break}if(t.lastId=this._lastIdInfo.lastId,t.sign(r),t.signature){e.next=6;break}throw Error("!signature");case 6:if(this._lastIdInfo.transactionSignatures.includes(a=""+t.signature)){e.next=11;break}return this._lastIdInfo.transactionSignatures.push(a),this._disableLastIdCaching&&(this._lastIdInfo.seconds=-1),e.abrupt("break",27);case 11:u=0;case 12:return e.next=14,this.getLastId();case 14:if(this._lastIdInfo.lastId==(o=e.sent)){e.next=18;break}return this._lastIdInfo={lastId:o,seconds:(new Date).getSeconds(),transactionSignatures:[]},e.abrupt("break",25);case 18:if(8!==u){e.next=20;break}throw Error("Unable to obtain new last id");case 20:return e.next=22,sleep(250);case 22:++u;case 23:e.next=12;break;case 25:e.next=0;break;case 27:return s=t.serialize(),e.next=30,this._rpcRequest("sendTransaction",[[].concat(_toConsumableArray(s))]);case 30:if(!(i=SendTokensRpcResult(e.sent)).error){e.next=34;break}throw Error(i.error.message);case 34:return assert(void 0!==i.result),assert(i.result),e.abrupt("return",i.result);case 37:case"end":return e.stop()}},e,this)}));return function(r,t){return e.apply(this,arguments)}}()}]),e}(),sendAndConfirmTransaction$$1=function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t,n){var a,u,o,s,i,c=arguments.length>3&&void 0!==arguments[3]&&arguments[3];return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return a=Date.now(),e.next=3,r.sendTransaction(t,n);case 3:u=e.sent,o=4;case 5:return e.next=7,r.getSignatureStatus(u);case 7:e.t0=s=e.sent,e.next="Confirmed"===e.t0?11:"ProgramRuntimeError"===e.t0?12:"GenericError"===e.t0?14:"SignatureNotFound"===e.t0?15:14;break;case 11:return e.abrupt("return");case 12:if(!c){e.next=14;break}return e.abrupt("return");case 14:throw Error("Transaction "+u+" failed ("+s+")");case 15:return e.abrupt("break",16);case 16:return e.next=18,sleep(500);case 18:if(0<=--o){e.next=21;break}throw i=(Date.now()-a)/1e3,Error("Transaction '"+u+"' was not confirmed in "+i.toFixed(2)+" seconds ("+s+")");case 21:e.next=5;break;case 23:case"end":return e.stop()}},e,this)}));return function(r,t,n){return e.apply(this,arguments)}}(),Loader$$1=function(){function e(r,t){_classCallCheck(this,e),_Object$assign(this,{connection:r,programId:t})}return _createClass(e,[{key:"load",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t,n){var a,u,o;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return a=BufferLayout.struct([BufferLayout.u32("instruction"),BufferLayout.u32("offset"),BufferLayout.u32("bytesLength"),BufferLayout.u32("bytesLengthPadding"),BufferLayout.seq(BufferLayout.u8("byte"),BufferLayout.offset(BufferLayout.u32(),-8),"bytes")]),u=Buffer.alloc(n.length+16),a.encode({instruction:0,offset:t,bytes:n},u),o=new Transaction({fee:0,keys:[r.publicKey],programId:this.programId,userdata:u}),e.next=6,sendAndConfirmTransaction$$1(this.connection,r,o);case 6:case"end":return e.stop()}},e,this)}));return function(r,t,n){return e.apply(this,arguments)}}()},{key:"finalize",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t,n,a;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return t=BufferLayout.struct([BufferLayout.u32("instruction")]),n=Buffer.alloc(t.span),t.encode({instruction:1},n),a=new Transaction({fee:0,keys:[r.publicKey],programId:this.programId,userdata:n}),e.next=6,sendAndConfirmTransaction$$1(this.connection,r,a);case 6:return a=SystemProgram.spawn(r.publicKey),e.next=9,sendAndConfirmTransaction$$1(this.connection,r,a);case 9:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()}]),e}(),NativeLoader$$1=function(){function e(){_classCallCheck(this,e)}return _createClass(e,null,[{key:"load",value:function(){var r=_asyncToGenerator(_regeneratorRuntime.mark(function r(t,n,a){var u,o,s,i;return _regeneratorRuntime.wrap(function(r){for(;;)switch(r.prev=r.next){case 0:return u=[].concat(_toConsumableArray(Buffer.from(a))),o=new Account,s=SystemProgram.createAccount(n.publicKey,o.publicKey,1,u.length+1,e.programId),r.next=5,sendAndConfirmTransaction$$1(t,n,s);case 5:return i=new Loader$$1(t,e.programId),r.next=8,i.load(o,0,u);case 8:return r.next=10,i.finalize(o);case 10:return r.abrupt("return",o.publicKey);case 11:case"end":return r.stop()}},r,this)}));return function(e,t,n){return r.apply(this,arguments)}}()},{key:"programId",get:function(){return new PublicKey("0x0202020202020202020202020202020202020202020202020202020202020202")}}]),e}(),SystemProgram=function(){function e(){_classCallCheck(this,e)}return _createClass(e,null,[{key:"createAccount",value:function(r,t,n,a,u){var o=BufferLayout.struct([BufferLayout.u32("instruction"),BufferLayout.ns64("tokens"),BufferLayout.ns64("space"),publicKey("programId")]),s=Buffer.alloc(o.span);return o.encode({instruction:0,tokens:n,space:a,programId:u.toBuffer()},s),new Transaction({fee:0,keys:[r,t],programId:e.programId,userdata:s})}},{key:"move",value:function(r,t,n){var a=BufferLayout.struct([BufferLayout.u32("instruction"),BufferLayout.ns64("amount")]),u=Buffer.alloc(a.span);return a.encode({instruction:2,amount:n},u),new Transaction({fee:0,keys:[r,t],programId:e.programId,userdata:u})}},{key:"assign",value:function(r,t){var n=BufferLayout.struct([BufferLayout.u32("instruction"),publicKey("programId")]),a=Buffer.alloc(n.span);return n.encode({instruction:1,programId:t.toBuffer()},a),new Transaction({fee:0,keys:[r],programId:e.programId,userdata:a})}},{key:"spawn",value:function(r){var t=BufferLayout.struct([BufferLayout.u32("instruction")]),n=Buffer.alloc(t.span);return t.encode({instruction:3},n),new Transaction({fee:0,keys:[r],programId:e.programId,userdata:n})}},{key:"programId",get:function(){return new PublicKey("0x000000000000000000000000000000000000000000000000000000000000000")}}]),e}(),TokenAmount$$1=function(e){function r(){return _classCallCheck(this,r),_possibleConstructorReturn(this,(r.__proto__||_Object$getPrototypeOf(r)).apply(this,arguments))}return _inherits(r,BN),_createClass(r,[{key:"toBuffer",value:function(){var e=_get(r.prototype.__proto__||_Object$getPrototypeOf(r.prototype),"toArray",this).call(this).reverse(),t=Buffer.from(e);if(8===t.length)return t;assert(8>t.length,"TokenAmount too large");var n=Buffer.alloc(8);return t.copy(n),n}}],[{key:"fromBuffer",value:function(e){return assert(8===e.length,"Invalid buffer length: "+e.length),new BN([].concat(_toConsumableArray(e)).reverse().map(function(e){return("00"+e.toString(16)).slice(-2)}).join(""),16)}}]),r}(),TokenInfoLayout=BufferLayout.struct([uint64("supply"),BufferLayout.u8("decimals"),rustString("name"),rustString("symbol")]),TokenAccountInfoLayout=BufferLayout.struct([publicKey("token"),publicKey("owner"),uint64("amount"),BufferLayout.u8("sourceOption"),publicKey("source"),uint64("originalAmount")]),SYSTEM_TOKEN_PROGRAM_ID=new PublicKey("0x500000000000000000000000000000000000000000000000000000000000000"),Token$$1=function(){function e(r,t){var n=arguments.length>2&&void 0!==arguments[2]?arguments[2]:SYSTEM_TOKEN_PROGRAM_ID;_classCallCheck(this,e),_Object$assign(this,{connection:r,token:t,programId:n})}return _createClass(e,[{key:"newAccount",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t,n,a,u,o,s=arguments.length>1&&void 0!==arguments[1]?arguments[1]:null;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return t=new Account,n=void 0,a=BufferLayout.struct([BufferLayout.u32("instruction")]),u=Buffer.alloc(a.span),a.encode({instruction:1},u),n=SystemProgram.createAccount(r.publicKey,t.publicKey,1,1+TokenAccountInfoLayout.span,this.programId),e.next=8,sendAndConfirmTransaction$$1(this.connection,r,n);case 8:return o=[t.publicKey,r.publicKey,this.token],s&&o.push(s),n=new Transaction({fee:0,keys:o,programId:this.programId,userdata:u}),e.next=13,sendAndConfirmTransaction$$1(this.connection,t,n);case 13:return e.abrupt("return",t.publicKey);case 14:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"tokenInfo",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(){var r,t,n;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.connection.getAccountInfo(this.token);case 2:if((r=e.sent).programId.equals(this.programId)){e.next=5;break}throw Error("Invalid token programId: "+_JSON$stringify(r.programId));case 5:if(1===(t=Buffer.from(r.userdata)).readUInt8(0)){e.next=8;break}throw Error("Invalid token userdata");case 8:return(n=TokenInfoLayout.decode(t,1)).supply=TokenAmount$$1.fromBuffer(n.supply),e.abrupt("return",n);case 11:case"end":return e.stop()}},e,this)}));return function(){return e.apply(this,arguments)}}()},{key:"accountInfo",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t,n,a;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.connection.getAccountInfo(r);case 2:if((t=e.sent).programId.equals(this.programId)){e.next=5;break}throw Error("Invalid token account programId");case 5:if(2===(n=Buffer.from(t.userdata)).readUInt8(0)){e.next=8;break}throw Error("Invalid token account userdata");case 8:if((a=TokenAccountInfoLayout.decode(n,1)).token=new PublicKey(a.token),a.owner=new PublicKey(a.owner),a.amount=TokenAmount$$1.fromBuffer(a.amount),0===a.sourceOption?(a.source=null,a.originalAmount=new TokenAmount$$1):(a.source=new PublicKey(a.source),a.originalAmount=TokenAmount$$1.fromBuffer(a.originalAmount)),a.token.equals(this.token)){e.next=15;break}throw Error("Invalid token account token: "+_JSON$stringify(a.token)+" !== "+_JSON$stringify(this.token));case 15:return e.abrupt("return",a);case 16:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"transfer",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t,n,a){var u,o,s,i,c;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.accountInfo(t);case 2:if(r.publicKey.equals((u=e.sent).owner)){e.next=5;break}throw Error("Account owner mismatch");case 5:return o=BufferLayout.struct([BufferLayout.u32("instruction"),uint64("amount")]),s=Buffer.alloc(o.span),o.encode({instruction:2,amount:new TokenAmount$$1(a).toBuffer()},s),i=[r.publicKey,t,n],u.source&&i.push(u.source),c=new Transaction({fee:0,keys:i,programId:this.programId,userdata:s}),e.next=13,sendAndConfirmTransaction$$1(this.connection,r,c);case 13:case"end":return e.stop()}},e,this)}));return function(r,t,n,a){return e.apply(this,arguments)}}()},{key:"approve",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t,n,a){var u,o,s;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return u=BufferLayout.struct([BufferLayout.u32("instruction"),uint64("amount")]),o=Buffer.alloc(u.span),u.encode({instruction:3,amount:new TokenAmount$$1(a).toBuffer()},o),s=new Transaction({fee:0,keys:[r.publicKey,t,n],programId:this.programId,userdata:o}),e.next=6,sendAndConfirmTransaction$$1(this.connection,r,s);case 6:case"end":return e.stop()}},e,this)}));return function(r,t,n,a){return e.apply(this,arguments)}}()},{key:"revoke",value:function(e,r,t){return this.approve(e,r,t,0)}},{key:"setOwner",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t,n){var a,u,o;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return a=BufferLayout.struct([BufferLayout.u32("instruction")]),u=Buffer.alloc(a.span),a.encode({instruction:4},u),o=new Transaction({fee:0,keys:[r.publicKey,t,n],programId:this.programId,userdata:u}),e.next=7,sendAndConfirmTransaction$$1(this.connection,r,o);case 7:case"end":return e.stop()}},e,this)}));return function(r,t,n){return e.apply(this,arguments)}}()}],[{key:"createNewToken",value:function(){var r=_asyncToGenerator(_regeneratorRuntime.mark(function r(t,n,a,u,o,s){var i,c,f,l,p,y,d,g=arguments.length>6&&void 0!==arguments[6]?arguments[6]:SYSTEM_TOKEN_PROGRAM_ID;return _regeneratorRuntime.wrap(function(r){for(;;)switch(r.prev=r.next){case 0:return i=new Account,c=new e(t,i.publicKey,g),r.next=4,c.newAccount(n,null);case 4:return f=r.sent,l=void 0,p=BufferLayout.struct([BufferLayout.u32("instruction"),uint64("supply"),BufferLayout.u8("decimals"),rustString("name"),rustString("symbol")]),y=Buffer.alloc(1024),d=p.encode({instruction:0,supply:a.toBuffer(),decimals:s,name:u,symbol:o},y),y=y.slice(0,d),l=SystemProgram.createAccount(n.publicKey,i.publicKey,1,1+y.length,g),r.next=13,sendAndConfirmTransaction$$1(t,n,l);case 13:return l=new Transaction({fee:0,keys:[i.publicKey,f],programId:g,userdata:y}),r.next=16,sendAndConfirmTransaction$$1(t,i,l);case 16:return r.abrupt("return",[c,f]);case 17:case"end":return r.stop()}},r,this)}));return function(e,t,n,a,u,o){return r.apply(this,arguments)}}()}]),e}();exports.Account=Account,exports.BudgetProgram=BudgetProgram,exports.Connection=Connection,exports.Loader=Loader$$1,exports.NativeLoader=NativeLoader$$1,exports.PublicKey=PublicKey,exports.SystemProgram=SystemProgram,exports.Token=Token$$1,exports.TokenAmount=TokenAmount$$1,exports.Transaction=Transaction,exports.sendAndConfirmTransaction=sendAndConfirmTransaction$$1;
+"use strict";function _interopDefault(e){return e&&"object"==typeof e&&"default"in e?e.default:e}Object.defineProperty(exports,"__esModule",{value:!0});var _classCallCheck=_interopDefault(require("babel-runtime/helpers/classCallCheck")),_createClass=_interopDefault(require("babel-runtime/helpers/createClass")),BN=_interopDefault(require("bn.js")),bs58=_interopDefault(require("bs58")),nacl=_interopDefault(require("tweetnacl")),BufferLayout=require("buffer-layout"),_toConsumableArray=_interopDefault(require("babel-runtime/helpers/toConsumableArray")),_Object$assign=_interopDefault(require("babel-runtime/core-js/object/assign")),assert=_interopDefault(require("assert")),_getIterator=_interopDefault(require("babel-runtime/core-js/get-iterator")),_Promise=_interopDefault(require("babel-runtime/core-js/promise")),_regeneratorRuntime=_interopDefault(require("babel-runtime/regenerator")),_asyncToGenerator=_interopDefault(require("babel-runtime/helpers/asyncToGenerator")),fetch=_interopDefault(require("node-fetch")),jayson=_interopDefault(require("jayson/lib/client/browser")),superstruct=require("superstruct"),_JSON$stringify=_interopDefault(require("babel-runtime/core-js/json/stringify")),_Object$getPrototypeOf=_interopDefault(require("babel-runtime/core-js/object/get-prototype-of")),_possibleConstructorReturn=_interopDefault(require("babel-runtime/helpers/possibleConstructorReturn")),_get=_interopDefault(require("babel-runtime/helpers/get")),_inherits=_interopDefault(require("babel-runtime/helpers/inherits")),PublicKey=function(){function e(r){for(_classCallCheck(this,e);;){if("string"==typeof r){if(/^[1-9A-HJ-NP-Za-km-z]{43,44}$/.test(r)){this._bn=new BN(bs58.decode(r));break}if(r.startsWith("0x")){this._bn=new BN(r.substring(2),16);break}}this._bn=new BN(r);break}if(this._bn.byteLength()>32)throw Error("Invalid public key input")}return _createClass(e,[{key:"equals",value:function(e){return this._bn.eq(e._bn)}},{key:"toBase58",value:function(){return bs58.encode(this.toBuffer())}},{key:"toBuffer",value:function(){var e=this._bn.toArrayLike(Buffer);if(32===e.length)return e;var r=Buffer.alloc(32);return e.copy(r,32-e.length),r}},{key:"toString",value:function(){return this.toBase58()}}],[{key:"isPublicKey",value:function(r){return r instanceof e}}]),e}(),Account=function(){function e(){var r=arguments.length>0&&void 0!==arguments[0]?arguments[0]:null;_classCallCheck(this,e),this._keypair=r?nacl.sign.keyPair.fromSecretKey(r):nacl.sign.keyPair()}return _createClass(e,[{key:"publicKey",get:function(){return new PublicKey(this._keypair.publicKey)}},{key:"secretKey",get:function(){return this._keypair.secretKey}}]),e}(),publicKey=function(){return BufferLayout.blob(32,arguments.length>0&&void 0!==arguments[0]?arguments[0]:"publicKey")},uint64=function(){return BufferLayout.blob(8,arguments.length>0&&void 0!==arguments[0]?arguments[0]:"uint64")},rustString=function(){var e=arguments.length>0&&void 0!==arguments[0]?arguments[0]:"string",r=BufferLayout.struct([BufferLayout.u32("length"),BufferLayout.u32("lengthPadding"),BufferLayout.blob(BufferLayout.offset(BufferLayout.u32(),-8),"chars")],e),t=r.decode.bind(r),n=r.encode.bind(r);return r.decode=function(e,r){return t(e,r).chars.toString("utf8")},r.encode=function(e,r,t){var a={chars:Buffer.from(e,"utf8")};return n(a,r,t)},r},Transaction=function(){function e(r){_classCallCheck(this,e),this.keys=[],this.fee=0,this.userdata=Buffer.alloc(0),r&&_Object$assign(this,r)}return _createClass(e,[{key:"_getSignData",value:function(){var e=this.lastId,r=this.keys,t=this.programId,n=this.userdata;if(!e)throw Error("Transaction lastId required");var a=[t],u=[{programId:0,accountsLength:r.length,accounts:[].concat(_toConsumableArray(r.keys())),userdataLength:n.length,userdata:n}],o=BufferLayout.struct([BufferLayout.u8("programId"),BufferLayout.u32("accountsLength"),BufferLayout.u32("accountsLengthPadding"),BufferLayout.seq(BufferLayout.u8("account"),BufferLayout.offset(BufferLayout.u32(),-8),"accounts"),BufferLayout.ns64("userdataLength"),BufferLayout.blob(n.length,"userdata")]),s=BufferLayout.struct([BufferLayout.u32("accountKeysLength"),BufferLayout.u32("accountKeysLengthPadding"),BufferLayout.seq(publicKey("accountKey"),BufferLayout.offset(BufferLayout.u32(),-8),"accountKeys"),publicKey("lastId"),BufferLayout.ns64("fee"),BufferLayout.u32("programIdsLength"),BufferLayout.u32("programIdsLengthPadding"),BufferLayout.seq(publicKey("programId"),BufferLayout.offset(BufferLayout.u32(),-8),"programIds"),BufferLayout.u32("instructionsLength"),BufferLayout.u32("instructionsLengthPadding"),BufferLayout.seq(o,BufferLayout.offset(BufferLayout.u32(),-8),"instructions")]),i={accountKeys:r.map(function(e){return e.toBuffer()}),lastId:Buffer.from(bs58.decode(e)),fee:0,programIds:a.map(function(e){return e.toBuffer()}),instructions:u},c=Buffer.alloc(2048),f=s.encode(i,c);return c=c.slice(0,f)}},{key:"sign",value:function(e){var r=this._getSignData();this.signature=nacl.sign.detached(r,e.secretKey),assert(64===this.signature.length)}},{key:"serialize",value:function(){var e=this.signature;if(!e)throw Error("Transaction has not been signed");var r=this._getSignData(),t=Buffer.alloc(e.length+r.length);return Buffer.from(e).copy(t,0),r.copy(t,e.length),t}}]),e}();function serializePayment(e){var r=e.to.toBuffer(),t=Buffer.alloc(8+r.length);return t.writeUInt32LE(e.amount,0),r.copy(t,8),t}function serializeDate(e){var r=Buffer.alloc(28);return r.writeUInt32LE(20,0),r.write(function(e){function r(e){return 10>e?"0"+e:e}return e.getUTCFullYear()+"-"+r(e.getUTCMonth()+1)+"-"+r(e.getUTCDate())+"T"+r(e.getUTCHours())+":"+r(e.getUTCMinutes())+":"+r(e.getUTCSeconds())+"Z"}(e),8),r}function serializeCondition(e){switch(e.type){case"timestamp":var r=serializeDate(e.when),t=e.from.toBuffer(),n=Buffer.alloc(4+r.length+t.length);return n.writeUInt32LE(0,0),r.copy(n,4),t.copy(n,4+r.length),n;case"signature":var a=BufferLayout.struct([BufferLayout.u32("condition"),publicKey("from")]),u=e.from.toBuffer(),o=Buffer.alloc(4+u.length);return a.encode({instruction:1,from:u},o),o;default:throw Error("Unknown condition type: "+e.type)}}var BudgetProgram=function(){function e(){_classCallCheck(this,e)}return _createClass(e,null,[{key:"timestampCondition",value:function(e,r){return{type:"timestamp",from:e,when:r}}},{key:"signatureCondition",value:function(e){return{type:"signature",from:e}}},{key:"pay",value:function(e,r,t,n){var a=Buffer.alloc(1024),u=0;a.writeUInt32LE(0,u),a.writeUInt32LE(n,u+=4),u+=8;for(var o=arguments.length,s=Array(o>4?o-4:0),i=4;o>i;i++)s[i-4]=arguments[i];switch(s.length){case 0:a.writeUInt32LE(0,u),u+=4;var c=serializePayment({amount:n,to:t});return c.copy(a,u),new Transaction({fee:0,keys:[e,t],programId:this.programId,userdata:a.slice(0,u+=c.length)});case 1:a.writeUInt32LE(1,u),u+=4;var f=serializeCondition(s[0]);f.copy(a,u),u+=f.length;var l=serializePayment({amount:n,to:t});return l.copy(a,u),new Transaction({fee:0,keys:[e,r,t],programId:this.programId,userdata:a.slice(0,u+=l.length)});case 2:a.writeUInt32LE(2,u),u+=4;var p=!0,y=!1,d=void 0;try{for(var g,m=_getIterator(s);!(p=(g=m.next()).done);p=!0){var h=serializeCondition(g.value);h.copy(a,u),u+=h.length;var b=serializePayment({amount:n,to:t});b.copy(a,u),u+=b.length}}catch(e){y=!0,d=e}finally{try{!p&&m.return&&m.return()}finally{if(y)throw d}}return new Transaction({fee:0,keys:[e,r,t],programId:this.programId,userdata:a.slice(0,u)});default:throw Error("A maximum of two conditions are support: "+s.length+" provided")}}},{key:"payOnBoth",value:function(e,r,t,n,a,u){var o=Buffer.alloc(1024),s=0;o.writeUInt32LE(0,s),o.writeUInt32LE(n,s+=4),o.writeUInt32LE(3,s+=8),s+=4;for(var i=[a,u],c=0;i.length>c;c++){var f=serializeCondition(i[c]);f.copy(o,s),s+=f.length}var l=serializePayment({amount:n,to:t});return l.copy(o,s),new Transaction({fee:0,keys:[e,r,t],programId:this.programId,userdata:o.slice(0,s+=l.length)})}},{key:"applyTimestamp",value:function(e,r,t,n){var a=serializeDate(n),u=Buffer.alloc(4+a.length);return u.writeUInt32LE(1,0),a.copy(u,4),new Transaction({fee:0,keys:[e,r,t],programId:this.programId,userdata:u})}},{key:"applySignature",value:function(e,r,t){var n=BufferLayout.struct([BufferLayout.u32("instruction")]),a=Buffer.alloc(n.span);return n.encode({instruction:2},a),new Transaction({fee:0,keys:[e,r,t],programId:this.programId,userdata:a})}},{key:"programId",get:function(){return new PublicKey("0x100000000000000000000000000000000000000000000000000000000000000")}},{key:"space",get:function(){return 128}}]),e}();function sleep(e){return new _Promise(function(r){return setTimeout(r,e)})}function createRpcRequest(e){var r,t=this,n=jayson((r=_asyncToGenerator(_regeneratorRuntime.mark(function r(n,a){var u,o;return _regeneratorRuntime.wrap(function(r){for(;;)switch(r.prev=r.next){case 0:return u={method:"POST",body:n,headers:{"Content-Type":"application/json"}},r.prev=1,r.next=4,fetch(e,u);case 4:return o=r.sent,r.next=7,o.text();case 7:a(null,r.sent),r.next=14;break;case 11:r.prev=11,r.t0=r.catch(1),a(r.t0);case 14:case"end":return r.stop()}},r,t,[[1,11]])})),function(e,t){return r.apply(this,arguments)}));return function(e,r){return new _Promise(function(t,a){n.request(e,r,function(e,r){e?a(e):t(r)})})}}var GetBalanceRpcResult=superstruct.struct({jsonrpc:superstruct.struct.literal("2.0"),id:"string",error:"any?",result:"number?"});function jsonRpcResult(e){var r=superstruct.struct.literal("2.0");return superstruct.struct.union([superstruct.struct({jsonrpc:r,id:"string",error:"any"}),superstruct.struct({jsonrpc:r,id:"string",error:"null?",result:e})])}var GetAccountInfoRpcResult=jsonRpcResult({executable:"boolean",loader_program_id:"array",program_id:"array",tokens:"number",userdata:"array"}),ConfirmTransactionRpcResult=jsonRpcResult("boolean"),GetSignatureStatusRpcResult=jsonRpcResult(superstruct.struct.enum(["AccountInUse","Confirmed","GenericFailure","ProgramRuntimeError","SignatureNotFound"])),GetTransactionCountRpcResult=jsonRpcResult("number"),GetLastId=jsonRpcResult("string"),GetFinalityRpcResult=jsonRpcResult("number"),RequestAirdropRpcResult=jsonRpcResult("string"),SendTokensRpcResult=jsonRpcResult("string"),Connection=function(){function e(r){if(_classCallCheck(this,e),this._disableLastIdCaching=!1,"string"!=typeof r)throw Error("Connection endpoint not specified");this._rpcRequest=createRpcRequest(r),this._lastIdInfo={lastId:null,seconds:-1,transactionSignatures:[]}}return _createClass(e,[{key:"getBalance",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getBalance",[r.toBase58()]);case 2:if(!(t=GetBalanceRpcResult(e.sent)).error){e.next=6;break}throw Error(t.error.message);case 6:return assert(void 0!==t.result),e.abrupt("return",t.result);case 8:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"getAccountInfo",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t,n;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getAccountInfo",[r.toBase58()]);case 2:if(!(t=GetAccountInfoRpcResult(e.sent)).error){e.next=6;break}throw Error(t.error.message);case 6:return assert(void 0!==(n=t.result)),e.abrupt("return",{executable:n.executable,tokens:n.tokens,programId:new PublicKey(n.program_id),loaderProgramId:new PublicKey(n.loader_program_id),userdata:Buffer.from(n.userdata)});case 9:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"confirmTransaction",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("confirmTransaction",[r]);case 2:if(!(t=ConfirmTransactionRpcResult(e.sent)).error){e.next=6;break}throw Error(t.error.message);case 6:return assert(void 0!==t.result),e.abrupt("return",t.result);case 8:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"getSignatureStatus",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getSignatureStatus",[r]);case 2:if(!(t=GetSignatureStatusRpcResult(e.sent)).error){e.next=6;break}throw Error(t.error.message);case 6:return assert(void 0!==t.result),e.abrupt("return",t.result);case 8:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"getTransactionCount",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(){var r;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getTransactionCount",[]);case 2:if(!(r=GetTransactionCountRpcResult(e.sent)).error){e.next=6;break}throw Error(r.error.message);case 6:return assert(void 0!==r.result),e.abrupt("return",+r.result);case 8:case"end":return e.stop()}},e,this)}));return function(){return e.apply(this,arguments)}}()},{key:"getLastId",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(){var r;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getLastId",[]);case 2:if(!(r=GetLastId(e.sent)).error){e.next=6;break}throw Error(r.error.message);case 6:return assert(void 0!==r.result),e.abrupt("return",r.result);case 8:case"end":return e.stop()}},e,this)}));return function(){return e.apply(this,arguments)}}()},{key:"getFinality",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(){var r;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getFinality",[]);case 2:if(!(r=GetFinalityRpcResult(e.sent)).error){e.next=6;break}throw Error(r.error.message);case 6:return assert(void 0!==r.result),e.abrupt("return",+r.result);case 8:case"end":return e.stop()}},e,this)}));return function(){return e.apply(this,arguments)}}()},{key:"requestAirdrop",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t){var n;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("requestAirdrop",[r.toBase58(),t]);case 2:if(!(n=RequestAirdropRpcResult(e.sent)).error){e.next=6;break}throw Error(n.error.message);case 6:return assert(void 0!==n.result),e.abrupt("return",n.result);case 8:case"end":return e.stop()}},e,this)}));return function(r,t){return e.apply(this,arguments)}}()},{key:"sendTransaction",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t){var n,a,u,o,s,i;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:if(n=(new Date).getSeconds(),null==this._lastIdInfo.lastId||this._lastIdInfo.seconds!==n){e.next=11;break}if(t.lastId=this._lastIdInfo.lastId,t.sign(r),t.signature){e.next=6;break}throw Error("!signature");case 6:if(this._lastIdInfo.transactionSignatures.includes(a=""+t.signature)){e.next=11;break}return this._lastIdInfo.transactionSignatures.push(a),this._disableLastIdCaching&&(this._lastIdInfo.seconds=-1),e.abrupt("break",27);case 11:u=0;case 12:return e.next=14,this.getLastId();case 14:if(this._lastIdInfo.lastId==(o=e.sent)){e.next=18;break}return this._lastIdInfo={lastId:o,seconds:(new Date).getSeconds(),transactionSignatures:[]},e.abrupt("break",25);case 18:if(8!==u){e.next=20;break}throw Error("Unable to obtain new last id");case 20:return e.next=22,sleep(250);case 22:++u;case 23:e.next=12;break;case 25:e.next=0;break;case 27:return s=t.serialize(),e.next=30,this._rpcRequest("sendTransaction",[[].concat(_toConsumableArray(s))]);case 30:if(!(i=SendTokensRpcResult(e.sent)).error){e.next=34;break}throw Error(i.error.message);case 34:return assert(void 0!==i.result),assert(i.result),e.abrupt("return",i.result);case 37:case"end":return e.stop()}},e,this)}));return function(r,t){return e.apply(this,arguments)}}()}]),e}(),sendAndConfirmTransaction$$1=function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t,n){var a,u,o,s,i,c,f=arguments.length>3&&void 0!==arguments[3]&&arguments[3];return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:a=3;case 1:return u=Date.now(),e.next=4,r.sendTransaction(t,n);case 4:o=e.sent,s="SignatureNotFound",i=4;case 7:return e.next=9,r.getSignatureStatus(o);case 9:if("SignatureNotFound"===(s=e.sent)){e.next=12;break}return e.abrupt("break",19);case 12:return e.next=14,sleep(500);case 14:if(0<--i){e.next=17;break}throw c=(Date.now()-u)/1e3,Error("Transaction '"+o+"' was not confirmed in "+c.toFixed(2)+" seconds ("+s+")");case 17:e.next=7;break;case 19:if(!("Confirmed"===s||"ProgramRuntimeError"===s&&f)){e.next=21;break}return e.abrupt("return");case 21:if("AccountInUse"===s&&--a>0){e.next=23;break}throw Error("Transaction "+o+" failed ("+s+")");case 23:e.next=1;break;case 25:case"end":return e.stop()}},e,this)}));return function(r,t,n){return e.apply(this,arguments)}}(),Loader$$1=function(){function e(r,t){_classCallCheck(this,e),_Object$assign(this,{connection:r,programId:t})}return _createClass(e,[{key:"load",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t,n){var a,u,o;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return a=BufferLayout.struct([BufferLayout.u32("instruction"),BufferLayout.u32("offset"),BufferLayout.u32("bytesLength"),BufferLayout.u32("bytesLengthPadding"),BufferLayout.seq(BufferLayout.u8("byte"),BufferLayout.offset(BufferLayout.u32(),-8),"bytes")]),u=Buffer.alloc(n.length+16),a.encode({instruction:0,offset:t,bytes:n},u),o=new Transaction({fee:0,keys:[r.publicKey],programId:this.programId,userdata:u}),e.next=6,sendAndConfirmTransaction$$1(this.connection,r,o);case 6:case"end":return e.stop()}},e,this)}));return function(r,t,n){return e.apply(this,arguments)}}()},{key:"finalize",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t,n,a;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return t=BufferLayout.struct([BufferLayout.u32("instruction")]),n=Buffer.alloc(t.span),t.encode({instruction:1},n),a=new Transaction({fee:0,keys:[r.publicKey],programId:this.programId,userdata:n}),e.next=6,sendAndConfirmTransaction$$1(this.connection,r,a);case 6:return a=SystemProgram.spawn(r.publicKey),e.next=9,sendAndConfirmTransaction$$1(this.connection,r,a);case 9:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()}]),e}(),NativeLoader$$1=function(){function e(){_classCallCheck(this,e)}return _createClass(e,null,[{key:"load",value:function(){var r=_asyncToGenerator(_regeneratorRuntime.mark(function r(t,n,a){var u,o,s,i;return _regeneratorRuntime.wrap(function(r){for(;;)switch(r.prev=r.next){case 0:return u=[].concat(_toConsumableArray(Buffer.from(a))),o=new Account,s=SystemProgram.createAccount(n.publicKey,o.publicKey,1,u.length+1,e.programId),r.next=5,sendAndConfirmTransaction$$1(t,n,s);case 5:return i=new Loader$$1(t,e.programId),r.next=8,i.load(o,0,u);case 8:return r.next=10,i.finalize(o);case 10:return r.abrupt("return",o.publicKey);case 11:case"end":return r.stop()}},r,this)}));return function(e,t,n){return r.apply(this,arguments)}}()},{key:"programId",get:function(){return new PublicKey("0x0202020202020202020202020202020202020202020202020202020202020202")}}]),e}(),SystemProgram=function(){function e(){_classCallCheck(this,e)}return _createClass(e,null,[{key:"createAccount",value:function(r,t,n,a,u){var o=BufferLayout.struct([BufferLayout.u32("instruction"),BufferLayout.ns64("tokens"),BufferLayout.ns64("space"),publicKey("programId")]),s=Buffer.alloc(o.span);return o.encode({instruction:0,tokens:n,space:a,programId:u.toBuffer()},s),new Transaction({fee:0,keys:[r,t],programId:e.programId,userdata:s})}},{key:"move",value:function(r,t,n){var a=BufferLayout.struct([BufferLayout.u32("instruction"),BufferLayout.ns64("amount")]),u=Buffer.alloc(a.span);return a.encode({instruction:2,amount:n},u),new Transaction({fee:0,keys:[r,t],programId:e.programId,userdata:u})}},{key:"assign",value:function(r,t){var n=BufferLayout.struct([BufferLayout.u32("instruction"),publicKey("programId")]),a=Buffer.alloc(n.span);return n.encode({instruction:1,programId:t.toBuffer()},a),new Transaction({fee:0,keys:[r],programId:e.programId,userdata:a})}},{key:"spawn",value:function(r){var t=BufferLayout.struct([BufferLayout.u32("instruction")]),n=Buffer.alloc(t.span);return t.encode({instruction:3},n),new Transaction({fee:0,keys:[r],programId:e.programId,userdata:n})}},{key:"programId",get:function(){return new PublicKey("0x000000000000000000000000000000000000000000000000000000000000000")}}]),e}(),TokenAmount$$1=function(e){function r(){return _classCallCheck(this,r),_possibleConstructorReturn(this,(r.__proto__||_Object$getPrototypeOf(r)).apply(this,arguments))}return _inherits(r,BN),_createClass(r,[{key:"toBuffer",value:function(){var e=_get(r.prototype.__proto__||_Object$getPrototypeOf(r.prototype),"toArray",this).call(this).reverse(),t=Buffer.from(e);if(8===t.length)return t;assert(8>t.length,"TokenAmount too large");var n=Buffer.alloc(8);return t.copy(n),n}}],[{key:"fromBuffer",value:function(e){return assert(8===e.length,"Invalid buffer length: "+e.length),new BN([].concat(_toConsumableArray(e)).reverse().map(function(e){return("00"+e.toString(16)).slice(-2)}).join(""),16)}}]),r}(),TokenInfoLayout=BufferLayout.struct([uint64("supply"),BufferLayout.u8("decimals"),rustString("name"),rustString("symbol")]),TokenAccountInfoLayout=BufferLayout.struct([publicKey("token"),publicKey("owner"),uint64("amount"),BufferLayout.u8("sourceOption"),publicKey("source"),uint64("originalAmount")]),SYSTEM_TOKEN_PROGRAM_ID=new PublicKey("0x500000000000000000000000000000000000000000000000000000000000000"),Token$$1=function(){function e(r,t){var n=arguments.length>2&&void 0!==arguments[2]?arguments[2]:SYSTEM_TOKEN_PROGRAM_ID;_classCallCheck(this,e),_Object$assign(this,{connection:r,token:t,programId:n})}return _createClass(e,[{key:"newAccount",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t,n,a,u,o,s=arguments.length>1&&void 0!==arguments[1]?arguments[1]:null;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return t=new Account,n=void 0,a=BufferLayout.struct([BufferLayout.u32("instruction")]),u=Buffer.alloc(a.span),a.encode({instruction:1},u),n=SystemProgram.createAccount(r.publicKey,t.publicKey,1,1+TokenAccountInfoLayout.span,this.programId),e.next=8,sendAndConfirmTransaction$$1(this.connection,r,n);case 8:return o=[t.publicKey,r.publicKey,this.token],s&&o.push(s),n=new Transaction({fee:0,keys:o,programId:this.programId,userdata:u}),e.next=13,sendAndConfirmTransaction$$1(this.connection,t,n);case 13:return e.abrupt("return",t.publicKey);case 14:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"tokenInfo",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(){var r,t,n;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.connection.getAccountInfo(this.token);case 2:if((r=e.sent).programId.equals(this.programId)){e.next=5;break}throw Error("Invalid token programId: "+_JSON$stringify(r.programId));case 5:if(1===(t=Buffer.from(r.userdata)).readUInt8(0)){e.next=8;break}throw Error("Invalid token userdata");case 8:return(n=TokenInfoLayout.decode(t,1)).supply=TokenAmount$$1.fromBuffer(n.supply),e.abrupt("return",n);case 11:case"end":return e.stop()}},e,this)}));return function(){return e.apply(this,arguments)}}()},{key:"accountInfo",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t,n,a;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.connection.getAccountInfo(r);case 2:if((t=e.sent).programId.equals(this.programId)){e.next=5;break}throw Error("Invalid token account programId");case 5:if(2===(n=Buffer.from(t.userdata)).readUInt8(0)){e.next=8;break}throw Error("Invalid token account userdata");case 8:if((a=TokenAccountInfoLayout.decode(n,1)).token=new PublicKey(a.token),a.owner=new PublicKey(a.owner),a.amount=TokenAmount$$1.fromBuffer(a.amount),0===a.sourceOption?(a.source=null,a.originalAmount=new TokenAmount$$1):(a.source=new PublicKey(a.source),a.originalAmount=TokenAmount$$1.fromBuffer(a.originalAmount)),a.token.equals(this.token)){e.next=15;break}throw Error("Invalid token account token: "+_JSON$stringify(a.token)+" !== "+_JSON$stringify(this.token));case 15:return e.abrupt("return",a);case 16:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"transfer",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t,n,a){var u,o,s,i,c;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.accountInfo(t);case 2:if(r.publicKey.equals((u=e.sent).owner)){e.next=5;break}throw Error("Account owner mismatch");case 5:return o=BufferLayout.struct([BufferLayout.u32("instruction"),uint64("amount")]),s=Buffer.alloc(o.span),o.encode({instruction:2,amount:new TokenAmount$$1(a).toBuffer()},s),i=[r.publicKey,t,n],u.source&&i.push(u.source),c=new Transaction({fee:0,keys:i,programId:this.programId,userdata:s}),e.next=13,sendAndConfirmTransaction$$1(this.connection,r,c);case 13:case"end":return e.stop()}},e,this)}));return function(r,t,n,a){return e.apply(this,arguments)}}()},{key:"approve",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t,n,a){var u,o,s;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return u=BufferLayout.struct([BufferLayout.u32("instruction"),uint64("amount")]),o=Buffer.alloc(u.span),u.encode({instruction:3,amount:new TokenAmount$$1(a).toBuffer()},o),s=new Transaction({fee:0,keys:[r.publicKey,t,n],programId:this.programId,userdata:o}),e.next=6,sendAndConfirmTransaction$$1(this.connection,r,s);case 6:case"end":return e.stop()}},e,this)}));return function(r,t,n,a){return e.apply(this,arguments)}}()},{key:"revoke",value:function(e,r,t){return this.approve(e,r,t,0)}},{key:"setOwner",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t,n){var a,u,o;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return a=BufferLayout.struct([BufferLayout.u32("instruction")]),u=Buffer.alloc(a.span),a.encode({instruction:4},u),o=new Transaction({fee:0,keys:[r.publicKey,t,n],programId:this.programId,userdata:u}),e.next=7,sendAndConfirmTransaction$$1(this.connection,r,o);case 7:case"end":return e.stop()}},e,this)}));return function(r,t,n){return e.apply(this,arguments)}}()}],[{key:"createNewToken",value:function(){var r=_asyncToGenerator(_regeneratorRuntime.mark(function r(t,n,a,u,o,s){var i,c,f,l,p,y,d,g=arguments.length>6&&void 0!==arguments[6]?arguments[6]:SYSTEM_TOKEN_PROGRAM_ID;return _regeneratorRuntime.wrap(function(r){for(;;)switch(r.prev=r.next){case 0:return i=new Account,c=new e(t,i.publicKey,g),r.next=4,c.newAccount(n,null);case 4:return f=r.sent,l=void 0,p=BufferLayout.struct([BufferLayout.u32("instruction"),uint64("supply"),BufferLayout.u8("decimals"),rustString("name"),rustString("symbol")]),y=Buffer.alloc(1024),d=p.encode({instruction:0,supply:a.toBuffer(),decimals:s,name:u,symbol:o},y),y=y.slice(0,d),l=SystemProgram.createAccount(n.publicKey,i.publicKey,1,1+y.length,g),r.next=13,sendAndConfirmTransaction$$1(t,n,l);case 13:return l=new Transaction({fee:0,keys:[i.publicKey,f],programId:g,userdata:y}),r.next=16,sendAndConfirmTransaction$$1(t,i,l);case 16:return r.abrupt("return",[c,f]);case 17:case"end":return r.stop()}},r,this)}));return function(e,t,n,a,u,o){return r.apply(this,arguments)}}()}]),e}();exports.Account=Account,exports.BudgetProgram=BudgetProgram,exports.Connection=Connection,exports.Loader=Loader$$1,exports.NativeLoader=NativeLoader$$1,exports.PublicKey=PublicKey,exports.SystemProgram=SystemProgram,exports.Token=Token$$1,exports.TokenAmount=TokenAmount$$1,exports.Transaction=Transaction,exports.sendAndConfirmTransaction=sendAndConfirmTransaction$$1;

lib/index.esm.js

@@ -1,1 +0,1 @@
-import _classCallCheck from"babel-runtime/helpers/classCallCheck";import _createClass from"babel-runtime/helpers/createClass";import BN from"bn.js";import bs58 from"bs58";import nacl from"tweetnacl";import{struct,u32,seq,u8,offset,ns64,blob}from"buffer-layout";import _toConsumableArray from"babel-runtime/helpers/toConsumableArray";import _Object$assign from"babel-runtime/core-js/object/assign";import assert from"assert";import _getIterator from"babel-runtime/core-js/get-iterator";import _Promise from"babel-runtime/core-js/promise";import _regeneratorRuntime from"babel-runtime/regenerator";import _asyncToGenerator from"babel-runtime/helpers/asyncToGenerator";import fetch from"node-fetch";import jayson from"jayson/lib/client/browser";import{struct as struct$1}from"superstruct";import _JSON$stringify from"babel-runtime/core-js/json/stringify";import _Object$getPrototypeOf from"babel-runtime/core-js/object/get-prototype-of";import _possibleConstructorReturn from"babel-runtime/helpers/possibleConstructorReturn";import _get from"babel-runtime/helpers/get";import _inherits from"babel-runtime/helpers/inherits";var PublicKey=function(){function e(r){for(_classCallCheck(this,e);;){if("string"==typeof r){if(/^[1-9A-HJ-NP-Za-km-z]{43,44}$/.test(r)){this._bn=new BN(bs58.decode(r));break}if(r.startsWith("0x")){this._bn=new BN(r.substring(2),16);break}}this._bn=new BN(r);break}if(this._bn.byteLength()>32)throw Error("Invalid public key input")}return _createClass(e,[{key:"equals",value:function(e){return this._bn.eq(e._bn)}},{key:"toBase58",value:function(){return bs58.encode(this.toBuffer())}},{key:"toBuffer",value:function(){var e=this._bn.toArrayLike(Buffer);if(32===e.length)return e;var r=Buffer.alloc(32);return e.copy(r,32-e.length),r}},{key:"toString",value:function(){return this.toBase58()}}],[{key:"isPublicKey",value:function(r){return r instanceof e}}]),e}(),Account=function(){function e(){var r=arguments.length>0&&void 0!==arguments[0]?arguments[0]:null;_classCallCheck(this,e),this._keypair=r?nacl.sign.keyPair.fromSecretKey(r):nacl.sign.keyPair()}return _createClass(e,[{key:"publicKey",get:function(){return new PublicKey(this._keypair.publicKey)}},{key:"secretKey",get:function(){return this._keypair.secretKey}}]),e}(),publicKey=function(){return blob(32,arguments.length>0&&void 0!==arguments[0]?arguments[0]:"publicKey")},uint64=function(){return blob(8,arguments.length>0&&void 0!==arguments[0]?arguments[0]:"uint64")},rustString=function(){var e=arguments.length>0&&void 0!==arguments[0]?arguments[0]:"string",r=struct([u32("length"),u32("lengthPadding"),blob(offset(u32(),-8),"chars")],e),t=r.decode.bind(r),n=r.encode.bind(r);return r.decode=function(e,r){return t(e,r).chars.toString("utf8")},r.encode=function(e,r,t){var a={chars:Buffer.from(e,"utf8")};return n(a,r,t)},r},Transaction=function(){function e(r){_classCallCheck(this,e),this.keys=[],this.fee=0,this.userdata=Buffer.alloc(0),r&&_Object$assign(this,r)}return _createClass(e,[{key:"_getSignData",value:function(){var e=this.lastId,r=this.keys,t=this.programId,n=this.userdata;if(!e)throw Error("Transaction lastId required");var a=[t],o=[{programId:0,accountsLength:r.length,accounts:[].concat(_toConsumableArray(r.keys())),userdataLength:n.length,userdata:n}],s=struct([u8("programId"),u32("accountsLength"),u32("accountsLengthPadding"),seq(u8("account"),offset(u32(),-8),"accounts"),ns64("userdataLength"),blob(n.length,"userdata")]),u=struct([u32("accountKeysLength"),u32("accountKeysLengthPadding"),seq(publicKey("accountKey"),offset(u32(),-8),"accountKeys"),publicKey("lastId"),ns64("fee"),u32("programIdsLength"),u32("programIdsLengthPadding"),seq(publicKey("programId"),offset(u32(),-8),"programIds"),u32("instructionsLength"),u32("instructionsLengthPadding"),seq(s,offset(u32(),-8),"instructions")]),i={accountKeys:r.map(function(e){return e.toBuffer()}),lastId:Buffer.from(bs58.decode(e)),fee:0,programIds:a.map(function(e){return e.toBuffer()}),instructions:o},c=Buffer.alloc(2048),l=u.encode(i,c);return c=c.slice(0,l)}},{key:"sign",value:function(e){var r=this._getSignData();this.signature=nacl.sign.detached(r,e.secretKey),assert(64===this.signature.length)}},{key:"serialize",value:function(){var e=this.signature;if(!e)throw Error("Transaction has not been signed");var r=this._getSignData(),t=Buffer.alloc(e.length+r.length);return Buffer.from(e).copy(t,0),r.copy(t,e.length),t}}]),e}();function serializePayment(e){var r=e.to.toBuffer(),t=Buffer.alloc(8+r.length);return t.writeUInt32LE(e.amount,0),r.copy(t,8),t}function serializeDate(e){var r=Buffer.alloc(28);return r.writeUInt32LE(20,0),r.write(function(e){function r(e){return 10>e?"0"+e:e}return e.getUTCFullYear()+"-"+r(e.getUTCMonth()+1)+"-"+r(e.getUTCDate())+"T"+r(e.getUTCHours())+":"+r(e.getUTCMinutes())+":"+r(e.getUTCSeconds())+"Z"}(e),8),r}function serializeCondition(e){switch(e.type){case"timestamp":var r=serializeDate(e.when),t=e.from.toBuffer(),n=Buffer.alloc(4+r.length+t.length);return n.writeUInt32LE(0,0),r.copy(n,4),t.copy(n,4+r.length),n;case"signature":var a=struct([u32("condition"),publicKey("from")]),o=e.from.toBuffer(),s=Buffer.alloc(4+o.length);return a.encode({instruction:1,from:o},s),s;default:throw Error("Unknown condition type: "+e.type)}}var BudgetProgram=function(){function e(){_classCallCheck(this,e)}return _createClass(e,null,[{key:"timestampCondition",value:function(e,r){return{type:"timestamp",from:e,when:r}}},{key:"signatureCondition",value:function(e){return{type:"signature",from:e}}},{key:"pay",value:function(e,r,t,n){var a=Buffer.alloc(1024),o=0;a.writeUInt32LE(0,o),a.writeUInt32LE(n,o+=4),o+=8;for(var s=arguments.length,u=Array(s>4?s-4:0),i=4;s>i;i++)u[i-4]=arguments[i];switch(u.length){case 0:a.writeUInt32LE(0,o),o+=4;var c=serializePayment({amount:n,to:t});return c.copy(a,o),new Transaction({fee:0,keys:[e,t],programId:this.programId,userdata:a.slice(0,o+=c.length)});case 1:a.writeUInt32LE(1,o),o+=4;var l=serializeCondition(u[0]);l.copy(a,o),o+=l.length;var f=serializePayment({amount:n,to:t});return f.copy(a,o),new Transaction({fee:0,keys:[e,r,t],programId:this.programId,userdata:a.slice(0,o+=f.length)});case 2:a.writeUInt32LE(2,o),o+=4;var p=!0,m=!1,d=void 0;try{for(var g,h=_getIterator(u);!(p=(g=h.next()).done);p=!0){var y=serializeCondition(g.value);y.copy(a,o),o+=y.length;var b=serializePayment({amount:n,to:t});b.copy(a,o),o+=b.length}}catch(e){m=!0,d=e}finally{try{!p&&h.return&&h.return()}finally{if(m)throw d}}return new Transaction({fee:0,keys:[e,r,t],programId:this.programId,userdata:a.slice(0,o)});default:throw Error("A maximum of two conditions are support: "+u.length+" provided")}}},{key:"payOnBoth",value:function(e,r,t,n,a,o){var s=Buffer.alloc(1024),u=0;s.writeUInt32LE(0,u),s.writeUInt32LE(n,u+=4),s.writeUInt32LE(3,u+=8),u+=4;for(var i=[a,o],c=0;i.length>c;c++){var l=serializeCondition(i[c]);l.copy(s,u),u+=l.length}var f=serializePayment({amount:n,to:t});return f.copy(s,u),new Transaction({fee:0,keys:[e,r,t],programId:this.programId,userdata:s.slice(0,u+=f.length)})}},{key:"applyTimestamp",value:function(e,r,t,n){var a=serializeDate(n),o=Buffer.alloc(4+a.length);return o.writeUInt32LE(1,0),a.copy(o,4),new Transaction({fee:0,keys:[e,r,t],programId:this.programId,userdata:o})}},{key:"applySignature",value:function(e,r,t){var n=struct([u32("instruction")]),a=Buffer.alloc(n.span);return n.encode({instruction:2},a),new Transaction({fee:0,keys:[e,r,t],programId:this.programId,userdata:a})}},{key:"programId",get:function(){return new PublicKey("0x100000000000000000000000000000000000000000000000000000000000000")}},{key:"space",get:function(){return 128}}]),e}();function sleep(e){return new _Promise(function(r){return setTimeout(r,e)})}function createRpcRequest(e){var r,t=this,n=jayson((r=_asyncToGenerator(_regeneratorRuntime.mark(function r(n,a){var o,s;return _regeneratorRuntime.wrap(function(r){for(;;)switch(r.prev=r.next){case 0:return o={method:"POST",body:n,headers:{"Content-Type":"application/json"}},r.prev=1,r.next=4,fetch(e,o);case 4:return s=r.sent,r.next=7,s.text();case 7:a(null,r.sent),r.next=14;break;case 11:r.prev=11,r.t0=r.catch(1),a(r.t0);case 14:case"end":return r.stop()}},r,t,[[1,11]])})),function(e,t){return r.apply(this,arguments)}));return function(e,r){return new _Promise(function(t,a){n.request(e,r,function(e,r){e?a(e):t(r)})})}}var GetBalanceRpcResult=struct$1({jsonrpc:struct$1.literal("2.0"),id:"string",error:"any?",result:"number?"});function jsonRpcResult(e){var r=struct$1.literal("2.0");return struct$1.union([struct$1({jsonrpc:r,id:"string",error:"any"}),struct$1({jsonrpc:r,id:"string",error:"null?",result:e})])}var GetAccountInfoRpcResult=jsonRpcResult({executable:"boolean",loader_program_id:"array",program_id:"array",tokens:"number",userdata:"array"}),ConfirmTransactionRpcResult=jsonRpcResult("boolean"),GetSignatureStatusRpcResult=jsonRpcResult(struct$1.enum(["Confirmed","SignatureNotFound","ProgramRuntimeError","GenericFailure"])),GetTransactionCountRpcResult=jsonRpcResult("number"),GetLastId=jsonRpcResult("string"),GetFinalityRpcResult=jsonRpcResult("number"),RequestAirdropRpcResult=jsonRpcResult("string"),SendTokensRpcResult=jsonRpcResult("string"),Connection=function(){function e(r){if(_classCallCheck(this,e),this._disableLastIdCaching=!1,"string"!=typeof r)throw Error("Connection endpoint not specified");this._rpcRequest=createRpcRequest(r),this._lastIdInfo={lastId:null,seconds:-1,transactionSignatures:[]}}return _createClass(e,[{key:"getBalance",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getBalance",[r.toBase58()]);case 2:if(!(t=GetBalanceRpcResult(e.sent)).error){e.next=6;break}throw Error(t.error.message);case 6:return assert(void 0!==t.result),e.abrupt("return",t.result);case 8:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"getAccountInfo",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t,n;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getAccountInfo",[r.toBase58()]);case 2:if(!(t=GetAccountInfoRpcResult(e.sent)).error){e.next=6;break}throw Error(t.error.message);case 6:return assert(void 0!==(n=t.result)),e.abrupt("return",{executable:n.executable,tokens:n.tokens,programId:new PublicKey(n.program_id),loaderProgramId:new PublicKey(n.loader_program_id),userdata:Buffer.from(n.userdata)});case 9:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"confirmTransaction",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("confirmTransaction",[r]);case 2:if(!(t=ConfirmTransactionRpcResult(e.sent)).error){e.next=6;break}throw Error(t.error.message);case 6:return assert(void 0!==t.result),e.abrupt("return",t.result);case 8:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"getSignatureStatus",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getSignatureStatus",[r]);case 2:if(!(t=GetSignatureStatusRpcResult(e.sent)).error){e.next=6;break}throw Error(t.error.message);case 6:return assert(void 0!==t.result),e.abrupt("return",t.result);case 8:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"getTransactionCount",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(){var r;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getTransactionCount",[]);case 2:if(!(r=GetTransactionCountRpcResult(e.sent)).error){e.next=6;break}throw Error(r.error.message);case 6:return assert(void 0!==r.result),e.abrupt("return",+r.result);case 8:case"end":return e.stop()}},e,this)}));return function(){return e.apply(this,arguments)}}()},{key:"getLastId",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(){var r;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getLastId",[]);case 2:if(!(r=GetLastId(e.sent)).error){e.next=6;break}throw Error(r.error.message);case 6:return assert(void 0!==r.result),e.abrupt("return",r.result);case 8:case"end":return e.stop()}},e,this)}));return function(){return e.apply(this,arguments)}}()},{key:"getFinality",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(){var r;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getFinality",[]);case 2:if(!(r=GetFinalityRpcResult(e.sent)).error){e.next=6;break}throw Error(r.error.message);case 6:return assert(void 0!==r.result),e.abrupt("return",+r.result);case 8:case"end":return e.stop()}},e,this)}));return function(){return e.apply(this,arguments)}}()},{key:"requestAirdrop",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t){var n;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("requestAirdrop",[r.toBase58(),t]);case 2:if(!(n=RequestAirdropRpcResult(e.sent)).error){e.next=6;break}throw Error(n.error.message);case 6:return assert(void 0!==n.result),e.abrupt("return",n.result);case 8:case"end":return e.stop()}},e,this)}));return function(r,t){return e.apply(this,arguments)}}()},{key:"sendTransaction",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t){var n,a,o,s,u,i;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:if(n=(new Date).getSeconds(),null==this._lastIdInfo.lastId||this._lastIdInfo.seconds!==n){e.next=11;break}if(t.lastId=this._lastIdInfo.lastId,t.sign(r),t.signature){e.next=6;break}throw Error("!signature");case 6:if(this._lastIdInfo.transactionSignatures.includes(a=""+t.signature)){e.next=11;break}return this._lastIdInfo.transactionSignatures.push(a),this._disableLastIdCaching&&(this._lastIdInfo.seconds=-1),e.abrupt("break",27);case 11:o=0;case 12:return e.next=14,this.getLastId();case 14:if(this._lastIdInfo.lastId==(s=e.sent)){e.next=18;break}return this._lastIdInfo={lastId:s,seconds:(new Date).getSeconds(),transactionSignatures:[]},e.abrupt("break",25);case 18:if(8!==o){e.next=20;break}throw Error("Unable to obtain new last id");case 20:return e.next=22,sleep(250);case 22:++o;case 23:e.next=12;break;case 25:e.next=0;break;case 27:return u=t.serialize(),e.next=30,this._rpcRequest("sendTransaction",[[].concat(_toConsumableArray(u))]);case 30:if(!(i=SendTokensRpcResult(e.sent)).error){e.next=34;break}throw Error(i.error.message);case 34:return assert(void 0!==i.result),assert(i.result),e.abrupt("return",i.result);case 37:case"end":return e.stop()}},e,this)}));return function(r,t){return e.apply(this,arguments)}}()}]),e}(),sendAndConfirmTransaction$$1=function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t,n){var a,o,s,u,i,c=arguments.length>3&&void 0!==arguments[3]&&arguments[3];return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return a=Date.now(),e.next=3,r.sendTransaction(t,n);case 3:o=e.sent,s=4;case 5:return e.next=7,r.getSignatureStatus(o);case 7:e.t0=u=e.sent,e.next="Confirmed"===e.t0?11:"ProgramRuntimeError"===e.t0?12:"GenericError"===e.t0?14:"SignatureNotFound"===e.t0?15:14;break;case 11:return e.abrupt("return");case 12:if(!c){e.next=14;break}return e.abrupt("return");case 14:throw Error("Transaction "+o+" failed ("+u+")");case 15:return e.abrupt("break",16);case 16:return e.next=18,sleep(500);case 18:if(0<=--s){e.next=21;break}throw i=(Date.now()-a)/1e3,Error("Transaction '"+o+"' was not confirmed in "+i.toFixed(2)+" seconds ("+u+")");case 21:e.next=5;break;case 23:case"end":return e.stop()}},e,this)}));return function(r,t,n){return e.apply(this,arguments)}}(),Loader$$1=function(){function e(r,t){_classCallCheck(this,e),_Object$assign(this,{connection:r,programId:t})}return _createClass(e,[{key:"load",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t,n){var a,o,s;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return a=struct([u32("instruction"),u32("offset"),u32("bytesLength"),u32("bytesLengthPadding"),seq(u8("byte"),offset(u32(),-8),"bytes")]),o=Buffer.alloc(n.length+16),a.encode({instruction:0,offset:t,bytes:n},o),s=new Transaction({fee:0,keys:[r.publicKey],programId:this.programId,userdata:o}),e.next=6,sendAndConfirmTransaction$$1(this.connection,r,s);case 6:case"end":return e.stop()}},e,this)}));return function(r,t,n){return e.apply(this,arguments)}}()},{key:"finalize",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t,n,a;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return t=struct([u32("instruction")]),n=Buffer.alloc(t.span),t.encode({instruction:1},n),a=new Transaction({fee:0,keys:[r.publicKey],programId:this.programId,userdata:n}),e.next=6,sendAndConfirmTransaction$$1(this.connection,r,a);case 6:return a=SystemProgram.spawn(r.publicKey),e.next=9,sendAndConfirmTransaction$$1(this.connection,r,a);case 9:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()}]),e}(),NativeLoader$$1=function(){function e(){_classCallCheck(this,e)}return _createClass(e,null,[{key:"load",value:function(){var r=_asyncToGenerator(_regeneratorRuntime.mark(function r(t,n,a){var o,s,u,i;return _regeneratorRuntime.wrap(function(r){for(;;)switch(r.prev=r.next){case 0:return o=[].concat(_toConsumableArray(Buffer.from(a))),s=new Account,u=SystemProgram.createAccount(n.publicKey,s.publicKey,1,o.length+1,e.programId),r.next=5,sendAndConfirmTransaction$$1(t,n,u);case 5:return i=new Loader$$1(t,e.programId),r.next=8,i.load(s,0,o);case 8:return r.next=10,i.finalize(s);case 10:return r.abrupt("return",s.publicKey);case 11:case"end":return r.stop()}},r,this)}));return function(e,t,n){return r.apply(this,arguments)}}()},{key:"programId",get:function(){return new PublicKey("0x0202020202020202020202020202020202020202020202020202020202020202")}}]),e}(),SystemProgram=function(){function e(){_classCallCheck(this,e)}return _createClass(e,null,[{key:"createAccount",value:function(r,t,n,a,o){var s=struct([u32("instruction"),ns64("tokens"),ns64("space"),publicKey("programId")]),u=Buffer.alloc(s.span);return s.encode({instruction:0,tokens:n,space:a,programId:o.toBuffer()},u),new Transaction({fee:0,keys:[r,t],programId:e.programId,userdata:u})}},{key:"move",value:function(r,t,n){var a=struct([u32("instruction"),ns64("amount")]),o=Buffer.alloc(a.span);return a.encode({instruction:2,amount:n},o),new Transaction({fee:0,keys:[r,t],programId:e.programId,userdata:o})}},{key:"assign",value:function(r,t){var n=struct([u32("instruction"),publicKey("programId")]),a=Buffer.alloc(n.span);return n.encode({instruction:1,programId:t.toBuffer()},a),new Transaction({fee:0,keys:[r],programId:e.programId,userdata:a})}},{key:"spawn",value:function(r){var t=struct([u32("instruction")]),n=Buffer.alloc(t.span);return t.encode({instruction:3},n),new Transaction({fee:0,keys:[r],programId:e.programId,userdata:n})}},{key:"programId",get:function(){return new PublicKey("0x000000000000000000000000000000000000000000000000000000000000000")}}]),e}(),TokenAmount$$1=function(e){function r(){return _classCallCheck(this,r),_possibleConstructorReturn(this,(r.__proto__||_Object$getPrototypeOf(r)).apply(this,arguments))}return _inherits(r,BN),_createClass(r,[{key:"toBuffer",value:function(){var e=_get(r.prototype.__proto__||_Object$getPrototypeOf(r.prototype),"toArray",this).call(this).reverse(),t=Buffer.from(e);if(8===t.length)return t;assert(8>t.length,"TokenAmount too large");var n=Buffer.alloc(8);return t.copy(n),n}}],[{key:"fromBuffer",value:function(e){return assert(8===e.length,"Invalid buffer length: "+e.length),new BN([].concat(_toConsumableArray(e)).reverse().map(function(e){return("00"+e.toString(16)).slice(-2)}).join(""),16)}}]),r}(),TokenInfoLayout=struct([uint64("supply"),u8("decimals"),rustString("name"),rustString("symbol")]),TokenAccountInfoLayout=struct([publicKey("token"),publicKey("owner"),uint64("amount"),u8("sourceOption"),publicKey("source"),uint64("originalAmount")]),SYSTEM_TOKEN_PROGRAM_ID=new PublicKey("0x500000000000000000000000000000000000000000000000000000000000000"),Token$$1=function(){function e(r,t){var n=arguments.length>2&&void 0!==arguments[2]?arguments[2]:SYSTEM_TOKEN_PROGRAM_ID;_classCallCheck(this,e),_Object$assign(this,{connection:r,token:t,programId:n})}return _createClass(e,[{key:"newAccount",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t,n,a,o,s,u=arguments.length>1&&void 0!==arguments[1]?arguments[1]:null;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return t=new Account,n=void 0,a=struct([u32("instruction")]),o=Buffer.alloc(a.span),a.encode({instruction:1},o),n=SystemProgram.createAccount(r.publicKey,t.publicKey,1,1+TokenAccountInfoLayout.span,this.programId),e.next=8,sendAndConfirmTransaction$$1(this.connection,r,n);case 8:return s=[t.publicKey,r.publicKey,this.token],u&&s.push(u),n=new Transaction({fee:0,keys:s,programId:this.programId,userdata:o}),e.next=13,sendAndConfirmTransaction$$1(this.connection,t,n);case 13:return e.abrupt("return",t.publicKey);case 14:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"tokenInfo",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(){var r,t,n;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.connection.getAccountInfo(this.token);case 2:if((r=e.sent).programId.equals(this.programId)){e.next=5;break}throw Error("Invalid token programId: "+_JSON$stringify(r.programId));case 5:if(1===(t=Buffer.from(r.userdata)).readUInt8(0)){e.next=8;break}throw Error("Invalid token userdata");case 8:return(n=TokenInfoLayout.decode(t,1)).supply=TokenAmount$$1.fromBuffer(n.supply),e.abrupt("return",n);case 11:case"end":return e.stop()}},e,this)}));return function(){return e.apply(this,arguments)}}()},{key:"accountInfo",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t,n,a;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.connection.getAccountInfo(r);case 2:if((t=e.sent).programId.equals(this.programId)){e.next=5;break}throw Error("Invalid token account programId");case 5:if(2===(n=Buffer.from(t.userdata)).readUInt8(0)){e.next=8;break}throw Error("Invalid token account userdata");case 8:if((a=TokenAccountInfoLayout.decode(n,1)).token=new PublicKey(a.token),a.owner=new PublicKey(a.owner),a.amount=TokenAmount$$1.fromBuffer(a.amount),0===a.sourceOption?(a.source=null,a.originalAmount=new TokenAmount$$1):(a.source=new PublicKey(a.source),a.originalAmount=TokenAmount$$1.fromBuffer(a.originalAmount)),a.token.equals(this.token)){e.next=15;break}throw Error("Invalid token account token: "+_JSON$stringify(a.token)+" !== "+_JSON$stringify(this.token));case 15:return e.abrupt("return",a);case 16:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"transfer",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t,n,a){var o,s,u,i,c;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.accountInfo(t);case 2:if(r.publicKey.equals((o=e.sent).owner)){e.next=5;break}throw Error("Account owner mismatch");case 5:return s=struct([u32("instruction"),uint64("amount")]),u=Buffer.alloc(s.span),s.encode({instruction:2,amount:new TokenAmount$$1(a).toBuffer()},u),i=[r.publicKey,t,n],o.source&&i.push(o.source),c=new Transaction({fee:0,keys:i,programId:this.programId,userdata:u}),e.next=13,sendAndConfirmTransaction$$1(this.connection,r,c);case 13:case"end":return e.stop()}},e,this)}));return function(r,t,n,a){return e.apply(this,arguments)}}()},{key:"approve",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t,n,a){var o,s,u;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return o=struct([u32("instruction"),uint64("amount")]),s=Buffer.alloc(o.span),o.encode({instruction:3,amount:new TokenAmount$$1(a).toBuffer()},s),u=new Transaction({fee:0,keys:[r.publicKey,t,n],programId:this.programId,userdata:s}),e.next=6,sendAndConfirmTransaction$$1(this.connection,r,u);case 6:case"end":return e.stop()}},e,this)}));return function(r,t,n,a){return e.apply(this,arguments)}}()},{key:"revoke",value:function(e,r,t){return this.approve(e,r,t,0)}},{key:"setOwner",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t,n){var a,o,s;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return a=struct([u32("instruction")]),o=Buffer.alloc(a.span),a.encode({instruction:4},o),s=new Transaction({fee:0,keys:[r.publicKey,t,n],programId:this.programId,userdata:o}),e.next=7,sendAndConfirmTransaction$$1(this.connection,r,s);case 7:case"end":return e.stop()}},e,this)}));return function(r,t,n){return e.apply(this,arguments)}}()}],[{key:"createNewToken",value:function(){var r=_asyncToGenerator(_regeneratorRuntime.mark(function r(t,n,a,o,s,u){var i,c,l,f,p,m,d,g=arguments.length>6&&void 0!==arguments[6]?arguments[6]:SYSTEM_TOKEN_PROGRAM_ID;return _regeneratorRuntime.wrap(function(r){for(;;)switch(r.prev=r.next){case 0:return i=new Account,c=new e(t,i.publicKey,g),r.next=4,c.newAccount(n,null);case 4:return l=r.sent,f=void 0,p=struct([u32("instruction"),uint64("supply"),u8("decimals"),rustString("name"),rustString("symbol")]),m=Buffer.alloc(1024),d=p.encode({instruction:0,supply:a.toBuffer(),decimals:u,name:o,symbol:s},m),m=m.slice(0,d),f=SystemProgram.createAccount(n.publicKey,i.publicKey,1,1+m.length,g),r.next=13,sendAndConfirmTransaction$$1(t,n,f);case 13:return f=new Transaction({fee:0,keys:[i.publicKey,l],programId:g,userdata:m}),r.next=16,sendAndConfirmTransaction$$1(t,i,f);case 16:return r.abrupt("return",[c,l]);case 17:case"end":return r.stop()}},r,this)}));return function(e,t,n,a,o,s){return r.apply(this,arguments)}}()}]),e}();export{Account,BudgetProgram,Connection,Loader$$1 as Loader,NativeLoader$$1 as NativeLoader,PublicKey,SystemProgram,Token$$1 as Token,TokenAmount$$1 as TokenAmount,Transaction,sendAndConfirmTransaction$$1 as sendAndConfirmTransaction};
+import _classCallCheck from"babel-runtime/helpers/classCallCheck";import _createClass from"babel-runtime/helpers/createClass";import BN from"bn.js";import bs58 from"bs58";import nacl from"tweetnacl";import{struct,u32,seq,u8,offset,ns64,blob}from"buffer-layout";import _toConsumableArray from"babel-runtime/helpers/toConsumableArray";import _Object$assign from"babel-runtime/core-js/object/assign";import assert from"assert";import _getIterator from"babel-runtime/core-js/get-iterator";import _Promise from"babel-runtime/core-js/promise";import _regeneratorRuntime from"babel-runtime/regenerator";import _asyncToGenerator from"babel-runtime/helpers/asyncToGenerator";import fetch from"node-fetch";import jayson from"jayson/lib/client/browser";import{struct as struct$1}from"superstruct";import _JSON$stringify from"babel-runtime/core-js/json/stringify";import _Object$getPrototypeOf from"babel-runtime/core-js/object/get-prototype-of";import _possibleConstructorReturn from"babel-runtime/helpers/possibleConstructorReturn";import _get from"babel-runtime/helpers/get";import _inherits from"babel-runtime/helpers/inherits";var PublicKey=function(){function e(r){for(_classCallCheck(this,e);;){if("string"==typeof r){if(/^[1-9A-HJ-NP-Za-km-z]{43,44}$/.test(r)){this._bn=new BN(bs58.decode(r));break}if(r.startsWith("0x")){this._bn=new BN(r.substring(2),16);break}}this._bn=new BN(r);break}if(this._bn.byteLength()>32)throw Error("Invalid public key input")}return _createClass(e,[{key:"equals",value:function(e){return this._bn.eq(e._bn)}},{key:"toBase58",value:function(){return bs58.encode(this.toBuffer())}},{key:"toBuffer",value:function(){var e=this._bn.toArrayLike(Buffer);if(32===e.length)return e;var r=Buffer.alloc(32);return e.copy(r,32-e.length),r}},{key:"toString",value:function(){return this.toBase58()}}],[{key:"isPublicKey",value:function(r){return r instanceof e}}]),e}(),Account=function(){function e(){var r=arguments.length>0&&void 0!==arguments[0]?arguments[0]:null;_classCallCheck(this,e),this._keypair=r?nacl.sign.keyPair.fromSecretKey(r):nacl.sign.keyPair()}return _createClass(e,[{key:"publicKey",get:function(){return new PublicKey(this._keypair.publicKey)}},{key:"secretKey",get:function(){return this._keypair.secretKey}}]),e}(),publicKey=function(){return blob(32,arguments.length>0&&void 0!==arguments[0]?arguments[0]:"publicKey")},uint64=function(){return blob(8,arguments.length>0&&void 0!==arguments[0]?arguments[0]:"uint64")},rustString=function(){var e=arguments.length>0&&void 0!==arguments[0]?arguments[0]:"string",r=struct([u32("length"),u32("lengthPadding"),blob(offset(u32(),-8),"chars")],e),t=r.decode.bind(r),n=r.encode.bind(r);return r.decode=function(e,r){return t(e,r).chars.toString("utf8")},r.encode=function(e,r,t){var a={chars:Buffer.from(e,"utf8")};return n(a,r,t)},r},Transaction=function(){function e(r){_classCallCheck(this,e),this.keys=[],this.fee=0,this.userdata=Buffer.alloc(0),r&&_Object$assign(this,r)}return _createClass(e,[{key:"_getSignData",value:function(){var e=this.lastId,r=this.keys,t=this.programId,n=this.userdata;if(!e)throw Error("Transaction lastId required");var a=[t],o=[{programId:0,accountsLength:r.length,accounts:[].concat(_toConsumableArray(r.keys())),userdataLength:n.length,userdata:n}],s=struct([u8("programId"),u32("accountsLength"),u32("accountsLengthPadding"),seq(u8("account"),offset(u32(),-8),"accounts"),ns64("userdataLength"),blob(n.length,"userdata")]),u=struct([u32("accountKeysLength"),u32("accountKeysLengthPadding"),seq(publicKey("accountKey"),offset(u32(),-8),"accountKeys"),publicKey("lastId"),ns64("fee"),u32("programIdsLength"),u32("programIdsLengthPadding"),seq(publicKey("programId"),offset(u32(),-8),"programIds"),u32("instructionsLength"),u32("instructionsLengthPadding"),seq(s,offset(u32(),-8),"instructions")]),i={accountKeys:r.map(function(e){return e.toBuffer()}),lastId:Buffer.from(bs58.decode(e)),fee:0,programIds:a.map(function(e){return e.toBuffer()}),instructions:o},c=Buffer.alloc(2048),l=u.encode(i,c);return c=c.slice(0,l)}},{key:"sign",value:function(e){var r=this._getSignData();this.signature=nacl.sign.detached(r,e.secretKey),assert(64===this.signature.length)}},{key:"serialize",value:function(){var e=this.signature;if(!e)throw Error("Transaction has not been signed");var r=this._getSignData(),t=Buffer.alloc(e.length+r.length);return Buffer.from(e).copy(t,0),r.copy(t,e.length),t}}]),e}();function serializePayment(e){var r=e.to.toBuffer(),t=Buffer.alloc(8+r.length);return t.writeUInt32LE(e.amount,0),r.copy(t,8),t}function serializeDate(e){var r=Buffer.alloc(28);return r.writeUInt32LE(20,0),r.write(function(e){function r(e){return 10>e?"0"+e:e}return e.getUTCFullYear()+"-"+r(e.getUTCMonth()+1)+"-"+r(e.getUTCDate())+"T"+r(e.getUTCHours())+":"+r(e.getUTCMinutes())+":"+r(e.getUTCSeconds())+"Z"}(e),8),r}function serializeCondition(e){switch(e.type){case"timestamp":var r=serializeDate(e.when),t=e.from.toBuffer(),n=Buffer.alloc(4+r.length+t.length);return n.writeUInt32LE(0,0),r.copy(n,4),t.copy(n,4+r.length),n;case"signature":var a=struct([u32("condition"),publicKey("from")]),o=e.from.toBuffer(),s=Buffer.alloc(4+o.length);return a.encode({instruction:1,from:o},s),s;default:throw Error("Unknown condition type: "+e.type)}}var BudgetProgram=function(){function e(){_classCallCheck(this,e)}return _createClass(e,null,[{key:"timestampCondition",value:function(e,r){return{type:"timestamp",from:e,when:r}}},{key:"signatureCondition",value:function(e){return{type:"signature",from:e}}},{key:"pay",value:function(e,r,t,n){var a=Buffer.alloc(1024),o=0;a.writeUInt32LE(0,o),a.writeUInt32LE(n,o+=4),o+=8;for(var s=arguments.length,u=Array(s>4?s-4:0),i=4;s>i;i++)u[i-4]=arguments[i];switch(u.length){case 0:a.writeUInt32LE(0,o),o+=4;var c=serializePayment({amount:n,to:t});return c.copy(a,o),new Transaction({fee:0,keys:[e,t],programId:this.programId,userdata:a.slice(0,o+=c.length)});case 1:a.writeUInt32LE(1,o),o+=4;var l=serializeCondition(u[0]);l.copy(a,o),o+=l.length;var f=serializePayment({amount:n,to:t});return f.copy(a,o),new Transaction({fee:0,keys:[e,r,t],programId:this.programId,userdata:a.slice(0,o+=f.length)});case 2:a.writeUInt32LE(2,o),o+=4;var p=!0,m=!1,d=void 0;try{for(var g,h=_getIterator(u);!(p=(g=h.next()).done);p=!0){var y=serializeCondition(g.value);y.copy(a,o),o+=y.length;var b=serializePayment({amount:n,to:t});b.copy(a,o),o+=b.length}}catch(e){m=!0,d=e}finally{try{!p&&h.return&&h.return()}finally{if(m)throw d}}return new Transaction({fee:0,keys:[e,r,t],programId:this.programId,userdata:a.slice(0,o)});default:throw Error("A maximum of two conditions are support: "+u.length+" provided")}}},{key:"payOnBoth",value:function(e,r,t,n,a,o){var s=Buffer.alloc(1024),u=0;s.writeUInt32LE(0,u),s.writeUInt32LE(n,u+=4),s.writeUInt32LE(3,u+=8),u+=4;for(var i=[a,o],c=0;i.length>c;c++){var l=serializeCondition(i[c]);l.copy(s,u),u+=l.length}var f=serializePayment({amount:n,to:t});return f.copy(s,u),new Transaction({fee:0,keys:[e,r,t],programId:this.programId,userdata:s.slice(0,u+=f.length)})}},{key:"applyTimestamp",value:function(e,r,t,n){var a=serializeDate(n),o=Buffer.alloc(4+a.length);return o.writeUInt32LE(1,0),a.copy(o,4),new Transaction({fee:0,keys:[e,r,t],programId:this.programId,userdata:o})}},{key:"applySignature",value:function(e,r,t){var n=struct([u32("instruction")]),a=Buffer.alloc(n.span);return n.encode({instruction:2},a),new Transaction({fee:0,keys:[e,r,t],programId:this.programId,userdata:a})}},{key:"programId",get:function(){return new PublicKey("0x100000000000000000000000000000000000000000000000000000000000000")}},{key:"space",get:function(){return 128}}]),e}();function sleep(e){return new _Promise(function(r){return setTimeout(r,e)})}function createRpcRequest(e){var r,t=this,n=jayson((r=_asyncToGenerator(_regeneratorRuntime.mark(function r(n,a){var o,s;return _regeneratorRuntime.wrap(function(r){for(;;)switch(r.prev=r.next){case 0:return o={method:"POST",body:n,headers:{"Content-Type":"application/json"}},r.prev=1,r.next=4,fetch(e,o);case 4:return s=r.sent,r.next=7,s.text();case 7:a(null,r.sent),r.next=14;break;case 11:r.prev=11,r.t0=r.catch(1),a(r.t0);case 14:case"end":return r.stop()}},r,t,[[1,11]])})),function(e,t){return r.apply(this,arguments)}));return function(e,r){return new _Promise(function(t,a){n.request(e,r,function(e,r){e?a(e):t(r)})})}}var GetBalanceRpcResult=struct$1({jsonrpc:struct$1.literal("2.0"),id:"string",error:"any?",result:"number?"});function jsonRpcResult(e){var r=struct$1.literal("2.0");return struct$1.union([struct$1({jsonrpc:r,id:"string",error:"any"}),struct$1({jsonrpc:r,id:"string",error:"null?",result:e})])}var GetAccountInfoRpcResult=jsonRpcResult({executable:"boolean",loader_program_id:"array",program_id:"array",tokens:"number",userdata:"array"}),ConfirmTransactionRpcResult=jsonRpcResult("boolean"),GetSignatureStatusRpcResult=jsonRpcResult(struct$1.enum(["AccountInUse","Confirmed","GenericFailure","ProgramRuntimeError","SignatureNotFound"])),GetTransactionCountRpcResult=jsonRpcResult("number"),GetLastId=jsonRpcResult("string"),GetFinalityRpcResult=jsonRpcResult("number"),RequestAirdropRpcResult=jsonRpcResult("string"),SendTokensRpcResult=jsonRpcResult("string"),Connection=function(){function e(r){if(_classCallCheck(this,e),this._disableLastIdCaching=!1,"string"!=typeof r)throw Error("Connection endpoint not specified");this._rpcRequest=createRpcRequest(r),this._lastIdInfo={lastId:null,seconds:-1,transactionSignatures:[]}}return _createClass(e,[{key:"getBalance",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getBalance",[r.toBase58()]);case 2:if(!(t=GetBalanceRpcResult(e.sent)).error){e.next=6;break}throw Error(t.error.message);case 6:return assert(void 0!==t.result),e.abrupt("return",t.result);case 8:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"getAccountInfo",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t,n;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getAccountInfo",[r.toBase58()]);case 2:if(!(t=GetAccountInfoRpcResult(e.sent)).error){e.next=6;break}throw Error(t.error.message);case 6:return assert(void 0!==(n=t.result)),e.abrupt("return",{executable:n.executable,tokens:n.tokens,programId:new PublicKey(n.program_id),loaderProgramId:new PublicKey(n.loader_program_id),userdata:Buffer.from(n.userdata)});case 9:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"confirmTransaction",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("confirmTransaction",[r]);case 2:if(!(t=ConfirmTransactionRpcResult(e.sent)).error){e.next=6;break}throw Error(t.error.message);case 6:return assert(void 0!==t.result),e.abrupt("return",t.result);case 8:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"getSignatureStatus",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getSignatureStatus",[r]);case 2:if(!(t=GetSignatureStatusRpcResult(e.sent)).error){e.next=6;break}throw Error(t.error.message);case 6:return assert(void 0!==t.result),e.abrupt("return",t.result);case 8:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"getTransactionCount",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(){var r;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getTransactionCount",[]);case 2:if(!(r=GetTransactionCountRpcResult(e.sent)).error){e.next=6;break}throw Error(r.error.message);case 6:return assert(void 0!==r.result),e.abrupt("return",+r.result);case 8:case"end":return e.stop()}},e,this)}));return function(){return e.apply(this,arguments)}}()},{key:"getLastId",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(){var r;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getLastId",[]);case 2:if(!(r=GetLastId(e.sent)).error){e.next=6;break}throw Error(r.error.message);case 6:return assert(void 0!==r.result),e.abrupt("return",r.result);case 8:case"end":return e.stop()}},e,this)}));return function(){return e.apply(this,arguments)}}()},{key:"getFinality",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(){var r;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("getFinality",[]);case 2:if(!(r=GetFinalityRpcResult(e.sent)).error){e.next=6;break}throw Error(r.error.message);case 6:return assert(void 0!==r.result),e.abrupt("return",+r.result);case 8:case"end":return e.stop()}},e,this)}));return function(){return e.apply(this,arguments)}}()},{key:"requestAirdrop",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t){var n;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this._rpcRequest("requestAirdrop",[r.toBase58(),t]);case 2:if(!(n=RequestAirdropRpcResult(e.sent)).error){e.next=6;break}throw Error(n.error.message);case 6:return assert(void 0!==n.result),e.abrupt("return",n.result);case 8:case"end":return e.stop()}},e,this)}));return function(r,t){return e.apply(this,arguments)}}()},{key:"sendTransaction",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t){var n,a,o,s,u,i;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:if(n=(new Date).getSeconds(),null==this._lastIdInfo.lastId||this._lastIdInfo.seconds!==n){e.next=11;break}if(t.lastId=this._lastIdInfo.lastId,t.sign(r),t.signature){e.next=6;break}throw Error("!signature");case 6:if(this._lastIdInfo.transactionSignatures.includes(a=""+t.signature)){e.next=11;break}return this._lastIdInfo.transactionSignatures.push(a),this._disableLastIdCaching&&(this._lastIdInfo.seconds=-1),e.abrupt("break",27);case 11:o=0;case 12:return e.next=14,this.getLastId();case 14:if(this._lastIdInfo.lastId==(s=e.sent)){e.next=18;break}return this._lastIdInfo={lastId:s,seconds:(new Date).getSeconds(),transactionSignatures:[]},e.abrupt("break",25);case 18:if(8!==o){e.next=20;break}throw Error("Unable to obtain new last id");case 20:return e.next=22,sleep(250);case 22:++o;case 23:e.next=12;break;case 25:e.next=0;break;case 27:return u=t.serialize(),e.next=30,this._rpcRequest("sendTransaction",[[].concat(_toConsumableArray(u))]);case 30:if(!(i=SendTokensRpcResult(e.sent)).error){e.next=34;break}throw Error(i.error.message);case 34:return assert(void 0!==i.result),assert(i.result),e.abrupt("return",i.result);case 37:case"end":return e.stop()}},e,this)}));return function(r,t){return e.apply(this,arguments)}}()}]),e}(),sendAndConfirmTransaction$$1=function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t,n){var a,o,s,u,i,c,l=arguments.length>3&&void 0!==arguments[3]&&arguments[3];return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:a=3;case 1:return o=Date.now(),e.next=4,r.sendTransaction(t,n);case 4:s=e.sent,u="SignatureNotFound",i=4;case 7:return e.next=9,r.getSignatureStatus(s);case 9:if("SignatureNotFound"===(u=e.sent)){e.next=12;break}return e.abrupt("break",19);case 12:return e.next=14,sleep(500);case 14:if(0<--i){e.next=17;break}throw c=(Date.now()-o)/1e3,Error("Transaction '"+s+"' was not confirmed in "+c.toFixed(2)+" seconds ("+u+")");case 17:e.next=7;break;case 19:if(!("Confirmed"===u||"ProgramRuntimeError"===u&&l)){e.next=21;break}return e.abrupt("return");case 21:if("AccountInUse"===u&&--a>0){e.next=23;break}throw Error("Transaction "+s+" failed ("+u+")");case 23:e.next=1;break;case 25:case"end":return e.stop()}},e,this)}));return function(r,t,n){return e.apply(this,arguments)}}(),Loader$$1=function(){function e(r,t){_classCallCheck(this,e),_Object$assign(this,{connection:r,programId:t})}return _createClass(e,[{key:"load",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t,n){var a,o,s;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return a=struct([u32("instruction"),u32("offset"),u32("bytesLength"),u32("bytesLengthPadding"),seq(u8("byte"),offset(u32(),-8),"bytes")]),o=Buffer.alloc(n.length+16),a.encode({instruction:0,offset:t,bytes:n},o),s=new Transaction({fee:0,keys:[r.publicKey],programId:this.programId,userdata:o}),e.next=6,sendAndConfirmTransaction$$1(this.connection,r,s);case 6:case"end":return e.stop()}},e,this)}));return function(r,t,n){return e.apply(this,arguments)}}()},{key:"finalize",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t,n,a;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return t=struct([u32("instruction")]),n=Buffer.alloc(t.span),t.encode({instruction:1},n),a=new Transaction({fee:0,keys:[r.publicKey],programId:this.programId,userdata:n}),e.next=6,sendAndConfirmTransaction$$1(this.connection,r,a);case 6:return a=SystemProgram.spawn(r.publicKey),e.next=9,sendAndConfirmTransaction$$1(this.connection,r,a);case 9:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()}]),e}(),NativeLoader$$1=function(){function e(){_classCallCheck(this,e)}return _createClass(e,null,[{key:"load",value:function(){var r=_asyncToGenerator(_regeneratorRuntime.mark(function r(t,n,a){var o,s,u,i;return _regeneratorRuntime.wrap(function(r){for(;;)switch(r.prev=r.next){case 0:return o=[].concat(_toConsumableArray(Buffer.from(a))),s=new Account,u=SystemProgram.createAccount(n.publicKey,s.publicKey,1,o.length+1,e.programId),r.next=5,sendAndConfirmTransaction$$1(t,n,u);case 5:return i=new Loader$$1(t,e.programId),r.next=8,i.load(s,0,o);case 8:return r.next=10,i.finalize(s);case 10:return r.abrupt("return",s.publicKey);case 11:case"end":return r.stop()}},r,this)}));return function(e,t,n){return r.apply(this,arguments)}}()},{key:"programId",get:function(){return new PublicKey("0x0202020202020202020202020202020202020202020202020202020202020202")}}]),e}(),SystemProgram=function(){function e(){_classCallCheck(this,e)}return _createClass(e,null,[{key:"createAccount",value:function(r,t,n,a,o){var s=struct([u32("instruction"),ns64("tokens"),ns64("space"),publicKey("programId")]),u=Buffer.alloc(s.span);return s.encode({instruction:0,tokens:n,space:a,programId:o.toBuffer()},u),new Transaction({fee:0,keys:[r,t],programId:e.programId,userdata:u})}},{key:"move",value:function(r,t,n){var a=struct([u32("instruction"),ns64("amount")]),o=Buffer.alloc(a.span);return a.encode({instruction:2,amount:n},o),new Transaction({fee:0,keys:[r,t],programId:e.programId,userdata:o})}},{key:"assign",value:function(r,t){var n=struct([u32("instruction"),publicKey("programId")]),a=Buffer.alloc(n.span);return n.encode({instruction:1,programId:t.toBuffer()},a),new Transaction({fee:0,keys:[r],programId:e.programId,userdata:a})}},{key:"spawn",value:function(r){var t=struct([u32("instruction")]),n=Buffer.alloc(t.span);return t.encode({instruction:3},n),new Transaction({fee:0,keys:[r],programId:e.programId,userdata:n})}},{key:"programId",get:function(){return new PublicKey("0x000000000000000000000000000000000000000000000000000000000000000")}}]),e}(),TokenAmount$$1=function(e){function r(){return _classCallCheck(this,r),_possibleConstructorReturn(this,(r.__proto__||_Object$getPrototypeOf(r)).apply(this,arguments))}return _inherits(r,BN),_createClass(r,[{key:"toBuffer",value:function(){var e=_get(r.prototype.__proto__||_Object$getPrototypeOf(r.prototype),"toArray",this).call(this).reverse(),t=Buffer.from(e);if(8===t.length)return t;assert(8>t.length,"TokenAmount too large");var n=Buffer.alloc(8);return t.copy(n),n}}],[{key:"fromBuffer",value:function(e){return assert(8===e.length,"Invalid buffer length: "+e.length),new BN([].concat(_toConsumableArray(e)).reverse().map(function(e){return("00"+e.toString(16)).slice(-2)}).join(""),16)}}]),r}(),TokenInfoLayout=struct([uint64("supply"),u8("decimals"),rustString("name"),rustString("symbol")]),TokenAccountInfoLayout=struct([publicKey("token"),publicKey("owner"),uint64("amount"),u8("sourceOption"),publicKey("source"),uint64("originalAmount")]),SYSTEM_TOKEN_PROGRAM_ID=new PublicKey("0x500000000000000000000000000000000000000000000000000000000000000"),Token$$1=function(){function e(r,t){var n=arguments.length>2&&void 0!==arguments[2]?arguments[2]:SYSTEM_TOKEN_PROGRAM_ID;_classCallCheck(this,e),_Object$assign(this,{connection:r,token:t,programId:n})}return _createClass(e,[{key:"newAccount",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t,n,a,o,s,u=arguments.length>1&&void 0!==arguments[1]?arguments[1]:null;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return t=new Account,n=void 0,a=struct([u32("instruction")]),o=Buffer.alloc(a.span),a.encode({instruction:1},o),n=SystemProgram.createAccount(r.publicKey,t.publicKey,1,1+TokenAccountInfoLayout.span,this.programId),e.next=8,sendAndConfirmTransaction$$1(this.connection,r,n);case 8:return s=[t.publicKey,r.publicKey,this.token],u&&s.push(u),n=new Transaction({fee:0,keys:s,programId:this.programId,userdata:o}),e.next=13,sendAndConfirmTransaction$$1(this.connection,t,n);case 13:return e.abrupt("return",t.publicKey);case 14:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"tokenInfo",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(){var r,t,n;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.connection.getAccountInfo(this.token);case 2:if((r=e.sent).programId.equals(this.programId)){e.next=5;break}throw Error("Invalid token programId: "+_JSON$stringify(r.programId));case 5:if(1===(t=Buffer.from(r.userdata)).readUInt8(0)){e.next=8;break}throw Error("Invalid token userdata");case 8:return(n=TokenInfoLayout.decode(t,1)).supply=TokenAmount$$1.fromBuffer(n.supply),e.abrupt("return",n);case 11:case"end":return e.stop()}},e,this)}));return function(){return e.apply(this,arguments)}}()},{key:"accountInfo",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r){var t,n,a;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.connection.getAccountInfo(r);case 2:if((t=e.sent).programId.equals(this.programId)){e.next=5;break}throw Error("Invalid token account programId");case 5:if(2===(n=Buffer.from(t.userdata)).readUInt8(0)){e.next=8;break}throw Error("Invalid token account userdata");case 8:if((a=TokenAccountInfoLayout.decode(n,1)).token=new PublicKey(a.token),a.owner=new PublicKey(a.owner),a.amount=TokenAmount$$1.fromBuffer(a.amount),0===a.sourceOption?(a.source=null,a.originalAmount=new TokenAmount$$1):(a.source=new PublicKey(a.source),a.originalAmount=TokenAmount$$1.fromBuffer(a.originalAmount)),a.token.equals(this.token)){e.next=15;break}throw Error("Invalid token account token: "+_JSON$stringify(a.token)+" !== "+_JSON$stringify(this.token));case 15:return e.abrupt("return",a);case 16:case"end":return e.stop()}},e,this)}));return function(r){return e.apply(this,arguments)}}()},{key:"transfer",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t,n,a){var o,s,u,i,c;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return e.next=2,this.accountInfo(t);case 2:if(r.publicKey.equals((o=e.sent).owner)){e.next=5;break}throw Error("Account owner mismatch");case 5:return s=struct([u32("instruction"),uint64("amount")]),u=Buffer.alloc(s.span),s.encode({instruction:2,amount:new TokenAmount$$1(a).toBuffer()},u),i=[r.publicKey,t,n],o.source&&i.push(o.source),c=new Transaction({fee:0,keys:i,programId:this.programId,userdata:u}),e.next=13,sendAndConfirmTransaction$$1(this.connection,r,c);case 13:case"end":return e.stop()}},e,this)}));return function(r,t,n,a){return e.apply(this,arguments)}}()},{key:"approve",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t,n,a){var o,s,u;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return o=struct([u32("instruction"),uint64("amount")]),s=Buffer.alloc(o.span),o.encode({instruction:3,amount:new TokenAmount$$1(a).toBuffer()},s),u=new Transaction({fee:0,keys:[r.publicKey,t,n],programId:this.programId,userdata:s}),e.next=6,sendAndConfirmTransaction$$1(this.connection,r,u);case 6:case"end":return e.stop()}},e,this)}));return function(r,t,n,a){return e.apply(this,arguments)}}()},{key:"revoke",value:function(e,r,t){return this.approve(e,r,t,0)}},{key:"setOwner",value:function(){var e=_asyncToGenerator(_regeneratorRuntime.mark(function e(r,t,n){var a,o,s;return _regeneratorRuntime.wrap(function(e){for(;;)switch(e.prev=e.next){case 0:return a=struct([u32("instruction")]),o=Buffer.alloc(a.span),a.encode({instruction:4},o),s=new Transaction({fee:0,keys:[r.publicKey,t,n],programId:this.programId,userdata:o}),e.next=7,sendAndConfirmTransaction$$1(this.connection,r,s);case 7:case"end":return e.stop()}},e,this)}));return function(r,t,n){return e.apply(this,arguments)}}()}],[{key:"createNewToken",value:function(){var r=_asyncToGenerator(_regeneratorRuntime.mark(function r(t,n,a,o,s,u){var i,c,l,f,p,m,d,g=arguments.length>6&&void 0!==arguments[6]?arguments[6]:SYSTEM_TOKEN_PROGRAM_ID;return _regeneratorRuntime.wrap(function(r){for(;;)switch(r.prev=r.next){case 0:return i=new Account,c=new e(t,i.publicKey,g),r.next=4,c.newAccount(n,null);case 4:return l=r.sent,f=void 0,p=struct([u32("instruction"),uint64("supply"),u8("decimals"),rustString("name"),rustString("symbol")]),m=Buffer.alloc(1024),d=p.encode({instruction:0,supply:a.toBuffer(),decimals:u,name:o,symbol:s},m),m=m.slice(0,d),f=SystemProgram.createAccount(n.publicKey,i.publicKey,1,1+m.length,g),r.next=13,sendAndConfirmTransaction$$1(t,n,f);case 13:return f=new Transaction({fee:0,keys:[i.publicKey,l],programId:g,userdata:m}),r.next=16,sendAndConfirmTransaction$$1(t,i,f);case 16:return r.abrupt("return",[c,l]);case 17:case"end":return r.stop()}},r,this)}));return function(e,t,n,a,o,s){return r.apply(this,arguments)}}()}]),e}();export{Account,BudgetProgram,Connection,Loader$$1 as Loader,NativeLoader$$1 as NativeLoader,PublicKey,SystemProgram,Token$$1 as Token,TokenAmount$$1 as TokenAmount,Transaction,sendAndConfirmTransaction$$1 as sendAndConfirmTransaction};

module.flow.js

@@ -44,3 +44,7 @@ /**
 
-  declare export type SignatureStatus = 'Confirmed' | 'SignatureNotFound' | 'ProgramRuntimeError' | 'GenericFailure';
+  declare export type SignatureStatus = 'Confirmed'
+    | 'AccountInUse'
+    | 'SignatureNotFound'
+    | 'ProgramRuntimeError'
+    | 'GenericFailure';
 
@@ -47,0 +51,0 @@ declare export class Connection {

package.json

 {
   "name": "@solana/web3.js",
-  "version": "0.6.11",
+  "version": "0.6.12",
   "description": "Solana Javascript API",
@@ -5,0 +5,0 @@ "keywords": [

No alert changes

Improved metrics

Total package byte prevSize

8645484

increased by0.44%

Lines of code

302862

increased by0.4%

No dependency changes