Merge branch 'master' into data-subsystem

Author: jondot

docs-site/content/docs/processing/task.md

@@ -15,8 +15,9 @@ top = false
 flair =[]
 +++
 
-Tasks in `Loco` serve as ad-hoc functionalities to handle specific aspects of your application. Whether you need to fix data, send emails, delete a user, or update a customer order, creating a dedicated task for each scenario provides a flexible and efficient solution. While tasks require manual execution, the investment is worthwhile for several reasons:
+Tasks in `Loco` serve as ad-hoc functionalities to handle specific aspects of your application. Whether you need to fix data, send emails, delete a user, or update a customer order, creating a dedicated task for each scenario provides a flexible and efficient solution. You can run tasks manually or by [scheduling the task](@/docs/processing/scheduler.md).
 
+Creating tasks is worthwhile for several reasons:
 - **Automation of Manual Work:** Tasks automate manual processes, streamlining repetitive actions.
 - **Utilization of Familiar Components:** Leverage your app's models, libraries, and existing logic within tasks.
 - **Elimination of UI Development:** Tasks don't require building user interfaces, focusing solely on backend operations.
@@ -56,6 +57,23 @@ cargo loco task <TASK_NAME>
 ```
 <!-- </snip> -->
 
+### Running a Task with Parameters
+
+To pass parameters to a task, add a list of key:value to the command
+```sh
+[PARAMS]...  Task params (e.g. <`my_task`> foo:bar baz:qux)`
+```
+```sh
+cargo loco task <TASK_NAME> [PARAMS]...
+```
+
+Then use that value using [`cli_arg`](https://docs.rs/loco-rs/latest/loco_rs/task/struct.Vars.html#method.cli_arg) in the `run` method of the task
+```rust
+async fn run(&self, app_context: &AppContext, vars: &task::Vars) -> Result<()> {
+    let foo = vars.cli_arg("foo");
+    Ok(())
+}
+```
 
 ## Listing All Tasks
 

src/schema.rs

@@ -62,77 +62,78 @@ pub enum ColType {
     PkAuto,
     PkUuid,
     CharLen(u32),
+    CharLenWithDefault(u32, char),
     CharLenNull(u32),
     CharLenUniq(u32),
     Char,
+    CharWithDefault(char),
     CharNull,
     CharUniq,
     StringLen(u32),
+    StringLenWithDefault(u32, String),
     StringLenNull(u32),
     StringLenUniq(u32),
     String,
+    StringWithDefault(String),
     StringNull,
     StringUniq,
     Text,
+    TextWithDefault(String),
     TextNull,
     TextUniq,
     Integer,
+    IntegerWithDefault(i32),
     IntegerNull,
     IntegerUniq,
     Unsigned,
+    UnsignedWithDefault(u32),
     UnsignedNull,
     UnsignedUniq,
-    // Tiny fields are not supported due to differences in data types between PostgreSQL and SQLite:
-    //  * Postgres: i16
-    //  * Sqlite: i8
-    // TinyUnsigned,
-    // TinyUnsignedNull,
-    // TinyUnsignedUniq,
     SmallUnsigned,
+    SmallUnsignedWithDefault(u16),
     SmallUnsignedNull,
     SmallUnsignedUniq,
     BigUnsigned,
+    BigUnsignedWithDefault(u64),
     BigUnsignedNull,
     BigUnsignedUniq,
-    // Tiny fields are not supported due to differences in data types between PostgreSQL and SQLite:
-    //  * Postgres: i16
-    //  * Sqlite: i8
-    // TinyInteger,
-    // TinyIntegerNull,
-    // TinyIntegerUniq,
     SmallInteger,
+    SmallIntegerWithDefault(i16),
     SmallIntegerNull,
     SmallIntegerUniq,
     BigInteger,
+    BigIntegerWithDefault(i64),
     BigIntegerNull,
     BigIntegerUniq,
     Decimal,
+    DecimalWithDefault(f64),
     DecimalNull,
     DecimalUniq,
     DecimalLen(u32, u32),
+    DecimalLenWithDefault(u32, u32, f64),
     DecimalLenNull(u32, u32),
     DecimalLenUniq(u32, u32),
     Float,
+    FloatWithDefault(f32),
     FloatNull,
     FloatUniq,
     Double,
+    DoubleWithDefault(f64),
     DoubleNull,
     DoubleUniq,
     Boolean,
+    BooleanWithDefault(bool),
     BooleanNull,
-    // Timestamp fields are not supported due to differences in data types between PostgreSQL and SQLite:
-    //  * Postgres: DateTime
-    //  * Sqlite: DateTimeUtc
-    // Timestamp,
-    // TimestampNull,
-    // TimestampUniq,
     Date,
+    DateWithDefault(String),
     DateNull,
     DateUniq,
     DateTime,
+    DateTimeWithDefault(String),
     DateTimeNull,
     DateTimeUniq,
     Time,
+    TimeWithDefault(String),
     TimeNull,
     TimeUniq,
     Interval(Option<PgInterval>, Option<u32>),
@@ -147,8 +148,8 @@ pub enum ColType {
     VarBinary(u32),
     VarBinaryNull(u32),
     VarBinaryUniq(u32),
-    // Added variants based on the JSON
     TimestampWithTimeZone,
+    TimestampWithTimeZoneWithDefault(String),
     TimestampWithTimeZoneNull,
     Json,
     JsonNull,
@@ -160,6 +161,7 @@ pub enum ColType {
     BlobNull,
     BlobUniq,
     Money,
+    MoneyWithDefault(f64),
     MoneyNull,
     MoneyUniq,
     Uuid,
@@ -317,6 +319,30 @@ impl ColType {
             Self::Array(kind) => array(name, kind.clone()),
             Self::ArrayNull(kind) => array_null(name, kind.clone()),
             Self::ArrayUniq(kind) => array_uniq(name, kind.clone()),
+            // defaults
+            Self::MoneyWithDefault(v) => money(name).default(*v).take(),
+            Self::IntegerWithDefault(v) => integer(name).default(*v).take(),
+            Self::UnsignedWithDefault(v) => unsigned(name).default(*v).take(),
+            Self::SmallUnsignedWithDefault(v) => small_unsigned(name).default(*v).take(),
+            Self::BigUnsignedWithDefault(v) => big_unsigned(name).default(*v).take(),
+            Self::SmallIntegerWithDefault(v) => small_integer(name).default(*v).take(),
+            Self::BigIntegerWithDefault(v) => big_integer(name).default(*v).take(),
+            Self::DecimalWithDefault(v) => decimal(name).default(*v).take(),
+            Self::DecimalLenWithDefault(p, s, v) => decimal_len(name, *p, *s).default(*v).take(),
+            Self::FloatWithDefault(v) => float(name).default(*v).take(),
+            Self::DoubleWithDefault(v) => double(name).default(*v).take(),
+            Self::BooleanWithDefault(v) => boolean(name).default(*v).take(),
+            Self::DateWithDefault(v) => date(name).default(v.clone()).take(),
+            Self::DateTimeWithDefault(v) => date_time(name).default(v.clone()).take(),
+            Self::TimeWithDefault(v) => time(name).default(v.clone()).take(),
+            Self::TimestampWithTimeZoneWithDefault(v) => {
+                timestamptz(name).default(v.clone()).take()
+            }
+            Self::CharWithDefault(v) => char(name).default(*v).take(),
+            Self::CharLenWithDefault(len, v) => char_len(name, *len).default(*v).take(),
+            Self::StringWithDefault(v) => string(name).default(v.clone()).take(),
+            Self::StringLenWithDefault(len, v) => string_len(name, *len).default(v.clone()).take(),
+            Self::TextWithDefault(v) => text(name).default(v.clone()).take(),
         }
     }
 }