Function updateShardChain

blockproducer/storage.go:314–360

(profile *types.SQLChainProfile)

}

func updateShardChain(profile *types.SQLChainProfile) storageProcedure {
	var (
		enc *bytes.Buffer
		err error
	)
	if enc, err = utils.EncodeMsgPack(profile); err != nil {
		return errPass(err)
	}
	return func(tx *sql.Tx) (err error) {
		log.WithFields(log.Fields{
			"profile_owner":         profile.Owner.String(),
			"profile_address":       profile.Address.String(),
			"profile_database_id":   profile.ID,
			"profile_token_type":    profile.TokenType,
			"profile_miners_number": len(profile.Miners),
		}).Debug("updating profile")
		_, err = tx.Exec(`INSERT OR REPLACE INTO "shardChain" ("address", "id", "encoded")
	VALUES (?, ?, ?)`,
			profile.Address.String(),
			string(profile.ID),
			enc.Bytes())
		if err != nil {
			return
		}

		for _, u := range profile.Users {
			if u.Permission.Role == types.Void {
				// remove index
				_, err = tx.Exec(`DELETE FROM "indexed_shardChains" WHERE "account" = ? AND "address" = ?`,
					u.Address.String(),
					profile.Address.String())
			} else {
				_, err = tx.Exec(`INSERT OR REPLACE INTO "indexed_shardChains" ("account", "address", "id") 
	VALUES(?, ?, ?)`,
					u.Address.String(),
					profile.Address.String(),
					profile.ID)
			}

			if err != nil {
				return
			}
		}

		return
	}
}

func deleteShardChain(id proto.DatabaseID) storageProcedure {
	return func(tx *sql.Tx) (err error) {