1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
/*-
* ============LICENSE_START=======================================================
* ONAP - SO
* ================================================================================
* Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
*/
package org.openecomp.mso.yangDecoder.transform.impl;
import org.openecomp.mso.yangDecoder.transform.api.ITransformJava2StringService;
import org.opendaylight.netconf.sal.restconf.impl.ControllerContext;
import org.opendaylight.netconf.sal.restconf.impl.InstanceIdentifierContext;
import org.opendaylight.netconf.sal.restconf.impl.NormalizedNodeContext;
import org.opendaylight.yangtools.binding.data.codec.api.BindingNormalizedNodeSerializer;
import org.opendaylight.yangtools.yang.binding.DataObject;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
import org.opendaylight.yangtools.yang.binding.Notification;
import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode;
import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
import org.opendaylight.yangtools.yang.model.api.DataSchemaNode;
import org.opendaylight.yangtools.yang.model.api.SchemaContext;
import org.opendaylight.yangtools.yang.model.api.SchemaNode;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.Map;
/**
* Created by Administrator on 2017/3/20.
*/
public class TransformJava2XMLServiceImpl implements ITransformJava2StringService {
private static final Logger LOG = LoggerFactory.getLogger(TransformJava2XMLServiceImpl.class);
BindingNormalizedNodeSerializer mappingservice;
SchemaContext schemaContext;
YangDataTransformJava2NNServiceImpl java2nnService;
YangDataTransformNN2XMLServiceImpl nn2xmlService;
YangOdlNN2XMLImpl yangODLnn2xml;
public TransformJava2XMLServiceImpl(BindingNormalizedNodeSerializer mappingService, SchemaContext schemaContext){
this.mappingservice=mappingService;
this.schemaContext=schemaContext;
java2nnService=new YangDataTransformJava2NNServiceImpl(mappingService);
nn2xmlService=new YangDataTransformNN2XMLServiceImpl(mappingService,schemaContext);
yangODLnn2xml=new YangOdlNN2XMLImpl(schemaContext);
}
@Override
public <T extends DataObject> String transformContrainerDataObjectToString(InstanceIdentifier<T> instanceIdentifier, String uriPath, T dataObject)
throws Exception {
// TODO Auto-generated method stub
NormalizedNode nn=java2nnService.yangDataObjecttoNN(instanceIdentifier,dataObject);
return yangODLnn2xml.yangNNtoXML(uriPath,nn);
}
@Override
public <T extends Notification> String transformNotificationToString(String uriPath, T notification)
throws Exception {
NormalizedNode nn= mappingservice.toNormalizedNodeNotification(notification);
return yangODLnn2xml.yangNNtoXML(uriPath,nn);
}
@Override
public <T extends DataObject> String transformRpcDataObjectToString(String uriPath, T dataObject)
throws Exception {
NormalizedNode nn=mappingservice.toNormalizedNodeRpcData(dataObject);
return yangODLnn2xml.yangNNtoXML(uriPath,nn);
}
//for container
public <T extends DataObject> String transformContrainerDataObjectToString(InstanceIdentifier<T> instanceIdentifier, T dataObject) {
// TODO Auto-generated method stub
NormalizedNode nn=java2nnService.yangDataObjecttoNN(instanceIdentifier,dataObject);
return nn2xmlService.transformNNToString(nn);
}
public <T extends Notification> String transformNotificationToString(T notification) {
NormalizedNode nn= mappingservice.toNormalizedNodeNotification(notification);
return nn2xmlService.transformNNToString(nn);
}
//for rpc
public <T extends DataObject> String transformRpcDataObjectToString(T dataObject) {
NormalizedNode nn=mappingservice.toNormalizedNodeRpcData(dataObject);
return nn2xmlService.transformNNToString(nn);
}
//for container
@Override
public DataObject transformContrainerDataObjectFromString(String uriPath, String sxml,boolean ispost) throws Exception {
// TODO Auto-generated method stub
if(ispost)
{
NormalizedNodeContext nnc=YangOdlNNC2XMLImpl.fromXML(uriPath,sxml, ispost);
final InstanceIdentifierContext<?> iicontext=nnc.getInstanceIdentifierContext();
Map.Entry<InstanceIdentifier<?>, DataObject> temp = mappingservice.fromNormalizedNode(iicontext.getInstanceIdentifier(),nnc.getData());
return (DataObject)temp.getValue();
}
final InstanceIdentifierContext<?> iicontext = ControllerContext.getInstance().toInstanceIdentifier(uriPath);
NormalizedNode nn =nn2xmlService.transformNNFromString(sxml);
Map.Entry<InstanceIdentifier<?>, DataObject> temp = mappingservice.fromNormalizedNode(iicontext.getInstanceIdentifier(),nn);
if (null == temp) {
return null;
} else {
return temp.getValue();
}
}
@Override
public Notification transformNotificationFromString(String notficationName, String sxml) throws Exception {
final InstanceIdentifierContext<?> iicontext = ControllerContext.getInstance().toInstanceIdentifier(notficationName);
NormalizedNode nn = nn2xmlService.transformNotificationStringtoNN(sxml, notficationName);
ContainerNode noti = (ContainerNode) nn;
SchemaNode snode=iicontext.getSchemaNode() ;
Notification obj = mappingservice.fromNormalizedNodeNotification(snode.getPath(), noti);
return obj;
}
//for rpc
@Override
public DataObject transformRpcDataObjectFromString(String rpcName, String sxml) throws Exception {
final InstanceIdentifierContext<?> iicontext = ControllerContext.getInstance().toInstanceIdentifier(rpcName);
Map.Entry<DataSchemaNode, NormalizedNode> nnentry = nn2xmlService.transformRpcNNEntryfromString(sxml,iicontext);
ContainerNode rpc = (ContainerNode) nnentry.getValue();
DataObject rpcdata= mappingservice.fromNormalizedNodeRpcData(nnentry.getKey().getPath(),rpc);
return rpcdata;
}
}
|
