upub-cli 0.3.2

cli maintenance tasks for upub
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

use futures::TryStreamExt;
use sea_orm::{ColumnTrait, QueryFilter, QueryOrder};
use upub::selector::{RichFillable, RichObject};


pub async fn export(
	ctx: upub::Context,
	actor: String,
	file: std::path::PathBuf,
	pretty: bool,
) -> Result<(), Box<dyn std::error::Error>> {
	let uid = ctx.uid(&actor);
	let internal = upub::model::actor::Entity::ap_to_internal(&uid, ctx.db())
		.await?
		.ok_or(sea_orm::DbErr::RecordNotFound(format!("could not find user {actor}")))?;

	let mut objects = Vec::new();
	
	let mut stream = upub::Query::objects(upub::query_feed_opts!(Some(internal), true))
		.filter(upub::model::object::Column::AttributedTo.eq(uid))
		.order_by_asc(upub::model::addressing::Column::Published)
		.order_by_asc(upub::model::activity::Column::Internal)
		.into_model::<RichObject>()
		.stream(ctx.db())
		.await?;

	while let Some(obj) = stream.try_next().await? {
		objects.push(ctx.ap(obj.load_batched_models(ctx.db()).await?));
	}

	let writer = std::fs::File::create(file)?;

	if pretty {
		serde_json::to_writer_pretty(writer, &objects)?;
	} else {
		serde_json::to_writer(writer, &objects)?;
	}

	Ok(())
}