~ubuntu-branches/ubuntu/precise/rygel/precise

}

 

 

RygelTrackerSearchContainer* rygel_tracker_search_container_construct (GType object_type, const char* id, RygelMediaContainer* parent, const char* title, const char* service, const char* query_condition, char** keywords, int keywords_length1) {

        GError * _inner_error_;

        RygelTrackerSearchContainer * self;

        char* _tmp0_;

        char** _tmp2_;

        char** _tmp1_;

        char* _tmp3_;

        g_return_val_if_fail (id != NULL, NULL);

        g_return_val_if_fail (parent != NULL, NULL);

        g_return_val_if_fail (title != NULL, NULL);

        g_return_val_if_fail (service != NULL, NULL);

        g_return_val_if_fail (query_condition != NULL, NULL);

        _inner_error_ = NULL;

        self = (RygelTrackerSearchContainer*) rygel_media_container_construct (object_type, id, parent, title, (guint) 0);

        self->service = (_tmp0_ = g_strdup (service), _g_free0 (self->service), _tmp0_);

        self->keywords = (_tmp2_ = (_tmp1_ = keywords, (_tmp1_ == NULL) ? ((gpointer) _tmp1_) : _vala_array_dup1 (_tmp1_, keywords_length1)), self->keywords = (_vala_array_free (self->keywords, self->keywords_length1, (GDestroyNotify) g_free), NULL), self->keywords_length1 = keywords_length1, _tmp2_);

        self->query_condition = (_tmp3_ = g_strdup (query_condition), _g_free0 (self->query_condition), _tmp3_);

        {

                rygel_tracker_search_container_create_proxies (self, &_inner_error_);

                if (_inner_error_ != NULL) {

                        if (_inner_error_->domain == DBUS_GERROR) {

                                goto __catch4_dbus_gerror;

                        }

                        goto __finally4;

                }

                rygel_tracker_search_container_get_children_count (self, NULL, NULL);

        }

        goto __finally4;

        __catch4_dbus_gerror:

                _error_ = _inner_error_;

                _inner_error_ = NULL;

                {

                        g_critical ("rygel-tracker-search-container.vala:66: Failed to connect to session bus: %s\n", _error_->message);

                        _g_error_free0 (_error_);

                }

        }

}

 

 

