database

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Mar 29, 2022 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrLockWaitTimeoutExceeded = errors.New("lock wait timeout exceeded")

ErrLockWaitTimeoutExceeded is returned when we cannot acquire a lock

View Source 
var ErrNoTransaction = errors.New("should be executed in a transaction")

ErrNoTransaction means that a called method/function cannot work outside of a transaction

View Source 
var ErrRelationCycle = errors.New("a group cannot become an ancestor of itself")

ErrRelationCycle is returned by CreateRelation() if the relation is impossible because it would create a cycle in the groups_groups graph.

Functions

func ClearAllDBEnums 

func ClearAllDBEnums()

ClearAllDBEnums clears all cached permission enums

func Default 

func Default() interface{}

Default returns gorm.Expr("DEFAULT")

func EscapeLikeString 

func EscapeLikeString(v string, escapeCharacter byte) string

EscapeLikeString escapes string with the given escape character. This escapes the contents of a string (provided as string) by adding the escape character before percent signs (%), and underscore signs (_).

func MockDBEnumQueries 

func MockDBEnumQueries(sqlMock sqlmock.Sqlmock)

MockDBEnumQueries stubs all the db queries for loading permission enums

func MockNow 

func MockNow(timestamp string)

MockNow changes the DB expression for getting current DB time so that it will return the given timestamp

func Now 

func Now() interface{}

Now returns a DB expression that returns current DB time (it is usually gorm.Expr("NOW()"))

func OpenRawDBConnection 

func OpenRawDBConnection(sourceDSN string) (*sql.DB, error)

OpenRawDBConnection creates a new DB connection

func QuoteName 

func QuoteName(name string) string

QuoteName surrounds a given table/column name in backtick quotes and escapes the content

func RestoreNow 

func RestoreNow()

RestoreNow sets the DB expression for getting current DB time to its default value (gorm.Expr("NOW()"))

Types

type AnswerStore 

type AnswerStore struct {
	*DataStore
}

AnswerStore implements database operations on `answers`

func (*AnswerStore) SubmitNewAnswer 

func (s *AnswerStore) SubmitNewAnswer(authorID, participantID, attemptID, itemID int64, answer string) (int64, error)

SubmitNewAnswer inserts a new row with type='Submission', created_at=NOW() into the `answers` table.

func (*AnswerStore) Visible 

func (s *AnswerStore) Visible(user *User) *DB

Visible returns a composable query for getting answers with the following access rights restrictions:

  1. the user should have at least 'content' access rights to the answers.item_id item,
  2. the user is able to see answers related to his group's attempts, so the user should be a member of the answers.participant_id team or answers.participant_id should be equal to the user's self group

func (*AnswerStore) WithItems 

func (s *AnswerStore) WithItems() *AnswerStore

WithItems joins `items`

func (*AnswerStore) WithResults 

func (s *AnswerStore) WithResults() *AnswerStore

WithResults creates a composable query for getting answers joined with results

func (*AnswerStore) WithUsers 

func (s *AnswerStore) WithUsers() *AnswerStore

WithUsers creates a composable query for getting answers joined with users (via author_id)

type AttemptStore 

type AttemptStore struct {
	*DataStore
}

AttemptStore implements database operations on `attempts`

func (*AttemptStore) CreateNew 

func (s *AttemptStore) CreateNew(participantID, parentAttemptID, itemID, creatorID int64) (attemptID int64, err error)

CreateNew creates a new attempt (with id > 0) with parent_attempt_id = parentAttemptID and a new result. It also sets attempts.created_at, results.started_at, results.latest_activity_at, so the result should be propagated.

type DB 

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

DB contains information for current db connection (wraps *gorm.DB)

func NewDBMock 

func NewDBMock() (*DB, sqlmock.Sqlmock)

NewDBMock generate a DB mock the database engine

func Open 

func Open(source interface{}) (*DB, error)

Open connects to the database and tests the connection nolint: gosec

func (*DB) Close 

func (conn *DB) Close() error

Close close current db connection. If database connection is not an io.Closer, returns an error.

func (*DB) Count 

func (conn *DB) Count(dest interface{}) *DB

Count gets how many records for a model

func (*DB) Delete 

func (conn *DB) Delete(where ...interface{}) *DB

Delete deletes value matching given conditions, if the value has primary key, then will including the primary key as condition

func (*DB) Error 

func (conn *DB) Error() error

Error returns current errors

func (*DB) Exec 

func (conn *DB) Exec(sqlQuery string, values ...interface{}) *DB

Exec executes raw sql

func (*DB) Group 

func (conn *DB) Group(query string) *DB

Group specifies the group method on the find

func (*DB) HasRows 

func (conn *DB) HasRows() (bool, error)

HasRows returns true if at least one row is found

func (*DB) Having 

func (conn *DB) Having(query interface{}, args ...interface{}) *DB

Having specifies HAVING conditions for GROUP BY

func (*DB) HavingMaxPermissionAtLeast 

func (conn *DB) HavingMaxPermissionAtLeast(permissionKind, permissionName string) *DB

HavingMaxPermissionAtLeast returns a composable query filtered by `MAX(can_*_generated_value)` >= indexOf(`permissionName`) depending on the given permission kind

func (*DB) InsertIgnoreMaps 

func (conn *DB) InsertIgnoreMaps(tableName string, dataMaps []map[string]interface{}) error

InsertIgnoreMaps reads fields from the given maps and inserts the values set in the first row (so keys in all maps should be same) into the given table ignoring errors (such as duplicates)

func (*DB) Joins 

func (conn *DB) Joins(query string, args ...interface{}) *DB

Joins specifies Joins conditions 

db.Joins("JOIN emails ON emails.user_id = users.id AND emails.email = ?", "jinzhu@example.org").Find(&user)

func (*DB) JoinsPermissionsForGroupToItemsWherePermissionAtLeast 

func (conn *DB) JoinsPermissionsForGroupToItemsWherePermissionAtLeast(groupID int64, permissionKind, neededPermission string) *DB

JoinsPermissionsForGroupToItemsWherePermissionAtLeast returns a composable query with access rights (as *_generated_value) for all the items on that the given group has 'permissionKind' >= `neededPermission`.

func (*DB) JoinsUserAndDefaultItemStrings 

func (conn *DB) JoinsUserAndDefaultItemStrings(user *User) *DB

JoinsUserAndDefaultItemStrings joins items_strings with the given view twice (as default_strings for item's default language and as user_strings for the user's default language)

func (*DB) Limit 

func (conn *DB) Limit(limit interface{}) *DB

Limit specifies the number of records to be retrieved

func (*DB) New 

func (conn *DB) New() *DB

New clones a new db connection without search conditions

func (*DB) Order 

func (conn *DB) Order(value interface{}, reorder ...bool) *DB

Order specifies order when retrieve records from database, set reorder to `true` to overwrite defined conditions 

