stores

package
v0.26.0 Latest Latest
Warning

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

 Go to latest Published: Mar 4, 2026 License: MIT Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConfigureRuntime added in v0.26.0 

func ConfigureRuntime(cfg RuntimeConfig)

ConfigureRuntime applies store runtime defaults.

func EnsureContentOverlay added in v0.24.0 

func EnsureContentOverlay(ctx context.Context, db *bun.DB) error

EnsureContentOverlay applies the admin content overlay (views + media table).

func NewFilteredContentRepository 

func NewFilteredContentRepository(content admin.CMSContentService, contentType string) *admin.CMSContentRepository

NewFilteredContentRepository wraps CMSContentService to enforce a fixed content_type.

func NewPageRecordRepository 

func NewPageRecordRepository(db *bun.DB, opts ...repository.Option) repository.Repository[*PageRecord]

NewPageRecordRepository builds a repository for CMS-backed page records.

func NewPostRecordRepository 

func NewPostRecordRepository(db *bun.DB, opts ...repository.Option) repository.Repository[*PostRecord]

NewPostRecordRepository builds a repository for CMS-backed post records.

func PageRecordToMap added in v0.24.0 

func PageRecordToMap(record *PageRecord) map[string]any

func ResolveContentDSN 

func ResolveContentDSN() string

ResolveContentDSN returns the SQLite DSN for content persistence. It checks configured runtime DSNs first, then falls back to a shared temp-file path to keep parity with the CMS/users examples.

func SanitizeSQLiteMigrations 

func SanitizeSQLiteMigrations(src fs.FS) fs.FS

func SetupContentDatabase 

func SetupContentDatabase(ctx context.Context, dsn string, opts ...persistence.ClientOption) (*bun.DB, error)

SetupContentDatabase opens a SQLite connection, applies the content migrations, and returns a Bun DB handle.

Types

type AdminPageStoreAdapter added in v0.24.0 

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

AdminPageStoreAdapter exposes admin read/write services backed by the page repository/store.

func NewAdminPageStoreAdapter added in v0.24.0 

func NewAdminPageStoreAdapter(repo repository.Repository[*PageRecord], store PageRepository, defaultLocale string) *AdminPageStoreAdapter

NewAdminPageStoreAdapter wires repo/store-backed admin page services.

func (*AdminPageStoreAdapter) Create added in v0.24.0 

func (s *AdminPageStoreAdapter) Create(ctx context.Context, payload map[string]any) (*admin.AdminPageRecord, error)

Create inserts a page record via the store.

func (*AdminPageStoreAdapter) Delete added in v0.24.0 

func (s *AdminPageStoreAdapter) Delete(ctx context.Context, id string) error

Delete removes a page record via the store.

func (*AdminPageStoreAdapter) Get added in v0.24.0 

func (s *AdminPageStoreAdapter) Get(ctx context.Context, id string, opts admin.AdminPageGetOptions) (*admin.AdminPageRecord, error)

Get returns a single admin page record using the CMS-backed store when available.

func (*AdminPageStoreAdapter) List added in v0.24.0 

func (s *AdminPageStoreAdapter) List(ctx context.Context, opts admin.AdminPageListOptions) ([]admin.AdminPageRecord, int, error)

List returns admin page records using the view-backed repository when available.

func (*AdminPageStoreAdapter) Publish added in v0.24.0 

func (s *AdminPageStoreAdapter) Publish(ctx context.Context, id string, payload map[string]any) (*admin.AdminPageRecord, error)

Publish applies publish updates via the store.

func (*AdminPageStoreAdapter) Unpublish added in v0.24.0 

func (s *AdminPageStoreAdapter) Unpublish(ctx context.Context, id string, payload map[string]any) (*admin.AdminPageRecord, error)

Unpublish applies draft updates via the store.

func (*AdminPageStoreAdapter) Update added in v0.24.0 

func (s *AdminPageStoreAdapter) Update(ctx context.Context, id string, payload map[string]any) (*admin.AdminPageRecord, error)

Update modifies a page record via the store.

type CMSPageStore 

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

CMSPageStore adapts a CMSContentService-backed page repository to the panel/store contract.

