File:  [ELWIX - Embedded LightWeight unIX -] / libaitcli / src / aitcli.c
Revision 1.2.2.2: download - view: text, annotated - select for diffs - revision graph
Fri Jun 4 12:46:27 2010 UTC (15 years, 6 months ago) by misho
Branches: cli2_0
Diff to: branchpoint 1.2: preferred, unified
prepare to include new cli
and merge with static new funcz

/*************************************************************************
* (C) 2010 AITNET ltd - Sofia/Bulgaria - <misho@aitbg.com>
*  by Michael Pounov <misho@openbsd-bg.org>
*
* $Author: misho $
* $Id: aitcli.c,v 1.2.2.2 2010/06/04 12:46:27 misho Exp $
*
*************************************************************************/
#include "global.h"


#pragma GCC visibility push(hidden)

/*
commands_t cli_stdCmds[] = {
	{ "test", cli_Cmd_Unsupported, "Test - Don`t use default command structure!", "test <cr>", cli_Comp_Filename }, 
	{ "-------", NULL, "---------------------", NULL, NULL }, 
	{ "help", cli_Cmd_Help, "Help screen", "help [command] <cr>", NULL }, 
	{ "exit", cli_Cmd_Exit, "Exit from console", "exit <cr>", NULL }, 
	{ NULL, NULL, NULL, NULL }
};
*/

// ------------------------------------------------

int cli_Errno;
char cli_Error[STRSIZ];

#pragma GCC visibility pop

// cli_GetErrno() Get error code of last operation
inline int
cli_GetErrno()
{
	return cli_Errno;
}

// io_GetError() Get error text of last operation
inline const char *
cli_GetError()
{
	return cli_Error;
}

// cli_SetErr() Set error to variables for internal use!!!
inline void
cli_SetErr(int eno, char *estr, ...)
{
	va_list lst;

	cli_Errno = eno;
	memset(cli_Error, 0, STRSIZ);
	va_start(lst, estr);
	vsnprintf(cli_Error, STRSIZ, estr, lst);
	va_end(lst);
}

// ------------------------------------------------------------

static inline void
clrscrEOL(linebuffer_t * __restrict buf)
{
	register int i;

	if (buf) {
		write(buf->line_out, K_CR, 1);

		for (i = 0; i < buf->line_len; i++)
			write(buf->line_out, K_SPACE, 1);
	}
}

static inline void
printfEOL(linebuffer_t * __restrict buf, int len, int prompt)
{
	if (buf) {
		write(buf->line_out, K_CR, 1);

		if (prompt && buf->line_prompt)
			write(buf->line_out, buf->line_prompt, buf->line_bol);

		write(buf->line_out, buf->line_buf, len == -1 ? buf->line_eol - buf->line_bol: len);
	}
}

static inline void
printfCR(linebuffer_t * __restrict buf, int prompt)
{
	if (buf) {
		write(buf->line_out, K_CR, 1);

		if (prompt)
			if (prompt && buf->line_prompt)
				write(buf->line_out, buf->line_prompt, buf->line_bol);
	}
}

static inline void
printfCLI(linebuffer_t * __restrict buf, const unsigned char *text, int textlen, int prompt)
{
	if (buf && text && textlen) {
		if (prompt && buf->line_prompt)
			write(buf->line_out, buf->line_prompt, buf->line_bol);

		write(buf->line_out, text, textlen);
	}
}

// ------------------------------------------------------------

