services

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Oct 15, 2023 License: MPL-2.0 Imports: 32 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidEventDeliveryStatus  = errors.New("only successful events can be force resent")
	ErrNoValidEndpointFound        = errors.New("no valid endpoint found")
	ErrNoValidOwnerIDEndpointFound = errors.New("owner ID has no configured endpoints")
	ErrInvalidEndpointID           = errors.New("please provide an endpoint ID")
)
View Source 
var (
	ErrInvalidSubscriptionFilterFormat = errors.New("invalid subscription filter format")
	ErrCreateSubscriptionError         = errors.New("failed to create subscription")
)
View Source 
var (
	ErrUpdateSubscriptionError   = errors.New("failed to update subscription")
	ErrValidateSubscriptionError = errors.New("failed to validate subscription")
)
View Source 
var ErrInvalidEndpoints = errors.New("endpoints cannot be empty")

Functions

func ValidateEndpointAuthentication added in v0.8.0 

func ValidateEndpointAuthentication(auth *datastore.EndpointAuthentication) (*datastore.EndpointAuthentication, error)

Types

type BatchReplayEventService added in v1.1.6 

type BatchReplayEventService struct {
	EndpointRepo datastore.EndpointRepository
	Queue        queue.Queuer
	EventRepo    datastore.EventRepository

	Filter *datastore.Filter
}

func (*BatchReplayEventService) Run added in v1.1.6 

func (e *BatchReplayEventService) Run(ctx context.Context) (int, int, error)

type BatchRetryEventDeliveryService added in v1.1.6 

type BatchRetryEventDeliveryService struct {
	EventDeliveryRepo datastore.EventDeliveryRepository
	EndpointRepo      datastore.EndpointRepository
	Queue             queue.Queuer
	EventRepo         datastore.EventRepository

	Filter *datastore.Filter
}

func (*BatchRetryEventDeliveryService) Run added in v1.1.6 

func (e *BatchRetryEventDeliveryService) Run(ctx context.Context) (int, int, error)

type CancelOrgMemberService added in v1.1.6 

type CancelOrgMemberService struct {
	Queue      queue.Queuer
	InviteRepo datastore.OrganisationInviteRepository
	InviteID   string
}

func (*CancelOrgMemberService) Run added in v1.1.6 

func (co *CancelOrgMemberService) Run(ctx context.Context) (*datastore.OrganisationInvite, error)

type CreateAPIKeyService added in v1.1.6 

type CreateAPIKeyService struct {
	ProjectRepo datastore.ProjectRepository
	APIKeyRepo  datastore.APIKeyRepository

	Member    *datastore.OrganisationMember
	NewApiKey *models.APIKey
}

func (*CreateAPIKeyService) Run added in v1.1.6 

func (ss *CreateAPIKeyService) Run(ctx context.Context) (*datastore.APIKey, string, error)

type CreateConfigService added in v1.1.6 

type CreateConfigService struct {
	ConfigRepo datastore.ConfigurationRepository
	NewConfig  *models.Configuration
}

func (*CreateConfigService) Run added in v1.1.6 

func (c *CreateConfigService) Run(ctx context.Context) (*datastore.Configuration, error)

type CreateDynamicEventService added in v1.1.6 

type CreateDynamicEventService struct {
	Queue queue.Queuer

	DynamicEvent *models.DynamicEvent
	Project      *datastore.Project
}

func (*CreateDynamicEventService) Run added in v1.1.6 

func (e *CreateDynamicEventService) Run(ctx context.Context) error

type CreateEndpointAPIKeyService added in v1.1.6 

type CreateEndpointAPIKeyService struct {
	APIKeyRepo datastore.APIKeyRepository
	D          *models.CreateEndpointApiKey
}

func (*CreateEndpointAPIKeyService) Run added in v1.1.6 

func (ss *CreateEndpointAPIKeyService) Run(ctx context.Context) (*datastore.APIKey, string, error)

type CreateEndpointPortalLinkService added in v1.1.6 

