50 lines
1014 B
JavaScript
50 lines
1014 B
JavaScript
import https from 'https';
|
|
import qs from 'qs';
|
|
|
|
export default function fetch(path, data) {
|
|
const post = qs.stringify(data);
|
|
|
|
return new Promise((resolve, reject) => {
|
|
const req = https.request({
|
|
hostname: 'api.telegram.org',
|
|
method: data ? 'POST' : 'GET',
|
|
path: '/bot' + path,
|
|
headers: {
|
|
'Content-Type': 'application/x-www-form-urlencoded'
|
|
}
|
|
}, response => {
|
|
return getBody(response).then(res => {
|
|
try {
|
|
let json = JSON.parse(res);
|
|
resolve(json);
|
|
} catch(e) {
|
|
reject(e);
|
|
}
|
|
}).catch(reject);
|
|
});
|
|
|
|
if (post) {
|
|
req.write(post);
|
|
}
|
|
req.end();
|
|
}).catch(err => {
|
|
console.error('Error sending request', err);
|
|
});
|
|
}
|
|
|
|
export function getBody(stream) {
|
|
let data = '';
|
|
|
|
return new Promise((resolve, reject) => {
|
|
stream.on('data', chunk => {
|
|
data += chunk;
|
|
});
|
|
|
|
stream.on('end', () => {
|
|
resolve(data);
|
|
});
|
|
|
|
stream.on('error', reject);
|
|
});
|
|
}
|