service

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Jun 19, 2024 License: MIT Imports: 47 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrNotFound = gorm.ErrRecordNotFound

Functions

func NewMailerTemplateRegistry 

func NewMailerTemplateRegistry() *mailer.TemplateRegistry

func TaskDefinitionOneTimeJob 

func TaskDefinitionOneTimeJob() gocron.JobDefinition

Types

type AuthServiceDefault 

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

func NewAuthService 

func NewAuthService() (*AuthServiceDefault, []core.ContextBuilderOption, error)

func (AuthServiceDefault) LoginOTP 

func (a AuthServiceDefault) LoginOTP(userId uint, code string) (string, error)

func (AuthServiceDefault) LoginPassword 

func (a AuthServiceDefault) LoginPassword(email string, password string, ip string) (string, *models.User, error)

func (AuthServiceDefault) LoginPubkey 

func (a AuthServiceDefault) LoginPubkey(pubkey string, ip string) (string, error)

func (AuthServiceDefault) ValidLoginByEmail 

func (a AuthServiceDefault) ValidLoginByEmail(email string, password string) (bool, *models.User, error)

func (AuthServiceDefault) ValidLoginByUserID 

func (a AuthServiceDefault) ValidLoginByUserID(id uint, password string) (bool, *models.User, error)

func (AuthServiceDefault) ValidLoginByUserObj 

func (a AuthServiceDefault) ValidLoginByUserObj(user *models.User, password string) bool

type CronServiceDefault 

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

func NewCronService 

func NewCronService() (*CronServiceDefault, []core.ContextBuilderOption, error)

func (*CronServiceDefault) CreateExistingJobScheduled 

func (c *CronServiceDefault) CreateExistingJobScheduled(uuid uuid.UUID, jobDef gocron.JobDefinition) error

func (*CronServiceDefault) CreateJob 

func (c *CronServiceDefault) CreateJob(function string, args any, tags []string) error

func (*CronServiceDefault) CreateJobIfNotExists 

func (c *CronServiceDefault) CreateJobIfNotExists(function string, args any, tags []string) error

func (*CronServiceDefault) CreateJobScheduled 

func (c *CronServiceDefault) CreateJobScheduled(function string, args any, tags []string, jobDef gocron.JobDefinition) error

func (*CronServiceDefault) JobExists 

func (c *CronServiceDefault) JobExists(function string, args any, tags []string) (bool, *models.CronJob)

func (*CronServiceDefault) RegisterEntity 

func (c *CronServiceDefault) RegisterEntity(service core.Cronable)

func (*CronServiceDefault) RegisterTask 

func (c *CronServiceDefault) RegisterTask(name string, taskFunc core.CronTaskFunction, taskDefFunc core.CronTaskDefArgsFactoryFunction, taskArgFunc core.CronTaskArgsFactoryFunction)

func (*CronServiceDefault) Start 

func (c *CronServiceDefault) Start() error

type DNSLinkServiceDefault 

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

func NewDNSLinkService 

func NewDNSLinkService() (*DNSLinkServiceDefault, []core.ContextBuilderOption, error)

func (DNSLinkServiceDefault) DNSLinkExists 

func (p DNSLinkServiceDefault) DNSLinkExists(hash []byte) (bool, *models.DNSLink, error)

type HTTPServiceDefault 

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

func NewHTTPService 

func NewHTTPService() (*HTTPServiceDefault, []core.ContextBuilderOption, error)

func (*HTTPServiceDefault) Init added in v0.1.1 

func (h *HTTPServiceDefault) Init() error

func (*HTTPServiceDefault) Router 

func (h *HTTPServiceDefault) Router() *mux.Router

func (*HTTPServiceDefault) Serve 

func (h *HTTPServiceDefault) Serve() error

type ImportServiceDefault 

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

func NewImportService 

func NewImportService() (*ImportServiceDefault, []core.ContextBuilderOption, error)

func (ImportServiceDefault) DeleteImport 

func (i ImportServiceDefault) DeleteImport(ctx context.Context, objectHash []byte) error

func (ImportServiceDefault) GetImport 

func (i ImportServiceDefault) GetImport(ctx context.Context, objectHash []byte) (core.ImportMetadata, error)

func (ImportServiceDefault) SaveImport 

func (i ImportServiceDefault) SaveImport(ctx context.Context, metadata core.ImportMetadata, skipExisting bool) error

func (ImportServiceDefault) UpdateProgress 

func (i ImportServiceDefault) UpdateProgress(ctx context.Context, objectHash []byte, stage int, totalStages int) error

func (ImportServiceDefault) UpdateStatus 

func (i ImportServiceDefault) UpdateStatus(ctx context.Context, objectHash []byte, status models.ImportStatus) error

type Mailer 

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

func NewMailerService 

func NewMailerService(templateRegistry *mailer.TemplateRegistry) (*Mailer, []core.ContextBuilderOption, error)

func (*Mailer) TemplateSend 