func NewCMSPageStore 

func NewCMSPageStore(content admin.CMSContentService, defaultLocale string) *CMSPageStore

NewCMSPageStore builds a go-cms-backed page store. Returns nil when no content service is provided.

func (*CMSPageStore) Create 

func (s *CMSPageStore) Create(ctx context.Context, record map[string]any) (map[string]any, error)

Create inserts a page into the CMS backend.

func (*CMSPageStore) Delete 

func (s *CMSPageStore) Delete(ctx context.Context, id string) error

Delete removes a page.

func (*CMSPageStore) Get 

func (s *CMSPageStore) Get(ctx context.Context, id string) (map[string]any, error)

Get returns a single page.

func (*CMSPageStore) List 

func (s *CMSPageStore) List(ctx context.Context, opts admin.ListOptions) ([]map[string]any, int, error)

List returns CMS pages filtered by locale/search.

func (*CMSPageStore) Publish 

func (s *CMSPageStore) Publish(ctx context.Context, ids []string) ([]map[string]any, error)

Publish marks matching pages as published.

func (*CMSPageStore) Seed 

func (s *CMSPageStore) Seed()

Seed inserts sample pages when the CMS backend is empty.

func (*CMSPageStore) Unpublish 

func (s *CMSPageStore) Unpublish(ctx context.Context, ids []string) ([]map[string]any, error)

Unpublish marks matching pages as drafts.

func (*CMSPageStore) Update 

func (s *CMSPageStore) Update(ctx context.Context, id string, record map[string]any) (map[string]any, error)

Update modifies an existing page.

func (*CMSPageStore) WithActivitySink 

func (s *CMSPageStore) WithActivitySink(sink admin.ActivitySink)

WithActivitySink wires an activity sink for CRUD events.

type CMSPostStore 

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

CMSPostStore adapts go-cms content to the post store contract.

func NewCMSPostStore 

func NewCMSPostStore(content admin.CMSContentService, defaultLocale string) *CMSPostStore

NewCMSPostStore builds a content-backed post store. Returns nil when no content service is provided.

func (*CMSPostStore) Archive 

func (s *CMSPostStore) Archive(ctx context.Context, ids []string) ([]map[string]any, error)

Archive marks matching posts as archived.

func (*CMSPostStore) Create 

func (s *CMSPostStore) Create(ctx context.Context, record map[string]any) (map[string]any, error)

Create inserts a post into the CMS backend.

func (*CMSPostStore) Delete 

func (s *CMSPostStore) Delete(ctx context.Context, id string) error

Delete removes a post.

func (*CMSPostStore) Get 

func (s *CMSPostStore) Get(ctx context.Context, id string) (map[string]any, error)

Get returns a post by id.

func (*CMSPostStore) List 

func (s *CMSPostStore) List(ctx context.Context, opts admin.ListOptions) ([]map[string]any, int, error)

List returns CMS posts filtered by content_type, locale, and search.

func (*CMSPostStore) Publish 

func (s *CMSPostStore) Publish(ctx context.Context, ids []string) ([]map[string]any, error)

Publish marks matching posts as published and stamps published_at.

func (*CMSPostStore) Schedule 

func (s *CMSPostStore) Schedule(ctx context.Context, ids []string, publishAt time.Time) ([]map[string]any, error)

Schedule marks matching posts as scheduled with a publish time (defaults to now when missing).

func (*CMSPostStore) Seed 

func (s *CMSPostStore) Seed()

Seed inserts sample posts when the CMS backend is empty.

func (*CMSPostStore) Unpublish 

func (s *CMSPostStore) Unpublish(ctx context.Context, ids []string) ([]map[string]any, error)

Unpublish marks matching posts as drafts and clears publish time.

func (*CMSPostStore) Update 

func (s *CMSPostStore) Update(ctx context.Context, id string, record map[string]any) (map[string]any, error)

Update modifies an existing post.

func (*CMSPostStore) WithActivitySink 

func (s *CMSPostStore) WithActivitySink(sink admin.ActivitySink)

WithActivitySink wires an activity sink for CRUD events.

type DataStores 

