Line data Source code
1 : /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
2 : /*
3 : * This file is part of the LibreOffice project.
4 : *
5 : * This Source Code Form is subject to the terms of the Mozilla Public
6 : * License, v. 2.0. If a copy of the MPL was not distributed with this
7 : * file, You can obtain one at http://mozilla.org/MPL/2.0/.
8 : *
9 : * This file incorporates work covered by the following license notice:
10 : *
11 : * Licensed to the Apache Software Foundation (ASF) under one or more
12 : * contributor license agreements. See the NOTICE file distributed
13 : * with this work for additional information regarding copyright
14 : * ownership. The ASF licenses this file to you under the Apache
15 : * License, Version 2.0 (the "License"); you may not use this file
16 : * except in compliance with the License. You may obtain a copy of
17 : * the License at http://www.apache.org/licenses/LICENSE-2.0 .
18 : */
19 :
20 : #include <vector>
21 :
22 : #include <ucbhelper/contentidentifier.hxx>
23 : #include <ucbhelper/providerhelper.hxx>
24 :
25 : #include <com/sun/star/ucb/OpenMode.hpp>
26 :
27 : #include "gio_datasupplier.hxx"
28 : #include "gio_content.hxx"
29 : #include "gio_provider.hxx"
30 :
31 : using namespace com::sun::star;
32 :
33 : using namespace gio;
34 :
35 : namespace gio
36 : {
37 :
38 : typedef std::vector< ResultListEntry* > ResultList;
39 :
40 0 : DataSupplier::DataSupplier( const uno::Reference< lang::XMultiServiceFactory >& rxSMgr,
41 : const uno::Reference< ::gio::Content >& rContent, sal_Int32 nOpenMode )
42 0 : : mxContent(rContent), m_xSMgr(rxSMgr), mnOpenMode(nOpenMode), mbCountFinal(false)
43 : {
44 0 : }
45 :
46 0 : bool DataSupplier::getData()
47 : {
48 0 : if (mbCountFinal)
49 0 : return true;
50 :
51 0 : GFile *pFile = mxContent->getGFile();
52 :
53 : GFileEnumerator* pEnumerator = g_file_enumerate_children(pFile, "*",
54 0 : G_FILE_QUERY_INFO_NONE, NULL, NULL);
55 :
56 0 : if (!pEnumerator)
57 0 : return false;
58 :
59 0 : GFileInfo *pInfo = NULL;
60 0 : while ((pInfo = g_file_enumerator_next_file (pEnumerator, NULL, NULL)))
61 : {
62 0 : switch ( mnOpenMode )
63 : {
64 : case ucb::OpenMode::FOLDERS:
65 0 : if (g_file_info_get_file_type(pInfo) != G_FILE_TYPE_DIRECTORY)
66 0 : continue;
67 0 : break;
68 : case ucb::OpenMode::DOCUMENTS:
69 0 : if (g_file_info_get_file_type(pInfo) != G_FILE_TYPE_REGULAR)
70 0 : continue;
71 0 : break;
72 : case ucb::OpenMode::ALL:
73 : default:
74 0 : break;
75 : }
76 :
77 0 : maResults.push_back( new ResultListEntry( pInfo ) );
78 0 : g_object_unref(pInfo);
79 : }
80 :
81 0 : mbCountFinal = true;
82 :
83 0 : g_file_enumerator_close(pEnumerator, NULL, NULL);
84 0 : return true;
85 : }
86 :
87 0 : DataSupplier::~DataSupplier()
88 : {
89 0 : ResultList::const_iterator it = maResults.begin();
90 0 : ResultList::const_iterator end = maResults.end();
91 :
92 0 : while ( it != end )
93 : {
94 0 : delete (*it);
95 0 : ++it;
96 : }
97 0 : }
98 :
99 0 : OUString DataSupplier::queryContentIdentifierString( sal_uInt32 nIndex )
100 : {
101 0 : if ( nIndex < maResults.size() )
102 : {
103 0 : OUString aId = maResults[ nIndex ]->aId;
104 0 : if ( aId.getLength() )
105 : {
106 : // Already cached.
107 0 : return aId;
108 0 : }
109 : }
110 :
111 0 : if ( getResult( nIndex ) )
112 : {
113 0 : GFile *pFile = mxContent->getGFile();
114 0 : char* parent = g_file_get_uri(pFile);
115 0 : OUString aId = OUString::createFromAscii( parent );
116 0 : g_free(parent);
117 :
118 : char *escaped_name =
119 0 : g_uri_escape_string( g_file_info_get_name(maResults[ nIndex ]->pInfo) , NULL, false);
120 :
121 0 : if ( ( aId.lastIndexOf( '/' ) + 1 ) != aId.getLength() )
122 0 : aId += "/";
123 :
124 0 : aId += OUString::createFromAscii( escaped_name );
125 :
126 0 : g_free( escaped_name );
127 :
128 0 : maResults[ nIndex ]->aId = aId;
129 0 : return aId;
130 : }
131 :
132 0 : return OUString();
133 : }
134 :
135 0 : uno::Reference< ucb::XContentIdentifier > DataSupplier::queryContentIdentifier( sal_uInt32 nIndex )
136 : {
137 0 : if ( nIndex < maResults.size() )
138 : {
139 0 : uno::Reference< ucb::XContentIdentifier > xId = maResults[ nIndex ]->xId;
140 0 : if ( xId.is() )
141 : {
142 : // Already cached.
143 0 : return xId;
144 0 : }
145 : }
146 :
147 0 : OUString aId = queryContentIdentifierString( nIndex );
148 0 : if ( aId.getLength() )
149 : {
150 0 : uno::Reference< ucb::XContentIdentifier > xId = new ucbhelper::ContentIdentifier( aId );
151 0 : maResults[ nIndex ]->xId = xId;
152 0 : return xId;
153 : }
154 :
155 0 : return uno::Reference< ucb::XContentIdentifier >();
156 : }
157 :
158 0 : uno::Reference< ucb::XContent > DataSupplier::queryContent( sal_uInt32 nIndex )
159 : {
160 0 : if ( nIndex < maResults.size() )
161 : {
162 0 : uno::Reference< ucb::XContent > xContent = maResults[ nIndex ]->xContent;
163 0 : if ( xContent.is() )
164 : {
165 : // Already cached.
166 0 : return xContent;
167 0 : }
168 : }
169 :
170 0 : uno::Reference< ucb::XContentIdentifier > xId = queryContentIdentifier( nIndex );
171 0 : if ( xId.is() )
172 : {
173 : try
174 : {
175 0 : uno::Reference< ucb::XContent > xContent = mxContent->getProvider()->queryContent( xId );
176 0 : maResults[ nIndex ]->xContent = xContent;
177 0 : return xContent;
178 : }
179 0 : catch ( ucb::IllegalIdentifierException& )
180 : {
181 : }
182 : }
183 0 : return uno::Reference< ucb::XContent >();
184 : }
185 :
186 0 : bool DataSupplier::getResult( sal_uInt32 nIndex )
187 : {
188 0 : if ( maResults.size() > nIndex ) // Result already present.
189 0 : return true;
190 :
191 0 : if ( getData() && maResults.size() > nIndex )
192 0 : return true;
193 :
194 0 : return false;
195 : }
196 :
197 0 : sal_uInt32 DataSupplier::totalCount()
198 : {
199 0 : getData();
200 0 : return maResults.size();
201 : }
202 :
203 0 : sal_uInt32 DataSupplier::currentCount()
204 : {
205 0 : return maResults.size();
206 : }
207 :
208 0 : bool DataSupplier::isCountFinal()
209 : {
210 0 : return mbCountFinal;
211 : }
212 :
213 0 : uno::Reference< sdbc::XRow > DataSupplier::queryPropertyValues( sal_uInt32 nIndex )
214 : {
215 0 : if ( nIndex < maResults.size() )
216 : {
217 0 : uno::Reference< sdbc::XRow > xRow = maResults[ nIndex ]->xRow;
218 0 : if ( xRow.is() )
219 : {
220 : // Already cached.
221 0 : return xRow;
222 0 : }
223 : }
224 :
225 0 : if ( getResult( nIndex ) )
226 : {
227 0 : uno::Reference< ucb::XContent > xContent( queryContent( nIndex ) );
228 0 : if ( xContent.is() )
229 : {
230 : try
231 : {
232 : uno::Reference< ucb::XCommandProcessor > xCmdProc(
233 0 : xContent, uno::UNO_QUERY_THROW );
234 0 : sal_Int32 nCmdId( xCmdProc->createCommandIdentifier() );
235 0 : ucb::Command aCmd;
236 0 : aCmd.Name = "getPropertyValues";
237 0 : aCmd.Handle = -1;
238 0 : aCmd.Argument <<= getResultSet()->getProperties();
239 0 : uno::Any aResult( xCmdProc->execute(
240 0 : aCmd, nCmdId, getResultSet()->getEnvironment() ) );
241 0 : uno::Reference< sdbc::XRow > xRow;
242 0 : if ( aResult >>= xRow )
243 : {
244 0 : maResults[ nIndex ]->xRow = xRow;
245 0 : return xRow;
246 0 : }
247 : }
248 0 : catch ( uno::Exception const & )
249 : {
250 : }
251 0 : }
252 : }
253 0 : return uno::Reference< sdbc::XRow >();
254 : }
255 :
256 0 : void DataSupplier::releasePropertyValues( sal_uInt32 nIndex )
257 : {
258 0 : if ( nIndex < maResults.size() )
259 0 : maResults[ nIndex ]->xRow = uno::Reference< sdbc::XRow >();
260 0 : }
261 :
262 0 : void DataSupplier::close()
263 : {
264 0 : }
265 :
266 0 : void DataSupplier::validate() throw( ucb::ResultSetException )
267 : {
268 0 : }
269 :
270 : }
271 :
272 : /* vim:set shiftwidth=4 softtabstop=4 expandtab: */
|