func (m *Mailer) TemplateSend(template string, subjectVars core.MailerTemplateData, bodyVars core.MailerTemplateData, to string) error

type MetadataServiceDefault 

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

func NewMetadataService 

func NewMetadataService() (*MetadataServiceDefault, []core.ContextBuilderOption, error)

func (*MetadataServiceDefault) DeleteUpload 

func (m *MetadataServiceDefault) DeleteUpload(ctx context.Context, objectHash []byte) error

func (*MetadataServiceDefault) GetAllUploads 

func (m *MetadataServiceDefault) GetAllUploads(ctx context.Context) ([]core.UploadMetadata, error)

func (*MetadataServiceDefault) GetUpload 

func (m *MetadataServiceDefault) GetUpload(ctx context.Context, objectHash []byte) (core.UploadMetadata, error)

func (*MetadataServiceDefault) SaveUpload 

func (m *MetadataServiceDefault) SaveUpload(ctx context.Context, metadata core.UploadMetadata, skipExisting bool) error

type OTPServiceDefault 

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

func NewOTPService 

func NewOTPService() (*OTPServiceDefault, []core.ContextBuilderOption, error)

func (OTPServiceDefault) OTPDisable 

func (o OTPServiceDefault) OTPDisable(userId uint) error

func (OTPServiceDefault) OTPEnable 

func (o OTPServiceDefault) OTPEnable(userId uint, code string) error

func (OTPServiceDefault) OTPGenerate 

func (o OTPServiceDefault) OTPGenerate(userId uint) (string, error)

func (OTPServiceDefault) OTPVerify 

func (o OTPServiceDefault) OTPVerify(userId uint, code string) (bool, error)

type PasswordResetServiceDefault 

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

func NewPasswordResetService 

func NewPasswordResetService() (*PasswordResetServiceDefault, []core.ContextBuilderOption, error)

func (PasswordResetServiceDefault) ResetPassword 

func (p PasswordResetServiceDefault) ResetPassword(email string, token string, password string) error

func (PasswordResetServiceDefault) SendPasswordReset 

func (p PasswordResetServiceDefault) SendPasswordReset(user *models.User) error

type PinServiceDefault 

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

func NewPinService 

func NewPinService() (*PinServiceDefault, []core.ContextBuilderOption, error)

func (PinServiceDefault) AccountPins 

func (p PinServiceDefault) AccountPins(id uint, createdAfter uint64) ([]models.Pin, error)

func (PinServiceDefault) DeletePinByHash 

func (p PinServiceDefault) DeletePinByHash(hash []byte, userId uint) error

func (PinServiceDefault) PinByHash 

func (p PinServiceDefault) PinByHash(hash []byte, userId uint) error

func (PinServiceDefault) PinByID 

func (p PinServiceDefault) PinByID(uploadId uint, userId uint) error

func (PinServiceDefault) UploadPinnedByUser 

func (p PinServiceDefault) UploadPinnedByUser(hash []byte, userId uint) (bool, error)

func (PinServiceDefault) UploadPinnedGlobal 

func (p PinServiceDefault) UploadPinnedGlobal(hash []byte) (bool, error)

type RenterDefault 

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

func NewRenterService 

func NewRenterService() (*RenterDefault, []core.ContextBuilderOption, error)

func (*RenterDefault) CreateBucketIfNotExists 

func (r *RenterDefault) CreateBucketIfNotExists(bucket string) error

func (*RenterDefault) DeleteObject 

func (r *RenterDefault) DeleteObject(ctx context.Context, bucket string, fileName string) error

func (*RenterDefault) DeleteObjectMetadata 

func (r *RenterDefault) DeleteObjectMetadata(ctx context.Context, bucket string, fileName string) error

func (*RenterDefault) GetObject 

func (r *RenterDefault) GetObject(ctx context.Context, bucket string, fileName string, options api.DownloadObjectOptions) (*api.GetObjectResponse, error)

func (*RenterDefault) GetObjectMetadata 

func (r *RenterDefault) GetObjectMetadata(ctx context.Context, bucket string, fileName string) (*api.Object, error)

func (*RenterDefault) GetSetting 

func (r *RenterDefault) GetSetting(ctx context.Context, setting string, out any) error

func (*RenterDefault) GougingSettings 

func (r *RenterDefault) GougingSettings(ctx context.Context) (api.GougingSettings, error)

func (*RenterDefault) ImportObjectMetadata 

func (r *RenterDefault) ImportObjectMetadata(ctx context.Context, bucket string, fileName string, object_ object.Object) error

func (*RenterDefault) RedundancySettings 

func (r *RenterDefault) RedundancySettings(ctx context.Context) (api.RedundancySettings, error)

func (*RenterDefault) UpdateGougingSettings 

func (r *RenterDefault) UpdateGougingSettings(ctx context.Context, settings api.GougingSettings) error

func (*RenterDefault) UploadExists 

