Use fetch instead of axios

Author: andreas-sqsh

jest.config.js

@@ -1,7 +1,7 @@
 /** @type {import('@ts-jest/dist/types').InitialOptionsTsJest} */
 module.exports = {
-  preset: 'ts-jest',
-  testEnvironment: 'node',
-  collectCoverage: true,
-  coverageDirectory: 'coverage'
+    preset: 'ts-jest',
+    testEnvironment: 'jsdom',
+    collectCoverage: true,
+    coverageDirectory: 'coverage'
 }

libundler.config.ts

@@ -2,11 +2,11 @@ import { defineConfig } from '@surmon-china/libundler'
 
 export default defineConfig({
   libName: 'MongoDBDataAPI',
-  outFileName: 'mongodb-data-api',
+  outFileName: 'mongodb-data-api-fetch',
   targets: ['cjs', 'esm'],
   entry: './src/index.ts',
   outDir: './dist',
-  external: ['axios', 'mongodb'],
+  external: ['mongodb'],
   terser: false,
   sourcemap: false
 })

package.json

@@ -1,20 +1,28 @@
 {
-  "name": "mongodb-data-api",
-  "version": "0.4.0",
-  "description": "MongoDB atlas data API SDK for Node.js",
+  "name": "mongodb-data-api-fetch",
+  "version": "0.1.0",
+  "description": "MongoDB Atlas Data API SDK for Cloudflare Workers",
   "author": "Surmon",
+  "contributors": [
+    {
+      "name": "trophologist",
+      "email": "info@trophologist.com",
+      "url": "https://trophologist.com"
+    }
+  ],
   "license": "MIT",
   "keywords": [
-    "MongoDB data API",
-    "MongoDB cloud data API",
-    "MongoDB Atlas data API SDK"
+    "MongoDB",
+    "MongoDB Data API",
+    "MongoDB Atlas Data API SDK",
+    "Cloudflare Workers",
+    "Fetch"
   ],
   "repository": {
     "type": "git",
-    "url": "https://github.com/surmon-china/mongodb-data-api.git"
+    "url": "https://github.com/trophologist/mongodb-data-api-fetch.git"
   },
   "files": [
-    "CHANGELOG.md",
     "dist"
   ],
   "sideEffects": false,
@@ -32,7 +40,6 @@
     "release": ". ./scripts/release.sh"
   },
   "dependencies": {
-    "axios": "^1.1.0",
     "mongodb": "^4.12.0"
   },
   "devDependencies": {
@@ -47,6 +54,7 @@
     "jest": "^29.3.0",
     "prettier": "^2.5.1",
     "ts-jest": "^29.0.0",
-    "typescript": "^4.9.0"
+    "typescript": "^4.9.0",
+    "jest-environment-jsdom": "^29.3.1"
   }
 }

src/index.ts

@@ -1,4 +1,3 @@
-import _axios, { AxiosInstance, AxiosRequestConfig } from 'axios'
 import type { Filter, FindOptions, Sort, UpdateFilter, Document } from 'mongodb'
 
 // https://github.com/surmon-china/mongodb-data-api/pull/3/files @maxfi
