tnn 0.1.3

A quality of life developer tool to interact with Telenor services
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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65

use crate::{
	call,
	core::api::{calls::WithCore, calls::WITH_CORE, Core, NAME},
	extension::{Call, CallContext, CallOutput, Extension, ExtensionContext},
	util::parent_command::ParentCommand,
};
use anyhow::Result;
use clap::CommandFactory;
use thiserror::Error;

use super::app::App;

pub const RUN: Call<(), ()> = call!((), (), "run", NAME);

pub static MANIFEST: Extension = Extension {
	name: env!("CARGO_PKG_NAME"),
	version: env!("CARGO_PKG_VERSION"),
	dependencies: &[],
	init: &|ctx| Box::pin(async { core_init(ctx).await }),
};

async fn core_init(ctx: ExtensionContext) -> Result<()> {
	ctx.state
		.lock()
		.await
		.put(Core::new(ParentCommand::new(<App as CommandFactory>::command())));
	crate::debug!("Added core");

	ctx.add_call(&RUN, &run).await?;
	ctx.add_call(&WITH_CORE, &with_core).await?;
	Ok(())
}

fn with_core(ctx: CallContext<WithCore>) -> CallOutput<()> {
	Box::pin(async move {
		let mut state = ctx.state.lock().await;
		crate::debug!("Taking core by {}", ctx.caller);
		let core1 = state.take::<Core>()?;
		crate::debug!("Core stolen by {}", ctx.caller);
		state.put(ctx.argument.0(core1)?);
		crate::debug!("Core given back by {}", ctx.caller);
		Ok(())
	})
}

fn run(ctx: CallContext<()>) -> CallOutput<()> {
	Box::pin(async move {
		if ctx.caller != "" {
			return Err(CallerNotAllowedError("tnn/run", ctx.caller).into());
		}

		let (command, handler) = ctx.state.lock().await.take::<Core>()?.finish().build();

		let matches = command.get_matches();

		crate::debug!("Running application!");
		handler(&matches).await?;

		Ok(())
	})
}

#[derive(Error, Debug)]
#[error("Call '{0}' can only be executed by owner, called by '{1}'")]
struct CallerNotAllowedError(&'static str, &'static str);