Skip to content

Commit cf52d64

Browse files
committed
add runtime_conditional and flow unary operator+
1 parent 84d426e commit cf52d64

23 files changed

+909
-277
lines changed

docs/flows.adoc

Lines changed: 62 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -44,11 +44,11 @@ Actions are added to the flow inside a component's `cib::config`.
4444
struct morning {
4545
constexpr auto config = cib::config(
4646
cib::extend<MorningRoutine>(
47-
WAKE_UP >>
48-
selfcare::SHOWER >>
49-
selfcare::GET_DRESSED >>
50-
food::MAKE_COFFEE >>
51-
food::DRINK_COFFEE));
47+
+WAKE_UP >>
48+
+selfcare::SHOWER >>
49+
+selfcare::GET_DRESSED >>
50+
+food::MAKE_COFFEE >>
51+
+food::DRINK_COFFEE));
5252
};
5353
----
5454

@@ -58,6 +58,17 @@ a shower. The flow library will order actions in a flow to respect these
5858
dependencies. The actions will be executed in an order that respects all given
5959
dependencies.
6060

61+
The unary `+` operator is used to explicitly add an action to the
62+
flow. Without the unary `+` operator an action is just a reference.
63+
A compile-time error will be triggered if an action is referenced without ever
64+
being explicitly added to the flow. If an action is added under a compile-time
65+
or runtime conditional, and the conditional is false, then it is as if the
66+
action was never added at all.
67+
68+
The behavior of the unary `+` operator ensures that merely referencing an
69+
action to create an ordering dependency doesn't unintentionally add the action
70+
to the flow.
71+
6172
If we only use the `morning` component in our project, the `MorningRoutine` flow
6273
graph would look like the following:
6374

@@ -93,11 +104,11 @@ struct childcare {
93104
constexpr auto config = cib::config(
94105
cib::extend<MorningRoutine>(
95106
food::MAKE_COFFEE >> // this step exists in the MorningRoutine flow
96-
PACK_SCHOOL_LUNCHES >> // new
107+
+PACK_SCHOOL_LUNCHES >> // new
97108
food::DRINK_COFFEE >> // existing
98-
food::MAKE_BREAKFAST >> // new
99-
food::EAT_BREAKFAST >> // new
100-
SEND_KIDS_TO_SCHOOL)); // new
109+
+food::MAKE_BREAKFAST >> // new
110+
+food::EAT_BREAKFAST >> // new
111+
+SEND_KIDS_TO_SCHOOL)); // new
101112
};
102113
----
103114

@@ -140,7 +151,7 @@ struct exercise {
140151
constexpr auto config = cib::config(
141152
cib::extend<MorningRoutine>(
142153
morning::WAKE_UP >>
143-
RIDE_STATIONARY_BIKE >>
154+
+RIDE_STATIONARY_BIKE >>
144155
selfcare::SHOWER));
145156
};
146157
----
@@ -321,7 +332,47 @@ namespace example_component {
321332
constexpr auto config = cib::config(
322333
cib::extend<MyFlow>(
323334
// no order requirement between these actions
324-
SOME_ACTION && SOME_OTHER_ACTION));
335+
+SOME_ACTION && +SOME_OTHER_ACTION));
336+
}
337+
----
338+
339+
==== unary `operator+`
340+
341+
Explicitly add an action to the flow. Actions used in flow extensions without
342+
the unary `+` will be treated as references only and will not be added to the
343+
flow at that location. It is a compilation error if an action is not added
344+
with a unary `+` in exactly one location in the overall config.
345+
346+
Actions can be added and ordered all at once:
347+
348+
[source,cpp]
349+
----
350+
namespace example_component {
351+
constexpr auto config = cib::config(
352+
cib::extend<MyFlow>(
353+
// Add both actions and create an ordering between them.
354+
+SOME_ACTION >> +SOME_OTHER_ACTION));
355+
}
356+
----
357+
358+
Actions can also be added and ordered seperately:
359+
360+
[source,cpp]
361+
----
362+
namespace other_component {
363+
constexpr auto INIT_SOMETHING = ...
364+
365+
constexpr auto config = cib::config(
366+
cib::extend<MyFlow>(+INIT_SOMETHING));
367+
}
368+
369+
namespace example_component {
370+
constexpr auto DO_A_THING = ...
371+
372+
constexpr auto config = cib::config(
373+
cib::extend<MyFlow>(
374+
other_component::INIT_SOMETHING >>
375+
+DO_A_THING));
325376
}
326377
----
327378

examples/flow_daily_routine/main.cpp