db.Order("name DESC")
db.Order("name DESC", true) // reorder
db.Order(gorm.SqlExpr("name = ? DESC", "first")) // sql expression

func (*DB) Pluck 

func (conn *DB) Pluck(column string, values interface{}) *DB

Pluck is used to query a single column into a slice of values 

var ids []int64
db.Table("users").Pluck("id", &ids)

The 'values' parameter should be a pointer to a slice

func (*DB) PluckFirst 

func (conn *DB) PluckFirst(column string, value interface{}) *DB

PluckFirst is used to query a single column and take the first value 

var id int64
db.Table("users").PluckFirst("id", &id)

The 'values' parameter should be a pointer to a value

func (*DB) QueryExpr 

func (conn *DB) QueryExpr() interface{}

QueryExpr returns the query as expr object

func (*DB) Raw 

func (conn *DB) Raw(query string, args ...interface{}) *DB

Raw uses raw sql as conditions 

db.Raw("SELECT name, age FROM users WHERE name = ?", 3).Scan(&result)

func (*DB) RowsAffected 

func (conn *DB) RowsAffected() int64

RowsAffected returns the number of rows affected by the last UPDATE/DELETE statement

func (*DB) Scan 

func (conn *DB) Scan(dest interface{}) *DB

Scan scans value to a struct

func (*DB) ScanAndHandleMaps 

func (conn *DB) ScanAndHandleMaps(handler func(map[string]interface{}) error) *DB

ScanAndHandleMaps scans values into maps and calls the given handler for each row

func (*DB) ScanIntoSliceOfMaps 

func (conn *DB) ScanIntoSliceOfMaps(dest *[]map[string]interface{}) *DB

ScanIntoSliceOfMaps scans value into a slice of maps

func (*DB) ScanIntoSlices 

func (conn *DB) ScanIntoSlices(pointersToSlices ...interface{}) *DB

ScanIntoSlices scans multiple columns into slices

func (*DB) Select 

func (conn *DB) Select(query interface{}, args ...interface{}) *DB

Select specifies fields that you want to retrieve from database when querying, by default, will select all fields; When creating/updating, specify fields that you want to save to database

func (*DB) Set 

func (conn *DB) Set(name string, value interface{}) *DB

Set sets setting by name, which could be used in callbacks, will clone a new db, and update its setting

func (*DB) SubQuery 

func (conn *DB) SubQuery() interface{}

SubQuery returns the query as sub query

func (*DB) Table 

func (conn *DB) Table(name string) *DB

Table specifies the table you would like to run db operations

func (*DB) Take 

func (conn *DB) Take(out interface{}, where ...interface{}) *DB

Take returns a record that match given conditions, the order will depend on the database implementation

func (*DB) Union 

func (conn *DB) Union(query interface{}) *DB

Union specifies UNION of two queries (receiver UNION query)

func (*DB) UnionAll 

func (conn *DB) UnionAll(query interface{}) *DB

UnionAll specifies UNION ALL of two queries (receiver UNION ALL query)

func (*DB) UpdateColumn 

func (conn *DB) UpdateColumn(attrs ...interface{}) *DB

UpdateColumn updates attributes without callbacks, refer: https://jinzhu.github.io/gorm/crud.html#update

func (*DB) Updates 

func (conn *DB) Updates(values interface{}, ignoreProtectedAttrs ...bool) *DB

Updates update attributes with callbacks, refer: https://jinzhu.github.io/gorm/crud.html#update

func (*DB) Where 

func (conn *DB) Where(query interface{}, args ...interface{}) *DB

Where returns a new relation, filters records with given conditions, accepts `map`, `struct` or `string` as conditions, refer http://jinzhu.github.io/gorm/crud.html#query

func (*DB) WhereGroupHasPermissionOnItems 

func (conn *DB) WhereGroupHasPermissionOnItems(groupID int64, permissionKind, neededPermission string) *DB

WhereGroupHasPermissionOnItems returns a subview of the items on that the given group has `can_[permissionKind]_generated` >= `neededPermission` basing on the given view.

func (*DB) WhereGroupRelationIsActual 

func (conn *DB) WhereGroupRelationIsActual() *DB

WhereGroupRelationIsActual restricts `groups_groups.type` to values corresponding to actual group membership and forces the relation to be not expired

func (*DB) WhereItemsAreVisible 

func (conn *DB) WhereItemsAreVisible(groupID int64) *DB

WhereItemsAreVisible returns a subview of the visible items for the given group basing on the given view

func (*DB) WherePermissionIsAtLeast 

func (conn *DB) WherePermissionIsAtLeast(permissionKind, permissionName string) *DB

WherePermissionIsAtLeast returns a composable query filtered by `can_*_generated_value` >= indexOf(`permissionName`) depending on the given permission kind

func (*DB) WhereUserHasPermissionOnItems 

func (conn *DB) WhereUserHasPermissionOnItems(user *User, permissionKind, neededPermission string) *DB

WhereUserHasPermissionOnItems returns a subview of the items on that the given user has `can_view_generated` >= `viewPermission` basing on the given view.

func (*DB) WhereUserHasViewPermissionOnItems 

func (conn *DB) WhereUserHasViewPermissionOnItems(user *User, viewPermission string) *DB

WhereUserHasViewPermissionOnItems returns a subview of the items on that the given user has `can_view_generated` >= `viewPermission` basing on the given view.

func (*DB) WhereUsersAreDescendantsOfGroup 

func (conn *DB) WhereUsersAreDescendantsOfGroup(groupID int64) *DB

WhereUsersAreDescendantsOfGroup joins `groups_ancestors_active` on ancestor_group_id=groupID & child_group_id=users.group_id

func (*DB) WithPersonalInfoViewApprovals 

func (conn *DB) WithPersonalInfoViewApprovals(manager *User) *DB

WithPersonalInfoViewApprovals returns a subview with information on if a user (in `users` table) approved viewing their personal info for the given manager (`groups_groups.personal_info_view_approved` is true for a group managed by the given manager). The approvals can be checked as `personal_info_view_approvals.approved`.

func (*DB) WithWriteLock 

func (conn *DB) WithWriteLock() *DB

WithWriteLock converts "SELECT ..." statement into "SELECT ... FOR UPDATE" statement

type DataStore 

type DataStore struct {
	*DB
	// contains filtered or unexported fields
}

DataStore gather all stores for database operations on business data

func NewDataStore 

func NewDataStore(conn *DB) *DataStore

NewDataStore returns a DataStore

func NewDataStoreWithTable 

func NewDataStoreWithTable(conn *DB, tableName string) *DataStore

NewDataStoreWithTable returns a specialized DataStore

func (*DataStore) ActiveGroupAncestors 

func (s *DataStore) ActiveGroupAncestors() *GroupAncestorStore

ActiveGroupAncestors returns a GroupAncestorStore working with the `groups_ancestors_active` view

func (*DataStore) ActiveGroupGroups 

