service

package

Go to main page

Versions in this module

v0

v0.4.1

Jan 6, 2025

v0.4.0

Dec 31, 2024

v0.3.2

Nov 6, 2024

v0.3.1

Nov 6, 2024

v0.3.0

Nov 6, 2024

Changes in this version

type CronServiceDefault

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

type PortalMetaBuilderDefault

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

type RenterDefault

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

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

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

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

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

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

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

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

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

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

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

+ func (r *RenterDefault) TriggerAutoPilot(_ context.Context) (bool, error)

v0.2.1

Oct 31, 2024

v0.2.0

Oct 30, 2024

Changes in this version

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

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

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

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

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

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

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

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

+ type AccessServiceDefault struct

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

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

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

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

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

+ func (a *AccessServiceDefault) ID() string

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

type AuthServiceDefault

+ func (a AuthServiceDefault) ID() string

+ func (a AuthServiceDefault) LoginID(id uint, ip string) (string, error)

+ type ConfigServiceDefault struct

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

+ func (cs *ConfigServiceDefault) ID() string

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

type CronServiceDefault

+ func (c *CronServiceDefault) ID() string

type HTTPServiceDefault

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

+ func (h *HTTPServiceDefault) ID() string

+ type JobConsumer struct

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

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

type Mailer

+ func (m *Mailer) ID() string

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

type OTPServiceDefault

+ func (o OTPServiceDefault) ID() string

type PasswordResetServiceDefault

+ func (p PasswordResetServiceDefault) ID() string

type PinServiceDefault

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

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

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

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

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

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

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

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

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

+ func (p PinServiceDefault) ID() string

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

+ type PortalMetaBuilderDefault struct

+ func NewPortalMetaBuilder(domain string) *PortalMetaBuilderDefault

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

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

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

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

+ type PostDataHandler struct

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

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

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

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

+ func (p *PostDataHandler) GetUploadDataModel() any

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

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

type RenterDefault

+ func (r *RenterDefault) ID() string

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

+ type RequestServiceDefault struct

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

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

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

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

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

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

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

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

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

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

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

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

+ func (r *RequestServiceDefault) ID() string

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

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

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

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

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

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

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

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

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

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

+ type StorageHashDefault struct

+ func (s StorageHashDefault) CIDType() uint64

+ func (s StorageHashDefault) Multihash() mh.Multihash

+ func (s StorageHashDefault) Proof() []byte

+ func (s StorageHashDefault) ProofExists() bool

+ func (s StorageHashDefault) Type() uint64

type StorageServiceDefault

+ func (s StorageServiceDefault) ID() string

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

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

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

+ type StorageUploadRequestDefault struct

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

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

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

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

+ func (s *StorageUploadRequestDefault) SetSize(size uint64)

+ func (s StorageUploadRequestDefault) Data() io.ReadSeeker

+ func (s StorageUploadRequestDefault) Hash() core.StorageHash

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

+ func (s StorageUploadRequestDefault) Protocol() core.StorageProtocol

+ func (s StorageUploadRequestDefault) Size() uint64

+ type TUSDataHandler struct

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

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

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

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

+ func (T TUSDataHandler) GetUploadDataModel() any

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

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

+ type TUSServiceDefault struct

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

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

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

+ func (t *TUSServiceDefault) ID() string

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

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

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

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

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

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

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

+ type TUSUploadCallbackHandler = tus.UploadCallbackHandler

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

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

+ func TUSDefaultUploadProgressHandler(ctx core.Context) TUSUploadCallbackHandler

+ func TUSDefaultUploadTerminatedHandler(ctx core.Context) TUSUploadCallbackHandler

+ type TUSUploadCreatedVerifyFunc = tus.UploadCreatedVerifyFunc

+ type TusHandler = tus.TusHandler

+ type TusHandlerConfig = tus.HandlerConfig

+ type UploadCreatedAfterFunc = tus.UploadCreatedAfterFunc

+ type UploadServiceDefault struct

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

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

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

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

+ func (m *UploadServiceDefault) ID() string

+ func (m *UploadServiceDefault) SaveUpload(ctx context.Context, upload *models.Upload) error

type UserServiceDefault

+ func (u *UserServiceDefault) DeleteAccount(userId uint) error

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

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

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

+ func (u UserServiceDefault) ID() string

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

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

+ func (u UserServiceDefault) ScheduleJobs(cron core.CronService) error

v0.1.1

Jun 19, 2024

Changes in this version

type HTTPServiceDefault

+ func (h *HTTPServiceDefault) Init() error

v0.1.0

Jun 19, 2024

Changes in this version

+ var ErrNotFound = gorm.ErrRecordNotFound

+ func NewMailerTemplateRegistry() *mailer.TemplateRegistry

+ func TaskDefinitionOneTimeJob() gocron.JobDefinition

+ type AuthServiceDefault struct

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

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

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

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

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

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

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

+ type CronServiceDefault struct

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

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

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

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

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

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

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

+ func (c *CronServiceDefault) RegisterTask(name string, taskFunc core.CronTaskFunction, ...)

+ func (c *CronServiceDefault) Start() error

+ type DNSLinkServiceDefault struct

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

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

+ type HTTPServiceDefault struct

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

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

+ func (h *HTTPServiceDefault) Serve() error

+ type ImportServiceDefault struct

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

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

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

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

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

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

+ type Mailer struct

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

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

+ type MetadataServiceDefault struct

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

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

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

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

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

+ type OTPServiceDefault struct

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

+ func (o OTPServiceDefault) OTPDisable(userId uint) error

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

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

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

+ type PasswordResetServiceDefault struct

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

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

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

+ type PinServiceDefault struct

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

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

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

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

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

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

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

+ type RenterDefault struct

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type StorageServiceDefault struct

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

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

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

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

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

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

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

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

+ func (s StorageServiceDefault) UploadObject(ctx context.Context, protocol core.StorageProtocol, data io.ReadSeeker, ...) (*core.UploadMetadata, error)

+ func (s StorageServiceDefault) UploadObjectProof(ctx context.Context, protocol core.StorageProtocol, data io.ReadSeeker, ...) error

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

+ type UserServiceDefault struct

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

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

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

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

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

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

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

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

+ func (u UserServiceDefault) SendEmailVerification(userId uint) error

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

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

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

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

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

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

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL