57aafc2ce0c7e3b88dfcb85806f6b4b794cbc00b
[vfc/nfvo/multivimproxy.git] /
1 /*
2  * Copyright 2016 Huawei Technologies Co., Ltd.
3  *
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  *     http://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16
17 package org.onap.vfc.nfvo.multivimproxy.service.adapter.impl;
18
19 import java.io.BufferedInputStream;
20 import java.io.FileInputStream;
21 import java.io.FileNotFoundException;
22 import java.io.IOException;
23 import java.io.InputStream;
24 import java.util.HashMap;
25 import java.util.Map;
26 import java.util.concurrent.Executors;
27
28 import org.onap.vfc.nfvo.multivimproxy.service.adapter.inf.IMultivimProxyAdapterMgrService;
29 import org.onap.vfc.nfvo.multivimproxy.common.constant.Constant;
30 import org.onap.vfc.nfvo.multivimproxy.common.constant.HttpConstant;
31 import org.onap.vfc.nfvo.multivimproxy.common.constant.ParamConstant;
32 import org.onap.vfc.nfvo.multivimproxy.common.constant.UrlConstant;
33 import org.onap.vfc.nfvo.multivimproxy.common.util.restclient.SystemEnvVariablesFactory;
34 import org.onap.vfc.nfvo.multivimproxy.service.adapter.inf.IMultivimProxyAdapter2MSBManager;
35 import org.onap.vfc.nfvo.multivimproxy.service.adapter.inf.IMultivimProxyAdapterMgrService;
36 import org.slf4j.Logger;
37 import org.slf4j.LoggerFactory;
38
39 import net.sf.json.JSONObject;
40
41 /**
42  * <br>
43  * <p>
44  * </p>
45  * 
46  * @author
47  * @version VFC 1.0 Sep 22, 2016
48  */
49 public class MultivimProxyAdapterMgrService implements IMultivimProxyAdapterMgrService {
50
51     private static final Logger LOG = LoggerFactory.getLogger(MultivimProxyAdapterMgrService.class);
52
53     public static final String RESMGRADAPTERINFO = "resmgradapterinfo.json";
54
55     @Override
56     public void register() {
57         // set BUS URL and mothedtype
58         Map<String, String> paramsMap = new HashMap<>();
59         paramsMap.put("url", UrlConstant.REST_MSB_REGISTER);
60         paramsMap.put("methodType", ParamConstant.PARAM_POST);
61
62         // get multivimproxy info and raise registration
63         try {
64             String resmgrInfo = readVimAdapterInfoFromJson();
65             if(!"".equals(resmgrInfo)) {
66                 JSONObject adapterObject = JSONObject.fromObject(resmgrInfo);
67                 RegisterMultivimProxyThread resmgrThread = new RegisterMultivimProxyThread(paramsMap, adapterObject);
68                 Executors.newSingleThreadExecutor().submit(resmgrThread);
69             } else {
70                 LOG.error("Resmgr info is null,please check!");
71             }
72
73         } catch(IOException e) {
74             LOG.error("Failed to read Resmgr info! " + e.getMessage(), e);
75         }
76
77     }
78
79     /**
80      * Retrieve VIM driver information.
81      * 
82      * @return
83      * @throws IOException
84      */
85     public static String readVimAdapterInfoFromJson() throws IOException {
86         String fileContent = "";
87
88         String fileName = SystemEnvVariablesFactory.getInstance().getAppRoot() + System.getProperty("file.separator")
89                 + "etc" + System.getProperty("file.separator") + "adapterInfo" + System.getProperty("file.separator")
90                 + RESMGRADAPTERINFO;
91
92         try (
93             InputStream ins = new FileInputStream(fileName);
94             BufferedInputStream bins = new BufferedInputStream(ins)){
95
96             byte[] contentByte = new byte[ins.available()];
97             int num = bins.read(contentByte);
98
99             if(num > 0) {
100                 fileContent = new String(contentByte);
101             }
102         } catch(FileNotFoundException e) {
103             LOG.error(fileName + "is not found!", e);
104         } 
105
106         return fileContent;
107     }
108
109     private static class RegisterMultivimProxyThread implements Runnable {
110
111         // Thread lock Object
112         private final Object lockObject = new Object();
113
114         private IMultivimProxyAdapter2MSBManager adapter2MSBMgr = new MultivimProxyAdapter2MSBManager();
115
116         // url and mothedtype
117         private Map<String, String> paramsMap;
118
119         // driver body
120         private JSONObject adapterInfo;
121
122         public RegisterMultivimProxyThread(Map<String, String> paramsMap, JSONObject adapterInfo) {
123             this.paramsMap = paramsMap;
124             this.adapterInfo = adapterInfo;
125         }
126
127         @Override
128         public void run() {
129             LOG.info("start register resmgr", RegisterMultivimProxyThread.class);
130
131             if(paramsMap == null || adapterInfo == null) {
132                 LOG.error("parameter is null,please check!", RegisterMultivimProxyThread.class);
133                 return;
134             }
135
136             // catch Runtime Exception
137             try {
138                 sendRequest(paramsMap, adapterInfo);
139             } catch(Exception e) {
140                 LOG.error(e.getMessage(), e);
141             }
142
143         }
144
145         private void sendRequest(Map<String, String> paramsMap, JSONObject driverInfo)throws InterruptedException {
146             JSONObject resultObj = adapter2MSBMgr.registerProxy(paramsMap, driverInfo);
147
148             if(Integer.valueOf(resultObj.get("retCode").toString()) == HttpConstant.HTTP_CREATED) {
149                 LOG.info("Resmgr has now Successfully Registered to the Microservice BUS!");
150             } else {
151                 LOG.error("Resmgr failed to  Register to the Microservice BUS! Reason:"
152                         + resultObj.get("reason").toString() + " retCode:" + resultObj.get("retCode").toString());
153
154                 // if registration fails,wait one minute and try again
155                 synchronized(lockObject) {
156                         while(Integer.valueOf(resultObj.get("retCode").toString()) != Constant.HTTP_CREATED){
157                         lockObject.wait(Constant.REPEAT_REG_TIME);
158                         resultObj = adapter2MSBMgr.registerProxy(this.paramsMap, this.adapterInfo);
159                         }
160                     }
161                 LOG.info("Resmgr has now Successfully Registered to the Microservice BUS!");
162             }
163
164         }
165
166     }
167
168     @Override
169     public void unregister() {
170         // unregister
171     }
172
173 }