Koa.js - APIs RESTful

Para criar aplicativos móveis, aplicativos de página única, usar chamadas AJAX e fornecer dados aos clientes, você precisará de uma API. Um estilo de arquitetura popular de como estruturar e nomear essas APIs e os terminais é chamadoREST(Representational Transfer State). HTTP 1.1 foi projetado mantendo os princípios REST em mente. REST foi introduzido porRoy Fielding em 2000 em seu artigo Fielding Dissertations.

URIs e métodos RESTful nos fornecem quase todas as informações de que precisamos para processar uma solicitação. A tabela a seguir resume como os vários verbos devem ser usados ​​e como os URIs devem ser nomeados. Estaremos criando uma API de filmes no final, então vamos discutir como ela será estruturada.

Método URI Detalhes Função
PEGUE /filmes Seguro, encaixável Obtém a lista de todos os filmes e seus detalhes
PEGUE / movies / 1234 Seguro, encaixável Obtém os detalhes da identificação do filme 1234
POSTAR /filmes N / D Cria um novo filme com os detalhes fornecidos. A resposta contém o URI para este recurso recém-criado.
COLOCAR / movies / 1234 Idempotente Modifica o ID do filme 1234 (cria um se ainda não existir). A resposta contém o URI para este recurso recém-criado.
EXCLUIR / movies / 1234 Idempotente A identificação do filme 1234 deve ser excluída, se existir. A resposta deve conter o status da solicitação.
DELETE ou PUT /filmes Inválido Deve ser inválido. DELETE e PUT devem especificar em qual recurso estão trabalhando.

Agora vamos criar essa API no Koa. Usaremos JSON como nosso formato de transporte de dados, pois é fácil de trabalhar em JavaScript e tem muitos outros benefícios. Substitua seu arquivo index.js pelo seguinte -

INDEX.JS

var koa = require('koa');
var router = require('koa-router');
var bodyParser = require('koa-body');

var app = koa();

//Set up body parsing middleware
app.use(bodyParser({
   formidable:{uploadDir: './uploads'},
   multipart: true,
   urlencoded: true
}));

//Require the Router we defined in movies.js
var movies = require('./movies.js');

//Use the Router on the sub route /movies
app.use(movies.routes());

app.listen(3000);

Agora que nosso aplicativo está configurado, vamos nos concentrar na criação da API. Primeiro, configure o arquivo movies.js. Não estamos usando um banco de dados para armazenar os filmes, mas sim na memória, portanto, toda vez que o servidor reiniciar, os filmes adicionados por nós desaparecerão. Isso pode ser facilmente imitado usando um banco de dados ou um arquivo (usando o módulo node fs).

Importe o roteador koa, crie um roteador e exporte-o usando module.exports.

var Router = require('koa-router');
var router = Router({
  prefix: '/movies'
});  //Prefixed all routes with /movies

var movies = [
   {id: 101, name: "Fight Club", year: 1999, rating: 8.1},
   {id: 102, name: "Inception", year: 2010, rating: 8.7},
   {id: 103, name: "The Dark Knight", year: 2008, rating: 9},
   {id: 104, name: "12 Angry Men", year: 1957, rating: 8.9}
];

//Routes will go here

module.exports = router;

Rotas GET

Defina a rota GET para obter todos os filmes.

router.get('/', sendMovies);
function *sendMovies(next){
   this.body = movies;
   yield next;
}

É isso aí. Para testar se está funcionando bem, execute seu aplicativo, abra o terminal e digite -

curl -i -H "Accept: application/json" -H "Content-Type: application/json" -X GET localhost:3000/movies

Você obterá a seguinte resposta -

[{"id":101,"name":"Fight 
Club","year":1999,"rating":8.1},{"id":102,"name":"Inception","year":2010,"rating":8.7},
{"id":103,"name":"The Dark Knight","year":2008,"rating":9},{"id":104,"name":"12 Angry 
Men","year":1957,"rating":8.9}]

Temos uma rota para obter todos os filmes. Agora vamos criar uma rota para obter um filme específico por seu id.

router.get('/:id([0-9]{3,})', sendMovieWithId);

function *sendMovieWithId(next){
   var ctx = this;
   var currMovie = movies.filter(function(movie){
      if(movie.id == ctx.params.id){
         return true;
      }
   });
   if(currMovie.length == 1){
      this.body = currMovie[0];
   } else {
      this.response.status = 404;//Set status to 404 as movie was not found
      this.body = {message: "Not Found"};
   }
   yield next;
}

Isso nos dará os filmes de acordo com a id que fornecemos. Para testar isso, use o seguinte comando em seu terminal.

curl -i -H "Accept: application/json" -H "Content-Type: application/json" -X GET localhost:3000/movies/101

Você receberá a resposta como -

{"id":101,"name":"Fight Club","year":1999,"rating":8.1}

Se você visitar uma rota inválida, produzirá um erro não é possível GET, enquanto se você visitar uma rota válida com um id que não existe, produzirá um erro 404.

Terminamos com as rotas GET. Agora, vamos passar para a rota POST.

POST Route

Use a seguinte rota para lidar com os dados POSTADOS.

router.post('/', addNewMovie);

function *addNewMovie(next){
   //Check if all fields are provided and are valid:
   if(!this.request.body.name || 
      !this.request.body.year.toString().match(/^[0-9]{4}$/g) || 
      !this.request.body.rating.toString().match(/^[0-9]\.[0-9]$/g)){
      
      this.response.status = 400;
      this.body = {message: "Bad Request"};
   } else {
      var newId = movies[movies.length-1].id+1;
      
      movies.push({
         id: newId,
         name: this.request.body.name,
         year: this.request.body.year,
         rating: this.request.body.rating
      });
      this.body = {message: "New movie created.", location: "/movies/" + newId};
   }
   yield next;
}

Isso criará um novo filme e o armazenará na variável movies. Para testar esta rota, digite o seguinte em seu terminal -

curl -X POST --data "name = Toy%20story&year = 1995&rating = 8.5" 
https://localhost:3000/movies

Você obterá a seguinte resposta -

{"message":"New movie created.","location":"/movies/105"}

Para testar se isso foi adicionado ao objeto movies, execute a solicitação get para / movies / 105 novamente. Você obterá a seguinte resposta -

{"id":105,"name":"Toy story","year":"1995","rating":"8.5"}

Vamos prosseguir para criar as rotas PUT e DELETE.

PUT Rota

A rota PUT é quase exatamente igual à rota POST. Estaremos especificando o id do objeto que será atualizado / criado. Crie a rota da seguinte maneira -

router.put('/:id', updateMovieWithId);

function *updateMovieWithId(next){
   //Check if all fields are provided and are valid:
   if(!this.request.body.name || 
      !this.request.body.year.toString().match(/^[0-9]{4}$/g) || 
      !this.request.body.rating.toString().match(/^[0-9]\.[0-9]$/g) ||
      !this.params.id.toString().match(/^[0-9]{3,}$/g)){
      
      this.response.status = 400;
      this.body = {message: "Bad Request"};
   } else {
      //Gets us the index of movie with given id.
      var updateIndex = movies.map(function(movie){
         return movie.id;
      }).indexOf(parseInt(this.params.id));
      
      if(updateIndex === -1){
         //Movie not found, create new movies.push({
            id: this.params.id,
            name: this.request.body.name,
            year: this.request.body.year,
            rating: this.request.body.rating
         });
         this.body = {message: "New movie created.", location: "/movies/" + this.params.id};    
      } else {
         //Update existing movie
         movies[updateIndex] = {
            id: this.params.id,
            name: this.request.body.name,
            year: this.request.body.year,
            rating: this.request.body.rating
         };
         this.body = {message: "Movie id " + this.params.id + " updated.", location: "/movies/" + this.params.id};
      }
   }
}

Esta rota fará a função que especificamos na tabela acima. Ele atualizará o objeto com novos detalhes, se existir. Se não existir, ele criará um novo objeto. Para testar essa rota, use o seguinte comando curl. Isso irá atualizar um filme existente. Para criar um novo filme, basta alterar o id para um id não existente.

curl -X PUT --data "name = Toy%20story&year = 1995&rating = 8.5" 
https://localhost:3000/movies/101

Resposta

{"message":"Movie id 101 updated.","location":"/movies/101"}

DELETE rota

Use o seguinte código para criar uma rota de exclusão.

router.delete('/:id', deleteMovieWithId);

function *deleteMovieWithId(next){
   var removeIndex = movies.map(function(movie){
      return movie.id;
   }).indexOf(this.params.id); //Gets us the index of movie with given id.
   
   if(removeIndex === -1){
      this.body = {message: "Not found"};
   } else {
      movies.splice(removeIndex, 1);
      this.body = {message: "Movie id " + this.params.id + " removed."};
   }
}

Teste a rota da mesma forma que fizemos com as outras. Na exclusão bem-sucedida (por exemplo, id 105), você obterá -

{message: "Movie id 105 removed."}

Finalmente, nosso arquivo movies.js se parece com -

var Router = require('koa-router');
var router = Router({
   prefix: '/movies'
});  //Prefixed all routes with /movies
var movies = [
   {id: 101, name: "Fight Club", year: 1999, rating: 8.1},
   {id: 102, name: "Inception", year: 2010, rating: 8.7},
   {id: 103, name: "The Dark Knight", year: 2008, rating: 9},
   {id: 104, name: "12 Angry Men", year: 1957, rating: 8.9}
];

//Routes will go here
router.get('/', sendMovies);
router.get('/:id([0-9]{3,})', sendMovieWithId);
router.post('/', addNewMovie);
router.put('/:id', updateMovieWithId);
router.delete('/:id', deleteMovieWithId);

function *deleteMovieWithId(next){
   var removeIndex = movies.map(function(movie){
      return movie.id;
   }).indexOf(this.params.id); //Gets us the index of movie with given id.
   
   if(removeIndex === -1){
      this.body = {message: "Not found"};
   } else {
      movies.splice(removeIndex, 1);
      this.body = {message: "Movie id " + this.params.id + " removed."};
   }
}

function *updateMovieWithId(next) {
   //Check if all fields are provided and are valid:
   if(!this.request.body.name ||
      !this.request.body.year.toString().match(/^[0-9]{4}$/g) ||
      !this.request.body.rating.toString().match(/^[0-9]\.[0-9]$/g) ||
      !this.params.id.toString().match(/^[0-9]{3,}$/g)){
      
      this.response.status = 400;
      this.body = {message: "Bad Request"};
   } else {
      //Gets us the index of movie with given id.
      var updateIndex = movies.map(function(movie){
         return movie.id;
      }).indexOf(parseInt(this.params.id));
      
      if(updateIndex === -1){
         //Movie not found, create new
         movies.push({
            id: this.params.id,
            name: this.request.body.name,
            year: this.request.body.year,
            rating: this.request.body.rating
         });
         this.body = {message: "New movie created.", location: "/movies/" + this.params.id};
      } else {
         //Update existing movie
            movies[updateIndex] = {
            id: this.params.id,
            name: this.request.body.name,
            year: this.request.body.year,
            rating: this.request.body.rating
         };
         this.body = {message: "Movie id " + this.params.id + " updated.", 
            location: "/movies/" + this.params.id};
      }
   }
}

function *addNewMovie(next){
   //Check if all fields are provided and are valid:
   if(!this.request.body.name ||
      !this.request.body.year.toString().match(/^[0-9]{4}$/g) ||
      !this.request.body.rating.toString().match(/^[0-9]\.[0-9]$/g)){
      
      this.response.status = 400;
      this.body = {message: "Bad Request"};
   } else {
      var newId = movies[movies.length-1].id+1;
      
      movies.push({
         id: newId,
         name: this.request.body.name,
         year: this.request.body.year,
         rating: this.request.body.rating
      });
      this.body = {message: "New movie created.", location: "/movies/" + newId};
   }
   yield next;
}
function *sendMovies(next){
   this.body = movies;
   yield next;
}
function *sendMovieWithId(next){
   var ctx = this
   
   var currMovie = movies.filter(function(movie){
      if(movie.id == ctx.params.id){
         return true;
      }
   });
   if(currMovie.length == 1){
      this.body = currMovie[0];
   } else {
      this.response.status = 404;//Set status to 404 as movie was not found
      this.body = {message: "Not Found"};
   }
   yield next;
}
module.exports = router;

Isso conclui nossa API REST. Agora você pode criar aplicativos muito mais complexos usando este estilo de arquitetura simples e Koa.