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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97

macro_rules! impl_cloneable {
    ($($t:ident = $idx:tt),+) => {
        impl <$( $t ),+> CloneableTuple for ($( &$t, )+) where
            $( $t: Clone + Send + Sync + 'static, )+
        {
            type Owned = ( $( $t, )+);

            fn clone_me<'a>(self) -> Self::Owned {
                ( $( self.$idx.clone(), )+ )
            }
        }

    };
}

#[rustfmt::skip]
mod impls {
    use super::super::CloneableTuple;

    impl_cloneable!(T1 = 0);
    impl_cloneable!(T1 = 0, T2 = 1);
    impl_cloneable!(T1 = 0, T2 = 1, T3 = 2);
    impl_cloneable!(T1 = 0, T2 = 1, T3 = 2, T4 = 3);
    impl_cloneable!(T1 = 0, T2 = 1, T3 = 2, T4 = 3, T5 = 4);
    impl_cloneable!(T1 = 0, T2 = 1, T3 = 2, T4 = 3, T5 = 4, T6 = 5);
    impl_cloneable!(T1 = 0, T2 = 1, T3 = 2, T4 = 3, T5 = 4, T6 = 5, T7 = 6);
    impl_cloneable!(T1 = 0, T2 = 1, T3 = 2, T4 = 3, T5 = 4, T6 = 5, T7 = 6, T8 = 7);
    impl_cloneable!(T1 = 0, T2 = 1, T3 = 2, T4 = 3, T5 = 4, T6 = 5, T7 = 6, T8 = 7, T9 = 8);
    impl_cloneable!(T1 = 0, T2 = 1, T3 = 2, T4 = 3, T5 = 4, T6 = 5, T7 = 6, T8 = 7, T9 = 8, T10 = 9);
    impl_cloneable!(T1 = 0, T2 = 1, T3 = 2, T4 = 3, T5 = 4, T6 = 5, T7 = 6, T8 = 7, T9 = 8, T10 = 9, T11 = 10);
    impl_cloneable!(T1 = 0, T2 = 1, T3 = 2, T4 = 3, T5 = 4, T6 = 5, T7 = 6, T8 = 7, T9 = 8, T10 = 9, T11 = 10, T12 = 11);
    impl_cloneable!(T1 = 0, T2 = 1, T3 = 2, T4 = 3, T5 = 4, T6 = 5, T7 = 6, T8 = 7, T9 = 8, T10 = 9, T11 = 10, T12 = 11, T13 = 12);
    impl_cloneable!(T1 = 0, T2 = 1, T3 = 2, T4 = 3, T5 = 4, T6 = 5, T7 = 6, T8 = 7, T9 = 8, T10 = 9, T11 = 10, T12 = 11, T13 = 12, T14 = 13);
    impl_cloneable!(T1 = 0, T2 = 1, T3 = 2, T4 = 3, T5 = 4, T6 = 5, T7 = 6, T8 = 7, T9 = 8, T10 = 9, T11 = 10, T12 = 11, T13 = 12, T14 = 13, T15 = 14);
}

/// Errors that will stop the loop
macro_rules! ok_or_break {
    ($target:literal, $e:expr) => {{
        match $e {
            Ok(x) => x,
            Err(e) => {
                tracing::error!(target: $target, "{e}");
                break Err(e.into());
            }
        }
    }};
    ($target:literal, $e:expr, $($arg:tt)*) => {{
        match $e {
            Ok(x) => x,
            Err(e) => {
                tracing::error!(target: $target, error = ?e, $($arg)*);
                break Err(e.into());
            }
        }
    }};
}

// TODO: implement retry machenism
/// Macro to handle error with continue
macro_rules! ok_or_continue {
    ($target:literal, $e:expr) => {{
        match $e {
            Ok(x) => x,
            Err(e) => {
                tracing::warn!(target: $target, error = ?e, "Error, continue");
                continue;
            }
        }
    }};
    ($target:literal, $e:expr, $($arg:tt)*) => {{
        match $e {
            Ok(x) => x,
            Err(e) => {
                tracing::warn!(target: $target, error = ?e, $($arg)*, "Error, continue");
                continue;
            }
        }
    }};
}

macro_rules! ok_or_warn {
    ($target:literal, $e:expr) => {{
        if let Err(e) = $e {
            tracing::warn!(target: $target, error = ?e);
        }
    }};
    ($target:literal, $e:expr, $($arg:tt)*) => {{
        if let Err(e) = $e {
            tracing::warn!(target: $target, error = ?e, $($arg)*);
        }
    }};
}

pub(crate) use ok_or_break;
pub(crate) use ok_or_continue;
pub(crate) use ok_or_warn;