mirror of
https://github.com/catdevnull/preciazo.git
synced 2024-11-26 11:36:20 +00:00
Compare commits
1 commit
5c450597d1
...
da5a0b9841
Author | SHA1 | Date | |
---|---|---|---|
|
da5a0b9841 |
4 changed files with 10 additions and 58 deletions
|
@ -23,7 +23,7 @@ COPY --from=build /usr/src/app/sitio/package.json package.real.json
|
||||||
RUN sh -c 'echo {\"name\":\"sitio\",\"type\":\"module\",\"dependencies\":$(jq .dependencies < package.real.json)} > package.json' && npm install
|
RUN sh -c 'echo {\"name\":\"sitio\",\"type\":\"module\",\"dependencies\":$(jq .dependencies < package.real.json)} > package.json' && npm install
|
||||||
COPY --from=build /usr/src/app/db-datos node_modules/db-datos
|
COPY --from=build /usr/src/app/db-datos node_modules/db-datos
|
||||||
COPY --from=build /usr/src/app/sitio/build .
|
COPY --from=build /usr/src/app/sitio/build .
|
||||||
COPY --from=build /usr/src/app/db-datos/drizzle drizzle
|
COPY --from=build /usr/src/app/db-datos/drizzle .
|
||||||
|
|
||||||
ENV DB_PATH=/db/db.db
|
ENV DB_PATH=/db/db.db
|
||||||
EXPOSE 3000
|
EXPOSE 3000
|
||||||
|
|
|
@ -16,9 +16,6 @@ export const hosts: { [host: string]: Supermercado } = {
|
||||||
"www.cotodigital3.com.ar": Supermercado.Coto,
|
"www.cotodigital3.com.ar": Supermercado.Coto,
|
||||||
"www.jumbo.com.ar": Supermercado.Jumbo,
|
"www.jumbo.com.ar": Supermercado.Jumbo,
|
||||||
};
|
};
|
||||||
export const hostBySupermercado = Object.fromEntries(
|
|
||||||
Object.entries(hosts).map(([a, b]) => [b, a])
|
|
||||||
) as Record<Supermercado, string>;
|
|
||||||
export const colorBySupermercado: { [supermercado in Supermercado]: string } = {
|
export const colorBySupermercado: { [supermercado in Supermercado]: string } = {
|
||||||
[Supermercado.Dia]: "#d52b1e",
|
[Supermercado.Dia]: "#d52b1e",
|
||||||
[Supermercado.Carrefour]: "#19549d",
|
[Supermercado.Carrefour]: "#19549d",
|
||||||
|
|
|
@ -1,43 +1,12 @@
|
||||||
import type { PageData, PageServerLoad } from "./$types";
|
import type { PageData, PageServerLoad } from "./$types";
|
||||||
import { getDb, schema } from "$lib/server/db";
|
import { getDb, schema } from "$lib/server/db";
|
||||||
const { precios } = schema;
|
const { precios } = schema;
|
||||||
import { desc, sql } from "drizzle-orm";
|
import { sql } from "drizzle-orm";
|
||||||
import {
|
|
||||||
Supermercado,
|
|
||||||
hostBySupermercado,
|
|
||||||
supermercados,
|
|
||||||
} from "db-datos/supermercado";
|
|
||||||
|
|
||||||
let cache: Promise<{ key: Date; data: { precios: Precios } }> = doQuery();
|
let cache: Promise<{ key: Date; data: { precios: Precios } }> = doQuery();
|
||||||
|
|
||||||
|
|
||||||
async function doQuery() {
|
async function doQuery() {
|
||||||
const db = await getDb();
|
const db = await getDb();
|
||||||
console.time("ean");
|
|
||||||
const eans = await db
|
|
||||||
.select({
|
|
||||||
ean: precios.ean,
|
|
||||||
})
|
|
||||||
.from(precios)
|
|
||||||
.groupBy(precios.ean)
|
|
||||||
.orderBy(sql`random()`)
|
|
||||||
.limit(50);
|
|
||||||
console.timeEnd("ean");
|
|
||||||
|
|
||||||
return;
|
|
||||||
|
|
||||||
const precioss = await Promise.all(
|
|
||||||
supermercados.map(
|
|
||||||
async (
|
|
||||||
supermercado,
|
|
||||||
): Promise<
|
|
||||||
[
|
|
||||||
Supermercado,
|
|
||||||
{ ean: string; name: string | null; imageUrl: string | null }[],
|
|
||||||
]
|
|
||||||
> => {
|
|
||||||
const host = hostBySupermercado[supermercado];
|
|
||||||
console.time(supermercado);
|
|
||||||
const q = db
|
const q = db
|
||||||
.select({
|
.select({
|
||||||
ean: precios.ean,
|
ean: precios.ean,
|
||||||
|
@ -46,18 +15,11 @@ async function doQuery() {
|
||||||
})
|
})
|
||||||
.from(precios)
|
.from(precios)
|
||||||
.groupBy(precios.ean)
|
.groupBy(precios.ean)
|
||||||
.having(sql`max(fetched_at)`)
|
.having(sql`max(length(name)) and max(parser_version) and in_stock`)
|
||||||
.where(
|
.orderBy(sql`random()`)
|
||||||
sql`ean in ${eans.map((x) => x.ean)} and in_stock and url like ${`%${host}%`}`,
|
.limit(150);
|
||||||
);
|
|
||||||
// console.debug(q.toSQL());
|
|
||||||
const res = await q;
|
const res = await q;
|
||||||
console.timeEnd(supermercado);
|
const data = { precios: res };
|
||||||
return [supermercado, res];
|
|
||||||
},
|
|
||||||
),
|
|
||||||
);
|
|
||||||
const data = { precios: precioss.flatMap(([_, r]) => r) };
|
|
||||||
return { key: new Date(), data };
|
return { key: new Date(), data };
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -7,13 +7,6 @@
|
||||||
(d): d is { ean: string; name: string; imageUrl: string | null } =>
|
(d): d is { ean: string; name: string; imageUrl: string | null } =>
|
||||||
!!d.name,
|
!!d.name,
|
||||||
);
|
);
|
||||||
$: productos = precios.reduce(
|
|
||||||
(prev, curr) => [
|
|
||||||
...prev,
|
|
||||||
...(prev.find((p) => p.ean === curr.ean) ? [] : [curr]),
|
|
||||||
],
|
|
||||||
[] as { ean: string; name: string; imageUrl: string | null }[],
|
|
||||||
);
|
|
||||||
</script>
|
</script>
|
||||||
|
|
||||||
<h1 class="text-xl">WIP</h1>
|
<h1 class="text-xl">WIP</h1>
|
||||||
|
@ -46,7 +39,7 @@
|
||||||
<section>
|
<section>
|
||||||
<h2 class="text-lg font-bold">Random</h2>
|
<h2 class="text-lg font-bold">Random</h2>
|
||||||
<ul class="grid grid-cols-1 gap-4 md:grid-cols-2 lg:grid-cols-3">
|
<ul class="grid grid-cols-1 gap-4 md:grid-cols-2 lg:grid-cols-3">
|
||||||
{#each productos as product}
|
{#each precios as product}
|
||||||
<li>
|
<li>
|
||||||
<ProductPreview {product} />
|
<ProductPreview {product} />
|
||||||
</li>
|
</li>
|
||||||
|
|
Loading…
Reference in a new issue