Criando API com DENO e MongoBD

 - controllers -- Users - database - model - utils .env server.ts 

 import { Application } from "https://deno.land/x/abc@v1.0.0-rc2/mod.ts"; const app = new Application(); app .get("/allusers", (c) => { return "Hello!"; .start({ port: 4000 }); console.log(`server listening on http://localhost:4000`); 

import "https://deno.land/x/dotenv/load.ts"; import { init, MongoClient } from "https://deno.land/x/mongo@v0.6.0/mod.ts"; // @ts-ignore await init(); const dbName = Deno.env.get('DATABASE_NAME') || "deno"; const dbURI = Deno.env.get('DATABASE_HOST') || "mongodb://localhost:27017"; 

 class DataBase { public client: MongoClient; constructor( public dbName: string, public url: string ) { this.dbName = dbName; this.url = url; this.client = {} as MongoClient;; } connect() { const client = new MongoClient(); client.connectWithUri(this.url); this.client = client; } 

 get findDatabase() { return this.client.database(this.dbName) } } 

 const connectionDatabase = new DataBase(dbName, dbURI); connectionDatabase.connect() export default connectionDatabase; 

 export default interface User { _id: { $oid: string; }; name: string; middleName: string; profession: string; } 

 import { MiddlewareFunc } from "https://deno.land/x/abc@v1.0.0-rc2/mod.ts"; // Você já sabe como uma class funciona o/ export class ErrorHandler extends Error { status: number; constructor(msg: string, status: number) { super(msg); // Super é responsável por dizer que essa é uma classe pai no nível l da hierarquia  this.status = status; } } export const ErrorMiddleware: MiddlewareFunc = (next) => async (data) => { try { // Se deu bom usamos o next() pra passar a info  await next(data); } catch (err) { // Se deu ruim passamos no request só o que precisamos ver, mensagem e status code const error = err as ErrorHandler; data.response.status = error.status || 500; data.response.body = error.message; } }; 

 // esses imports são para tipagem dos métodos de contexto e de trafego de informação pelas rotas da lib ABC import { HandlerFunc, Context, } from "https://deno.land/x/abc@v1.0.0-rc2/mod.ts"; // Importamos a nossa connectionDatabase para abriemos conexão com o banco de dados import connectionDatabase from "../../database/connection.ts"; // Importamos o handler de erros que criamos para termos um padrão na saída deles import { ErrorHandler } from "../../utils/handleError.ts"; // Abriremos nossa conexão passando a nossa collection previamente criada const database = connectionDatabase.findDatabase; const user = database.collection("users"); export const createUser: HandlerFunc = async (data: Context) => { // Vamos adotar a boa prática de passar um try...catch try { // Nesse primeiro if verificamos se nós estamos passando no Headers o content-type como application/json, se não estiver ele dispara um erro if (data.request.headers.get("content-type") !== "application/json") { throw new ErrorHandler("Body invalido", 422); } // Para pegar o que passamos no corpo da aplicação, vamos escrever uma request usando await de tudo que temos no data.body (data é o parâmetro dessa nossa função) const body = await (data.body()); // Esse nosso if usamos o Object.keys() para verificar se foi passado objetos no corpo da requisição if (!Object.keys(body).length) { throw new ErrorHandler("O body não pode estar vazio!!", 400); } // Feito essas validações vou desestruturar o que preciso inserir no banco const { name, profession, middleName } = body; // Depois usamos o método insertOne({}) do MongoDB para persistir esses dados await user.insertOne({ name, middleName, profession, }); // Terminamos aqui com o return passando uma mensagem que deu bom e o statusCode 200 o/ return data.json('Usuário cadastrado com sucesso', 201); } catch (error) { // Se der ruim nosso ErrorHandler será encarregado de nos avisar  throw new ErrorHandler(error.message, error.status || 500); } }; 

 import { HandlerFunc, Context, } from "https://deno.land/x/abc@v1.0.0-rc2/mod.ts"; import connectionDatabase from "../../database/connection.ts"; import { ErrorHandler } from "../../utils/handleError.ts"; // Importamos a nossa tipagem de dados de usuário  import Users from '../../model/users.ts' const database = connectionDatabase.findDatabase; const user = database.collection("users"); export const getAllUsers: HandlerFunc = async (data: Context) => { try { // Verificamos se existe o user com o método find() do Mongo const existUser: Users[] = await user.find(); // Se existir retornamos com o map(), se não retornamos array vazio if (existUser) { const list = existUser.length ? existUser.map((item: any) => { const { _id: { $oid }, name, middleName, profession } = item; console.log('item :>> ', item); return { id: $oid, name, middleName, profession }; }) : []; return data.json(list, 200); } } catch (error) { throw new ErrorHandler(error.message, error.status || 500); } }; 

 import { HandlerFunc, Context, } from "https://deno.land/x/abc@v1.0.0-rc2/mod.ts"; import connectionDatabase from "../../database/connection.ts"; import { ErrorHandler } from "../../utils/handleError.ts"; const database = connectionDatabase.findDatabase; const user = database.collection("users"); export const getUser: HandlerFunc = async (data: Context) => { try { // Vamos capturar o que será passado como parâmetro e usando o as do typescript para tipar o valor como string const { id } = data.params as { id: string }; // Usaremos o findOne() do mongo pra trazer uma bolleana de existUser ou não o valor const existUser = await user.findOne({ _id: { "$oid": id } }); if (existUser) { // Existindo, vamos desestruturar o resultado e retornar no data.json() junto com o status code const { _id: { $oid }, name, middleName, profession } = existUser; return data.json({ id: $oid, name, middleName, profession }, 200); } // Caso não exista, receberemos a mensagem abaixo com o status 404 throw new ErrorHandler("Usuário não encontrado", 404); } catch (error) { throw new ErrorHandler(error.message, error.status || 500); } }; 

 import { HandlerFunc, Context, } from "https://deno.land/x/abc@v1.0.0-rc2/mod.ts"; import connectionDatabase from "../../database/connection.ts"; import { ErrorHandler } from "../../utils/handleError.ts"; const database = connectionDatabase.findDatabase; const user = database.collection("users"); export const updateUser: HandlerFunc = async (data: Context) => { try { const { id } = data.params as { id: string }; if (data.request.headers.get("content-type") !== "application/json") { throw new ErrorHandler("Invalid body", 422); } // Capturamos o valor do corpo da aplicação e tipamos os dados passando o sinal de ? para sinalizar que é um campo opcional const body = await (data.body()) as { name?: string; middleName?: string; profession?: string; }; if (!Object.keys(body).length) { throw new ErrorHandler("O body não pode estar vazio!", 400); } // Aqui vamos usar o findOne() novamente e verificar se existe const existUser = await user.findOne({ _id: { "$oid": id } }); if (existUser) { const { matchedCount } = await user.updateOne( { _id: { "$oid": id } }, { $set: body }, ); // Esse matchedCount que recebemos no resultado do findOne() é o responsável por nos dar a informação de se foi encontrado ou não no caso será 1 dado e finalizamos com return data.string() if (matchedCount) { return data.string("O usuário foi atualizado com sucesso!", 204); } // Caso não der certo mandaremos essa mensagem para a requisição  return data.string("Não foi possível atualizar esse usuário"); } throw new ErrorHandler("Usuário não encontrado", 404); } catch (error) { throw new ErrorHandler(error.message, error.status || 500); } }; 

 import { HandlerFunc, Context, } from "https://deno.land/x/abc@v1.0.0-rc2/mod.ts"; import connectionDatabase from "../../database/connection.ts"; import { ErrorHandler } from "../../utils/handleError.ts"; const database = connectionDatabase.findDatabase; const user = database.collection("users"); export const deleteUser: HandlerFunc = async (data: Context) => { try { const { id } = data.params as { id: string }; const existUser = await user.findOne({ _id: { "$oid": id } }); if (existUser) { // Usaremos o deleteOne() do banco para realizar a operação e ele vai retornar o valor de dado deletado, no caso 1 const deleteCount = await user.deleteOne({ _id: { "$oid": id } }); if (deleteCount) { // Após receber o valor 1 vamos responder a requisição com a mensagem abaixo return data.string("Usuário foi deletado!", 204); } throw new ErrorHandler("Não foi possivel excuir esse usuário", 400); } throw new ErrorHandler("Usuário não encontrado", 404); } catch (error) { throw new ErrorHandler(error.message, error.status || 500); } }; 

 export { getAllUsers } from './getAllUsers.ts'; export { createUser } from './createUser.ts'; export { getUser } from './getOneUser.ts'; export { updateUser } from './updateUser.ts'; export { deleteUser } from './deleteUser.ts'; 

 DATABASE_NAME=deno DATABASE_HOST=<_sua_url_do_mongo_>