ap-relay 0.3.114

A simple activitypub relay
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

use crate::{error::Error, future::BoxFuture, jobs::JobState};
use background_jobs::{Backoff, Job};

#[derive(Clone, Debug, serde::Deserialize, serde::Serialize)]
pub(crate) struct RecordLastOnline;

impl RecordLastOnline {
    #[tracing::instrument(skip(state))]
    async fn perform(self, state: JobState) -> Result<(), Error> {
        let nodes = state.state.last_online.take();

        state.state.db.mark_last_seen(nodes).await
    }
}

impl Job for RecordLastOnline {
    type State = JobState;
    type Error = Error;
    type Future = BoxFuture<'static, Result<(), Self::Error>>;

    const NAME: &'static str = "relay::jobs::RecordLastOnline";
    const QUEUE: &'static str = "maintenance";
    const BACKOFF: Backoff = Backoff::Linear(1);

    fn run(self, state: Self::State) -> Self::Future {
        Box::pin(self.perform(state))
    }
}