You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nlpcraft.apache.org by ar...@apache.org on 2021/01/25 02:28:27 UTC

[incubator-nlpcraft] 01/01: Update NCExternalConfigManager.scala

This is an automated email from the ASF dual-hosted git repository.

aradzinski pushed a commit to branch NLPCRAFT-228
in repository https://gitbox.apache.org/repos/asf/incubator-nlpcraft.git

commit bff04ca83927ffd55c31f51ef6950d9f9926783b
Author: Aaron Radzinski <ar...@datalingvo.com>
AuthorDate: Sun Jan 24 18:28:13 2021 -0800

    Update NCExternalConfigManager.scala
---
 .../common/extcfg/NCExternalConfigManager.scala    | 22 ++++++++++++++++++++--
 1 file changed, 20 insertions(+), 2 deletions(-)

diff --git a/nlpcraft/src/main/scala/org/apache/nlpcraft/common/extcfg/NCExternalConfigManager.scala b/nlpcraft/src/main/scala/org/apache/nlpcraft/common/extcfg/NCExternalConfigManager.scala
index 773bfe7..7b74fa6 100644
--- a/nlpcraft/src/main/scala/org/apache/nlpcraft/common/extcfg/NCExternalConfigManager.scala
+++ b/nlpcraft/src/main/scala/org/apache/nlpcraft/common/extcfg/NCExternalConfigManager.scala
@@ -183,6 +183,24 @@ object NCExternalConfigManager extends NCService {
     }
 
     /**
+     *
+     * @param typ Resource type.
+     * @param res Resource name.
+     * @return
+     */
+    private def mkFile(typ: NCResourceType, res: String): File = {
+        val file = mkExtFile(typ, res)
+
+        if (!file.exists() || !file.canRead)
+            throw new NCE(
+                s"Configuration file '$res' not found or not readable. Delete all files from an external " +
+                s"configuration folder '${Config.dir}' and restart."
+            )
+
+        file
+    }
+
+    /**
       *
       * @param typ
       * @param res
@@ -191,7 +209,7 @@ object NCExternalConfigManager extends NCService {
     @throws[NCE]
     def getContent(typ: NCResourceType, res: String, parent: Span = null): String =
         startScopedSpan("getContent", parent, "res" → res) { _ ⇒
-            mkString(U.readFile(mkExtFile(typ, res), "UTF-8"))
+            mkString(U.readFile(mkFile(typ, res), "UTF-8"))
         }
 
     /**
@@ -203,7 +221,7 @@ object NCExternalConfigManager extends NCService {
     @throws[NCE]
     def getStream(typ: NCResourceType, res: String, parent: Span = null): InputStream =
         startScopedSpan("getStream", parent, "res" → res) { _ ⇒
-            new BufferedInputStream(new FileInputStream(mkExtFile(typ, res)))
+            new BufferedInputStream(new FileInputStream(mkFile(typ, res)))
         }
 
     /**