Crie uma API RESTful com o HapiJS e o MongoDB

1
npm init
2
3
npm install @hapi/hapi --save

1
const Hapi = require('@hapi/hapi');
2
3
const server = Hapi.server({
4
    port: 3000,
5
    host: 'localhost'
6
});
7
8
server.route({
9
    method: 'GET',
10
    path: '/',
11
    handler: (req, h) => {
12
13
        return 'Hello from HapiJS!';
14
    }
15
});
16
17
server.start();
18
console.log('Server running on %s', server.info.uri);

1
node index.js

1
const Hapi = require('@hapi/hapi');
2
3
const server = Hapi.server({
4
    port: 3000,
5
    host: 'localhost'
6
});
7
8
// Get all movies
9
server.route({
10
    method: 'GET',
11
    path: '/movies',
12
    handler: (req, h) => {
13
14
        return 'List all the movies';
15
    }
16
});
17
18
// Add a new movie to the database
19
server.route({
20
    method: 'POST',
21
    path: '/movies',
22
    handler: (req, h) => {
23
24
        return 'Add new movie';
25
    }
26
});
27
28
// Get a single movie
29
server.route({
30
    method: 'GET',
31
    path: '/movies/{id}',
32
    handler: (req, h) => {
33
34
        return 'Return a single movie';
35
    }
36
});
37
38
// Update the details of a movie
39
server.route({
40
    method: 'PUT',
41
    path: '/movies/{id}',
42
    handler: (req, h) => {
43
44
        return 'Update a single movie';
45
    }
46
});
47
48
// Delete a movie from the database
49
server.route({
50
    method: 'DELETE',
51
    path: '/movies/{id}',
52
    handler: (req, h) => {
53
54
        return 'Delete a single movie';
55
    }
56
});
57
58
// Search for a movie
59
server.route({
60
    method: 'GET',
61
    path: '/search',
62
    handler: (req, h) => {
63
64
        return 'Return search results for the specified term';
65
    }
66
});
67
68
server.start();
69
console.log('Server running on %s', server.info.uri);

1
npm install hapi-mongodb --save   

1
server.register({
2
    plugin: require('hapi-mongodb'),
3
    options: {
4
      uri: 'mongodb+srv://{YOUR-USERNAME}:{YOUR-PASSWORD}@main.zxsxp.mongodb.net/sample_mflix?retryWrites=true&w=majority',
5
      settings : {
6
        useUnifiedTopology: true
7
      },
8
      decorate: true
9
    }
10
});

1
const Hapi = require('@hapi/hapi');
2
3
const init = async () => {
4
5
    const server = Hapi.server({
6
        port: 3000,
7
        host: 'localhost'
8
    });
9
10
    await server.register({
11
        plugin: require('hapi-mongodb'),
12
        options: {
13
          url: 'mongodb+srv://{YOUR-USERNAME}:{YOUR-PASSWORD}@main.zxsxp.mongodb.net/sample_mflix?retryWrites=true&w=majority',
14
          settings: {
15
              useUnifiedTopology: true
16
          },
17
          decorate: true
18
        }
19
    });
20
21
    // Get all movies
22
    server.route({
23
        method: 'GET',
24
        path: '/movies',
25
        handler: (req, h) => {
26
27
            return 'List all the movies';
28
        }
29
    });
30
31
    // Add a new movie to the database
32
    server.route({
33
        method: 'POST',
34
        path: '/movies',
35
        handler: (req, h) => {
36
37
            return 'Add new movie';
38
        }
39
    });
40
41
    // Get a single movie
42
    server.route({
43
        method: 'GET',
44
        path: '/movies/{id}',
45
        handler: (req, h) => {
46
47
            return 'Return a single movie';
48
        }
49
    });
50
51
    // Update the details of a movie
52
    server.route({
53
        method: 'PUT',
54
        path: '/movies/{id}',
55
        handler: (req, h) => {
56
57
            return 'Update a single movie';
58
        }
59
    });
60
61
    // Delete a movie from the database
62
    server.route({
63
        method: 'DELETE',
64
        path: '/movies/{id}',
65
        handler: (req, h) => {
66
67
            return 'Delete a single movie';
68
        }
69
    });
70
71
    // Search for a movie
72
    server.route({
73
        method: 'GET',
74
        path: '/search',
75
        handler: (req, h) => {
76
77
            return 'Return search results for the specified term';
78
        }
79
    });
80
81
    await server.start();
82
    console.log('Server running on %s', server.info.uri);
83
}
84
85
init();  

