Chromium Code Reviews| Index: components/copresence/public/copresence_client.h |
| diff --git a/components/copresence/public/copresence_client.h b/components/copresence/public/copresence_client.h |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..255f707ca908f4cdd22c33a2dccb43b8e158f3c9 |
| --- /dev/null |
| +++ b/components/copresence/public/copresence_client.h |
| @@ -0,0 +1,81 @@ |
| +// Copyright 2014 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. |
| + |
| +#ifndef COMPONENTS_COPRESENCE_PUBLIC_COPRESENCE_CLIENT_H_ |
| +#define COMPONENTS_COPRESENCE_PUBLIC_COPRESENCE_CLIENT_H_ |
| + |
| +#include <string> |
| +#include <vector> |
| + |
| +#include "base/callback.h" |
| +#include "base/macros.h" |
| +#include "base/memory/scoped_ptr.h" |
| +#include "base/memory/weak_ptr.h" |
| +#include "components/copresence/proto/rpcs.pb.h" |
| +#include "components/copresence/public/copresence_client_delegate.h" |
| + |
| +namespace net { |
| +class URLContextGetter; |
| +} |
| + |
| +namespace copresence { |
| + |
| +class CopresenceClientDelegate; |
| +class RpcHandler; |
| + |
| +struct PendingRequest { |
| + PendingRequest(const copresence::ReportRequest& report, |
| + const std::string app_id, |
| + const StatusCallback& callback); |
| + ~PendingRequest(); |
| + |
| + copresence::ReportRequest report; |
| + std::string app_id; |
| + StatusCallback callback; |
| +}; |
| + |
| +// The CopresenceClient class is the central interface for Copresence |
| +// functionality. This class handles all the initialization and delegation of |
| +// copresence tasks. Any user of copresence only needs to interact with this |
| +// client. |
| +class CopresenceClient : public base::SupportsWeakPtr<CopresenceClient> { |
| + public: |
| + // The delegate must outlive us. |
| + CopresenceClient(CopresenceClientDelegate* delegate); |
|
jochen (gone - plz use gerrit)
2014/07/31 19:22:46
nit explicit
rkc
2014/07/31 20:13:36
Done.
|
| + virtual ~CopresenceClient(); |
| + |
| + // This method will execute a report request. Each report request can have |
| + // multiple (un)publishes, (un)subscribes. This will ensure that once the |
| + // client is initialized, it sends all request to the server and handles |
| + // the response. If an error is encountered, the status callback is used |
| + // to relay it to the requester. |
| + void ExecuteReportRequest(copresence::ReportRequest request, |
| + const std::string& app_id, |
| + const StatusCallback& callback); |
| + |
| + // Called before the API (and thus the Client) is destructed. |
| + void Shutdown(); |
| + |
| + private: |
| + void CompleteInitialization(); |
| + void InitStepComplete(const std::string& step, bool success); |
| + |
| + CopresenceClientDelegate* delegate_; |
| + bool init_failed_; |
| + std::vector<PendingRequest> pending_requests_queue_; |
| + |
| + // TODO(rkc): This code is almost identical to what we use in feedback to |
| + // perform multiple blocking tasks and then run a post process method. Look |
| + // into refactoring it all out to a common construct, like maybe a |
| + // PostMultipleTasksAndReply? |
| + size_t pending_init_operations_; |
| + |
| + scoped_ptr<RpcHandler> rpc_handler_; |
| + |
| + DISALLOW_COPY_AND_ASSIGN(CopresenceClient); |
| +}; |
| + |
| +} // namespace copresence |
| + |
| +#endif // COMPONENTS_COPRESENCE_PUBLIC_COPRESENCE_CLIENT_H_ |