func (s *DataStore) ActiveGroupGroups() *GroupGroupStore

ActiveGroupGroups returns a GroupGroupStore working with the `groups_groups_active` view

func (*DataStore) Answers 

func (s *DataStore) Answers() *AnswerStore

Answers returns a AnswerStore

func (*DataStore) Attempts 

func (s *DataStore) Attempts() *AttemptStore

Attempts returns a AttemptStore

func (*DataStore) ByID 

func (s *DataStore) ByID(id int64) *DB

ByID returns a composable query for filtering by _table_.id

func (*DataStore) CheckIfTeamParticipationsConflictWithExistingUserMemberships 

func (store *DataStore) CheckIfTeamParticipationsConflictWithExistingUserMemberships(
	teamID, userGroupID int64, withLock bool) (bool, error)

CheckIfTeamParticipationsConflictWithExistingUserMemberships returns true if the given team has at least one active participation conflicting with active participations of the given user's teams.

func (*DataStore) GetGroupJoiningByCodeInfoByCode 

func (s *DataStore) GetGroupJoiningByCodeInfoByCode(code string, withLock bool) (*GroupJoiningByCodeInfo, error)

GetGroupJoiningByCodeInfoByCode returns GroupJoiningByCodeInfo for a given code (or null if there is no public team with this code or the code has expired)

func (*DataStore) Gradings 

func (s *DataStore) Gradings() *GradingStore

Gradings returns a GradingStore

func (*DataStore) GroupAncestors 

func (s *DataStore) GroupAncestors() *GroupAncestorStore

GroupAncestors returns a GroupAncestorStore

func (*DataStore) GroupContestItems 

func (s *DataStore) GroupContestItems() *GroupContestItemStore

GroupContestItems returns a GroupContestItemStore

func (*DataStore) GroupGroups 

func (s *DataStore) GroupGroups() *GroupGroupStore

GroupGroups returns a GroupGroupStore

func (*DataStore) GroupManagers 

func (s *DataStore) GroupManagers() *GroupManagerStore

GroupManagers returns a GroupManagerStore

func (*DataStore) GroupMembershipChanges 

func (s *DataStore) GroupMembershipChanges() *GroupMembershipChangeStore

GroupMembershipChanges returns a GroupMembershipChangeStore

func (*DataStore) GroupPendingRequests 

func (s *DataStore) GroupPendingRequests() *GroupPendingRequestStore

GroupPendingRequests returns a GroupPendingRequestStore

func (*DataStore) Groups 

func (s *DataStore) Groups() *GroupStore

Groups returns a GroupStore

func (*DataStore) InTransaction 

func (s *DataStore) InTransaction(txFunc func(*DataStore) error) error

InTransaction executes the given function in a transaction and commits

func (*DataStore) InsertMap 

func (s *DataStore) InsertMap(dataMap map[string]interface{}) error

InsertMap reads fields from the given map and inserts the values which have been set into the store's table

func (*DataStore) InsertMaps 

func (s *DataStore) InsertMaps(dataMaps []map[string]interface{}) error

InsertMaps reads fields from the given map and inserts the values set in the first row (so all the rows should have the same keys) into the store's table

func (*DataStore) InsertOrUpdateMap 

func (s *DataStore) InsertOrUpdateMap(dataMap map[string]interface{}, updateColumns []string) error

InsertOrUpdateMap reads fields from the given map and inserts the values which have been set into the store's table (like InsertMap does). If it is a duplicate, the listed columns will be updated.

func (*DataStore) InsertOrUpdateMaps 

func (s *DataStore) InsertOrUpdateMaps(dataMap []map[string]interface{}, updateColumns []string) error

InsertOrUpdateMaps reads fields from the given maps and inserts the values set in the first row (so all the maps should have the same keys) into the store's table (like InsertMaps does). If it is a duplicate, the listed columns will be updated.

func (*DataStore) ItemAncestors 

func (s *DataStore) ItemAncestors() *ItemAncestorStore

ItemAncestors returns an ItemAncestorStore

func (*DataStore) ItemDependencies 

func (s *DataStore) ItemDependencies() *ItemDependencyStore

ItemDependencies returns an ItemDependencyStore

func (*DataStore) ItemItems 

func (s *DataStore) ItemItems() *ItemItemStore

ItemItems returns an ItemItemStore

func (*DataStore) ItemStrings 

func (s *DataStore) ItemStrings() *ItemStringStore

ItemStrings returns an ItemStringStore

func (*DataStore) Items 

func (s *DataStore) Items() *ItemStore

Items returns a ItemStore

func (*DataStore) Languages 

func (s *DataStore) Languages() *LanguageStore

Languages returns a LanguageStore

func (*DataStore) NewID 

func (s *DataStore) NewID() int64

NewID generates a positive random int64 to be used as id !!! To be safe, the insertion should be be retried if the id conflicts with an existing entry

func (*DataStore) Permissions 

func (s *DataStore) Permissions() *PermissionGeneratedStore

Permissions returns a PermissionGeneratedStore

func (*DataStore) PermissionsGranted 

func (s *DataStore) PermissionsGranted() *PermissionGrantedStore

PermissionsGranted returns a PermissionGrantedStore

func (*DataStore) Platforms 

func (s *DataStore) Platforms() *PlatformStore

Platforms returns a PlatformStore

func (*DataStore) RefreshTokens 

func (s *DataStore) RefreshTokens() *RefreshTokenStore

RefreshTokens returns a RefreshTokenStore

func (*DataStore) Results 

func (s *DataStore) Results() *ResultStore

Results returns a ResultStore

func (*DataStore) RetryOnDuplicateKeyError 

func (s *DataStore) RetryOnDuplicateKeyError(keyName, nameInError string, f func(store *DataStore) error) error

RetryOnDuplicateKeyError will retry the given function on getting duplicate entry errors for the given key

func (*DataStore) RetryOnDuplicatePrimaryKeyError 

func (s *DataStore) RetryOnDuplicatePrimaryKeyError(f func(store *DataStore) error) error

RetryOnDuplicatePrimaryKeyError will retry the given function on getting duplicate entry errors for primary keys

func (*DataStore) Sessions 

func (s *DataStore) Sessions() *SessionStore

Sessions returns a SessionStore

func (*DataStore) UserBatchPrefixes 

func (s *DataStore) UserBatchPrefixes() *UserBatchPrefixStore

UserBatchPrefixes returns a UserBatchPrefixStore

func (*DataStore) UserBatches 

func (s *DataStore) UserBatches() *UserBatchStore

UserBatches returns a UserBatchStore

func (*DataStore) Users 

func (s *DataStore) Users() *UserStore

Users returns a UserStore

func (*DataStore) WithForeignKeyChecksDisabled 

func (s *DataStore) WithForeignKeyChecksDisabled(blockFunc func(*DataStore) error) error

WithForeignKeyChecksDisabled executes the given function with foreign keys checking disabled (wraps it up in a transaction if no transaction started)

