@page "/bulk-members" @attribute [Authorize] @inject IUserSessionService Session @inject IUserContextAccessor UserContext @inject ISessionManager SessionMgr @inject IElevationCoordinator Elevation @inject IBulkMemberService BulkSvc @inject ICsvValidationService CsvValidation @inject BulkResultCsvExportService ExportSvc @inject WebExportService WebExport @rendermode InteractiveServer

Bulk Members

Add users to SharePoint groups from a CSV file.

@if (!Session.HasProfile) { return; } @if (UserContext.Role < UserRole.TechN1) { return; }
@if (_rows.Count > 0) {
@_rows.Count(r => r.IsValid) valid rows, @_rows.Count(r => !r.IsValid) errors.
@foreach (var row in _rows.Take(50)) { }
GroupEmailRoleStatus
@(row.Record?.GroupName ?? "—") @(row.Record?.Email ?? "—") @(row.Record?.Role ?? "—") @(row.IsValid ? "✓" : string.Join("; ", row.Errors))
}
@if (_running) { }
@if (!string.IsNullOrEmpty(_error)) {
@_error
} @if (_summary != null) {
Processed: @_summary.SuccessCount / @_summary.TotalCount. Failures: @_summary.FailedCount
@if (_summary.HasFailures) { }
} @code { private List _sites = new(); private List> _rows = new(); private bool _running; private string _status = string.Empty, _error = string.Empty; private int _current, _total; private BulkOperationSummary? _summary; private CancellationTokenSource? _cts; private async Task LoadFile(InputFileChangeEventArgs e) { _rows.Clear(); var file = e.File; using var stream = file.OpenReadStream(maxAllowedSize: 10 * 1024 * 1024); _rows = CsvValidation.ParseAndValidateMembers(stream); } private async Task RunBulk() { _error = string.Empty; _summary = null; _running = true; _cts = new CancellationTokenSource(); var validRows = _rows.Where(r => r.IsValid && r.Record != null).Select(r => r.Record!).ToList(); var siteUrl = _sites.FirstOrDefault()?.Url; if (string.IsNullOrWhiteSpace(siteUrl)) { _error = "Please select a site."; _running = false; return; } var progress = new Progress(p => { _status = p.Message; _current = p.Current; _total = p.Total; InvokeAsync(StateHasChanged); }); try { _summary = await Elevation.RunAsync(async c => { var ctx = await SessionMgr.GetOrCreateContextAsync(siteUrl, Session.CurrentProfile!, c); return await BulkSvc.AddMembersAsync(ctx, Session.CurrentProfile!, validRows, progress, c); }, _cts.Token); _status = $"Complete: {_summary.SuccessCount} added, {_summary.FailedCount} failed."; } catch (OperationCanceledException) { _status = "Cancelled."; } catch (Exception ex) { _error = ex.Message; } finally { _running = false; await InvokeAsync(StateHasChanged); } } private void Cancel() => _cts?.Cancel(); private async Task ExportErrors() { if (_summary == null) return; var csv = ExportSvc.BuildFailedItemsCsv(_summary.Results.ToList()); await WebExport.DownloadCsvAsync(csv, $"bulk_members_errors_{DateTime.Now:yyyyMMdd_HHmmss}.csv"); } }