'everything' removed tracker plugin from core
SVN revision: 47803
This commit is contained in:
Hannes Janetzek
parent
21b0e27b24
commit
91477b60c2
|
|
@ -34,13 +34,6 @@ evry_plug_dir_browse_la_LIBADD = @e_libs@ ../libfoo.la
|
|||
evry_plug_dir_browse_la_LDFLAGS = -module -avoid-version
|
||||
evry_plug_dir_browse_la_LIBTOOLFLAGS = --tag=disable-static
|
||||
|
||||
evry_plug_trackerdir = $(plugindir)
|
||||
evry_plug_tracker_LTLIBRARIES = evry_plug_tracker.la
|
||||
evry_plug_tracker_la_SOURCES = evry_plug_tracker.c
|
||||
evry_plug_tracker_la_LIBADD = @e_libs@ ../libfoo.la
|
||||
evry_plug_tracker_la_LDFLAGS = -module -avoid-version
|
||||
evry_plug_tracker_la_LIBTOOLFLAGS = --tag=disable-static
|
||||
|
||||
evry_plug_calcdir = $(plugindir)
|
||||
evry_plug_calc_LTLIBRARIES = evry_plug_calc.la
|
||||
evry_plug_calc_la_SOURCES = evry_plug_calc.c
|
||||
|
|
|
|||
|
|
@ -1,557 +0,0 @@
|
|||
#include "e_mod_main.h"
|
||||
|
||||
/* TODO check if trackerd is running and version */
|
||||
|
||||
|
||||
typedef struct _Plugin Plugin;
|
||||
|
||||
struct _Plugin
|
||||
{
|
||||
Evry_Plugin base;
|
||||
|
||||
int active;
|
||||
char *condition;
|
||||
char *service;
|
||||
int max_hits;
|
||||
const char *input;
|
||||
const char *matched;
|
||||
Eina_List *files;
|
||||
};
|
||||
|
||||
static E_DBus_Connection *conn = NULL;
|
||||
static Eina_List *plugins = NULL;
|
||||
static int _prio = 5;
|
||||
static int active = 0;
|
||||
|
||||
static DBusPendingCall *pending_get_name_owner = NULL;
|
||||
static E_DBus_Signal_Handler *cb_name_owner_changed = NULL;
|
||||
static const char bus_name[] = "org.freedesktop.Tracker";
|
||||
static const char fdo_bus_name[] = "org.freedesktop.DBus";
|
||||
static const char fdo_interface[] = "org.freedesktop.DBus";
|
||||
static const char fdo_path[] = "/org/freedesktop/DBus";
|
||||
|
||||
static Evry_Plugin *
|
||||
_begin(Evry_Plugin *plugin, const Evry_Item *it)
|
||||
{
|
||||
PLUGIN(p, plugin);
|
||||
|
||||
p->active = 0;
|
||||
|
||||
/* is APPLICATION ? */
|
||||
if (it && it->plugin->type_out == plugin->type_in)
|
||||
{
|
||||
ITEM_APP(app, it);
|
||||
Eina_List *l;
|
||||
const char *mime;
|
||||
char mime_entry[256];
|
||||
char rdf_query[32768];
|
||||
int len = 0;
|
||||
|
||||
if (p->condition[0]) free (p->condition);
|
||||
p->condition = "";
|
||||
|
||||
if (!app->desktop || !app->desktop->mime_types)
|
||||
return NULL;
|
||||
|
||||
rdf_query[0] = '\0';
|
||||
strcat(rdf_query, "<rdfq:Condition><rdfq:or>");
|
||||
|
||||
EINA_LIST_FOREACH(app->desktop->mime_types, l, mime)
|
||||
{
|
||||
if (!strcmp(mime, "x-directory/normal"))
|
||||
return NULL;
|
||||
|
||||
snprintf(mime_entry, 256,
|
||||
"<rdfq:contains>"
|
||||
"<rdfq:Property name=\"File:Mime\" />"
|
||||
"<rdf:String>%s</rdf:String> "
|
||||
"</rdfq:contains>",
|
||||
mime);
|
||||
|
||||
strcat(rdf_query, mime_entry);
|
||||
len += 256;
|
||||
if (len > 32000) break;
|
||||
}
|
||||
strcat(rdf_query, "</rdfq:or></rdfq:Condition>");
|
||||
|
||||
p->condition = strdup(rdf_query);
|
||||
}
|
||||
|
||||
return plugin;
|
||||
}
|
||||
|
||||
static void
|
||||
_item_free(Evry_Item *it)
|
||||
{
|
||||
ITEM_FILE(file, it);
|
||||
if (file->uri) eina_stringshare_del(file->uri);
|
||||
if (file->mime) eina_stringshare_del(file->mime);
|
||||
|
||||
E_FREE(file);
|
||||
}
|
||||
|
||||
|
||||
static const char *
|
||||
_item_id(const char *uri)
|
||||
{
|
||||
const char *s1, *s2, *s3;
|
||||
s1 = s2 = s3 = uri;
|
||||
|
||||
while (s1 && ++s1 && (s1 = strchr(s1, '/')))
|
||||
{
|
||||
s3 = s2;
|
||||
s2 = s1;
|
||||
}
|
||||
|
||||
return s3;
|
||||
}
|
||||
|
||||
static Evry_Item_File *
|
||||
_item_add(Plugin *p, char *path, char *mime, int prio)
|
||||
{
|
||||
Evry_Item_File *file;
|
||||
|
||||
const char *filename;
|
||||
int folder = (!strcmp(mime, "Folder"));
|
||||
|
||||
/* folders are specifically searched */
|
||||
if (folder && EVRY_PLUGIN(p)->begin)
|
||||
return NULL;
|
||||
|
||||
filename = ecore_file_file_get(path);
|
||||
|
||||
if (!filename)
|
||||
return NULL;
|
||||
|
||||
file = E_NEW(Evry_Item_File, 1);
|
||||
if (!file) return NULL;
|
||||
|
||||
evry_item_new(EVRY_ITEM(file), EVRY_PLUGIN(p), filename, _item_free);
|
||||
EVRY_ITEM(file)->id = eina_stringshare_add(_item_id(path));
|
||||
file->uri = eina_stringshare_add(path);
|
||||
|
||||
if (folder)
|
||||
{
|
||||
EVRY_ITEM(file)->browseable = EINA_TRUE;
|
||||
EVRY_ITEM(file)->priority = 1;
|
||||
file->mime = eina_stringshare_add("x-directory/normal");
|
||||
}
|
||||
else
|
||||
file->mime = eina_stringshare_add(mime);
|
||||
|
||||
return file;
|
||||
}
|
||||
|
||||
static void
|
||||
_cleanup(Evry_Plugin *plugin)
|
||||
{
|
||||
PLUGIN(p, plugin);
|
||||
Evry_Item_File *file;
|
||||
|
||||
p->active = 0;
|
||||
|
||||
if (p->input)
|
||||
eina_stringshare_del(p->input);
|
||||
p->input = NULL;
|
||||
|
||||
if (p->matched)
|
||||
eina_stringshare_del(p->matched);
|
||||
p->matched = NULL;
|
||||
|
||||
EINA_LIST_FREE(p->files, file)
|
||||
evry_item_free(EVRY_ITEM(file));
|
||||
|
||||
EVRY_PLUGIN_ITEMS_CLEAR(p);
|
||||
}
|
||||
|
||||
static int
|
||||
_cb_sort(const void *data1, const void *data2)
|
||||
{
|
||||
const Evry_Item *it1, *it2;
|
||||
|
||||
it1 = data1;
|
||||
it2 = data2;
|
||||
|
||||
if (it1->priority - it2->priority)
|
||||
return (it1->priority - it2->priority);
|
||||
|
||||
return strcasecmp(it1->label, it2->label);
|
||||
}
|
||||
|
||||
static void
|
||||
_dbus_cb_reply(void *data, DBusMessage *msg, DBusError *error)
|
||||
{
|
||||
DBusMessageIter array, iter, item;
|
||||
char *uri, *mime, *date;
|
||||
Evry_Item_File *file;
|
||||
Eina_List *files = NULL;
|
||||
Plugin *p = data;
|
||||
|
||||
if (p->active) p->active--;
|
||||
|
||||
if (dbus_error_is_set(error))
|
||||
{
|
||||
_cleanup(EVRY_PLUGIN(p));
|
||||
active = 0;
|
||||
ERR("%s - %s\n", error->name, error->message);
|
||||
return;
|
||||
}
|
||||
|
||||
if (p->active) return;
|
||||
|
||||
dbus_message_iter_init(msg, &array);
|
||||
if(dbus_message_iter_get_arg_type(&array) == DBUS_TYPE_ARRAY)
|
||||
{
|
||||
dbus_message_iter_recurse(&array, &item);
|
||||
while(dbus_message_iter_get_arg_type(&item) == DBUS_TYPE_ARRAY)
|
||||
{
|
||||
dbus_message_iter_recurse(&item, &iter);
|
||||
|
||||
if (dbus_message_iter_get_arg_type(&iter) == DBUS_TYPE_STRING)
|
||||
{
|
||||
dbus_message_iter_get_basic(&iter, &uri);
|
||||
dbus_message_iter_next(&iter);
|
||||
/* dbus_message_iter_get_basic(&iter, &service); */
|
||||
dbus_message_iter_next(&iter);
|
||||
dbus_message_iter_get_basic(&iter, &mime);
|
||||
|
||||
dbus_message_iter_next(&iter);
|
||||
dbus_message_iter_get_basic(&iter, &date);
|
||||
|
||||
if (uri && mime && date)
|
||||
{
|
||||
file = _item_add(p, uri, mime, atoi(date));
|
||||
if (file) files = eina_list_append(files, file);
|
||||
}
|
||||
}
|
||||
dbus_message_iter_next(&item);
|
||||
}
|
||||
}
|
||||
|
||||
EVRY_PLUGIN_ITEMS_CLEAR(p);
|
||||
|
||||
if (files)
|
||||
{
|
||||
Eina_List *l;
|
||||
|
||||
EINA_LIST_FREE(p->files, file)
|
||||
evry_item_free(EVRY_ITEM(file));
|
||||
|
||||
files = eina_list_sort(files, eina_list_count(files), _cb_sort);
|
||||
p->files = files;
|
||||
|
||||
EINA_LIST_FOREACH(p->files, l, file)
|
||||
EVRY_PLUGIN_ITEM_APPEND(p, file);
|
||||
|
||||
if (p->matched)
|
||||
eina_stringshare_del(p->matched);
|
||||
if (p->input)
|
||||
p->matched = eina_stringshare_add(p->input);
|
||||
else
|
||||
p->matched = NULL;
|
||||
}
|
||||
else if (p->files && p->input && p->matched &&
|
||||
(strlen(p->input) > strlen(p->matched)))
|
||||
{
|
||||
Eina_List *l;
|
||||
|
||||
EINA_LIST_FOREACH(p->files, l, file)
|
||||
if (evry_fuzzy_match(EVRY_ITEM(file)->label, (p->input + strlen(p->matched))))
|
||||
EVRY_PLUGIN_ITEM_APPEND(p, file);
|
||||
}
|
||||
else
|
||||
{
|
||||
EINA_LIST_FREE(p->files, file)
|
||||
evry_item_free(EVRY_ITEM(file));
|
||||
|
||||
if (p->input)
|
||||
eina_stringshare_del(p->input);
|
||||
p->input = NULL;
|
||||
|
||||
if (p->matched)
|
||||
eina_stringshare_del(p->matched);
|
||||
p->matched = NULL;
|
||||
}
|
||||
|
||||
evry_plugin_async_update(EVRY_PLUGIN(p), EVRY_ASYNC_UPDATE_ADD);
|
||||
}
|
||||
|
||||
static int
|
||||
_fetch(Evry_Plugin *plugin, const char *input)
|
||||
{
|
||||
if (active)
|
||||
{
|
||||
PLUGIN(p, plugin);
|
||||
|
||||
DBusMessage *msg;
|
||||
int live_query_id = 0;
|
||||
int max_hits = p->max_hits;
|
||||
int offset = 0;
|
||||
int sort_descending = 1;
|
||||
int sort_by_service = 0;
|
||||
int sort_by_access = 0;
|
||||
char *search_text = NULL;
|
||||
char *fields[2];
|
||||
char *keywords[1];
|
||||
char *sort_fields[1];
|
||||
fields[0] = "File:Mime";
|
||||
fields[1] = "File:Accessed";
|
||||
keywords[0] = "";
|
||||
sort_fields[0] = "File:Accessed";
|
||||
char **_fields = fields;
|
||||
char **_keywords = keywords;
|
||||
char **_sort_fields = sort_fields;
|
||||
|
||||
if (p->input)
|
||||
eina_stringshare_del(p->input);
|
||||
p->input = NULL;
|
||||
|
||||
if (!conn)
|
||||
{
|
||||
_cleanup(plugin);
|
||||
return 0;
|
||||
}
|
||||
|
||||
if (input && (strlen(input) > 2))
|
||||
{
|
||||
p->input = eina_stringshare_add(input);
|
||||
search_text = malloc(sizeof(char) * strlen(input) + 1);
|
||||
sprintf(search_text, "%s", input);
|
||||
max_hits = 100;
|
||||
}
|
||||
else if (!input && !plugin->begin && plugin->type == type_object)
|
||||
{
|
||||
sort_by_access = 1;
|
||||
search_text = "";
|
||||
}
|
||||
else
|
||||
{
|
||||
_cleanup(plugin);
|
||||
return 0;
|
||||
}
|
||||
|
||||
p->active++;
|
||||
|
||||
msg = dbus_message_new_method_call(bus_name,
|
||||
"/org/freedesktop/Tracker/Search",
|
||||
"org.freedesktop.Tracker.Search",
|
||||
"Query");
|
||||
dbus_message_append_args(msg,
|
||||
DBUS_TYPE_INT32, &live_query_id,
|
||||
DBUS_TYPE_STRING, &p->service,
|
||||
DBUS_TYPE_ARRAY, DBUS_TYPE_STRING,
|
||||
&_fields, 2,
|
||||
DBUS_TYPE_STRING, &search_text,
|
||||
DBUS_TYPE_ARRAY, DBUS_TYPE_STRING,
|
||||
&_keywords, 0,
|
||||
DBUS_TYPE_STRING, &p->condition,
|
||||
DBUS_TYPE_BOOLEAN, &sort_by_service,
|
||||
DBUS_TYPE_ARRAY, DBUS_TYPE_STRING,
|
||||
&_sort_fields, sort_by_access,
|
||||
DBUS_TYPE_BOOLEAN, &sort_descending,
|
||||
DBUS_TYPE_INT32, &offset,
|
||||
DBUS_TYPE_INT32, &max_hits,
|
||||
DBUS_TYPE_INVALID);
|
||||
|
||||
e_dbus_message_send(conn, msg, _dbus_cb_reply, -1, p);
|
||||
dbus_message_unref(msg);
|
||||
|
||||
if (search_text && search_text[0] != '\0')
|
||||
free(search_text);
|
||||
|
||||
if (p->files) return 1;
|
||||
}
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
static Evas_Object *
|
||||
_icon_get(Evry_Plugin *p __UNUSED__, const Evry_Item *it, Evas *e)
|
||||
{
|
||||
ITEM_FILE(file, it);
|
||||
|
||||
if (it->browseable)
|
||||
return evry_icon_theme_get("folder", e);
|
||||
else
|
||||
return evry_icon_mime_get(file->mime, e);
|
||||
|
||||
return NULL;
|
||||
}
|
||||
|
||||
static void
|
||||
_plugin_new(const char *name, int type, char *service, int max_hits, int begin)
|
||||
{
|
||||
Plugin *p;
|
||||
|
||||
p = E_NEW(Plugin, 1);
|
||||
p->condition = "";
|
||||
p->service = service;
|
||||
p->max_hits = max_hits;
|
||||
p->active = 0;
|
||||
|
||||
if (!begin)
|
||||
evry_plugin_new(EVRY_PLUGIN(p), name, type, "", "FILE", 1, NULL, NULL,
|
||||
NULL, _cleanup, _fetch,
|
||||
NULL, _icon_get, NULL, NULL);
|
||||
else if (type == type_object)
|
||||
evry_plugin_new(EVRY_PLUGIN(p), name, type, "APPLICATION", "FILE", 1, NULL, NULL,
|
||||
_begin, _cleanup, _fetch,
|
||||
NULL, _icon_get, NULL, NULL);
|
||||
|
||||
plugins = eina_list_append(plugins, p);
|
||||
|
||||
evry_plugin_register(EVRY_PLUGIN(p), _prio++);
|
||||
}
|
||||
|
||||
|
||||
static void
|
||||
_dbus_cb_version(void *data, DBusMessage *msg, DBusError *error)
|
||||
{
|
||||
DBusMessageIter iter;
|
||||
int version = 0;
|
||||
|
||||
if (dbus_error_is_set(error))
|
||||
{
|
||||
ERR("%s - %s\n", error->name, error->message);
|
||||
return;
|
||||
}
|
||||
|
||||
dbus_message_iter_init(msg, &iter);
|
||||
|
||||
if (dbus_message_iter_get_arg_type(&iter) == DBUS_TYPE_INT32)
|
||||
dbus_message_iter_get_basic(&iter, &version);
|
||||
else
|
||||
return;
|
||||
|
||||
if (version >= 690)
|
||||
active = EINA_TRUE;
|
||||
else
|
||||
{
|
||||
ERR("tracker version 0.69 required, is: %d\n", version);
|
||||
active = EINA_FALSE;
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
_get_version(void)
|
||||
{
|
||||
DBusMessage *msg;
|
||||
|
||||
msg = dbus_message_new_method_call(bus_name,
|
||||
"/org/freedesktop/Tracker",
|
||||
bus_name,
|
||||
"GetVersion");
|
||||
|
||||
e_dbus_message_send(conn, msg, _dbus_cb_version, -1, NULL);
|
||||
dbus_message_unref(msg);
|
||||
}
|
||||
|
||||
static void
|
||||
_name_owner_changed(void *data __UNUSED__, DBusMessage *msg)
|
||||
{
|
||||
DBusError err;
|
||||
const char *name, *from, *to;
|
||||
|
||||
dbus_error_init(&err);
|
||||
if (!dbus_message_get_args(msg, &err,
|
||||
DBUS_TYPE_STRING, &name,
|
||||
DBUS_TYPE_STRING, &from,
|
||||
DBUS_TYPE_STRING, &to,
|
||||
DBUS_TYPE_INVALID))
|
||||
{
|
||||
ERR("could not get NameOwnerChanged arguments: %s: %s",
|
||||
err.name, err.message);
|
||||
dbus_error_free(&err);
|
||||
return;
|
||||
}
|
||||
|
||||
if (strcmp(name, bus_name) != 0)
|
||||
return;
|
||||
|
||||
DBG("NameOwnerChanged from=[%s] to=[%s]", from, to);
|
||||
|
||||
if (to[0] == '\0')
|
||||
active = EINA_FALSE;
|
||||
else
|
||||
active = EINA_TRUE;
|
||||
/* _get_version(); */
|
||||
}
|
||||
|
||||
static void
|
||||
_get_name_owner(void *data __UNUSED__, DBusMessage *msg, DBusError *err)
|
||||
{
|
||||
DBusMessageIter itr;
|
||||
int t;
|
||||
const char *uid;
|
||||
|
||||
pending_get_name_owner = NULL;
|
||||
|
||||
if (dbus_error_is_set(err))
|
||||
{
|
||||
ERR("request name error: %s", err->message);
|
||||
//dbus_error_free(err);
|
||||
e_dbus_connection_close(conn);
|
||||
conn = NULL;
|
||||
return;
|
||||
}
|
||||
|
||||
if (!dbus_message_iter_init(msg, &itr))
|
||||
return;
|
||||
|
||||
t = dbus_message_iter_get_arg_type(&itr);
|
||||
if (t != DBUS_TYPE_STRING)
|
||||
return;
|
||||
|
||||
dbus_message_iter_get_basic(&itr, &uid);
|
||||
|
||||
if (uid)
|
||||
active = EINA_TRUE;
|
||||
/* _get_version(); */
|
||||
|
||||
return;
|
||||
}
|
||||
|
||||
static Eina_Bool
|
||||
_init(void)
|
||||
{
|
||||
conn = e_dbus_bus_get(DBUS_BUS_SESSION);
|
||||
|
||||
if (!conn) return EINA_FALSE;
|
||||
|
||||
cb_name_owner_changed = e_dbus_signal_handler_add
|
||||
(conn, fdo_bus_name, fdo_path, fdo_interface, "NameOwnerChanged",
|
||||
_name_owner_changed, NULL);
|
||||
|
||||
pending_get_name_owner = e_dbus_get_name_owner
|
||||
(conn, bus_name, _get_name_owner, NULL);
|
||||
|
||||
_plugin_new("Folders", type_subject, "Folders", 20, 0);
|
||||
_plugin_new("Images", type_subject, "Images", 20, 0);
|
||||
_plugin_new("Music", type_subject, "Music", 20, 0);
|
||||
_plugin_new("Videos", type_subject, "Videos", 20, 0);
|
||||
_plugin_new("Documents", type_subject, "Documents", 20, 0);
|
||||
|
||||
_plugin_new("Find Files", type_object, "Files", 20, 1);
|
||||
_plugin_new("Folders", type_object, "Folders", 20, 0);
|
||||
|
||||
return EINA_TRUE;
|
||||
}
|
||||
|
||||
static void
|
||||
_shutdown(void)
|
||||
{
|
||||
Plugin *p;
|
||||
|
||||
if (conn) e_dbus_connection_close(conn);
|
||||
|
||||
EINA_LIST_FREE(plugins, p)
|
||||
{
|
||||
if (p->condition[0]) free(p->condition);
|
||||
|
||||
EVRY_PLUGIN_FREE(p);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
EINA_MODULE_INIT(_init);
|
||||
EINA_MODULE_SHUTDOWN(_shutdown);
|
||||
Loading…
Reference in New Issue