mirror of
				https://github.com/superseriousbusiness/gotosocial.git
				synced 2025-11-03 23:12:26 -06:00 
			
		
		
		
	* revamp http client to not limit requests, instead use sender worker Signed-off-by: kim <grufwub@gmail.com> * remove separate sender worker pool, spawn 2*GOMAXPROCS batch senders each time, no need for transport cache sweeping Signed-off-by: kim <grufwub@gmail.com> * improve batch senders to keep popping recipients until remote URL found Signed-off-by: kim <grufwub@gmail.com> * fix recipient looping issue Signed-off-by: kim <grufwub@gmail.com> * fix missing mutex unlock Signed-off-by: kim <grufwub@gmail.com> * move request id ctx key to gtscontext, finish filling out more code comments, add basic support for not logging client IP Signed-off-by: kim <grufwub@gmail.com> * slight code reformatting Signed-off-by: kim <grufwub@gmail.com> * a whitespace Signed-off-by: kim <grufwub@gmail.com> * remove unused code Signed-off-by: kim <grufwub@gmail.com> * add missing license headers Signed-off-by: kim <grufwub@gmail.com> * fix request backoff calculation Signed-off-by: kim <grufwub@gmail.com> --------- Signed-off-by: kim <grufwub@gmail.com>
		
			
				
	
	
		
			91 lines
		
	
	
	
		
			3.4 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			91 lines
		
	
	
	
		
			3.4 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 gtscontext
 | 
						|
 | 
						|
import (
 | 
						|
	"context"
 | 
						|
)
 | 
						|
 | 
						|
// package private context key type.
 | 
						|
type ctxkey uint
 | 
						|
 | 
						|
const (
 | 
						|
	// context keys.
 | 
						|
	_ ctxkey = iota
 | 
						|
	barebonesKey
 | 
						|
	fastFailKey
 | 
						|
	pubKeyIDKey
 | 
						|
	requestIDKey
 | 
						|
)
 | 
						|
 | 
						|
// RequestID returns the request ID associated with context. This value will usually
 | 
						|
// be set by the request ID middleware handler, either pulling an existing supplied
 | 
						|
// value from request headers, or generating a unique new entry. This is useful for
 | 
						|
// tying together log entries associated with an original incoming request.
 | 
						|
func RequestID(ctx context.Context) string {
 | 
						|
	id, _ := ctx.Value(requestIDKey).(string)
 | 
						|
	return id
 | 
						|
}
 | 
						|
 | 
						|
// SetRequestID stores the given request ID value and returns the wrapped
 | 
						|
// context. See RequestID() for further information on the request ID value.
 | 
						|
func SetRequestID(ctx context.Context, id string) context.Context {
 | 
						|
	return context.WithValue(ctx, requestIDKey, id)
 | 
						|
}
 | 
						|
 | 
						|
// PublicKeyID returns the public key ID (URI) associated with context. This
 | 
						|
// value is useful for logging situations in which a given public key URI is
 | 
						|
// relevant, e.g. for outgoing requests being signed by the given key.
 | 
						|
func PublicKeyID(ctx context.Context) string {
 | 
						|
	id, _ := ctx.Value(pubKeyIDKey).(string)
 | 
						|
	return id
 | 
						|
}
 | 
						|
 | 
						|
// SetPublicKeyID stores the given public key ID value and returns the wrapped
 | 
						|
// context. See PublicKeyID() for further information on the public key ID value.
 | 
						|
func SetPublicKeyID(ctx context.Context, id string) context.Context {
 | 
						|
	return context.WithValue(ctx, pubKeyIDKey, id)
 | 
						|
}
 | 
						|
 | 
						|
// IsFastFail returns whether the "fastfail" context key has been set. This
 | 
						|
// can be used to indicate to an http client, for example, that the result
 | 
						|
// of an outgoing request is time sensitive and so not to bother with retries.
 | 
						|
func IsFastfail(ctx context.Context) bool {
 | 
						|
	_, ok := ctx.Value(fastFailKey).(struct{})
 | 
						|
	return ok
 | 
						|
}
 | 
						|
 | 
						|
// SetFastFail sets the "fastfail" context flag and returns this wrapped context.
 | 
						|
// See IsFastFail() for further information on the "fastfail" context flag.
 | 
						|
func SetFastFail(ctx context.Context) context.Context {
 | 
						|
	return context.WithValue(ctx, fastFailKey, struct{}{})
 | 
						|
}
 | 
						|
 | 
						|
// Barebones returns whether the "barebones" context key has been set. This
 | 
						|
// can be used to indicate to the database, for example, that only a barebones
 | 
						|
// model need be returned, Allowing it to skip populating sub models.
 | 
						|
func Barebones(ctx context.Context) bool {
 | 
						|
	_, ok := ctx.Value(barebonesKey).(struct{})
 | 
						|
	return ok
 | 
						|
}
 | 
						|
 | 
						|
// SetBarebones sets the "barebones" context flag and returns this wrapped context.
 | 
						|
// See Barebones() for further information on the "barebones" context flag.
 | 
						|
func SetBarebones(ctx context.Context) context.Context {
 | 
						|
	return context.WithValue(ctx, barebonesKey, struct{}{})
 | 
						|
}
 |