resource

package

Go to main page

Versions in this module

v0

v0.7.0

Jul 8, 2018

Changes in this version

type ActionPerformerInterface

+ func NewGenerateOauth2TokenPerformer(configStore *ConfigStore, cruds map[string]*DbResource) (ActionPerformerInterface, error)

+ func NewMakeResponsePerformer() (ActionPerformerInterface, error)

+ type GenerateOauth2TokenActionPerformer struct

+ func (d *GenerateOauth2TokenActionPerformer) DoAction(request ActionRequest, inFieldMap map[string]interface{}) (api2go.Responder, []ActionResponse, []error)

+ func (d *GenerateOauth2TokenActionPerformer) Name() string

+ type MakeResponsePerformer struct

+ func (d *MakeResponsePerformer) DoAction(request ActionRequest, inFieldMap map[string]interface{}) (api2go.Responder, []ActionResponse, []error)

+ func (d *MakeResponsePerformer) Name() string

v0.6.9

Jun 9, 2018

Changes in this version

+ const DATE_LAYOUT

+ var StandardTasks = []Task

+ var ValidatorInstance *validator.Validate = validator.New()

+ func RegisterTranslations()

+ func UpdateTasksData(initConfig *CmsConfig, db database.DatabaseConnection) error

type ActionPerformerInterface

+ func NewExportCsvDataPerformer(initConfig *CmsConfig, cruds map[string]*DbResource) (ActionPerformerInterface, error)

+ func NewSyncSiteStorageActionPerformer(cruds map[string]*DbResource) (ActionPerformerInterface, error)

type ActionRequest

+ func BuildActionRequest(closer io.ReadCloser, actionType, actionName string, params gin.Params) (*ActionRequest, error)

+ type ActiveTaskInstance struct

+ ActionRequest ActionRequest

+ DbResource *DbResource

+ Task Task

+ func (ati *ActiveTaskInstance) Run()

type AggregationRequest

+ Query []Query

type CmsConfig

+ Tasks []Task

type ColumnType

+ GraphqlType *graphql.Scalar

type ColumnTypeManager

+ func (ctm *ColumnTypeManager) GetGraphqlType(columnType string) *graphql.Scalar

+ type CronjobExecutor interface

+ Execute func(attributes map[string]interface{}) error

type DaptinError

+ func (de *DaptinError) Error() string

type DbResource

+ ActionHandlerMap map[string]ActionPerformerInterface

+ func (db *DbResource) HandleActionRequest(actionRequest *ActionRequest, req api2go.Request) ([]ActionResponse, error)

+ func (db *DbResource) NewActiveTaskInstance(task Task) *ActiveTaskInstance

+ func (dr *DbResource) GetAdminEmailId() string

+ func (dr *DbResource) GetAdminReferenceId() string

+ func (dr *DbResource) GetObjectByWhereClause(typeName string, column string, val string) (map[string]interface{}, error)

+ func (dr *DbResource) GetUserEmailIdByUsergroupId(usergroupId int64) string

+ func (dr *DbResource) GetUserIdByUsergroupId(usergroupId int64) string

+ func (res *DbResource) SyncStorageToPath(cloudStore CloudStore, tempDirectoryPath string) error

+ func (resource *DbResource) GetAllTasks() ([]Task, error)

+ func (resource *DbResource) GetCloudStoreByReferenceId(referenceID string) (CloudStore, error)

+ type DefaultTaskScheduler struct

+ func (dts *DefaultTaskScheduler) AddTask(task Task) error

+ func (dts *DefaultTaskScheduler) StartTasks()

+ type ExportCsvDataPerformer struct

+ func (d *ExportCsvDataPerformer) DoAction(request ActionRequest, inFields map[string]interface{}) (api2go.Responder, []ActionResponse, []error)

+ func (d *ExportCsvDataPerformer) Name() string

type Marketplace

+ Name string

+ type SyncSiteStorageActionPerformer struct

+ func (d *SyncSiteStorageActionPerformer) DoAction(request ActionRequest, inFields map[string]interface{}) (api2go.Responder, []ActionResponse, []error)

+ func (d *SyncSiteStorageActionPerformer) Name() string

+ type Task struct

+ ActionName string

+ Active bool

+ AsUserEmail string

+ Attributes map[string]interface{}

+ AttributesJson string

+ EntityName string

+ Id int64

+ Name string

+ ReferenceId string

+ Schedule string

+ func GetTasks(connection database.DatabaseConnection) ([]Task, error)

+ type TaskScheduler interface

+ AddTask func(task Task) error

+ StartTasks func()

+ func NewTaskScheduler(cmsConfig *CmsConfig, cruds map[string]*DbResource, configStore *ConfigStore) TaskScheduler

v0.6.8

Mar 24, 2018

Changes in this version

+ func InArray(val []string, ar string) (exists bool)

type AggregationRequest

+ Order []string

type ConfigStore

+ func (c *ConfigStore) GetConfigIntValueFor(key string, configtype string) (int, error)

+ func (c *ConfigStore) SetConfigIntValueFor(key string, val int, configtype string) error

+ type Group struct

+ ColumnName string

+ Order string

+ type Query struct

+ ColumnName string

+ Operator string

+ Value string

v0.6.7

Feb 24, 2018

v0.6.6

Feb 21, 2018

Changes in this version

type ActionPerformerInterface

+ func NewUploadCsvFileToEntityPerformer(initConfig *CmsConfig, cruds map[string]*DbResource) (ActionPerformerInterface, error)

