/*  MasqMail
    Copyright (C) 2000 Oliver Kurth

    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 2 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, write to the Free Software
    Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*/

#include <signal.h>
#include <stdio.h>
#include <stdlib.h>
#include <setjmp.h>
#include <unistd.h>
#include <ctype.h>

#include "readsock.h"
/*#include "masqmail.h"*/

jmp_buf jmp_timeout;

static void
sig_timeout_handler(int sig)
{
	longjmp(jmp_timeout, 1);
}

static struct sigaction old_sa_alrm;

static void
alarm_on(int timeout)
{
	struct sigaction sa;

	sa.sa_handler = sig_timeout_handler;
	sigemptyset(&(sa.sa_mask));
	sa.sa_flags = 0;
	sigaction(SIGALRM, &sa, &old_sa_alrm);

	if (timeout > 0)
		alarm(timeout);
}

static void
alarm_off()
{
	alarm(0);

	sigaction(SIGALRM, &old_sa_alrm, NULL);
}

static void
_read_chug(FILE * in)
{
	int c = 0;

	c = fgetc(in);
	while (isspace(c) && (c != EOF))
		c = fgetc(in);
	ungetc(c, in);
}

static int
_read_line(FILE * in, char *buf, int buf_len, int timeout)
{
	int p = 0;
	int c = 0;

	c = fgetc(in);
	while ((c != '\n') && (c != EOF) && (p < buf_len - 1)) {
		buf[p++] = c;
		c = fgetc(in);
	}

	buf[p] = '\0';

	if (c == EOF)
		return -1;
	else if (p >= buf_len) {
		ungetc(c, in);
		return -2;
	}

	buf[p++] = c;  /* \n */
	buf[p] = '\0';

	return p;
}

int
read_sockline(FILE * in, char *buf, int buf_len, int timeout, unsigned int flags)
{
	int p = 0;

	if (setjmp(jmp_timeout) != 0) {
		alarm_off();
		return -3;
	}

	alarm_on(timeout);

	/* strip leading spaces */
	if (flags & READSOCKL_CHUG) {
		_read_chug(in);
	}

	p = _read_line(in, buf, buf_len, timeout);

	alarm_off();

	if (p > 1) {
		/* here we are sure that buf[p-1] == '\n' */
		if (flags & READSOCKL_CVT_CRLF) {
			if ((buf[p - 2] == '\r') && (buf[p - 1] == '\n')) {
				buf[p - 2] = '\n';
				buf[p - 1] = 0;
				p--;
			}
		}
	}
	return p;
}

int
read_sockline1(FILE * in, char **pbuf, int *buf_len, int timeout, unsigned int flags)
{
	int p = 0, size = *buf_len;
	char *buf;

	if (setjmp(jmp_timeout) != 0) {
		alarm_off();
		return -3;
	}

	alarm_on(timeout);

	/* strip leading spaces */
	if (flags & READSOCKL_CHUG) {
		_read_chug(in);
	}

	if (!*pbuf)
		*pbuf = g_malloc(size);
	buf = *pbuf;

	while (1) {
		int pp;

		pp = _read_line(in, buf, size, timeout);
		if (pp == -2) {
			*pbuf = realloc(*pbuf, *buf_len + size);
			buf = *pbuf + *buf_len;
			*buf_len += size;
			p += size;
		} else {
			if (pp > 0)
				p += pp;
			else
				p = pp;
			break;
		}
	}

	alarm_off();

	if (p > 1) {
		buf = *pbuf;
		/* here we are sure that buf[p-1] == '\n' */
		if (flags & READSOCKL_CVT_CRLF) {
			if ((buf[p - 2] == '\r') && (buf[p - 1] == '\n')) {
				buf[p - 2] = '\n';
				buf[p - 1] = '\0';
				p--;
			}
		}
	}
	return p;
}