1
// Get all movies
2
server.route({
3
    method: 'GET',
4
    path: '/movies',
5
    handler: async (req, h) => {
6
7
      const movie = await req.mongo.db.collection('movies').findOne({})
8
9
      return movie;
10
    }
11
});

1
// Get all movies
2
server.route({
3
    method: 'GET',
4
    path: '/movies',
5
    handler: async (req, h) => {
6
7
      const offset = Number(req.query.offset) || 0;
8
9
      const movies = await req.mongo.db.collection('movies').find({}).sort({metacritic:-1}).skip(offset).limit(20).toArray();
10
11
      return movies;
12
    }
13
});

1
// Get a single movie
2
server.route({
3
    method: 'GET',
4
    path: '/movies/{id}',
5
    handler: async (req, h) => {
6
        const id = req.params.id
7
        const ObjectID = req.mongo.ObjectID;
8
9
        const movie = await req.mongo.db.collection('movies').findOne({_id: new ObjectID(id)},{projection:{title:1,plot:1,cast:1,year:1, released:1}});
10
11
        return movie;
12
    }
13
});

1
// Add a new movie to the database
2
server.route({
3
    method: 'POST',
4
    path: '/movies',
5
    handler: async (req, h) => {
6
7
        const payload = req.payload
8
9
        const status = await req.mongo.db.collection('movies').insertOne(payload);
10
11
        return status;
12
    }
13
});
14
15
The payload that we are going to submit to this endpoint will look like this: 
16
17
.. code-block:: javascript
18
19
{
20
     "title": "Avengers: Endgame",
21
     "plot": "The avengers save the day",
22
     "cast" : ["Robert Downey Jr.", "Chris Evans", "Scarlett Johansson", "Samuel L. Jackson"],
23
     "year": 2019
24
}  

1
npm install @hapi/joi --save
2
npm install joi-objectid --save

1
// Add this below the @hapi/hapi require statement
2
const Joi = require('@hapi/joi');
3
Joi.objectId = require('joi-objectid')(Joi)
4
5
// Update the details of a movie
6
server.route({
7
    method: 'PUT',
8
    path: '/movies/{id}',
9
    options: {
10
        validate: {
11
            params: Joi.object({
12
                id: Joi.objectId()
13
            })
14
        }
15
    },
16
    handler: async (req, h) => {
17
        const id = req.params.id
18
        const ObjectID = req.mongo.ObjectID;
19
20
        const payload = req.payload
21
22
        const status = await req.mongo.db.collection('movies').updateOne({_id: ObjectID(id)}, {$set: payload});
23
24
        return status;
25
26
    }
27
});

1
// Update the details of a movie
2
server.route({
3
    method: 'PUT',
4
    path: '/movies/{id}',
5
    options: {
6
        validate: {
7
            params: Joi.object({
8
                id: Joi.objectId()
9
            })
10
        }
11
    },
12
    handler: async (req, h) => {
13
        const id = req.params.id
14
        const ObjectID = req.mongo.ObjectID;
15
16
        const payload = req.payload
17
18
        const status = await req.mongo.db.collection('movies').deleteOne({_id: ObjectID(id)});
19
20
        return status;
21
22
    }
23
});   

1
// Search for a movie
2
server.route({
3
    method: 'GET',
4
    path: '/search',
5
    handler: async(req, h) => {
6
        const query = req.query.term;
7
8
        const results = await req.mongo.db.collection("movies").aggregate([
9
            {
10
                $searchBeta: {
11
                    "search": {
12
                        "query": query,
13
                        "path":"title"
14
                    }
15
                }
16
            },
17
            {
18
                $project : {title:1, plot: 1}
19
            },
20
            {  
21
                $limit: 10
22
            }
23
            ]).toArray()
24
25
        return results;
26
    }
27
});