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
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
|
/**
*
*/
package org.onap.ccsdk.sli.northbound.dmaapclient;
import static org.junit.Assert.*;
import java.io.InputStream;
import java.net.URL;
import java.sql.SQLException;
import java.util.Properties;
import javax.sql.rowset.CachedRowSet;
import org.junit.After;
import org.junit.BeforeClass;
import org.junit.Test;
import org.onap.ccsdk.sli.core.dblib.DBResourceManager;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import ch.vorburger.mariadb4j.DB;
import ch.vorburger.mariadb4j.DBConfigurationBuilder;
/**
* @author dt5972
*
*/
public class TestSdncDhcpEventConsumer {
private static final Logger LOG = LoggerFactory.getLogger(TestSdncDhcpEventConsumer.class);
private static final String DHCP_MAP_TABLE = "CREATE TABLE `DHCP_MAP` (\n" +
" mac_addr varchar(80) NOT NULL,\n" +
" ip_addr varchar(80),\n" +
" PRIMARY KEY(`mac_addr`)\n" +
")";
private static final String VALID_DHCP_EVENT = "{\"msg_name\":\"DHCPACK\"," +
"\"macaddr\":\"fa:16:3e:8f:ea:68\"," +
"\"yiaddr\":\"10.3.0.2\"}";
private static final String SECOND_DHCP_EVENT = "{\"msg_name\":\"DHCPACK\"," +
"\"macaddr\":\"fa:16:3e:8f:ea:68\"," +
"\"yiaddr\":\"10.3.0.3\"}";
private static final String MISSING_MSG_NAME_DHCP_EVENT = "{\"macaddr\":\"fa:16:3e:8f:ea:68\"," +
"\"yiaddr\":\"10.3.0.2\"}";
private static final String MISSING_MAC_ADDR_DHCP_EVENT = "{\"msg_name\":\"DHCPACK\"," +
"\"yiaddr\":\"10.3.0.2\"}";
private static final String MISSING_IP_ADDR_DHCP_EVENT = "{\"msg_name\":\"DHCPACK\"," +
"\"macaddr\":\"fa:16:3e:8f:ea:68\"}";
private static final String GET_DHCP_MAPPING = "SELECT * FROM DHCP_MAP WHERE mac_addr = 'fa:16:3e:8f:ea:68'";
private static DBResourceManager dblibSvc;
private static DB db;
private static SdncDhcpEventConsumer consumer;
/**
* @throws java.lang.Exception
*/
@BeforeClass
public static void setUpBeforeClass() throws Exception {
LOG.debug("Setting up DHCP event testing");
InputStream propStr = TestSdncDhcpEventConsumer.class.getResourceAsStream("/dblib.properties");
Properties props = new Properties();
props.load(propStr);
// Start MariaDB4j database
LOG.debug("Starting MariaDB instance");
DBConfigurationBuilder config = DBConfigurationBuilder.newBuilder();
config.setPort(0); // 0 => autom. detect free port
db = DB.newEmbeddedDB(config.build());
db.start();
// Override jdbc URL and database name
props.setProperty("org.onap.ccsdk.sli.jdbc.database", "test");
props.setProperty("org.onap.ccsdk.sli.jdbc.url", config.getURL("test"));
// Create dblib connection
LOG.debug("Getting DBResourceManager instance");
dblibSvc = new DBResourceManager(props);
// Create DHCP_MAP table
dblibSvc.writeData(DHCP_MAP_TABLE, null, null);
consumer = new SdncDhcpEventConsumer();
consumer.setJdbcDataSource(dblibSvc);
LOG.debug("Setup complete");
}
@Test
public void testValid() throws InvalidMessageException, SQLException {
consumer.processMsg(VALID_DHCP_EVENT);
consumer.processMsg(SECOND_DHCP_EVENT);
CachedRowSet results = dblibSvc.getData(GET_DHCP_MAPPING, null, null);
if (!results.next()) {
fail("Test query ["+GET_DHCP_MAPPING+"] returned no data");
} else {
String ipAddr = results.getString("ip_addr");
if (!"10.3.0.3".equals(ipAddr)) {
fail("Expecting ipAddr to be 10.3.0.3, but was "+ipAddr);
}
}
}
@Test (expected = InvalidMessageException.class)
public void testMissingMsgName() throws InvalidMessageException {
consumer.processMsg(MISSING_MSG_NAME_DHCP_EVENT);
}
@Test (expected = InvalidMessageException.class)
public void testMissingMacAddress() throws InvalidMessageException {
consumer.processMsg(MISSING_MAC_ADDR_DHCP_EVENT);
}
@Test (expected = InvalidMessageException.class)
public void testMissingIpAddress() throws InvalidMessageException {
consumer.processMsg(MISSING_IP_ADDR_DHCP_EVENT);
}
}
|
