WeddingPlatform.Services.JsonMediaMigrationService에 대한 상속 다이어그램 :

WeddingPlatform.Services.JsonMediaMigrationService에 대한 협력 다이어그램:

[범례]

Public 멤버 함수
	JsonMediaMigrationService (ITenantStore tenants, WeddingOptions options, IMediaQuotaPolicyResolver policyResolver, IImageOptimizationService imageOptimization)
async Task< IReadOnlyDictionary< string, MediaMigrationTenantStatus > >	GetAllAsync (CancellationToken ct=default)
async Task< MediaMigrationTenantStatus?>	GetTenantStatusAsync (string slug, CancellationToken ct=default)
async Task	QueueTenantAsync (string slug, CancellationToken ct=default)
async Task	RetryTenantAsync (string slug, CancellationToken ct=default)

속성
string	StatusPath `[get]`

Private 멤버 함수
async Task	ProcessTenantSafeAsync (string slug, CancellationToken ct)
async Task	ProcessTenantAsync (string slug, CancellationToken ct)
async Task< Dictionary< string, MediaMigrationTenantStatus > >	LoadAsync (CancellationToken ct)
async Task	SaveAsync (Dictionary< string, MediaMigrationTenantStatus > status, CancellationToken ct)
bool	IsRunning (string slug)
void	StartBackground (string slug)
string	ResolveWritableOutputFormat (string? preferredFormat, string? sourceFileName)

정적 Private 멤버 함수
static MediaMigrationTenantStatus	GetOrCreate (Dictionary< string, MediaMigrationTenantStatus > all, string slug)
static void	MarkFile (MediaMigrationFileStatus fileStatus, MediaMigrationState state, string message)
static string	BuildProgressMessage (MediaMigrationTenantStatus status, int processed, int total)
static string	NormalizeFormat (string? outputFormat)

Private 속성
readonly ITenantStore	_tenants
readonly WeddingOptions	_options
readonly IMediaQuotaPolicyResolver	_policyResolver
readonly IImageOptimizationService	_imageOptimization
readonly SemaphoreSlim	_gate = new(1, 1)
readonly object	_runningGate = new()
readonly HashSet< string >	_runningSlugs = new(StringComparer.OrdinalIgnoreCase)
readonly JsonSerializerOptions	_jsonOptions = new() { WriteIndented = true }
Dictionary< string, MediaMigrationTenantStatus >?	_cache

상세한 설명

JSON 상태 파일을 사용해 이미지 마이그레이션을 멱등적으로 수행합니다.

JsonMediaMigrationService.cs 파일의 15 번째 라인에서 정의되었습니다.

생성자 & 소멸자 문서화

◆ JsonMediaMigrationService()

WeddingPlatform.Services.JsonMediaMigrationService.JsonMediaMigrationService	(	ITenantStore	tenants,
		WeddingOptions	options,
		IMediaQuotaPolicyResolver	policyResolver,
		IImageOptimizationService	imageOptimization )

inline

지정한 설정으로 JsonMediaMigrationService 클래스의 새 인스턴스를 초기화합니다.

매개변수

tenants	tenants에 사용할 `ITenantStore` 값입니다.
options	동작을 구성하는 설정입니다.
policyResolver	policy Resolver에 사용할 `IMediaQuotaPolicyResolver` 값입니다.
imageOptimization	image Optimization에 사용할 `IImageOptimizationService` 값입니다.

JsonMediaMigrationService.cs 파일의 140 번째 라인에서 정의되었습니다.

    {
        _tenants = tenants;
        _options = options;
        _policyResolver = policyResolver;
        _imageOptimization = imageOptimization;
    }

다음을 참조함 : _imageOptimization, _options, _policyResolver, _tenants.

멤버 함수 문서화

◆ BuildProgressMessage()

string WeddingPlatform.Services.JsonMediaMigrationService.BuildProgressMessage	(	MediaMigrationTenantStatus	status,
		int	processed,
		int	total )

inlinestaticprivate

Progress Message 값을 구성합니다.

매개변수

status	status에 사용할 `MediaMigrationTenantStatus` 값입니다.
processed	processed에 사용할 `int` 값입니다.
total	total에 사용할 `int` 값입니다.

반환값: Build Progress Message 작업에서 생성한 string 결과입니다.