type TableInfo

+ func (ti *TableInfo) GetColumnByName(name string) (*api2go.ColumnInfo, bool)

+ type UploadCsvFileToEntityPerformer struct

+ func (d *UploadCsvFileToEntityPerformer) DoAction(request ActionRequest, inFields map[string]interface{}) (api2go.Responder, []ActionResponse, []error)

+ func (d *UploadCsvFileToEntityPerformer) Name() string

+ type UploadXlsFileToEntityPerformer struct

+ func (d *UploadXlsFileToEntityPerformer) DoAction(request ActionRequest, inFields map[string]interface{}) (api2go.Responder, []ActionResponse, []error)

+ func (d *UploadXlsFileToEntityPerformer) Name() string

v0.6.5

Feb 15, 2018

Changes in this version

type DbResource

+ func (d *DbResource) GetUserPassword(email string) (string, error)

+ func (dbResource *DbResource) UserGroupNameToId(groupName string) (uint64, error)

+ func (dr *DbResource) CreateWithoutFilter(obj interface{}, req api2go.Request) (map[string]interface{}, error)

+ func (dr *DbResource) DeleteWithoutFilters(id string, req api2go.Request) error

+ func (dr *DbResource) PaginatedFindAllWithoutFilters(req api2go.Request) ([]map[string]interface{}, [][]map[string]interface{}, *PaginationData, error)

+ func (dr *DbResource) StoreToken(token *oauth2.Token, token_type string, oauth_connect_reference_id string) error

+ func (dr *DbResource) UpdateWithoutFilters(obj interface{}, req api2go.Request) (map[string]interface{}, error)

+ func (resource *DbResource) GetTokenByTokenName(name string) (*oauth2.Token, error)

type Outcome

+ Condition string

+ SkipInResponse bool

+ type PaginationData struct

+ PageNumber uint64

+ PageSize uint64

+ TotalCount uint64

type SubSite

+ Id *int64

+ type TokenResponse struct

+ Scope string

v0.6.4

Jan 28, 2018

Changes in this version

+ func GroupNamesToIds(db *sqlx.DB, groupsName []string) []int64

type SubSite

+ ReferenceId string

type TableInfo

+ DefaultGroups []string

v0.6.3

Jan 15, 2018

Changes in this version

+ var StandardData = []api2go.Api2GoModel

+ func UpdateStandardData(initConfig *CmsConfig, db *sqlx.DB)

v0.6.2

Dec 30, 2017

Changes in this version

+ func BeginsWith(longerString string, smallerString string) bool

+ func CheckInfo(err error, message ...interface{})

+ func ImportDataMapArray(data []map[string]interface{}, entityName string, crud *DbResource, ...) []error

+ func ImportDataStringArray(data [][]string, headers []string, entityName string, crud *DbResource, ...) []error

+ type AggregateData struct

+ Data []map[string]interface{}

+ type AggregationRequest struct

+ Filter []string

+ GroupBy []string

+ Join []string

+ ProjectColumn []string

+ RootEntity string

+ TimeFrom string

+ TimeSample TimeStamp

+ TimeTo string

type CmsConfig

+ ActionPerformers []ActionPerformerInterface

type DbResource

+ func (dr *DbResource) DataStats(req AggregationRequest) (AggregateData, error)

+ func (resource *DbResource) GetCloudStoreByName(name string) (CloudStore, error)

+ func (resource *DbResource) GetFileFromCloudStore(data api2go.ForeignKeyData, filesList []map[string]interface{}) (resp []map[string]interface{}, err error)

type TableInfo

+ Icon string

+ type TimeStamp string

v0.6.1

Dec 18, 2017

v0.6.0

Dec 18, 2017

Changes in this version

+ func GetTokensScope(tokUrl string, scope string, clientId string, secret string) (string, error)

type ActionPerformerInterface

+ func NewNetworkRequestPerformer(initConfig *CmsConfig, cruds map[string]*DbResource) (ActionPerformerInterface, error)

+ func NewOuathProfileExchangePerformer(initConfig *CmsConfig, cruds map[string]*DbResource) (ActionPerformerInterface, error)

type DbResource

+ func (dr *DbResource) GetTotalCountBySelectBuilder(builder squirrel.SelectBuilder) uint64

+ type NetworkRequestActionPerformer struct

+ func (d *NetworkRequestActionPerformer) DoAction(request ActionRequest, inFieldMap map[string]interface{}) (api2go.Responder, []ActionResponse, []error)

+ func (d *NetworkRequestActionPerformer) Name() string

+ type OuathProfileExchangePerformer struct

+ func (d *OuathProfileExchangePerformer) DoAction(request ActionRequest, inFieldMap map[string]interface{}) (api2go.Responder, []ActionResponse, []error)

+ func (d *OuathProfileExchangePerformer) Name() string

type TableInfo

+ DefaultOrder string

v0.5.7

Oct 12, 2017

Changes in this version

+ var ErrUnauthorized = errors.New("Unauthorized")

+ func PrintRelations(relations []api2go.TableRelation)

+ func PrintTableInfo(info *TableInfo)

type CmsConfig

+ func (ti *CmsConfig) AddRelations(relations ...api2go.TableRelation)

+ type DaptinError struct

+ Code string

+ Message string

+ func NewDaptinError(str string, code string) DaptinError

+ type PermissionInstance struct

+ Permission auth.ObjectPermission

+ UserGroupId []auth.GroupPermission