func (*DataStore) WithNamedLock 

func (s *DataStore) WithNamedLock(lockName string, timeout time.Duration, txFunc func(*DataStore) error) error

WithNamedLock wraps the given function in GET_LOCK/RELEASE_LOCK

type GradingStore 

type GradingStore struct {
	*DataStore
}

GradingStore implements database operations on `gradings`

type GroupAncestorStore 

type GroupAncestorStore struct {
	*DataStore
}

GroupAncestorStore implements database operations on `groups_ancestors` (which is a precomputed cache over groups_groups)

func (*GroupAncestorStore) ManagedByUser 

func (s *GroupAncestorStore) ManagedByUser(user *User) *DB

ManagedByUser returns a composable query for getting all the groups_ancestors rows linking manager groups (as ancestor_group_id) to managed groups (as child_group_id) where the manager groups are ancestors of the given user. Basically the groups_ancestors.child_group_id are the groups the user can manage.

The result may contain duplicated `groups_ancestors.ancestor_group_id`-`groups_ancestors.child_group_id` pairs since there can be different paths to a managed group through the `group_managers` table and the group ancestry graph.

type GroupApprovals 

type GroupApprovals struct {
	PersonalInfoViewApproval bool
	LockMembershipApproval   bool
	WatchApproval            bool
}

GroupApprovals represents all the approvals that can be given by a user to the group managers

func (*GroupApprovals) FromString 

func (approvals *GroupApprovals) FromString(s string)

FromString initializes GroupApprovals from the given comma-separated list of approvals

func (*GroupApprovals) ToArray 

func (approvals *GroupApprovals) ToArray() []string

ToArray converts GroupApprovals to a list of approvals

type GroupContestItemStore 

type GroupContestItemStore struct {
	*DataStore
}

GroupContestItemStore implements database operations on `groups_contest_items`

type GroupGroupStore 

type GroupGroupStore struct {
	*DataStore
}

GroupGroupStore implements database operations on `groups_groups` (which stores parent-child relationships between groups).

func (*GroupGroupStore) After 

func (s *GroupGroupStore) After() (err error)

After is a "listener" that calls GroupGroupStore::createNewAncestors()

func (*GroupGroupStore) CreateRelation 

func (s *GroupGroupStore) CreateRelation(parentGroupID, childGroupID int64) (err error)

CreateRelation creates a direct relation between two groups

func (*GroupGroupStore) CreateRelationsWithoutChecking 

func (s *GroupGroupStore) CreateRelationsWithoutChecking(relations []map[string]interface{}) (err error)

CreateRelationsWithoutChecking creates multiple direct relations at once without checking for possible cycles in the graph and without deletion of old relations. This method is only suitable to create relations with new groups. Callers must check that parent groups are not users.

func (*GroupGroupStore) DeleteRelation 

func (s *GroupGroupStore) DeleteRelation(parentGroupID, childGroupID int64, shouldDeleteOrphans bool) (err error)

DeleteRelation deletes a relation between two groups. It can also delete orphaned groups.

func (*GroupGroupStore) Transition 

func (s *GroupGroupStore) Transition(action GroupGroupTransitionAction,
	parentGroupID int64, childGroupIDs []int64, approvals map[int64]GroupApprovals,
	performedByUserID int64) (results GroupGroupTransitionResults, approvalsToRequest map[int64]GroupApprovals, err error)

Transition performs a groups_groups relation transition according to groupGroupTransitionRules

func (*GroupGroupStore) WhereUserIsMember 

func (s *GroupGroupStore) WhereUserIsMember(user *User) *DB

WhereUserIsMember returns a composable query of direct ancestors (parents) of user's self group, i.e. groups of which he is a direct member

func (*GroupGroupStore) WithGroupsRelationsLock 

func (s *GroupGroupStore) WithGroupsRelationsLock(txFunc func(*DataStore) error) error

WithGroupsRelationsLock wraps the given function in GET_LOCK/RELEASE_LOCK specific for modifying relations between groups

type GroupGroupTransitionAction 

type GroupGroupTransitionAction int

GroupGroupTransitionAction represents a groups_groups relation transition action 

const (
	// AdminCreatesInvitation means a group admin invites new users to the group
	AdminCreatesInvitation GroupGroupTransitionAction = iota
	// UserCreatesJoinRequest means a user creates a request to become a group member
	UserCreatesJoinRequest
	// UserCreatesAcceptedJoinRequest means a user adds himself into a group that he owns
	// It doesn't check if the user owns the group / all needed approvals are given (a calling service should check that)
	UserCreatesAcceptedJoinRequest
	// UserAcceptsInvitation means a user accepts a group invitation
	UserAcceptsInvitation
	// AdminAcceptsJoinRequest means a group admin accepts a request to join a group.
	// For this action we check that all the approvals required by the group are given in the join request
	// and set groups_groups.*_approved_at to group_pending_requests.at for each.
	AdminAcceptsJoinRequest
	// AdminAcceptsLeaveRequest means a group admin accepts a request to leave a group
	AdminAcceptsLeaveRequest
	// AdminRefusesLeaveRequest means a group admin refuses a request to leave a group
	AdminRefusesLeaveRequest
	// UserRefusesInvitation means a user refuses a group invitation
	UserRefusesInvitation
	// AdminRefusesJoinRequest means a group admin refuses a request to join the group
	AdminRefusesJoinRequest
	// AdminRemovesUser means a group admin removes a user from a group. It marks relations as "removed".
	// It doesn't check if a child is a user or not.
	AdminRemovesUser
	// AdminWithdrawsInvitation means a group admin withdraws an invitation
	AdminWithdrawsInvitation
	// UserLeavesGroup means a user leaves a group
	UserLeavesGroup
	// UserCreatesLeaveRequest means a user creates a request to leave a group
	// We don't check that groups.require_lock_membership_approval_until & groups_groups.lock_membership_approved_at
	// are not null (a calling service should check that by itself)
	UserCreatesLeaveRequest
	// UserCancelsJoinRequest means a user cancels his request to join a group
	UserCancelsJoinRequest
	// UserCancelsLeaveRequest means a user cancels his request to leave a group
	UserCancelsLeaveRequest
	// AdminRemovesDirectRelation removes a direct relation
	AdminRemovesDirectRelation
	// UserJoinsGroupByCode means a user joins a group using a group's code
	// We don't check the code here (a calling service should check the code by itself)
	UserJoinsGroupByCode
)

type GroupGroupTransitionResult 

type GroupGroupTransitionResult string

GroupGroupTransitionResult is an enum{cycle, invalid, success, unchanged} 

