Getting Started With Bun and MongoDB

1
git clone https://github.com/mongodb-developer/bun-with-mongodb
2
cd bun-with-mongodb
3
bun i
4
echo "MONGODB_URI=<your_atlas_connection_string>" > .env
5
bun run index.ts

1
bun init
2
bun add mongodb

1
const server = Bun.serve({
2
  async fetch(req) {
3
    const url = new URL(req.url);
4
    const method = req.method;
5
    if (url.pathname === "/") return new Response("Welcome to the movie database");
6
    return new Response("404!");
7
  },
8
});
9
console.log(`Listening on http://localhost:${server.port} ...`);

1
bun --watch run index.ts

1
curl localhost:3000

1
import { MongoClient } from "mongodb";
2
let MONGODB_URI = process.env.MONGODB_URI;
3
if (!MONGODB_URI) {
4
  throw new Error("Please define the MONGODB_URI environment variable inside .env");
5
}
6
7
const client: MongoClient = await MongoClient.connect(MONGODB_URI);
8
const moviesCollection = client.db("sample_mflix").collection("movies");
9
10
export {
11
  moviesCollection
12
}

1
MONGODB_URI=<your_atlas_connection_string>

1
import type { ObjectId } from "mongodb";
2
3
// Create a custom type for our movies
4
export interface Movie {
5
  _id?: ObjectId,
6
  title: string,
7
  actors: string[],
8
  year?: number,
9
}

1
// Import the Movies collection
2
import { moviesCollection } from '../utils/db.ts';
3
// Import the necessary types
4
import type { ObjectId } from "mongodb";
5
import type { Movie } from "../models/movies.ts";
6
7
class MovieController {
8
  /**
9
   * CRUD operations for the movies collection
10
   */
11
12
  // Add a movie
13
  public async addMovie(movie: Movie) {
14
    return await moviesCollection.insertOne(movie);
15
  }
16
17
  // Fetch the latest ten movies
18
  public async getMovies() {
19
    return await moviesCollection.find({}).sort({_id: -1}).limit(10).toArray();
20
  }
21
22
  // Fetch one movie
23
  public async getMovieById(_id: ObjectId) {
24
    return await moviesCollection.findOne({_id});
25
  }
26
27
  // Update the movies
28
  public async updateMovie(_id: ObjectId, movie: Movie) {
29
    return await moviesCollection.updateOne({ _id }, { $set: movie });
30
  }
31
32
  // Delete a single movie
33
  public async deleteMovie(movieId: ObjectId) {
34
    return await moviesCollection.deleteOne({ _id: movieId });
35
  }
36
}
37
38
export default MovieController;

1
// Import the Movies functions
2
import { ObjectId } from "mongodb";
3
import MovieController from "./controllers/movies.ts";
4
import type { Movie } from "./models/movies.ts";

1
const server = Bun.serve({
2
  async fetch(req) {
3
    const url = new URL(req.url);
4
    const method = req.method;
5
    if (url.pathname === "/") return new Response("Welcome to the movie database");
6
7
    // Routes for the API
8
    let moviesRoutes = new RegExp(/^\/movies\/?(.*)/)
9
    const movies = new MovieController();
10
11
    // POST /movies
12
    if (url.pathname.match(moviesRoutes) && method === "POST") {
13
      return new Response("Not implemented yet!");
14
    }
15
16
    // GET /movies and GET /movies/:id
17
    if (url.pathname.match(moviesRoutes) && method === "GET") {
18
      return new Response("Not implemented yet!");
19
    }
20
21
    // PUT /movies/:id
22
    if (url.pathname.match(moviesRoutes) && method === "PUT") {
23
      return new Response("Not implemented yet!");
24
    }
25
26
    // DELETE /movies/:id
27
28
    if (url.pathname.match(moviesRoutes) && method === "DELETE") {
29
      return new Response("Not implemented yet!");
30
    }
31
32
    return new Response("404!");
33
  },
34
});

1
curl localhost:3000/movies
2
curl localhost:3000/movies -X POST
3
curl localhost:3000/movies -X PUT
4
curl localhost:3000/movies -X DELETE
5
curl localhost:3000/movies -X PATCH # 404!

1
    // POST /movies
2
    if (url.pathname.match(moviesRoutes) && method === "POST") {
3
      const movie: Movie = await req.json();
4
      return Response.json(await movies.addMovie(movie));
5
    }

1
curl localhost:3000/movies -X POST --data '{"title": "New Movie"}'

1
    // GET /movies and GET /movies/:id
2
    if (url.pathname.match(moviesRoutes) && method === "GET") {
3
      const routeParams = url.pathname.split("/");
4
      if (routeParams[2]) {
5
        const movieId: ObjectId = new ObjectId(routeParams[2]);
6
        return Response.json(await movies.getMovieById(movieId));
7
      } else {
8
        return Response.json(await movies.getMovies());
9
      }
10
    }

1
curl localhost:3000/movies
2
curl localhost:3000/movies/668e855f76f86976e4045ae9

1
    // PUT /movies/:id
2
    if (url.pathname.match(moviesRoutes) && method === "PUT") {
3
      const movieId: ObjectId = new ObjectId(url.pathname.split("/")[2]);
4
      const movie: Movie = await req.json();
5
      return Response.json(await movies.updateMovie(movieId, movie));
6
    }

1
    // DELETE /movies/:id
2
    if (url.pathname.match(moviesRoutes) && method === "DELETE") {
3
      const movieId: ObjectId = new ObjectId(url.pathname.split("/")[2]);
4
      return Response.json(await movies.deleteMovie(movieId));
5
    }