Class SubscriptionManagerImpl

java.lang.Object

com.biglybt.core.subs.impl.SubscriptionManagerImpl

All Implemented Interfaces:

SubscriptionManager, AEDiagnosticsEvidenceGenerator, DataSourceResolver.DataSourceImporter, UtilitiesImpl.PluginSubscriptionManager

public class SubscriptionManagerImpl
extends Object
implements SubscriptionManager, DataSourceResolver.DataSourceImporter, AEDiagnosticsEvidenceGenerator

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static interface	SubscriptionManagerImpl.downloadListener
(package private) static interface	SubscriptionManagerImpl.subsLookupListener

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	ASSOC_CHECK_PERIOD
private static final int	ASSOC_CHECK_TICKS
private static final int	ASSOC_PUBLISH_PERIOD
private static final int	ASSOC_PUBLISH_TICKS
private AsyncDispatcher	async_dispatcher
private LinkedList<BuddyPluginBeta.ChatInstance>	chat_assoc_done
private static final int	CHAT_CHECK_PERIOD
private static final int	CHAT_CHECK_TICKS
private Set<String>	chat_st_done
private AsyncDispatcher	chat_write_dispatcher
private static final String	CONFIG_ACTIVATE_ON_CHANGE
private static final String	CONFIG_ADD_HASHES
private static final String	CONFIG_AUTO_MARK_READ
private static final String	CONFIG_AUTO_START_DLS
private static final String	CONFIG_AUTO_START_MAX_MB
private static final String	CONFIG_AUTO_START_MIN_MB
private static final String	CONFIG_DEF_CHECK_MINS
private AtomicBoolean	config_dirty
private static final String	CONFIG_DL_RATE_LIMITS
private static final String	CONFIG_DL_SUBS_ENABLE
private static final String	CONFIG_ENABLE_SEARCH
private static final String	CONFIG_FILE
private static final String	CONFIG_HIDE_SEARCH_TEMPLATES
private static final String	CONFIG_MARK_LIB_RESULTS_READ
private static final String	CONFIG_MAX_RESULTS
private static final String	CONFIG_RSS_ENABLE
private Core	core
private static final int	DELETE_UNUSED_AFTER_MILLIS
private DHTPluginInterface	dht_plugin_public
private Pattern	exclusion_pattern
private Map<String,String>	gmar_cache
private Map<String, AtomicInteger>	imported_sids
private boolean	js_plugin_install_tried
private SubscriptionImpl	last_gmar
private static final AtomicInteger	lib_mutation_count
private static final Object	LIB_MUTATION_KEY
private static AsyncDispatcher	library_checker
private CopyOnWriteList<SubscriptionManagerListener>	listeners
private AEDiagnosticsLogger	logger
private static final String	LOGGER_NAME
private boolean	meta_search_listener_added
private boolean	periodic_lookup_in_progress
private List<Object[]>	potential_associations
private Map<HashWrapper, Object[]>	potential_associations2
private Map<HashWrapper, Object[]>	potential_associations3
private static boolean	pre_initialised
private int	priority_lookup_pending
private static final int	PUB_ASSOC_CONC_MAX
private static final int	PUB_SLEEPING_ASSOC_CONC_MAX
private int	publish_associations_active
private boolean	publish_next_asyc_pending
private boolean	publish_subscription_active
private static final int	random_seed
private Map<SubscriptionImpl, Object[]>	result_cache
private static AsyncDispatcher	result_exec
private SubscriptionRSSFeed	rss_publisher
private SubscriptionSchedulerImpl	scheduler
private static final int	SERVER_PUB_CHECK_PERIOD
private static final int	SERVER_PUB_CHECK_TICKS
private static final int	SET_SELECTED_FIRST_TICK
private static final int	SET_SELECTED_PERIOD
private static final int	SET_SELECTED_TICKS
private static SubscriptionManagerImpl	singleton
private static final Object	SP_CONSEC_FAIL
private static final Object	SP_LAST_ATTEMPTED
private boolean	started
private static final Object	SUBS_CHAT_KEY
private CopyOnWriteMap<String, SubscriptionImpl>	subscription_map
private TorrentAttribute	ta_category
private TorrentAttribute	ta_networks
private TorrentAttribute	ta_subs_download
private TorrentAttribute	ta_subs_download_rd
private TorrentAttribute	ta_subscription_info
private static final int	TIDY_POT_ASSOC_PERIOD
private static final int	TIDY_POT_ASSOC_TICKS
private static final int	TIMER_PERIOD

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SubscriptionManagerImpl(boolean stand_alone)

Method Summary

