Add experimental signal validation.

examples/asm-dom/demos/actions.cpp

@@ -22,7 +22,10 @@ init_demo(std::string dom_id)
     static dom::system the_dom;
 
     initialize(the_dom, the_system, dom_id, [](dom::context ctx) {
-        do_ui(ctx, get_state(ctx, 0), get_state(ctx, empty<int>()));
+        do_ui(
+            ctx,
+            enforce_validity(ctx, get_state(ctx, 0)),
+            enforce_validity(ctx, get_state(ctx, empty<int>())));
     });
 }
 
@@ -55,7 +58,7 @@ init_demo(std::string dom_id)
     static dom::system the_dom;
 
     initialize(the_dom, the_system, dom_id, [](dom::context ctx) {
-        do_ui(ctx, get_state(ctx, 1));
+        do_ui(ctx, enforce_validity(ctx, get_state(ctx, 1)));
     });
 }
 
@@ -158,7 +161,7 @@ init_demo(std::string dom_id)
     static dom::system the_dom;
 
     initialize(the_dom, the_system, dom_id, [](dom::context ctx) {
-        do_ui(ctx, get_state(ctx, empty<int>()));
+        do_ui(ctx, enforce_validity(ctx, get_state(ctx, empty<int>())));
     });
 }
 

examples/asm-dom/demos/adaptors.cpp

@@ -23,7 +23,7 @@ init_demo(std::string dom_id)
     static dom::system the_dom;
 
     initialize(the_dom, the_system, dom_id, [](dom::context ctx) {
-        do_ui(ctx, get_state(ctx, 1.));
+        do_ui(ctx, enforce_validity(ctx, get_state(ctx, 1.)));
     });
 }
 

examples/asm-dom/demos/application.cpp

@@ -42,7 +42,7 @@ init_demo(std::string dom_id)
     static dom::system the_dom;
 
     initialize(the_dom, the_system, dom_id, [](dom::context ctx) {
-        do_ui(ctx, get_state(ctx, empty<int>()));
+        do_ui(ctx, enforce_validity(ctx, get_state(ctx, empty<int>())));
     });
 }
 

examples/asm-dom/demos/numerical.cpp

@@ -24,8 +24,8 @@ init_demo(std::string dom_id)
     initialize(the_dom, the_system, dom_id, [](dom::context ctx) {
         do_addition_ui(
             ctx,
-            get_state(ctx, empty<double>()),
-            get_state(ctx, empty<double>()));
+            get_state(ctx, enforce_validity(ctx, empty<double>())),
+            get_state(ctx, enforce_validity(ctx, empty<double>())));
     });
 }
 
@@ -38,10 +38,10 @@ namespace numerical_analysis {
 void
 do_ui(dom::context ctx)
 {
+    auto n = enforce_validity(ctx, get_state(ctx, empty<double>()));
+
     // clang-format off
 /// [analysis]
-auto n = get_state(ctx, empty<double>());
-
 dom::do_text(ctx, "Enter a number:");
 
 dom::do_input(ctx, n);
@@ -197,7 +197,7 @@ init_demo(std::string dom_id)
     static dom::system the_dom;
 
     initialize(the_dom, the_system, dom_id, [](dom::context ctx) {
-        do_factor_tree_demo(ctx, get_state(ctx, 600));
+        do_factor_tree_demo(ctx, enforce_validity(ctx, get_state(ctx, 600)));
     });
 }
 

examples/asm-dom/demos/timing.cpp

@@ -89,7 +89,7 @@ init_demo(std::string dom_id)
     static dom::system the_dom;
 
     initialize(the_dom, the_system, dom_id, [](dom::context ctx) {
-        do_ui(ctx, get_state(ctx, 42));
+        do_ui(ctx, enforce_validity(ctx, get_state(ctx, 42)));
     });
 }
 
@@ -157,7 +157,7 @@ init_demo(std::string dom_id)
     static dom::system the_dom;
 
     initialize(the_dom, the_system, dom_id, [](dom::context ctx) {
-        do_ui(ctx, get_state(ctx, 1));
+        do_ui(ctx, enforce_validity(ctx, get_state(ctx, 1)));
     });
 }
 

examples/asm-dom/demos/tracking.cpp

@@ -37,7 +37,7 @@ init_demo(std::string dom_id)
     static dom::system the_dom;
 
     initialize(the_dom, the_system, dom_id, [](dom::context ctx) {
-        do_ui(ctx, get_state(ctx, empty<int>()));
+        do_ui(ctx, enforce_validity(ctx, get_state(ctx, empty<int>())));
     });
 }
 

examples/asm-dom/dom.cpp

@@ -63,7 +63,7 @@ struct input_data
     component_identity identity;
     captured_id external_id;
     string value;
-    bool invalid = false;
+    signal_validation_data validation;
     element_data element;
     unsigned version = 0;
 };
