11320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci// Copyright 2014 The Chromium Authors. All rights reserved. 21320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci// Use of this source code is governed by a BSD-style license that can be 31320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci// found in the LICENSE file. 41320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 51320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci#ifndef REMOTING_HOST_NATIVE_MESSAGING_PIPE_MESSAGING_CHANNEL_H_ 61320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci#define REMOTING_HOST_NATIVE_MESSAGING_PIPE_MESSAGING_CHANNEL_H_ 71320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 81320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci#include "base/callback.h" 91320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci#include "base/files/file.h" 101320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci#include "base/memory/ref_counted.h" 111320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci#include "base/memory/scoped_ptr.h" 121320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci#include "base/memory/weak_ptr.h" 131320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci#include "base/threading/non_thread_safe.h" 141320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci#include "extensions/browser/api/messaging/native_messaging_channel.h" 151320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci#include "remoting/host/native_messaging/native_messaging_reader.h" 161320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci#include "remoting/host/native_messaging/native_messaging_writer.h" 171320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 181320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tuccinamespace base { 191320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucciclass DictionaryValue; 201320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucciclass Value; 211320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci} // namespace base 221320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 231320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tuccinamespace remoting { 241320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 251320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci// An implementation of extensions::NativeMessagingChannel using a pipe. It 261320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci// is used by the It2MeNativeMessagingHost and Me2MeNativeMessagingHost to 271320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci// communicate with the chrome process. 281320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci// TODO(kelvinp): Move this class to the extensions/browser/api/messaging 291320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci// directory. 301320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucciclass PipeMessagingChannel : public extensions::NativeMessagingChannel, 311320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci public base::NonThreadSafe { 321320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci public: 331320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci typedef extensions::NativeMessagingChannel::EventHandler EventHandler; 341320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 351320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci // Constructs an object taking the ownership of |input| and |output|. Closes 361320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci // |input| and |output| to prevent the caller from using them. 371320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci PipeMessagingChannel(base::File input, base::File output); 381320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci virtual ~PipeMessagingChannel(); 391320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 401320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci // extensions::NativeMessagingChannel implementation. 411320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci virtual void Start(EventHandler* event_handler) OVERRIDE; 421320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci virtual void SendMessage(scoped_ptr<base::Value> message) OVERRIDE; 431320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 441320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci private: 451320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci // Processes a message received from the client app. 461320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci void ProcessMessage(scoped_ptr<base::Value> message); 471320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 481320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci // Initiates shutdown. 491320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci void Shutdown(); 501320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 511320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci NativeMessagingReader native_messaging_reader_; 521320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci scoped_ptr<NativeMessagingWriter> native_messaging_writer_; 531320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 541320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci EventHandler* event_handler_; 551320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci base::WeakPtr<PipeMessagingChannel> weak_ptr_; 561320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci base::WeakPtrFactory<PipeMessagingChannel> weak_factory_; 571320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 581320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci DISALLOW_COPY_AND_ASSIGN(PipeMessagingChannel); 591320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci}; 601320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 611320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci} // namespace remoting 621320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 631320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci#endif // REMOTING_HOST_NATIVE_MESSAGING_PIPE_MESSAGING_CHANNEL_H_ 64