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
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
|
/**
* Copyright 2017 Huawei Technologies Co., Ltd.
*
* 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.
*/
package org.onap.vnfsdk.marketplace.common;
import com.google.gson.Gson;
import com.google.gson.JsonElement;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.text.DecimalFormat;
import java.util.ArrayList;
import java.util.Collection;
import java.util.UUID;
/**
* common utility class.
*
*/
public class ToolUtil {
private static final Logger LOG = LoggerFactory.getLogger(ToolUtil.class);
public static final String CATALOGUE_CSAR_DIR_NAME = "csar";
public static final String CATALOGUE_IMAGE_DIR_NAME = "image";
public static final int FILE_PERCENT = 1024 * 1024; // 1M
public static boolean isEmptyString(String val) {
return val == null || "".equals(val);
}
public static boolean isTrimedEmptyString(String val) {
return val == null || "".equals(val.trim());
}
public static boolean isTrimedEmptyArray(String[] val) {
return val == null || val.length == 0;
}
/**
* trimed string.
*
* @param val string array to trim
* @return String[]
*/
public static String[] trimedStringArray(String[] val) {
if (isTrimedEmptyArray(val)) {
return val;
}
String[] rets = new String[val.length];
for (int i = 0; i < val.length; i++) {
rets[i] = val[i].trim();
}
return rets;
}
public static boolean isEmptyCollection(Collection<?> coll) {
return null == coll || coll.isEmpty();
}
/**
* store chunk file to local temp directory.
*
* @param dirName directory name
* @param fileName file name
* @param uploadedInputStream upload input stream
* @return String
* @throws IOException e
*/
public static String storeChunkFileInLocal(String dirName, String fileName,
InputStream uploadedInputStream) throws IOException {
File tmpDir = new File(dirName);
LOG.info("tmpdir = " + File.separator + dirName);
if (!tmpDir.exists()) {
tmpDir.mkdirs();
}
File file = new File(tmpDir + File.separator + fileName);
OutputStream os = null;
try {
int read = 0;
byte[] bytes = new byte[1024];
os = new FileOutputStream(file, true);
while ((read = uploadedInputStream.read(bytes)) != -1) {
os.write(bytes, 0, read);
}
os.flush();
return file.getAbsolutePath();
} finally {
if (os != null) {
os.close();
}
}
}
/**
* get temp dirctory when upload package.
*
* @param dirName temp directory name
* @param fileName package name
* @return String
*/
public static String getTempDir(String dirName, String fileName) {
// File tmpDir = new File(File.separator + dirName);
return Thread.currentThread().getContextClassLoader().getResource("/").getPath() + dirName + File.separator
+ fileName.replace(".csar", "");
}
public static String getUnzipDir(String dirName) {
File tmpDir = new File(File.separator + dirName);
return tmpDir.getAbsolutePath().replace(".csar", "");
}
/**
* delete file.
*
* @param dirName the directory of file
* @param fileName file name
* @return boolean
*/
public static boolean deleteFile(String dirName, String fileName) {
File tmpDir = new File(getCataloguePath() + File.separator + dirName);
if (!tmpDir.exists()) {
return true;
}
File file = new File(tmpDir.getAbsolutePath() + File.separator + fileName);
if (file.exists()) {
return file.delete();
}
return true;
}
public static String getCataloguePath() {
// return Config.getConfigration().getCataloguePath();
return "";
}
public static String getCatalogueCsarPath() {
return getCataloguePath() + File.separator + CATALOGUE_CSAR_DIR_NAME;
}
public static String getCatalogueImagePath() {
return getCataloguePath() + File.separator + CATALOGUE_IMAGE_DIR_NAME;
}
/**
* get file size.
*
* @param file file which to get the size
* @param fileUnit file unit
* @return String file size
*/
public static String getFileSize(File file, int fileUnit) {
String fileSize = "";
DecimalFormat format = new DecimalFormat("#0.00");
if (file.exists()) {
fileSize = format.format((double) file.length() / fileUnit) + "M";
}
return fileSize;
}
public static String formatFileSize(double fileLength, int fileUnit) {
DecimalFormat format = new DecimalFormat("#0.00");
return format.format(fileLength / fileUnit) + "M";
}
/**
* get file size by content.
*
* @param contentRange content range
* @return String
*/
public static String getFileSizeByContent(String contentRange) {
String size =
contentRange.substring(contentRange.indexOf("/") + 1, contentRange.length()).trim();
return formatFileSize(Double.parseDouble(size), FILE_PERCENT);
}
/**
* fix package format.
*
* @param csarId package ID
* @return String
*/
public static String formatCsar(String csarId) {
String result = csarId;
if (csarId.indexOf(".csar") < 0) {
result += ".csar";
}
return result;
}
/**
* delete the file and file directory.
*
* @param dir file
* @return boolean
*/
public static boolean deleteDir(File dir) {
if (dir.isDirectory()) {
String[] children = dir.list();
for (int i = 0; i < children.length; i++) {
boolean success = deleteDir(new File(dir, children[i]));
if (!success) {
return false;
}
}
}
return dir.delete();
}
// public static boolean unZipCsar(String fileLocation) throws IOException {
// String tempfolder=System.getProperty("java.io.tmpdir");
// ArrayList<String> unzipFiles = FileUtil.unzip(fileLocation, tempfolder);
// if(unzipFiles.isEmpty()){
// return true;
// }
// }
/**
* judge the file's format is yaml or not.
*
* @param file file to judge
* @return boolean
*/
public static boolean isYamlFile(File file) {
if (!file.isDirectory() && file.getName().indexOf(".yaml") != -1) {
return true;
}
return false;
}
/**
* remove the csar suffix.
*
* @param csarName package name
* @return String
*/
public static String removeCsarSuffix(String csarName) {
return csarName.replaceAll(".csar", "");
}
/**
* add the csar fuffix.
*
* @param csarName package name
* @return String
*/
public static String addCsarSuffix(String csarName) {
if (csarName.indexOf(".csar") == -1) {
return csarName + ".csar";
}
return csarName;
}
/**
* process file name.
*
* @param fileName file's name
* @return String
*/
public static String processFileName(String fileName) {
int index = fileName.indexOf(".zip");
if (index == -1) {
return fileName;
}
return addCsarSuffix(fileName.replaceAll(".zip", ""));
}
/**
* exchange object to string.
*
* @param obj object
* @return String
*/
public static String objectToString(Object obj) {
if (obj == null) {
return "";
}
Gson gson = new Gson();
String str = gson.toJson(obj);
return str;
}
public static String generateId() {
return UUID.randomUUID().toString();
}
/**
* get the size format according file size.
*
* @param fileSize file size
* @return size format
*/
public static String getFormatFileSize(long fileSize) {
long kb = 1024;
long mb = kb * 1024;
long gb = mb * 1024;
if (fileSize >= gb) {
return String.format("%.1f GB", (float) fileSize / gb);
} else if (fileSize >= mb) {
float fi = (float) fileSize / mb;
return String.format(fi > 100 ? "%.0f MB" : "%.1f MB", fi);
} else if (fileSize >= kb) {
float fi = (float) fileSize / kb;
return String.format(fi > 100 ? "%.0f KB" : "%.1f KB", fi);
} else {
return String.format("%d B", fileSize);
}
}
/**
* get gson from json.
* @param jsonString json string
* @param templateClass template class
* @return Template
*/
public static <T> T fromJson(String jsonString, Class<T> templateClass) {
Gson gson = new Gson();
return gson.fromJson(jsonString, templateClass);
}
/**
* gson to json.
* @param template class name
* @return String
*/
public static <T> String toJson(T template) {
Gson gson = new Gson();
return gson.toJson(template);
}
/**
* @param value
* @return
*/
public static String getAsString(JsonElement value) {
if (value.isJsonPrimitive()) {
return value.getAsString();
}
return value.toString();
}
}
|