components/copresence/handlers/directive_handler.cc

   1 // Copyright 2014 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "components/copresence/handlers/directive_handler.h"
   6
   7 #include "base/time/time.h"
   8 #include "components/copresence/handlers/audio/audio_directive_handler.h"
   9 #include "components/copresence/proto/data.pb.h"
  10
  11 namespace copresence {
  12
  13 DirectiveHandler::DirectiveHandler() {}
  14
  15 void DirectiveHandler::Initialize(
  16     const AudioRecorder::DecodeSamplesCallback& decode_cb,
  17     const AudioDirectiveHandler::EncodeTokenCallback& encode_cb) {
  18   audio_handler_.reset(new AudioDirectiveHandler(decode_cb, encode_cb));
  19   audio_handler_->Initialize();
  20 }
  21
  22 DirectiveHandler::~DirectiveHandler() {
  23 }
  24
  25 void DirectiveHandler::AddDirective(const Directive& directive) {
  26   // We only handle Token directives; wifi/ble requests aren't implemented.
  27   DCHECK_EQ(directive.instruction_type(), TOKEN);
  28
  29   std::string op_id;
  30   if (directive.has_published_message_id()) {
  31     op_id = directive.published_message_id();
  32   } else if (directive.has_subscription_id()) {
  33     op_id = directive.subscription_id();
  34   } else {
  35     NOTREACHED() << "No operation associated with directive!";
  36     return;
  37   }
  38
  39   const TokenInstruction& ti = directive.token_instruction();
  40   DCHECK(audio_handler_.get()) << "Clients must call Initialize() before "
  41                                << "any other DirectiveHandler methods.";
  42   // We currently only support audio.
  43   if (ti.medium() == AUDIO_ULTRASOUND_PASSBAND ||
  44       ti.medium() == AUDIO_AUDIBLE_DTMF) {
  45     audio_handler_->AddInstruction(
  46         ti, op_id, base::TimeDelta::FromMilliseconds(directive.ttl_millis()));
  47   }
  48 }
  49
  50 void DirectiveHandler::RemoveDirectives(const std::string& op_id) {
  51   DCHECK(audio_handler_.get()) << "Clients must call Initialize() before "
  52                                << "any other DirectiveHandler methods.";
  53   audio_handler_->RemoveInstructions(op_id);
  54 }
  55
  56 const std::string& DirectiveHandler::CurrentAudibleToken() const {
  57   return audio_handler_->PlayingAudibleToken();
  58 }
  59
  60 const std::string& DirectiveHandler::CurrentInaudibleToken() const {
  61   return audio_handler_->PlayingInaudibleToken();
  62 }
  63
  64 }  // namespace copresence