Function initUploadModule

client/js/src/internal/upload/index.ts:22–117

(
    telemetry: ProtonDriveTelemetry,
    apiService: DriveAPIService,
    driveCrypto: DriveCrypto,
    sharesService: SharesService,
    nodesService: NodesService,
    featureFlagProvider: FeatureFlagProvider,
    clientUid?: string,
    allowSmallFileUpload: boolean = true,
)

 * and verifications.
 */
export function initUploadModule(
    telemetry: ProtonDriveTelemetry,
    apiService: DriveAPIService,
    driveCrypto: DriveCrypto,
    sharesService: SharesService,
    nodesService: NodesService,
    featureFlagProvider: FeatureFlagProvider,
    clientUid?: string,
    allowSmallFileUpload: boolean = true,
) {
    const api = new UploadAPIService(apiService, clientUid);
    const cryptoService = new UploadCryptoService(telemetry, driveCrypto, nodesService);

    const uploadTelemetry = new UploadTelemetry(telemetry, sharesService);
    const manager = new UploadManager(telemetry, api, cryptoService, nodesService, clientUid);

    const queue = new UploadQueue();

    async function shouldUseSmallFileUpload(expectedSize: number): Promise<boolean> {
        const isEnabled =
            allowSmallFileUpload && (await featureFlagProvider.isEnabled(FeatureFlags.DriveSmallFileUpload));
        if (!isEnabled) {
            return false;
        }
        return expectedSize < SMALL_FILE_SIZE_LIMIT;
    }

    /**
     * Returns a FileUploader instance that can be used to upload a file to
     * a parent folder.
     *
     * This operation does not call the API, it only returns a FileUploader
     * instance when the upload queue has capacity.
     */
    async function getFileUploader(
        parentFolderUid: string,
        name: string,
        metadata: UploadMetadata,
        signal?: AbortSignal,
    ): Promise<FileUploader> {
        await queue.waitForCapacity(metadata.expectedSize, signal);

        const onFinish = () => {
            queue.releaseCapacity(metadata.expectedSize);
        };

        return new FileUploaderClass(
            uploadTelemetry,
            api,
            cryptoService,
            manager,
            parentFolderUid,
            name,
            metadata,
            onFinish,
            shouldUseSmallFileUpload,
            signal,
        );