feat: implement plans

Author: damilola-paystack

.env.sample

@@ -1,2 +1,3 @@
 DB_FILE_NAME=file:local.db
-PAYSTACK_SECRET_KEY=sk_domain_xxxx
+PAYSTACK_SECRET_KEY=sk_domain_xxxx
+PAYSTACK_BASE_URL="https://api.paystack.co"

.gitignore

@@ -26,3 +26,6 @@ lerna-debug.log*
 
 # misc
 .DS_Store
+
+# db
+local.db

package.json

@@ -9,10 +9,12 @@
   },
   "dependencies": {
     "@hono/node-server": "^1.19.5",
+    "@hono/zod-validator": "^0.7.3",
     "@libsql/client": "^0.15.15",
     "dotenv": "^17.2.3",
     "drizzle-orm": "^0.44.6",
-    "hono": "^4.9.9"
+    "hono": "^4.9.9",
+    "zod": "^4.1.11"
   },
   "devDependencies": {
     "@types/node": "^20.11.17",

pnpm-lock.yaml

@@ -0,0 +1,4 @@
+import 'dotenv/config';
+import { drizzle } from 'drizzle-orm/libsql';
+
+export const db = drizzle(process.env.DB_FILE_NAME!);

src/db.ts

@@ -0,0 +1,10 @@
+import { int, sqliteTable, text } from "drizzle-orm/sqlite-core";
+
+export const plansTable = sqliteTable("plans", {
+  id: int().primaryKey({ autoIncrement: true }),
+  name: text().notNull(),
+  amount: int().notNull().default(0),
+  interval: text().notNull(),
+  code: text().notNull().unique(),
+  description: text()
+});

src/db/schema/plans.ts

@@ -1,12 +1,19 @@
 import { serve } from '@hono/node-server'
 import { Hono } from 'hono'
+import plansRouter from './routes/plans.js'
+import { showRoutes } from 'hono/dev'
 
 const app = new Hono()
 
 app.get('/', (c) => {
-  return c.text('Hello Hono!')
+  return c.text('Server running fine')
 })
 
+app.route("/plan", plansRouter)
+
+// To list all routes
+showRoutes(app)
+
 serve({
   fetch: app.fetch,
   port: 3000

src/index.ts

@@ -0,0 +1,95 @@
+import 'dotenv/config';
+import { Hono } from "hono";
+import { db } from '../db.js';
+import { plansTable } from '../db/schema/plans.js';
+import { zValidator } from '@hono/zod-validator';
+import { PlanCreate, PlanUpdate } from '../schema/index.js';
+import { eq } from 'drizzle-orm';
+
+const plansRouter = new Hono()
+
+plansRouter.get("/", async (c) => {
+  const plans = await db.select().from(plansTable)
+
+  return c.json({
+    status: true,
+    data: plans,
+  }, 200)
+})
+
+plansRouter.post("/",
+  zValidator('json', PlanCreate),
+  async (c) => {
+    const validateReq = c.req.valid('json')
+    const api = await fetch(`${process.env.PAYSTACK_BASE_URL}/plan`, {
+      method: "POST",
+      headers: {
+        "Authorization": `Bearer ${process.env.PAYSTACK_SECRET_KEY}`,
+        'Content-Type': "application/json"
+      },
+      body: JSON.stringify(validateReq)
+    })
+
+    const data = await api.json()
+
+    if (!data["status"]) {
+      return c.json({
+        status: false,
+        data: {}
+      }, 500)
+    }
+
+    const plan = await db.insert(plansTable)
+      .values({
+        name: data["data"]["name"],
+        amount: data["data"]["amount"],
+        interval: data["data"]["interval"],
+        code: data["data"]["plan_code"],
+      })
+      .returning()
+
+    return c.json({
+      status: true,
+      data: plan[0]
+    }, 201)
+  })
+
+plansRouter.put("/:id",
+  zValidator('json', PlanUpdate),
+  async (c) => {
+    const validatedReq = c.req.valid('json')
+    const id = c.req.param('id')
+    const result = await db.select({ code: plansTable.code }).from(plansTable)
+    const { code } = result[0]
+
+    const api = await fetch(`${process.env.PAYSTACK_BASE_URL}/plan/${code}`, {
+      method: "PUT",
+      headers: {
+        "Authorization": `Bearer ${process.env.PAYSTACK_SECRET_KEY}`,
+        'Content-Type': "application/json"
+      },
+      body: JSON.stringify(validatedReq)
+    })
+
+    const data = await api.json()
+    console.log("Data: ", data)
+
+    if (!data["status"]) {
+      return c.json({
+        status: false,
+        data: {}
+      }, 500)
+    }
+
+    const plan = await db.update(plansTable)
+      .set({ ...validatedReq })
+      .where(eq(plansTable.id, parseInt(id)))
+      .returning();
+
+    return c.json({
+      status: true,
+      data: plan[0]
+    }, 200)
+  })
+
+export default plansRouter

src/routes/plans.ts

@@ -0,0 +1,15 @@
+import * as z from "zod";
+
+export const PlanCreate = z.object({
+  name: z.string(),
+  amount: z.number(),
+  interval: z.string(),
+  description: z.boolean().optional()
+});
+
+export const PlanUpdate = z.object({
+  name: z.string().optional(),
+  amount: z.number().optional(),
+  interval: z.string().optional(),
+  update_existing_subscriptions: z.boolean().optional()
+});