diff --git a/crates/moments-data/src/github_repo.rs b/crates/moments-data/src/github_repo.rs index 42bbbab..807133f 100644 --- a/crates/moments-data/src/github_repo.rs +++ b/crates/moments-data/src/github_repo.rs @@ -244,13 +244,18 @@ fn parse_commit(item: &Value, repo: &Repo) -> Option { .ok()? .with_timezone(&Utc); + let mut payload = item.clone(); + if let Some(obj) = payload.as_object_mut() { + obj.insert("_repo".into(), Value::String(repo.full_name.clone())); + } + Some(Event { id: format!("github-commit:{sha}"), source: Source::Github, action: "Commit".into(), occurred_at, public: !repo.private, - payload: item.clone(), + payload, }) } diff --git a/crates/moments-data/src/lib.rs b/crates/moments-data/src/lib.rs index 0cb317f..4bb4a46 100644 --- a/crates/moments-data/src/lib.rs +++ b/crates/moments-data/src/lib.rs @@ -145,7 +145,8 @@ impl EventReader for PgStore { CASE source WHEN 'github' THEN COALESCE( payload->'repo'->>'name', - payload->'repository'->>'full_name' + payload->'repository'->>'full_name', + payload->>'_repo' ) WHEN 'gitea' THEN COALESCE( payload->'repo'->>'full_name',