Method UpsertMCPServerUserToken

enterprise/dbcrypt/dbcrypt.go:857–877

(ctx context.Context, params database.UpsertMCPServerUserTokenParams)

}

func (db *dbCrypt) UpsertMCPServerUserToken(ctx context.Context, params database.UpsertMCPServerUserTokenParams) (database.MCPServerUserToken, error) {
	if strings.TrimSpace(params.AccessToken) == "" {
		params.AccessTokenKeyID = sql.NullString{}
	} else if err := db.encryptField(&params.AccessToken, &params.AccessTokenKeyID); err != nil {
		return database.MCPServerUserToken{}, err
	}
	if strings.TrimSpace(params.RefreshToken) == "" {
		params.RefreshTokenKeyID = sql.NullString{}
	} else if err := db.encryptField(&params.RefreshToken, &params.RefreshTokenKeyID); err != nil {
		return database.MCPServerUserToken{}, err
	}

	tok, err := db.Store.UpsertMCPServerUserToken(ctx, params)
	if err != nil {
		return database.MCPServerUserToken{}, err
	}
	if err := db.decryptMCPServerUserToken(&tok); err != nil {
		return database.MCPServerUserToken{}, err
	}
	return tok, nil
}

func (db *dbCrypt) CreateUserSecret(ctx context.Context, params database.CreateUserSecretParams) (database.UserSecret, error) {
	if err := db.encryptField(&params.Value, &params.ValueKeyID); err != nil {