aboutsummaryrefslogtreecommitdiffhomepage
path: root/crates/shirabe/src/repository/composer_repository.rs
diff options
context:
space:
mode:
authornsfisis <nsfisis@gmail.com>2026-06-09 00:09:08 +0900
committernsfisis <nsfisis@gmail.com>2026-06-09 00:09:20 +0900
commit436e12381dd79e419dce755718be17b66d73e17f (patch)
tree09dc809c64efe407b4049695341519ce26c411b3 /crates/shirabe/src/repository/composer_repository.rs
parent1c0eb589741de4aa52ef941ff9315b34dbe48aa0 (diff)
downloadphp-shirabe-436e12381dd79e419dce755718be17b66d73e17f.tar.gz
php-shirabe-436e12381dd79e419dce755718be17b66d73e17f.tar.zst
php-shirabe-436e12381dd79e419dce755718be17b66d73e17f.zip
feat(event-dispatcher): unify event dispatch via EventInterface trait
Extract a superclass-trait EventInterface from the base Event. pool_builder's PrePoolCreateEvent stays deferred: its constructor needs owned, non-cloneable Request and repository boxes the builder only holds by reference (owned-payload blocker). The event is plugin-only, so its construction is re-tagged TODO(plugin). Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
Diffstat (limited to 'crates/shirabe/src/repository/composer_repository.rs')
-rw-r--r--crates/shirabe/src/repository/composer_repository.rs43
1 files changed, 27 insertions, 16 deletions
diff --git a/crates/shirabe/src/repository/composer_repository.rs b/crates/shirabe/src/repository/composer_repository.rs
index 3dbca7d..f634e23 100644
--- a/crates/shirabe/src/repository/composer_repository.rs
+++ b/crates/shirabe/src/repository/composer_repository.rs
@@ -2757,10 +2757,12 @@ impl ComposerRepository {
.map(|(k, v)| (k, Box::new(v)))
.collect(),
);
- // TODO(phase-b): dispatcher.dispatch expects Option<Event>, not concrete event types;
- // need a way to pass PreFileDownloadEvent through EventDispatcher's API.
- let _ = &mut pre_file_download_event;
- dispatcher.dispatch(Some(pre_file_download_event.get_name()), None)?;
+ let pre_file_download_event_name =
+ pre_file_download_event.get_name().to_string();
+ dispatcher.dispatch(
+ Some(&pre_file_download_event_name),
+ Some(&mut pre_file_download_event),
+ )?;
filename = pre_file_download_event.get_processed_url().to_string();
options = pre_file_download_event
.get_transport_options()
@@ -2815,9 +2817,12 @@ impl ComposerRepository {
m.into()
},
);
- // TODO(phase-b): dispatcher.dispatch expects Option<Event>, not concrete event types
- let _ = &mut post_file_download_event;
- dispatcher.dispatch(Some(post_file_download_event.get_name()), None)?;
+ let post_file_download_event_name =
+ post_file_download_event.get_name().to_string();
+ dispatcher.dispatch(
+ Some(&post_file_download_event_name),
+ Some(&mut post_file_download_event),
+ )?;
}
let decoded = response.decode_json()?;
@@ -2954,9 +2959,11 @@ impl ComposerRepository {
.map(|(k, v)| (k, Box::new(v)))
.collect(),
);
- // TODO(phase-b): dispatcher.dispatch expects Option<Event>, not concrete event types
- let _ = &mut pre_file_download_event;
- dispatcher.dispatch(Some(pre_file_download_event.get_name()), None)?;
+ let pre_file_download_event_name = pre_file_download_event.get_name().to_string();
+ dispatcher.dispatch(
+ Some(&pre_file_download_event_name),
+ Some(&mut pre_file_download_event),
+ )?;
filename = pre_file_download_event.get_processed_url().to_string();
options = pre_file_download_event
.get_transport_options()
@@ -3015,9 +3022,11 @@ impl ComposerRepository {
m.into()
},
);
- // TODO(phase-b): dispatcher.dispatch expects Option<Event>, not concrete event types
- let _ = &mut post_file_download_event;
- dispatcher.dispatch(Some(post_file_download_event.get_name()), None)?;
+ let post_file_download_event_name = post_file_download_event.get_name().to_string();
+ dispatcher.dispatch(
+ Some(&post_file_download_event_name),
+ Some(&mut post_file_download_event),
+ )?;
}
let decoded = response.decode_json()?;
@@ -3120,9 +3129,11 @@ impl ComposerRepository {
.map(|(k, v)| (k, Box::new(v)))
.collect(),
);
- // TODO(phase-b): dispatcher.dispatch expects Option<Event>, not concrete event types
- let _ = &mut pre_file_download_event;
- dispatcher.dispatch(Some(pre_file_download_event.get_name()), None)?;
+ let pre_file_download_event_name = pre_file_download_event.get_name().to_string();
+ dispatcher.dispatch(
+ Some(&pre_file_download_event_name),
+ Some(&mut pre_file_download_event),
+ )?;
filename = pre_file_download_event.get_processed_url().to_string();
options = pre_file_download_event
.get_transport_options()