fixes sourceplusplus/sourceplusplus#854

Author: BFergerson

common/src/main/kotlin/spp/jetbrains/status/SourceStatusService.kt

@@ -29,6 +29,9 @@ interface SourceStatusService {
         }
     }
 
+    fun isReady(): Boolean
+    fun isConnected(): Boolean
+
     fun getCurrentStatus(): Pair<SourceStatus, String?>
     fun update(status: SourceStatus, message: String? = null)
 }

marker/src/main/kotlin/spp/jetbrains/marker/SourceMarker.kt

@@ -32,6 +32,7 @@ import spp.jetbrains.marker.source.mark.api.event.SourceMarkEventListener
 import spp.jetbrains.marker.source.mark.guide.GuideMark
 import spp.jetbrains.marker.source.mark.gutter.GutterMark
 import spp.jetbrains.marker.source.mark.inlay.InlayMark
+import spp.jetbrains.status.SourceStatusService
 import spp.protocol.artifact.ArtifactQualifiedName
 
 /**
@@ -101,9 +102,14 @@ class SourceMarker(private val project: Project) {
         if (fileMarker != null) {
             return fileMarker
         } else if (!SourceFileMarker.isFileSupported(psiFile)) {
+            log.warn("File type not supported: ${psiFile.fileType.name}")
             return null
         } else if (psiFile.virtualFile == null || !psiFile.virtualFile.isInLocalFileSystem) {
-            return null //skip in-memory/non-local files
+            log.warn("Skipping in-memory/non-local file: ${psiFile.virtualFile}")
+            return null
+        } else if (!SourceStatusService.getInstance(project).isConnected()) {
+            log.warn("Not connected, skipping source file marker creation for: $psiFile")
+            return null
         }
 
         fileMarker = configuration.sourceFileMarkerProvider.createSourceFileMarker(psiFile)

plugin/src/main/kotlin/spp/jetbrains/sourcemarker/stat/SourceStatusServiceImpl.kt

@@ -45,6 +45,14 @@ class SourceStatusServiceImpl(val project: Project) : SourceStatusService {
     private val reconnectionLock = Any()
     private var reconnectionJob: Job? = null
 
+    override fun isReady(): Boolean {
+        return getCurrentStatus().first == Ready
+    }
+
+    override fun isConnected(): Boolean {
+        return getCurrentStatus().first.let { it == Ready || it == Pending }
+    }
+
     override fun getCurrentStatus(): Pair<SourceStatus, String?> {
         synchronized(statusLock) {
             return Pair(status, message)