comparing 806b263de268647910a2c2cd613572c77a629b71 and main on edouard.paris/vnd-atproto

.gitignore

···

       1
        
       target/

     

       2
        
       cli/history.txt

     

       0
        
       
     

       0

···

       1
        
       target/

     

       2
        
       cli/history.txt

     

       3
       +
       cli/operation.json

     

       4
       +
       cli/previous_operation.json

+22 -2

Cargo.lock

···

       136
        
       checksum = "4c7f02d4ea65f2c1853089ffd8d2787bdbc63de2f0d29dedbcf8ccdfa0ccd4cf"

     

       137
        
       

     

       138
        
       [[package]]

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       139
        
       name = "base58"

     

       140
        
       version = "0.2.0"

     

       141
        
       source = "registry+https://github.com/rust-lang/crates.io-index"

     

       142
        
       checksum = "6107fe1be6682a68940da878d9e9f5e90ca5745b3dec9fd1bb393c8777d4f581"

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       143
        
       

     

       144
        
       [[package]]

     

       145
        
       name = "base64ct"

     
···

       242
        
       [[package]]

     

       243
        
       name = "cid"

     

       244
        
       version = "0.11.1"

     

       245
       -
       source = "git+https://github.com/edouardparis/rust-cid?branch=fix-dep-serde_bytes-features#d8aeda78e2dd4784dbea3086a6ca85fa88782d2d"

     

       246
        
       dependencies = [

     

       247
        
        "core2",

     

       248
        
        "multibase",

     
···

       1253
        
       [[package]]

     

       1254
        
       name = "serde_ipld_dagcbor"

     

       1255
        
       version = "0.6.3"

     

       1256
       -
       source = "git+http://github.com/edouardparis/serde_ipld_dagcbor?branch=scopeguard-no-default-features#82eca93ee126750ad80feedbfe9cee0bf162c587"

     

       1257
        
       dependencies = [

     

       1258
        
        "cbor4ii",

     

       1259
        
        "ipld-core",

     
···

       1600
        
       version = "0.0.1"

     

       1601
        
       dependencies = [

     

       1602
        
        "base58",

     

       0
        
       
     

       1603
        
        "hex-literal",

     

       0
        
       
     

       1604
        
        "postcard",

     

       1605
        
        "serde",

     

       1606
        
        "serde_ipld_dagcbor",

     
···

       1612
        
       name = "vnd-atproto-cli"

     

       1613
        
       version = "0.0.1"

     

       1614
        
       dependencies = [

     

       0
        
       
     

       1615
        
        "base58",

     

       0
        
       
     

       0
        
       
     

       1616
        
        "clap",

     

       1617
        
        "hidapi",

     

       1618
        
        "ledger-transport-hid",

     

       1619
        
        "rustyline",

     

       1620
        
        "serde",

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       1621
        
        "shellwords",

     

       1622
        
        "tokio",

     

       1623
        
        "vnd-atproto-client",

···

       136
        
       checksum = "4c7f02d4ea65f2c1853089ffd8d2787bdbc63de2f0d29dedbcf8ccdfa0ccd4cf"

     

       137
        
       

     

       138
        
       [[package]]

     

       139
       +
       name = "base32"

     

       140
       +
       version = "0.5.1"

     

       141
       +
       source = "registry+https://github.com/rust-lang/crates.io-index"

     

       142
       +
       checksum = "022dfe9eb35f19ebbcb51e0b40a5ab759f46ad60cadf7297e0bd085afb50e076"

     

       143
       +
       

     

       144
       +
       [[package]]

     

       145
        
       name = "base58"

     

       146
        
       version = "0.2.0"

     

       147
        
       source = "registry+https://github.com/rust-lang/crates.io-index"

     

       148
        
       checksum = "6107fe1be6682a68940da878d9e9f5e90ca5745b3dec9fd1bb393c8777d4f581"

     

       149
       +
       

     

       150
       +
       [[package]]

     

       151
       +
       name = "base64"

     

       152
       +
       version = "0.22.1"

     

       153
       +
       source = "registry+https://github.com/rust-lang/crates.io-index"

     

       154
       +
       checksum = "72b3254f16251a8381aa12e40e3c4d2f0199f8c6508fbecb9d91f575e0fbb8c6"

     

       155
        
       

     

       156
        
       [[package]]

     

       157
        
       name = "base64ct"

     
···

       254
        
       [[package]]

     

       255
        
       name = "cid"

     

       256
        
       version = "0.11.1"

     

       257
       +
       source = "git+https://github.com/multiformats/rust-cid?branch=master#6a13cb931d3237e5e1f5635a943edfd166e2e78c"

     

       258
        
       dependencies = [

     

       259
        
        "core2",

     

       260
        
        "multibase",

     
···

       1265
        
       [[package]]

     

       1266
        
       name = "serde_ipld_dagcbor"

     

       1267
        
       version = "0.6.3"

     

       1268
       +
       source = "git+http://github.com/ipld/serde_ipld_dagcbor?branch=master#d7f93d06ce6a19867abeea78d02d6ded6c476b81"

     

       1269
        
       dependencies = [

     

       1270
        
        "cbor4ii",

     

       1271
        
        "ipld-core",

     
···

       1612
        
       version = "0.0.1"

     

       1613
        
       dependencies = [

     

       1614
        
        "base58",

     

       1615
       +
        "cid",

     

       1616
        
        "hex-literal",

     

       1617
       +
        "k256",

     

       1618
        
        "postcard",

     

       1619
        
        "serde",

     

       1620
        
        "serde_ipld_dagcbor",

     
···

       1626
        
       name = "vnd-atproto-cli"

     

       1627
        
       version = "0.0.1"

     

       1628
        
       dependencies = [

     

       1629
       +
        "base32",

     

       1630
        
        "base58",

     

       1631
       +
        "base64",

     

       1632
       +
        "cid",

     

       1633
        
        "clap",

     

       1634
        
        "hidapi",

     

       1635
        
        "ledger-transport-hid",

     

       1636
        
        "rustyline",

     

       1637
        
        "serde",

     

       1638
       +
        "serde_ipld_dagcbor",

     

       1639
       +
        "serde_json",

     

       1640
       +
        "sha2",

     

       1641
        
        "shellwords",

     

       1642
        
        "tokio",

     

       1643
        
        "vnd-atproto-client",

+4 -2

Cargo.toml

···

       10
        
       stack_size = 65536

     

       11
        
       

     

       12
        
       [dependencies]

     

       0
        
       
     

       0
        
       
     

       13
        
       postcard = { version = "1.1.1", features = ["alloc"] }

     

       14
       -
       serde_ipld_dagcbor = { git = "http://github.com/edouardparis/serde_ipld_dagcbor", branch = "scopeguard-no-default-features", default-features = false }

     

       15
        
       sdk = { package = "vanadium-app-sdk", git = "https://github.com/LedgerHQ/vanadium"}

     

       16
        
       common = { package = "vnd-atproto-common", path = "common" }

     

       17
        
       base58 = "0.2.0"

     

       18
        
       serde = { version = "1.0", default-features = false, features = ["alloc"] }

     

       19
        
       

     

       20
        
       [patch.crates-io]

     

       21
       -
       cid = { git = "https://github.com/edouardparis/rust-cid", branch = "fix-dep-serde_bytes-features" }

     

       22
        
       

     

       23
        
       [dev-dependencies]

     

       24
        
       hex-literal = "0.4.1"

···

       10
        
       stack_size = 65536

     

       11
        
       

     

       12
        
       [dependencies]

     

       13
       +
       k256 = { version = "0.13.4", default-features = false, features = ["alloc", "ecdsa-core"] }

     

       14
       +
       cid = { version = "0.11.1", default-features = false, features = ['alloc'] }

     

       15
        
       postcard = { version = "1.1.1", features = ["alloc"] }

     

       16
       +
       serde_ipld_dagcbor = { git = "http://github.com/ipld/serde_ipld_dagcbor", branch = "master", default-features = false }

     

       17
        
       sdk = { package = "vanadium-app-sdk", git = "https://github.com/LedgerHQ/vanadium"}

     

       18
        
       common = { package = "vnd-atproto-common", path = "common" }

     

       19
        
       base58 = "0.2.0"

     

       20
        
       serde = { version = "1.0", default-features = false, features = ["alloc"] }

     

       21
        
       

     

       22
        
       [patch.crates-io]

     

       23
       +
       cid = { git = "https://github.com/multiformats/rust-cid", branch = "master" }

     

       24
        
       

     

       25
        
       [dev-dependencies]

     

       26
        
       hex-literal = "0.4.1"

cli/Cargo.toml

···

       5
        
       

     

       6
        
       [dependencies]

     

       7
        
       base58 = "0.2.0"

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       8
        
       client = { package = "vnd-atproto-client", path = "../client"}

     

       9
        
       clap = { version = "4.5.31", features = ["derive"] }

     

       10
        
       rustyline = "15.0.0"

     

       11
        
       shellwords = "1.1.0"

     

       12
        
       hidapi = "2.6.3"

     

       13
        
       ledger-transport-hid = "0.11.0"

     

       0
        
       
     

       0
        
       
     

       14
        
       serde = { version = "1.0", default-features = false, features = ["alloc", "derive"] }

     

       0
        
       
     

       15
        
       tokio = { version = "1.38.1", features = ["io-util", "macros", "net", "rt", "rt-multi-thread", "sync"] }

     

       16

···

       5
        
       

     

       6
        
       [dependencies]

     

       7
        
       base58 = "0.2.0"

     

       8
       +
       base32 = "0.5.1"

     

       9
       +
       base64 = "0.22.1"

     

       10
       +
       sha2 = "0.10.8"

     

       11
        
       client = { package = "vnd-atproto-client", path = "../client"}

     

       12
        
       clap = { version = "4.5.31", features = ["derive"] }

     

       13
        
       rustyline = "15.0.0"

     

       14
        
       shellwords = "1.1.0"

     

       15
        
       hidapi = "2.6.3"

     

       16
        
       ledger-transport-hid = "0.11.0"

     

       17
       +
       cid = { version = "0.11.1", default-features = false }

     

       18
       +
       serde_ipld_dagcbor = { git = "http://github.com/ipld/serde_ipld_dagcbor", branch = "master", default-features = false }

     

       19
        
       serde = { version = "1.0", default-features = false, features = ["alloc", "derive"] }

     

       20
       +
       serde_json = { version = "1.0", default-features = false, features = ["alloc"] }

     

       21
        
       tokio = { version = "1.38.1", features = ["io-util", "macros", "net", "rt", "rt-multi-thread", "sync"] }

     

       22

+20

cli/previous_operation.json

···

       1
       +
       {

     

       2
       +
         "alsoKnownAs": [

     

       3
       +
           "at://test-vnd.edouard.paris"

     

       4
       +
         ],

     

       5
       +
         "prev": null,

     

       6
       +
         "rotationKeys": [

     

       7
       +
           "did:key:zQ3shiNS7Bm7F3AH5NU4uimiSpZ8ryYj365Uq1N7KMsWUaXKp"

     

       8
       +
         ],

     

       9
       +
         "services": {

     

       10
       +
           "atproto_pds": {

     

       11
       +
             "endpoint": "https://pds.edouard.paris",

     

       12
       +
             "type": "AtprotoPersonalDataServer"

     

       13
       +
           }

     

       14
       +
         },

     

       15
       +
         "sig": "kfShJ7A67jZAjZhydcnz3HRnrlE0NqocV2RmjRNlCB5hyj4Qiw51Kn_Bkqj704KYOTEiyhpiVajRc-qVc9ssWw",

     

       16
       +
         "type": "plc_operation",

     

       17
       +
         "verificationMethods": {

     

       18
       +
           "atproto": "did:key:zQ3shiNS7Bm7F3AH5NU4uimiSpZ8ryYj365Uq1N7KMsWUaXKp"

     

       19
       +
         }

     

       20
       +
       }

+66

cli/src/main.rs

···

       1
        
       use base58::ToBase58;

     

       0
        
       
     

       0
        
       
     

       2
        
       use clap::{CommandFactory, Parser, Subcommand};

     

       3
        
       use rustyline::completion::{Completer, Pair};

     

       4
        
       use rustyline::error::ReadlineError;

     
···

       6
        
       use rustyline::hint::Hinter;

     

       7
        
       use rustyline::validate::{ValidationContext, ValidationResult, Validator};

     

       8
        
       use rustyline::{Context, Editor, Helper};

     

       0
        
       
     

       9
        
       

     

       10
        
       use hidapi::HidApi;

     

       11
        
       use ledger_transport_hid::TransportNativeHID;

     
···

       17
        
       };

     

       18
        
       

     

       19
        
       use std::borrow::Cow;

     

       0
        
       
     

       0
        
       
     

       20
        
       use std::sync::Arc;

     

       21
        
       

     

       22
        
       #[derive(Parser, Debug)]

     
···

       34
        
               key_index: Option<u32>,

     

       35
        
               #[clap(long, default_missing_value = "true", num_args = 0..=1)]

     

       36
        
               display: bool,

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       37
        
           },

     

       38
        
           Exit,

     

       39
        
       }

     
···

       186
        
                       .await?;

     

       187
        
                   println!("did:key:z{}", key.to_base58());

     

       188
        
               }

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       189
        
               CliCommand::Exit => {

     

       0
        
       
     

       190
        
                   return Err("Exiting".into());

     

       191
        
               }

     

       192
        
           }

     

       193
        
           Ok(())

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       194
        
       }

     

       195
        
       

     

       196
        
       #[tokio::main(flavor = "multi_thread")]

···

       1
        
       use base58::ToBase58;

     

       2
       +
       use base64::Engine;

     

       3
       +
       use cid::multihash;

     

       4
        
       use clap::{CommandFactory, Parser, Subcommand};

     

       5
        
       use rustyline::completion::{Completer, Pair};

     

       6
        
       use rustyline::error::ReadlineError;

     
···

       8
        
       use rustyline::hint::Hinter;

     

       9
        
       use rustyline::validate::{ValidationContext, ValidationResult, Validator};

     

       10
        
       use rustyline::{Context, Editor, Helper};

     

       11
       +
       use sha2::Digest;

     

       12
        
       

     

       13
        
       use hidapi::HidApi;

     

       14
        
       use ledger_transport_hid::TransportNativeHID;

     
···

       20
        
       };

     

       21
        
       

     

       22
        
       use std::borrow::Cow;

     

       23
       +
       use std::fs::File;

     

       24
       +
       use std::io::Read;

     

       25
        
       use std::sync::Arc;

     

       26
        
       

     

       27
        
       #[derive(Parser, Debug)]

     
···

       39
        
               key_index: Option<u32>,

     

       40
        
               #[clap(long, default_missing_value = "true", num_args = 0..=1)]

     

       41
        
               display: bool,

     

       42
       +
           },

     

       43
       +
           SignPlcOperation {

     

       44
       +
               #[clap(long)]

     

       45
       +
               key_index: Option<u32>,

     

       46
       +
               /// Path to operation json file

     

       47
       +
               #[clap(long)]

     

       48
       +
               operation: String,

     

       49
       +
               /// Path to previous operation json file

     

       50
       +
               #[clap(long)]

     

       51
       +
               previous: Option<String>,

     

       52
       +
               #[clap(long, default_missing_value = "true", num_args = 0..=1)]

     

       53
       +
               new_plc_did: bool,

     

       54
       +
           },

     

       55
       +
           GetCID {

     

       56
       +
               /// Path to operation json file

     

       57
       +
               #[clap(long)]

     

       58
       +
               operation: String,

     

       59
        
           },

     

       60
        
           Exit,

     

       61
        
       }

     
···

       208
        
                       .await?;

     

       209
        
                   println!("did:key:z{}", key.to_base58());

     

       210
        
               }

     

       211
       +
               CliCommand::SignPlcOperation {

     

       212
       +
                   key_index,

     

       213
       +
                   operation,

     

       214
       +
                   previous,

     

       215
       +
                   new_plc_did,

     

       216
       +
               } => {

     

       217
       +
                   let operation: client::PlcOperation = read_json_file(&operation)?;

     

       218
       +
                   let previous: Option<client::SignedPlcOperation> = if let Some(path) = previous {

     

       219
       +
                       Some(read_json_file(&path)?)

     

       220
       +
                   } else {

     

       221
       +
                       None

     

       222
       +
                   };

     

       223
       +
                   let sig = app_client

     

       224
       +
                       .sign_plc_operation(key_index.unwrap_or(0), operation.clone(), previous)

     

       225
       +
                       .await

     

       226
       +
                       .map(|s| base64::prelude::BASE64_URL_SAFE_NO_PAD.encode(s))?;

     

       227
       +
                   println!("sig: {}", sig);

     

       228
       +
                   if *new_plc_did {

     

       229
       +
                       let b = serde_ipld_dagcbor::to_vec(&operation.signed(sig)).unwrap();

     

       230
       +
                       let hash = sha2::Sha256::digest(b);

     

       231
       +
                       let s = base32::encode(base32::Alphabet::Rfc4648Lower { padding: true }, &hash);

     

       232
       +
                       eprintln!("did:plc:{}", &s[..24]);

     

       233
       +
                   }

     

       234
       +
               }

     

       235
       +
               CliCommand::GetCID { operation } => {

     

       236
       +
                   let operation: client::SignedPlcOperation = read_json_file(&operation)?;

     

       237
       +
                   let b = serde_ipld_dagcbor::to_vec(&operation).unwrap();

     

       238
       +
                   let digest = sha2::Sha256::digest(b);

     

       239
       +
                   let wrap = multihash::Multihash::wrap(0x12, &digest).unwrap();

     

       240
       +
                   let cid = cid::Cid::new(cid::Version::V1, 0x71, wrap).unwrap();

     

       241
       +
                   eprintln!("cid: {}", cid);

     

       242
       +
               }

     

       243
        
               CliCommand::Exit => {

     

       244
       +
                   app_client.exit().await?;

     

       245
        
                   return Err("Exiting".into());

     

       246
        
               }

     

       247
        
           }

     

       248
        
           Ok(())

     

       249
       +
       }

     

       250
       +
       

     

       251
       +
       fn read_json_file<T>(path: &str) -> Result<T, Box<dyn std::error::Error>>

     

       252
       +
       where

     

       253
       +
           T: serde::de::DeserializeOwned,

     

       254
       +
       {

     

       255
       +
           let mut file = File::open(path)?;

     

       256
       +
           let mut contents = String::new();

     

       257
       +
           file.read_to_string(&mut contents)?;

     

       258
       +
           let data: T = serde_json::from_str(&contents)?;

     

       259
       +
           Ok(data)

     

       260
        
       }

     

       261
        
       

     

       262
        
       #[tokio::main(flavor = "multi_thread")]

