Function ensureGoogleDriveFolder

packages/web-backend/src/Storage/GoogleDrive.ts:538–595

(
	config: GoogleDriveIntegrationConfig,
	name: string,
	parentId?: string,
	tokenStore?: GoogleDriveTokenStore,
)

	);

export const ensureGoogleDriveFolder = (
	config: GoogleDriveIntegrationConfig,
	name: string,
	parentId?: string,
	tokenStore?: GoogleDriveTokenStore,
) =>
	Effect.gen(function* () {
		const query = [
			`name='${escapeDriveQueryValue(name)}'`,
			"mimeType='application/vnd.google-apps.folder'",
			"trashed=false",
			...(parentId ? [`'${escapeDriveQueryValue(parentId)}' in parents`] : []),
		].join(" and ");
		const listUrl = appendSharedDriveListParams(
			`${DRIVE_API_BASE}/files?q=${encodeURIComponent(query)}&fields=files(id,name)&spaces=drive`,
			config,
		);
		const listResponse = yield* driveFetch(
			config,
			listUrl,
			undefined,
			tokenStore,
		);
		const listBody = yield* Effect.tryPromise({
			try: () => parseDriveJson<GoogleDriveListResponse>(listResponse),
			catch: (cause) => new Storage.StorageError({ cause }),
		});
		const existingId = listBody.files?.[0]?.id;
		if (existingId) return existingId;

		const createResponse = yield* driveFetch(
			config,
			appendSharedDriveCreateParams(`${DRIVE_API_BASE}/files`),
			{
				method: "POST",
				headers: { "Content-Type": "application/json" },
				body: JSON.stringify({
					name,
					mimeType: GOOGLE_DRIVE_FOLDER_MIME_TYPE,
					...(parentId ? { parents: [parentId] } : {}),
				}),
			},
			tokenStore,
		);

		const created = yield* Effect.tryPromise({
			try: () => parseDriveJson<GoogleDriveFile>(createResponse),
			catch: (cause) => new Storage.StorageError({ cause }),
		});
		if (!created.id) {
			return yield* Effect.fail(
				new Storage.StorageError({
					cause: new Error("Google Drive folder creation did not return an id"),
				}),
			);
		}
		return created.id;
	});