service

package
v0.3.2 Latest Latest
Warning

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

 Go to latest Published: Nov 6, 2024 License: MIT Imports: 66 Imported by: 1

Documentation

Overview

File: service/meta.go

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateTusHandler added in v0.2.0 

func CreateTusHandler(ctx core.Context, config TusHandlerConfig) (*tus.TusHandler, error)

func MailerTemplatesFromEmbed added in v0.2.0 

func MailerTemplatesFromEmbed(embed *embed.FS, prefix string) (map[string]core.MailerTemplate, error)

func NewCronLogger added in v0.2.0 

func NewCronLogger(logger *core.Logger) gocron.Logger

func NewMailerTemplate added in v0.2.0 

func NewMailerTemplate(subject *template.Template, body *template.Template) *mailer.EmailTemplate

func NewMailerTemplateRegistry 

func NewMailerTemplateRegistry() *mailer.TemplateRegistry

func NewStorageHash added in v0.2.0 

func NewStorageHash(hash []byte, typ uint64, cidType uint64, proof []byte) core.StorageHash

func NewStorageHashFromMultihash added in v0.2.0 

func NewStorageHashFromMultihash(hash mh.Multihash, cidType uint64, proof []byte) core.StorageHash

func NewStorageHashFromMultihashBytes added in v0.2.0 

func NewStorageHashFromMultihashBytes(hash []byte, cidType uint64, proof []byte) core.StorageHash

func NewStorageUploadRequest added in v0.2.0 

func NewStorageUploadRequest(options ...core.StorageUploadOption) core.StorageUploadRequest

NewStorageUploadRequest creates a new StorageUploadRequest with the given options

func TaskDefinitionOneTimeJob 

func TaskDefinitionOneTimeJob() gocron.JobDefinition

Types

type AccessServiceDefault added in v0.2.0 

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

func NewAccessService added in v0.2.0 

func NewAccessService() (*AccessServiceDefault, []core.ContextBuilderOption, error)

func (*AccessServiceDefault) AssignRoleToUser added in v0.2.0 

func (a *AccessServiceDefault) AssignRoleToUser(userId uint, role string) error

func (*AccessServiceDefault) CheckAccess added in v0.2.0 

func (a *AccessServiceDefault) CheckAccess(userId uint, fqdn, path, method string) (bool, error)

func (*AccessServiceDefault) ExportModel added in v0.2.0 

func (a *AccessServiceDefault) ExportModel() *core.AccessModel

func (*AccessServiceDefault) ExportUserPolicy added in v0.2.0 

func (a *AccessServiceDefault) ExportUserPolicy(userId uint) ([]*core.AccessPolicy, error)

func (*AccessServiceDefault) ID added in v0.2.0 

func (a *AccessServiceDefault) ID() string

func (*AccessServiceDefault) RegisterRoute added in v0.2.0 

func (a *AccessServiceDefault) RegisterRoute(subdomain, path, method, role string) error

type AuthServiceDefault 

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

func NewAuthService 

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

func (AuthServiceDefault) ID added in v0.2.0 

func (a AuthServiceDefault) ID() string

func (AuthServiceDefault) LoginID added in v0.2.0 

func (a AuthServiceDefault) LoginID(id uint, ip string) (string, 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, rememberMe bool) (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 ConfigServiceDefault added in v0.2.0 

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

func NewConfigService added in v0.2.0 

func NewConfigService() (*ConfigServiceDefault, []core.ContextBuilderOption, error)

func (*ConfigServiceDefault) ID added in v0.2.0 

func (cs *ConfigServiceDefault) ID() string

func (*ConfigServiceDefault) RegisterPropertyHandler added in v0.2.0 

func (cs *ConfigServiceDefault) RegisterPropertyHandler(scope config.Scope, handler core.ConfigPropertyUpdateHandler)

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) error

func (*CronServiceDefault) CreateJob 

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

func (*CronServiceDefault) CreateJobIfNotExists 

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

func (*CronServiceDefault) CreateJobScheduled 

func (c *CronServiceDefault) CreateJobScheduled(function string, args any) error

func (*CronServiceDefault) CreateRecurringOneOffJob added in v0.3.0 

func (c *CronServiceDefault) CreateRecurringOneOffJob(function string, args any) error

