mirror of
https://github.com/gomods/athens
synced 2026-02-09 17:38:10 +00:00
0e470d0294
* switch proxy to config file pull in single flight changes * changes for single-flight * intermediate stage. All tests passing. pkg still has env refs * remove all env references * delete config/env entirely * fix failing tests * create the config.toml file as part of dev setup * create config file only if it doesn't exist * update Dockerfiles to use config file * move composing elements to the top * verbose parameter naming * newline * add flag for config file path * update docs with config file flag * remove unnecessary nil check * use filepath.join * rename redis port to address * fix path.join * fix issues after merge * add vendor dir
57 lines
1.2 KiB
Go
57 lines
1.2 KiB
Go
package module
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/gobuffalo/envy"
|
|
"github.com/stretchr/testify/suite"
|
|
)
|
|
|
|
type DeleteTests struct {
|
|
suite.Suite
|
|
}
|
|
|
|
func TestDelete(t *testing.T) {
|
|
suite.Run(t, new(DeleteTests))
|
|
}
|
|
|
|
func (d *DeleteTests) SetupTest() {
|
|
envy.Set("ATHENS_TIMEOUT", "1")
|
|
}
|
|
|
|
func (d *DeleteTests) TearDownTest() {
|
|
envy.Set("ATHENS_TIMEOUT", "300")
|
|
}
|
|
|
|
func (d *DeleteTests) TestDeleteTimeout() {
|
|
r := d.Require()
|
|
|
|
err := Delete(context.Background(), "mx", "1.1.1", delWithTimeout, time.Second)
|
|
|
|
r.Error(err, "deleter returned at least one error")
|
|
r.Contains(err.Error(), "deleting mx.1.1.1.info failed: context deadline exceeded")
|
|
r.Contains(err.Error(), "deleting mx.1.1.1.zip failed: context deadline exceeded")
|
|
r.Contains(err.Error(), "deleting mx.1.1.1.mod failed: context deadline exceeded")
|
|
}
|
|
|
|
func (d *DeleteTests) TestDeleteError() {
|
|
r := d.Require()
|
|
|
|
err := Delete(context.Background(), "mx", "1.1.1", delWithErr, time.Second)
|
|
|
|
r.Error(err, "deleter returned at least one error")
|
|
r.Contains(err.Error(), "some err")
|
|
}
|
|
|
|
func delWithTimeout(ctx context.Context, path string) error {
|
|
time.Sleep(2 * time.Second)
|
|
return nil
|
|
}
|
|
|
|
func delWithErr(ctx context.Context, path string) error {
|
|
return errors.New("some err")
|
|
}
|