pkg://tlf-0.9.30.tar.gz:390608/
tlf-0.9.30/
src/splitscreen.c
downloads
/*
* Tlf - contest logging program for amateur radio operators
* Copyright (C) 2001-2002-2003 Rein Couperus <pa0rct@amsat.org>
*
* 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 Library 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.
*/
/* Splitscreen telnet client */
/* Uses ncurses, so hopefully compatible with much */
/* dave brown n2rjt (dcb@vectorbd.com) wrote most of this */
/* TLF integration and TNC interface by PA0RCT 07/30/2002 */
#define VERSIONSPLIT "V1.4.1 5/18/96 - N2RJT"
#include "splitscreen.h"
#include "get_time.h"
int currow;
int curcol;
int maxtln_loglines = DEFAULTTLN_LOGLINES;
int attr[3];
int color[3][2];
int curattr = 0;
int insmode = TRUE;
char outbuffer[82];
char lanflag;
int lanspotflg = 0;
int tln_loglines = 0;
int view_state = STATE_EDITING;
char tln_input_buffer[2 * BUFFERSIZE ];
void addlog(char *s)
{
extern struct tln_logline *loghead;
extern struct tln_logline *logtail;
extern struct tln_logline *temp;
extern struct tln_logline *viewing;
extern char spot_ptr[MAX_SPOTS][82];
extern char lastmsg[];
extern int ptr;
extern int clusterlog;
int len;
FILE *fp;
for (len = 0; len < strlen(s); len += 80) {
strncpy(spot_ptr[ptr], s+len, 80);
if (strlen(spot_ptr[ptr]) > 5){
lastmsg[0] = '\0';
strncat(lastmsg, spot_ptr[ptr],79);
}
if (clusterlog == 1) {
if ( (fp = fopen("clusterlog","a")) == NULL){
mvprintw(24,0, "Opening clusterlog not possible.");
}
else{
if (strlen(lastmsg) > 20) {
fputs( lastmsg, fp);
fputs("\n", fp);
}
fclose(fp);
}
}
ptr++;
if (ptr > 99) {
for (ptr=10; ptr <= 99; ptr++)
strcpy (spot_ptr[ptr-10], spot_ptr[ptr]);
for (ptr=99; ptr >=89; ptr--)
spot_ptr[ptr][0]='\0';
ptr=90;
}
}
if (tln_loglines >= maxtln_loglines) {
temp = loghead;
loghead = loghead->next;
loghead->prev = NULL;
if (viewing == temp){
viewing = loghead;
}
free(temp->text);
} else {
temp = (struct tln_logline *) malloc (sizeof(struct tln_logline));
}
tln_loglines++;
temp->next = NULL;
temp->text = strdup(s);
temp->attr = curattr;
if (loghead) {
logtail->next = temp;
temp->prev = logtail;
} else {
loghead = temp;
temp->prev = NULL;
}
logtail = temp;
}
int logattr(void)
{
extern struct tln_logline *viewing;
if (!viewing)
return 0;
else
return viewing->attr;
}
char *firstlog(void)
{
extern struct tln_logline *loghead;
extern struct tln_logline *viewing;
viewing = loghead;
view_state = STATE_VIEWING;
return viewing->text;
}
char *lastlog(void)
{
extern struct tln_logline *logtail;
extern struct tln_logline *viewing;
viewing = logtail;
view_state = STATE_VIEWING;
return viewing->text;
}
char *nextlog(void)
{
extern struct tln_logline *loghead;
extern struct tln_logline *logtail;
extern struct tln_logline *viewing;
if (view_state == STATE_EDITING)
viewing = loghead;
else if (viewing)
viewing = viewing->next;
if (viewing) {
view_state = STATE_VIEWING;
return viewing->text;
} else {
viewing = logtail;
return NULL;
}
}
char *prevlog(void)
{
extern struct tln_logline *loghead;
extern struct tln_logline *logtail;
extern struct tln_logline *viewing;
if (view_state == STATE_EDITING)
viewing = logtail;
else if (viewing)
viewing = viewing->prev;
if (viewing) {
view_state = STATE_VIEWING;
return viewing->text;
} else {
viewing = loghead;
return NULL;
}
}
void start_editing(void)
{
extern struct tln_logline *viewing;
extern WINDOW *entwin;
werase(entwin);
currow = curcol = 0;
viewing = NULL;
view_state = STATE_EDITING;
}
void delete_prev_char(void)
{
extern WINDOW *entwin;
int i,j;
int c,cc;
if (currow != 0 || curcol != 0) {
if (curcol-- == 0) {
curcol = COLS-1;
currow--;
}
c = ' ';
for (i=ENTRYROWS-1,j=COLS-1;i>currow || j>=curcol; j--) {
if (j<0) {
j = COLS-1;
i--;
}
cc = mvwinch(entwin,i,j);
waddch(entwin,c);
c = cc;
}
wmove(entwin,currow,curcol);
}
}
void right_arrow(void)
{
extern WINDOW *entwin;
if (++curcol >= COLS) {
curcol = 0;
if (++currow >= ENTRYROWS){
currow = ENTRYROWS-1;
curcol = COLS-1;
}
}
wmove(entwin,currow,curcol);
}
void left_arrow(void)
{
extern WINDOW *entwin;
if (--curcol < 0) {
curcol = COLS-1;
if (--currow < 0) {
currow = curcol = 0;
}
}
wmove(entwin,currow,curcol);
}
void move_eol(void)
{
extern WINDOW *entwin;
currow = ENTRYROWS-1;
curcol = COLS-1;
while ((A_CHARTEXT & mvwinch(entwin,currow,curcol))==' ') {
curcol--;
if (curcol<0) {
if (currow>0) {
currow--;
curcol = COLS-1;
} else {
break;
}
}
}
right_arrow();
}
void gather_input(char *s)
{
extern WINDOW *entwin;
int l = 0;
int i,j;
for (i=j=0;i<ENTRYROWS && j < 81;j++) {
if (j>=COLS) {
j = 0;
i++;
}
if (i<ENTRYROWS)
s[l++] = A_CHARTEXT & mvwinch(entwin,i,j);
}
while (--l>=0) {
if (s[l]!=' ')
break;
else
s[l] = '\0';
}
/*s[++l] = '\n';*/
}
int attop = 0;
int walkup(void)
{ int i;
if (attop)
return 0;
attop = TRUE;
for (i=0; i<LINES-ENTRYROWS-1; i++) {
if (prevlog()==NULL){ /* Not enough to view .. you already see it all */
beep();
return 1;
}
}
return 0;
}
int walkdn(void)
{ int i;
if (!attop)
return 0;
attop = FALSE;
for (i=0; i<LINES-ENTRYROWS-1; i++) {
if (nextlog()==NULL){ /* Not enough to view */
beep();
return 1;
}
}
return 0;
}
int pageup(int lines)
{
extern WINDOW *sclwin;
int i;
char *s = NULL;
walkup();
for (i=0; i<lines; i++) {
wmove(sclwin,0,0);
s = prevlog();
if (s == NULL){
beep();
break;
}
winsertln(sclwin);
wattrset(sclwin, logattr());
mvwaddstr(sclwin,0,0,s);
}
wrefresh(sclwin);
return (s != NULL);
}
int pagedn(int lines)
{
extern WINDOW *sclwin;
int i;
char *s = NULL;
walkdn();
for (i=0; i<lines; i++) {
s = nextlog();
if (s == NULL){
beep();
break;
}
scroll(sclwin);
wattrset(sclwin, logattr());
mvwprintw(sclwin,LINES-ENTRYROWS-1,0,"%s",s);
}
wrefresh(sclwin);
return (s != NULL);
}
char entry_text[BUFFERSIZE];
void viewbottom(void)
{
extern WINDOW *sclwin;
int i;
char *s;
for (i=0; i<LINES-ENTRYROWS; i++) {
if (i==0)
s = lastlog();
else
s = prevlog();
if (s == NULL)
break;
}
werase(sclwin);
while (1) {
s = nextlog();
if (s == NULL)
break;
wattrset(sclwin, logattr());
wprintw(sclwin,"%s\n",s);
}
if (strlen(tln_input_buffer)>0){
wprintw(sclwin,"%s",tln_input_buffer);
}
wrefresh(sclwin);
attop = FALSE;
}
void viewtop(void)
{
extern WINDOW *sclwin;
int i;
char *s;
werase(sclwin);
for (i=0; i<LINES-ENTRYROWS; i++) {
if (i == 0)
s = firstlog();
else
s = nextlog();
if (s == NULL)
break;
wattrset(sclwin, logattr());
wprintw(sclwin,"%s\n",s);
}
wrefresh(sclwin);
attop = FALSE;
}
void resume_editing(void)
{
extern WINDOW *entwin;
extern WINDOW *sclwin;
extern struct tln_logline *viewing;
viewbottom();
wattrset(sclwin, curattr);
werase(entwin);
mvwprintw(entwin,0,0,entry_text);
wmove(entwin,currow,curcol);
viewing = NULL;
view_state = STATE_EDITING;
wrefresh(entwin);
}
void viewlog(void)
{
extern WINDOW *entwin;
extern struct tln_logline *viewing;
attop = FALSE;
if (walkup()){
view_state = STATE_EDITING;
viewing = NULL;
return;
}
gather_input(entry_text);
werase(entwin);
mvwprintw(entwin,0,0,"Viewing data... hit ENTER to return\n");
pageup(SCROLLSIZE);
}
int litflag = FALSE;
int edit_line(int c)
{
extern WINDOW *entwin;
extern WINDOW *sclwin;
if (view_state != STATE_EDITING) {
if (c == '\n')
resume_editing();
else if (c == KEY_PPAGE)
pageup(SCROLLSIZE);
else if (c == KEY_NPAGE)
pagedn(SCROLLSIZE);
else if (c == KEY_UP)
pageup(1);
else if (c == KEY_DOWN)
pagedn(1);
else if (c == KEY_HOME)
viewtop();
else if (c == KEY_END)
viewbottom();
} else {
if (litflag) {
wprintw(sclwin,"Keycode = %o octal\n", c);
wrefresh(sclwin);
litflag = FALSE;
return 0;
}
if (c == erasechar() || c == KEY_BACKSPACE)
delete_prev_char();
else if (c == killchar() || c == KEY_CLEAR)
start_editing();
else if (c == '\n')
return 1;
else if (c == KEY_IC)
insmode = TRUE;
else if (c == KEY_EIC)
insmode = FALSE;
else if (c == KEY_F(10))
insmode = !insmode;
else if (c == KEY_DOWN) {
if (currow < ENTRYROWS)
currow++;
wmove(entwin,currow,curcol);
} else if (c == KEY_UP) {
if (currow > 0)
currow--;
wmove(entwin,currow,curcol);
} else if (c == KEY_PPAGE) {
viewlog();
} else if (c == KEY_LEFT) {
left_arrow();
} else if (c == KEY_RIGHT) {
right_arrow();
} else if (c == KEY_HOME || c == '\001') {
currow = curcol = 0;
wmove(entwin,currow,curcol);
} else if (c == KEY_END || c == '\005') {
move_eol();
} else if (c == KEY_DC) {
right_arrow();
delete_prev_char();
} else if (c == KEY_EOS) {
wclrtobot(entwin);
} else if (c == KEY_EOL) {
wclrtoeol(entwin);
} else if (c == KEY_F(9)) {
litflag = TRUE;
}
else if (c == (c & A_CHARTEXT)){
if (insmode) {
if (currow < ENTRYROWS-1) {
int i;
i = A_CHARTEXT & mvwinch(entwin,currow,COLS-1);
mvwinsch(entwin,currow+1,0,i);
}
mvwinsch(entwin,currow,curcol,c);
} else {
waddch(entwin,c);
}
curcol++;
if (curcol == COLS && currow < ENTRYROWS-1){
curcol = 0;
currow++;
}
wmove(entwin,currow,curcol);
}
}
return 0;
}
void sanitize(char *s)
{
char *t;
for (t=s; *s!='\0'; s++) {
if (*s == '\007')
beep();
else if (*s == '\015')
;
else if (*s < 0)
*t++ = *s - 128;
else
*t++ = *s;
}
*t = '\0';
}
void addtext(char *s)
{
extern int use_rxvt;
extern WINDOW *sclwin;
extern int in_packetclient;
extern int lan_active;
extern char call[];
extern char hiscall[];
extern struct tm *time_ptr;
extern char talkarray[5][62] ;
char lan_out[256];
static char convers_calls[50][6];
static int ci, cl = 0, cc;
static char spotline[160];
static int m =0, t = 0;
static char dxtext[160];
static char spottime[40];
static float freq;
static char *spotpointer;
int i,l;
l = strlen(tln_input_buffer);
if (view_state == STATE_EDITING)
{
if (s[0] == '<' && s[1] != '<')
{ // must be convers
for (ci = 0; ci <= cl; ci++)
{
if (strncmp(convers_calls[ci], s, 5) == 0) break;
}
if (ci <= cl) { // found
cc = ci;
while (cc > 5) cc -=5;
} else
{
if (cl < 48) cl++;
strncpy(convers_calls[cl], s, 5);
cc = cl;
while (cc > 5) cc -=5;
}
cc +=1;
if (use_rxvt == 0) wattron(sclwin, COLOR_PAIR(cc)| A_BOLD);
else wattron(sclwin, COLOR_PAIR(cc));
}
if (strncmp(s, "***", 3) == 0){
cc = 1;
wattron(sclwin, COLOR_PAIR(cc));
cc = 0;
} // end convers
wprintw(sclwin,"%s",s);
wattroff(sclwin, A_BOLD);
if (in_packetclient == 1)
wrefresh(sclwin);
}
// Cluster private spotting interface
if (strncmp(s, call, strlen(call)-1) == 0
&& strlen(s) < 81
&& strchr(s, '>') == NULL) {
mvprintw(24,0, " ");
if ((strlen(s) + strlen(call) +3) < 80){
strcpy (dxtext, s + strlen(call) + 3);
if (dxtext[strlen(dxtext)-1] == '\n')
dxtext[strlen(dxtext)-1] = '\0'; // remove the newline
mvprintw(24,0, dxtext);
mvprintw(12, 29, hiscall);
}
refresh();
spotpointer = strchr(dxtext, ':');
if (spotpointer != NULL && strncmp(spotpointer, ": DX ", 5) == 0){
spotline[0] = '\0';
s[0] = '\0';
strcat (spotline, "DX de ");
strncat (spotline, dxtext , spotpointer - dxtext);
strcat (spotline, ": ");
freq = atof (spotpointer + 5);
if (freq > 1800.0 && freq < 30000.0) {
if (freq >= 100000.0){
sprintf(spotline+16, "%5.1f " , freq);
sprintf(spotline + 26, spotpointer + 14);
}
else if (freq >= 10000.0){
sprintf(spotline+17, "%5.1f " , freq);
sprintf(spotline + 26, spotpointer + 13);
}
else if (freq >= 1000.0) {
sprintf(spotline+18, "%5.1f " , freq);
sprintf (spotline + 26, spotpointer + 12);
}
else {
sprintf(spotline+19, "%5.1f " , freq);
sprintf (spotline + 26, spotpointer + 11);
}
for (m=25; m < 38; m++){
if (spotline[m] > 96) spotline[m] -= 32;
}
strcat (spotline, " ");
get_time();
// strftime(spottime, 80, "%H%MZ", time_ptr); ### bug fix
strftime(spottime, sizeof(spottime), "%H%MZ", time_ptr);
strcpy (spotline+70, spottime);
spotline[75] = '\0';
strcat (spotline, " <<\n");
strcpy (s, spotline);
}
}
else {
for (t=0; t <=4; t++) strcpy(talkarray[t], talkarray[t+1]);
if (s[strlen(s)-1] == '\n')
s[strlen(s)-1] = '\0'; // remove the newline
talkarray[4][0]= '\0';
strncat (talkarray[4], s + 8, 60);
if (s[strlen(s) - 1] != '\n')
strcat (s, "\n"); // we need to restore newline here...
}
}
// end cluster private spotting interface
for (i=0; i<strlen(s); i++) {
if (s[i]=='\n' || i+l+1 >= COLS) {
addlog(tln_input_buffer);
if (lan_active == 1 && lanspotflg == 0){
if ((strlen(tln_input_buffer) > 0) && (tln_input_buffer[0] > 32) && (tln_input_buffer[0] < 126)){
strncpy (lan_out, tln_input_buffer, 78);
strcat (lan_out, "\n");
if (strlen(s) == 0)
tln_input_buffer[0] = '\0';
send_lan_message(CLUSTERMSG ,lan_out);
lan_out[0]='\0';
}
}
l = strlen(tln_input_buffer);
l = -i-1;
} else {
if (s[i] != '\0' ) tln_input_buffer[i+l] = s[i];
}
tln_input_buffer[i+l+1] = '\0';
}
}
/* =========================================
=
= .
= This initializes the packet windows
=
===========================================*/
int init_packet(void){
extern int prsock;
extern int portnum;
extern char pr_hostaddress[16];
extern SCREEN *packetscreen;
extern WINDOW *sclwin;
extern WINDOW *entwin;
extern char spot_ptr[MAX_SPOTS][82];
extern int tncport;
extern int fdSertnc;
extern int fdFIFO;
extern int packetinterface;
extern int tnc_serial_rate;
extern int verbose;
extern int use_rxvt;
extern char tncportname[];
struct termios termattribs;
int addrarg;
int iptr=0;
mode_t mode = 0666;
static int initialized = 0;
tln_input_buffer[0] = '\0';
attr[NORMAL_ATTR] = A_NORMAL;
if (use_rxvt == 0) {
attr[MINE_ATTR] = A_BOLD;
attr[ENTRY_ATTR] = A_BOLD;
} else {
attr[MINE_ATTR] = A_NORMAL;
attr[ENTRY_ATTR] = A_NORMAL;
}
addrarg = 0;
if (initialized == 0) {
initialized = 1;
packetscreen= newterm(NULL, stdout, stdin) ;
start_color();
init_pair(0, 0,0);
init_pair(1, 1,0);
init_pair(2, 2,0);
init_pair(3, 3,0);
init_pair(4, 4,0);
init_pair(5, 5,0);
init_pair(6, 6,0);
init_pair(7, 7,0);
sclwin = newwin(LINES-ENTRYROWS, COLS, 0, 0);
entwin = newwin(ENTRYROWS, COLS, LINES-ENTRYROWS, 0);
scrollok(sclwin,TRUE);
scrollok(entwin,FALSE);
keypad(entwin,TRUE);
intrflush(entwin,FALSE);
wattrset(sclwin, attr[NORMAL_ATTR]);
wattrset(entwin, attr[ENTRY_ATTR]);
noecho();
cbreak();
wtimeout(entwin,30);
wrefresh(sclwin);
start_editing();
curattr = attr[NORMAL_ATTR];
}
if (packetinterface == TELNET_INTERFACE) {
wprintw(sclwin,"Trying %s:%d ... \n",pr_hostaddress, portnum);
wrefresh(sclwin);
if ((prsock=startcli() ) < 0){
wprintw(sclwin,"\n\nconnect failed... please check network connectivity !!\n");
wrefresh(sclwin);
sleep(2);
return(-1);
} else {
wprintw(sclwin,"connected.\n");
}
socktimeout(30);
} else if (packetinterface == TNC_INTERFACE){
if (strlen (tncportname) > 2) {
tncportname[strlen(tncportname)-1] = '\0'; // remove '\n'
if ((fdSertnc = open(tncportname, O_RDWR | O_NONBLOCK)) < 0) {
wprintw(sclwin, "open of %s failed!!!\n", tncportname);
wrefresh(sclwin);
sleep(2);
return(-1);
}
} else {
if (tncport == 1) {
if ((fdSertnc = open("/dev/ttyS0", O_RDWR | O_NONBLOCK)) < 0) {
wprintw(sclwin, "open of /dev/ttyS0 failed!!!\n");
wrefresh(sclwin);
sleep(2);
return(-1);
}
}else if(tncport == 2){
if ((fdSertnc = open("/dev/ttyS1", O_RDWR | O_NONBLOCK)) < 0) {
wprintw(sclwin, "open of /dev/ttyS1 failed!!!\n");
wrefresh(sclwin);
sleep(2);
return(-1);
}
}
}
termattribs.c_iflag = IGNBRK | IGNPAR | IMAXBEL | IXOFF;
termattribs.c_oflag = 0;
termattribs.c_cflag = CS8 | CSTOPB | CREAD | CLOCAL;
termattribs.c_lflag = 0; /* Set some term flags */
/* The ensure there are no read timeouts (possibly writes?) */
termattribs.c_cc[VMIN] = 1;
termattribs.c_cc[VTIME] = 0;
switch(tnc_serial_rate) {
case 1200 : {
cfsetispeed(&termattribs,B1200); /* Set input speed */
cfsetospeed(&termattribs,B1200); /* Set output speed */
break;
}
case 2400 : {
cfsetispeed(&termattribs,B2400); /* Set input speed */
cfsetospeed(&termattribs,B2400); /* Set output speed */
break;
}
case 4800 : {
cfsetispeed(&termattribs,B4800); /* Set input speed */
cfsetospeed(&termattribs,B4800); /* Set output speed */
break;
}
case 9600 : {
cfsetispeed(&termattribs,B9600); /* Set input speed */
cfsetospeed(&termattribs,B9600); /* Set output speed */
break;
}
default: {
cfsetispeed(&termattribs,B9600); /* Set input speed */
cfsetospeed(&termattribs,B9600); /* Set output speed */
}
}
tcsetattr(fdSertnc,TCSANOW,&termattribs); /* Set the serial port */
wprintw(sclwin, "ttyS%d opened...\n", (tncport-1));
wrefresh(sclwin);
} else if (packetinterface == FIFO_INTERFACE) {
wprintw(sclwin,"Trying to open input FIFO \n");
wrefresh(sclwin);
if ((mkfifo("clfile", mode)) < 0) {
wprintw(sclwin, "FIFO clfile exists...\n");
wrefresh(sclwin);
if (verbose == 1) sleep(1);
} else {
wprintw(sclwin, "FIFO clfile made\n");
wrefresh(sclwin);
if (verbose == 1) sleep(1);
}
if ((fdFIFO = open ("clfile", O_RDONLY | O_NONBLOCK)) < 0){
wprintw(sclwin, "Open FIFO failed\n");
wrefresh(sclwin);
sleep(1);
} else {
wprintw(sclwin, "FIFO clfile open\n\n");
wrefresh(sclwin);
if (verbose == 1) sleep(1);
}
}
wprintw(sclwin, "\n Use \":\" to go to tlf !! \n");
wrefresh(sclwin);
for (iptr=0; iptr < 100; iptr++)
spot_ptr[iptr][0]='\0';
return(0);
}
/* =========================================
=
= Throw away the sockets and windows ...
=
=
===========================================*/
int cleanup_telnet (void){
extern int prsock;
extern WINDOW *entwin;
extern SCREEN *mainscreen;
extern int packetinterface;
extern int fdSertnc;
extern int fdFIFO;
if (packetinterface == TELNET_INTERFACE) {
wattrset(entwin,A_NORMAL);
wclear(entwin);
wmove(entwin,1,0);
wrefresh(entwin);
vidattr(A_NORMAL);
endwin();
if (prsock > 0)
close_s(prsock);
} else if (packetinterface == TNC_INTERFACE){
if (fdSertnc > 0) close (fdSertnc);
}else if (packetinterface == FIFO_INTERFACE){
if (fdFIFO > 0) close (fdFIFO);
remove ("./clfile");
}
set_term(mainscreen);
clear();
clear_display();
return(0);
}
/* =========================================
=
= Basic packet loop
=
=
===========================================*/
int packet(){
extern SCREEN *mainscreen;
extern SCREEN *packetscreen;
extern WINDOW *sclwin;
extern WINDOW *entwin;
extern int prsock;
extern int fdSertnc;
extern int fdFIFO;
extern int packetinterface;
extern int in_packetclient;
extern char clusterlogin[];
char line[BUFFERSIZE];
int i = 0;
int c, count;
static int sent_login = 0;
in_packetclient=1;
sleep(1);
set_term(packetscreen);
wclear(sclwin);
wclear(entwin);
count=0;
if ((tln_loglines == 0) && (packetinterface == TELNET_INTERFACE)) {
addtext ("Welcome to TLF telnet\n\n");
if ((sent_login == 0) && (strlen(clusterlogin) > 0) && (packetinterface == TELNET_INTERFACE) && (prsock > 0)){
usputs(prsock, clusterlogin);
sent_login = 1;
addtext ("logged into cluster...\n\n");
sleep(1);
endwin();
set_term(mainscreen);
clear();
clear_display();
in_packetclient=0;
return(0);
}
}
if ((tln_loglines == 0) && (packetinterface == TNC_INTERFACE)) addtext ("Welcome to TLF tnc terminal\n\n");
while(1){
wrefresh(entwin);
while ((c = wgetch(entwin))==-1)
{
if (packetinterface == TELNET_INTERFACE)
{
if (prsock > 0)
{
line[0]='\0';
i=0;
i = recvline(&prsock, line, BUFFERSIZE-1);
}
else
{
wprintw(sclwin, "There is no connection.... going back to tlf !!\n");
wrefresh(sclwin);
sleep(2);
i = -1;
}
if (i == -1)
{
cleanup_telnet();
return(-1);
}
else if (i != -2)
{
line[i] = '\0';
sanitize(line);
addtext(line);
}
}
else if (packetinterface == TNC_INTERFACE)
{
if (fdSertnc > 0)
{
i = read (fdSertnc, line, BUFFERSIZE-1);
if ( i > 0) {
line[i] = '\0';
sanitize(line);
addtext(line);
}
}
}
else if (packetinterface == FIFO_INTERFACE){
if (fdFIFO > 0) {
i = read(fdFIFO, line, BUFFERSIZE-1);
if ( i > 0) {
line[i] = '\0';
sanitize(line);
addtext(line);
}
}
}
}
if (edit_line(c)) {
gather_input(line);
if( strcmp(line, ":exit") == 0) {
endwin();
exit(1);
}
if( strcmp(line, " :exit") == 0){
endwin();
exit(1);
}
if( strcmp(line, ":") == 0) break;
if( strcmp(line, " :") == 0) break;
curattr = attr[MINE_ATTR];
wattrset(sclwin, curattr);
strcat(line,"\n");
addtext(line);
if ((packetinterface == TELNET_INTERFACE) && (prsock > 0)){
usputs(prsock,line);
}
if (packetinterface == TNC_INTERFACE) {
line[strlen(line)-1]=13;
line[strlen(line)]='\0';
write (fdSertnc, line, strlen(line));
}
curattr = attr[NORMAL_ATTR];
wattrset(sclwin, curattr);
wrefresh(sclwin);
start_editing();
}
}
endwin();
set_term(mainscreen);
clear();
clear_display();
in_packetclient=0;
return(0);
}
/* ======================================================
Receive info from cluster
========================================================
*/
int receive_packet(void){
extern int prsock;
extern int packetinterface;
extern int fdSertnc;
extern int fdFIFO;
extern int in_packetclient;
char line[BUFFERSIZE];
int i = 0;
if (in_packetclient ==1)
return(0);
if (packetinterface == TELNET_INTERFACE) {
if (prsock > 0) {
i = recvline(&prsock, line, BUFFERSIZE-1);
view_state = STATE_EDITING;
if (i == -1) {
cleanup_telnet();
return(-1);
} else if (i != -2){
line[i] = '\0';
sanitize(line);
addtext(line);
}
}
} else if (packetinterface == TNC_INTERFACE) {
if(fdSertnc > 0) {
i = read (fdSertnc, line, BUFFERSIZE-1);
if (i > 0) {
line[i] = '\0';
sanitize(line);
addtext(line);
}
}
} else if (packetinterface == FIFO_INTERFACE) {
if (fdFIFO > 0) {
i = read (fdFIFO, line, BUFFERSIZE-1);
if (i > 0) {
line[i] = '\0';
sanitize(line);
addtext(line);
}
}
}
return(0);
}
/* ======================================================
send command to cluster
========================================================
*/
int send_cluster(void) {
extern int fdSertnc;
extern int packetinterface;
extern int prsock;
extern int cluster;
extern int showscore_flag;
char line[61]="";
cluster = CLUSTER;
showscore_flag = 0;
mvprintw(24,0, " ");
mvprintw(24,0, ">");
refresh();
echo();
getnstr(line, 60);
noecho();
strcat(line, "\n");
if (packetinterface == TNC_INTERFACE) {
line[strlen(line)-1]=13;
line[strlen(line)]='\0';
write (fdSertnc, line, strlen(line));
}
if ((packetinterface == TELNET_INTERFACE) && (prsock > 0))
usputs(prsock,line);
attron(COLOR_PAIR(COLOR_GREEN) | A_STANDOUT);
mvprintw(24,0, " ");
refresh();
line[0]='\0';
return(0);
}