Modifier and Type	Method	Description
void	addListener(SubscriptionManagerListener listener)
protected void	addMetaSearchListener()
protected void	addPotentialAssociation(SubscriptionImpl subs, String result_id, String key)
protected void	addPrepareTrigger(byte[] hash, Subscription[] subs, SubscriptionResult[] results)
protected SubscriptionImpl	addSubscription(SubscriptionImpl subs)
protected boolean	askIfCanUpgrade(SubscriptionImpl subs, int new_version)
protected void	associationAdded(SubscriptionImpl subscription, byte[] association_hash)
protected void	associationLookupComplete()
private void	assocOK(SubscriptionImpl subs, SubscriptionImpl.association assoc)
protected void	changeSubscription(SubscriptionImpl subs, int reason)
private void	checkGloballyMarkedRead(SubscriptionImpl subs, Collection<SubscriptionResultImpl> results)
protected void	checkInitialDownload(SubscriptionImpl subs)
protected void	checkMaxResults(int max)
protected void	checkPotentialAssociations(byte[] hash, String key)
protected void	checkServerPublications(List subs)
protected void	checkSingletonPublish(SubscriptionImpl subs)
protected void	checkStuff(int ticks)
protected void	checkUpgrade(SubscriptionImpl sub)
protected void	checkURL(URL url)
protected void	configDirty()
protected void	configDirty(SubscriptionImpl subs, int reason)
Subscription	create(String name, boolean public_subs, String json)
Subscription	createFromURI(String uri)
Subscription	createRSS(String name, URL url, int check_interval_mins, boolean is_anonymous, Map user_data)
Subscription	createRSS(String name, URL url, int check_interval_mins, Map user_data)
SubscriptionImpl	createSingletonRSS(String name, URL url, int check_interval_mins, boolean is_anon)
protected SubscriptionImpl	createSingletonRSSSupport(String name, URL url, boolean is_public, int check_interval_mins, boolean is_anon, int add_type, boolean subscribe)
protected SubscriptionImpl	createSingletonSubscription(Map singleton_details, int add_type, boolean subscribe)
Subscription	createSubscriptionTemplate(String name)
protected Map	decodeSubscriptionDetails(byte[] data)
private boolean	downloadIsIgnored(Download download)
private void	downloadSubscription(String description, byte[] association_hash, byte[] torrent_hash, byte[] sid, int version, int size, SubscriptionManagerImpl.subsLookupListener listener)
private void	downloadSubscription(String description, TOTorrent torrent, InetSocketAddress peer, byte[] subs_id, int version, String name, SubscriptionManagerImpl.downloadListener listener)
protected Object[]	downloadTorrent(byte[] hash, int update_size)
protected byte[]	encodeSubscriptionDetails(SubscriptionImpl subs)
protected void	evalScript(SubscriptionImpl subs, String script, List<SubscriptionResultImpl> subs_results, String intent_key)
void	generate(IndentWriter writer)
boolean	getActivateSubscriptionOnChange()
boolean	getAddHashDirs()
int	getAutoDownloadMarkReadAfterDays()
boolean	getAutoStartDownloads()
int	getAutoStartMaxMB()
int	getAutoStartMinMB()
int	getDefaultCheckFrequencyMins()
protected Engine	getEngine(SubscriptionImpl subs, Map json_map, boolean local_only)
private SubscriptionImpl	getGMAR(boolean create_if_missing)
private byte[]	getKeyBytes(String key)
int	getKnownSubscriptionCount()
Subscription[]	getKnownSubscriptions(byte[] hash)	Cached view of hash's subs
Subscription[]	getLinkedSubscriptions(byte[] hash)
private AEDiagnosticsLogger	getLogger()
protected MagnetPlugin	getMagnetPlugin()
boolean	getMarkResultsInLibraryRead()
int	getMaxNonDeletedResults()
protected void	getPopularity(SubscriptionImpl subs, SubscriptionPopularityListener listener)
protected void	getPopularityFromDHT(SubscriptionImpl subs, SubscriptionPopularityListener listener, boolean sync)
protected void	getPopularitySupport(DHTPluginInterface dht_plugin, SubscriptionImpl subs, SubscriptionPopularityListener _listener, boolean sync)
private int	getPublishRemainingCount()
String	getRateLimits()
protected File	getResultsFile(SubscriptionImpl subs)
String	getRSSLink()
SubscriptionScheduler	getScheduler()
protected Object[]	getSearchTemplateVuzeFile(SubscriptionImpl sub)
static SubscriptionManager	getSingleton(boolean stand_alone)
protected Map	getSingletonMap(String name, URL url, boolean is_public, int check_interval_mins, boolean is_anon)
SubscriptionImpl	getSubscriptionByID(String id)
int	getSubscriptionCount(boolean subscribed_only)
protected int	getSubscriptionDownloadCount()
protected SubscriptionImpl	getSubscriptionFromName(String name)
protected SubscriptionImpl	getSubscriptionFromPlatform(byte[] sid, boolean is_anon, int add_type)
protected SubscriptionImpl	getSubscriptionFromSID(byte[] sid)
protected SubscriptionImpl	getSubscriptionFromVuzeFile(byte[] sid, int add_type, VuzeFile vf)
protected SubscriptionImpl	getSubscriptionFromVuzeFile(byte[] sid, int add_type, File file)
protected SubscriptionImpl	getSubscriptionFromVuzeFileContent(byte[] sid, int add_type, String content)
SubscriptionImpl[]	getSubscriptions()
SubscriptionImpl[]	getSubscriptions(boolean subscribed_only)
protected File	getSubsDir()
protected String	getUniqueName(String name)
protected File	getVuzeFile(SubscriptionImpl subs)
boolean	hideSearchTemplates()
Object	importDataSource(Map<String,Object> map)
Subscription	importSubscription(int type, Map map, boolean warn_user)
protected void	initialise()
protected void	initWithCore(Core _core)
protected boolean	isClosing()
boolean	isRSSPublishEnabled()
boolean	isSearchEnabled()
boolean	isSearchTemplateImportable(SubscriptionImpl sub)
boolean	isSubsDownloadEnabled()
protected boolean	isVisible(SubscriptionImpl subs)
private void	libraryMutated()
private void	loadConfig()
protected LinkedHashMap<String, SubscriptionResultImpl>	loadResults(SubscriptionImpl subs)
void	log(String s)
void	log(String s, Throwable e)
protected void	lookupAssociations(boolean high_priority)
SubscriptionAssociationLookup	lookupAssociations(byte[] hash, SubscriptionLookupListener listener)
SubscriptionAssociationLookup	lookupAssociations(byte[] hash, String description, SubscriptionLookupListener listener)	Full lookup
SubscriptionAssociationLookup	lookupAssociations(byte[] hash, String description, String[] networks, SubscriptionLookupListener listener)
private SubscriptionAssociationLookup	lookupAssociations(DHTPluginInterface dht_plugin, byte[] hash, String description, SubscriptionLookupListener listener)
protected SubscriptionAssociationLookup	lookupAssociationsSupport(DHTPluginInterface dht_plugin, byte[] hash, String description, SubscriptionLookupListener _listener)
protected SubscriptionImpl	lookupSingletonRSS(String name, URL url, boolean is_public, int check_interval_mins, boolean is_anon)
private void	lookupSubscription(String description, byte[] association_hash, byte[] sid, int version, boolean is_anon, SubscriptionManagerImpl.subsLookupListener listener)
void	markReadInAllSubscriptions(SearchSubsResultBase[] results)
private List<SubscriptionResult>	matchSubscriptionResults(SearchMatcher matcher)
static void	preInitialise()
protected void	prepareDownload(Download download, Subscription[] subscriptions, SubscriptionResult[] results)
private void	processResults(SubscriptionImpl subs, Collection<SubscriptionResultImpl> results, boolean has_new_results)
private void	publishAssociation(SubscriptionImpl subs, SubscriptionImpl.association assoc)
private boolean	publishAssociations()
private void	publishNextAssociation()
protected void	publishSubscription(SubscriptionImpl subs)
protected void	publishSubscriptions()
protected void	recordAssociations(byte[] association_hash, SubscriptionImpl[] subscriptions, boolean full_lookup)
protected boolean	recordAssociationsSupport(byte[] association_hash, SubscriptionImpl[] subscriptions, boolean full_lookup)
protected boolean	recoverSubscriptionUpdate(Download download, Map rd)
protected void	removeDownload(Download download, boolean remove_data)
void	removeListener(SubscriptionManagerListener listener)
protected void	removePrepareTrigger(byte[] hash)
protected void	removeSubscription(SubscriptionImpl subs)
void	requestSubscription(SearchProvider sp, Map<String,Object> search_parameters)
void	requestSubscription(URL url, Map<String,Object> options)
protected void	saveConfig()
protected void	saveResults(SubscriptionImpl subs, SubscriptionResultImpl[] results, List<SubscriptionResultImpl> new_unread_results)
SearchInstance	searchSubscriptions(Map<String,Object> search_parameters, SearchObserver observer)
private void	searchTemplateOK(SubscriptionImpl subs, Download download)
private DHTPluginInterface	selectDHTPlugin(SubscriptionImpl subs)
private DHTPluginInterface	selectDHTPlugin(Download download)
private DHTPluginInterface	selectDHTPlugin(String[] networks)
protected void	selectSubscription(SubscriptionImpl subs)
void	setActivateSubscriptionOnChange(boolean b)
void	setAddHashDirs(boolean b)
void	setAutoDownloadMarkReadAfterDays(int days)
void	setAutoStartDownloads(boolean auto_start)
void	setAutoStartMaxMB(int mb)
void	setAutoStartMinMB(int mb)
protected void	setCategoryOnExisting(SubscriptionImpl subscription, String old_category, String new_category)
void	setDefaultCheckFrequencyMins(int def)
void	setMarkResultsInLibraryRead(boolean b)
void	setMaxNonDeletedResults(int max)
void	setRateLimits(String limits)
void	setRSSPublishEnabled(boolean enabled)
void	setSearchEnabled(boolean enabled)
protected void	setSelected(SubscriptionImpl sub)
protected void	setSelected(List subs)
void	setSubsDownloadEnabled(boolean enabled)
protected boolean	shouldAutoStart(Torrent torrent)
Subscription	subscribeToRSS(String name, URL url, int interval, boolean is_public, String creator_ref)
Subscription	subscribeToSubscription(String uri)
protected boolean	subscriptionExists(Download download, SubscriptionImpl subs)
protected void	subscriptionUpdated()
protected void	tidyPotentialAssociations()
protected void	updatePopularityFromDHT(SubscriptionImpl subs, boolean sync)
protected void	updatePublicSubscription(SubscriptionImpl subs)
protected void	updateSubscription(SubscriptionImpl subs, int new_version)
protected void	updateSubscription(SubscriptionImpl subs, int update_version, byte[] update_hash, int update_size)
protected void	updateSubscription(SubscriptionImpl subs, int new_version, TOTorrent torrent, InetSocketAddress peer)
protected void	updateSubscription(SubscriptionImpl subs, Download download, File torrent_file, File data_file)
protected void	updateSubscription(SubscriptionImpl subs, File data_location)
private void	waitForChat(BuddyPluginBeta.ChatInstance chat, AERunnable runnable)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

