Skip to content

Commit 393ff4f

Browse files
committed
NIFI-15928 Added support for the localizationEngineID in UsmUserDeserializer
1 parent af8ec30 commit 393ff4f

4 files changed

Lines changed: 18 additions & 7 deletions

File tree

nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/main/java/org/apache/nifi/snmp/utils/UsmUserDeserializer.java

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,12 +73,19 @@ public UsmUser deserialize(JsonParser jp, DeserializationContext ctxt) throws IO
7373
"authentication protocol is specified.");
7474
}
7575

76+
OctetString localizationEngineID = null;
77+
final JsonNode localizationEngineIDNode = node.get("localizationEngineID");
78+
if (localizationEngineIDNode != null) {
79+
localizationEngineID = new OctetString(localizationEngineIDNode.asText());
80+
}
81+
7682
return new UsmUser(
7783
new OctetString(securityName),
7884
authProtocol,
7985
authPassphrase,
8086
privProtocol,
81-
privPassphrase
87+
privPassphrase,
88+
localizationEngineID
8289
);
8390
}
8491
}

nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/test/java/org/apache/nifi/snmp/utils/JsonUsmReaderTest.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -56,8 +56,7 @@ void testReadInvalidJsonThrowsException() {
5656
}
5757

5858
static String readFile(String path) throws IOException {
59-
byte[] encoded = Files.readAllBytes(Paths.get(path));
60-
return new String(encoded, StandardCharsets.UTF_8);
59+
return Files.readString(Paths.get(path), StandardCharsets.UTF_8);
6160
}
6261

6362
}

nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/test/java/org/apache/nifi/snmp/utils/JsonUsmReaderTestBase.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -39,14 +39,17 @@ public class JsonUsmReaderTestBase {
3939
new OID("1.3.6.1.6.3.10.1.1.7"),
4040
new OctetString("abc12345"),
4141
new OID("1.3.6.1.4.1.4976.2.2.1.1.1"),
42-
new OctetString("abc12345")
42+
new OctetString("abc12345"),
43+
new OctetString("8000000001020304")
44+
4345
));
4446
expectedUsmUsers.add(new UsmUser(
4547
new OctetString("user2"),
4648
new OID("1.3.6.1.6.3.10.1.1.5"),
4749
new OctetString("abc12345"),
4850
new OID("1.3.6.1.4.1.4976.2.2.1.1.2"),
49-
new OctetString("abc12345")
51+
new OctetString("abc12345"),
52+
new OctetString("8000000001020308")
5053
));
5154
}
5255

nifi-extension-bundles/nifi-snmp-bundle/nifi-snmp-processors/src/test/resources/usm_users.json

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,13 +4,15 @@
44
"authProtocol":"HMAC384SHA512",
55
"authPassphrase":"abc12345",
66
"privProtocol":"AES192",
7-
"privPassphrase":"abc12345"
7+
"privPassphrase":"abc12345",
8+
"localizationEngineID":"8000000001020304"
89
},
910
{
1011
"securityName":"user2",
1112
"authProtocol":"HMAC192SHA256",
1213
"authPassphrase":"abc12345",
1314
"privProtocol":"AES256",
14-
"privPassphrase":"abc12345"
15+
"privPassphrase":"abc12345",
16+
"localizationEngineID":"8000000001020308"
1517
}
1618
]

0 commit comments

Comments
 (0)