WIP

Author: chrismwendt

package.json

@@ -21,6 +21,7 @@
   },
   "dependencies": {
     "@sourcegraph/prettierrc": "^2.2.0",
+    "rxjs": "^6.3.2",
     "vscode-ws-jsonrpc": "^0.0.1-alpha.5"
   }
 }

src/extension.ts

@@ -1,46 +1,68 @@
 import * as sourcegraph from 'sourcegraph'
 import * as rpc from 'vscode-ws-jsonrpc'
+import { BehaviorSubject, Unsubscribable, Subscription, EMPTY, of } from 'rxjs'
+import { map, switchMap, distinct, distinctUntilChanged } from 'rxjs/operators'
 
-const PORT = 1234
+interface FullSettings {
+    'graphql.langserver-address': string
+}
+
+type Settings = Partial<FullSettings>
+
+function connectTo(address: string): Promise<rpc.MessageConnection> {
+    return new Promise(resolve => {
+        const webSocket = new WebSocket('ws://' + address)
+        rpc.listen({
+            webSocket,
+            onConnection: (connection: rpc.MessageConnection) => {
+                resolve(connection)
+            },
+        })
+    })
+}
 
 export function activate(): void {
-    const webSocket = new WebSocket('ws://localhost:' + PORT)
-    rpc.listen({
-        webSocket,
-        onConnection: (connection: rpc.MessageConnection) => {
-            connection.listen()
+    const address = sourcegraph.configuration.get<Settings>().get('graphql.langserver-address')
+    if (!address) {
+        console.log('No graphql.langserver-address was set, exiting.')
+        return
+    }
+    console.log('Connecting to', address)
 
-            sourcegraph.languages.registerHoverProvider(['*'], {
-                provideHover: async (doc, pos) => {
-                    return connection.sendRequest<sourcegraph.Hover>('hover', doc, pos).then(hover => {
-                        return (
-                            hover && {
-                                contents: {
-                                    value: '```python\n' + (hover.contents as any).join('\n') + '\n```',
-                                    kind: sourcegraph.MarkupKind.Markdown,
-                                },
-                            }
-                        )
-                    })
-                },
-            })
+    connectTo(address).then((connection: rpc.MessageConnection) => {
+        console.log('Connected')
+        connection.listen()
+
+        sourcegraph.languages.registerHoverProvider(['*'], {
+            provideHover: async (doc, pos) => {
+                return connection.sendRequest<sourcegraph.Hover>('hover', doc, pos).then(hover => {
+                    return (
+                        hover && {
+                            contents: {
+                                value: '```python\n' + (hover.contents as any).join('\n') + '\n```',
+                                kind: sourcegraph.MarkupKind.Markdown,
+                            },
+                        }
+                    )
+                })
+            },
+        })
 
-            sourcegraph.languages.registerDefinitionProvider(['*'], {
-                provideDefinition: async (doc, pos) => {
-                    return connection.sendRequest<any>('definition', doc, pos).then(definition => {
-                        return (
-                            definition &&
-                            new sourcegraph.Location(
-                                new sourcegraph.URI(doc.uri),
-                                new sourcegraph.Range(
-                                    new sourcegraph.Position(definition.start.line, definition.start.character),
-                                    new sourcegraph.Position(definition.end.line, definition.end.character)
-                                )
+        sourcegraph.languages.registerDefinitionProvider(['*'], {
+            provideDefinition: async (doc, pos) => {
+                return connection.sendRequest<any>('definition', doc, pos).then(definition => {
+                    return (
+                        definition &&
+                        new sourcegraph.Location(
+                            new sourcegraph.URI(doc.uri),
+                            new sourcegraph.Range(
+                                new sourcegraph.Position(definition.start.line, definition.start.character),
+                                new sourcegraph.Position(definition.end.line, definition.end.character)
                             )
                         )
-                    })
-                },
-            })
-        },
+                    )
+                })
+            },
+        })
     })
 }

yarn.lock

@@ -3522,7 +3522,7 @@ ripemd160@^2.0.0, ripemd160@^2.0.1:
 
 rxjs@^6.3.2:
   version "6.3.2"
-  resolved "https://registry.yarnpkg.com/rxjs/-/rxjs-6.3.2.tgz#6a688b16c4e6e980e62ea805ec30648e1c60907f"
+  resolved "https://registry.npmjs.org/rxjs/-/rxjs-6.3.2.tgz#6a688b16c4e6e980e62ea805ec30648e1c60907f"
   dependencies:
     tslib "^1.9.0"