Function makeGoogleDriveAccess

packages/web-backend/src/Storage/index.ts:335–735

({
	repo,
	integration,
	config,
}: {
	repo: StorageRepo;
	integration: typeof Db.storageIntegrations.$inferSelect;
	config: GoogleDriveIntegrationConfig;
})

	);

const makeGoogleDriveAccess = ({
	repo,
	integration,
	config,
}: {
	repo: StorageRepo;
	integration: typeof Db.storageIntegrations.$inferSelect;
	config: GoogleDriveIntegrationConfig;
}) => {
	const integrationId = integration.id;
	const ownerId = integration.ownerId;
	const tokenStore = makeGoogleDriveTokenStore(repo, integration);

	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,