func (*CronServiceDefault) ID added in v0.2.0 

func (c *CronServiceDefault) ID() string

func (*CronServiceDefault) JobExists 

func (c *CronServiceDefault) JobExists(function string, args any) (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[core.CronTaskArgs], taskDefFunc core.CronTaskDefArgsFactoryFunction, taskArgFunc core.CronTaskArgsFactoryFunction, recurring bool)

func (*CronServiceDefault) Start 

func (c *CronServiceDefault) Start() error

type HTTPServiceDefault 

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

func NewHTTPService 

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

func (*HTTPServiceDefault) APISubdomain added in v0.2.0 

func (h *HTTPServiceDefault) APISubdomain(id string, proto bool) string

func (*HTTPServiceDefault) ID added in v0.2.0 

func (h *HTTPServiceDefault) ID() string

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 JobConsumer added in v0.2.0 

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

func NewJobConsumer added in v0.2.0 

func NewJobConsumer(cron *CronServiceDefault, function string) *JobConsumer

func (*JobConsumer) Consume added in v0.2.0 

func (jc *JobConsumer) Consume(delivery rmq.Delivery)

type Mailer 

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

func NewMailerService 

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

func (*Mailer) ID added in v0.2.0 

func (m *Mailer) ID() string

func (*Mailer) TemplateRegister added in v0.2.0 

func (m *Mailer) TemplateRegister(name string, template core.MailerTemplate) error

func (*Mailer) TemplateSend 

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

type OTPServiceDefault 

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

func NewOTPService 

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

func (OTPServiceDefault) ID added in v0.2.0 

func (o OTPServiceDefault) ID() string

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) ID added in v0.2.0 

func (p PasswordResetServiceDefault) ID() string

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) AllAccountPins added in v0.2.0 

func (p PinServiceDefault) AllAccountPins(id uint) ([]*models.Pin, error)

func (*PinServiceDefault) CreatePin added in v0.2.0 

func (p *PinServiceDefault) CreatePin(ctx context.Context, pin *models.Pin, protocolData any) (*models.Pin, error)

func (*PinServiceDefault) DeletePin added in v0.2.0 

func (p *PinServiceDefault) DeletePin(ctx context.Context, id uint) error

DeletePin deletes a pin by ID

func (PinServiceDefault) DeletePinByHash 

func (p PinServiceDefault) DeletePinByHash(hash core.StorageHash, userId uint) error

func (*PinServiceDefault) GetPin added in v0.2.0 

func (p *PinServiceDefault) GetPin(ctx context.Context, id uint) (*models.Pin, error)

GetPin retrieves a pin by ID

func (PinServiceDefault) GetPinsByUploadID added in v0.2.0 

func (p PinServiceDefault) GetPinsByUploadID(ctx context.Context, uploadID uint) ([]*models.Pin, error)

func (*PinServiceDefault) GetProtocolPin added in v0.2.0 

func (p *PinServiceDefault) GetProtocolPin(ctx context.Context, id uint) (any, error)

GetProtocolPin retrieves the protocol-specific data for a pin

func (PinServiceDefault) ID added in v0.2.0 

func (p PinServiceDefault) ID() string

func (PinServiceDefault) PinByHash 

func (p PinServiceDefault) PinByHash(hash core.StorageHash, userId uint, protocolData any) error

func (PinServiceDefault) PinByID 

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

func (*PinServiceDefault) QueryPin added in v0.2.0 

func (p *PinServiceDefault) QueryPin(ctx context.Context, query interface{}, filter core.PinFilter) (*models.Pin, error)

func (*PinServiceDefault) QueryProtocolPin added in v0.2.0 

func (p *PinServiceDefault) QueryProtocolPin(ctx context.Context, protocol string, query any, filter core.PinFilter) (any, error)

func (PinServiceDefault) UpdatePin added in v0.2.0 

func (p PinServiceDefault) UpdatePin(ctx context.Context, pin *models.Pin) error

func (*PinServiceDefault) UpdateProtocolPin added in v0.2.0 

func (p *PinServiceDefault) UpdateProtocolPin(ctx context.Context, id uint, protocolData any) error

UpdateProtocolPin updates the protocol-specific data for a pin

func (PinServiceDefault) UploadPinnedByUser 

