database

package
v0.23.0 Latest Latest
Warning

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

 Go to latest Published: Aug 6, 2025 License: AGPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetDatabase 

func GetDatabase(dsn string, debug bool) (*gorm.DB, error)

Types

type CertQuery 

type CertQuery struct {
	Query[model.Certificate]
	// contains filtered or unexported fields
}

func NewCertQuery 

func NewCertQuery(db *gorm.DB) *CertQuery

func (*CertQuery) Count 

func (q *CertQuery) Count() int64

func (*CertQuery) Delete 

func (q *CertQuery) Delete() error

func (*CertQuery) Get 

func (q *CertQuery) Get() []*model.Certificate

func (*CertQuery) Limit 

func (q *CertQuery) Limit(n int) *CertQuery

func (*CertQuery) Login 

func (q *CertQuery) Login(login string) *CertQuery

func (*CertQuery) Offset 

func (q *CertQuery) Offset(n int) *CertQuery

func (*CertQuery) One 

func (q *CertQuery) One() *model.Certificate

func (*CertQuery) Order 

func (q *CertQuery) Order(s string) *CertQuery

func (*CertQuery) SN 

func (q *CertQuery) SN(sn string) *CertQuery

func (*CertQuery) UID 

func (q *CertQuery) UID(uid string) *CertQuery

func (*CertQuery) Update 

func (q *CertQuery) Update(updates map[string]any) error

type ChangeQuery 

type ChangeQuery struct {
	Query[model.Change]
	// contains filtered or unexported fields
}

func NewChangeQuery 

func NewChangeQuery(db *gorm.DB) *ChangeQuery

func (*ChangeQuery) After 

func (q *ChangeQuery) After(t time.Time) *ChangeQuery

func (*ChangeQuery) Delete 

func (q *ChangeQuery) Delete() error

func (*ChangeQuery) Get 

func (q *ChangeQuery) Get() []*model.Change

func (*ChangeQuery) Id 

func (q *ChangeQuery) Id(id uint) *ChangeQuery

func (*ChangeQuery) Limit 

func (q *ChangeQuery) Limit(n int) *ChangeQuery

func (*ChangeQuery) Mission 

func (q *ChangeQuery) Mission(id uint) *ChangeQuery

func (*ChangeQuery) Offset 

func (q *ChangeQuery) Offset(n int) *ChangeQuery

func (*ChangeQuery) One 

func (q *ChangeQuery) One() *model.Change

func (*ChangeQuery) Order 

func (q *ChangeQuery) Order(s string) *ChangeQuery

func (*ChangeQuery) Update 

func (q *ChangeQuery) Update(updates map[string]any) error

type DatabaseManager 

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

func New 

func New(db *gorm.DB) *DatabaseManager

func (*DatabaseManager) AddDefaults 

func (mm *DatabaseManager) AddDefaults()

func (*DatabaseManager) AddMissionPoint 

func (mm *DatabaseManager) AddMissionPoint(mission *model.Mission, msg *cot.CotMessage) *model.Change

func (*DatabaseManager) AddMissionResource 

func (mm *DatabaseManager) AddMissionResource(mission *model.Mission, hash string, authorUID string) *model.Change

func (*DatabaseManager) CertsQuery 

func (mm *DatabaseManager) CertsQuery() *CertQuery

func (*DatabaseManager) ChangeQuery 

func (mm *DatabaseManager) ChangeQuery() *ChangeQuery

func (*DatabaseManager) Create 

func (mm *DatabaseManager) Create(s any) error

func (*DatabaseManager) CreateMission 

func (mm *DatabaseManager) CreateMission(m *model.Mission) error

func (*DatabaseManager) DeleteMissionContent 

func (mm *DatabaseManager) DeleteMissionContent(mission *model.Mission, hash string, authorUID string) *model.Change

func (*DatabaseManager) DeleteMissionPoint 

func (mm *DatabaseManager) DeleteMissionPoint(mission *model.Mission, uid string, authorUID string) *model.Change

func (*DatabaseManager) DeviceQuery 

func (mm *DatabaseManager) DeviceQuery() *DeviceQuery

func (*DatabaseManager) FeedQuery added in v0.23.0 

func (mm *DatabaseManager) FeedQuery() *FeedQuery

func (*DatabaseManager) ForceSave 

func (mm *DatabaseManager) ForceSave(s any) error

func (*DatabaseManager) GetChanges 

func (mm *DatabaseManager) GetChanges(missionId uint, after time.Time, squashed bool) []*model.Change

func (*DatabaseManager) GetInvitations 

