Apps/ImageApi
1
0
Fork 0
Code Issues Pull Requests 1 Releases Wiki Activity

feature/exif-endpoint #44

Merged
cameron merged 29 commits from feature/exif-endpoint into master 2025-12-27 03:25:19 +00:00
Conversation 0 Commits 29 Files Changed 34 +7 -4
2 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit c0021734b6 - Show all commits

6
src/main.rs
View File

@@ -158,7 +158,8 @@ async fn get_file_metadata(
let tracer = global_tracer(); let tracer = global_tracer();
let context = extract_context_from_request(&request); let context = extract_context_from_request(&request);
let mut span = tracer.start_with_context("get_file_metadata", &context); let mut span = tracer.start_with_context("get_file_metadata", &context);
let span_context = opentelemetry::Context::current(); let span_context =
opentelemetry::Context::new().with_remote_span_context(span.span_context().clone());
let full_path = is_valid_full_path(&app_state.base_path, &path.path, false); let full_path = is_valid_full_path(&app_state.base_path, &path.path, false);
@@ -206,7 +207,8 @@ async fn upload_image(
let tracer = global_tracer(); let tracer = global_tracer();
let context = extract_context_from_request(&request); let context = extract_context_from_request(&request);
let mut span = tracer.start_with_context("upload_image", &context); let mut span = tracer.start_with_context("upload_image", &context);
let span_context = opentelemetry::Context::current(); let span_context =
opentelemetry::Context::new().with_remote_span_context(span.span_context().clone());
let mut file_content: BytesMut = BytesMut::new(); let mut file_content: BytesMut = BytesMut::new();
let mut file_name: Option<String> = None; let mut file_name: Option<String> = None;

5
src/memories.rs
View File

@@ -6,7 +6,7 @@ use chrono::{
}; };
use log::{debug, trace, warn}; use log::{debug, trace, warn};
use opentelemetry::KeyValue; use opentelemetry::KeyValue;
use opentelemetry::trace::{Span, Status, Tracer}; use opentelemetry::trace::{Span, Status, TraceContextExt, Tracer};
use rayon::prelude::*; use rayon::prelude::*;
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
use std::collections::HashSet; use std::collections::HashSet;
@@ -476,7 +476,8 @@ pub async fn list_memories(
let tracer = global_tracer(); let tracer = global_tracer();
let parent_context = extract_context_from_request(&request); let parent_context = extract_context_from_request(&request);
let mut span = tracer.start_with_context("list_memories", &parent_context); let mut span = tracer.start_with_context("list_memories", &parent_context);
let span_context = opentelemetry::Context::current(); let span_context =
opentelemetry::Context::new().with_remote_span_context(span.span_context().clone());
let span_mode = q.span.unwrap_or(MemoriesSpan::Day); let span_mode = q.span.unwrap_or(MemoriesSpan::Day);
let years_back: u32 = 15; let years_back: u32 = 15;