@@ -58,19 +57,17 @@ export type Config = XOR<UrlEndpointConfig, PackEndpointConfig>
 export class MongoDBDataAPI<InnerDoc = Document> {
   #config: Config
   #baseParams: BaseParams
-  #axios: AxiosInstance
 
-  constructor(config: Config, baseParams?: BaseParams, axios?: AxiosInstance) {
+  constructor (config: Config, baseParams?: BaseParams) {
     if (!config.apiKey) {
       throw new Error('Invalid API key!')
     }
 
     this.#config = config
     this.#baseParams = baseParams || {}
-    this.#axios = axios || _axios.create()
   }
 
-  #newAPI<D>(params: BaseParams) {
+  #newAPI<D> (params: BaseParams) {
     return new MongoDBDataAPI<D>(
       { ...this.#config },
       {
@@ -81,23 +78,23 @@ export class MongoDBDataAPI<InnerDoc = Document> {
   }
 
   /** Select a cluster. */
-  public $cluster(clusterName: string) {
+  public $cluster (clusterName: string) {
     return this.#newAPI<InnerDoc>({ dataSource: clusterName }) as Omit<
       MongoDBDataAPI<InnerDoc>,
       '$cluster' | '$collection'
     >
   }
 
   /** Select a database. */
-  public $database(database: string) {
+  public $database (database: string) {
     return this.#newAPI<InnerDoc>({ database }) as Omit<
       MongoDBDataAPI<InnerDoc>,
       '$cluster' | '$database'
     >
   }
 
   /** Select a collection. */
-  public $collection<Doc = InnerDoc>(collection: string) {
+  public $collection<Doc = InnerDoc> (collection: string) {
     return this.#newAPI<Doc>({ collection }) as Omit<
       MongoDBDataAPI<Doc>,
       '$cluster' | '$database' | '$collection'
@@ -108,10 +105,9 @@ export class MongoDBDataAPI<InnerDoc = Document> {
    * Execute a API action.
    * @link https://www.mongodb.com/docs/atlas/api/data-api-resources/
    */
-  public $$action<Result = unknown>(
+  public $$action<Result = unknown> (
     type: string,
-    params: BaseParams = {},
-    axiosConfig?: AxiosRequestConfig
+    params: BaseParams = {}
   ): Promise<Result> {
     const mergedParams = {
       ...this.#baseParams,
@@ -134,36 +130,37 @@ export class MongoDBDataAPI<InnerDoc = Document> {
       return `${endpoint}/action/${action}`
     }
 
-    return this.#axios({
-      method: 'post',
-      data: JSON.stringify(mergedParams),
-      url: this.#config.urlEndpoint
+    return fetch(
+      this.#config.urlEndpoint
         ? getActionUrl(this.#config.urlEndpoint, type)
         : getActionUrl(
             getUrlEndpoint(this.#config.appId!, this.#config.region, this.#config.cloud),
             type
           ),
-      headers: {
-        'Content-Type': 'application/json',
-        'Access-Control-Request-Headers': '*',
-        'api-key': this.#config.apiKey
-      },
-      ...axiosConfig
-    })
-      .then((response) => {
-        return response.data
+      {
+        method: 'post',
+        body: JSON.stringify(mergedParams),
+        headers: {
+          'Content-Type': 'application/json',
+          'Access-Control-Request-Headers': '*',
+          'api-key': this.#config.apiKey
+        }
+      }
+    )
+      .then((response: any) => {
+        return response.json()
       })
-      .catch((error) => {
+      .catch((error: any) => {
         // https://www.mongodb.com/docs/atlas/api/data-api-resources/#error-codes
-        return Promise.reject(_axios.isAxiosError(error) ? error.toJSON() : error)
+        return Promise.reject(error)
       })
   }
 
   /**
    * Find a Single Document.
    * @link https://www.mongodb.com/docs/atlas/api/data-api-resources/#find-a-single-document
    */
-  public findOne<D = InnerDoc, T = NoInfer<D>>(
+  public findOne<D = InnerDoc, T = NoInfer<D>> (
     params?: ExtendBaseParams<{
       filter?: Filter<T>
       projection?: Projection
@@ -176,7 +173,7 @@ export class MongoDBDataAPI<InnerDoc = Document> {
    * Find Multiple Documents.
    * @link https://www.mongodb.com/docs/atlas/api/data-api-resources/#find-multiple-documents
    */
-  public find<D = InnerDoc, T = NoInfer<D>>(
+  public find<D = InnerDoc, T = NoInfer<D>> (
     params?: ExtendBaseParams<{
       filter?: Filter<T>
       projection?: Projection
@@ -192,7 +189,7 @@ export class MongoDBDataAPI<InnerDoc = Document> {
    * Insert a Single Document.
    * @link https://www.mongodb.com/docs/atlas/api/data-api-resources/#insert-a-single-document
    */
-  public insertOne<D = InnerDoc, T = NoInfer<D>>(
+  public insertOne<D = InnerDoc, T = NoInfer<D>> (
     params: ExtendBaseParams<{ document: AnyKeys<T> | Document }>
   ) {
     return this.$$action<{ insertedId: string }>('insertOne', params)
@@ -202,7 +199,7 @@ export class MongoDBDataAPI<InnerDoc = Document> {
    * Insert Multiple Documents.
    * @link https://www.mongodb.com/docs/atlas/api/data-api-resources/#insert-multiple-documents
    */
-  public insertMany<D = InnerDoc, T = NoInfer<D>>(
+  public insertMany<D = InnerDoc, T = NoInfer<D>> (
     params: ExtendBaseParams<{ documents: Array<AnyKeys<T> | Document> }>
   ) {
     return this.$$action<{ insertedIds: Array<string> }>('insertMany', params)
@@ -212,7 +209,7 @@ export class MongoDBDataAPI<InnerDoc = Document> {
    * Update a Single Document.
    * @link https://www.mongodb.com/docs/atlas/api/data-api-resources/#update-a-single-document
    */
-  public updateOne<D = InnerDoc, T = NoInfer<D>>(
+  public updateOne<D = InnerDoc, T = NoInfer<D>> (
     params: ExtendBaseParams<{
       filter: Filter<T>
       update: UpdateFilter<T>
@@ -230,7 +227,7 @@ export class MongoDBDataAPI<InnerDoc = Document> {
    * Update Multiple Documents.
    * @link https://www.mongodb.com/docs/atlas/api/data-api-resources/#update-multiple-documents
    */
-  public updateMany<D = InnerDoc, T = NoInfer<D>>(
+  public updateMany<D = InnerDoc, T = NoInfer<D>> (
     params: ExtendBaseParams<{
       filter: Filter<T>
       update: UpdateFilter<T>
@@ -248,7 +245,7 @@ export class MongoDBDataAPI<InnerDoc = Document> {
    * Replace a Single Document.
    * @link https://www.mongodb.com/docs/atlas/api/data-api-resources/#replace-a-single-document
    */
-  public replaceOne<D = InnerDoc, T = NoInfer<D>>(
+  public replaceOne<D = InnerDoc, T = NoInfer<D>> (
     params: ExtendBaseParams<{
       filter: Filter<T>
       replacement: any
@@ -266,7 +263,7 @@ export class MongoDBDataAPI<InnerDoc = Document> {
    * Delete a Single Document.
    * @link https://www.mongodb.com/docs/atlas/api/data-api-resources/#delete-a-single-document
    */
-  public deleteOne<D = InnerDoc, T = NoInfer<D>>(
+  public deleteOne<D = InnerDoc, T = NoInfer<D>> (
     params: ExtendBaseParams<{ filter: Filter<T> }>
   ) {
     return this.$$action<{ deletedCount: number }>('deleteOne', params)
@@ -276,7 +273,7 @@ export class MongoDBDataAPI<InnerDoc = Document> {
    * Delete Multiple Documents.
    * @link https://www.mongodb.com/docs/atlas/api/data-api-resources/#delete-multiple-documents
    */
-  public deleteMany<D = InnerDoc, T = NoInfer<D>>(
+  public deleteMany<D = InnerDoc, T = NoInfer<D>> (
     params: ExtendBaseParams<{ filter: Filter<T> }>
   ) {
     return this.$$action<{ deletedCount: number }>('deleteMany', params)
@@ -286,13 +283,13 @@ export class MongoDBDataAPI<InnerDoc = Document> {
    * Run an Aggregation Pipeline.
    * @link https://www.mongodb.com/docs/atlas/api/data-api-resources/#run-an-aggregation-pipeline
    */
-  public aggregate<T extends Array<any>>(
+  public aggregate<T extends Array<any>> (
     params: ExtendBaseParams<{ pipeline: Array<Document> }>
   ) {
     return this.$$action<{ documents: T }>('aggregate', params)
   }
 }
 
-export const createMongoDBDataAPI = (config: Config, axios?: AxiosInstance) => {
-  return new MongoDBDataAPI(config, void 0, axios)
+export const createMongoDBDataAPI = (config: Config) => {
+  return new MongoDBDataAPI(config, void 0)
 }

tests/index.spec.ts

@@ -1,4 +1,3 @@
-import axios from 'axios'
 import { createMongoDBDataAPI, MongoDBDataAPI } from '../src'
 
 test('<type> should be function type', () => {
@@ -57,19 +56,6 @@ test('<runtime> should be error', async () => {
     })
     await api.$cluster('test').$database('test').$collection('test').find()
   } catch (error) {
-    expect(axios.isAxiosError(error)).toBeFalsy()
-  }
-})
-
-test('<runtime> should be axios error', async () => {
-  try {
-    const api = createMongoDBDataAPI({
-      apiKey: 'test_api_key',
-      urlEndpoint: 'https://data.mongodb-api.com/app/test_app/endpoint/data/v1'
-    })
-    await api.$cluster('test').$database('test').$collection('test').findOne()
-  } catch (error: any) {
-    expect(error.name).toBe('AxiosError')
-    expect(error.status).toBe(404)
+    expect(error).toBeTruthy()
   }
 })

tsconfig.json

@@ -2,7 +2,7 @@
   "compilerOptions": {
     "module": "esnext",
     "target": "ES6",
-    "lib": ["ESNext"],
+    "lib": ["ESNext", "webworker"],
     "moduleResolution": "node",
     "strict": true,
     "strictNullChecks": true,