Improve error handling

Signed-off-by: Jonathan Mezach <[email protected]>
rr-wfm · Oct 11, 2024 · 52bb7fb · 52bb7fb
1 parent 9f27f26
commit 52bb7fb
Showing 1 changed file with 19 additions and 19 deletions.
diff --git a/src/MSBuild.Sdk.SqlProj.Aspire/SqlProjectPublishService.cs b/src/MSBuild.Sdk.SqlProj.Aspire/SqlProjectPublishService.cs
@@ -21,29 +21,29 @@ public async Task PublishSqlProject(SqlProjectResource sqlProject, SqlServerData
  {
  var logger = _resourceLoggerService.GetLogger(sqlProject);
 
- var dacpacPath = sqlProject.GetDacpacPath();
- if (!File.Exists(dacpacPath))
+ try
  {
- logger.LogError("SQL Server Database project package not found at path {DacpacPath}.", dacpacPath);
- await _resourceNotificationService.PublishUpdateAsync(sqlProject,
- state => state with { State = new ResourceStateSnapshot("Failed", KnownResourceStateStyles.Error) });
- return;
- }
+ var dacpacPath = sqlProject.GetDacpacPath();
+ if (!File.Exists(dacpacPath))
+ {
+ logger.LogError("SQL Server Database project package not found at path {DacpacPath}.", dacpacPath);
+ await _resourceNotificationService.PublishUpdateAsync(sqlProject,
+ state => state with { State = new ResourceStateSnapshot("Failed", KnownResourceStateStyles.Error) });
+ return;
+ }
+
+ var connectionString = await target.ConnectionStringExpression.GetValueAsync(cancellationToken);
+ if (connectionString == null)
+ {
+ logger.LogError("Failed to retrieve connection string for target database {TargetDatabaseResourceName}.", target.Name);
+ await _resourceNotificationService.PublishUpdateAsync(sqlProject,
+ state => state with { State = new ResourceStateSnapshot("Failed", KnownResourceStateStyles.Error) });
+ return;
+ }
 
- var connectionString = await target.ConnectionStringExpression.GetValueAsync(cancellationToken);
- if (connectionString == null)
- {
- logger.LogError("Failed to retrieve connection string for target database {TargetDatabaseResourceName}.", target.Name);
  await _resourceNotificationService.PublishUpdateAsync(sqlProject,
- state => state with { State = new ResourceStateSnapshot("Failed", KnownResourceStateStyles.Error) });
- return;
- }
-
- await _resourceNotificationService.PublishUpdateAsync(sqlProject,
- state => state with { State = new ResourceStateSnapshot("Publishing", KnownResourceStateStyles.Info) });
+ state => state with { State = new ResourceStateSnapshot("Publishing", KnownResourceStateStyles.Info) });
 
- try
- {
  _deployer.Deploy(dacpacPath, connectionString, target.DatabaseName, logger, cancellationToken);
 
  await _resourceNotificationService.PublishUpdateAsync(sqlProject,