api

Documentation

Index

• func AuthCurrentUserHandler(w http.ResponseWriter, r *http.Request)
• func AuthGoogleCallbackHandler(w http.ResponseWriter, r *http.Request)
• func AuthLoginHandler(w http.ResponseWriter, r *http.Request)
• func AuthLogoutHandler(w http.ResponseWriter, r *http.Request)
• func BackupCreateHandler(w http.ResponseWriter, r *http.Request)
• func BackupDeleteHandler(w http.ResponseWriter, r *http.Request)
• func BackupExecuteHandler(w http.ResponseWriter, r *http.Request)
• func BackupListHandler(w http.ResponseWriter, r *http.Request)
• func BackupPauseHandler(w http.ResponseWriter, r *http.Request)
• func BackupResumeHandler(w http.ResponseWriter, r *http.Request)
• func BackupRunHandler(w http.ResponseWriter, r *http.Request)
• func BackupStatusHandler(w http.ResponseWriter, r *http.Request)
• func BackupUpdateHandler(w http.ResponseWriter, r *http.Request)
• func ChangeStreamsStatusHandler(w http.ResponseWriter, r *http.Request)
• func DeleteUserHandler(w http.ResponseWriter, r *http.Request)
• func ExecuteSQLHandler(w http.ResponseWriter, r *http.Request)
• func ExtractTokenFromHeader(authHeader string) string
• func GenerateAdminToken() string
• func GenerateUserToken(username, accessLevel string) string
• func GetAdminTokenHandler(w http.ResponseWriter, r *http.Request)
• func GetAllUsers() ([]map[string]interface{}, error)
• func GetAuthConfig(provider string) (map[string]interface{}, error)
• func GetOAuthConfigHandler(w http.ResponseWriter, r *http.Request)
• func GetTableSchemaHandler(w http.ResponseWriter, r *http.Request)
• func GetUserByUsername(username string) (map[string]interface{}, error)
• func GetUserData(username string) (map[string]interface{}, error)
• func GetUsersHandler(w http.ResponseWriter, r *http.Request)
• func NewRouter() http.Handler
• func SaveGoogleUser(email, name string) (string, string, error)
• func SyncCreateHandler(w http.ResponseWriter, r *http.Request)
• func SyncDeleteHandler(w http.ResponseWriter, r *http.Request)
• func SyncListHandler(w http.ResponseWriter, r *http.Request)
• func SyncLogsHandler(w http.ResponseWriter, r *http.Request)
• func SyncMetricsHandler(w http.ResponseWriter, r *http.Request)
• func SyncMonitorHandler(w http.ResponseWriter, r *http.Request)
• func SyncStartHandler(w http.ResponseWriter, r *http.Request)
• func SyncStopHandler(w http.ResponseWriter, r *http.Request)
• func SyncTablesHandler(w http.ResponseWriter, r *http.Request)
• func SyncUpdateHandler(w http.ResponseWriter, r *http.Request)
• func TestConnectionHandler(w http.ResponseWriter, r *http.Request)
• func UpdateAdminPasswordHandler(w http.ResponseWriter, r *http.Request)
• func UpdateAuthConfig(provider string, config map[string]interface{}) error
• func UpdateOAuthConfigHandler(w http.ResponseWriter, r *http.Request)
• func UpdatePasswordHandler(w http.ResponseWriter, r *http.Request)
• func UpdateUserAccessHandler(w http.ResponseWriter, r *http.Request)
• func UpdateUserPassword(username, newPassword string) error
• func ValidateAdminToken(token string) bool
• func ValidateUser(username, password string) (bool, string, error)
• func ValidateUserToken(token string) (bool, string, string)
• type BackupTaskStatus
• type Field
• type SchemaRequest
• type SchemaResponse

Functions

func AuthCurrentUserHandler

func AuthCurrentUserHandler(w http.ResponseWriter, r *http.Request)

AuthCurrentUserHandler GET /api/currentUser

func AuthGoogleCallbackHandler

func AuthGoogleCallbackHandler(w http.ResponseWriter, r *http.Request)

