2 // This file is part of the aMule Project.
4 // Copyright (c) 2003-2008 aMule Team ( admin@amule.org / http://www.amule.org )
5 // Copyright (c) 2002-2008 Merkur ( devs@emule-project.net / http://www.emule-project.net )
7 // Any parts of this program derived from the xMule, lMule or eMule project,
8 // or contributed by third-party developers are copyrighted by their
11 // This program is free software; you can redistribute it and/or modify
12 // it under the terms of the GNU General Public License as published by
13 // the Free Software Foundation; either version 2 of the License, or
14 // (at your option) any later version.
16 // This program is distributed in the hope that it will be useful,
17 // but WITHOUT ANY WARRANTY; without even the implied warranty of
18 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
19 // GNU General Public License for more details.
21 // You should have received a copy of the GNU General Public License
22 // along with this program; if not, write to the Free Software
23 // Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
29 #include "Timer.h" // Needed for CTimer
30 #include "ObservableQueue.h" // Needed for CQueueObserver
31 #include "SearchFile.h" // Needed for CSearchFile
32 #include <memory> // Do_not_auto_remove (lionel's Mac, 10.3)
53 typedef std::vector
<CSearchFile
*> CSearchResultList
;
56 class CSearchList
: public wxEvtHandler
59 //! Structure used to pass search-parameters.
62 /** Prevents accidential use of uninitialized variables. */
63 CSearchParams() { minSize
= maxSize
= availability
= 0; }
65 //! The actual string to search for.
66 wxString searchString
;
67 //! The type of files to search for (may be empty), one of ED2KFTSTR_*
69 //! The filename extension. May be empty.
71 //! The smallest filesize in bytes to accept, zero for any.
73 //! The largest filesize in bytes to accept, zero for any.
75 //! The minumum available (source-count), zero for any.
76 uint32_t availability
;
82 /** Frees any remaining search-results. */
86 * Starts a new search.
88 * @param searchID The ID of the search, which may be modified.
89 * @param type The type of search, see SearchType.
90 * @param params The search parameters, see CSearchParams.
91 * @return An empty string on success, otherwise an error-message.
93 wxString
StartNewSearch(uint32
* searchID
, SearchType type
, const CSearchParams
& params
);
95 /** Stops the current search, if any is in progress. */
96 void StopGlobalSearch();
98 /** Returns the completion percentage of the current search. */
99 uint32
GetSearchProgress() const;
101 /** This function is called once the local (ed2k) search has ended. */
102 void LocalSearchEnd();
106 * Returns the list of results for the specified search.
108 * If the search is not valid, an empty list is returned.
110 const CSearchResultList
& GetSearchResults(long searchID
) const;
112 /** Removes all results for the specified search. */
113 void RemoveResults(long searchID
);
116 /** Finds the search-result (by hash) and downloads it in the given category. */
117 void AddFileToDownloadByHash(const CMD4Hash
& hash
, uint8 category
= 0);
121 * Processes a list of shared files from a client.
123 * @param packet The raw packet received from the client.
124 * @param size the length of the packet.
125 * @param sender The sender of the packet.
126 * @param moreResultsAvailable Set to a value specifying if more results are available.
127 * @param directory The directory containing the shared files.
129 void ProcessSharedFileList(const byte
* packet
, uint32 size
, CUpDownClient
* sender
, bool* moreResultsAvailable
, const wxString
& directory
);
132 * Processes a search-result sent via TCP from the local server. All results are added.
134 * @param packet The packet containing one or more search-results.
135 * @param size the length of the packet.
136 * @param optUTF8 Specifies if the server supports UTF8.
137 * @param serverIP The IP of the server sending the results.
138 * @param serverPort The Port of the server sending the results.
140 void ProcessSearchAnswer(const uint8_t* packet
, uint32_t size
, bool optUTF8
, uint32_t serverIP
, uint16_t serverPort
);
143 * Processes a search-result sent via UDP. Only one result is read from the packet.
145 * @param packet The packet containing one or more search-results.
146 * @param optUTF8 Specifies if the server supports UTF8.
147 * @param serverIP The IP of the server sending the results.
148 * @param serverPort The Port of the server sending the results.
150 void ProcessUDPSearchAnswer(const CMemFile
& packet
, bool optUTF8
, uint32 serverIP
, uint16 serverPort
);
154 * Adds a result in the form of a kad search-keyword to the specified result-list.
156 * @param searchID The search to which this result belongs.
157 * @param fileID The hash of the result-file.
158 * @param name The filename of the result.
159 * @param size The filesize of the result.
160 * @param type The filetype of the result (TODO: Not used?)
161 * @param kadPublishInfo The kademlia publish information of the result.
162 * @param taglist List of additional tags associated with the search-result.
164 void KademliaSearchKeyword(uint32_t searchID
, const Kademlia::CUInt128
*fileID
, const wxString
& name
, uint64_t size
, const wxString
& type
, uint32_t kadPublishInfo
, const TagPtrList
& taglist
);
168 /** Event-handler for global searches. */
169 void OnGlobalSearchTimer(CTimerEvent
& evt
);
172 * Adds the specified file to the current search's results.
174 * @param toadd The result to add.
175 * @param clientResponse Is the result sent by a client (shared-files list).
176 * @return True if the results were added, false otherwise.
178 * Note that this function takes ownership of the CSearchFile object,
179 * regardless of whenever or not it was actually added to the results list.
181 bool AddToList(CSearchFile
* toadd
, bool clientResponse
= false);
183 //! This auto-pointer is used to safely prevent leaks.
184 typedef std::auto_ptr
<CMemFile
> CMemFilePtr
;
186 /** Create a basic search-packet for the given search-type. */
187 CMemFilePtr
CreateSearchData(const CSearchParams
& params
, SearchType type
, bool supports64bit
, bool& packetUsing64bit
);
190 //! Timer used for global search intervals.
191 CTimer m_searchTimer
;
193 //! The current search-type, regarding the last/current search.
194 SearchType m_searchType
;
196 //! Specifies if a search is being performed.
197 bool m_searchInProgress
;
199 //! The ID of the current search.
200 long m_currentSearch
;
202 //! The current packet used for searches.
203 CPacket
* m_searchPacket
;
205 //! Does the current search packet contain 64bit values?
206 bool m_64bitSearchPacket
;
208 //! Queue of servers to ask when doing global searches.
209 //! TODO: Replace with 'cookie' system.
210 CQueueObserver
<CServer
*> m_serverQueue
;
212 //! Shorthand for the map of results (key is a SearchID).
213 typedef std::map
<long, CSearchResultList
> ResultMap
;
215 //! Map of all search-results added.
218 //! Contains the results type desired in the current search.
219 //! If not empty, results of different types are filtered.
220 wxString m_resultType
;
223 DECLARE_EVENT_TABLE()
227 #endif // SEARCHLIST_H
228 // File_checked_for_headers