Add notaryd

Cargo.toml

@@ -22,6 +22,10 @@ path = "src/sample.rs"
 name = "civkit-marketd"
 path = "src/services/marketd.rs"
 
+[[bin]]
+name = "civkit-notaryd"
+path = "src/services/notaryd.rs"
+
 [dependencies]
 futures-channel = "0.3.28"
 futures-util = "0.3.28"

src/proto/civkitservice.proto

@@ -5,6 +5,8 @@ package civkitservice;
 
 service CivkitService {
 	rpc RegisterService(RegisterRequest) returns (RegisterReply);
+	rpc FetchServiceEvent(FetchRequest) returns (FetchReply);
+	rpc SubmitServiceEvent(SubmitRequest) returns (SubmitReply);
 }
 
 message RegisterRequest {
@@ -14,3 +16,15 @@ message RegisterRequest {
 message RegisterReply {
 	uint64 registration_result = 1;
 }
+
+message FetchRequest {
+}
+
+message FetchReply {
+}
+
+message SubmitRequest {
+}
+
+message SubmitReply {
+}

src/server.rs

@@ -268,6 +268,20 @@ impl CivkitService for DummyManager {
 
 		Ok(Response::new(civkitservice::RegisterReply { registration_result: 1 }))
 	}
+
+	async fn fetch_service_event(&self, request: Request<civkitservice::FetchRequest>) -> Result<Response<civkitservice::FetchReply>, Status> {
+
+		println!("Received fetch service");
+
+		Ok(Response::new(civkitservice::FetchReply {}))
+	}
+
+	async fn submit_service_event(&self, request: Request<civkitservice::SubmitRequest>) -> Result<Response<civkitservice::SubmitReply>, Status> {
+
+		println!("Submit service");
+
+		Ok(Response::new(civkitservice::SubmitReply {}))
+	}
 }
 
 #[derive(Parser, Debug)]

src/services/notaryd.rs

@@ -0,0 +1,56 @@
+// This file is Copyright its original authors, visible in version control
+// history.
+//
+// This file is licensed under the Apache License, Version 2.0 <LICENSE-APACHE
+// or http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
+// <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your option.
+// You may not use this file except in accordance with one or both of these
+// licenses.
+
+use civkitservice::civkit_service_client::CivkitServiceClient;
+
+use civkitservice::{RegisterRequest, RegisterReply};
+
+use bitcoin::secp256k1::{SecretKey, PublicKey, Secp256k1};
+use bitcoin::secp256k1;
+
+pub mod civkitservice {
+	tonic::include_proto!("civkitservice");
+}
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn std::error::Error>> {
+
+	let mut civkitd_client = CivkitServiceClient::connect(format!("http://[::1]:{}", 50031)).await?;
+
+	let secp_ctx = Secp256k1::new();
+	let pubkey = PublicKey::from_secret_key(&secp_ctx, &SecretKey::from_slice(&[42;32]).unwrap());
+
+	let request = tonic::Request::new(RegisterRequest {
+		service_pubkey: pubkey.serialize().to_vec()
+	});
+
+	let response = civkitd_client.register_service(request).await?;
+
+	//TODO: step 1 receive queries from Nostr client
+	//		- add new event kind `service payload` 
+	//		- add mainstay / opentimestamp  attestations in nostr event content
+
+	//TODO: step 2 store attestation in local service store
+	//		- add a map
+
+	//TODO: step 3 have the notary server counter-sign the attestation (+ maybe add block hash)
+
+	//TODO: step 4 build a merkle tree or pay-to-contract with the attestation
+
+	//TODO: step 5 commit the notarization anchor in a Bitcoin on-chain transaction when X is reached
+	//		- X is the frequency declared in the "service policy" at register_service
+
+	//TODO: step 6 broadcast the on-chain transaction
+
+	//TODO: step 7 return the result to the Nostr client ?
+	//		- add pre-notification at step 3 if the client does not want to be dependent
+	//			on blockchain interval
+
+	Ok(())
+}