AuthGoogleCallbackHandler POST /api/login/google/callback

func AuthLoginHandler

func AuthLoginHandler(w http.ResponseWriter, r *http.Request)

AuthLoginHandler POST /api/login

func AuthLogoutHandler

func AuthLogoutHandler(w http.ResponseWriter, r *http.Request)

AuthLogoutHandler POST /api/logout

func BackupCreateHandler

func BackupCreateHandler(w http.ResponseWriter, r *http.Request)

func BackupDeleteHandler

func BackupDeleteHandler(w http.ResponseWriter, r *http.Request)

func BackupExecuteHandler

func BackupExecuteHandler(w http.ResponseWriter, r *http.Request)

BackupExecuteHandler Execute the backup task with the specified ID (async) POST /api/backup/execute/{id}

func BackupListHandler

func BackupListHandler(w http.ResponseWriter, r *http.Request)

func BackupPauseHandler

func BackupPauseHandler(w http.ResponseWriter, r *http.Request)

func BackupResumeHandler

func BackupResumeHandler(w http.ResponseWriter, r *http.Request)

func BackupRunHandler

func BackupRunHandler(w http.ResponseWriter, r *http.Request)

func BackupStatusHandler

func BackupStatusHandler(w http.ResponseWriter, r *http.Request)

BackupStatusHandler Get the status of a background backup task GET /api/backup/status/{taskId}

func BackupUpdateHandler

func BackupUpdateHandler(w http.ResponseWriter, r *http.Request)

func ChangeStreamsStatusHandler

func ChangeStreamsStatusHandler(w http.ResponseWriter, r *http.Request)

GET /api/changestreams/status

func DeleteUserHandler

func DeleteUserHandler(w http.ResponseWriter, r *http.Request)

DeleteUserHandler DELETE /api/users

func ExecuteSQLHandler

func ExecuteSQLHandler(w http.ResponseWriter, r *http.Request)

ExecuteSQLHandler POST /api/sql/execute

func ExtractTokenFromHeader

func ExtractTokenFromHeader(authHeader string) string

ExtractTokenFromHeader extracts token from HTTP request header

func GenerateAdminToken

func GenerateAdminToken() string

GenerateAdminToken generates admin verification token Based on current date and secret key, changes daily

func GenerateUserToken

func GenerateUserToken(username, accessLevel string) string

GenerateUserToken generates a token for a specific user Based on username, access level, current date and secret key

func GetAdminTokenHandler

func GetAdminTokenHandler(w http.ResponseWriter, r *http.Request)

GetAdminTokenHandler GET /api/getAdminToken

func GetAllUsers

func GetAllUsers() ([]map[string]interface{}, error)

GetAllUsers gets all user information

func GetAuthConfig

func GetAuthConfig(provider string) (map[string]interface{}, error)

func GetOAuthConfigHandler

func GetOAuthConfigHandler(w http.ResponseWriter, r *http.Request)

GetOAuthConfigHandler handles GET /api/oauth/{provider}/config

func GetTableSchemaHandler

func GetTableSchemaHandler(w http.ResponseWriter, r *http.Request)

TableSchemaHandler processes POST requests to get table/collection structure

func GetUserByUsername

func GetUserByUsername(username string) (map[string]interface{}, error)

GetUserByUsername gets user information by username

func GetUserData

func GetUserData(username string) (map[string]interface{}, error)

GetUserData gets user data for frontend display

func GetUsersHandler

func GetUsersHandler(w http.ResponseWriter, r *http.Request)

GetUsersHandler GET /api/users

func NewRouter

func NewRouter() http.Handler

NewRouter creates and returns the routing configuration for the entire /api

func SaveGoogleUser

func SaveGoogleUser(email, name string) (string, string, error)

SaveGoogleUser saves or updates Google user information

func SyncCreateHandler

func SyncCreateHandler(w http.ResponseWriter, r *http.Request)

POST /api/sync => create

func SyncDeleteHandler

func SyncDeleteHandler(w http.ResponseWriter, r *http.Request)