func (r *RenterDefault) UploadExists(ctx context.Context, bucket string, fileName string) (bool, error)

func (*RenterDefault) UploadObject 

func (r *RenterDefault) UploadObject(ctx context.Context, file io.Reader, bucket string, fileName string) error

func (*RenterDefault) UploadObjectMultipart 

func (r *RenterDefault) UploadObjectMultipart(ctx context.Context, params *core.MultiPartUploadParams) error

type StorageServiceDefault 

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

func NewStorageService 

func NewStorageService() (*StorageServiceDefault, []core.ContextBuilderOption, error)

func (StorageServiceDefault) DeleteObject 

func (s StorageServiceDefault) DeleteObject(ctx context.Context, protocol core.StorageProtocol, objectHash []byte) error

func (StorageServiceDefault) DeleteObjectProof 

func (s StorageServiceDefault) DeleteObjectProof(ctx context.Context, protocol core.StorageProtocol, objectHash []byte) error

func (StorageServiceDefault) DownloadObject 

func (s StorageServiceDefault) DownloadObject(ctx context.Context, protocol core.StorageProtocol, objectHash []byte, start int64) (io.ReadCloser, error)

func (StorageServiceDefault) DownloadObjectProof 

func (s StorageServiceDefault) DownloadObjectProof(ctx context.Context, protocol core.StorageProtocol, objectHash []byte) (io.ReadCloser, error)

func (StorageServiceDefault) HashObject 

func (s StorageServiceDefault) HashObject(ctx context.Context, data io.Reader, size uint64) (*bao.Result, error)

func (StorageServiceDefault) S3Client 

func (s StorageServiceDefault) S3Client(ctx context.Context) (*s3.Client, error)

func (StorageServiceDefault) S3MultipartUpload 

func (s StorageServiceDefault) S3MultipartUpload(ctx context.Context, data io.ReadCloser, bucket, key string, size uint64) error

func (StorageServiceDefault) UploadObject 

func (s StorageServiceDefault) UploadObject(ctx context.Context, protocol core.StorageProtocol, data io.ReadSeeker, size uint64, muParams *core.MultiPartUploadParams, proof *bao.Result) (*core.UploadMetadata, error)

func (StorageServiceDefault) UploadObjectProof 

func (s StorageServiceDefault) UploadObjectProof(ctx context.Context, protocol core.StorageProtocol, data io.ReadSeeker, proof *bao.Result, size uint64) error

func (StorageServiceDefault) UploadStatus 

func (s StorageServiceDefault) UploadStatus(ctx context.Context, protocol core.StorageProtocol, objectName string) (core.StorageUploadStatus, error)

type UserServiceDefault 

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

func NewUserService 

func NewUserService() (*UserServiceDefault, []core.ContextBuilderOption, error)

func (UserServiceDefault) AccountExists 

func (u UserServiceDefault) AccountExists(id uint) (bool, *models.User, error)

func (UserServiceDefault) AddPubkeyToAccount 

func (u UserServiceDefault) AddPubkeyToAccount(user models.User, pubkey string) error

func (UserServiceDefault) CreateAccount 

func (u UserServiceDefault) CreateAccount(email string, password string, verifyEmail bool) (*models.User, error)

func (UserServiceDefault) EmailExists 

func (u UserServiceDefault) EmailExists(email string) (bool, *models.User, error)

func (UserServiceDefault) Exists 

func (u UserServiceDefault) Exists(model any, conditions map[string]any) (bool, any, error)

func (UserServiceDefault) HashPassword 

func (u UserServiceDefault) HashPassword(password string) (string, error)

func (UserServiceDefault) PubkeyExists 

func (u UserServiceDefault) PubkeyExists(pubkey string) (bool, *models.PublicKey, error)

func (UserServiceDefault) SendEmailVerification 

func (u UserServiceDefault) SendEmailVerification(userId uint) error

func (UserServiceDefault) UpdateAccountEmail 

func (u UserServiceDefault) UpdateAccountEmail(userId uint, email string, password string) error

func (UserServiceDefault) UpdateAccountInfo 

func (u UserServiceDefault) UpdateAccountInfo(userId uint, info models.User) error

func (UserServiceDefault) UpdateAccountName 

func (u UserServiceDefault) UpdateAccountName(userId uint, firstName string, lastName string) error

func (UserServiceDefault) UpdateAccountPassword 

func (u UserServiceDefault) UpdateAccountPassword(userId uint, password string, newPassword string) error

func (UserServiceDefault) ValidLoginByUserID 

func (u UserServiceDefault) ValidLoginByUserID(id uint, password string) (bool, *models.User, error)

func (UserServiceDefault) ValidLoginByUserObj 

func (u UserServiceDefault) ValidLoginByUserObj(user *models.User, password string) bool

func (UserServiceDefault) VerifyEmail 

func (u UserServiceDefault) VerifyEmail(email string, token string) error

Source Files

View all Source files

Directories

Path Synopsis
internal
auth
mailer
renter

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.