JsonMediaMigrationService.cs 파일의 910 번째 라인에서 정의되었습니다.

    {
        var failed = status.Files.Count(x => x.State == MediaMigrationState.Failed);
        var completed = status.Files.Count(x => x.State == MediaMigrationState.Completed);
        var skipped = status.Files.Count(x => x.State == MediaMigrationState.Skipped);
        if (failed > 0) return $"처리 중 ({processed}/{total}, 실패 {failed})";
        return $"처리 중 ({processed}/{total}, 완료 {completed}, 건너뜀 {skipped})";
    }

다음을 참조함 : WeddingPlatform.Models.MediaMigrationTenantStatus.Files.

다음에 의해서 참조됨 : ProcessTenantAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ GetAllAsync()

async Task< IReadOnlyDictionary< string, MediaMigrationTenantStatus > > WeddingPlatform.Services.JsonMediaMigrationService.GetAllAsync ( CancellationToken ct = default )

inline

All Async 값을 가져옵니다.

매개변수

ct	취소 요청을 감시하는 토큰입니다.

반환값: Get All Async 작업에서 생성한 Task<IReadOnlyDictionary<string, MediaMigrationTenantStatus>> 결과입니다.

WeddingPlatform.Services.IMediaMigrationService를 구현.

JsonMediaMigrationService.cs 파일의 176 번째 라인에서 정의되었습니다.

    {
        return await LoadAsync(ct).ConfigureAwait(false);
    }

다음을 참조함 : LoadAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

◆ GetOrCreate()

MediaMigrationTenantStatus WeddingPlatform.Services.JsonMediaMigrationService.GetOrCreate	(	Dictionary< string, MediaMigrationTenantStatus >	all,
		string	slug )

inlinestaticprivate

Or Create 값을 가져옵니다.

매개변수

all	all에 사용할 `Dictionary<string, MediaMigrationTenantStatus>` 값입니다.
slug	slug에 사용할 `string` 값입니다.

반환값: Get Or Create 작업에서 생성한 MediaMigrationTenantStatus 결과입니다.

JsonMediaMigrationService.cs 파일의 780 번째 라인에서 정의되었습니다.

    {
        if (all.TryGetValue(slug, out var status)) return status;
        status = new MediaMigrationTenantStatus { Slug = slug, State = MediaMigrationState.Pending };
        all[slug] = status;
        return status;
    }

다음을 참조함 : WeddingPlatform.Models.Pending.

다음에 의해서 참조됨 : ProcessTenantAsync(), ProcessTenantSafeAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ GetTenantStatusAsync()

async Task< MediaMigrationTenantStatus?> WeddingPlatform.Services.JsonMediaMigrationService.GetTenantStatusAsync	(	string	slug,
		CancellationToken	ct = default )

inline

Tenant Status Async 값을 가져옵니다.

매개변수

slug	slug에 사용할 `string` 값입니다.
ct	취소 요청을 감시하는 토큰입니다.

반환값: Get Tenant Status Async 작업에서 생성한 Task<MediaMigrationTenantStatus?> 결과입니다.

WeddingPlatform.Services.IMediaMigrationService를 구현.

JsonMediaMigrationService.cs 파일의 213 번째 라인에서 정의되었습니다.

    {
        var all = await LoadAsync(ct).ConfigureAwait(false);
        return all.TryGetValue(slug, out var status) ? status : null;
    }

다음을 참조함 : LoadAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

◆ IsRunning()

bool WeddingPlatform.Services.JsonMediaMigrationService.IsRunning ( string slug )

inlineprivate

Is Running 조건을 확인합니다.

매개변수

slug	slug에 사용할 `string` 값입니다.

반환값: Is Running 조건이 충족되면 true이고, 그렇지 않으면 false입니다.

JsonMediaMigrationService.cs 파일의 698 번째 라인에서 정의되었습니다.

    {
        lock (_runningGate)
        {
            return _runningSlugs.Contains(slug);
        }
    }

다음을 참조함 : _runningGate, _runningSlugs.

다음에 의해서 참조됨 : QueueTenantAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ LoadAsync()

async Task< Dictionary< string, MediaMigrationTenantStatus > > WeddingPlatform.Services.JsonMediaMigrationService.LoadAsync ( CancellationToken ct )

inlineprivate

Async 데이터를 불러옵니다.

매개변수

ct	취소 요청을 감시하는 토큰입니다.

반환값: Load Async 작업에서 생성한 Task<Dictionary<string, MediaMigrationTenantStatus>> 결과입니다.