DELETE /api/sync/{id}

func SyncListHandler

func SyncListHandler(w http.ResponseWriter, r *http.Request)

GET /api/sync => query sync_tasks

func SyncLogsHandler

func SyncLogsHandler(w http.ResponseWriter, r *http.Request)

GET /api/sync/{id}/logs

func SyncMetricsHandler

func SyncMetricsHandler(w http.ResponseWriter, r *http.Request)

GET /api/sync/{id}/metrics

func SyncMonitorHandler

func SyncMonitorHandler(w http.ResponseWriter, r *http.Request)

GET /api/sync/{id}/monitor => {status, progress, tps, ...}

func SyncStartHandler

func SyncStartHandler(w http.ResponseWriter, r *http.Request)

PUT /api/sync/{id}/start => enable=1, update config_json.status='Running'

func SyncStopHandler

func SyncStopHandler(w http.ResponseWriter, r *http.Request)

PUT /api/sync/{id}/stop => enable=0, Update config_json.status='Stopped'

func SyncTablesHandler

func SyncTablesHandler(w http.ResponseWriter, r *http.Request)

GET /api/sync/{id}/tables => returns tables info and sync stats for today

func SyncUpdateHandler

func SyncUpdateHandler(w http.ResponseWriter, r *http.Request)

PUT /api/sync/{id} => Update sync_tasks.config_json + enable + last_update_time

func TestConnectionHandler

func TestConnectionHandler(w http.ResponseWriter, r *http.Request)

TestConnectionHandler POST /api/test-connection

func UpdateAdminPasswordHandler

func UpdateAdminPasswordHandler(w http.ResponseWriter, r *http.Request)

UpdateAdminPasswordHandler PUT /api/updateAdminPassword

func UpdateAuthConfig

func UpdateAuthConfig(provider string, config map[string]interface{}) error

func UpdateOAuthConfigHandler

func UpdateOAuthConfigHandler(w http.ResponseWriter, r *http.Request)

UpdateOAuthConfigHandler handles PUT /api/oauth/{provider}/config

func UpdatePasswordHandler

func UpdatePasswordHandler(w http.ResponseWriter, r *http.Request)

UpdatePasswordHandler PUT /api/updatePassword

func UpdateUserAccessHandler

func UpdateUserAccessHandler(w http.ResponseWriter, r *http.Request)

UpdateUserAccessHandler PUT /api/users/access

func UpdateUserPassword

func UpdateUserPassword(username, newPassword string) error

UpdateUserPassword updates user password

func ValidateAdminToken

func ValidateAdminToken(token string) bool

ValidateAdminToken validates if admin token is valid

func ValidateUser

func ValidateUser(username, password string) (bool, string, error)

ValidateUser validates username and password

func ValidateUserToken

func ValidateUserToken(token string) (bool, string, string)

ValidateUserToken validates if user token is valid and returns username and access level

Types

type BackupTaskStatus

type BackupTaskStatus struct {
	TaskID      string     `json:"taskId"`
	BackupID    int        `json:"backupId"`
	Status      string     `json:"status"` // pending, running, completed, failed
	Message     string     `json:"message"`
	CreatedAt   time.Time  `json:"createdAt"`
	CompletedAt *time.Time `json:"completedAt,omitempty"`
	Error       string     `json:"error,omitempty"`
}

BackupTaskStatus represents the status of a background backup task

type Field

type Field struct {
	Name      string `json:"name"`
	Type      string `json:"type"`
	IsPrimary bool   `json:"isPrimary"`
}

Field represents table field information

type SchemaRequest

type SchemaRequest struct {
	SourceType string `json:"sourceType"`
	Connection struct {
		Host     string `json:"host"`
		Port     string `json:"port"`
		User     string `json:"user"`
		Password string `json:"password"`
		Database string `json:"database"`
	} `json:"connection"`
	TableName string `json:"tableName"`
}

SchemaRequest represents a request to get table structure

type SchemaResponse

type SchemaResponse struct {
	Fields []Field `json:"fields"`
}

SchemaResponse represents a table structure response