func (p PinServiceDefault) UploadPinnedByUser(hash core.StorageHash, userId uint) (bool, error)

func (PinServiceDefault) UploadPinnedGlobal 

func (p PinServiceDefault) UploadPinnedGlobal(hash core.StorageHash) (bool, error)

type PortalMetaBuilderDefault added in v0.2.0 

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

PortalMetaBuilderDefault implements core.PortalMetaBuilder

func NewPortalMetaBuilder added in v0.2.0 

func NewPortalMetaBuilder(domain string) *PortalMetaBuilderDefault

NewPortalMetaBuilder creates a new PortalMetaBuilderDefault

func (*PortalMetaBuilderDefault) AddFeatureFlag added in v0.2.0 

func (b *PortalMetaBuilderDefault) AddFeatureFlag(key string, value bool) core.PortalMetaBuilder

AddFeatureFlag adds a feature flag

func (*PortalMetaBuilderDefault) AddPlugin added in v0.2.0 

func (b *PortalMetaBuilderDefault) AddPlugin(key string) core.PortalMetaBuilder

AddPlugin adds a plugin without build info

func (*PortalMetaBuilderDefault) AddPluginMeta added in v0.2.0 

func (b *PortalMetaBuilderDefault) AddPluginMeta(pluginKey string, metaKey string, metaValue any) core.PortalMetaBuilder

AddPluginMeta adds or updates meta for a plugin

func (*PortalMetaBuilderDefault) AddPluginWithBuild added in v0.3.0 

func (b *PortalMetaBuilderDefault) AddPluginWithBuild(key string, buildInfo build.Info) core.PortalMetaBuilder

AddPluginWithBuild adds a plugin with build info

func (*PortalMetaBuilderDefault) Build added in v0.2.0 

func (b *PortalMetaBuilderDefault) Build() *core.PortalMeta

Build returns the built PortalMeta

type PostDataHandler added in v0.2.0 

type PostDataHandler struct {
}

func (*PostDataHandler) CompleteUploadData added in v0.2.0 

func (p *PostDataHandler) CompleteUploadData(_ context.Context, _ *gorm.DB, _ uint) error

func (*PostDataHandler) CreateUploadData added in v0.2.0 

func (p *PostDataHandler) CreateUploadData(_ context.Context, _ *gorm.DB, _ uint, _ any) error

func (*PostDataHandler) DeleteUploadData added in v0.2.0 

func (p *PostDataHandler) DeleteUploadData(_ context.Context, _ *gorm.DB, _ uint) error

func (*PostDataHandler) GetUploadData added in v0.2.0 

func (p *PostDataHandler) GetUploadData(_ context.Context, _ *gorm.DB, _ uint) (any, error)

func (*PostDataHandler) GetUploadDataModel added in v0.2.0 

func (p *PostDataHandler) GetUploadDataModel() any

func (*PostDataHandler) QueryUploadData added in v0.2.0 

func (p *PostDataHandler) QueryUploadData(_ context.Context, tx *gorm.DB, _ any) *gorm.DB

func (*PostDataHandler) UpdateUploadData added in v0.2.0 

func (p *PostDataHandler) UpdateUploadData(_ context.Context, _ *gorm.DB, _ uint, _ any) error

type RenterDefault 

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

func NewRenterService 

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

func (*RenterDefault) AddHostsToAllowlist added in v0.3.0 

func (r *RenterDefault) AddHostsToAllowlist(ctx context.Context, hosts []types.PublicKey) error

func (*RenterDefault) AutopilotConfig added in v0.3.0 

func (r *RenterDefault) AutopilotConfig(_ context.Context) (api.AutopilotConfig, error)

func (*RenterDefault) AutopilotHosts added in v0.3.0 

func (r *RenterDefault) AutopilotHosts(ctx context.Context, usabilityMode core.RenterHostUsabilityMode, filterMode core.RenterHostFilterMode) ([]api.HostResponse, error)

func (*RenterDefault) AutopilotState added in v0.3.0 

func (r *RenterDefault) AutopilotState(_ context.Context) (api.AutopilotStateResponse, error)

func (*RenterDefault) ConsensusState added in v0.3.0 

func (r *RenterDefault) ConsensusState(ctx context.Context) (api.ConsensusState, 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) GetAllowlistedHosts added in v0.3.0 

