Browse Source

用户ID从1开始,0为无效ID

pull/41/head
Sydonian 1 year ago
parent
commit
b90bc244db
2 changed files with 15 additions and 15 deletions
  1. +1
    -1
      sdks/imfs/imfs_test.go
  2. +14
    -14
      sdks/storage/storage_test.go

+ 1
- 1
sdks/imfs/imfs_test.go View File

@@ -32,7 +32,7 @@ func Test_Package(t *testing.T) {
URL: "http://localhost:7893", URL: "http://localhost:7893",
}) })


_, err := cli.PackageGetWithObjects(PackageGetWithObjectsInfos{UserID: 0, PackageID: 13})
_, err := cli.PackageGetWithObjects(PackageGetWithObjectsInfos{UserID: 1, PackageID: 13})
So(err, ShouldBeNil) So(err, ShouldBeNil)
}) })
} }

+ 14
- 14
sdks/storage/storage_test.go View File

@@ -24,7 +24,7 @@ func Test_PackageGet(t *testing.T) {


pkgName := uuid.NewString() pkgName := uuid.NewString()
upResp, err := cli.PackageUpload(PackageUploadReq{ upResp, err := cli.PackageUpload(PackageUploadReq{
UserID: 0,
UserID: 1,
BucketID: 1, BucketID: 1,
Name: pkgName, Name: pkgName,
Files: iterator.Array( Files: iterator.Array(
@@ -41,7 +41,7 @@ func Test_PackageGet(t *testing.T) {
So(err, ShouldBeNil) So(err, ShouldBeNil)


getResp, err := cli.PackageGet(PackageGetReq{ getResp, err := cli.PackageGet(PackageGetReq{
UserID: 0,
UserID: 1,
PackageID: upResp.PackageID, PackageID: upResp.PackageID,
}) })
So(err, ShouldBeNil) So(err, ShouldBeNil)
@@ -50,7 +50,7 @@ func Test_PackageGet(t *testing.T) {
So(getResp.Package.Name, ShouldEqual, pkgName) So(getResp.Package.Name, ShouldEqual, pkgName)


err = cli.PackageDelete(PackageDeleteReq{ err = cli.PackageDelete(PackageDeleteReq{
UserID: 0,
UserID: 1,
PackageID: upResp.PackageID, PackageID: upResp.PackageID,
}) })
So(err, ShouldBeNil) So(err, ShouldBeNil)
@@ -70,7 +70,7 @@ func Test_Object(t *testing.T) {


nodeAff := NodeID(2) nodeAff := NodeID(2)
upResp, err := cli.PackageUpload(PackageUploadReq{ upResp, err := cli.PackageUpload(PackageUploadReq{
UserID: 0,
UserID: 1,
BucketID: 1, BucketID: 1,
Name: uuid.NewString(), Name: uuid.NewString(),
NodeAffinity: &nodeAff, NodeAffinity: &nodeAff,
@@ -88,7 +88,7 @@ func Test_Object(t *testing.T) {
So(err, ShouldBeNil) So(err, ShouldBeNil)


// downFs, err := cli.ObjectDownload(ObjectDownloadReq{ // downFs, err := cli.ObjectDownload(ObjectDownloadReq{
// UserID: 0,
// UserID: 1,
// ObjectID: upResp.ObjectID, // ObjectID: upResp.ObjectID,
// }) // })
// So(err, ShouldBeNil) // So(err, ShouldBeNil)
@@ -99,7 +99,7 @@ func Test_Object(t *testing.T) {
// downFs.Close() // downFs.Close()


err = cli.PackageDelete(PackageDeleteReq{ err = cli.PackageDelete(PackageDeleteReq{
UserID: 0,
UserID: 1,
PackageID: upResp.PackageID, PackageID: upResp.PackageID,
}) })
So(err, ShouldBeNil) So(err, ShouldBeNil)
@@ -118,7 +118,7 @@ func Test_Storage(t *testing.T) {
} }


upResp, err := cli.PackageUpload(PackageUploadReq{ upResp, err := cli.PackageUpload(PackageUploadReq{
UserID: 0,
UserID: 1,
BucketID: 1, BucketID: 1,
Name: uuid.NewString(), Name: uuid.NewString(),
Files: iterator.Array( Files: iterator.Array(
@@ -135,14 +135,14 @@ func Test_Storage(t *testing.T) {
So(err, ShouldBeNil) So(err, ShouldBeNil)


_, err = cli.StorageLoadPackage(StorageLoadPackageReq{ _, err = cli.StorageLoadPackage(StorageLoadPackageReq{
UserID: 0,
UserID: 1,
PackageID: upResp.PackageID, PackageID: upResp.PackageID,
StorageID: 1, StorageID: 1,
}) })
So(err, ShouldBeNil) So(err, ShouldBeNil)


err = cli.PackageDelete(PackageDeleteReq{ err = cli.PackageDelete(PackageDeleteReq{
UserID: 0,
UserID: 1,
PackageID: upResp.PackageID, PackageID: upResp.PackageID,
}) })
So(err, ShouldBeNil) So(err, ShouldBeNil)
@@ -161,7 +161,7 @@ func Test_Cache(t *testing.T) {
} }


upResp, err := cli.PackageUpload(PackageUploadReq{ upResp, err := cli.PackageUpload(PackageUploadReq{
UserID: 0,
UserID: 1,
BucketID: 1, BucketID: 1,
Name: uuid.NewString(), Name: uuid.NewString(),
Files: iterator.Array( Files: iterator.Array(
@@ -178,14 +178,14 @@ func Test_Cache(t *testing.T) {
So(err, ShouldBeNil) So(err, ShouldBeNil)


_, err = cli.CacheMovePackage(CacheMovePackageReq{ _, err = cli.CacheMovePackage(CacheMovePackageReq{
UserID: 0,
UserID: 1,
PackageID: upResp.PackageID, PackageID: upResp.PackageID,
NodeID: 1, NodeID: 1,
}) })
So(err, ShouldBeNil) So(err, ShouldBeNil)


err = cli.PackageDelete(PackageDeleteReq{ err = cli.PackageDelete(PackageDeleteReq{
UserID: 0,
UserID: 1,
PackageID: upResp.PackageID, PackageID: upResp.PackageID,
}) })
So(err, ShouldBeNil) So(err, ShouldBeNil)
@@ -199,14 +199,14 @@ func Test_GetNodeInfos(t *testing.T) {
}) })
resp1, err := cli.PackageGetCachedNodes(PackageGetCachedNodesReq{ resp1, err := cli.PackageGetCachedNodes(PackageGetCachedNodesReq{
PackageID: 11, PackageID: 11,
UserID: 0,
UserID: 1,
}) })
So(err, ShouldBeNil) So(err, ShouldBeNil)
fmt.Printf("resp1: %v\n", resp1) fmt.Printf("resp1: %v\n", resp1)


resp2, err := cli.PackageGetLoadedNodes(PackageGetLoadedNodesReq{ resp2, err := cli.PackageGetLoadedNodes(PackageGetLoadedNodesReq{
PackageID: 11, PackageID: 11,
UserID: 0,
UserID: 1,
}) })
So(err, ShouldBeNil) So(err, ShouldBeNil)
fmt.Printf("resp2: %v\n", resp2) fmt.Printf("resp2: %v\n", resp2)


Loading…
Cancel
Save