Pipeline Transition Audit

{
  "label": "Supplied agency data"
}

{
  "code": "const slug=\"pipeline-transition-audit\";\n\nfunction fail(reason){throw new Error('Invalid '+slug+' input: '+reason);}\nfunction safe(value){if(!Number.isSafeInteger(value))fail('unsafe integer arithmetic');return value;}\nfunction nonneg(value,name='quantity'){if(!Number.isSafeInteger(value)||value<0)fail(name+' must be nonnegative');return value;}\nfunction positive(value,name='quantity'){nonneg(value,name);if(value===0)fail(name+' must be positive');return value;}\nfunction ident(value){if(typeof value!=='string'||!value.trim())fail('blank identity');return value.trim();}\nfunction unique(values,key){const seen=new Set();for(const value of values){const k=ident(key?value[key]:value);if(seen.has(k))fail('duplicate identity');seen.add(k);}return values;}\nfunction rows(values,key='id'){return unique(values,key);}\nfunction sum(values){return values.reduce((total,value)=>safe(total+value),0);}\nfunction mul(a,b){return safe(a*b);}\nfunction sorted(values){return [...values].sort((a,b)=>a<b?-1:a>b?1:0);}\nfunction distinct(values){return [...new Set(values)];}\nfunction pair(a,b){return JSON.stringify([a,b]);}\nfunction day(value){if(typeof value!=='string'||!/^\\d{4}-\\d{2}-\\d{2}$/.test(value))fail('invalid calendar date');const n=Date.parse(value+'T00:00:00Z');if(!Number.isFinite(n)||new Date(n).toISOString().slice(0,10)!==value)fail('invalid calendar date');return n/86400000;}\nfunction dayText(value){const date=new Date(mul(value,86400000));if(!Number.isFinite(date.getTime())||date.getUTCFullYear()<0||date.getUTCFullYear()>9999)fail('four-digit calendar range');return date.toISOString().slice(0,10);}\nfunction stamp(value){const match=typeof value==='string'&&value.match(/^(\\d{4}-\\d{2}-\\d{2})T(\\d{2}):(\\d{2}):(\\d{2})(Z|[+-]\\d{2}:\\d{2})$/);if(!match)fail('invalid offset timestamp');day(match[1]);if(+match[2]>23||+match[3]>59||+match[4]>59)fail('invalid clock time');if(match[5]!=='Z'&&(+match[5].slice(1,3)>23||+match[5].slice(4)>59))fail('invalid offset');const n=Date.parse(value);if(!Number.isFinite(n))fail('invalid timestamp');return n/1000;}\nfunction stampText(value){const date=new Date(mul(value,1000));if(!Number.isFinite(date.getTime())||date.getUTCFullYear()<0||date.getUTCFullYear()>9999)fail('four-digit calendar range');return date.toISOString();}\nfunction interval(start,end){if(end<=start)fail('reversed or empty interval');}\nfunction normalize(value,key=''){if(typeof value==='string'&&(key==='id'||key.endsWith('Id')||key.endsWith('Ids')||['members','clients','partners','pageIds','expectedIds','jobs','requiredAttendees','requires','dependsOn'].includes(key)))return value.trim();if(Array.isArray(value))return value.map(v=>normalize(v,key));if(value&&typeof value==='object')return Object.fromEntries(Object.entries(value).map(([k,v])=>[k,normalize(v,k)]));return value;}\nfunction graphCheck(nodes,edges){const byId=new Map(rows(nodes).map(n=>[n.id,n]));const visiting=new Set(),done=new Set();function visit(id){if(visiting.has(id))fail('dependency cycle');if(done.has(id))return;const node=byId.get(id);if(!node)fail('unknown dependency reference');visiting.add(id);unique(edges(node));for(const target of edges(node)){if(target===id)fail('self prerequisite');visit(target);}visiting.delete(id);done.add(id);}for(const id of byId.keys())visit(id);return byId;}\nfunction monthNumber(date){day(date);return Number(date.slice(0,4))*12+Number(date.slice(5,7))-1;}\nfunction sweep(items,startKey,endKey,limit){const points=sorted(distinct(items.flatMap(item=>[item[startKey],item[endKey]]))).sort((a,b)=>a-b),out=[];for(let i=0;i+1<points.length;i++){const start=points[i],end=points[i+1],active=sorted(items.filter(item=>item[startKey]<=start&&item[endKey]>start).map(item=>item.id));if(active.length>limit){const last=out.at(-1);if(last&&last.end===start&&JSON.stringify(last.active)===JSON.stringify(active))last.end=end;else out.push({start,end,active});}}return out;}\nfunction httpUrl(value){if(typeof value!=='string'||/[\\u0000-\\u0020\\u007f<>\"\\\\]/.test(value)||/%(?![0-9a-f]{2})/i.test(value))return null;const m=value.match(/^https?:\\/\\/([^/?#]+)([^#]*)(?:#.*)?$/i);if(!m||m[1].includes('@'))return null;const authority=m[1].match(/^([^:]+)(?::(\\d{1,5}))?$/);if(!authority||(authority[2]&&Number(authority[2])>65535))return null;const host=authority[1],labels=host.split('.');if(host.length>253||labels.some(l=>!l||l.length>63||!/^[a-z0-9](?:[a-z0-9-]*[a-z0-9])?$/i.test(l)))return null;if(labels.every(l=>/^\\d+$/.test(l))&&(labels.length!==4||labels.some(l=>Number(l)>255||(l.length>1&&l[0]==='0'))))return null;const q=m[2].indexOf('?'),raw=q<0?'':m[2].slice(q+1),query=[];try{if(raw)for(const part of raw.split('&')){const at=part.indexOf('='),key=at<0?part:part.slice(0,at),val=at<0?'':part.slice(at+1);query.push([decodeURIComponent(key.replace(/\\+/g,' ')),decodeURIComponent(val.replace(/\\+/g,' '))]);}}catch{return null;}return {query};}\n\nconst input=normalize(context.input);\nreturn (input=>{\n rows(input.events);const allowed=new Set(input.allowed.map(a=>{ident(a.from);ident(a.to);return pair(a.from,a.to);})),groups=new Map(),disallowed=new Set(),discontinuous=new Set();\n for(const e of input.events){ident(e.dealId);ident(e.from);ident(e.to);positive(e.sequence,'sequence');const list=groups.get(e.dealId)||[];list.push(e);groups.set(e.dealId,list);if(!allowed.has(pair(e.from,e.to)))disallowed.add(e.id);}for(const events of groups.values()){const seq=new Set();for(const e of events){if(seq.has(e.sequence))fail('duplicate sequence');seq.add(e.sequence);}events.sort((a,b)=>a.sequence-b.sequence);for(let i=1;i<events.length;i++)if(events[i].from!==events[i-1].to)discontinuous.add(events[i].id);}\n return {disallowedIds:input.events.filter(e=>disallowed.has(e.id)).map(e=>e.id),discontinuousIds:input.events.filter(e=>discontinuous.has(e.id)).map(e=>e.id)};\n})(input);",
  "label": "Pipeline Transition Audit",
  "memoryLimit": 16,
  "outputVar": "result",
  "timeout": 1000
}