func (mm *DatabaseManager) GetInvitations(uid string) []string

func (*DatabaseManager) GetSubscribers 

func (mm *DatabaseManager) GetSubscribers(missionId uint) []string

func (*DatabaseManager) InvitationQuery 

func (mm *DatabaseManager) InvitationQuery() *InvitationQuery

func (*DatabaseManager) Invite 

func (mm *DatabaseManager) Invite(s *model.Invitation) (*model.Invitation, error)

func (*DatabaseManager) Migrate 

func (mm *DatabaseManager) Migrate() error

func (*DatabaseManager) MissionQuery 

func (mm *DatabaseManager) MissionQuery() *MissionQuery

func (*DatabaseManager) PointQuery 

func (mm *DatabaseManager) PointQuery() *PointQuery

func (*DatabaseManager) ProfileQuery 

func (mm *DatabaseManager) ProfileQuery() *ProfileQuery

func (*DatabaseManager) ResourceQuery 

func (mm *DatabaseManager) ResourceQuery() *ResourceQuery

func (*DatabaseManager) Save 

func (mm *DatabaseManager) Save(s any) error

func (*DatabaseManager) Subscribe 

func (mm *DatabaseManager) Subscribe(user *model.Device, mission *model.Mission, uid, password string) (*model.Subscription, error)

func (*DatabaseManager) SubscriptionQuery 

func (mm *DatabaseManager) SubscriptionQuery() *SubscriptionQuery

func (*DatabaseManager) UpdateContentTool 

func (mm *DatabaseManager) UpdateContentTool(id uint, tool string) error

func (*DatabaseManager) UpdateKw 

func (mm *DatabaseManager) UpdateKw(name, scope string, kw []string) error

func (*DatabaseManager) UpdateMissionChanged 

func (mm *DatabaseManager) UpdateMissionChanged(id uint) error

type DeviceQuery 

type DeviceQuery struct {
	Query[model.Device]
	// contains filtered or unexported fields
}

func NewDeviceQuery 

func NewDeviceQuery(db *gorm.DB) *DeviceQuery

func (*DeviceQuery) Count 

func (q *DeviceQuery) Count() int64

func (*DeviceQuery) Delete 

func (q *DeviceQuery) Delete(login string) error

func (*DeviceQuery) Full 

func (q *DeviceQuery) Full() *DeviceQuery

func (*DeviceQuery) Get 

func (q *DeviceQuery) Get() []*model.Device

func (*DeviceQuery) Limit 

func (q *DeviceQuery) Limit(n int) *DeviceQuery

func (*DeviceQuery) Login 

func (q *DeviceQuery) Login(login string) *DeviceQuery

func (*DeviceQuery) Offset 

func (q *DeviceQuery) Offset(n int) *DeviceQuery

func (*DeviceQuery) One 

func (q *DeviceQuery) One() *model.Device

func (*DeviceQuery) Order 

func (q *DeviceQuery) Order(s string) *DeviceQuery

func (*DeviceQuery) Scope 

func (q *DeviceQuery) Scope(scope string) *DeviceQuery

func (*DeviceQuery) Update 

func (q *DeviceQuery) Update(updates map[string]any) error

type FeedQuery added in v0.23.0 

type FeedQuery struct {
	Query[model.Feed2]
	// contains filtered or unexported fields
}

func NewFeedQuery added in v0.23.0 

func NewFeedQuery(db *gorm.DB) *FeedQuery

func (*FeedQuery) All added in v0.23.0 

func (q *FeedQuery) All(all bool) *FeedQuery

func (*FeedQuery) Count added in v0.23.0 

func (q *FeedQuery) Count() int64

func (*FeedQuery) Delete added in v0.23.0 

func (q *FeedQuery) Delete() error

func (*FeedQuery) Get added in v0.23.0 

func (q *FeedQuery) Get() []*model.Feed2

func (*FeedQuery) Limit added in v0.23.0 

func (q *FeedQuery) Limit(n int) *FeedQuery

func (*FeedQuery) Offset added in v0.23.0 

func (q *FeedQuery) Offset(n int) *FeedQuery

func (*FeedQuery) One added in v0.23.0 

func (q *FeedQuery) One() *model.Feed2

func (*FeedQuery) Order added in v0.23.0 

func (q *FeedQuery) Order(s string) *FeedQuery

func (*FeedQuery) ReadScope added in v0.23.0 

func (q *FeedQuery) ReadScope(scope []string) *FeedQuery

func (*FeedQuery) Scope added in v0.23.0 

