summaryrefslogtreecommitdiff
path: root/internal/timeline/itemindex.go
diff options
context:
space:
mode:
authorLibravatar tobi <31960611+tsmethurst@users.noreply.github.com>2022-11-22 19:38:10 +0100
committerLibravatar GitHub <noreply@github.com>2022-11-22 18:38:10 +0000
commit50dc179d332af4a3dc0e69e2c4e39bbbccd3fec5 (patch)
treeb48421907353aa6530a76f8c345e3bc11aeab4c9 /internal/timeline/itemindex.go
parent[docs] Document http/s/socks5 proxy use (#1118) (diff)
downloadgotosocial-50dc179d332af4a3dc0e69e2c4e39bbbccd3fec5.tar.xz
[feature] Prune timelines once per hour to plug memory leak (#1117)
* export highest/lowest ULIDs as proper const * add stop + start to timeline manager, other small fixes * unexport unused interface funcs + tidy up * add LastGot func * add timeline Prune function * test prune * update lastGot
Diffstat (limited to 'internal/timeline/itemindex.go')
-rw-r--r--internal/timeline/itemindex.go86
1 files changed, 0 insertions, 86 deletions
diff --git a/internal/timeline/itemindex.go b/internal/timeline/itemindex.go
deleted file mode 100644
index 968650e07..000000000
--- a/internal/timeline/itemindex.go
+++ /dev/null
@@ -1,86 +0,0 @@
-/*
- GoToSocial
- Copyright (C) 2021-2022 GoToSocial Authors admin@gotosocial.org
-
- 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 timeline
-
-import (
- "container/list"
- "context"
- "errors"
-)
-
-type itemIndex struct {
- data *list.List
- skipInsert SkipInsertFunction
-}
-
-type itemIndexEntry struct {
- itemID string
- boostOfID string
- accountID string
- boostOfAccountID string
-}
-
-func (p *itemIndex) insertIndexed(ctx context.Context, i *itemIndexEntry) (bool, error) {
- if p.data == nil {
- p.data = &list.List{}
- }
-
- // if we have no entries yet, this is both the newest and oldest entry, so just put it in the front
- if p.data.Len() == 0 {
- p.data.PushFront(i)
- return true, nil
- }
-
- var insertMark *list.Element
- var position int
- // We need to iterate through the index to make sure we put this item in the appropriate place according to when it was created.
- // We also need to make sure we're not inserting a duplicate item -- this can happen sometimes and it's not nice UX (*shudder*).
- for e := p.data.Front(); e != nil; e = e.Next() {
- position++
-
- entry, ok := e.Value.(*itemIndexEntry)
- if !ok {
- return false, errors.New("index: could not parse e as an itemIndexEntry")
- }
-
- skip, err := p.skipInsert(ctx, i.itemID, i.accountID, i.boostOfID, i.boostOfAccountID, entry.itemID, entry.accountID, entry.boostOfID, entry.boostOfAccountID, position)
- if err != nil {
- return false, err
- }
- if skip {
- return false, nil
- }
-
- // if the item to index is newer than e, insert it before e in the list
- if insertMark == nil {
- if i.itemID > entry.itemID {
- insertMark = e
- }
- }
- }
-
- if insertMark != nil {
- p.data.InsertBefore(i, insertMark)
- return true, nil
- }
-
- // if we reach this point it's the oldest item we've seen so put it at the back
- p.data.PushBack(i)
- return true, nil
-}