Function copyGoogleDriveFile

packages/web-backend/src/Storage/GoogleDrive.ts:1205–1264

({
	repo,
	config,
	sourceFileId,
	input,
	tokenStore,
}: {
	repo: StorageRepo;
	config: GoogleDriveIntegrationConfig;
	sourceFileId: string;
	input: CreateGoogleDriveUploadInput;
	tokenStore?: GoogleDriveTokenStore;
})

	).pipe(Effect.asVoid);

export const copyGoogleDriveFile = ({
	repo,
	config,
	sourceFileId,
	input,
	tokenStore,
}: {
	repo: StorageRepo;
	config: GoogleDriveIntegrationConfig;
	sourceFileId: string;
	input: CreateGoogleDriveUploadInput;
	tokenStore?: GoogleDriveTokenStore;
}) =>
	Effect.gen(function* () {
		const parentId = yield* getGoogleDriveUploadParentId(
			repo,
			config,
			input,
			tokenStore,
		);
		const response = yield* driveFetch(
			config,
			appendSharedDriveCreateParams(
				`${DRIVE_API_BASE}/files/${encodeURIComponent(sourceFileId)}/copy?fields=id,name,mimeType,size`,
			),
			{
				method: "POST",
				headers: { "Content-Type": "application/json" },
				body: JSON.stringify({
					name: getDriveFileName(input.key),
					parents: [parentId],
					appProperties: {
						capObjectKey: input.key,
					},
				}),
			},
			tokenStore,
		);
		const copied = yield* Effect.tryPromise({
			try: () => parseDriveJson<GoogleDriveFile>(response),
			catch: (cause) => new Storage.StorageError({ cause }),
		});
		if (!copied.id) {
			return yield* Effect.fail(
				new Storage.StorageError({
					cause: new Error("Google Drive copy did not return an id"),
				}),
			);
		}
		yield* repo.upsertObject({
			integrationId: input.integrationId,
			ownerId: input.ownerId,
			videoId: input.videoId,
			objectKey: input.key,
			providerObjectId: copied.id,
			uploadStatus: "complete",
			contentType: copied.mimeType ?? input.contentType,
			contentLength: copied.size ? Number(copied.size) : null,