type CreateEndpointPortalLinkService struct {
	PortalLinkRepo datastore.PortalLinkRepository
	EndpointRepo   datastore.EndpointRepository
	Cache          cache.Cache
	ProjectRepo    datastore.ProjectRepository

	Project    *datastore.Project
	Data       models.CreateEndpoint
	PortalLink *datastore.PortalLink
}

func (*CreateEndpointPortalLinkService) Run added in v1.1.6 

func (p *CreateEndpointPortalLinkService) Run(ctx context.Context) (*datastore.Endpoint, error)

type CreateEndpointService added in v1.1.6 

type CreateEndpointService struct {
	Cache          cache.Cache
	PortalLinkRepo datastore.PortalLinkRepository
	EndpointRepo   datastore.EndpointRepository
	ProjectRepo    datastore.ProjectRepository

	E         models.CreateEndpoint
	ProjectID string
}

func (*CreateEndpointService) Run added in v1.1.6 

func (a *CreateEndpointService) Run(ctx context.Context) (*datastore.Endpoint, error)

type CreateEventService added in v1.1.6 

type CreateEventService struct {
	EndpointRepo datastore.EndpointRepository
	EventRepo    datastore.EventRepository
	Queue        queue.Queuer

	NewMessage *models.CreateEvent
	Project    *datastore.Project
}

func (*CreateEventService) FindEndpoints added in v1.1.6 

func (c *CreateEventService) FindEndpoints(ctx context.Context, newMessage *models.CreateEvent, project *datastore.Project) ([]datastore.Endpoint, error)

func (*CreateEventService) Run added in v1.1.6 

func (c *CreateEventService) Run(ctx context.Context) (*datastore.Event, error)

type CreateFanoutEventService added in v1.1.6 

type CreateFanoutEventService struct {
	EndpointRepo   datastore.EndpointRepository
	EventRepo      datastore.EventRepository
	PortalLinkRepo datastore.PortalLinkRepository
	Queue          queue.Queuer

	NewMessage *models.FanoutEvent
	Project    *datastore.Project
}

func (*CreateFanoutEventService) Run added in v1.1.6 

func (e *CreateFanoutEventService) Run(ctx context.Context) (*datastore.Event, error)

type CreateOrganisationService added in v1.1.6 

type CreateOrganisationService struct {
	OrgRepo       datastore.OrganisationRepository
	OrgMemberRepo datastore.OrganisationMemberRepository
	NewOrg        *models.Organisation
	User          *datastore.User
}

func (*CreateOrganisationService) Run added in v1.1.6 

func (co *CreateOrganisationService) Run(ctx context.Context) (*datastore.Organisation, error)

type CreatePersonalAPIKeyService added in v1.1.6 

type CreatePersonalAPIKeyService struct {
	ProjectRepo datastore.ProjectRepository
	UserRepo    datastore.UserRepository
	APIKeyRepo  datastore.APIKeyRepository

	User      *datastore.User
	NewApiKey *models.PersonalAPIKey
}

func (*CreatePersonalAPIKeyService) Run added in v1.1.6 

func (cpa *CreatePersonalAPIKeyService) Run(ctx context.Context) (*datastore.APIKey, string, error)

type CreatePortalLinkService added in v1.1.6 

type CreatePortalLinkService struct {
	PortalLinkRepo datastore.PortalLinkRepository
	EndpointRepo   datastore.EndpointRepository

	Portal  *models.PortalLink
	Project *datastore.Project
}

func (*CreatePortalLinkService) Run added in v1.1.6 

func (p *CreatePortalLinkService) Run(ctx context.Context) (*datastore.PortalLink, error)

type CreateSourceService added in v1.1.6 

type CreateSourceService struct {
	SourceRepo datastore.SourceRepository
	Cache      cache.Cache
	NewSource  *models.CreateSource
	Project    *datastore.Project
}

func (*CreateSourceService) Run added in v1.1.6 

func (s *CreateSourceService) Run(ctx context.Context) (*datastore.Source, error)

type CreateSubscriptionService added in v1.1.6 