CONFIG_FILE

private static final String CONFIG_FILE

See Also:

• Constant Field Values

LOGGER_NAME

private static final String LOGGER_NAME

See Also:

• Constant Field Values

CONFIG_DEF_CHECK_MINS

private static final String CONFIG_DEF_CHECK_MINS

See Also:

• Constant Field Values

CONFIG_MAX_RESULTS

private static final String CONFIG_MAX_RESULTS

See Also:

• Constant Field Values

CONFIG_AUTO_START_DLS

private static final String CONFIG_AUTO_START_DLS

See Also:

• Constant Field Values

CONFIG_AUTO_START_MIN_MB

private static final String CONFIG_AUTO_START_MIN_MB

See Also:

• Constant Field Values

CONFIG_AUTO_START_MAX_MB

private static final String CONFIG_AUTO_START_MAX_MB

See Also:

• Constant Field Values

CONFIG_AUTO_MARK_READ

private static final String CONFIG_AUTO_MARK_READ

See Also:

• Constant Field Values

CONFIG_ADD_HASHES

private static final String CONFIG_ADD_HASHES

See Also:

• Constant Field Values

CONFIG_RSS_ENABLE

private static final String CONFIG_RSS_ENABLE

See Also:

• Constant Field Values

CONFIG_ENABLE_SEARCH

private static final String CONFIG_ENABLE_SEARCH

See Also:

• Constant Field Values

CONFIG_HIDE_SEARCH_TEMPLATES

private static final String CONFIG_HIDE_SEARCH_TEMPLATES

See Also:

• Constant Field Values

CONFIG_DL_SUBS_ENABLE

private static final String CONFIG_DL_SUBS_ENABLE

See Also:

• Constant Field Values

CONFIG_DL_RATE_LIMITS

private static final String CONFIG_DL_RATE_LIMITS

See Also:

• Constant Field Values

CONFIG_ACTIVATE_ON_CHANGE

private static final String CONFIG_ACTIVATE_ON_CHANGE

See Also:

• Constant Field Values

CONFIG_MARK_LIB_RESULTS_READ

private static final String CONFIG_MARK_LIB_RESULTS_READ

See Also:

• Constant Field Values

DELETE_UNUSED_AFTER_MILLIS

private static final int DELETE_UNUSED_AFTER_MILLIS

See Also:

• Constant Field Values

PUB_ASSOC_CONC_MAX

private static final int PUB_ASSOC_CONC_MAX

PUB_SLEEPING_ASSOC_CONC_MAX

private static final int PUB_SLEEPING_ASSOC_CONC_MAX

See Also:

• Constant Field Values

singleton

private static SubscriptionManagerImpl singleton

pre_initialised

private static boolean pre_initialised

random_seed

private static final int random_seed

started

private boolean started

TIMER_PERIOD

private static final int TIMER_PERIOD

See Also:

• Constant Field Values

ASSOC_CHECK_PERIOD

private static final int ASSOC_CHECK_PERIOD

See Also:

• Constant Field Values

ASSOC_CHECK_TICKS

private static final int ASSOC_CHECK_TICKS

See Also:

• Constant Field Values

ASSOC_PUBLISH_PERIOD

private static final int ASSOC_PUBLISH_PERIOD

See Also:

• Constant Field Values

ASSOC_PUBLISH_TICKS

private static final int ASSOC_PUBLISH_TICKS

See Also:

• Constant Field Values

CHAT_CHECK_PERIOD

private static final int CHAT_CHECK_PERIOD

See Also:

• Constant Field Values

CHAT_CHECK_TICKS

private static final int CHAT_CHECK_TICKS

See Also:

• Constant Field Values

SERVER_PUB_CHECK_PERIOD

private static final int SERVER_PUB_CHECK_PERIOD

See Also:

• Constant Field Values

SERVER_PUB_CHECK_TICKS

private static final int SERVER_PUB_CHECK_TICKS

See Also:

• Constant Field Values

TIDY_POT_ASSOC_PERIOD

private static final int TIDY_POT_ASSOC_PERIOD

See Also:

• Constant Field Values

TIDY_POT_ASSOC_TICKS

private static final int TIDY_POT_ASSOC_TICKS

See Also:

• Constant Field Values

SET_SELECTED_PERIOD

private static final int SET_SELECTED_PERIOD

See Also:

• Constant Field Values

SET_SELECTED_FIRST_TICK

private static final int SET_SELECTED_FIRST_TICK

See Also:

• Constant Field Values

SET_SELECTED_TICKS

private static final int SET_SELECTED_TICKS

See Also:

• Constant Field Values

SP_LAST_ATTEMPTED

private static final Object SP_LAST_ATTEMPTED

SP_CONSEC_FAIL

private static final Object SP_CONSEC_FAIL

core

private Core core

dht_plugin_public

private volatile DHTPluginInterface dht_plugin_public

subscription_map

private CopyOnWriteMap<String, SubscriptionImpl> subscription_map

config_dirty

private AtomicBoolean config_dirty

publish_associations_active

private int publish_associations_active

publish_next_asyc_pending

private boolean publish_next_asyc_pending

publish_subscription_active

private boolean publish_subscription_active

ta_subs_download

private TorrentAttribute ta_subs_download

ta_subs_download_rd

private TorrentAttribute ta_subs_download_rd

ta_subscription_info

private TorrentAttribute ta_subscription_info

ta_category

private TorrentAttribute ta_category

ta_networks

private TorrentAttribute ta_networks

periodic_lookup_in_progress

private boolean periodic_lookup_in_progress

priority_lookup_pending

private int priority_lookup_pending

listeners

private CopyOnWriteList<SubscriptionManagerListener> listeners

scheduler

private SubscriptionSchedulerImpl scheduler

potential_associations

private List<Object[]> potential_associations

potential_associations2

private Map<HashWrapper, Object[]> potential_associations2

potential_associations3

private Map<HashWrapper, Object[]> potential_associations3

meta_search_listener_added

private boolean meta_search_listener_added

exclusion_pattern

private Pattern exclusion_pattern

rss_publisher

private SubscriptionRSSFeed rss_publisher

logger

private AEDiagnosticsLogger logger

result_cache

private Map<SubscriptionImpl, Object[]> result_cache

async_dispatcher

private AsyncDispatcher async_dispatcher

SUBS_CHAT_KEY

