ok2/RFKPOS - Change WW3R2OTSI3NJJP2HXQ7QHBGYOO3NVS2NM3OQBDTLX5JQ3Z2DO7NAC

Remove bookstore example and replace it by RFKPOS objects.

Created by ok2 on November 5, 2022

WW3R2OTSI3NJJP2HXQ7QHBGYOO3NVS2NM3OQBDTLX5JQ3Z2DO7NAC

Dependencies

In channels

main

Change contents

Replacement in src/main.rs at line 4 [6.49]

∅:D[4.42] → [5.60:173]

∅:D[7.166] → [5.60:173]

B:BD[5.60] → [5.60:173]

use bookstore::bookstore_server::{Bookstore, BookstoreServer};
use bookstore::{GetBookRequest, GetBookResponse};

[4.42]

[4.43]

use rfkpos::rfkpos_server::{RFKPOS, RFKPOSServer};
use rfkpos::{NewTransaction, LastTransaction};

Replacement in src/main.rs at line 9 [6.49]

B:BD[5.175] → [5.175:221]

mod bookstore {
    include!("bookstore.rs");

[5.174]

[5.221]

mod rfkpos {
    include!("rfkpos.rs");

Replacement in src/main.rs at line 17 [6.49]
B:BD[5.378] → [5.378:406]
```
pub struct BookStoreImpl {}
```
[5.378]
[5.406]
```
pub struct RFKPOSImpl {}
```

Replacement in src/main.rs at line 20 [6.49]

B:BD[5.429] → [5.429:597]

impl Bookstore for BookStoreImpl {
    async fn get_book(
        &self,
        request: Request<GetBookRequest>,
    ) -> Result<Response<GetBookResponse>, Status> {

[5.429]

[5.597]

impl RFKPOS for RFKPOSImpl {
    asynf fn new_transaction(&self, request: Request<Transaction>) -> Result<Response<TransactionReturn>, Status> {

Insertion in src/main.rs at line 23 [6.49]

[5.659]

        Ok(Response::new(TransactionReturn { err: Error { message = "Not implemented", prio = ERR_CRITICAL } }))
    }

Replacement in src/main.rs at line 26 [6.49]

B:BD[5.660] → [5.660:897]

        let response = GetBookResponse {
            id: request.into_inner().id,
            author: "Peter".to_owned(),
            name: "Zero to One".to_owned(),
            year: 2014,
        };
        Ok(Response::new(response))

[5.660]

[4.69]

    asynf fn last_transaction(&self) -> Result<Response<TransactionReturn>, Status> {
        println!("Request from {:?}", request.remote_addr());
        Ok(Response::new(TransactionReturn { err: Error { message = "Not implemented", prio = ERR_CRITICAL } }))

Replacement in src/main.rs at line 35 [6.49]

B:BD[4.210] → [4.210:282]

        reporter.set_serving::<BookstoreServer<BookStoreImpl>>().await;

[4.210]

[2.30]

        reporter.set_serving::<RFKPOSServer<RFKPOSImpl>>().await;

Replacement in src/main.rs at line 54 [6.49]

∅:D[2.267] → [5.1027:1073]

∅:D[7.322] → [5.1027:1073]

B:BD[5.1027] → [5.1027:1073]

B:BD[5.1073] → [2.268:439]

    let bookstore = BookStoreImpl::default();
    let bookstore_auth = Arc::clone(&authenticator);
    let bookstore_svc = BookstoreServer::with_interceptor(bookstore, move |r| check_auth(r, bookstore_auth.clone()));

[2.267]

[5.1073]

    let rfkpos = RFKPOSImpl::default();
    let rfkpos_auth = Arc::clone(&authenticator);
    let rfkpos_svc = RFKPOSServer::with_interceptor(rfkpos, move |r| check_auth(r, rfkpos_auth.clone()));

Replacement in src/main.rs at line 59 [6.49]

B:BD[5.1166] → [5.1166:1244]

        .register_encoded_file_descriptor_set(bookstore::FILE_DESCRIPTOR_SET)

[5.1166]

[5.1244]

        .register_encoded_file_descriptor_set(rfkpos::FILE_DESCRIPTOR_SET)

Replacement in src/main.rs at line 65 [6.49]

B:BD[4.372] → [4.372:447]

    health_reporter.set_serving::<BookstoreServer<BookStoreImpl>>().await;

[4.372]

[4.447]

    health_reporter.set_serving::<RFKPOSServer<RFKPOSImpl>>().await;

Replacement in src/main.rs at line 68 [6.49]

B:BD[5.1281] → [5.1281:1337]

    println!("Bookstore server listening on {}", addr);

[5.1281]

[5.1337]

    println!("RFKPOS server listening on {}", addr);

Replacement in src/main.rs at line 73 [6.49]
∅:D[4.551] → [7.561:597]
B:BD[7.561] → [7.561:597]
```
        .add_service(bookstore_svc)
```
[4.551]
[7.597]
```
        .add_service(rfkpos_svc)
```

Insertion in proto/rfkpos.proto at line 141 [5.1576]

[3.1429]

message User {
    string name = 0;
    string public_key = 1;
}