var SpeechToTextV1 = require('watson-developer-cloud/speech-to-text/v1');
var fs = require('fs');

var speech_to_text = new SpeechToTextV1 ({
  username: '34be4f5a-4f53-439a-a6c1-ac5b95a5628e',
  password: 'BctKwXYGDTU8'
});

var params = {
  // model: 'en-US_BroadbandModel',
  content_type: 'audio/flac',
  'interim_results': false,
  'max_alternatives': 1,
  'word_confidence': true,
  timestamps: true,
};

// Create the stream.
var recognizeStream = speech_to_text.createRecognizeStream(params);

// Pipe in the audio.
fs.createReadStream('out001.flac').pipe(recognizeStream);

// Pipe out the transcription to a file.
recognizeStream.pipe(fs.createWriteStream('transcription.txt'));

// Get strings instead of buffers from 'data' events.
recognizeStream.setEncoding('utf8');

// Listen for events.
recognizeStream.on('results', function(event) {
  fs.writeFileSync("./data.json", event.results.map(e => e.transcript).join(" "))
  // onEvent('Results:', event);

 });
recognizeStream.on('data', function(event) { onEvent('Data:', event); });
recognizeStream.on('error', function(event) { onEvent('Error:', event); });
recognizeStream.on('close', function(event) { onEvent('Close:', event); });
recognizeStream.on('speaker_labels', function(event) { onEvent('Speaker_Labels:', event); });

// Displays events on the console.
function onEvent(name, event) {
  console.log(name, JSON.stringify(event, null, 2));
};