diff src/protocols/icq/filesession.c @ 2086:424a40f12a6c

[gaim-migrate @ 2096] moving protocols from plugins/ to src/protocols. making it so that you can select which protocols are compiled statically. committer: Tailor Script <[e-mail]>

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/protocols/icq/filesession.c	Tue Jul 31 01:00:39 2001 +0000
@@ -0,0 +1,292 @@
+/* -*- Mode: C; tab-width: 2; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
+
+/*
+ * $Id: filesession.c 2096 2001-07-31 01:00:39Z warmenhoven $
+ *
+ * Copyright (C) 1998-2001, Denis V. Dmitrienko <[e-mail]> and
+ *                          Bill Soudan <[e-mail]>
+ *
+ * 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., 675 Mass Ave, Cambridge, MA 02139, USA.
+ *
+ */
+
+#include <stdlib.h>
+#include <fcntl.h>
+#include <sys/stat.h>
+
+#ifdef _MSVC_
+#include <io.h>
+#define open _open
+#define close _close
+#define read _read
+#define write _write
+#endif
+
+#include "icqlib.h"
+#include "filesession.h"
+#include "stdpackets.h"
+
+icq_FileSession *icq_FileSessionNew(icq_Link *icqlink)
+{
+  icq_FileSession *p=(icq_FileSession *)malloc(sizeof(icq_FileSession));
+
+  if (p)
+  {
+    p->status=0;
+    p->id=0L;
+    p->icqlink=icqlink;
+    p->tcplink=NULL;
+    p->current_fd=-1;
+    p->current_file_num=0;
+    p->current_file_progress=0;
+    p->current_file_size=0;
+    p->files=0L;
+    p->current_speed=100;
+    p->total_bytes=0;
+    p->total_files=0;
+    p->total_transferred_bytes=0;
+    p->working_dir[0]=0;
+    p->user_data=NULL;
+    icq_ListInsert(icqlink->d->icq_FileSessions, 0, p);
+  }
+	
+  return p;
+}
+
+void icq_FileSessionDelete(void *pv)
+{
+  icq_FileSession *p=(icq_FileSession *)pv;
+
+  invoke_callback(p->icqlink, icq_FileNotify)(p, FILE_NOTIFY_CLOSE, 0, 
+    NULL);
+
+  if(p->files) {
+    char **p2=p->files;
+    while(*p2)
+      free(*(p2++));
+    free(p->files);
+    p->files=NULL;
+  }
+
+  if (p->current_fd > -1 ) {
+     close(p->current_fd);
+     p->current_fd=-1;
+  }
+
+  free(p);
+}
+
+int _icq_FindFileSession(void *p, va_list data)
+{
+  icq_FileSession *psession=(icq_FileSession *)p;
+  DWORD uin=va_arg(data, DWORD);
+  unsigned long id=va_arg(data, unsigned long);
+  
+  return (psession->remote_uin == uin) && ( id ? (psession->id == id) : 1 );
+
+}
+
+icq_FileSession *icq_FindFileSession(icq_Link *icqlink, DWORD uin,
+  unsigned long id)
+{
+  return icq_ListTraverse(icqlink->d->icq_FileSessions, _icq_FindFileSession, 
+    uin, id);
+}
+
+void icq_FileSessionSetStatus(icq_FileSession *p, int status)
+{
+  if(status!=p->status)
+  {
+    p->status=status;
+    if(p->id)
+      invoke_callback(p->icqlink, icq_FileNotify)(p, FILE_NOTIFY_STATUS,
+        status, NULL);
+    if (status == FILE_STATUS_SENDING)
+      icq_SocketSetHandler(p->tcplink->socket, ICQ_SOCKET_WRITE,
+        icq_FileSessionSendData, p);
+    else
+      icq_SocketSetHandler(p->tcplink->socket, ICQ_SOCKET_WRITE, NULL, NULL);
+  }
+}
+
+void icq_FileSessionSetHandle(icq_FileSession *p, const char *handle)
+{
+  strncpy(p->remote_handle, handle, 64);
+}
+
+void icq_FileSessionSetCurrentFile(icq_FileSession *p, const char *filename)
+{
+#ifdef _WIN32
+  struct _stat file_status;
+#else
+  struct stat file_status;
+#endif
+  char file[1024];
+
+  strcpy(file, p->working_dir);
+  strcat(file, filename);
+
+  if (p->current_fd>-1) {
+    close(p->current_fd);
+    p->current_fd=-1;
+  }
+
+  strncpy(p->current_file, file, 64);
+  p->current_file_progress=0;
+
+  /* does the file already exist? */
+#ifdef _WIN32
+  if (_stat(file, &file_status)==0) {
+#else
+  if (stat(file, &file_status)==0) {
+#endif
+    p->current_file_progress=file_status.st_size;
+    p->total_transferred_bytes+=file_status.st_size;
+#ifdef _WIN32
+    p->current_fd=open(file, _O_WRONLY | _O_APPEND | _O_BINARY);
+#else
+    p->current_fd=open(file, O_WRONLY | O_APPEND);
+#endif
+  } else {
+#ifdef _WIN32
+    p->current_fd=open(file, _O_WRONLY | _O_CREAT | _O_BINARY, 
+      _S_IREAD|_S_IWRITE);
+#else
+    p->current_fd=open(file, O_WRONLY | O_CREAT, S_IRWXU);
+#endif
+  }
+
+  /* make sure we have a valid filehandle */
+  if (p->current_fd == -1)
+    perror("couldn't open file: ");
+      
+}
+
+void icq_FileSessionPrepareNextFile(icq_FileSession *p)
+{
+  int i=0;
+  char **files=p->files;
+
+  p->current_file_num++;
+
+  while(*files) {
+    i++;
+    if(i==p->current_file_num)
+      break;
+    else
+      files++;
+  }
+
+  if(*files) {
+#ifdef _WIN32
+    struct _stat file_status;
+#else
+    struct stat file_status;
+#endif
+
+    if (p->current_fd>-1) {
+       close(p->current_fd);
+       p->current_fd=-1;
+    }
+
+#ifdef _WIN32
+    if (_stat(*files, &file_status)==0) {
+       char *basename=*files;
+       char *pos=strrchr(basename, '\\');
+#else
+    if (stat(*files, &file_status)==0) {
+       char *basename=*files;
+       char *pos=strrchr(basename, '/');
+#endif
+       if(pos) basename=pos+1;
+       strncpy(p->current_file, basename, 64);
+       p->current_file_progress=0;
+       p->current_file_size=file_status.st_size;
+#ifdef _WIN32
+       p->current_fd=open(*files, _O_RDONLY | _O_BINARY);
+#else
+       p->current_fd=open(*files, O_RDONLY);
+#endif
+    }
+
+    /* make sure we have a valid filehandle */
+    if (p->current_fd == -1)
+       perror("couldn't open file: ");
+  }     
+}        
+
+void icq_FileSessionSendData(icq_FileSession *p)
+{
+  /* for now just send a packet at a time */
+  char buffer[2048];
+  int count=read(p->current_fd, buffer, 2048);
+
+  if(count>0) {
+      icq_Packet *p2=icq_TCPCreateFile06Packet(count, buffer);
+      icq_TCPLinkSend(p->tcplink, p2);
+      p->total_transferred_bytes+=count;
+      p->current_file_progress+=count;
+      icq_FileSessionSetStatus(p, FILE_STATUS_SENDING);
+
+      invoke_callback(p->icqlink, icq_FileNotify)(p, FILE_NOTIFY_DATAPACKET,
+        count, buffer);
+  }
+
+  /* done transmitting if read returns less that 2048 bytes */
+  if(count<2048)
+      icq_FileSessionClose(p);
+
+  return;
+}
+
+/* public */
+
+void icq_FileSessionSetSpeed(icq_FileSession *p, int speed)
+{
+  icq_Packet *packet=icq_TCPCreateFile05Packet(speed);
+
+  icq_TCPLinkSend(p->tcplink, packet);
+}
+
+void icq_FileSessionClose(icq_FileSession *p)
+{
+  icq_TCPLink *plink=p->tcplink;
+
+  /* TODO: handle closing already unallocated filesession? */
+
+  /* if we're attached to a tcplink, unattach so the link doesn't try
+   * to close us, and then close the tcplink */
+  if (plink)
+  {
+    plink->session=0L;
+    icq_TCPLinkClose(plink);
+  }
+
+  icq_ListRemove(p->icqlink->d->icq_FileSessions, p);
+  icq_FileSessionDelete(p);
+}   
+
+void icq_FileSessionSetWorkingDir(icq_FileSession *p, const char *dir)
+{
+  int length = sizeof(p->working_dir);
+  strncpy(p->working_dir, dir, length);
+  p->working_dir[length-1]='\0';
+}  
+
+void icq_FileSessionSetFiles(icq_FileSession *p, char **files)
+{
+  p->files=files;
+}
+