diff options
author | 2025-03-10 00:11:39 +0100 | |
---|---|---|
committer | 2025-03-10 01:59:49 +0100 | |
commit | 5e62aaf724e7f3d79427aebd1d5cdbbb3547265e (patch) | |
tree | 266556645a0ed5ecf1e5f7a248ea1adc6cf9fd13 /internal/db/sqlite/errors_libsqlite3.go | |
parent | [chore] remove vendor (diff) | |
download | gotosocial-5e62aaf724e7f3d79427aebd1d5cdbbb3547265e.tar.xz |
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.go | 60 |
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, + ) +} |