resource

Mar 9, 2023

Changes in this version

+ func CreateNewPublicPrivateKeyPEMBytes() ([]byte, []byte, *rsa.PrivateKey, error)

type DaptinImapUser

+ func (diu *DaptinImapUser) CreateMailboxWithTransaction(name string, transaction *sqlx.Tx) error

+ func (diu *DaptinImapUser) GetMailboxWithTransaction(name string, transaction *sqlx.Tx) (backend.Mailbox, error)

Aug 6, 2022

Changes in this version

+ var OlricCache *olric.DMap

+ var OperatorMap = map[string]string

+ func BuildActionContext(outcomeAttributes interface{}, inFieldMap map[string]interface{}) (interface{}, error)

+ func BuildWhereClause(functionName string, leftVal string, rightVal interface{}) (goqu.Expression, error)

+ func ColumnToInterfaceArray(s []column) []interface

+ func GetAdminReferenceIdWithTransaction(transaction *sqlx.Tx) map[string]bool

+ func GetExistingIndexes(db *sqlx.Tx) map[string]bool

+ func GetIdToReferenceIdWithTransaction(typeName string, id int64, transaction *sqlx.Tx) (string, error)

+ func GetJoins(rel api2go.TableRelation) []join

+ func GetMD5HashString(text string) string

+ func GetObjectByWhereClauseWithTransaction(objType string, transaction *sqlx.Tx, queries ...goqu.Ex) ([]map[string]interface{}, error)

+ func GetObjectGroupsByObjectIdWithTransaction(objectType string, objectId int64, transaction *sqlx.Tx) []auth.GroupPermission

+ func GetReferenceIdByWhereClauseWithTransaction(typeName string, transaction *sqlx.Tx, queries ...goqu.Ex) ([]string, error)

+ func GetReferenceIdListToIdListWithTransaction(typeName string, referenceId []string, transaction *sqlx.Tx) (map[string]int64, error)

+ func GetReferenceIdToIdWithTransaction(typeName string, referenceId string, updateTransaction *sqlx.Tx) (int64, error)

+ func GetReverseJoins(rel api2go.TableRelation) []join

+ func GetSingleColumnValueByReferenceIdWithTransaction(typeName string, selectColumn []interface{}, matchColumn string, ...) ([]interface{}, error)

+ func GetTotalCountBySelectBuilderWithTransaction(builder *goqu.SelectDataset, transaction *sqlx.Tx) (uint64, error)

+ func GetUserMembersByGroupNameWithTransaction(groupName string, transaction *sqlx.Tx) []string

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

+ func IsAdminWithTransaction(userReferenceId string, transaction *sqlx.Tx) bool

+ func MapArrayToInterfaceArray(s []map[string]interface{}) []interface

+ func RelationNamesToIds(db database.DatabaseConnection, tableInfo TableInfo) (map[string][]int64, error)

+ func ToExpressionArray(s []string) []exp.Expression

+ func ToInterfaceArray(s []string) []interface

+ func ToOrderedExpressionArray(s []string) []exp.OrderedExpression

+ func ValuesOf(mapItem map[string]int64) []int64

type Action

+ RequestSubjectRelations []string

+ type ActionExchangeHandler struct

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

type ActionPerformerInterface

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

+ func NewMailSendActionPerformer(cruds map[string]*DbResource, mailDaemon *guerrilla.Daemon, ...) (ActionPerformerInterface, error)

+ func NewRandomValueGeneratePerformer() (ActionPerformerInterface, error)

+ type AggregateRow struct

+ Attributes map[string]interface{}

+ Id string

+ Type string

type AggregationRequest

+ Having []string

type ConfigStore

+ func (configStore *ConfigStore) GetConfigValueForWithTransaction(key string, configtype string, transaction *sqlx.Tx) (string, error)

+ func (configStore *ConfigStore) SetConfigValueForWithTransaction(key string, val interface{}, configtype string, transaction *sqlx.Tx) error

type DatabaseRequestInterceptor

+ func NewYJSHandlerMiddleware(documentProvider ydb.DocumentProvider) DatabaseRequestInterceptor

type DbResource

+ Connection database.DatabaseConnection

+ OlricDb *olric.Olric

+ func (dbResource *DbResource) CreateWithTransaction(obj interface{}, req api2go.Request, transaction *sqlx.Tx) (api2go.Responder, error)

+ func (dbResource *DbResource) DeleteWithTransaction(id string, req api2go.Request, transaction *sqlx.Tx) (api2go.Responder, error)

+ func (dbResource *DbResource) FindOneWithTransaction(referenceId string, req api2go.Request, transaction *sqlx.Tx) (api2go.Responder, error)

+ func (dbResource *DbResource) GetAllObjectsWithWhereWithTransaction(typeName string, transaction *sqlx.Tx, where ...goqu.Ex) ([]map[string]interface{}, error)

+ func (dbResource *DbResource) GetAllRawObjectsWithTransaction(typeName string, transaction *sqlx.Tx) ([]map[string]interface{}, error)

+ func (dbResource *DbResource) GetCloudStoreByNameWithTransaction(name string, transaction *sqlx.Tx) (CloudStore, error)

+ func (dbResource *DbResource) GetIdListToReferenceIdList(typeName string, ids []int64) (map[int64]string, error)

+ func (dbResource *DbResource) GetIdToObjectWithTransaction(typeName string, id int64, transaction *sqlx.Tx) (map[string]interface{}, error)

+ func (dbResource *DbResource) GetObjectByWhereClauseWithTransaction(typeName string, column string, val interface{}, transaction *sqlx.Tx) (map[string]interface{}, error)

+ func (dbResource *DbResource) GetObjectPermissionByIdWithTransaction(objectType string, id int64, transaction *sqlx.Tx) PermissionInstance

+ func (dbResource *DbResource) GetObjectPermissionByWhereClauseWithTransaction(objectType string, colName string, colValue string, transaction *sqlx.Tx) PermissionInstance

+ func (dbResource *DbResource) GetObjectUserGroupsByWhereWithTransaction(objectType string, transaction *sqlx.Tx, colName string, colValue interface{}) []auth.GroupPermission

+ func (dbResource *DbResource) GetRandomRow(typeName string, count uint) ([]map[string]interface{}, error)

+ func (dbResource *DbResource) GetReferenceIdListToIdList(typeName string, referenceId []string) (map[string]int64, error)

+ func (dbResource *DbResource) GetReferenceIdToObjectColumnWithTransaction(typeName string, referenceId string, columnToSelect string, ...) (interface{}, error)

+ func (dbResource *DbResource) GetReferenceIdToObjectWithTransaction(typeName string, referenceId string, transaction *sqlx.Tx) (map[string]interface{}, error)

+ func (dbResource *DbResource) GetRowPermissionWithTransaction(row map[string]interface{}, transaction *sqlx.Tx) PermissionInstance

+ func (dbResource *DbResource) GetRowsByWhereClauseWithTransaction(typeName string, includedRelations map[string]bool, transaction *sqlx.Tx, ...) ([]map[string]interface{}, [][]map[string]interface{}, error)

+ func (dbResource *DbResource) GetSingleRowByReferenceIdWithTransaction(typeName string, referenceId string, includedRelations map[string]bool, ...) (map[string]interface{}, []map[string]interface{}, error)

+ func (dbResource *DbResource) GetUserAccountRowByEmailWithTransaction(email string, transaction *sqlx.Tx) (map[string]interface{}, error)

+ func (dbResource *DbResource) GetUserById(userId int64) (map[string]interface{}, error)

+ func (dbResource *DbResource) GetUserMembersByGroupName(groupName string) []string

+ func (dbResource *DbResource) IsAdmin(userReferenceId string) bool

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

+ func (dbResource *DbResource) PaginatedFindAllWithTransaction(req api2go.Request, transaction *sqlx.Tx) (totalCount uint, response api2go.Responder, err error)

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

+ func (dbResource *DbResource) UpdateWithTransaction(obj interface{}, req api2go.Request, transaction *sqlx.Tx) (api2go.Responder, error)

+ func (dbResource *DbResource) UserGroupNameToIdWithTransaction(groupName string, transaction *sqlx.Tx) (uint64, error)

+ type EventMessage struct

+ EventData map[string]interface{}

+ EventType string

+ MessageSource string

+ ObjectType string

type ExchangeContract

+ AsUserId int64

+ User auth.SessionUser

type ExternalExchange

+ func NewActionExchangeHandler(exchangeContract ExchangeContract, cruds map[string]*DbResource) ExternalExchange

type Outcome

+ ContinueOnError bool

type PermissionInstance

+ func GetObjectPermissionByReferenceIdWithTransaction(objectType string, referenceId string, transaction *sqlx.Tx) PermissionInstance

type TableInfo

+ DefaultRelations map[string][]string

+ func (ti *TableInfo) GetRelationByName(name string) (*api2go.TableRelation, bool)

Aug 15, 2020

Changes in this version

+ func CreateDefaultLocalStorage(db database.DatabaseConnection, localStoragePath string) error

type ActionPerformerInterface

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

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

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

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

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

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

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

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

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

type AssetFolderCache

+ func (afc *AssetFolderCache) DeleteFileByName(fileName string) error

+ func (afc *AssetFolderCache) GetPathContents(path string) ([]map[string]interface{}, error)

+ type CloudStoreFileDeleteActionPerformer struct

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

+ func (d *CloudStoreFileDeleteActionPerformer) Name() string

+ type CloudStoreFileGetActionPerformer struct

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

+ func (d *CloudStoreFileGetActionPerformer) Name() string

+ type CloudStoreFileListActionPerformer struct

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

+ func (d *CloudStoreFileListActionPerformer) Name() string

+ type CloudStoreFolderCreateActionPerformer struct

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

+ func (d *CloudStoreFolderCreateActionPerformer) Name() string

+ type CloudStorePathMoveActionPerformer struct

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

+ func (d *CloudStorePathMoveActionPerformer) Name() string

+ type CloudStoreSiteCreateActionPerformer struct

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

+ func (d *CloudStoreSiteCreateActionPerformer) Name() string

type DbResource

+ MailSender func(e *mail.Envelope, task backends.SelectTask) (backends.Result, error)

+ type DeleteWorldPerformer struct

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

+ func (d *DeleteWorldPerformer) Name() string

+ type GeneratePasswordResetActionPerformer struct

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

+ func (d *GeneratePasswordResetActionPerformer) Name() string

+ type GeneratePasswordResetVerifyActionPerformer struct

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

+ func (d *GeneratePasswordResetVerifyActionPerformer) Name() string

type SubSite

+ SiteType string

Jul 20, 2020

Changes in this version

type ActionPerformerInterface

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

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

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

type AssetFolderCache

+ func (afc *AssetFolderCache) GetFileByName(fileName string) (*os.File, error)

type DbResource

+ func (dr *DbResource) GetReferenceIdToObjectColumn(typeName string, referenceId string, columnToSelect string) (interface{}, error)

+ type Generate2FAJwtTokenActionPerformer struct

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

+ func (d *Generate2FAJwtTokenActionPerformer) Name() string

+ type GenerateHOTPQRCodeActionPerformer struct

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

+ func (d *GenerateHOTPQRCodeActionPerformer) Name() string

+ type ImportCloudStoreFilesPerformer struct

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

+ func (d *ImportCloudStoreFilesPerformer) Name() string

type TableInfo

+ CompositeKeys [][]string

+ type TableRelation struct

+ OnDelete string

Mar 9, 2020

Changes in this version

+ const DEFAULT_LANGUAGE

+ const USER_ACCOUNT_ID_COLUMN

+ const USER_ACCOUNT_TABLE_NAME

+ func AsStringOrEmpty(i interface{}) string

+ func CheckTranslationTables(config *CmsConfig)

+ func CreateRequestBody(mode Mode, mediaType string, name string, schema *openapi3.Schema, ...) (interface{}, error)

+ func EndsWith(str string, endsWith string) (string, bool)

+ func GenerateCertPEMWithKey(hostname string, privateKey *rsa.PrivateKey) ([]byte, error)

+ func GetBodyParameterNames(mode Mode, name string, schema *openapi3.Schema) ([]string, error)

+ func GetParametersNames(s string) ([]string, error)

+ func GetPublicPrivateKeyPEMBytes() ([]byte, []byte, *rsa.PrivateKey, error)

+ func HasAnyFlag(flags []string, flagToFind []string) bool

+ func HasFlag(flags []string, flagToFind string) bool

+ func HmacCheckStringHash(userProvidedPassword, challenge, userPassword string) bool

+ func IsStandardColumn(colName string) bool

+ func ParseRsaPrivateKeyFromPemStr(privPEM string) (*rsa.PrivateKey, error)

+ type AcmeTlsCertificateGenerateActionPerformer struct

+ func (d *AcmeTlsCertificateGenerateActionPerformer) CleanUp(domain, token, keyAuth string) error

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

+ func (d *AcmeTlsCertificateGenerateActionPerformer) Name() string

+ func (d *AcmeTlsCertificateGenerateActionPerformer) Present(domain, token, keyAuth string) error

type ActionPerformerInterface

+ func NewAcmeTlsCertificateGenerateActionPerformer(cruds map[string]*DbResource, configStore *ConfigStore, hostSwitch *gin.Engine) (ActionPerformerInterface, error)

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

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

+ func NewIntegrationActionPerformer(integration Integration, initConfig *CmsConfig, cruds map[string]*DbResource, ...) (ActionPerformerInterface, error)

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

+ func NewMailServersSyncActionPerformer(cruds map[string]*DbResource, mailDaemon *guerrilla.Daemon, ...) (ActionPerformerInterface, error)

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

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

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

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

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

+ type AssetFolderCache struct

+ CloudStore CloudStore

+ Keyname string

+ LocalSyncPath string

+ func (afc *AssetFolderCache) UploadFiles(files []interface{})

+ type CertificateManager struct

+ func NewCertificateManager(cruds map[string]*DbResource, configStore *ConfigStore) (*CertificateManager, error)

+ func (cm *CertificateManager) GetTLSConfig(hostname string, createIfNotFound bool) (*tls.Config, []byte, []byte, []byte, []byte, error)

type CmsConfig

+ EnableGraphQL bool

type ColumnTypeManager

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

type ConfigStore

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

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

+ type DaptinImapBackend struct

+ func NewImapServer(cruds map[string]*DbResource) *DaptinImapBackend

+ func (be *DaptinImapBackend) Login(conn *imap.ConnInfo, username, password string) (backend.User, error)

+ func (be *DaptinImapBackend) LoginMd5(conn *imap.ConnInfo, username, challenge string, response string) (backend.User, error)

+ type DaptinImapMailBox struct

+ func (dimb *DaptinImapMailBox) Check() error

+ func (dimb *DaptinImapMailBox) CopyMessages(uid bool, seqset *imap.SeqSet, dest string) error

+ func (dimb *DaptinImapMailBox) CreateMessage(flags []string, date time.Time, body imap.Literal) error

+ func (dimb *DaptinImapMailBox) Expunge() error

+ func (dimb *DaptinImapMailBox) Info() (*imap.MailboxInfo, error)

+ func (dimb *DaptinImapMailBox) ListMessages(uid bool, seqset *imap.SeqSet, items []imap.FetchItem, ch chan<- *imap.Message) error

+ func (dimb *DaptinImapMailBox) Name() string

+ func (dimb *DaptinImapMailBox) SearchMessages(uid bool, criteria *imap.SearchCriteria) ([]uint32, error)

+ func (dimb *DaptinImapMailBox) SetSubscribed(subscribed bool) error

+ func (dimb *DaptinImapMailBox) Status(items []imap.StatusItem) (*imap.MailboxStatus, error)

+ func (dimb *DaptinImapMailBox) UpdateMessagesFlags(uid bool, seqset *imap.SeqSet, operation imap.FlagsOp, flags []string) error

+ type DaptinImapUser struct

+ func (diu *DaptinImapUser) CreateMailbox(name string) error

+ func (diu *DaptinImapUser) DeleteMailbox(name string) error

+ func (diu *DaptinImapUser) GetMailbox(name string) (backend.Mailbox, error)

+ func (diu *DaptinImapUser) ListMailboxes(subscribed bool) ([]backend.Mailbox, error)

+ func (diu *DaptinImapUser) Logout() error

+ func (diu *DaptinImapUser) RenameMailbox(existingName, newName string) error

+ func (diu *DaptinImapUser) Username() string

type DbResource

+ AssetFolderCache map[string]map[string]AssetFolderCache

+ Cruds map[string]*DbResource

+ SubsiteFolderCache map[string]AssetFolderCache

+ func NewFromDbResourceWithTransaction(resources *DbResource, tx *sqlx.Tx) *DbResource

+ func (d *DbResource) CreateMailAccountBox(mailAccountId string, sessionUser *auth.SessionUser, mailBoxName string) (map[string]interface{}, error)

+ func (d *DbResource) DeleteMailAccountBox(mailAccountId int64, mailBoxName string) error

+ func (d *DbResource) GetMailAccountBox(mailAccountId int64, mailBoxName string) (map[string]interface{}, error)