func (q *FeedQuery) Scope(scope string) *FeedQuery

func (*FeedQuery) UID added in v0.23.0 

func (q *FeedQuery) UID(uid string) *FeedQuery

func (*FeedQuery) Update added in v0.23.0 

func (q *FeedQuery) Update(updates map[string]any) error

func (*FeedQuery) User added in v0.23.0 

func (q *FeedQuery) User(user string) *FeedQuery

type InvitationQuery 

type InvitationQuery struct {
	Query[model.Invitation]
	// contains filtered or unexported fields
}

func NewInvitationQuery 

func NewInvitationQuery(db *gorm.DB) *InvitationQuery

func (*InvitationQuery) Delete 

func (q *InvitationQuery) Delete() error

func (*InvitationQuery) Full 

func (q *InvitationQuery) Full() *InvitationQuery

func (*InvitationQuery) Get 

func (q *InvitationQuery) Get() []*model.Invitation

func (*InvitationQuery) Id 

func (q *InvitationQuery) Id(id uint) *InvitationQuery

func (*InvitationQuery) Invitee 

func (q *InvitationQuery) Invitee(uid string) *InvitationQuery

func (*InvitationQuery) Limit 

func (q *InvitationQuery) Limit(n int) *InvitationQuery

func (*InvitationQuery) Mission 

func (q *InvitationQuery) Mission(id uint) *InvitationQuery

func (*InvitationQuery) Offset 

func (q *InvitationQuery) Offset(n int) *InvitationQuery

func (*InvitationQuery) One 

func (q *InvitationQuery) One() *model.Invitation

func (*InvitationQuery) Order 

func (q *InvitationQuery) Order(s string) *InvitationQuery

func (*InvitationQuery) Type 

func (q *InvitationQuery) Type(s string) *InvitationQuery

func (*InvitationQuery) Update 

func (q *InvitationQuery) Update(updates map[string]any) error

type MissionQuery 

type MissionQuery struct {
	Query[model.Mission]
	// contains filtered or unexported fields
}

func NewMissionQuery 

func NewMissionQuery(db *gorm.DB) *MissionQuery

func (*MissionQuery) Delete 

func (q *MissionQuery) Delete(id uint) error

func (*MissionQuery) Full 

func (q *MissionQuery) Full() *MissionQuery

func (*MissionQuery) Get 

func (q *MissionQuery) Get() []*model.Mission

func (*MissionQuery) Id 

func (q *MissionQuery) Id(id uint) *MissionQuery

func (*MissionQuery) Limit 

func (q *MissionQuery) Limit(n int) *MissionQuery

func (*MissionQuery) Name 

func (q *MissionQuery) Name(name string) *MissionQuery

func (*MissionQuery) Offset 

func (q *MissionQuery) Offset(n int) *MissionQuery

func (*MissionQuery) One 

func (q *MissionQuery) One() *model.Mission

func (*MissionQuery) Order 

func (q *MissionQuery) Order(s string) *MissionQuery

func (*MissionQuery) ReadScope 

func (q *MissionQuery) ReadScope(scope []string) *MissionQuery

func (*MissionQuery) Scope 

func (q *MissionQuery) Scope(scope string) *MissionQuery

func (*MissionQuery) Tool 

func (q *MissionQuery) Tool(tool string) *MissionQuery

func (*MissionQuery) Update 

func (q *MissionQuery) Update(updates map[string]any) error

type PointQuery 

type PointQuery struct {
	Query[model.Point]
	// contains filtered or unexported fields
}

func NewPointQuery 

func NewPointQuery(db *gorm.DB) *PointQuery

func (*PointQuery) Delete 

func (q *PointQuery) Delete() error

func (*PointQuery) Get 

func (q *PointQuery) Get() []*model.Point

func (*PointQuery) Id 

func (q *PointQuery) Id(id uint) *PointQuery

func (*PointQuery) Limit 

func (q *PointQuery) Limit(n int) *PointQuery

func (*PointQuery) Offset 

func (q *PointQuery) Offset(n int) *PointQuery

func (*PointQuery) One 

func (q *PointQuery) One() *model.Point

func (*PointQuery) Order 

func (q *PointQuery) Order(s string) *PointQuery

func (*PointQuery) Scope 

func (q *PointQuery) Scope(scope string) *PointQuery

func (*PointQuery) Stale added in v0.23.0 

func (q *PointQuery) Stale(b bool) *PointQuery

func (*PointQuery) UID 

func (q *PointQuery) UID(uid string) *PointQuery

func (*PointQuery) Update 

func (q *PointQuery) Update(updates map[string]any) error