private static final Object SUBS_CHAT_KEY

imported_sids

private Map<String, AtomicInteger> imported_sids

chat_write_dispatcher

private AsyncDispatcher chat_write_dispatcher

chat_st_done

private Set<String> chat_st_done

chat_assoc_done

private LinkedList<BuddyPluginBeta.ChatInstance> chat_assoc_done

LIB_MUTATION_KEY

private static final Object LIB_MUTATION_KEY

lib_mutation_count

private static final AtomicInteger lib_mutation_count

library_checker

private static AsyncDispatcher library_checker

result_exec

private static AsyncDispatcher result_exec

js_plugin_install_tried

private boolean js_plugin_install_tried

last_gmar

private SubscriptionImpl last_gmar

gmar_cache

private Map<String,String> gmar_cache

Constructor Details

SubscriptionManagerImpl

protected SubscriptionManagerImpl(boolean stand_alone)

Method Details

preInitialise

public static void preInitialise()

getSingleton

public static SubscriptionManager getSingleton(boolean stand_alone)

initialise

protected void initialise()

initWithCore

protected void initWithCore(Core _core)

isClosing

protected boolean isClosing()

getSearchTemplateVuzeFile

protected Object[] getSearchTemplateVuzeFile(SubscriptionImpl sub)

isSearchTemplateImportable

public boolean isSearchTemplateImportable(SubscriptionImpl sub)

searchSubscriptions

public SearchInstance searchSubscriptions(Map<String,Object> search_parameters,
 SearchObserver observer)
                                   throws SearchException

Throws:

SearchException

matchSubscriptionResults

private List<SubscriptionResult> matchSubscriptionResults(SearchMatcher matcher)

checkMaxResults

protected void checkMaxResults(int max)

getScheduler

public SubscriptionScheduler getScheduler()

Specified by:

getScheduler in interface SubscriptionManager

isRSSPublishEnabled

public boolean isRSSPublishEnabled()

Specified by:

isRSSPublishEnabled in interface SubscriptionManager

setRSSPublishEnabled

public void setRSSPublishEnabled(boolean enabled)

Specified by:

setRSSPublishEnabled in interface SubscriptionManager

isSearchEnabled

public boolean isSearchEnabled()

Specified by:

isSearchEnabled in interface SubscriptionManager

setSearchEnabled

public void setSearchEnabled(boolean enabled)

Specified by:

setSearchEnabled in interface SubscriptionManager

hideSearchTemplates

public boolean hideSearchTemplates()

Specified by:

hideSearchTemplates in interface SubscriptionManager

isSubsDownloadEnabled

public boolean isSubsDownloadEnabled()

Specified by:

isSubsDownloadEnabled in interface SubscriptionManager

setSubsDownloadEnabled

public void setSubsDownloadEnabled(boolean enabled)

Specified by:

setSubsDownloadEnabled in interface SubscriptionManager

setRateLimits

public void setRateLimits(String limits)

Specified by:

setRateLimits in interface SubscriptionManager

getRateLimits

public String getRateLimits()

Specified by:

getRateLimits in interface SubscriptionManager

setActivateSubscriptionOnChange

public void setActivateSubscriptionOnChange(boolean b)

Specified by:

setActivateSubscriptionOnChange in interface SubscriptionManager

getActivateSubscriptionOnChange

public boolean getActivateSubscriptionOnChange()

Specified by:

getActivateSubscriptionOnChange in interface SubscriptionManager

setMarkResultsInLibraryRead

public void setMarkResultsInLibraryRead(boolean b)

Specified by:

setMarkResultsInLibraryRead in interface SubscriptionManager

getMarkResultsInLibraryRead

public boolean getMarkResultsInLibraryRead()

Specified by:

getMarkResultsInLibraryRead in interface SubscriptionManager

getRSSLink

public String getRSSLink()

Specified by:

getRSSLink in interface SubscriptionManager

create

public Subscription create(String name,
 boolean public_subs,
 String json)
                    throws SubscriptionException

Specified by:

create in interface SubscriptionManager

Throws:

SubscriptionException

createSingletonRSS

public SubscriptionImpl createSingletonRSS(String name,
 URL url,
 int check_interval_mins,
 boolean is_anon)
                                    throws SubscriptionException

Specified by:

createSingletonRSS in interface SubscriptionManager

Throws:

SubscriptionException

createFromURI

public Subscription createFromURI(String uri)
                           throws SubscriptionException

Specified by:

createFromURI in interface SubscriptionManager

Throws:

SubscriptionException

lookupSingletonRSS

protected SubscriptionImpl lookupSingletonRSS(String name,
 URL url,
 boolean is_public,
 int check_interval_mins,
 boolean is_anon)
                                       throws SubscriptionException

Throws:

SubscriptionException

createSingletonRSSSupport

protected SubscriptionImpl createSingletonRSSSupport(String name,
 URL url,
 boolean is_public,
 int check_interval_mins,
 boolean is_anon,
 int add_type,
 boolean subscribe)
                                              throws SubscriptionException

Throws:

SubscriptionException

getUniqueName

protected String getUniqueName(String name)

getSingletonMap

protected Map getSingletonMap(String name,
 URL url,
 boolean is_public,
 int check_interval_mins,
 boolean is_anon)
                       throws SubscriptionException

Throws:

SubscriptionException

createSingletonSubscription

protected SubscriptionImpl createSingletonSubscription(Map singleton_details,
 int add_type,
 boolean subscribe)
                                                throws SubscriptionException

Throws:

SubscriptionException

requestSubscription

public void requestSubscription(URL url,
 Map<String,Object> options)

Specified by:

