mirror of https://github.com/Xhofe/alist
test(aria2): init aria2 client
parent
3fe0a7bf6b
commit
2612cd7f1c
|
@ -5,6 +5,7 @@ import (
|
||||||
"github.com/alist-org/alist/v3/pkg/aria2/rpc"
|
"github.com/alist-org/alist/v3/pkg/aria2/rpc"
|
||||||
"github.com/alist-org/alist/v3/pkg/task"
|
"github.com/alist-org/alist/v3/pkg/task"
|
||||||
"github.com/pkg/errors"
|
"github.com/pkg/errors"
|
||||||
|
log "github.com/sirupsen/logrus"
|
||||||
"time"
|
"time"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -18,6 +19,11 @@ func InitAria2Client(uri string, secret string, timeout int) error {
|
||||||
return errors.Wrap(err, "failed to init aria2 client")
|
return errors.Wrap(err, "failed to init aria2 client")
|
||||||
}
|
}
|
||||||
client = c
|
client = c
|
||||||
|
version, err := client.GetVersion()
|
||||||
|
if err != nil {
|
||||||
|
return errors.Wrapf(err, "failed get aria2 version")
|
||||||
|
}
|
||||||
|
log.Infof("using aria2 version: %s", version.Version)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -0,0 +1,10 @@
|
||||||
|
package aria2
|
||||||
|
|
||||||
|
import "testing"
|
||||||
|
|
||||||
|
func TestConnect(t *testing.T) {
|
||||||
|
err := InitAria2Client("http://localhost:16800/jsonrpc", "secret", 3)
|
||||||
|
if err != nil {
|
||||||
|
t.Errorf("failed to init aria2: %+v", err)
|
||||||
|
}
|
||||||
|
}
|
Loading…
Reference in New Issue