type ProfileQuery 

type ProfileQuery struct {
	Query[model.Profile]
	// contains filtered or unexported fields
}

func NewProfileQuery 

func NewProfileQuery(db *gorm.DB) *ProfileQuery

func (*ProfileQuery) After 

func (q *ProfileQuery) After(t time.Time) *ProfileQuery

func (*ProfileQuery) Count 

func (q *ProfileQuery) Count() int64

func (*ProfileQuery) Delete 

func (q *ProfileQuery) Delete() error

func (*ProfileQuery) Get 

func (q *ProfileQuery) Get() []*model.Profile

func (*ProfileQuery) Limit 

func (q *ProfileQuery) Limit(n int) *ProfileQuery

func (*ProfileQuery) Login 

func (q *ProfileQuery) Login(login string) *ProfileQuery

func (*ProfileQuery) Offset 

func (q *ProfileQuery) Offset(n int) *ProfileQuery

func (*ProfileQuery) One 

func (q *ProfileQuery) One() *model.Profile

func (*ProfileQuery) Order 

func (q *ProfileQuery) Order(s string) *ProfileQuery

func (*ProfileQuery) UID 

func (q *ProfileQuery) UID(uid string) *ProfileQuery

func (*ProfileQuery) Update 

func (q *ProfileQuery) Update(updates map[string]any) error

type Query 

type Query[T any] struct {
	// contains filtered or unexported fields
}

type ResourceQuery 

type ResourceQuery struct {
	Query[model.Resource]
	// contains filtered or unexported fields
}

func NewResourceQuery 

func NewResourceQuery(db *gorm.DB) *ResourceQuery

func (*ResourceQuery) Delete 

func (q *ResourceQuery) Delete() error

func (*ResourceQuery) Get 

func (q *ResourceQuery) Get() []*model.Resource

func (*ResourceQuery) Hash 

func (q *ResourceQuery) Hash(hash string) *ResourceQuery

func (*ResourceQuery) Id 

func (q *ResourceQuery) Id(id uint) *ResourceQuery

func (*ResourceQuery) Limit 

func (q *ResourceQuery) Limit(n int) *ResourceQuery

func (*ResourceQuery) Name 

func (q *ResourceQuery) Name(name string) *ResourceQuery

func (*ResourceQuery) Offset 

func (q *ResourceQuery) Offset(n int) *ResourceQuery

func (*ResourceQuery) One 

func (q *ResourceQuery) One() *model.Resource

func (*ResourceQuery) Order 

func (q *ResourceQuery) Order(s string) *ResourceQuery

func (*ResourceQuery) ReadScope 

func (q *ResourceQuery) ReadScope(scope []string) *ResourceQuery

func (*ResourceQuery) Scope 

func (q *ResourceQuery) Scope(scope string) *ResourceQuery

func (*ResourceQuery) Tool 

func (q *ResourceQuery) Tool(tool string) *ResourceQuery

func (*ResourceQuery) UID 

func (q *ResourceQuery) UID(uid string) *ResourceQuery

func (*ResourceQuery) Update 

func (q *ResourceQuery) Update(updates map[string]any) error

type SubscriptionQuery 

type SubscriptionQuery struct {
	Query[model.Subscription]
	// contains filtered or unexported fields
}

func NewSubscriptionQuery 

func NewSubscriptionQuery(db *gorm.DB) *SubscriptionQuery

func (*SubscriptionQuery) Client 

func (q *SubscriptionQuery) Client(uid string) *SubscriptionQuery

func (*SubscriptionQuery) Delete 

func (q *SubscriptionQuery) Delete() error

func (*SubscriptionQuery) Get 

func (q *SubscriptionQuery) Get() []*model.Subscription

func (*SubscriptionQuery) Id 

func (q *SubscriptionQuery) Id(id uint) *SubscriptionQuery

func (*SubscriptionQuery) Limit 

func (q *SubscriptionQuery) Limit(n int) *SubscriptionQuery

func (*SubscriptionQuery) Mission 

func (q *SubscriptionQuery) Mission(id uint) *SubscriptionQuery

func (*SubscriptionQuery) Offset 

func (q *SubscriptionQuery) Offset(n int) *SubscriptionQuery

func (*SubscriptionQuery) One 

func (q *SubscriptionQuery) One() *model.Subscription

func (*SubscriptionQuery) Order 

func (q *SubscriptionQuery) Order(s string) *SubscriptionQuery

func (*SubscriptionQuery) Update 

func (q *SubscriptionQuery) Update(updates map[string]any) 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.