/*
 *  XmNap  A Motif napster client
 *  
 *  Copyright (C) 2000 Mats Peterson
 *  
 *  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; see the file COPYING.  If not, write to
 *  the Free Software Foundation, Inc., 59 Temple Place - Suite 330,
 *  Boston, MA 02111-1307, USA.
 *  
 *  Please send any comments/bug reports to
 *  mats_peterson@swipnet.se  (Mats Peterson)
 */

#include <Xm/Xm.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <errno.h>

#include "main.h"
#include "message.h"
#include "connect.h"
#include "command.h"
#include "chat.h"
#include "search.h"
#include "shared.h"
#include "msgbox.h"
#include "chnlist.h"
#include "hotlist.h"
#include "linklist.h"
#include "banlist.h"
#include "ullist.h"
#include "netutil.h"

XtInputId srvCB;

int srvSock, srvPort;
int srvConn = 0;


static String Redirect(String metaServer, int metaPort)
{
    int i, r, metaSock;
    String tmp = XtMalloc(4096);
    char c;

    sprintf(tmp, "Trying metaserver %s...", metaServer);
    SimpleMsg(tmp);

    if (! ConnSock(metaServer, metaPort, &metaSock))
	goto error;

    memset(tmp, 0, strlen(tmp));
    i = 0;

    while (1) {
	while (((r = read(metaSock, &c, 1)) == -1) &&
		(errno == EAGAIN));
	if (r <= 0) {
	    if (r == -1) {
		close(metaSock);
		ErrMsg(strerror(r));
		goto error;
	    }
	    break;
	}
	if (c == '\n')
	    break;
	tmp[i++] = c;
    }

    close(metaSock);
    SimpleMsgRemove();
    return tmp;
    
error:
    XtFree(tmp);
    return NULL;
}


void Connect(String server, int port, int meta)
{
    char loginMsg[256];
    int realPort;
    String tmp, srvString;
    XmString xms;
    static int connInProgress = 0;
    
    if (srvConn)
	return;

    if (connInProgress) {
	ErrMsg("Connect already in progress");
	return;
    }
    connInProgress = 1;

    if (curServer.name)
	XtFree(curServer.name);
    curServer.name = XtNewString(server);
    curServer.port = port;
    curServer.meta = meta;

    if (realSrvName) {
	XtFree(realSrvName);
	realSrvName = NULL;
    }
     
    if (meta) {
	if (! (srvString = Redirect(server, port)))
	    goto error;
	if ((! strlen(srvString)) || (! strchr(srvString, ':'))) {
	    ErrMsg("Got invalid string from metaserver");
	    XtFree(srvString);
	    goto error;
	}
        tmp = strtok(srvString, ":");
	realSrvName = XtNewString(tmp);
	realPort = atoi(strtok(NULL, "\0"));
	XtFree(srvString);
    } else {
	realSrvName = XtNewString(server);
	realPort = port;
    }

    tmp = XtMalloc(sizeof("Connecting to ") +
	    strlen(realSrvName) + sizeof("...") + 1);
    sprintf(tmp, "Connecting to %s...", realSrvName);
    SimpleMsg(tmp);
    XtFree(tmp);

    if (! ConnSock(realSrvName, realPort, &srvSock))
	goto error;
    
    srvCB = XtAppAddInput(appCon, srvSock, (XtPointer)XtInputReadMask,
	    (XtInputCallbackProc)GetMsg, NULL);

    if (! userInfo.registered) {
	if (SendMsg(MSG_CLIENT_REGISTER, userInfo.userName)) {
	    Disconnect(strerror(errno));
	    goto error;
	}
    } else {
	sprintf(loginMsg, "%s %s %04d \"%s\" %d",
		userInfo.userName, userInfo.passWord,
		userInfo.dataPort, client, userInfo.linkType);

	if (SendMsg(MSG_CLIENT_LOGIN, loginMsg)) {
	    Disconnect(strerror(errno));
	    goto error;
	}
    }
 
    XtVaSetValues(mainBtn[0],
	    XmNlabelPixmap, mainPix[6],
	    XmNarmPixmap, armPix[6],
	    NULL);

    xms = XmStringCreateLocalized("Disc");
    XtVaSetValues(mainLbl[0], XmNlabelString, xms, NULL);
    XmStringFree(xms);

    srvConn = 1;

error:
    connInProgress = 0;
    SimpleMsgRemove();
}


void DoLoginStuff(XtPointer closure, XtIntervalId *id)
{
    NotifySharedFiles();
    SendHotList();
    SendAutoCommands();
}


void Disconnect(String err)
{
    XmString xms;
    
    if (strlen(err))
	ErrMsg(err);

    PartAllChannels();
    CloseAllPrivs();
    ClearOnLineList();

    DestroyResultsWin();
    DestroyLinksWin();
    DestroyUlListWin();
    DestroyChnListWin();
    DestroyBanListWin();
    DestroyOnLineListWin();
    
    XtRemoveInput(srvCB);
    close(srvSock);

    XtVaSetValues(mainBtn[0],
	    XmNlabelPixmap, mainPix[0],
	    XmNarmPixmap, armPix[0],
	    NULL);

    xms = XmStringCreateLocalized("Connect");
    XtVaSetValues(mainLbl[0], XmNlabelString, xms, NULL);
    XmStringFree(xms);

    xms = XmStringCreateLocalized("");
    XtVaSetValues(statusLbl1, XmNlabelString, xms, NULL);
    XtVaSetValues(statusLbl2, XmNlabelString, xms, NULL);
    XmStringFree(xms);

    srvConn = 0;
}
.