postgres

func (*Driver) AddATeamMemberToProject ¶

func (d *Driver) AddATeamMemberToProject(ctx context.Context, req *models.TeamMemberAddRequest) error

AddATeamMemberToProject adds a team member to a project using SQL

func (*Driver) AddSystemUserMetaInfo ¶

func (d *Driver) AddSystemUserMetaInfo(ctx context.Context, doc *types.DefaultDocumentStructure) (*types.DefaultDocumentStructure, error)

AddSystemUserMetaInfo adds metadata to a system user using SQL

func (*Driver) AddTeamMetaInfo ¶

func (d *Driver) AddTeamMetaInfo(ctx context.Context, docs []*models.SystemUser) ([]*models.SystemUser, error)

AddTeamMetaInfo is retired; membership lives on user_projects.

func (*Driver) AddWebhookToProject ¶

func (d *Driver) AddWebhookToProject(ctx context.Context, doc *models.Webhook) (*models.Webhook, error)

AddWebhookToProject adds a webhook to a project using SQL

func (*Driver) AssignProjectToOrganization ¶

func (d *Driver) AssignProjectToOrganization(ctx context.Context, orgId, userId, projectId string) error

AssignProjectToOrganization is retired.

func (*Driver) AssignTeamToOrganization ¶

func (d *Driver) AssignTeamToOrganization(ctx context.Context, orgId, userId, teamId string) error

AssignTeamToOrganization is retired.

func (*Driver) BlacklistAToken ¶

func (d *Driver) BlacklistAToken(ctx context.Context, token map[string]interface{}) error

BlacklistAToken adds a token to the blacklist using SQL

func (*Driver) CheckProjectName ¶

func (d *Driver) CheckProjectName(ctx context.Context, name string) error

CheckProjectName checks if a project name already exists using SQL

func (*Driver) CheckProjectWithRoles ¶

func (d *Driver) CheckProjectWithRoles(ctx context.Context, userId, projectId string) (*models.ProjectWithRoles, error)

CheckProjectWithRoles checks if a user belongs to a project and returns roles/permissions using SQL

func (*Driver) CheckTeamMemberExists ¶

func (d *Driver) CheckTeamMemberExists(ctx context.Context, projectId string, memberID string) error

CheckTeamMemberExists checks if a team member exists in a project using SQL

func (*Driver) CheckTokenBlacklisted ¶

func (d *Driver) CheckTokenBlacklisted(ctx context.Context, tokenId string) error

CheckTokenBlacklisted checks if a token is blacklisted using SQL

func (*Driver) Close ¶

func (d *Driver) Close() error

func (*Driver) CountProjectUsersByRole ¶

func (d *Driver) CountProjectUsersByRole(ctx context.Context, projectID string) (map[string]int, error)

func (*Driver) CreateOrganization ¶

func (d *Driver) CreateOrganization(ctx context.Context, org *models.Organization) (*models.Organization, error)

CreateOrganization is retired; it does not persist.

func (*Driver) CreateProject ¶

func (d *Driver) CreateProject(ctx context.Context, userId string, project *models.Project) (*models.Project, error)

CreateProject creates a new project using SQL

func (*Driver) CreateSchemaOperation ¶

func (d *Driver) CreateSchemaOperation(ctx context.Context, op *models.SchemaOperation) error

func (*Driver) CreateSystemUser ¶

func (d *Driver) CreateSystemUser(ctx context.Context, user *models.SystemUser) (*models.SystemUser, error)

CreateSystemUser creates a new system user using SQL

func (*Driver) CreateTeam ¶

func (d *Driver) CreateTeam(ctx context.Context, team *models.Team) (*models.Team, error)

CreateTeam is retired; it does not persist.

func (*Driver) CreateUser ¶

func (d *Driver) CreateUser(ctx context.Context, row *models.User) (*models.User, error)

func (*Driver) DeleteModelType ¶

func (d *Driver) DeleteModelType(ctx context.Context, projectID, modelName string) error

DeleteModelType implements interfaces.ApitoSystemDB — delete one model_types row.