type CreateSubscriptionService struct {
	SubRepo         datastore.SubscriptionRepository
	EndpointRepo    datastore.EndpointRepository
	SourceRepo      datastore.SourceRepository
	Project         *datastore.Project
	NewSubscription *models.CreateSubscription
}

func (*CreateSubscriptionService) Run added in v1.1.6 

func (s *CreateSubscriptionService) Run(ctx context.Context) (*datastore.Subscription, error)

type DeviceService added in v0.7.0 

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

func NewDeviceService added in v0.7.0 

func NewDeviceService(deviceRepo datastore.DeviceRepository) *DeviceService

func (*DeviceService) LoadDevicesPaged added in v0.7.0 

func (d *DeviceService) LoadDevicesPaged(ctx context.Context, g *datastore.Project, f *datastore.ApiKeyFilter, pageable datastore.Pageable) ([]datastore.Device, datastore.PaginationData, error)

type ExpireSecretService added in v1.1.6 

type ExpireSecretService struct {
	Queuer       queue.Queuer
	Cache        cache.Cache
	EndpointRepo datastore.EndpointRepository
	ProjectRepo  datastore.ProjectRepository

	S        *models.ExpireSecret
	Endpoint *datastore.Endpoint
	Project  *datastore.Project
}

func (*ExpireSecretService) Run added in v1.1.6 

func (a *ExpireSecretService) Run(ctx context.Context) (*datastore.Endpoint, error)

type FindUserByInviteTokenService added in v1.1.6 

type FindUserByInviteTokenService struct {
	Queue      queue.Queuer
	InviteRepo datastore.OrganisationInviteRepository
	OrgRepo    datastore.OrganisationRepository
	UserRepo   datastore.UserRepository

	Token string
}

func (*FindUserByInviteTokenService) Run added in v1.1.6 

func (ri *FindUserByInviteTokenService) Run(ctx context.Context) (*datastore.User, *datastore.OrganisationInvite, error)

type ForceResendEventDeliveriesService added in v1.1.6 

type ForceResendEventDeliveriesService struct {
	EventDeliveryRepo datastore.EventDeliveryRepository
	EndpointRepo      datastore.EndpointRepository
	Queue             queue.Queuer

	IDs     []string
	Project *datastore.Project
}

func (*ForceResendEventDeliveriesService) Run added in v1.1.6 

func (e *ForceResendEventDeliveriesService) Run(ctx context.Context) (int, int, error)

type GeneratePasswordResetTokenService added in v1.1.6 

type GeneratePasswordResetTokenService struct {
	UserRepo datastore.UserRepository
	Queue    queue.Queuer

	BaseURL string
	Data    *models.ForgotPassword
}

func (*GeneratePasswordResetTokenService) Run added in v1.1.6 

func (u *GeneratePasswordResetTokenService) Run(ctx context.Context) error

type InviteUserService added in v1.1.6 

type InviteUserService struct {
	Queue      queue.Queuer
	InviteRepo datastore.OrganisationInviteRepository

	InviteeEmail string
	Role         auth.Role
	User         *datastore.User
	Organisation *datastore.Organisation
}

func (*InviteUserService) Run added in v1.1.6 

func (iu *InviteUserService) Run(ctx context.Context) (*datastore.OrganisationInvite, error)

type LoginUserService added in v1.1.6 

type LoginUserService struct {
	UserRepo datastore.UserRepository
	Cache    cache.Cache
	JWT      *jwt.Jwt
	Data     *models.LoginUser
}

func (*LoginUserService) Run added in v1.1.6 

func (u *LoginUserService) Run(ctx context.Context) (*datastore.User, *jwt.Token, error)

type LogoutUserService added in v1.1.6 

type LogoutUserService struct {
	JWT      *jwt.Jwt
	UserRepo datastore.UserRepository
	Token    string
}

func (*LogoutUserService) Run added in v1.1.6 

func (u *LogoutUserService) Run(ctx context.Context) error

type MetaEvent added in v1.1.6 

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

func NewMetaEvent added in v1.1.6 

func NewMetaEvent(queue queue.Queuer, projectRepo datastore.ProjectRepository, metaEventRepo datastore.MetaEventRepository) *MetaEvent

