Function checkStorage

packages/server/src/utils/quotaUsage.ts:153–171

(orgId: string, subscriptionId: string, usageCacheManager: UsageCacheManager)

}

export const checkStorage = async (orgId: string, subscriptionId: string, usageCacheManager: UsageCacheManager) => {
    if (!usageCacheManager || !subscriptionId) return

    let currentStorageUsage = 0
    currentStorageUsage = (await usageCacheManager.get(`storage:${orgId}`)) || 0

    const quotas = await usageCacheManager.getQuotas(subscriptionId)
    const storageLimit = quotas[LICENSE_QUOTAS.STORAGE_LIMIT]
    if (storageLimit === -1) return

    if (currentStorageUsage >= storageLimit) {
        throw new InternalFlowiseError(StatusCodes.PAYMENT_REQUIRED, 'Storage limit exceeded')
    }

    return {
        usage: currentStorageUsage,
        limit: storageLimit
    }
}