blob: 36edf73ecf095045ed67a2dd55256df2d0a8e2a7 [file] [log] [blame]
/**
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
**/
#include "cli/LineReaderDumb.hpp"
#include <cstddef>
#include <cstdio>
#include <string>
using std::feof;
using std::fflush;
using std::fgetc;
using std::fgets;
using std::printf;
using std::string;
using std::ungetc;
namespace quickstep {
namespace {
static constexpr std::size_t kReadBufferSize = 1024;
} // namespace
LineReaderDumb::LineReaderDumb(const string &default_prompt, const string &continue_prompt)
: LineReader(default_prompt, continue_prompt) {
}
std::string LineReaderDumb::getLineInternal(const bool continuing) {
if (feof(stdin)) {
printf("\n");
return string("");
}
printf("%s", continuing ? continue_prompt_.c_str() : default_prompt_.c_str());
fflush(stdout);
string line;
char read_buffer[kReadBufferSize];
while (fgets(read_buffer, sizeof(read_buffer), stdin) != nullptr) {
line.append(read_buffer);
if ((!line.empty()) && (line.back() == '\n')) {
return line;
} else {
if (feof(stdin)) {
break;
}
const int next_char = fgetc(stdin);
if (next_char == EOF) {
break;
} else {
ungetc(next_char, stdin);
}
}
}
// The above while loop terminated because fgets() hit EOF before it got to
// a newline.
printf("\n");
return string("");
}
} // namespace quickstep