1use reqwest;
13
14use bytes::Bytes;
15use crate::apis::ResponseContent;
16use super::{Error, configuration};
17
18
19#[derive(Debug, Clone, Serialize, Deserialize)]
21#[serde(untagged)]
22pub enum OctoprintBackupsCreateError {
23 Status409(crate::models::ErrorDetail),
24 Status400(crate::models::ErrorDetail),
25 Status401(crate::models::ErrorDetail),
26 Status403(crate::models::ErrorDetail),
27 Status500(crate::models::ErrorDetail),
28 UnknownValue(serde_json::Value),
29}
30
31#[derive(Debug, Clone, Serialize, Deserialize)]
33#[serde(untagged)]
34pub enum OctoprintBackupsListError {
35 Status400(crate::models::ErrorDetail),
36 Status401(crate::models::ErrorDetail),
37 Status403(crate::models::ErrorDetail),
38 Status500(crate::models::ErrorDetail),
39 UnknownValue(serde_json::Value),
40}
41
42#[derive(Debug, Clone, Serialize, Deserialize)]
44#[serde(untagged)]
45pub enum OctoprintBackupsRetrieveError {
46 Status404(crate::models::ErrorDetail),
47 Status400(crate::models::ErrorDetail),
48 Status401(crate::models::ErrorDetail),
49 Status403(crate::models::ErrorDetail),
50 Status500(crate::models::ErrorDetail),
51 UnknownValue(serde_json::Value),
52}
53
54#[derive(Debug, Clone, Serialize, Deserialize)]
56#[serde(untagged)]
57pub enum OctoprintCreateError {
58 Status409(crate::models::ErrorDetail),
59 Status400(crate::models::ErrorDetail),
60 Status401(crate::models::ErrorDetail),
61 Status403(crate::models::ErrorDetail),
62 Status500(crate::models::ErrorDetail),
63 UnknownValue(serde_json::Value),
64}
65
66#[derive(Debug, Clone, Serialize, Deserialize)]
68#[serde(untagged)]
69pub enum OctoprintGcodeFilesCreateError {
70 Status409(crate::models::ErrorDetail),
71 Status400(crate::models::ErrorDetail),
72 Status401(crate::models::ErrorDetail),
73 Status403(crate::models::ErrorDetail),
74 Status500(crate::models::ErrorDetail),
75 UnknownValue(serde_json::Value),
76}
77
78#[derive(Debug, Clone, Serialize, Deserialize)]
80#[serde(untagged)]
81pub enum OctoprintGcodeFilesListError {
82 Status400(crate::models::ErrorDetail),
83 Status401(crate::models::ErrorDetail),
84 Status403(crate::models::ErrorDetail),
85 Status500(crate::models::ErrorDetail),
86 UnknownValue(serde_json::Value),
87}
88
89#[derive(Debug, Clone, Serialize, Deserialize)]
91#[serde(untagged)]
92pub enum OctoprintGcodeFilesRetrieveError {
93 Status404(crate::models::ErrorDetail),
94 Status400(crate::models::ErrorDetail),
95 Status401(crate::models::ErrorDetail),
96 Status403(crate::models::ErrorDetail),
97 Status500(crate::models::ErrorDetail),
98 UnknownValue(serde_json::Value),
99}
100
101#[derive(Debug, Clone, Serialize, Deserialize)]
103#[serde(untagged)]
104pub enum OctoprintListError {
105 Status400(crate::models::ErrorDetail),
106 Status401(crate::models::ErrorDetail),
107 Status403(crate::models::ErrorDetail),
108 Status500(crate::models::ErrorDetail),
109 UnknownValue(serde_json::Value),
110}
111
112#[derive(Debug, Clone, Serialize, Deserialize)]
114#[serde(untagged)]
115pub enum OctoprintPartialUpdateError {
116 UnknownValue(serde_json::Value),
117}
118
119#[derive(Debug, Clone, Serialize, Deserialize)]
121#[serde(untagged)]
122pub enum OctoprintPrinterProfilesCreateError {
123 Status409(crate::models::ErrorDetail),
124 Status400(crate::models::ErrorDetail),
125 Status401(crate::models::ErrorDetail),
126 Status403(crate::models::ErrorDetail),
127 Status500(crate::models::ErrorDetail),
128 UnknownValue(serde_json::Value),
129}
130
131#[derive(Debug, Clone, Serialize, Deserialize)]
133#[serde(untagged)]
134pub enum OctoprintPrinterProfilesListError {
135 Status400(crate::models::ErrorDetail),
136 Status401(crate::models::ErrorDetail),
137 Status403(crate::models::ErrorDetail),
138 Status500(crate::models::ErrorDetail),
139 UnknownValue(serde_json::Value),
140}
141
142#[derive(Debug, Clone, Serialize, Deserialize)]
144#[serde(untagged)]
145pub enum OctoprintPrinterProfilesPartialUpdateError {
146 UnknownValue(serde_json::Value),
147}
148
149#[derive(Debug, Clone, Serialize, Deserialize)]
151#[serde(untagged)]
152pub enum OctoprintPrinterProfilesUpdateError {
153 Status409(crate::models::ErrorDetail),
154 Status400(crate::models::ErrorDetail),
155 Status401(crate::models::ErrorDetail),
156 Status403(crate::models::ErrorDetail),
157 Status500(crate::models::ErrorDetail),
158 UnknownValue(serde_json::Value),
159}
160
161#[derive(Debug, Clone, Serialize, Deserialize)]
163#[serde(untagged)]
164pub enum OctoprintProfileUpdateOrCreateError {
165 UnknownValue(serde_json::Value),
166}
167
168#[derive(Debug, Clone, Serialize, Deserialize)]
170#[serde(untagged)]
171pub enum OctoprintServerUpdateOrCreateError {
172 UnknownValue(serde_json::Value),
173}
174
175#[derive(Debug, Clone, Serialize, Deserialize)]
177#[serde(untagged)]
178pub enum OctoprintSettingsCreateError {
179 Status409(crate::models::ErrorDetail),
180 Status400(crate::models::ErrorDetail),
181 Status401(crate::models::ErrorDetail),
182 Status403(crate::models::ErrorDetail),
183 Status500(crate::models::ErrorDetail),
184 UnknownValue(serde_json::Value),
185}
186
187#[derive(Debug, Clone, Serialize, Deserialize)]
189#[serde(untagged)]
190pub enum OctoprintSettingsListError {
191 Status400(crate::models::ErrorDetail),
192 Status401(crate::models::ErrorDetail),
193 Status403(crate::models::ErrorDetail),
194 Status500(crate::models::ErrorDetail),
195 UnknownValue(serde_json::Value),
196}
197
198#[derive(Debug, Clone, Serialize, Deserialize)]
200#[serde(untagged)]
201pub enum OctoprintSettingsPartialUpdateError {
202 UnknownValue(serde_json::Value),
203}
204
205#[derive(Debug, Clone, Serialize, Deserialize)]
207#[serde(untagged)]
208pub enum OctoprintSettingsUpdateError {
209 Status409(crate::models::ErrorDetail),
210 Status400(crate::models::ErrorDetail),
211 Status401(crate::models::ErrorDetail),
212 Status403(crate::models::ErrorDetail),
213 Status500(crate::models::ErrorDetail),
214 UnknownValue(serde_json::Value),
215}
216
217#[derive(Debug, Clone, Serialize, Deserialize)]
219#[serde(untagged)]
220pub enum OctoprintSettingsUpdateOrCreateError {
221 UnknownValue(serde_json::Value),
222}
223
224#[derive(Debug, Clone, Serialize, Deserialize)]
226#[serde(untagged)]
227pub enum OctoprintUpdateError {
228 Status409(crate::models::ErrorDetail),
229 Status400(crate::models::ErrorDetail),
230 Status401(crate::models::ErrorDetail),
231 Status403(crate::models::ErrorDetail),
232 Status500(crate::models::ErrorDetail),
233 UnknownValue(serde_json::Value),
234}
235
236#[derive(Debug, Clone, Serialize, Deserialize)]
238#[serde(untagged)]
239pub enum PisOctoprintServerListError {
240 Status400(crate::models::ErrorDetail),
241 Status401(crate::models::ErrorDetail),
242 Status403(crate::models::ErrorDetail),
243 Status500(crate::models::ErrorDetail),
244 UnknownValue(serde_json::Value),
245}
246
247
248pub async fn octoprint_backups_create(configuration: &configuration::Configuration, hostname: &str, name: &str, octoprint_version: &str, file: std::path::PathBuf) -> Result<crate::models::OctoPrintBackup, Error<OctoprintBackupsCreateError>> {
249 let local_var_configuration = configuration;
250
251 let local_var_client = &local_var_configuration.client;
252
253 let local_var_uri_str = format!("{}/api/octoprint/backups/", local_var_configuration.base_path);
254 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
255
256 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
257 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
258 }
259 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
260 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
261 };
262 let mut local_var_form = reqwest::multipart::Form::new();
263 local_var_form = local_var_form.text("hostname", hostname.to_string());
264 local_var_form = local_var_form.text("name", name.to_string());
265 local_var_form = local_var_form.text("octoprint_version", octoprint_version.to_string());
266 let local_var_param_value = file;
267 let kind = infer::get_from_path(&local_var_param_value)?.map(|v| v.mime_type().to_string()).unwrap_or_else(|| "application/octet-stream".to_string());
268 let filebytes = tokio::fs::read(&local_var_param_value).await?;
269 let file_part = reqwest::multipart::Part::bytes(filebytes)
270 .file_name(local_var_param_value.display().to_string())
271 .mime_str(&kind)?;
272 local_var_form = local_var_form.part("file", file_part);
273 local_var_req_builder = local_var_req_builder.multipart(local_var_form);
274
275 let local_var_req = local_var_req_builder.build()?;
276 let local_var_resp = local_var_client.execute(local_var_req).await?;
277
278 let local_var_status = local_var_resp.status();
279 let local_var_content = local_var_resp.text().await?;
280
281 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
282 serde_json::from_str(&local_var_content).map_err(Error::from)
283 } else {
284 let local_var_entity: Option<OctoprintBackupsCreateError> = serde_json::from_str(&local_var_content).ok();
285 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
286 Err(Error::ResponseError(local_var_error))
287 }
288}
289
290pub async fn octoprint_backups_list(configuration: &configuration::Configuration, page: Option<i32>) -> Result<crate::models::PaginatedOctoPrintBackupList, Error<OctoprintBackupsListError>> {
291 let local_var_configuration = configuration;
292
293 let local_var_client = &local_var_configuration.client;
294
295 let local_var_uri_str = format!("{}/api/octoprint/backups/", local_var_configuration.base_path);
296 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
297
298 if let Some(ref local_var_str) = page {
299 local_var_req_builder = local_var_req_builder.query(&[("page", &local_var_str.to_string())]);
300 }
301 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
302 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
303 }
304 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
305 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
306 };
307
308 let local_var_req = local_var_req_builder.build()?;
309 let local_var_resp = local_var_client.execute(local_var_req).await?;
310
311 let local_var_status = local_var_resp.status();
312 let local_var_content = local_var_resp.text().await?;
313
314 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
315 serde_json::from_str(&local_var_content).map_err(Error::from)
316 } else {
317 let local_var_entity: Option<OctoprintBackupsListError> = serde_json::from_str(&local_var_content).ok();
318 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
319 Err(Error::ResponseError(local_var_error))
320 }
321}
322
323pub async fn octoprint_backups_retrieve(configuration: &configuration::Configuration, id: i32) -> Result<crate::models::OctoPrintBackup, Error<OctoprintBackupsRetrieveError>> {
324 let local_var_configuration = configuration;
325
326 let local_var_client = &local_var_configuration.client;
327
328 let local_var_uri_str = format!("{}/api/octoprint/backups/{id}/", local_var_configuration.base_path, id=id);
329 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
330
331 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
332 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
333 }
334 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
335 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
336 };
337
338 let local_var_req = local_var_req_builder.build()?;
339 let local_var_resp = local_var_client.execute(local_var_req).await?;
340
341 let local_var_status = local_var_resp.status();
342 let local_var_content = local_var_resp.text().await?;
343
344 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
345 serde_json::from_str(&local_var_content).map_err(Error::from)
346 } else {
347 let local_var_entity: Option<OctoprintBackupsRetrieveError> = serde_json::from_str(&local_var_content).ok();
348 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
349 Err(Error::ResponseError(local_var_error))
350 }
351}
352
353pub async fn octoprint_create(configuration: &configuration::Configuration, octo_print_server_request: crate::models::OctoPrintServerRequest) -> Result<crate::models::OctoPrintServer, Error<OctoprintCreateError>> {
354 let local_var_configuration = configuration;
355
356 let local_var_client = &local_var_configuration.client;
357
358 let local_var_uri_str = format!("{}/api/octoprint/", local_var_configuration.base_path);
359 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
360
361 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
362 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
363 }
364 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
365 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
366 };
367 local_var_req_builder = local_var_req_builder.json(&octo_print_server_request);
368
369 let local_var_req = local_var_req_builder.build()?;
370 let local_var_resp = local_var_client.execute(local_var_req).await?;
371
372 let local_var_status = local_var_resp.status();
373 let local_var_content = local_var_resp.text().await?;
374
375 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
376 serde_json::from_str(&local_var_content).map_err(Error::from)
377 } else {
378 let local_var_entity: Option<OctoprintCreateError> = serde_json::from_str(&local_var_content).ok();
379 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
380 Err(Error::ResponseError(local_var_error))
381 }
382}
383
384pub async fn octoprint_gcode_files_create(configuration: &configuration::Configuration, name: &str, file: std::path::PathBuf, hash: &str) -> Result<crate::models::GcodeFile, Error<OctoprintGcodeFilesCreateError>> {
385 let local_var_configuration = configuration;
386
387 let local_var_client = &local_var_configuration.client;
388
389 let local_var_uri_str = format!("{}/api/octoprint/gcode-files/", local_var_configuration.base_path);
390 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
391
392 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
393 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
394 }
395 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
396 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
397 };
398 let mut local_var_form = reqwest::multipart::Form::new();
399 local_var_form = local_var_form.text("name", name.to_string());
400 let local_var_param_value = file;
401 let kind = infer::get_from_path(&local_var_param_value)?.map(|v| v.mime_type().to_string()).unwrap_or_else(|| "application/octet-stream".to_string());
402 let filebytes = tokio::fs::read(&local_var_param_value).await?;
403 let file_part = reqwest::multipart::Part::bytes(filebytes)
404 .file_name(local_var_param_value.display().to_string())
405 .mime_str(&kind)?;
406 local_var_form = local_var_form.part("file", file_part);
407 local_var_form = local_var_form.text("hash", hash.to_string());
408 local_var_req_builder = local_var_req_builder.multipart(local_var_form);
409
410 let local_var_req = local_var_req_builder.build()?;
411 let local_var_resp = local_var_client.execute(local_var_req).await?;
412
413 let local_var_status = local_var_resp.status();
414 let local_var_content = local_var_resp.text().await?;
415
416 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
417 serde_json::from_str(&local_var_content).map_err(Error::from)
418 } else {
419 let local_var_entity: Option<OctoprintGcodeFilesCreateError> = serde_json::from_str(&local_var_content).ok();
420 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
421 Err(Error::ResponseError(local_var_error))
422 }
423}
424
425pub async fn octoprint_gcode_files_list(configuration: &configuration::Configuration, page: Option<i32>) -> Result<crate::models::PaginatedGcodeFileList, Error<OctoprintGcodeFilesListError>> {
426 let local_var_configuration = configuration;
427
428 let local_var_client = &local_var_configuration.client;
429
430 let local_var_uri_str = format!("{}/api/octoprint/gcode-files/", local_var_configuration.base_path);
431 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
432
433 if let Some(ref local_var_str) = page {
434 local_var_req_builder = local_var_req_builder.query(&[("page", &local_var_str.to_string())]);
435 }
436 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
437 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
438 }
439 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
440 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
441 };
442
443 let local_var_req = local_var_req_builder.build()?;
444 let local_var_resp = local_var_client.execute(local_var_req).await?;
445
446 let local_var_status = local_var_resp.status();
447 let local_var_content = local_var_resp.text().await?;
448
449 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
450 serde_json::from_str(&local_var_content).map_err(Error::from)
451 } else {
452 let local_var_entity: Option<OctoprintGcodeFilesListError> = serde_json::from_str(&local_var_content).ok();
453 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
454 Err(Error::ResponseError(local_var_error))
455 }
456}
457
458pub async fn octoprint_gcode_files_retrieve(configuration: &configuration::Configuration, id: i32) -> Result<crate::models::GcodeFile, Error<OctoprintGcodeFilesRetrieveError>> {
459 let local_var_configuration = configuration;
460
461 let local_var_client = &local_var_configuration.client;
462
463 let local_var_uri_str = format!("{}/api/octoprint/gcode-files/{id}/", local_var_configuration.base_path, id=id);
464 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
465
466 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
467 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
468 }
469 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
470 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
471 };
472
473 let local_var_req = local_var_req_builder.build()?;
474 let local_var_resp = local_var_client.execute(local_var_req).await?;
475
476 let local_var_status = local_var_resp.status();
477 let local_var_content = local_var_resp.text().await?;
478
479 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
480 serde_json::from_str(&local_var_content).map_err(Error::from)
481 } else {
482 let local_var_entity: Option<OctoprintGcodeFilesRetrieveError> = serde_json::from_str(&local_var_content).ok();
483 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
484 Err(Error::ResponseError(local_var_error))
485 }
486}
487
488pub async fn octoprint_list(configuration: &configuration::Configuration, page: Option<i32>) -> Result<crate::models::PaginatedOctoPrintServerList, Error<OctoprintListError>> {
489 let local_var_configuration = configuration;
490
491 let local_var_client = &local_var_configuration.client;
492
493 let local_var_uri_str = format!("{}/api/octoprint/", local_var_configuration.base_path);
494 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
495
496 if let Some(ref local_var_str) = page {
497 local_var_req_builder = local_var_req_builder.query(&[("page", &local_var_str.to_string())]);
498 }
499 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
500 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
501 }
502 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
503 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
504 };
505
506 let local_var_req = local_var_req_builder.build()?;
507 let local_var_resp = local_var_client.execute(local_var_req).await?;
508
509 let local_var_status = local_var_resp.status();
510 let local_var_content = local_var_resp.text().await?;
511
512 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
513 serde_json::from_str(&local_var_content).map_err(Error::from)
514 } else {
515 let local_var_entity: Option<OctoprintListError> = serde_json::from_str(&local_var_content).ok();
516 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
517 Err(Error::ResponseError(local_var_error))
518 }
519}
520
521pub async fn octoprint_partial_update(configuration: &configuration::Configuration, id: i32, patched_octo_print_server_request: Option<crate::models::PatchedOctoPrintServerRequest>) -> Result<crate::models::OctoPrintServer, Error<OctoprintPartialUpdateError>> {
522 let local_var_configuration = configuration;
523
524 let local_var_client = &local_var_configuration.client;
525
526 let local_var_uri_str = format!("{}/api/octoprint/{id}/", local_var_configuration.base_path, id=id);
527 let mut local_var_req_builder = local_var_client.request(reqwest::Method::PATCH, local_var_uri_str.as_str());
528
529 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
530 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
531 }
532 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
533 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
534 };
535 local_var_req_builder = local_var_req_builder.json(&patched_octo_print_server_request);
536
537 let local_var_req = local_var_req_builder.build()?;
538 let local_var_resp = local_var_client.execute(local_var_req).await?;
539
540 let local_var_status = local_var_resp.status();
541 let local_var_content = local_var_resp.text().await?;
542
543 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
544 serde_json::from_str(&local_var_content).map_err(Error::from)
545 } else {
546 let local_var_entity: Option<OctoprintPartialUpdateError> = serde_json::from_str(&local_var_content).ok();
547 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
548 Err(Error::ResponseError(local_var_error))
549 }
550}
551
552pub async fn octoprint_printer_profiles_create(configuration: &configuration::Configuration, octo_printer_profile_request: crate::models::OctoPrinterProfileRequest) -> Result<crate::models::OctoPrinterProfile, Error<OctoprintPrinterProfilesCreateError>> {
553 let local_var_configuration = configuration;
554
555 let local_var_client = &local_var_configuration.client;
556
557 let local_var_uri_str = format!("{}/api/octoprint/printer-profiles/", local_var_configuration.base_path);
558 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
559
560 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
561 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
562 }
563 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
564 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
565 };
566 local_var_req_builder = local_var_req_builder.json(&octo_printer_profile_request);
567
568 let local_var_req = local_var_req_builder.build()?;
569 let local_var_resp = local_var_client.execute(local_var_req).await?;
570
571 let local_var_status = local_var_resp.status();
572 let local_var_content = local_var_resp.text().await?;
573
574 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
575 serde_json::from_str(&local_var_content).map_err(Error::from)
576 } else {
577 let local_var_entity: Option<OctoprintPrinterProfilesCreateError> = serde_json::from_str(&local_var_content).ok();
578 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
579 Err(Error::ResponseError(local_var_error))
580 }
581}
582
583pub async fn octoprint_printer_profiles_list(configuration: &configuration::Configuration, page: Option<i32>) -> Result<crate::models::PaginatedOctoPrinterProfileList, Error<OctoprintPrinterProfilesListError>> {
584 let local_var_configuration = configuration;
585
586 let local_var_client = &local_var_configuration.client;
587
588 let local_var_uri_str = format!("{}/api/octoprint/printer-profiles/", local_var_configuration.base_path);
589 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
590
591 if let Some(ref local_var_str) = page {
592 local_var_req_builder = local_var_req_builder.query(&[("page", &local_var_str.to_string())]);
593 }
594 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
595 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
596 }
597 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
598 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
599 };
600
601 let local_var_req = local_var_req_builder.build()?;
602 let local_var_resp = local_var_client.execute(local_var_req).await?;
603
604 let local_var_status = local_var_resp.status();
605 let local_var_content = local_var_resp.text().await?;
606
607 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
608 serde_json::from_str(&local_var_content).map_err(Error::from)
609 } else {
610 let local_var_entity: Option<OctoprintPrinterProfilesListError> = serde_json::from_str(&local_var_content).ok();
611 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
612 Err(Error::ResponseError(local_var_error))
613 }
614}
615
616pub async fn octoprint_printer_profiles_partial_update(configuration: &configuration::Configuration, id: i32, patched_octo_printer_profile_request: Option<crate::models::PatchedOctoPrinterProfileRequest>) -> Result<crate::models::OctoPrinterProfile, Error<OctoprintPrinterProfilesPartialUpdateError>> {
617 let local_var_configuration = configuration;
618
619 let local_var_client = &local_var_configuration.client;
620
621 let local_var_uri_str = format!("{}/api/octoprint/printer-profiles/{id}/", local_var_configuration.base_path, id=id);
622 let mut local_var_req_builder = local_var_client.request(reqwest::Method::PATCH, local_var_uri_str.as_str());
623
624 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
625 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
626 }
627 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
628 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
629 };
630 local_var_req_builder = local_var_req_builder.json(&patched_octo_printer_profile_request);
631
632 let local_var_req = local_var_req_builder.build()?;
633 let local_var_resp = local_var_client.execute(local_var_req).await?;
634
635 let local_var_status = local_var_resp.status();
636 let local_var_content = local_var_resp.text().await?;
637
638 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
639 serde_json::from_str(&local_var_content).map_err(Error::from)
640 } else {
641 let local_var_entity: Option<OctoprintPrinterProfilesPartialUpdateError> = serde_json::from_str(&local_var_content).ok();
642 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
643 Err(Error::ResponseError(local_var_error))
644 }
645}
646
647pub async fn octoprint_printer_profiles_update(configuration: &configuration::Configuration, id: i32, octo_printer_profile_request: crate::models::OctoPrinterProfileRequest) -> Result<crate::models::OctoPrinterProfile, Error<OctoprintPrinterProfilesUpdateError>> {
648 let local_var_configuration = configuration;
649
650 let local_var_client = &local_var_configuration.client;
651
652 let local_var_uri_str = format!("{}/api/octoprint/printer-profiles/{id}/", local_var_configuration.base_path, id=id);
653 let mut local_var_req_builder = local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
654
655 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
656 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
657 }
658 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
659 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
660 };
661 local_var_req_builder = local_var_req_builder.json(&octo_printer_profile_request);
662
663 let local_var_req = local_var_req_builder.build()?;
664 let local_var_resp = local_var_client.execute(local_var_req).await?;
665
666 let local_var_status = local_var_resp.status();
667 let local_var_content = local_var_resp.text().await?;
668
669 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
670 serde_json::from_str(&local_var_content).map_err(Error::from)
671 } else {
672 let local_var_entity: Option<OctoprintPrinterProfilesUpdateError> = serde_json::from_str(&local_var_content).ok();
673 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
674 Err(Error::ResponseError(local_var_error))
675 }
676}
677
678pub async fn octoprint_profile_update_or_create(configuration: &configuration::Configuration, octo_printer_profile_request: crate::models::OctoPrinterProfileRequest) -> Result<crate::models::OctoPrinterProfile, Error<OctoprintProfileUpdateOrCreateError>> {
679 let local_var_configuration = configuration;
680
681 let local_var_client = &local_var_configuration.client;
682
683 let local_var_uri_str = format!("{}/api/octoprint/printer-profiles/update-or-create/", local_var_configuration.base_path);
684 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
685
686 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
687 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
688 }
689 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
690 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
691 };
692 local_var_req_builder = local_var_req_builder.json(&octo_printer_profile_request);
693
694 let local_var_req = local_var_req_builder.build()?;
695 let local_var_resp = local_var_client.execute(local_var_req).await?;
696
697 let local_var_status = local_var_resp.status();
698 let local_var_content = local_var_resp.text().await?;
699
700 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
701 serde_json::from_str(&local_var_content).map_err(Error::from)
702 } else {
703 let local_var_entity: Option<OctoprintProfileUpdateOrCreateError> = serde_json::from_str(&local_var_content).ok();
704 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
705 Err(Error::ResponseError(local_var_error))
706 }
707}
708
709pub async fn octoprint_server_update_or_create(configuration: &configuration::Configuration, octo_print_server_request: crate::models::OctoPrintServerRequest) -> Result<crate::models::OctoPrintServer, Error<OctoprintServerUpdateOrCreateError>> {
710 let local_var_configuration = configuration;
711
712 let local_var_client = &local_var_configuration.client;
713
714 let local_var_uri_str = format!("{}/api/octoprint/update-or-create/", local_var_configuration.base_path);
715 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
716
717 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
718 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
719 }
720 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
721 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
722 };
723 local_var_req_builder = local_var_req_builder.json(&octo_print_server_request);
724
725 let local_var_req = local_var_req_builder.build()?;
726 let local_var_resp = local_var_client.execute(local_var_req).await?;
727
728 let local_var_status = local_var_resp.status();
729 let local_var_content = local_var_resp.text().await?;
730
731 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
732 serde_json::from_str(&local_var_content).map_err(Error::from)
733 } else {
734 let local_var_entity: Option<OctoprintServerUpdateOrCreateError> = serde_json::from_str(&local_var_content).ok();
735 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
736 Err(Error::ResponseError(local_var_error))
737 }
738}
739
740pub async fn octoprint_settings_create(configuration: &configuration::Configuration, octo_print_settings_request: crate::models::OctoPrintSettingsRequest) -> Result<crate::models::OctoPrintSettings, Error<OctoprintSettingsCreateError>> {
741 let local_var_configuration = configuration;
742
743 let local_var_client = &local_var_configuration.client;
744
745 let local_var_uri_str = format!("{}/api/octoprint/settings/", local_var_configuration.base_path);
746 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
747
748 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
749 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
750 }
751 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
752 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
753 };
754 local_var_req_builder = local_var_req_builder.json(&octo_print_settings_request);
755
756 let local_var_req = local_var_req_builder.build()?;
757 let local_var_resp = local_var_client.execute(local_var_req).await?;
758
759 let local_var_status = local_var_resp.status();
760 let local_var_content = local_var_resp.text().await?;
761
762 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
763 serde_json::from_str(&local_var_content).map_err(Error::from)
764 } else {
765 let local_var_entity: Option<OctoprintSettingsCreateError> = serde_json::from_str(&local_var_content).ok();
766 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
767 Err(Error::ResponseError(local_var_error))
768 }
769}
770
771pub async fn octoprint_settings_list(configuration: &configuration::Configuration, page: Option<i32>) -> Result<crate::models::PaginatedOctoPrintSettingsList, Error<OctoprintSettingsListError>> {
772 let local_var_configuration = configuration;
773
774 let local_var_client = &local_var_configuration.client;
775
776 let local_var_uri_str = format!("{}/api/octoprint/settings/", local_var_configuration.base_path);
777 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
778
779 if let Some(ref local_var_str) = page {
780 local_var_req_builder = local_var_req_builder.query(&[("page", &local_var_str.to_string())]);
781 }
782 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
783 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
784 }
785 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
786 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
787 };
788
789 let local_var_req = local_var_req_builder.build()?;
790 let local_var_resp = local_var_client.execute(local_var_req).await?;
791
792 let local_var_status = local_var_resp.status();
793 let local_var_content = local_var_resp.text().await?;
794
795 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
796 serde_json::from_str(&local_var_content).map_err(Error::from)
797 } else {
798 let local_var_entity: Option<OctoprintSettingsListError> = serde_json::from_str(&local_var_content).ok();
799 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
800 Err(Error::ResponseError(local_var_error))
801 }
802}
803
804pub async fn octoprint_settings_partial_update(configuration: &configuration::Configuration, id: i32, patched_octo_print_settings_request: Option<crate::models::PatchedOctoPrintSettingsRequest>) -> Result<crate::models::OctoPrintSettings, Error<OctoprintSettingsPartialUpdateError>> {
805 let local_var_configuration = configuration;
806
807 let local_var_client = &local_var_configuration.client;
808
809 let local_var_uri_str = format!("{}/api/octoprint/settings/{id}/", local_var_configuration.base_path, id=id);
810 let mut local_var_req_builder = local_var_client.request(reqwest::Method::PATCH, local_var_uri_str.as_str());
811
812 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
813 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
814 }
815 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
816 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
817 };
818 local_var_req_builder = local_var_req_builder.json(&patched_octo_print_settings_request);
819
820 let local_var_req = local_var_req_builder.build()?;
821 let local_var_resp = local_var_client.execute(local_var_req).await?;
822
823 let local_var_status = local_var_resp.status();
824 let local_var_content = local_var_resp.text().await?;
825
826 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
827 serde_json::from_str(&local_var_content).map_err(Error::from)
828 } else {
829 let local_var_entity: Option<OctoprintSettingsPartialUpdateError> = serde_json::from_str(&local_var_content).ok();
830 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
831 Err(Error::ResponseError(local_var_error))
832 }
833}
834
835pub async fn octoprint_settings_update(configuration: &configuration::Configuration, id: i32, octo_print_settings_request: crate::models::OctoPrintSettingsRequest) -> Result<crate::models::OctoPrintSettings, Error<OctoprintSettingsUpdateError>> {
836 let local_var_configuration = configuration;
837
838 let local_var_client = &local_var_configuration.client;
839
840 let local_var_uri_str = format!("{}/api/octoprint/settings/{id}/", local_var_configuration.base_path, id=id);
841 let mut local_var_req_builder = local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
842
843 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
844 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
845 }
846 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
847 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
848 };
849 local_var_req_builder = local_var_req_builder.json(&octo_print_settings_request);
850
851 let local_var_req = local_var_req_builder.build()?;
852 let local_var_resp = local_var_client.execute(local_var_req).await?;
853
854 let local_var_status = local_var_resp.status();
855 let local_var_content = local_var_resp.text().await?;
856
857 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
858 serde_json::from_str(&local_var_content).map_err(Error::from)
859 } else {
860 let local_var_entity: Option<OctoprintSettingsUpdateError> = serde_json::from_str(&local_var_content).ok();
861 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
862 Err(Error::ResponseError(local_var_error))
863 }
864}
865
866pub async fn octoprint_settings_update_or_create(configuration: &configuration::Configuration, octo_print_settings_request: crate::models::OctoPrintSettingsRequest) -> Result<crate::models::OctoPrintSettings, Error<OctoprintSettingsUpdateOrCreateError>> {
867 let local_var_configuration = configuration;
868
869 let local_var_client = &local_var_configuration.client;
870
871 let local_var_uri_str = format!("{}/api/octoprint/settings/update-or-create/", local_var_configuration.base_path);
872 let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
873
874 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
875 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
876 }
877 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
878 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
879 };
880 local_var_req_builder = local_var_req_builder.json(&octo_print_settings_request);
881
882 let local_var_req = local_var_req_builder.build()?;
883 let local_var_resp = local_var_client.execute(local_var_req).await?;
884
885 let local_var_status = local_var_resp.status();
886 let local_var_content = local_var_resp.text().await?;
887
888 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
889 serde_json::from_str(&local_var_content).map_err(Error::from)
890 } else {
891 let local_var_entity: Option<OctoprintSettingsUpdateOrCreateError> = serde_json::from_str(&local_var_content).ok();
892 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
893 Err(Error::ResponseError(local_var_error))
894 }
895}
896
897pub async fn octoprint_update(configuration: &configuration::Configuration, id: i32, octo_print_server_request: crate::models::OctoPrintServerRequest) -> Result<crate::models::OctoPrintServer, Error<OctoprintUpdateError>> {
898 let local_var_configuration = configuration;
899
900 let local_var_client = &local_var_configuration.client;
901
902 let local_var_uri_str = format!("{}/api/octoprint/{id}/", local_var_configuration.base_path, id=id);
903 let mut local_var_req_builder = local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
904
905 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
906 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
907 }
908 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
909 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
910 };
911 local_var_req_builder = local_var_req_builder.json(&octo_print_server_request);
912
913 let local_var_req = local_var_req_builder.build()?;
914 let local_var_resp = local_var_client.execute(local_var_req).await?;
915
916 let local_var_status = local_var_resp.status();
917 let local_var_content = local_var_resp.text().await?;
918
919 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
920 serde_json::from_str(&local_var_content).map_err(Error::from)
921 } else {
922 let local_var_entity: Option<OctoprintUpdateError> = serde_json::from_str(&local_var_content).ok();
923 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
924 Err(Error::ResponseError(local_var_error))
925 }
926}
927
928pub async fn pis_octoprint_server_list(configuration: &configuration::Configuration, pi_id: i32, page: Option<i32>) -> Result<crate::models::PaginatedOctoPrintServerList, Error<PisOctoprintServerListError>> {
929 let local_var_configuration = configuration;
930
931 let local_var_client = &local_var_configuration.client;
932
933 let local_var_uri_str = format!("{}/api/pis/{pi_id}/octoprint-server/", local_var_configuration.base_path, pi_id=pi_id);
934 let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
935
936 if let Some(ref local_var_str) = page {
937 local_var_req_builder = local_var_req_builder.query(&[("page", &local_var_str.to_string())]);
938 }
939 if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
940 local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
941 }
942 if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
943 local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
944 };
945
946 let local_var_req = local_var_req_builder.build()?;
947 let local_var_resp = local_var_client.execute(local_var_req).await?;
948
949 let local_var_status = local_var_resp.status();
950 let local_var_content = local_var_resp.text().await?;
951
952 if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
953 serde_json::from_str(&local_var_content).map_err(Error::from)
954 } else {
955 let local_var_entity: Option<PisOctoprintServerListError> = serde_json::from_str(&local_var_content).ok();
956 let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
957 Err(Error::ResponseError(local_var_error))
958 }
959}
960