[AVRO] - All tests working

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

Author: pateash

src/commands/avro.ts

@@ -89,7 +89,7 @@ export default class Avro extends Command {
         // @ts-ignore
         Utilities.appendStringToFile(this, flags.output, JSON.stringify(recordStr))
       })
-    Logger.success(this, `output written to file: ${chalk.green(flags.output)}`) // this will output error and exit command
+    Logger.success(this, `${chalk.blue('Json')} written to file: ${chalk.green(flags.output)}`) // this will output error and exit command
   }
 
   private toAvro(flags: any, args: any) {
@@ -117,6 +117,7 @@ export default class Avro extends Command {
         Logger.warn(this, `${chalk.yellow('[SKIPPING RECORD]')} schema is invalid: ${chalk.yellowBright(JSON.stringify(data))}`)
       }
     })
+    Logger.success(this, `${chalk.blue('Avro')} written to file: ${chalk.green(flags.output)}`) // this will output error and exit command
     avroEncoder.end()
   }
 }

test/commands/avro.test.ts

@@ -19,14 +19,14 @@ describe('avro', () => {
     })
   test
     .stdout()
-    .command(['avro', '-f', 'test/resources/avro/person.avro', '-o', 'output_file.example'])
+    .command(['avro', '-f', 'test/resources/avro/person.avro', '-o', 'test/resources/avro/output/person.json'])
     .exit(0)
     .it('if command not passed', ctx => {
       expect(ctx.stdout).to.contain('Command is empty or not provided')
     })
   test
     .stdout()
-    .command(['avro', '-f', 'test/resources/avro/person.avro', '-o', 'output_file.example', 'unsupported_command'])
+    .command(['avro', '-f', 'test/resources/avro/person.avro', '-o', 'test/resources/avro/output/person.json', 'unsupported_command'])
     .exit(0)
     .it('if command is invalid', ctx => {
       expect(ctx.stdout).to.contain('Unsupported Command')
@@ -43,17 +43,12 @@ describe('avro', () => {
 
   test
     .stdout()
-    .command(['avro', '-f', 'test/resources/avro/person.avro', '-o', 'output_file.example', 'to_avro'])
+    .command(['avro', '-f', 'test/resources/avro/person.json', '-o', 'test/resources/avro/output/person.avro', 'to_avro'])
     .exit(0)
     .it('if schema file path is not passed for to_avro', ctx => {
       expect(ctx.stdout).to.contain('Schema file is not provided')
     })
 
-  // positive cases
-  // 1 - get schema
-  // 2 - to json
-  // 3 - to avro
-
   /* TODO: why this tests is breaking */
   // test
   //   .stdout()
@@ -62,5 +57,22 @@ describe('avro', () => {
   //     expect(ctx.stdout).to.contain('success')
   //   })
 
+  //      setTimeout(() => // TODO: can we remove it and check if we can resolve promise here
+  //         expect(ctx.stdout).to.contain(' [[email protected]] minified:6.5 kB gzip:2.6 kB')
+  //       , 5000) // proving 5 seconds just to be safe
+
+  test
+    .stdout()
+    .command(['avro', '-f', 'test/resources/avro/person.avro', '-o', 'test/resources/avro/output/person.json','to_json'])
+    .it('if to_json commands run with success', ctx => {
+      expect(ctx.stdout).to.contain('success')
+    })
 
+  test
+    .timeout(20000) // added timeout to resolve timeout problem
+    .stdout()
+    .command(['avro', '-f', 'test/resources/avro/person.json', '-o', 'test/resources/avro/output/person.avro', '-t', 'test/resources/avro/person.avsc', 'to_avro'])
+    .it('if to_avro commands run with success', ctx => {
+      expect(ctx.stdout).to.contain('success')
+    })
 })

test/resources/avro/output_complex.avsc renamed to test/resources/avro/output/output_complex.avsc

@@ -0,0 +1 @@
+{"name":"Person","type":"record","fields":[{"name":"ID","type":"long"},{"name":"First","type":"string"},{"name":"Last","type":"string"},{"name":"Phone","type":"string"},{"name":"Age","type":"int"}]}