[ISSUE#51]: to_json done

igned-off-by: ashish <ashishpatel0720@gmail.com>

Signed-off-by: ashish <ashishpatel0720@gmail.com>

Author: pateash

src/commands/avro.ts

@@ -1,5 +1,6 @@
 import {Command, flags} from '@oclif/command'
-import * as avro from 'avsc' // includes all from avro-js and some more
+import * as avro from 'avsc'
+import * as chalk from 'chalk' // includes all from avro-js and some more
 
 import Logger from '../utilities/logger'
 import Utilities from '../utilities/utilities'
@@ -60,14 +61,21 @@ export default class Avro extends Command {
 
   }
   private toJson(flags: any, args: any) {
+    Utilities.truncateFile(this, flags.output)
     avro.createFileDecoder(flags.file)
-      .on('data', function (data) {
-        return data
+      .on('data', function (recordStr) {
+        Utilities.appendStringToFile(this, flags.output, JSON.stringify(recordStr, null, '\t'))
       })
-
+    Logger.success(this, `output written to file: ${chalk.green(flags.output)}`) // this will output error and exit command
   }
   private toAvro(flags: any, args: any) {
 
   }
 
+  // private checkValidAvsc(){
+  //   // Or we can specify a path to a schema file (not in the browser):
+  //   var type = avro.parse('./Person.avsc');
+  //   var person = {name: 'Bob', address: {city: 'Cambridge', zip: '02139'}};
+  //   var status = type.isValid(person); // Boolean status.
+  // }
 }

src/utilities/utilities.ts

@@ -50,4 +50,16 @@ export default class Utilities {
     // return `${chalk.red(pkg)} ${message}`
 
   }
+
+  public static appendStringToFile(thisRef: any, filePath: string, string: string) {
+    if (!fs.existsSync(filePath))
+      Logger.info(thisRef, `Could not find file: ${chalk.yellow(filePath + ', creating new one')}`) // this will output error and exit command
+    fs.appendFileSync(filePath, string)
+  }
+
+  public static truncateFile(thisRef: any, filePath: string) {
+    if (fs.existsSync(filePath))
+      Logger.info(thisRef, `file found: ${chalk.yellow(filePath + ', truncating')}`) // this will output error and exit command
+    Utilities.writeStringToFile(thisRef, filePath, '') // write nothing
+  }
 }