type DataStores struct {
	Users        *UserStore
	UserProfiles *UserProfileStore
	Pages        PageRepository
	Posts        PostRepository
	Templates    *TemplateStore
	Media        *MediaStore
	Stats        *StatsStore
	PageRecords  repository.Repository[*PageRecord]
	PostRecords  repository.Repository[*PostRecord]
	MediaRecords repository.Repository[*MediaRecord]
}

DataStores holds all in-memory or CMS-backed data stores.

func Initialize 

func Initialize(contentSvc admin.CMSContentService, defaultLocale string, userDeps UserDependencies, repoOptions ...repository.Option) (*DataStores, error)

Initialize creates all data stores backed by the CMS content service (pages/posts) and Bun for user/media data.

func InitializeWithOptions added in v0.15.0 

func InitializeWithOptions(contentSvc admin.CMSContentService, defaultLocale string, userDeps UserDependencies, opts InitOptions) (*DataStores, error)

InitializeWithOptions creates data stores with persistence options applied.

type InitOptions added in v0.15.0 

type InitOptions struct {
	RepoOptions        []repository.Option
	PersistenceOptions []persistence.ClientOption
}

InitOptions configures initialization for data stores.

type MediaRecord 

type MediaRecord struct {
	bun.BaseModel `bun:"table:media,alias:m" crud:"resource:media"`

	ID         uuid.UUID      `json:"id" bun:"id,pk,type:uuid"`
	Filename   string         `json:"filename" bun:"filename"`
	URL        string         `json:"url" bun:"url"`
	Type       string         `json:"type" bun:"type"`
	MimeType   string         `json:"mime_type,omitempty" bun:"mime_type"`
	Size       int64          `json:"size" bun:"size"`
	Metadata   map[string]any `json:"metadata,omitempty" bun:"metadata,type:jsonb"`
	UploadedBy string         `json:"uploaded_by,omitempty" bun:"uploaded_by"`
	CreatedAt  *time.Time     `json:"created_at,omitempty" bun:"created_at,nullzero,default:current_timestamp"`
	UpdatedAt  *time.Time     `json:"updated_at,omitempty" bun:"updated_at,nullzero,default:current_timestamp"`
}

MediaRecord represents media assets in go-crud responses.

type MediaStore 

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

MediaStore manages media files backed by SQLite/Bun.

func NewMediaStore 

func NewMediaStore(db *bun.DB, opts ...repository.Option) (*MediaStore, error)

NewMediaStore creates a new MediaStore instance.

func (*MediaStore) Create 

func (s *MediaStore) Create(ctx context.Context, record map[string]any) (map[string]any, error)

Create creates a new media file.

func (*MediaStore) Delete 

func (s *MediaStore) Delete(ctx context.Context, id string) error

Delete deletes a media file by ID.

func (*MediaStore) DeleteMany 

func (s *MediaStore) DeleteMany(ctx context.Context, ids []string) ([]map[string]any, error)

DeleteMany removes multiple media files in one pass.

func (*MediaStore) Get 

func (s *MediaStore) Get(ctx context.Context, id string) (map[string]any, error)

Get returns a single media file by ID.

func (*MediaStore) List 

func (s *MediaStore) List(ctx context.Context, opts admin.ListOptions) ([]map[string]any, int, error)

List returns a list of media files matching the given options.

func (*MediaStore) Repository 

func (s *MediaStore) Repository() repository.Repository[*MediaRecord]

Repository exposes the underlying go-repository-bun repository.

func (*MediaStore) Seed 

func (s *MediaStore) Seed()

Seed populates the MediaStore with initial data when empty.

func (*MediaStore) Update 

func (s *MediaStore) Update(ctx context.Context, id string, record map[string]any) (map[string]any, error)

Update updates an existing media file.

func (*MediaStore) WithActivitySink 

func (s *MediaStore) WithActivitySink(sink admin.ActivitySink)

WithActivitySink enables activity emission on CRUD operations.

type PageRecord 

