diff --git a/upub/cli/Cargo.toml b/upub/cli/Cargo.toml
index 2884a7d..ec11cdf 100644
--- a/upub/cli/Cargo.toml
+++ b/upub/cli/Cargo.toml
@@ -13,7 +13,6 @@ readme = "README.md"
 [dependencies]
 apb = { path = "../../apb/" }
 upub = { path = "../core" }
-upub-processor = { path = "../processor/" }
 tracing = "0.1"
 serde_json = "1"
 sha256 = "1.5"
diff --git a/upub/cli/src/fetch.rs b/upub/cli/src/fetch.rs
index ef99456..5f89fe2 100644
--- a/upub/cli/src/fetch.rs
+++ b/upub/cli/src/fetch.rs
@@ -1,5 +1,5 @@
 use sea_orm::EntityTrait;
-use upub_processor::{fetch::{Fetchable, PullError}, normalize::{AP, Normalizer}};
+use upub::traits::{fetch::{Fetchable, PullError}, Normalizer};
 
 pub async fn fetch(ctx: upub::Context, uri: String, save: bool) -> Result<(), PullError> {
 	use apb::Base;
@@ -15,7 +15,7 @@ pub async fn fetch(ctx: upub::Context, uri: String, save: bool) -> Result<(), Pu
 		match obj.base_type() {
 			Ok(apb::BaseType::Object(apb::ObjectType::Actor(_))) => {
 				upub::model::actor::Entity::insert(
-					AP::actor_q(&obj).unwrap()
+					upub::AP::actor_q(&obj).unwrap()
 				).exec(ctx.db()).await.unwrap();
 			},
 			Ok(apb::BaseType::Object(apb::ObjectType::Activity(_))) => {
diff --git a/upub/cli/src/fix.rs b/upub/cli/src/fix.rs
index a782a12..d7b8394 100644
--- a/upub/cli/src/fix.rs
+++ b/upub/cli/src/fix.rs
@@ -1,6 +1,6 @@
 use sea_orm::EntityTrait;
 
-pub async fn fix(ctx: upub::Context, likes: bool, shares: bool, replies: bool) -> upub::Result<()> {
+pub async fn fix(ctx: upub::Context, likes: bool, shares: bool, replies: bool) -> Result<(), sea_orm::DbErr> {
 	use futures::TryStreamExt;
 	let db = ctx.db();
 
diff --git a/upub/cli/src/lib.rs b/upub/cli/src/lib.rs
index a8f9009..7fe394f 100644
--- a/upub/cli/src/lib.rs
+++ b/upub/cli/src/lib.rs
@@ -93,12 +93,12 @@ pub enum CliCommand {
 	}
 }
 
-pub async fn run(ctx: upub::Context, command: CliCommand) -> upub::Result<()> {
+pub async fn run(ctx: upub::Context, command: CliCommand) -> Result<(), Box<dyn std::error::Error>> {
 	match command {
 		CliCommand::Faker { count } =>
 			Ok(faker(ctx, count as i64).await?),
 		CliCommand::Fetch { uri, save } =>
-			Ok(fetch(ctx, uri, save).await.map_err(|_e| upub::Error::internal_server_error())?),
+			Ok(fetch(ctx, uri, save).await?),
 		CliCommand::Relay { actor, accept } =>
 			Ok(relay(ctx, actor, accept).await?),
 		CliCommand::Fix { likes, shares, replies } =>
diff --git a/upub/cli/src/register.rs b/upub/cli/src/register.rs
index 9ef54b0..607664b 100644
--- a/upub/cli/src/register.rs
+++ b/upub/cli/src/register.rs
@@ -1,4 +1,4 @@
-use upub::server::admin::Administrable;
+use upub::traits::Administrable;
 
 pub async fn register(
 	ctx: upub::Context,
@@ -8,7 +8,7 @@ pub async fn register(
 	summary: Option<String>,
 	avatar_url: Option<String>,
 	banner_url: Option<String>,
-) -> upub::Result<()> {
+) -> Result<(), sea_orm::DbErr> {
 	ctx.register_user(
 		username.clone(),
 		password,
diff --git a/upub/cli/src/relay.rs b/upub/cli/src/relay.rs
index c2a672e..30eb4ca 100644
--- a/upub/cli/src/relay.rs
+++ b/upub/cli/src/relay.rs
@@ -1,8 +1,7 @@
 use sea_orm::{ActiveValue::{Set, NotSet}, ColumnTrait, EntityTrait, QueryFilter, QueryOrder};
+use upub::traits::Addresser;
 
-use upub_processor::address::Addresser;
-
-pub async fn relay(ctx: upub::Context, actor: String, accept: bool) -> upub::Result<()> {
+pub async fn relay(ctx: upub::Context, actor: String, accept: bool) -> Result<(), sea_orm::DbErr> {
 	let aid = ctx.aid(&uuid::Uuid::new_v4().to_string());
 
 	let mut activity_model = upub::model::activity::ActiveModel {
diff --git a/upub/cli/src/update.rs b/upub/cli/src/update.rs
index cac556a..adf30e4 100644
--- a/upub/cli/src/update.rs
+++ b/upub/cli/src/update.rs
@@ -1,9 +1,8 @@
 use futures::TryStreamExt;
 use sea_orm::{ActiveValue::Set, ColumnTrait, EntityTrait, QueryFilter};
+use upub::traits::Fetcher;
 
-use upub_processor::{fetch::Fetcher, normalize::AP};
-
-pub async fn update_users(ctx: upub::Context, days: i64) -> upub::Result<()> {
+pub async fn update_users(ctx: upub::Context, days: i64) -> Result<(), sea_orm::DbErr> {
 	let mut count = 0;
 	let mut insertions = Vec::new();
 
@@ -19,7 +18,7 @@ pub async fn update_users(ctx: upub::Context, days: i64) -> upub::Result<()> {
 			match ctx.pull(&user.id).await.map(|x| x.actor()) {
 				Err(e) => tracing::warn!("could not update user {}: {e}", user.id),
 				Ok(Err(e)) => tracing::warn!("could not update user {}: {e}", user.id),
-				Ok(Ok(doc)) => match AP::actor_q(&doc) {
+				Ok(Ok(doc)) => match upub::AP::actor_q(&doc) {
 					Ok(mut u) => {
 						u.internal = Set(user.internal);
 						u.updated = Set(chrono::Utc::now());