info: name: Get Contracts with two or more participants (scripted) type: http seq: 4 http: method: GET url: "{{IrisApiUrl}}/contracts;full?year=2025&wfState=signed&page=1" params: - name: pid value: BELL_B_25_CCS_IST_RA_01 type: query disabled: true - name: pid value: VIGN_G_25_CCS_COM_RA_FMT_01 type: query disabled: true - name: pid value: BETT_S_25_CRCT_RA_CHIESI_01 type: query disabled: true - name: pid value: BUSC_A_25_CRCT_RA_IRENAMBIENTE_01 type: query disabled: true - name: pid value: RICC_A_25_CRCT_RA_KEMIN_01 type: query disabled: true - name: pid value: GOBB_G_25_CONV_QUA_01 type: query disabled: true - name: pid value: DELM_N_25_CRCT_RA_BAUMER_01 type: query disabled: true - name: pid value: AMER_F_25_CCS_IST_RA_CODICI_01 type: query disabled: true - name: year value: "2025" type: query - name: wfState value: signed type: query - name: page value: "1" type: query auth: inherit runtime: scripts: - type: after-response code: "// Aggregates contracts with 2+ contributors across all pages and reports summary.\r // // Fixes TypeError: pm.request.url.query.toObject(...).find is not a function by avoiding Array.prototype.find on toObject() result.\r // Adds robust helpers for working with query params across Postman SDK versions and edge cases.\r //\r // Requirements addressed:\r // 1) Read Page-Count header to know total pages\r // 2) Iteratively call same endpoint for pages from current+1 to Page-Count, preserving other query params\r // 3) Aggregate items where contributorSet exists and has length >= 2\r // 4) Build a map pid -> contributorCount across all pages (including initial)\r // 5) Print summary in Test Results and set env var `multiContributorContracts` with [{ pid, contributorCount }]\r // 6) Robust error handling, rate limiting, early stop on non-2xx; handle JSON array or paginated object response shapes\r // 7) Augment aggregation with department (ownerSet[0].organizationUnit.idAb + \" - \" + description). Keep first non-empty.\r \r (function () {\r \ const RATE_LIMIT_DELAY_MS = 200; // small delay between page fetches\r \ const TARGET_ENV_VAR = 'multiContributorContracts';\r \ const PAGE_PARAM = 'page';\r \r \ // ---------------- URL and Query helpers (SDK-safe) -----------------\r \ // Returns a plain object of query params. Works with:\r // // - pm.request.url.query (SDK v8+ as QueryList) using .toObject()\r \ // - URL that has no query or is a raw string\r \ function getQueryObject(url) {\r \ try {\r // // pm.request.url can be a Url object or a string. Normalize to raw string.\r \ const raw = (typeof url === 'string') ? url : (url && (url.toString ? url.toString() : url.raw || ''));\r \ // Try SDK path first if it's a Url object with .query\r \ if (url && url.query && typeof url.query.toObject === 'function') {\r \ const obj = url.query.toObject();\r \ // toObject may return undefined/null on empty query\r \ return obj && typeof obj === 'object' ? { ...obj } : {};\r \ }\r \ // Fallback: parse the raw string\r \ if (typeof raw === 'string') {\r \ const qIndex = raw.indexOf('?');\r \ if (qIndex === -1) return {};\r \ const queryStr = raw.substring(qIndex + 1);\r \ if (!queryStr) return {};\r \ return queryStr.split('&').reduce((acc, pair) => {\r \ if (!pair) return acc;\r \ const [k, v] = pair.split('=');\r \ if (!k) return acc;\r \ acc[decodeURIComponent(k)] = v !== undefined ? decodeURIComponent(v) : '';\r \ return acc;\r \ }, {});\r \ }\r \ } catch (e) {\r \ // fallthrough\r \ }\r \ return {};\r \ }\r \r \ function setQueryObject(url, updates) {\r \ // Returns a new raw URL string with given query params merged\r \ const raw = (typeof url === 'string') ? url : (url && (url.toString ? url.toString() : url.raw || ''));\r \ const qIndex = raw.indexOf('?');\r \ const base = qIndex === -1 ? raw : raw.substring(0, qIndex);\r \ const current = getQueryObject(url);\r \ const merged = { ...current, ...updates };\r \ // Filter out empty/undefined to avoid adding stray keys\r \ const parts = Object.keys(merged)\r \ .filter(k => merged[k] !== undefined && merged[k] !== null && merged[k] !== '')\r \ .map(k => encodeURIComponent(k) + '=' + encodeURIComponent(String(merged[k])));\r \ return parts.length ? base + '?' + parts.join('&') : base;\r \ }\r \r \ // ---------------- Response shape helpers -----------------\r \ function isObject(x) { return x && typeof x === 'object' && !Array.isArray(x); }\r \r \ function getItemsFromResponseBody(rb) {\r \ // Supports either an array payload or an object with an array at known keys\r \ if (Array.isArray(rb)) return rb;\r \ if (isObject(rb)) {\r \ // Try common keys: 'items', 'data', 'results'\r \ if (Array.isArray(rb.items)) return rb.items;\r \ if (Array.isArray(rb.data)) return rb.data;\r \ if (Array.isArray(rb.results)) return rb.results;\r \ }\r \ return [];\r \ }\r \r \ function safeJson(body) {\r \ try { return JSON.parse(body); } catch (e) { return null; }\r \ }\r \r \ // ---------------- Aggregation store -----------------\r \ // Map: pid -> { contributorCount, department }\r \ const aggregate = {};\r \r \ function extractDepartment(item) {\r \ try {\r \ const owner0 = Array.isArray(item.ownerSet) && item.ownerSet.length > 0 ? item.ownerSet[0] : null;\r \ const ou = owner0 && owner0.organizationUnit ? owner0.organizationUnit : null;\r \ const idAb = ou && typeof ou.idAb === 'string' ? ou.idAb : null;\r \ const desc = ou && typeof ou.description === 'string' ? ou.description : null;\r \ if (idAb && desc) return idAb + ' - ' + desc;\r \ return '';\r \ } catch (e) {\r \ return '';\r \ }\r \ }\r \r \ function considerItems(items) {\r \ items.forEach(it => {\r \ const contributors = Array.isArray(it.contributorSet) ? it.contributorSet : [];\r \ if (contributors.length >= 2) {\r \ const pid = (it.pid != null) ? String(it.pid) : '';\r \ if (!pid) return;\r \ const contributorCount = contributors.length;\r \ const dept = extractDepartment(it);\r \ if (!aggregate[pid]) {\r \ aggregate[pid] = { contributorCount, department: dept || '' };\r \ } else {\r \ // keep max contributor count seen (in case of variations) and first non-empty department\r \ aggregate[pid].contributorCount = Math.max(aggregate[pid].contributorCount, contributorCount);\r \ if (!aggregate[pid].department && dept) {\r \ aggregate[pid].department = dept;\r \ }\r \ }\r \ }\r \ });\r \ }\r \r \ // ---------------- Paging orchestration -----------------\r \ const initialStatus = res.getStatus();\r \ const is2xx = initialStatus >= 200 && initialStatus < 300;\r \ if (!is2xx) {\r \ test('Request failed - not aggregating on non-2xx', function () {\r \ expect(is2xx).to.eql(true);\r \ });\r \ return;\r \ }\r \r \ const rb = safeJson(JSON.stringify(res.getBody()));\r \ const initialItems = rb ? getItemsFromResponseBody(rb) : [];\r \ considerItems(initialItems);\r \r \ // Derive total pages from header 'Page-Count' or 'page-count'\r \ const pageCountHeader = res.getHeader('Page-Count') || res.getHeader('page-count') || res.getHeader('X-Total-Pages');\r \ const totalPages = pageCountHeader ? parseInt(pageCountHeader, 10) : 1;\r \r \ // Figure out current page from request URL (query param 'page')\r \ const currentQuery = getQueryObject(req.getUrl());\r \ const currentPage = parseInt(currentQuery[PAGE_PARAM] || '1', 10) || 1;\r \r \ // Build a function that fetches page N and aggregates\r \ function fetchPage(n) {\r \ return new Promise((resolve) => {\r \ const nextUrl = setQueryObject(req.getUrl(), { [PAGE_PARAM]: String(n) });\r \ setTimeout(function () {\r \ await bru.sendRequest({ url: nextUrl, method: 'GET' }, async function(err, res) {\r \ if (err || !res) {\r \ test('Error fetching page ' + n, function () {\r \ expect(err).to.eql(null);\r \ });\r \ return resolve(false);\r \ }\r \ const ok = res.status >= 200 && res.status < 300;\r \ if (!ok) {\r \ test('Non-2xx on page ' + n + ' - stop further paging', function () {\r \ expect(ok).to.eql(true);\r \ });\r \ return resolve(false);\r \ }\r \ const body = res.data;\r \ const json = safeJson(body);\r \ const items = json ? getItemsFromResponseBody(json) : [];\r \ considerItems(items);\r \ resolve(true);\r \ });\r \ }, RATE_LIMIT_DELAY_MS);\r \ });\r \ }\r \r \ async function run() {\r \ // If there are more pages, iterate\r \ for (let p = currentPage + 1; p <= totalPages; p++) {\r \ const cont = await fetchPage(p);\r \ if (!cont) break;\r \ }\r \r \ // Prepare output array\r \ const output = Object.keys(aggregate).map(pid => ({\r \ pid,\r \ contributorCount: aggregate[pid].contributorCount,\r \ department: aggregate[pid].department || ''\r \ }));\r \r \ // Save to environment\r \ bru.setEnvVar(TARGET_ENV_VAR, JSON.stringify(output));\r \r \ // Basic summary tests\r \ test('Aggregated items have required properties', function () {\r \ output.forEach(item => {\r \ expect(item).to.have.property('pid');\r \ expect(item.pid).to.be.a('string');\r \ expect(item).to.have.property('contributorCount');\r \ expect(item.contributorCount).to.be.a('number');\r \ expect(item).to.have.property('department');\r \ expect(item.department).to.be.a('string');\r \ });\r \ });\r \r \ // Optional: Log summary count\r \ test('Total multi-contributor contracts aggregated', function () {\r \ expect(output.length).to.be.at.least(0);\r \ });\r \ }\r \r \ run();\r })();" settings: encodeUrl: true timeout: 0 followRedirects: true maxRedirects: 5