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.util.Optional;
  34
  35 import javax.validation.constraints.NotNull;
  36
  37 import org.slf4j.Logger;
  38 import org.slf4j.LoggerFactory;
  39 import org.springframework.beans.factory.annotation.Autowired;
  40 import org.springframework.stereotype.Component;
  41
  42 @Component
  43 public class ConfigurationFile {
  44     private static final Logger logger = LoggerFactory.getLogger(ConfigurationFile.class);
  45
  46     final ApplicationConfig appConfig;
  47     final Gson gson = new Gson();
  48
  49     @Autowired
  50     public ConfigurationFile(ApplicationConfig appConfig) {
  51         this.appConfig = appConfig;
  52     }
  53
  54     public synchronized Optional<JsonObject> readFile() {
  55         String filepath = appConfig.getLocalConfigurationFilePath();
  56         if (!fileExists(filepath)) {
  57             return Optional.empty();
  58         }
  59
  60         try (InputStream inputStream = createInputStream(filepath)) {
  61             JsonObject rootObject = getJsonElement(inputStream).getAsJsonObject();
  62             logger.debug("Local configuration file read: {}", filepath);
  63             return Optional.of(rootObject);
  64         } catch (Exception e) {
  65             logger.error("Local configuration file not read: {}, {}", filepath, e.getMessage());
  66             return Optional.empty();
  67         }
  68     }
  69
  70     public synchronized void writeFile(JsonObject content) throws IOException {
  71         String filepath = appConfig.getLocalConfigurationFilePath();
  72         try (FileWriter fileWriter = getFileWriter(filepath)) {
  73             gson.toJson(content, fileWriter);
  74             logger.debug("Local configuration file written: {}", filepath);
  75         }
  76     }
  77
  78     FileWriter getFileWriter(String filepath) throws IOException {
  79         return new FileWriter(filepath);
  80     }
  81
  82     private boolean fileExists(String filepath) {
  83         return (new File(filepath).exists());
  84     }
  85
  86     private JsonElement getJsonElement(InputStream inputStream) {
  87         return JsonParser.parseReader(new InputStreamReader(inputStream));
  88     }
  89
  90     private InputStream createInputStream(@NotNull String filepath) throws IOException {
  91         return new BufferedInputStream(new FileInputStream(filepath));
  92     }
  93 }