Package: TranslatorAppKeystoreQueryKapuaKura

TranslatorAppKeystoreQueryKapuaKura

name	instruction	branch	complexity	line	method
TranslatorAppKeystoreQueryKapuaKura()	M: 3 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 1 C: 0 0%	M: 1 C: 0 0%
getClassFrom()	M: 2 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 1 C: 0 0%	M: 1 C: 0 0%
static {...}	M: 5 C: 0 0%	M: 0 C: 0 100%	M: 1 C: 0 0%	M: 1 C: 0 0%	M: 1 C: 0 0%
translatePayload(KeystoreRequestPayload)	M: 42 C: 0 0%	M: 4 C: 0 0%	M: 3 C: 0 0%	M: 11 C: 0 0%	M: 1 C: 0 0%

Coverage

1: /*******************************************************************************
2: * Copyright (c) 2021, 2022 Eurotech and/or its affiliates and others
3: *
4: * This program and the accompanying materials are made
5: * available under the terms of the Eclipse Public License 2.0
6: * which is available at https://www.eclipse.org/legal/epl-2.0/
7: *
8: * SPDX-License-Identifier: EPL-2.0
9: *
10: * Contributors:
11: * Eurotech - initial API and implementation
12: *******************************************************************************/
13: package org.eclipse.kapua.translator.kapua.kura.keystore;
14:
15: import org.eclipse.kapua.service.device.call.kura.model.keystore.KuraKeystoreItemQuery;
16: import org.eclipse.kapua.service.device.call.message.kura.app.request.KuraRequestMessage;
17: import org.eclipse.kapua.service.device.call.message.kura.app.request.KuraRequestPayload;
18: import org.eclipse.kapua.service.device.management.commons.setting.DeviceManagementSetting;
19: import org.eclipse.kapua.service.device.management.commons.setting.DeviceManagementSettingKey;
20: import org.eclipse.kapua.service.device.management.keystore.internal.message.request.KeystoreQueryRequestMessage;
21: import org.eclipse.kapua.service.device.management.keystore.internal.message.request.KeystoreRequestPayload;
22: import org.eclipse.kapua.service.device.management.keystore.model.DeviceKeystoreItemQuery;
23: import org.eclipse.kapua.translator.Translator;
24: import org.eclipse.kapua.translator.exception.InvalidPayloadException;
25:
26: /**
27: * {@link Translator} implementation from {@link KeystoreQueryRequestMessage} to {@link KuraRequestMessage}
28: *
29: * @since 1.5.0
30: */
31: public class TranslatorAppKeystoreQueryKapuaKura extends AbstractTranslatorAppKeystoreKapuaKura<KeystoreQueryRequestMessage> {
32:
33: private static final String CHAR_ENCODING = DeviceManagementSetting.getInstance().getString(DeviceManagementSettingKey.CHAR_ENCODING);
34:
35: @Override
36: protected KuraRequestPayload translatePayload(KeystoreRequestPayload kapuaPayload) throws InvalidPayloadException {
37: try {
38: KuraRequestPayload kuraRequestPayload = new KuraRequestPayload();
39:
40:• if (kapuaPayload.hasBody()) {
41: DeviceKeystoreItemQuery deviceKeystoreItemQuery = kapuaPayload.getItemQuery();
42:
43:• if (deviceKeystoreItemQuery.hasFilters()) {
44:
45: KuraKeystoreItemQuery kuraItemQuery = new KuraKeystoreItemQuery();
46: kuraItemQuery.setKeystoreServicePid(deviceKeystoreItemQuery.getKeystoreId());
47: kuraItemQuery.setAlias(deviceKeystoreItemQuery.getAlias());
48:
49: kuraRequestPayload.setBody(getJsonMapper().writeValueAsString(kuraItemQuery).getBytes(CHAR_ENCODING));
50: }
51: }
52:
53: return kuraRequestPayload;
54: } catch (Exception e) {
55: throw new InvalidPayloadException(e, kapuaPayload);
56: }
57: }
58:
59: @Override
60: public Class<KeystoreQueryRequestMessage> getClassFrom() {
61: return KeystoreQueryRequestMessage.class;
62: }
63: }