/*
 * Copyright (c) 2021-2023 Huawei Device Co., Ltd.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#ifndef OHOS_DISTRIBUTED_SCHED_ADAPTER_H
#define OHOS_DISTRIBUTED_SCHED_ADAPTER_H

#include "ability_info.h"
#include "ability_manager_client.h"
#include "caller_info.h"
#include "device_auth.h"
#include "dfx/distributed_radar.h"
#include "distributed_sched_interface.h"
#include "event_handler.h"
#include "if_system_ability_manager.h"
#include "iremote_object.h"
#include "mission/distributed_mission_change_listener.h"
#include "mission/distributed_mission_info.h"
#include "single_instance.h"
#include "uri.h"

namespace OHOS {
namespace DistributedSchedule {
class DistributedSchedAdapter {
    DECLARE_SINGLE_INSTANCE(DistributedSchedAdapter);

public:
    using AccountInfo = IDistributedSched::AccountInfo;

    void Init();
    void UnInit();

    int32_t ConnectAbility(const OHOS::AAFwk::Want& want, const sptr<IRemoteObject>& connect,
        const sptr<IRemoteObject>& callerToken);
    int32_t DisconnectAbility(const sptr<IRemoteObject>& connect);
    void DeviceOnline(const std::string& deviceId);
    void DeviceOffline(const std::string& deviceId);
    void ProcessConnectDied(const sptr<IRemoteObject>& connect);
    int32_t GetLocalMissionInfos(int32_t numMissions, std::vector<DstbMissionInfo>& missionInfos);
    int32_t RegisterMissionListener(const sptr<AAFwk::IMissionListener>& listener);
    int32_t UnRegisterMissionListener(const sptr<AAFwk::IMissionListener>& listener);
    int32_t GetLocalMissionSnapshotInfo(const std::string& networkId, int32_t missionId,
        AAFwk::MissionSnapshot& missionSnapshot);
    int32_t ReleaseAbility(const sptr<IRemoteObject>& connect, const AppExecFwk::ElementName &element);
    int32_t StartAbilityByCall(const OHOS::AAFwk::Want& want, const sptr<IRemoteObject>& connect,
        const sptr<IRemoteObject>& callerToken);
    void ProcessCallerDied(const sptr<IRemoteObject>& connect, int32_t deviceType);
    void ProcessCalleeDied(const sptr<IRemoteObject>& connect);
    bool InitHichainService();
    void ProcessCallResult(const sptr<IRemoteObject>& calleeConnect, const sptr<IRemoteObject>& callerConnect);
    bool CheckAccessToGroup(const std::string& groupId, const std::string& targetBundleName);
    bool GetRelatedGroups(const std::string& udid, const std::string& bundleName, std::string& returnGroups);
private:
    void ProcessDeviceOffline(const std::string& deviceId);

    std::shared_ptr<AppExecFwk::EventHandler> dmsAdapterHandler_;
    const DeviceGroupManager* hichainGmInstance_ = nullptr;
    std::mutex hichainLock_;
};
} // namespace DistributedSchedule
} // namespace OHOS
#endif // OHOS_DISTRIBUTED_SCHED_ADAPTER_H