WIP

internal/lsp/server.go

@@ -182,7 +182,8 @@ func (l *LanguageServer) StartDiagnosticsWorker(ctx context.Context) {
 			if ok && len(aggDiags) > 0 {
 				l.diagnosticRequestWorkspace <- fmt.Sprintf("file %q with aggregate violation changed", evt.URI)
 			}
-		case <-l.diagnosticRequestWorkspace:
+		case r := <-l.diagnosticRequestWorkspace:
+			l.logError(fmt.Errorf("diagnostic request workspace: %s", r))
 			// results will be sent in response to the next workspace/diagnostics request
 			err := updateAllDiagnostics(ctx, l.cache, l.loadedConfig, l.clientRootURI)
 			if err != nil {

internal/lsp/server_test.go

@@ -583,6 +583,8 @@ allow := true
 	ctx, cancel := context.WithCancel(context.Background())
 	defer cancel()
 
+	fmt.Fprintf(os.Stderr, "start	\n")
+
 	ls := NewLanguageServer(&LanguageServerOptions{
 		ErrorLog: os.Stderr,
 	})
@@ -592,8 +594,16 @@ allow := true
 	receivedMessages := make(chan jsonrpc2.Request, 1)
 	clientHandler := func(_ context.Context, _ *jsonrpc2.Conn, req *jsonrpc2.Request) (result any, err error) {
 		if req.Method == methodTextDocumentPublishDiagnostics {
+			fmt.Fprintf(os.Stderr, "received diagnostics: %v\n", req.Method)
 			receivedMessages <- *req
 
+			var requestData FileDiagnostics
+			err = json.Unmarshal(*req.Params, &requestData)
+			if err != nil {
+				t.Fatalf("failed to unmarshal diagnostics: %s", err)
+			}
+			fmt.Fprintf(os.Stderr, "received diagnostics: %v items\n", len(requestData.Items))
+
 			return struct{}{}, nil
 		}
 
@@ -691,6 +701,8 @@ allow := true
 	case <-time.After(3 * time.Second):
 		t.Fatalf("timed out waiting for file diagnostics to be sent")
 	}
+
+	t.Fatalf("done")
 }
 
 func createConnections(