+ func (d *DbResource) GetUserAccountRowByEmail(email string) (map[string]interface{}, error)

+ func (d *DbResource) GetUserMailAccountRowByEmail(username string) (map[string]interface{}, error)

+ func (d *DbResource) RenameMailAccountBox(mailAccountId int64, oldBoxName string, newBoxName string) error

+ func (d *DbResource) SetMailBoxSubscribed(mailAccountId int64, mailBoxName string, subscribed bool) error

+ func (dr *DbResource) ExpungeMailBox(mailBoxId int64) (int64, error)

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

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

+ func (dr *DbResource) GetFirstUnseenMailSequence(mailBoxId int64) uint32

+ func (dr *DbResource) GetMailBoxMailsByOffset(mailBoxId int64, start uint32, stop uint32) ([]map[string]interface{}, error)

+ func (dr *DbResource) GetMailBoxMailsByUidSequence(mailBoxId int64, start uint32, stop uint32) ([]map[string]interface{}, error)

+ func (dr *DbResource) GetMailBoxStatus(mailAccountId int64, mailBoxId int64) (*imap.MailboxStatus, error)

+ func (dr *DbResource) GetMailboxNextUid(mailBoxId int64) (uint32, error)

+ func (dr *DbResource) GetObjectPermissionById(objectType string, id int64) PermissionInstance

+ func (dr *DbResource) GetObjectPermissionByReferenceId(objectType string, referenceId string) PermissionInstance

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

+ func (dr *DbResource) TableInfo() *TableInfo

+ func (dr *DbResource) UpdateMailFlags(mailBoxId int64, mailId int64, newFlags []string) error

+ func (resource *DbResource) GetActiveIntegrations() ([]Integration, error)

+ func (resource *DbResource) GetFileFromLocalCloudStore(tableName string, columnName string, filesList []map[string]interface{}) (resp []map[string]interface{}, err error)

type DefaultTaskScheduler

+ func (dts *DefaultTaskScheduler) StopTasks()

+ type DeleteWorldColumnPerformer struct

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

+ func (d *DeleteWorldColumnPerformer) Name() string

+ type GraphqlEnableActionPerformer struct

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

+ func (d *GraphqlEnableActionPerformer) Name() string

+ type Integration struct

+ AuthenticationSpecification string

+ AuthenticationType string

+ Enable bool

+ Name string

+ Specification string

+ SpecificationFormat string

+ SpecificationLanguage string

+ type IntegrationActionPerformer struct

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

+ func (d *IntegrationActionPerformer) Name() string

+ type IntegrationInstallationPerformer struct

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

+ func (d *IntegrationInstallationPerformer) Name() string

+ type MailServersSyncActionPerformer struct

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

+ func (d *MailServersSyncActionPerformer) Name() string

+ type Mode int

+ const ModeRequest

+ const ModeResponse

+ type MyUser struct

+ Email string

+ Registration *registration.Resource

+ func (u *MyUser) GetEmail() string

+ func (u *MyUser) GetPrivateKey() crypto.PrivateKey

+ func (u MyUser) GetRegistration() *registration.Resource

+ type OtpGenerateActionPerformer struct

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

+ func (d *OtpGenerateActionPerformer) Name() string

+ type OtpLoginVerifyActionPerformer struct

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

+ func (d *OtpLoginVerifyActionPerformer) Name() string

+ type RenameWorldColumnPerformer struct

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

+ func (d *RenameWorldColumnPerformer) Name() string

+ type SelfTlsCertificateGenerateActionPerformer struct

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

+ func (d *SelfTlsCertificateGenerateActionPerformer) Name() string

type StreamProcessor

+ func (dr *StreamProcessor) GetName() string

type SubSite

+ Enable bool

+ FtpEnabled bool

+ type SyncColumnStorageActionPerformer struct

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

+ func (d *SyncColumnStorageActionPerformer) Name() string

type TableInfo

+ TranslationsEnabled bool

type TaskScheduler

+ StopTasks func()

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

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

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

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

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

Jan 28, 2018

Changes in this version

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

type SubSite

+ ReferenceId string

type TableInfo

+ DefaultGroups []string

Jan 15, 2018

Changes in this version

+ var StandardData = []api2go.Api2GoModel

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

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

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

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)

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

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

Jul 4, 2017

Changes in this version

type Action

+ InstanceOptional bool

type ActionRow

+ InstanceOptional bool

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