Lines changed: 12 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -95,14 +95,10 @@ struct self_care_component_t {
9595
// Extend flow services
9696
constexpr static auto config = cib::config(
9797

98-
cib::extend<morning_routine_t>(self_care_component_t::WAKE_UP >>
99-
self_care_component_t::EXERCISE >>
100-
self_care_component_t::TAKE_BATH),
98+
cib::extend<morning_routine_t>(+WAKE_UP >> +EXERCISE >> +TAKE_BATH),
10199

102-
cib::extend<evening_routine_t>(self_care_component_t::EXERCISE >>
103-
self_care_component_t::TAKE_BATH >>
104-
self_care_component_t::RELAX >>
105-
self_care_component_t::GO_TO_BED));
100+
cib::extend<evening_routine_t>(+EXERCISE >> +TAKE_BATH >> +RELAX >>
101+
+GO_TO_BED));
106102
};
107103

108104
struct food_component_t {
@@ -119,10 +115,10 @@ struct food_component_t {
119115
constexpr static auto config = cib::config(
120116

121117
cib::extend<morning_routine_t>(self_care_component_t::TAKE_BATH >>
122-
food_component_t::BREAKFAST),
118+
+BREAKFAST),
123119

124120
cib::extend<evening_routine_t>(self_care_component_t::RELAX >>
125-
food_component_t::DINNER >>
121+
+DINNER >>
126122
self_care_component_t::GO_TO_BED));
127123
};
128124

@@ -141,16 +137,13 @@ struct dress_up_component_t {
141137
constexpr static auto config = cib::config(
142138

143139
cib::extend<morning_routine_t>(
144-
self_care_component_t::WAKE_UP >>
145-
dress_up_component_t::GET_READY_FOR_EXERCISE >>
140+
self_care_component_t::WAKE_UP >> +GET_READY_FOR_EXERCISE >>
146141
self_care_component_t::EXERCISE >>
147-
self_care_component_t::TAKE_BATH >>
148-
dress_up_component_t::GET_READY_TO_WORK >>
142+
self_care_component_t::TAKE_BATH >> +GET_READY_TO_WORK >>
149143
food_component_t::BREAKFAST),
150144

151-
cib::extend<evening_routine_t>(
152-
dress_up_component_t::GET_READY_FOR_EXERCISE >>
153-
self_care_component_t::EXERCISE));
145+
cib::extend<evening_routine_t>(+GET_READY_FOR_EXERCISE >>
146+
self_care_component_t::EXERCISE));
154147
};
155148

156149
struct commute_component_t {
@@ -167,11 +160,10 @@ struct commute_component_t {
167160
constexpr static auto config = cib::config(
168161

169162
cib::extend<morning_routine_t>(food_component_t::BREAKFAST >>
170-
commute_component_t::GO_TO_OFFICE),
163+
+GO_TO_OFFICE),
171164

172165
cib::extend<evening_routine_t>(
173-
commute_component_t::RETURN_HOME >>
174-
dress_up_component_t::GET_READY_FOR_EXERCISE));
166+
+RETURN_HOME >> dress_up_component_t::GET_READY_FOR_EXERCISE));
175167
};
176168

177169
struct daily_routine_component_t {
@@ -206,7 +198,7 @@ struct daily_routine_component_t {
206198

207199
// we need to extend the MainLoop as cib::top implements
208200
// MainLoop service
209-
cib::extend<cib::MainLoop>(DAILY_ROUTINES));
201+
cib::extend<cib::MainLoop>(+DAILY_ROUTINES));
210202
};
211203

