fix: release lock

Author: subframe7536

playground/src/index.ts

@@ -39,15 +39,15 @@ document.querySelector('.import')?.addEventListener('click', async () => {
  file = await selectFile('.db,.sqlite,.sqlite3')
  } catch (error) {
  // eslint-disable-next-line no-alert
- prompt(`${error}`)
+ alert(`${error}`)
  return
  }
  db = await initSQLite(
- useIdbMemoryStorage('test.db', withExistDB(file, { url })),
- // useIdbMemoryStorage('test.db', { url }),
+ // useIdbMemoryStorage('test.db', withExistDB(file, { url })),
+ useIdbMemoryStorage('test.db', { url }),
  // useIdbStorage('test.db', { url }),
  )
- // await importDatabase(db.vfs, db.path, file)
+ await db.sync(file)
  console.log(
  await db.run(`SELECT "type", "tbl_name" AS "table", CASE WHEN "sql" LIKE '%PRIMARY KEY AUTOINCREMENT%' THEN 1 ELSE "name" END AS "name" FROM "sqlite_master"`),
  )

src/io/import.ts

@@ -125,13 +125,19 @@ async function importDatabaseToOpfs(
  source: ReadableStream<Uint8Array>,
 ): Promise<void> {
  const handle = await getHandleFromPath(path, true)
- const [streamForVerify, streamData] = source.tee()
+ const [verifyStream, dataStream] = source.tee()
 
- await parseHeaderAndVerify(streamForVerify.getReader())
+ const verifyReader = verifyStream.getReader()
+ try {
+ // throw error if fail to verify
+ await parseHeaderAndVerify(verifyReader)
+ } finally {
+ verifyReader.releaseLock()
+ }
 
  const writable = await handle.createWritable()
  // `pipeTo()` will auto close `writable`
- await streamData.pipeTo(writable)
+ await dataStream.pipeTo(writable)
 }
 
 /**
@@ -148,7 +154,6 @@ export async function importDatabase(
  isOpfsVFS = defaultIsOpfsVFS,
 ): Promise<void> {
  const stream = data instanceof globalThis.File ? data.stream() : data
- // is `OPFSCoopSyncVFS`
  if (isOpfsVFS(vfs)) {
  await importDatabaseToOpfs(path, stream)
  } else {