/*
 * cliNetInit() Initialize Readline if CLI bind to socket
 * @csProg = program name
 * @pty = Master pty
 * @term = stdin termios
 * return: none
*/
/*
void cliNetInit(const char *csProg, int pty, struct termios *term)
{
	struct termios t;
	int on = 1;

	memset(&t, 0, sizeof t);
	if (term)
		t = *term;
	else {
		t.c_lflag = TTYDEF_LFLAG;
		t.c_iflag = TTYDEF_IFLAG;
		t.c_oflag = TTYDEF_OFLAG;
		t.c_cflag = TTYDEF_CFLAG;
		cfsetspeed(&t, B9600);
	}

	t.c_lflag &= ~(ICANON | ISIG | IEXTEN | ECHO | ECHOCTL | ECHOE | ECHOK | ECHOKE | ECHONL | ECHOPRT);
//	t.c_iflag &= ~(ICRNL | BRKINT | INPCK | ISTRIP | IXON);
	t.c_iflag &= ~ICRNL;
	t.c_iflag |= IGNBRK;
	t.c_cc[VMIN] = 1;
	t.c_cc[VTIME] = 0;
	tcsetattr(pty, TCSANOW, &t);

	ioctl(pty, TIOCPKT, &on);

	rl_readline_name = csProg;
	rl_variable_bind("editing-mode", "emacs");

	rl_instream = fdopen(pty, "r");
	rl_outstream = NULL;
}
*/
/*
 * cliNetExec() Execute net CLI main loop
 * @cmdList = Commands list
 * @csPrompt = Prompt text
 * @sock = client socket
 * @term = stdin termios
 * @win = window size of tty
 * return: -1 error, 0 = exit w/^+D, 1 done.
*/
int
cliNetExec(commands_t *cmdList, const char *csPrompt, int sock, struct termios *term, struct winsize *win)
{
	int pty, ret = 0, r, s, alen, attrlen, flg;
	fd_set fds;
	struct timeval tv = { DEFAULT_SOCK_TIMEOUT, 0 };
	u_char buf[BUFSIZ];
	struct telnetAttrs *a, Attr[10];

	switch (forkpty(&pty, NULL, term, win)) {
		case -1:
			LOGERR;
			return -1;
		case 0:
			close(sock);

			ret = cliExec(cmdList, csPrompt) < 0 ? 1 : 0;
			/* spawn Shell mode */
			/*
			execl("/bin/tcsh", "tcsh", NULL);
			*/
			_exit(ret);
		default:
			/* spawn Shell mode */
			telnet_SetCmd(Attr + 0, DO, TELOPT_TTYPE);
			telnet_SetCmd(Attr + 1, WILL, TELOPT_ECHO);
			telnet_Set_SubOpt(Attr + 2, TELOPT_LFLOW, LFLOW_OFF, NULL, 0);
			telnet_Set_SubOpt(Attr + 3, TELOPT_LFLOW, LFLOW_RESTART_XON, NULL, 0);
			telnet_SetCmd(Attr + 4, DO, TELOPT_LINEMODE);
			if ((ret = telnetSend(sock, Attr, 5, NULL, 0, 0)) == -1) {
				cli_Errno = telnet_GetErrno();
				strlcpy(cli_Error, telnet_GetError(), STRSIZ);
				return -1;
			} else
				flg = 0;

			while (42) {
				FD_ZERO(&fds);
				FD_SET(sock, &fds);
				FD_SET(pty, &fds);
				if ((ret = select(FD_SETSIZE, &fds, NULL, NULL, &tv)) < 1) {
					if (!ret)
						cli_SetErr(ETIMEDOUT, "Client session timeout ...");

					break;
				}

				r = FD_ISSET(sock, &fds) ? sock : pty;
				s = FD_ISSET(sock, &fds) ? pty : sock;

				if ((ret = telnetRecv(r, &a, &alen, buf, BUFSIZ)) < 0) {
					if (a)
						free(a);

					if (-2 == ret)
						continue;
					// EOF
					if (-3 == ret)
						shutdown(r, SHUT_RD);
					else {
						cli_Errno = telnet_GetErrno();
						strlcpy(cli_Error, telnet_GetError(), STRSIZ);
					}
					break;
				}
				attrlen = 0;
				if (1 == flg && alen) {
					telnet_SetCmd(&Attr[attrlen++], DONT, TELOPT_SGA);
					telnet_SetCmd(&Attr[attrlen++], DO, TELOPT_ECHO);
				}
				if (2 == flg && alen) {
					telnet_SetCmd(&Attr[attrlen++], WILL, TELOPT_ECHO);
					telnet_Set_SubOpt(&Attr[attrlen++], TELOPT_LFLOW, 
							LFLOW_OFF, NULL, 0);
					telnet_Set_SubOpt(&Attr[attrlen++], TELOPT_LFLOW, 
							LFLOW_RESTART_XON, NULL, 0);
					telnet_SetCmd(&Attr[attrlen++], DONT, TELOPT_LINEMODE);
				}
				if (a)
					free(a);

				if ((ret = telnetSend(s, Attr, pty == s ? 0 : attrlen, buf, ret, 0)) == -1) {
					cli_Errno = telnet_GetErrno();
					strlcpy(cli_Error, telnet_GetError(), STRSIZ);
					break;
				} else
					flg++;
			}

			close(pty);
	}

	return ret;
}

