filespooler 1.2.4

Sequential, distributed, POSIX-style job queue processing
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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153

/*! Handling CLI commands */
/*
    Copyright (C) 2022 John Goerzen <jgoerzen@complete.org>

    This program is free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.

    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with this program.  If not, see <http://www.gnu.org/licenses/>.

*/

use crate::cmd::cmd_exec::{ProcessOpts, QueueProcessOpts};
use crate::cmd::cmd_prepare::{PrepareOpts, SFOpts, SFSetOpts};
use crate::cmd::cmd_queue::{
    QueueInitOpts, QueueJobOpts, QueueOpts, QueueOptsWithDecoder, QueueSetSeqOpts,
};
use clap::{Args, Parser, Subcommand};
use tracing::*;
use uuid::Uuid;
pub mod cmd_exec;
pub mod cmd_info;
pub mod cmd_prepare;
pub mod cmd_queue;

/// Sub-commands
#[derive(Debug, Subcommand)]
pub enum Command {
    /// Display a UUID to stdout
    GenUUID,

    /// Display a fspl-*.fspl filename to stdout
    GenFilename,

    /// Prepare a command for transmission, writing to stdout
    Prepare(PrepareOpts),

    /// Prepare a NOP packet for transmission, writing to stdout
    PrepareNOP(SFOpts),

    /// Prepare a fail packet for transmission, writing to stdout
    PrepareFail(SFOpts),

    /// Get the next sequence number for prepare
    PrepareGetNext(SFOpts),

    /// Set the next sequence number for prepare
    PrepareSetNext(SFSetOpts),

    /// Process a queue
    QueueProcess(QueueProcessOpts),

    /// Initialize a queue
    QueueInit(QueueInitOpts),

    /// Show information about a specific job ID in a queue
    QueueInfo(QueueJobOpts),

    /// Save a packet from stdin to a queue
    QueueWrite(QueueOpts),

    /// Gets information about the jobs in a queue
    QueueLs(QueueOptsWithDecoder),

    /// Prints the next sequence number for the queue
    QueueGetNext(QueueOpts),

    /// Sets the next sequence number for the queue
    QueueSetNext(QueueSetSeqOpts),

    /// Dump the payload of a job to stdout
    QueuePayload(QueueJobOpts),

    /// Get information about a packet piped to filespooler on stdin
    StdinInfo,

    /// Dumps the payload from the packet on stdin to stdout
    StdinPayload,

    /// Process a command from a job packet read from stdin
    StdinProcess(ProcessOpts),

    /// Show the license information
    ShowLicense,
}

#[derive(Debug, Args)]
pub struct GlobalOpts {
    /// Gives the logging (to stderr) level.  Default is INFO.  Options
    /// in order from most to least info: TRACE, DEBUG, INFO, WARN, ERROR.
    #[arg(long, short, value_name = "LEVEL", default_value_t = Level::INFO)]
    pub log_level: Level,
}

#[derive(Parser, Debug)]
#[command(author, version, about)]
pub struct Cli {
    #[clap(flatten)]
    pub globalopts: GlobalOpts,

    #[clap(subcommand)]
    pub command: Command,
}

pub fn parse() -> Cli {
    Cli::parse()
}

pub static LICENSE: &str = "\
Filespooler

    Copyright (C) 2022 John Goerzen <jgoerzen@complete.org>

    This program is free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.

    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with this program.  If not, see <http://www.gnu.org/licenses/>.
";

pub fn cmd_showlicense() -> Result<(), anyhow::Error> {
    println!("{}", LICENSE);

    Ok(())
}

pub fn cmd_genuuid() -> Result<(), anyhow::Error> {
    let mut buf = Uuid::encode_buffer();
    let uuid = Uuid::new_v4().hyphenated().encode_lower(&mut buf);
    println!("{}", uuid);
    Ok(())
}

pub fn cmd_genfilename() -> Result<(), anyhow::Error> {
    let mut buf = Uuid::encode_buffer();
    let uuid = Uuid::new_v4().hyphenated().encode_lower(&mut buf);
    println!("fspl-{}.fspl", uuid);
    Ok(())
}