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
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
|
/*
* Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.onap.vfc.nfvo.emsdriver.collector;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import org.onap.vfc.nfvo.emsdriver.commons.constant.Constant;
import org.onap.vfc.nfvo.emsdriver.commons.model.CollectVo;
import org.onap.vfc.nfvo.emsdriver.commons.utils.Gzip;
import org.onap.vfc.nfvo.emsdriver.messagemgr.MessageChannelFactory;
import java.io.File;
import java.io.IOException;
import java.util.List;
import static org.junit.Assert.assertTrue;
public class TaskThreadTest {
private String csvPath = System.getProperty("user.dir") + "/data/" + "PM-ENB-EUTRANCELLNB-test.csv";
private String xmlPath = System.getProperty("user.dir") + "/data/" + "PM-test.xml";
private String gzPath = System.getProperty("user.dir") + "/data/" + "PM-ENB-EUTRANCELLNB-testa.csv.gz";
private TaskThread taskThread;
private List<File> list = null;
@Before
public void setUp() throws IOException {
taskThread = new TaskThread();
taskThread.pmResultChannel = MessageChannelFactory.getMessageChannel(Constant.COLLECT_RESULT_PM_CHANNEL_KEY);
Gzip gzip = new Gzip();
gzip.compress(csvPath, gzPath);
}
@Test
public void decompressed() {
list = taskThread.decompressed(gzPath);
assertTrue(list.size() > 0);
new File(gzPath).delete();
}
@Test
public void processPMCsv() {
list = taskThread.decompressed(gzPath);
for (File file : list) {
boolean re = taskThread.processPMCsv(file);
assertTrue(re);
}
}
@Test
public void processPMXml() {
File file = new File(xmlPath);
boolean re = taskThread.processPMXml(file);
assertTrue(re);
System.out.println(taskThread.pmResultChannel.size());
}
@Test
public void parseFtpAndSendMessage() {
CollectVo collectVo = new CollectVo();
collectVo.setType("ems-p");
taskThread.parseFtpAndSendMessage(gzPath, collectVo);
}
@Test
public void createMessage() {
CollectVo collectVo = new CollectVo();
collectVo.setType("ems-p");
taskThread.createMessage("zipName", "user", "pwd", "ip", "port", 122, "nename");
}
@After
public void setDown() throws IOException {
new File(gzPath).delete();
new File(gzPath.replace(".gz", "")).delete();
}
}
|
