1 /*
2  * Copyright (c) 2021-2024 Huawei Device Co., Ltd.
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 OHOS_DCAMERA_SINK_CONTROLLER_H
17 #define OHOS_DCAMERA_SINK_CONTROLLER_H
18 
19 #include "event_handler.h"
20 #include "icamera_controller.h"
21 
22 #include "icamera_channel.h"
23 #include "icamera_operator.h"
24 #include "icamera_sink_access_control.h"
25 #include "icamera_sink_output.h"
26 #include <mutex>
27 #include <atomic>
28 #include "device_manager.h"
29 #include "device_manager_callback.h"
30 #include "property_carrier.h"
31 #include "idcamera_sink_callback.h"
32 
33 namespace OHOS {
34 namespace DistributedHardware {
35 constexpr uint32_t EVENT_FRAME_TRIGGER = 1;
36 constexpr uint32_t EVENT_AUTHORIZATION = 2;
37 class DCameraSinkController : public ICameraController, public std::enable_shared_from_this<DCameraSinkController> {
38 public:
39     explicit DCameraSinkController(std::shared_ptr<ICameraSinkAccessControl>& accessControl,
40         const sptr<IDCameraSinkCallback> &sinkCallback);
41     ~DCameraSinkController() override;
42 
43     int32_t StartCapture(std::vector<std::shared_ptr<DCameraCaptureInfo>>& captureInfos, int32_t sceneMode) override;
44     int32_t StopCapture() override;
45     int32_t ChannelNeg(std::shared_ptr<DCameraChannelInfo>& info) override;
46     int32_t DCameraNotify(std::shared_ptr<DCameraEvent>& events) override;
47     int32_t UpdateSettings(std::vector<std::shared_ptr<DCameraSettings>>& settings) override;
48     int32_t GetCameraInfo(std::shared_ptr<DCameraInfo>& camInfo) override;
49     int32_t OpenChannel(std::shared_ptr<DCameraOpenInfo>& openInfo) override;
50     int32_t CloseChannel() override;
51     int32_t Init(std::vector<DCameraIndex>& indexs) override;
52     int32_t UnInit() override;
53     int32_t PauseDistributedHardware(const std::string &networkId) override;
54     int32_t ResumeDistributedHardware(const std::string &networkId) override;
55     int32_t StopDistributedHardware(const std::string &networkId) override;
56 
57     void OnStateChanged(std::shared_ptr<DCameraEvent>& event);
58     void OnMetadataResult(std::vector<std::shared_ptr<DCameraSettings>>& settings);
59 
60     void OnSessionState(int32_t state);
61     void OnSessionError(int32_t eventType, int32_t eventReason, std::string detail);
62     void OnDataReceived(std::vector<std::shared_ptr<DataBuffer>>& buffers);
63 
64     class DCameraSinkContrEventHandler : public AppExecFwk::EventHandler {
65         public:
66             DCameraSinkContrEventHandler(const std::shared_ptr<AppExecFwk::EventRunner> &runner,
67                 std::shared_ptr<DCameraSinkController> sinkContrPtr);
68             ~DCameraSinkContrEventHandler() override = default;
69             void ProcessEvent(const AppExecFwk::InnerEvent::Pointer &event) override;
70         private:
71             std::weak_ptr<DCameraSinkController> sinkContrWPtr_;
72     };
73 
74 private:
75     int32_t StartCaptureInner(std::vector<std::shared_ptr<DCameraCaptureInfo>>& captureInfos);
76     int32_t DCameraNotifyInner(int32_t type, int32_t result, std::string content);
77     int32_t HandleReceivedData(std::shared_ptr<DataBuffer>& dataBuffer);
78     void PostAuthorization(std::vector<std::shared_ptr<DCameraCaptureInfo>>& captureInfos);
79     bool CheckDeviceSecurityLevel(const std::string &srcDeviceId, const std::string &dstDeviceId);
80     int32_t GetDeviceSecurityLevel(const std::string &udid);
81     std::string GetUdidByNetworkId(const std::string &networkId);
82     int32_t PullUpPage();
83     bool CheckPermission();
84     void ProcessFrameTrigger(const AppExecFwk::InnerEvent::Pointer &event);
85     void ProcessPostAuthorization(const AppExecFwk::InnerEvent::Pointer &event);
86 
87     bool isInit_;
88     int32_t sessionState_;
89     std::mutex autoLock_;
90     std::mutex captureLock_;
91     std::mutex channelLock_;
92     std::string dhId_;
93     std::string srcDevId_;
94     std::shared_ptr<DCameraSinkContrEventHandler> sinkCotrEventHandler_;
95     std::shared_ptr<ICameraChannel> channel_;
96     std::shared_ptr<ICameraOperator> operator_;
97     std::shared_ptr<ICameraSinkAccessControl> accessControl_;
98     std::shared_ptr<ICameraSinkOutput> output_;
99     sptr<IDCameraSinkCallback> sinkCallback_;
100     std::atomic<bool> isPageStatus_ = false;
101     std::shared_ptr<DmInitCallback> initCallback_;
102     bool isSensitive_ = false;
103     bool isSameAccount_ = false;
104     bool isCheckSecLevel_ = false;
105     int32_t sceneMode_ = 0;
106 
107     const std::string SESSION_FLAG = "control";
108     const std::string SRC_TYPE = "camera";
109     const size_t DATABUFF_MAX_SIZE = 100 * 1024 * 1024;
110 };
111 
112 class DeviceInitCallback : public DmInitCallback {
113     void OnRemoteDied() override;
114 };
115 } // namespace DistributedHardware
116 } // namespace OHOS
117 #endif // OHOS_DCAMERA_SINK_CONTROLLER_H