--- /dev/null
+
+#include "includes.hpp"
+
+
+//
+// TRANSPORT LAYER OPERATIONS
+//
+
+// Attach to the Citadel server
+// FIX (add check for not allowed to log in)
+int CitClient::attach(wxString host, wxString port) {
+ wxString ServerReady;
+ wxIPV4address addr;
+
+ if (sock->IsConnected())
+ sock->Close();
+
+ addr.Hostname(host);
+ addr.Service(504);
+ sock->SetNotify(0);
+ sock->Connect(addr, TRUE);
+ if (sock->IsConnected()) {
+ cout << "Connect succeeded\n" ;
+ serv_gets(ServerReady);
+ initialize_session();
+ return(0);
+ } else {
+ cout << "Connect failed\n" ;
+ return(1);
+ }
+}
+
+
+// constructor
+CitClient::CitClient(void) {
+
+ wxSocketHandler::Master();
+ sock = new wxSocketClient();
+ sock->SetFlags(wxSocketBase::WAITALL);
+ wxSocketHandler::Master().Register(sock);
+ sock->SetNotify(wxSocketBase::REQ_LOST);
+
+ (void)new keepalive(this);
+
+}
+
+
+// destructor
+CitClient::~CitClient(void) {
+ // Be nice and log out from the server if it's still connected
+ sock->Close();
+}
+
+void CitClient::detach(void) {
+ wxString buf;
+
+ if (sock->IsConnected()) {
+ serv_puts("QUIT");
+ serv_gets(buf);
+ sock->Close();
+ }
+}
+
+
+// Is this client connected? Simply return the IsConnected status of sock.
+bool CitClient::IsConnected(void) {
+ return sock->IsConnected();
+}
+
+
+
+// Read a line of text from the server
+void CitClient::serv_gets(wxString& buf) {
+ char charbuf[256];
+ int i;
+
+ cout << "serv_gets() called\n";
+
+ for (i=0; i<(sizeof charbuf); ++i) charbuf[i] = 0;
+
+ buf.Empty();
+ do {
+ while (!sock->IsData()) sock->WaitForRead();
+ sock->Read(charbuf, 1);
+ if (charbuf[0] != 10) {
+ buf.Append(charbuf[0], 1);
+ }
+ } while(charbuf[0] != 10);
+
+ cout << "got: " << buf << "\n";
+}
+
+
+// Write a line of text to the server
+void CitClient::serv_puts(wxString buf) {
+
+ cout << "<<" << buf << "\n" ;
+ sock->Write((const char *)buf, buf.Len());
+ sock->Write("\n", 1);
+}
+
+
+//
+// SESSION LAYER OPERATIONS
+//
+
+
+// Server transaction (returns first digit of server response code)
+int CitClient::serv_trans(
+ wxString& command,
+ wxString& response,
+ wxStringList& xferbuf,
+ wxString desired_room
+ ) {
+
+ int first_digit;
+ int i;
+ wxString buf, pw, junk;
+ bool express_messages_waiting = FALSE;
+
+ // If the caller specified that this transaction must take place
+ // in a particular room, make sure we're in that room.
+ if (desired_room.Length() > 0) {
+ if (desired_room.CmpNoCase(CurrentRoom) != 0) {
+ pw = "";
+ GotoRoom(desired_room, pw, junk);
+ }
+ }
+
+
+ // If a mutex is to be wrapped around this function in the future,
+ // it must begin HERE.
+ Critter.Enter();
+
+ serv_puts(command);
+ serv_gets(response);
+ first_digit = (response.GetChar(0)) - '0';
+
+ if (response.GetChar(3) == '*')
+ express_messages_waiting = TRUE;
+
+ if (first_digit == 1) { // LISTING_FOLLOWS
+ xferbuf.Clear();
+ while (serv_gets(buf), buf != "000") {
+ xferbuf.Add(buf);
+ }
+ } else if (first_digit == 4) { // SEND_LISTING
+ for (i=0; i<xferbuf.Number(); ++i) {
+ buf.Printf("%s", (wxString *)xferbuf.Nth(i)->GetData());
+ serv_puts(buf);
+ }
+ serv_puts("000");
+ }
+
+ // If a mutex is to be wrapped around this function in the future,
+ // it must end HERE.
+ Critter.Leave();
+
+ if (express_messages_waiting) {
+ download_express_messages();
+ }
+
+ return first_digit;
+}
+
+// Shorter forms of serv_trans()
+int CitClient::serv_trans(
+ wxString& command,
+ wxString& response,
+ wxStringList& xferbuf
+ ) {
+ return serv_trans(command, response, xferbuf, "");
+}
+
+int CitClient::serv_trans(wxString& command, wxString& response) {
+ wxStringList junklist;
+ return serv_trans(command, response, junklist);
+}
+
+int CitClient::serv_trans(wxString& command) {
+ wxString junkbuf;
+ return serv_trans(command, junkbuf);
+}
+
+//
+// PRESENTATION LAYER OPERATIONS
+//
+
+
+void CitClient::download_express_messages(void) {
+ wxString sendcmd, recvcmd, x_user, x_sys;
+ wxStringList xferbuf;
+
+ sendcmd = "GEXP";
+ while (serv_trans(sendcmd, recvcmd, xferbuf) == 1) {
+ extract(x_user, recvcmd, 3);
+ extract(x_sys, recvcmd, 4);
+ (void)new express_message(this, x_user, x_sys, xferbuf);
+ }
+}
+
+
+
+// Set up some things that we do at the beginning of every session
+void CitClient::initialize_session(void) {
+ wxStringList info;
+ wxString sendcmd;
+ wxString recvcmd;
+ int i;
+ wxString *infoptr;
+ wxString infoline;
+
+ CurrentRoom = "";
+
+ sendcmd = "IDEN 0|6|001|Daphne";
+ serv_trans(sendcmd);
+
+ sendcmd = "INFO";
+ if (serv_trans(sendcmd, recvcmd, info)==1) {
+ for (i=0; i<info.Number(); ++i) {
+ infoptr = (wxString *) info.Nth(i)->GetData();
+ infoline.Printf("%s", infoptr);
+ switch(i) {
+ case 0: SessionID = atoi(infoline);
+ case 1: NodeName = infoline;
+ case 2: HumanNode = infoline;
+ case 3: FQDN = infoline;
+ case 4: ServerSoftware = infoline;
+ case 5: ServerRev = atoi(infoline);
+ case 6: GeoLocation = infoline;
+ case 7: SysAdmin = infoline;
+ case 8: ServerType = atoi(infoline);
+ case 9: MorePrompt = infoline;
+ case 10: UseFloors = ((atoi(infoline)>0)
+ ? TRUE : FALSE);
+ case 11: PagingLevel = atoi(infoline);
+ }
+ }
+ }
+}
+
+
+
+// Goto a room
+
+bool CitClient::GotoRoom(wxString roomname, wxString password,
+ wxString& server_response) {
+ int retval;
+ wxString sendcmd, recvcmd;
+
+ sendcmd = "GOTO " + roomname + "|" + password;
+ retval = serv_trans(sendcmd, recvcmd);
+ server_response = recvcmd;
+
+ if (retval != 2) return FALSE;
+
+ extract(CurrentRoom, recvcmd.Mid(4, 255), 0);
+ BigMDI->SetStatusText(CurrentRoom, 2);
+ return TRUE;
+}
+
+
+
+
+
+
+
+// This is a simple timer that periodically wakes up and sends a NOOP to the
+// server. This accomplishes two things: it keeps the server connection
+// alive by trickling some data through when it's otherwise idle, and it allows
+// the "check for express messages" loop to activate if it has to.
+
+keepalive::keepalive(CitClient *sock)
+ : wxTimer() {
+
+ which_sock = sock; // Know which instance to refresh
+ Start(15000, FALSE); // Call every 15 seconds
+}
+
+
+void keepalive::Notify(void) {
+ if (which_sock->IsConnected()) {
+ wxString noop = "NOOP";
+ which_sock->serv_trans(noop);
+ }
+}
projects / citadel.git / commitdiff