feat: convert to TS

.changeset/smooth-lamps-rest.md

@@ -0,0 +1,5 @@
+---
+"barnard59-http": patch
+---
+
+Added TS declarations

packages/http/.gitignore

@@ -0,0 +1 @@
+*.js

packages/http/.npmignore

@@ -0,0 +1,3 @@
+*.ts
+!*.d.ts
+test/

packages/http/get.js → packages/http/get.ts

@@ -1,6 +1,7 @@
+import type { GetInit } from './lib/fetch.js'
 import fetch from './lib/fetch.js'
 
-function get(options) {
+function get(options: GetInit) {
   return fetch(options)
 }
 

packages/http/lib/fetch.js → packages/http/lib/fetch.ts

@@ -1,21 +1,23 @@
+/* eslint-disable @typescript-eslint/no-explicit-any */
 import { SpanStatusCode } from '@opentelemetry/api'
 import toReadable from 'duplex-to/readable.js'
+import type { RequestInit } from 'node-fetch'
 import nodeFetch from 'node-fetch'
 import tracer from './tracer.js'
 
-async function fetch({ method = 'GET', url, ...options } = {}) {
+export type GetInit = RequestInit & { url: string }
+
+export default async function fetch({ method = 'GET', url, ...options }: GetInit) {
   return await tracer.startActiveSpan('fetch', async span => {
     try {
       const response = await nodeFetch(url, { method, ...options })
 
-      return toReadable(response.body)
-    } catch (e) {
+      return toReadable(response.body as any)
+    } catch (e: any) {
       span.recordException(e)
       span.setStatus({ code: SpanStatusCode.ERROR, message: e.message })
     } finally {
       span.end()
     }
   })
 }
-
-export default fetch

packages/http/lib/writableFetch.ts

@@ -0,0 +1,26 @@
+/* eslint-disable @typescript-eslint/no-explicit-any */
+import type { Duplex } from 'node:stream'
+import { PassThrough, Readable } from 'node:stream'
+import duplexify from 'duplexify'
+import tracer from './tracer.js'
+
+export type PostInit = RequestInit & { url: string }
+
+export default async function writableFetch({ method = 'POST', url, ...options }: PostInit): Promise<Duplex> {
+  const inputStream: any = new PassThrough()
+  const outputStream = new PassThrough()
+
+  tracer.startActiveSpan('writableFetch', span => setTimeout(async () => {
+    try {
+      const response = await fetch(url, { method, body: inputStream, ...options })
+
+      Readable.fromWeb(response.body as any).pipe(outputStream)
+    } catch (err) {
+      outputStream.emit('error', err)
+    } finally {
+      span.end()
+    }
+  }, 0))
+
+  return duplexify(inputStream, outputStream)
+}

packages/http/package.json

@@ -5,7 +5,9 @@
   "main": "index.js",
   "type": "module",
   "scripts": {
-    "test": "mocha"
+    "test": "mocha",
+    "build": "tsc",
+    "prepack": "npm run build"
   },
   "repository": {
     "type": "git",
@@ -27,6 +29,7 @@
     "readable-stream": ">=3"
   },
   "devDependencies": {
+    "@types/duplexify": "^3.6.4",
     "express-as-promise": "^1.2.0",
     "get-stream": "^6.0.1",
     "is-stream": "^3.0.0"

packages/http/post.js → packages/http/post.ts

@@ -1,6 +1,7 @@
+import type { PostInit } from './lib/writableFetch.js'
 import writableFetch from './lib/writableFetch.js'
 
-function post(options) {
+function post(options: PostInit) {
   return writableFetch(options)
 }
 

packages/http/tsconfig.json

@@ -0,0 +1,7 @@
+{
+  "extends": "../../tsconfig.json",
+  "files": ["./index.ts"],
+  "compilerOptions": {
+    "skipLibCheck": true
+  }
+}