server

package
v0.0.0-...-a65c8f7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 31, 2020 License: MIT Imports: 60 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// characters used for short-urls
	SYMBOLS = "0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ"

	// someone set us up the bomb !!
	BASE = int64(len(SYMBOLS))
)
View Source 
const GDriveDirectoryMimeType = "application/vnd.google-apps.folder"
View Source 
const GDriveRootConfigFile = "root_id.conf"
View Source 
const GDriveTokenJsonFile = "token.json"
View Source 
const SERVER_INFO = "transfer.sh"

Variables

This section is empty.

Functions

func Decode 

func Decode(input string) int64

Decodes a string given in our encoding and returns the decimal integer.

func Encode 

func Encode(number int64) string

encodes a number into our *base* representation TODO can this be made better with some bitshifting?

func IPFilterHandler 

func IPFilterHandler(h http.Handler, ipFilterOptions *IPFilterOptions) http.HandlerFunc

func LoveHandler 

func LoveHandler(h http.Handler) http.HandlerFunc

Create a log handler for every request it receives.

func RenderFloat 

func RenderFloat(format string, n float64) string

func RenderInteger 

func RenderInteger(format string, n int) string

func WrapIPFilter 

func WrapIPFilter(next http.Handler, opts IPFilterOptions) http.Handler

WrapIPFilter is equivalent to NewIPFilter(opts) then Wrap(next)

Types

type GDrive 

type GDrive struct {
	// contains filtered or unexported fields
}

func NewGDriveStorage 

func NewGDriveStorage(clientJsonFilepath string, localConfigPath string, basedir string, chunkSize int, logger *log.Logger) (*GDrive, error)

func (*GDrive) Delete 

func (s *GDrive) Delete(token string, filename string) (err error)

func (*GDrive) Get 

func (s *GDrive) Get(token string, filename string) (reader io.ReadCloser, contentLength uint64, err error)

func (*GDrive) Head 

func (s *GDrive) Head(token string, filename string) (contentLength uint64, err error)

func (*GDrive) IsNotExist 

func (s *GDrive) IsNotExist(err error) bool

func (*GDrive) Put 

func (s *GDrive) Put(token string, filename string, reader io.Reader, contentType string, contentLength uint64) error

func (*GDrive) Type 

func (s *GDrive) Type() string

type IPFilter 

type IPFilter struct {
	// contains filtered or unexported fields
}

func NewIPFilter 

func NewIPFilter(opts IPFilterOptions) *IPFilter

New constructs IPFilter instance.

func (*IPFilter) AllowIP 

func (f *IPFilter) AllowIP(ip string) bool

func (*IPFilter) Allowed 

func (f *IPFilter) Allowed(ipstr string) bool

Allowed returns if a given IP can pass through the filter

func (*IPFilter) BlockIP 

func (f *IPFilter) BlockIP(ip string) bool

func (*IPFilter) Blocked 

func (f *IPFilter) Blocked(ip string) bool

Blocked returns if a given IP can NOT pass through the filter

func (*IPFilter) NetAllowed 

func (f *IPFilter) NetAllowed(ip net.IP) bool

NetAllowed returns if a given net.IP can pass through the filter

func (*IPFilter) NetBlocked 

func (f *IPFilter) NetBlocked(ip net.IP) bool

NetBlocked returns if a given net.IP can NOT pass through the filter

func (*IPFilter) ToggleDefault 

func (f *IPFilter) ToggleDefault(allowed bool)

ToggleDefault alters the default setting

func (*IPFilter) ToggleIP 

func (f *IPFilter) ToggleIP(str string, allowed bool) bool

func (*IPFilter) Wrap 

func (f *IPFilter) Wrap(next http.Handler) http.Handler

WrapIPFilter the provided handler with simple IP blocking middleware using this IP filter and its configuration

type IPFilterOptions 

type IPFilterOptions struct {
	//explicity allowed IPs
	AllowedIPs []string
	//explicity blocked IPs
	BlockedIPs []string
	//block by default (defaults to allow)
	BlockByDefault bool
	// TrustProxy enable check request IP from proxy
	TrustProxy bool

	Logger interface {
		Printf(format string, v ...interface{})
	}
}

IPFilterOptions for IPFilter. Allowed takes precendence over Blocked. IPs can be IPv4 or IPv6 and can optionally contain subnet masks (/24). Note however, determining if a given IP is included in a subnet requires a linear scan so is less performant than looking up single IPs.

This could be improved with some algorithmic magic.

type LocalStorage 

type LocalStorage struct {
	Storage
	// contains filtered or unexported fields
}

func NewLocalStorage 

func NewLocalStorage(basedir string, logger *log.Logger) (*LocalStorage, error)

func (*LocalStorage) Delete 

func (s *LocalStorage) Delete(token string, filename string) (err error)

func (*LocalStorage) Get 

func (s *LocalStorage) Get(token string, filename string) (reader io.ReadCloser, contentLength uint64, err error)

func (*LocalStorage) Head 

