Skip to content

Commit

Permalink
stick with single style of reference
Browse files Browse the repository at this point in the history
  • Loading branch information
michaeldjeffrey committed Aug 2, 2024
1 parent 7732150 commit da594c7
Showing 1 changed file with 14 additions and 15 deletions.
29 changes: 14 additions & 15 deletions mobile_verifier/src/coverage.rs
Original file line number Diff line number Diff line change
Expand Up @@ -20,9 +20,7 @@ use futures::{
use h3o::{CellIndex, LatLng};
use helium_proto::services::{
mobile_config::NetworkKeyRole,
poc_mobile::{
self as proto, CoverageObjectV1, CoverageObjectValidity, SignalLevel as SignalLevelProto,
},
poc_mobile::{self as proto, CoverageObjectValidity, SignalLevel as SignalLevelProto},
};
use hex_assignments::assignment::HexAssignments;
use hextree::Cell;
Expand Down Expand Up @@ -88,17 +86,18 @@ impl CoverageDaemon {
auth_client: AuthorizationClient,
new_coverage_object_notifier: NewCoverageObjectNotifier,
) -> anyhow::Result<impl ManagedTask> {
let (valid_coverage_objs, valid_coverage_objs_server) = CoverageObjectV1::file_sink_opts(
settings.store_base_path(),
file_upload.clone(),
env!("CARGO_PKG_NAME"),
|builder| {
builder
.auto_commit(false)
.roll_time(Duration::from_secs(15 * 60))
},
)
.await?;
let (valid_coverage_objs, valid_coverage_objs_server) =
proto::CoverageObjectV1::file_sink_opts(
settings.store_base_path(),
file_upload.clone(),
env!("CARGO_PKG_NAME"),
|builder| {
builder
.auto_commit(false)
.roll_time(Duration::from_secs(15 * 60))
},
)
.await?;

let (coverage_objs, coverage_objs_server) =
file_source::continuous_source::<CoverageObjectIngestReport, _>()
Expand Down Expand Up @@ -129,7 +128,7 @@ impl CoverageDaemon {
pool: PgPool,
auth_client: AuthorizationClient,
coverage_objs: Receiver<FileInfoStream<CoverageObjectIngestReport>>,
coverage_obj_sink: FileSinkClient<proto::CoverageObjectV1>,
coverage_obj_sink: FileSinkClient<CoverageObjectV1>,
new_coverage_object_notifier: NewCoverageObjectNotifier,
) -> Self {
Self {
Expand Down

0 comments on commit da594c7

Please sign in to comment.