Function recoverDriveFileId

packages/web-backend/src/Storage/index.ts:350–390

(
		key: string,
		previous: typeof Db.storageObjects.$inferSelect,
	)

	const getObjectRecord = (key: string) =>
		mapStorageError(requireDriveObject(repo, integrationId, key));
	const recoverDriveFileId = (
		key: string,
		previous: typeof Db.storageObjects.$inferSelect,
	) =>
		findGoogleDriveFileByObjectKey(config, key, tokenStore).pipe(
			Effect.flatMap(
				Option.match({
					onNone: () =>
						Effect.fail(
							new StorageDomain.StorageError({
								cause: new Error(`Google Drive object not found: ${key}`),
							}),
						),
					onSome: (file) => {
						const videoId = parseObjectKeyVideoId(key);
						const contentType = file.mimeType ?? previous.contentType;
						return mapStorageError(
							repo.upsertObject({
								integrationId,
								ownerId,
								videoId,
								objectKey: key,
								providerObjectId: file.id,
								uploadStatus: "complete",
								contentType,
								contentLength:
									parseGoogleDriveContentLength(file) ??
									previous.contentLength ??
									null,
								metadata: {
									...(previous.metadata ?? {}),
									videoId: videoId ?? previous.metadata?.videoId,
									fileName: file.name ?? previous.metadata?.fileName,
									contentType: file.mimeType ?? previous.metadata?.contentType,
								},
							}),
						).pipe(Effect.as(file.id));
					},
				}),
			),
		);
	const withRecoveredDriveFile = <A>(
		key: string,
		object: typeof Db.storageObjects.$inferSelect,