/* * Copyright (c) 2017-2018 PlayerOne. * * The MIT License * * Permission is hereby granted, free of charge, to any person obtaining a copy * of this software and associated documentation files (the "Software"), to deal * in the Software without restriction, including without limitation the rights * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell * copies of the Software, and to permit persons to whom the Software is * furnished to do so, subject to the following conditions: * * The above copyright notice and this permission notice shall be included in all * copies or substantial portions of the Software. * * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE * SOFTWARE. */ package io.plactal.eoscommander.data; import com.google.gson.Gson; import com.google.gson.GsonBuilder; import com.google.gson.JsonObject; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import javax.inject.Inject; import javax.inject.Singleton; import io.plactal.eoscommander.crypto.ec.EosPrivateKey; import io.plactal.eoscommander.crypto.ec.EosPublicKey; import io.plactal.eoscommander.data.local.repository.EosAccountRepository; import io.plactal.eoscommander.data.prefs.PreferencesHelper; import io.plactal.eoscommander.data.remote.NodeosApi; import io.plactal.eoscommander.data.remote.model.abi.EosAbiMain; import io.plactal.eoscommander.data.remote.model.api.AccountInfoRequest; import io.plactal.eoscommander.data.remote.model.api.EosChainInfo; import io.plactal.eoscommander.data.remote.model.api.GetBalanceRequest; import io.plactal.eoscommander.data.remote.model.api.GetCodeRequest; import io.plactal.eoscommander.data.remote.model.api.GetRequestForCurrency; import io.plactal.eoscommander.data.remote.model.api.GetRequiredKeys; import io.plactal.eoscommander.data.remote.model.api.GetTableRequest; import io.plactal.eoscommander.data.remote.model.api.JsonToBinRequest; import io.plactal.eoscommander.data.remote.model.api.PushTxnResponse; import io.plactal.eoscommander.data.remote.model.chain.Action; import io.plactal.eoscommander.data.remote.model.chain.PackedTransaction; import io.plactal.eoscommander.data.remote.model.chain.SignedTransaction; import io.plactal.eoscommander.data.remote.model.types.EosNewAccount; import io.plactal.eoscommander.data.remote.model.types.EosTransfer; import io.plactal.eoscommander.data.remote.model.types.TypeAccountName; import io.plactal.eoscommander.data.remote.model.types.TypeAsset; import io.plactal.eoscommander.data.remote.model.types.TypeChainId; import io.plactal.eoscommander.data.remote.model.types.TypePublicKey; import io.plactal.eoscommander.data.remote.model.types.TypeSymbol; import io.plactal.eoscommander.data.wallet.EosWalletManager; import io.plactal.eoscommander.util.Consts; import io.plactal.eoscommander.util.StringUtils; import io.plactal.eoscommander.util.Utils; import io.reactivex.Observable; import static io.plactal.eoscommander.util.Consts.EOSIO_SYSTEM_ACCOUNT; import static io.plactal.eoscommander.util.Consts.EOSIO_TOKEN_CONTRACT; import static io.plactal.eoscommander.util.Consts.TX_EXPIRATION_IN_MILSEC; /** * Created by swapnibble on 2017-11-03. */ @Singleton public class EoscDataManager { private final NodeosApi mNodeosApi; private final PreferencesHelper mPrefHelper; private final EosWalletManager mWalletMgr; private final EosAccountRepository mAccountRepository; private HashMap mAbiObjHouse; @Inject public EoscDataManager(NodeosApi nodeosApi, EosWalletManager walletManager, EosAccountRepository accountRepository, PreferencesHelper prefHelper) { mNodeosApi = nodeosApi; mWalletMgr = walletManager; mAccountRepository = accountRepository; mPrefHelper = prefHelper; // set wallet directory mWalletMgr.setDir( mPrefHelper.getWalletDirFile() ); mWalletMgr.openExistingsInDir(); // set core symbol TypeSymbol.setCoreSymbol( mPrefHelper.getCoreSymbolPrecision(), mPrefHelper.getCoreSymbolString()); mAbiObjHouse = new HashMap<>(); } public void updateCoreSymbol(String symbolStr, int symbolPrecision){ mPrefHelper.putCoreSymbolInfo( StringUtils.isEmpty(symbolStr) ? Consts.DEFAULT_SYMBOL_STRING : symbolStr , symbolPrecision <= 0 ? Consts.DEFAULT_SYMBOL_PRECISION : symbolPrecision ); TypeSymbol.setCoreSymbol( mPrefHelper.getCoreSymbolPrecision(), mPrefHelper.getCoreSymbolString()); } public EosWalletManager getWalletManager() { return mWalletMgr; } public PreferencesHelper getPreferenceHelper() { return mPrefHelper; } public void addAccountHistory(String... accountNames){ mAccountRepository.addAll(accountNames); } public void addAccountHistory(List accountNames){ mAccountRepository.addAll(accountNames); } public void deleteAccountHistory( String accountName ) { mAccountRepository.delete( accountName ); } public List searchAccount( String nameStarts){ return mAccountRepository.searchName( nameStarts ); } public void pushAbiObject(String key, EosAbiMain abi){ mAbiObjHouse.put(key , abi ); } public EosAbiMain popAbiObject( String key) { return mAbiObjHouse.remove( key ); } public void clearAbiObjects(){ mAbiObjHouse.clear(); } public Observable getChainInfo(){ return mNodeosApi.readInfo("get_info"); } public Observable getTable( String accountName, String code, String table ,int indexPos, String keyType, String encodeType,String lowerBound, String upperBound, int limit ){ return mNodeosApi.getTable( new GetTableRequest(accountName, code, table, indexPos , keyType, encodeType, lowerBound, upperBound, limit)) .map( tableResult -> Utils.prettyPrintJson(tableResult)); } public Observable createKey( int count ) { return Observable.fromCallable( () -> { EosPrivateKey[] retKeys = new EosPrivateKey[ count ]; for ( int i = 0; i < count; i++) { retKeys[i] = new EosPrivateKey(); } return retKeys; } ); } private SignedTransaction createTransaction(String contract, String actionName, String dataAsHex, String[] permissions, EosChainInfo chainInfo){ currentBlockInfo = chainInfo; Action action = new Action(contract, actionName); action.setAuthorization(permissions); action.setData( dataAsHex ); SignedTransaction txn = new SignedTransaction(); txn.addAction( action ); txn.putSignatures( new ArrayList<>()); if ( null != chainInfo ) { txn.setReferenceBlock(chainInfo.getHeadBlockId()); txn.setExpiration(chainInfo.getTimeAfterHeadBlockTime(TX_EXPIRATION_IN_MILSEC)); } return txn; } private SignedTransaction createTransactionWithPrivateKey(String contract, String actionName, String dataAsHex, String[] permissions, EosChainInfo chainInfo, String privateKey){ currentBlockInfo = chainInfo; Action action = new Action(contract, actionName); action.setAuthorization(permissions); action.setData( dataAsHex ); SignedTransaction txn = new SignedTransaction(); txn.setPrivKey(privateKey); txn.addAction( action ); txn.putSignatures( new ArrayList<>()); if ( null != chainInfo ) { txn.setReferenceBlock(chainInfo.getHeadBlockId()); txn.setExpiration(chainInfo.getTimeAfterHeadBlockTime(TX_EXPIRATION_IN_MILSEC)); } return txn; } private SignedTransaction createTransaction(List actions, EosChainInfo chainInfo ){ currentBlockInfo = chainInfo; SignedTransaction txn = new SignedTransaction(); txn.setActions( actions ); txn.putSignatures( new ArrayList<>()); if ( null != chainInfo ) { txn.setReferenceBlock(chainInfo.getHeadBlockId()); txn.setExpiration(chainInfo.getTimeAfterHeadBlockTime(TX_EXPIRATION_IN_MILSEC)); } return txn; } private PackedTransaction signAndPackTransactionNoWallet(SignedTransaction txnBeforeSign) { txnBeforeSign.sign(new TypeChainId(currentBlockInfo.getChain_id())); return new PackedTransaction(txnBeforeSign); } private Observable signAndPackTransaction(SignedTransaction txnBeforeSign) { return mNodeosApi.getRequiredKeys( new GetRequiredKeys( txnBeforeSign, mWalletMgr.listPubKeys() )) .map( keys -> { final SignedTransaction stxn ; if ( mPrefHelper.shouldSkipSigning() ) { stxn = txnBeforeSign; } else { stxn = mWalletMgr.signTransaction(txnBeforeSign, keys.getKeys(), new TypeChainId(currentBlockInfo.getChain_id())); } return new PackedTransaction(stxn); }); } private String[] getActivePermission(String accountName ) { return new String[] { accountName + "@active" }; } public Observable readAccountInfo(String accountName ) { return mNodeosApi.getAccountInfo(new AccountInfoRequest(accountName)); } public Observable getActions(String accountName, int pos, int offset ) { JsonObject gsonObject = new JsonObject(); gsonObject.addProperty( "account_name", accountName); gsonObject.addProperty( "pos", pos); gsonObject.addProperty( "offset", offset); return mNodeosApi.getActions( gsonObject); } public Observable getServants( String accountName ) { JsonObject gsonObject = new JsonObject(); gsonObject.addProperty( NodeosApi.GET_SERVANTS_KEY, accountName); return mNodeosApi.getServants( gsonObject); } EosChainInfo currentBlockInfo; void setInfo(EosChainInfo info){ currentBlockInfo = info; } public Observable createAccount(EosNewAccount newAccountData) { return getChainInfo() .map( info -> createTransaction(EOSIO_SYSTEM_ACCOUNT, newAccountData.getActionName(), newAccountData.getAsHex() , getActivePermission( newAccountData.getCreatorName() ), info )) .flatMap( txn -> signAndPackTransaction( txn)) .flatMap( packedTxn -> mNodeosApi.pushTransaction( packedTxn )); } public Observable createAccountAction(String creator, String newAccount, EosPublicKey ownerKey, EosPublicKey activeKey) { EosNewAccount newAccountData = new EosNewAccount(creator, newAccount , TypePublicKey.from( ownerKey) , TypePublicKey.from( activeKey) ); Action action = new Action(EOSIO_SYSTEM_ACCOUNT, newAccountData.getActionName()); action.setAuthorization( getActivePermission( newAccountData.getCreatorName() ) ); action.setData( newAccountData.getAsHex() ); return Observable.just( action ); } private Observable getActionAfterBindArgs( String contract, String permissionAccount, String actionName, String args) { return mNodeosApi.jsonToBin( new JsonToBinRequest( contract, actionName, args) ) .map( binResp -> { Action action = new Action(contract, actionName ); action.setAuthorization( getActivePermission(permissionAccount)); action.setData( binResp.getBinargs()); return action; }); } public Observable buyRamInAssetAction(String payer, String receiver, String assetQuantity) { JsonObject object = new JsonObject(); object.addProperty("payer", new TypeAccountName(payer).toString()); object.addProperty("receiver", new TypeAccountName(receiver).toString()); object.addProperty("quant", new TypeAsset( assetQuantity ).toString()); return getActionAfterBindArgs( EOSIO_SYSTEM_ACCOUNT, payer, "buyram", new Gson().toJson(object)); } public Observable delegateAction( String from, String receiver, String networkAsset, String cpuAsset, boolean transfer) { JsonObject object = new JsonObject(); object.addProperty("from", new TypeAccountName(from).toString()); object.addProperty("receiver", new TypeAccountName(receiver).toString()); object.addProperty("stake_net_quantity", new TypeAsset(networkAsset).toString() ); object.addProperty("stake_cpu_quantity", new TypeAsset(cpuAsset).toString() ); object.addProperty( "transfer", transfer); return getActionAfterBindArgs( EOSIO_SYSTEM_ACCOUNT, from, "delegatebw", new Gson().toJson(object) ); } public Observable transfer( String from, String to, long amount, String memo ) { EosTransfer transfer = new EosTransfer(from, to, amount, memo); return pushActionRetJson(EOSIO_TOKEN_CONTRACT, transfer.getActionName(),Utils.prettyPrintJson(transfer) , getActivePermission( from ) ); //transfer.getAsHex() } public Observable pushActionRetJson(String contract, String action, String data, String[] permissions) { return mNodeosApi.jsonToBin( new JsonToBinRequest( contract, action, data )) .flatMap( jsonToBinResp -> getChainInfo() .map( info -> createTransaction( contract, action, jsonToBinResp.getBinargs(), permissions, info )) ) .flatMap( this::signAndPackTransaction ) .flatMap( mNodeosApi::pushTransactionRetJson ); } public Observable pushAction(String contract, String action, String data, String[] permissions) { return mNodeosApi.jsonToBin( new JsonToBinRequest( contract, action, data )) .flatMap( jsonToBinResp -> getChainInfo() .map( info -> createTransaction( contract, action, jsonToBinResp.getBinargs(), permissions, info )) ) .flatMap( this::signAndPackTransaction ) .flatMap( mNodeosApi::pushTransaction ); } public Observable pushActionNoWallet(String contract, String action, String data, String[] permissions, String privKey) { return mNodeosApi.jsonToBin( new JsonToBinRequest( contract, action, data )) .flatMap( jsonToBinResp -> getChainInfo() .map( info -> createTransactionWithPrivateKey( contract, action, jsonToBinResp.getBinargs(), permissions, info, privKey)) ) .map( trx -> signAndPackTransactionNoWallet(trx) ) .flatMap( mNodeosApi::pushTransaction ); } public Observable pushActions(List actions ){ return getChainInfo() .map( info -> createTransaction( actions, info )) .flatMap( this::signAndPackTransaction ) .flatMap( mNodeosApi::pushTransaction ); } public Observable getCodeAbi( String contract ) { return mNodeosApi.getCode( new GetCodeRequest(contract)) .filter( codeResp -> codeResp.isValidCode()) .map( result -> new GsonBuilder().excludeFieldsWithoutExposeAnnotation() .create().fromJson(result.getAbi(), EosAbiMain.class) ); } public Observable getAbi( String contract ) { return mNodeosApi.getAbi( new GetCodeRequest(contract)) .map( result -> new GsonBuilder().excludeFieldsWithoutExposeAnnotation() .create().fromJson(result.getAbi(), EosAbiMain.class) ); } public Observable getAbiMainFromJson( String jsonStr ) { return Observable.just( new GsonBuilder().excludeFieldsWithoutExposeAnnotation() .create().fromJson(jsonStr, EosAbiMain.class)); } public Observable getCurrencyBalance(String contract, String account, String symbol){ return mNodeosApi.getCurrencyBalance( new GetBalanceRequest(contract,account,symbol)) .map( result -> Utils.prettyPrintJson(result)); } public Observable getCurrencyStats(String contract, String symbol){ return mNodeosApi.getCurrencyStats( new GetRequestForCurrency(contract, symbol)) .map( result -> Utils.prettyPrintJson(result)); } }