|
|
@ -285,11 +285,11 @@ if (cluster.isMaster) { |
|
|
|
}) |
|
|
|
}) |
|
|
|
|
|
|
|
|
|
|
|
app.get('/api/v1/streaming/hashtag', (req, res) => { |
|
|
|
app.get('/api/v1/streaming/hashtag', (req, res) => { |
|
|
|
streamFrom(`timeline:hashtag:${req.params.tag}`, req, streamToHttp(req, res), streamHttpEnd(req), true) |
|
|
|
streamFrom(`timeline:hashtag:${req.query.tag}`, req, streamToHttp(req, res), streamHttpEnd(req), true) |
|
|
|
}) |
|
|
|
}) |
|
|
|
|
|
|
|
|
|
|
|
app.get('/api/v1/streaming/hashtag/local', (req, res) => { |
|
|
|
app.get('/api/v1/streaming/hashtag/local', (req, res) => { |
|
|
|
streamFrom(`timeline:hashtag:${req.params.tag}:local`, req, streamToHttp(req, res), streamHttpEnd(req), true) |
|
|
|
streamFrom(`timeline:hashtag:${req.query.tag}:local`, req, streamToHttp(req, res), streamHttpEnd(req), true) |
|
|
|
}) |
|
|
|
}) |
|
|
|
|
|
|
|
|
|
|
|
wss.on('connection', ws => { |
|
|
|
wss.on('connection', ws => { |
|
|
|