How to use loadDB method of state Package

Best Syzkaller code snippet using state.loadDB

repo_drones.go

Source:repo_drones.go Github

copy

Full Screen

...36 return &repoDrones{DBUserLocation: svcConf.StoreDBPath}37}38// region ======== METHODS ===============================================================39func (r *repoDrones) IsPopulated() bool {40 db, err := r.loadDB()41 if err != nil {42 return false43 }44 defer db.Close()45 return isPopulated(db)46}47// PopulateDB Populate the database with the initial information only if "IsPopulated" is48// false or does not exist49//nolint:gocognit50func (r *repoDrones) PopulateDB() error {51 db, err := r.loadDB()52 if err != nil {53 return err54 }55 defer db.Close()56 // If it is already populated, the execution of the function stops57 if isPopulated(db) {return errors.New(schema.ErrBuntdbPopulated)}58 var fakeUsersList = fakeUsers()59 var fakeDronesList = fakeDrones()60 var fakeMedicationsList = fakeMedications()61 log.Println("writing users in database")62 err = db.Update(func(tx *buntdb.Tx) error {63 for i := 0; i < len(fakeUsersList); i++ {64 res, err := jsoniter.MarshalToString(fakeUsersList[i])65 log.Printf("user #%d: %s", i, res)66 if err != nil {67 return err68 }69 _, _, err = tx.Set(strconv.Itoa(i), res, nil)70 if err != nil {71 return err72 }73 }74 return nil75 })76 if err != nil {77 return err78 }79 log.Println("successfully added users")80 log.Println("writing drones in database")81 err = db.Update(func(tx *buntdb.Tx) error {82 for i := 0; i < len(fakeDronesList); i++ {83 res, err := jsoniter.MarshalToString(fakeDronesList[i])84 if err != nil {85 return err86 }87 // add drone value with "serialnumber" key88 _, _, err = tx.Set("drone:"+fakeDronesList[i].SerialNumber, res, nil)89 if err != nil {90 return err91 }92 }93 return nil94 })95 if err != nil {96 return err97 }98 log.Println("successfully added drones")99 log.Println("writing medications in database")100 err = db.Update(func(tx *buntdb.Tx) error {101 for i := 0; i < len(fakeMedicationsList); i++ {102 res, err := jsoniter.MarshalToString(fakeMedicationsList[i])103 if err != nil {104 return err105 }106 // add drone value with "code" key107 _, _, err = tx.Set("med:"+fakeMedicationsList[i].Code, res, nil)108 if err != nil {109 return err110 }111 }112 return nil113 })114 if err != nil {115 return err116 }117 log.Println("successfully added medications")118 // set IsPopulated to true119 err = db.Update(func(tx *buntdb.Tx) error {120 res, err := jsoniter.MarshalToString(dto.ConfigDB{IsPopulated: true})121 if err != nil {122 return err123 }124 _, _, err = tx.Set("config", res, nil)125 return err126 })127 if err != nil {128 return err129 }130 log.Println("'IsPopulated' has been set to true")131 return nil132}133// GetUser get the user from the DB134func (r *repoDrones) GetUser(field string, filterOptional ...bool) (*dto.User, error) {135 filter := false136 if len(filterOptional) > 0 {137 filter = filterOptional[0]138 }139 user := dto.User{}140 // Open the data.db file. It will be created if it doesn't exist.141 db, err := buntdb.Open(r.DBUserLocation)142 if err != nil {143 return nil, err144 }145 defer db.Close()146 err = db.CreateIndex("username", "*", buntdb.IndexString)147 if err != nil {148 return nil, err149 }150 err = db.View(func(tx *buntdb.Tx) error {151 if filter {152 err := tx.Ascend("username", func(key, value string) bool {153 if strings.Contains(value, field) {154 err := jsoniter.UnmarshalFromString(value, &user)155 if err != nil {156 return false157 }158 return false159 }160 return true161 })162 return err163 }164 // filter = false165 //value, err := tx.Get(field)166 //if err != nil {167 // return err168 //}169 //err = jsoniter.UnmarshalFromString(value, &user)170 //if err != nil {171 // return err172 //}173 return nil174 })175 if err != nil {176 return nil, err177 }178 return &user, nil179}180// GetUsers return a list of dto.User181func (r *repoDrones) GetUsers() (*[]dto.User, error) {182 // Open the data.db file. It will be created if it doesn't exist.183 db, err := buntdb.Open(r.DBUserLocation)184 if err != nil {185 return nil, err186 }187 defer db.Close()188 user := dto.User{}189 var list []dto.User190 err = db.CreateIndex("username", "*", buntdb.IndexString)191 if err != nil {192 return nil, err193 }194 err = db.View(func(tx *buntdb.Tx) error {195 tx.Ascend("username", func(key, value string) bool {196 err = jsoniter.UnmarshalFromString(value, &user)197 if err == nil {198 list = append(list, user)199 }200 return err == nil201 })202 return nil203 })204 if err != nil {205 return nil, err206 }207 return &list, nil208}209// region ======== Drones ======================================================210// GetDrone get a specific drone211func (r *repoDrones) GetDrone(serialNumber string) (*dto.Drone, error) {212 db, err := r.loadDB()213 if err != nil {214 return nil, err215 }216 defer db.Close()217 drone := dto.Drone{}218 db.CreateIndex("drone_state", "drone:*", buntdb.IndexJSON("batteryCapacity"))219 err = db.View(func(tx *buntdb.Tx) error {220 value, err := tx.Get("drone:"+serialNumber)221 if err != nil{222 return err223 }224 err = jsoniter.UnmarshalFromString(value, &drone)225 if err != nil{226 return err227 }228 return nil229 })230 if err != nil {231 return nil, err232 }233 return &drone, nil234}235// GetDrones A read-only transaction, return drones in db236// allows filtering by a specific string field237func (r *repoDrones) GetDrones(filter string) (*[]dto.Drone, error) {238 db, err := r.loadDB()239 if err != nil {240 return nil, err241 }242 defer db.Close()243 drone := dto.Drone{}244 dronesList := make([]dto.Drone, 0)245 // custom index: sort drones descending by battery capacity246 db.CreateIndex("drone_state", "drone:*", buntdb.IndexJSON("batteryCapacity"))247 err = db.View(func(tx *buntdb.Tx) error {248 if filter != "" {249 err := tx.Descend("drone_state", func(key, value string) bool {250 if strings.Contains(value, filter) {251 err = jsoniter.UnmarshalFromString(value, &drone)252 if err == nil {253 dronesList = append(dronesList, drone)254 }255 return err == nil256 }257 return true258 })259 return err260 }261 err := tx.Descend("drone_state", func(key, value string) bool {262 err = jsoniter.UnmarshalFromString(value, &drone)263 if err == nil {264 dronesList = append(dronesList, drone)265 }266 return err == nil267 })268 return err269 })270 if err != nil {271 return nil, err272 }273 return &dronesList, nil274}275func (r *repoDrones) RegisterDrone(drone *dto.Drone) error {276 db, err := r.loadDB()277 if err != nil {278 return err279 }280 defer db.Close()281 log.Printf("writing the drone '%s' in database", drone.SerialNumber)282 err = db.Update(func(tx *buntdb.Tx) error {283 res, err := jsoniter.MarshalToString(drone)284 if err != nil {285 return err286 }287 _, _, err = tx.Set("drone:"+drone.SerialNumber, res, nil)288 if err != nil {289 return err290 }291 return nil292 })293 if err != nil {294 return err295 }296 log.Println("successfully added drone")297 return nil298}299// CheckingLoadedMedicationsItems checking loaded medication items for a given drone300func (r *repoDrones) CheckingLoadedMedicationsItems(serialNumber string) (*[]string, error) {301 db, err := r.loadDB()302 if err != nil {303 return nil, err304 }305 defer db.Close()306 // medications id slice loaded by the drone307 loadedMeds := make([]string, 0)308 db.CreateIndex("loaded_medications", "loaded_medications:*", buntdb.IndexString)309 err = db.View(func(tx *buntdb.Tx) error {310 value, err := tx.Get("loaded_medications:"+serialNumber)311 if err != nil{312 return err313 }314 err = jsoniter.UnmarshalFromString(value, &loadedMeds)315 if err != nil{316 return err317 }318 return nil319 })320 if err != nil {321 return nil, err322 }323 return &loadedMeds, nil324}325func (r *repoDrones) LoadMedicationItemsADrone(drone *dto.Drone, medicationItemIDs []interface{}) error {326 db, err := r.loadDB()327 if err != nil {328 return err329 }330 defer db.Close()331 // begin: validating medication item IDs332 medication := dto.Medication{}333 medicationIdsRealMap := make(map[string]float64)334 db.CreateIndex("medication_id", "med:*", buntdb.IndexJSON("weight"))335 err = db.View(func(tx *buntdb.Tx) error {336 err := tx.Descend("medication_id", func(key, value string) bool {337 err = jsoniter.UnmarshalFromString(value, &medication)338 if err == nil {339 medicationIdsRealMap[medication.Code] = medication.Weight340 }341 return err == nil342 })343 return err344 })345 if err != nil {346 return err347 }348 // to guarantee non-repeated id349 medicationItemIDs = lib.Unique(medicationItemIDs)350 // compares the request IDs (medicationItemIDs) with the collection obtained from the database (medicationIdsRealMap)351 // also returns the total weight352 packedTotalWeight, allIDValid := thereAreAll(medicationIdsRealMap, medicationItemIDs)353 if !allIDValid {354 return fmt.Errorf("at least one of the medication items does not exist")355 }356 // prevent the drone from being loaded with more weight that it can carry357 if packedTotalWeight > drone.WeightLimit {358 return schema.ErrDroneMaximumLoadWeightExceeded359 }360 // end: validating medication item IDs361 log.Printf("loading a drone '%s' with medication items: %s", drone.SerialNumber, medicationItemIDs)362 err = db.Update(func(tx *buntdb.Tx) error {363 res, err := jsoniter.MarshalToString(medicationItemIDs)364 if err != nil {365 return err366 }367 _, _, err = tx.Set("loaded_medications:"+drone.SerialNumber, res, nil)368 if err != nil {369 return err370 }371 return nil372 })373 if err != nil {374 return err375 }376 log.Println("successfully loaded medication items")377 return nil378}379func (r *repoDrones) ExistDrone(serialNumber string) error {380 db, err := r.loadDB()381 if err != nil {382 return err383 }384 defer db.Close()385 err = db.View(func(tx *buntdb.Tx) error {386 _, err := tx.Get("drone:"+serialNumber)387 if err != nil {388 return err389 }390 return nil391 })392 // Getting non-existent values will cause an ErrNotFound error.393 if err != nil {394 return err395 }396 return nil397}398// endregion ======== Drones ======================================================399// region ======== Medications ======================================================400func (r *repoDrones) GetMedications() (*[]dto.Medication, error) {401 db, err := r.loadDB()402 if err != nil {403 return nil, err404 }405 defer db.Close()406 medication := dto.Medication{}407 medicationsList := make([]dto.Medication, 0)408 // custom index: sort medications descending by weight409 db.CreateIndex("medication_state", "med:*", buntdb.IndexJSON("weight"))410 err = db.View(func(tx *buntdb.Tx) error {411 err := tx.Descend("medication_state", func(key, value string) bool {412 err = jsoniter.UnmarshalFromString(value, &medication)413 if err == nil {414 medicationsList = append(medicationsList, medication)415 }416 return err == nil417 })418 return err419 })420 if err != nil {421 return nil, err422 }423 return &medicationsList, nil424}425// endregion ======== Medications ======================================================426// region ======== PRIVATE AUX ===========================================================427func (r *repoDrones) loadDB() (*buntdb.DB, error) {428 log.Println("Load DB ", r.DBUserLocation)429 // Open the data.db file. It will be created if it doesn't exist.430 db, err := buntdb.Open(r.DBUserLocation)431 if err != nil {432 log.Fatal(err)433 return nil, err434 }435 return db, nil436}437func isPopulated(db *buntdb.DB) bool {438 log.Println("checking if StoreDB has already been populated")439 configDB := dto.ConfigDB{}440 db.CreateIndex("config", "config", buntdb.IndexString)441 err := db.View(func(tx *buntdb.Tx) error {...

