mirror of
https://github.com/expressjs/express.git
synced 2026-02-26 02:54:58 +00:00
d12772393c
* Fix Redis example to support Redis v4+ and Express 4/5
* update optional route syntax to /{:query} and refactor Redis initialization into dedicated function to guarantee that it is complete before server starts
---------
Co-authored-by: Sebastian Beltran <bjohansebas@gmail.com>
84 lines
1.5 KiB
JavaScript
84 lines
1.5 KiB
JavaScript
'use strict'
|
|
|
|
// install redis first:
|
|
// https://redis.io/
|
|
|
|
// then:
|
|
// $ npm install redis
|
|
// $ redis-server
|
|
|
|
/**
|
|
* Module dependencies.
|
|
*/
|
|
|
|
var express = require('../..');
|
|
var path = require('node:path');
|
|
var redis = require('redis');
|
|
|
|
var db = redis.createClient();
|
|
var app = express();
|
|
|
|
app.use(express.static(path.join(__dirname, 'public')));
|
|
|
|
// npm install redis
|
|
|
|
/**
|
|
* Redis Initialization
|
|
*/
|
|
|
|
async function initializeRedis() {
|
|
try {
|
|
// connect to Redis
|
|
|
|
await db.connect();
|
|
|
|
// populate search
|
|
|
|
await db.sAdd('ferret', 'tobi');
|
|
await db.sAdd('ferret', 'loki');
|
|
await db.sAdd('ferret', 'jane');
|
|
await db.sAdd('cat', 'manny');
|
|
await db.sAdd('cat', 'luna');
|
|
} catch (err) {
|
|
console.error('Error initializing Redis:', err);
|
|
process.exit(1);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* GET search for :query.
|
|
*/
|
|
|
|
app.get('/search/{:query}', function (req, res, next) {
|
|
var query = req.params.query || '';
|
|
db.sMembers(query)
|
|
.then((vals) => res.send(vals))
|
|
.catch((err) => {
|
|
console.error(`Redis error for query "${query}":`, err);
|
|
next(err);
|
|
});
|
|
});
|
|
|
|
/**
|
|
* GET client javascript. Here we use sendFile()
|
|
* because serving __dirname with the static() middleware
|
|
* would also mean serving our server "index.js" and the "search.jade"
|
|
* template.
|
|
*/
|
|
|
|
app.get('/client.js', function(req, res){
|
|
res.sendFile(path.join(__dirname, 'client.js'));
|
|
});
|
|
|
|
/**
|
|
* Start the Server
|
|
*/
|
|
|
|
(async () => {
|
|
await initializeRedis();
|
|
if (!module.parent) {
|
|
app.listen(3000);
|
|
console.log('Express started on port 3000');
|
|
}
|
|
})();
|