async-snmp 0.18.0

Modern async-first SNMP client library for Rust
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

//! Crate-internal request fixtures.

use std::net::{Ipv4Addr, SocketAddr};

use bytes::Bytes;

use crate::handler::RequestContext;
use crate::{Community, CommunityVersion, PduType, SecurityLevel, Version};

const TEST_MSG_MAX_SIZE: usize = 65_507;

pub(crate) fn request_context(pdu_type: PduType) -> RequestContext {
    community_request_context(CommunityVersion::V2c, pdu_type)
}

pub(crate) fn request_context_for_version(version: Version, pdu_type: PduType) -> RequestContext {
    match version {
        Version::V1 => community_request_context(CommunityVersion::V1, pdu_type),
        Version::V2c => community_request_context(CommunityVersion::V2c, pdu_type),
        Version::V3 => usm_request_context(SecurityLevel::NoAuthNoPriv, pdu_type),
    }
}

pub(crate) fn community_request_context(
    version: CommunityVersion,
    pdu_type: PduType,
) -> RequestContext {
    community_request_context_with(
        version,
        Community::from("public"),
        SocketAddr::from((Ipv4Addr::LOCALHOST, 12_345)),
        1,
        pdu_type,
    )
}

pub(crate) fn community_request_context_with(
    version: CommunityVersion,
    community: Community,
    source: SocketAddr,
    request_id: i32,
    pdu_type: PduType,
) -> RequestContext {
    RequestContext::community(source, version, community, request_id, pdu_type, Vec::new())
}

pub(crate) fn usm_request_context(
    security_level: SecurityLevel,
    pdu_type: PduType,
) -> RequestContext {
    usm_request_context_with(
        Bytes::from_static(b"user"),
        security_level,
        Bytes::new(),
        SocketAddr::from((Ipv4Addr::LOCALHOST, 12_345)),
        1,
        pdu_type,
        TEST_MSG_MAX_SIZE,
    )
}

#[allow(clippy::too_many_arguments)]
pub(crate) fn usm_request_context_with(
    username: Bytes,
    security_level: SecurityLevel,
    context_name: Bytes,
    source: SocketAddr,
    request_id: i32,
    pdu_type: PduType,
    msg_max_size: usize,
) -> RequestContext {
    RequestContext::usm(
        source,
        username,
        security_level,
        context_name,
        request_id,
        pdu_type,
        msg_max_size,
        Vec::new(),
    )
}

pub(crate) fn with_vacm_views(
    mut context: RequestContext,
    read_view: impl Into<Bytes>,
    write_view: impl Into<Bytes>,
) -> RequestContext {
    context.set_vacm_access(
        Bytes::from_static(b"test-group"),
        read_view.into(),
        write_view.into(),
    );
    context
}