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 long getLastModified() {
  55         File file = new File(appConfig.getLocalConfigurationFilePath());
  56         if (file.exists()) {
  57             return file.lastModified();
  58         }
  59         return 0;
  60     }
  61
  62     public synchronized Optional<JsonObject> readFile() {
  63         String filepath = appConfig.getLocalConfigurationFilePath();
  64         File file = new File(filepath);
  65         if (!file.exists()) {
  66             return Optional.empty();
  67         }
  68
  69         try (InputStream inputStream = createInputStream(filepath)) {
  70             JsonObject rootObject = getJsonElement(inputStream).getAsJsonObject();
  71             logger.debug("Local configuration file read: {}", filepath);
  72             return Optional.of(rootObject);
  73         } catch (Exception e) {
  74             logger.error("Local configuration file not read: {}, {}", filepath, e.getMessage());
  75             return Optional.empty();
  76         }
  77     }
  78
  79     public synchronized void writeFile(JsonObject content) throws IOException {
  80         String filepath = appConfig.getLocalConfigurationFilePath();
  81         try (FileWriter fileWriter = getFileWriter(filepath)) {
  82             gson.toJson(content, fileWriter);
  83             logger.debug("Local configuration file written: {}", filepath);
  84         }
  85     }
  86
  87     FileWriter getFileWriter(String filepath) throws IOException {
  88         return new FileWriter(filepath);
  89     }
  90
  91     private JsonElement getJsonElement(InputStream inputStream) {
  92         return JsonParser.parseReader(new InputStreamReader(inputStream));
  93     }
  94
  95     private InputStream createInputStream(@NotNull String filepath) throws IOException {
  96         return new BufferedInputStream(new FileInputStream(filepath));
  97     }
  98 }