requestSubscription in interface UtilitiesImpl.PluginSubscriptionManager

requestSubscription

public void requestSubscription(SearchProvider sp,
 Map<String,Object> search_parameters)
                         throws SubscriptionException

Specified by:

requestSubscription in interface UtilitiesImpl.PluginSubscriptionManager

Throws:

SubscriptionException

createRSS

public Subscription createRSS(String name,
 URL url,
 int check_interval_mins,
 Map user_data)
                       throws SubscriptionException

Specified by:

createRSS in interface SubscriptionManager

Throws:

SubscriptionException

createRSS

public Subscription createRSS(String name,
 URL url,
 int check_interval_mins,
 boolean is_anonymous,
 Map user_data)
                       throws SubscriptionException

Specified by:

createRSS in interface SubscriptionManager

Throws:

SubscriptionException

createSubscriptionTemplate

public Subscription createSubscriptionTemplate(String name)
                                        throws SubscriptionException

Specified by:

createSubscriptionTemplate in interface SubscriptionManager

Throws:

SubscriptionException

checkURL

protected void checkURL(URL url)
                 throws SubscriptionException

Throws:

SubscriptionException

addSubscription

protected SubscriptionImpl addSubscription(SubscriptionImpl subs)

addMetaSearchListener

protected void addMetaSearchListener()

changeSubscription

protected void changeSubscription(SubscriptionImpl subs,
 int reason)

selectSubscription

protected void selectSubscription(SubscriptionImpl subs)

removeSubscription

protected void removeSubscription(SubscriptionImpl subs)

updatePublicSubscription

protected void updatePublicSubscription(SubscriptionImpl subs)

checkSingletonPublish

protected void checkSingletonPublish(SubscriptionImpl subs)
                              throws SubscriptionException

Throws:

SubscriptionException

checkServerPublications

protected void checkServerPublications(List subs)

checkStuff

protected void checkStuff(int ticks)

importSubscription

public Subscription importSubscription(int type,
 Map map,
 boolean warn_user)
                                throws SubscriptionException

Throws:

SubscriptionException

getSubscriptions

public SubscriptionImpl[] getSubscriptions()

Specified by:

getSubscriptions in interface SubscriptionManager

getSubscriptions

public SubscriptionImpl[] getSubscriptions(boolean subscribed_only)

Specified by:

getSubscriptions in interface SubscriptionManager

Specified by:

getSubscriptions in interface UtilitiesImpl.PluginSubscriptionManager

getSubscriptionCount

public int getSubscriptionCount(boolean subscribed_only)

Specified by:

getSubscriptionCount in interface SubscriptionManager

getSubscriptionFromName

protected SubscriptionImpl getSubscriptionFromName(String name)

getSubscriptionByID

public SubscriptionImpl getSubscriptionByID(String id)

Specified by:

getSubscriptionByID in interface SubscriptionManager

importDataSource

public Object importDataSource(Map<String,Object> map)

Specified by:

importDataSource in interface DataSourceResolver.DataSourceImporter

getSubscriptionFromSID

protected SubscriptionImpl getSubscriptionFromSID(byte[] sid)

getSubsDir

protected File getSubsDir()
                   throws IOException

Throws:

IOException

getVuzeFile

protected File getVuzeFile(SubscriptionImpl subs)
                    throws IOException

Throws:

IOException

getResultsFile

protected File getResultsFile(SubscriptionImpl subs)
                       throws IOException

Throws:

IOException

getKnownSubscriptionCount

public int getKnownSubscriptionCount()

Specified by:

getKnownSubscriptionCount in interface SubscriptionManager

getKnownSubscriptions

public Subscription[] getKnownSubscriptions(byte[] hash)

Description copied from interface: SubscriptionManager

Cached view of hash's subs

Specified by:

getKnownSubscriptions in interface SubscriptionManager

Parameters:

hash -

Returns:

subscriptionExists

protected boolean subscriptionExists(Download download,
 SubscriptionImpl subs)

downloadIsIgnored

private boolean downloadIsIgnored(Download download)

isVisible

protected boolean isVisible(SubscriptionImpl subs)

getLinkedSubscriptions

public Subscription[] getLinkedSubscriptions(byte[] hash)

Specified by:

getLinkedSubscriptions in interface SubscriptionManager

lookupAssociations

protected void lookupAssociations(boolean high_priority)

associationLookupComplete

protected void associationLookupComplete()

setSelected

protected void setSelected(List subs)

checkUpgrade

protected void checkUpgrade(SubscriptionImpl sub)

setSelected

protected void setSelected(SubscriptionImpl sub)

checkInitialDownload

protected void checkInitialDownload(SubscriptionImpl subs)

lookupAssociations

public SubscriptionAssociationLookup lookupAssociations(byte[] hash,
 String description,
 String[] networks,
 SubscriptionLookupListener listener)
                                                 throws SubscriptionException

Specified by:

lookupAssociations in interface SubscriptionManager

Throws:

SubscriptionException

lookupAssociations

public SubscriptionAssociationLookup lookupAssociations(byte[] hash,
 SubscriptionLookupListener listener)
                                                 throws SubscriptionException

Specified by:

lookupAssociations in interface SubscriptionManager

Parameters:

hash -

listener -

Returns:

Throws:

SubscriptionException

lookupAssociations

public SubscriptionAssociationLookup lookupAssociations(byte[] hash,
 String description,
 SubscriptionLookupListener listener)
                                                 throws SubscriptionException

Description copied from interface: SubscriptionManager

Full lookup

Specified by:

lookupAssociations in interface SubscriptionManager

Parameters:

hash -

listener -

Returns:

Throws:

SubscriptionException

lookupAssociations

private SubscriptionAssociationLookup lookupAssociations(DHTPluginInterface dht_plugin,
 byte[] hash,
 String description,
 SubscriptionLookupListener listener)
                                                  throws SubscriptionException

Throws:

SubscriptionException

lookupAssociationsSupport

protected SubscriptionAssociationLookup lookupAssociationsSupport(DHTPluginInterface dht_plugin,
 byte[] hash,
 String description,
 SubscriptionLookupListener _listener)
                                                           throws SubscriptionException

Throws:

SubscriptionException

getPopularity

protected void getPopularity(SubscriptionImpl subs,
 SubscriptionPopularityListener listener)
                      throws SubscriptionException

Throws:

SubscriptionException

getPopularityFromDHT

protected void getPopularityFromDHT(SubscriptionImpl subs,
 SubscriptionPopularityListener listener,
 boolean sync)

updatePopularityFromDHT

protected void updatePopularityFromDHT(SubscriptionImpl subs,
 boolean sync)

getPopularitySupport

protected void getPopularitySupport(DHTPluginInterface dht_plugin,
 SubscriptionImpl subs,
 SubscriptionPopularityListener _listener,
 boolean sync)

lookupSubscription

private void lookupSubscription(String description,
 byte[] association_hash,
 byte[] sid,
 int version,
 boolean is_anon,
 SubscriptionManagerImpl.subsLookupListener listener)

getSubscriptionFromPlatform

protected SubscriptionImpl getSubscriptionFromPlatform(byte[] sid,
 boolean is_anon,
 int add_type)
                                                throws SubscriptionException

Throws:

SubscriptionException

getSubscriptionFromVuzeFile

protected SubscriptionImpl getSubscriptionFromVuzeFile(byte[] sid,
 int add_type,
 File file)
                                                throws SubscriptionException

Throws:

SubscriptionException

getSubscriptionFromVuzeFileContent

protected SubscriptionImpl getSubscriptionFromVuzeFileContent(byte[] sid,
 int add_type,
 String content)
                                                       throws SubscriptionException

Throws:

SubscriptionException

getSubscriptionFromVuzeFile

protected SubscriptionImpl getSubscriptionFromVuzeFile(byte[] sid,
 int add_type,
 VuzeFile vf)
                                                throws SubscriptionException

Throws:

SubscriptionException

downloadSubscription

private void downloadSubscription(String description,
 byte[] association_hash,
 byte[] torrent_hash,
 byte[] sid,
 int version,
 int size,
 SubscriptionManagerImpl.subsLookupListener listener)

getSubscriptionDownloadCount

protected int getSubscriptionDownloadCount()

associationAdded

protected void associationAdded(SubscriptionImpl subscription,
 byte[] association_hash)

addPotentialAssociation

protected void addPotentialAssociation(SubscriptionImpl subs,
 String result_id,
 String key)

checkPotentialAssociations

protected void checkPotentialAssociations(byte[] hash,
 String key)

tidyPotentialAssociations

protected void tidyPotentialAssociations()

recordAssociations

protected void recordAssociations(byte[] association_hash,
 SubscriptionImpl[] subscriptions,
 boolean full_lookup)

addPrepareTrigger

protected void addPrepareTrigger(byte[] hash,
 Subscription[] subs,
 SubscriptionResult[] results)

removePrepareTrigger

protected void removePrepareTrigger(byte[] hash)

prepareDownload

protected void prepareDownload(Download download,
 Subscription[] subscriptions,
 SubscriptionResult[] results)

recordAssociationsSupport

protected boolean recordAssociationsSupport(byte[] association_hash,
 SubscriptionImpl[] subscriptions,
 boolean full_lookup)

searchTemplateOK

private void searchTemplateOK(SubscriptionImpl subs,
 Download download)

assocOK

private void assocOK(SubscriptionImpl subs,
 SubscriptionImpl.association assoc)

waitForChat

private void waitForChat(BuddyPluginBeta.ChatInstance chat,
 AERunnable runnable)

publishAssociations

private boolean publishAssociations()

getPublishRemainingCount

private int getPublishRemainingCount()

publishAssociation

private void publishAssociation(SubscriptionImpl subs,
 SubscriptionImpl.association assoc)

publishNextAssociation

private void publishNextAssociation()

subscriptionUpdated

protected void subscriptionUpdated()

publishSubscriptions

protected void publishSubscriptions()

publishSubscription

protected void publishSubscription(SubscriptionImpl subs)

updateSubscription

protected void updateSubscription(SubscriptionImpl subs,
 int new_version)

encodeSubscriptionDetails

protected byte[] encodeSubscriptionDetails(SubscriptionImpl subs)
                                    throws IOException

Throws:

IOException

decodeSubscriptionDetails

protected Map decodeSubscriptionDetails(byte[] data)
                                 throws IOException

Throws:

IOException

updateSubscription

protected void updateSubscription(SubscriptionImpl subs,
 int update_version,
 byte[] update_hash,
 int update_size)

downloadTorrent

protected Object[] downloadTorrent(byte[] hash,
 int update_size)

downloadSubscription

private void downloadSubscription(String description,
 TOTorrent torrent,
 InetSocketAddress peer,
 byte[] subs_id,
 int version,
 String name,
 SubscriptionManagerImpl.downloadListener listener)

updateSubscription

protected void updateSubscription(SubscriptionImpl subs,
 int new_version,
 TOTorrent torrent,
 InetSocketAddress peer)

askIfCanUpgrade