+ UserId string

+ func (p PermissionInstance) CanCreate(userId string, usergroupId []auth.GroupPermission) bool

+ func (p PermissionInstance) CanDelete(userId string, usergroupId []auth.GroupPermission) bool

+ func (p PermissionInstance) CanExecute(userId string, usergroupId []auth.GroupPermission) bool

+ func (p PermissionInstance) CanPeek(userId string, usergroupId []auth.GroupPermission) bool

+ func (p PermissionInstance) CanRead(userId string, usergroupId []auth.GroupPermission) bool

+ func (p PermissionInstance) CanRefer(userId string, usergroupId []auth.GroupPermission) bool

+ func (p PermissionInstance) CanUpdate(userId string, usergroupId []auth.GroupPermission) bool

+ func (p1 PermissionInstance) CheckBit(userId string, usergroupId []auth.GroupPermission, bit auth.AuthPermission) bool

type TableInfo

+ func (ti *TableInfo) AddRelation(relations ...api2go.TableRelation)

v0.4.2

Sep 28, 2017

v0.4.1

Sep 28, 2017

v0.4.0

Sep 28, 2017

Changes in this version

+ var StandardMarketplaces = []Marketplace

+ var StandardStreams = []StreamContract

+ func CopyFile(src, dst string) (err error)

+ func GetFakeRow(columns []api2go.ColumnInfo) map[string]interface

+ func UpdateMarketplaces(initConfig *CmsConfig, db *sqlx.DB)

+ func UpdateStreams(initConfig *CmsConfig, db *sqlx.DB)

type ActionPerformerInterface

+ func NewMarketplacePackageInstaller(initConfig *CmsConfig, cruds map[string]*DbResource) (ActionPerformerInterface, error)

+ func NewRandomDataGeneratePerformer(initConfig *CmsConfig, cruds map[string]*DbResource) (ActionPerformerInterface, error)

+ func NewRefreshMarketplacePackagelistPerformer(initConfig *CmsConfig, cruds map[string]*DbResource) (ActionPerformerInterface, error)

type CmsConfig

+ MarketplaceHandlers map[string]*MarketplaceService

+ Marketplaces []Marketplace

+ Streams []StreamContract

type ColumnType

+ DataTypes []string

+ ReclineType string

type DbResource

+ func (resource *DbResource) GetAllMarketplaces() ([]Marketplace, error)

+ func (resource *DbResource) GetMarketplaceByReferenceId(referenceId string) (Marketplace, error)

+ type MarketPackage struct

+ Location string

+ Name string

+ Summary string

+ type Marketplace struct

+ Endpoint string

+ Permission int

+ ReferenceId string

+ RootPath string

+ UserId *int

+ type MarketplacePackageInstallActionPerformer struct

+ func (d *MarketplacePackageInstallActionPerformer) DoAction(request ActionRequest, inFieldMap map[string]interface{}) ([]ActionResponse, []error)

+ func (d *MarketplacePackageInstallActionPerformer) Name() string

+ type MarketplaceService struct

+ Marketplace Marketplace

+ func NewMarketplaceService(marketplace Marketplace) (*MarketplaceService, error)

+ func (mp *MarketplaceService) GetPackage(packageName string) *MarketPackage

+ func (mp *MarketplaceService) GetPackageList() ([]MarketPackage, error)

+ func (mp *MarketplaceService) PackageExists(packageName string) bool

+ func (mp *MarketplaceService) RefreshRepository() error

+ type RandomDataGeneratePerformer struct

+ func (d *RandomDataGeneratePerformer) DoAction(request ActionRequest, inFields map[string]interface{}) ([]ActionResponse, []error)

+ func (d *RandomDataGeneratePerformer) Name() string

+ type RefreshMarketplacePackagelistPerformer struct

+ func (d *RefreshMarketplacePackagelistPerformer) DoAction(request ActionRequest, inFieldMap map[string]interface{}) ([]ActionResponse, []error)

+ func (d *RefreshMarketplacePackagelistPerformer) Name() string

+ type StreamContract struct

+ Columns []api2go.ColumnInfo

+ QueryParams map[string][]string

+ Relations []api2go.TableRelation

+ RootEntityName string

+ StreamName string

+ Transformations []Transformation

+ type StreamProcessor struct

+ func NewStreamProcessor(stream StreamContract, cruds map[string]*DbResource) *StreamProcessor

+ func (dr *StreamProcessor) Create(obj interface{}, req api2go.Request) (api2go.Responder, error)

+ func (dr *StreamProcessor) Delete(id string, req api2go.Request) (api2go.Responder, error)

+ func (dr *StreamProcessor) FindOne(ID string, req api2go.Request) (api2go.Responder, error)

+ func (dr *StreamProcessor) GetContract() StreamContract

+ func (dr *StreamProcessor) PaginatedFindAll(req api2go.Request) (totalCount uint, response api2go.Responder, err error)

+ func (dr *StreamProcessor) Update(obj interface{}, req api2go.Request) (api2go.Responder, error)

+ type Transformation struct

+ Attributes map[string]interface{}

+ Operation string

v0.3.2

Sep 5, 2017

v0.3.1

Sep 5, 2017

v0.3.0

Sep 5, 2017

v0.2.1

Sep 5, 2017

Changes in this version

+ var EntityTypeToColumnTypeMap = map[fieldtypes.EntityType]string

+ var EntityTypeToDataTypeMap = map[fieldtypes.EntityType]string

+ var ReservedWords = []string

+ func CheckAuditTables(config *CmsConfig, db *sqlx.DB)

+ func EndsWithCheck(str string, endsWith string) bool

+ func GetDataArray(sheet *xlsx.Sheet) (dataMap []map[string]interface{}, columnNames []string, err error)

+ func ImportDataFiles(initConfig *CmsConfig, db *sqlx.DB, cruds map[string]*DbResource)

+ func InfoErr(err error, message string)

+ func InitialiseColumnManager()

+ func IsReservedWord(w string) bool

+ func SmallSnakeCaseText(str string) string

type Action

+ Conformations []ColumnTag

+ Validations []ColumnTag

type ActionPerformerInterface

+ func NewExportDataPerformer(initConfig *CmsConfig, cruds map[string]*DbResource) (ActionPerformerInterface, error)

+ func NewFileUploadActionPerformer(initConfig *CmsConfig, cruds map[string]*DbResource) (ActionPerformerInterface, error)

+ func NewImportDataPerformer(initConfig *CmsConfig, cruds map[string]*DbResource) (ActionPerformerInterface, error)

+ func NewUploadFileToEntityPerformer(initConfig *CmsConfig, cruds map[string]*DbResource) (ActionPerformerInterface, error)

type ActionRow

+ ActionSchema string

+ type CloudStore struct

+ CreatedAt *time.Time

+ DeletedAt *time.Time

+ Id int64

+ Name string

+ OAutoTokenId string

+ Permission int

+ ReferenceId string

+ RootPath string

+ StoreParameters map[string]interface{}

+ StoreProvider string

+ StoreType string

+ UpdatedAt *time.Time

+ UserId string

+ Version int

type CmsConfig

+ Hostname string

+ Imports []DataFileImport

+ SubSites map[string]SubSiteInformation

+ Validator *validator.Validate

+ type ColumnTag struct

+ ColumnName string

+ Tags string

+ type ColumnType struct

+ BlueprintType string

+ Conformations []string

+ Name string

+ Validations []string

+ func (ct ColumnType) Fake() interface{}

+ type ColumnTypeManager struct

+ ColumnMap map[string]ColumnType

+ var ColumnManager *ColumnTypeManager

+ func (ctm *ColumnTypeManager) GetBlueprintType(colName string) string

+ func (ctm *ColumnTypeManager) GetFakedata(colTypeName string) string

+ func (ctm *ColumnTypeManager) IsValidValue(val string, colType string, validator *validator2.Validate) error

+ type DataFileImport struct

+ Entity string

+ FilePath string

+ FileType string

+ func (s DataFileImport) String() string

+ type DataValidationMiddleware struct

+ func (dvm *DataValidationMiddleware) InterceptAfter(dr *DbResource, req *api2go.Request, results []map[string]interface{}) ([]map[string]interface{}, error)

+ func (dvm *DataValidationMiddleware) InterceptBefore(dr *DbResource, req *api2go.Request, objects []map[string]interface{}) ([]map[string]interface{}, error)

+ func (dvm DataValidationMiddleware) String() string

type DatabaseRequestInterceptor

+ func NewDataValidationMiddleware(cmsConfig *CmsConfig, cruds *map[string]*DbResource) DatabaseRequestInterceptor

type DbResource

+ func (dr *DbResource) DirectInsert(typeName string, data map[string]interface{}) error

+ func (dr *DbResource) GetAllObjects(typeName string) ([]map[string]interface{}, error)

+ func (dr *DbResource) GetAllRawObjects(typeName string) ([]map[string]interface{}, error)

+ func (dr *DbResource) ResultToArrayOfMapRaw(rows *sqlx.Rows, columnMap map[string]api2go.ColumnInfo) ([]map[string]interface{}, error)

+ func (dr *DbResource) TruncateTable(typeName string) error

+ func (resource *DbResource) GetAllCloudStores() ([]CloudStore, error)

+ func (resource *DbResource) GetAllSites() ([]SubSite, error)

+ func (resource *DbResource) GetOauthDescriptionByTokenReferenceId(referenceId string) (*oauth2.Config, error)

+ func (resource *DbResource) GetTokenByTokenId(id int64) (*oauth2.Token, error)

+ func (resource *DbResource) GetTokenByTokenReferenceId(referenceId string) (*oauth2.Token, error)

+ func (resource *DbResource) UpdateAccessTokenByTokenId(id int64, accessToken string, expiresIn int64) error

+ func (resource *DbResource) UpdateAccessTokenByTokenReferenceId(referenceId string, accessToken string, expiresIn int64) error

+ type ExportDataPerformer struct

+ func (d *ExportDataPerformer) DoAction(request ActionRequest, inFields map[string]interface{}) ([]ActionResponse, []error)

+ func (d *ExportDataPerformer) Name() string

+ type Faker interface

+ Fake func() string

+ type FileUploadActionPerformer struct

+ func (d *FileUploadActionPerformer) DoAction(request ActionRequest, inFields map[string]interface{}) ([]ActionResponse, []error)

+ func (d *FileUploadActionPerformer) Name() string

+ type GomsError struct

+ Code string

+ Message string

+ func NewGomsError(str string, code string) GomsError

+ type ImportDataPerformer struct

+ func (d *ImportDataPerformer) DoAction(request ActionRequest, inFields map[string]interface{}) ([]ActionResponse, []error)

+ func (d *ImportDataPerformer) Name() string

+ type ObjectAccessPermissionChecker struct

+ func (pc *ObjectAccessPermissionChecker) InterceptAfter(dr *DbResource, req *api2go.Request, results []map[string]interface{}) ([]map[string]interface{}, error)

+ func (pc *ObjectAccessPermissionChecker) InterceptBefore(dr *DbResource, req *api2go.Request, results []map[string]interface{}) ([]map[string]interface{}, error)

+ func (pc *ObjectAccessPermissionChecker) String() string

+ type ObjectModificationAuditMiddleware struct

+ func (omam *ObjectModificationAuditMiddleware) InterceptAfter(dr *DbResource, req *api2go.Request, results []map[string]interface{}) ([]map[string]interface{}, error)

+ func (omam *ObjectModificationAuditMiddleware) InterceptBefore(dr *DbResource, req *api2go.Request, results []map[string]interface{}) ([]map[string]interface{}, error)

+ func (omam *ObjectModificationAuditMiddleware) String() string

type StateMachineEvent

+ func NewStateMachineEvent(machineId string, eventName string) StateMachineEvent

+ type SubSite struct

+ CloudStoreId int64

+ Hostname string

+ Name string

+ Path string

+ Permission int

+ UserId int64

+ type SubSiteInformation struct

+ CloudStore CloudStore

+ SourceRoot string

+ SubSite SubSite

type TableInfo

+ Conformations []ColumnTag

+ IsAuditEnabled bool

+ Validations []ColumnTag

+ type UploadFileToEntityPerformer struct

+ func (d *UploadFileToEntityPerformer) DoAction(request ActionRequest, inFields map[string]interface{}) ([]ActionResponse, []error)

+ func (d *UploadFileToEntityPerformer) Name() string

v0.2.0

Jul 4, 2017

Changes in this version

type Action

+ InstanceOptional bool

type ActionRow

+ InstanceOptional bool

v0.1.20

Jun 29, 2017

v0.1.11

Jul 1, 2017

v0.1.10

Jul 1, 2017

v0.1.8

Jul 1, 2017

v0.1.7

Jul 1, 2017

v0.1.6

Jul 1, 2017

v0.1.5

Jul 1, 2017

v0.1.4

Jul 1, 2017

v0.1.3

Jul 1, 2017

v0.1.2

Jul 1, 2017

v0.1.1

Jul 1, 2017

v0.1.0

Jun 29, 2017

Changes in this version

+ const Added

+ const ChangedType

+ const ChangedValue

+ const Removed

+ var CollectionTypes = []string

+ var ColumnTypes = []string

+ var ConfigTableStructure = TableInfo

+ var ERR_UNAUTHORIZED = errors.New("Unauthorized")

+ var StandardColumns = []api2go.ColumnInfo

+ var StandardRelations = []api2go.TableRelation

+ var StandardTables = []TableInfo

+ var SystemActions = []Action

+ var SystemExchanges = []ExchangeContract

+ var SystemSmds = []LoopbookFsmDescription

+ func BcryptCheckStringHash(newString, hash string) bool

+ func BcryptHashString(password string) (string, error)

+ func BuildOutcome(inFieldMap map[string]interface{}, outcome Outcome) (*api2go.Api2GoModel, api2go.Request, error)

+ func CheckAllTableStatus(initConfig *CmsConfig, db *sqlx.DB)

+ func CheckErr(err error, message string)

+ func CheckError(err error, msg string)

+ func CheckRelations(config *CmsConfig, db *sqlx.DB)

+ func CheckTable(tableInfo *TableInfo, db *sqlx.DB)

+ func CreateAMapOfColumnsWeWantInTheFinalTable(tableInfo *TableInfo) (map[string]bool, map[string]api2go.ColumnInfo)

+ func CreateGetActionHandler(initConfig *CmsConfig, configStore *ConfigStore, cruds map[string]*DbResource) func(*gin.Context)

+ func CreateGuestActionListHandler(initConfig *CmsConfig, cruds map[string]*DbResource) func(*gin.Context)

+ func CreateIndexes(initConfig *CmsConfig, db *sqlx.DB)

+ func CreatePostActionHandler(initConfig *CmsConfig, configStore *ConfigStore, cruds map[string]*DbResource, ...) func(*gin.Context)

+ func CreateRelations(initConfig *CmsConfig, db *sqlx.DB)

+ func CreateTable(tableInfo *TableInfo, db *sqlx.DB)

+ func CreateUniqueConstraints(initConfig *CmsConfig, db *sqlx.DB)

+ func Decrypt(key []byte, cryptoText string) (string, error)

+ func Encrypt(key []byte, text string) (string, error)

+ func GetActionMapByTypeName(db *sqlx.DB) (map[string]map[string]interface{}, error)

+ func GetAdminUserIdAndUserGroupId(db *sqlx.DB) (int64, int64)

+ func GetMD5Hash(text string) string

+ func GetOauthConnectionById(authenticatorId int64, dbResource *DbResource) (*oauth2.Config, string, error)

+ func GetOauthConnectionDescription(authenticator string, dbResource *DbResource) (*oauth2.Config, string, error)

+ func GetObjectByWhereClause(objType string, db *sqlx.DB, queries ...squirrel.Eq) ([]map[string]interface{}, error)

+ func GetValidatedInFields(actionRequest ActionRequest, action Action) (map[string]interface{}, error)

+ func GetWorldTableMapBy(col string, db *sqlx.DB) (map[string]map[string]interface{}, error)

+ func MakeCreateTableQuery(tableInfo *TableInfo, sqlDriverName string) string

+ func NewClientNotification(notificationType string, message string, title string) map[string]interface

+ func NewMapStringScan(columnNames []string) *mapStringScan

+ func NewResponse(metadata map[string]interface{}, result interface{}, statusCode int, ...) api2go.Responder

+ func ReferenceIdToIntegerId(typeName string, referenceId string, db *sqlx.DB) (int64, error)

+ func RowsToMap(rows *sqlx.Rows, typeName string) ([]map[string]interface{}, error)

+ func UpdateActionTable(initConfig *CmsConfig, db *sqlx.DB) error

+ func UpdateExchanges(initConfig *CmsConfig, db *sqlx.DB)

+ func UpdateStateMachineDescriptions(initConfig *CmsConfig, db *sqlx.DB)

+ func UpdateWorldColumnTable(initConfig *CmsConfig, db *sqlx.DB)

+ func UpdateWorldTable(initConfig *CmsConfig, db *sqlx.DB)

+ func ValueOf(x interface{}) interface

+ type Action struct

+ InFields []api2go.ColumnInfo

+ Label string

+ Name string

+ OnType string

+ OutFields []Outcome

+ ReferenceId string

+ type ActionPerformerInterface interface

+ DoAction func(request ActionRequest, inFields map[string]interface{}) ([]ActionResponse, []error)

+ Name func() string

+ func NewBecomeAdminPerformer(initConfig *CmsConfig, cruds map[string]*DbResource) (ActionPerformerInterface, error)

+ func NewDownloadCmsConfigPerformer(initConfig *CmsConfig) (ActionPerformerInterface, error)

+ func NewGenerateJwtTokenPerformer(configStore *ConfigStore, cruds map[string]*DbResource) (ActionPerformerInterface, error)

+ func NewOauthLoginBeginActionPerformer(initConfig *CmsConfig, cruds map[string]*DbResource, configStore *ConfigStore) (ActionPerformerInterface, error)

+ func NewOauthLoginResponseActionPerformer(initConfig *CmsConfig, cruds map[string]*DbResource, configStore *ConfigStore) (ActionPerformerInterface, error)

+ func NewRestarSystemPerformer(initConfig *CmsConfig) (ActionPerformerInterface, error)

+ type ActionRequest struct

+ Action string

+ Attributes map[string]interface{}

+ Type string

+ type ActionResponse struct

+ Attributes interface{}

+ ResponseType string

+ func NewActionResponse(responseType string, attrs interface{}) ActionResponse

+ type ActionRow struct

+ InFields string

+ Label string

+ Name string

+ OnType string

+ OutFields string

+ ReferenceId string

+ type AuthBossUser struct

+ AttemptNumber int64

+ AttemptTime time.Time

+ ConfirmToken string

+ Confirmed bool

+ Email string

+ ID int

+ Locked time.Time

+ Name string

+ Oauth2Expiry time.Time

+ Oauth2Provider string

+ Oauth2Refresh string

+ Oauth2Token string

+ Oauth2Uid string

+ Password string

+ RecoverToken string

+ RecoverTokenExpiry time.Time

+ type BecomeAdminActionPerformer struct

+ func (d *BecomeAdminActionPerformer) DoAction(request ActionRequest, inFieldMap map[string]interface{}) ([]ActionResponse, []error)

+ func (d *BecomeAdminActionPerformer) Name() string

+ type Change struct

+ ChangeType changeType

+ NewValue interface{}

+ OldValue interface{}

+ func Diff(a, b interface{}) (desc []Change)

+ func Fdiff(a, b interface{}) []Change

+ type CmsConfig struct

+ Actions []Action

+ ExchangeContracts []ExchangeContract

+ Relations []api2go.TableRelation

+ StateMachineDescriptions []LoopbookFsmDescription

+ Tables []TableInfo

+ type ColumnMap struct

+ SourceColumn string

+ SourceColumnType string

+ TargetColumn string

+ TargetColumnType string

+ type ColumnMapping []ColumnMap

+ func (c *ColumnMapping) UnmarshalJSON(payload []byte) error

+ type Config struct

+ ConfigEnv string

+ ConfigState string

+ ConfigType string

+ Name string

+ PreviousValue string

+ UpdatedAt time.Time

+ Value string

+ ValueType string

+ type ConfigStore struct

+ func NewConfigStore(db *sqlx.DB) (*ConfigStore, error)

+ func (c *ConfigStore) GetConfigValueFor(key string, configtype string) (string, error)

+ func (c *ConfigStore) GetWebConfig() map[string]string

+ func (c *ConfigStore) SetConfigValueFor(key string, val string, configtype string) error

+ func (c *ConfigStore) SetDefaultEnv(env string)

+ type DatabaseRequestInterceptor interface

+ InterceptAfter func(*DbResource, *api2go.Request, []map[string]interface{}) ([]map[string]interface{}, error)

+ InterceptBefore func(*DbResource, *api2go.Request) (api2go.Responder, error)

+ func NewCreateEventHandler() DatabaseRequestInterceptor

+ func NewDeleteEventHandler() DatabaseRequestInterceptor

+ func NewExchangeMiddleware(cmsConfig *CmsConfig, cruds *map[string]*DbResource) DatabaseRequestInterceptor

+ func NewFindOneEventHandler() DatabaseRequestInterceptor

+ func NewUpdateEventHandler() DatabaseRequestInterceptor

+ type DbResource struct

