@Inject is not supported in translator classes

Cosium · Jan 9, 2025 · 00c8f5d · 00c8f5d
1 parent 33d4b28
commit 00c8f5d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 16 deletions.
diff --git a/.../org/eclipse/kapua/translator/kapua/kura/TranslatorAppConfigurationCreationKapuaKura.java b/.../org/eclipse/kapua/translator/kapua/kura/TranslatorAppConfigurationCreationKapuaKura.java
@@ -14,10 +14,8 @@
 package org.eclipse.kapua.translator.kapua.kura;
 
 import com.fasterxml.jackson.annotation.JsonProperty;
-import com.fasterxml.jackson.databind.ObjectMapper;
 import java.util.ArrayList;
 import java.util.List;
-import javax.inject.Inject;
 import org.eclipse.kapua.service.device.call.kura.model.configuration.ConfigurationMetrics;
 import org.eclipse.kapua.service.device.call.message.kura.app.request.KuraRequestChannel;
 import org.eclipse.kapua.service.device.call.message.kura.app.request.KuraRequestMessage;
@@ -30,9 +28,6 @@
 
 public class TranslatorAppConfigurationCreationKapuaKura extends AbstractTranslatorKapuaKura<ConfigurationRequestChannel, ConfigurationCreationRequestPayload, ConfigurationCreationRequestMessage> {
 
-    @Inject
-    private ObjectMapper jsonMapper;
-
     @Override
     protected KuraRequestChannel translateChannel(ConfigurationRequestChannel kapuaChannel) throws InvalidChannelException {
         try {
@@ -51,7 +46,7 @@ protected KuraRequestPayload translatePayload(ConfigurationCreationRequestPayloa
             RequestBody requestBody = new RequestBody();
             requestBody.configs.add(new Configs(kapuaPayload.getComponentFactoryId(), kapuaPayload.getComponentId()));
 
-            kuraRequestPayload.setBody(jsonMapper.writeValueAsBytes(requestBody));
+            kuraRequestPayload.setBody(getJsonMapper().writeValueAsBytes(requestBody));
 
             // Return Kura Payload
             return kuraRequestPayload;

diff --git a/...org/eclipse/kapua/translator/kura/kapua/TranslatorAppConfigurationFactoriesKuraKapua.java b/...org/eclipse/kapua/translator/kura/kapua/TranslatorAppConfigurationFactoriesKuraKapua.java
@@ -15,14 +15,12 @@
 
 import com.fasterxml.jackson.annotation.JsonCreator;
 import com.fasterxml.jackson.annotation.JsonProperty;
-import com.fasterxml.jackson.databind.ObjectMapper;
 import java.util.Set;
-import javax.inject.Inject;
 import org.eclipse.kapua.service.device.call.kura.model.configuration.ConfigurationMetrics;
 import org.eclipse.kapua.service.device.call.message.kura.app.response.KuraResponseChannel;
 import org.eclipse.kapua.service.device.call.message.kura.app.response.KuraResponsePayload;
 import org.eclipse.kapua.service.device.management.configuration.DeviceComponentConfigurationFactories;
-import org.eclipse.kapua.service.device.management.configuration.DeviceConfigurationFactory;
+import org.eclipse.kapua.service.device.management.configuration.internal.DeviceComponentConfigurationFactoriesImpl;
 import org.eclipse.kapua.service.device.management.configuration.message.internal.ConfigurationFactoriesResponseMessage;
 import org.eclipse.kapua.service.device.management.configuration.message.internal.ConfigurationFactoriesResponsePayload;
 import org.eclipse.kapua.service.device.management.configuration.message.internal.ConfigurationResponseChannel;
@@ -31,11 +29,6 @@
 
 public class TranslatorAppConfigurationFactoriesKuraKapua extends AbstractSimpleTranslatorResponseKuraKapua<ConfigurationResponseChannel, ConfigurationFactoriesResponsePayload, ConfigurationFactoriesResponseMessage> {
 
-    @Inject
-    private ObjectMapper jsonMapper;
-    @Inject
-    private DeviceConfigurationFactory deviceConfigurationFactory;
-
     public TranslatorAppConfigurationFactoriesKuraKapua() {
         super(ConfigurationFactoriesResponseMessage.class, ConfigurationFactoriesResponsePayload.class);
     }
@@ -54,8 +47,8 @@ protected ConfigurationResponseChannel translateChannel(KuraResponseChannel kura
     @Override
     protected ConfigurationFactoriesResponsePayload translatePayload(KuraResponsePayload kuraResponsePayload) throws InvalidPayloadException {
         try {
-            Representation representation = jsonMapper.readValue(kuraResponsePayload.getBody(), Representation.class);
-            DeviceComponentConfigurationFactories factories = deviceConfigurationFactory.newComponentConfigurationFactories();
+            Representation representation = getJsonMapper().readValue(kuraResponsePayload.getBody(), Representation.class);
+            DeviceComponentConfigurationFactories factories = new DeviceComponentConfigurationFactoriesImpl();
             representation.pids.stream().sorted().forEach(factories.getIds()::add);
             return new ConfigurationFactoriesResponsePayload(factories);
         } catch (Exception e) {