1 | /* |
2 | This file is part of the KDE libraries |
3 | SPDX-FileCopyrightText: 1999 David Faure <faure@kde.org> |
4 | |
5 | SPDX-License-Identifier: LGPL-2.0-only |
6 | */ |
7 | |
8 | #include "ksycoca.h" |
9 | #include "ksycocadict_p.h" |
10 | #include "ksycocaentry.h" |
11 | #include "ksycocaentry_p.h" |
12 | #include "ksycocafactory_p.h" |
13 | #include "ksycocatype.h" |
14 | #include "sycocadebug.h" |
15 | |
16 | #include <QDebug> |
17 | #include <QHash> |
18 | #include <QIODevice> |
19 | #include <QThread> |
20 | |
21 | class KSycocaFactoryPrivate |
22 | { |
23 | public: |
24 | KSycocaFactoryPrivate() |
25 | { |
26 | } |
27 | ~KSycocaFactoryPrivate() |
28 | { |
29 | delete m_sycocaDict; |
30 | } |
31 | |
32 | int mOffset = 0; |
33 | int m_sycocaDictOffset = 0; |
34 | int m_beginEntryOffset = 0; |
35 | int m_endEntryOffset = 0; |
36 | KSycocaDict *m_sycocaDict = nullptr; |
37 | }; |
38 | |
39 | KSycocaFactory::KSycocaFactory(KSycocaFactoryId factory_id, KSycoca *sycoca) |
40 | : m_sycoca(sycoca) |
41 | , d(new KSycocaFactoryPrivate) |
42 | { |
43 | if (!m_sycoca->isBuilding() && (m_str = m_sycoca->findFactory(id: factory_id))) { |
44 | // Read position of index tables.... |
45 | qint32 i; |
46 | (*m_str) >> i; |
47 | d->m_sycocaDictOffset = i; |
48 | (*m_str) >> i; |
49 | d->m_beginEntryOffset = i; |
50 | (*m_str) >> i; |
51 | d->m_endEntryOffset = i; |
52 | |
53 | QDataStream *str = stream(); |
54 | qint64 saveOffset = str->device()->pos(); |
55 | // Init index tables |
56 | d->m_sycocaDict = new KSycocaDict(str, d->m_sycocaDictOffset); |
57 | saveOffset = str->device()->seek(pos: saveOffset); |
58 | } else { |
59 | // We are in kbuildsycoca -- build new database! |
60 | m_entryDict = new KSycocaEntryDict; |
61 | d->m_sycocaDict = new KSycocaDict; |
62 | d->m_beginEntryOffset = 0; |
63 | d->m_endEntryOffset = 0; |
64 | |
65 | // m_resourceList will be filled in by inherited constructors |
66 | } |
67 | m_sycoca->addFactory(this); |
68 | } |
69 | |
70 | KSycocaFactory::~KSycocaFactory() |
71 | { |
72 | delete m_entryDict; |
73 | } |
74 | |
75 | void KSycocaFactory::(QDataStream &str) |
76 | { |
77 | // Write header |
78 | str.device()->seek(pos: d->mOffset); |
79 | str << qint32(d->m_sycocaDictOffset); |
80 | str << qint32(d->m_beginEntryOffset); |
81 | str << qint32(d->m_endEntryOffset); |
82 | } |
83 | |
84 | void KSycocaFactory::save(QDataStream &str) |
85 | { |
86 | if (!m_entryDict) { |
87 | return; // Error! Function should only be called when building database |
88 | } |
89 | if (!d->m_sycocaDict) { |
90 | return; // Error! |
91 | } |
92 | |
93 | d->mOffset = str.device()->pos(); // store position in member variable |
94 | d->m_sycocaDictOffset = 0; |
95 | |
96 | // Write header (pass #1) |
97 | saveHeader(str); |
98 | |
99 | d->m_beginEntryOffset = str.device()->pos(); |
100 | |
101 | // Write all entries. |
102 | int entryCount = 0; |
103 | for (KSycocaEntry::Ptr entry : std::as_const(t&: *m_entryDict)) { |
104 | entry->d_ptr->save(s&: str); |
105 | entryCount++; |
106 | } |
107 | |
108 | d->m_endEntryOffset = str.device()->pos(); |
109 | |
110 | // Write indices... |
111 | // Linear index |
112 | str << qint32(entryCount); |
113 | for (const KSycocaEntry::Ptr &entry : std::as_const(t&: *m_entryDict)) { |
114 | str << qint32(entry.data()->offset()); |
115 | } |
116 | |
117 | // Dictionary index |
118 | d->m_sycocaDictOffset = str.device()->pos(); |
119 | d->m_sycocaDict->save(str); |
120 | |
121 | qint64 endOfFactoryData = str.device()->pos(); |
122 | |
123 | // Update header (pass #2) |
124 | saveHeader(str); |
125 | |
126 | // Seek to end. |
127 | str.device()->seek(pos: endOfFactoryData); |
128 | } |
129 | |
130 | void KSycocaFactory::addEntry(const KSycocaEntry::Ptr &newEntry) |
131 | { |
132 | if (!m_entryDict) { |
133 | return; // Error! Function should only be called when |
134 | } |
135 | // building database |
136 | |
137 | if (!d->m_sycocaDict) { |
138 | return; // Error! |
139 | } |
140 | |
141 | KSycocaEntry::Ptr oldEntry = m_entryDict->value(key: newEntry->storageId()); |
142 | if (oldEntry) { |
143 | // Already exists -> replace |
144 | // We found a more-local override, e.g. ~/.local/share/applications/kde5/foo.desktop |
145 | // So forget about the more global file. |
146 | // |
147 | // This can also happen with two .protocol files using the same protocol= entry. |
148 | // If we didn't remove one here, we would end up asserting because save() |
149 | // wasn't called on one of the entries. |
150 | // qDebug() << "removing" << oldEntry.data() << oldEntry->entryPath() << "because of" << newEntry->entryPath() << "they have the same storageId" << |
151 | // newEntry->storageId(); |
152 | removeEntry(entryName: newEntry->storageId()); |
153 | } |
154 | |
155 | const QString name = newEntry->storageId(); |
156 | m_entryDict->insert(key: name, value: newEntry); |
157 | d->m_sycocaDict->add(key: name, payload: newEntry); |
158 | } |
159 | |
160 | void KSycocaFactory::removeEntry(const QString &entryName) |
161 | { |
162 | if (!m_entryDict) { |
163 | return; // Error! Function should only be called when |
164 | } |
165 | // building database |
166 | |
167 | if (!d->m_sycocaDict) { |
168 | return; // Error! |
169 | } |
170 | |
171 | m_entryDict->remove(key: entryName); |
172 | d->m_sycocaDict->remove(key: entryName); // O(N) |
173 | } |
174 | |
175 | KSycocaEntry::List KSycocaFactory::allEntries() const |
176 | { |
177 | KSycocaEntry::List list; |
178 | |
179 | // Assume we're NOT building a database |
180 | |
181 | QDataStream *str = stream(); |
182 | if (!str) { |
183 | return list; |
184 | } |
185 | str->device()->seek(pos: d->m_endEntryOffset); |
186 | qint32 entryCount; |
187 | (*str) >> entryCount; |
188 | |
189 | if (entryCount > 8192) { |
190 | qCWarning(SYCOCA) << QThread::currentThread() << "error detected in factory" << this; |
191 | KSycoca::flagError(); |
192 | return list; |
193 | } |
194 | |
195 | // offsetList is needed because createEntry() modifies the stream position |
196 | qint32 *offsetList = new qint32[entryCount]; |
197 | for (int i = 0; i < entryCount; i++) { |
198 | (*str) >> offsetList[i]; |
199 | } |
200 | |
201 | for (int i = 0; i < entryCount; i++) { |
202 | KSycocaEntry *newEntry = createEntry(offset: offsetList[i]); |
203 | if (newEntry) { |
204 | list.append(t: KSycocaEntry::Ptr(newEntry)); |
205 | } |
206 | } |
207 | delete[] offsetList; |
208 | return list; |
209 | } |
210 | |
211 | int KSycocaFactory::offset() const |
212 | { |
213 | return d->mOffset; |
214 | } |
215 | |
216 | const KSycocaResourceList &KSycocaFactory::resourceList() const |
217 | { |
218 | return m_resourceList; |
219 | } |
220 | |
221 | const KSycocaDict *KSycocaFactory::sycocaDict() const |
222 | { |
223 | return d->m_sycocaDict; |
224 | } |
225 | |
226 | bool KSycocaFactory::isEmpty() const |
227 | { |
228 | return d->m_beginEntryOffset == d->m_endEntryOffset; |
229 | } |
230 | |
231 | QDataStream *KSycocaFactory::stream() const |
232 | { |
233 | return m_str; |
234 | } |
235 | |
236 | QStringList KSycocaFactory::allDirectories(const QString &subdir) |
237 | { |
238 | // We don't use QStandardPaths::locateAll() because we want all paths, even those that don't exist yet |
239 | QStringList topDirs = QStandardPaths::standardLocations(type: QStandardPaths::GenericDataLocation); |
240 | for (auto &dir : topDirs) { |
241 | dir += QLatin1Char('/') + subdir; |
242 | } |
243 | return topDirs; |
244 | } |
245 | |
246 | void KSycocaFactory::virtual_hook(int /*id*/, void * /*data*/) |
247 | { |
248 | /*BASE::virtual_hook( id, data );*/ |
249 | } |
250 | |