type PageRecord struct {
	bun.BaseModel `bun:"table:admin_page_records,alias:pr" crud:"resource:page"`

	ID                 uuid.UUID  `json:"id" bun:"id,pk,type:uuid"`
	ContentID          uuid.UUID  `json:"content_id" bun:"content_id,type:uuid"`
	TranslationGroupID *uuid.UUID `json:"translation_group_id,omitempty" bun:"translation_group_id,type:uuid"`
	TemplateID         uuid.UUID  `json:"template_id" bun:"template_id,type:uuid"`
	Title              string     `json:"title" bun:"title"`
	Slug               string     `json:"slug" bun:"slug"`
	Path               string     `json:"path" bun:"path"`
	Locale             string     `json:"locale" bun:"locale"`
	PrimaryLocale      string     `json:"primary_locale,omitempty" bun:"primary_locale"`
	AvailableLocales   string     `json:"available_locales,omitempty" bun:"available_locales"`
	Status             string     `json:"status" bun:"status"`
	ParentID           *uuid.UUID `json:"parent_id,omitempty" bun:"parent_id"`
	MetaTitle          string     `json:"meta_title,omitempty" bun:"meta_title"`
	MetaDescription    string     `json:"meta_description,omitempty" bun:"meta_description"`
	Summary            *string    `json:"summary,omitempty" bun:"summary"`
	Content            string     `json:"content,omitempty" bun:"content"`
	Tags               []string   `json:"tags,omitempty" bun:"tags,type:jsonb"`
	Blocks             any        `json:"blocks,omitempty" bun:"-"`
	PreviewURL         string     `json:"preview_url,omitempty" bun:"preview_url"`
	PublishedAt        *time.Time `json:"published_at,omitempty" bun:"published_at,nullzero"`
	CreatedAt          *time.Time `json:"created_at,omitempty" bun:"created_at,nullzero,default:current_timestamp"`
	UpdatedAt          *time.Time `json:"updated_at,omitempty" bun:"updated_at,nullzero,default:current_timestamp"`
}

PageRecord maps CMS-backed page records used by admin content tooling.

func PageRecordFromMap added in v0.24.0 

func PageRecordFromMap(record map[string]any) *PageRecord

type PageRepository 

type PageRepository interface {
	Seed()
	WithActivitySink(admin.ActivitySink)
	List(ctx context.Context, opts admin.ListOptions) ([]map[string]any, int, error)
	Get(ctx context.Context, id string) (map[string]any, error)
	Create(ctx context.Context, record map[string]any) (map[string]any, error)
	Update(ctx context.Context, id string, record map[string]any) (map[string]any, error)
	Delete(ctx context.Context, id string) error
	Publish(ctx context.Context, ids []string) ([]map[string]any, error)
	Unpublish(ctx context.Context, ids []string) ([]map[string]any, error)
}

PageRepository represents the operations needed by panels, search, and commands.

type PageStore 

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

PageStore manages pages backed by SQLite/Bun.

func NewPageStore 

func NewPageStore(db *bun.DB, opts ...repository.Option) (*PageStore, error)

NewPageStore creates a new page store.

func (*PageStore) Create 

func (s *PageStore) Create(ctx context.Context, record map[string]any) (map[string]any, error)

Create creates a new page.

func (*PageStore) Delete 

func (s *PageStore) Delete(ctx context.Context, id string) error

Delete deletes a page by ID.

func (*PageStore) Get 

func (s *PageStore) Get(ctx context.Context, id string) (map[string]any, error)

Get returns a single page by ID.

func (*PageStore) List 

func (s *PageStore) List(ctx context.Context, opts admin.ListOptions) ([]map[string]any, int, error)

List returns a list of pages matching the given options.

func (*PageStore) Publish 

func (s *PageStore) Publish(ctx context.Context, ids []string) ([]map[string]any, error)

Publish sets the status to published for matching pages (or all when ids are empty).

func (*PageStore) Repository 

func (s *PageStore) Repository() repository.Repository[*PageRecord]

Repository exposes the underlying go-repository-bun repository.

func (*PageStore) Seed 

func (s *PageStore) Seed()

Seed populates the store with sample data when empty.

func (*PageStore) Unpublish 

func (s *PageStore) Unpublish(ctx context.Context, ids []string) ([]map[string]any, error)

Unpublish marks matching pages as drafts.

func (*PageStore) Update 

