1 /*
2 * Copyright (c) 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 #include <meta/api/make_callback.h>
16 #include <meta/interface/intf_recyclable.h>
17
18 #include "instantiating_object_provider.h"
19
META_BEGIN_NAMESPACE()20 META_BEGIN_NAMESPACE()
21
22 ObjectProviderBase::~ObjectProviderBase()
23 {
24 SetDataModel(nullptr);
25 }
26
CreateObject(const DataModelIndex & index)27 IObject::Ptr ObjectProviderBase::CreateObject(const DataModelIndex& index)
28 {
29 if (!index.IsValid() || !model_) {
30 return nullptr;
31 }
32
33 IObject::Ptr obj;
34 if (auto data = model_->GetModelData(index)) {
35 if (!recyclebin_.empty()) {
36 obj = recyclebin_.back();
37 recyclebin_.pop_back();
38 } else {
39 obj = Construct(data);
40 }
41 if (auto i = interface_cast<IRecyclable>(obj)) {
42 i->ReBuild(data);
43 } else {
44 BindProperties(obj, data);
45 }
46 }
47 return obj;
48 }
49
DisposeObject(const META_NS::IObject::Ptr & item)50 bool ObjectProviderBase::DisposeObject(const META_NS::IObject::Ptr& item)
51 {
52 if (auto i = interface_cast<IRecyclable>(item)) {
53 i->Dispose();
54 } else if (auto d = interface_cast<IMetadata>(item)) {
55 for (auto&& p : d->GetAllProperties()) {
56 if (!IsFlagSet(p, ObjectFlagBits::NATIVE)) {
57 PropertyLock l { p };
58 l->ResetBind();
59 }
60 }
61 }
62 bool recycle = recyclebin_.size() < CacheHint()->GetValue();
63 if (recycle) {
64 recyclebin_.push_back(item);
65 }
66 return recycle;
67 }
68
GetObjectCount(const DataModelIndex & index) const69 size_t ObjectProviderBase::GetObjectCount(const DataModelIndex& index) const
70 {
71 return model_ ? model_->GetSize() : 0;
72 }
73
SetDataModel(const IDataModel::Ptr & model)74 bool ObjectProviderBase::SetDataModel(const IDataModel::Ptr& model)
75 {
76 if (model_) {
77 model_->OnDataAdded()->RemoveHandler(uintptr_t(this));
78 model_->OnDataRemoved()->RemoveHandler(uintptr_t(this));
79 model_->OnDataMoved()->RemoveHandler(uintptr_t(this));
80 }
81 model_ = model;
82 if (model_) {
83 model_->OnDataAdded()->AddHandler(MakeCallback<IOnDataAdded>([this](DataModelIndex base, size_t count) {
84 META_ACCESS_EVENT(OnDataAdded)->Invoke(base, count);
85 }),
86 uintptr_t(this));
87 model_->OnDataRemoved()->AddHandler(MakeCallback<IOnDataRemoved>([this](DataModelIndex base, size_t count) {
88 META_ACCESS_EVENT(OnDataRemoved)->Invoke(base, count);
89 }),
90 uintptr_t(this));
91 model_->OnDataMoved()->AddHandler(
92 MakeCallback<IOnDataMoved>([this](DataModelIndex from, size_t count, DataModelIndex to) {
93 META_ACCESS_EVENT(OnDataMoved)->Invoke(from, count, to);
94 }),
95 uintptr_t(this));
96 }
97 return true;
98 }
99
GetDataModel() const100 IDataModel::Ptr ObjectProviderBase::GetDataModel() const
101 {
102 return model_;
103 }
104
BindProperties(const IObject::Ptr & object,const IMetadata::Ptr & data) const105 void ObjectProviderBase::BindProperties(const IObject::Ptr& object, const IMetadata::Ptr& data) const
106 {
107 if (auto odata = interface_cast<IMetadata>(object)) {
108 for (auto&& p : data->GetAllProperties()) {
109 BASE_NS::string name = "Model." + p->GetName();
110 IProperty::Ptr prop = odata->GetPropertyByName(name);
111 if (!prop) {
112 prop = DuplicatePropertyType(META_NS::GetObjectRegistry(), p, name);
113 if (prop) {
114 odata->AddProperty(prop);
115 }
116 }
117 if (prop) {
118 PropertyLock l { prop };
119 l->SetBind(p);
120 }
121 }
122 }
123 }
124
Construct(const IMetadata::Ptr & data)125 IObject::Ptr ObjectProviderBase::Construct(const IMetadata::Ptr& data)
126 {
127 return nullptr;
128 }
129
130 META_END_NAMESPACE()
131