throttle requests
This commit is contained in:
parent
1e00780395
commit
46c8642534
10
app.js
10
app.js
@ -1,9 +1,10 @@
|
|||||||
require('dotenv').config();
|
require('dotenv').config();
|
||||||
|
|
||||||
var request = require("request");
|
var request = require("request");
|
||||||
cachedRequest = require('cached-request')(request)
|
var throttledRequest = require('throttled-request')(request);
|
||||||
cacheDirectory = "./cache";
|
throttledRequest.configure({requests: 8, milliseconds: 60000}); //send 1 request per second
|
||||||
cachedRequest.setCacheDirectory(cacheDirectory);
|
cachedRequest = require('cached-request')(throttledRequest);
|
||||||
|
cachedRequest.setCacheDirectory("./cache");
|
||||||
|
|
||||||
const logger = require('perfect-logger');
|
const logger = require('perfect-logger');
|
||||||
const TelegramBot = require('node-telegram-bot-api');
|
const TelegramBot = require('node-telegram-bot-api');
|
||||||
@ -84,6 +85,7 @@ bot.on('message', (msg) => {
|
|||||||
};
|
};
|
||||||
|
|
||||||
cachedRequest(options, function (error, response, body) {
|
cachedRequest(options, function (error, response, body) {
|
||||||
|
console.log(response)
|
||||||
if (error) throw new Error(error);
|
if (error) throw new Error(error);
|
||||||
|
|
||||||
// console.log(body);
|
// console.log(body);
|
||||||
@ -123,6 +125,8 @@ bot.on('message', (msg) => {
|
|||||||
};
|
};
|
||||||
|
|
||||||
request(options, function (error, response, body) {
|
request(options, function (error, response, body) {
|
||||||
|
console.log(response)
|
||||||
|
|
||||||
if (error) throw new Error(error);
|
if (error) throw new Error(error);
|
||||||
let jsonBody = JSON.parse(body)
|
let jsonBody = JSON.parse(body)
|
||||||
bot.sendMessage(msg.chat.id, jsonBody.content)
|
bot.sendMessage(msg.chat.id, jsonBody.content)
|
||||||
|
5
package-lock.json
generated
5
package-lock.json
generated
@ -772,6 +772,11 @@
|
|||||||
"resolved": "https://registry.npmjs.org/supports-color/-/supports-color-1.2.0.tgz",
|
"resolved": "https://registry.npmjs.org/supports-color/-/supports-color-1.2.0.tgz",
|
||||||
"integrity": "sha1-/x7R5hFp0Gs88tWI4YixjYhH4X4="
|
"integrity": "sha1-/x7R5hFp0Gs88tWI4YixjYhH4X4="
|
||||||
},
|
},
|
||||||
|
"throttled-request": {
|
||||||
|
"version": "0.1.1",
|
||||||
|
"resolved": "https://registry.npmjs.org/throttled-request/-/throttled-request-0.1.1.tgz",
|
||||||
|
"integrity": "sha1-QUa3C3elrsozxGMyzxPrnHkelxs="
|
||||||
|
},
|
||||||
"to-iso-string": {
|
"to-iso-string": {
|
||||||
"version": "0.0.2",
|
"version": "0.0.2",
|
||||||
"resolved": "https://registry.npmjs.org/to-iso-string/-/to-iso-string-0.0.2.tgz",
|
"resolved": "https://registry.npmjs.org/to-iso-string/-/to-iso-string-0.0.2.tgz",
|
||||||
|
@ -19,6 +19,7 @@
|
|||||||
"node-telegram-bot-api": "^0.50.0",
|
"node-telegram-bot-api": "^0.50.0",
|
||||||
"perfect-logger": "^2.0.1",
|
"perfect-logger": "^2.0.1",
|
||||||
"rapidapi-connect": "0.0.6",
|
"rapidapi-connect": "0.0.6",
|
||||||
"request": "^2.88.2"
|
"request": "^2.88.2",
|
||||||
|
"throttled-request": "^0.1.1"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user