8 releases

0.1.7 Mar 15, 2021
0.1.6 Mar 9, 2021

#4 in #hana

MIT license

15KB
351 lines

Hana server

Usage

use std::sync::mpsc::channel;
use std::sync::Arc;
use std::sync::RwLock;
use drive_server::types::Metadata;
use drive_server::drive_server::DriveServer;

fn main() -> Result<(), std::io::Error> {
    // Source of truth
    let lock = Arc::new(RwLock::new(vec![types::Metadata {
        name: "fuji".to_string(),
        extension: "jpg".to_string(),
        name_extension: "fuji.jpg".to_string(),
        hash: "b0e490e762234567eabc74fade854476fe692e320".to_string(),
        size: 124093,
    }]));

    let c_lock = Arc::clone(&lock);

    let (tx, rx) = channel();

    thread::spawn(move || {
        for received in rx {
            let mut meta = lock.write().unwrap();
            println!("File received: {:?}", received);
            meta.push(received);
        }
    });

   DriveServer::listen(&c_lock, tx).unwrap();

Dependencies

~1.7–3MB
~65K SLoC