diff options
author | 2024-02-09 15:24:49 +0100 | |
---|---|---|
committer | 2024-02-09 14:24:49 +0000 | |
commit | e890169e6f151f668580398685c2dbf3c4b780ff (patch) | |
tree | 3d3be4348eee2c71288c93772cfcaa128aabd71b /internal/processing/workers | |
parent | [chore] Move `DoOnce` func wrapper to util (#2613) (diff) | |
download | gotosocial-e890169e6f151f668580398685c2dbf3c4b780ff.tar.xz |
use pointer for freshness window (#2614)
Diffstat (limited to 'internal/processing/workers')
-rw-r--r-- | internal/processing/workers/fromfediapi.go | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/internal/processing/workers/fromfediapi.go b/internal/processing/workers/fromfediapi.go index 6dd4e543d..74ec0db25 100644 --- a/internal/processing/workers/fromfediapi.go +++ b/internal/processing/workers/fromfediapi.go @@ -23,6 +23,8 @@ import ( "codeberg.org/gruf/go-kv" "codeberg.org/gruf/go-logger/v2/level" "github.com/superseriousbusiness/gotosocial/internal/ap" + "github.com/superseriousbusiness/gotosocial/internal/federation/dereferencing" + "github.com/superseriousbusiness/gotosocial/internal/gtscontext" "github.com/superseriousbusiness/gotosocial/internal/gtserror" "github.com/superseriousbusiness/gotosocial/internal/gtsmodel" @@ -179,7 +181,8 @@ func (p *fediAPI) CreateStatus(ctx context.Context, fMsg messages.FromFediAPI) e fMsg.ReceivingAccount.Username, bareStatus, statusable, - true, + // Force refresh within 5min window. + dereferencing.Fresh, ) if err != nil { return gtserror.Newf("error processing new status %s: %w", bareStatus.URI, err) @@ -487,7 +490,8 @@ func (p *fediAPI) UpdateAccount(ctx context.Context, fMsg messages.FromFediAPI) fMsg.ReceivingAccount.Username, account, apubAcc, - true, // Force refresh. + // Force refresh within 5min window. + dereferencing.Fresh, ) if err != nil { log.Errorf(ctx, "error refreshing account: %v", err) @@ -512,7 +516,8 @@ func (p *fediAPI) UpdateStatus(ctx context.Context, fMsg messages.FromFediAPI) e fMsg.ReceivingAccount.Username, existing, apStatus, - true, + // Force refresh within 5min window. + dereferencing.Fresh, ) if err != nil { log.Errorf(ctx, "error refreshing status: %v", err) |