212204
struct person_routine_proj {

include/cib/config.hpp

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@
77
#include <cib/detail/config_item.hpp>
88
#include <cib/detail/exports.hpp>
99
#include <cib/detail/extend.hpp>
10+
#include <cib/detail/runtime_conditional.hpp>
1011

1112
#include <stdx/compiler.hpp>
1213

@@ -22,6 +23,7 @@ namespace cib {
2223
* @see cib::extend
2324
* @see cib::exports
2425
* @see cib::conditional
26+
* @see cib::runtime_conditional
2527
*/
2628
template <typename... Configs>
2729
[[nodiscard]] CONSTEVAL auto config(Configs const &...configs) {
@@ -72,4 +74,10 @@ template <typename Predicate, typename... Configs>
7274
Configs const &...configs) {
7375
return detail::conditional<Predicate, Configs...>{configs...};
7476
}
77+
78+
template <stdx::ct_string Name>
79+
constexpr auto runtime_condition = []<typename P>(P) {
80+
static_assert(std::is_default_constructible_v<P>);
81+
return detail::runtime_condition<Name, P>{};
82+
};
7583
} // namespace cib
Lines changed: 81 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,81 @@
1+
#pragma once
2+
3+
#include <cib/detail/config_details.hpp>
4+
#include <cib/detail/config_item.hpp>
5+
#include <cib/detail/extend.hpp>
6+
7+
#include <stdx/compiler.hpp>
8+
#include <stdx/ct_format.hpp>
9+
#include <stdx/tuple.hpp>
10+
#include <stdx/tuple_algorithms.hpp>
11+
12+
namespace cib::detail {
13+
template <typename Cond, typename... Configs>
14+
struct runtime_conditional : config_item {
15+
detail::config<Configs...> body;
16+
17+
CONSTEVAL explicit runtime_conditional(Configs const &...configs)
18+
: body{configs...} {}
19+
20+
[[nodiscard]] constexpr auto extends_tuple() const {
21+
return stdx::transform(
22+
[]<typename E>(E e) {
23+
auto args_tuple = stdx::transform(
24+
[]<typename Arg>(Arg) {
25+
return make_runtime_conditional(Cond{}, Arg{});
26+
},
27+
e.args_tuple);
28+
29+
return stdx::apply(
30+
[]<typename... Args>(Args...) {
31+
return extend<typename E::service_type, Args...>{
32+
Args{}...};
33+
},
34+
args_tuple);
35+
},
36+
body.extends_tuple());
37+
}
38+
39+
[[nodiscard]] constexpr auto exports_tuple() const {
40+
return body.exports_tuple();
41+
}
42+
};
43+
44+
template <stdx::ct_string Name, typename... Ps> // FIXME: concept for Ps
45+
struct runtime_condition {
46+
constexpr static auto predicates = stdx::make_tuple(Ps{}...);
47+
48+
constexpr static auto ct_name = Name;
49+
50+
template <typename... Configs>
51+
[[nodiscard]] CONSTEVAL auto operator()(Configs const &...configs) const {
52+
return detail::runtime_conditional<runtime_condition<Name, Ps...>,
53+
Configs...>{configs...};
54+
}
55+
56+
explicit operator bool() const { return (Ps{}() and ...); }
57+
58+
template <stdx::ct_string RhsName, typename... RhsPs>
59+
[[nodiscard]] constexpr auto
60+
operator and(runtime_condition<RhsName, RhsPs...> rhs) const {
61+
if constexpr ((sizeof...(Ps) + sizeof...(RhsPs)) == 0) {
62+
return runtime_condition<"always">{};
63+
64+
} else if constexpr (sizeof...(Ps) == 0) {
65+
return rhs;
66+
67+
} else if constexpr (sizeof...(RhsPs) == 0) {
68+
return *this;
69+
70+
} else {
71+
constexpr auto name =
72+
stdx::ct_format<"{} and {}">(CX_VALUE(Name), CX_VALUE(RhsName));
73+
74+
return runtime_condition<name, Ps..., RhsPs...>{};
75+
}
76+
}
77+
};
78+
79+
using always_condition_t = runtime_condition<"always">;
80+
constexpr auto always_condition = always_condition_t{};
81+
} // namespace cib::detail

include/flow/detail/par.hpp

Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,20 @@ template <node Lhs, node Rhs> struct par {
1111

1212
using is_node = void;
1313

14+
constexpr auto operator+() const {
15+
using lhs_t = decltype(+lhs);
16+
using rhs_t = decltype(+rhs);
17+
18+
return par<lhs_t, rhs_t>{lhs_t{}, rhs_t{}};
19+
}
20+
21+
constexpr auto operator-() const {
22+
using lhs_t = decltype(-lhs);
23+
using rhs_t = decltype(-rhs);
24+
25+
return par<lhs_t, rhs_t>{lhs_t{}, rhs_t{}};
26+
}
27+
1428
private:
1529
friend constexpr auto tag_invoke(get_initials_t, par const &p) {
1630
return stdx::tuple_cat(get_initials(p.lhs), get_initials(p.rhs));
@@ -24,6 +38,11 @@ template <node Lhs, node Rhs> struct par {
2438
return stdx::tuple_cat(get_nodes(p.lhs), get_nodes(p.rhs));
2539
}
2640

41+
friend constexpr auto tag_invoke(get_all_mentioned_nodes_t, par const &p) {
42+
return stdx::tuple_cat(get_all_mentioned_nodes(p.lhs),
43+
get_all_mentioned_nodes(p.rhs));
44+
}
45+
2746
friend constexpr auto tag_invoke(get_edges_t, par const &p) {
2847
return stdx::tuple_cat(get_edges(p.lhs), get_edges(p.rhs));
2948
}
@@ -36,3 +55,9 @@ template <flow::dsl::node Lhs, flow::dsl::node Rhs>
3655
[[nodiscard]] constexpr auto operator&&(Lhs const &lhs, Rhs const &rhs) {
3756
return flow::dsl::par{lhs, rhs};
3857
}
58+
59+
template <typename Cond, flow::dsl::node Lhs, flow::dsl::node Rhs>
60+
constexpr auto make_runtime_conditional(Cond, flow::dsl::par<Lhs, Rhs>) {
61+
return flow::dsl::par{make_runtime_conditional(Cond{}, Lhs{}),
62+
make_runtime_conditional(Cond{}, Rhs{})};
63+
}

0 commit comments

Comments
 (0)