SEEC-II-Demo/src/test/java/nju/seec/SEECdemo/service/api/SecretApiImplTest.java

package nju.seec.SEECdemo.service.api;


import io.kubernetes.client.apis.AppsV1Api;
import io.kubernetes.client.apis.CoreV1Api;
import nju.seec.SEECdemo.logic.api.k8s.SecretApi;
import nju.seec.SEECdemo.logic.api.k8s.util.SecretTypeEnum;
import nju.seec.SEECdemo.logic.api.k8s.vo.SecretVO;
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.test.context.junit4.SpringRunner;

import java.util.List;

@RunWith(SpringRunner.class)
@SpringBootTest
public class SecretApiImplTest {

    @Autowired
    private AppsV1Api appsV1Api;

    @Autowired
    private CoreV1Api coreV1Api;

    @Autowired
    private SecretApi secretApi;

    @Test
    public void testCreateSecret() {

        //Secret默认创建的Type为Opaque，base64编码格式的Secret,用来储存密码、密钥等。

//        V1Secret v1Secret = new V1Secret();
//        v1Secret.setApiVersion("v1");
//        Map<String, byte[]> secretMap = new HashMap<>();
//        String dockerConfigJson =
//                "{\"auths\":{\"10.1.1.243:18082\":{\"username\":\"admin\",\"password\":\"admin123\",\"auth\":\"admin:admin123\"}}}";
//        secretMap.put(".dockerconfigjson", dockerConfigJson.getBytes());
//        V1ObjectMeta meta = new V1ObjectMeta();
//        meta.setName("my-secret4");
//        meta.setNamespace("mjj-test");
//        v1Secret.setData(secretMap);
//        v1Secret.setKind("Secret");
//        v1Secret.setMetadata(meta);
//        v1Secret.setType("123");
//
//        v1Secret.setType("kubernetes.io/dockerconfigjson");
//
//        try {
//            V1Secret returnSecret = coreV1Api.createNamespacedSecret("mjj-test", v1Secret, "OK");
//            Map<String, byte[]> dataMap = returnSecret.getData();
//            for (Map.Entry<String, byte[]> entry : dataMap.entrySet()) {
//                System.out.println(entry.getKey());
//                System.out.println(new String(entry.getValue()));
//            }
//            System.out.println(returnSecret.getType());
//        } catch (ApiException e) {
//            //如果已经存在相同命名的Secret会抛出异常
//            System.out.println(e.getResponseBody());
//        }

//        String namespace = "mjj-test";
//        try {
//            V1SecretList v1SecretList = coreV1Api.listNamespacedSecret(namespace, "OK", "", "",false, "", 200, "", 10, false);
//            List<V1Secret> secretList = v1SecretList.getItems();
//            for (V1Secret secret : secretList) {
//
//                Map<String, byte[]> data = secret.getData();
//                for (Map.Entry<String, byte[]> entry : data.entrySet()) {
//                    System.out.println(entry.getKey());
//                    System.out.println(new String(entry.getValue()));
//                }
//            }
//        } catch (ApiException e) {
//            System.out.println(e.getResponseBody());
//        }


        //test createGenericSecret()
/*        String namespace = "mjj-test";
        String name = "secret";
        Map<String, byte[]> data = new HashMap<>();
        data.put("mysql", "123456".getBytes());
        secretApi.createGenericSecret(namespace, name, data);*/

        //test createPrivateRegistrySecret()
        /*String namespace = "mjj-test";
        String sever = "10.1.1.243:18082";
        String user = "admin";
        String password = "admin123";
        secretApi.createPrivateRegistrySecret(namespace, sever, user, password);*/

        //test getSecret()
        /*String namespace = "mjj-test";
        String name = "my-secret2";
        ApiResult apiResult = secretApi.getSecret(namespace, name);
        if (apiResult.getErrorCode() == 0) {
            V1Secret secret = (V1Secret) apiResult.getValue();
            Map<String, byte[]> map = secret.getData();
            for (Map.Entry<String, byte[]> entry : map.entrySet()) {
                System.out.println(entry.getKey());
                System.out.println(new String(entry.getValue()));
            }
        } else {
            System.out.println("获取失败");
        }*/


        //test delete a Secret
        /*String name = "my-secret2";
        String namespace = "mjj-test";*/
        /*V1DeleteOptions body = new V1DeleteOptions();
        try {
            coreV1Api.deleteNamespacedSecret(name, namespace, body, "", 5, false, "");
        } catch (ApiException e) {
            System.out.println(e.getResponseBody());
        }*/

    }

    @Test
    public void testGetSecret() {
        SecretVO v1Secret = secretApi.getSecretByName("group24", "regcred");
        System.out.println(v1Secret);
    }

    @Test
    public void testGetSecretByType() {
        List<SecretVO> v1Secret = secretApi.getSecretListByType("demo", SecretTypeEnum.Generic);
        v1Secret.stream().forEach((v1Secret1 -> {
            v1Secret1.getData().values().forEach((stringEntry -> {
                System.out.println(stringEntry);
            }));
        }));
        System.out.println(v1Secret);
    }

    @Test
    public void testCreate() {
        secretApi.createPrivateRegistrySecret("demo2", "10.1.1.243:18082", "admin", "admin123");
    }
}