Skip to content

Instantly share code, notes, and snippets.

@jonico
Last active September 20, 2022 11:44
Show Gist options
  • Star 1 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save jonico/34ebcdc2aabc40162fbef75e95a69ba4 to your computer and use it in GitHub Desktop.
Save jonico/34ebcdc2aabc40162fbef75e95a69ba4 to your computer and use it in GitHub Desktop.
How to debug PlanetScale database-js API with a proxy hooked into node-js 18's fetch API (based on undici)
import { connect } from '@planetscale/database'
import dotenv from 'dotenv'
import express from 'express'
import { ProxyAgent } from 'undici';
const agent = new ProxyAgent('http://localhost:5555');
global[Symbol.for('undici.globalDispatcher.1')] = agent;
process.env['NODE_TLS_REJECT_UNAUTHORIZED'] = '0';
dotenv.config()
const app = express()
app.use(express.json())
const config = {
host: process.env.DATABASE_HOST,
username: process.env.DATABASE_USERNAME,
password: process.env.DATABASE_PASSWORD,
}
const conn = await connect(config)
app.get('/', async (req, res) => {
const results = await conn.execute("SELECT * FROM hotels")
console.log(results)
res.json(results.rows)
})
// add endpoint to retrieve a single hotel
app.get('/:id', async (req, res) => {
const results = await conn.execute("SELECT * FROM hotels WHERE id = ?", [req.params.id])
console.log(results)
// if no results, return 404
if (results.rows.length === 0) {
res.status(404).send()
return
}
// return the first row
res.json(results.rows[0])
})
app.post('/', async (req, res) => {
const query = "INSERT INTO hotels (`name`, `address`, `stars`) VALUES (:name, :address, :stars)"
const params = {
name: req.body.name,
address: req.body.address,
stars: req.body.stars
}
const results = await conn.execute(query, params)
console.log(results)
res.json({
id: results.insertId,
name: req.body.name,
address: req.body.address,
stars: req.body.stars
})
})
app.put('/:id', async (req, res) => {
const query = "UPDATE hotels set `name`=:name, `address`=:address, `stars`=:stars WHERE `id`=:id"
const params = {
id: req.params.id,
name: req.body.name,
address: req.body.address,
stars: req.body.stars
}
const results = await conn.execute(query, params)
console.log(results)
res.status(200).send()
})
app.delete("/:id", async (req, res) => {
const query = "DELETE FROM hotels WHERE `id`=:id"
const params = {
id: req.params.id,
name: req.body.name,
address: req.body.address,
stars: req.body.stars
}
const results = await conn.execute(query, params)
// check if a row was deleted
if (results.rowsAffected != 1) {
res.status(404).send()
return
}
console.log(results)
res.status(200).send()
})
const port = process.env.PORT || 3000
app.listen(port, () => {
console.log(`API running on http://localhost:${port}`)
})
@jonico
Copy link
Author

jonico commented Sep 9, 2022

Node-JS 18's fetch implementation based on undici makes it quite complicated to intercept every call with a proxy to capture API requests. Using the workaround described here.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment