summaryrefslogtreecommitdiff
path: root/internal/db/sqlite/errors_libsqlite3.go
diff options
context:
space:
mode:
authorLibravatar Terin Stock <terinjokes@gmail.com>2025-03-10 00:11:39 +0100
committerLibravatar Terin Stock <terinjokes@gmail.com>2025-03-10 01:59:49 +0100
commit5e62aaf724e7f3d79427aebd1d5cdbbb3547265e (patch)
tree266556645a0ed5ecf1e5f7a248ea1adc6cf9fd13 /internal/db/sqlite/errors_libsqlite3.go
parent[chore] remove vendor (diff)
downloadgotosocial-trunk.tar.xz
[feat] utilize system's libsqlite3HEADtrunknext
Add support for using the system's libsqlite3 library by adding a driver using "github.com/mattn/go-sqlite3".
Diffstat (limited to 'internal/db/sqlite/errors_libsqlite3.go')
-rw-r--r--internal/db/sqlite/errors_libsqlite3.go60
1 files changed, 60 insertions, 0 deletions
diff --git a/internal/db/sqlite/errors_libsqlite3.go b/internal/db/sqlite/errors_libsqlite3.go
new file mode 100644
index 000000000..483d9ed14
--- /dev/null
+++ b/internal/db/sqlite/errors_libsqlite3.go
@@ -0,0 +1,60 @@
+// GoToSocial
+// Copyright (C) GoToSocial Authors admin@gotosocial.org
+// SPDX-License-Identifier: AGPL-3.0-or-later
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU Affero General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+// GNU Affero General Public License for more details.
+//
+// You should have received a copy of the GNU Affero General Public License
+// along with this program. If not, see <http://www.gnu.org/licenses/>.
+
+//go:build !moderncsqlite3 && !nowasm && libsqlite3
+
+package sqlite
+
+import (
+ "database/sql/driver"
+ "fmt"
+
+ sqlite3 "github.com/mattn/go-sqlite3"
+ "github.com/superseriousbusiness/gotosocial/internal/db"
+)
+
+// processSQLiteError processes an sqlite3.Error to
+// handle conversion to any of our common db types.
+func processSQLiteError(err error) error {
+ // Attempt to cast as sqlite error.
+ sqliteErr, ok := err.(sqlite3.Error)
+ if !ok {
+ return err
+ }
+
+ // Handle supplied error code:
+ switch sqliteErr.ExtendedCode {
+ case sqlite3.ErrConstraintUnique,
+ sqlite3.ErrConstraintPrimaryKey:
+ return db.ErrAlreadyExists
+
+ // Busy should be very rare, but on
+ // busy tell the database to close the
+ // connection, re-open and re-attempt
+ // which should give necessary timeout.
+ case sqlite3.ErrBusyRecovery,
+ sqlite3.ErrBusySnapshot:
+ return driver.ErrBadConn
+ }
+
+ // Wrap the returned error with the code and
+ // extended code for easier debugging later.
+ return fmt.Errorf("%w (code=%d extended=%d)", err,
+ sqliteErr.Code,
+ sqliteErr.ExtendedCode,
+ )
+}