gerrit.onap Code Review - ccsdk/oran.git/blob

   1 /*-
   2  * ========================LICENSE_START=================================
   3  * Copyright (C) 2020 Nordix Foundation. All rights reserved.
   4  * ======================================================================
   5  * Licensed under the Apache License, Version 2.0 (the "License");
   6  * you may not use this file except in compliance with the License.
   7  * You may obtain a copy of the License at
   8  *
   9  *      http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  * Unless required by applicable law or agreed to in writing, software
  12  * distributed under the License is distributed on an "AS IS" BASIS,
  13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  * See the License for the specific language governing permissions and
  15  * limitations under the License.
  16  * ========================LICENSE_END===================================
  17  */
  18
  19 package org.onap.ccsdk.oran.a1policymanagementservice.configuration;
  20
  21 import com.google.gson.Gson;
  22 import com.google.gson.JsonElement;
  23 import com.google.gson.JsonObject;
  24 import com.google.gson.JsonParser;
  25
  26 import java.io.BufferedInputStream;
  27 import java.io.File;
  28 import java.io.FileInputStream;
  29 import java.io.FileWriter;
  30 import java.io.IOException;
  31 import java.io.InputStream;
  32 import java.io.InputStreamReader;
  33 import java.lang.invoke.MethodHandles;
  34 import java.util.Optional;
  35
  36 import org.slf4j.Logger;
  37 import org.slf4j.LoggerFactory;
  38 import org.springframework.stereotype.Component;
  39
  40 @Component
  41 public class ConfigurationFile {
  42     private static final Logger logger = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
  43
  44     final ApplicationConfig appConfig;
  45     final Gson gson = new Gson();
  46
  47     public ConfigurationFile(ApplicationConfig appConfig) {
  48         this.appConfig = appConfig;
  49     }
  50
  51     public long getLastModified() {
  52         File file = new File(appConfig.getLocalConfigurationFilePath());
  53         if (file.exists()) {
  54             return file.lastModified();
  55         }
  56         return 0;
  57     }
  58
  59     public synchronized Optional<JsonObject> readFile() {
  60         String filepath = appConfig.getLocalConfigurationFilePath();
  61         File file = new File(filepath);
  62         if (!file.exists()) {
  63             return Optional.empty();
  64         }
  65
  66         try (InputStream inputStream = createInputStream(filepath)) {
  67             JsonObject rootObject = getJsonElement(inputStream).getAsJsonObject();
  68             logger.debug("Local configuration file read: {}", filepath);
  69             return Optional.of(rootObject);
  70         } catch (Exception e) {
  71             logger.error("Local configuration file not read: {}, {}", filepath, e.getMessage());
  72             return Optional.empty();
  73         }
  74     }
  75
  76     public synchronized void writeFile(JsonObject content) throws IOException {
  77         String filepath = appConfig.getLocalConfigurationFilePath();
  78         try (FileWriter fileWriter = getFileWriter(filepath)) {
  79             gson.toJson(content, fileWriter);
  80             logger.debug("Local configuration file written: {}", filepath);
  81         }
  82     }
  83
  84     FileWriter getFileWriter(String filepath) throws IOException {
  85         return new FileWriter(filepath);
  86     }
  87
  88     private JsonElement getJsonElement(InputStream inputStream) {
  89         return JsonParser.parseReader(new InputStreamReader(inputStream));
  90     }
  91
  92     private InputStream createInputStream(String filepath) throws IOException {
  93         return new BufferedInputStream(new FileInputStream(filepath));
  94     }
  95 }