Flow.Launcher/Plugins/Flow.Launcher.Plugin.Explorer/Search/WindowsIndex/IndexSearcher.cs
2020-05-19 18:46:42 +10:00

103 lines
3.4 KiB
C#

using Flow.Launcher.Infrastructure.Logger;
using Flow.Launcher.Plugin.SharedCommands;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data.OleDb;
using System.Diagnostics;
namespace Flow.Launcher.Plugin.Explorer.Search.WindowsIndex
{
internal class IndexSearcher
{
public OleDbConnection conn;
public OleDbCommand command;
public OleDbDataReader dataReaderResults;
private PluginInitContext _context;
private readonly object _lock = new object();
public IndexSearcher(PluginInitContext context)
{
_context = context;
}
internal List<Result> ExecuteWindowsIndexSearch(string query, string connectionString)
{
var results = new List<Result>();
try
{
using (conn = new OleDbConnection(connectionString))
{
conn.Open();
using (command = new OleDbCommand(query, conn))
{
// Results return as an OleDbDataReader.
using (dataReaderResults = command.ExecuteReader())
{
if (dataReaderResults.HasRows)
{
while (dataReaderResults.Read())
{
if (dataReaderResults.GetValue(0) != DBNull.Value && dataReaderResults.GetValue(1) != DBNull.Value)
{
results.Add(CreateResult(dataReaderResults.GetString(0),
dataReaderResults.GetString(1),
dataReaderResults.GetString(2)));
}
}
}
}
}
}
}
catch (InvalidOperationException)
{
// Internal error from ExecuteReader(): Connection closed.
}
catch (Exception ex)
{
Log.Info(ex.ToString());//UPDATE THIS LOGGING
}
return results;
}
private Result CreateResult(string filename, string path, string fileType)
{
return new Result
{
Title = filename,
SubTitle = path,
IcoPath = fileType == "Directory" ? Constants.FolderImagePath : Constants.FileImagePath,
Action = c =>
{
try
{
FilesFolders.OpenPath(path);
}
catch (Win32Exception)
{
_context.API.ShowMsg("Explorer plugin: ", "Unable to open the selected file", string.Empty); //<=========
}
return true;
}
};
}
internal List<Result> WindowsIndexSearch(string query, string connectionString, Func<string, string> constructQuery)
{
lock (_lock)
{
var constructedQuery = constructQuery(query);
return ExecuteWindowsIndexSearch(constructedQuery, connectionString);
}
}
}
}