JsonMediaMigrationService.cs 파일의 576 번째 라인에서 정의되었습니다.

    {
        if (_cache is not null) return _cache;
 
        await _gate.WaitAsync(ct).ConfigureAwait(false);
        try
        {
            if (_cache is not null) return _cache;
            var path = StatusPath;
            if (!File.Exists(path))
            {
                _cache = new Dictionary<string, MediaMigrationTenantStatus>(StringComparer.OrdinalIgnoreCase);
                return _cache;
            }
 
            await using var stream = File.OpenRead(path);
            _cache = await JsonSerializer.DeserializeAsync<Dictionary<string, MediaMigrationTenantStatus>>(stream, _jsonOptions, ct).ConfigureAwait(false)
                ?? new Dictionary<string, MediaMigrationTenantStatus>(StringComparer.OrdinalIgnoreCase);
            return _cache;
        }
        finally
        {
            _gate.Release();
        }
    }

다음을 참조함 : _cache, _gate, _jsonOptions, StatusPath.

다음에 의해서 참조됨 : GetAllAsync(), GetTenantStatusAsync(), ProcessTenantAsync(), ProcessTenantSafeAsync(), QueueTenantAsync(), RetryTenantAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ MarkFile()

void WeddingPlatform.Services.JsonMediaMigrationService.MarkFile	(	MediaMigrationFileStatus	fileStatus,
		MediaMigrationState	state,
		string	message )

inlinestaticprivate

Mark File 작업을 수행합니다.

매개변수

fileStatus	file Status에 사용할 `MediaMigrationFileStatus` 값입니다.
state	state에 사용할 `MediaMigrationState` 값입니다.
message	처리할 메시지입니다.

JsonMediaMigrationService.cs 파일의 820 번째 라인에서 정의되었습니다.

    {
        fileStatus.State = state;
        fileStatus.Message = message;
        fileStatus.UpdatedAt = DateTime.Now;
    }

다음에 의해서 참조됨 : ProcessTenantAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ NormalizeFormat()

string WeddingPlatform.Services.JsonMediaMigrationService.NormalizeFormat ( string? outputFormat )

inlinestaticprivate

Normalize Format 작업을 수행합니다.

매개변수

outputFormat output Format에 사용할 string? 값입니다.

반환값: Normalize Format 작업에서 생성한 string 결과입니다.

JsonMediaMigrationService.cs 파일의 943 번째 라인에서 정의되었습니다.

    {
        var normalized = outputFormat?.Trim().TrimStart('.').ToLowerInvariant();
        return string.IsNullOrWhiteSpace(normalized) ? "webp" : normalized;
    }

다음에 의해서 참조됨 : ProcessTenantAsync(), ResolveWritableOutputFormat().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ ProcessTenantAsync()

async Task WeddingPlatform.Services.JsonMediaMigrationService.ProcessTenantAsync	(	string	slug,
		CancellationToken	ct )

inlineprivate

Process Tenant Async 작업을 수행합니다.

매개변수

slug	slug에 사용할 `string` 값입니다.
ct	취소 요청을 감시하는 토큰입니다.

반환값: Process Tenant Async 작업에서 생성한 Task 결과입니다.

예외

InvalidOperationException 현재 객체 상태에서 Process Tenant Async 작업을 수행할 수 없는 경우 발생합니다.

