Test

Signed-off-by: lucklove <gnu.crazier@gmail.com>

cmd/mirror.go

@@ -140,14 +140,10 @@ func newMirrorIntroduceCmd() *cobra.Command {
 			// the privPath can point to a public key becase the Public method of KeyInfo works on both priv and pub key
 			privKey, err := loadPrivKey(privPath)
 			if err != nil {
-				// For test, should remove before merge
-				panic(err)
 				return err
 			}
 			pubKey, err := privKey.Public()
 			if err != nil {
-				// For test, should remove before merge
-				panic(err)
 				return err
 			}
 

pkg/repository/mirror.go

@@ -175,6 +175,7 @@ func (l *localFilesystem) Introduce(id, name string, key *v1manifest.KeyInfo) er
 		return err
 	}
 
+	panic("For test")
 	return nil
 }
 

pkg/repository/model/model.go

@@ -49,12 +49,10 @@ func (m *model) Introduce(id, name string, key *v1manifest.KeyInfo) error {
 
 	keyID, err := key.ID()
 	if err != nil {
-		// For test, should remove before merge
-		panic(err)
 		return err
 	}
 
-	return utils.RetryUntil(func() error {
+	err = utils.RetryUntil(func() error {
 		var indexFileVersion *v1manifest.FileVersion
 		if err := m.updateIndexManifest(initTime, func(im *v1manifest.Manifest) (*v1manifest.Manifest, error) {
 			signed := im.Signed.(*v1manifest.Index)
@@ -115,10 +113,15 @@ func (m *model) Introduce(id, name string, key *v1manifest.KeyInfo) error {
 			return err
 		}
 
-		return m.txn.Commit()
+		err = m.txn.Commit()
+		panic(err)
+		return err
 	}, func(err error) bool {
 		return err == store.ErrorFsCommitConflict && m.txn.ResetManifest() == nil
 	})
+
+	panic(err)
+	return err
 }
 
 // Publish implements Model

pkg/repository/store/txn.go

@@ -156,6 +156,7 @@ func (t *localTxn) Stat(filename string) (os.FileInfo, error) {
 
 func (t *localTxn) Commit() error {
 	if err := t.store.lock(); err != nil {
+		panic(err)
 		return err
 	}
 	defer t.store.unlock()