// Copyright (c) 2010 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
//
// Class that handles the details of sending and receiving client
// invalidation packets.

#ifndef CHROME_BROWSER_SYNC_NOTIFIER_CACHE_INVALIDATION_PACKET_HANDLER_H_
#define CHROME_BROWSER_SYNC_NOTIFIER_CACHE_INVALIDATION_PACKET_HANDLER_H_

#include <string>

#include "base/basictypes.h"
#include "talk/xmpp/jid.h"

namespace buzz {
class XmppClient;
}  // namespace buzz

namespace invalidation {
class InvalidationClient;
class NetworkEndpoint;
}  // namespace invalidation

namespace sync_notifier {

// TODO(akalin): Add a NonThreadSafe member to this class and use it.

class CacheInvalidationPacketHandler {
 public:
  // Starts routing packets from |invalidation_client| through
  // |xmpp_client|.  |invalidation_client| must not already be routing
  // packets through something.  Does not take ownership of
  // |xmpp_client| or |invalidation_client|.
  CacheInvalidationPacketHandler(
      buzz::XmppClient* xmpp_client,
      invalidation::InvalidationClient* invalidation_client);

  // Makes the invalidation client passed into the constructor not
  // route packets through the XMPP client passed into the constructor
  // anymore.
  ~CacheInvalidationPacketHandler();

 private:
  void HandleOutboundPacket(
      invalidation::NetworkEndpoint* const& network_endpoint);

  void HandleInboundPacket(const std::string& packet);

  buzz::XmppClient* xmpp_client_;
  invalidation::InvalidationClient* invalidation_client_;

  // Parameters for sent messages.

  // Monotonically increasing sequence number.
  int seq_;
  // Unique session token.
  const std::string sid_;

  DISALLOW_COPY_AND_ASSIGN(CacheInvalidationPacketHandler);
};

}  // namespace sync_notifier

#endif  // CHROME_BROWSER_SYNC_NOTIFIER_CACHE_INVALIDATION_PACKET_HANDLER_H_