// Copyright 2018 The go-ethereum Authors // This file is part of the go-ethereum library. // // The go-ethereum library is free software: you can redistribute it and/or modify // it under the terms of the GNU Lesser General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // // The go-ethereum library is distributed in the hope that it will be useful, // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU Lesser General Public License for more details. // // You should have received a copy of the GNU Lesser General Public License // along with the go-ethereum library. If not, see . package mru import ( "hash" "unsafe" "github.com/ethereum/go-ethereum/common" "github.com/ethereum/go-ethereum/common/hexutil" "github.com/ethereum/go-ethereum/swarm/storage" ) // View represents a particular user's view of a resource type View struct { Topic Topic `json:"topic"` User common.Address `json:"user"` } // View layout: // TopicLength bytes // userAddr common.AddressLength bytes const viewLength = TopicLength + common.AddressLength // mapKey calculates a unique id for this view for the cache map in `Handler` func (u *View) mapKey() uint64 { serializedData := make([]byte, viewLength) u.binaryPut(serializedData) hasher := hashPool.Get().(hash.Hash) defer hashPool.Put(hasher) hasher.Reset() hasher.Write(serializedData) hash := hasher.Sum(nil) return *(*uint64)(unsafe.Pointer(&hash[0])) } // binaryPut serializes this View instance into the provided slice func (u *View) binaryPut(serializedData []byte) error { if len(serializedData) != viewLength { return NewErrorf(ErrInvalidValue, "Incorrect slice size to serialize View. Expected %d, got %d", viewLength, len(serializedData)) } var cursor int copy(serializedData[cursor:cursor+TopicLength], u.Topic[:TopicLength]) cursor += TopicLength copy(serializedData[cursor:cursor+common.AddressLength], u.User[:]) cursor += common.AddressLength return nil } // binaryLength returns the expected size of this structure when serialized func (u *View) binaryLength() int { return viewLength } // binaryGet restores the current instance from the information contained in the passed slice func (u *View) binaryGet(serializedData []byte) error { if len(serializedData) != viewLength { return NewErrorf(ErrInvalidValue, "Incorrect slice size to read View. Expected %d, got %d", viewLength, len(serializedData)) } var cursor int copy(u.Topic[:], serializedData[cursor:cursor+TopicLength]) cursor += TopicLength copy(u.User[:], serializedData[cursor:cursor+common.AddressLength]) cursor += common.AddressLength return nil } // Hex serializes the View to a hex string func (u *View) Hex() string { serializedData := make([]byte, viewLength) u.binaryPut(serializedData) return hexutil.Encode(serializedData) } // FromValues deserializes this instance from a string key-value store // useful to parse query strings func (u *View) FromValues(values Values) (err error) { topic := values.Get("topic") if topic != "" { if err := u.Topic.FromHex(values.Get("topic")); err != nil { return err } } else { // see if the user set name and relatedcontent name := values.Get("name") relatedContent, _ := hexutil.Decode(values.Get("relatedcontent")) if len(relatedContent) > 0 { if len(relatedContent) < storage.AddressLength { return NewErrorf(ErrInvalidValue, "relatedcontent field must be a hex-encoded byte array exactly %d bytes long", storage.AddressLength) } relatedContent = relatedContent[:storage.AddressLength] } u.Topic, err = NewTopic(name, relatedContent) if err != nil { return err } } u.User = common.HexToAddress(values.Get("user")) return nil } // AppendValues serializes this structure into the provided string key-value store // useful to build query strings func (u *View) AppendValues(values Values) { values.Set("topic", u.Topic.Hex()) values.Set("user", u.User.Hex()) }