Admin tool to fix sha256 for a PackageVersion.

Author: isoos

app/lib/admin/actions/actions.dart

@@ -27,6 +27,7 @@ import 'package_reservation_create.dart';
 import 'package_reservation_delete.dart';
 import 'package_reservation_list.dart';
 import 'package_version_delete.dart';
+import 'package_version_fix_sha256.dart';
 import 'package_version_info.dart';
 import 'package_version_retraction.dart';
 import 'publisher_create.dart';
@@ -116,6 +117,7 @@ final class AdminAction {
     packageReservationDelete,
     packageReservationList,
     packageVersionDelete,
+    packageVersionFixSha256,
     packageVersionInfo,
     packageVersionRetraction,
     publisherCreate,

app/lib/package/tarball_storage.dart

@@ -3,11 +3,13 @@
 // BSD-style license that can be found in the LICENSE file.
 
 import 'dart:io';
+import 'dart:typed_data';
 
 import 'package:crypto/crypto.dart';
 import 'package:gcloud/storage.dart';
 import 'package:logging/logging.dart';
 import 'package:meta/meta.dart';
+import 'package:pub_dev/admin/actions/actions.dart';
 import 'package:pub_dev/package/api_export/exported_api.dart';
 import '../shared/datastore.dart';
 import '../shared/storage.dart';
@@ -317,6 +319,17 @@ class TarballStorage {
       archivesDeleted: deleteObjects.length,
     );
   }
+
+  /// Loads the bytes from the canonical archive for [package] [version].
+  Future<Uint8List> getCanonicalArchiveBytes(
+      String package, String version) async {
+    final objectName = tarballObjectName(package, version);
+    final info = await _canonicalBucket.tryInfo(objectName);
+    if (info == null) {
+      throw NotFoundException('Canonical archive not found.');
+    }
+    return await _canonicalBucket.readAsBytes(objectName);
+  }
 }
 
 class PublicBucketUpdateStat {

app/test/admin/package_version_actions_test.dart

@@ -3,6 +3,7 @@
 // BSD-style license that can be found in the LICENSE file.
 
 import 'package:_pub_shared/data/admin_api.dart';
+import 'package:gcloud/db.dart';
 import 'package:pub_dev/package/backend.dart';
 import 'package:test/test.dart';
 
@@ -59,5 +60,33 @@ void main() {
       final newLatest = await packageBackend.getLatestVersion('oxygen');
       expect(newLatest != latest, isTrue);
     });
+
+    testWithProfile('package-version-fix-sha256', fn: () async {
+      final latest = await packageBackend.getLatestVersion('oxygen');
+      final oldPv =
+          await packageBackend.lookupPackageVersion('oxygen', latest!);
+      oldPv!.sha256 = [0, 1, 2];
+      await dbService.commit(inserts: [oldPv]);
+
+      final api = createPubApiClient(authToken: siteAdminToken);
+      final result = await api.adminInvokeAction(
+        'package-version-fix-sha256',
+        AdminInvokeActionArguments(arguments: {
+          'package': 'oxygen',
+          'version': latest,
+        }),
+      );
+
+      expect(result.output, {
+        'package': 'oxygen',
+        'version': latest,
+        'before': {
+          'sha256': '000102',
+        },
+        'after': {
+          'sha256': hasLength(64),
+        },
+      });
+    });
   });
 }