chore: update deps

go.mod

@@ -13,21 +13,24 @@ require (
 	go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.18.0
 	go.opentelemetry.io/otel/sdk/metric v0.41.0
 	go.uber.org/multierr v1.11.0
-	golang.org/x/sync v0.3.0
+	golang.org/x/sync v0.7.0
 )
 
 require (
 	github.com/agnivade/levenshtein v1.1.1 // indirect
+	github.com/antlr/antlr4/runtime/Go/antlr/v4 v4.0.0-20230512164433-5d1fd1a340c9 // indirect
 	github.com/beorn7/perks v1.0.1 // indirect
 	github.com/cespare/xxhash/v2 v2.2.0 // indirect
 	github.com/felixge/httpsnoop v1.0.3 // indirect
 	github.com/hashicorp/golang-lru/v2 v2.0.3 // indirect
+	github.com/libsql/sqlite-antlr4-parser v0.0.0-20230802215326-5cb5bb604475 // indirect
 	github.com/matttproud/golang_protobuf_extensions v1.0.4 // indirect
 	github.com/mitchellh/mapstructure v1.5.0 // indirect
 	github.com/prometheus/client_model v0.4.1-0.20230718164431-9a2bf3000d16 // indirect
 	github.com/prometheus/common v0.44.0 // indirect
 	github.com/prometheus/procfs v0.12.0 // indirect
 	go.opentelemetry.io/contrib v1.16.1 // indirect
+	golang.org/x/exp v0.0.0-20220722155223-a9213eeb770e // indirect
 	google.golang.org/genproto/googleapis/api v0.0.0-20230711160842-782d3b101e98 // indirect
 	google.golang.org/genproto/googleapis/rpc v0.0.0-20230711160842-782d3b101e98 // indirect
 )