+ func NewDbResource(model *api2go.Api2GoModel, db *sqlx.DB, ms *MiddlewareSet, ...) *DbResource

+ func (dbResource *DbResource) BecomeAdmin(userId int64) bool

+ func (dbResource *DbResource) CanBecomeAdmin() bool

+ func (dr *DbResource) Create(obj interface{}, req api2go.Request) (api2go.Responder, error)

+ func (dr *DbResource) Delete(id string, req api2go.Request) (api2go.Responder, error)

+ func (dr *DbResource) FindOne(referenceId string, req api2go.Request) (api2go.Responder, error)

+ func (dr *DbResource) GetActionByName(typeName string, actionName string) (Action, error)

+ func (dr *DbResource) GetActionPermissionByName(worldId int64, actionName string) (Permission, error)

+ func (dr *DbResource) GetActionsByType(typeName string) ([]Action, error)

+ func (dr *DbResource) GetContext(key string) interface{}

+ func (dr *DbResource) GetIdByWhereClause(typeName string, queries ...squirrel.Eq) ([]int64, error)

+ func (dr *DbResource) GetIdToObject(typeName string, id int64) (map[string]interface{}, error)

+ func (dr *DbResource) GetIdToReferenceId(typeName string, id int64) (string, error)

+ func (dr *DbResource) GetObjectGroupsByObjectId(objType string, objectId int64) []auth.GroupPermission

+ func (dr *DbResource) GetObjectPermission(objectType string, referenceId string) Permission

+ func (dr *DbResource) GetObjectPermissionByWhereClause(objectType string, colName string, colValue string) Permission

+ func (dr *DbResource) GetObjectUserGroupsByWhere(objType string, colName string, colvalue string) []auth.GroupPermission

+ func (dr *DbResource) GetReferenceIdByWhereClause(typeName string, queries ...squirrel.Eq) ([]string, error)

+ func (dr *DbResource) GetReferenceIdToId(typeName string, referenceId string) (uint64, error)

+ func (dr *DbResource) GetReferenceIdToObject(typeName string, referenceId string) (map[string]interface{}, error)

+ func (dr *DbResource) GetRowPermission(row map[string]interface{}) Permission

+ func (dr *DbResource) GetRowsByWhereClause(typeName string, where squirrel.Eq) ([]map[string]interface{}, [][]map[string]interface{}, error)

+ func (dr *DbResource) GetSingleColumnValueByReferenceId(typeName string, selectColumn, matchColumn string, values []string) ([]interface{}, error)

+ func (dr *DbResource) GetSingleRowByReferenceId(typeName string, referenceId string) (map[string]interface{}, []map[string]interface{}, error)

+ func (dr *DbResource) GetTotalCount() uint64

+ func (dr *DbResource) GetUserGroupIdByUserId(userId uint64) uint64

+ func (dr *DbResource) IsUserActionAllowed(userReferenceId string, userGroups []auth.GroupPermission, typeName string, ...) bool

+ func (dr *DbResource) PaginatedFindAll(req api2go.Request) (totalCount uint, response api2go.Responder, err error)

+ func (dr *DbResource) PutContext(key string, val interface{})

+ func (dr *DbResource) ResultToArrayOfMap(rows *sqlx.Rows, columnMap map[string]api2go.ColumnInfo, includeNextLevel bool) ([]map[string]interface{}, [][]map[string]interface{}, error)

+ func (dr *DbResource) Update(obj interface{}, req api2go.Request) (api2go.Responder, error)

+ func (resource *DbResource) GetOauthDescriptionByTokenId(id *int64) (*oauth2.Config, error)

+ func (resource *DbResource) GetTokenForExchangeByTokenId(id *int64) (*oauth2.Token, error)

+ func (resource *DbResource) UpdateAccessToken(id *int64, accessToken string, expiresIn int64) error

+ type DownloadCmsConfigActionPerformer struct

+ func (d *DownloadCmsConfigActionPerformer) DoAction(request ActionRequest, inFields map[string]interface{}) ([]ActionResponse, []error)

+ func (d *DownloadCmsConfigActionPerformer) Name() string

+ type ExchangeContract struct

+ Attributes []ColumnMap

+ Name string

+ OauthTokenId *int64

+ Options map[string]interface{}

+ ReferenceId string

+ SourceAttributes map[string]interface{}

+ SourceType string

+ TargetAttributes map[string]interface{}

+ TargetType string

+ type ExchangeExecution struct

+ ExchangeContract ExchangeContract

+ func NewExchangeExecution(exchange ExchangeContract, oauthToken *oauth2.Token, ...) *ExchangeExecution

+ func (ec *ExchangeExecution) Execute(inFields map[string]interface{}, data []map[string]interface{}) (err error)

+ type ExchangeInterface interface

+ Update func(target string, data []map[string]interface{}) error

+ type ExchangeMiddleware struct

+ func (em *ExchangeMiddleware) InterceptAfter(dr *DbResource, req *api2go.Request, results []map[string]interface{}) ([]map[string]interface{}, error)

+ func (em *ExchangeMiddleware) InterceptBefore(dr *DbResource, req *api2go.Request) (api2go.Responder, error)

+ func (em *ExchangeMiddleware) String() string

+ type ExternalExchange interface

+ ExecuteTarget func(row map[string]interface{}, inFieldMap map[string]interface{}) error

+ func NewRestExchangeHandler(exchangeContext ExchangeContract, oauthToken *oauth2.Token, ...) (ExternalExchange, error)

