-
Notifications
You must be signed in to change notification settings - Fork 41
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
12 changed files
with
440 additions
and
111 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,7 +1,7 @@ | ||
| { | ||
| "settings": { | ||
| "git.openRepositoryInParentFolders": "never", | ||
| "xstate.server.enable": true | ||
| "xstate.server.enabled": true | ||
| }, | ||
| "folders": [{ "path": "basic" }] | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,112 +1,106 @@ | ||
| import { getTsdk } from '@volar/vscode'; | ||
| import { LanguageClient, TransportKind } from '@volar/vscode/node.js'; | ||
| import { helloRequest } from '@xstate/language-server/protocol'; | ||
| import * as vscode from 'vscode'; | ||
| import { RequestType } from 'vscode-languageserver-protocol'; | ||
| import { assertEvent, assign, createActor, fromPromise, setup } from 'xstate'; | ||
| import { languageClientMachine } from './languageClient'; | ||
| import { assertDefined, assertExtendedEvent } from './utils'; | ||
|
|
||
| let client: LanguageClient | undefined; | ||
| let disposable: vscode.Disposable | undefined; | ||
|
|
||
| export async function activate(context: vscode.ExtensionContext) { | ||
| const { tsdk } = await getTsdk(context); | ||
|
|
||
| client = new LanguageClient( | ||
| 'XState', | ||
| { | ||
| module: context.asAbsolutePath('dist/language-server.js'), | ||
| transport: TransportKind.ipc, | ||
| }, | ||
| { | ||
| documentSelector: [{ language: 'typescript' }], | ||
| initializationOptions: { | ||
| typescript: { tsdk }, | ||
| const extensionMachine = setup({ | ||
| types: {} as { | ||
| context: { | ||
| extensionContext: vscode.ExtensionContext | undefined; | ||
| }; | ||
| events: | ||
| | { type: 'ACTIVATE'; extensionContext: vscode.ExtensionContext } | ||
| | { type: 'DEACTIVATE' }; | ||
| }, | ||
| actions: { | ||
| assignExtensionContext: assign(({ event }) => { | ||
| assertEvent(event, 'ACTIVATE'); | ||
| return { extensionContext: event.extensionContext }; | ||
| }), | ||
| }, | ||
| actors: { | ||
| getTsdk: fromPromise( | ||
| async ({ | ||
| input: extensionContext, | ||
| }: { | ||
| input: vscode.ExtensionContext; | ||
| }) => ({ tsdk: (await getTsdk(extensionContext)).tsdk }), | ||
| ), | ||
| languageClient: languageClientMachine, | ||
| }, | ||
| }).createMachine({ | ||
| context: { | ||
| extensionContext: undefined, | ||
| }, | ||
| initial: 'idle', | ||
| states: { | ||
| idle: { | ||
| on: { | ||
| ACTIVATE: { | ||
| target: 'active', | ||
| actions: 'assignExtensionContext', | ||
| }, | ||
| }, | ||
| }, | ||
| ); | ||
|
|
||
| tryRestartServer(context); | ||
|
|
||
| context.subscriptions.push( | ||
| vscode.workspace.onDidChangeConfiguration((event) => { | ||
| if (event.affectsConfiguration('xstate.server.enable')) { | ||
| tryRestartServer(context); | ||
| } | ||
| }), | ||
| ); | ||
|
|
||
| context.subscriptions.push( | ||
| vscode.commands.registerCommand('xstate.hello', () => { | ||
| const activeTextEditorUri = | ||
| vscode.window.activeTextEditor?.document.uri.toString(); | ||
| sendRequest(helloRequest, { | ||
| name: 'Andarist', | ||
| textDocument: activeTextEditorUri | ||
| ? { | ||
| uri: activeTextEditorUri, | ||
| } | ||
| : undefined, | ||
| }); | ||
| }), | ||
| ); | ||
| } | ||
| active: { | ||
| initial: 'starting', | ||
| states: { | ||
| starting: { | ||
| invoke: { | ||
| src: 'getTsdk', | ||
| id: 'getTsdk', | ||
| input: ({ context }) => { | ||
| assertDefined(context.extensionContext); | ||
| return context.extensionContext; | ||
| }, | ||
| onDone: { | ||
| target: 'running', | ||
| }, | ||
| }, | ||
| }, | ||
| running: { | ||
| invoke: { | ||
| src: 'languageClient', | ||
| input: ({ context, event }) => { | ||
| assertDefined(context.extensionContext); | ||
|
|
||
| export async function deactivate() { | ||
| await stopServer(); | ||
| } | ||
| const extendedEvent = assertExtendedEvent< | ||
| typeof event, | ||
| { | ||
| type: 'xstate.done.actor.getTsdk'; | ||
| output: Pick<Awaited<ReturnType<typeof getTsdk>>, 'tsdk'>; | ||
| } | ||
| >(event, 'xstate.done.actor.getTsdk'); | ||
|
|
||
| async function startServer(_: vscode.ExtensionContext) { | ||
| const currentClient = client; | ||
| if (!currentClient) { | ||
| return; | ||
| } | ||
| if (currentClient.needsStart()) { | ||
| await vscode.window.withProgress( | ||
| { | ||
| location: vscode.ProgressLocation.Window, | ||
| title: 'Starting XState Language Server…', | ||
| return { | ||
| extensionContext: context.extensionContext, | ||
| tsdk: extendedEvent.output.tsdk, | ||
| isServerEnabled: | ||
| vscode.workspace | ||
| .getConfiguration('xstate') | ||
| .get('server.enabled') ?? true, | ||
| }; | ||
| }, | ||
| }, | ||
| }, | ||
| }, | ||
| async () => { | ||
| await currentClient.start(); | ||
| // this `disposable` acts as a placeholder in case some extra cleanup has to be done here in the future | ||
| disposable = new vscode.Disposable(() => {}); | ||
| on: { | ||
| DEACTIVATE: 'deactivated', | ||
| }, | ||
| ); | ||
| } | ||
| } | ||
|
|
||
| async function stopServer() { | ||
| const currentClient = client; | ||
| if (!currentClient) { | ||
| return; | ||
| } | ||
| if (currentClient.needsStop()) { | ||
| disposable?.dispose(); | ||
| }, | ||
| deactivated: { | ||
| type: 'final', | ||
| }, | ||
| }, | ||
| }); | ||
|
|
||
| await currentClient.stop(); | ||
| } | ||
| } | ||
| const extensionActorRef = createActor(extensionMachine).start(); | ||
|
|
||
| async function tryRestartServer(context: vscode.ExtensionContext) { | ||
| await stopServer(); | ||
| if (vscode.workspace.getConfiguration('xstate').get('server.enable')) { | ||
| await startServer(context); | ||
| } | ||
| export async function activate(context: vscode.ExtensionContext) { | ||
| extensionActorRef.send({ type: 'ACTIVATE', extensionContext: context }); | ||
| } | ||
|
|
||
| /** | ||
| * A wrapper function that proxies to the `client.sendRequest`. | ||
| * It's only purpose is to provide better types since `client.sendRequest` has 6 overloads | ||
| * and reports poor error messages partially cause of that. | ||
| * | ||
| * This mitigates the problem by defining 1 focused signature. | ||
| */ | ||
| function sendRequest<P, R, E>( | ||
| request: RequestType<P, R, E>, | ||
| params: P, | ||
| ): Promise<R> | undefined { | ||
| const currentClient = client; | ||
| if (!currentClient) { | ||
| return; | ||
| } | ||
| return currentClient.sendRequest(request, params); | ||
| export async function deactivate() { | ||
| extensionActorRef.send({ type: 'DEACTIVATE' }); | ||
| } |
Oops, something went wrong.