func (*MetaEvent) Run added in v1.1.6 

func (m *MetaEvent) Run(eventType string, projectID string, data interface{}) error

type MetaEventService added in v1.1.6 

type MetaEventService struct {
	Queue         queue.Queuer
	MetaEventRepo datastore.MetaEventRepository
}

func (*MetaEventService) Run added in v1.1.6 

func (m *MetaEventService) Run(ctx context.Context, metaEvent *datastore.MetaEvent) error

type OrganisationMemberService added in v0.6.0 

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

func NewOrganisationMemberService added in v0.6.0 

func NewOrganisationMemberService(orgMemberRepo datastore.OrganisationMemberRepository) *OrganisationMemberService

func (*OrganisationMemberService) CreateOrganisationMember added in v0.6.0 

func (om *OrganisationMemberService) CreateOrganisationMember(ctx context.Context, org *datastore.Organisation, user *datastore.User, role *auth.Role) (*datastore.OrganisationMember, error)

func (*OrganisationMemberService) DeleteOrganisationMember added in v0.6.0 

func (om *OrganisationMemberService) DeleteOrganisationMember(ctx context.Context, memberID string, org *datastore.Organisation) error

func (*OrganisationMemberService) UpdateOrganisationMember added in v0.6.0 

func (om *OrganisationMemberService) UpdateOrganisationMember(ctx context.Context, organisationMember *datastore.OrganisationMember, role *auth.Role) (*datastore.OrganisationMember, error)

type PauseEndpointService added in v1.1.6 

type PauseEndpointService struct {
	EndpointRepo datastore.EndpointRepository
	ProjectID    string
	EndpointId   string
}

func (*PauseEndpointService) Run added in v1.1.6 

func (s *PauseEndpointService) Run(ctx context.Context) (*datastore.Endpoint, error)

type ProcessInviteService added in v1.1.6 

type ProcessInviteService struct {
	Queue         queue.Queuer
	InviteRepo    datastore.OrganisationInviteRepository
	UserRepo      datastore.UserRepository
	OrgRepo       datastore.OrganisationRepository
	OrgMemberRepo datastore.OrganisationMemberRepository

	Token    string
	Accepted bool
	NewUser  *models.User
}

func (*ProcessInviteService) Run added in v1.1.6 

func (pis *ProcessInviteService) Run(ctx context.Context) error

type ProjectService added in v0.8.0 

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

func NewProjectService added in v0.8.0 

func NewProjectService(apiKeyRepo datastore.APIKeyRepository, projectRepo datastore.ProjectRepository, eventRepo datastore.EventRepository, eventDeliveryRepo datastore.EventDeliveryRepository, cache cache.Cache) (*ProjectService, error)

func (*ProjectService) CreateProject added in v0.8.0 

func (ps *ProjectService) CreateProject(ctx context.Context, newProject *models.CreateProject, org *datastore.Organisation, member *datastore.OrganisationMember) (*datastore.Project, *models.APIKeyResponse, error)

func (*ProjectService) UpdateProject added in v0.8.0 

func (ps *ProjectService) UpdateProject(ctx context.Context, project *datastore.Project, update *models.UpdateProject) (*datastore.Project, error)

type RefreshTokenService added in v1.1.6 

type RefreshTokenService struct {
	UserRepo datastore.UserRepository
	JWT      *jwt.Jwt

	Data *models.Token
}

func (*RefreshTokenService) Run added in v1.1.6 

func (u *RefreshTokenService) Run(ctx context.Context) (*jwt.Token, error)

type RegenerateProjectAPIKeyService added in v1.1.6 

type RegenerateProjectAPIKeyService struct {
	ProjectRepo datastore.ProjectRepository
	UserRepo    datastore.UserRepository
	APIKeyRepo  datastore.APIKeyRepository

	Project *datastore.Project
	Member  *datastore.OrganisationMember
}

func (*RegenerateProjectAPIKeyService) Run added in v1.1.6 

func (ss *RegenerateProjectAPIKeyService) Run(ctx context.Context) (*datastore.APIKey, string, error)

