Trigger analyzer job to pick up the new dartdoc results. (#1306)

Author: isoos

app/bin/service/dartdoc.dart

@@ -10,6 +10,7 @@ import 'package:gcloud/db.dart';
 import 'package:gcloud/storage.dart';
 import 'package:logging/logging.dart';
 
+import 'package:pub_dartlang_org/analyzer/backend.dart';
 import 'package:pub_dartlang_org/history/backend.dart';
 import 'package:pub_dartlang_org/job/backend.dart';
 import 'package:pub_dartlang_org/job/job.dart';
@@ -95,6 +96,7 @@ void _workerMain(WorkerEntryMessage message) {
 Future _registerServices() async {
   registerDartdocMemcache(new DartdocMemcache(memcacheService));
 
+  registerAnalysisBackend(new AnalysisBackend(dbService));
   final Bucket storageBucket = await getOrCreateBucket(
       storageService, activeConfiguration.dartdocStorageBucketName);
   registerDartdocBackend(new DartdocBackend(dbService, storageBucket));

app/lib/dartdoc/dartdoc_runner.dart

@@ -12,6 +12,8 @@ import 'package:pana/src/utils.dart' show runProc;
 import 'package:path/path.dart' as p;
 import 'package:uuid/uuid.dart';
 
+import '../analyzer/backend.dart';
+import '../job/backend.dart';
 import '../job/job.dart';
 import '../shared/configuration.dart' show envConfig;
 import '../shared/urls.dart';
@@ -118,6 +120,21 @@ class DartdocJobProcessor extends JobProcessor {
 
     await dartdocBackend.removeObsolete(job.packageName, job.packageVersion);
 
+    // Trigger analyzer job to pick up the new dartdoc results.
+    final pkgStatus = await analysisBackend.getPackageStatus(
+        job.packageName, job.packageVersion);
+    if (pkgStatus.exists &&
+        !pkgStatus.isDiscontinued &&
+        !pkgStatus.isObsolete) {
+      await jobBackend.createOrUpdate(
+          JobService.analyzer,
+          job.packageName,
+          job.packageVersion,
+          job.isLatestStable,
+          job.packageVersionUpdated,
+          true);
+    }
+
     return hasContent ? JobStatus.success : JobStatus.failed;
   }