blob: 3e8d5d6ae3f933db405fadb8b3a0be61c78a6b30 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
|
/*
* SIP Communicator, the OpenSource Java VoIP and Instant Messaging client.
*
* Distributable under LGPL license.
* See terms of license at gnu.org.
*/
package net.java.sip.communicator.impl.protocol.icq;
import java.io.*;
import net.java.sip.communicator.service.protocol.*;
import net.java.sip.communicator.service.protocol.event.*;
import net.java.sip.communicator.util.*;
import net.kano.joustsim.oscar.oscar.service.icbm.ft.*;
import net.kano.joustsim.oscar.oscar.service.icbm.ft.FileTransfer;
import net.kano.joustsim.oscar.oscar.service.icbm.ft.controllers.*;
import net.kano.joustsim.oscar.oscar.service.icbm.ft.events.*;
import net.kano.joustsim.oscar.oscar.service.icbm.ft.state.*;
/**
* The Filetransfer imeplementation for ICQ.
* @author Damian Minkov
*/
public class FileTransferImpl
extends AbstractFileTransfer
{
/**
* Logger
*/
private static final Logger logger =
Logger.getLogger(FileTransferImpl.class);
private String id = null;
private Contact contact = null;
private File file = null;
private int direction = -1;
private long transferedBytes;
private FileTransfer fileTransfer;
public FileTransferImpl(
FileTransfer fileTransfer,
String id, Contact contact, File file, int direction)
{
this.fileTransfer = fileTransfer;
this.id = id;
this.contact = contact;
this.file = file;
this.direction = direction;
fileTransfer.addEventListener(new IcqFileTransferEventListener());
}
/**
* Cancels this file transfer. When this method is called transfer should
* be interrupted.
*/
public void cancel()
{
fileTransfer.close();
}
/**
* Returns the number of bytes already transfered through this file transfer.
*
* @return the number of bytes already transfered through this file transfer
*/
public long getTransferedBytes()
{
return transferedBytes;
}
/**
* Uniquie ID that is identifying the FileTransfer
* if the request has been accepted.
*
* @return the id.
*/
public String getID()
{
return id;
}
/**
* The file transfer direction.
* @return returns the direction of the file transfer : IN or OUT.
*/
public int getDirection()
{
return direction;
}
/**
* Returns the contact that we are transferring files with.
* @return the contact.
*/
public Contact getContact()
{
return contact;
}
/**
* Returns the local file that is being transferred or to which we transfer.
*
* @return the file
*/
public File getLocalFile()
{
return file;
}
/**
* @param transferedBytes the transferedBytes to set
*/
public void setTransferedBytes(long transferedBytes)
{
this.transferedBytes = transferedBytes;
}
/**
* Provides support for files sent and received.
*/
class IcqFileTransferEventListener
implements RvConnectionEventListener
{
public void handleEventWithStateChange(
final RvConnection transfer,
RvConnectionState state,
RvConnectionEvent event)
{
if (state==FileTransferState.CONNECTING)
{
// this both are hacks that detects cancels while transfering
// as only connection is closed from other side
// we detect it by receiving ConnectionTimedOutEvent
if(transfer instanceof OutgoingFileTransferImpl)
{
((OutgoingFileTransferImpl)transfer).getStateController().
addControllerListener(new ControllerListener()
{
public void handleControllerSucceeded(
StateController controller, SuccessfulStateInfo info)
{
}
public void handleControllerFailed(
StateController controller, FailedStateInfo info)
{
if(info instanceof FailureEventInfo
&& ((FailureEventInfo)info).getEvent()
instanceof ConnectionTimedOutEvent)
{
FileTransferImpl.this.fireStatusChangeEvent(
FileTransferStatusChangeEvent.CANCELED);
fileTransfer.close();
}
}
});
}
}
else if (state==FileTransferState.FINISHED)
{
fireStatusChangeEvent(FileTransferStatusChangeEvent.COMPLETED);
}
else if (state==FileTransferState.FAILED)
{
if(event instanceof LocallyCancelledEvent)
{
// sender cancels before other party accepts
fireStatusChangeEvent(FileTransferStatusChangeEvent.CANCELED);
}
else if(event instanceof BuddyCancelledEvent)
{
// we receive this event for both when the other party
// rejects and when it accepts but cancels the transfer
if(getTransferedBytes() > 0)
fireStatusChangeEvent(
FileTransferStatusChangeEvent.CANCELED);
else
fireStatusChangeEvent(
FileTransferStatusChangeEvent.REFUSED);
}
else if(event instanceof UnknownErrorEvent)
{
fireStatusChangeEvent(FileTransferStatusChangeEvent.CANCELED);
}
else
{
fireStatusChangeEvent(FileTransferStatusChangeEvent.FAILED);
}
}
else if (state==FileTransferState.TRANSFERRING)
{
if (event instanceof TransferringFileEvent)
{
fireStatusChangeEvent(
FileTransferStatusChangeEvent.IN_PROGRESS);
final ProgressStatusProvider psp = (
(TransferringFileEvent)event).getProgressProvider();
new Thread("Transfer for " + transfer.getBuddyScreenname())
{
public void run()
{
while (transfer.isOpen())
{
long transfered = psp.getPosition();
setTransferedBytes(transfered);
fireProgressChangeEvent(
System.currentTimeMillis(), transfered);
try {
Thread.sleep(100);
}
catch (InterruptedException e)
{}
}
}
}.start();
}
}
}
public void handleEvent(RvConnection transfer, RvConnectionEvent event)
{
}
}
}
|
