rewrite: elysia → hono

.dev.example.vars

@@ -0,0 +1,6 @@
+DATABASE_URL="postgresql://comuline:password@localhost:5432/comuline"
+COMULINE_ENV="development"
+
+# Take token from .env.db
+UPSTASH_REDIS_REST_TOKEN=""
+UPSTASH_REDIS_REST_URL="http://localhost:8079"

.env.db

@@ -1,3 +1,10 @@
+# PostgreSQL
 POSTGRES_USER="comuline"
 POSTGRES_PASSWORD="password"
-POSTGRES_DB="comuline"
+POSTGRES_DB="comuline"
+
+# Redis
+SRH_MODE=env
+# openssl rand -base64 32
+SRH_TOKEN="1Pf91ZNy5LDTKG621uhX/E73P8RmhVZu43kIV/WCmHg="
+SRH_CONNECTION_STRING=redis://redis:6379

.github/workflows/api.build.yml

@@ -0,0 +1,28 @@
+name: Build API on Pull Request
+
+on:
+  pull_request:
+    branches: ["main"]
+    types: [opened, reopened, synchronize]
+
+concurrency:
+  group: ${{ github.workflow }}-${{ github.event.pull_request.number || github.ref || github.run_id }}
+  cancel-in-progress: true
+
+jobs:
+  build-test:
+    runs-on: ubuntu-latest
+
+    steps:
+      - uses: actions/checkout@v4
+
+      - name: Install Bun
+        uses: oven-sh/setup-bun@v2
+        with:
+          bun-version: "latest"
+
+      - name: Install package deps
+        run: bun i
+
+      - name: Build package
+        run: bun run build

.github/workflows/api.deploy.yml

@@ -0,0 +1,28 @@
+name: Deploy API to Cloudflare Workers
+
+on:
+  push:
+    branches: ["main"]
+
+jobs:
+  deploy:
+    runs-on: ubuntu-latest
+
+    steps:
+      - uses: actions/checkout@v4
+
+      - name: Installing Bun
+        uses: oven-sh/setup-bun@v2
+
+      - name: Install package deps
+        run: bun i
+
+      - name: Build package
+        run: bun run build
+
+      - name: Deploy to Cloudflare Workers
+        uses: cloudflare/wrangler-action@v3
+        with:
+          apiToken: ${{ secrets.CLOUDFLARE_API_TOKEN }}
+          accountId: ${{ secrets.CLOUDFLARE_ACCOUNT_ID }}
+          command: deploy --minify src/index.ts

.gitignore

