module: upgrade to esmodule

.eslintrc.json

@@ -52,8 +52,8 @@
     "after": true
   },
   "parserOptions": {
-    "ecmaVersion": 8,
-    "sourceType": "script",
+    "ecmaVersion": "latest",
+    "sourceType": "module",
     "ecmaFeatures": {
       "jsx": true
     }

lib/index.js

@@ -1,13 +1,13 @@
-'use strict';
 
-const zlib = require('zlib');
-const http = require('http');
-const https = require('https');
-const parse = require('url').parse;
-const format = require('url').format;
 
-const debugBody = require('debug')('httpx:body');
-const debugHeader = require('debug')('httpx:header');
+import zlib from 'zlib';
+import http from 'http';
+import https from 'https';
+import { parse, format } from 'url';
+import debug from 'debug';
+
+const debugBody = debug('httpx:body');
+const debugHeader = debug('httpx:header');
 
 const httpAgent = new http.Agent({ keepAlive: true });
 const httpsAgent = new https.Agent({ keepAlive: true });
@@ -45,7 +45,7 @@ const isNumber = function (num) {
   return num !== null && !isNaN(num);
 };
 
-exports.request = function (url, opts) {
+export function request(url, opts) {
   opts || (opts = {});
 
   const parsed = typeof url === 'string' ? parse(url) : url;
@@ -180,9 +180,9 @@ exports.request = function (url, opts) {
       }
     });
   });
-};
+}
 
-exports.read = function (response, encoding) {
+export function read(response, encoding) {
   const readable = decompress(response);
 
   return new Promise((resolve, reject) => {
@@ -260,7 +260,7 @@ exports.read = function (response, encoding) {
     readable.on('data', onData);
     readable.on('end', onEnd);
   });
-};
+}
 
 function readyToRead(readable) {
   return new Promise((resolve, reject) => {
@@ -270,7 +270,7 @@ function readyToRead(readable) {
       readable.removeListener('error', onError);
       readable.removeListener('end', onEnd);
       readable.removeListener('readable', onReadable);
-    }
+    };
 
     onReadable = function () {
       cleanup();
@@ -280,20 +280,20 @@ function readyToRead(readable) {
     onEnd = function () {
       cleanup();
       resolve(true);
-    }
+    };
 
     onError = function (err) {
       cleanup();
       reject(err);
-    }
+    };
 
     readable.once('readable', onReadable);
     readable.once('end', onEnd);
     readable.once('error', onError);
   });
 }
 
-class Event {
+export class Event {
   constructor(id, event, data, retry) {
     this.id = id;
     this.event = event;
@@ -302,8 +302,6 @@ class Event {
   }
 }
 
-exports.Event = Event;
-
 const DATA_PREFIX = 'data: ';
 const EVENT_PREFIX = 'event: ';
 const ID_PREFIX = 'id: ';
@@ -345,7 +343,7 @@ function tryGetEvents(head, chunk) {
  * @param {ReadableStream} response 
  * @returns AsyncGenerator<Event, void, unknown>
  */
-exports.readAsSSE = async function* (response) {
+export async function* readAsSSE(response) {
   const readable = decompress(response);
 
   const socket = response.socket || response.client;
@@ -370,4 +368,10 @@ exports.readAsSSE = async function* (response) {
       }
     }
   }
-};
+}
+
+export default {
+  request,
+  read,
+  readAsSSE
+};