fix costco
This commit is contained in:
parent
47507799d4
commit
32511344b7
2 changed files with 43 additions and 28 deletions
24
app.py
24
app.py
|
@ -1,6 +1,6 @@
|
|||
from flask import Flask,render_template,send_from_directory
|
||||
from flask_caching import Cache
|
||||
import requests
|
||||
import httpx
|
||||
|
||||
app=Flask(__name__)
|
||||
app.config['CACHE_TYPE']='SimpleCache'
|
||||
|
@ -14,14 +14,28 @@ def index():
|
|||
def favicon():
|
||||
return send_from_directory(app.static_folder,"gas.svg")
|
||||
|
||||
@app.route("/gas.csv")
|
||||
@app.route("/samsclub.csv")
|
||||
@cache.cached(timeout=1800)
|
||||
def gas():
|
||||
result=["Sams https://www.samsclub.com/local/fuel-center/-/X"]
|
||||
def sams():
|
||||
url='https://www.samsclub.com/api/node/vivaldi/browse/v2/clubfinder/list?distance=10000&nbrOfStores=1000&singleLineAddr=10001'
|
||||
sams=requests.get(url,headers={'User-Agent':'Mozilla/5.0','Accept-Encoding':'ztsd'}).json()
|
||||
headers={'User-Agent':'Mozilla/5.0','Accept-Encoding':'ztsd'}
|
||||
sams=httpx.get(url,headers=headers,timeout=10).json()
|
||||
result=[]
|
||||
for s in sams:
|
||||
if 'gasPrices' in s:
|
||||
p={g['gradeId']:int(g['price']*100) for g in s['gasPrices']}
|
||||
result.append(f"{p[11]},{p[16]},{s['geoPoint']['latitude']},{s['geoPoint']['longitude']},{s['id']}")
|
||||
return "\n".join(result)
|
||||
|
||||
@app.route("/costco.csv")
|
||||
@cache.cached(timeout=1800)
|
||||
def costco():
|
||||
url='https://www.costco.com/AjaxWarehouseBrowseLookupView?hasGas=true&populateWarehouseDetails=true'
|
||||
headers={'Accept':'*/*','Accept-Encoding':'gzip,deflate,br,zstd','Accept-Language':'en','Referer':'costco.com','Sec-Fetch-Mode':'cors','User-Agent':'Mozilla/5.0 Firefox/140.0'}
|
||||
costco=httpx.Client(http2=True).get(url,headers=headers,timeout=60).json()[1:]
|
||||
result=[]
|
||||
for s in costco:
|
||||
if 'regular' in s['gasPrices'] and s['country']=='US':
|
||||
p={g:int(float(s['gasPrices'][g])*100) for g in ['regular','premium']}
|
||||
result.append(f"{p['regular']},{p['premium']},{s['latitude']},{s['longitude']},{s['displayName']}")
|
||||
return "\n".join(result)
|
||||
|
|
|
@ -14,44 +14,45 @@
|
|||
color:black;
|
||||
text-decoration:none;
|
||||
}
|
||||
.Sams{
|
||||
.samsclub,.costco{
|
||||
display:flex;
|
||||
border-radius:33%;
|
||||
text-align:center;
|
||||
align-items:center;
|
||||
font-size:14px;
|
||||
font-weight:bold;
|
||||
background-color:rgba(0,103,160,0.5);
|
||||
}
|
||||
.samsclub{background-color:rgba(0,103,160,0.5);}
|
||||
.costco{background-color:rgba(227,42,54,0.5);}
|
||||
</style>
|
||||
</head>
|
||||
<body>
|
||||
<div id="map"></div>
|
||||
<script>
|
||||
let osm=L.tileLayer("https://{s}.tile.openstreetmap.org/{z}/{x}/{y}.png")
|
||||
let map=L.map("map",{center:[38.243,-85.647],zoom:11,layers:[osm]});
|
||||
let layerControl=L.control.layers({"fetching gas prices...":osm},null,{collapsed:false}).addTo(map);
|
||||
fetch("gas.csv").then(response=>{
|
||||
layerControl.remove();
|
||||
let map=L.map("map",{center:[38.243,-85.647],zoom:11,layers:[L.tileLayer("https://{s}.tile.openstreetmap.org/{z}/{x}/{y}.png")]});
|
||||
let layerControl=L.control.layers(null,null,{collapsed:false}).addTo(map);
|
||||
let chains={"Sam's Club":"https://www.samsclub.com/local/fuel-center/-/X","Costco":"https://www.costco.com/warehouse-locations-X.html#:~:text=Gas%20Station"};
|
||||
for (const [chain,url] of Object.entries(chains)){
|
||||
const chainId=chain.toLowerCase().replace(/[^a-z]/g,'');
|
||||
chains[chain]=L.layerGroup().addTo(map);
|
||||
layerControl.addOverlay(chains[chain],`${chain} loading...`)
|
||||
fetch(chainId+".csv").then(response=>{
|
||||
if(!response.ok){throw new Error(response.status)}
|
||||
return response.text()
|
||||
}).then(csv=>{
|
||||
let storeLayers={},store,url;
|
||||
}).then(csv=>{
|
||||
csv.split("\n").forEach(line=>{
|
||||
if(line.includes(",")){
|
||||
let [u,p,lat,lng,id]=line.split(",");
|
||||
[u,p]=[u,p].map(cents=>"$"+(cents/100).toFixed(2));
|
||||
L.marker([lat,lng],{icon:L.divIcon({className:store,html:`<a href="${url.replace("X",id)}">${u}\n${p}</a>`,iconSize:[44,44]})}).addTo(storeLayers[store])
|
||||
}else{
|
||||
[store,url]=line.split(" ");
|
||||
storeLayers[store]=L.layerGroup().addTo(map)
|
||||
}
|
||||
L.marker([lat,lng],{icon:L.divIcon({className:chainId,html:`<a href="${url.replace("X",id)}">${u}\n${p}</a>`,iconSize:[44,44]})}).addTo(chains[chain])
|
||||
})
|
||||
L.control.layers(null,storeLayers,{collapsed:false}).addTo(map)
|
||||
}).catch(error=>{
|
||||
L.control.layers({"fetch failed. you could try reloading, otherwise email me.":osm},null,{collapsed:false}).addTo(map);
|
||||
console.error(error)
|
||||
})
|
||||
layerControl.removeLayer(chains[chain]);
|
||||
layerControl.addOverlay(chains[chain],`${chain} (${chains[chain].getLayers().length} locations)`)
|
||||
}).catch(error=>{
|
||||
console.error(error);
|
||||
layerControl.removeLayer(chains[chain]);
|
||||
layerControl.addOverlay(L.layerGroup(),`${chain} request was blocked :(`)
|
||||
})
|
||||
}
|
||||
</script>
|
||||
</body>
|
||||
</html>
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue