File "read-files-from-data-transfer.ts"
Full Path: /home/markqprx/iniasli.pro/client/ui/interactions/dnd/read-files-from-data-transfer.ts
File size: 1.75 KB
MIME-type: text/plain
Charset: utf-8
import {UploadedFile} from '@common/uploads/uploaded-file';
export async function* readFilesFromDataTransfer(dataTransfer: DataTransfer) {
const entries: FileSystemEntry[] = [];
// Pull out all entries before reading them, otherwise
// some entries will be lost due to recursion with promises
for (const item of dataTransfer.items) {
if (item.kind === 'file') {
const entry = item.webkitGetAsEntry();
if (entry) {
entries.push(entry);
}
}
}
for (const entry of entries) {
if (entry.isFile) {
if (entry.name === '.DS_Store') continue;
const file = await getEntryFile(entry as FileSystemFileEntry);
yield new UploadedFile(file, entry.fullPath);
} else if (entry.isDirectory) {
yield* getEntriesFromDirectory(entry as FileSystemDirectoryEntry);
}
}
}
async function* getEntriesFromDirectory(
item: FileSystemDirectoryEntry
): AsyncIterable<any> {
const reader = item.createReader();
// We must call readEntries repeatedly because there may be a limit to the
// number of entries that are returned at once.
let entries: FileSystemEntry[];
do {
entries = await new Promise((resolve, reject) => {
reader.readEntries(resolve, reject);
});
for (const entry of entries) {
if (entry.isFile) {
if (entry.name === '.DS_Store') continue;
const file = await getEntryFile(entry as FileSystemFileEntry);
yield new UploadedFile(file, entry.fullPath);
} else if (entry.isDirectory) {
yield* getEntriesFromDirectory(entry as FileSystemDirectoryEntry);
}
}
} while (entries.length > 0);
}
function getEntryFile(entry: FileSystemFileEntry): Promise<File> {
return new Promise((resolve, reject) => entry.file(resolve, reject));
}