diff options
author | 2023-07-27 01:30:39 -0700 | |
---|---|---|
committer | 2023-07-27 10:30:39 +0200 | |
commit | 22ac4607a1c283a719eea95844e07513b8a67570 (patch) | |
tree | 61baf7949b62f84d2dff29c4d99614d946774f64 /internal/db/bundb/relationship_note.go | |
parent | [performance] retry db queries on busy errors (#2025) (diff) | |
download | gotosocial-22ac4607a1c283a719eea95844e07513b8a67570.tar.xz |
[feature] Support setting private notes on accounts (#1982)
* Support setting private notes on accounts
* Reformat comment whitespace
* Add missing license headers
* Use apiutil.ParseID
* Rename Note model and cache to AccountNote
* Update golden cache config in test/envparsing.sh
* Rename gtsmodel/note.go to gtsmodel/accountnote.go
* Update AccountNote uniqueness constraint name
Now has same prefix as other indexes on this table.
---------
Co-authored-by: tobi <31960611+tsmethurst@users.noreply.github.com>
Diffstat (limited to 'internal/db/bundb/relationship_note.go')
-rw-r--r-- | internal/db/bundb/relationship_note.go | 99 |
1 files changed, 99 insertions, 0 deletions
diff --git a/internal/db/bundb/relationship_note.go b/internal/db/bundb/relationship_note.go new file mode 100644 index 000000000..97e740bcd --- /dev/null +++ b/internal/db/bundb/relationship_note.go @@ -0,0 +1,99 @@ +// 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/>. + +package bundb + +import ( + "context" + "fmt" + "time" + + "github.com/superseriousbusiness/gotosocial/internal/gtscontext" + "github.com/superseriousbusiness/gotosocial/internal/gtsmodel" + "github.com/uptrace/bun" +) + +func (r *relationshipDB) GetNote(ctx context.Context, sourceAccountID string, targetAccountID string) (*gtsmodel.AccountNote, error) { + return r.getNote( + ctx, + "AccountID.TargetAccountID", + func(note *gtsmodel.AccountNote) error { + return r.conn.NewSelect().Model(note). + Where("? = ?", bun.Ident("account_id"), sourceAccountID). + Where("? = ?", bun.Ident("target_account_id"), targetAccountID). + Scan(ctx) + }, + sourceAccountID, + targetAccountID, + ) +} + +func (r *relationshipDB) getNote(ctx context.Context, lookup string, dbQuery func(*gtsmodel.AccountNote) error, keyParts ...any) (*gtsmodel.AccountNote, error) { + // Fetch note from cache with loader callback + note, err := r.state.Caches.GTS.AccountNote().Load(lookup, func() (*gtsmodel.AccountNote, error) { + var note gtsmodel.AccountNote + + // Not cached! Perform database query + if err := dbQuery(¬e); err != nil { + return nil, r.conn.ProcessError(err) + } + + return ¬e, nil + }, keyParts...) + if err != nil { + // already processed + return nil, err + } + + if gtscontext.Barebones(ctx) { + // Only a barebones model was requested. + return note, nil + } + + // Set the note source account + note.Account, err = r.state.DB.GetAccountByID( + gtscontext.SetBarebones(ctx), + note.AccountID, + ) + if err != nil { + return nil, fmt.Errorf("error getting note source account: %w", err) + } + + // Set the note target account + note.TargetAccount, err = r.state.DB.GetAccountByID( + gtscontext.SetBarebones(ctx), + note.TargetAccountID, + ) + if err != nil { + return nil, fmt.Errorf("error getting note target account: %w", err) + } + + return note, nil +} + +func (r *relationshipDB) PutNote(ctx context.Context, note *gtsmodel.AccountNote) error { + note.UpdatedAt = time.Now() + return r.state.Caches.GTS.AccountNote().Store(note, func() error { + _, err := r.conn. + NewInsert(). + Model(note). + On("CONFLICT (?, ?) DO UPDATE", bun.Ident("account_id"), bun.Ident("target_account_id")). + Set("? = ?, ? = ?", bun.Ident("updated_at"), note.UpdatedAt, bun.Ident("comment"), note.Comment). + Exec(ctx) + return r.conn.ProcessError(err) + }) +} |