JsonMediaMigrationService.cs 파일의 410 번째 라인에서 정의되었습니다.

    {
        var config = await _tenants.GetAsync(slug, ct).ConfigureAwait(false);
        if (config is null) return;
 
        var policy = await _policyResolver.ResolveAsync(config, ct).ConfigureAwait(false);
        var all = await LoadAsync(ct).ConfigureAwait(false);
        var status = GetOrCreate(all, slug);
        status.State = MediaMigrationState.Processing;
        status.Message = "처리 중";
        status.UpdatedAt = DateTime.Now;
        await SaveAsync(all, ct).ConfigureAwait(false);
 
        var root = _tenants.GetTenantDataPath(slug);
        var galleryDir = Path.Combine(root, "gallery");
        var thumbDir = Path.Combine(root, "thumb");
        var originalDir = Path.Combine(root, "original");
        Directory.CreateDirectory(galleryDir);
        Directory.CreateDirectory(thumbDir);
        Directory.CreateDirectory(originalDir);
 
        if (config.GalleryFileNames.Count == 0)
        {
            status.State = MediaMigrationState.Skipped;
            status.Message = "변환할 이미지가 없습니다.";
            status.UpdatedAt = DateTime.Now;
            await SaveAsync(all, ct).ConfigureAwait(false);
            return;
        }
 
        var anyFailed = false;
        var anyProcessed = false;
        var allSkipped = true;
        var total = config.GalleryFileNames.Count;
        var processed = 0;
 
        foreach (var fileName in config.GalleryFileNames.ToArray())
        {
            ct.ThrowIfCancellationRequested();
            var fileStatus = status.Files.FirstOrDefault(x => string.Equals(x.SourceFileName, fileName, StringComparison.OrdinalIgnoreCase));
            if (fileStatus is { State: MediaMigrationState.Completed or MediaMigrationState.Skipped })
            {
                processed++;
                continue;
            }
 
            fileStatus ??= new MediaMigrationFileStatus { SourceFileName = fileName };
            if (!status.Files.Contains(fileStatus)) status.Files.Add(fileStatus);
 
            var sourcePath = Path.Combine(galleryDir, fileName);
            if (!File.Exists(sourcePath))
            {
                MarkFile(fileStatus, MediaMigrationState.Skipped, "원본 파일 없음");
                continue;
            }
 
            var outputFormat = ResolveWritableOutputFormat(policy.ImageOutputFormat, fileName);
            if (string.IsNullOrWhiteSpace(outputFormat))
            {
                MarkFile(fileStatus, MediaMigrationState.Skipped, $"{policy.ImageOutputFormat} 인코더 없음");
                processed++;
                continue;
            }
 
            try
            {
                fileStatus.State = MediaMigrationState.Processing;
                fileStatus.Message = $"처리 중 ({processed + 1}/{total})";
                fileStatus.UpdatedAt = DateTime.Now;
                status.Message = fileStatus.Message;
                await SaveAsync(all, ct).ConfigureAwait(false);
 
                var targetName = $"{Path.GetFileNameWithoutExtension(fileName)}.{outputFormat}";
                var tempPath = Path.Combine(galleryDir, $"{Path.GetFileNameWithoutExtension(fileName)}.migration.tmp.{outputFormat}");
                var finalPath = Path.Combine(galleryDir, targetName);
                var result = await _imageOptimization.OptimizeAsync(sourcePath, tempPath, policy, ct).ConfigureAwait(false);
                if (!result.Succeeded || !File.Exists(tempPath) || new FileInfo(tempPath).Length == 0)
                {
                    if (File.Exists(tempPath)) File.Delete(tempPath);
                    throw new InvalidOperationException(result.Message);
                }
 
                if (policy.KeepOriginalImages)
                {
                    File.Copy(sourcePath, Path.Combine(originalDir, fileName), overwrite: true);
                }
 
                File.Move(tempPath, finalPath, overwrite: true);
                File.Copy(finalPath, Path.Combine(thumbDir, targetName), overwrite: true);
 
                var index = config.GalleryFileNames.FindIndex(x => string.Equals(x, fileName, StringComparison.OrdinalIgnoreCase));
                if (index >= 0)
                {
                    config.GalleryFileNames[index] = targetName;
                    await _tenants.SaveAsync(config, ct).ConfigureAwait(false);
                }
 
                if (!policy.KeepOriginalImages && !string.Equals(sourcePath, finalPath, StringComparison.OrdinalIgnoreCase))
                {
                    File.Delete(sourcePath);
                    var oldThumb = Path.Combine(thumbDir, fileName);
                    if (File.Exists(oldThumb)) File.Delete(oldThumb);
                }
 
                fileStatus.TargetFileName = targetName;
                var requestedFormat = NormalizeFormat(policy.ImageOutputFormat);
                var formatMessage = string.Equals(requestedFormat, outputFormat, StringComparison.OrdinalIgnoreCase)
                    ? "완료"
                    : $"완료 ({policy.ImageOutputFormat} 미지원, {outputFormat.ToUpperInvariant()}로 최적화)";
                MarkFile(fileStatus, MediaMigrationState.Completed, formatMessage);
                anyProcessed = true;
                allSkipped = false;
            }
            catch (Exception ex)
            {
                anyFailed = true;
                MarkFile(fileStatus, MediaMigrationState.Failed, ex.Message);
            }
 
            processed++;
            status.Message = BuildProgressMessage(status, processed, total);
            await SaveAsync(all, ct).ConfigureAwait(false);
        }
 
        status.State = anyFailed
            ? MediaMigrationState.Failed
            : anyProcessed
                ? MediaMigrationState.Completed
                : allSkipped
                    ? MediaMigrationState.Skipped
                    : MediaMigrationState.Completed;
        status.Message = status.State switch
        {
            MediaMigrationState.Completed => "완료",
            MediaMigrationState.Failed => "실패 항목 있음",
            MediaMigrationState.Skipped => "건너뜀",
            _ => status.Message
        };
        status.UpdatedAt = DateTime.Now;
        await SaveAsync(all, ct).ConfigureAwait(false);
    }

다음을 참조함 : _imageOptimization, _policyResolver, _tenants, BuildProgressMessage(), WeddingPlatform.Models.Completed, WeddingPlatform.Models.Failed, GetOrCreate(), LoadAsync(), MarkFile(), NormalizeFormat(), ResolveWritableOutputFormat(), SaveAsync(), WeddingPlatform.Models.Skipped.

다음에 의해서 참조됨 : ProcessTenantSafeAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ ProcessTenantSafeAsync()

async Task WeddingPlatform.Services.JsonMediaMigrationService.ProcessTenantSafeAsync	(	string	slug,
		CancellationToken	ct )

inlineprivate

Process Tenant Safe Async 작업을 수행합니다.

매개변수

slug	slug에 사용할 `string` 값입니다.
ct	취소 요청을 감시하는 토큰입니다.

반환값: Process Tenant Safe Async 작업에서 생성한 Task 결과입니다.

JsonMediaMigrationService.cs 파일의 353 번째 라인에서 정의되었습니다.

    {
        try
        {
            await ProcessTenantAsync(slug, ct).ConfigureAwait(false);
        }
        catch (Exception ex)
        {
            var all = await LoadAsync(CancellationToken.None).ConfigureAwait(false);
            var status = GetOrCreate(all, slug);
            status.State = MediaMigrationState.Failed;
            status.Message = ex.Message;
            status.UpdatedAt = DateTime.Now;
            await SaveAsync(all, CancellationToken.None).ConfigureAwait(false);
        }
    }

다음을 참조함 : GetOrCreate(), LoadAsync(), ProcessTenantAsync(), SaveAsync().

다음에 의해서 참조됨 : StartBackground().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ QueueTenantAsync()

async Task WeddingPlatform.Services.JsonMediaMigrationService.QueueTenantAsync	(	string	slug,
		CancellationToken	ct = default )

inline

Queue Tenant Async 작업을 수행합니다.

매개변수

slug	slug에 사용할 `string` 값입니다.
ct	취소 요청을 감시하는 토큰입니다.

반환값: Queue Tenant Async 작업에서 생성한 Task 결과입니다.

WeddingPlatform.Services.IMediaMigrationService를 구현.

JsonMediaMigrationService.cs 파일의 251 번째 라인에서 정의되었습니다.

    {
        var all = await LoadAsync(ct).ConfigureAwait(false);
        if (!all.TryGetValue(slug, out var status))
        {
            status = new MediaMigrationTenantStatus { Slug = slug, State = MediaMigrationState.Pending };
            all[slug] = status;
        }
 
        if (status.State is MediaMigrationState.Processing && IsRunning(slug))
        {
            return;
        }
 
        status.State = MediaMigrationState.Pending;
        status.Message = "변환 대기";
        status.UpdatedAt = DateTime.Now;
        await SaveAsync(all, ct).ConfigureAwait(false);
        StartBackground(slug);
    }

다음을 참조함 : IsRunning(), LoadAsync(), WeddingPlatform.Models.Pending, SaveAsync(), StartBackground().

다음에 의해서 참조됨 : RetryTenantAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ ResolveWritableOutputFormat()

string WeddingPlatform.Services.JsonMediaMigrationService.ResolveWritableOutputFormat	(	string?	preferredFormat,
		string?	sourceFileName )

inlineprivate

Resolve Writable Output Format 작업을 수행합니다.

매개변수

preferredFormat	preferred Format에 사용할 `string?` 값입니다.
sourceFileName	source File Name에 사용할 `string?` 값입니다.

반환값: Resolve Writable Output Format 작업에서 생성한 string 결과입니다.

JsonMediaMigrationService.cs 파일의 859 번째 라인에서 정의되었습니다.

    {
        var preferred = NormalizeFormat(preferredFormat);
        if (_imageOptimization.CanEncode(preferred)) return preferred;
 
        if (_imageOptimization.CanEncode("jpg")) return "jpg";
 
        var original = NormalizeFormat(Path.GetExtension(sourceFileName));
        return _imageOptimization.CanEncode(original) ? original : "";
    }

다음을 참조함 : _imageOptimization, NormalizeFormat().

다음에 의해서 참조됨 : ProcessTenantAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ RetryTenantAsync()

async Task WeddingPlatform.Services.JsonMediaMigrationService.RetryTenantAsync	(	string	slug,
		CancellationToken	ct = default )

inline

Retry Tenant Async 작업을 수행합니다.

매개변수

slug	slug에 사용할 `string` 값입니다.
ct	취소 요청을 감시하는 토큰입니다.

반환값: Retry Tenant Async 작업에서 생성한 Task 결과입니다.

WeddingPlatform.Services.IMediaMigrationService를 구현.

JsonMediaMigrationService.cs 파일의 304 번째 라인에서 정의되었습니다.

    {
        var all = await LoadAsync(ct).ConfigureAwait(false);
        if (all.TryGetValue(slug, out var status))
        {
            foreach (var file in status.Files.Where(x => x.State == MediaMigrationState.Failed))
            {
                file.State = MediaMigrationState.Pending;
                file.Message = "재시도 대기";
                file.UpdatedAt = DateTime.Now;
            }
        }
 
        await SaveAsync(all, ct).ConfigureAwait(false);
        await QueueTenantAsync(slug, ct).ConfigureAwait(false);
    }

다음을 참조함 : LoadAsync(), QueueTenantAsync(), SaveAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

◆ SaveAsync()

async Task WeddingPlatform.Services.JsonMediaMigrationService.SaveAsync	(	Dictionary< string, MediaMigrationTenantStatus >	status,
		CancellationToken	ct )

inlineprivate

Async 데이터를 저장합니다.

매개변수

status	status에 사용할 `Dictionary<string, MediaMigrationTenantStatus>` 값입니다.
ct	취소 요청을 감시하는 토큰입니다.

반환값: Save Async 작업에서 생성한 Task 결과입니다.

JsonMediaMigrationService.cs 파일의 634 번째 라인에서 정의되었습니다.

    {
        await _gate.WaitAsync(ct).ConfigureAwait(false);
        try
        {
            Directory.CreateDirectory(Path.GetDirectoryName(StatusPath)!);
            var tmp = StatusPath + ".tmp";
            await using (var stream = File.Create(tmp))
            {
                await JsonSerializer.SerializeAsync(stream, status, _jsonOptions, ct).ConfigureAwait(false);
            }
 
            File.Copy(tmp, StatusPath, overwrite: true);
            File.Delete(tmp);
            _cache = status;
        }
        finally
        {
            _gate.Release();
        }
    }

다음을 참조함 : _cache, _gate, _jsonOptions, StatusPath.

다음에 의해서 참조됨 : ProcessTenantAsync(), ProcessTenantSafeAsync(), QueueTenantAsync(), RetryTenantAsync().

이 함수를 호출하는 함수들에 대한 그래프입니다.:

◆ StartBackground()

void WeddingPlatform.Services.JsonMediaMigrationService.StartBackground ( string slug )

inlineprivate

Start Background 작업을 수행합니다.

매개변수

slug	slug에 사용할 `string` 값입니다.

JsonMediaMigrationService.cs 파일의 722 번째 라인에서 정의되었습니다.

    {
        lock (_runningGate)
        {
            if (!_runningSlugs.Add(slug))
            {
                return;
            }
        }
 
        _ = Task.Run(async () =>
        {
            try
            {
                await ProcessTenantSafeAsync(slug, CancellationToken.None).ConfigureAwait(false);
            }
            finally
            {
                lock (_runningGate)
                {
                    _runningSlugs.Remove(slug);
                }
            }
        });
    }

다음을 참조함 : _runningGate, _runningSlugs, ProcessTenantSafeAsync().

다음에 의해서 참조됨 : QueueTenantAsync().

이 함수 내부에서 호출하는 함수들에 대한 그래프입니다.:

이 함수를 호출하는 함수들에 대한 그래프입니다.:

멤버 데이터 문서화

◆ _cache

Dictionary<string, MediaMigrationTenantStatus>? WeddingPlatform.Services.JsonMediaMigrationService._cache

private

cache 값을 보관합니다.

JsonMediaMigrationService.cs 파일의 98 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : LoadAsync(), SaveAsync().

◆ _gate

readonly SemaphoreSlim WeddingPlatform.Services.JsonMediaMigrationService._gate = new(1, 1)

private

gate 값을 보관합니다.

JsonMediaMigrationService.cs 파일의 61 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : LoadAsync(), SaveAsync().

◆ _imageOptimization

readonly IImageOptimizationService WeddingPlatform.Services.JsonMediaMigrationService._imageOptimization

private

image Optimization 값을 보관합니다.

JsonMediaMigrationService.cs 파일의 52 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : JsonMediaMigrationService(), ProcessTenantAsync(), ResolveWritableOutputFormat().

◆ _jsonOptions

readonly JsonSerializerOptions WeddingPlatform.Services.JsonMediaMigrationService._jsonOptions = new() { WriteIndented = true }

private

json Options 값을 보관합니다.

JsonMediaMigrationService.cs 파일의 88 번째 라인에서 정의되었습니다.

88{ WriteIndented = true };

다음에 의해서 참조됨 : LoadAsync(), SaveAsync().

◆ _options

readonly WeddingOptions WeddingPlatform.Services.JsonMediaMigrationService._options

private

options 값을 보관합니다.

JsonMediaMigrationService.cs 파일의 34 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : JsonMediaMigrationService().

◆ _policyResolver

readonly IMediaQuotaPolicyResolver WeddingPlatform.Services.JsonMediaMigrationService._policyResolver

private

policy Resolver 값을 보관합니다.

JsonMediaMigrationService.cs 파일의 43 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : JsonMediaMigrationService(), ProcessTenantAsync().

◆ _runningGate

readonly object WeddingPlatform.Services.JsonMediaMigrationService._runningGate = new()

private

running Gate 값을 보관합니다.

JsonMediaMigrationService.cs 파일의 70 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : IsRunning(), StartBackground().

◆ _runningSlugs

readonly HashSet<string> WeddingPlatform.Services.JsonMediaMigrationService._runningSlugs = new(StringComparer.OrdinalIgnoreCase)

private

running Slugs 값을 보관합니다.

JsonMediaMigrationService.cs 파일의 79 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : IsRunning(), StartBackground().

◆ _tenants

readonly ITenantStore WeddingPlatform.Services.JsonMediaMigrationService._tenants

private

tenants 값을 보관합니다.

JsonMediaMigrationService.cs 파일의 25 번째 라인에서 정의되었습니다.

다음에 의해서 참조됨 : JsonMediaMigrationService(), ProcessTenantAsync().

속성 문서화

◆ StatusPath

string WeddingPlatform.Services.JsonMediaMigrationService.StatusPath

getprivate

Status Path 값을 가져옵니다.

JsonMediaMigrationService.cs 파일의 664 번째 라인에서 정의되었습니다.

    {
        get
        {
            var dataRoot = Path.GetDirectoryName(_options.ResolvedDataPath.TrimEnd(Path.DirectorySeparatorChar))
                ?? Path.Combine(AppContext.BaseDirectory, "App_Data");
            return Path.Combine(dataRoot, "media-migration-status.json");
        }
    }

다음에 의해서 참조됨 : LoadAsync(), SaveAsync().

이 클래스에 대한 문서화 페이지는 다음의 파일로부터 생성되었습니다.:

JsonMediaMigrationService.cs

Public 멤버 함수

속성

Private 멤버 함수

정적 Private 멤버 함수

Private 속성

상세한 설명

생성자 & 소멸자 문서화

◆ JsonMediaMigrationService()

멤버 함수 문서화

◆ BuildProgressMessage()

◆ GetAllAsync()

◆ GetOrCreate()

◆ GetTenantStatusAsync()

◆ IsRunning()

◆ LoadAsync()

◆ MarkFile()

◆ NormalizeFormat()

◆ ProcessTenantAsync()

◆ ProcessTenantSafeAsync()

◆ QueueTenantAsync()

◆ ResolveWritableOutputFormat()

◆ RetryTenantAsync()

◆ SaveAsync()

◆ StartBackground()

멤버 데이터 문서화

◆ _cache

◆ _gate

◆ _imageOptimization

◆ _jsonOptions

◆ _options

◆ _policyResolver

◆ _runningGate

◆ _runningSlugs

◆ _tenants

속성 문서화

◆ StatusPath