1/*
2 * Copyright (c) Huawei Technologies Co., Ltd. 2021. All rights reserved.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at
6 *
7 * http://www.apache.org/licenses/LICENSE-2.0
8 *
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
14 */
15
16#ifndef COMMAND_POLLER_H
17#define COMMAND_POLLER_H
18
19#include <memory>
20
21class ManagerInterface;
22class CreateSessionCmd;
23class DestroySessionCmd;
24class StartSessionCmd;
25class StopSessionCmd;
26
27#include "logging.h"
28#include "plugin_service.ipc.h"
29
30using ManagerInterfacePtr = STD_PTR(shared, ManagerInterface);
31
32class CommandPoller final : public IPluginServiceClient {
33public:
34    explicit CommandPoller(const ManagerInterfacePtr& p);
35    ~CommandPoller();
36
37    bool OnCreateSessionCmd(const CreateSessionCmd& cmd, SocketContext& context) const;
38    bool OnDestroySessionCmd(const DestroySessionCmd& cmd) const;
39    bool OnStartSessionCmd(const StartSessionCmd& cmd, PluginResult& result) const;
40    bool OnStopSessionCmd(const StopSessionCmd& cmd) const;
41    bool OnReportBasicDataCmd(const RefreshSessionCmd& cmd) const;
42
43    uint32_t GetRequestId();
44    bool OnConnect();
45
46protected:
47    bool OnGetCommandResponse(SocketContext& context, ::GetCommandResponse& response) override;
48
49private:
50    uint32_t requestIdAutoIncrease_;
51    std::weak_ptr<ManagerInterface> pluginManager_;
52};
53
54#endif // !COMMAND_POLLER_H