Fix tb (#646)

* 🐛 fix tb

* 🐛 fix tb

* fix(tb): add url params to pipes

---------

Co-authored-by: mxkaske <[e-mail]>

apps/web/src/app/app/[workspaceSlug]/(dashboard)/monitors/[id]/_components/date-picker-preset.tsx

···
 
   function onSelect(value: Period) {
     const searchParams = updateSearchParams({ period: value });
-    router.replace(`${pathname}?${searchParams}`);
+    router.replace(`${pathname}?${searchParams}`, { scroll: false });
   }
 
   return (

apps/web/src/app/app/[workspaceSlug]/(dashboard)/monitors/[id]/_components/interval-preset.tsx

···
 
   function onSelect(value: Interval) {
     const searchParams = updateSearchParams({ interval: value });
-    router.replace(`${pathname}?${searchParams}`);
+    router.replace(`${pathname}?${searchParams}`, { scroll: false });
   }
 
   return (

apps/web/src/app/app/[workspaceSlug]/(dashboard)/monitors/[id]/_components/quantile-preset.tsx

···
 
   function onSelect(value: Quantile) {
     const searchParams = updateSearchParams({ quantile: value });
-    router.replace(`${pathname}?${searchParams}`);
+    router.replace(`${pathname}?${searchParams}`, { scroll: false });
   }
 
   return (

apps/web/src/app/app/[workspaceSlug]/(dashboard)/monitors/[id]/_components/region-preset.tsx

···
   function onOpenChange(open: boolean) {
     if (!open) {
       const searchParams = updateSearchParams({ regions: selected.join(",") });
-      router.replace(`${pathname}?${searchParams}`);
+      router.replace(`${pathname}?${searchParams}`, { scroll: false });
     }
   }
 

apps/web/src/app/app/[workspaceSlug]/(dashboard)/monitors/[id]/data/page.tsx

···
 
   const data = await getResponseListData({
     monitorId: id,
+    url: monitor.url,
     fromDate: date.from.getTime(),
     toDate: date.to.getTime(),
   });

apps/web/src/app/app/[workspaceSlug]/(dashboard)/monitors/[id]/overview/page.tsx

···
 
   const data = await getResponseGraphData({
     monitorId: id,
+    url: monitor.url,
     ...search.data,
     /**
      *
···
 
   const metrics = await getResponseTimeMetricsData({
     monitorId: id,
+    url: monitor.url,
     interval: periodicityHours,
   });
 
   const metricsByRegion = await getResponseTimeMetricsByRegionData({
     monitorId: id,
+    url: monitor.url,
     interval: periodicityHours,
   });
 

apps/web/src/app/monitor/[id]/page.tsx

···
 import { columns } from "@/components/data-table/columns";
 import { DataTable } from "@/components/data-table/data-table";
 import { getResponseListData } from "@/lib/tb";
+import { api } from "@/trpc/server";
 
 //
 
···
   searchParams: { [key: string]: string | string[] | undefined };
 }) {
   const search = searchParamsSchema.safeParse(searchParams);
+  const monitor = await api.monitor.getMonitorById.query({
+    id: Number(params.id),
+  });
   const data = search.success
     ? // TODO: lets hard-code our `monitorId` here
-      await getResponseListData({ monitorId: params.id, ...search.data })
-    : await getResponseListData({ monitorId: params.id });
+      await getResponseListData({
+        monitorId: params.id,
+        url: monitor.url,
+        ...search.data,
+      })
+    : await getResponseListData({ monitorId: params.id, url: monitor.url });
   if (!data || !search.success) return <div>Something went wrong</div>;
   return <DataTable columns={columns} data={data} />;
 }

apps/web/src/components/status-page/monitor.tsx

···
   const data = await getMonitorListData({
     monitorId: String(monitor.id),
     timezone: gmt,
+    url: monitor.url,
   });
 
   // TODO: we could handle the `statusReports` here instead of passing it down to the tracker

apps/web/src/components/status-page/status-check.tsx

···
       monitors.map((monitor) => {
         return getResponseListData({
           monitorId: String(monitor.id),
+          url: monitor.url,
           limit: 10,
         });
       }),

apps/web/src/lib/tb.ts

···
   props: Pick<MonitorListParams, "timezone">,
 ) {
   try {
-    const res = await getHomeMonitorList(tb)({ monitorId: "1", ...props });
+    const res = await getHomeMonitorList(tb)({
+      monitorId: "1",
+      ...props,
+      url: "https://www.openstatus.dev",
+    });
     return res.data;
   } catch (e) {
     console.error(e);

packages/tinybird/pipes/public_status.pipe

···
     FROM ping_response_v5
     WHERE
         monitorId = {{ String(monitorId, '1') }}
+        {% if defined(url) %} AND url = {{ String(url) }} {% end %}
         AND cronTimestamp
         >= toUnixTimestamp64Milli(toDateTime64(now() - INTERVAL 3 HOUR, 3))
     GROUP BY cronTimestamp, monitorId

packages/tinybird/pipes/response_details.pipe

···
     FROM ping_response__v7
     WHERE
         monitorId = {{ String(monitorId, '1') }}
+        {% if defined(url) %} AND url = {{ String(url) }} {% end %}
         AND cronTimestamp = {{ Int64(cronTimestamp, 1706467215188) }}
         AND region = {{ String(region, 'ams') }}
 

packages/tinybird/pipes/response_graph.pipe

···
     FROM ping_response__v7
     WHERE
         monitorId = {{ String(monitorId, '1') }}
+        {% if defined(url) %} AND url = {{ String(url) }} {% end %}
         {% if defined(fromDate) %} AND timestamp >= {{ Int64(fromDate) }} {% end %}
         {% if defined(toDate) %} AND timestamp <= {{ Int64(toDate) }} {% end %}
     GROUP BY h, region

packages/tinybird/pipes/response_list.pipe

···
     SELECT latency, monitorId, region, statusCode, timestamp, url, workspaceId, cronTimestamp, message
     FROM ping_response__v7
     WHERE monitorId = {{ String(monitorId, 'openstatusPing') }}
+    {% if defined(url) %} AND url = {{ String(url) }} {% end %}
     {% if defined(region) %}
     AND region = {{ String(region) }}
     {% end %}

packages/tinybird/pipes/response_time_metrics.pipe

···
             FROM materialized_view_ping_response_45d_ttl__v7
             WHERE
                 monitorId = {{ String(monitorId, '1') }}
+                {% if defined(url) %} AND url = {{ String(url) }} {% end %}
                 AND timestamp
                 >= toUnixTimestamp64Milli(toDateTime64(now() - INTERVAL {{ Int32(interval, 24)}} HOUR, 3))
         ) as lastTimestamp,
···
     FROM materialized_view_ping_response_45d_ttl__v7
     WHERE
         monitorId = {{ String(monitorId, '1') }}
+        {% if defined(url) %} AND url = {{ String(url) }} {% end %}
         AND timestamp
         >= toUnixTimestamp64Milli(toDateTime64(now() - INTERVAL {{ Int32(interval, 24)}} HOUR, 3))
     UNION ALL
···
     FROM materialized_view_ping_response_45d_ttl__v7
     WHERE
         monitorId = {{ String(monitorId, '1') }}
+        {% if defined(url) %} AND url = {{ String(url) }} {% end %}
         AND timestamp
         >= toUnixTimestamp64Milli(toDateTime64(now() - INTERVAL {{ Int32(interval, 24)}}*2 HOUR, 3))
         AND timestamp

packages/tinybird/pipes/response_time_metrics_by_region.pipe

···
     FROM materialized_view_ping_response_45d_ttl__v7
     WHERE
         monitorId = {{ String(monitorId, '1') }}
+        {% if defined(url) %} AND url = {{ String(url) }} {% end %}
         AND timestamp
         >= toUnixTimestamp64Milli(toDateTime64(now() - INTERVAL {{ Int32(interval, 24) }} HOUR, 3))
     GROUP BY region

packages/tinybird/pipes/status_timezone.pipe

···
         statusCode,
         latency
     FROM ping_response__v7
+    {% if defined(url) %} AND url = {{ String(url) }} {% end %}
     WHERE monitorId = {{ String(monitorId, '1') }}
         -- by default, we only query the last 45 days
         AND cronTimestamp >= toUnixTimestamp64Milli(

packages/tinybird/src/validation.ts

···
  */
 export const tbParameterResponseList = z.object({
   monitorId: z.string().default(""), // REMINDER: remove default once alpha
+  url: z.string().url().optional(),
   fromDate: z.number().int().default(0), // always start from a date
   toDate: z.number().int().optional(),
   limit: z.number().int().optional().default(7500), // one day has 2448 pings (17 (regions) * 6 (per hour) * 24) * 3 days for historical data
···
  */
 export const tbParameterResponseDetails = tbParameterResponseList.pick({
   monitorId: true,
+  url: true,
   cronTimestamp: true,
   region: true,
 });
···
  */
 export const tbParameterResponseGraph = z.object({
   monitorId: z.string().default(""),
+  url: z.string().url().optional(),
   interval: z.number().int().default(10),
   fromDate: z.number().int().default(0),
   toDate: z.number().int().optional(),
···
  */
 export const tbParameterMonitorList = z.object({
   monitorId: z.string(),
+  url: z.string().url().optional(),
   timezone: z.string().optional(),
   limit: z.number().int().default(46).optional(), // 46 days
 });
···
  */
 export const tbParameterPublicStatus = z.object({
   monitorId: z.string(),
+  url: z.string().url().optional(),
   limit: z.number().int().default(5).optional(), // 5 last cronTimestamps
 });
 
···
  */
 export const tbParameterResponseTimeMetrics = z.object({
   monitorId: z.string(),
+  url: z.string().url().optional(),
   interval: z.number().int().default(24), // 24 hours
 });
 
···
  */
 export const tbParameterResponseTimeMetricsByRegion = z.object({
   monitorId: z.string(),
+  url: z.string().url().optional(),
   interval: z.number().int().default(24), // 24 hours
 });