report CrashReported instead

src/ApiService/ApiService/Functions/Jobs.cs

@@ -138,8 +138,9 @@ private async Task<HttpResponseData> Get(HttpRequestData req) {
             var tasks = _context.TaskOperations.SearchStates(jobId);
 
             IAsyncEnumerable<IJobTaskInfo> taskInfo = search.WithTasks ?? false ? tasks : tasks.Select(TaskToJobTaskInfo);
-            var hasBugs = await _context.AdoNotificationEntryOperations.WasNotfied(jobId);
-            return await RequestHandling.Ok(req, JobResponse.ForJob(job, taskInfo.ToEnumerable(), hasBugs));
+
+            var crashReported = await _context.JobCrashReportedOperations.CrashReported(jobId);
+            return await RequestHandling.Ok(req, JobResponse.ForJob(job, taskInfo.ToEnumerable(), crashReported));
         }
 
         var jobs = await _context.JobOperations.SearchState(states: search.State ?? Enumerable.Empty<JobState>()).ToListAsync();

src/ApiService/ApiService/Functions/QueueJobResult.cs

@@ -49,6 +49,10 @@ public async Async.Task Run([QueueTrigger("job-result", Connection = "AzureWebJo
         var jobResultType = data.Type;
         _log.LogInformation($"job result data type: {jobResultType}");
 
+        if (jobResultType == "CrashReported") {
+            var _result = await _context.JobCrashReportedOperations.ReportCrash(job.JobId, jr.TaskId);
+        }
+
         Dictionary<string, double> value;
         if (jr.Value.Count > 0) {
             value = jr.Value;

src/ApiService/ApiService/OneFuzzTypes/Model.cs

@@ -968,9 +968,12 @@ public record Job(
     StoredUserInfo? UserInfo,
     string? Error = null,
     DateTimeOffset? EndTime = null
-) : StatefulEntityBase<JobState>(State) {
+) : StatefulEntityBase<JobState>(State);
 
-}
+public record JobCrashReported(
+    [PartitionKey] Guid JobId,
+    [RowKey] Guid TaskId
+) : EntityBase;
 
 // This is like UserInfo but lacks the UPN:
 public record StoredUserInfo(Guid? ApplicationId, Guid? ObjectId);

src/ApiService/ApiService/OneFuzzTypes/Responses.cs

@@ -103,10 +103,10 @@ public record JobResponse(
     StoredUserInfo? UserInfo,
     [property: JsonPropertyName("Timestamp")] // must retain capital T for backcompat
     DateTimeOffset? Timestamp,
-    bool HasBugs
+    bool CrashReported
 // not including UserInfo from Job model
 ) : BaseResponse() {
-    public static JobResponse ForJob(Job j, IEnumerable<IJobTaskInfo>? taskInfo, bool hasBugs = false)
+    public static JobResponse ForJob(Job j, IEnumerable<IJobTaskInfo>? taskInfo, bool crashReported = false)
         => new(
             JobId: j.JobId,
             State: j.State,
@@ -116,7 +116,7 @@ public static JobResponse ForJob(Job j, IEnumerable<IJobTaskInfo>? taskInfo, boo
             TaskInfo: taskInfo,
             UserInfo: j.UserInfo,
             Timestamp: j.Timestamp,
-            HasBugs: hasBugs
+            CrashReported: crashReported
         );
     public DateTimeOffset? StartTime => EndTime is DateTimeOffset endTime ? endTime.Subtract(TimeSpan.FromHours(Config.Duration)) : null;
 }

src/ApiService/ApiService/Program.cs

@@ -199,6 +199,7 @@ public static async Async.Task Main() {
                 .AddScoped<ISubnet, Subnet>()
                 .AddScoped<IAutoScaleOperations, AutoScaleOperations>()
                 .AddScoped<IAdoNotificationEntryOperations, AdoNotificationEntryOperations>()
+                .AddScoped<IJobCrashReportedOperations, JobCrashReportedOperations>()
                 .AddSingleton<GraphServiceClient>(new GraphServiceClient(new DefaultAzureCredential()))
                 .AddSingleton<DependencyTrackingTelemetryModule>()
                 .AddSingleton<ICreds, Creds>()

src/ApiService/ApiService/onefuzzlib/JobCrashReported.cs

@@ -0,0 +1,28 @@
+using System.Threading.Tasks;
+using ApiService.OneFuzzLib.Orm;
+using Microsoft.Extensions.Logging;
+namespace Microsoft.OneFuzz.Service;
+
+public interface IJobCrashReportedOperations : IOrm<JobCrashReported> {
+    public Task<bool> CrashReported(Guid jobId);
+    public Task<OneFuzzResultVoid> ReportCrash(Guid jobId, Guid taskId);
+}
+
+public class JobCrashReportedOperations : Orm<JobCrashReported>, IJobCrashReportedOperations {
+    public JobCrashReportedOperations(ILogger<NsgOperations> logTracer, IOnefuzzContext context) : base(logTracer, context) {
+    }
+
+    public async Task<bool> CrashReported(Guid jobId) {
+        return await QueryAsync(Query.RowKey(jobId.ToString())).AnyAsync();
+    }
+
+    public async Task<OneFuzzResultVoid> ReportCrash(Guid jobId, Guid taskId) {
+
+        var result = await Update(new JobCrashReported(jobId, taskId));
+        if (!result.IsOk) {
+            return OneFuzzResultVoid.Error(ErrorCode.UNABLE_TO_UPDATE, "Failed to update job crash reported");
+        }
+
+        return OneFuzzResultVoid.Ok;
+    }
+}

src/ApiService/ApiService/onefuzzlib/OnefuzzContext.cs

@@ -50,6 +50,7 @@ public interface IOnefuzzContext {
     IGithubIssues GithubIssues { get; }
     IAdo Ado { get; }
     IAdoNotificationEntryOperations AdoNotificationEntryOperations { get; }
+    IJobCrashReportedOperations JobCrashReportedOperations =>;
 
     IFeatureManagerSnapshot FeatureManagerSnapshot { get; }
     IConfigurationRefresher ConfigurationRefresher { get; }
@@ -102,6 +103,7 @@ public OnefuzzContext(IServiceProvider serviceProvider) {
     public ITeams Teams => _serviceProvider.GetRequiredService<ITeams>();
     public IGithubIssues GithubIssues => _serviceProvider.GetRequiredService<IGithubIssues>();
     public IAdo Ado => _serviceProvider.GetRequiredService<IAdo>();
+    public IJobCrashReportedOperations JobCrashReportedOperations => _serviceProvider.GetRequiredService<IJobCrashReportedOperations>();
 
     public IFeatureManagerSnapshot FeatureManagerSnapshot => _serviceProvider.GetRequiredService<IFeatureManagerSnapshot>();
 

src/ApiService/IntegrationTests/JobsTests.cs

@@ -248,6 +248,6 @@ await Context.InsertAll(
         var response = BodyAs<JobResponse>(result);
         Assert.Equal(_jobId, response.JobId);
         Assert.NotNull(response.TaskInfo);
-        Assert.True(response.HasBugs);
+        Assert.True(response.CrashReported);
     }
 }

src/pytypes/onefuzztypes/models.py

@@ -761,7 +761,7 @@ class Job(BaseModel):
     task_info: Optional[List[Union[Task, JobTaskInfo]]]
     user_info: Optional[UserInfo]
     start_time: Optional[datetime] = None
-    has_bugs: Optional[bool] = None
+    crash_reported: Optional[bool] = None
 
 
 class NetworkConfig(BaseModel):