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
|
use google_calendar3::api::{Event, EventAttendee};
use google_calendar3::CalendarHub;
use home;
use hyper;
use hyper_rustls;
use tokio;
use yup_oauth2 as oauth2;
use std::env;
use std::fs;
use std::process;
#[derive(Debug)]
enum EventResponseStatus {
Accepted,
Declined,
Tentative,
}
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
let args: Vec<String> = env::args().collect();
let mut action: Option<EventResponseStatus> = None;
let mut email = false;
let mut event_ids = Vec::new();
for arg in &args[1..] {
match arg.as_ref() {
"-y" | "--yes" => action = Some(EventResponseStatus::Accepted),
"-n" | "--no" => action = Some(EventResponseStatus::Declined),
"-m" | "--maybe" => action = Some(EventResponseStatus::Tentative),
"--email" => email = true,
id => event_ids.push(id),
}
}
if event_ids.is_empty() {
eprintln!("error: missing event ID argument");
process::exit(exitcode::USAGE);
}
for event_id in &event_ids {
rsvp(event_id).await;
}
Ok(())
}
async fn rsvp(event_id: &str) {
let secret = secret_from_file();
let auth = oauth2::InstalledFlowAuthenticator::builder(
secret,
oauth2::InstalledFlowReturnMethod::HTTPRedirect,
)
.persist_tokens_to_disk(
home::home_dir()
.unwrap()
.join(".google-service-cli/google-calendar-rsvp")
)
.build().await.unwrap();
let hub = CalendarHub::new(
hyper::Client::builder()
.build(hyper_rustls::HttpsConnector::with_native_roots()),
auth,
);
let result = hub.events()
.get("primary", event_id)
.doit()
.await
.unwrap();
let mut event = Event::default();
let mut attendee = EventAttendee::default();
if let Some(attendees) = result.1.attendees {
for a in &attendees {
if let Some(is_me) = a.self_ {
if is_me {
attendee.email = a.email.clone();
break;
}
}
}
}
attendee.response_status = Some("accepted".to_owned());
event.attendees = Some(vec![attendee]);
let res = hub.events()
.patch(event, "primary", event_id)
.doit()
.await
.unwrap();
dbg!(res);
}
fn secret_from_file() -> oauth2::ApplicationSecret {
let f = fs::File::open(
home::home_dir()
.unwrap()
.join(".google-service-cli/calendar3-secret.json"),
).unwrap();
let console_secret: oauth2::ConsoleApplicationSecret = serde_json::from_reader(f).unwrap();
match console_secret.installed {
Some(secret) => secret,
None => todo!(),
}
}
|
