Exporting the per-package RSS/atom feed with the rest of exported APIs. (#8707)

Author: isoos

CHANGELOG.md

@@ -2,6 +2,7 @@ Important changes to data models, configuration, and migrations between each
 AppEngine version, listed here to ease deployment and troubleshooting.
 
 ## Next Release (replace with git tag when deployed)
+ * Note: after the release we should update the load balancer rules to also include the `/api/packages/<package>/feed.atom` URLs.
 
 ## `20250403t085600-all`
  * Bump runtimeVersion to `2025.04.01`.

app/lib/admin/actions/moderate_package.dart

@@ -79,6 +79,9 @@ Note: the action may take a longer time to complete as the public archive bucket
         return pkg;
       });
 
+      // make sure visibility cache is updated immediately
+      await purgePackageCache(package);
+
       // sync exported API(s)
       await apiExporter?.synchronizePackage(package, forceDelete: true);
 

app/lib/admin/actions/moderate_package_versions.dart

@@ -112,6 +112,9 @@ Set the moderated flag on a package version (updating the flag and the timestamp
         return v;
       });
 
+      // make sure visibility cache is updated immediately
+      await purgePackageCache(package);
+
       // sync exported API(s)
       await apiExporter?.synchronizePackage(package, forceDelete: true);
 

app/lib/frontend/handlers/atom_feed.dart

@@ -32,7 +32,7 @@ Future<shelf.Response> allPackagesAtomFeedhandler(shelf.Request request) async {
   );
 }
 
-/// Handles requests for `/packages/<package>/feed.atom`
+/// Handles requests for `/api/packages/<package>/feed.atom`
 Future<shelf.Response> packageAtomFeedhandler(
   shelf.Request request,
   String package,

app/lib/frontend/handlers/pubapi.client.dart

@@ -132,6 +132,13 @@ class PubApiClient {
     ));
   }
 
+  Future<List<int>> packageAtomFeed(String package) async {
+    return await _client.requestBytes(
+      verb: 'get',
+      path: '/api/packages/$package/feed.atom',
+    );
+  }
+
   Future<_i5.PublisherInfo> createPublisher(String publisherId) async {
     return _i5.PublisherInfo.fromJson(await _client.requestJson(
       verb: 'post',

app/lib/frontend/handlers/pubapi.dart

@@ -9,6 +9,7 @@ import 'package:_pub_shared/data/package_api.dart';
 import 'package:_pub_shared/data/publisher_api.dart';
 import 'package:_pub_shared/data/task_api.dart';
 import 'package:api_builder/api_builder.dart';
+import 'package:pub_dev/frontend/handlers/atom_feed.dart';
 import 'package:shelf/shelf.dart';
 import 'package:shelf_router/shelf_router.dart';
 
@@ -215,6 +216,11 @@ class PubApi {
   ) async =>
       await packageBackend.inviteUploader(package, invite);
 
+  /// Renders the Atom XML feed for the package.
+  @EndPoint.get('/api/packages/<package>/feed.atom')
+  Future<Response> packageAtomFeed(Request request, String package) =>
+      packageAtomFeedhandler(request, package);
+
   // ****
   // **** Publisher API
   // ****

app/lib/frontend/handlers/pubapi.g.dart

@@ -176,11 +176,6 @@ class PubSiteService {
   Future<Response> packageVersions(Request request, String package) =>
       packageVersionsListHandler(request, package);
 
-  /// Renders the Atom XML feed for the package.
-  @Route.get('/packages/<package>/feed.atom')
-  Future<Response> packageAtomFeed(Request request, String package) =>
-      packageAtomFeedhandler(request, package);
-
   @Route.get('/packages/<package>')
   Future<Response> package(Request request, String package) =>
       packageVersionHandlerHtml(request, package);

app/lib/frontend/handlers/routes.dart

@@ -244,6 +244,10 @@ final class ApiExporter {
           versionListing,
           forceWrite: forceWrite,
         );
+    await _api.package(package).feedAtomFile.write(
+          await buildPackageAtomFeedContent(package),
+          forceWrite: forceWrite,
+        );
   }
 
   /// Scan for updates from packages until [abort] is resolved, or [claim]