/*
 * cliExec() Execute CLI main loop
 * @cmdList = Commands list
 * @csPrompt = Prompt text
 * return: -1 error, 0 = exit w/^+D, 1 done.
*/
/*
int cliExec(cliCommands_t *cmdList, const char *csPrompt)
{
	char *line, *s, *t, **app, *items[MAX_PROMPT_ITEMS];
	int ret = 0;
	register int i;
	cliCommands_t *cmd = NULL;
	FILE *out;

	inline int inline_help()
	{
		cli_Cmd_Help(cmdList ? cmdList : cli_stdCmds, -1, out, NULL);
		rl_on_new_line();
		return 0;
	}

	char **cli_stdCompletion(const char *text, int start, int end)
	{
		register int i;
		char **matches = NULL;

		char *cmdCompGet(const char *text, int state)
		{
			int len = strlen(text);

			for (i = state; cmdList[i].cmd_name; i++) {
				if (strncmp(cmdList[i].cmd_name, "---", 3) && 
						!strncmp(cmdList[i].cmd_name, text, len))
					return strdup(cmdList[i].cmd_name);
			}

			return NULL;
		}

		if (!start)
			matches = rl_completion_matches(text, cmdCompGet);
		else
			for (i = 0; cmdList[i].cmd_name; i++) {
				if (!cmdList[i].cmd_comp)
					continue;
				if (!strncmp(rl_line_buffer, cmdList[i].cmd_name, strlen(cmdList[i].cmd_name)))
					matches = rl_completion_matches(text, cmdList[i].cmd_comp);
			}

		return matches;
	}
	char *cli_stdCompEntry(const char *ignore, int invoking_key)
	{
		return NULL;
	}
*/
	/* --- main body of CLI --- */
/*
	out = rl_outstream;
	if (!out)
		out = stdout;

	rl_bind_key('?', inline_help);
	if (!rl_attempted_completion_function) 
		cliComp(cli_stdCompletion, cli_stdCompEntry);

	do {
		line = readline(csPrompt);
		if (!line) {	// ^+d
			cli_Printf(out, "\n");
			break;
		}
		// clear whitespaces
		for (s = line; isspace(*s); s++);
		if (*s) {
			for (t = s + strlen(s) - 1; t > s && isspace(*t); t--);
			*++t = 0;
		}

		if (*s) {
			add_history(s);

			memset(items, 0, sizeof(char*) * MAX_PROMPT_ITEMS);
			for (app = items; app < items + MAX_PROMPT_ITEMS - 1 && (*app = strsep(&s, " \t")); 
					*app ? app++ : app);

			// exec_cmd ...
			for (cmd = NULL, i = 0; cmdList[i].cmd_name; i++)
				if (*items[0] && !strncmp(cmdList[i].cmd_name, items[0], strlen(items[0]))) {
					cmd = &cmdList[i];
					break;
				}
			if (!cmd) {
				cli_Printf(out, "Command '%s' not found!\n", items[0]);
				ret = -1;
			} else
				ret = cmd->cmd_func(cmdList, i, out, items);
		}

		free(line);
	} while (ret < 1);

	return ret;
}
*/

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>