func (r *RenterDefault) GetAllowlistedHosts(ctx context.Context) ([]types.PublicKey, 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) Host added in v0.3.0 

func (r *RenterDefault) Host(ctx context.Context, host types.PublicKey) (api.Host, error)

func (*RenterDefault) Hosts added in v0.3.0 

func (r *RenterDefault) Hosts(ctx context.Context, usabilityMode core.RenterHostUsabilityMode, filterMode core.RenterHostFilterMode) ([]api.Host, error)

func (*RenterDefault) ID added in v0.2.0 

func (r *RenterDefault) ID() string

func (*RenterDefault) ImportObjectMetadata 

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

func (*RenterDefault) RecommendedFee added in v0.3.0 

func (r *RenterDefault) RecommendedFee(ctx context.Context) (types.Currency, error)

func (*RenterDefault) RedundancySettings 

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

func (*RenterDefault) ScanHost added in v0.3.0 

func (r *RenterDefault) ScanHost(ctx context.Context, host types.PublicKey, hostIP string) (api.RHPScanResponse, error)

func (*RenterDefault) SlabSize added in v0.2.0 

func (r *RenterDefault) SlabSize(ctx context.Context) (uint64, error)

func (*RenterDefault) TestAutoPilotConfig added in v0.3.0 

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

func (*RenterDefault) TriggerAutoPilot added in v0.3.0 

func (r *RenterDefault) TriggerAutoPilot(_ context.Context) (bool, 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, *models.SiaUpload, 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 RequestServiceDefault added in v0.2.0 

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

func NewRequestService added in v0.2.0 

func NewRequestService() (*RequestServiceDefault, []core.ContextBuilderOption, error)

func (*RequestServiceDefault) CompleteRequest added in v0.2.0 

func (r *RequestServiceDefault) CompleteRequest(ctx context.Context, id uint) error

func (*RequestServiceDefault) CompleteUploadData added in v0.2.0 

func (r *RequestServiceDefault) CompleteUploadData(ctx context.Context, id uint) error

func (*RequestServiceDefault) CreateRequest added in v0.2.0 

func (r *RequestServiceDefault) CreateRequest(ctx context.Context, req *models.Request, protocolData any, uploadData any) (*models.Request, error)

func (*RequestServiceDefault) CreateUploadData added in v0.2.0 

func (r *RequestServiceDefault) CreateUploadData(ctx context.Context, id uint, data any) error

func (*RequestServiceDefault) DeleteRequest added in v0.2.0 

func (r *RequestServiceDefault) DeleteRequest(ctx context.Context, id uint) error

func (*RequestServiceDefault) DeleteUploadData added in v0.2.0 

func (r *RequestServiceDefault) DeleteUploadData(ctx context.Context, id uint) error

func (*RequestServiceDefault) GetProtocolData added in v0.2.0 

func (r *RequestServiceDefault) GetProtocolData(ctx context.Context, id uint) (any, error)

func (*RequestServiceDefault) GetRequest added in v0.2.0 

func (r *RequestServiceDefault) GetRequest(ctx context.Context, id uint) (*models.Request, error)

func (*RequestServiceDefault) GetRequestByHash added in v0.2.0 

func (r *RequestServiceDefault) GetRequestByHash(ctx context.Context, hash core.StorageHash, filter core.RequestFilter) (*models.Request, error)

func (*RequestServiceDefault) GetRequestByUploadHash added in v0.2.0 

func (r *RequestServiceDefault) GetRequestByUploadHash(ctx context.Context, hash core.StorageHash, filter core.RequestFilter) (*models.Request, error)

func (*RequestServiceDefault) GetUploadData added in v0.2.0 

func (r *RequestServiceDefault) GetUploadData(ctx context.Context, id uint) (any, error)

func (*RequestServiceDefault) ID added in v0.2.0 

func (r *RequestServiceDefault) ID() string

func (*RequestServiceDefault) ListRequestsByStatus added in v0.2.0 

func (r *RequestServiceDefault) ListRequestsByStatus(ctx context.Context, status string, filter core.RequestFilter) ([]*models.Request, error)

func (*RequestServiceDefault) ListRequestsByUser added in v0.2.0 

func (r *RequestServiceDefault) ListRequestsByUser(ctx context.Context, userID uint, filter core.RequestFilter) ([]*models.Request, error)

func (*RequestServiceDefault) QueryProtocolData added in v0.2.0 

func (r *RequestServiceDefault) QueryProtocolData(ctx context.Context, protocol string, query any, filter core.RequestFilter) (interface{}, error)

func (*RequestServiceDefault) QueryRequest added in v0.2.0 

func (r *RequestServiceDefault) QueryRequest(ctx context.Context, query interface{}, filter core.RequestFilter) (*models.Request, error)

func (*RequestServiceDefault) QueryUploadData added in v0.2.0 

func (r *RequestServiceDefault) QueryUploadData(ctx context.Context, uploadMethod models.RequestOperationType, query any, filter core.RequestFilter) (any, error)

func (*RequestServiceDefault) RequestExists added in v0.2.0 

func (r *RequestServiceDefault) RequestExists(ctx context.Context, id uint) (bool, error)

func (*RequestServiceDefault) UpdateProtocolData added in v0.2.0 

func (r *RequestServiceDefault) UpdateProtocolData(ctx context.Context, id uint, data any) error

func (*RequestServiceDefault) UpdateRequest added in v0.2.0 

func (r *RequestServiceDefault) UpdateRequest(ctx context.Context, req *models.Request) error

func (*RequestServiceDefault) UpdateRequestStatus added in v0.2.0 

func (r *RequestServiceDefault) UpdateRequestStatus(ctx context.Context, id uint, status models.RequestStatusType) error

func (*RequestServiceDefault) UpdateUploadData added in v0.2.0 

func (r *RequestServiceDefault) UpdateUploadData(ctx context.Context, id uint, data any) error

type StorageHashDefault added in v0.2.0 

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

func (StorageHashDefault) CIDType added in v0.2.0 

func (s StorageHashDefault) CIDType() uint64

func (StorageHashDefault) Multihash added in v0.2.0 

func (s StorageHashDefault) Multihash() mh.Multihash

func (StorageHashDefault) Proof added in v0.2.0 

func (s StorageHashDefault) Proof() []byte

func (StorageHashDefault) ProofExists added in v0.2.0 

func (s StorageHashDefault) ProofExists() bool

func (StorageHashDefault) Type added in v0.2.0 

func (s StorageHashDefault) Type() uint64

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 core.StorageHash) error

