mirror of
https://github.com/gomods/athens
synced 2026-02-03 11:00:32 +00:00
9df207561d
* Add .info to upload payload everywhere else as well + Upload payload includes Info + CLI uploads `version.info` as blob to storage + Getter and Saver methods updated for all storages implemented + Migration updated to include Info column + Tests no longer check RevInfo, now checking for Info same as Zip + Updated docs * newline in .fizz * change RevInfo.Info to []byte + change to []byte instead of io.Reader + adjust tests to check for info byte contents directly + add error check for minio client GetObject `pkg/storage/minio/getter.go`
37 lines
838 B
Go
37 lines
838 B
Go
package mongo
|
|
|
|
import (
|
|
"io/ioutil"
|
|
)
|
|
|
|
func (m *MongoTests) TestGetSaveListRoundTrip() {
|
|
r := m.Require()
|
|
m.storage.Save(module, version, mod, zip, info)
|
|
listedVersions, err := m.storage.List(module)
|
|
r.NoError(err)
|
|
r.Equal(1, len(listedVersions))
|
|
retVersion := listedVersions[0]
|
|
r.Equal(version, retVersion)
|
|
gotten, err := m.storage.Get(module, version)
|
|
r.NoError(err)
|
|
defer gotten.Zip.Close()
|
|
// TODO: test the time
|
|
r.Equal(gotten.Mod, mod)
|
|
zipContent, err := ioutil.ReadAll(gotten.Zip)
|
|
r.NoError(err)
|
|
r.Equal(zipContent, zip)
|
|
r.Equal(gotten.Info, info)
|
|
}
|
|
|
|
func (m *MongoTests) TestNewMongoStorage() {
|
|
r := m.Require()
|
|
url := "mongodb://127.0.0.1:27017"
|
|
getterSaver := NewStorage(url)
|
|
getterSaver.Connect()
|
|
|
|
r.NotNil(getterSaver.c)
|
|
r.NotNil(getterSaver.d)
|
|
r.NotNil(getterSaver.s)
|
|
r.Equal(getterSaver.url, url)
|
|
}
|