@@ -39,6 +42,7 @@ require (
 	github.com/golang/protobuf v1.5.3 // indirect
 	github.com/grpc-ecosystem/grpc-gateway/v2 v2.16.0 // indirect
 	github.com/prometheus/client_golang v1.17.0
+	github.com/tursodatabase/go-libsql v0.0.0-20240322134723-08771dcdd2f1
 	go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.44.0
 	go.opentelemetry.io/contrib/instrumentation/runtime v0.42.0
 	go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.18.0 // indirect
@@ -47,9 +51,9 @@ require (
 	go.opentelemetry.io/otel/sdk v1.18.0
 	go.opentelemetry.io/otel/trace v1.18.0
 	go.opentelemetry.io/proto/otlp v1.0.0 // indirect
-	golang.org/x/net v0.17.0 // indirect
+	golang.org/x/net v0.23.0 // indirect
-	golang.org/x/sys v0.13.0 // indirect
+	golang.org/x/sys v0.18.0 // indirect
-	golang.org/x/text v0.13.0 // indirect
+	golang.org/x/text v0.14.0 // indirect
-	google.golang.org/grpc v1.58.0 // indirect
+	google.golang.org/grpc v1.58.3 // indirect
-	google.golang.org/protobuf v1.31.0 // indirect
+	google.golang.org/protobuf v1.33.0 // indirect
 )

go.sum

@@ -4,6 +4,8 @@ github.com/agnivade/levenshtein v1.1.1 h1:QY8M92nrzkmr798gCo3kmMyqXFzdQVpxLlGPRB
 github.com/agnivade/levenshtein v1.1.1/go.mod h1:veldBMzWxcCG2ZvUTKD2kJNRdCk5hVbJomOvKkmgYbo=
 github.com/andreyvit/diff v0.0.0-20170406064948-c7f18ee00883 h1:bvNMNQO63//z+xNgfBlViaCIJKLlCJ6/fmUseuG0wVQ=
 github.com/andreyvit/diff v0.0.0-20170406064948-c7f18ee00883/go.mod h1:rCTlJbsFo29Kk6CurOXKm700vrz8f0KW0JNfpkRJY/8=
+github.com/antlr/antlr4/runtime/Go/antlr/v4 v4.0.0-20230512164433-5d1fd1a340c9 h1:goHVqTbFX3AIo0tzGr14pgfAW2ZfPChKO21Z9MGf/gk=
+github.com/antlr/antlr4/runtime/Go/antlr/v4 v4.0.0-20230512164433-5d1fd1a340c9/go.mod h1:pSwJ0fSY5KhvocuWSx4fz3BA8OrA1bQn+K1Eli3BRwM=
 github.com/arbovm/levenshtein v0.0.0-20160628152529-48b4e1c0c4d0 h1:jfIu9sQUG6Ig+0+Ap1h4unLjW6YQJpKZVmUzxsD4E/Q=
 github.com/arbovm/levenshtein v0.0.0-20160628152529-48b4e1c0c4d0/go.mod h1:t2tdKJDJF9BV14lnkjHmOQgcvEKgtqs5a1N3LNdJhGE=
 github.com/beorn7/perks v1.0.1 h1:VlbKKnNfV8bJzeqoa4cOKqO6bYr3WgKZxO8Z16+hsOM=
@@ -42,6 +44,8 @@ github.com/hashicorp/golang-lru/v2 v2.0.3/go.mod h1:QeFd9opnmA6QUJc5vARoKUSoFhyf
 github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=
 github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
 github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
+github.com/libsql/sqlite-antlr4-parser v0.0.0-20230802215326-5cb5bb604475 h1:6PfEMwfInASh9hkN83aR0j4W/eKaAZt/AURtXAXlas0=
+github.com/libsql/sqlite-antlr4-parser v0.0.0-20230802215326-5cb5bb604475/go.mod h1:20nXSmcf0nAscrzqsXeC2/tA3KkV2eCiJqYuyAgl+ss=
 github.com/matryer/is v1.4.1 h1:55ehd8zaGABKLXQUe2awZ99BD/PTc2ls+KV/dXphgEQ=
 github.com/matryer/is v1.4.1/go.mod h1:8I/i5uYgLzgsgEloJE1U6xx5HkBQpAZvepWuujKwMRU=
 github.com/matttproud/golang_protobuf_extensions v1.0.4 h1:mmDVorXM7PCGKw94cs5zkfA9PSy5pEvNWRP0ET0TIVo=
@@ -65,6 +69,8 @@ github.com/sergi/go-diff v1.3.1/go.mod h1:aMJSSKb2lpPvRNec0+w3fl7LP9IOFzdc9Pa4NF
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=
 github.com/stretchr/testify v1.8.4 h1:CcVxjf3Q8PM0mHUKJCdn+eZZtm5yQwehR5yeSVQQcUk=
+github.com/tursodatabase/go-libsql v0.0.0-20240322134723-08771dcdd2f1 h1:lQwP++jvwcQiPqqIXIvabCIvfh8bzibpjYvT4s0jWmA=
+github.com/tursodatabase/go-libsql v0.0.0-20240322134723-08771dcdd2f1/go.mod h1:sb520Yr+GHBsfL43FQgQ+rLFfuJkItgRWlTgbIQHVxA=
 github.com/vektah/gqlparser/v2 v2.5.6 h1:Ou14T0N1s191eRMZ1gARVqohcbe1e8FrcONScsq8cRU=
 github.com/vektah/gqlparser/v2 v2.5.6/go.mod h1:z8xXUff237NntSuH8mLFijZ+1tjV1swDbpDqjJmk6ME=
 go.opentelemetry.io/contrib v1.16.1 h1:EpASvVyGx6/ZTlmXzxYfTMZxHROelCeXXa2uLiwltcs=
@@ -93,15 +99,26 @@ go.opentelemetry.io/proto/otlp v1.0.0 h1:T0TX0tmXU8a3CbNXzEKGeU5mIVOdf0oykP+u2lI
 go.opentelemetry.io/proto/otlp v1.0.0/go.mod h1:Sy6pihPLfYHkr3NkUbEhGHFhINUSI/v80hjKIs5JXpM=
 go.uber.org/multierr v1.11.0 h1:blXXJkSxSSfBVBlC76pxqeO+LN3aDfLQo+309xJstO0=
 go.uber.org/multierr v1.11.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=
+golang.org/x/exp v0.0.0-20220722155223-a9213eeb770e h1:+WEEuIdZHnUeJJmEUjyYC2gfUMj69yZXw17EnHg/otA=
+golang.org/x/exp v0.0.0-20220722155223-a9213eeb770e/go.mod h1:Kr81I6Kryrl9sr8s2FK3vxD90NdsKWRuOIl2O4CvYbA=
 golang.org/x/net v0.17.0 h1:pVaXccu2ozPjCXewfr1S7xza/zcXTity9cCdXQYSjIM=
 golang.org/x/net v0.17.0/go.mod h1:NxSsAGuq816PNPmqtQdLE42eU2Fs7NoRIZrHJAlaCOE=
+golang.org/x/net v0.23.0 h1:7EYJ93RZ9vYSZAIb2x3lnuvqO5zneoD6IvWjuhfxjTs=
+golang.org/x/net v0.23.0/go.mod h1:JKghWKKOSdJwpW2GEx0Ja7fmaKnMsbu+MWVZTokSYmg=
 golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.3.0 h1:ftCYgMx6zT/asHUrPw8BLLscYtGznsLAnjq5RH9P66E=
 golang.org/x/sync v0.3.0/go.mod h1:FU7BRWz2tNW+3quACPkgCx/L+uEAv1htQ0V83Z9Rj+Y=
+golang.org/x/sync v0.6.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
+golang.org/x/sync v0.7.0 h1:YsImfSBoP9QPYL0xyKJPq0gcaJdG3rInoqxTWbfQu9M=
+golang.org/x/sync v0.7.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
 golang.org/x/sys v0.13.0 h1:Af8nKPmuFypiUBjVoU9V20FiaFXOcuZI21p0ycVYYGE=
 golang.org/x/sys v0.13.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.18.0 h1:DBdB3niSjOA/O0blCZBqDefyWNYveAYMNF1Wum0DYQ4=
+golang.org/x/sys v0.18.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
 golang.org/x/text v0.13.0 h1:ablQoSUd0tRdKxZewP80B+BaqeKJuVhuRxj/dkrun3k=
 golang.org/x/text v0.13.0/go.mod h1:TvPlkZtksWOMsz7fbANvkp4WM8x/WCo/om8BMLbz+aE=
+golang.org/x/text v0.14.0 h1:ScX5w1eTa3QqT8oi6+ziP7dTV1S2+ALU0bI+0zXKWiQ=
+golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
 golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 google.golang.org/genproto v0.0.0-20230711160842-782d3b101e98 h1:Z0hjGZePRE0ZBWotvtrwxFNrNE9CUAGtplaDK5NNI/g=
 google.golang.org/genproto/googleapis/api v0.0.0-20230711160842-782d3b101e98 h1:FmF5cCW94Ij59cfpoLiwTgodWmm60eEV0CjlsVg2fuw=
@@ -110,10 +127,14 @@ google.golang.org/genproto/googleapis/rpc v0.0.0-20230711160842-782d3b101e98 h1:
 google.golang.org/genproto/googleapis/rpc v0.0.0-20230711160842-782d3b101e98/go.mod h1:TUfxEVdsvPg18p6AslUXFoLdpED4oBnGwyqk3dV1XzM=
 google.golang.org/grpc v1.58.0 h1:32JY8YpPMSR45K+c3o6b8VL73V+rR8k+DeMIr4vRH8o=
 google.golang.org/grpc v1.58.0/go.mod h1:tgX3ZQDlNJGU96V6yHh1T/JeoBQ2TXdr43YbYSsCJk0=
+google.golang.org/grpc v1.58.3 h1:BjnpXut1btbtgN/6sp+brB2Kbm2LjNXnidYujAVbSoQ=
+google.golang.org/grpc v1.58.3/go.mod h1:tgX3ZQDlNJGU96V6yHh1T/JeoBQ2TXdr43YbYSsCJk0=
 google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw=
 google.golang.org/protobuf v1.26.0/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc=
 google.golang.org/protobuf v1.31.0 h1:g0LDEJHgrBl9N9r17Ru3sqWhkIx2NB67okBHPwC7hs8=
 google.golang.org/protobuf v1.31.0/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I=
+google.golang.org/protobuf v1.33.0 h1:uNO2rsAINq/JlFpSdYEKIZ0uKD/R9cpdv0T+yoGwGmI=
+google.golang.org/protobuf v1.33.0/go.mod h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=

grug/math/math.go

@@ -1,189 +0,0 @@
-// grug math is an unbounded precision math library for integers. It is not designed to be performant in any means. But as an example of how one works.
-package math
-
-import "strconv"
-
-type Number []rune
-
-func NewNumber() *Number {
-	return &Number{}
-}
-
-func (*Number) FromString(s string) *Number {
-	for _, a := range s {
-		if !(a >= '0' && a <= '9') {
-			return nil
-		}
-	}
-
-	var n Number = []rune(s)
-	
-	i:=0
-	for range n[:len(n)-1] {
-		if n[i] == 0 || n[i] == '0' {
-			i++
-		} else {
-			break
-		}
-	}
-	n = n[i:]
-
-	return &n
-}
-
-func (*Number) FromInt(i int) *Number {
-	s := strconv.Itoa(i)
-	var n Number = []rune(s)
-	return &n
-}
-
-func (n *Number) String() string {
-	if n == nil || len(*n) == 0 {
-		return "NaN"
-	}
-	return string(*n)
-}
-
-func (n *Number) Add(a *Number) *Number {
-	if n == nil || a == nil {
-		return nil
-	}
-
-	lenN, lenA := len(*n), len(*a)
-	sum := make(Number, max(lenN, lenA)+1)
-
-	for i := range sum[:len(sum)-1] {
-		ii := len(sum) - i - 1
-
-		switch {
-		case lenN == lenA:
-			j := (*n)[lenN-i-1]
-			k := (*a)[lenA-i-1]
-
-			sum[ii-1], sum[ii] = add(j, k, sum[ii])
-
-		case lenN > lenA:
-			j := (*n)[lenN-i-1]
-			k := '0'
-			if i < lenA {
-				k = (*a)[lenA-i-1]
-			}
-
-			sum[ii-1], sum[ii] = add(j, k, sum[ii])
-
-		case lenN < lenA:
-			j := '0'
-			if i < lenN {
-				j = (*n)[lenN-i-1]
-			}
-			k := (*a)[lenA-i-1]
-
-			sum[ii-1], sum[ii] = add(j, k, sum[ii])
-		}
-	}
-
-	// Trim the extra 0 if present
-	if sum[0] == 0 || sum[0] == '0' {
-		sum = sum[1:]
-	}
-
-	return &sum
-}
-
-
-func (n *Number) Sub(s *Number) *Number {
-	if n == nil || s == nil {
-		return nil
-	}
-
-	lenN, lenA := len(*n), len(*s)
-	sum := make(Number, max(lenN, lenA)+1)
-
-	for i := range sum[:len(sum)-1] {
-		ii := len(sum) - i - 1
-
-		switch {
-		case lenN == lenA:
-			j := (*n)[lenN-i-1]
-			k := (*s)[lenA-i-1]
-			c := '0'
-			if i+1 < lenN {
-				c = (*n)[lenN-i-2]
-			}
-
-			sum[ii-1], sum[ii] = sub(j, k, c)
-
-		case lenN > lenA:
-			j := (*n)[lenN-i-1]
-			k := '0'
-			if i < lenA {
-				k = (*s)[lenA-i-1]
-			}
-			c := '0'
-			if i+1 < lenN {
-				c = (*n)[lenN-i-2]
-			}
-
-			sum[ii-1], sum[ii] = sub(j, k, c)
-			if i+1 < lenN {
-				(*n)[lenN-i-2] =sum[ii-1]
-			}
-
-		case lenN < lenA:
-			j := '0'
-			if i < lenN {
-				j = (*n)[lenN-i-1]
-			}
-			k := (*s)[lenA-i-1]
-			c := '0'
-			if i+1 < lenN {
-				c = (*n)[lenN-i-2]
-			}
-
-			sum[ii-1], sum[ii] = sub(j, k, c)
-		}
-	}
-
-	// Trim the extra 0 if present
-	i:=0
-	for range sum[:len(sum)-1] {
-		if sum[i] == 0 || sum[i] == '0' {
-			i++
-		} else {
-			break
-		}
-	}
-	sum = sum[i:]
-
-
-	return &sum
-}
-
-
-func friends(r rune) (int32, int32) {
-	return 1, 10 - int32(r-'0')
-}
-func add(a, b, c rune) (rune, rune) {
-	up, dn := friends(b)
-	if c == 0 {
-		c = '0'
-	}
-	a = a + c - '0'
-
-	if a-dn < '0' {
-		return '0', a + b - '0'
-	}
-	return c + up, a - dn
-}
-
-func sub(a, b, c rune) (rune, rune) {
-	dn, up := friends(b)
-	if c == 0 {
-		c = '0'
-	}
-
-	if a+up > '9' {
-		return c, a - b + '0'
-	}
-	return c - dn, a + up
-}

grug/math/math_test.go

@@ -1,74 +0,0 @@
-package math_test
-
-import (
-	"testing"
-
-	"github.com/matryer/is"
-	"go.sour.is/pkg/grug/math"
-)
-
-func TestNumber(t *testing.T) {
-	is := is.New(t)
-
-	n := math.NewNumber().FromInt(100)
-	is.Equal(n.String(), "100")
-
-	n = n.FromString("00001")
-	is.Equal(n.String(), "1")
-
-	n = n.FromString("1x0")
-	is.True(n==nil)
-	is.Equal(n.String(), "NaN")
-
-	n = n.FromString("200")
-	is.True(n!=nil)
-	is.Equal(n.String(), "200")
-
-	n = (&math.Number{}).FromString("300")
-	is.True(n!=nil)
-	is.Equal(n.String(), "300")
-}
-
-func TestAdd(t *testing.T) {
-	is := is.New(t)
-
-	n := math.NewNumber().FromString("100")
-
-	n = n.Add(nil)
-	is.Equal(n.String(), "NaN")
-
-	n = n.FromInt(100)
-	n = n.Add(n.FromString("900"))
-	is.Equal(n.String(), "1000")
-
-	n = n.Add(math.NewNumber())
-	is.Equal(n.String(), "1000")
-
-	n = n.Add(n.FromString("10"))
-	is.Equal(n.String(), "1010")
-
-	n = n.Add(n.FromString("10000"))
-	is.Equal(n.String(), "11010")
-
-	n = n.Add(n.FromString("9000"))
-	is.Equal(n.String(), "20010")
-}
-
-func TestSub(t *testing.T) {
-	is := is.New(t)
-
-	n := math.NewNumber()
-
-	// n = n.FromString("100")
-	// n = n.Sub(n.FromInt(100))
-	// is.Equal(n.String(), "0")
-
-	// n = n.FromString("200")
-	// n = n.Sub(n.FromInt(100))
-	// is.Equal(n.String(), "100")
-
-	n = n.FromString("100")
-	n = n.Sub(n.FromInt(50))
-	is.Equal(n.String(), "50")
-
-}

libsql_embed/open.go

@@ -0,0 +1,120 @@
+package libsqlembed
+
+import (
+	"context"
+	"database/sql"
+	"database/sql/driver"
+	"fmt"
+	"net/url"
+	"os"
+	"path/filepath"
+	"strconv"
+	"strings"
+	"sync"
+	"time"
+
+	"github.com/tursodatabase/go-libsql"
+)
+
+func init() {
+	sql.Register("libsql+embed", &db{})
+}
+
+type db struct {
+	conns map[string]connector
+	mu    sync.RWMutex
+}
+
+type connector struct {
+	*libsql.Connector
+	dsn    string
+	dir    string
+	driver *db
+}
+
+func (c *connector) Close() error {
+	c.driver.mu.Lock()
+	delete(c.driver.conns, c.dsn)
+	c.driver.mu.Unlock()
+
+	defer os.RemoveAll(c.dir)
+
+	if err := c.Connector.Sync(); err != nil {
+		return fmt.Errorf("syncing database: %w", err)
+	}
+
+	return c.Connector.Close()
+}
+
+func (db *db) OpenConnector(dsn string) (driver.Connector, error) {
+	if c, ok := func() (connector, bool) {
+		db.mu.RLock()
+		defer db.mu.RUnlock()
+		c, ok := db.conns[dsn]
+		return c, ok
+	}(); ok {
+		return c, nil
+	}
+
+	db.mu.Lock()
+	defer db.mu.Unlock()
+
+	u, err := url.Parse(dsn)
+	if err != nil {
+		return nil, err
+	}
+
+	var primary url.URL
+	primary.Scheme = strings.TrimSuffix(u.Scheme, "+embed")
+	primary.Host = u.Host
+
+	dbname, _, _ := strings.Cut(u.Host, ".")
+
+	authToken := u.Query().Get("authToken")
+	if authToken == "" {
+		return nil, fmt.Errorf("missing authToken")
+	}
+
+	opts := []libsql.Option{
+		libsql.WithAuthToken(authToken),
+	}
+
+	if refresh, err := strconv.ParseInt(u.Query().Get("refresh"),10,64); err == nil {
+		opts = append(opts, libsql.WithSyncInterval(time.Duration(refresh)*time.Minute))
+	}
+
+	if readWrite, err := strconv.ParseBool(u.Query().Get("readYourWrites")); err == nil {
+		opts = append(opts, libsql.WithReadYourWrites(readWrite))
+	}
+	if key := u.Query().Get("key"); key != "" {
+		opts = append(opts, libsql.WithEncryption(key))
+	}
+	
+	dir, err := os.MkdirTemp("", "libsql-*")
+	if err != nil {
+		return nil, fmt.Errorf("creating temporary directory: %w", err)
+	}
+
+	dbPath := filepath.Join(dir, dbname)
+
+	c, err := libsql.NewEmbeddedReplicaConnector(
+		dbPath,
+		primary.String(),
+		opts...)
+	if err != nil {
+		return nil, fmt.Errorf("creating connector: %w", err)
+	}
+
+	connector := connector{c, dsn, dir, db}
+	db.conns[dsn] = connector
+
+	return connector, nil
+}
+
+func (db *db) Open(dsn string) (driver.Conn, error) {
+	c, err := db.OpenConnector(dsn)
+	if err != nil {
+		return nil, err
+	}
+	return c.Connect(context.Background())
+}