chromium/src/third_party/blink/perf_tests/owp_storage/resources/idb-load-docs-runner.html - manifest_repos/chromium_src - Git at Google

 <!doctype html>
 <title>IDB Offline Google Docs Load Runner</title>
 <div id="content"></div>
 <script src="resources/shared.js"></script>
 <script src="resources/idb-load-docs-shared.js"></script>
 <script>
   let openRequest = window.indexedDB.open(databaseName);
   openRequest.onsuccess = async () => {
     let db = openRequest.result;

     // https://docs.google.com/document/d/1JC1RgMyxBAjUPSHjm2Bd1KPzcqpPPvxRomKevOkMPm0/edit
     // contiains information about each transaction and their ordering.
     let txn1 = () => {
       let txn = db.transaction("Users", "readonly");
       txn.onabort = reportError;
       let users = txn.objectStore("Users");

       let get = users.get("ufa1a865c6eb48d97");
       get.onsuccess = () => {
         logToDocumentBody(["Txn1 got user ", get.result.emailAddress]);
       }
       return transactionCompletePromise(txn).then(() => {
         logToDocumentBody("Txn1 done");
       });
     };

     let txn2 = () => {
       let txn = db.transaction(["DocumentLocks"], "readwrite");
       txn.onabort = reportError;
       let locks = txn.objectStore("DocumentLocks");

       let get = locks.get([docId1]);
       get.onsuccess = () => {
         logToDocumentBody(["Txn2 got lock", get.result.e]);
       }
       t2_DocumentLocksValues.forEach((value) => (locks.put(value)));
       return transactionCompletePromise(txn).then(() => {
         logToDocumentBody("Txn2 done.");
       });
     };

     let txn3 = () => {
       let txn = db.transaction(["Documents"], "readonly");
       txn.onabort = reportError;
       let documents = txn.objectStore("Documents");

       let get = documents.get(docId1);
       get.onsuccess = () => {
         var div = logToDocumentBody(
             "Txn3 done, got the document, with image: ");
         let img = document.createElement("img");
         div.appendChild(img);
         img.src = get.result.docosKeyData[8][2];
       }
       return transactionCompletePromise(txn).then(() => {
         logToDocumentBody("Txn3 done.");
       });
     };

     let txn4 = () => {
       let txn = db.transaction(["PendingQueues"], "readonly");
       txn.onabort = reportError;
       let queues = txn.objectStore("PendingQueues");

       let get = queues.get(docId1);
       get.onsuccess = () => {
         logToDocumentBody(["Txn4 got queue: ", get.result.r]);
       }
       return transactionCompletePromise(txn).then(() => {
         logToDocumentBody("Txn4 done.");
       });
     };

     let txn5 = () => {
       let txn = db.transaction(["SyncObjects"], "readwrite");
       txn.onabort = reportError;
       let syncs = txn.objectStore("SyncObjects");

       t5_SyncObjectsValues.forEach((value) => { syncs.put(value); });

       return transactionCompletePromise(txn).then(() => {
         logToDocumentBody(
           ["Txn5 done, set ", t5_SyncObjectsValues.length, " values."]);
       });
     };

     let txn6_15 = () => {
       let promises = [];
       for (let i = 0; i < 9; ++i) {
         let txn = db.transaction("FontMetadata", "readonly");
         txn.onabort = reportError;
         let get = txn.objectStore("FontMetadata").get("Cambria");
         let name = "Txn " + (i + 6);
         get.onsuccess = () => {
           logToDocumentBody([name, " got font with ",
                              get.result.fontFaces.length, " faces."]);
         }
         promises.push(transactionCompletePromise(txn).then(() => {
           logToDocumentBody([name, " done."]);
         }));
       }
       return Promise.all(promises);
     };

     let txn16 = () => {
       let txn = db.transaction("BlobMetadata", "readonly");
       txn.onabort = reportError;
       let request = txn.objectStore("BlobMetadata")
           .openCursor(IDBKeyRange.only("test"));
       request.onsuccess = function(event) {
         logToDocumentBody("Checked blob metadata.");
       }
       return transactionCompletePromise(txn).then(() => {
         logToDocumentBody("Txn16 done.");
       });
     };

     let txn17 = (docGetCallback) => {
       let txn = db.transaction(["DocumentLocks", "Documents", "PendingQueues",
                                 "BlobMetadata", "DocumentCommands"],
                                "readwrite");
       txn.onabort = reportError;
       let locks = txn.objectStore("DocumentLocks");
       let documents = txn.objectStore("Documents");
       let documentCommands = txn.objectStore("DocumentCommands");

       let queues = txn.objectStore("PendingQueues");

       let lockGet;
       let documentGet;
       let commandsDelete;
       let queuesGet;
       let gets_done = () => {
         logToDocumentBody(["Starting edit, got lock: ", lockGet.result.e]);

         let div = logToDocumentBody("Document with picture: ");
         let img = document.createElement("img");
         div.appendChild(img);
         img.src = documentGet.result.docosKeyData[8][2];

         logToDocumentBody(["And the queue: ", queuesGet.result.r]);

         locks.put(t17_DocumentLocksValue);
         documents.put(t17_DocumentsValue);
         documentCommands.put(t17_DocumentCommandsValue);
         queues.put(t17_PendingQueuesValue);
       };
       let incrementBarrier = createIncrementalBarrier(gets_done);

       lockGet = locks.get([docId1]);
       documentGet = documents.get(docId1);
       queuesGet = queues.get(docId1);
       commandsDelete = documentCommands.delete(
             IDBKeyRange.bound([docId1], [docId1, []], false, false));

       lockGet.onsuccess = incrementBarrier();
       let docGetBarrier = incrementBarrier();
       let docGetCallbackPromise;
       documentGet.onsuccess = () => {
         docGetCallbackPromise = docGetCallback();
         docGetBarrier();
       };
       commandsDelete.onsuccess = incrementBarrier();
       queuesGet.onsuccess = incrementBarrier();

       return transactionCompletePromise(txn).then(async () => {
         await docGetCallbackPromise;
         logToDocumentBody("Txn17 done.");
       });
     };

     let txn18 = () => {
       let txn = db.transaction(["Documents"], "readonly");
       txn.onabort = reportError;
       let documents = txn.objectStore("Documents");

       documents.get(docId1).onsuccess = () => {
         logToDocumentBody("Got final document!");
       }

       return transactionCompletePromise(txn).then(() => {
         logToDocumentBody("Txn18 done");
       });
     };

     // https://docs.google.com/document/d/1JC1RgMyxBAjUPSHjm2Bd1KPzcqpPPvxRomKevOkMPm0/edit
     // has an explanation of transaction order.
     await txn1();
     await Promise.all([txn2(), txn3(), txn4()]);
     await Promise.all([txn5(), txn6_15(), txn16(), txn17(txn18)]);
     reportDone();
   };
 </script>
	<!doctype html>
	<title>IDB Offline Google Docs Load Runner</title>
	<div id="content"></div>
	<script src="resources/shared.js"></script>
	<script src="resources/idb-load-docs-shared.js"></script>
	<script>
	let openRequest = window.indexedDB.open(databaseName);
	openRequest.onsuccess = async () => {
	let db = openRequest.result;

	// https://docs.google.com/document/d/1JC1RgMyxBAjUPSHjm2Bd1KPzcqpPPvxRomKevOkMPm0/edit
	// contiains information about each transaction and their ordering.
	let txn1 = () => {
	let txn = db.transaction("Users", "readonly");
	txn.onabort = reportError;
	let users = txn.objectStore("Users");

	let get = users.get("ufa1a865c6eb48d97");
	get.onsuccess = () => {
	logToDocumentBody(["Txn1 got user ", get.result.emailAddress]);
	}
	return transactionCompletePromise(txn).then(() => {
	logToDocumentBody("Txn1 done");
	});
	};

	let txn2 = () => {
	let txn = db.transaction(["DocumentLocks"], "readwrite");
	txn.onabort = reportError;
	let locks = txn.objectStore("DocumentLocks");

	let get = locks.get([docId1]);
	get.onsuccess = () => {
	logToDocumentBody(["Txn2 got lock", get.result.e]);
	}
	t2_DocumentLocksValues.forEach((value) => (locks.put(value)));
	return transactionCompletePromise(txn).then(() => {
	logToDocumentBody("Txn2 done.");
	});
	};

	let txn3 = () => {
	let txn = db.transaction(["Documents"], "readonly");
	txn.onabort = reportError;
	let documents = txn.objectStore("Documents");

	let get = documents.get(docId1);
	get.onsuccess = () => {
	var div = logToDocumentBody(
	"Txn3 done, got the document, with image: ");
	let img = document.createElement("img");
	div.appendChild(img);
	img.src = get.result.docosKeyData[8][2];
	}
	return transactionCompletePromise(txn).then(() => {
	logToDocumentBody("Txn3 done.");
	});
	};

	let txn4 = () => {
	let txn = db.transaction(["PendingQueues"], "readonly");
	txn.onabort = reportError;
	let queues = txn.objectStore("PendingQueues");

	let get = queues.get(docId1);
	get.onsuccess = () => {
	logToDocumentBody(["Txn4 got queue: ", get.result.r]);
	}
	return transactionCompletePromise(txn).then(() => {
	logToDocumentBody("Txn4 done.");
	});
	};

	let txn5 = () => {
	let txn = db.transaction(["SyncObjects"], "readwrite");
	txn.onabort = reportError;
	let syncs = txn.objectStore("SyncObjects");

	t5_SyncObjectsValues.forEach((value) => { syncs.put(value); });

	return transactionCompletePromise(txn).then(() => {
	logToDocumentBody(
	["Txn5 done, set ", t5_SyncObjectsValues.length, " values."]);
	});
	};

	let txn6_15 = () => {
	let promises = [];
	for (let i = 0; i < 9; ++i) {
	let txn = db.transaction("FontMetadata", "readonly");
	txn.onabort = reportError;
	let get = txn.objectStore("FontMetadata").get("Cambria");
	let name = "Txn " + (i + 6);
	get.onsuccess = () => {
	logToDocumentBody([name, " got font with ",
	get.result.fontFaces.length, " faces."]);
	}
	promises.push(transactionCompletePromise(txn).then(() => {
	logToDocumentBody([name, " done."]);
	}));
	}
	return Promise.all(promises);
	};

	let txn16 = () => {
	let txn = db.transaction("BlobMetadata", "readonly");
	txn.onabort = reportError;
	let request = txn.objectStore("BlobMetadata")
	.openCursor(IDBKeyRange.only("test"));
	request.onsuccess = function(event) {
	logToDocumentBody("Checked blob metadata.");
	}
	return transactionCompletePromise(txn).then(() => {
	logToDocumentBody("Txn16 done.");
	});
	};

	let txn17 = (docGetCallback) => {
	let txn = db.transaction(["DocumentLocks", "Documents", "PendingQueues",
	"BlobMetadata", "DocumentCommands"],
	"readwrite");
	txn.onabort = reportError;
	let locks = txn.objectStore("DocumentLocks");
	let documents = txn.objectStore("Documents");
	let documentCommands = txn.objectStore("DocumentCommands");

	let queues = txn.objectStore("PendingQueues");

	let lockGet;
	let documentGet;
	let commandsDelete;
	let queuesGet;
	let gets_done = () => {
	logToDocumentBody(["Starting edit, got lock: ", lockGet.result.e]);

	let div = logToDocumentBody("Document with picture: ");
	let img = document.createElement("img");
	div.appendChild(img);
	img.src = documentGet.result.docosKeyData[8][2];

	logToDocumentBody(["And the queue: ", queuesGet.result.r]);

	locks.put(t17_DocumentLocksValue);
	documents.put(t17_DocumentsValue);
	documentCommands.put(t17_DocumentCommandsValue);
	queues.put(t17_PendingQueuesValue);
	};
	let incrementBarrier = createIncrementalBarrier(gets_done);

	lockGet = locks.get([docId1]);
	documentGet = documents.get(docId1);
	queuesGet = queues.get(docId1);
	commandsDelete = documentCommands.delete(
	IDBKeyRange.bound([docId1], [docId1, []], false, false));

	lockGet.onsuccess = incrementBarrier();
	let docGetBarrier = incrementBarrier();
	let docGetCallbackPromise;
	documentGet.onsuccess = () => {
	docGetCallbackPromise = docGetCallback();
	docGetBarrier();
	};
	commandsDelete.onsuccess = incrementBarrier();
	queuesGet.onsuccess = incrementBarrier();

	return transactionCompletePromise(txn).then(async () => {
	await docGetCallbackPromise;
	logToDocumentBody("Txn17 done.");
	});
	};

	let txn18 = () => {
	let txn = db.transaction(["Documents"], "readonly");
	txn.onabort = reportError;
	let documents = txn.objectStore("Documents");

	documents.get(docId1).onsuccess = () => {
	logToDocumentBody("Got final document!");
	}

	return transactionCompletePromise(txn).then(() => {
	logToDocumentBody("Txn18 done");
	});
	};

	// https://docs.google.com/document/d/1JC1RgMyxBAjUPSHjm2Bd1KPzcqpPPvxRomKevOkMPm0/edit
	// has an explanation of transaction order.
	await txn1();
	await Promise.all([txn2(), txn3(), txn4()]);
	await Promise.all([txn5(), txn6_15(), txn16(), txn17(txn18)]);
	reportDone();
	};
	</script>