samples.go

package main

import (
	"crypto/sha1"
	"encoding/hex"
	"encoding/json"
	"fmt"
	"io/ioutil"
	"multiorgledger/blockchain/invoke"
	"multiorgledger/blockchain/org"
	"multiorgledger/chaincode/model"
	"sync"
)

type AllUsers struct {
	Users []model.User `json:"users"`
}

func SampleUsers() {

	var org string
	fmt.Println("Enter the Org - ( org1, org2, org3, org4) ")
	fmt.Scanln(&org)

	byteValue, _ := ioutil.ReadFile("samples/" + org + ".json")

	users := []model.User{}

	v := []byte(byteValue)

	err := json.Unmarshal(v, &users)

	if err != nil {
		fmt.Println("unable to convert the result to object: %v", err)
	}

	threads := len(users)
	var wg sync.WaitGroup

	respond := make(chan string, threads)
	wg.Add(threads)

	for i := 0; i < len(users); i++ {

		email := users[i].Email
		name := users[i].Name
		mobile := users[i].Mobile
		age := users[i].Age
		salary := users[i].Salary
		owner := users[i].Owner
		role := users[i].Role

		go createUser(respond, &wg, email, name, age, mobile, salary, owner, role)
	}

	wg.Wait()
	close(respond)

	for queryResp := range respond {
		fmt.Println("Query Response: " + queryResp)
	}
}

func hash(s string) string {
	h := sha1.New()
	h.Write([]byte(s))
	sha1_hash := hex.EncodeToString(h.Sum(nil))

	return sha1_hash
}

func createUser(respond chan<- string, wg *sync.WaitGroup, email, name, age, mobile, salary, owner, role string) {

	fmt.Println(" Create User ---- " + email + " ---- Org = " + owner)

	password := hash("Test@#123")

	setup := &org.OrgSetup{}
	_ = setup.Init(false)

	Org, err := setup.InitializeOrg(owner)
	if err != nil {
		defer wg.Done()
		respond <- fmt.Sprintf("Web ----- Unable to initialize org  - %s", err.Error())
	} else {

		orgUser, err := Org.RegisterUserWithCA(owner, email, password, role)

		orgInvoke := invoke.OrgInvoke{
			User: orgUser,
		}

		if err != nil {

			defer wg.Done()
			respond <- fmt.Sprintf("Web Error ----->>> Unable to Register Error Msg  - %s", err.Error())

		} else {

			err := orgInvoke.InvokeCreateUser(name, age, mobile, salary)

			defer wg.Done()
			if err != nil {
				respond <- fmt.Sprintf("failed to invoke user  - %s", err.Error())
			} else {
				respond <- fmt.Sprintf("User Created Successfully  - %s", email)
			}

		}
	}
}