This repository has been archived by the owner on Jun 25, 2021. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 13
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
5 changed files
with
211 additions
and
16 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,156 @@ | ||
| // Copyright 2021 MaidSafe.net limited. | ||
| // | ||
| // This SAFE Network Software is licensed to you under the MIT license <LICENSE-MIT | ||
| // https://opensource.org/licenses/MIT> or the Modified BSD license <LICENSE-BSD | ||
| // https://opensource.org/licenses/BSD-3-Clause>, at your option. This file may not be copied, | ||
| // modified, or distributed except according to those terms. Please review the Licences for the | ||
| // specific language governing permissions and limitations relating to use of the SAFE Network | ||
| // Software. | ||
|
|
||
| use super::{AuthorisationKind, CmdError, DataAuthKind, Error, QueryResponse}; | ||
| use serde::{Deserialize, Serialize}; | ||
| use sn_data_types::{ | ||
| register::{Address, Entry, Register, RegisterOp, User}, | ||
| PublicKey, | ||
| }; | ||
| use std::fmt; | ||
| use xor_name::XorName; | ||
|
|
||
| /// Register reading queries | ||
| #[derive(Hash, Eq, PartialEq, PartialOrd, Clone, Serialize, Deserialize)] | ||
| pub enum RegisterRead { | ||
| /// Get Register from the network. | ||
| Get(Address), | ||
| /// Read last entry, or entries if there are branches, from the Register. | ||
| Read(Address), | ||
| /// List current policy | ||
| GetPolicy(Address), | ||
| /// Get current permissions for a specified user(s). | ||
| GetUserPermissions { | ||
| /// Register address. | ||
| address: Address, | ||
| /// User to get permissions for. | ||
| user: User, | ||
| }, | ||
| /// Get current owner. | ||
| GetOwner(Address), | ||
| } | ||
|
|
||
| /// Register writing commands | ||
| #[allow(clippy::large_enum_variant)] | ||
| #[derive(Eq, PartialEq, Clone, Serialize, Deserialize)] | ||
| pub enum RegisterWrite { | ||
| /// Create a new Register on the network. | ||
| New(Register), | ||
| /// Edit the Register (insert/remove entry). | ||
| Edit(RegisterOp<Entry>), | ||
| /// Delete a private Register. | ||
| /// | ||
| /// This operation MUST return an error if applied to public Register. Only the current | ||
| /// owner(s) can perform this action. | ||
| Delete(Address), | ||
| } | ||
|
|
||
| impl RegisterRead { | ||
| /// Creates a Response containing an error, with the Response variant corresponding to the | ||
| /// Request variant. | ||
| pub fn error(&self, error: Error) -> QueryResponse { | ||
| match *self { | ||
| RegisterRead::Get(_) => QueryResponse::GetRegister(Err(error)), | ||
| RegisterRead::Read(_) => QueryResponse::ReadRegister(Err(error)), | ||
| RegisterRead::GetPolicy(_) => QueryResponse::GetRegisterPolicy(Err(error)), | ||
| RegisterRead::GetUserPermissions { .. } => { | ||
| QueryResponse::GetRegisterUserPermissions(Err(error)) | ||
| } | ||
| RegisterRead::GetOwner(_) => QueryResponse::GetRegisterOwner(Err(error)), | ||
| } | ||
| } | ||
|
|
||
| /// Returns the access categorisation of the request. | ||
| pub fn authorisation_kind(&self) -> AuthorisationKind { | ||
| match *self { | ||
| RegisterRead::Get(address) | ||
| | RegisterRead::Read(address) | ||
| | RegisterRead::GetPolicy(address) | ||
| | RegisterRead::GetUserPermissions { address, .. } | ||
| | RegisterRead::GetOwner(address) => { | ||
| if address.is_public() { | ||
| AuthorisationKind::Data(DataAuthKind::PublicRead) | ||
| } else { | ||
| AuthorisationKind::Data(DataAuthKind::PrivateRead) | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| /// Returns the address of the destination for request. | ||
| pub fn dst_address(&self) -> XorName { | ||
| match self { | ||
| RegisterRead::Get(ref address) | ||
| | RegisterRead::Read(ref address) | ||
| | RegisterRead::GetPolicy(ref address) | ||
| | RegisterRead::GetUserPermissions { ref address, .. } | ||
| | RegisterRead::GetOwner(ref address) => *address.name(), | ||
| } | ||
| } | ||
| } | ||
|
|
||
| impl fmt::Debug for RegisterRead { | ||
| fn fmt(&self, formatter: &mut fmt::Formatter) -> fmt::Result { | ||
| write!( | ||
| formatter, | ||
| "RegisterRead::{}", | ||
| match *self { | ||
| RegisterRead::Get(_) => "GetRegister", | ||
| RegisterRead::Read(_) => "ReadRegister", | ||
| RegisterRead::GetPolicy { .. } => "GetRegisterPolicy", | ||
| RegisterRead::GetUserPermissions { .. } => "GetUserPermissions", | ||
| RegisterRead::GetOwner { .. } => "GetOwner", | ||
| } | ||
| ) | ||
| } | ||
| } | ||
|
|
||
| impl RegisterWrite { | ||
| /// Creates a Response containing an error, with the Response variant corresponding to the | ||
| /// Request variant. | ||
| pub fn error(&self, error: Error) -> CmdError { | ||
| CmdError::Data(error) | ||
| } | ||
|
|
||
| /// Returns the access categorisation of the request. | ||
| pub fn authorisation_kind(&self) -> AuthorisationKind { | ||
| AuthorisationKind::Data(DataAuthKind::Write) | ||
| } | ||
|
|
||
| /// Returns the address of the destination for request. | ||
| pub fn dst_address(&self) -> XorName { | ||
| match self { | ||
| RegisterWrite::New(ref data) => *data.name(), | ||
| RegisterWrite::Delete(ref address) => *address.name(), | ||
| RegisterWrite::Edit(ref op) => *op.address.name(), | ||
| } | ||
| } | ||
|
|
||
| /// Owner of the RegisterWrite | ||
| pub fn owner(&self) -> Option<PublicKey> { | ||
| match self { | ||
| Self::New(data) => Some(data.owner()), | ||
| _ => None, | ||
| } | ||
| } | ||
| } | ||
|
|
||
| impl fmt::Debug for RegisterWrite { | ||
| fn fmt(&self, formatter: &mut fmt::Formatter) -> fmt::Result { | ||
| write!( | ||
| formatter, | ||
| "RegisterWrite::{}", | ||
| match *self { | ||
| RegisterWrite::New(_) => "NewRegister", | ||
| RegisterWrite::Delete(_) => "DeleteRegister", | ||
| RegisterWrite::Edit(_) => "EditRegister", | ||
| } | ||
| ) | ||
| } | ||
| } |
Oops, something went wrong.