[wip] Using the dispatcher... taking notes

Signed-off-by: dd di cesare <[email protected]>

src/filter/http_context.rs

@@ -1,3 +1,4 @@
+use crate::action_dispatcher::ActionDispatcher;
 use crate::configuration::{FailureMode, FilterConfig};
 use crate::envoy::{RateLimitResponse, RateLimitResponse_Code};
 use crate::policy::Policy;
@@ -14,6 +15,7 @@ pub struct Filter {
  pub config: Rc<FilterConfig>,
  pub response_headers_to_add: Vec<(String, String)>,
  pub header_resolver: Rc<HeaderResolver>,
+ pub action_dispatcher: Rc<ActionDispatcher>,
 }
 
 impl Filter {
@@ -40,6 +42,9 @@ impl Filter {
  return Action::Continue;
  }
 
+ // ActionDispatcher gets populated with actions, on Pending State
+ // ActionDispatcher calls next, with service and message. Or probably it needs to initiate the messages on previous step and attach services when created?
+
  // todo(adam-cattermole): For now we just get the first GrpcService but we expect to have
  // an action which links to the service that should be used
  let rls = self

src/filter/root_context.rs

@@ -1,3 +1,4 @@
+use crate::action_dispatcher::ActionDispatcher;
 use crate::configuration::{FilterConfig, PluginConfiguration};
 use crate::filter::http_context::Filter;
 use crate::service::HeaderResolver;
@@ -42,6 +43,7 @@ impl RootContext for FilterRoot {
  config: Rc::clone(&self.config),
  response_headers_to_add: Vec::default(),
  header_resolver: Rc::new(HeaderResolver::new()),
+ action_dispatcher: Rc::new(ActionDispatcher::default()),
  }))
  }