import * as httpm from '../';
import * as path from 'path';
import * as fs from 'fs';

let sampleFilePath: string = path.join(__dirname, 'testoutput.txt');

describe('basics', () => {
    let _http: httpm.HttpClient;

    beforeEach(() => {
        _http = new httpm.HttpClient('http-client-tests');
    })
  
    afterEach(() => {

    })
  
    it('constructs', () => {
        let http: httpm.HttpClient = new httpm.HttpClient('thttp-client-tests');
        expect(http).toBeDefined();
    });

    // responses from httpbin return something like:
    // {
    //     "args": {}, 
    //     "headers": {
    //       "Connection": "close", 
    //       "Host": "httpbin.org", 
    //       "User-Agent": "typed-test-client-tests"
    //     }, 
    //     "origin": "173.95.152.44", 
    //     "url": "https://httpbin.org/get"
    //  }

    it('does basic http get request', async(done) => {
        let res: httpm.HttpClientResponse = await _http.get('http://httpbin.org/get');
        expect(res.message.statusCode).toBe(200);
        let body: string = await res.readBody();      
        let obj: any = JSON.parse(body);
        expect(obj.url).toBe("https://httpbin.org/get");
        expect(obj.headers["User-Agent"]).toBeTruthy();
        done();
    });   
        
    it('does basic http get request with no user agent', async(done) => {
        let http: httpm.HttpClient = new httpm.HttpClient();
        let res: httpm.HttpClientResponse = await http.get('http://httpbin.org/get');
        expect(res.message.statusCode).toBe(200);
        let body: string = await res.readBody();      
        let obj: any = JSON.parse(body);
        expect(obj.url).toBe("https://httpbin.org/get");
        expect(obj.headers["User-Agent"]).toBeFalsy();
        done();
    });    

    it('does basic https get request', async(done) => {
        let res: httpm.HttpClientResponse = await _http.get('https://httpbin.org/get');
        expect(res.message.statusCode).toBe(200);
        let body: string = await res.readBody();
        let obj: any = JSON.parse(body);
        expect(obj.url).toBe("https://httpbin.org/get");
        done();
    });

    it('does basic http get request with default headers', async(done) => {
        let http: httpm.HttpClient = new httpm.HttpClient('http-client-tests', [], {
            headers: {
                'Accept': 'application/json',
                'Content-Type': 'application/json'
            }
        });
        let res: httpm.HttpClientResponse = await http.get('http://httpbin.org/get');
        expect(res.message.statusCode).toBe(200);
        let body: string = await res.readBody(); 
        let obj:any = JSON.parse(body);
        expect(obj.headers.Accept).toBe('application/json');
        expect(obj.headers['Content-Type']).toBe('application/json');
        expect(obj.url).toBe("https://httpbin.org/get");
        done();
    });    

    it('does basic http get request with merged headers', async(done) => {
        let http: httpm.HttpClient = new httpm.HttpClient('http-client-tests', [], {
            headers: {
                'Accept': 'application/json',
                'Content-Type': 'application/json'
            }
        });
        let res: httpm.HttpClientResponse = await http.get('http://httpbin.org/get', {
            'content-type': 'application/x-www-form-urlencoded'
        });
        expect(res.message.statusCode).toBe(200);
        let body: string = await res.readBody(); 
        let obj:any = JSON.parse(body);
        expect(obj.headers.Accept).toBe('application/json');
        expect(obj.headers['Content-Type']).toBe('application/x-www-form-urlencoded');
        expect(obj.url).toBe("https://httpbin.org/get");
        done();
    });    

    it('pipes a get request', () => {
        return new Promise<string>(async (resolve, reject) => {
            let file: NodeJS.WritableStream = fs.createWriteStream(sampleFilePath);
            (await _http.get('https://httpbin.org/get')).message.pipe(file).on('close', () => {
                let body: string = fs.readFileSync(sampleFilePath).toString();
                let obj:any = JSON.parse(body);
                expect(obj.url).toBe("https://httpbin.org/get");
                resolve();
            });
        });
    });
    
    it('does basic get request with redirects', async(done) => {
        let res: httpm.HttpClientResponse = await _http.get("https://httpbin.org/redirect-to?url=" + encodeURIComponent("https://httpbin.org/get"))
        expect(res.message.statusCode).toBe(200);
        let body: string = await res.readBody();
        let obj:any = JSON.parse(body);
        expect(obj.url).toBe("https://httpbin.org/get");
        done();
    });

    it('does basic get request with redirects (303)', async(done) => {
        let res: httpm.HttpClientResponse = await _http.get("https://httpbin.org/redirect-to?url=" + encodeURIComponent("https://httpbin.org/get") + '&status_code=303')
        expect(res.message.statusCode).toBe(200);
        let body: string = await res.readBody();
        let obj:any = JSON.parse(body);
        expect(obj.url).toBe("https://httpbin.org/get");
        done();
    });    

    it('returns 404 for not found get request on redirect', async(done) => {
        let res: httpm.HttpClientResponse = await _http.get("https://httpbin.org/redirect-to?url=" + encodeURIComponent("https://httpbin.org/status/404") + '&status_code=303')
        expect(res.message.statusCode).toBe(404);
        let body: string = await res.readBody();
        done();
    });    

    it('does not follow redirects if disabled', async(done) => {
        let http: httpm.HttpClient = new httpm.HttpClient('typed-test-client-tests', null, { allowRedirects: false });
        let res: httpm.HttpClientResponse = await http.get("https://httpbin.org/redirect-to?url=" + encodeURIComponent("https://httpbin.org/get"))
        expect(res.message.statusCode).toBe(302);
        let body: string = await res.readBody();
        done();
    });

    it('does basic head request', async(done) => {
        let res: httpm.HttpClientResponse = await _http.head('http://httpbin.org/get');
        expect(res.message.statusCode).toBe(200);
        done();
    });    

    it('does basic http delete request', async(done) => {
        let res: httpm.HttpClientResponse = await _http.del('http://httpbin.org/delete');
        expect(res.message.statusCode).toBe(200);
        let body: string = await res.readBody();      
        let obj:any = JSON.parse(body);
        done();
    });

    it('does basic http post request', async(done) => {
        let b: string = 'Hello World!';
        let res: httpm.HttpClientResponse = await _http.post('http://httpbin.org/post', b);
        expect(res.message.statusCode).toBe(200);
        let body: string = await res.readBody();
        let obj:any = JSON.parse(body);
        expect(obj.data).toBe(b);
        expect(obj.url).toBe("https://httpbin.org/post");
        done();
    });    

    it('does basic http patch request', async(done) => {
        let b: string = 'Hello World!';
        let res: httpm.HttpClientResponse = await _http.patch('http://httpbin.org/patch', b);
        expect(res.message.statusCode).toBe(200);
        let body: string = await res.readBody();
        let obj:any = JSON.parse(body);
        expect(obj.data).toBe(b);
        expect(obj.url).toBe("https://httpbin.org/patch");
        done();
    });
    
    it('does basic http options request', async(done) => {
        let res: httpm.HttpClientResponse = await _http.options('http://httpbin.org');
        expect(res.message.statusCode).toBe(200);
        let body: string = await res.readBody();
        done();
    }); 
    
    it('returns 404 for not found get request', async(done) => {
        let res: httpm.HttpClientResponse = await _http.get('http://httpbin.org/status/404');
        expect(res.message.statusCode).toBe(404);
        let body: string = await res.readBody();
        done();
    });    
})