func (*Driver) DeleteProjectFromSystem ¶

func (d *Driver) DeleteProjectFromSystem(ctx context.Context, projectId string) error

DeleteProjectFromSystem deletes a project and all related data using SQL

func (*Driver) DeleteUser ¶

func (d *Driver) DeleteUser(ctx context.Context, projectID, userID string) error

func (*Driver) DeleteWebhook ¶

func (d *Driver) DeleteWebhook(ctx context.Context, projectId, hookId string) error

DeleteWebhook deletes a webhook using SQL

func (*Driver) EnsureBootstrapAdmin ¶

func (d *Driver) EnsureBootstrapAdmin(ctx context.Context) error

EnsureBootstrapAdmin creates the default admin user if missing (idempotent). Exported for pro layered system bootstrap (e.g. libsql starter provisioned outside OSS driver defaults).

func (*Driver) EnsureBootstrapOrgTeamProjectWithStarterCreate ¶

func (d *Driver) EnsureBootstrapOrgTeamProjectWithStarterCreate(ctx context.Context, fn bootstrapmeta.CreateStarterProjectFn) error

EnsureBootstrapOrgTeamProjectWithStarterCreate seeds the starter project only. Named Team/Organization graph is retired; grants live on user_projects.

func (*Driver) EnsureBootstrapProjectSettingsRow ¶

func (d *Driver) EnsureBootstrapProjectSettingsRow(ctx context.Context, projectID string) error

EnsureBootstrapProjectSettingsRow ensures a project_settings row exists (idempotent). Exported for pro layered bootstrap that skips open-core ensureStarterProjectDriver.

func (*Driver) EnsureSystemBootstrap ¶

func (d *Driver) EnsureSystemBootstrap(ctx context.Context) error

func (*Driver) FindOrganizationAdmin ¶

func (d *Driver) FindOrganizationAdmin(ctx context.Context, orgId string) (*models.SystemUser, error)

FindOrganizationAdmin implements interfaces.ApitoSystemDB.

func (*Driver) FindUserOrganizations ¶

func (d *Driver) FindUserOrganizations(ctx context.Context, userId string) ([]*models.Organization, error)

FindUserOrganizations is retired; named orgs are gone.

func (*Driver) FindUserProjects ¶

func (d *Driver) FindUserProjects(ctx context.Context, userId string) ([]*models.Project, error)

FindUserProjects retrieves all projects for a given user using SQL

func (*Driver) FindUserProjectsWithRoles ¶

func (d *Driver) FindUserProjectsWithRoles(ctx context.Context, userId string) ([]*models.ProjectWithRoles, error)

FindUserProjectsWithRoles implements interfaces.ApitoSystemDB.

func (*Driver) FindUserTeams ¶

func (d *Driver) FindUserTeams(ctx context.Context, userId string) ([]*models.Team, error)

FindUserTeams is retired.

func (*Driver) GetOrganizations ¶

func (d *Driver) GetOrganizations(ctx context.Context, userId string) (*models.SearchResponse[models.Organization], error)

GetOrganizations implements interfaces.ApitoSystemDB.

func (*Driver) GetProject ¶

func (d *Driver) GetProject(ctx context.Context, id string) (*models.Project, error)

GetProject retrieves a project by ID using SQL

func (*Driver) GetProjectTeams ¶

func (d *Driver) GetProjectTeams(ctx context.Context, projectId string) (*models.Team, error)

GetProjectTeams is retired.

func (*Driver) GetProjectWithRolesAndPermission ¶

func (d *Driver) GetProjectWithRolesAndPermission(ctx context.Context, userId string) ([]*models.ProjectWithRoles, error)

GetProjectWithRolesAndPermission retrieves projects with roles and permissions for a user using SQL

func (*Driver) GetProjects ¶

func (d *Driver) GetProjects(ctx context.Context, keys []string) ([]*models.Project, error)

GetProjects retrieves multiple projects by their IDs using SQL

func (*Driver) GetSQLBase ¶

func (d *Driver) GetSQLBase() *sqlcommon.Base

func (*Driver) GetSchemaOperation ¶

func (d *Driver) GetSchemaOperation(ctx context.Context, id string) (*models.SchemaOperation, error)

func (*Driver) GetSystemUser ¶

func (d *Driver) GetSystemUser(ctx context.Context, id string) (*models.SystemUser, error)

GetSystemUser retrieves a system user by ID using SQL

func (*Driver) GetSystemUserByEmail ¶

func (d *Driver) GetSystemUserByEmail(ctx context.Context, email string) (*models.SystemUser, error)

GetSystemUserByEmail retrieves a system user by email using SQL

func (*Driver) GetSystemUsers ¶

func (d *Driver) GetSystemUsers(ctx context.Context, keys []string) ([]*models.SystemUser, error)

GetSystemUsers retrieves multiple system users by their IDs using SQL

func (*Driver) GetTeams ¶

func (d *Driver) GetTeams(ctx context.Context, userId string) ([]*models.Team, error)

GetTeams implements interfaces.ApitoSystemDB.

func (*Driver) GetTeamsMembers ¶

func (d *Driver) GetTeamsMembers(ctx context.Context, projectId string) ([]*models.SystemUser, error)

GetTeamsMembers implements interfaces.ApitoSystemDB.

func (*Driver) GetUser ¶

func (d *Driver) GetUser(ctx context.Context, projectID, userID string) (*models.User, error)

func (*Driver) GetUserByUsername ¶

func (d *Driver) GetUserByUsername(ctx context.Context, projectID, username string) (*models.User, error)

func (*Driver) GetWebHook ¶

func (d *Driver) GetWebHook(ctx context.Context, projectId, hookId string) (*models.Webhook, error)

GetWebHook retrieves a specific webhook by ID using SQL

func (*Driver) ListAllProjects ¶

func (d *Driver) ListAllProjects(ctx context.Context, userId string) ([]*models.Project, error)

ListAllProjects lists all projects for a user (with admin check) using SQL

func (*Driver) ListAllUsers ¶

func (d *Driver) ListAllUsers(ctx context.Context) ([]*models.SystemUser, error)

ListAllUsers lists all system users using SQL

func (*Driver) ListSchemaOperationsByStatus ¶

func (d *Driver) ListSchemaOperationsByStatus(ctx context.Context, projectID string, statuses []string, limit int) ([]*models.SchemaOperation, error)

func (*Driver) ListTeams ¶

func (d *Driver) ListTeams(ctx context.Context, projectId string) ([]*models.SystemUser, error)

ListTeams lists console operators for a project from user_projects.

func (*Driver) ListUsersByEmail ¶

func (d *Driver) ListUsersByEmail(ctx context.Context, projectID, email string) ([]*models.User, error)

func (*Driver) ListUsersByGoogleSub ¶

func (d *Driver) ListUsersByGoogleSub(ctx context.Context, projectID, googleSub string) ([]*models.User, error)

func (*Driver) ListUsersByPhone ¶

func (d *Driver) ListUsersByPhone(ctx context.Context, projectID, phone string) ([]*models.User, error)

func (*Driver) PersistProjectModelTypes ¶

func (d *Driver) PersistProjectModelTypes(ctx context.Context, projectID string, schemaModels []*models.ModelType) error

PersistProjectModelTypes implements interfaces.ApitoSystemDB: deletes model_types rows for projectID whose name is not in schemaModels, then inserts or updates each model row. schemaModels nil means no-op (reserved). An empty slice deletes all model_types for the project.

func (*Driver) Ping ¶

func (d *Driver) Ping() error

func (*Driver) RemoveATeamFromOrganization ¶

func (d *Driver) RemoveATeamFromOrganization(ctx context.Context, orgId, userId, teamId string) error

RemoveATeamFromOrganization is retired.

func (*Driver) RemoveATeamMemberFromProject ¶

func (d *Driver) RemoveATeamMemberFromProject(ctx context.Context, projectId string, memberID string) error

RemoveATeamMemberFromProject removes a team member from a project using SQL

func (*Driver) RemoveProjectFromOrganization ¶

func (d *Driver) RemoveProjectFromOrganization(ctx context.Context, orgId, userId, projectId string) error

RemoveProjectFromOrganization is retired.

func (*Driver) RunMigration ¶

func (d *Driver) RunMigration(ctx context.Context) error

func (*Driver) SaveAuditLog ¶

func (d *Driver) SaveAuditLog(ctx context.Context, auditLog *models.AuditLogs) error

SaveAuditLog implements interfaces.ApitoSystemDB.

func (*Driver) SaveProjectAuthenticationSettings ¶

func (d *Driver) SaveProjectAuthenticationSettings(ctx context.Context, projectID string, auth *models.AuthenticationSettings) error

func (*Driver) SaveProjectStorageSettings ¶

func (d *Driver) SaveProjectStorageSettings(ctx context.Context, projectID string, storage *models.StorageSettings) error

func (*Driver) SaveRawData ¶

func (d *Driver) SaveRawData(ctx context.Context, collection string, data map[string]interface{}) error

SaveRawData saves raw data using SQL for payment-related operations

func (*Driver) SearchAuditLogs ¶

func (d *Driver) SearchAuditLogs(ctx context.Context, param *models.CommonSystemParams) (*models.SearchResponse[models.AuditLogs], error)

SearchAuditLogs implements interfaces.ApitoSystemDB.

func (*Driver) SearchFunctions ¶

func (d *Driver) SearchFunctions(ctx context.Context, param *models.CommonSystemParams) (*models.SearchResponse[models.ApitoFunction], error)

SearchFunctions searches for cloud functions in a project using SQL

func (*Driver) SearchProjectUsers ¶

func (d *Driver) SearchProjectUsers(ctx context.Context, projectID, q string, limit, offset int) ([]*models.User, int, error)

func (*Driver) SearchProjects ¶

func (d *Driver) SearchProjects(ctx context.Context, param *models.CommonSystemParams) (*models.SearchResponse[models.Project], error)

SearchProjects searches for projects based on common system parameters using SQL

func (*Driver) SearchResource ¶

func (d *Driver) SearchResource(ctx context.Context, param *models.CommonSystemParams) (*models.SearchResponse[any], error)

SearchResource implements interfaces.ApitoSystemDB.

func (*Driver) SearchSystemUsers ¶

func (d *Driver) SearchSystemUsers(ctx context.Context, param *models.CommonSystemParams) (*models.SearchResponse[models.SystemUser], error)

SearchSystemUsers searches for system users based on parameters using SQL

func (*Driver) SearchWebHooks ¶

func (d *Driver) SearchWebHooks(ctx context.Context, param *models.CommonSystemParams) (*models.SearchResponse[models.Webhook], error)

SearchWebHooks searches for webhooks in a project using SQL

func (*Driver) TouchProjectUpdatedAt ¶

func (d *Driver) TouchProjectUpdatedAt(ctx context.Context, projectID string) error

TouchProjectUpdatedAt implements interfaces.ApitoSystemDB.

func (*Driver) UpdateProject ¶

func (d *Driver) UpdateProject(ctx context.Context, project *models.Project, replace bool) error

UpdateProject updates a project using SQL

func (*Driver) UpdateSchemaOperation ¶

func (d *Driver) UpdateSchemaOperation(ctx context.Context, op *models.SchemaOperation) error

func (*Driver) UpdateSystemUser ¶

func (d *Driver) UpdateSystemUser(ctx context.Context, user *models.SystemUser, replace bool) error

UpdateSystemUser updates a system user using SQL

func (*Driver) UpdateUser ¶

func (d *Driver) UpdateUser(ctx context.Context, row *models.User) error

func (*Driver) UpsertModelType ¶

func (d *Driver) UpsertModelType(ctx context.Context, projectID string, m *models.ModelType) error

UpsertModelType implements interfaces.ApitoSystemDB — single model_types row, no orphan reconciliation.