Skip to content

Commit 6855df6

Browse files
committed
fix(memorystore): Fix outdated nodejs example for Memorystore for Redis.
1 parent 455d71e commit 6855df6

1 file changed

Lines changed: 22 additions & 12 deletions

File tree

memorystore/redis/server.js

Lines changed: 22 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -20,22 +20,32 @@ const redis = require('redis');
2020
const REDISHOST = process.env.REDISHOST || 'localhost';
2121
const REDISPORT = process.env.REDISPORT || 6379;
2222

23-
const client = redis.createClient(REDISPORT, REDISHOST);
23+
const client = redis.createClient({
24+
url: `redis://${REDISHOST}:${REDISPORT}`,
25+
});
26+
2427
client.on('error', err => console.error('ERR:REDIS:', err));
2528

26-
// create a server
29+
client
30+
.connect()
31+
.then(() => {
32+
console.log('Connected to Redis');
33+
})
34+
.catch(console.error);
35+
2736
http
28-
.createServer((req, res) => {
29-
// increment the visit counter
30-
client.incr('visits', (err, reply) => {
31-
if (err) {
32-
console.log(err);
33-
res.status(500).send(err.message);
34-
return;
35-
}
37+
.createServer(async (req, res) => {
38+
try {
39+
const reply = await client.incr('visits');
3640
res.writeHead(200, {'Content-Type': 'text/plain'});
3741
res.end(`Visitor number: ${reply}\n`);
38-
});
42+
} catch (err) {
43+
console.error(err);
44+
res.statusCode = 500;
45+
res.end(err.message);
46+
}
3947
})
40-
.listen(8080);
48+
.listen(8080, () => {
49+
console.log('Server listening on port 8080');
50+
});
4151
// [END memorystore_server_js]

0 commit comments

Comments
 (0)