-
Notifications
You must be signed in to change notification settings - Fork 33
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Provide back button navigation in new cluster wizard
Fixes #21 Signed-off-by: azerr <[email protected]>
- Loading branch information
1 parent
824a615
commit 4d7ca6f
Showing
8 changed files
with
661 additions
and
109 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 |
|---|---|---|
| @@ -0,0 +1,134 @@ | ||
| import { QuickPickItem, window } from "vscode"; | ||
| import { SaslOption } from "../client"; | ||
| import { INPUT_TITLE } from "../constants"; | ||
| import { KafkaExplorer } from "../explorer/kafkaExplorer"; | ||
| import { ClusterSettings } from "../settings/clusters"; | ||
| import { MultiStepInput, showErrorMessage, State } from "./multiStepInput"; | ||
| import { validateBroker, validateClusterName, validateAuthentificationUserName } from "./validators"; | ||
|
|
||
| const DEFAULT_BROKER = 'localhost:9092'; | ||
|
|
||
| interface AddClusterState extends State { | ||
| bootstrap: string; | ||
| name: string; | ||
| saslOption: SaslOption; | ||
| } | ||
|
|
||
| export async function addClusterWizard(clusterSettings: ClusterSettings, explorer: KafkaExplorer): Promise<void> { | ||
|
|
||
| const state: Partial<AddClusterState> = { | ||
| totalSteps: 3 | ||
| }; | ||
|
|
||
| async function collectInputs(state: Partial<AddClusterState>, clusterSettings: ClusterSettings) { | ||
| await MultiStepInput.run(input => inputBrokers(input, state, clusterSettings)); | ||
| } | ||
|
|
||
| async function inputBrokers(input: MultiStepInput, state: Partial<AddClusterState>, clusterSettings: ClusterSettings) { | ||
| state.bootstrap = await input.showInputBox({ | ||
| title: INPUT_TITLE, | ||
| step: input.getStepNumber(), | ||
| totalSteps: state.totalSteps, | ||
| value: state.bootstrap ? state.bootstrap : DEFAULT_BROKER, | ||
| prompt: 'Broker(s) (localhost:9092,localhost:9093...)', | ||
| validate: validateBroker | ||
| }); | ||
| return (input: MultiStepInput) => inputClusterName(input, state, clusterSettings); | ||
| } | ||
|
|
||
| async function inputClusterName(input: MultiStepInput, state: Partial<AddClusterState>, clusterSettings: ClusterSettings) { | ||
| const existingClusterNames = clusterSettings.getAll().map(cluster => cluster.name); | ||
| state.name = await input.showInputBox({ | ||
| title: INPUT_TITLE, | ||
| step: input.getStepNumber(), | ||
| totalSteps: state.totalSteps, | ||
| value: state.name || '', | ||
| prompt: 'Friendly name', | ||
| validationContext: existingClusterNames, | ||
| validate: validateClusterName | ||
| }); | ||
|
|
||
| return (input: MultiStepInput) => inputAuthentification(input, state); | ||
| } | ||
|
|
||
| async function inputAuthentification(input: MultiStepInput, state: Partial<AddClusterState>) { | ||
| const authOptions: QuickPickItem[] = [{ "label": "None" }, { "label": "SASL/PLAIN" }]; | ||
| const authentification = (await input.showQuickPick({ | ||
| title: INPUT_TITLE, | ||
| step: input.getStepNumber(), | ||
| totalSteps: state.totalSteps, | ||
| placeholder: 'Pick authentification', | ||
| items: authOptions, | ||
| activeItem: authOptions[0] | ||
| })).label; | ||
| if (authentification && authentification == authOptions[1].label) { | ||
| state.saslOption = { mechanism: 'plain' }; | ||
| return (input: MultiStepInput) => inputAuthentificationUserName(input, state); | ||
| } | ||
| return undefined; | ||
| } | ||
|
|
||
| async function inputAuthentificationUserName(input: MultiStepInput, state: Partial<AddClusterState>) { | ||
| if (!state.saslOption) { | ||
| return; | ||
| } | ||
| state.saslOption.username = await input.showInputBox({ | ||
| title: INPUT_TITLE, | ||
| step: input.getStepNumber(), | ||
| totalSteps: state.totalSteps, | ||
| value: state.saslOption?.username || '', | ||
| prompt: ' Username', | ||
| validate: validateAuthentificationUserName | ||
| }); | ||
|
|
||
| return (input: MultiStepInput) => inputAuthentificationPassword(input, state); | ||
| } | ||
|
|
||
| async function inputAuthentificationPassword(input: MultiStepInput, state: Partial<AddClusterState>) { | ||
| if (!state.saslOption) { | ||
| return; | ||
| } | ||
| state.saslOption.password = await input.showInputBox({ | ||
| title: INPUT_TITLE, | ||
| step: input.getStepNumber(), | ||
| totalSteps: state.totalSteps, | ||
| value: state.saslOption.password || '', | ||
| prompt: ' Password', | ||
| password: true | ||
| }); | ||
| } | ||
|
|
||
| try { | ||
| await collectInputs(state, clusterSettings); | ||
| } catch (e) { | ||
| showErrorMessage('Error while collecting inputs for creating cluster', e); | ||
| return; | ||
| } | ||
|
|
||
| const addClusterState: AddClusterState = state as AddClusterState; | ||
| const bootstrap = state.bootstrap; | ||
| if (!bootstrap) { | ||
| return; | ||
| } | ||
| const name = state.name; | ||
| if (!name) { | ||
| return; | ||
| } | ||
| const saslOption = addClusterState.saslOption; | ||
| const sanitizedName = name.replace(/[^a-zA-Z0-9]/g, ""); | ||
| const suffix = Buffer.from(bootstrap).toString("base64").replace(/=/g, ""); | ||
|
|
||
| try { | ||
| clusterSettings.upsert({ | ||
| id: `${sanitizedName}-${suffix}`, | ||
| bootstrap, | ||
| name, | ||
| saslOption, | ||
| }); | ||
| explorer.refresh(); | ||
| window.showInformationMessage(`Cluster '${name}' created successfully`); | ||
| } | ||
| catch (error) { | ||
| showErrorMessage(`Error while creating cluster`, error); | ||
| } | ||
| } |
Oops, something went wrong.