const setCache = (key, data) => LOCALSTATUS.put(key, data);  
const getCache = key => LOCALSTATUS.get(key);function sleep(ms) {  
  return new Promise(resolve => setTimeout(resolve, ms));  
}

function dateToStatus(dateTime) {  
 var isoDateNow = Date.now();  
 var dateDiff = (isoDateNow - dateTime);  
 if (dateDiff < 180000) {  
  return 1  
 } else {  
  return 0  
 }  
}

async function getStatuses() {  
 const cacheKeys = await LOCALSTATUS.list();  
 while (!(cacheKeys.listcomplete === true)) {  
  sleep(5)  
 } 
 
 const numKeys = cacheKeys.keys.length;  
 
 var statuses = []; for (var i = 0; i < numKeys; i++) {  
  var c = cacheKeys.keys[i];  
  var epcDate = await getCache(c.name);  
  var data = {date: Number(epcDate), name: c.name};  
  data.strDate = new Date(data.date).toISOString();  
  data.status = dateToStatus(data.date);  
  data.statusIndicator = getStatusIndicator(data.status);  
  statuses.push(data);  
 }
 
 const body = html(JSON.stringify(statuses || [])); return new Response(body, {  
  headers: { 'Content-Type': 'text/html' },  
 });  
}

async function getStatus(cacheKey) {  
  var cacheDate = await getCache(cacheKey); if (!cacheDate) {  
    return new Response('invalid status key', { status: 500 });  
  } else {  
   var status = dateToStatus(cacheDate);  
   return new Response(status, {status: 200});  
  }  
}

async function updateStatus(cacheKey) {  
  try {  
   var isoDate = Date.now();  
   await setCache(cacheKey, isoDate);  
   var strDate = new Date(isoDate).toISOString();  
   return new Response((cacheKey + " set at " + strDate + "\n"), { status: 200 });  
  } catch (err) {  
   return new Response(err, { status: 500 });  
  }  
}

async function handleRequest(request) {  
  let statusKey = new URL(request.url).searchParams.get('service');  
  let queryType = new URL(request.url).searchParams.get('query'); 
  if (request.method === 'POST') {  
   return updateStatus(statusKey);  
  } else if (queryType === 'simple') {  
   return getStatus(statusKey);  
  } else {  
   return getStatuses();  
  }  
}
addEventListener('fetch', event => {  
 event.respondWith(handleRequest(event.request))  
})