mongodb example

Author: v1rtl

app.ts

@@ -1,5 +1,6 @@
 // deno-lint-ignore-file
 import { NextFunction, Router, Handler, Middleware, UseMethodParams } from 'https://esm.sh/@tinyhttp/router'
+export type { NextFunction, Router, Handler, Middleware, UseMethodParams }
 import { onErrorHandler, ErrorHandler } from './onError.ts'
 // import { setImmediate } from 'https://deno.land/std@0.88.0/node/timers.ts'
 import rg from 'https://esm.sh/regexparam'

egg.json

@@ -4,14 +4,9 @@
   "entry": "./app.ts",
   "description": "0-legacy, tiny & fast web framework as a replacement of Express",
   "homepage": "https://github.com/talentlessguy/tinyhttp-deno",
-  "version": "0.0.12",
-  "ignore": [
-    "./examples/**/*.ts"
-  ],
-  "files": [
-    "./**/*.ts",
-    "README.md"
-  ],
+  "version": "0.0.14",
+  "ignore": ["./examples/**/*.ts"],
+  "files": ["./**/*.ts", "README.md"],
   "checkFormat": false,
   "checkTests": false,
   "checkInstallation": false,

examples/basic/README.md

@@ -0,0 +1,9 @@
+# Basic example
+
+Basic tinyhttp example with simple routing and route pattern matching.
+
+## Run
+
+```sh
+deno run --allow-net server.ts
+```

examples/basic/server.ts

@@ -2,8 +2,23 @@ import { App } from '../../app.ts'
 
 const app = new App()
 
-app.get('/', (req, res) => {
-  res.send(`Hello on ${req.url} from Deno v${Deno.version.deno} and tinyhttp! 🦕`)
-})
+app
+  .get('/', (req, res) => {
+    const greeting = `Hello on ${req.url} from Deno v${Deno.version.deno} and tinyhttp! 🦕`
+    res.format({
+      html: () => `<h1>${greeting}</h1>`,
+      text: () => greeting
+    })
+  })
+  .get('/page/:page/', (req, res) => {
+    res.status = 200
+    res.send(`
+  <h1>Some cool page</h1>
+  <h2>URL</h2>
+  ${req.url}
+  <h2>Params</h2>
+  ${JSON.stringify(req.params, null, 2)}
+`)
+  })
 
-app.listen(3000, () => console.log(`Started on :3000`))
+app.listen(3000, () => console.log(`Listening on http://localhost:3000`))

examples/eta/README.md

@@ -0,0 +1,9 @@
+# EJS example
+
+Basic example of using tinyhttp and [Eta](https://github.com/eta-dev/eta).
+
+## Run
+
+```sh
+deno run --allow-read --allow-net server.ts
+```

examples/mongodb/README.md

@@ -0,0 +1,23 @@
+# tinyhttp MongoDB example
+
+A simple note app using [tinyhttp](https://github.com/talentlessguy/tinyhttp-deno) and [MongoDB](https://www.mongodb.com).
+
+## Setup
+
+1. Install MongoDB server.
+
+## Run
+
+```sh
+deno run --allow-env --allow-read --allow-net server.ts
+```
+
+## Endpoints
+
+- `GET /notes` - list notes with 2 properties which are title and desc.
+
+- `POST /notes` - create a post using the data from `title` and `desc` query
+
+- `DELETE /notes` - delete a note with specified ID
+
+- `PUT /notes` - update a note by ID

examples/mongodb/server.ts

@@ -1,63 +1,77 @@
-import { App } from '../../app.ts'
-// import { MongoClient, Bson } from 'https://deno.land/x/mongo@v0.21.0/mod.ts'
-// import * as dotenv from 'https://deno.land/x/dotenv/mod.ts'
+import { App, Handler } from '../../app.ts'
+import { Request } from '../../request.ts'
+import { MongoClient, Bson } from 'https://deno.land/x/mongo@v0.21.2/mod.ts'
+import * as dotenv from 'https://deno.land/x/tiny_env@1.0.0/mod.ts'
 
-// dotenv.config()
+dotenv.load()
 
-const app = new App()
+type Req = Request & {
+  bodyResult: any
+}
+
+const app = new App<any, Req>({
+  onError: (err, req) => {
+    console.log(err)
+    req.respond({ body: 'Error' })
+  }
+})
 const port = parseInt(Deno.env.get('PORT') || '') || 3000
 
 // connect to mongodb
-/* const client = new MongoClient()
+const client = new MongoClient()
 
 await client.connect(Deno.env.get('DB_URI') || '')
 
 const db = client.database('notes')
-const coll = db.collection('notes') */
-
-app.get(async (req, res) => {
-  const buf: Uint8Array = await Deno.readAll(req.body)
-
-  console.log(buf.toString())
+const coll = db.collection('notes')
 
-  res.send('bruh')
-})
-
-/* // get all notes
+// get all notes
 app.get('/notes', async (_, res, next) => {
   try {
     const r = await coll.find({}).toArray()
+
     res.send(r)
     next()
   } catch (err) {
     next(err)
   }
 })
 
+const bodyParser: Handler<Req> = async (req, res, next) => {
+  const buf = await Deno.readAll(req.body)
+
+  const dec = new TextDecoder()
+
+  const body = dec.decode(buf)
+
+  try {
+    const result = JSON.parse(body)
+    req.bodyResult = result
+  } catch (e) {
+    next(e)
+  }
+  next()
+}
+app.use(bodyParser)
+
 // add new note
 app.post('/notes', async (req, res, next) => {
   try {
+    const { title, desc } = req.bodyResult
+    const r = await coll.insertOne({ title, desc })
 
-
-    if (result?.value) {
-      const { title, desc } = result.value
-      const r = await coll.insertOne({ title, desc })
-      assertStrictEquals(1, r.insertedCount)
-      res.send(`Note with title of "${title}" has been added`)
-    } else {
-      next('No body provided')
-    }
+    res.send(`Note with title of "${title}" has been added`)
   } catch (err) {
     next(err)
   }
 })
- */
-/* // delete note
+
+// delete note
 app.delete('/notes', async (req, res, next) => {
   try {
-    const { id } = req.body
-    const r = await coll.deleteOne({ _id: new Bson.ObjectId(id) })
-    assertStrictEquals(1, r)
+    const { id } = req.bodyResult
+    await coll.deleteOne({ _id: new Bson.ObjectId(id) })
+
     res.send(`Note with id of ${id} has been deleted`)
   } catch (err) {
     next(err)
@@ -67,16 +81,12 @@ app.delete('/notes', async (req, res, next) => {
 // update existing note
 app.put('/notes', async (req, res, next) => {
   try {
-    const { title, desc, id } = req.body
-    await coll.findOneAndUpdate(
-      { _id: new mongodb.ObjectId(id) },
-      { $set: { title, desc } },
-      { returnOriginal: false, upsert: true }
-    )
+    const { title, desc, id } = req.bodyResult
+    await coll.updateOne({ _id: new Bson.ObjectId(id) }, { $set: { title, desc } })
     res.send(`Note with title of ${title} has been updated`)
   } catch (err) {
     next(err)
   }
 })
- */
+
 app.listen(port, () => console.log(`Started on http://localhost:${port}`))