Improves handling of NSFW options and lifecycle

Enhances robustness in options processing by validating error callback and excluded paths.

Ensures proper thread joining and queue management during object destruction to prevent potential crashes.

Refines error messages for clarity and user understanding, providing more informative feedback in case of failures.

Adds checks to ensure queue and interface are valid before calling methods on them.

Author: julianmesa-gitkraken

src/NSFW.cpp

@@ -56,37 +56,47 @@ NSFW::NSFW(const Napi::CallbackInfo &info):
 
     // errorCallback
     Napi::Value maybeErrorCallback = options["errorCallback"];
-    if (options.Has("errorCallback") && !maybeErrorCallback.IsFunction()) {
+    if (options.Has("errorCallback") && !maybeErrorCallback.IsFunction() && !maybeErrorCallback.IsNull() && !maybeErrorCallback.IsUndefined()) {
       throw Napi::TypeError::New(env, "options.errorCallback must be a function.");
     }
 
-    mErrorCallback = Napi::ThreadSafeFunction::New(
-      env,
-      maybeErrorCallback.IsFunction()
-        ? maybeErrorCallback.As<Napi::Function>()
-        : Napi::Function::New(env, [](const Napi::CallbackInfo &info) {}),
-      "nsfw",
-      0,
-      1
-    );
+    if (maybeErrorCallback.IsFunction()) {
+      mErrorCallback = Napi::ThreadSafeFunction::New(
+        env,
+        maybeErrorCallback.As<Napi::Function>(),
+        "nsfw",
+        0,
+        1
+      );
+    } else {
+      mErrorCallback = Napi::ThreadSafeFunction::New(
+        env,
+        Napi::Function::New(env, [](const Napi::CallbackInfo &info) {}),
+        "nsfw",
+        0,
+        1
+      );
+    }
 
     // excludedPaths
     Napi::Value maybeExcludedPaths = options["excludedPaths"];
     if (options.Has("excludedPaths") && !maybeExcludedPaths.IsArray()) {
       throw Napi::TypeError::New(env, "options.excludedPaths must be an array.");
     }
-    Napi::Array paths = maybeExcludedPaths.As<Napi::Array>();
-    for(uint32_t i = 0; i < paths.Length(); i++) {
-      Napi::Value path = paths[i];
-      if (path.IsString())
-      {
-        std::string str = path.ToString().Utf8Value();
-        if (str.back() == '/') {
-          str.pop_back();
+    if (maybeExcludedPaths.IsArray()) {
+      Napi::Array paths = maybeExcludedPaths.As<Napi::Array>();
+      for(uint32_t i = 0; i < paths.Length(); i++) {
+        Napi::Value path = paths[i];
+        if (path.IsString())
+        {
+          std::string str = path.ToString().Utf8Value();
+          if (!str.empty() && (str.back() == '/' || str.back() == '\\')) {
+            str.pop_back();
+          }
+          mExcludedPaths.push_back(str);
+        } else {
+          throw Napi::TypeError::New(env, "options.excludedPaths elements must be strings.");
         }
-        mExcludedPaths.push_back(str);
-      } else {
-        throw Napi::TypeError::New(env, "options.excludedPaths elements must be strings.");
       }
     }
 
@@ -105,9 +115,9 @@ NSFW::~NSFW() {
       mRunning = false;
     }
     mWaitPoolEvents.notify_one();
-  }
-  if (mPollThread.joinable()) {
-    mPollThread.join();
+    if (mPollThread.joinable()) {
+      mPollThread.join();
+    }
   }
   if (gcEnabled) {
     instanceCount--;
@@ -160,12 +170,12 @@ void NSFW::StartWorker::OnOK() {
   switch (mStatus) {
     case ALREADY_RUNNING:
       mNSFW->Unref();
-      mDeferred.Reject(Napi::Error::New(env, "This NSFW cannot be started, because it is already running.").Value());
+      mDeferred.Reject(Napi::Error::New(env, "NSFW watcher cannot be started: already running.").Value());
       break;
 
     case COULD_NOT_START:
       mNSFW->Unref();
-      mDeferred.Reject(Napi::Error::New(env, "NSFW was unable to start watching that directory.").Value());
+      mDeferred.Reject(Napi::Error::New(env, "NSFW failed to start: unable to watch directory.").Value());
       break;
 
     case STARTED:
@@ -228,7 +238,7 @@ void NSFW::StopWorker::OnOK() {
     mNSFW->Unref();
     mDeferred.Resolve(Env().Undefined());
   } else {
-    mDeferred.Reject(Napi::Error::New(Env(), "This NSFW cannot be stopped, because it is not running.").Value());
+    mDeferred.Reject(Napi::Error::New(Env(), "NSFW watcher cannot be stopped: not currently running.").Value());
   }
 }
 
@@ -257,7 +267,7 @@ void NSFW::PauseWorker::OnOK() {
   if (mDidPauseEvents) {
     mDeferred.Resolve(Env().Undefined());
   } else {
-    mDeferred.Reject(Napi::Error::New(Env(), "This NSFW could not be paused.").Value());
+    mDeferred.Reject(Napi::Error::New(Env(), "NSFW watcher could not be paused.").Value());
   }
 }
 
@@ -286,7 +296,7 @@ void NSFW::ResumeWorker::OnOK() {
   if (mDidResumeEvents) {
     mDeferred.Resolve(Env().Undefined());
   } else {
-    mDeferred.Reject(Napi::Error::New(Env(), "This NSFW could not be resumed.").Value());
+    mDeferred.Reject(Napi::Error::New(Env(), "NSFW watcher could not be resumed.").Value());
   }
 }
 
@@ -344,7 +354,7 @@ NSFW::UpdateExcludedPathsWorker::UpdateExcludedPathsWorker(Napi::Env env, const
   for(uint32_t i = 0; i < paths.Length(); i++) {
     Napi::Value path = paths[i];
     std::string str = path.ToString().Utf8Value();
-    if (str.back() == '/') {
+    if (!str.empty() && (str.back() == '/' || str.back() == '\\')) {
       str.pop_back();
     }
     mNSFW->mExcludedPaths.push_back(str);
@@ -374,15 +384,21 @@ Napi::Value NSFW::UpdateExcludedPaths(const Napi::CallbackInfo &info) {
 }
 
 void NSFW::updateExcludedPaths() {
-  mInterface->updateExcludedPaths(mExcludedPaths);
+  if (mInterface) {
+    mInterface->updateExcludedPaths(mExcludedPaths);
+  }
 }
 
 void NSFW::pauseQueue() {
-  mQueue->pause();
+  if (mQueue) {
+    mQueue->pause();
+  }
 }
 
 void NSFW::resumeQueue() {
-  mQueue->resume();
+  if (mQueue) {
+    mQueue->resume();
+  }
 }
 
 void NSFW::pollForEvents() {