Method write

api/src/services/tus/data-store.ts:145–204

(readable: stream.Readable, tus_id: string, offset: number)

	}

	public override async write(readable: stream.Readable, tus_id: string, offset: number): Promise<number> {
		const logger = useLogger();
		const fileData = await this.getFileById(tus_id);
		const filePath = fileData.filename_disk!;

		const sudoFilesItemsService = new ItemsService<File>('directus_files', {
			schema: this.schema,
		});

		try {
			const newOffset = await this.storageDriver.writeChunk(
				filePath,
				readable,
				offset,
				fileData.tus_data as ChunkedUploadContext,
			);

			await sudoFilesItemsService.updateOne(fileData.id!, {
				tus_data: {
					...fileData.tus_data,
					offset: newOffset,
				},
			});

			if (Number(fileData.filesize) === newOffset) {
				try {
					await this.storageDriver.finishChunkedUpload(filePath, fileData.tus_data as ChunkedUploadContext);
				} catch (err) {
					await this.remove(fileData.tus_id!);
					throw err;
				}

				const targetId = fileData.tus_data?.['metadata']?.['id'] as string | undefined;
				const isReplacement = targetId && targetId !== fileData.id;

				// If the file is a replacement, delete the old files, and upgrade the temp file. DB record will be cleanup on in onUploadFinish handler
				if (isReplacement) {
					const replaceData = await sudoFilesItemsService.readOne(targetId, { fields: ['filename_disk'] });

					// delete the previously saved file and thumbnails to ensure they're generated fresh
					for await (const partPath of this.storageDriver.list(targetId)) {
						await this.storageDriver.delete(partPath);
					}

					// Upgrade the temp file to the final filename
					await this.storageDriver.move(filePath, replaceData.filename_disk);
				}
			}

			return newOffset;
		} catch (err: any) {
			logger.error(err, 'Error writing chunk for upload "%s" at offset %d', tus_id, offset);

			if ('status_code' in err && err.status_code === 500) {
				throw err;
			}

			throw ERRORS.FILE_WRITE_ERROR;