func (s *PageStore) Update(ctx context.Context, id string, record map[string]any) (map[string]any, error)

Update updates an existing page.

func (*PageStore) WithActivitySink 

func (s *PageStore) WithActivitySink(sink admin.ActivitySink)

WithActivitySink enables activity emission on CRUD operations.

type PostRecord 

type PostRecord struct {
	bun.BaseModel `bun:"table:admin_post_records,alias:apr" crud:"resource:post"`

	ID                 uuid.UUID  `json:"id" bun:"id,pk,type:uuid"`
	Title              string     `json:"title" bun:"title"`
	Slug               string     `json:"slug" bun:"slug"`
	Status             string     `json:"status" bun:"status"`
	Locale             string     `json:"locale" bun:"locale"`
	TranslationGroupID *uuid.UUID `json:"translation_group_id,omitempty" bun:"translation_group_id,type:uuid"`
	PrimaryLocale      string     `json:"primary_locale,omitempty" bun:"primary_locale"`
	AvailableLocales   string     `json:"available_locales,omitempty" bun:"available_locales"`
	Path               string     `json:"path" bun:"path"`
	Author             string     `json:"author,omitempty" bun:"author"`
	Excerpt            string     `json:"excerpt,omitempty" bun:"excerpt"`
	Content            string     `json:"content,omitempty" bun:"content"`
	Category           string     `json:"category,omitempty" bun:"category"`
	FeaturedImage      string     `json:"featured_image,omitempty" bun:"featured_image"`
	Tags               []string   `json:"tags,omitempty" bun:"tags,type:jsonb"`
	MetaTitle          string     `json:"meta_title,omitempty" bun:"meta_title"`
	MetaDescription    string     `json:"meta_description,omitempty" bun:"meta_description"`
	PublishedAt        *time.Time `json:"published_at,omitempty" bun:"published_at,nullzero"`
	CreatedAt          *time.Time `json:"created_at,omitempty" bun:"created_at,nullzero,default:current_timestamp"`
	UpdatedAt          *time.Time `json:"updated_at,omitempty" bun:"updated_at,nullzero,default:current_timestamp"`
}

PostRecord represents posts used by admin content tooling.

type PostRepository 

type PostRepository interface {
	Seed()
	WithActivitySink(admin.ActivitySink)
	List(ctx context.Context, opts admin.ListOptions) ([]map[string]any, int, error)
	Get(ctx context.Context, id string) (map[string]any, error)
	Create(ctx context.Context, record map[string]any) (map[string]any, error)
	Update(ctx context.Context, id string, record map[string]any) (map[string]any, error)
	Delete(ctx context.Context, id string) error
	Publish(ctx context.Context, ids []string) ([]map[string]any, error)
	Unpublish(ctx context.Context, ids []string) ([]map[string]any, error)
	Schedule(ctx context.Context, ids []string, publishAt time.Time) ([]map[string]any, error)
	Archive(ctx context.Context, ids []string) ([]map[string]any, error)
}

PostRepository captures blog post operations plus publish/archive actions.

type PostStore 

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

PostStore manages blog posts backed by SQLite/Bun.

func NewPostStore 

func NewPostStore(db *bun.DB, opts ...repository.Option) (*PostStore, error)

NewPostStore creates a new PostStore instance.

func (*PostStore) Archive 

func (s *PostStore) Archive(ctx context.Context, ids []string) ([]map[string]any, error)

Archive marks matching posts as archived.

func (*PostStore) Create 

func (s *PostStore) Create(ctx context.Context, record map[string]any) (map[string]any, error)

Create creates a new post.

func (*PostStore) Delete 

func (s *PostStore) Delete(ctx context.Context, id string) error

Delete deletes a post by ID.

func (*PostStore) Get 

func (s *PostStore) Get(ctx context.Context, id string) (map[string]any, error)

Get returns a single post by ID.

func (*PostStore) List 

func (s *PostStore) List(ctx context.Context, opts admin.ListOptions) ([]map[string]any, int, error)

List returns a list of posts matching the given options.

func (*PostStore) Publish 

func (s *PostStore) Publish(ctx context.Context, ids []string) ([]map[string]any, error)