const (
	// Cycle means that the transition wasn't performed because it would create a cycle in groups_groups graph
	Cycle GroupGroupTransitionResult = "cycle"
	// Invalid means that the transition is impossible
	Invalid GroupGroupTransitionResult = "invalid"
	// ApprovalsMissing means that one or more approvals required by the transition are missing
	ApprovalsMissing GroupGroupTransitionResult = "approvals_missing"
	// Full means that the parent group is full (in terms of `groups.max_participants`) when `enforce_max_participants` is true
	// (The number of participants is computed as the number of non-expired users or teams which are direct children
	//  of the group + invitations (join requests are not counted).)
	Full GroupGroupTransitionResult = "full"
	// Success means that the transition was performed successfully
	Success GroupGroupTransitionResult = "success"
	// Unchanged means that the transition has been already performed
	Unchanged GroupGroupTransitionResult = "unchanged"
)

type GroupGroupTransitionResults 

type GroupGroupTransitionResults map[int64]GroupGroupTransitionResult

GroupGroupTransitionResults represents results of mass transition (format: map{ id -> GroupGroupTransitionResult })

type GroupJoiningByCodeInfo 

type GroupJoiningByCodeInfo struct {
	GroupID             int64
	Type                string
	CodeExpiresAtIsNull bool
	CodeLifetimeIsNull  bool
	FrozenMembership    bool
}

GroupJoiningByCodeInfo represents info related to ability to join a team by code

type GroupManagerStore 

type GroupManagerStore struct {
	*DataStore
}

GroupManagerStore implements database operations on `group_managers` (which stores group managers and their permissions).

func (*GroupManagerStore) CanManageIndexByName 

func (s *GroupManagerStore) CanManageIndexByName(name string) int

CanManageIndexByName returns the index of the given group manager permission from the `can_manage` enum

func (*GroupManagerStore) CanManageNameByIndex 

func (s *GroupManagerStore) CanManageNameByIndex(index int) string

CanManageNameByIndex returns the name of the given group manager permission from the `can_manage` enum

type GroupMembershipAction 

type GroupMembershipAction string

GroupMembershipAction represents an action that changes relation between two groups 

const (
	// InvitationCreated means a pending group admin's invitation for user to join a group was created
	InvitationCreated GroupMembershipAction = "invitation_created"
	// JoinRequestCreated means a pending user's request to join a group was created
	JoinRequestCreated GroupMembershipAction = "join_request_created"
	// InvitationAccepted means a user became a member of a group by accepting an invitation
	InvitationAccepted GroupMembershipAction = "invitation_accepted"
	// JoinRequestAccepted means a user became a member of a group since a group admin accepted his request
	JoinRequestAccepted GroupMembershipAction = "join_request_accepted"
	// LeaveRequestAccepted means a user left a group since a group admin accepted his leave request
	LeaveRequestAccepted GroupMembershipAction = "leave_request_accepted"
	// InvitationRefused means a user refused an invitation to join a group
	InvitationRefused GroupMembershipAction = "invitation_refused"
	// InvitationWithdrawn means an admin withdrew his invitation to join a group
	InvitationWithdrawn GroupMembershipAction = "invitation_withdrawn"
	// JoinedByCode means a user joined a group by the group's code
	JoinedByCode GroupMembershipAction = "joined_by_code"
	// JoinRequestRefused means an admin refused a user's request to join a group
	JoinRequestRefused GroupMembershipAction = "join_request_refused"
	// JoinRequestWithdrawn means a user withdrew his request to join a group
	JoinRequestWithdrawn GroupMembershipAction = "join_request_withdrawn"
	// Removed means a user was removed from a group
	Removed GroupMembershipAction = "removed"
	// Left means a user left a group
	Left GroupMembershipAction = "left"
	// IsMember means a user is a member of a group
	IsMember GroupMembershipAction = "is_member"
	// LeaveRequestCreated means a pending user's request to leave a group was created
	LeaveRequestCreated GroupMembershipAction = "is_member,leave_request_created"
	// LeaveRequestExpired means a pending user's leave request for an expired membership
	LeaveRequestExpired GroupMembershipAction = "leave_request_created"
	// LeaveRequestRefused means a manager refused a user's request to leave a group
	LeaveRequestRefused GroupMembershipAction = "leave_request_refused"
	// LeaveRequestWithdrawn means a user withdrew his request to leave a group
	LeaveRequestWithdrawn GroupMembershipAction = "leave_request_withdrawn"
	// NoRelation means there is no row for the group pair in the groups_groups/group_pending_requests tables
	NoRelation GroupMembershipAction = ""
)

func (GroupMembershipAction) PendingType 

func (groupMembershipAction GroupMembershipAction) PendingType() string

PendingType converts the GroupMembershipAction into `group_pending_requests.type`

type GroupMembershipChangeStore 

type GroupMembershipChangeStore struct {
	*DataStore
}

GroupMembershipChangeStore implements database operations on `group_membership_changes` (which stores the history of group membership changes).

type GroupPendingRequestStore 

type GroupPendingRequestStore struct {
	*DataStore
}

GroupPendingRequestStore implements database operations on `group_pending_requests` (which stores requests that require an action from a user).

type GroupStore 

type GroupStore struct {
	*DataStore
}

GroupStore implements database operations on groups

func (*GroupStore) CheckIfEntryConditionsStillSatisfiedForAllActiveParticipations 

func (s *GroupStore) CheckIfEntryConditionsStillSatisfiedForAllActiveParticipations(
	teamGroupID, userID int64, isAdding, withLock bool) (bool, error)

CheckIfEntryConditionsStillSatisfiedForAllActiveParticipations checks whether adding/removal of a user specified by userID would keep entry conditions satisfied for all active participations of teamGroupID. If at least one entry condition becomes broken for at least one active participation, the method returns false. An active participation is one that is started (`results.started_at` is not null for the `root_item_id`), still allows submissions and is not ended. Entry conditions are defined by items.entry_min_admitted_members_ratio & items.entry_max_team_size (for more info see description of the itemGetEntryState service). The isAdding parameter specifies if we are going to add or remove a user.

func (*GroupStore) CreateNew 

func (s *GroupStore) CreateNew(name, groupType string) (groupID int64, err error)

CreateNew creates a new group with given name and type. It also runs GroupGroupStore.createNewAncestors().

func (*GroupStore) DeleteGroup 

func (s *GroupStore) DeleteGroup(groupID int64) (err error)

DeleteGroup deletes a group and emerging orphaned groups

func (*GroupStore) GenerateQueryCheckingIfActionBreaksEntryConditionsForActiveParticipations 

func (s *GroupStore) GenerateQueryCheckingIfActionBreaksEntryConditionsForActiveParticipations(
	teamGroupIDExpr *gorm.SqlExpr, userID int64, isAdding, withLock bool) *DB

GenerateQueryCheckingIfActionBreaksEntryConditionsForActiveParticipations generates an SQL query checking whether adding/removal of a user specified by userID would break any of entry conditions for any of active participations of teamGroupID. If at least one entry condition becomes broken for at least one active participation, the query returns a row with 1. An active participation is one that is started (`results.started_at` is not null for the `root_item_id`), still allows submissions and is not ended. Entry conditions are defined by items.entry_min_admitted_members_ratio & items.entry_max_team_size (for more info see description of the itemGetEntryState service). The isAdding parameter specifies if we are going to add or remove a user.

