Skip to workflow content
Vora
← Workflow library

Client Reporting

Review Rating Reconciliation

Reconcile supplied star-rating buckets with a reported review count and average without retrieving or authenticating reviews.

Experimental native example · local preview · revision 1

WORKFLOW PREVIEW

See how it works

2 nodes · 1 connections

Use + and − to zoom, F to fit. Press Enter on a node to inspect it.

Private preview. These tested drafts are available for inspection. Adding them to a Vora workspace is still being tested.

What you need

  • Authorized supplied facts matching the declared fields.
  • Operator-reviewed policy, units and client scope.
Follow the workflow step by step
  1. Supplied agency data

    Receive the explicitly supplied manual input packet.

  2. Review Rating Reconciliation

    Reconcile supplied star-rating buckets with a reported review count and average without retrieving or authenticating reviews.

Setup and review

  • Review the declared input/output and boundary rules.
  • Run a synthetic manual example.
  • Inspect all exclusions and unknowns before any downstream proposal.

Inspect every node

Expand a node to inspect its complete settings. Review the runtime and adoption evidence before installing it.

Supplied agency data · wfManualTrigger
{
  "label": "Supplied agency data"
}
Review Rating Reconciliation · code
{
  "code": "const slug=\"review-rating-reconciliation\";\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 const stars=new Set();let observedCount=0,totalStars=0;for(const r of input.ratings){positive(r.stars,'stars');if(r.stars>5||stars.has(r.stars))fail('invalid or duplicate star bucket');stars.add(r.stars);nonneg(r.count,'rating count');observedCount=safe(observedCount+r.count);totalStars=safe(totalStars+mul(r.stars,r.count));}nonneg(input.declaredCount,'declared count');nonneg(input.declaredAverageHundredths,'declared average');if(input.declaredAverageHundredths>500)fail('declared average out of range');const weightedAverageHundredths=observedCount?Math.floor(mul(totalStars,100)/observedCount):null;return {observedCount,weightedAverageHundredths,countDifference:safe(observedCount-input.declaredCount),averageDifferenceHundredths:weightedAverageHundredths===null?null:weightedAverageHundredths-input.declaredAverageHundredths};\n})(input);",
  "label": "Review Rating Reconciliation",
  "memoryLimit": 16,
  "outputVar": "result",
  "timeout": 1000
}
Input and output contracts

Input

{
  "type": "object",
  "properties": {
    "ratings": {
      "type": "array",
      "items": {
        "type": "object",
        "properties": {
          "stars": {
            "type": "integer",
            "minimum": -9007199254740991,
            "maximum": 9007199254740991
          },
          "count": {
            "type": "integer",
            "minimum": -9007199254740991,
            "maximum": 9007199254740991
          }
        },
        "required": [
          "stars",
          "count"
        ],
        "additionalProperties": false
      },
      "maxItems": 100
    },
    "declaredCount": {
      "type": "integer",
      "minimum": -9007199254740991,
      "maximum": 9007199254740991
    },
    "declaredAverageHundredths": {
      "type": "integer",
      "minimum": -9007199254740991,
      "maximum": 9007199254740991
    }
  },
  "required": [
    "ratings",
    "declaredCount",
    "declaredAverageHundredths"
  ],
  "additionalProperties": false
}

Output

{
  "type": "object",
  "properties": {
    "observedCount": {
      "type": "integer",
      "minimum": -9007199254740991,
      "maximum": 9007199254740991
    },
    "weightedAverageHundredths": {
      "type": [
        "integer",
        "null"
      ],
      "minimum": -9007199254740991,
      "maximum": 9007199254740991
    },
    "countDifference": {
      "type": "integer",
      "minimum": -9007199254740991,
      "maximum": 9007199254740991
    },
    "averageDifferenceHundredths": {
      "type": [
        "integer",
        "null"
      ],
      "minimum": -9007199254740991,
      "maximum": 9007199254740991
    }
  },
  "required": [
    "observedCount",
    "weightedAverageHundredths",
    "countDifference",
    "averageDifferenceHundredths"
  ],
  "additionalProperties": false
}

Choose an output for this job

This business workflow also has 15 delivery formats. Compare their inputs, output examples and limits.

Compare implementations for this job

Example input and result

These examples use synthetic data.

Input

{
  "ratings": [
    {
      "stars": 5,
      "count": 1
    },
    {
      "stars": 3,
      "count": 1
    }
  ],
  "declaredCount": 3,
  "declaredAverageHundredths": 400
}

Expected result

{
  "observedCount": 2,
  "weightedAverageHundredths": 400,
  "countDifference": -1,
  "averageDifferenceHundredths": 0
}

Success means: Reconcile supplied star-rating buckets with a reported review count and average without retrieving or authenticating reviews.

When something goes wrong

  • Correct the rejected supplied fact (stars outside one to five) and repeat a controlled test. Preserve every quarantine or unknown result.

Limits and costs

  • Missing star buckets have zero supplied count; declared average must be0..500. Pure supplied-data processing; no external effect. No independent source/authenticity/legal/customer-acceptance verification.
  • No paid model calls or metered third-party operations are declared in this pure graph. Vora plan availability, compute and quotas still apply; pricing has not been verified by this batch.

USE IN VORA

Review Rating Reconciliation

Review this workflow’s steps and required inputs. Get access to Vora before setting it up in your workspace.

Workspace installation is being connected. This page lets you inspect the workflow; it does not create or run one.

Required input fields
{
  "type": "object",
  "properties": {
    "ratings": {
      "type": "array",
      "items": {
        "type": "object",
        "properties": {
          "stars": {
            "type": "integer",
            "minimum": -9007199254740991,
            "maximum": 9007199254740991
          },
          "count": {
            "type": "integer",
            "minimum": -9007199254740991,
            "maximum": 9007199254740991
          }
        },
        "required": [
          "stars",
          "count"
        ],
        "additionalProperties": false
      },
      "maxItems": 100
    },
    "declaredCount": {
      "type": "integer",
      "minimum": -9007199254740991,
      "maximum": 9007199254740991
    },
    "declaredAverageHundredths": {
      "type": "integer",
      "minimum": -9007199254740991,
      "maximum": 9007199254740991
    }
  },
  "required": [
    "ratings",
    "declaredCount",
    "declaredAverageHundredths"
  ],
  "additionalProperties": false
}