1 package org.commscope.tr069adapter.mapper.ves.impl;
\r
3 import org.commscope.tr069adapter.acs.common.DeviceRPCRequest;
\r
4 import org.commscope.tr069adapter.acs.common.DeviceRPCResponse;
\r
5 import org.commscope.tr069adapter.acs.common.OperationResponse;
\r
6 import org.commscope.tr069adapter.mapper.MapperConfigProperties;
\r
7 import org.commscope.tr069adapter.mapper.model.ErrorCodeDetails;
\r
8 import org.commscope.tr069adapter.mapper.sync.SynchronizedRequestHandler;
\r
9 import org.commscope.tr069adapter.mapper.util.ErrorCodeUtil;
\r
10 import org.commscope.tr069adapter.mapper.util.MapperConstants;
\r
11 import org.commscope.tr069adapter.mapper.ves.VesRequestHandler;
\r
12 import org.slf4j.Logger;
\r
13 import org.slf4j.LoggerFactory;
\r
14 import org.springframework.beans.factory.annotation.Autowired;
\r
15 import org.springframework.stereotype.Component;
\r
18 public class VesRequestHandlerImpl implements VesRequestHandler {
\r
20 private static final Logger LOG = LoggerFactory.getLogger(VesRequestHandlerImpl.class);
\r
23 SynchronizedRequestHandler syncHandler;
\r
26 MapperConfigProperties config;
\r
29 private ErrorCodeUtil errorCodeUtil;
\r
33 public DeviceRPCResponse handleDeviceConnectivityRequest(DeviceRPCRequest deviceRPCRequest) {
\r
34 DeviceRPCResponse deviceRPCResponse = syncHandler.performDeviceOperation(deviceRPCRequest);
\r
35 if (null == deviceRPCResponse) {
\r
36 return getTimeOutResponse(deviceRPCRequest);
\r
39 return deviceRPCResponse;
\r
42 private DeviceRPCResponse getTimeOutResponse(DeviceRPCRequest deviceRPCRequest) {
\r
43 DeviceRPCResponse timeOutErrorResponse = new DeviceRPCResponse();
\r
45 timeOutErrorResponse.setDeviceDetails(deviceRPCRequest.getDeviceDetails());
\r
47 OperationResponse operationResponse = new OperationResponse();
\r
48 operationResponse.setStatus(MapperConstants.DEVICE_REACHABILITY_OP_FAILURE_CODE);// device
\r
49 // reachable...change
\r
54 operationResponse.setOperationCode(deviceRPCRequest.getOpDetails().getOpCode());
\r
56 timeOutErrorResponse.setOperationResponse(operationResponse);
\r
57 timeOutErrorResponse.setFaultKey(MapperConstants.DEVICE_TIMEOUT_STATUS_CODE);
\r
58 ErrorCodeDetails errorCodeDetails =
\r
59 errorCodeUtil.getErrorCodeMetaData(MapperConstants.DEVICE_TIMEOUT_STATUS_CODE);
\r
60 if (null != errorCodeDetails) {
\r
61 timeOutErrorResponse.setFaultString(errorCodeDetails.getErrorMessage());
\r
63 timeOutErrorResponse.setFaultString(MapperConstants.DEFAULT_OP_TIMEOUT_MSG);
\r
65 return timeOutErrorResponse;
\r