func (*GroupStore) ManagedBy 

func (s *GroupStore) ManagedBy(user *User) *DB

ManagedBy returns a composable query for getting all the groups the user can manage.

The `groups` in the result may be duplicated since there can be different paths to a managed group through the `group_managers` table and the group ancestry graph.

func (*GroupStore) TeamGroupForTeamItemAndUser 

func (s *GroupStore) TeamGroupForTeamItemAndUser(itemID int64, user *User) *DB

TeamGroupForTeamItemAndUser returns a composable query for getting a team that

  1. the given user is a member of
  2. has an unexpired attempt with root_item_id = `itemID`.

If more than one team is found (which should be impossible), the one with the smallest `groups.id` is returned.

func (*GroupStore) TeamGroupForUser 

func (s *GroupStore) TeamGroupForUser(teamGroupID int64, user *User) *DB

TeamGroupForUser returns a composable query for getting team group of the given user with given id

type HintsInfo 

type HintsInfo struct {
	HintsRequested *string
	HintsCached    int32
}

HintsInfo contains information on requested hints and their cached count

type ItemAccessDetails 

type ItemAccessDetails struct {
	// MAX(permissions_generated.can_view_generated_value) converted back into the string representation
	CanView string `json:"can_view"`
}

ItemAccessDetails represents access rights for an item

func (*ItemAccessDetails) IsForbidden 

func (accessDetails *ItemAccessDetails) IsForbidden() bool

IsForbidden returns true when can_view_generated = 'none'

func (*ItemAccessDetails) IsInfo 

func (accessDetails *ItemAccessDetails) IsInfo() bool

IsInfo returns true when can_view_generated = 'info'

type ItemAccessDetailsWithID 

type ItemAccessDetailsWithID struct {
	ItemID int64
	ItemAccessDetails
}

ItemAccessDetailsWithID represents access rights for an item + ItemID

type ItemAncestorStore 

type ItemAncestorStore struct {
	*DataStore
}

ItemAncestorStore implements database operations on `items_ancestors`

func (*ItemAncestorStore) DescendantsOf 

func (s *ItemAncestorStore) DescendantsOf(ancestorID int64) *ItemItemStore

DescendantsOf returns a composable query for getting descendants of the given item

type ItemDependencyStore 

type ItemDependencyStore struct {
	*DataStore
}

ItemDependencyStore implements database operations on `item_dependencies`

type ItemItemStore 

type ItemItemStore struct {
	*DataStore
}

ItemItemStore implements database operations on `items_items`

func (*ItemItemStore) After 

func (s *ItemItemStore) After() (err error)

After is a "listener" that calls ItemItemStore::createNewAncestors(), PermissionGrantedStore::computeAllAccess() & ResultStore.Propagate()

func (*ItemItemStore) ChildrenOf 

func (s *ItemItemStore) ChildrenOf(parentID int64) *ItemItemStore

ChildrenOf returns a composable query for selecting children of the given item

func (*ItemItemStore) ContentViewPropagationIndexByName 

func (s *ItemItemStore) ContentViewPropagationIndexByName(name string) int

ContentViewPropagationIndexByName returns the index of the given content view propagation level in the enum

func (*ItemItemStore) ContentViewPropagationNameByIndex 

func (s *ItemItemStore) ContentViewPropagationNameByIndex(index int) string

ContentViewPropagationNameByIndex returns the content view propagation level name with the given index from the enum

func (*ItemItemStore) UpperViewLevelsPropagationIndexByName 

func (s *ItemItemStore) UpperViewLevelsPropagationIndexByName(name string) int

UpperViewLevelsPropagationIndexByName returns the index of the given upper-level view propagation kind in the enum

func (*ItemItemStore) UpperViewLevelsPropagationNameByIndex 

func (s *ItemItemStore) UpperViewLevelsPropagationNameByIndex(index int) string

UpperViewLevelsPropagationNameByIndex returns the upper-level view propagation kind name with the given index from the enum

func (*ItemItemStore) WithItemsRelationsLock 

func (s *ItemItemStore) WithItemsRelationsLock(txFunc func(*DataStore) error) error

WithItemsRelationsLock wraps the given function in GET_LOCK/RELEASE_LOCK specific for modifying relations between items

type ItemStore 

type ItemStore struct {
	*DataStore
}

ItemStore implements database operations on items

func (*ItemStore) BreadcrumbsHierarchyForAttempt 

func (s *ItemStore) BreadcrumbsHierarchyForAttempt(ids []int64, groupID, attemptID int64, withWriteLock bool) (
	attemptIDMap map[int64]int64, attemptNumberMap map[int64]int, err error)

BreadcrumbsHierarchyForAttempt returns attempts ids and 'order' (for items allowing multiple attempts) for the given list of item ids if it is a valid participation hierarchy for the given `attemptID` which means all the following statements are true:

  • the first item in `ids` is an activity/skill item (groups.root_activity_id/root_skill_id) of a group the `groupID` is a descendant of,
  • `ids` is an ordered list of parent-child items,
  • the `groupID` group has at least 'content' access on each of the items in `ids` except for the last one and at least 'info' access on the last one,
  • the `groupID` group has a started result for each item, with `attemptID` (or its parent attempt each time we reach a root of an attempt) as the attempt.

func (*ItemStore) BreadcrumbsHierarchyForParentAttempt 

func (s *ItemStore) BreadcrumbsHierarchyForParentAttempt(ids []int64, groupID, parentAttemptID int64, withWriteLock bool) (
	attemptIDMap map[int64]int64, attemptNumberMap map[int64]int, err error)

BreadcrumbsHierarchyForParentAttempt returns attempts ids and 'order' (for items allowing multiple attempts) for the given list of item ids (but the last item) if it is a valid participation hierarchy for the given `parentAttemptID` which means all the following statements are true:

  • the first item in `ids` is a root activity/skill (groups.root_activity_id/root_skill_id) of a group the `groupID` is a descendant of,
  • `ids` is an ordered list of parent-child items,
  • the `groupID` group has at least 'content' access on each of the items in `ids` except for the last one and at least 'info' access on the last one,
  • the `groupID` group has a started result for each item but the last, with `parentAttemptID` (or its parent attempt each time we reach a root of an attempt) as the attempt,
  • if `ids` consists of only one item, the `parentAttemptID` is zero.

func (*ItemStore) CheckSubmissionRights 

func (s *ItemStore) CheckSubmissionRights(participantID, itemID int64) (hasAccess bool, reason, err error)

CheckSubmissionRights checks if the participant group can submit an answer for the given item (task), i.e. the item (task) exists and is not read-only and the participant has at least content:view permission on the item;

func (*ItemStore) ContestManagedByUser 