func (StorageServiceDefault) DeleteObjectProof 

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

func (StorageServiceDefault) DownloadObject 

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

func (StorageServiceDefault) DownloadObjectProof 

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

func (StorageServiceDefault) ID added in v0.2.0 

func (s StorageServiceDefault) ID() string

func (StorageServiceDefault) S3Client 

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

func (StorageServiceDefault) S3DeleteTemporaryUpload added in v0.2.0 

func (s StorageServiceDefault) S3DeleteTemporaryUpload(ctx context.Context, protocol core.StorageProtocol, uploadId string) error

func (StorageServiceDefault) S3GetTemporaryUpload added in v0.2.0 

func (s StorageServiceDefault) S3GetTemporaryUpload(ctx context.Context, protocol core.StorageProtocol, uploadId string) (io.ReadCloser, error)

func (StorageServiceDefault) S3MultipartUpload 

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

func (StorageServiceDefault) S3TemporaryUpload added in v0.2.0 

func (s StorageServiceDefault) S3TemporaryUpload(ctx context.Context, data io.ReadCloser, size uint64, protocol core.StorageProtocol) (string, error)

func (StorageServiceDefault) UploadObject 

func (s StorageServiceDefault) UploadObject(ctx context.Context, request core.StorageUploadRequest) (*models.Upload, error)

func (StorageServiceDefault) UploadObjectProof 

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

func (StorageServiceDefault) UploadStatus 

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

type StorageUploadRequestDefault added in v0.2.0 

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

func (StorageUploadRequestDefault) Data added in v0.2.0 

func (s StorageUploadRequestDefault) Data() io.ReadSeeker

func (StorageUploadRequestDefault) Hash added in v0.2.0 

func (s StorageUploadRequestDefault) Hash() core.StorageHash

func (StorageUploadRequestDefault) MuParams added in v0.2.0 

