1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157
// This file is part of yash, an extended POSIX shell.
// Copyright (C) 2020 WATANABE Yuki
//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program. If not, see <https://www.gnu.org/licenses/>.
//! Methods about passing [source](crate::source) code to the [parser](crate::parser).
use async_trait::async_trait;
use std::ops::DerefMut;
/// Parameter passed to the input function
///
/// The context is passed to the [input function](Input::next_line) so that it
/// can read the input in a context-dependent way.
#[derive(Debug)]
#[non_exhaustive]
pub struct Context {
is_first_line: bool,
}
impl Default for Context {
fn default() -> Self {
Self {
is_first_line: true,
}
}
}
impl Context {
/// Whether the current line is the first line of the input
#[inline]
#[must_use]
pub fn is_first_line(&self) -> bool {
self.is_first_line
}
/// Sets whether the current line is the first line of the input
///
/// This method is used by the lexer to set the flag. It can also be used in
/// tests to simulate a non-first line. The default value is `true`.
#[inline]
pub fn set_is_first_line(&mut self, is_first_line: bool) {
self.is_first_line = is_first_line;
}
}
/// Error returned by the [Input] function.
pub type Error = std::io::Error;
/// Result of the [Input] function.
pub type Result = std::result::Result<String, Error>;
/// Line-oriented source code reader.
///
/// An `Input` object provides the parser with source code by reading from underlying source.
#[async_trait(?Send)]
pub trait Input {
/// Reads a next line of the source code.
///
/// The input function is line-oriented; that is, this function returns a string that is
/// terminated by a newline unless the end of input (EOF) is reached, in which case the
/// remaining characters up to the EOF must be returned without a trailing newline. If there
/// are no more characters at all, the returned line is empty.
///
/// Errors returned from this function are considered unrecoverable. Once an error is returned,
/// this function should not be called any more.
///
/// For object safety, this async method is declared to return the future in a pinned box.
async fn next_line(&mut self, context: &Context) -> Result;
}
#[async_trait(?Send)]
impl<T> Input for T
where
T: DerefMut,
T::Target: Input,
{
async fn next_line(&mut self, context: &Context) -> Result {
self.deref_mut().next_line(context).await
}
}
/// Input function that reads from a string in memory.
pub struct Memory<'a> {
lines: std::str::SplitInclusive<'a, char>,
}
impl Memory<'_> {
/// Creates a new `Memory` that reads the given string.
pub fn new(code: &str) -> Memory<'_> {
let lines = code.split_inclusive('\n');
Memory { lines }
}
}
#[async_trait(?Send)]
impl Input for Memory<'_> {
async fn next_line(&mut self, _context: &Context) -> Result {
Ok(self.lines.next().unwrap_or("").to_owned())
}
}
#[cfg(test)]
mod tests {
use super::*;
use futures_util::FutureExt;
#[test]
fn memory_empty_source() {
let mut input = Memory::new("");
let context = Context::default();
let line = input.next_line(&context).now_or_never().unwrap().unwrap();
assert_eq!(line, "");
}
#[test]
fn memory_one_line() {
let mut input = Memory::new("one\n");
let context = Context::default();
let line = input.next_line(&context).now_or_never().unwrap().unwrap();
assert_eq!(line, "one\n");
let line = input.next_line(&context).now_or_never().unwrap().unwrap();
assert_eq!(line, "");
}
#[test]
fn memory_three_lines() {
let mut input = Memory::new("one\ntwo\nthree");
let context = Context::default();
let line = input.next_line(&context).now_or_never().unwrap().unwrap();
assert_eq!(line, "one\n");
let line = input.next_line(&context).now_or_never().unwrap().unwrap();
assert_eq!(line, "two\n");
let line = input.next_line(&context).now_or_never().unwrap().unwrap();
assert_eq!(line, "three");
let line = input.next_line(&context).now_or_never().unwrap().unwrap();
assert_eq!(line, "");
}
}