|
1 | 1 | import template from "./todo-list.template.js"; |
2 | 2 | import TodoItem from "../todo-item/todo-item.component.js"; |
| 3 | +import { createStorageManager } from "../../storage/storage-factory.js"; |
3 | 4 |
|
4 | 5 | import globalStyles from "../../styles/global.constructable.js"; |
5 | 6 | import listStyles from "../../styles/todo-list.constructable.js"; |
6 | 7 |
|
7 | | -class IndexedDBManager { |
8 | | - constructor() { |
9 | | - this.dbName = "todoDB"; |
10 | | - this.dbVersion = 1; |
11 | | - this.storeName = "todos"; |
12 | | - this.db = null; |
13 | | - this.pendingAdditions = 0; |
14 | | - this.totalItemsToggled = 0; |
15 | | - this.totalItemsDeleted = 0; |
16 | | - this.initDB().then(() => { |
17 | | - const newDiv = document.createElement("div"); |
18 | | - newDiv.classList.add("indexeddb-ready"); |
19 | | - newDiv.style.display = "none"; |
20 | | - document.body.append(newDiv); |
21 | | - }); |
22 | | - } |
23 | | - |
24 | | - initDB() { |
25 | | - return new Promise((resolve, reject) => { |
26 | | - // Delete the existing database first for clean state |
27 | | - const deleteRequest = indexedDB.deleteDatabase(this.dbName); |
28 | | - |
29 | | - deleteRequest.onerror = (event) => { |
30 | | - // Continue despite error in deletion |
31 | | - this.openDatabase(resolve, reject); |
32 | | - }; |
33 | | - |
34 | | - deleteRequest.onsuccess = () => { |
35 | | - this.openDatabase(resolve, reject); |
36 | | - }; |
37 | | - |
38 | | - deleteRequest.onblocked = () => { |
39 | | - // Try opening anyway |
40 | | - this.openDatabase(resolve, reject); |
41 | | - }; |
42 | | - }); |
43 | | - } |
44 | | - |
45 | | - openDatabase(resolve, reject) { |
46 | | - const request = indexedDB.open(this.dbName, this.dbVersion); |
47 | | - |
48 | | - request.onerror = (event) => { |
49 | | - reject(event.target.error); |
50 | | - }; |
51 | | - |
52 | | - request.onsuccess = (event) => { |
53 | | - this.db = event.target.result; |
54 | | - resolve(this.db); |
55 | | - }; |
56 | | - |
57 | | - request.onupgradeneeded = (event) => { |
58 | | - const db = event.target.result; |
59 | | - |
60 | | - // Create object store (since we're always creating a fresh DB now) |
61 | | - const store = db.createObjectStore(this.storeName, { keyPath: "itemNumber" }); |
62 | | - store.createIndex("id", "id", { unique: true }); |
63 | | - store.createIndex("title", "title", { unique: false }); |
64 | | - store.createIndex("completed", "completed", { unique: false }); |
65 | | - store.createIndex("priority", "priority", { unique: false }); |
66 | | - }; |
67 | | - } |
68 | | - |
69 | | - addTodo(todo) { |
70 | | - return new Promise((resolve, reject) => { |
71 | | - // Ensure the database connection is established |
72 | | - if (!this.db) { |
73 | | - this.initDB() |
74 | | - .then(() => this.addTodo(todo)) |
75 | | - .then(resolve) |
76 | | - .catch(reject); |
77 | | - return; |
78 | | - } |
79 | | - |
80 | | - // Add todo item to IndexedDB |
81 | | - const transaction = this.db.transaction(this.storeName, "readwrite"); |
82 | | - const store = transaction.objectStore(this.storeName); |
83 | | - |
84 | | - const request = store.add(todo); |
85 | | - this.pendingAdditions++; |
86 | | - |
87 | | - request.onsuccess = () => { |
88 | | - if (--this.pendingAdditions === 0) |
89 | | - window.dispatchEvent(new CustomEvent("indexeddb-add-completed", {})); |
90 | | - |
91 | | - resolve(todo); |
92 | | - }; |
93 | | - |
94 | | - request.onerror = (event) => { |
95 | | - reject(event.target.error); |
96 | | - }; |
97 | | - }); |
98 | | - } |
99 | | - |
100 | | - getTodos(upperItemNumber, count) { |
101 | | - return new Promise((resolve, reject) => { |
102 | | - // Ensure the database connection is established |
103 | | - if (!this.db) { |
104 | | - this.initDB() |
105 | | - .then(() => this.getTodos(upperItemNumber, count)) |
106 | | - .then(resolve) |
107 | | - .catch(reject); |
108 | | - return; |
109 | | - } |
110 | | - |
111 | | - const transaction = this.db.transaction(this.storeName, "readonly"); |
112 | | - const store = transaction.objectStore(this.storeName); |
113 | | - |
114 | | - // Use IDBKeyRange to get items with itemNumber less than upperItemNumber |
115 | | - const range = IDBKeyRange.upperBound(upperItemNumber, true); // true = exclusive bound |
116 | | - |
117 | | - // Open a cursor to iterate through records in descending order |
118 | | - const request = store.openCursor(range, "prev"); |
119 | | - |
120 | | - const items = []; |
121 | | - let itemsProcessed = 0; |
122 | | - |
123 | | - request.onsuccess = (event) => { |
124 | | - const cursor = event.target.result; |
125 | | - |
126 | | - // Check if we have a valid cursor and haven't reached our count limit |
127 | | - if (cursor && itemsProcessed < count) { |
128 | | - items.push(cursor.value); |
129 | | - itemsProcessed++; |
130 | | - cursor.continue(); // Move to next item |
131 | | - } else { |
132 | | - // We're done - sort items by itemNumber in descending order |
133 | | - // for proper display order (newest to oldest) |
134 | | - items.sort((a, b) => a.itemNumber - b.itemNumber); |
135 | | - |
136 | | - resolve(items); |
137 | | - } |
138 | | - }; |
139 | | - |
140 | | - request.onerror = (event) => { |
141 | | - reject(event.target.error); |
142 | | - }; |
143 | | - |
144 | | - // Also handle transaction errors |
145 | | - transaction.onerror = (event) => { |
146 | | - reject(event.target.error); |
147 | | - }; |
148 | | - }); |
149 | | - } |
150 | | - |
151 | | - toggleTodo(itemNumber, completed) { |
152 | | - return new Promise((resolve, reject) => { |
153 | | - // Ensure the database connection is established |
154 | | - if (!this.db) { |
155 | | - this.initDB() |
156 | | - .then(() => this.toggleTodo(itemNumber, completed)) |
157 | | - .then(resolve) |
158 | | - .catch(reject); |
159 | | - return; |
160 | | - } |
161 | | - |
162 | | - // Access the todo item directly by its itemNumber (keyPath) |
163 | | - const transaction = this.db.transaction(this.storeName, "readwrite"); |
164 | | - const store = transaction.objectStore(this.storeName); |
165 | | - |
166 | | - // Get the todo item directly using its primary key (itemNumber) |
167 | | - const getRequest = store.get(itemNumber); |
168 | | - |
169 | | - getRequest.onsuccess = (event) => { |
170 | | - const todoItem = getRequest.result; |
171 | | - |
172 | | - if (!todoItem) { |
173 | | - reject(new Error(`Todo item with itemNumber '${itemNumber}' not found`)); |
174 | | - return; |
175 | | - } |
176 | | - |
177 | | - // Update the completed status |
178 | | - todoItem.completed = completed; |
179 | | - |
180 | | - // Save the updated item back to the database |
181 | | - const updateRequest = store.put(todoItem); |
182 | | - |
183 | | - updateRequest.onsuccess = () => { |
184 | | - if (window.numberOfItemsToAdd && ++this.totalItemsToggled === window.numberOfItemsToAdd) |
185 | | - window.dispatchEvent(new CustomEvent("indexeddb-toggle-completed", {})); |
186 | | - |
187 | | - resolve(todoItem); |
188 | | - }; |
189 | | - |
190 | | - updateRequest.onerror = (event) => { |
191 | | - reject(event.target.error); |
192 | | - }; |
193 | | - }; |
194 | | - |
195 | | - getRequest.onerror = (event) => { |
196 | | - reject(event.target.error); |
197 | | - }; |
198 | | - |
199 | | - // Handle potential errors in finding the item |
200 | | - transaction.onerror = (event) => { |
201 | | - reject(event.target.error); |
202 | | - }; |
203 | | - |
204 | | - // Handle transaction errors |
205 | | - transaction.onerror = (event) => { |
206 | | - reject(event.target.error); |
207 | | - }; |
208 | | - }); |
209 | | - } |
210 | | - |
211 | | - removeTodo(itemNumber) { |
212 | | - return new Promise((resolve, reject) => { |
213 | | - // Ensure the database connection is established |
214 | | - if (!this.db) { |
215 | | - this.initDB() |
216 | | - .then(() => this.removeTodo(itemNumber)) |
217 | | - .then(resolve) |
218 | | - .catch(reject); |
219 | | - return; |
220 | | - } |
221 | | - |
222 | | - // Access the todo item directly by its itemNumber (keyPath) |
223 | | - const transaction = this.db.transaction(this.storeName, "readwrite"); |
224 | | - const store = transaction.objectStore(this.storeName); |
225 | | - |
226 | | - // Delete the todo item directly using its primary key (itemNumber) |
227 | | - const deleteRequest = store.delete(itemNumber); |
228 | | - |
229 | | - deleteRequest.onsuccess = () => { |
230 | | - if (window.numberOfItemsToAdd && ++this.totalItemsDeleted === window.numberOfItemsToAdd) |
231 | | - window.dispatchEvent(new CustomEvent("indexeddb-remove-completed", {})); |
232 | | - |
233 | | - resolve(itemNumber); |
234 | | - }; |
235 | | - |
236 | | - deleteRequest.onerror = (event) => { |
237 | | - reject(event.target.error); |
238 | | - }; |
239 | | - |
240 | | - // Handle transaction errors |
241 | | - transaction.onerror = (event) => { |
242 | | - reject(event.target.error); |
243 | | - }; |
244 | | - }); |
245 | | - } |
246 | | -} |
247 | | - |
248 | 8 | const MAX_ON_SCREEN_ITEMS = 10; |
249 | 9 |
|
250 | 10 | const customListStyles = new CSSStyleSheet(); |
251 | 11 | customListStyles.replaceSync(` |
252 | | - .todo-list > todo-item { |
253 | | - display: block; |
254 | | - } |
255 | | -
|
256 | 12 | .todo-list[route="completed"] > [itemcompleted="false"] { |
257 | 13 | display: none; |
258 | 14 | } |
@@ -286,7 +42,7 @@ class TodoList extends HTMLElement { |
286 | 42 | this.shadow.adoptedStyleSheets = [globalStyles, listStyles, customListStyles]; |
287 | 43 | this.shadow.append(node); |
288 | 44 | this.classList.add("show-priority"); |
289 | | - this.storageManager = new IndexedDBManager(); |
| 45 | + this.storageManager = createStorageManager(); |
290 | 46 |
|
291 | 47 | if (window.extraTodoListCssToAdopt) { |
292 | 48 | let extraAdoptedStyleSheet = new CSSStyleSheet(); |
@@ -354,7 +110,7 @@ class TodoList extends HTMLElement { |
354 | 110 | this.listNode.setAttribute("route", "completed"); |
355 | 111 | break; |
356 | 112 | case "active": |
357 | | - this.listNode.setAttribute("rout", "active"); |
| 113 | + this.listNode.setAttribute("route", "active"); |
358 | 114 | break; |
359 | 115 | default: |
360 | 116 | this.listNode.setAttribute("route", "all"); |
|
0 commit comments