+1 -1

client/Cargo.toml

···

       7
        
       postcard = { version = "1.1.1", features = ["alloc"] }

     

       8
        
       common = { package = "vnd-atproto-common", path = "../common"}

     

       9
        
       sdk = { package = "vanadium-client-sdk", git = "https://github.com/LedgerHQ/vanadium"}

     

       10
       -
       serde_ipld_dagcbor = { git = "http://github.com/edouardparis/serde_ipld_dagcbor", branch = "scopeguard-no-default-features", default-features = false }

···

       7
        
       postcard = { version = "1.1.1", features = ["alloc"] }

     

       8
        
       common = { package = "vnd-atproto-common", path = "../common"}

     

       9
        
       sdk = { package = "vanadium-client-sdk", git = "https://github.com/LedgerHQ/vanadium"}

     

       10
       +
       serde_ipld_dagcbor = { git = "http://github.com/ipld/serde_ipld_dagcbor", branch = "master", default-features = false }

+24

client/src/lib.rs

···

       0
        
       
     

       1
        
       use common::message::{Request, Response};

     

       2
        
       use sdk::vanadium_client::{VAppClient, VAppExecutionError};

     

       3
        
       

     
···

       85
        
               let response_raw = self.send_message(&msg).await?;

     

       86
        
               match Self::parse_response(&response_raw).await? {

     

       87
        
                   Response::DidKey(key) => Ok(key),

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       88
        
                   _ => Err(AtprotoAppClientError::InvalidResponse("Invalid response")),

     

       89
        
               }

     

       90
        
           }

···

       1
       +
       pub use common::message::{PlcOperation, SignedPlcOperation};

     

       2
        
       use common::message::{Request, Response};

     

       3
        
       use sdk::vanadium_client::{VAppClient, VAppExecutionError};

     

       4
        
       

     
···

       86
        
               let response_raw = self.send_message(&msg).await?;

     

       87
        
               match Self::parse_response(&response_raw).await? {

     

       88
        
                   Response::DidKey(key) => Ok(key),

     

       89
       +
                   _ => Err(AtprotoAppClientError::InvalidResponse("Invalid response")),

     

       90
       +
               }

     

       91
       +
           }

     

       92
       +
       

     

       93
       +
           pub async fn sign_plc_operation(

     

       94
       +
               &mut self,

     

       95
       +
               key_index: u32,

     

       96
       +
               operation: PlcOperation,

     

       97
       +
               previous: Option<SignedPlcOperation>,

     

       98
       +
           ) -> Result<Vec<u8>, AtprotoAppClientError> {

     

       99
       +
               let msg = postcard::to_allocvec(&Request::SignPlcOperation {

     

       100
       +
                   key_index,

     

       101
       +
                   previous,

     

       102
       +
                   operation,

     

       103
       +
               })

     

       104
       +
               .map_err(|e| {

     

       105
       +
                   eprintln!("{:?}", e);

     

       106
       +
                   AtprotoAppClientError::GenericError("Failed to serialize SignPlcOperation request")

     

       107
       +
               })?;

     

       108
       +
       

     

       109
       +
               let response_raw = self.send_message(&msg).await?;

     

       110
       +
               match Self::parse_response(&response_raw).await? {

     

       111
       +
                   Response::Signature(sig) => Ok(sig),

     

       112
        
                   _ => Err(AtprotoAppClientError::InvalidResponse("Invalid response")),

     

       113
        
               }

     

       114
        
           }

+64 -8

common/src/message.rs

···

       1
        
       use alloc::{string::String, vec::Vec};

     

       2
        
       use serde::{Deserialize, Serialize};

     

       3
        
       

     

       0
        
       
     

       4
        
       #[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq)]

     

       5
        
       pub enum Request {

     

       6
        
           Exit,

     

       7
       -
           GetDidKey { index: u32, display: bool },

     

       8
       -
           // SignPlcOperation {

     

       9
       -
           //     key_index: u32,

     

       10
       -
           //     previous: Option<PlcOperation>,

     

       11
       -
           //     operation: PlcOperation,

     

       12
       -
           // },

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       13
        
       }

     

       14
        
       

     

       15
        
       #[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq)]

     

       16
       -
       pub enum PlcOperation {}

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       17
        
       

     

       18
        
       #[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq)]

     

       19
        
       pub enum Response {

     

       20
        
           DidKey(Vec<u8>),

     

       21
       -
           // Signature(Vec<u8>),

     

       22
        
           Error(String),

     

       23
        
       }

···

       1
        
       use alloc::{string::String, vec::Vec};

     

       2
        
       use serde::{Deserialize, Serialize};

     

       3
        
       

     

       4
       +
       #[allow(clippy::large_enum_variant)]

     

       5
        
       #[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq)]

     

       6
        
       pub enum Request {

     

       7
        
           Exit,

     

       8
       +
           GetDidKey {

     

       9
       +
               index: u32,

     

       10
       +
               display: bool,

     

       11
       +
           },

     

       12
       +
           SignPlcOperation {

     

       13
       +
               key_index: u32,

     

       14
       +
               operation: PlcOperation,

     

       15
       +
               previous: Option<SignedPlcOperation>,

     

       16
       +
           },

     

       17
        
       }

     

       18
        
       

     

       19
        
       #[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq)]

     

       20
       +
       #[serde(rename_all = "camelCase")]

     

       21
       +
       pub struct PlcOperation {

     

       22
       +
           pub r#type: String,

     

       23
       +
           pub rotation_keys: Vec<String>,

     

       24
       +
           pub verification_methods: VerificationMethods,

     

       25
       +
           pub also_known_as: Vec<String>,

     

       26
       +
           pub services: Services,

     

       27
       +
           pub prev: Option<String>,

     

       28
       +
       }

     

       29
       +
       

     

       30
       +
       impl PlcOperation {

     

       31
       +
           pub fn signed(self, sig: String) -> SignedPlcOperation {

     

       32
       +
               SignedPlcOperation {

     

       33
       +
                   r#type: self.r#type,

     

       34
       +
                   rotation_keys: self.rotation_keys,

     

       35
       +
                   verification_methods: self.verification_methods,

     

       36
       +
                   also_known_as: self.also_known_as,

     

       37
       +
                   services: self.services,

     

       38
       +
                   prev: self.prev,

     

       39
       +
                   sig,

     

       40
       +
               }

     

       41
       +
           }

     

       42
       +
       }

     

       43
       +
       

     

       44
       +
       #[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq)]

     

       45
       +
       #[serde(rename_all = "camelCase")]

     

       46
       +
       pub struct SignedPlcOperation {

     

       47
       +
           pub r#type: String,

     

       48
       +
           pub rotation_keys: Vec<String>,

     

       49
       +
           pub verification_methods: VerificationMethods,

     

       50
       +
           pub also_known_as: Vec<String>,

     

       51
       +
           pub services: Services,

     

       52
       +
           pub prev: Option<String>,

     

       53
       +
           pub sig: String,

     

       54
       +
       }

     

       55
       +
       

     

       56
       +
       #[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq)]

     

       57
       +
       #[serde(rename_all = "camelCase")]

     

       58
       +
       pub struct VerificationMethods {

     

       59
       +
           pub atproto: String,

     

       60
       +
       }

     

       61
       +
       

     

       62
       +
       #[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq)]

     

       63
       +
       pub struct Services {

     

       64
       +
           pub atproto_pds: Service,

     

       65
       +
       }

     

       66
       +
       

     

       67
       +
       #[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq)]

     

       68
       +
       #[serde(rename_all = "camelCase")]

     

       69
       +
       pub struct Service {

     

       70
       +
           pub r#type: String,

     

       71
       +
           pub endpoint: String,

     

       72
       +
       }

     

       73
        
       

     

       74
        
       #[derive(Serialize, Deserialize, Debug, Clone, PartialEq, Eq)]

     

       75
        
       pub enum Response {

     

       76
        
           DidKey(Vec<u8>),

     

       77
       +
           Signature(Vec<u8>),

     

       78
        
           Error(String),

     

       79
        
       }

+214 -18

src/main.rs

···

       2
        
       

     

       3
        
       extern crate alloc;

     

       4
        
       

     

       5
       -
       use alloc::{string::ToString, vec::Vec};

     

       6
       -
       use common::message::{Request, Response};

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       7
        
       use sdk::{

     

       8
        
           App,

     

       9
       -
           curve::{Curve, EcfpPrivateKey, Secp256k1, ToPublicKey},

     

       0
        
       
     

       10
        
       };

     

       11
        
       

     

       12
        
       sdk::bootstrap!();

     

       13
        
       

     

       14
        
       const HARDENED_PATH: u32 = '🦋' as u32 | (1 << 31);

     

       15
        
       

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       16
        
       #[cfg(not(test))]

     

       17
       -
       fn display_key(pubkey: &[u8], index: u32) -> bool {

     

       18
       -
           use alloc::string::ToString;

     

       19
       -
           use base58::ToBase58;

     

       20
        
           use sdk::ux::TagValue;

     

       21
       -
       

     

       22
       -
           let did_key = alloc::format!("did:key:z{}", pubkey.to_base58());

     

       23
        
       

     

       24
        
           sdk::ux::review_pairs(

     

       25
        
               "Verify Atproto DID key",

     
···

       34
        
                       value: alloc::format!("m/{}'/{}", '🦋' as u32, index),

     

       35
        
                   },

     

       36
        
               ],

     

       37
       -
               &did_key,

     

       38
        
               "Confirm",

     

       39
        
               false,

     

       40
        
           )

     

       41
        
       }

     

       42
        
       

     

       43
        
       #[cfg(test)]

     

       44
       -
       fn display_key(pubkey: &[u8], index: u32) -> bool {

     

       45
        
           true

     

       46
        
       }

     

       47
        
       

     

       48
        
       pub fn get_did_key(index: u32, display: bool) -> Result<Response, &'static str> {

     

       49
        
           if index > 256 {

     

       50
       -
               return Err("Derivation path is too long");

     

       51
        
           }

     

       52
        
       

     

       53
        
           let hd_node = sdk::curve::Secp256k1::derive_hd_node(&[HARDENED_PATH, index])?;

     

       54
        
           let privkey: EcfpPrivateKey<Secp256k1, 32> = EcfpPrivateKey::new(*hd_node.privkey);

     

       55
        
           let pubkey = privkey.to_public_key();

     

       56
       -
           let uncompressed_pubkey = pubkey.as_ref().to_bytes();

     

       57
       -
       

     

       58
       -
           let mut key = Vec::with_capacity(34);

     

       59
       -
           key.push(0xE7);

     

       60
       -
           key.push(uncompressed_pubkey[64] % 2 + 0x02);

     

       61
       -
           key.extend_from_slice(&uncompressed_pubkey[1..33]);

     

       62
        
       

     

       63
        
           if display && !display_key(&key, index) {

     

       64
        
               return Err("Rejected by the user");

     

       65
        
           }

     

       66
        
       

     

       67
       -
           Ok(Response::DidKey(key))

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       68
        
       }

     

       69
        
       

     

       70
        
       fn process(_app: &mut App, request: &[u8]) -> Vec<u8> {

     
···

       76
        
               Request::GetDidKey { index, display } => {

     

       77
        
                   get_did_key(index, display).unwrap_or_else(|e| Response::Error(e.to_string()))

     

       78
        
               }

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       79
        
           };

     

       80
        
           postcard::to_allocvec(&response).unwrap()

     

       81
        
       }

···

       2
        
       

     

       3
        
       extern crate alloc;

     

       4
        
       

     

       5
       +
       use alloc::{

     

       6
       +
           string::{String, ToString},

     

       7
       +
           vec::Vec,

     

       8
       +
       };

     

       9
       +
       use base58::ToBase58;

     

       10
       +
       use common::message::{PlcOperation, Request, Response, SignedPlcOperation};

     

       11
        
       use sdk::{

     

       12
        
           App,

     

       13
       +
           curve::{Curve, EcfpPrivateKey, EcfpPublicKey, Secp256k1, ToPublicKey},

     

       14
       +
           hash::Hasher,

     

       15
        
       };

     

       16
        
       

     

       17
        
       sdk::bootstrap!();

     

       18
        
       

     

       19
        
       const HARDENED_PATH: u32 = '🦋' as u32 | (1 << 31);

     

       20
        
       

     

       21
       +
       struct PublicDidKey(Vec<u8>);

     

       22
       +
       

     

       23
       +
       impl PublicDidKey {

     

       24
       +
           fn new(pubkey: &EcfpPublicKey<Secp256k1, 32>) -> Self {

     

       25
       +
               let bytes = pubkey.as_ref().to_bytes();

     

       26
       +
               let mut key = Vec::with_capacity(34);

     

       27
       +
               key.push(0xE7);

     

       28
       +
               key.push(0x01);

     

       29
       +
               key.push(bytes[64] % 2 + 0x02);

     

       30
       +
               key.extend_from_slice(&bytes[1..33]);

     

       31
       +
               PublicDidKey(key)

     

       32
       +
           }

     

       33
       +
       }

     

       34
       +
       

     

       35
       +
       impl ToString for PublicDidKey {

     

       36
       +
           fn to_string(&self) -> String {

     

       37
       +
               alloc::format!("did:key:z{}", self.0.to_base58())

     

       38
       +
           }

     

       39
       +
       }

     

       40
       +
       

     

       41
        
       #[cfg(not(test))]

     

       42
       +
       fn display_key(pubkey: &PublicDidKey, index: u32) -> bool {

     

       0
        
       
     

       0
        
       
     

       43
        
           use sdk::ux::TagValue;

     

       0
        
       
     

       0
        
       
     

       44
        
       

     

       45
        
           sdk::ux::review_pairs(

     

       46
        
               "Verify Atproto DID key",

     
···

       55
        
                       value: alloc::format!("m/{}'/{}", '🦋' as u32, index),

     

       56
        
                   },

     

       57
        
               ],

     

       58
       +
               &pubkey.to_string(),

     

       59
        
               "Confirm",

     

       60
        
               false,

     

       61
        
           )

     

       62
        
       }

     

       63
        
       

     

       64
        
       #[cfg(test)]

     

       65
       +
       fn display_key(pubkey: &PublicDidKey, index: u32) -> bool {

     

       66
        
           true

     

       67
        
       }

     

       68
        
       

     

       69
        
       pub fn get_did_key(index: u32, display: bool) -> Result<Response, &'static str> {

     

       70
        
           if index > 256 {

     

       71
       +
               return Err("Index is too long");

     

       72
        
           }

     

       73
        
       

     

       74
        
           let hd_node = sdk::curve::Secp256k1::derive_hd_node(&[HARDENED_PATH, index])?;

     

       75
        
           let privkey: EcfpPrivateKey<Secp256k1, 32> = EcfpPrivateKey::new(*hd_node.privkey);

     

       76
        
           let pubkey = privkey.to_public_key();

     

       77
       +
           let key = PublicDidKey::new(&pubkey);

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       78
        
       

     

       79
        
           if display && !display_key(&key, index) {

     

       80
        
               return Err("Rejected by the user");

     

       81
        
           }

     

       82
        
       

     

       83
       +
           Ok(Response::DidKey(key.0))

     

       84
       +
       }

     

       85
       +
       

     

       86
       +
       #[cfg(not(test))]

     

       87
       +
       fn all_operation_tags(operation: &PlcOperation) -> Vec<sdk::ux::TagValue> {

     

       88
       +
           use sdk::ux::TagValue;

     

       89
       +
           let mut tags: Vec<TagValue> = operation

     

       90
       +
               .rotation_keys

     

       91
       +
               .iter()

     

       92
       +
               .map(|value| TagValue {

     

       93
       +
                   tag: "Rotation key:".into(),

     

       94
       +
                   value: value.to_string(),

     

       95
       +
               })

     

       96
       +
               .collect();

     

       97
       +
       

     

       98
       +
           tags.push(TagValue {

     

       99
       +
               tag: "Verification method (atproto):".into(),

     

       100
       +
               value: operation.verification_methods.atproto.to_string(),

     

       101
       +
           });

     

       102
       +
       

     

       103
       +
           for tag in operation.also_known_as.iter().map(|value| TagValue {

     

       104
       +
               tag: "Known as:".into(),

     

       105
       +
               value: value.to_string(),

     

       106
       +
           }) {

     

       107
       +
               tags.push(tag);

     

       108
       +
           }

     

       109
       +
       

     

       110
       +
           tags.push(TagValue {

     

       111
       +
               tag: "Service (atproto pds):".into(),

     

       112
       +
               value: operation.services.atproto_pds.endpoint.to_string(),

     

       113
       +
           });

     

       114
       +
       

     

       115
       +
           tags

     

       116
       +
       }

     

       117
       +
       

     

       118
       +
       #[cfg(not(test))]

     

       119
       +
       fn changed_operation_tags(

     

       120
       +
           operation: &PlcOperation,

     

       121
       +
           previous: &SignedPlcOperation,

     

       122
       +
       ) -> Vec<sdk::ux::TagValue> {

     

       123
       +
           use sdk::ux::TagValue;

     

       124
       +
           let mut tags: Vec<TagValue> = Vec::new();

     

       125
       +
       

     

       126
       +
           if operation.rotation_keys != previous.rotation_keys {

     

       127
       +
               tags = operation

     

       128
       +
                   .rotation_keys

     

       129
       +
                   .iter()

     

       130
       +
                   .map(|value| TagValue {

     

       131
       +
                       tag: "Rotation key:".into(),

     

       132
       +
                       value: value.to_string(),

     

       133
       +
                   })

     

       134
       +
                   .collect();

     

       135
       +
           }

     

       136
       +
       

     

       137
       +
           if operation.verification_methods != previous.verification_methods {

     

       138
       +
               tags.push(TagValue {

     

       139
       +
                   tag: "Verification method (atproto):".into(),

     

       140
       +
                   value: operation.verification_methods.atproto.to_string(),

     

       141
       +
               });

     

       142
       +
           }

     

       143
       +
       

     

       144
       +
           if operation.also_known_as != previous.also_known_as {

     

       145
       +
               for tag in operation.also_known_as.iter().map(|value| TagValue {

     

       146
       +
                   tag: "Known as:".into(),

     

       147
       +
                   value: value.to_string(),

     

       148
       +
               }) {

     

       149
       +
                   tags.push(tag);

     

       150
       +
               }

     

       151
       +
           }

     

       152
       +
       

     

       153
       +
           if operation.services != previous.services {

     

       154
       +
               tags.push(TagValue {

     

       155
       +
                   tag: "Service (atproto pds):".into(),

     

       156
       +
                   value: operation.services.atproto_pds.endpoint.to_string(),

     

       157
       +
               });

     

       158
       +
           }

     

       159
       +
       

     

       160
       +
           tags

     

       161
       +
       }

     

       162
       +
       

     

       163
       +
       #[cfg(not(test))]

     

       164
       +
       fn display_partial_operation(

     

       165
       +
           pubkey: &PublicDidKey,

     

       166
       +
           index: u32,

     

       167
       +
           operation: &PlcOperation,

     

       168
       +
           previous: &SignedPlcOperation,

     

       169
       +
       ) -> bool {

     

       170
       +
           sdk::ux::review_pairs(

     

       171
       +
               "Sign plc operation",

     

       172
       +
               "",

     

       173
       +
               &changed_operation_tags(operation, previous),

     

       174
       +
               &alloc::format!("with key #{} {} ", index, pubkey.to_string()),

     

       175
       +
               "Confirm",

     

       176
       +
               false,

     

       177
       +
           )

     

       178
       +
       }

     

       179
       +
       

     

       180
       +
       #[cfg(test)]

     

       181
       +
       fn display_partial_operation(

     

       182
       +
           _pubkey: &PublicDidKey,

     

       183
       +
           _index: u32,

     

       184
       +
           _operation: &PlcOperation,

     

       185
       +
           _previous: &PlcOperation,

     

       186
       +
       ) -> bool {

     

       187
       +
           true

     

       188
       +
       }

     

       189
       +
       

     

       190
       +
       #[cfg(not(test))]

     

       191
       +
       fn display_full_operation(pubkey: &PublicDidKey, index: u32, operation: &PlcOperation) -> bool {

     

       192
       +
           sdk::ux::review_pairs(

     

       193
       +
               "Sign plc operation",

     

       194
       +
               "",

     

       195
       +
               &all_operation_tags(operation),

     

       196
       +
               &alloc::format!("with key #{} {} ", index, pubkey.to_string()),

     

       197
       +
               "Confirm",

     

       198
       +
               false,

     

       199
       +
           )

     

       200
       +
       }

     

       201
       +
       

     

       202
       +
       #[cfg(test)]

     

       203
       +
       fn display_full_operation(_pubkey: &PublicDidKey, _index: u32, _operation: &PlcOperation) -> bool {

     

       204
       +
           true

     

       205
       +
       }

     

       206
       +
       

     

       207
       +
       pub fn sign_plc_operation(

     

       208
       +
           key_index: u32,

     

       209
       +
           operation: PlcOperation,

     

       210
       +
           previous: Option<SignedPlcOperation>,

     

       211
       +
       ) -> Result<Response, &'static str> {

     

       212
       +
           if key_index > 256 {

     

       213
       +
               return Err("Index is too long");

     

       214
       +
           }

     

       215
       +
       

     

       216
       +
           if operation.r#type != "plc_operation" {

     

       217
       +
               return Err("Wrong payload type");

     

       218
       +
           }

     

       219
       +
       

     

       220
       +
           let hd_node = sdk::curve::Secp256k1::derive_hd_node(&[HARDENED_PATH, key_index])?;

     

       221
       +
           let privkey: EcfpPrivateKey<Secp256k1, 32> = EcfpPrivateKey::new(*hd_node.privkey);

     

       222
       +
           let did_key = PublicDidKey::new(&privkey.to_public_key());

     

       223
       +
       

     

       224
       +
           if let Some(previous) = previous {

     

       225
       +
               if !previous.rotation_keys.contains(&did_key.to_string()) {

     

       226
       +
                   return Err("Key is not part of the previous operation rotation_keys");

     

       227
       +
               }

     

       228
       +
       

     

       229
       +
               let msg =

     

       230
       +
                   serde_ipld_dagcbor::to_vec(&previous).map_err(|_| "Failed to serialize operation")?;

     

       231
       +
               let mut hasher = sdk::hash::Sha256::new();

     

       232
       +
               hasher.update(&msg);

     

       233
       +
               let mut digest = [0u8; 32];

     

       234
       +
               hasher.digest(&mut digest);

     

       235
       +
               let wrap = cid::multihash::Multihash::wrap(0x12, &digest).unwrap();

     

       236
       +
               let cid = cid::Cid::new(cid::Version::V1, 0x71, wrap).unwrap();

     

       237
       +
               if operation.prev != Some(cid.to_string()) {

     

       238
       +
                   return Err("Prev does not match the previous operation CID");

     

       239
       +
               }

     

       240
       +
       

     

       241
       +
               if !display_partial_operation(&did_key, key_index, &operation, &previous) {

     

       242
       +
                   return Err("Rejected by the user");

     

       243
       +
               }

     

       244
       +
           } else if !display_full_operation(&did_key, key_index, &operation) {

     

       245
       +
               return Err("Rejected by the user");

     

       246
       +
           }

     

       247
       +
       

     

       248
       +
           let msg =

     

       249
       +
               serde_ipld_dagcbor::to_vec(&operation).map_err(|_| "Failed to serialize operation")?;

     

       250
       +
           let mut hasher = sdk::hash::Sha256::new();

     

       251
       +
           hasher.update(&msg);

     

       252
       +
           let mut digest = [0u8; 32];

     

       253
       +
           hasher.digest(&mut digest);

     

       254
       +
       

     

       255
       +
           let sig = privkey.ecdsa_sign_hash(&digest).unwrap();

     

       256
       +
           let sig = k256::ecdsa::Signature::from_der(&sig).unwrap();

     

       257
       +
           Ok(Response::Signature(sig.to_bytes().to_vec()))

     

       258
        
       }

     

       259
        
       

     

       260
        
       fn process(_app: &mut App, request: &[u8]) -> Vec<u8> {

     
···

       266
        
               Request::GetDidKey { index, display } => {

     

       267
        
                   get_did_key(index, display).unwrap_or_else(|e| Response::Error(e.to_string()))

     

       268
        
               }

     

       269
       +
               Request::SignPlcOperation {

     

       270
       +
                   key_index,

     

       271
       +
                   previous,

     

       272
       +
                   operation,

     

       273
       +
               } => sign_plc_operation(key_index, operation, previous)

     

       274
       +
                   .unwrap_or_else(|e| Response::Error(e.to_string())),

     

       275
        
           };

     

       276
        
           postcard::to_allocvec(&response).unwrap()

     

       277
        
       }

Compare changes