path: root/apsh.c

/* See LICENSE file for copyright and license details. */
#include "common.h"

USAGE("");


void
initialise_parser_context(struct parser_context *ctx)
{
	memset(ctx, 0, sizeof(*ctx));
	ctx->preparser_line_number = 1;
	ctx->tokeniser_line_number = 1;
	ctx->mode_stack = ecalloc(1, sizeof(*ctx->mode_stack));
	ctx->mode_stack->mode = NORMAL_MODE;
	ctx->mode_stack->she_is_comment = 1;
	ctx->parser_state = ecalloc(1, sizeof(*ctx->parser_state));
	ctx->here_documents_next = &ctx->here_documents_first;
}

int
main(int argc, char *argv[])
{
	struct parser_context ctx;
	char *buffer = NULL;
	size_t buffer_size = 0;
	size_t buffer_head = 0;
	size_t buffer_tail = 0;
	ssize_t r;
	size_t n, nremoved;

	ARGBEGIN {
	default:
		usage();
	} ARGEND;

	if (argc)
		usage();

	initialise_parser_context(&ctx);
	ctx.tty_input = isatty(STDIN_FILENO);
	if (ctx.tty_input)
		weprintf("apsh is currently not implemented to be interactive\n");

	for (;;) {
		if (buffer_size - buffer_head < PARSE_RINGBUFFER_MIN_AVAILABLE) {
			if (buffer_tail && buffer_head - buffer_tail <= buffer_tail) {
				memcpy(&buffer[0], &buffer[buffer_tail], buffer_head - buffer_tail);
				buffer_head -= buffer_tail;
				buffer_tail = 0;
			}
			if (buffer_size - buffer_head < PARSE_RINGBUFFER_MIN_AVAILABLE)
				buffer = erealloc(buffer, buffer_size += PARSE_RINGBUFFER_INCREASE_SIZE);
		}

		r = read(STDIN_FILENO, &buffer[buffer_head], buffer_size - buffer_head);
		if (r <= 0) {
			if (!r)
				break;
			eprintf("read <stdin>:");
		}
		n = (size_t)r;

		buffer_head += n;
		buffer_tail += n = parse(&ctx, &buffer[buffer_tail], buffer_head - buffer_tail, &nremoved);
		buffer_head -= nremoved;
	}

	ctx.end_of_file_reached = 1;
	buffer_tail += parse(&ctx, &buffer[buffer_tail], buffer_head - buffer_tail, &nremoved);
	buffer_head -= nremoved;
	if (buffer_tail != buffer_head || ctx.premature_end_of_file)
		eprintf("premature end of file reached\n");

	free(buffer);
	return 0;
}