@@ -74,35 +74,38 @@ struct value_update_event : targeted_event
 };
 
 void
-do_input_(dom::context ctx, duplex<string> value)
+do_input_(dom::context ctx, duplex<string> value_)
 {
     input_data* data;
     get_cached_data(ctx, &data);
 
+    auto value = enforce_validity(ctx, value_, data->validation);
+
     on_refresh(ctx, [&](auto ctx) {
         refresh_component_identity(ctx, data->identity);
 
-        refresh_signal_shadow(
-            data->external_id,
-            value,
-            [&](string new_value) {
-                data->value = std::move(new_value);
-                data->invalid = false;
-                ++data->version;
-            },
-            [&]() {
-                data->value.clear();
-                data->invalid = false;
-                ++data->version;
-            });
+        if (!value.is_invalidated())
+        {
+            refresh_signal_shadow(
+                data->external_id,
+                value,
+                [&](string new_value) {
+                    data->value = std::move(new_value);
+                    ++data->version;
+                },
+                [&]() {
+                    data->value.clear();
+                    ++data->version;
+                });
+        }
     });
 
     auto* system = &ctx.get<system_tag>();
     auto external_id = externalize(&data->identity);
 
     add_element(ctx, data->element, make_id(data->version), [&]() {
         asmdom::Attrs attrs;
-        if (data->invalid)
+        if (value.is_invalidated())
             attrs["class"] = "invalid-input";
         return asmdom::h(
             "input",
@@ -119,17 +122,7 @@ do_input_(dom::context ctx, duplex<string> value)
     });
     on_targeted_event<value_update_event>(
         ctx, &data->identity, [=](auto ctx, auto& e) {
-            if (signal_ready_to_write(value))
-            {
-                try
-                {
-                    write_signal(value, e.value);
-                }
-                catch (validation_error&)
-                {
-                    data->invalid = true;
-                }
-            }
+            write_signal(value, e.value);
             data->value = e.value;
             ++data->version;
         });

src/alia/signals/adaptors.hpp

@@ -72,6 +72,16 @@ struct readability_faker : signal<
     {
         return wrapped_.write(value);
     }
+    bool
+    invalidate(std::exception_ptr error) const
+    {
+        return wrapped_.invalidate(error);
+    }
+    bool
+    is_invalidated() const
+    {
+        return wrapped_.is_invalidated();
+    }
 
  private:
     Wrapped wrapped_;
@@ -168,6 +178,16 @@ struct casting_signal : regular_signal<
     {
         return wrapped_.write(static_cast<typename Wrapped::value_type>(value));
     }
+    bool
+    invalidate(std::exception_ptr error) const
+    {
+        return wrapped_.invalidate(error);
+    }
+    bool
+    is_invalidated() const
+    {
+        return wrapped_.is_invalidated();
+    }
 
  private:
     Wrapped wrapped_;
@@ -311,6 +331,16 @@ struct fallback_signal : signal<
     {
         primary_.write(value);
     }
+    bool
+    invalidate(std::exception_ptr error) const
+    {
+        return primary_.invalidate(error);
+    }
+    bool
+    is_invalidated() const
+    {
+        return primary_.is_invalidated();
+    }
 
  private:
     mutable id_pair<simple_id<bool>, id_ref> id_;
@@ -368,6 +398,16 @@ struct simplified_id_wrapper : regular_signal<
     {
         return wrapped_.write(value);
     }
+    bool
+    invalidate(std::exception_ptr error) const
+    {
+        return wrapped_.invalidate(error);
+    }
+    bool
+    is_invalidated() const
+    {
+        return wrapped_.is_invalidated();
+    }
 
  private:
     Wrapped wrapped_;
@@ -423,6 +463,16 @@ struct masking_signal : signal<
     {
         primary_.write(value);
     }
+    bool
+    invalidate(std::exception_ptr error) const
+    {
+        return primary_.invalidate(error);
+    }
+    bool
+    is_invalidated() const
+    {
+        return primary_.is_invalidated();
+    }
 
  private:
     Primary primary_;
@@ -490,6 +540,16 @@ struct write_masking_signal : signal<
     {
         primary_.write(value);
     }
+    bool
+    invalidate(std::exception_ptr error) const
+    {
+        return primary_.invalidate(error);
+    }
+    bool
+    is_invalidated() const
+    {
+        return primary_.is_invalidated();
+    }
 
  private:
     Primary primary_;
@@ -560,6 +620,16 @@ struct unwrapper_signal : signal<
     {
         wrapped_.write(value);
     }
+    bool
+    invalidate(std::exception_ptr error) const
+    {
+        return wrapped_.invalidate(error);
+    }
+    bool
+    is_invalidated() const
+    {
+        return wrapped_.is_invalidated();
+    }
 
  private:
     Wrapped wrapped_;