Added assertion

Author: SagarGi

steps/sampletest/context.go

@@ -18,5 +18,6 @@ func NewSampleTestFeatureContext(fc *featurecontext.FeatureContext, sc *godog.Sc
 
 func (f *SampleTestFeatureContext) Register(ctx *godog.ScenarioContext) {
 	// steps
-	ctx.Step(`^user "([^"]*)" shares a file "([^"]*)" with the following users concurrently$`, f.userSharesAFileWithTheFollowingUsers)
+	ctx.Step(`^user "([^"]*)" shares a file "([^"]*)" with the following users concurrently$`, f.UserSharesAFileWithTheFollowingUsers)
+	ctx.Step(`^the concurrent user sharing should have been successfull$`, f.TheConcurrentUserSharingShouldHaveBeenSuccessfull)
 }

steps/sampletest/steps.go

@@ -1,6 +1,7 @@
 package sampletest
 
 import (
+	"errors"
 	"fmt"
 	identityv1beta1 "github.com/cs3org/go-cs3apis/cs3/identity/user/v1beta1"
 	rpc "github.com/cs3org/go-cs3apis/cs3/rpc/v1beta1"
@@ -14,13 +15,15 @@ import (
 )
 
 type CreateShareResult struct {
-	ShareInfo *identityv1beta1.UserId                   // Replace with your actual type
-	Result    *collaborationv1beta1.CreateShareResponse // Replace with the actual response type
+	ResourceInformation *providerv1beta1.ResourceInfo
+	InformationOfSharee *identityv1beta1.UserId
 	Status    *rpc.Status
-	Err       error
+	Error error
 }
 
-func (f *SampleTestFeatureContext) userSharesAFileWithTheFollowingUsers(shareer string, resourceName string, sharees *godog.Table) error {
+var concurentResults []*CreateShareResult
+
+func (f *SampleTestFeatureContext) UserSharesAFileWithTheFollowingUsers(shareer string, resourceName string, sharees *godog.Table) error {
 	ctx, err := f.GetAuthContext(shareer)
 	if err != nil {
 		return err
@@ -104,7 +107,6 @@ func (f *SampleTestFeatureContext) userSharesAFileWithTheFollowingUsers(shareer
 
 	for _, UserId := range collectedShareesInfos {
 		wg.Add(1)
-
 		go func(UserId *identityv1beta1.UserId) {
 			defer wg.Done()
 			createShareResponse, err := f.Client.CreateShare(
@@ -126,29 +128,37 @@ func (f *SampleTestFeatureContext) userSharesAFileWithTheFollowingUsers(shareer
 			)
 
 			result := CreateShareResult{
-				ShareInfo: UserId,
-				Result:    createShareResponse,
-				Err:       err,
-			}
-
-			if err == nil && createShareResponse != nil {
-				result.Status = createShareResponse.GetStatus()
+				ResourceInformation: resourceInfo,
+				InformationOfSharee: UserId,
+				Status:    createShareResponse.GetStatus(),
+				Error: err,
 			}
 			resultChannel <- result
 
 		}(UserId)
 	}
-
 	wg.Wait()
 	close(resultChannel)
 
 	for result := range resultChannel {
-		if result.Err != nil {
-			fmt.Printf("Error for ShareInformation: %+v - %v\n", result.ShareInfo, result.Err)
-		} else {
-			fmt.Printf("Success for ShareInfo: %+v - Status: %s\n", result.ShareInfo, result.Status)
-		}
+		concurentResults = append(concurentResults, &CreateShareResult{
+			ResourceInformation: result.ResourceInformation,
+			InformationOfSharee: result.InformationOfSharee,
+			Status: result.Status,
+			Error:  result.Error,
+		})
 	}
 
 	return nil
 }
+
+func (f *SampleTestFeatureContext) TheConcurrentUserSharingShouldHaveBeenSuccessfull( ) error {
+	for _, concurentResult := range concurentResults {
+		if concurentResult.Status.Code != rpc.Code_CODE_OK || concurentResult.Error != nil {
+			err := errors.New("Could not create share for user with information " + concurentResult.InformationOfSharee.String() + " for the resource " + concurentResult.ResourceInformation.Name)
+			fmt.Println(err)
+		}
+	}
+	return nil
+}
+