Invoking API with Rivr about rivr HOT 7 CLOSED

package com.nuecho.rivr.cookbook.dialogue;

import java.io.*;
import java.net.*;
import java.nio.charset.*;

import javax.json.*;

import com.nuecho.rivr.core.channel.*;
import com.nuecho.rivr.core.dialogue.*;
import com.nuecho.rivr.core.util.*;
import com.nuecho.rivr.voicexml.dialogue.*;
import com.nuecho.rivr.voicexml.turn.first.*;
import com.nuecho.rivr.voicexml.turn.input.*;
import com.nuecho.rivr.voicexml.turn.last.*;
import com.nuecho.rivr.voicexml.turn.output.*;
import com.nuecho.rivr.voicexml.turn.output.audio.*;
import com.nuecho.rivr.voicexml.turn.output.grammar.*;

public class Menu implements VoiceXmlDialogue {

    @Override
    public VoiceXmlLastTurn run(VoiceXmlFirstTurn firstTurn, VoiceXmlDialogueContext context) throws Timeout,
            InterruptedException {

        String number = getNumber(context);

        try {
            String processedNumber = invokeApi(number);
            Message resultMessage = new Message("resultMessage",
                                                new SpeechSynthesis("The result is: " + processedNumber));
            DialogueUtils.doTurn(resultMessage, context);
        } catch (IOException exception) {
            Message errorMessage = new Message("errorMessage",
                                               new SpeechSynthesis("An error occured: "
                                                                   + exception.getMessage()));
            DialogueUtils.doTurn(errorMessage, context);
        }

        return new Exit("exit");
    }

    private String getNumber(VoiceXmlDialogueContext context) throws Timeout, InterruptedException {
        String number = null;

        do {
            DtmfRecognition dtmfRecognition = new DtmfRecognition(new GrammarReference("builtin:dtmf/digits"));
            SpeechSynthesis promptText = new SpeechSynthesis("Enter a number.");

            Interaction interaction = OutputTurns.interaction("askNumber")
                                                 .addPrompt(dtmfRecognition, promptText)
                                                 .build(dtmfRecognition, Duration.milliseconds(5));

            VoiceXmlInputTurn inputTurn = DialogueUtils.doTurn(interaction, context);

            if (inputTurn.getRecognitionInfo() != null) {
                JsonArray recognitionResult = inputTurn.getRecognitionInfo().getRecognitionResult();
                number = recognitionResult.getJsonObject(0).getString("interpretation");
            }
        } while (number != null); //loop until valid value is provided

        return number;
    }

    public static String invokeApi(String number) throws IOException {
        URL apiUrl = new URL("http://localhost:8080/api/x/v1/numbers/" + number);
        HttpURLConnection connection = (HttpURLConnection) apiUrl.openConnection();
        connection.setRequestMethod("GET");

        int responseCode = connection.getResponseCode();
        if (responseCode != 200) throw new IOException("Non-200 reponse from API: " + responseCode);

        return readAllStream(connection.getInputStream());
    }

    public static String readAllStream(InputStream inputStream) throws IOException {
        int bufferSize = 1024;
        char[] buffer = new char[bufferSize];
        StringBuilder out = new StringBuilder();
        Reader in = new InputStreamReader(inputStream, StandardCharsets.UTF_8);
        for (int numRead; (numRead = in.read(buffer, 0, buffer.length)) > 0;) {
            out.append(buffer, 0, numRead);
        }
        return out.toString();
    }
}