func (s StorageUploadRequestDefault) MuParams() *core.MultipartUploadParams

func (StorageUploadRequestDefault) Protocol added in v0.2.0 

func (s StorageUploadRequestDefault) Protocol() core.StorageProtocol

func (*StorageUploadRequestDefault) SetData added in v0.2.0 

func (s *StorageUploadRequestDefault) SetData(data io.ReadSeeker)

func (*StorageUploadRequestDefault) SetHash added in v0.2.0 

func (s *StorageUploadRequestDefault) SetHash(hash core.StorageHash)

func (*StorageUploadRequestDefault) SetMuParams added in v0.2.0 

func (s *StorageUploadRequestDefault) SetMuParams(muParams *core.MultipartUploadParams)

func (*StorageUploadRequestDefault) SetProtocol added in v0.2.0 

func (s *StorageUploadRequestDefault) SetProtocol(protocol core.StorageProtocol)

func (*StorageUploadRequestDefault) SetSize added in v0.2.0 

func (s *StorageUploadRequestDefault) SetSize(size uint64)

func (StorageUploadRequestDefault) Size added in v0.2.0 

func (s StorageUploadRequestDefault) Size() uint64

type TUSDataHandler added in v0.2.0 

type TUSDataHandler struct {
}

func (TUSDataHandler) CompleteUploadData added in v0.2.0 

func (T TUSDataHandler) CompleteUploadData(ctx context.Context, tx *gorm.DB, id uint) error

func (TUSDataHandler) CreateUploadData added in v0.2.0 

func (T TUSDataHandler) CreateUploadData(ctx context.Context, tx *gorm.DB, id uint, data any) error

func (TUSDataHandler) DeleteUploadData added in v0.2.0 

func (T TUSDataHandler) DeleteUploadData(ctx context.Context, tx *gorm.DB, id uint) error

func (TUSDataHandler) GetUploadData added in v0.2.0 

func (T TUSDataHandler) GetUploadData(ctx context.Context, tx *gorm.DB, id uint) (any, error)

func (TUSDataHandler) GetUploadDataModel added in v0.2.0 

func (T TUSDataHandler) GetUploadDataModel() any

func (TUSDataHandler) QueryUploadData added in v0.2.0 

func (T TUSDataHandler) QueryUploadData(ctx context.Context, tx *gorm.DB, query any) *gorm.DB

func (TUSDataHandler) UpdateUploadData added in v0.2.0 

func (T TUSDataHandler) UpdateUploadData(ctx context.Context, tx *gorm.DB, id uint, data any) error

type TUSServiceDefault added in v0.2.0 

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

func NewTUSService added in v0.2.0 

func NewTUSService() (*TUSServiceDefault, []core.ContextBuilderOption, error)

func (*TUSServiceDefault) CreateUpload added in v0.2.0 

func (t *TUSServiceDefault) CreateUpload(ctx context.Context, hash core.StorageHash, uploadID string, uploaderID uint, uploaderIP string, protocol core.StorageProtocol, mimeType string) (*models.TUSRequest, error)

func (*TUSServiceDefault) DeleteUpload added in v0.2.0 

func (t *TUSServiceDefault) DeleteUpload(ctx context.Context, uploadID string) error

func (*TUSServiceDefault) ID added in v0.2.0 

func (t *TUSServiceDefault) ID() string

func (*TUSServiceDefault) SetHash added in v0.2.0 

func (t *TUSServiceDefault) SetHash(ctx context.Context, uploadID string, hash core.StorageHash) error

func (*TUSServiceDefault) UploadCompleted added in v0.2.0 

func (t *TUSServiceDefault) UploadCompleted(ctx context.Context, uploadID string) error

func (*TUSServiceDefault) UploadExists added in v0.2.0 

func (t *TUSServiceDefault) UploadExists(ctx context.Context, id string) (bool, *models.TUSRequest)

func (*TUSServiceDefault) UploadHashExists added in v0.2.0 

func (t *TUSServiceDefault) UploadHashExists(ctx context.Context, hash core.StorageHash) (bool, *models.TUSRequest)

func (*TUSServiceDefault) UploadProcessing added in v0.2.0 

func (t *TUSServiceDefault) UploadProcessing(ctx context.Context, uploadID string) error

func (*TUSServiceDefault) UploadProgress added in v0.2.0 