func (s *ItemStore) ContestManagedByUser(contestItemID int64, user *User) *DB

ContestManagedByUser returns a composable query for getting a contest with the given item id managed by the given user

func (*ItemStore) DeleteItem 

func (s *ItemStore) DeleteItem(itemID int64) (err error)

DeleteItem deletes an item. Note the method fails if the item has children.

func (*ItemStore) IsValidParticipationHierarchyForParentAttempt 

func (s *ItemStore) IsValidParticipationHierarchyForParentAttempt(
	ids []int64, groupID, parentAttemptID int64, requireContentAccessToTheLastItem, withWriteLock bool) (bool, error)

IsValidParticipationHierarchyForParentAttempt checks if the given list of item ids is a valid participation hierarchy for the given `parentAttemptID` which means all the following statements are true:

  • the first item in `ids` is a root activity/skill (groups.root_activity_id/root_skill_id) of a group the `groupID` is a descendant of,
  • `ids` is an ordered list of parent-child items,
  • the `groupID` group has at least 'content' access on each of the items in `ids`,
  • the `groupID` group has a started, allowing submission, not ended result for each item but the last, with `parentAttemptID` (or its parent attempt each time we reach a root of an attempt) as the attempt,
  • if `ids` consists of only one item, the `parentAttemptID` is zero.

func (*ItemStore) Visible 

func (s *ItemStore) Visible(groupID int64) *DB

Visible returns a view of the visible items for the given participant

func (*ItemStore) VisibleByID 

func (s *ItemStore) VisibleByID(groupID, itemID int64) *DB

VisibleByID returns a view of the visible item identified by itemID, for the given participant

type ItemStringStore 

type ItemStringStore struct {
	*DataStore
}

ItemStringStore implements database operations on `items_strings`

type LanguageStore 

type LanguageStore struct {
	*DataStore
}

LanguageStore implements database operations on languages

func (*LanguageStore) ByTag 

func (s *LanguageStore) ByTag(tag string) *DB

ByTag returns a composable query for filtering by _table_.tag

type ParentChild 

type ParentChild struct {
	ParentID int64
	ChildID  int64
}

ParentChild represents a (ParentID, ChildID) pair.

type PermissionGeneratedStore 

type PermissionGeneratedStore struct {
	*DataStore
}

PermissionGeneratedStore implements database operations on `permissions_generated`

func (*PermissionGeneratedStore) AggregatedPermissionsForItems 

func (s *PermissionGeneratedStore) AggregatedPermissionsForItems(groupID int64) *DB

AggregatedPermissionsForItems returns a composable query for getting access rights of the given group (as *_generated_value) and item ids (as item_id) for all items.

func (*PermissionGeneratedStore) AggregatedPermissionsForItemsOnWhichGroupHasPermission 

func (s *PermissionGeneratedStore) AggregatedPermissionsForItemsOnWhichGroupHasPermission(
	groupID int64, permissionKind, neededPermission string) *DB

AggregatedPermissionsForItemsOnWhichGroupHasPermission returns a composable query for getting access rights (as *_generated_value) and item ids (as item_id) for all the items on that the given group has 'permissionKind' >= `neededPermission`.

func (*PermissionGeneratedStore) AggregatedPermissionsForItemsOnWhichGroupHasViewPermission 

func (s *PermissionGeneratedStore) AggregatedPermissionsForItemsOnWhichGroupHasViewPermission(groupID int64, viewPermission string) *DB

AggregatedPermissionsForItemsOnWhichGroupHasViewPermission returns a composable query for getting access rights (as can_view_generated_value) and item ids (as item_id) for all the items on that the given group has `can_view_generated` >= `viewPermission`.

func (*PermissionGeneratedStore) AggregatedPermissionsForItemsVisibleToGroup 

func (s *PermissionGeneratedStore) AggregatedPermissionsForItemsVisibleToGroup(groupID int64) *DB

AggregatedPermissionsForItemsVisibleToGroup returns a composable query for getting access rights (as can_view_generated_value) and item ids (as item_id) for all the items that are visible to the given group.

func (*PermissionGeneratedStore) MatchingGroupAncestors 

func (s *PermissionGeneratedStore) MatchingGroupAncestors(groupID int64) *DB

MatchingGroupAncestors returns a composable query of generated permissions matching groups of which the given group is descendant

func (*PermissionGeneratedStore) MatchingUserAncestors 

func (s *PermissionGeneratedStore) MatchingUserAncestors(user *User) *DB

MatchingUserAncestors returns a composable query of generated permissions matching groups of which the user is descendant

type PermissionGrantedStore 

type PermissionGrantedStore struct {
	*DataStore
}

PermissionGrantedStore implements database operations on `permissions_granted`

func (*PermissionGrantedStore) After 

func (s *PermissionGrantedStore) After() (err error)

After is a "listener" that calls PermissionGrantedStore::computeAllAccess()

func (*PermissionGrantedStore) EditIndexByName 

func (s *PermissionGrantedStore) EditIndexByName(name string) int

EditIndexByName returns the index of the given "edit" permission name in the 'can_edit' enum

func (*PermissionGrantedStore) EditNameByIndex 

func (s *PermissionGrantedStore) EditNameByIndex(index int) string

EditNameByIndex returns the 'edit' permission name with the given index from 'can_edit' enum

func (*PermissionGrantedStore) GrantViewIndexByName 

func (s *PermissionGrantedStore) GrantViewIndexByName(name string) int

GrantViewIndexByName returns the index of the given "grant view" permission name in the 'can_grant_view' enum

func (*PermissionGrantedStore) GrantViewNameByIndex 

func (s *PermissionGrantedStore) GrantViewNameByIndex(index int) string

GrantViewNameByIndex returns the 'grant view' permission name with the given index from 'can_grant_view' enum

func (*PermissionGrantedStore) PermissionIndexByKindAndName 

func (s *PermissionGrantedStore) PermissionIndexByKindAndName(kind, name string) int

PermissionIndexByKindAndName returns the index of the given permission in the enum

func (*PermissionGrantedStore) PermissionIsAtLeastSqlExpr 

func (s *PermissionGrantedStore) PermissionIsAtLeastSqlExpr(permissionKind, permissionName string) *gorm.SqlExpr

PermissionIsAtLeastSqlExpr returns a gorm.SqlExpr for filtering by `can_*_generated_value` >= indexOf(`permissionName`) depending on the given permission kind

func (*PermissionGrantedStore) PermissionNameByKindAndIndex 

func (s *PermissionGrantedStore) PermissionNameByKindAndIndex(kind string, index int) string

PermissionNameByKindAndIndex returns the permission name of the given kind with the given index from the enum

func (*PermissionGrantedStore) ViewIndexByName 

func (s *PermissionGrantedStore) ViewIndexByName(name string) int

ViewIndexByName returns the index of the given view kind in the 'can_view' enum

func (*PermissionGrantedStore) ViewNameByIndex 

