mirror of
				https://github.com/superseriousbusiness/gotosocial.git
				synced 2025-11-03 20:02:27 -06:00 
			
		
		
		
	# Description - updates account delete processing to handle side-effects synchronously to prevent OOM - updates account delete processing to check more often if account.IsLocal() for certain deletes / side-effects - ensures that mutes get removed from database on delete ## Checklist - [x] I/we have read the [GoToSocial contribution guidelines](https://codeberg.org/superseriousbusiness/gotosocial/src/branch/main/CONTRIBUTING.md). - [x] I/we have discussed the proposed changes already, either in an issue on the repository, or in the Matrix chat. - [x] I/we have not leveraged AI to create the proposed changes. - [x] I/we have performed a self-review of added code. - [x] I/we have written code that is legible and maintainable by others. - [x] I/we have commented the added code, particularly in hard-to-understand areas. - [ ] I/we have made any necessary changes to documentation. - [ ] I/we have added tests that cover new code. - [ ] I/we have run tests and they pass locally with the changes. - [x] I/we have run `go fmt ./...` and `golangci-lint run`. Reviewed-on: https://codeberg.org/superseriousbusiness/gotosocial/pulls/4260 Co-authored-by: kim <grufwub@gmail.com> Co-committed-by: kim <grufwub@gmail.com>
		
			
				
	
	
		
			72 lines
		
	
	
	
		
			1.8 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			72 lines
		
	
	
	
		
			1.8 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
// 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 util
 | 
						|
 | 
						|
import (
 | 
						|
	"fmt"
 | 
						|
	"os"
 | 
						|
	"runtime"
 | 
						|
 | 
						|
	"codeberg.org/gruf/go-errors/v2"
 | 
						|
)
 | 
						|
 | 
						|
// Must executes 'fn' repeatedly until
 | 
						|
// it successfully returns without panic.
 | 
						|
func Must(fn func()) {
 | 
						|
	if fn == nil {
 | 
						|
		panic("nil func")
 | 
						|
	}
 | 
						|
	for !func() (done bool) {
 | 
						|
		defer Recover()
 | 
						|
		fn()
 | 
						|
		done = true
 | 
						|
		return
 | 
						|
	}() { //nolint
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
// Recover wraps runtime.recover() to dump the current
 | 
						|
// stack to stderr on panic and return the panic value.
 | 
						|
func Recover() any {
 | 
						|
	if r := recover(); r != nil {
 | 
						|
		// Gather calling func frames.
 | 
						|
		pcs := make([]uintptr, 10)
 | 
						|
		n := runtime.Callers(3, pcs)
 | 
						|
		i := runtime.CallersFrames(pcs[:n])
 | 
						|
		c := gatherFrames(i, n)
 | 
						|
		fmt.Fprintf(os.Stderr, "recovered panic: %v\n\n%s\n", r, c.String())
 | 
						|
		return r
 | 
						|
	}
 | 
						|
	return nil
 | 
						|
}
 | 
						|
 | 
						|
// gatherFrames collates runtime frames from a frame iterator.
 | 
						|
func gatherFrames(iter *runtime.Frames, n int) errors.Callers {
 | 
						|
	if iter == nil {
 | 
						|
		return nil
 | 
						|
	}
 | 
						|
	frames := make([]runtime.Frame, 0, n)
 | 
						|
	for {
 | 
						|
		f, ok := iter.Next()
 | 
						|
		if !ok {
 | 
						|
			break
 | 
						|
		}
 | 
						|
		frames = append(frames, f)
 | 
						|
	}
 | 
						|
	return frames
 | 
						|
}
 |