+ type FsmManager interface

+ ApplyEvent func(subject map[string]interface{}, stateMachineEvent StateMachineEvent) (string, error)

+ func NewFsmManager(db *sqlx.DB, cruds map[string]*DbResource) FsmManager

+ type GenerateJwtTokenActionPerformer struct

+ func (d *GenerateJwtTokenActionPerformer) DoAction(request ActionRequest, inFieldMap map[string]interface{}) ([]ActionResponse, []error)

+ func (d *GenerateJwtTokenActionPerformer) Name() string

+ type LoopbackEventDesc struct

+ Color string

+ Dst string

+ Label string

+ Name string

+ Src []string

+ type LoopbookFsmDescription struct

+ Events []LoopbackEventDesc

+ InitialState string

+ Label string

+ Name string

+ type MemStorer struct

+ Tokens map[string][]string

+ Users map[string]AuthBossUser

+ func NewMemStorer(userCrud *DbResource) *MemStorer

+ func (s MemStorer) AddToken(key, token string) error

+ func (s MemStorer) ConfirmUser(tok string) (result interface{}, err error)

+ func (s MemStorer) Create(key string, attr authboss.Attributes) error

+ func (s MemStorer) DelTokens(key string) error

+ func (s MemStorer) Get(key string) (result interface{}, err error)

+ func (s MemStorer) GetOAuth(uid, provider string) (result interface{}, err error)

+ func (s MemStorer) Put(key string, attr authboss.Attributes) error

+ func (s MemStorer) PutOAuth(uid, provider string, attr authboss.Attributes) error

+ func (s MemStorer) RecoverUser(rec string) (result interface{}, err error)

+ func (s MemStorer) UseToken(givenKey, token string) error

+ type MiddlewareSet struct

+ AfterCreate []DatabaseRequestInterceptor

+ AfterDelete []DatabaseRequestInterceptor

+ AfterFindAll []DatabaseRequestInterceptor

+ AfterFindOne []DatabaseRequestInterceptor

+ AfterUpdate []DatabaseRequestInterceptor

+ BeforeCreate []DatabaseRequestInterceptor

+ BeforeDelete []DatabaseRequestInterceptor

+ BeforeFindAll []DatabaseRequestInterceptor

+ BeforeFindOne []DatabaseRequestInterceptor

+ BeforeUpdate []DatabaseRequestInterceptor

+ type OauthLoginBeginActionPerformer struct

+ func (d *OauthLoginBeginActionPerformer) DoAction(request ActionRequest, inFieldMap map[string]interface{}) ([]ActionResponse, []error)

+ func (d *OauthLoginBeginActionPerformer) Name() string

+ type OauthLoginResponseActionPerformer struct

+ func (d *OauthLoginResponseActionPerformer) DoAction(request ActionRequest, inFieldMap map[string]interface{}) ([]ActionResponse, []error)

+ func (d *OauthLoginResponseActionPerformer) Name() string

+ type Outcome struct

+ Attributes map[string]interface{}

+ Method string

+ Reference string

+ Type string

+ type Permission struct

+ Permission int64

+ UserGroupId []auth.GroupPermission

+ UserId string

+ func (p Permission) CanExecute(userId string, usergroupId []auth.GroupPermission) bool

+ func (p Permission) CanRead(userId string, usergroupId []auth.GroupPermission) bool

+ func (p Permission) CanWrite(userId string, usergroupId []auth.GroupPermission) bool

+ func (p1 Permission) CheckBit(userId string, usergroupId []auth.GroupPermission, bit int64) bool

+ type RestExchange struct

+ Body map[string]interface{}

+ Headers map[string]interface{}

+ Method string

+ Name string

+ QueryParams map[string]interface{}

+ Url string

+ type RestExternalExchange struct

+ func (g *RestExternalExchange) ExecuteTarget(row map[string]interface{}, inFieldMap map[string]interface{}) error

+ type RestartSystemActionPerformer struct

+ func (d *RestartSystemActionPerformer) DoAction(request ActionRequest, inFields map[string]interface{}) ([]ActionResponse, []error)

+ func (d *RestartSystemActionPerformer) Name() string

+ type StateMachineEvent interface

+ GetEventName func() string

+ GetStateMachineInstanceId func() string

+ type StateMachineInstance struct

+ CurrestState string

+ ObjectId int64

+ StateMachineId int64

+ type StatusResponse struct

+ Message string

+ type TableAccessPermissionChecker struct

+ func (pc *TableAccessPermissionChecker) InterceptAfter(dr *DbResource, req *api2go.Request, results []map[string]interface{}) ([]map[string]interface{}, error)

+ func (pc *TableAccessPermissionChecker) InterceptBefore(dr *DbResource, req *api2go.Request) (api2go.Responder, error)

+ func (pc *TableAccessPermissionChecker) String() string

+ type TableInfo struct

+ Columns []api2go.ColumnInfo

+ DefaultPermission int64

+ IsHidden bool

+ IsJoinTable bool

+ IsStateTrackingEnabled bool

+ IsTopLevel bool

+ Permission int64

+ Relations []api2go.TableRelation

+ StateMachines []LoopbookFsmDescription

+ TableId int

+ TableName string

+ UserId uint64

+ type User struct

+ CreatedAt time.Time

+ DeletedAt *time.Time

+ Email string

+ Id uint64

+ Name string

+ Password string

+ Permission int

+ Status string

+ UpdatedAt time.Time

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL