Skip to content

Commit

Permalink
chore: Move ContractService implementation to Contract
Browse files Browse the repository at this point in the history
  • Loading branch information
chubei committed Aug 23, 2023
1 parent 13ccd0c commit 87c0061
Show file tree
Hide file tree
Showing 11 changed files with 330 additions and 312 deletions.
2 changes: 1 addition & 1 deletion dozer-cli/src/errors.rs
Original file line number Diff line number Diff line change
Expand Up @@ -190,7 +190,7 @@ pub enum ConfigCombineError {

#[derive(Debug, Error)]
pub enum BuildError {
#[error("Endpoint {0} found in DAG but not in configuration file")]
#[error("Endpoint {0} not found in DAG")]
MissingEndpoint(String),
#[error("Got mismatching primary key for `{endpoint_name}`. Expected: `{expected:?}`, got: `{actual:?}`")]
MismatchPrimaryKey {
Expand Down
4 changes: 3 additions & 1 deletion dozer-cli/src/live/errors.rs
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
use crate::errors::{CliError, OrchestrationError};
use crate::errors::{BuildError, CliError, OrchestrationError};
use dozer_core::errors::ExecutionError;
use dozer_sql::pipeline::errors::PipelineError;

Expand Down Expand Up @@ -28,6 +28,8 @@ pub enum LiveError {
#[error("Cannot start ui server: {0}")]
CannotStartUiServer(#[source] std::io::Error),

#[error(transparent)]
Build(#[from] BuildError),
#[error(transparent)]
PipelineError(#[from] PipelineError),
#[error(transparent)]
Expand Down
141 changes: 0 additions & 141 deletions dozer-cli/src/live/graph.rs

This file was deleted.

8 changes: 0 additions & 8 deletions dozer-cli/src/live/helper.rs

This file was deleted.

4 changes: 1 addition & 3 deletions dozer-cli/src/live/mod.rs
Original file line number Diff line number Diff line change
@@ -1,14 +1,12 @@
mod downloader;
mod errors;
mod graph;
mod server;
mod state;
mod watcher;
use std::sync::Arc;
mod helper;
use self::state::LiveState;
use crate::{cli::types::Live, live::server::LIVE_PORT, shutdown::ShutdownReceiver};
use dozer_types::{grpc_types::live::ConnectResponse, log::info};
use std::sync::Arc;
mod progress;
pub use errors::LiveError;
use futures::stream::{AbortHandle, Abortable};
Expand Down
Loading

0 comments on commit 87c0061

Please sign in to comment.