Method InsertMCPServerConfig

enterprise/dbcrypt/dbcrypt.go:803–828

(ctx context.Context, params database.InsertMCPServerConfigParams)

}

func (db *dbCrypt) InsertMCPServerConfig(ctx context.Context, params database.InsertMCPServerConfigParams) (database.MCPServerConfig, error) {
	if strings.TrimSpace(params.OAuth2ClientSecret) == "" {
		params.OAuth2ClientSecretKeyID = sql.NullString{}
	} else if err := db.encryptField(&params.OAuth2ClientSecret, &params.OAuth2ClientSecretKeyID); err != nil {
		return database.MCPServerConfig{}, err
	}
	if strings.TrimSpace(params.APIKeyValue) == "" {
		params.APIKeyValueKeyID = sql.NullString{}
	} else if err := db.encryptField(&params.APIKeyValue, &params.APIKeyValueKeyID); err != nil {
		return database.MCPServerConfig{}, err
	}
	if strings.TrimSpace(params.CustomHeaders) == "" {
		params.CustomHeadersKeyID = sql.NullString{}
	} else if err := db.encryptField(&params.CustomHeaders, &params.CustomHeadersKeyID); err != nil {
		return database.MCPServerConfig{}, err
	}

	cfg, err := db.Store.InsertMCPServerConfig(ctx, params)
	if err != nil {
		return database.MCPServerConfig{}, err
	}
	if err := db.decryptMCPServerConfig(&cfg); err != nil {
		return database.MCPServerConfig{}, err
	}
	return cfg, nil
}

func (db *dbCrypt) UpdateMCPServerConfig(ctx context.Context, params database.UpdateMCPServerConfigParams) (database.MCPServerConfig, error) {
	if strings.TrimSpace(params.OAuth2ClientSecret) == "" {