func (s *PermissionGrantedStore) ViewNameByIndex(index int) string

ViewNameByIndex returns the view permission name with the given index from the 'can_view' enum

func (*PermissionGrantedStore) WatchIndexByName 

func (s *PermissionGrantedStore) WatchIndexByName(name string) int

WatchIndexByName returns the index of the given "watch" permission name in the 'can_watch' enum

func (*PermissionGrantedStore) WatchNameByIndex 

func (s *PermissionGrantedStore) WatchNameByIndex(index int) string

WatchNameByIndex returns the 'watch' permission name with the given index from 'can_watch' enum

type PlatformStore 

type PlatformStore struct {
	*DataStore
}

PlatformStore implements database operations on `platforms`

type RawGeneratedPermissionFields 

type RawGeneratedPermissionFields struct {
	CanViewGeneratedValue      int
	CanGrantViewGeneratedValue int
	CanWatchGeneratedValue     int
	CanEditGeneratedValue      int
	IsOwnerGenerated           bool
}

RawGeneratedPermissionFields represents DB data fields for item permissions used by item-related services

func (*RawGeneratedPermissionFields) AsItemPermissions 

func (raw *RawGeneratedPermissionFields) AsItemPermissions(
	permissionGrantedStore *PermissionGrantedStore) *structures.ItemPermissions

AsItemPermissions converts RawGeneratedPermissionFields into structures.ItemPermissions

type RefreshTokenStore 

type RefreshTokenStore struct {
	*DataStore
}

RefreshTokenStore implements database operations on `refresh_tokens`

type ResultStore 

type ResultStore struct {
	*DataStore
}

ResultStore implements database operations on `results`

func (*ResultStore) ByID 

func (s *ResultStore) ByID(participantID, attemptID, itemID int64) *DB

ByID returns a composable query for getting a result row by the primary key (participant_id, attemptID, itemID)

func (*ResultStore) GetHintsInfoForActiveAttempt 

func (s *ResultStore) GetHintsInfoForActiveAttempt(participantID, attemptID, itemID int64) (result *HintsInfo, err error)

GetHintsInfoForActiveAttempt returns HintsInfo of the result identified by given participantID, attemptID, itemID and linked to an active attempt. If such a result doesn't exist, the gorm.ErrRecordNotFound error is returned.

func (*ResultStore) MarkAsToBePropagated 

func (s *ResultStore) MarkAsToBePropagated(participantID, attemptID, itemID int64) error

MarkAsToBePropagated marks a given result as 'to_be_propagated'

func (*ResultStore) Propagate 

func (s *ResultStore) Propagate() (err error)

Propagate recomputes fields of results For results marked as 'to_be_propagated'/'to_be_recomputed':

  1. We mark all their ancestors in results as 'to_be_recomputed' (we consider a row in results as an ancestor if a) it has the same value in group_id b) its item_id is an ancestor of the original row's item_id c) its attempt_id is equal to the original row's attempt_id for original rows with root_item_id != item_id or its attempt_id is equal to the original row's parent_attempt_id for original rows with root_item_id = item_id).
  2. We process all objects that are marked as 'to_be_recomputed' and that have no children marked as 'to_be_recomputed'. Then, if an object has children, we update latest_activity_at, tasks_tried, tasks_with_help, validated_at. This step is repeated until no records are updated.
  3. We insert new permissions_granted for each unlocked item according to corresponding item_dependencies.

type SessionStore 

type SessionStore struct {
	*DataStore
}

SessionStore implements database operations on `sessions`

func (*SessionStore) InsertNewOAuth 

func (s *SessionStore) InsertNewOAuth(userID int64, token string, secondsUntilExpiry int32, issuer string) error

InsertNewOAuth inserts a new OAuth token for the given user into the DB

type Time 

type Time time.Time

Time is the same as time.Time, but it can be assigned from MySQL datetime string representation (implements Scanner interface), can convert itself to sql/driver.Value (implements Valuer interface) and marshal itself as JSON (implements json.Marshaler)

swagger:strfmt date-time

func (*Time) MarshalJSON 

func (t *Time) MarshalJSON() ([]byte, error)

MarshalJSON returns the JSON encoding of t

func (*Time) Scan 

func (t *Time) Scan(src interface{}) (err error)

Scan assigns a value from a database driver value ([]byte)

func (*Time) ScanString 

func (t *Time) ScanString(str string) (err error)

ScanString assigns a value from string with a database driver value

func (*Time) Value 

func (t *Time) Value() (driver.Value, error)

Value returns a database driver Value (*time.Time)

type User 

type User struct {
	GroupID             int64
	Login               string
	LoginID             *int64
	DefaultLanguage     string
	IsAdmin             bool
	IsTempUser          bool `sql:"column:temp_user"`
	AccessGroupID       *int64
	NotificationsReadAt *Time
}

User represents data associated with the user (from the `users` table)

func (*User) Clone 

func (u *User) Clone() *User

Clone returns a deep copy of the given User structure

type UserBatchPrefixStore 

type UserBatchPrefixStore struct {
	*DataStore
}

UserBatchPrefixStore implements database operations on `user_batch_prefixes`

type UserBatchStore 

type UserBatchStore struct {
	*DataStore
}

UserBatchStore implements database operations on `user_batches`

type UserStore 

type UserStore struct {
	*DataStore
}

UserStore implements database operations on `users`

func (*UserStore) ByID 

func (s *UserStore) ByID(id int64) *DB

ByID returns a composable query for filtering by _table_.group_id

func (*UserStore) DeleteTemporaryWithTraps 

func (s *UserStore) DeleteTemporaryWithTraps() (err error)

DeleteTemporaryWithTraps deletes temporary users who don't have active sessions. It also removes linked rows in the tables:

  1. [`users_threads`, `filters`, `sessions`, `refresh_tokens`] having `user_id` = `users.group_id`;
  2. `answers` having `author_id`/`participant_id` = `users.group_id`;
  3. [`permissions_granted`, `permissions_generated`, `attempts`] having `group_id` = `users.group_id`;
  4. [`attempts`, `results`] having `participant_id` = `users.group_id`;
  5. `groups_groups` having `parent_group_id` or `child_group_id` equal to `users.group_id`;
  6. `groups_ancestors` having `ancestor_group_id` or `child_group_id` equal to `users.group_id`;
  7. [`groups_propagate`, `groups`] having `id` equal to `users.group_id`.

func (*UserStore) DeleteWithTraps 

func (s *UserStore) DeleteWithTraps(user *User) (err error)

DeleteWithTraps deletes a given user. It also removes linked rows in the same way as DeleteTemporaryWithTraps.

func (*UserStore) DeleteWithTrapsByScope 

func (s *UserStore) DeleteWithTrapsByScope(scopeFunc func(store *DataStore) *DB) (err error)

DeleteWithTrapsByScope deletes users matching the given scope. It also removes linked rows in the same way as DeleteTemporaryWithTraps.

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.