openflow/test/KubeUtil.test.ts at master · ITCSsDeveloper/openflow · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
const path = require("path");
const env = path.join(process.cwd(), 'config', '.env');
require("dotenv").config({ path: env }); // , debug: false
import { suite, test, timeout } from '@testdeck/mocha';
import { Config } from "../OpenFlow/src/Config";
import { DatabaseConnection } from '../OpenFlow/src/DatabaseConnection';
import assert = require('assert');
import { Logger } from '../OpenFlow/src/Logger';
import { KubeUtil } from '../OpenFlow/src/ee/KubeUtil';

@suite class kubeutil_test {
    @timeout(10000)
    async before() {
        Config.workitem_queue_monitoring_enabled = false;
        Config.disablelogging();
        Logger.configure(true, true);
        Config.db = new DatabaseConnection(Config.mongodb_url, Config.mongodb_db, false);
        await Config.db.connect(null);
    }
    async after() {
        await Logger.shutdown();
    }
    @test async 'GetStatefulSet'() {
        var sfs = await KubeUtil.instance().GetStatefulSet(Config.namespace, "findme");
        assert.strictEqual(sfs, null)
    }
    @test async 'GetDeployment'() {
        var dep = await KubeUtil.instance().GetDeployment(Config.namespace, "api");
        assert.notStrictEqual(dep, null);
        assert.strictEqual(dep.metadata.name, "api");
    }
    @test async 'GetIngressV1beta1'() {
        var dep = await KubeUtil.instance().GetIngressV1beta1(Config.namespace, "useringress");
        assert.notStrictEqual(dep, null);
        assert.strictEqual(dep.metadata.name, "useringress");
    }
    @timeout(60000)
    @test async 'listNamespacedPod'() {
        const list = await KubeUtil.instance().CoreV1Api.listNamespacedPod(Config.namespace);
        assert.notStrictEqual(list, null);
        assert.notStrictEqual(list.body, null);
        assert.notStrictEqual(list.body.items, null);
        assert.ok(list.body.items.length > 0)
        var pod = list.body.items[0];
        var name = pod.metadata.name;
        pod = await KubeUtil.instance().GetPod(Config.namespace, pod.metadata.name);
        assert.notStrictEqual(pod, null);
        assert.strictEqual(pod.metadata.name, name);

        var metrics = await KubeUtil.instance().GetPodMetrics(Config.namespace, name);
        assert.notStrictEqual(metrics, null);
        assert.notStrictEqual(metrics.cpu, null);
        assert.notStrictEqual(metrics.memory, null);
    }
    @test async 'GetService'() {
        var service = await KubeUtil.instance().GetService(Config.namespace, "api");
        assert.notStrictEqual(service, null);
        assert.strictEqual(service.metadata.name, "api");

    }
    @test async 'GetReplicaset'() {
        var rep = await KubeUtil.instance().GetReplicaset(Config.namespace, "name", "test");
        assert.strictEqual(rep, null);
    }
    @test async 'getpods'() {
        var list = await KubeUtil.instance().GetPods(Config.namespace);
        assert.notStrictEqual(list, null);
        assert.notStrictEqual(list.body, null);
        assert.notStrictEqual(list.body.items, null);
        assert.ok(list.body.items.length > 0)
    }
}
// cls | ./node_modules/.bin/_mocha 'test/**/KubeUtil.test.ts'