*/
package org.opendaylight.transportpce.tapi.impl;
+import java.util.HashMap;
import org.eclipse.jdt.annotation.NonNull;
import org.opendaylight.mdsal.binding.api.DataBroker;
import org.opendaylight.mdsal.binding.api.DataTreeIdentifier;
import org.opendaylight.mdsal.binding.api.RpcProviderService;
import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
import org.opendaylight.transportpce.common.network.NetworkTransactionService;
+import org.opendaylight.transportpce.servicehandler.service.ServiceDataStoreOperations;
+import org.opendaylight.transportpce.tapi.connectivity.ConnectivityUtils;
import org.opendaylight.transportpce.tapi.connectivity.TapiConnectivityImpl;
import org.opendaylight.transportpce.tapi.topology.TapiTopologyImpl;
import org.opendaylight.transportpce.tapi.topology.TopologyUtils;
private final RpcProviderService rpcProviderService;
private ObjectRegistration<TapiConnectivityService> rpcRegistration;
private final OrgOpenroadmServiceService serviceHandler;
+ private final ServiceDataStoreOperations serviceDataStoreOperations;
private final TapiListener tapiListener;
private final NetworkTransactionService networkTransactionService;
public TapiProvider(DataBroker dataBroker, RpcProviderService rpcProviderService,
- OrgOpenroadmServiceService serviceHandler, TapiListener tapiListener,
- NetworkTransactionService networkTransactionService) {
+ OrgOpenroadmServiceService serviceHandler, ServiceDataStoreOperations serviceDataStoreOperations,
+ TapiListener tapiListener, NetworkTransactionService networkTransactionService) {
this.dataBroker = dataBroker;
this.rpcProviderService = rpcProviderService;
this.serviceHandler = serviceHandler;
+ this.serviceDataStoreOperations = serviceDataStoreOperations;
this.tapiListener = tapiListener;
this.networkTransactionService = networkTransactionService;
}
LOG.info("Empty TAPI context created: {}", tapiContext.getTapiContext());
TopologyUtils topologyUtils = new TopologyUtils(this.networkTransactionService, this.dataBroker);
- TapiInitialORMapping tapiInitialORMapping = new TapiInitialORMapping(topologyUtils, tapiContext);
+ ConnectivityUtils connectivityUtils = new ConnectivityUtils(this.serviceDataStoreOperations, new HashMap<>(),
+ tapiContext);
+ TapiInitialORMapping tapiInitialORMapping = new TapiInitialORMapping(topologyUtils, connectivityUtils,
+ tapiContext, this.serviceDataStoreOperations);
tapiInitialORMapping.performTopoInitialMapping();
+ tapiInitialORMapping.performServInitialMapping();
TapiConnectivityImpl tapi = new TapiConnectivityImpl(this.serviceHandler);
TapiTopologyImpl topo = new TapiTopologyImpl(this.dataBroker, tapiContext, topologyUtils);