un-got

mostly changed json to body in the requests and added the method option where needed.

Author: cubap

routes/create.js

@@ -1,24 +1,23 @@
 const express = require('express')
 const router = express.Router()
-const got = require('got')
 
 /* POST a create to the thing. */
 router.post('/', async (req, res, next) => {
 
   try {
     // check body for JSON
     JSON.stringify(req.body)
-    const createBody = req.body
     const createOptions = {
-      json: createBody,
+      method: 'POST',
+      body: req.body,
       headers: {
         'user-agent': 'Tiny-Node',
         'Authorization': `Bearer ${process.env.ACCESS_TOKEN}`, // not required for query
         'Content-Type' : "application/json;charset=utf-8"
       }
     }
     const createURL = `${process.env.RERUM_API_ADDR}create`
-    const result = await got.post(createURL, createOptions).json()
+    const result = await fetch(createURL, createOptions).json()
     res.setHeader("Location", result["@id"])
     res.status(201)
     res.send(result)

routes/delete.js

@@ -1,25 +1,26 @@
 const express = require('express')
 const router = express.Router()
-const got = require('got')
 
 /* Legacy delete pattern w/body */
 
 /* DELETE a delete to the thing. */
 router.delete('/', async (req, res, next) => {
   try {
+    JSON.stringify(req.body)
     const deleteBody = req.body ?? {}
 
     const deleteOptions = {
-      json: deleteBody,
+      body: deleteBody,
+      method: 'DELETE',
       headers: {
         'user-agent': 'Tiny-Node',
         'Authorization': `Bearer ${process.env.ACCESS_TOKEN}`,
-        'Content-Type' : "application/json"
+        'Content-Type' : "application/json; charset=utf-8"
       }
     }
     console.log(deleteBody)
     const deleteURL = `${process.env.RERUM_API_ADDR}delete`
-    const result = await got.delete(deleteURL, deleteOptions).text()
+    const result = await fetch(deleteURL, deleteOptions).text()
     res.status(204)
     res.send(result)
   }
@@ -35,12 +36,13 @@ router.delete('/:id', async (req, res, next) => {
 
     const deleteURL = `${process.env.RERUM_API_ADDR}delete/${req.params.id}`
     const deleteOptions = {
+      method: 'DELETE',
       headers: {
         'user-agent': 'Tiny-Node',
         'Authorization': `Bearer ${process.env.ACCESS_TOKEN}`,
       }
     }
-    const result = await got.delete(deleteURL, deleteOptions).text()
+    const result = await fetch(deleteURL, deleteOptions).text()
     res.status(204)
     res.send(result)
   }

routes/overwrite.js

@@ -1,6 +1,5 @@
 const express = require('express')
 const router = express.Router()
-const got = require('got')
 
 /* PUT an overwrite to the thing. */
 router.put('/', async (req, res, next) => {
@@ -16,19 +15,20 @@ router.put('/', async (req, res, next) => {
     }
 
     const overwriteOptions = {
-      json: overwriteBody,
+      method: 'PUT',
+      body: overwriteBody,
       headers: {
         'user-agent': 'Tiny-Node',
         'Authorization': `Bearer ${process.env.ACCESS_TOKEN}`,
         'Content-Type' : "application/json;charset=utf-8"
       }
     }
     const overwriteURL = `${process.env.RERUM_API_ADDR}overwrite`
-    const result = await got.put(overwriteURL, overwriteOptions).json()
+    const result = await fetch(overwriteURL, overwriteOptions).json()
     res.status(200)
     res.send(result)
   }
-  catch (err) {
+  catch (err) {    
     console.log(err)
     res.status(500).send("Caught Error:" + err)
   }

routes/query.js

@@ -1,6 +1,5 @@
 const express = require('express')
 const router = express.Router()
-const got = require('got')
 
 /* POST a query to the thing. */
 router.post('/', async (req, res, next) => {
@@ -18,15 +17,16 @@ router.post('/', async (req, res, next) => {
       throw Error("`limit` and `skip` values must be positive integers or omitted.")
     }
     const queryOptions = {
-      json: queryBody,
+      method: 'POST',
+      body: queryBody,
       headers: {
         'user-agent': 'Tiny-Node',
         'Authorization': `Bearer ${process.env.RERUM_TOKEN}`, // not required for query
         'Content-Type' : "application/json;charset=utf-8"
       }
     }
     const queryURL = `${process.env.RERUM_API_ADDR}query?limit=${lim}&skip=${skip}`
-    const results = await got.post(queryURL, queryOptions).json()
+    const results = await fetch(queryURL, queryOptions).json()
     res.status(200)
     res.send(results)
   }

routes/update.js

@@ -1,6 +1,5 @@
 const express = require('express')
 const router = express.Router()
-const got = require('got')
 
 /* PUT an update to the thing. */
 router.put('/', async (req, res, next) => {
@@ -16,15 +15,16 @@ router.put('/', async (req, res, next) => {
     }
 
     const updateOptions = {
-      json: updateBody,
+      method: 'PUT',
+      body: updateBody,
       headers: {
         'user-agent': 'Tiny-Node',
         'Authorization': `Bearer ${process.env.ACCESS_TOKEN}`, // not required for query
         'Content-Type' : "application/json;charset=utf-8"
       }
     }
     const updateURL = `${process.env.RERUM_API_ADDR}update`
-    const result = await got.put(updateURL, updateOptions).json()
+    const result = await fetch(updateURL, updateOptions).json()
     res.status(200)
     res.send(result)
   }

sample.env

@@ -6,7 +6,7 @@ REFRESH_TOKEN=short-token
 RERUM_REGISTRATION_URL = https://store.rerum.io/v1/
 RERUM_API_ADDR = https://store.rerum.io/v1/api/
 RERUM_ID_PATTERN = https://store.rerum.io/v1/id/
-RERUM_ACCESS_TOKEN_URL = http://store.rerum.io/v1/client/request-new-access-token
+RERUM_ACCESS_TOKEN_URL = http://store.rerum.io/client/request-new-access-token
 
 #Make this value true if you plan to use this as a public API.
 OPEN_API_CORS = false

tokens.js

@@ -1,5 +1,4 @@
 require('dotenv').config()
-const got = require('got')
 const fs = require('node:fs/promises')
 const { parse, stringify } = require('envfile')
 const sourcePath = '.env'
@@ -15,10 +14,14 @@ const isTokenExpired = (token) => (Date.now() >= JSON.parse(Buffer.from(token.sp
  */
 async function generateNewAccessToken() {
     try {
-        const tokenObject = await got.post(process.env.RERUM_ACCESS_TOKEN_URL, {
+        const tokenObject = await fetch(process.env.RERUM_ACCESS_TOKEN_URL, {
+            method: 'POST',
+            headers: {
+              'Content-Type': 'application/json',
+            },
+            body: JSON.stringify({ "refresh_token": process.env.REFRESH_TOKEN }),
             timeout: 10000,
-            json: { "refresh_token": process.env.REFRESH_TOKEN }
-        }).json()
+          }).json()
         process.env.ACCESS_TOKEN = tokenObject.access_token
         try{
             const data = await fs.readFile('./.env', { encoding: 'utf8' })