Publish sets matching posts to published and stamps published_at when missing.

func (*PostStore) Repository 

func (s *PostStore) Repository() repository.Repository[*PostRecord]

Repository exposes the underlying go-repository-bun repository.

func (*PostStore) Schedule 

func (s *PostStore) Schedule(ctx context.Context, ids []string, publishAt time.Time) ([]map[string]any, error)

Schedule sets posts to scheduled with a publish time (defaults to now when empty).

func (*PostStore) Seed 

func (s *PostStore) Seed()

Seed populates the PostStore with initial data when empty.

func (*PostStore) Unpublish 

func (s *PostStore) Unpublish(ctx context.Context, ids []string) ([]map[string]any, error)

Unpublish marks matching posts as drafts and clears publish time.

func (*PostStore) Update 

func (s *PostStore) Update(ctx context.Context, id string, record map[string]any) (map[string]any, error)

Update updates an existing post.

func (*PostStore) WithActivitySink 

func (s *PostStore) WithActivitySink(sink admin.ActivitySink)

WithActivitySink enables activity emission on CRUD operations.

type RuntimeConfig added in v0.26.0 

type RuntimeConfig struct {
	CMSDSN     string
	ContentDSN string
}

RuntimeConfig controls stores package runtime defaults.

type StatsStore 

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

StatsStore manages statistics

func NewStatsStore 

func NewStatsStore() *StatsStore

NewStatsStore creates a new StatsStore instance

func (*StatsStore) GetContentStats 

func (s *StatsStore) GetContentStats() map[string]any

GetContentStats returns content statistics

func (*StatsStore) GetStorageStats 

func (s *StatsStore) GetStorageStats() map[string]any

GetStorageStats returns storage statistics

func (*StatsStore) GetUserStats 

func (s *StatsStore) GetUserStats() map[string]any

GetUserStats returns user statistics

func (*StatsStore) Seed 

func (s *StatsStore) Seed()

Seed initializes the StatsStore (stats are computed dynamically)

type TemplateOption added in v0.24.0 

type TemplateOption struct {
	ID           string `json:"id"`
	Label        string `json:"label"`
	Name         string `json:"name,omitempty"`
	Slug         string `json:"slug,omitempty"`
	TemplatePath string `json:"template_path,omitempty"`
}

TemplateOption is a minimal payload for relationship selectors.

type TemplateStore added in v0.24.0 

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

TemplateStore provides read access to CMS templates for relationship selectors.

func NewTemplateStore added in v0.24.0 

func NewTemplateStore(db *bun.DB) *TemplateStore

NewTemplateStore returns a store backed by the CMS content database.

func (*TemplateStore) List added in v0.24.0 

func (s *TemplateStore) List(ctx context.Context, query string, ids []string, limit int) ([]TemplateOption, error)

List returns templates filtered by optional ids or query.

type User 

type User struct {
	bun.BaseModel   `bun:"table:users,alias:u"`
	ID              uuid.UUID `json:"id" bun:"id,pk,type:uuid"`
	Username        string    `json:"username" bun:"username"`
	Email           string    `json:"email" bun:"email"`
	Label           string    `json:"label" bun:"-"`
	FirstName       string    `json:"first_name" bun:"first_name"`
	LastName        string    `json:"last_name" bun:"last_name"`
	PhoneNumber     string    `json:"phone_number" bun:"phone_number"`
	IsEmailVerified bool      `json:"is_email_verified" bun:"is_email_verified"`
	Role            string    `json:"role" bun:"role"`
	Status          string    `json:"status" bun:"status"`
	CreatedAt       time.Time `json:"created_at" bun:"created_at"`
	UpdatedAt       time.Time `json:"updated_at" bun:"updated_at"`
	LastLogin       time.Time `json:"last_login" bun:"last_login"`
}

User mirrors the JSON shape expected by go-crud.

type UserDependencies 