protected boolean askIfCanUpgrade(SubscriptionImpl subs,
 int new_version)

recoverSubscriptionUpdate

protected boolean recoverSubscriptionUpdate(Download download,
 Map rd)

updateSubscription

protected void updateSubscription(SubscriptionImpl subs,
 Download download,
 File torrent_file,
 File data_file)

removeDownload

protected void removeDownload(Download download,
 boolean remove_data)

updateSubscription

protected void updateSubscription(SubscriptionImpl subs,
 File data_location)

getMagnetPlugin

protected MagnetPlugin getMagnetPlugin()

getEngine

protected Engine getEngine(SubscriptionImpl subs,
 Map json_map,
 boolean local_only)
                    throws SubscriptionException

Throws:

SubscriptionException

libraryMutated

private void libraryMutated()

loadResults

protected LinkedHashMap<String, SubscriptionResultImpl> loadResults(SubscriptionImpl subs)

setCategoryOnExisting

protected void setCategoryOnExisting(SubscriptionImpl subscription,
 String old_category,
 String new_category)

getDefaultCheckFrequencyMins

public int getDefaultCheckFrequencyMins()

Specified by:

getDefaultCheckFrequencyMins in interface SubscriptionManager

setDefaultCheckFrequencyMins

public void setDefaultCheckFrequencyMins(int def)

Specified by:

setDefaultCheckFrequencyMins in interface SubscriptionManager

getMaxNonDeletedResults

public int getMaxNonDeletedResults()

Specified by:

getMaxNonDeletedResults in interface SubscriptionManager

setMaxNonDeletedResults

public void setMaxNonDeletedResults(int max)

Specified by:

setMaxNonDeletedResults in interface SubscriptionManager

getAutoStartDownloads

public boolean getAutoStartDownloads()

Specified by:

getAutoStartDownloads in interface SubscriptionManager

setAutoStartDownloads

public void setAutoStartDownloads(boolean auto_start)

Specified by:

setAutoStartDownloads in interface SubscriptionManager

getAutoStartMinMB

public int getAutoStartMinMB()

Specified by:

getAutoStartMinMB in interface SubscriptionManager

setAutoStartMinMB

public void setAutoStartMinMB(int mb)

Specified by:

setAutoStartMinMB in interface SubscriptionManager

getAutoStartMaxMB

public int getAutoStartMaxMB()

Specified by:

getAutoStartMaxMB in interface SubscriptionManager

setAutoStartMaxMB

public void setAutoStartMaxMB(int mb)

Specified by:

setAutoStartMaxMB in interface SubscriptionManager

getAutoDownloadMarkReadAfterDays

public int getAutoDownloadMarkReadAfterDays()

Specified by:

getAutoDownloadMarkReadAfterDays in interface SubscriptionManager

setAutoDownloadMarkReadAfterDays

public void setAutoDownloadMarkReadAfterDays(int days)

Specified by:

setAutoDownloadMarkReadAfterDays in interface SubscriptionManager

getAddHashDirs

public boolean getAddHashDirs()

Specified by:

getAddHashDirs in interface SubscriptionManager

setAddHashDirs

public void setAddHashDirs(boolean b)

Specified by:

setAddHashDirs in interface SubscriptionManager

shouldAutoStart

protected boolean shouldAutoStart(Torrent torrent)

saveResults

protected void saveResults(SubscriptionImpl subs,
 SubscriptionResultImpl[] results,
 List<SubscriptionResultImpl> new_unread_results)

processResults

private void processResults(SubscriptionImpl subs,
 Collection<SubscriptionResultImpl> results,
 boolean has_new_results)

checkGloballyMarkedRead

private void checkGloballyMarkedRead(SubscriptionImpl subs,
 Collection<SubscriptionResultImpl> results)

evalScript

protected void evalScript(SubscriptionImpl subs,
 String script,
 List<SubscriptionResultImpl> subs_results,
 String intent_key)

loadConfig

private void loadConfig()

configDirty

protected void configDirty(SubscriptionImpl subs,
 int reason)

configDirty

protected void configDirty()

saveConfig

protected void saveConfig()

getKeyBytes

private byte[] getKeyBytes(String key)

getLogger

private AEDiagnosticsLogger getLogger()

log

public void log(String s,
 Throwable e)

log

public void log(String s)

addListener

public void addListener(SubscriptionManagerListener listener)

Specified by:

addListener in interface SubscriptionManager

removeListener

public void removeListener(SubscriptionManagerListener listener)

Specified by:

removeListener in interface SubscriptionManager

generate

public void generate(IndentWriter writer)

Specified by:

generate in interface AEDiagnosticsEvidenceGenerator

selectDHTPlugin

private DHTPluginInterface selectDHTPlugin(SubscriptionImpl subs)

selectDHTPlugin

private DHTPluginInterface selectDHTPlugin(Download download)

selectDHTPlugin

private DHTPluginInterface selectDHTPlugin(String[] networks)

subscribeToSubscription

public Subscription subscribeToSubscription(String uri)
                                     throws Exception

Specified by:

subscribeToSubscription in interface SubscriptionManager

Throws:

Exception

subscribeToRSS

public Subscription subscribeToRSS(String name,
 URL url,
 int interval,
 boolean is_public,
 String creator_ref)
                            throws Exception

Specified by:

subscribeToRSS in interface SubscriptionManager

Throws:

Exception

getGMAR

private SubscriptionImpl getGMAR(boolean create_if_missing)

markReadInAllSubscriptions

public void markReadInAllSubscriptions(SearchSubsResultBase[] results)

Specified by:

markReadInAllSubscriptions in interface SubscriptionManager