@@ -2,6 +2,7 @@ import { PGlite, PGliteInterface } from '@electric-sql/pglite'
2
2
import { vector } from '@electric-sql/pglite/vector'
3
3
import { mkdir , readFile , access , rm } from 'node:fs/promises'
4
4
import net from 'node:net'
5
+ import path from 'node:path'
5
6
import { createReadStream } from 'node:fs'
6
7
import { pipeline } from 'node:stream/promises'
7
8
import { createGunzip } from 'node:zlib'
@@ -15,6 +16,14 @@ const supabaseKey = process.env.SUPABASE_SERVICE_ROLE_KEY ?? ''
15
16
const dataMount = process . env . DATA_MOUNT ?? './data'
16
17
const s3fsMount = process . env . S3FS_MOUNT ?? './s3'
17
18
const wildcardDomain = process . env . WILDCARD_DOMAIN ?? 'db.example.com'
19
+ const packageJson = JSON . parse (
20
+ await readFile ( path . join ( import . meta. dirname , '..' , 'package.json' ) , 'utf8' )
21
+ ) as {
22
+ dependencies : {
23
+ '@electric-sql/pglite' : string
24
+ }
25
+ }
26
+ const pgliteVersion = `(PGlite ${ packageJson . dependencies [ '@electric-sql/pglite' ] } )`
18
27
19
28
const dumpDir = `${ s3fsMount } /dbs`
20
29
const tlsDir = `${ s3fsMount } /tls`
@@ -69,9 +78,11 @@ const server = net.createServer((socket) => {
69
78
const {
70
79
rows : [ { version } ] ,
71
80
} = await db . query < { version : string } > (
72
- `select split_part( current_setting('server_version'), '.', 1 ) as version;`
81
+ `select current_setting('server_version') as version;`
73
82
)
74
- return version
83
+ const serverVersion = `${ version } ${ pgliteVersion } `
84
+ console . log ( serverVersion )
85
+ return serverVersion
75
86
} ,
76
87
auth : {
77
88
method : 'scram-sha-256' ,
0 commit comments