pidcat 0.2.1

An adb logcat wrapper and filters
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

use crate::log::Log;
use crate::sink::Sink;
use anyhow::Result;
use async_trait::async_trait;
use std::path::PathBuf;
use tokio::fs::{File, OpenOptions};
use tokio::io::AsyncWriteExt;
use tokio::task;

pub(crate) struct FileSink {
    file: File,
}

impl FileSink {
    #[allow(dead_code)]
    pub(crate) async fn new(file: PathBuf) -> Result<Self> {
        let f = OpenOptions::new()
            .write(true)
            .truncate(true)
            .create(true)
            .open(file)
            .await?;
        Ok(Self { file: f })
    }
}

#[async_trait]
impl Sink for FileSink {
    async fn write(&self, log: Log) {
        let s = format!(
            "{} {:11} {:>5} {:<5} {} {}   {}\n",
            log.date, log.time, log.pid, log.tid, log.level, log.tag, log.message
        );
        let file = self.file.try_clone().await;
        task::spawn(async move {
            if let Ok(mut file) = file {
                if let Ok(_) = file.write_all(s.as_bytes()).await {}
            }
        });
    }
}