mapradar 0.5.0

Turn addresses into coordinates and find nearby amenities using Google Maps API
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
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
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129

use moka::future::Cache;
use std::time::Duration;

use crate::models::{GeoLocation, NearbyService, ServiceType};

const GEOCODE_TTL_SECS: u64 = 3600;
const PLACES_TTL_SECS: u64 = 900;
const MAX_GEOCODE_ENTRIES: u64 = 10_000;
const MAX_PLACES_ENTRIES: u64 = 50_000;

#[derive(Clone)]
pub struct GeoCache {
    geocode: Cache<String, GeoLocation>,
    reverse_geocode: Cache<String, GeoLocation>,
    nearby: Cache<String, Vec<NearbyService>>,
}

impl Default for GeoCache {
    fn default() -> Self {
        Self::new()
    }
}

impl GeoCache {
    pub fn new() -> Self {
        Self {
            geocode: Cache::builder()
                .max_capacity(MAX_GEOCODE_ENTRIES)
                .time_to_live(Duration::from_secs(GEOCODE_TTL_SECS))
                .build(),
            reverse_geocode: Cache::builder()
                .max_capacity(MAX_GEOCODE_ENTRIES)
                .time_to_live(Duration::from_secs(GEOCODE_TTL_SECS))
                .build(),
            nearby: Cache::builder()
                .max_capacity(MAX_PLACES_ENTRIES)
                .time_to_live(Duration::from_secs(PLACES_TTL_SECS))
                .build(),
        }
    }

    /// Generates cache key for geocoding requests.
    fn geocode_key(address: &str) -> String {
        address.to_lowercase().trim().to_string()
    }

    /// Generates cache key for reverse geocoding requests.
    fn reverse_geocode_key(lat: f64, lng: f64) -> String {
        format!("{:.6},{:.6}", lat, lng)
    }

    /// Generates cache key for nearby search requests.
    fn nearby_key(
        lat: f64,
        lng: f64,
        service_type: ServiceType,
        radius_meters: f64,
        max_results: usize,
    ) -> String {
        format!(
            "{:.4},{:.4}:{:?}:{:.0}:{}",
            lat, lng, service_type, radius_meters, max_results
        )
    }

    /// Gets cached geocode result.
    pub async fn get_geocode(&self, address: &str) -> Option<GeoLocation> {
        self.geocode.get(&Self::geocode_key(address)).await
    }

    /// Stores geocode result in cache.
    pub async fn set_geocode(&self, address: &str, location: GeoLocation) {
        self.geocode
            .insert(Self::geocode_key(address), location)
            .await;
    }

    /// Gets cached reverse geocode result.
    pub async fn get_reverse_geocode(&self, lat: f64, lng: f64) -> Option<GeoLocation> {
        self.reverse_geocode
            .get(&Self::reverse_geocode_key(lat, lng))
            .await
    }

    /// Stores reverse geocode result in cache.
    pub async fn set_reverse_geocode(&self, lat: f64, lng: f64, location: GeoLocation) {
        self.reverse_geocode
            .insert(Self::reverse_geocode_key(lat, lng), location)
            .await;
    }

    /// Gets cached nearby search result.
    pub async fn get_nearby(
        &self,
        lat: f64,
        lng: f64,
        service_type: ServiceType,
        radius_meters: f64,
        max_results: usize,
    ) -> Option<Vec<NearbyService>> {
        self.nearby
            .get(&Self::nearby_key(
                lat,
                lng,
                service_type,
                radius_meters,
                max_results,
            ))
            .await
    }

    /// Stores nearby search result in cache.
    pub async fn set_nearby(
        &self,
        lat: f64,
        lng: f64,
        service_type: ServiceType,
        radius_meters: f64,
        max_results: usize,
        services: Vec<NearbyService>,
    ) {
        self.nearby
            .insert(
                Self::nearby_key(lat, lng, service_type, radius_meters, max_results),
                services,
            )
            .await;
    }
}