@@ -41,3 +41,9 @@ yarn-error.log*
 package-lock.json
 **/*.bun
 .env
+wrangler.toml
+.wrangler
+.dev.vars
+
+# build
+.dist

README.md

@@ -1,18 +1,18 @@
 # @comuline/api
 
-An API to get the schedule of KRL commuter line in Jakarta and Yogyakarta using [Elsyia](https://elysiajs.com/) and [Bun](https://bun.sh/), deployed to [Render](https://render.com/). This API is primarily used on the [web app](https://comuline.com/) ([source code](https://github.com/comuline/web)).
+An API to get the schedule of KRL commuter line in Jakarta and Yogyakarta using [Hono](https://hono.dev/) and [Bun](https://bun.sh/), deployed to [Cloudflare Workers](https://workers.cloudflare.com/). This API is primarily used on the [web app](https://comuline.com/) ([source code](https://github.com/comuline/web)).
 
 ### How does it work?
 
 This API uses a daily cron job (at 00:00) to fetch the schedule of KRL commuter line in Jakarta and Yogyakarta from the official website of PT. KAI. The data is then processed and stored in a PostgreSQL database and cached in a Redis (for every once read request). All endpoints can be found in the [docs](https://www.api.comuline.com/docs).
 
 ### Technology stacks
 
-1. [Elsyia](https://elysiajs.com/) API framework
+1. [Hono](https://hono.dev/) API framework
 2. [Bun](https://bun.sh/) runtime
-3. PostgresSQL ([Neon](https://neon.tech/))
-4. Redis ([Upstash](https://upstash.com/))
-5. [Render](https://render.com/) deployment platform
+3. (Serverless) PostgresSQL ([Neon](https://neon.tech/))
+4. (Serverless) Redis ([Upstash](https://upstash.com/))
+5. [Cloudflare Workers](https://workers.cloudflare.com/) deployment platform
 6. [Drizzle](https://orm.drizzle.team/) ORM
 
 ## Getting Started
@@ -31,113 +31,76 @@ git clone https://github.com/comuline/api.git
 bun install
 ```
 
-3. Run database locally
+3. Copy the `.dev.example.vars` to `.dev.vars`
 
-```bash
-docker-compose up -d
+```
+cp .dev.example.vars .dev.vars
 ```
 
-4. Copy the `.env.example` to `.env`
+4. Generate `UPSTASH_REDIS_REST_TOKEN` using `openssl rand -hex 32` and copy it to your `.dev.vars` file
 
-```
-cp .env.example .env
+5. Run database locally
+
+```bash
+docker-compose up -d
 ```
 
-5. Run the database migration
+6. Run the database migration
 
 ```bash
-bun db:generate && bun db:migrate
+bun run migrate:apply
 ```
 
-6. Sync the data and populate it into your local database (once only as you needed)
+7. Sync the data and populate it into your local database (once only as you needed)
 
 ```bash
 # Please do this in order
 # 1. Sync station data and wait until it's done
-curl --request POST --url http://localhost:3001/v1/station/
+bun run sync:station
 # 2. Sync schedule data
-curl --request POST --url http://localhost:3001/v1/schedule/
+bun run sync:schedule
 ```
 
 ### Deployment
 
-1. Create a new PostgreSQL database in [Neon](https://neon.tech/) and copy the connection string value as `DATABASE_URL` in your `.env` file
+1. Create a new PostgreSQL database in [Neon](https://neon.tech/) and copy the connection string value as `DATABASE_URL` in your `.production.vars` file
 
 2. Run the database migration
 
 ```bash
-bun db:generate && bun db:migrate
+bun run migrate:apply
 ```
 
 3. Sync the data and populate it into your remote database (once only as you needed)
 
 ```bash
 # Please do this in order
 # 1. Sync station data and wait until it's done
-curl --request POST --url http://localhost:3001/v1/station/
+bun run sync:station
 # 2. Sync schedule data
-curl --request POST --url http://localhost:3001/v1/schedule/
-
+bun run sync:schedule
 ```
 
-4. Generate `SYNC_TOKEN` (This is used in production level only to prevent unauthorized access to your `POST /v1/station` and `POST /v1/schedule` endpoint)
+4. Add `COMULINE_ENV` to your `.production.vars` file
 
-```bash
-openssl rand -base64 32
-# Copy the output value as a `SYNC_TOKEN`
+```
+COMULINE_ENV=production
 ```
 
-2. Create a new Redis database in [Upstash](https://upstash.com/) and copy the connection string value as `REDIS_URL`
+5. Create a new Redis database in [Upstash](https://upstash.com/) and copy the value of `UPSTASH_REDIS_REST_TOKEN` and `UPSTASH_REDIS_REST_URL` to your `.production.vars` file
 
-3. Create a `Web Service` in [Render](https://render.com/), copy the `DATABASE_URL`, `REDIS_URL`, and `SYNC_TOKEN` as environment variables, and deploy the application.
+6. Save your `.production.vars` file to your environment variables in your Cloudflare Workers using `wrangler`
+
+```bash
+bunx wrangler secret put --env production $(cat .production.vars)
+```
 
-4. Set the cron job to fetch the schedule data using [Cron-Job](https://cron-job.org/en/). Don't forget to set the `SYNC_TOKEN` as a header in your request. Add the `?from_cron=true` query parameter to flag the request as a cron job request.
+6. Deploy the API to Cloudflare Workers
 
 ```bash
-# Example
-curl --request POST --url https://your-service-name.onrender.com/v1/station?from_cron=true -H "Authorization: Bearer ${SYNC_TOKEN}"
-curl --request POST --url https://your-service-name.onrender.com/v1/schedule?from_cron=true -H "Authorization: Bearer ${SYNC_TOKEN}"
+bun run deploy
 ```
 
 ### Database schema
 
-> **Station**
-
-| Column Name  | Data Type | Description                     |
-| ------------ | --------- | ------------------------------- |
-| id           | TEXT      | Primary key (Station ID)        |
-| name         | TEXT      | Station name                    |
-| daop         | INTEGER   | Station regional operation code |
-| fgEnable     | BOOLEAN   | -                               |
-| haveSchedule | BOOLEAN   | Schedule availability status    |
-| updatedAt    | TEXT      | Last updated date               |
-
-> **Schedule**
-
-| Column Name     | Data Type | Description                         |
-| --------------- | --------- | ----------------------------------- |
-| id              | TEXT      | Primary key (Station ID + Train ID) |
-| stationId       | TEXT      | Station ID                          |
-| trainId         | TEXT      | Train ID                            |
-| line            | TEXT      | Train commuter line                 |
-| route           | TEXT      | Train route                         |
-| color           | TEXT      | Commuter line color                 |
-| destination     | TEXT      | Train destination                   |
-| timeEstimated   | TIME      | Estimated time                      |
-| destinationTime | TIME      | Destination time                    |
-| updatedAt       | TEXT      | Last updated date                   |
-
-> **Sync**
-
-| Column Name | Data Type | Description                            |
-| ----------- | --------- | -------------------------------------- |
-| id          | TEXT      | Primary key (Sync ID)                  |
-| n           | BIGINT    | n of sync                              |
-| type        | ENUM      | Sync type (manual, cron)               |
-| status      | ENUM      | Sync status (PENDING, SUCCESS, FAILED) |
-| item        | ENUM      | Sync item (station, schedule)          |
-| duration    | BIGINT    | Sync duration                          |
-| message     | TEXT      | Sync message (if status failed)        |
-| startedAt   | TEXT      | Sync started date                      |
-| endedAt     | TEXT      | Sync ended date                        |
-| createdAt   | TEXT      | Sync created date                      |
+> TBD

docker-compose.yml

@@ -1,21 +1,34 @@
 version: "3.9"
 
 services:
+  # Serverless PostgresSQL
   postgres:
     image: "postgres:15.2-alpine"
-    restart: always
-    container_name: "comuline-db"
     ports:
       - "5432:5432"
-    volumes:
-      - db:/var/lib/postgresql/data
     env_file:
       - ./.env.db
+  pg_proxy:
+    image: ghcr.io/neondatabase/wsproxy:latest
+    environment:
+      APPEND_PORT: "postgres:5432"
+      ALLOW_ADDR_REGEX: ".*"
+      LOG_TRAFFIC: "true"
+    ports:
+      - "5433:80"
+    depends_on:
+      - postgres
+
+  # Serverless Redis
   redis:
     image: redis
-    container_name: "comuline-cache"
     ports:
       - "6379:6379"
-
-volumes:
-  db:
+  serverless-redis-http:
+    ports:
+      - "8079:80"
+    image: hiett/serverless-redis-http:latest
+    env_file:
+      - ./.env.db
+    depends_on:
+      - redis

drizzle.config.ts

@@ -1,10 +1,7 @@
 import type { Config } from "drizzle-kit"
 
 export default {
+  out: "./drizzle/migrations",
+  dialect: "postgresql",
   schema: "./src/db/schema",
-  out: "./src/db/migrations",
-  driver: "pg",
-  dbCredentials: {
-    connectionString: process.env.DATABASE_URL!,
-  },
 } satisfies Config

drizzle/migrations/0000_talented_daimon_hellstrom.sql

@@ -0,0 +1,57 @@
+DO $$ BEGIN
+ CREATE TYPE "public"."station_type" AS ENUM('KRL', 'MRT', 'LRT');
+EXCEPTION
+ WHEN duplicate_object THEN null;
+END $$;
+--> statement-breakpoint
+CREATE TABLE IF NOT EXISTS "schedule" (
+	"id" text PRIMARY KEY NOT NULL,
+	"station_id" text NOT NULL,
+	"station_origin_id" text,
+	"station_destination_id" text,
+	"train_id" text NOT NULL,
+	"line" text NOT NULL,
+	"route" text NOT NULL,
+	"time_departure" time NOT NULL,
+	"time_at_destination" time NOT NULL,
+	"metadata" jsonb,
+	"created_at" timestamp with time zone DEFAULT now(),
+	"updated_at" timestamp with time zone DEFAULT now(),
+	CONSTRAINT "schedule_id_unique" UNIQUE("id")
+);
+--> statement-breakpoint
+CREATE TABLE IF NOT EXISTS "station" (
+	"uid" text PRIMARY KEY NOT NULL,
+	"id" text NOT NULL,
+	"name" text NOT NULL,
+	"type" "station_type" NOT NULL,
+	"metadata" jsonb,
+	"created_at" timestamp with time zone DEFAULT now(),
+	"updated_at" timestamp with time zone DEFAULT now(),
+	CONSTRAINT "station_uid_unique" UNIQUE("uid"),
+	CONSTRAINT "station_id_unique" UNIQUE("id")
+);
+--> statement-breakpoint
+DO $$ BEGIN
+ ALTER TABLE "schedule" ADD CONSTRAINT "schedule_station_id_station_id_fk" FOREIGN KEY ("station_id") REFERENCES "public"."station"("id") ON DELETE no action ON UPDATE no action;
+EXCEPTION
+ WHEN duplicate_object THEN null;
+END $$;
+--> statement-breakpoint
+DO $$ BEGIN
+ ALTER TABLE "schedule" ADD CONSTRAINT "schedule_station_origin_id_station_id_fk" FOREIGN KEY ("station_origin_id") REFERENCES "public"."station"("id") ON DELETE no action ON UPDATE no action;
+EXCEPTION
+ WHEN duplicate_object THEN null;
+END $$;
+--> statement-breakpoint
+DO $$ BEGIN
+ ALTER TABLE "schedule" ADD CONSTRAINT "schedule_station_destination_id_station_id_fk" FOREIGN KEY ("station_destination_id") REFERENCES "public"."station"("id") ON DELETE no action ON UPDATE no action;
+EXCEPTION
+ WHEN duplicate_object THEN null;
+END $$;
+--> statement-breakpoint
+CREATE UNIQUE INDEX IF NOT EXISTS "schedule_idx" ON "schedule" USING btree ("id");--> statement-breakpoint
+CREATE INDEX IF NOT EXISTS "schedule_station_idx" ON "schedule" USING btree ("station_id");--> statement-breakpoint
+CREATE UNIQUE INDEX IF NOT EXISTS "station_uidx" ON "station" USING btree ("uid");--> statement-breakpoint
+CREATE INDEX IF NOT EXISTS "station_idx" ON "station" USING btree ("id");--> statement-breakpoint
+CREATE INDEX IF NOT EXISTS "station_type_idx" ON "station" USING btree ("type");