All files / services/request request.service.ts

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
3x
3x
3x
3x
 
 
3x
 
1x
1x
1x
1x
1x
1x
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
import { Service } from '../../container';
import { Observable } from 'rxjs';
import { get as httpGet } from 'http';
import { get as httpsGet } from 'https';
 
@Service()
export class RequestService {
    get(link: string) {
        return new Observable((o) => {
            Eif (link.includes('https://')) {
                httpsGet(link, (resp) => {
                    let data = '';
                    resp.on('data', (chunk) => data += chunk);
                    resp.on('end', () => o.next(data));
                }).on('error', (err) => {
                    console.error('Error: ' + err.message);
                    o.error(err);
                });
            } else {
                httpGet(link, (resp) => {
                    let data = '';
                    resp.on('data', (chunk) => data += chunk);
                    resp.on('end', () => o.next(data));
                }).on('error', (err) => {
                    console.error('Error: ' + err.message);
                    o.error(err);
                });
            }
        });
    }
}