@applitools/ufg-client
Advanced tools
Comparing version 1.2.9 to 1.2.10
@@ -17,3 +17,3 @@ "use strict"; | ||
const requests = (0, requests_1.makeUFGRequests)({ config, logger }); | ||
const fetchResource = (0, fetch_resource_1.makeFetchResource)({ logger }); | ||
const fetchResource = (0, fetch_resource_1.makeFetchResource)({ logger, fetchConcurrency: config.fetchConcurrency }); | ||
const uploadResource = (0, upload_resource_1.makeUploadResource)({ requests, logger }); | ||
@@ -20,0 +20,0 @@ const processResources = (0, process_resources_1.makeProcessResources)({ fetchResource, uploadResource, cache, logger }); |
"use strict"; | ||
var __importDefault = (this && this.__importDefault) || function (mod) { | ||
return (mod && mod.__esModule) ? mod : { "default": mod }; | ||
}; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
@@ -8,3 +11,4 @@ exports.makeFetchResource = void 0; | ||
const create_user_agent_header_1 = require("../utils/create-user-agent-header"); | ||
function makeFetchResource({ retryLimit = 5, streamingTimeout = 30 * 1000, cache = new Map(), fetch, logger, } = {}) { | ||
const throat_1 = __importDefault(require("throat")); | ||
function makeFetchResource({ retryLimit = 5, streamingTimeout = 30 * 1000, fetchTimeout = 30 * 1000, fetchConcurrency, cache = new Map(), fetch, logger, } = {}) { | ||
const req = (0, req_1.makeReq)({ | ||
@@ -17,3 +21,4 @@ retry: { | ||
}); | ||
return async function fetchResource({ resource, settings = {}, }) { | ||
return fetchConcurrency ? (0, throat_1.default)(fetchConcurrency, fetchResource) : fetchResource; | ||
async function fetchResource({ resource, settings = {}, }) { | ||
var _a; | ||
@@ -41,2 +46,3 @@ let runningRequest = cache.get(resource.id); | ||
hooks: [handleLogs({ logger }), handleStreaming({ timeout: streamingTimeout, logger })], | ||
timeout: fetchTimeout, | ||
}) | ||
@@ -55,3 +61,3 @@ .then(async (response) => { | ||
return runningRequest; | ||
}; | ||
} | ||
} | ||
@@ -58,0 +64,0 @@ exports.makeFetchResource = makeFetchResource; |
{ | ||
"name": "@applitools/ufg-client", | ||
"version": "1.2.9", | ||
"version": "1.2.10", | ||
"homepage": "https://applitools.com", | ||
@@ -5,0 +5,0 @@ "bugs": { |
@@ -1,9 +0,8 @@ | ||
import type { UFGClient } from './types'; | ||
import type { UFGClient, UFGClientConfig } from './types'; | ||
import { type Logger } from '@applitools/logger'; | ||
import { type UFGRequestsConfig } from './server/requests'; | ||
export declare const defaultResourceCache: Map<string, any>; | ||
export declare function makeUFGClient({ config, cache, logger, }: { | ||
config: UFGRequestsConfig; | ||
config: UFGClientConfig; | ||
cache?: Map<string, any>; | ||
logger?: Logger; | ||
}): UFGClient; |
@@ -19,5 +19,7 @@ import type { Cookie } from '../types'; | ||
}) => Promise<ContentfulResource | FailedResource>; | ||
export declare function makeFetchResource({ retryLimit, streamingTimeout, cache, fetch, logger, }?: { | ||
export declare function makeFetchResource({ retryLimit, streamingTimeout, fetchTimeout, fetchConcurrency, cache, fetch, logger, }?: { | ||
retryLimit?: number; | ||
streamingTimeout?: number; | ||
fetchConcurrency?: number; | ||
fetchTimeout?: number; | ||
cache?: Map<string, Promise<ContentfulResource | FailedResource>>; | ||
@@ -24,0 +26,0 @@ fetch?: Fetch; |
@@ -7,2 +7,3 @@ /// <reference types="node" /> | ||
import { type ProcessResourcesSettings } from './resources/process-resources'; | ||
import { type UFGRequestsConfig } from './server/requests'; | ||
export type DomSnapshot = { | ||
@@ -130,2 +131,5 @@ cdt: any[]; | ||
} | ||
export type UFGClientConfig = UFGRequestsConfig & { | ||
fetchConcurrency?: number; | ||
}; | ||
export type RendererEnvironment = { | ||
@@ -132,0 +136,0 @@ rendererId: string; |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
101247
1827