Method create

api/src/services/tus/data-store.ts:51–143

(upload: Upload)

	}

	public override async create(upload: Upload): Promise<Upload> {
		const logger = useLogger();
		const knex = getDatabase();

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

		upload.creation_date = new Date().toISOString();

		if (!upload.size || !upload.metadata || !upload.metadata['filename_download']) {
			throw ERRORS.INVALID_METADATA;
		}

		if (!upload.metadata['type']) {
			upload.metadata['type'] = 'application/octet-stream';
		}

		if (!upload.metadata['title']) {
			upload.metadata['title'] = formatTitle(upload.metadata['filename_download']);
		}

		let existingFile: Record<string, unknown> | undefined;

		// If the payload contains a primary key, we'll check if the file already exists for replacement
		if (upload.metadata['id']) {
			existingFile = await knex.select('tus_id').from('directus_files').andWhere({ id: upload.metadata['id'] }).first();

			if (existingFile && existingFile['tus_id'] !== null) {
				throw ERRORS.INVALID_METADATA;
			}
		}

		const fileData: Partial<File> = {
			...omit(upload.metadata, ['id']),
			tus_id: upload.id,
			tus_data: upload,
			filesize: upload.size,
			storage: this.location,
		};

		if (fileData.filename_disk) {
			fileData.filename_disk = sanitizeFilepath(fileData.filename_disk);
			assertValidStoragePath(fileData.filename_disk, this.location);
			await assertUniqueFilename(knex, fileData.filename_disk, upload.metadata['id']);
		}

		// If no folder is specified, we'll use the default folder from the settings if it exists
		if ('folder' in fileData === false) {
			const settings = await knex.select('storage_default_folder').from('directus_settings').first();

			if (settings?.storage_default_folder) {
				fileData.folder = settings.storage_default_folder;
			}
		}