91 lines
3.8 KiB
Go
91 lines
3.8 KiB
Go
package datastore
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"time"
|
|
|
|
"git.itzana.me/strafesnet/maps-service/pkg/model"
|
|
)
|
|
|
|
var (
|
|
ErrNotExist = errors.New("resource does not exist")
|
|
ErroNoRowsAffected = errors.New("query did not affect any rows")
|
|
ErrInvalidListSort = errors.New("invalid list sort parameter [1,2,3,4]")
|
|
)
|
|
|
|
type ListSort uint32
|
|
const (
|
|
ListSortDisabled ListSort = 0
|
|
ListSortDisplayNameAscending ListSort = 1
|
|
ListSortDisplayNameDescending ListSort = 2
|
|
ListSortDateAscending ListSort = 3
|
|
ListSortDateDescending ListSort = 4
|
|
)
|
|
|
|
type Datastore interface {
|
|
AuditEvents() AuditEvents
|
|
Mapfixes() Mapfixes
|
|
Operations() Operations
|
|
Submissions() Submissions
|
|
Scripts() Scripts
|
|
ScriptPolicy() ScriptPolicy
|
|
}
|
|
|
|
type AuditEvents interface {
|
|
Get(ctx context.Context, id int64) (model.AuditEvent, error)
|
|
Create(ctx context.Context, smap model.AuditEvent) (model.AuditEvent, error)
|
|
Update(ctx context.Context, id int64, values OptionalMap) error
|
|
Delete(ctx context.Context, id int64) error
|
|
List(ctx context.Context, filters OptionalMap, page model.Page) ([]model.AuditEvent, error)
|
|
}
|
|
|
|
type Mapfixes interface {
|
|
Get(ctx context.Context, id int64) (model.Mapfix, error)
|
|
GetList(ctx context.Context, id []int64) ([]model.Mapfix, error)
|
|
Create(ctx context.Context, smap model.Mapfix) (model.Mapfix, error)
|
|
Update(ctx context.Context, id int64, values OptionalMap) error
|
|
IfStatusThenUpdate(ctx context.Context, id int64, statuses []model.MapfixStatus, values OptionalMap) error
|
|
IfStatusThenUpdateAndGet(ctx context.Context, id int64, statuses []model.MapfixStatus, values OptionalMap) (model.Mapfix, error)
|
|
Delete(ctx context.Context, id int64) error
|
|
List(ctx context.Context, filters OptionalMap, page model.Page, sort ListSort) ([]model.Mapfix, error)
|
|
ListWithTotal(ctx context.Context, filters OptionalMap, page model.Page, sort ListSort) (int64, []model.Mapfix, error)
|
|
}
|
|
|
|
type Operations interface {
|
|
Get(ctx context.Context, id int32) (model.Operation, error)
|
|
Create(ctx context.Context, smap model.Operation) (model.Operation, error)
|
|
Update(ctx context.Context, id int32, values OptionalMap) error
|
|
Delete(ctx context.Context, id int32) error
|
|
CountSince(ctx context.Context, owner int64, since time.Time) (int64, error)
|
|
}
|
|
|
|
type Submissions interface {
|
|
Get(ctx context.Context, id int64) (model.Submission, error)
|
|
GetList(ctx context.Context, id []int64) ([]model.Submission, error)
|
|
Create(ctx context.Context, smap model.Submission) (model.Submission, error)
|
|
Update(ctx context.Context, id int64, values OptionalMap) error
|
|
IfStatusThenUpdate(ctx context.Context, id int64, statuses []model.SubmissionStatus, values OptionalMap) error
|
|
IfStatusThenUpdateAndGet(ctx context.Context, id int64, statuses []model.SubmissionStatus, values OptionalMap) (model.Submission, error)
|
|
Delete(ctx context.Context, id int64) error
|
|
List(ctx context.Context, filters OptionalMap, page model.Page, sort ListSort) ([]model.Submission, error)
|
|
ListWithTotal(ctx context.Context, filters OptionalMap, page model.Page, sort ListSort) (int64, []model.Submission, error)
|
|
}
|
|
|
|
type Scripts interface {
|
|
Get(ctx context.Context, id int64) (model.Script, error)
|
|
Create(ctx context.Context, smap model.Script) (model.Script, error)
|
|
Update(ctx context.Context, id int64, values OptionalMap) error
|
|
Delete(ctx context.Context, id int64) error
|
|
List(ctx context.Context, filters OptionalMap, page model.Page) ([]model.Script, error)
|
|
}
|
|
|
|
type ScriptPolicy interface {
|
|
Get(ctx context.Context, id int64) (model.ScriptPolicy, error)
|
|
GetFromHash(ctx context.Context, hash uint64) (model.ScriptPolicy, error)
|
|
Create(ctx context.Context, smap model.ScriptPolicy) (model.ScriptPolicy, error)
|
|
Update(ctx context.Context, id int64, values OptionalMap) error
|
|
Delete(ctx context.Context, id int64) error
|
|
List(ctx context.Context, filters OptionalMap, page model.Page) ([]model.ScriptPolicy, error)
|
|
}
|