type RegisterUserService added in v1.1.6 

type RegisterUserService struct {
	UserRepo      datastore.UserRepository
	OrgRepo       datastore.OrganisationRepository
	OrgMemberRepo datastore.OrganisationMemberRepository
	Queue         queue.Queuer
	JWT           *jwt.Jwt
	ConfigRepo    datastore.ConfigurationRepository

	BaseURL string
	Data    *models.RegisterUser
}

func (*RegisterUserService) Run added in v1.1.6 

func (u *RegisterUserService) Run(ctx context.Context) (*datastore.User, *jwt.Token, error)

type ReplayEventService added in v1.1.6 

type ReplayEventService struct {
	EndpointRepo datastore.EndpointRepository
	Queue        queue.Queuer

	Event *datastore.Event
}

func (*ReplayEventService) Run added in v1.1.6 

func (e *ReplayEventService) Run(ctx context.Context) error

type ResendEmailVerificationTokenService added in v1.1.6 

type ResendEmailVerificationTokenService struct {
	UserRepo datastore.UserRepository
	Queue    queue.Queuer

	BaseURL string
	User    *datastore.User
}

func (*ResendEmailVerificationTokenService) Run added in v1.1.6 

func (u *ResendEmailVerificationTokenService) Run(ctx context.Context) error

type ResendOrgMemberService added in v1.1.6 

type ResendOrgMemberService struct {
	Queue      queue.Queuer
	InviteRepo datastore.OrganisationInviteRepository

	InviteID     string
	User         *datastore.User
	Organisation *datastore.Organisation
}

func (*ResendOrgMemberService) Run added in v1.1.6 

func (rs *ResendOrgMemberService) Run(ctx context.Context) (*datastore.OrganisationInvite, error)

type ResetPasswordService added in v1.1.6 

type ResetPasswordService struct {
	UserRepo datastore.UserRepository

	Token string
	Data  *models.ResetPassword
}

func (*ResetPasswordService) Run added in v1.1.6 

func (u *ResetPasswordService) Run(ctx context.Context) (*datastore.User, error)

type RetryEventDeliveryService added in v1.1.6 

type RetryEventDeliveryService struct {
	EventDeliveryRepo datastore.EventDeliveryRepository
	EndpointRepo      datastore.EndpointRepository
	Queue             queue.Queuer

	EventDelivery *datastore.EventDelivery
	Project       *datastore.Project
}

func (*RetryEventDeliveryService) Run added in v1.1.6 

func (e *RetryEventDeliveryService) Run(ctx context.Context) error

type RevokePersonalAPIKeyService added in v1.1.6 

type RevokePersonalAPIKeyService struct {
	ProjectRepo datastore.ProjectRepository
	UserRepo    datastore.UserRepository
	APIKeyRepo  datastore.APIKeyRepository

	UID  string
	User *datastore.User
}

func (*RevokePersonalAPIKeyService) Run added in v1.1.6 

func (ss *RevokePersonalAPIKeyService) Run(ctx context.Context) error

type SearchEventService added in v1.1.6 

type SearchEventService struct {
	EventRepo datastore.EventRepository
	Searcher  searcher.Searcher

	Filter *datastore.Filter
}

func (*SearchEventService) Run added in v1.1.6 

func (e *SearchEventService) Run(ctx context.Context) ([]datastore.Event, datastore.PaginationData, error)

type ServiceError 

type ServiceError struct {
	ErrMsg string
	Err    error
}

func (*ServiceError) Error 

func (a *ServiceError) Error() string

func (*ServiceError) Unwrap added in v1.1.6 

func (a *ServiceError) Unwrap() error

type ToggleEndpointStatusService added in v1.1.6 

type ToggleEndpointStatusService struct {
	EndpointRepo datastore.EndpointRepository
	ProjectID    string
	EndpointId   string
}

func (*ToggleEndpointStatusService) Run added in v1.1.6 

func (s *ToggleEndpointStatusService) Run(ctx context.Context) (*datastore.Endpoint, error)

type UpdateAPIKeyService added in v1.1.6 