func (s *LocalStorage) Head(token string, filename string) (contentLength uint64, err error)

func (*LocalStorage) IsNotExist 

func (s *LocalStorage) IsNotExist(err error) bool

func (*LocalStorage) Put 

func (s *LocalStorage) Put(token string, filename string, reader io.Reader, contentType string, contentLength uint64) error

func (*LocalStorage) Type 

func (s *LocalStorage) Type() string

type Metadata 

type Metadata struct {
	// ContentType is the original uploading content type
	ContentType string
	// Secret as knowledge to delete file
	// Secret string
	// Downloads is the actual number of downloads
	Downloads int
	// MaxDownloads contains the maximum numbers of downloads
	MaxDownloads int
	// MaxDate contains the max age of the file
	MaxDate time.Time
	// DeletionToken contains the token to match against for deletion
	DeletionToken string
}

func MetadataForRequest 

func MetadataForRequest(contentType string, r *http.Request) Metadata

type OptionFn 

type OptionFn func(*Server)

func ClamavHost 

func ClamavHost(s string) OptionFn

func CorsDomains 

func CorsDomains(s string) OptionFn

func EnableProfiler 

func EnableProfiler() OptionFn

func FilterOptions 

func FilterOptions(options IPFilterOptions) OptionFn

func ForceHTTPs 

func ForceHTTPs() OptionFn

func GoogleAnalytics 

func GoogleAnalytics(gaKey string) OptionFn

func HttpAuthCredentials 

func HttpAuthCredentials(user string, pass string) OptionFn

func Listener 

func Listener(s string) OptionFn

func LogFile 

func LogFile(logger *log.Logger, s string) OptionFn

func Logger 

func Logger(logger *log.Logger) OptionFn

func ProfileListener 

func ProfileListener(s string) OptionFn

func ProxyPath 

func ProxyPath(s string) OptionFn

func ProxyPort 

func ProxyPort(s string) OptionFn

func RateLimit 

func RateLimit(requests int) OptionFn

func TLSConfig 

func TLSConfig(cert, pk string) OptionFn

func TLSListener 

func TLSListener(s string, t bool) OptionFn

func TempPath 

func TempPath(s string) OptionFn

func UseLetsEncrypt 

func UseLetsEncrypt(hosts []string) OptionFn

func UseStorage 

func UseStorage(s Storage) OptionFn

func UserVoice 

func UserVoice(userVoiceKey string) OptionFn

func VirustotalKey 

func VirustotalKey(s string) OptionFn

func WebPath 

func WebPath(s string) OptionFn

type S3Storage 

type S3Storage struct {
	Storage
	// contains filtered or unexported fields
}

func NewS3Storage 

func NewS3Storage(accessKey, secretKey, bucketName, region, endpoint string, logger *log.Logger, disableMultipart bool, forcePathStyle bool) (*S3Storage, error)

func (*S3Storage) Delete 

func (s *S3Storage) Delete(token string, filename string) (err error)

func (*S3Storage) Get 

func (s *S3Storage) Get(token string, filename string) (reader io.ReadCloser, contentLength uint64, err error)

func (*S3Storage) Head 

func (s *S3Storage) Head(token string, filename string) (contentLength uint64, err error)

func (*S3Storage) IsNotExist 

func (s *S3Storage) IsNotExist(err error) bool

func (*S3Storage) Put 

func (s *S3Storage) Put(token string, filename string, reader io.Reader, contentType string, contentLength uint64) (err error)

func (*S3Storage) Type 

func (s *S3Storage) Type() string

type Server 

type Server struct {
	AuthUser string
	AuthPass string

	VirusTotalKey    string
	ClamAVDaemonHost string

	TLSListenerOnly bool

	CorsDomains           string
	ListenerString        string
	TLSListenerString     string
	ProfileListenerString string

	Certificate string

	LetsEncryptCache string
	// contains filtered or unexported fields
}

func New 

func New(options ...OptionFn) (*Server, error)

func (*Server) BasicAuthHandler 

func (s *Server) BasicAuthHandler(h http.Handler) http.HandlerFunc

func (*Server) CheckDeletionToken 

func (s *Server) CheckDeletionToken(deletionToken, token, filename string) error

func (*Server) CheckMetadata 

func (s *Server) CheckMetadata(token, filename string, increaseDownload bool) (Metadata, error)

func (*Server) Lock 

func (s *Server) Lock(token, filename string) error

func (*Server) RedirectHandler 

func (s *Server) RedirectHandler(h http.Handler) http.HandlerFunc

func (*Server) Run 

func (s *Server) Run()

func (*Server) Unlock 

func (s *Server) Unlock(token, filename string) error

type Storage 

type Storage interface {
	Get(token string, filename string) (reader io.ReadCloser, contentLength uint64, err error)
	Head(token string, filename string) (contentLength uint64, err error)
	Put(token string, filename string, reader io.Reader, contentType string, contentLength uint64) error
	Delete(token string, filename string) error
	IsNotExist(err error) bool

	Type() string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.