package com.cloud.device;

import ch.qos.logback.core.net.SyslogOutputStream;
import com.alibaba.fastjson.JSONObject;
import com.cloud.common.utils.RestTemplateUtil;
import com.cloud.device.model.Cluster;
import com.cloud.device.model.Database;
import com.cloud.device.model.Node;
import com.cloud.device.service.ClusterService;
import com.cloud.device.vo.ClusterNodeVo;
import com.cloud.device.vo.NodeVo;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.http.MediaType;
import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

//@SpringBootTest
//@RunWith(SpringRunner.class)
//public class Test11 {

//    @Autowired
//    ClusterService clusterService;
//    @Test
//    public void test() {
        /*String url ="http://192.168.1.171:11111/searchNode";

        JSONObject a = new JSONObject();

        String all=  RestTemplateUtil.post(url, a, MediaType.APPLICATION_JSON_UTF8, String.class, false);

        List<Node> list = JSONObject.parseArray(all, Node.class);
        //TokenInfo t = RestTemplateUtil.post(httpUrl,jsonObject ,MediaType.APPLICATION_FORM_URLENCODED ,TokenInfo.class , false);

        String port =url.substring(url.indexOf(":")+1, url.lastIndexOf("/"));

        list.stream().forEach(e ->
            e.setLocalDates(findByNode(getUrl(e.getNodeId(),getPort(url))))
        );


        List<Database> syncDatabase = getSyncDatabase(url);

        System.out.println("syncDatabase :" + syncDatabase.toString());

        System.out.println(list.toString());*/
//    }

    /*public List<Database> findByNode(String url){
        JSONObject a = new JSONObject();
        String all=  RestTemplateUtil.post(url, a, MediaType.APPLICATION_JSON_UTF8, String.class, false);
        List<Database> list = JSONObject.parseArray(all, Database.class);

        System.out.println("NODE-----------" + url);
        System.out.println(list);
        return list;
    }

    public String getUrl(String nodeId,String port){
        return "http://"+nodeId.substring(nodeId.indexOf("@")+1,nodeId.length())+":"+port+"/findLocalDatabase";
    }

    public String  getPort(String url){
        return url.substring(url.lastIndexOf(":")+1, url.lastIndexOf("/"));
    }


    public List<Database> getSyncDatabase(String url){
        String all=  RestTemplateUtil.post(url, new JSONObject(), MediaType.APPLICATION_JSON_UTF8, String.class, false);
        List<Database> list = JSONObject.parseArray(all, Database.class);
        return list;
    }


    @Test
    public void test2222(){
        Map<String,Object> a = new HashMap<>();
        List<Cluster> list = clusterService.findAllNode(a);

        list.stream().forEach(e-> System.out.println(e.toString()));
    }


    @Test
    public void testFindNodesByIds(){
        String ids = "ea5f694d-4c9d-58ca-98a4-0ed033a1398d";


       List<ClusterNodeVo> list =  clusterService.findNodesByIds(ids);

       list.stream().forEach(e-> System.out.println(e.toString()));

    }*/

//}