RygelTrackerSearchContainer* rygel_tracker_search_container_new (const char* id, RygelMediaContainer* parent, const char* title, const char* service, const char* query_condition, char** keywords, int keywords_length1) {

        return rygel_tracker_search_container_construct (RYGEL_TYPE_TRACKER_SEARCH_CONTAINER, id, parent, title, service, query_condition, keywords, keywords_length1);

}

 

 

                case 0:

                {

                        {

                                if (_vala_strcmp0 (data->self->query_condition, "") != 0) {

                                        data->query = (data->_tmp1_ = g_strconcat (data->_tmp0_ = g_strconcat ("<rdfq:Condition>\n", data->self->query_condition, NULL), "</rdfq:Condition>", NULL), _g_free0 (data->query), data->_tmp1_);

                                        _g_free0 (data->_tmp0_);

                                } else {

                                        data->query = (data->_tmp2_ = g_strdup (""), _g_free0 (data->query), data->_tmp2_);

                                }

                                rygel_tracker_search_iface_query (data->self->search_proxy, 0, data->self->service, (data->_tmp3_ = g_new0 (char*, 0 + 1), data->_tmp3__length1 = 0, data->_tmp3_), 0, "", data->self->keywords, data->self->keywords_length1, data->query, FALSE, (data->_tmp4_ = g_new0 (char*, 0 + 1), data->_tmp4__length1 = 0, data->_tmp4_), 0, FALSE, 0, -1, rygel_tracker_search_container_get_children_count_ready, data);

                                data->_state_ = 3;

                                        goto __catch5_g_error;

                                        goto __finally5;

                                }

                                ((RygelMediaContainer*) data->self)->child_count = (guint) data->search_result_length1;

                                rygel_media_container_updated ((RygelMediaContainer*) data->self);

                                _g_free0 (data->query);

                                data->search_result = (_vala_array_free (data->search_result, data->search_result_length1 * data->search_result_length2, (GDestroyNotify) g_free), NULL);

                        }

                                data->_error_ = data->_inner_error_;

                                data->_inner_error_ = NULL;

                                {

                                        g_critical ("rygel-tracker-search-container.vala:101: error getting items under service '%s': %s", data->self->service, data->_error_->message);

                                        _g_error_free0 (data->_error_);

                                        {

                                                if (data->_state_ == 0) {

                case 0:

                {

                        data->expression = rygel_relational_expression_new ();

                        ((RygelSearchExpression*) data->expression)->op = GINT_TO_POINTER (GUPNP_SEARCH_CRITERIA_OP_EQ);

                        ((RygelSearchExpression*) data->expression)->operand1 = (data->_tmp0_ = g_strdup ("@parentID"), _g_free0 (((RygelSearchExpression*) data->expression)->operand1), data->_tmp0_);

                        ((RygelSearchExpression*) data->expression)->operand2 = (data->_tmp1_ = g_strdup (((RygelMediaObject*) data->self)->id), _g_free0 (((RygelSearchExpression*) data->expression)->operand2), data->_tmp1_);

                        rygel_media_container_search ((RygelMediaContainer*) data->self, (RygelSearchExpression*) data->expression, data->offset, data->max_count, data->cancellable, rygel_tracker_search_container_get_children_ready, data);

                        data->_state_ = 4;

                        return FALSE;

                {

                        data->query = rygel_tracker_search_container_create_query_from_expression (data->self, data->expression);

                        data->results = gee_array_list_new (RYGEL_TYPE_MEDIA_OBJECT, (GBoxedCopyFunc) g_object_ref, g_object_unref, NULL);

                        if (data->query == NULL) {

                                data->result = (GeeList*) data->results;

                                _g_free0 (data->query);

                                {

                                data->i = (guint) 0;

                                {

                                        data->_tmp7_ = TRUE;

                                        while (TRUE) {

                                                if (!data->_tmp7_) {

                                                        data->i++;

                                                }

                                                data->_tmp7_ = FALSE;

                                                if (!(data->i < data->search_result_length1)) {

                                                        break;

                                                }

                                                data->path = g_strdup (data->search_result[(data->i * data->search_result_length2) + 0]);

                                                data->service = g_strdup (data->search_result[(data->i * data->search_result_length2) + 1]);

                                                                return FALSE;

                                                        }

                                                }

                                                gee_abstract_collection_add ((GeeAbstractCollection*) data->results, (RygelMediaObject*) data->item);

                                                _g_free0 (data->path);

                                                _g_free0 (data->service);

                                                data->metadata = (_vala_array_free (data->metadata, data->metadata_length1, (GDestroyNotify) g_free), NULL);

                                        }

                                }

                        }

                        data->total_matches = (guint) gee_collection_get_size ((GeeCollection*) data->results);

                        data->result = (GeeList*) data->results;

                        _g_free0 (data->query);

                        data->keys = (_vala_array_free (data->keys, data->keys_length1, (GDestroyNotify) g_free), NULL);

}

 

 

static char* rygel_tracker_search_container_create_query_from_expression (RygelTrackerSearchContainer* self, RygelSearchExpression* expression) {

        char* result;

        char* query;

        gboolean _tmp0_ = FALSE;

        RygelRelationalExpression* rel_expression;

        char* query_op;

        gboolean _tmp2_ = FALSE;

        g_return_val_if_fail (self != NULL, NULL);

        g_return_val_if_fail (expression != NULL, NULL);

        query = NULL;

        if (expression == NULL) {

                _tmp0_ = TRUE;

        } else {

                _tmp0_ = !RYGEL_IS_RELATIONAL_EXPRESSION (expression);

        }

        if (_tmp0_) {

                result = query;

                return result;

        }

        rel_expression = _rygel_search_expression_ref0 ((_tmp1_ = expression, RYGEL_IS_RELATIONAL_EXPRESSION (_tmp1_) ? ((RygelRelationalExpression*) _tmp1_) : NULL));

        query_op = rygel_tracker_search_container_get_op_for_expression (self, rel_expression);

        if (_vala_strcmp0 ((const char*) ((RygelSearchExpression*) rel_expression)->operand1, "@id") == 0) {

                _tmp2_ = query_op != NULL;

        } else {

                _tmp2_ = FALSE;

        }

        if (_tmp2_) {

                char* _tmp3_;

                query = (_tmp3_ = rygel_tracker_search_container_create_query_for_id (self, rel_expression, query_op), _g_free0 (query), _tmp3_);

        } else {

                gboolean _tmp4_ = FALSE;

                if (_vala_strcmp0 ((const char*) ((RygelSearchExpression*) rel_expression)->operand1, "@parentID") == 0) {

                        _tmp4_ = rygel_relational_expression_compare_string (rel_expression, ((RygelMediaObject*) self)->id);

                } else {

                        _tmp4_ = FALSE;

                }

                if (_tmp4_) {

                        if (_vala_strcmp0 (self->query_condition, "") != 0) {

                                char* _tmp6_;

                                char* _tmp5_;

                                query = (_tmp6_ = g_strconcat (_tmp5_ = g_strconcat ("<rdfq:Condition>\n", self->query_condition, NULL), "</rdfq:Condition>", NULL), _g_free0 (query), _tmp6_);

                                _g_free0 (_tmp5_);

                        } else {

                                char* _tmp7_;

                                query = (_tmp7_ = g_strdup (""), _g_free0 (query), _tmp7_);

                        }

                }

        }

        result = query;

        _rygel_search_expression_unref0 (rel_expression);

        _g_free0 (query_op);

        return result;

}

 

 

static char* rygel_tracker_search_container_create_query_for_id (RygelTrackerSearchContainer* self, RygelRelationalExpression* expression, const char* query_op) {

        char* result;

        char* query;

        char* parent_id;

        char* path;

        gboolean _tmp6_ = FALSE;

        gboolean _tmp7_ = FALSE;

        g_return_val_if_fail (self != NULL, NULL);

        g_return_val_if_fail (expression != NULL, NULL);

        g_return_val_if_fail (query_op != NULL, NULL);

        query = NULL;

        parent_id = NULL;

        service = NULL;

        path = (_tmp4_ = (_tmp1_ = rygel_tracker_search_container_get_item_info (self, (const char*) ((RygelSearchExpression*) expression)->operand2, &_tmp0_, &_tmp3_), parent_id = (_tmp2_ = _tmp0_, _g_free0 (parent_id), _tmp2_), _tmp1_), service = (_tmp5_ = _tmp3_, _g_free0 (service), _tmp5_), _tmp4_);

        if (path != NULL) {

                _tmp7_ = parent_id != NULL;

        } else {

                _tmp7_ = FALSE;

        }

        if (_tmp7_) {

                _tmp6_ = _vala_strcmp0 (parent_id, ((RygelMediaObject*) self)->id) == 0;

        } else {

                _tmp6_ = FALSE;

        }

        if (_tmp6_) {

                char* dir;

                char* basename;

                char* _tmp28_;

                char* _tmp8_;

                char* _tmp29_;

                char* search_condition;

                dir = g_path_get_dirname (path);

                basename = g_path_get_basename (path);

                search_condition = (_tmp29_ = g_strconcat (_tmp28_ = g_strconcat (_tmp27_ = g_strconcat (_tmp26_ = g_strconcat (_tmp25_ = g_strconcat (_tmp24_ = g_strconcat (_tmp23_ = g_strconcat (_tmp22_ = g_strconcat (_tmp21_ = g_strconcat (_tmp20_ = g_strconcat (_tmp19_ = g_strconcat (_tmp18_ = g_strconcat (_tmp17_ = g_strconcat (_tmp16_ = g_strconcat (_tmp15_ = g_strconcat (_tmp14_ = g_strconcat (_tmp13_ = g_strconcat (_tmp12_ = g_strconcat (_tmp11_ = g_strconcat (_tmp10_ = g_strconcat (_tmp9_ = g_strconcat (_tmp8_ = g_strconcat ("<rdfq:and>\n" "<", query_op, NULL), ">\n", NULL), "<rdfq:Property ", NULL), "name=\"File:Path\" />\n", NULL), "<rdf:String>", NULL), dir, NULL), "</rdf:String>\n", NULL), "</", NULL), query_op, NULL), ">\n", NULL), "<", NULL), query_op, NULL), ">\n", NULL), "<rdfq:Property ", NULL), "name=\"File:Name\" />\n", NULL), "<rdf:String>", NULL), basename, NULL), "</rdf:String>\n", NULL), "</", NULL), query_op, NULL), ">\n", NULL), "</rdfq:and>\n", NULL), _g_free0 (_tmp28_), _g_free0 (_tmp27_), _g_free0 (_tmp26_), _g_free0 (_tmp25_), _g_free0 (_tmp24_), _g_free0 (_tmp23_), _g_free0 (_tmp22_), _g_free0 (_tmp21_), _g_free0 (_tmp20_), _g_free0 (_tmp19_), _g_free0 (_tmp18_), _g_free0 (_tmp17_), _g_free0 (_tmp16_), _g_free0 (_tmp15_), _g_free0 (_tmp14_), _g_free0 (_tmp13_), _g_free0 (_tmp12_), _g_free0 (_tmp11_), _g_free0 (_tmp10_), _g_free0 (_tmp9_), _g_free0 (_tmp8_), _tmp29_);

                if (_vala_strcmp0 (self->query_condition, "") != 0) {

                        char* _tmp33_;

                        char* _tmp32_;

                        char* _tmp31_;

                        char* _tmp30_;

                        query = (_tmp33_ = g_strconcat (_tmp32_ = g_strconcat (_tmp31_ = g_strconcat (_tmp30_ = g_strconcat ("<rdfq:Condition>\n" "<rdfq:and>\n", search_condition, NULL), self->query_condition, NULL), "</rdfq:and>\n", NULL), "</rdfq:Condition>", NULL), _g_free0 (query), _tmp33_);

                        _g_free0 (_tmp32_);

                        _g_free0 (_tmp31_);

                        _g_free0 (_tmp30_);

                } else {

                        char* _tmp35_;

                        char* _tmp34_;

                        query = (_tmp35_ = g_strconcat (_tmp34_ = g_strconcat ("<rdfq:Condition>\n", search_condition, NULL), "</rdfq:Condition>", NULL), _g_free0 (query), _tmp35_);

                        _g_free0 (_tmp34_);

                }

                _g_free0 (dir);

        _g_free0 (parent_id);

        _g_free0 (service);

        _g_free0 (path);

        return result;

}

 

 

static char* rygel_tracker_search_container_get_op_for_expression (RygelTrackerSearchContainer* self, RygelRelationalExpression* expression) {

        char* result;

        g_return_val_if_fail (self != NULL, NULL);

        g_return_val_if_fail (expression != NULL, NULL);

        switch (GPOINTER_TO_INT (((RygelSearchExpression*) expression)->op)) {

                case GUPNP_SEARCH_CRITERIA_OP_EQ:

                {

                        result = g_strdup ("rdfq:equals");

                        return result;

                }

                case GUPNP_SEARCH_CRITERIA_OP_CONTAINS:

                {

                        result = g_strdup ("rdfq:contains");

                        return result;

                }

                default:

                {

                        result = NULL;

                        return result;

                }

        }

}

 

 

static RygelMediaItem* rygel_tracker_search_container_create_item (RygelTrackerSearchContainer* self, const char* service, const char* path, char** metadata, int metadata_length1, GError** error) {

        RygelMediaItem* result;

        GError * _inner_error_;

        char* _tmp2_;

        char* _tmp0_;

        char* _tmp3_;

        char* id;

        g_return_val_if_fail (self != NULL, NULL);

        g_return_val_if_fail (service != NULL, NULL);

        g_return_val_if_fail (path != NULL, NULL);

        _inner_error_ = NULL;

        id = (_tmp3_ = g_strconcat (_tmp2_ = g_strconcat (_tmp1_ = g_strconcat (_tmp0_ = g_strconcat (service, ":", NULL), ((RygelMediaObject*) self)->id, NULL), ":", NULL), path, NULL), _g_free0 (_tmp2_), _g_free0 (_tmp1_), _g_free0 (_tmp0_), _tmp3_);

        if (_vala_strcmp0 (service, RYGEL_TRACKER_VIDEO_ITEM_SERVICE) == 0) {

                RygelTrackerVideoItem* _tmp4_;

                _tmp4_ = rygel_tracker_video_item_new (id, path, self, metadata, metadata_length1, &_inner_error_);

                if (_inner_error_ != NULL) {

                        g_propagate_error (error, _inner_error_);

                        _g_free0 (id);

                }

                result = (RygelMediaItem*) _tmp4_;

                _g_free0 (id);

                return result;

        } else {

                if (_vala_strcmp0 (service, RYGEL_TRACKER_IMAGE_ITEM_SERVICE) == 0) {

                        RygelTrackerImageItem* _tmp5_;

                        _tmp5_ = rygel_tracker_image_item_new (id, path, self, metadata, metadata_length1, &_inner_error_);

                        if (_inner_error_ != NULL) {

                                g_propagate_error (error, _inner_error_);

                                _g_free0 (id);

                        }

                        result = (RygelMediaItem*) _tmp5_;

                        _g_free0 (id);

                        return result;

                } else {

                        if (_vala_strcmp0 (service, RYGEL_TRACKER_MUSIC_ITEM_SERVICE) == 0) {

                                RygelTrackerMusicItem* _tmp6_;

                                _tmp6_ = rygel_tracker_music_item_new (id, path, self, metadata, metadata_length1, &_inner_error_);

                                if (_inner_error_ != NULL) {

                                        g_propagate_error (error, _inner_error_);

                                        _g_free0 (id);

                                }

                                result = (RygelMediaItem*) _tmp6_;

                                _g_free0 (id);

                                return result;

                        } else {

                                result = NULL;

                                _g_free0 (id);

                                return result;

                        }

                }

        }

}

 

 

static char* rygel_tracker_search_container_get_item_info (RygelTrackerSearchContainer* self, const char* item_id, char** parent_id, char** service) {

        char* result;

        char** _tmp1_;

        gint tokens_size;

        char** tokens;

        gboolean _tmp2_ = FALSE;

        gboolean _tmp3_ = FALSE;

        g_return_val_if_fail (self != NULL, NULL);

        g_return_val_if_fail (item_id != NULL, NULL);

        if (parent_id != NULL) {

                *parent_id = NULL;

        }

                *service = NULL;

        }

        tokens = (_tmp1_ = _tmp0_ = g_strsplit (item_id, ":", 3), tokens_length1 = _vala_array_length (_tmp0_), tokens_size = tokens_length1, _tmp1_);

        if (tokens[0] != NULL) {

                _tmp3_ = tokens[1] != NULL;

        } else {

                _tmp3_ = FALSE;

        }

        if (_tmp3_) {

                _tmp2_ = tokens[2] != NULL;

        } else {

                _tmp2_ = FALSE;

        }

        if (_tmp2_) {

                char* _tmp4_;

                char* _tmp5_;

                *service = (_tmp4_ = g_strdup (tokens[0]), _g_free0 (*service), _tmp4_);

                *parent_id = (_tmp5_ = g_strdup (tokens[1]), _g_free0 (*parent_id), _tmp5_);

                result = g_strdup (tokens[2]);

                tokens = (_vala_array_free (tokens, tokens_length1, (GDestroyNotify) g_free), NULL);

                return result;

        } else {

                result = NULL;

                tokens = (_vala_array_free (tokens, tokens_length1, (GDestroyNotify) g_free), NULL);

                return result;

        }

        tokens = (_vala_array_free (tokens, tokens_length1, (GDestroyNotify) g_free), NULL);

}

 

 

static void rygel_tracker_search_container_create_proxies (RygelTrackerSearchContainer* self, GError** error) {

        GError * _inner_error_;

        DBusGConnection* connection;

        RygelTrackerSearchIface* _tmp0_;

        g_return_if_fail (self != NULL);

        _inner_error_ = NULL;

        connection = dbus_g_bus_get (DBUS_BUS_SESSION, &_inner_error_);

        if (_inner_error_ != NULL) {

                if (_inner_error_->domain == DBUS_GERROR) {

                        g_propagate_error (error, _inner_error_);

                        return;

                }

        }

        self->search_proxy = (_tmp0_ = rygel_tracker_search_iface_dbus_proxy_new (connection, RYGEL_TRACKER_SEARCH_CONTAINER_TRACKER_SERVICE, RYGEL_TRACKER_SEARCH_CONTAINER_SEARCH_PATH), _g_object_unref0 (self->search_proxy), _tmp0_);

        _dbus_g_connection_unref0 (connection);

}

 

 

static char** rygel_tracker_search_container_slice_strvv_tail (RygelTrackerSearchContainer* self, char** strvv, int strvv_length1, int strvv_length2, guint row, guint index, int* result_length1) {

        char** result;

        char** _tmp1_;

        gint slice_size;

        gint _tmp0_;

        char** slice;

        char** _tmp4_;

        g_return_val_if_fail (self != NULL, NULL);

        slice = (_tmp1_ = g_new0 (char*, (_tmp0_ = strvv_length2 - index) + 1), slice_length1 = _tmp0_, slice_size = slice_length1, _tmp1_);

        {

                gint i;

                i = 0;

                {

                        gboolean _tmp2_;

                        _tmp2_ = TRUE;

                        while (TRUE) {

                                char* _tmp3_;

                                if (!_tmp2_) {

                                        i++;

                                }

                                _tmp2_ = FALSE;

                                if (!(i < slice_length1)) {

                                        break;

                                }

                                slice[i] = (_tmp3_ = g_strdup (strvv[(row * strvv_length2) + (i + index)]), _g_free0 (slice[i]), _tmp3_);

                        }

                }

        }

        result = (_tmp4_ = slice, *result_length1 = slice_length1, _tmp4_);

        return result;

        slice = (_vala_array_free (slice, slice_length1, (GDestroyNotify) g_free), NULL);

}