v0.0.1-beta.4

Author: asg017

VERSION

@@ -1 +1 @@
-v0.0.1-beta.3
+v0.0.1-beta.4

ex.sql

@@ -0,0 +1,48 @@
+.load dist/http0
+.mode box
+.timer on
+.bail on
+
+create table if not exists snapshots as
+  select * from http_get() limit 0;
+
+insert into snapshots
+  select *
+  from http_get('http://www.ridembl.com:8080/MBLBusTracker/BusTracker/getRouteDetailByRouteID?RouteId=10');
+
+
+create table vehicle_readings as
+  select 
+    snapshots.rowid as snapshot,
+    snapshots.timings ->> '$.body_end' as response_time,
+    vehicles.value ->> '$.BlockFareboxId'              as block_farebox_id,
+    vehicles.value ->> '$.CommStatus'                  as comm_status,
+    vehicles.value ->> '$.Destination'                 as destination,
+    vehicles.value ->> '$.Deviation'                   as deviation,
+    vehicles.value ->> '$.Direction'                   as direction,
+    vehicles.value ->> '$.DirectionLong'               as direction_long,
+    vehicles.value ->> '$.DisplayStatus'               as display_status,
+    vehicles.value ->> '$.StopId'                      as stop_id,
+    vehicles.value ->> '$.CurrentStatus'               as current_status,
+    vehicles.value ->> '$.DriverName'                  as driver_name,
+    vehicles.value ->> '$.GPSStatus'                   as gps_status,
+    vehicles.value ->> '$.Heading'                     as heading,
+    vehicles.value ->> '$.LastStop'                    as last_stop,
+    vehicles.value ->> '$.LastUpdated'                 as last_updated,
+    vehicles.value ->> '$.Latitude'                    as latitude,
+    vehicles.value ->> '$.Longitude'                   as longitude,
+    vehicles.value ->> '$.Name'                        as name,
+    vehicles.value ->> '$.OccupancyStatus'             as occupancy_status,
+    vehicles.value ->> '$.OnBoard'                     as on_board,
+    vehicles.value ->> '$.OpStatus'                    as op_status,
+    vehicles.value ->> '$.RouteId'                     as route_id,
+    vehicles.value ->> '$.RunId'                       as run_id,
+    vehicles.value ->> '$.Speed'                       as speed,
+    vehicles.value ->> '$.TripId'                      as trip_id,
+    vehicles.value ->> '$.VehicleId'                   as vehicle_id,
+    vehicles.value ->> '$.SeatingCapacity'             as seating_capacity,
+    vehicles.value ->> '$.TotalCapacity'               as total_capacity,
+    vehicles.value ->> '$.PropertyName'                as property_name,
+    vehicles.value ->> '$.OccupancyStatusReportLabel'  as occupancy_status_report_label
+  from snapshots
+  join json_each(snapshots.response_body, '$.Vehicles') as vehicles

suncalc.sql

@@ -0,0 +1,70 @@
+.bail on
+.mode box
+.header on
+.load dist/http0
+
+create table cities as 
+  select
+      value ->> '$.city'       as name,
+      value ->> '$.latitude'   as latitude,
+      value ->> '$.longitude'  as longitude,
+      value ->> '$.population' as population,
+      value ->> '$.state'      as state
+  from json_each(
+    http_get_body('https://gist.githubusercontent.com/Miserlou/c5cd8364bf9b2420bb29/raw/2bf258763cdddd704f8ffd3ea9a3e81d25e2c6f6/cities.json')
+  );
+
+create table christmas_suntimes as 
+  with suntimes as (
+    select rowid as city,
+    http_post_body(
+      'http://localhost:3001/suncalc', 
+      null, 
+      json_object(
+        'longitude', longitude,
+        'latitude', latitude,
+        -- ho ho ho 
+        'date', '2022-12-25'
+      )
+    ) as suncalc_times
+    from cities
+  ),
+  final as (
+    select
+      cities.rowid as city,
+      suncalc_times ->> '$.nadir'          as nadir,
+      suncalc_times ->> '$.nightEnd'       as night_end,
+      suncalc_times ->> '$.nauticalDawn'   as nautical_dawn,
+      suncalc_times ->> '$.dawn'           as dawn,
+      suncalc_times ->> '$.sunrise'        as sunrise,
+      suncalc_times ->> '$.sunriseEnd'     as sunrise_end,
+      suncalc_times ->> '$.goldenHourEnd'  as golden_hour_end,
+      suncalc_times ->> '$.solarNoon'      as solar_noon,
+      suncalc_times ->> '$.goldenHour'     as golden_hour,
+      suncalc_times ->> '$.sunsetStart'    as sunset_start,
+      suncalc_times ->> '$.sunset'         as sunset,
+      suncalc_times ->> '$.dusk'           as dusk,
+      suncalc_times ->> '$.nauticalDusk'   as nautical_dusk,
+      suncalc_times ->> '$.night'          as night
+    from suntimes
+    left join cities on cities.rowid = suntimes.city
+  )
+  select * from final;
+
+select 
+  cities.name,
+  cities.state,
+  (unixepoch(sunset) - unixepoch(sunrise)) as daylight_seconds
+from christmas_suntimes
+left join cities on cities.rowid = christmas_suntimes.city
+order by 3 desc
+limit 10;
+
+select 
+  cities.name,
+  cities.state,
+  (unixepoch(sunset) - unixepoch(sunrise)) as daylight_seconds
+from christmas_suntimes
+left join cities on cities.rowid = christmas_suntimes.city
+order by 3 asc
+limit 10;

suncalc.ts

@@ -0,0 +1,28 @@
+import suncalc from "https://cdn.skypack.dev/suncalc";
+import { serve } from "https://deno.land/[email protected]/http/server.ts";
+
+const port = 3001;
+
+const suntimesRoute = new URLPattern({ pathname: "/suncalc" });
+
+interface SuntimePostParams {
+  latitude: number;
+  longitude: number;
+  date: string;
+}
+
+// user POSTs JSON object SuntimePostParams to "/suntimes", return suncalc.getTimes response
+async function handleSuntimes(request: Request): Promise<Response> {
+  const { latitude, longitude, date } =
+    (await request.json()) as SuntimePostParams;
+  const times = suncalc.getTimes(new Date(date), latitude, longitude);
+  return Promise.resolve(new Response(JSON.stringify(times), { status: 200 }));
+}
+
+await serve(
+  (request: Request): Promise<Response> => {
+    if (suntimesRoute.test(request.url)) return handleSuntimes(request);
+    return Promise.resolve(new Response("not found :(", { status: 404 }));
+  },
+  { port }
+);