func (t *TUSServiceDefault) UploadProgress(ctx context.Context, uploadID string) error

func (*TUSServiceDefault) Uploads added in v0.2.0 

func (t *TUSServiceDefault) Uploads(ctx context.Context, uploaderID uint) ([]*models.TUSRequest, error)

type TUSUploadCallbackHandler added in v0.2.0 

type TUSUploadCallbackHandler = tus.UploadCallbackHandler

func TUSDefaultUploadCompletedHandler added in v0.2.0 

func TUSDefaultUploadCompletedHandler(ctx core.Context, processHandler TUSUploadCallbackHandler) TUSUploadCallbackHandler

func TUSDefaultUploadCreatedHandler added in v0.2.0 

func TUSDefaultUploadCreatedHandler(ctx core.Context, verifyFunc TUSUploadCreatedVerifyFunc, afterFunc UploadCreatedAfterFunc) TUSUploadCallbackHandler

func TUSDefaultUploadProgressHandler added in v0.2.0 

func TUSDefaultUploadProgressHandler(ctx core.Context) TUSUploadCallbackHandler

func TUSDefaultUploadTerminatedHandler added in v0.2.0 

func TUSDefaultUploadTerminatedHandler(ctx core.Context) TUSUploadCallbackHandler

type TUSUploadCreatedVerifyFunc added in v0.2.0 

type TUSUploadCreatedVerifyFunc = tus.UploadCreatedVerifyFunc

type TusHandler added in v0.2.0 

type TusHandler = tus.TusHandler

type TusHandlerConfig added in v0.2.0 

type TusHandlerConfig = tus.HandlerConfig

type UploadCreatedAfterFunc added in v0.2.0 

type UploadCreatedAfterFunc = tus.UploadCreatedAfterFunc

type UploadServiceDefault added in v0.2.0 

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

func NewMetadataService 

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

func (*UploadServiceDefault) DeleteUpload added in v0.2.0 

func (m *UploadServiceDefault) DeleteUpload(ctx context.Context, objectHash core.StorageHash) error

func (*UploadServiceDefault) GetAllUploads added in v0.2.0 

func (m *UploadServiceDefault) GetAllUploads(ctx context.Context) ([]*models.Upload, error)

func (*UploadServiceDefault) GetUpload added in v0.2.0 

func (m *UploadServiceDefault) GetUpload(ctx context.Context, objectHash core.StorageHash) (*models.Upload, error)

func (*UploadServiceDefault) GetUploadByID added in v0.2.0 

func (m *UploadServiceDefault) GetUploadByID(ctx context.Context, uploadID uint) (*models.Upload, error)

func (*UploadServiceDefault) ID added in v0.2.0 

func (m *UploadServiceDefault) ID() string

func (*UploadServiceDefault) SaveUpload added in v0.2.0 

func (m *UploadServiceDefault) SaveUpload(ctx context.Context, upload *models.Upload) 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) DeleteAccount added in v0.2.0 

func (u *UserServiceDefault) DeleteAccount(userId uint) 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) GetAccountsPendingDeletion added in v0.2.0 

func (u *UserServiceDefault) GetAccountsPendingDeletion() ([]*models.User, error)

func (UserServiceDefault) HashPassword 

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

func (UserServiceDefault) ID added in v0.2.0 

func (u UserServiceDefault) ID() string

func (*UserServiceDefault) IsAccountPendingDeletion added in v0.2.0 

func (u *UserServiceDefault) IsAccountPendingDeletion(userId uint) (bool, error)

func (UserServiceDefault) IsAccountVerified added in v0.2.0 

func (u UserServiceDefault) IsAccountVerified(userId uint) (bool, error)

func (UserServiceDefault) PubkeyExists 

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

func (UserServiceDefault) RegisterTasks added in v0.2.0 

func (u UserServiceDefault) RegisterTasks(crn core.CronService) error

func (*UserServiceDefault) RequestAccountDeletion added in v0.2.0 

func (u *UserServiceDefault) RequestAccountDeletion(userId uint, userIP string) error

func (UserServiceDefault) ScheduleJobs added in v0.2.0 

func (u UserServiceDefault) ScheduleJobs(cron core.CronService) 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 map[string]any) 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
tus
user

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.