Edits history of script submission #175 for ' Watch for new flows (windmillhub)'

• deno

  Edit in Windmill

  Embed

  import * as wmill from "https://deno.land/x/windmill@v1.39.0/mod.ts"
  
  export async function main() {
    const state = await wmill.getInternalState();
    const previousLatestId = state?.latestId ?? 0;
    
    // Fetch and validate
    const data = await (await fetch('https://hub.windmill.dev/searchFlowData')).json();
    const flows = assertFlows(data.flows);
    const newFlows = flows.filter(flow => flow.flow_id > previousLatestId);
  
    // Update state
    const latestId: number = flows.reduce((prevId, flow) => {
      return Math.max(prevId, flow.flow_id);
    }, previousLatestId);
    const newState = {
      ...state,
      latestId,
    };
    await wmill.setInternalState(newState);
    console.info('old state', state);
    console.info('new state', newState);
    
    // Return new flows
    return newFlows;
  }
  
  function assertFlows(items: any): { flow_id: number }[] {
    if (!Array.isArray(items)) {
      throw Error('"flows" must be an array');
    }
    if (!items.every((item: any) => !!item && Number.isInteger(item.flow_id))) {
      throw Error('Not all flows have an integer "flow_id"');
    }
    return items;
  }

  Submitted by jaller94 561 days ago