type UpdateAPIKeyService struct {
	ProjectRepo datastore.ProjectRepository
	UserRepo    datastore.UserRepository
	APIKeyRepo  datastore.APIKeyRepository

	UID  string
	Role *auth.Role
}

func (*UpdateAPIKeyService) Run added in v1.1.6 

func (ss *UpdateAPIKeyService) Run(ctx context.Context) (*datastore.APIKey, error)

type UpdateConfigService added in v1.1.6 

type UpdateConfigService struct {
	ConfigRepo datastore.ConfigurationRepository
	Config     *models.Configuration
}

func (*UpdateConfigService) Run added in v1.1.6 

func (c *UpdateConfigService) Run(ctx context.Context) (*datastore.Configuration, error)

type UpdateEndpointService added in v1.1.6 

type UpdateEndpointService struct {
	Cache        cache.Cache
	EndpointRepo datastore.EndpointRepository
	ProjectRepo  datastore.ProjectRepository

	E        models.UpdateEndpoint
	Endpoint *datastore.Endpoint
	Project  *datastore.Project
}

func (*UpdateEndpointService) Run added in v1.1.6 

func (a *UpdateEndpointService) Run(ctx context.Context) (*datastore.Endpoint, error)

type UpdateOrganisationService added in v1.1.6 

type UpdateOrganisationService struct {
	OrgRepo       datastore.OrganisationRepository
	OrgMemberRepo datastore.OrganisationMemberRepository
	Org           *datastore.Organisation
	Update        *models.Organisation
}

func (*UpdateOrganisationService) Run added in v1.1.6 

func (os *UpdateOrganisationService) Run(ctx context.Context) (*datastore.Organisation, error)

type UpdatePasswordService added in v1.1.6 

type UpdatePasswordService struct {
	UserRepo datastore.UserRepository

	Data *models.UpdatePassword
	User *datastore.User
}

func (*UpdatePasswordService) Run added in v1.1.6 

func (u *UpdatePasswordService) Run(ctx context.Context) (*datastore.User, error)

type UpdatePortalLinkService added in v1.1.6 

type UpdatePortalLinkService struct {
	PortalLinkRepo datastore.PortalLinkRepository
	EndpointRepo   datastore.EndpointRepository

	Project    *datastore.Project
	Update     *models.PortalLink
	PortalLink *datastore.PortalLink
}

func (*UpdatePortalLinkService) Run added in v1.1.6 

func (p *UpdatePortalLinkService) Run(ctx context.Context) (*datastore.PortalLink, error)

type UpdateSourceService added in v1.1.6 

type UpdateSourceService struct {
	SourceRepo   datastore.SourceRepository
	Cache        cache.Cache
	Project      *datastore.Project
	SourceUpdate *models.UpdateSource
	Source       *datastore.Source
}

func (*UpdateSourceService) Run added in v1.1.6 

func (s *UpdateSourceService) Run(ctx context.Context) (*datastore.Source, error)

type UpdateSubscriptionService added in v1.1.6 

type UpdateSubscriptionService struct {
	SubRepo        datastore.SubscriptionRepository
	EndpointRepo   datastore.EndpointRepository
	SourceRepo     datastore.SourceRepository
	ProjectId      string
	SubscriptionId string
	Update         *models.UpdateSubscription
}

func (*UpdateSubscriptionService) Run added in v1.1.6 

func (s *UpdateSubscriptionService) Run(ctx context.Context) (*datastore.Subscription, error)

type UpdateUserService added in v1.1.6 

type UpdateUserService struct {
	UserRepo datastore.UserRepository

	Data *models.UpdateUser
	User *datastore.User
}

func (*UpdateUserService) Run added in v1.1.6 

func (u *UpdateUserService) Run(ctx context.Context) (*datastore.User, error)

type VerifyEmailService added in v1.1.6 

type VerifyEmailService struct {
	UserRepo datastore.UserRepository
	Token    string
}

func (*VerifyEmailService) Run added in v1.1.6 

func (u *VerifyEmailService) Run(ctx context.Context) error

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.