Completion support for kafka file

Fixes #146

Signed-off-by: azerr <[email protected]>

CHANGELOG.md

@@ -6,6 +6,7 @@ All notable changes to Kafka extension will be documented in this file.
 - Extension API to contribute clusters. See [#123](https://github.com/jlandersen/vscode-kafka/issues/123).
 - declare key/value formats for CONSUMER in kafka file. See [#112](https://github.com/jlandersen/vscode-kafka/issues/112).
 - declare key/value formats for PRODUCER in kafka file. See [#113](https://github.com/jlandersen/vscode-kafka/issues/113).
+ - completion support for property names, values of CONSUMER and PRODUCER block. See [#146](https://github.com/jlandersen/vscode-kafka/issues/146).
 
 ### Changed
 - Improved the "New topic" wizard: the replication factor is now read from the broker configuration. Input will be skipped if value can't be higher than 1. See [#64](https://github.com/jlandersen/vscode-kafka/issues/64).

snippets/producers.json

@@ -40,7 +40,7 @@
             "PRODUCER ${1:key-formatted-message}",
             "topic: ${2:topic_name}",
             "key: ${3:mykeyq}",
-            "key-format: ${3|none,double,float,integer,long,short|}",
+            "key-format: ${3|string,double,float,integer,long,short|}",
             "${4:{{random.words}}}",
             "",
             "###",
@@ -56,7 +56,7 @@
             "PRODUCER ${1:formatted-message}",
             "topic: ${2:topic_name}",
             "key: ${3:mykeyq}",
-            "value-format: ${3|none,double,float,integer,long,short|}",
+            "value-format: ${3|string,double,float,integer,long,short|}",
             "${4:{{random.words}}}",
             "",
             "###",

src/kafka-file/kafkaFileClient.ts

@@ -6,7 +6,7 @@ import { ClusterSettings } from "../settings/clusters";
 import { getLanguageModelCache, LanguageModelCache } from './languageModelCache';
 import { KafkaFileDocument } from "./languageservice/parser/kafkaFileParser";
 import { ConsumerLaunchStateProvider, getLanguageService, LanguageService, ProducerLaunchStateProvider, SelectedClusterProvider } from "./languageservice/kafkaFileLanguageService";
-import { runSafeAsync } from "./runner";
+import { runSafeAsync } from "./utils/runner";
 
 export function startLanguageClient(
     clusterSettings: ClusterSettings,
@@ -41,7 +41,7 @@ export function startLanguageClient(
         { language: "kafka", scheme: "untitled" },
         { language: "kafka", scheme: "kafka" },
     ];
-    
+
     // Code Lenses
     const codeLensProvider = new KafkaFileCodeLensProvider(kafkaFileDocuments, languageService);
     context.subscriptions.push(
@@ -61,6 +61,10 @@ export function startLanguageClient(
         codeLensProvider.refresh();
     });
 
+    // Completion
+    context.subscriptions.push(
+        vscode.languages.registerCompletionItemProvider(documentSelector, new KafkaFileCompletionItemProvider(kafkaFileDocuments, languageService)));
+
     return {
         dispose() {
             kafkaFileDocuments.dispose();
@@ -103,7 +107,7 @@ class AbstractKafkaFileFeature {
     constructor(
         private kafkaFileDocuments: LanguageModelCache<KafkaFileDocument>,
         protected readonly languageService: LanguageService
-    ) {}
+    ) { }
 
     getKafkaFileDocument(document: vscode.TextDocument): KafkaFileDocument {
         return this.kafkaFileDocuments.get(document);
@@ -133,4 +137,23 @@ class KafkaFileCodeLensProvider extends AbstractKafkaFileFeature implements vsco
     refresh() {
         this._onDidChangeCodeLenses.fire();
     }
-}
+}
+
+class KafkaFileCompletionItemProvider extends AbstractKafkaFileFeature implements vscode.CompletionItemProvider {
+
+    constructor(
+        kafkaFileDocuments: LanguageModelCache<KafkaFileDocument>,
+        languageService: LanguageService
+    ) {
+        super(kafkaFileDocuments, languageService);
+    }
+
+    provideCompletionItems(document: vscode.TextDocument, position: vscode.Position, token: vscode.CancellationToken, context: vscode.CompletionContext): vscode.ProviderResult<vscode.CompletionItem[] | vscode.CompletionList> {
+        return runSafeAsync(async () => {
+            const kafkaFileDocument = this.getKafkaFileDocument(document);
+            return this.languageService.doComplete(document, kafkaFileDocument, position);
+        }, new vscode.CompletionList(), `Error while computing code lenses for ${document.uri}`, token);
+    }
+
+}
+

src/kafka-file/languageservice/kafkaFileLanguageService.ts

@@ -1,8 +1,9 @@
-import { CodeLens, TextDocument, Uri } from "vscode";
+import { CodeLens, CompletionList, Position, TextDocument, Uri } from "vscode";
 import { ConsumerLaunchState } from "../../client";
 import { ProducerLaunchState } from "../../client/producer";
 import { KafkaFileDocument, parseKafkaFile } from "./parser/kafkaFileParser";
-import { KafkaFileDocumentCodeLenses } from "./services/codeLensProvider";
+import { KafkaFileCodeLenses } from "./services/codeLensProvider";
+import { KafkaFileCompletion } from "./services/completion";
 
 /**
  * Provider API which gets the state for a given producer.
@@ -27,41 +28,45 @@ export interface SelectedClusterProvider {
 
 /**
  * Kafka language service API.
- * 
+ *
  */
 export interface LanguageService {
     /**
      * Parse the given text document and returns an AST.
-     * 
+     *
      * @param document the text document of a kafka file.
-     * 
+     *
      * @returns the parsed AST.
      */
     parseKafkaFileDocument(document: TextDocument): KafkaFileDocument;
 
     /**
      * Returns the code lenses for the given text document and parsed AST.
-     * 
+     *
      * @param document the text document.
      * @param kafkaFileDocument the parsed AST.
-     * 
+     *
      * @returns the code lenses.
      */
     getCodeLenses(document: TextDocument, kafkaFileDocument: KafkaFileDocument): CodeLens[];
+
+    doComplete(document: TextDocument, kafkaFileDocument: KafkaFileDocument, position: Position): CompletionList | undefined
 }
 
 /**
  * Returns the Kafka file language service which manages codelens, completion, validation features for kafka file.
- * 
+ *
  * @param producerLaunchStateProvider the provider which gets the state for a given producer.
  * @param consumerLaunchStateProvider the provider which gets the state for a given consumer.
- * @param selectedClusterProvider the provider which gets the selected cluster id and name. 
+ * @param selectedClusterProvider the provider which gets the selected cluster id and name.
  */
 export function getLanguageService(producerLaunchStateProvider: ProducerLaunchStateProvider, consumerLaunchStateProvider: ConsumerLaunchStateProvider, selectedClusterProvider: SelectedClusterProvider): LanguageService {
 
-    const kafkaFileDocumentCodeLenses = new KafkaFileDocumentCodeLenses(producerLaunchStateProvider, consumerLaunchStateProvider, selectedClusterProvider);
+    const kafkaFileCodeLenses = new KafkaFileCodeLenses(producerLaunchStateProvider, consumerLaunchStateProvider, selectedClusterProvider);
+    const kafkaFileCompletion = new KafkaFileCompletion();
     return {
         parseKafkaFileDocument: (document: TextDocument) => parseKafkaFile(document),
-        getCodeLenses: kafkaFileDocumentCodeLenses.getCodeLenses.bind(kafkaFileDocumentCodeLenses)
+        getCodeLenses: kafkaFileCodeLenses.getCodeLenses.bind(kafkaFileCodeLenses),
+        doComplete: kafkaFileCompletion.doComplete.bind(kafkaFileCompletion)
     };
 }

src/kafka-file/languageservice/model.ts

@@ -0,0 +1,175 @@
+export interface ModelDefinition {
+    name: string;
+    description: string;
+    enum?: ModelDefinition[];
+}
+
+export const consumerProperties = [
+    {
+        name: "topic",
+        description: "The topic id *[required]*"
+    },
+    {
+        name: "from",
+        description: "The offset from which the consumer group will start consuming messages from. Possible values are: `earliest`, `latest`, or an integer value. *[optional]*.",
+        enum: [
+            {
+                name: "earliest"
+            },
+            {
+                name: "last"
+            },
+            {
+                name: "0"
+            }
+        ]
+    },
+    {
+        name: "key-format",
+        description: "[Deserializer](https://github.com/jlandersen/vscode-kafka/blob/master/docs/Consuming.md#Deserializer) to use for the key *[optional]*.",
+        enum: [
+            {
+                name: "none",
+                description: "No deserializer (ignores content)"
+            },
+            {
+                name: "string",
+                description: "Similar deserializer to the Kafka Java client [org.apache.kafka.common.serialization.StringDeserializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/StringDeserializer.java) which currently only supports `UTF-8` encoding."
+            },
+            {
+                name: "double",
+                description: "Similar deserializer to the Kafka Java client [org.apache.kafka.common.serialization.DoubleDeserializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/DoubleDeserializer.java)."
+            },
+            {
+                name: "float",
+                description: "Similar deserializer to the Kafka Java client [org.apache.kafka.common.serialization.FloatDeserializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/FloatDeserializer.java)."
+            },
+            {
+                name: "integer",
+                description: "Similar deserializer to the Kafka Java client [org.apache.kafka.common.serialization.IntegerDeserializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/IntegerDeserializer.java)."
+            },
+            {
+                name: "long",
+                description: "Similar deserializer to the Kafka Java client [org.apache.kafka.common.serialization.LongDeserializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/LongDeserializer.java)."
+            },
+            {
+                name: "short",
+                description: "Similar deserializer to the Kafka Java client [org.apache.kafka.common.serialization.ShortDeserializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/ShortDeserializer.java)."
+            }
+        ]
+    },
+    {
+        name: "value-format",
+        description: "[Deserializer](https://github.com/jlandersen/vscode-kafka/blob/master/docs/Consuming.md#Deserializer) to use for the value *[optional]*.",
+        enum: [
+            {
+                name: "none",
+                description: "No deserializer (ignores content)"
+            },
+            {
+                name: "string",
+                description: "Similar deserializer to the Kafka Java client [org.apache.kafka.common.serialization.StringDeserializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/StringDeserializer.java) which currently only supports `UTF-8` encoding."
+            },
+            {
+                name: "double",
+                description: "Similar deserializer to the Kafka Java client [org.apache.kafka.common.serialization.DoubleDeserializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/DoubleDeserializer.java)."
+            },
+            {
+                name: "float",
+                description: "Similar deserializer to the Kafka Java client [org.apache.kafka.common.serialization.FloatDeserializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/FloatDeserializer.java)."
+            },
+            {
+                name: "integer",
+                description: "Similar deserializer to the Kafka Java client [org.apache.kafka.common.serialization.IntegerDeserializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/IntegerDeserializer.java)."
+            },
+            {
+                name: "long",
+                description: "Similar deserializer to the Kafka Java client [org.apache.kafka.common.serialization.LongDeserializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/LongDeserializer.java)."
+            },
+            {
+                name: "short",
+                description: "Similar deserializer to the Kafka Java client [org.apache.kafka.common.serialization.ShortDeserializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/ShortDeserializer.java)."
+            }
+        ]
+    },
+    {
+        name: "partitions",
+        description: "the partition number(s), or a partitions range, or a combinaison of partitions ranges *[optional]*. eg:\n* 0\n* 0,1,2\n* 0-2\n* 0,2-3",
+        enum: [
+            {
+                name: "0"
+            }
+        ]
+    }
+] as ModelDefinition[];
+
+export const producerProperties = [
+    {
+        name: "topic",
+        description: "The topic id *[required]*"
+    },
+    {
+        name: "key",
+        description: "The key *[optional]*."
+    },
+    {
+        name: "key-format",
+        description: "[Serializer](https://github.com/jlandersen/vscode-kafka/blob/master/docs/Producing.md#Serializer) to use for the key *[optional]*.",
+        enum: [
+            {
+                name: "string",
+                description: "Similar serializer to the Kafka Java client [org.apache.kafka.common.serialization.StringSerializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/StringSerializer.java) which currently only supports `UTF-8` encoding."
+            },
+            {
+                name: "double",
+                description: "Similar serializer to the Kafka Java client [org.apache.kafka.common.serialization.DoubleSerializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/DoubleSerializer.java)."
+            },
+            {
+                name: "float",
+                description: "Similar serializer to the Kafka Java client [org.apache.kafka.common.serialization.FloatSerializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/FloatSerializer.java)."
+            },
+            {
+                name: "integer",
+                description: "Similar serializer to the Kafka Java client [org.apache.kafka.common.serialization.IntegerSerializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/IntegerSerializer.java)."
+            },
+            {
+                name: "long",
+                description: "Similar serializer to the Kafka Java client [org.apache.kafka.common.serialization.LongSerializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/LongSerializer.java)."
+            },
+            {
+                name: "short",
+                description: "Similar serializer to the Kafka Java client [org.apache.kafka.common.serialization.ShortSerializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/ShortSerializer.java)."
+            }
+        ]
+    },
+    {
+        name: "value-format",
+        description: "[Serializer](https://github.com/jlandersen/vscode-kafka/blob/master/docs/Producing.md#Serializer) to use for the value *[optional]*.",
+        enum: [
+            {
+                name: "string",
+                description: "Similar serializer to the Kafka Java client [org.apache.kafka.common.serialization.StringSerializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/StringSerializer.java) which currently only supports `UTF-8` encoding."
+            },
+            {
+                name: "double",
+                description: "Similar serializer to the Kafka Java client [org.apache.kafka.common.serialization.DoubleSerializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/DoubleSerializer.java)."
+            },
+            {
+                name: "float",
+                description: "Similar serializer to the Kafka Java client [org.apache.kafka.common.serialization.FloatSerializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/FloatSerializer.java)."
+            },
+            {
+                name: "integer",
+                description: "Similar serializer to the Kafka Java client [org.apache.kafka.common.serialization.IntegerSerializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/IntegerSerializer.java)."
+            },
+            {
+                name: "long",
+                description: "Similar serializer to the Kafka Java client [org.apache.kafka.common.serialization.LongSerializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/LongSerializer.java)."
+            },
+            {
+                name: "short",
+                description: "Similar serializer to the Kafka Java client [org.apache.kafka.common.serialization.ShortSerializer](https://github.com/apache/kafka/blob/master/clients/src/main/java/org/apache/kafka/common/serialization/ShortSerializer.java)."
+            }
+        ]
+    }
+] as ModelDefinition[];