mirror of https://github.com/sipwise/jitsi.git
Damian Minkov
17 years ago
parent
8a7cd18b2b
commit
ab6e04cdcf
@ -0,0 +1,69 @@
|
||||
/*
|
||||
* 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.filehistory;
|
||||
|
||||
import org.osgi.framework.*;
|
||||
import net.java.sip.communicator.service.history.*;
|
||||
import net.java.sip.communicator.service.filehistory.*;
|
||||
import net.java.sip.communicator.util.*;
|
||||
|
||||
/**
|
||||
*
|
||||
* @author Damian Minkov
|
||||
*/
|
||||
public class FileHistoryActivator
|
||||
implements BundleActivator
|
||||
{
|
||||
private static Logger logger =
|
||||
Logger.getLogger(FileHistoryActivator.class);
|
||||
|
||||
private FileHistoryServiceImpl fileHistoryService = null;
|
||||
|
||||
/**
|
||||
* Initialize and start file history
|
||||
*
|
||||
* @param bundleContext BundleContext
|
||||
* @throws Exception
|
||||
*/
|
||||
public void start(BundleContext bundleContext) throws Exception
|
||||
{
|
||||
try{
|
||||
|
||||
logger.logEntry();
|
||||
|
||||
ServiceReference refHistory = bundleContext.getServiceReference(
|
||||
HistoryService.class.getName());
|
||||
|
||||
HistoryService historyService = (HistoryService)
|
||||
bundleContext.getService(refHistory);
|
||||
|
||||
//Create and start the file history service.
|
||||
fileHistoryService =
|
||||
new FileHistoryServiceImpl();
|
||||
// set the history service
|
||||
fileHistoryService.setHistoryService(historyService);
|
||||
|
||||
fileHistoryService.start(bundleContext);
|
||||
|
||||
bundleContext.registerService(
|
||||
FileHistoryService.class.getName(), fileHistoryService, null);
|
||||
|
||||
logger.info("File History Service ...[REGISTERED]");
|
||||
}
|
||||
finally
|
||||
{
|
||||
logger.logExit();
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
public void stop(BundleContext bundleContext) throws Exception
|
||||
{
|
||||
if(fileHistoryService != null)
|
||||
fileHistoryService.stop(bundleContext);
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,760 @@
|
||||
/*
|
||||
* 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.filehistory;
|
||||
|
||||
import java.io.*;
|
||||
import java.util.*;
|
||||
import org.osgi.framework.*;
|
||||
import net.java.sip.communicator.service.contactlist.*;
|
||||
import net.java.sip.communicator.service.filehistory.*;
|
||||
import net.java.sip.communicator.service.history.*;
|
||||
import net.java.sip.communicator.service.history.records.*;
|
||||
import net.java.sip.communicator.service.protocol.*;
|
||||
import net.java.sip.communicator.service.protocol.event.*;
|
||||
import net.java.sip.communicator.util.*;
|
||||
|
||||
/**
|
||||
* File History Service stores info for file transfers from various protocols.
|
||||
* Uses History Service.
|
||||
*
|
||||
* @author Damian Minkov
|
||||
*/
|
||||
public class FileHistoryServiceImpl
|
||||
implements FileHistoryService,
|
||||
ServiceListener,
|
||||
FileTransferStatusListener,
|
||||
FileTransferListener
|
||||
{
|
||||
/**
|
||||
* The logger for this class.
|
||||
*/
|
||||
private static final Logger logger =
|
||||
Logger.getLogger(FileHistoryServiceImpl.class);
|
||||
|
||||
private static String[] STRUCTURE_NAMES =
|
||||
new String[] { "file", "dir", "date", "status"};
|
||||
|
||||
private static HistoryRecordStructure recordStructure =
|
||||
new HistoryRecordStructure(STRUCTURE_NAMES);
|
||||
|
||||
// the field used to search by keywords
|
||||
private static final String SEARCH_FIELD = "file";
|
||||
|
||||
/**
|
||||
* The BundleContext that we got from the OSGI bus.
|
||||
*/
|
||||
private BundleContext bundleContext = null;
|
||||
|
||||
private HistoryService historyService = null;
|
||||
|
||||
/**
|
||||
* Starts the service. Check the current registerd protocol providers
|
||||
* which supports FileTransfer and adds a listener to them.
|
||||
*
|
||||
* @param bc BundleContext
|
||||
*/
|
||||
public void start(BundleContext bc)
|
||||
{
|
||||
logger.debug("Starting the file history implementation.");
|
||||
this.bundleContext = bc;
|
||||
|
||||
// start listening for newly register or removed protocol providers
|
||||
bc.addServiceListener(this);
|
||||
|
||||
ServiceReference[] protocolProviderRefs = null;
|
||||
try
|
||||
{
|
||||
protocolProviderRefs = bc.getServiceReferences(
|
||||
ProtocolProviderService.class.getName(),
|
||||
null);
|
||||
}
|
||||
catch (InvalidSyntaxException ex)
|
||||
{
|
||||
// this shouldn't happen since we're providing no parameter string
|
||||
// but let's log just in case.
|
||||
logger.error(
|
||||
"Error while retrieving service refs", ex);
|
||||
return;
|
||||
}
|
||||
|
||||
// in case we found any
|
||||
if (protocolProviderRefs != null)
|
||||
{
|
||||
logger.debug("Found "
|
||||
+ protocolProviderRefs.length
|
||||
+ " already installed providers.");
|
||||
for (int i = 0; i < protocolProviderRefs.length; i++)
|
||||
{
|
||||
ProtocolProviderService provider = (ProtocolProviderService) bc
|
||||
.getService(protocolProviderRefs[i]);
|
||||
|
||||
this.handleProviderAdded(provider);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Stops the service.
|
||||
*
|
||||
* @param bc BundleContext
|
||||
*/
|
||||
public void stop(BundleContext bc)
|
||||
{
|
||||
bc.removeServiceListener(this);
|
||||
|
||||
ServiceReference[] protocolProviderRefs = null;
|
||||
try
|
||||
{
|
||||
protocolProviderRefs = bc.getServiceReferences(
|
||||
ProtocolProviderService.class.getName(),
|
||||
null);
|
||||
}
|
||||
catch (InvalidSyntaxException ex)
|
||||
{
|
||||
// this shouldn't happen since we're providing no parameter string
|
||||
// but let's log just in case.
|
||||
logger.error("Error while retrieving service refs", ex);
|
||||
return;
|
||||
}
|
||||
|
||||
// in case we found any
|
||||
if (protocolProviderRefs != null)
|
||||
{
|
||||
for (int i = 0; i < protocolProviderRefs.length; i++)
|
||||
{
|
||||
ProtocolProviderService provider = (ProtocolProviderService) bc
|
||||
.getService(protocolProviderRefs[i]);
|
||||
|
||||
this.handleProviderRemoved(provider);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Used to attach the File History Service to existing or
|
||||
* just registered protocol provider. Checks if the provider has implementation
|
||||
* of OperationSetFileTransfer
|
||||
*
|
||||
* @param provider ProtocolProviderService
|
||||
*/
|
||||
private void handleProviderAdded(ProtocolProviderService provider)
|
||||
{
|
||||
logger.debug("Adding protocol provider " + provider.getProtocolName());
|
||||
|
||||
// check whether the provider has a file transfer operation set
|
||||
OperationSetFileTransfer opSetFileTransfer =
|
||||
(OperationSetFileTransfer) provider
|
||||
.getOperationSet(OperationSetFileTransfer.class);
|
||||
|
||||
if (opSetFileTransfer != null)
|
||||
{
|
||||
opSetFileTransfer.addFileTransferListener(this);
|
||||
}
|
||||
else
|
||||
{
|
||||
logger.trace("Service did not have a file transfer op. set.");
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Removes the specified provider from the list of currently known providers
|
||||
*
|
||||
* @param provider the ProtocolProviderService that has been unregistered.
|
||||
*/
|
||||
private void handleProviderRemoved(ProtocolProviderService provider)
|
||||
{
|
||||
OperationSetFileTransfer opSetFileTransfer =
|
||||
(OperationSetFileTransfer) provider
|
||||
.getOperationSet(OperationSetFileTransfer.class);
|
||||
|
||||
if (opSetFileTransfer != null)
|
||||
{
|
||||
opSetFileTransfer.addFileTransferListener(this);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Set the history service.
|
||||
*
|
||||
* @param historyService HistoryService
|
||||
*/
|
||||
public void setHistoryService(HistoryService historyService)
|
||||
{
|
||||
this.historyService = historyService;
|
||||
}
|
||||
|
||||
/**
|
||||
* Gets all the history readers for the contacts in the given MetaContact
|
||||
* @param contact MetaContact
|
||||
* @return Hashtable
|
||||
*/
|
||||
private Map<Contact, HistoryReader> getHistoryReaders(MetaContact contact)
|
||||
{
|
||||
Map<Contact, HistoryReader> readers = new Hashtable<Contact, HistoryReader>();
|
||||
Iterator<Contact> iter = contact.getContacts();
|
||||
while (iter.hasNext())
|
||||
{
|
||||
Contact item = iter.next();
|
||||
|
||||
try
|
||||
{
|
||||
History history = this.getHistory(null, item);
|
||||
readers.put(item, history.getReader());
|
||||
}
|
||||
catch (IOException e)
|
||||
{
|
||||
logger.error("Could not read history", e);
|
||||
}
|
||||
}
|
||||
return readers;
|
||||
}
|
||||
|
||||
private FileRecord createFileRecordFromHistoryRecord(HistoryRecord hr)
|
||||
{
|
||||
String file = null;
|
||||
String dir = null;
|
||||
long date = 0;
|
||||
String status = null;
|
||||
|
||||
for (int i = 0; i < hr.getPropertyNames().length; i++)
|
||||
{
|
||||
String propName = hr.getPropertyNames()[i];
|
||||
|
||||
if (propName.equals(STRUCTURE_NAMES[0]))
|
||||
file = hr.getPropertyValues()[i];
|
||||
else if (propName.equals(STRUCTURE_NAMES[1]))
|
||||
dir = hr.getPropertyValues()[i];
|
||||
else if (propName.equals(STRUCTURE_NAMES[2]))
|
||||
{
|
||||
try
|
||||
{
|
||||
date = Long.valueOf(hr.getPropertyValues()[i]);
|
||||
}
|
||||
catch (NumberFormatException e)
|
||||
{
|
||||
logger.error("Wrong date : " + hr.getPropertyValues()[i]);
|
||||
}
|
||||
}
|
||||
else if (propName.equals(STRUCTURE_NAMES[3]))
|
||||
status = hr.getPropertyValues()[i];
|
||||
}
|
||||
|
||||
return new FileRecord(dir, date, new File(file), status);
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns all the file transfers made after the given date
|
||||
*
|
||||
* @param contact MetaContact the receiver or sender of the file
|
||||
* @param startDate Date the start date of the transfers
|
||||
* @return Collection of FileRecords
|
||||
* @throws RuntimeException
|
||||
*/
|
||||
public Collection<FileRecord> findByStartDate(
|
||||
MetaContact contact, Date startDate)
|
||||
throws RuntimeException
|
||||
{
|
||||
TreeSet<FileRecord> result =
|
||||
new TreeSet<FileRecord>(new FileRecordComparator());
|
||||
// get the readers for this contact
|
||||
Map<Contact, HistoryReader> readers = getHistoryReaders(contact);
|
||||
|
||||
for (Map.Entry<Contact, HistoryReader> readerEntry : readers.entrySet())
|
||||
{
|
||||
HistoryReader reader = readerEntry.getValue();
|
||||
|
||||
// add the progress listeners
|
||||
Iterator<HistoryRecord> recs = reader.findByStartDate(startDate);
|
||||
while (recs.hasNext())
|
||||
{
|
||||
result.add(createFileRecordFromHistoryRecord(recs.next()));
|
||||
}
|
||||
}
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns all the file transfers made before the given date
|
||||
*
|
||||
* @param contact MetaContact the receiver or sender of the file
|
||||
* @param endDate Date the end date of the transfers
|
||||
* @return Collection of FileRecords
|
||||
* @throws RuntimeException
|
||||
*/
|
||||
public Collection<FileRecord> findByEndDate(MetaContact contact, Date endDate)
|
||||
throws RuntimeException
|
||||
{
|
||||
TreeSet<FileRecord> result =
|
||||
new TreeSet<FileRecord>(new FileRecordComparator());
|
||||
// get the readers for this contact
|
||||
Map<Contact, HistoryReader> readers = getHistoryReaders(contact);
|
||||
|
||||
for (Map.Entry<Contact, HistoryReader> readerEntry : readers.entrySet())
|
||||
{
|
||||
HistoryReader reader = readerEntry.getValue();
|
||||
|
||||
// add the progress listeners
|
||||
Iterator<HistoryRecord> recs = reader.findByEndDate(endDate);
|
||||
while (recs.hasNext())
|
||||
{
|
||||
result.add(createFileRecordFromHistoryRecord(recs.next()));
|
||||
}
|
||||
}
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns all the file transfers made between the given dates and
|
||||
* having the given keywords in the filename
|
||||
*
|
||||
* @param contact MetaContact the receiver or sender of the file
|
||||
* @param startDate Date the start date of the transfers
|
||||
* @param endDate Date the end date of the transfers
|
||||
* @param keywords array of keywords
|
||||
* @return Collection of FileRecords
|
||||
* @throws RuntimeException
|
||||
*/
|
||||
public Collection<FileRecord> findByPeriod(MetaContact contact,
|
||||
Date startDate, Date endDate, String[] keywords)
|
||||
throws RuntimeException
|
||||
{
|
||||
return findByPeriod(contact, startDate, endDate, keywords, false);
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns all the file transfers made between the given dates
|
||||
* and having the given keywords in the filename
|
||||
*
|
||||
* @param contact MetaContact the receiver or sender of the file
|
||||
* @param startDate Date the start date of the transfers
|
||||
* @param endDate Date the end date of the transfers
|
||||
* @param keywords array of keywords
|
||||
* @param caseSensitive is keywords search case sensitive
|
||||
* @return Collection of FileRecords
|
||||
* @throws RuntimeException
|
||||
*/
|
||||
public Collection<FileRecord> findByPeriod(MetaContact contact, Date startDate, Date endDate,
|
||||
String[] keywords, boolean caseSensitive)
|
||||
throws RuntimeException
|
||||
{
|
||||
TreeSet<FileRecord> result =
|
||||
new TreeSet<FileRecord>(new FileRecordComparator());
|
||||
// get the readers for this contact
|
||||
Map<Contact, HistoryReader> readers = getHistoryReaders(contact);
|
||||
|
||||
for (Map.Entry<Contact, HistoryReader> readerEntry : readers.entrySet())
|
||||
{
|
||||
HistoryReader reader = readerEntry.getValue();
|
||||
|
||||
// add the progress listeners
|
||||
Iterator<HistoryRecord> recs = reader.findByPeriod(
|
||||
startDate, endDate, keywords, SEARCH_FIELD, caseSensitive);
|
||||
while (recs.hasNext())
|
||||
{
|
||||
result.add(createFileRecordFromHistoryRecord(recs.next()));
|
||||
}
|
||||
}
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns all the file transfers made between the given dates
|
||||
*
|
||||
* @param contact MetaContact the receiver or sender of the file
|
||||
* @param startDate Date the start date of the transfers
|
||||
* @param endDate Date the end date of the transfers
|
||||
* @return Collection of FileRecords
|
||||
* @throws RuntimeException
|
||||
*/
|
||||
public Collection<FileRecord> findByPeriod(
|
||||
MetaContact contact, Date startDate, Date endDate)
|
||||
throws RuntimeException
|
||||
{
|
||||
TreeSet<FileRecord> result =
|
||||
new TreeSet<FileRecord>(new FileRecordComparator());
|
||||
// get the readers for this contact
|
||||
Map<Contact, HistoryReader> readers = getHistoryReaders(contact);
|
||||
|
||||
for (Map.Entry<Contact, HistoryReader> readerEntry : readers.entrySet())
|
||||
{
|
||||
HistoryReader reader = readerEntry.getValue();
|
||||
|
||||
// add the progress listeners
|
||||
Iterator<HistoryRecord> recs = reader.findByPeriod(startDate, endDate);
|
||||
while (recs.hasNext())
|
||||
{
|
||||
result.add(createFileRecordFromHistoryRecord(recs.next()));
|
||||
}
|
||||
}
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns the supplied number of file transfers
|
||||
*
|
||||
* @param contact MetaContact the receiver or sender of the file
|
||||
* @param count filetransfer count
|
||||
* @return Collection of FileRecords
|
||||
* @throws RuntimeException
|
||||
*/
|
||||
public Collection<FileRecord> findLast(MetaContact contact, int count)
|
||||
throws RuntimeException
|
||||
{
|
||||
TreeSet<FileRecord> result =
|
||||
new TreeSet<FileRecord>(new FileRecordComparator());
|
||||
// get the readers for this contact
|
||||
Map<Contact, HistoryReader> readers = getHistoryReaders(contact);
|
||||
|
||||
for (Map.Entry<Contact, HistoryReader> readerEntry : readers.entrySet())
|
||||
{
|
||||
HistoryReader reader = readerEntry.getValue();
|
||||
|
||||
// add the progress listeners
|
||||
Iterator<HistoryRecord> recs = reader.findLast(count);
|
||||
while (recs.hasNext())
|
||||
{
|
||||
result.add(createFileRecordFromHistoryRecord(recs.next()));
|
||||
}
|
||||
}
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns all the file transfers having the given keyword in the filename
|
||||
*
|
||||
* @param contact MetaContact the receiver or sender of the file
|
||||
* @param keyword keyword
|
||||
* @return Collection of FileRecords
|
||||
* @throws RuntimeException
|
||||
*/
|
||||
public Collection<FileRecord> findByKeyword(
|
||||
MetaContact contact, String keyword)
|
||||
throws RuntimeException
|
||||
{
|
||||
return findByKeyword(contact, keyword, false);
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns all the file transfers having the given keyword in the filename
|
||||
*
|
||||
* @param contact MetaContact the receiver or sender of the file
|
||||
* @param keyword keyword
|
||||
* @param caseSensitive is keywords search case sensitive
|
||||
* @return Collection of FileRecords
|
||||
* @throws RuntimeException
|
||||
*/
|
||||
public Collection<FileRecord> findByKeyword(
|
||||
MetaContact contact, String keyword, boolean caseSensitive)
|
||||
throws RuntimeException
|
||||
{
|
||||
return findByKeywords(contact, new String[]{keyword}, caseSensitive);
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns all the file transfers having the given keywords in the filename
|
||||
*
|
||||
* @param contact MetaContact the receiver or sender of the file
|
||||
* @param keywords keyword
|
||||
* @return Collection of FileRecords
|
||||
* @throws RuntimeException
|
||||
*/
|
||||
public Collection<FileRecord> findByKeywords(
|
||||
MetaContact contact, String[] keywords)
|
||||
throws RuntimeException
|
||||
{
|
||||
return findByKeywords(contact, keywords, false);
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns all the file transfershaving the given keywords in the filename
|
||||
*
|
||||
* @param contact MetaContact the receiver or sender of the file
|
||||
* @param keywords keyword
|
||||
* @param caseSensitive is keywords search case sensitive
|
||||
* @return Collection of FileRecords
|
||||
* @throws RuntimeException
|
||||
*/
|
||||
public Collection<FileRecord> findByKeywords(
|
||||
MetaContact contact, String[] keywords, boolean caseSensitive)
|
||||
throws RuntimeException
|
||||
{
|
||||
TreeSet<FileRecord> result =
|
||||
new TreeSet<FileRecord>(new FileRecordComparator());
|
||||
// get the readers for this contact
|
||||
Map<Contact, HistoryReader> readers = getHistoryReaders(contact);
|
||||
|
||||
for (Map.Entry<Contact, HistoryReader> readerEntry : readers.entrySet())
|
||||
{
|
||||
HistoryReader reader = readerEntry.getValue();
|
||||
|
||||
// add the progress listeners
|
||||
Iterator<HistoryRecord> recs =
|
||||
reader.findByKeywords(keywords, SEARCH_FIELD, caseSensitive);
|
||||
while (recs.hasNext())
|
||||
{
|
||||
result.add(createFileRecordFromHistoryRecord(recs.next()));
|
||||
}
|
||||
}
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns the supplied number of recent file transfers after the given date
|
||||
*
|
||||
* @param contact MetaContact the receiver or sender of the file
|
||||
* @param date transfers after date
|
||||
* @param count transfers count
|
||||
* @return Collection of FileRecords
|
||||
* @throws RuntimeException
|
||||
*/
|
||||
public Collection<FileRecord> findFirstRecordsAfter(
|
||||
MetaContact contact, Date date, int count)
|
||||
throws RuntimeException
|
||||
{
|
||||
TreeSet<FileRecord> result =
|
||||
new TreeSet<FileRecord>(new FileRecordComparator());
|
||||
// get the readers for this contact
|
||||
Map<Contact, HistoryReader> readers = getHistoryReaders(contact);
|
||||
|
||||
for (Map.Entry<Contact, HistoryReader> readerEntry : readers.entrySet())
|
||||
{
|
||||
HistoryReader reader = readerEntry.getValue();
|
||||
|
||||
// add the progress listeners
|
||||
Iterator<HistoryRecord> recs =
|
||||
reader.findFirstRecordsAfter(date, count);
|
||||
while (recs.hasNext())
|
||||
{
|
||||
result.add(createFileRecordFromHistoryRecord(recs.next()));
|
||||
}
|
||||
}
|
||||
|
||||
LinkedList<FileRecord> resultAsList = new LinkedList<FileRecord>(result);
|
||||
|
||||
int toIndex = count;
|
||||
if(toIndex > resultAsList.size())
|
||||
toIndex = resultAsList.size();
|
||||
|
||||
return resultAsList.subList(0, toIndex);
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns the supplied number of recent file transfers before the given date
|
||||
*
|
||||
* @param contact MetaContact the receiver or sender of the file
|
||||
* @param date transfers before date
|
||||
* @param count transfers count
|
||||
* @return Collection of FileRecords
|
||||
* @throws RuntimeException
|
||||
*/
|
||||
public Collection<FileRecord> findLastRecordsBefore(
|
||||
MetaContact contact, Date date, int count)
|
||||
throws RuntimeException
|
||||
{
|
||||
TreeSet<FileRecord> result =
|
||||
new TreeSet<FileRecord>(new FileRecordComparator());
|
||||
// get the readers for this contact
|
||||
Map<Contact, HistoryReader> readers = getHistoryReaders(contact);
|
||||
|
||||
for (Map.Entry<Contact, HistoryReader> readerEntry : readers.entrySet())
|
||||
{
|
||||
HistoryReader reader = readerEntry.getValue();
|
||||
|
||||
// add the progress listeners
|
||||
Iterator<HistoryRecord> recs =
|
||||
reader.findLastRecordsBefore(date, count);
|
||||
while (recs.hasNext())
|
||||
{
|
||||
result.add(createFileRecordFromHistoryRecord(recs.next()));
|
||||
}
|
||||
}
|
||||
|
||||
LinkedList<FileRecord> resultAsList = new LinkedList<FileRecord>(result);
|
||||
int startIndex = resultAsList.size() - count;
|
||||
|
||||
if(startIndex < 0)
|
||||
startIndex = 0;
|
||||
|
||||
return resultAsList.subList(startIndex, resultAsList.size());
|
||||
}
|
||||
|
||||
/**
|
||||
* When new protocol provider is registered we check
|
||||
* does it supports FileTransfer and if so add a listener to it
|
||||
*
|
||||
* @param serviceEvent ServiceEvent
|
||||
*/
|
||||
public void serviceChanged(ServiceEvent serviceEvent)
|
||||
{
|
||||
Object sService = bundleContext.getService(serviceEvent.getServiceReference());
|
||||
|
||||
logger.trace("Received a service event for: " + sService.getClass().getName());
|
||||
|
||||
// we don't care if the source service is not a protocol provider
|
||||
if (! (sService instanceof ProtocolProviderService))
|
||||
{
|
||||
return;
|
||||
}
|
||||
|
||||
logger.debug("Service is a protocol provider.");
|
||||
if (serviceEvent.getType() == ServiceEvent.REGISTERED)
|
||||
{
|
||||
logger.debug("Handling registration of a new Protocol Provider.");
|
||||
|
||||
this.handleProviderAdded((ProtocolProviderService)sService);
|
||||
}
|
||||
else if (serviceEvent.getType() == ServiceEvent.UNREGISTERING)
|
||||
{
|
||||
this.handleProviderRemoved( (ProtocolProviderService) sService);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Returns the history by specified local and remote contact
|
||||
* if one of them is null the default is used
|
||||
*
|
||||
* @param localContact Contact
|
||||
* @param remoteContact Contact
|
||||
* @return History
|
||||
* @throws IOException
|
||||
*/
|
||||
private History getHistory(Contact localContact, Contact remoteContact)
|
||||
throws IOException
|
||||
{
|
||||
History retVal = null;
|
||||
|
||||
String localId = localContact == null ? "default" : localContact
|
||||
.getAddress();
|
||||
String remoteId = remoteContact == null ? "default" : remoteContact
|
||||
.getAddress();
|
||||
|
||||
String account = "unkown";
|
||||
if (remoteContact != null)
|
||||
account = remoteContact.getProtocolProvider().getAccountID().
|
||||
getAccountUniqueID();
|
||||
|
||||
HistoryID historyId = HistoryID.createFromRawID(
|
||||
new String[] { "filehistory",
|
||||
localId,
|
||||
account,
|
||||
remoteId });
|
||||
|
||||
if (this.historyService.isHistoryExisting(historyId))
|
||||
{
|
||||
retVal = this.historyService.getHistory(historyId);
|
||||
} else
|
||||
{
|
||||
retVal = this.historyService.createHistory(historyId,
|
||||
recordStructure);
|
||||
}
|
||||
|
||||
return retVal;
|
||||
}
|
||||
|
||||
/**
|
||||
* Listens for changes in filetransfers.
|
||||
* @param event
|
||||
*/
|
||||
public void statusChanged(FileTransferStatusChangeEvent event)
|
||||
{
|
||||
try
|
||||
{
|
||||
FileTransfer ft = event.getFileTransfer();
|
||||
String status = getStatus(ft.getStatus());
|
||||
|
||||
// ignore events we don't need
|
||||
if(status == null)
|
||||
return;
|
||||
|
||||
History history = getHistory(null, ft.getContact());
|
||||
HistoryWriter historyWriter = history.getWriter();
|
||||
|
||||
historyWriter.addRecord(new String[]{
|
||||
ft.getFile().getCanonicalPath(),
|
||||
getDirection(ft.getDirection()),
|
||||
String.valueOf(new Date().getTime()),
|
||||
status
|
||||
});
|
||||
|
||||
} catch (IOException e)
|
||||
{
|
||||
logger.error("Could not add file transfer log to history", e);
|
||||
}
|
||||
}
|
||||
|
||||
private static String getDirection(int direction)
|
||||
{
|
||||
switch(direction)
|
||||
{
|
||||
case FileTransfer.IN :
|
||||
return FileRecord.IN;
|
||||
case FileTransfer.OUT :
|
||||
return FileRecord.OUT;
|
||||
default: return null;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Maps only the statuses we are interested in, otherwise returns null.
|
||||
* @param status the status as receive from FileTransfer
|
||||
* @return the corresponding status of FileRecord.
|
||||
*/
|
||||
private static String getStatus(int status)
|
||||
{
|
||||
switch(status)
|
||||
{
|
||||
case FileTransferStatusChangeEvent.CANCELED :
|
||||
return FileRecord.CANCELED;
|
||||
case FileTransferStatusChangeEvent.COMPLETED :
|
||||
return FileRecord.COMPLETED;
|
||||
case FileTransferStatusChangeEvent.FAILED :
|
||||
return FileRecord.FAILED;
|
||||
case FileTransferStatusChangeEvent.REFUSED :
|
||||
return FileRecord.REFUSED;
|
||||
default: return null;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* We ignore filetransfer requests.
|
||||
* @param event
|
||||
*/
|
||||
public void fileTransferRequestReceived(FileTransferRequestEvent event)
|
||||
{
|
||||
}
|
||||
|
||||
/**
|
||||
* New filetransfer was created.
|
||||
* @param fileTransfer
|
||||
*/
|
||||
public void fileTransferCreated(FileTransfer fileTransfer)
|
||||
{
|
||||
fileTransfer.addStatusListener(this);
|
||||
}
|
||||
|
||||
/**
|
||||
* Used to compare FileRecords
|
||||
* and to be ordered in TreeSet according their timestamp
|
||||
*/
|
||||
private static class FileRecordComparator
|
||||
implements Comparator
|
||||
{
|
||||
public int compare(Object o1, Object o2)
|
||||
{
|
||||
long date1 = ((FileRecord)o1).getDate();
|
||||
long date2 = ((FileRecord)o2).getDate();
|
||||
|
||||
return (date1 < date2) ? -1 : ((date1 == date2) ? 0 : 1);
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,15 @@
|
||||
Bundle-Activator: net.java.sip.communicator.impl.filehistory.FileHistoryActivator
|
||||
Bundle-Name: File History Service Provider
|
||||
Bundle-Description: A bundle that implements the file history package.
|
||||
Bundle-Vendor: sip-communicator.org
|
||||
Bundle-Version: 0.0.1
|
||||
System-Bundle: yes
|
||||
Import-Package: org.osgi.framework,
|
||||
net.java.sip.communicator.service.history,
|
||||
net.java.sip.communicator.service.history.records,
|
||||
net.java.sip.communicator.service.history.event,
|
||||
net.java.sip.communicator.service.contactlist,
|
||||
net.java.sip.communicator.util,
|
||||
net.java.sip.communicator.service.protocol,
|
||||
net.java.sip.communicator.service.protocol.event
|
||||
Export-Package: net.java.sip.communicator.service.filehistory
|
||||
Loading…
Reference in new issue