Full Screen

Full Screen

snapshot.go

Source:snapshot.go Github

copy

Full Screen

1package server2import (3 "fmt"4 "io"5 "os"6 "path/filepath"7 "strings"8 "github.com/NPC-Chain/npcchub/codec"9 "github.com/spf13/cobra"10 "github.com/spf13/viper"11 bc "github.com/tendermint/tendermint/blockchain"12 "github.com/tendermint/tendermint/consensus"13 tmcli "github.com/tendermint/tendermint/libs/cli"14 tmsm "github.com/tendermint/tendermint/state"15 "github.com/tendermint/tendermint/types"16 dbm "github.com/tendermint/tm-db"17)18const flagTmpDir = "tmp-dir"19const pathSeparator = string(os.PathSeparator)20// SnapshotCmd delete historical block data and index data21func SnapshotCmd(ctx *Context, cdc *codec.Codec, appReset AppReset) *cobra.Command {22 cmd := &cobra.Command{23 Use: "snapshot",24 Short: "snapshot the latest information and drop the others",25 RunE: func(cmd *cobra.Command, args []string) error {26 defer func() {27 if r := recover(); r != nil {28 err := r.(error)29 ctx.Logger.Error("snapshot file is created failed", "err", err.Error())30 }31 }()32 home := viper.GetString(tmcli.HomeFlag)33 emptyState, err := isEmptyState(home)34 if err != nil || emptyState {35 ctx.Logger.Error("State is not initialized")36 return nil37 }38 targetDir := viper.GetString(flagTmpDir)39 if len(targetDir) == 0 {40 targetDir = filepath.Join(home, "data.bak")41 }42 dataDir := filepath.Join(home, "data")43 if err = snapshot(ctx, cdc, dataDir, targetDir, appReset); err != nil {44 _ = os.RemoveAll(targetDir)45 ctx.Logger.Error("snapshot file is created failed")46 return err47 }48 ctx.Logger.Info("snapshot file is created successful", "location", targetDir)49 return nil50 },51 }52 cmd.Flags().String(flagTmpDir, "", "Snapshot file storage directory")53 return cmd54}55func loadDb(name, path string) *dbm.GoLevelDB {56 db, err := dbm.NewGoLevelDB(name, path)57 if err != nil {58 panic(err)59 }60 return db61}62func snapshot(ctx *Context, cdc *codec.Codec, dataDir, targetDir string, appReset AppReset) error {63 blockDB := loadDb("blockstore", dataDir)64 blockStore := bc.NewBlockStore(blockDB)65 stateDB := loadDb("state", dataDir)66 state := tmsm.LoadState(stateDB)67 defer func() {68 blockDB.Close()69 stateDB.Close()70 }()71 if blockStore.Height() != state.LastBlockHeight {72 if err := reset(ctx, appReset, state.LastBlockHeight); err != nil {73 return err74 }75 }76 //save local current block and flush disk77 snapshotBlock(blockStore, targetDir, state.LastBlockHeight)78 //save local current block height state79 snapshotState(cdc, stateDB, targetDir)80 //save local current block height consensus data81 snapshotCsWAL(ctx, dataDir, targetDir, state.LastBlockHeight)82 //copy application83 appDir := filepath.Join(dataDir, "application.db")84 appTargetDir := filepath.Join(targetDir, "application.db")85 if err := copyDir(appDir, appTargetDir); err != nil {86 return err87 }88 //copy evidence.db89 evidenceDir := filepath.Join(dataDir, "evidence.db")90 evidenceTargetDir := filepath.Join(targetDir, "evidence.db")91 return copyDir(evidenceDir, evidenceTargetDir)92}93func snapshotState(cdc *codec.Codec, tmDB *dbm.GoLevelDB, targetDir string) {94 targetDb := loadDb("state", targetDir)95 defer targetDb.Close()96 state := tmsm.LoadState(tmDB)97 saveValidatorsInfo(cdc, tmDB, targetDb, state.LastBlockHeight)98 saveConsensusParamsInfo(cdc, tmDB, targetDb, state.LastBlockHeight)99 tmsm.SaveState(targetDb, state)100}101func snapshotBlock(originStore *bc.BlockStore, targetDir string, height int64) int64 {102 targetDb := loadDb("blockstore", targetDir)103 defer targetDb.Close()104 bsj := bc.BlockStoreStateJSON{Height: height - 1}105 bsj.Save(targetDb)106 targetStore := bc.NewBlockStore(targetDb)107 block := originStore.LoadBlock(height)108 seenCommit := originStore.LoadSeenCommit(height)109 partSet := block.MakePartSet(types.BlockPartSizeBytes)110 targetStore.SaveBlock(block, partSet, seenCommit)111 return height112}113func snapshotCsWAL(ctx *Context, home, targetDir string, height int64) {114 walTargetDir := filepath.Join(targetDir, "cs.wal", "wal")115 targetWAL, err := consensus.NewWAL(walTargetDir)116 walSourceDir := filepath.Join(home, "cs.wal", "wal")117 sourceWAL, err := consensus.NewWAL(walSourceDir)118 if err != nil {119 ctx.Logger.Info("failed to open WAL for consensus state", "err", err.Error())120 return121 }122 gr, found, err := sourceWAL.SearchForEndHeight(height, &consensus.WALSearchOptions{IgnoreDataCorruptionErrors: true})123 if err != nil || !found {124 ctx.Logger.Info(fmt.Sprintf("cannot replay height %d. WAL does not contain #ENDHEIGHT for %d", height, height-1))125 return126 }127 defer func() {128 if err = gr.Close(); err != nil {129 ctx.Logger.Info("resource release failed", "err", err.Error())130 return131 }132 }()133 var msg *consensus.TimedWALMessage134 dec := consensus.NewWALDecoder(gr)135 for {136 msg, err = dec.Decode()137 if err == io.EOF {138 break139 } else if consensus.IsDataCorruptionError(err) {140 ctx.Logger.Info("data has been corrupted in last height %d of consensus WAL", height)141 return142 } else if err != nil {143 ctx.Logger.Info("decode WALMessage failed", "err", err.Error())144 return145 }146 if err := targetWAL.Write(msg.Msg); err != nil {147 ctx.Logger.Info("write data to file failed", "err", err.Error())148 return149 }150 }151 err = targetWAL.WriteSync(consensus.EndHeightMessage{Height: height})152 if err != nil {153 ctx.Logger.Info("write data to file failed", "err", err.Error())154 return155 }156}157func copyDir(srcPath string, destPath string) error {158 if _, err := os.Stat(srcPath); err != nil {159 return err160 }161 return filepath.Walk(srcPath, func(path string, f os.FileInfo, err error) error {162 if f == nil {163 return err164 }165 if f.IsDir() {166 return nil167 }168 path = strings.Replace(path, fmt.Sprintf("\\%s", pathSeparator), pathSeparator, -1)169 destNewPath := strings.Replace(path, srcPath, destPath, -1)170 _, err = copyFile(path, destNewPath)171 return err172 })173}174func copyFile(src, dest string) (w int64, err error) {175 srcFile, err := os.Open(src)176 defer srcFile.Close()177 if err != nil {178 return179 }180 destSplitPathDirs := strings.Split(dest, pathSeparator)181 destSplitPath := ""182 for index, dir := range destSplitPathDirs {183 if index < len(destSplitPathDirs)-1 {184 destSplitPath = destSplitPath + dir + pathSeparator185 if b, _ := pathExists(destSplitPath); b == false {186 err := os.Mkdir(destSplitPath, os.ModePerm)187 if err != nil {188 return 0, err189 }190 }191 }192 }193 dstFile, err := os.Create(dest)194 if err != nil {195 return196 }197 defer dstFile.Close()198 return io.Copy(dstFile, srcFile)199}200func pathExists(path string) (bool, error) {201 _, err := os.Stat(path)202 if err == nil {203 return true, nil204 }205 if os.IsNotExist(err) {206 return false, nil207 }208 return false, err209}210func loadValidatorsInfo(cdc *codec.Codec, db dbm.DB, height int64) *tmsm.ValidatorsInfo {211 buf := db.Get(calcValidatorsKey(height))212 if len(buf) == 0 {213 return nil214 }215 v := new(tmsm.ValidatorsInfo)216 err := cdc.UnmarshalBinaryBare(buf, v)217 if err != nil {218 return v219 }220 return v221}222func saveValidatorsInfo(cdc *codec.Codec, originDb, targetDb dbm.DB, height int64) {223 valInfo := loadValidatorsInfo(cdc, originDb, height)224 if valInfo.LastHeightChanged > height {225 panic("LastHeightChanged cannot be greater than ValidatorsInfo height")226 }227 if valInfo.ValidatorSet == nil {228 valInfo = loadValidatorsInfo(cdc, originDb, valInfo.LastHeightChanged)229 }230 targetDb.Set(calcValidatorsKey(valInfo.LastHeightChanged), valInfo.Bytes())231}232func loadConsensusParamsInfo(cdc *codec.Codec, db dbm.DB, height int64) *tmsm.ConsensusParamsInfo {233 buf := db.Get(calcConsensusParamsKey(height))234 if len(buf) == 0 {235 return nil236 }237 paramsInfo := new(tmsm.ConsensusParamsInfo)238 err := cdc.UnmarshalBinaryBare(buf, paramsInfo)239 if err != nil {240 return paramsInfo241 }242 return paramsInfo243}244func saveConsensusParamsInfo(cdc *codec.Codec, originDb, targetDb dbm.DB, height int64) {245 consensusParamsInfo := loadConsensusParamsInfo(cdc, originDb, height)246 if consensusParamsInfo.ConsensusParams.Equals(&types.ConsensusParams{}) {247 consensusParamsInfo = loadConsensusParamsInfo(cdc, originDb, consensusParamsInfo.LastHeightChanged)248 }249 paramsInfo := &tmsm.ConsensusParamsInfo{250 LastHeightChanged: consensusParamsInfo.LastHeightChanged,251 }252 targetDb.Set(calcConsensusParamsKey(consensusParamsInfo.LastHeightChanged), paramsInfo.Bytes())253}254func calcValidatorsKey(height int64) []byte {255 return []byte(fmt.Sprintf("validatorsKey:%v", height))256}257func calcConsensusParamsKey(height int64) []byte {258 return []byte(fmt.Sprintf("consensusParamsKey:%v", height))259}260func reset(ctx *Context, appReset AppReset, height int64) error {261 cfg := ctx.Config262 home := cfg.RootDir263 traceWriterFile := viper.GetString(flagTraceStore)264 db, err := openDB(home)265 if err != nil {266 return err267 }268 traceWriter, err := openTraceWriter(traceWriterFile)269 if err != nil {270 return err271 }272 if err := appReset(ctx, ctx.Logger, db, traceWriter, height); err != nil {273 return err274 }275 return nil276}...

