@@ -158,15 +158,10 @@ public async Task<SearchResult[]> RunSearchAsync(SearchQuery query, bool reload
158158 Task < SearchResult > task = await Task . WhenAny ( tasks ) ;
159159 tasks . Remove ( task ) ;
160160
161- // Debug.WriteLine($"{task.Id} {task.Status}");
162161 SearchResult result = await task ;
163162
164- // ProcessResult(result);
165-
166163 results [ i ] = result ;
167164 i ++ ;
168-
169- // results.Add(result);
170165 }
171166
172167 ResultChannel ? . Writer . Complete ( ) ;
@@ -176,10 +171,6 @@ public async Task<SearchResult[]> RunSearchAsync(SearchQuery query, bool reload
176171
177172 if ( Config . PriorityEngines == SearchEngineOptions . Auto ) {
178173
179- // var sri = results.SelectMany(r => r.Results).ToArray();
180- // var result = Optimize(sri).FirstOrDefault() ?? sri.FirstOrDefault();
181- //todo
182-
183174 try {
184175
185176 var ordered = results . Select ( x => x . GetBestResult ( ) )
@@ -236,17 +227,6 @@ private void ProcessResult(SearchResult result)
236227
237228 private static void OpenResult ( [ MN ] Url url1 )
238229 {
239- // #if DEBUG && !TEST
240- /*
241- #pragma warning disable CA1822
242-
243- // ReSharper disable once MemberCanBeMadeStatic.Local
244- Logger.LogDebug("Not opening {url}", url1);
245- return;
246-
247- #pragma warning restore CA1822
248- */
249- // #else
250230
251231 if ( url1 == null ) {
252232 return ;
@@ -259,46 +239,29 @@ private static void OpenResult([MN] Url url1)
259239 // var b = Open(url1, out var proc);
260240
261241 if ( b && proc is { } ) {
262- /*var o = proc.WaitForExit(TimeSpan.FromSeconds(3));
263-
264- if (o) {
265- Debug.WriteLine($"{proc}");
266- }*/
267242 proc . Dispose ( ) ;
268243 }
269244
270- // Process.Start(url1);
271- // HttpUtilities.TryOpenUrl(url1);
272- // #endif
273-
274245 }
275246
276247 private void OpenResult ( [ MN ] SearchResultItem result )
277248 {
278- // #if DEBUG && !TEST
279- /* #pragma warning disable CA1822
249+ #if DEBUG && ! TEST
250+ #pragma warning disable CA1822
280251
281252 // ReSharper disable once MemberCanBeMadeStatic.Local
282253 Logger . LogDebug ( "Not opening result {result}" , result ) ;
283254 return ;
284255
285- #pragma warning restore CA1822*/
286- // #else
287-
256+ #pragma warning restore CA1822
257+ #endif
288258 OnOpen ? . Invoke ( this , result ) ;
289259
290260 if ( result != null ) {
291261
292- if ( Config . OpenRaw ) {
293- OpenResult ( result . Root . GetRawResultItem ( ) . Url ) ;
294- }
295- else {
296- OpenResult ( result . Url ) ;
297- // OpenResult(result);
298-
299- }
262+ var url = Config . OpenRaw ? result . Root . GetRawResultItem ( ) . Url : result . Url ;
263+ OpenResult ( url ) ;
300264 }
301- // #endif
302265
303266 }
304267
@@ -313,9 +276,6 @@ public List<Task<SearchResult>> GetSearchTasks(SearchQuery query, TaskScheduler
313276 Task < SearchResult > res = e . GetResultAsync ( query , token : token )
314277 . ContinueWith ( ( r ) =>
315278 {
316-
317- // Debug.Assert(r.IsCompleted);
318- // Debug.WriteLine($"{r.Id} :: {r.Status}");
319279 ProcessResult ( r . Result ) ;
320280 return r . Result ;
321281
@@ -365,63 +325,6 @@ public BaseSearchEngine TryGetEngine(SearchEngineOptions o)
365325 return Engines . FirstOrDefault ( e => e . EngineOption == o ) ;
366326 }
367327
368- /*public static ValueTask<IReadOnlyList<SearchResultItem>> Filter(IEnumerable<SearchResultItem> sri)
369- {
370- var sri2 = sri.AsParallel().DistinctBy(e => e.Url).ToList();
371-
372- return ValueTask.FromResult<IReadOnlyList<SearchResultItem>>(sri2);
373- }
374-
375- public static IReadOnlyList<SearchResultItem> Optimize(IEnumerable<SearchResultItem> sri)
376- {
377- var items = sri.Where(r => SearchQuery.IsValidSourceType(r.Url))
378- .OrderByDescending(r => r.Score)
379- .ThenByDescending(r => r.Similarity)
380- .ToArray();
381-
382- try {
383- /*var c = items.Where(r => r.Root.Engine.EngineOption == SearchEngineOptions.TraceMoe
384- /*&& r.Similarity <= TraceMoeEngine.FILTER_THRESHOLD#2#);
385- items = items.Except(c).ToArray();#1#
386-
387- }
388- catch (Exception e) {
389- Logger.LogError("{Error}", e.Message);
390- }
391- finally { }
392-
393- return items.AsReadOnly();
394- }
395-
396- public static async Task<IReadOnlyList<UniSource>> GetDirectImagesAsync(IEnumerable<SearchResultItem> sri)
397- {
398- //
399- var filter = Optimize(sri)
400- .DistinctBy(r => r.Url)
401- // .Where(r => r.Score >= SearchResultItem.SCORE_THRESHOLD) // probably can be removed/reduced
402- .Select(async r =>
403- {
404- bool b = await r.LoadUniAsync();
405- return r.Uni;
406- })
407- .ToList();
408-
409- var di = new List<UniSource>();
410-
411- while (filter.Any()) {
412- var t1 = await Task.WhenAny(filter);
413- filter.Remove(t1);
414- var uf = await t1;
415-
416- if (uf != null) {
417- di.AddRange(uf);
418- }
419-
420- }
421-
422- return di.AsReadOnly();
423- }*/
424-
425328 public void Dispose ( )
426329 {
427330 foreach ( BaseSearchEngine engine in Engines ) {
0 commit comments