22
33namespace Utopia \Migration ;
44
5- use Utopia \Migration \Resources \Database \Column ;
5+ use Utopia \Migration \Resources \Database \Attribute ;
6+ use Utopia \Migration \Resources \Database \Collection ;
7+ use Utopia \Migration \Resources \Database \Document ;
68use Utopia \Migration \Resources \Database \Index ;
7- use Utopia \Migration \Resources \Database \Row ;
8- use Utopia \Migration \Resources \Database \Table ;
99use Utopia \Migration \Resources \Functions \Deployment ;
1010use Utopia \Migration \Resources \Storage \File ;
1111
@@ -42,19 +42,16 @@ public function resolveResourceCacheKey(Resource $resource): string
4242 $ keys = [];
4343
4444 switch ($ resourceName ) {
45- case Resource::TYPE_TABLE :
4645 case Resource::TYPE_COLLECTION :
47- /** @var Table $resource */
46+ /** @var Collection $resource */
4847 $ keys [] = $ resource ->getDatabase ()->getSequence ();
4948 break ;
5049
51- case Resource::TYPE_ROW :
5250 case Resource::TYPE_DOCUMENT :
53- case Resource::TYPE_COLUMN :
5451 case Resource::TYPE_ATTRIBUTE :
5552 case Resource::TYPE_INDEX :
56- /** @var Row|Column |Index $resource */
57- $ table = $ resource ->getTable ();
53+ /** @var Document|Attribute |Index $resource */
54+ $ table = $ resource ->getCollection ();
5855 $ keys [] = $ table ->getDatabase ()->getSequence ();
5956 $ keys [] = $ table ->getSequence ();
6057 break ;
@@ -75,8 +72,7 @@ public function resolveResourceCacheKey(Resource $resource): string
7572
7673 $ keys [] = $ resource ->getSequence ();
7774
78- $ joinedKey = implode ('_ ' , $ keys );
79- return $ joinedKey ;
75+ return \implode ('_ ' , $ keys );
8076 }
8177
8278 /**
@@ -88,7 +84,7 @@ public function resolveResourceCacheKey(Resource $resource): string
8884 public function add (Resource $ resource ): void
8985 {
9086 $ key = $ this ->resolveResourceCacheKey ($ resource );
91- if ($ resource ->getName () == Resource::TYPE_ROW || $ resource -> getName () == Resource:: TYPE_DOCUMENT ) {
87+ if ($ resource ->getName () == Resource::TYPE_DOCUMENT ) {
9288 $ status = $ resource ->getStatus ();
9389 $ this ->cache [$ resource ->getName ()][$ key ] = $ status ;
9490 return ;
@@ -128,7 +124,7 @@ public function update(Resource $resource): void
128124 {
129125 $ key = $ this ->resolveResourceCacheKey ($ resource );
130126 // if rows then updating the status counter only
131- if ($ resource ->getName () == Resource::TYPE_ROW || $ resource -> getName () == Resource:: TYPE_DOCUMENT ) {
127+ if ($ resource ->getName () == Resource::TYPE_DOCUMENT ) {
132128 if (!isset ($ this ->cache [$ resource ->getName ()][$ key ])) {
133129 $ this ->add ($ resource );
134130 } else {
@@ -168,7 +164,7 @@ public function updateAll(array $resources): void
168164 public function remove (Resource $ resource ): void
169165 {
170166 $ key = $ this ->resolveResourceCacheKey ($ resource );
171- if ($ resource ->getName () == Resource::TYPE_ROW || $ resource -> getName () == Resource:: TYPE_DOCUMENT ) {
167+ if ($ resource ->getName () == Resource::TYPE_DOCUMENT ) {
172168 if (! isset ($ this ->cache [$ resource ->getName ()][$ key ])) {
173169 throw new \Exception ('Resource does not exist in cache ' );
174170 }
0 commit comments