type UserDependencies struct {
	DB             *bun.DB
	RepoManager    auth.RepositoryManager
	AuthRepo       types.AuthRepository
	InventoryRepo  types.UserInventoryRepository
	RoleRegistry   types.RoleRegistry
	ActivitySink   types.ActivitySink
	ActivityRepo   types.ActivityRepository
	ProfileRepo    types.ProfileRepository
	PreferenceRepo types.PreferenceRepository
	SecureLinks    types.SecureLinkManager
	UserTokenRepo  types.UserTokenRepository
	ResetRepo      types.PasswordResetRepository
}

UserDependencies wires DB-backed user storage and related services.

type UserProfile 

type UserProfile struct {
	bun.BaseModel `bun:"table:user_profiles,alias:up"`

	ID          uuid.UUID `json:"id" bun:"user_id,pk,type:uuid"`
	DisplayName string    `json:"display_name" bun:"display_name"`
	AvatarURL   string    `json:"avatar_url" bun:"avatar_url"`
	Email       string    `json:"email" bun:"email"`
	Locale      string    `json:"locale" bun:"locale"`
	Timezone    string    `json:"timezone" bun:"timezone"`
	Bio         string    `json:"bio" bun:"bio"`
	CreatedAt   time.Time `json:"created_at" bun:"created_at"`
	UpdatedAt   time.Time `json:"updated_at" bun:"updated_at"`
}

UserProfile mirrors the JSON shape expected by go-crud/DataGrid. Note: bun tags are used by go-crud query parsing; the store does not rely on Bun scans for this model.

type UserProfileStore 

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

UserProfileStore manages profile data through the go-users profile repository.

func NewUserProfileStore 

func NewUserProfileStore(deps UserDependencies) (*UserProfileStore, error)

NewUserProfileStore provisions a DB-backed profile store for the example.

func (*UserProfileStore) Create 

func (s *UserProfileStore) Create(ctx context.Context, record map[string]any) (map[string]any, error)

Create adds a new profile (keyed by the user id).

func (*UserProfileStore) Delete 

func (s *UserProfileStore) Delete(ctx context.Context, id string) error

Delete removes a profile by user id.

func (*UserProfileStore) Get 

func (s *UserProfileStore) Get(ctx context.Context, id string) (map[string]any, error)

Get returns a single profile by user id (record id).

func (*UserProfileStore) List 

func (s *UserProfileStore) List(ctx context.Context, opts admin.ListOptions) ([]map[string]any, int, error)

List returns user profiles honoring search/filters/pagination.

func (*UserProfileStore) Repository 

func (s *UserProfileStore) Repository() repository.Repository[*UserProfile]

Repository exposes a go-crud compatible repository adapter.

func (*UserProfileStore) Update 

func (s *UserProfileStore) Update(ctx context.Context, id string, record map[string]any) (map[string]any, error)

Update modifies an existing profile (user id is immutable).

type UserStore 

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

UserStore manages user data through a go-users-compatible repository.

func NewUserStore 

func NewUserStore(deps UserDependencies) (*UserStore, error)

NewUserStore provisions a DB-backed go-users repository for the example.

func (*UserStore) Create 

func (s *UserStore) Create(ctx context.Context, record map[string]any) (map[string]any, error)

Create adds a new user.

func (*UserStore) Delete 

func (s *UserStore) Delete(ctx context.Context, id string) error

Delete removes a user.

func (*UserStore) Get 

func (s *UserStore) Get(ctx context.Context, id string) (map[string]any, error)

Get returns a single user by ID.

func (*UserStore) List 

func (s *UserStore) List(ctx context.Context, opts admin.ListOptions) ([]map[string]any, int, error)

List returns users honoring search/filters/pagination.

func (*UserStore) Repository 

func (s *UserStore) Repository() repository.Repository[*User]

Repository exposes a go-crud compatible repository adapter.

func (*UserStore) Seed 

func (s *UserStore) Seed()

Seed populates the store with sample data.

func (*UserStore) Teardown 

func (s *UserStore) Teardown()

Teardown clears all user records (used by tests/fixtures).

func (*UserStore) Update 

func (s *UserStore) Update(ctx context.Context, id string, record map[string]any) (map[string]any, error)

Update modifies an existing user.

func (*UserStore) WithActivitySink 

func (s *UserStore) WithActivitySink(sink admin.ActivitySink)

WithActivitySink enables activity emission on create/update/delete operations.

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.