format files

Author: marle3003

types/mokapi/kafka.d.ts

@@ -101,12 +101,12 @@ export interface ProduceArgs {
      *   });
      * }
      */
-    messages?: Message[]
+    messages?: Message[];
 
     /**
      * The retry option is used if script is executed before Kafka topic is set up.
      */
-    retry?: ProduceRetry
+    retry?: ProduceRetry;
 }
 
 /**
@@ -123,7 +123,7 @@ export interface Message {
     data?: JSONValue;
 
     /** Kafka message value not validating against schema. If data and value are not specified, a random value will be generated based on the topic configuration. */
-    value?: string | number | boolean | null
+    value?: string | number | boolean | null;
 
     /** Kafka message headers. */
     headers?: { [name: string]: JSONValue };
@@ -145,8 +145,8 @@ export interface ProduceResult {
     /** Kafka topic name where the message was written. */
     readonly topic: string;
 
-    //** List of produced Kafka messages */
-    messages: MessageResult[]
+    // ** List of produced Kafka messages */
+    messages: MessageResult[];
 
     /** Kafka partition where the message was written. */
     readonly partition: number;
@@ -172,27 +172,27 @@ export interface MessageResult {
     /**
      * Kafka partition index in which the message was written.
      */
-    readonly partition: number
+    readonly partition: number;
 
     /**
      * Kafka offset of the written message.
      */
-    readonly offset: number
+    readonly offset: number;
 
     /**
      * Kafka written message key.
      */
-    readonly key: string
+    readonly key: string;
 
     /**
      * Kafka written message value.
      */
-    readonly value: string
+    readonly value: string;
 
     /**
      * Kafka written message headers.
      */
-    readonly headers: { [name: string]: string }
+    readonly headers: { [name: string]: string };
 }
 
 /**
@@ -212,7 +212,7 @@ export interface ProduceRetry {
      *   produce({ topic: 'foo', messages: [{ value: 'value-1' }], retry: { maxRetryTime: '30s' } })
      * }
      */
-    maxRetryTime: string | number
+    maxRetryTime: string | number;
 
     /**
      * Initial value used to calculate the wait time
@@ -227,7 +227,7 @@ export interface ProduceRetry {
      *   produce({ topic: 'foo', messages: [{ value: 'value-1' }], retry: { initialRetryTime: '2s' } })
      * }
      */
-    initialRetryTime: string | number
+    initialRetryTime: string | number;
 
     /**
      * Factor for increasing the wait time for next retry.
@@ -236,11 +236,11 @@ export interface ProduceRetry {
      * 3th retry: 4 * 800ms = 3200ms
      * @default 4
      */
-    factor: number
+    factor: number;
 
     /**
      * Max number of retries
      * @default 5
      */
-    retries: number
-}
+    retries: number;
+}

types/mokapi/mokapi-tests.ts

@@ -140,7 +140,7 @@ h = (req: HttpRequest, res: HttpResponse) => {
     // @ts-expect-error
     res.statusCode = "200";
     res.statusCode = 200;
-    res.data.name = 'foo'
+    res.data.name = "foo";
     // @ts-expect-error
     res.body = {};
     // @ts-expect-error

types/mokapi/test/kafka-test.ts

@@ -1,6 +1,6 @@
 import { produce, produceAsync, ProduceResult } from "mokapi/kafka";
 
-produce()
+produce();
 // @ts-expect-error
 produce(1);
 // @ts-expect-error
@@ -45,8 +45,8 @@ produce({
     }],
 });
 
-produceAsync()
-produceAsync({ topic: 'foo' })
+produceAsync();
+produceAsync({ topic: "foo" });
 
 const args: ProduceResult = produce({});
 // @ts-expect-error

types/mokapi/test/yaml-test.ts

@@ -7,7 +7,6 @@ parse("");
 const person = parse("");
 person.name;
 
-
 // @ts-expect-error
 const n1: number = stringify(1);
 const s1: string = stringify({});