Full Screen

Full Screen

loadDB

Using AI Code Generation

copy

Full Screen

1import (2type SimpleChaincode struct {3}4func main() {5 err := shim.Start(new(SimpleChaincode))6 if err != nil {7 fmt.Printf("Error starting Simple chaincode: %s", err)8 }9}10func (t *SimpleChaincode) Init(stub shim.ChaincodeStubInterface) peer.Response {11 return shim.Success(nil)12}13func (t *SimpleChaincode) Invoke(stub shim.ChaincodeStubInterface) peer.Response {14 function, args := stub.GetFunctionAndParameters()15 if function == "put" {16 return t.put(stub, args)17 }18 return shim.Error("Invalid invoke function name. Expecting \"put\"")19}20func (t *SimpleChaincode) put(stub shim.ChaincodeStubInterface, args []string) peer.Response {21 if len(args) != 2 {22 return shim.Error("Incorrect number of arguments. Expecting 2")23 }24 err := stub.PutState(args[0], []byte(args[1]))25 if err != nil {26 return shim.Error(err.Error())27 }28 return shim.Success(nil)29}30import (31type SimpleChaincode struct {32}33func main() {34 err := shim.Start(new(SimpleChaincode))35 if err != nil {36 fmt.Printf("Error starting Simple chaincode: %s", err)37 }38}39func (t *SimpleChaincode) Init(stub shim.ChaincodeStubInterface) peer.Response {40 return shim.Success(nil)41}42func (t *SimpleChaincode) Invoke(stub shim.ChaincodeStubInterface) peer.Response {43 function, args := stub.GetFunctionAndParameters()44 if function == "put" {45 return t.put(stub, args)46 }47 return shim.Error("Invalid invoke function name. Expecting \"put\"")48}49func (t *SimpleChaincode) put(stub shim.ChaincodeStubInterface, args []string) peer.Response {50 if len(args) != 2 {51 return shim.Error("Incorrect number of arguments. Expecting 2")52 }

Full Screen

Full Screen

loadDB

Using AI Code Generation

copy

Full Screen

1import (2type SimpleChaincode struct {3}4func (t *SimpleChaincode) Init(stub shim.ChaincodeStubInterface) peer.Response {5 return shim.Success(nil)6}7func (t *SimpleChaincode) Invoke(stub shim.ChaincodeStubInterface) peer.Response {8 function, args := stub.GetFunctionAndParameters()9 if function == "loadDB" {10 return t.loadDB(stub, args)11 }12 return shim.Error("Invalid invoke function name. Expecting \"loadDB\"")13}14func (t *SimpleChaincode) loadDB(stub shim.ChaincodeStubInterface, args []string) peer.Response {15 err := stub.PutState(args[0], []byte(args[1]))16 if err != nil {17 return shim.Error(fmt.Sprintf("Failed to load DB: %s", args[0]))18 }19 return shim.Success([]byte("success"))20}21func main() {22 err := shim.Start(new(SimpleChaincode))23 if err != nil {24 fmt.Printf("Error starting Simple chaincode: %s", err)25 }26}27import (28type SimpleChaincode struct {29}30func (t *SimpleChaincode) Init(stub shim.ChaincodeStubInterface) peer.Response {31 return shim.Success(nil)32}33func (t *SimpleChaincode) Invoke(stub shim.ChaincodeStubInterface) peer.Response {34 function, args := stub.GetFunctionAndParameters()35 if function == "queryDB" {36 return t.queryDB(stub, args)37 }38 return shim.Error("Invalid invoke function name. Expecting \"queryDB\"")39}40func (t *SimpleChaincode) queryDB(stub shim.ChaincodeStubInterface, args []string) peer.Response {41 value, err := stub.GetState(args[0])42 if err != nil {43 return shim.Error(fmt.Sprintf("Failed to query DB: %s", args[0]))44 }

Full Screen

Full Screen

loadDB

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 db, err := ethdb.NewMemDatabase()4 if err != nil {5 log.Fatal(err)6 }7 statedb, err := state.New(common.Hash{}, state.NewDatabase(db))8 if err != nil {9 log.Fatal(err)10 }11 statedb2, err := state.New(common.Hash{}, state.NewDatabase(db))12 if err != nil {13 log.Fatal(err)14 }15 statedb3, err := state.New(common.Hash{}, state.NewDatabase(db))16 if err != nil {17 log.Fatal(err)18 }19 statedb4, err := state.New(common.Hash{}, state.NewDatabase(db))20 if err != nil {21 log.Fatal(err)22 }23 statedb5, err := state.New(common.Hash{}, state.NewDatabase(db))24 if err != nil {25 log.Fatal(err)26 }27 statedb6, err := state.New(common.Hash{}, state.NewDatabase(db))28 if err != nil {29 log.Fatal(err)30 }31 statedb7, err := state.New(common.Hash{}, state.NewDatabase(db))32 if err != nil {33 log.Fatal(err)34 }35 statedb8, err := state.New(common.Hash{}, state.NewDatabase(db))36 if err != nil {37 log.Fatal(err)38 }39 statedb9, err := state.New(common.Hash{}, state.NewDatabase(db))40 if err != nil {41 log.Fatal(err)42 }

Full Screen

Full Screen

loadDB

Using AI Code Generation

copy

Full Screen

1func main() {2 state := state{}3 state.loadDB()4}5func main() {6 state := state{}7 state.loadDB()8}9func main() {10 state := state{}11 state.loadDB()12}13func main() {14 state := state{}15 state.loadDB()16}17func main() {18 state := state{}19 state.loadDB()20}21func main() {22 state := state{}23 state.loadDB()24}25func main() {26 state := state{}27 state.loadDB()28}29func main() {30 state := state{}31 state.loadDB()32}33func main() {34 state := state{}35 state.loadDB()36}37func main() {38 state := state{}39 state.loadDB()40}41func main() {42 state := state{}43 state.loadDB()44}45func main() {46 state := state{}47 state.loadDB()48}49func main() {50 state := state{}51 state.loadDB()52}53func main() {54 state := state{}55 state.loadDB()56}57func main() {58 state := state{}59 state.loadDB()60}61func main()

Full Screen

Full Screen

loadDB

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 db, err := ethdb.NewLDBDatabase(path.Join(os.Getenv("HOME"), ".ethereum", "chaindata"), 0, 0)4 if err != nil {5 fmt.Println("Error in getting the database")6 fmt.Println(err)7 }8 defer db.Close()9 stateobj := state.New(common.HexToAddress("0x0"), state.NewDatabase(db))10 err = stateobj.LoadDB()11 if err != nil {12 fmt.Println("Error in loading the database")13 fmt.Println(err)14 }15 balance := stateobj.GetBalance()16 fmt.Println("Balance of the account is ", balance)17 nonce := stateobj.GetNonce()18 fmt.Println("Nonce of the account is ", nonce)19 codehash := stateobj.GetCodeHash()20 fmt.Println("Code hash of the account is ", codehash)21 code := stateobj.GetCode()22 fmt.Println("Code of the account is ", code)23 codesize := stateobj.GetCodeSize()24 fmt.Println("Code size of the account is ", codesize)25 storageroot := stateobj.GetStorageRoot()26 fmt.Println("Storage root of the account is ", storageroot)27 storagetrie, err := stateobj.StorageTrie()28 if err != nil {29 fmt.Println("Error in getting the storage trie")30 fmt.Println(err)31 }32 storagevalue, err := storagetrie.TryGet([]byte("0x0"))33 if err != nil {34 fmt.Println("Error in getting the storage value")35 fmt.Println(err)

Full Screen

Full Screen

loadDB

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 db, err := ethdb.NewMemDatabase()4 if err != nil {5 fmt.Println(err)6 }7 state, err := New(db)8 if err != nil {9 fmt.Println(err)10 }11 state.LoadDB()12}13import (14func main() {15 db, err := ethdb.NewMemDatabase()16 if err != nil {17 fmt.Println(err)18 }19 state, err := New(db)20 if err != nil {21 fmt.Println(err)22 }23 state.LoadDB()24}25import (26func main() {27 db, err := ethdb.NewMemDatabase()28 if err != nil {29 fmt.Println(err)30 }31 state, err := New(db)32 if err != nil {33 fmt.Println(err)34 }35 state.LoadDB()36}37import (38func main() {39 db, err := ethdb.NewMemDatabase()40 if err != nil {41 fmt.Println(err)42 }43 state, err := New(db)44 if err != nil {45 fmt.Println(err)46 }47 state.LoadDB()48}49import (50func main() {51 db, err := ethdb.NewMemDatabase()52 if err != nil {

Full Screen

Full Screen

loadDB

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 fmt.Println("Starting")4 s := state.NewState()5 s.LoadDB()6}7import (8func main() {9 fmt.Println("Starting")10 s := state.NewState()11 s.LoadDB()12}13import (14func main() {15 fmt.Println("Starting")16 s := state.NewState()17 s.LoadDB()18}19import (20func main() {21 fmt.Println("Starting")22 s := state.NewState()23 s.LoadDB()24}25import (26func main() {27 fmt.Println("Starting")28 s := state.NewState()29 s.LoadDB()30}31import (32func main() {33 fmt.Println("Starting")34 s := state.NewState()35 s.LoadDB()36}37import (38func main() {39 fmt.Println("Starting")40 s := state.NewState()41 s.LoadDB()42}43import (44func main() {45 fmt.Println("Starting")46 s := state.NewState()47 s.LoadDB()48}49import (50func main() {51 fmt.Println("Starting")52 s := state.NewState()53 s.LoadDB()54}

Full Screen

Full Screen

loadDB

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 s := state.State{}4 s.LoadDB()5 fmt.Println(s)6}7import "fmt"8type State struct {9}10func (s *State) LoadDB() {11 fmt.Println("db loaded")12}13import (14func TestLoadDB(t *testing.T) {15 s := State{}16 s.LoadDB()17 fmt.Println(s)18}19import (20func TestLoadDB(t *testing.T) {21 s := State{}22 s.LoadDB()23 fmt.Println(s)24}25import (26func TestLoadDB(t *testing.T) {27 s := State{}28 s.LoadDB()29 fmt.Println(s)30}31import (32func TestLoadDB(t *testing.T) {33 s := State{}34 s.LoadDB()35 fmt.Println(s)36}37import (38func TestLoadDB(t *testing.T) {39 s := State{}40 s.LoadDB()41 fmt.Println(s)42}43import (44func TestLoadDB(t *testing.T) {45 s := State{}46 s.LoadDB()47 fmt.Println(s)48}49import (50func TestLoadDB(t *testing.T) {51 s := State{}52 s.LoadDB()53 fmt.Println(s)54}55import (56func TestLoadDB(t *testing.T) {57 s := State{}58 s.LoadDB()59 fmt.Println(s)60}

Full Screen

Full Screen

loadDB

Using AI Code Generation

copy

Full Screen

1import (2type State struct {3}4func (s *State) LoadDB() {5 fmt.Println("Loading database from file")6}7func (s *State) CloseDB() {8 fmt.Println("Closing database")9}10func main() {11 fmt.Println("Type of s is", reflect.TypeOf(s))12 fmt.Println("Value of s is", reflect.ValueOf(s))13 fmt.Println("Value of s is", reflect.ValueOf(&s))14 s.LoadDB()15}16import (17type State struct {18}19func (s *State) LoadDB() {20 fmt.Println("Loading database from file")21}22func (s *State) CloseDB() {23 fmt.Println("Closing database")24}25func main() {26 fmt.Println("Type of s is", reflect.TypeOf(s))27 fmt.Println("Value of s is", reflect.ValueOf(s))28 fmt.Println("Value of s is", reflect.ValueOf(&s))29 s.LoadDB()30 reflect.ValueOf(&s).MethodByName("LoadDB").Call(nil)31}32import (33type State struct {34}35func (s *State) LoadDB() {36 fmt.Println("Loading database from file")37}38func (s *State) CloseDB() {39 fmt.Println("Closing database")40}41func main() {42 fmt.Println("Type of s is", reflect.TypeOf(s))43 fmt.Println("Value of s is", reflect.ValueOf(s))44 fmt.Println("Value of s is", reflect.ValueOf(&s))45 s.LoadDB()46 reflect.ValueOf(&s).MethodByName("LoadDB").Call(nil)47 reflect.ValueOf(&s).MethodByName("CloseDB").Call(nil)

Full Screen

Full Screen

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.

LambdaTest Learning Hubs:

YouTube

You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.

Run Syzkaller automation tests on LambdaTest cloud grid

Perform automation testing on 3000+ real desktop and mobile devices online.

... View sample repo... View DocumentationSign up Free
›
_

Most used method in

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

...
Sign up with GoogleSign up with Email
Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful