From abc8a0e8fb1a45f0635fe6106e6a6d30b9a34153 Mon Sep 17 00:00:00 2001
From: Lukas <git@lukasnotes.dk>
Date: Wed, 18 Sep 2024 12:45:01 +0200
Subject: [PATCH 1/5] support unix socket

---
 main.go | 37 ++++++++++++++++++++++++-------------
 1 file changed, 24 insertions(+), 13 deletions(-)

diff --git a/main.go b/main.go
index d14d6a2..7626297 100644
--- a/main.go
+++ b/main.go
@@ -42,6 +42,7 @@ type Config struct {
 	UseHostHeader  bool   `env:"USE_HOST_HEADER" envDefault:"false"`
 	LogTraffic     bool   `env:"LOG_TRAFFIC" envDefault:"false"`
 	LogConnInfo    bool   `env:"LOG_CONN_INFO" envDefault:"true"`
+	UnixSocketPath string `env:"UNIX_SOCKET_PATH" envDefault:""`
 }
 
 var upgrader = websocket.Upgrader{
@@ -81,7 +82,11 @@ func NewProxyHandler(config *Config) (*ProxyHandler, error) {
 	}, nil
 }
 
-func (h *ProxyHandler) ExtractProxyDest(r *http.Request) (string, error) {
+func (h *ProxyHandler) ExtractProxyDest(r *http.Request) (string, string, error) {
+	if h.cfg.UnixSocketPath != "" {
+		return "unix", h.cfg.UnixSocketPath, nil
+	}
+
 	addressArg := r.URL.Query().Get("address")
 	hostHeader := r.Host
 
@@ -106,10 +111,10 @@ func (h *ProxyHandler) ExtractProxyDest(r *http.Request) (string, error) {
 	}
 
 	if !allowed {
-		return "", fmt.Errorf("proxying to specified address not allowed")
+		return "", "", fmt.Errorf("proxying to specified address not allowed")
 	}
 
-	return addr, nil
+	return "tcp", addr, nil
 }
 
 func (h *ProxyHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
@@ -117,7 +122,7 @@ func (h *ProxyHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 		log.Printf("Got request from %s", r.RemoteAddr)
 	}
 
-	addr, err := h.ExtractProxyDest(r)
+	network, addr, err := h.ExtractProxyDest(r)
 	if err != nil {
 		http.Error(w, err.Error(), http.StatusBadRequest)
 		return
@@ -130,27 +135,26 @@ func (h *ProxyHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	}
 	defer conn.Close()
 
-	err = h.HandleWS(conn, addr)
+	err = h.HandleWS(conn, network, addr)
 	if err != nil {
 		log.Printf("failed to handle websocket: %v\n", err)
 		return
 	}
 }
 
-func (h *ProxyHandler) HandleWS(conn *websocket.Conn, addr string) error {
+func (h *ProxyHandler) HandleWS(conn *websocket.Conn, network, addr string) error {
 	connectionsProcessed.Inc()
 	activeConnections.Inc()
 	defer activeConnections.Dec()
 
-	socket, err := net.Dial("tcp", addr)
+	socket, err := net.Dial(network, addr)
 	if err != nil {
 		return err
 	}
 	defer socket.Close()
 
 	go func() {
-		message := websocket.FormatCloseMessage(websocket.CloseNormalClosure, "TCP connection is closed")
-		// Close the websocket connection when TCP connection loop is finished.
+		message := websocket.FormatCloseMessage(websocket.CloseNormalClosure, "Connection is closed")
 		defer func() {
 			err := conn.WriteControl(websocket.CloseMessage, message, time.Now().Add(time.Second))
 			if err != nil {
@@ -163,11 +167,13 @@ func (h *ProxyHandler) HandleWS(conn *websocket.Conn, addr string) error {
 		for {
 			n, err := socket.Read(buf)
 			if err != nil {
-				log.Printf("failed to read from socket: %v\n", err)
+				if err != io.EOF {
+					log.Printf("failed to read from socket: %v\n", err)
+				}
 				return
 			}
 
-			proxiedBytes.WithLabelValues("tcp").Add(float64(n))
+			proxiedBytes.WithLabelValues(network).Add(float64(n))
 
 			if h.cfg.LogTraffic {
 				log.Printf("Got %d bytes pg->client: %s\n", n, base64.StdEncoding.EncodeToString(buf[:n]))
@@ -184,7 +190,10 @@ func (h *ProxyHandler) HandleWS(conn *websocket.Conn, addr string) error {
 	for {
 		_, b, err := conn.ReadMessage()
 		if err != nil {
-			return err
+			if websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway, websocket.CloseAbnormalClosure) {
+				log.Printf("websocket error: %v", err)
+			}
+			return nil
 		}
 
 		proxiedBytes.WithLabelValues("ws").Add(float64(len(b)))
@@ -232,7 +241,9 @@ func main() {
 		log.Fatalf("Failed to parse config: %v", err)
 	}
 
-	if cfg.AllowAddrRegex == "" {
+	if cfg.UnixSocketPath != "" {
+		log.Printf("Using Unix socket path: %s", cfg.UnixSocketPath)
+	} else if cfg.AllowAddrRegex == "" {
 		log.Printf("WARN: No regex for allowed addresses, allowing all")
 	} else {
 		log.Printf("Using regex for allowed addresses: %v", cfg.AllowAddrRegex)

From f754a26446ce587daeeb4a97157ddb87e09eacc7 Mon Sep 17 00:00:00 2001
From: Lukas <git@lukasnotes.dk>
Date: Wed, 18 Sep 2024 12:55:02 +0200
Subject: [PATCH 2/5] add link to deploy docs

---
 README.md | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/README.md b/README.md
index 602bed2..6ca11c4 100644
--- a/README.md
+++ b/README.md
@@ -2,6 +2,8 @@
 
 Lightweight websocket->TCP proxy. Look at `main.go` for available configuration options.
 
+Read more about how to deploy with Neon Serverless proxy: https://github.com/neondatabase/serverless/blob/main/DEPLOY.md
+
 Run:
 
 ```bash

From 43a087995b63e68e5919d1a148f9a48bd0f1d054 Mon Sep 17 00:00:00 2001
From: Lukas <git@lukasnotes.dk>
Date: Wed, 18 Sep 2024 13:01:03 +0200
Subject: [PATCH 3/5] add makefile for common scripts

---
 Makefile | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)
 create mode 100644 Makefile

diff --git a/Makefile b/Makefile
new file mode 100644
index 0000000..740dbdc
--- /dev/null
+++ b/Makefile
@@ -0,0 +1,16 @@
+GITHUB_USER=neondatabase
+IMAGE_NAME=wsproxy
+PLATFORMS=linux/amd64,linux/arm64
+BUILDER_NAME=$(IMAGE_NAME)-builder
+REMOTE_TAG=ghcr.io/$(GITHUB_USER)/$(IMAGE_NAME)
+
+build:
+	docker build -t $(IMAGE_NAME) .
+
+run:
+	docker run --rm -p 80:80 -p 2112:2112 --name $(IMAGE_NAME) $(IMAGE_NAME)
+
+publish:
+	docker buildx create --use --name $(BUILDER_NAME) || true
+	docker buildx build --platform $(PLATFORMS) -t $(REMOTE_TAG) --push .
+	docker buildx rm $(BUILDER_NAME)
\ No newline at end of file

From 44956892b92aebdb6e7861399e06bf2d65a73714 Mon Sep 17 00:00:00 2001
From: Lukas <git@lukasnotes.dk>
Date: Wed, 18 Sep 2024 13:15:50 +0200
Subject: [PATCH 4/5] add neon + unix + drizzle example

---
 examples/with-unix-socket/.gitignore          | 175 ++++++++++++++++++
 examples/with-unix-socket/README.md           |  24 +++
 examples/with-unix-socket/bun.lockb           | Bin 0 -> 30758 bytes
 examples/with-unix-socket/docker-compose.yaml |  28 +++
 examples/with-unix-socket/index.ts            |  37 ++++
 examples/with-unix-socket/package.json        |  16 ++
 examples/with-unix-socket/tsconfig.json       |  27 +++
 7 files changed, 307 insertions(+)
 create mode 100644 examples/with-unix-socket/.gitignore
 create mode 100644 examples/with-unix-socket/README.md
 create mode 100755 examples/with-unix-socket/bun.lockb
 create mode 100644 examples/with-unix-socket/docker-compose.yaml
 create mode 100644 examples/with-unix-socket/index.ts
 create mode 100644 examples/with-unix-socket/package.json
 create mode 100644 examples/with-unix-socket/tsconfig.json

diff --git a/examples/with-unix-socket/.gitignore b/examples/with-unix-socket/.gitignore
new file mode 100644
index 0000000..9b1ee42
--- /dev/null
+++ b/examples/with-unix-socket/.gitignore
@@ -0,0 +1,175 @@
+# Based on https://raw.githubusercontent.com/github/gitignore/main/Node.gitignore
+
+# Logs
+
+logs
+_.log
+npm-debug.log_
+yarn-debug.log*
+yarn-error.log*
+lerna-debug.log*
+.pnpm-debug.log*
+
+# Caches
+
+.cache
+
+# Diagnostic reports (https://nodejs.org/api/report.html)
+
+report.[0-9]_.[0-9]_.[0-9]_.[0-9]_.json
+
+# Runtime data
+
+pids
+_.pid
+_.seed
+*.pid.lock
+
+# Directory for instrumented libs generated by jscoverage/JSCover
+
+lib-cov
+
+# Coverage directory used by tools like istanbul
+
+coverage
+*.lcov
+
+# nyc test coverage
+
+.nyc_output
+
+# Grunt intermediate storage (https://gruntjs.com/creating-plugins#storing-task-files)
+
+.grunt
+
+# Bower dependency directory (https://bower.io/)
+
+bower_components
+
+# node-waf configuration
+
+.lock-wscript
+
+# Compiled binary addons (https://nodejs.org/api/addons.html)
+
+build/Release
+
+# Dependency directories
+
+node_modules/
+jspm_packages/
+
+# Snowpack dependency directory (https://snowpack.dev/)
+
+web_modules/
+
+# TypeScript cache
+
+*.tsbuildinfo
+
+# Optional npm cache directory
+
+.npm
+
+# Optional eslint cache
+
+.eslintcache
+
+# Optional stylelint cache
+
+.stylelintcache
+
+# Microbundle cache
+
+.rpt2_cache/
+.rts2_cache_cjs/
+.rts2_cache_es/
+.rts2_cache_umd/
+
+# Optional REPL history
+
+.node_repl_history
+
+# Output of 'npm pack'
+
+*.tgz
+
+# Yarn Integrity file
+
+.yarn-integrity
+
+# dotenv environment variable files
+
+.env
+.env.development.local
+.env.test.local
+.env.production.local
+.env.local
+
+# parcel-bundler cache (https://parceljs.org/)
+
+.parcel-cache
+
+# Next.js build output
+
+.next
+out
+
+# Nuxt.js build / generate output
+
+.nuxt
+dist
+
+# Gatsby files
+
+# Comment in the public line in if your project uses Gatsby and not Next.js
+
+# https://nextjs.org/blog/next-9-1#public-directory-support
+
+# public
+
+# vuepress build output
+
+.vuepress/dist
+
+# vuepress v2.x temp and cache directory
+
+.temp
+
+# Docusaurus cache and generated files
+
+.docusaurus
+
+# Serverless directories
+
+.serverless/
+
+# FuseBox cache
+
+.fusebox/
+
+# DynamoDB Local files
+
+.dynamodb/
+
+# TernJS port file
+
+.tern-port
+
+# Stores VSCode versions used for testing VSCode extensions
+
+.vscode-test
+
+# yarn v2
+
+.yarn/cache
+.yarn/unplugged
+.yarn/build-state.yml
+.yarn/install-state.gz
+.pnp.*
+
+# IntelliJ based IDEs
+.idea
+
+# Finder (MacOS) folder config
+.DS_Store
diff --git a/examples/with-unix-socket/README.md b/examples/with-unix-socket/README.md
new file mode 100644
index 0000000..afa756a
--- /dev/null
+++ b/examples/with-unix-socket/README.md
@@ -0,0 +1,24 @@
+# with-unix-socket
+
+Run Postgres instance with Unix socket and connect to it using Neon's WS Proxy and Drizzle ORM.
+
+This project was created using `bun init` in bun v1.1.27. [Bun](https://bun.sh) is a fast all-in-one JavaScript runtime.
+
+To install dependencies:
+
+```bash
+bun install
+```
+
+To run:
+
+```bash
+docker compose up -d
+NEON_WS_PROXY_HOST=$(docker compose port neon 80) bun run index.ts
+```
+
+To clean up:
+
+```bash
+docker compose down
+```
diff --git a/examples/with-unix-socket/bun.lockb b/examples/with-unix-socket/bun.lockb
new file mode 100755
index 0000000000000000000000000000000000000000..c42cd6656876272602503682871083fc5f92712c
GIT binary patch
literal 30758
zcmeHw2|QI@7x$$rLxY)ALZv}mv&a}3nuulz7Z=yuy;np<lcF+YXryRRH0VhxrKFHT
zG*9$IX;3O@p1!ruz5Cu%ueXQ1zwdkB-`D;<``LG&b=H5cz1BK=@3Z%@8m6Wl&Sq(Q
zF+;Q&Aq!Q#!b2n=YXyaR2l_ID7+SuetYA7vYoU&WFoi-H<znzEEp_0FYImiYz>VW{
z3`C!b1*p<n*1WM~-BaH;A|nEBg5<<4C}KaAvAlY!Bku=MNKq)U_VB9@l-f`ZfHDP2
zaVQ<2S#;f;S6+g$FVw^Qv^a~x80@rO6iR=nuYgh-%7sw&gVLXOJ=81Q7d7I_t51Vc
zg3Heg;TThf0}bJS7okuT5r1zkei@WVE)OWtb#GA$MFz?mC=q`dl!%YP_6lbP`A`hu
zBDzlnN(CszdF31E1gbai$_r4+L%k46IVgAV%5}Ull2`ih%4xjPj8~50mGV%^0>3b?
zd<m*X^?SVXB9utp<GgYYuT0~Wt<Yc8{#__hKmS+z;SNSe{q$jYh5LamgW1U16v{xz
z$WB|J1Qo?rfm5Lp`bu2CxTr&OukjqIq!HPR<FlNLCrVN_OdD}{!O4DGN6)^{WRqn0
zQlXvQzAi=Eb^VB=<|g8yW);tzx11c2S+FnnnMQ!#ncPB$>Jb4f>r1f|wtMs=$F_Y}
zvK~+-)(sYSi@vecspi<<=QnF+onLdU*0rNfDY4Gc&|2Lmx3|4zuy3vBfnoIp!3nec
zy!z)>?{?nU;3eOGqN}(6&2dBY?dVUU(uX>p{>yS<%(u}QQnBOp=O46v_`G;vsp{AI
zmEVtMeI6hmA~nq1CPMVhvHEN&<@2MSIt6*=e7})$Vtl?Gb3V&*<hFi_6P{)rTv+L1
zQ8#9=vUG0NAf4i?PrY3)yo*&?ylZA^s_FA#0qeJ{@lyCAE~z5-PD5stzR=p{?7J&`
z?Q}EloGqiY*^hWCY&GE1Cta6|MvM!h(>B^Y2`&?pwit6<D6M)8b-%xd^ti~JeM<w{
z#MH0oSa0z-)>~58Xi9Za_J+c!vyW2t$|~Bwf1JT-&$fJbl6k^xuR-tN77vFV)hiXx
zsW6o%86COx+4_IAAB~M?GV}FHOcGa63?2-;Sh1_{{Pm+ZlN>Jg9$hk7XIV$|bHAE3
zGOa^*UfQ&1d%zXucJ)}zF{>C}Lg0TrNoW*C$px|{_%r&ghW^*Zg!#{aAd`6f@LW(}
z80b>M{NnJ#0Qg}zLE|6=hRH4^%s(A|SO7oL2MncMPMALhevAWt7{kzffaZWMCCq;l
zevAix)NeFabhrNlU>-3Bek!k3jQdYQ;QMlbe**BM{-ca>y2{@I{K$S#bSvTZb)Z3O
z;74`TepeIbX8}Kw|99Ij0)8Ff$Nk5+|0D;#ujQxq@%66qYk<Mcc<m#e?(+KrzY&SQ
zt2)H(Yy*D${KC}K?e-Pmftv{JBRur%b=QBF1Ctf-gBpodT6g8Y0{jl7{sT;x67K&%
zc<7P*$bV4A*Z&Cw-xm)2Q-L4dkNOU4sxBqWe-rqT{Sgz=Uw8X23j-e>zYs6RMR>nT
z_&zt_N8<;&7uGLmE!L%k`KQ3*23Fazi0OCuw*o)b-|z50=^?)%Od36De|Zo2F9ZMN
z9_Vi%OghMae^>wBJ>=itL;klt<hOvAte*6Lbr1RLddRN?3x=M^?*;t!J+S}29`e8H
zA^%v(p2@!y_-%X8|8qU$7lRkMp0q!;hx{9W--g$J7z(>Re_RKCG=HMG56wSaO?dnt
z0q?zd{($#>Vh!9C49p(}{CNKO9sV=GkH_!d;qMERPEYvf_K<&15Bc8!Kb}8+r~ekf
zgvX!X;a}ZD{<<FWE5U-LC-QsskUzhN{2e{yH-`mhPx>DR{CNKO9sAexkY5fqC418T
zydLuB06!kTf2aSCd&sW|o3%Y@e?brVi+afa8Tj>J{-DC3kLD0~o#|4-<G&WXbZP=W
zs-yQ8gwd6R`R4+^A@Cz!l*PNk4EJFEMBq0i@ek@I{}tdj0DgFlBHsUCIoqX#+m}(|
zzW<2;7n*<Z^{#**9+Z*Hs*q9t)gU7s4u^~qD$#XyRDpy_WFycykvc2U{aQTwuS#Td
zUC2mgeaMIpbU`FkqU%Py(wMkPtQCk~s1A<~#gTXYf3ZaUn+6#k0g4~5AODLbvYS6o
zepI456Ef;wAg>+-B~E|*?*Fad{{QKB-z2{w$NWzwz!RcyammnBhs7svE2k`+(xEx2
z&|K||+TF)aiz?y+Q&L|Xn4e}|#|Ze!QQM{2_GSF^hWYtBRSI5J`H1xOTI?}ee9Tm@
z1=5R2xX4yGQU6kNJ+fD<DF0Kb<x}72hLcNmWcK!M<g9Ep+`RCh_bpw`z(=7T7tTBk
zuNt?0T;3^@K-rtypW5|NO!;u-jzha*F$tGEPg1`#_H2@`q*d1EkFA_nFxBt;R&QN1
zlhLMY!*|NBy}wMl`GwYkq!&@@Z64F|->1)>S?ly>`?Z_na=!(<ww7CFP({K;V>(XM
zReEPOP5rdC@?8G`y%fxf&tHxEP_XxqOhtqD(YD*PPoq8^cD}iKPTjQaYM$ctD{s3#
z5V5%xGvv@~$Mu)L$xw>PxM<A4iF&x|+~aFZPs{L%$T8!EE0UdxT@GKf9Gk%Kr>~RS
za*wmC%&3kXW0BACS98`W7fLzDwn*B<H0WiKAri5`b<7r$yySOQ>WFFUOdn@+tR?cC
z7o_H>%!-wp<*)yu+_c*A!P|wL{IPovtF=r^cdQw%U9xi1+(ja8+G`g7wL$IugEN!m
zeV;|`BH@zPG1LVz??<E^OWWDIU{6No-5ql!`WS0Sei*f_eeIB$6|GnHI@QE}?8mtH
zQDKQzQdqg-XIrr?4^#`RXFj}gaFy7n>scgRv`)Z@y7t4o^UKWNOfAi@{B-fk=V=^W
zyLUdrt{$JP9e;1Zw!hs+?fjZ$C3e-}3Mcpr>+p-aDihmgwhE`dxG<q;U14x#D+!mp
z?xBhdv&lTQS)6k?R`O^}y4)>hLELf!rXx#V&d#(nQ_g<CEjf|*N@t#5Ovp^=dxK?@
zT2*UseMRc^tVw=J3UbODNw{cF0VnF1zd{abs}_k|4;y>CsD9Ecf6t7p#$9{fj!E!5
zX#F~Bz_Sg<C0D&JHh$S>@ClWGeS`MsJ7*OY-YkD5T*9)N85c&vg>6rMqKe&&OdMS@
zVfsUp!&lZjKbm#Qf2PQrw)_GESN019!yKEbo7>Dkm9yeauiC{mX}L$fS{$>gWc;8f
zE8A2e--jPjB;k_RUsUrYVJEFd2wi<<T;l6Ga8KIf#mP-dHbR@v<vnO?X@A>suVs#_
z34O8$Yn=U@K*if*YwV2c+j5qdRU{i;eD76dM8fUImln>*p1#`<XK!2FYns?88cYA4
zcd~SLuuJ-hR$r62jn-oh<`(Sv61r+=WrAmVZSKKo1zQK%*PSVNk?OW0DERf6qwYB*
zT-ZM2Co1*w)wrlvEha_DIp<rNeBAR^mdg+LcBhZ>jp9d<B2(nb>D%`1{%fbmi;|&Q
z^&yiV6<ic4wLGBwV2gzD%PT^UE|G9yTZ^BlbH=y^(+)ITmf4Ve)@9b)4f^}r+>0yD
zW@>DZ^u1twR%O}!){<#`_S{+RQs5Ds^~LjzL!_U~4Sm{ZJN^A~3CX!6T-Yw+Cu$~p
z%TzV5<8i5aa;N4b7ey=+id@~V<Kcl@{kC10Rp%+C6heDsS8g}_&Wc@AB=@bZx*Vfd
zUS#QV<0VxgTjb;UauP0V<M0zzQM&I?>q%LwS-qxj5uZdYDU#k0$I!}B{`#o=WIg@W
zh_k(WeU$NCaG<09LW9Qcg^{OPpKWuT6RzlXkRj*($bv({h3yf3qNZN0`FM8x=A0Wx
z-QK+&Etj*~#B{Pc?Ln3M{dbnFQ)bNgwr7xx(t=&NcOwo6Yebk2`RurIaQ*(q72_C7
zg6`_Rwj<%9cSW42haVO>nio%zckJWszz(R54l43#YmAYREi7_V8kRel?Pyc5E8fcE
zoVCvFs&N(8YL>zeMqRn`O7`^1Nq)=311^(rVLO1Is0AHX+a;~T$4GCQ?DyCFjQM`7
zyl1Mjk|U}z8&(K=L|3<(8a$tUO#F1vn9;LNU-3QBdrjQPzy0%Uv;%wJxv*Pv9|;#;
z)A@;dT>9F*l6$pfdUV#tH<b<h1GLMpEzj0nVVkvq9_?Z;b9=h(-w(fkdJ-K~yh?q@
z%L%@#mnMWi&{+S>y04<MW&2GME?UFmM0GJ9xaVm``VqC{0s2lw!`T^%&KBbo9THBS
zk8?jTh~4XBgyn;}kKRw8R^^$!WfT`}Oy9CEzIEm)1ru*Q#RZXVBwVzn#)&HXs7`#a
zOz@r@i9w;y99NWyT7;@BJCffvDy4Gc=24ZeTt^@G@)(zFDttWbMbU+ccDdfmx0uPV
zGOye^K+lX>wS<HVuWS57UGVI1_Tw1`D*jqsWXf2&KD_8$wU6Uk_3^PZ$%8|uuawy^
z<8AIX=i9>e7jC#re=X!=D)eFR!y<>xGR=LS4)hS(1(Q2Kqwkg|@EXTY)QD7f=0dk2
z+a+t(otPDVy<tY?E%SG;Grqm8*Lb*KTxkE(V{7AQyw=^{Ke6>(Qd!*NqemuQ*;clD
z{9MQNuj+!bjuP^6anUycI8o<n`ac`u9+o&;WvN7;Qzj+Nei{yK_jQ~#C-n0^ai}G5
z{FWo%_4LP!i3jNio>-~Fn9R0YU@&^ep!(V!ZgzJ9u90xb@43{>@Kaekrtg1dqxnJ7
z`)>N@uQo{orJj!yx^;g@c6HvXq}jze(Y;ms_O1N7-EFS^wZG?CFRm><sCK5bt>)~A
zZ>@<0E|oaH9gKyAl6rARoeE7#x%H_|@56C2I-YN|uhk2ewqDrfxjES?_f5YHx$tIL
ziL=|ovJB!h<BMYAQ{<xjzkR4Fo)^*2e$!GX9xhU{G8uQQ#TfNUwE?CR4CfEg+1)QN
z=j~mychyoiiwAt4WgPxSH%~NCXzdXpUG?VWPpg(2&?USQ6WMLPS$#uyCgfce)#Blz
zwaySSZm697yv?H1WArC8ou<6`>*Vm3kJ?$;N3Lb+`*2cJgl^7>wO8M`&c~_r?AwOI
ztEDfdo`^o4vEx?s%7-_se8p>|c(}2EsY1pLzae6uqva(rFn{fb5k6A>!X`&fJgvQX
z{co{xM#sIF!O{oW8}}-yp55?d$&5$&vt4Hz^ozS<k~1>(^aQ6RTN*70T#A?~V4{o@
zHG1Q5`WV{yw;$MwdMhNaiM3NL_YYD%vp+go*Ss!A_wZzqz{02zjw6rmm3$T~R@|~a
zdD3;J>98H&hp|1=$0t^BafOlps$ozlsh?|(UGvs#^rRLIi4UBUP=6rECQ5C|MfPr)
z%J$Z6kK5Dx&TUlL`+~BeTq*ZyZK|~CjyEHBXuIui>^N4g_m}8Q0yma;E{2kE=djxs
zjg&U5iZx=@Z8#Vkqh7CY+U7~aehqPvo%Dd^%^&{0XB4gaD0uALv-j=1oEG;>DY07X
z5N~3u$+Az9eJ@AgQVHB)WZc_v&%->@v<s7kTt;UG-YUI(j8>)B-}^!I5~l2#JK6do
zqxN55-<}+*mbQnv_4OgjTG_R&^Q6Af>5aO>l$V8a=L?D$TAQK$5}c?-A}MB{lMgr4
zZ&C;gIGnDWrhRPedFr!9qvsQJvfUz*@AO}i6g1eQ^w_ZGmaMEb(X8wDf)^!P#eW%`
zxJO*mM3<{yG338^{{>-FUwJm9H&^v4{Zu<^j=D#4R-x6}yxKK4miK9QOD}&a+O($l
z{n@bzI<#B*-oDQ(7Du)2ZXT(;tMA(pnWoO|Ims>rE_d)5frUl5F{4gS(X&j@OE65k
zHk_)lCS>}HHC687Z&D@%Z1R75kCrKsJKRU6VdI+U5C{8XpE+~BA2GfErmVQvsa~$*
zcAl6_;EGXV0c#`~*Y#UnZ><ZGpXyD_%^WDxCm&01l7IKCe17qc+Nm$5obn!K*l>Q`
z^ADk?8lz>TTj{B)*7=LmFKS;YFE>(69eI#Dt`oxpWfU2A%?r2BkDOZNg<P1y%3Jyt
zsw-Q}y{uH{zcpu!=^DLJuWe_@<m^~JVpf9m!=$m9V+$VHY&tmgZ`Dond{q>i*A+hD
z$&37VG#S@&^?`X3#Y4}#JB>FS6>eOAB)9tP6P1!X?%SgjF3YM}9O;NYHRw>G1E=7f
zR?gvob9WZLzLRHCH7Qm?)MG|a^b`V@B8J8X4KnWTTF;8<y(&#k+>A<6D%jfpY5#?1
z4`?X9mUOEc9a$z`ZkpJ}F+DOwX#3!%Nmta*tr<>t{<MGL&0&3Kt{ZCoC6)U=L=lSx
z%rRu#l(8PR=X3gX3=aHKViiAf#ndgQwyzi8rM<s$XGUp+?VyhZPJwo-mzk~H;=AGS
zVCy&b3M|^2;3L!Dy$F6a`=#n4p1f9oiTCpmJT=*<e1a>-E3Iy(>oey@+o|yxI}_PT
zyBq6csMkU-jha??rkYa{@W8}pt=d@O?FSxh-k`g<S+Q{Bi?tmK#(vew<l!Ry;(b5@
z*Eu0)-_w07H})%V)=a5=zrO$3cg8yF1Fi&Wx}K$_&6s89T0kk9(p;{Qn_Xq?A%7r7
zxS_`BkmJUFUIYD_qm#Jn2VvqlrXfIHqJGb)OfJvOcUILXnfWp9O=AsxZq)EL&+=*K
zjl+UDLT`_imKd3j@M;;)^vru&XsQ~@h#kJRKFs9w-nBPl-t9Y0$jg17*T$ewQYniI
zPmi_O{!QomxuG%7&7S2kcSWzd*LP!ZdB#VT8_&J1?zzY0GTY+j3ajtB=}<(E9HM^X
zq<!_{){g!)Wh-NRNw_*>T$Ru(&p)0DtXq5I3A3ZMxvYTx@bl}s7>yavr=Bd&inw8#
z_bp22bHE4sy4Nzy{JrX)o4>kV3~YaHx-l!{;^>+v5-!?D#fj=q4Oo6?%#LZ^SF<Ea
zBtFK>6FF)1>0#)e_%!R|+v4kjBmDYCmnh^v+T?fVw$xZX#jt@jvo3vazvLdb>DvIY
zze7mt64;yPC+gyfrNtIAm5g#1XPPegs%qSSjm4$b8LaD}Iqea1jJ`gOYFlL(>2~SL
znOWLJ?8BwszBJ}ETtB#pZs@X9<+=Fw&s={X?1uJxaiZS3l-2u$la;1PxXZ-dqBFci
z^M>ivt>{-*q$)a%CM{}d>-On+s%Bb)i{a}2Wp#21qE|CdQsZCNPnXEI(+!9pLc+!S
z#|WEBQ*UtVr+F_S#m=Pofcr+Kr|iVCSa&^R`{hsi&#Qg;JbCYI#-VAhl?V3Qi_4eD
zj5)hF^yo6t!HLRSGlvN+qM>nD2&|9BbvPs7C+dS;p>nHQN=18#N?M)xyY6;;#a4^S
z&*B<eCMG$R&;R`W@RwBiQKOU>3>JOTt2HEbcEOi#V-7}GONxqqQY;A%N#@}qe6+uf
z6V=jI-oR^UROIb55g%(0^s;0J-&$tbxY@S0WyAaYrnpxf%8jeP9aNY<eqSG{@3IwR
zCPvg$$==;P?zB_Iw1kxh&3L$I+!>2Op`?oD44Ks1vv5j9pY=Nnk~Vq0oO_RzQn6jh
zDMBOeqnA{acK+Eb9=?k0)BVFtKEI<RsIxctPtxirpOZ=})zI1B&clrbEW8ho;Hl07
zwCrb3%%UIis6D=C$@tr=28=asai1J-oDg>_Vn(aC{N!b#yQh{k@7$cNKhk#m!?eJO
zoQ#MD(KicqW5px=c<V`GU1EX&d5LOUe1D3Hi|fUX6z0}<7w;=JeZ3#OuHW4f>bizr
z#hP~-WZk7w5)1Xjn-8>#EI4$=dX&ZBPun-G9QFQMm=C?YF_e&(Laa;R+gg62e)zEa
z+THgqe*2q(OMUWUZ|}Rma#Q-Ix=qRN)k<BaN~JEcQA#~B@5m*Z>}k(daoOp&B*G@<
zHNDuNy8nGz<tnBA1TJ@70%tz_M9o}ob+<z@!Lx3ha^PscOoPYAl-`?}@45Dz^FBWO
zfT3M|4X5PO2cfz-ck<4Bce~N>hPnLw;-=Jqy+uuCZ!4R)>nQHJ1it0tC#uZK=BjmT
zPfWkhX@9OXb7r54!rW=L3ZI!)Ix(Jy)tHO7f6usAlbtozeOii2;se^`$n6Uq^R!CZ
znr@i9Z`rR+UYD5jQNeD~35tHJ7gyBz&uA=@71?xaMPyv!rwSv*ed^VQl_HascQ4-=
z_kG4$^I$zo<$3Cx&71O%9bKYQRp!2^k3`NZv*ld<66+H9c95T_jgGgoZHsO8Xso*B
z5OC;*-{DuiH<$OGS#mYSwW(HP&bAzbC$iVC=Ji*%vT_qrIWA<o<!zgAYudDwYWJNA
zLoP-WxZJ@9zA5D=YM$h!q`3$0jhvRION|eB)Mxb;^UO)L_j-@4iyHaz)1a3hqWex<
zaa<#*GMyfHXXmV&2eWhL1w0o?aq);MN-r;bOyF|YC02Y?(8I^nmCw?L>oj?6Ra)jV
zajNN%cLsS5fv?Mr&mK8h`K(5G(FV~^Ox^sjj8z4<(sh=KYord%9eTQL>d4!+H7^bg
z7>)G+nB&Q~jq|*1PQ2YI>?wb8dF%9@pC3IqX7bmT*qoL1o=&xL!d`yoH?}lY2*(e-
zI)CegtG2VeQmg5gH(Pr~l^15tQWl@XlNZgK)?{4AK?9ouS}i@&RDClpC$?49U!gvc
zby+M_dgsJD2hU;RT4VM{)kPj!a`N!IVb1jr%2f2%t~=6aiA|qA8sk&as|WMsMdO1F
z8Fyu#eDePC_;Iq!V~*d*&OU5CTft@6`K0EFt2f6)?}+le<vZKKZ5{nguc)ZM?9!KN
zwG1(AQwv$u61}lSe!Jt;dpz7&z??wFb(*1Pu3C1X{Elf9yZ87dPn>l198%~<sXmm3
zyVw3Q^WB;+E5GK>(6!BOV~%AE7aBEv*W3#ePo&RSv)*Le!q_EPUMs+~CF2g>TXlBe
zjrK<e#Kr4OEdv%zZE@Z--MLTG<6UNbJ1%LetO%4CI{wykuR}XOm_P4Gl2@o}{orAp
zC~|QWP4mcQhe)2hNWXSuT+tHG>k<oMD4|Bj+SRYyL@Va@T^lZ;T60}bQR}$lIqU3^
zx~8vkM3j~$j=VaiP;1n<oeD88baS#aq@Bd~r@fLOaJlOedou3GO_#S^{;nan{!CNt
zb*<?hGZk{@ZPVWw<=*s3ZS15u6Rl5HD_WN9?l@;qZSbb%$*$QNt7LbZd5SFgR?kYB
z?8TioV~O)L2QqF*fUviErc}wRe!}v>)ko|{CeXx<T(7U48uZpDR!Q-7@1Uy%4*j#v
zvF{gVI_<rXXdGB*sy3xMBtm=2v!SVt286ua_0B{xu1rZT`}JqLBZ@xK)-t1ur;J{g
zI(2h<d)aM;rfb<k%O(8lJBl|>IGVL^Uzyj?`|4*tc*h51PCD3Mr!La$N^IUT67D22
z?vuIf6NQ(2f~#&Hs+pmx9_ip+d(gi^sNG-PylU0Uu#?)^vsRBd^!%~>h1Rz>E%Vtg
zR2EQL?K6j+IT~%-;4?jqgbUv+@e_3-%Q?#M=_b*!`GePgU3vUVN`|c7{Reet12<ke
zD%G@Gq;l`g!N<#urR{`sR@FFG?;d2;QaVF(pinOr1>4VI&+JLKQ~0PbKI{)KT@%~5
zq*><cM|XpozzIegIWBgFif*f8Vvi3GTL8OHMn_NUE;FjgR(XAWc9GfbPmj{qOw932
zcW_u;ed-~1oaE|vDjB!&YW;?<6N;>!*3QuzGt_KXU~eCxB<bCaC#`Cek}urd;QD@6
zgV5^vo(oI+Daap4l@5M;`iA?Qv*9)xYix#J(@i1Ci_g6gJk>B%=;CT?hq?mB6SZ{>
zPd=o7G<NP7XFTq3uD8@4<G7YZx5sT&*YoS2xYS8<ak^&ly&Iux<G)2)_}*!o|My2F
zwEz1j^-KdWd-4Ak6aE;L<{iN98Q_1I8_9?NM$#D;ws4LT`yX!N58Qv52L9Omzsw;2
zgW{kyBTBgB*1GrqKhsP1^!4ZNKN|R>fj=7fqk%sf_@jY88u+7uKN|R>fj=7fqk;bk
z4cy}G&C0>wC!-``#%6ibm?3NqJt&BVBh%4luow&rRXrV5HZzJ5>Z_@0ph^#7`h|r0
z;%}$Fedi_wg3fi(do(`p$91&FgU-GY4gYPF6|dpQX>bvegju-0o(16lo0bqS!a;u<
zfZp@{A*1g$&^H$7dkFOHf+}Pt<N(MB))}%3<mr%SK%NPC7UbEG=Rlqd*%k6U$ZnA5
zLw1Mk0ofBW9kLf>Z^%B78IXM;Bi*4sqVEsXAP<8)9I_u|bQX`kA3)zkq3@T_w??BN
zqi=Z7_crL;7<8_Vbc4QUL3%+tL1)b9JQ$tbqH|VsCW_84(OIJv<nfTLA=^Nn02!S*
zq4ObhmV?e+&>0Cj&p>An=$ruU>F?#~b`DYkq<_*e>KEddf{b)61es^v|0_i=XipTf
z2xMgA-jF3B_lMjMGVBMVxN^kbLBjSh@%Q-14#@V%2c#j(L6(6m3wZ!!^lh*rWCh5`
zSCG#jy(2pydmy_Y`ye|Zdm+0aTOykdg^cX03K@O#h`y&p-)f@oK+!j*==)VA$Vm4{
z4rB*p4`df)A7m$FFJw1lKP$+{p2)7qzR1qV-pKCA{>TrIUm*WLeuR7j`4aLoWLs=k
zq#u;m@a!6k92b&=**ra?`QgU!#2WFRBVEB0i|h*ei`~wPlO`qPZb;Lif%;HS5Cun8
z6B7=ia~N!n;Jg6G(i20DK_sMc&~Pk{>L)DZu0u1Sf#667V5?Xh_m80H>qA3feq7#1
zHch8zu9lIJ6S6Qzy@tQV3t>c}Qn{ZS<<aQPc5*_<Iw-LibZ-!ZlKl8qqf+wuG{mDz
zFa<7RGlCX@Z%k2r7+!WyR=^Xyh`k^P)Mnt3RQ{p$p*-S2TBK0mIt?9rL_GL1xp+k{
z7J-H-Ob$bzlAU<ghNG2{geb@g6iQeqo8!k~u!ris&c8K&=oCajcA-#GAd5p!aYRFb
z1Y39%9HUM^*$EV+9h&5e)i)kK+(<~EPt&9690W>VpbV5(mtHn(dNn~IdRhz=cmiU>
znFp`h+uF4Y&?<of&qwUgX^I_RPYb&XDA#$E_5jBXs;iqz1(aqU<@H<5yf|w1N7N4T
zI|}7BWO(9YORA6BiEXx<C*VPY0r*es!Wo((>b0v95swbd7;K8Z43+`PyaKT~4Ccxp
zIU#plngI<Sh@n7%=P}mS)?wXZIjTRGM;A!wuTSKG66@iXB)YRso#-hc0s2l8QKY7N
zY<%sKWh#)slSj$<5TZl9Ffdp^2?xpm;1Thg6nMYSm<I@rYoDKelqUhSv>tfi*^Ny&
zb3*Fwz2;Q{o;^Iu=n3bnq|5gb+Tr@n&(;<eGN$S3(%^B$ky3HwO7M6Cc(OnTIHoF&
zaVgCAYaDeIN5K?OaQsyq4^voZsUc0zh-QG=AtI{c2$#Y_y4+?cIOZyjfyt#Hxp7oh
z93>Ob;88@f;rOjMo+gh1;{lHFiX(0UMUMteQ7AYDERM+uJw<3h!BJvy)J~v)sZl#P
zJ}i#c322A{!r{|C9HEjJDRfO}V<|XhDvn`Ev;(6Rg@U81;wYC~9@HTmUlzyv1d1Nb
z5RFJU!Yq#XNua?q2R(&J20e2)HYiXGXk$@3Wk8Vv3XT>E6r^mR{HxSUp?PDPo(_&+
zizA8xj}Aznr%Ndl<v#T|wx|FNN4v$*M+qJyLZdLr$$$hnt|wK9*9-+mn#GYn1r!{M
z7RLq^P;j(b96eM(!SQTyd{F@fN4&)mNCgyO81`gAHXNf=K*3RSaTHSl1;^FJaZUvk
z9C;T<LKRSOY+f8IRY1YfdvP>X0R_kR#qm}J6dVB<M`RUHc0hm7ScPM@3Me>=Fplaf
zpx`*eIPR-}f+G>*$glzmj#Z3f#|kJonlX+pE1=+b$2k71fPy0;;|R3^3Xau_W2b^w
z8PN1$2>BQ9l@d~x=FVa`&M%I;N}!q0boD4WqVW%&NKiWUM1s<(ClZuSJ&~Yv>WKuU
zQ%@u)oq8fc>C_VmN~fMkP&)NQg3_rc5|mCok)U+yi3FunPb4UvdLlvT)DsCxr=Cbq
zI`u??(y1pBlukX7pmgeq1f^3?Bq%sqG>+a2o`~iWn4o`NBcVA9rUh7v;7HOqvM<aS
z#xRcR>U1)nF4cokQIBT)?`PUN-uhSyz1%_i@nx6I2wuow(QG3*3|0s|XgY_*4Dqv2
z)fFtEjRi|+f}g|oCd$&!a=Te+$#N*LJGv&>xYMjnc|kFU&1SFwbN*G;WiGyxKlFx$
z2AX458XHy%MfU$@#gij3f`CEqWw2(~?QF?T+z`R!_-loSFeA0t5Hg;@A%e1dvzTEV
zE8?d%M3eVnF{7d&mV6+SV->;(4e_CK=w5U-Lz^o~5QELew?MRce-0;%Jx*Jj#qeXY
zIjlvrkg(tYHZ7Fpr%k#`TZ>%N(xIU>JdNWQ#cMXq4~4NOL|{aQg=)dt8dlIeBC%}e
z{pK#Zt%8_d@Jrh}h{*`yScS2e>|i>t<^{cCuy_diR*@h*jTwq>1zmbGg0%5E+$uB-
z02o1xU<SypO%G#QLB$&k=Zz4w!~6(2!h+}_46qA5h@p+uVZ~wkczFkfhWn5dgSGgh
z4D<-L7TYI~CxaHthpmNBtO#!3AUcbo9TCb3WU$y=6@XM)j1WI&2!nw<NE@nLh5SO<
z|ISpPd4b(P@$g!O^!_U(t|x@~0V}K$xeHU0twKV57;rs|70L<q4h{MR66r237Ut2?
zMGK>@$$^>!Zd7P-pHE!_#0ied^k#Au_6r%vw*d^fszoe?|4ALt39dp2Z4f`T(286S
z2?4~A@L;f#H})tkI*UbL#IJcR;xOp^8d#mdufXyfo^5&%{{o91;>Y+!SAM(^X_WUi
zsYP&tQqkMeuZ_!R!L5^F@HH)B9o|(W)G0Cws%sHz{H`JpN+LrL7rG<`dLaN#R1p0q
ztkM-75@sT|Nn9Y>{6`GF(Gfqt0`2p>;#ci+U%R-B=mm`6()|Zb;gJ-EWZ)##;DOdN
z;JPC3RYHq95Hna-_%?9BU~Ml}C=8ZX_$CCzU<boL976YDuzn%$zu^EW1ngjJBkrj3
z!`<GYEQVG%hZ)57V{o)!^b8I0W%~W1E%I&90J#cJ9E?LqOR#wo8nlq16&C2H6-*Cf
z{{rvlTLJUuON93SaUddVP0%ZV6I8%)(8dc0$PNvMDF(@=#SRY(3uSSBA>zN@45<Hl
z5zLHU{SZ7jx-U#`zO2w-!F^q7;YVa0u-QMk9jPr~Ce;Lw8u2gDaQ{)2UkJfdAb?<1
z@?JktkFe8d2Qfp!BVqgu{^?4jkpce-J3J(mtwp{P!3@#Y`{9ZYodp+vxWt8K()IQD
zNHC#$v3-8HiwpI`U36Fug))79kP2TTOW_O08$ZMG`$LkSdo3)?`(LiH^-Xjl`O=|v
z$<KIP@jyQ$US3~+yod$-@hTSa$E#d{f<i+>{7A6etFWx{UidFpgPCD$BLl{-CVqZ5
zxHy;t?Em8h@M~hT1G&L3+~+4ao>+V|Uj6sLcs=KX@#@_L`$4$?_Cvk9U_aOoz<#KA
z7mVy7fJLr$7mDP7fJCZw7l`ED07R;F7l`Xl#G?a1q}uNR5zi$bh^YM@5b=!hfrwgn
zfv^X`C<8#GT6cl4_i%wowciDT?tnxX2x{F05{$EeBdBy2MlgZ{jG)q87_Qf#Q6FFg
zmF~g_W*vYLRJsepRR`Br{NLRL;m?vF3jcR^LAa{mO2YsBdmvno;evF-UpiUALWj6Z
zStJPj_YX4%UT)w;F|hx9307{fMUHULF_f;Js+sODrlL+)GH7$^hm{N+Hdu(!;}=Lj
zO=`cKBXI*=hx^4G*?q8I%#qyz!($kDzz<^@QAhUd4j5_pA;5m9cNdI2DGHw6-;#^_
z%;GMRYTcEIG%JEgq*`}@xR2exnIpTSaxT!nnIpRogmuIp7K{wK+coS_oz9WnkqCQF
zr*q`*072)#Y8V!3-R&CJb9l3opwe9!!L$hC2rAu$;o7LvIkG$25loAMrwmlyU1_-L
z;M$7+ySpI#c@ae6|L!gbS1(*i_`iP-gzGW<hoQS5{3!>y9iD!=2tu6jA&a1Yl@qpF
z^kH}Q*KcIOY`8s`O>Fb&|HHj_Pdq#Xc+fUK+NU)62PXb;0FQ^e@5(*YA*NdHo@~Ug
x_J4Q{M<7{Y2c9_gA?9iBDGPU7{1;Oy(FAcg0sw*vY#SSKw|cl|F8_W1|36Al{4D?g

literal 0
HcmV?d00001

diff --git a/examples/with-unix-socket/docker-compose.yaml b/examples/with-unix-socket/docker-compose.yaml
new file mode 100644
index 0000000..705b567
--- /dev/null
+++ b/examples/with-unix-socket/docker-compose.yaml
@@ -0,0 +1,28 @@
+services:
+    pgsql:
+        image: timescale/timescaledb:latest-pg16
+        restart: always
+        tmpfs:
+            - /var/lib/postgresql/data
+        volumes:
+            - pg_socket:/var/run/postgresql
+        environment:
+            POSTGRES_DB: neon-db
+            POSTGRES_USER: postgres
+            POSTGRES_PASSWORD: neon-password
+    
+    neon:
+        image: ghcr.io/flexchar/wsproxy:latest
+        restart: always
+        depends_on:
+            - pgsql
+        environment:
+            LOG_CONN_INFO: true
+            UNIX_SOCKET_PATH: "/var/run/postgresql/.s.PGSQL.5432"
+        volumes:
+            - pg_socket:/var/run/postgresql
+        ports:
+          - 80
+
+volumes:
+    pg_socket:
diff --git a/examples/with-unix-socket/index.ts b/examples/with-unix-socket/index.ts
new file mode 100644
index 0000000..0e6ce18
--- /dev/null
+++ b/examples/with-unix-socket/index.ts
@@ -0,0 +1,37 @@
+import { Pool, neonConfig } from '@neondatabase/serverless';
+import { drizzle } from 'drizzle-orm/neon-serverless';
+import { sql } from 'drizzle-orm';
+
+// Docs
+// https://orm.drizzle.team/docs/get-started-postgresql#neon-postgres
+// Test with
+// NEON_WS_PROXY_HOST=$(docker compose port neon 80) bun run serverless.ts
+
+const NEON_WS_PROXY_HOST = process.env.NEON_WS_PROXY_HOST;
+console.log('NEON_WS_PROXY_HOST', NEON_WS_PROXY_HOST);
+
+if (!NEON_WS_PROXY_HOST) {
+    throw new Error('NEON_WS_PROXY_HOST is not set');
+}
+
+// Set the WebSocket proxy to work with the local instance
+neonConfig.wsProxy = () => `${process.env.NEON_WS_PROXY_HOST}/v1`;
+
+// Disable TLS when running on local machine
+neonConfig.useSecureWebSocket = false;
+// Disable all authentication and encryption
+neonConfig.pipelineTLS = false;
+neonConfig.pipelineConnect = false;
+
+const connectionString = `pgsql://postgres:neon-password@placeholder/neon-db`;
+
+const pool = new Pool({ connectionString });
+const db = drizzle(pool);
+
+const result = await db.execute(sql`SELECT version()`);
+const res = result.rows[0];
+
+console.log(res);
+
+await pool.end();
+process.exit(0);
diff --git a/examples/with-unix-socket/package.json b/examples/with-unix-socket/package.json
new file mode 100644
index 0000000..cc34411
--- /dev/null
+++ b/examples/with-unix-socket/package.json
@@ -0,0 +1,16 @@
+{
+  "name": "with-unix-socket",
+  "module": "index.ts",
+  "type": "module",
+  "devDependencies": {
+    "@types/bun": "latest",
+    "drizzle-kit": "^0.24.2"
+  },
+  "peerDependencies": {
+    "typescript": "^5.0.0"
+  },
+  "dependencies": {
+    "@neondatabase/serverless": "^0.9.5",
+    "drizzle-orm": "^0.33.0"
+  }
+}
\ No newline at end of file
diff --git a/examples/with-unix-socket/tsconfig.json b/examples/with-unix-socket/tsconfig.json
new file mode 100644
index 0000000..238655f
--- /dev/null
+++ b/examples/with-unix-socket/tsconfig.json
@@ -0,0 +1,27 @@
+{
+  "compilerOptions": {
+    // Enable latest features
+    "lib": ["ESNext", "DOM"],
+    "target": "ESNext",
+    "module": "ESNext",
+    "moduleDetection": "force",
+    "jsx": "react-jsx",
+    "allowJs": true,
+
+    // Bundler mode
+    "moduleResolution": "bundler",
+    "allowImportingTsExtensions": true,
+    "verbatimModuleSyntax": true,
+    "noEmit": true,
+
+    // Best practices
+    "strict": true,
+    "skipLibCheck": true,
+    "noFallthroughCasesInSwitch": true,
+
+    // Some stricter flags (disabled by default)
+    "noUnusedLocals": false,
+    "noUnusedParameters": false,
+    "noPropertyAccessFromIndexSignature": false
+  }
+}

From 19323ff2c916e4294386add1271cd01a41b218b3 Mon Sep 17 00:00:00 2001
From: Lukas <git@lukasnotes.dk>
Date: Wed, 18 Sep 2024 13:21:44 +0200
Subject: [PATCH 5/5] add more comments

---
 examples/with-unix-socket/index.ts | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/examples/with-unix-socket/index.ts b/examples/with-unix-socket/index.ts
index 0e6ce18..702be86 100644
--- a/examples/with-unix-socket/index.ts
+++ b/examples/with-unix-socket/index.ts
@@ -5,7 +5,7 @@ import { sql } from 'drizzle-orm';
 // Docs
 // https://orm.drizzle.team/docs/get-started-postgresql#neon-postgres
 // Test with
-// NEON_WS_PROXY_HOST=$(docker compose port neon 80) bun run serverless.ts
+// NEON_WS_PROXY_HOST=$(docker compose port neon 80) bun run index.ts
 
 const NEON_WS_PROXY_HOST = process.env.NEON_WS_PROXY_HOST;
 console.log('NEON_WS_PROXY_HOST', NEON_WS_PROXY_HOST);
@@ -18,12 +18,14 @@ if (!NEON_WS_PROXY_HOST) {
 neonConfig.wsProxy = () => `${process.env.NEON_WS_PROXY_HOST}/v1`;
 
 // Disable TLS when running on local machine
-neonConfig.useSecureWebSocket = false;
+neonConfig.useSecureWebSocket = false; // or true, if you, for example, expose using Cloudflare Tunnel
 // Disable all authentication and encryption
 neonConfig.pipelineTLS = false;
 neonConfig.pipelineConnect = false;
 
 const connectionString = `pgsql://postgres:neon-password@placeholder/neon-db`;
+// "placeholder" can be any string just to satisfy Neon's connection string format,
+// because we're using Unix socket, we don't need to specify the host and port at all.
 
 const pool = new Pool({ connectionString });
 const db = drizzle(pool);