function updateStreamsList()

in web/js/producer.js [319:356]

• 34 lines of code
• 7 McCabe index (conditional complexity)

    function updateStreamsList(startStream, streamArray ) {

        if(streamArray === undefined) {
            streamArray = [];
        }

        var params = {
            Limit: 100
        };
        if(startStream !== undefined) {
            params.ExclusiveStartStreamName = startStream;
        }

        kinesis.listStreams(params, function(err, data) {
            if(err) {
                console.log(err, err.stack);
            }
            else{
                streamArray.push.apply(streamArray, data.StreamNames);
                if(data.HasMoreStreams) {
                    updateStreamsList(data.StreamNames[data.StreamNames.length - 1], streamArray);
                }
                else {
                    if(streamArray.length > 0) {
                        $("#no-streams-msg").remove();
                        var html = "<optgroup label='Kinesis Streams'>";
                        for (var n = 0; n < streamArray.length; n++) {
                            html += "<option value='" + streamArray[n] + "'>" + streamArray[n] + "</option>";
                        }
                        html += "</optgroup>";
                        $("#btnCreateData").prop("disabled", false);
                        $("#streamName").append(html);
                    }
                }
            }
        });

    }