Multitype db

src/Migration/Cache.php

@@ -46,6 +46,7 @@ public function resolveResourceCacheKey(Resource $resource): string
             case Resource::TYPE_TABLE:
             case Resource::TYPE_COLLECTION:
                 /** @var Table $resource */
+                $keys[] = $resource->getDatabase()->getType();
                 $keys[] = $resource->getDatabase()->getSequence();
                 break;
 

src/Migration/Resource.php

@@ -30,6 +30,13 @@ abstract class Resource implements \JsonSerializable
 
     public const TYPE_DATABASE = 'database';
 
+    public const TYPE_DATABASE_LEGACY = 'legacy';
+
+    public const TYPE_DATABASE_TABLESDB = 'tablesdb';
+
+    public const TYPE_DATABASE_DOCUMENTSDB = 'documentsdb';
+    public const TYPE_DATABASE_VECTORDB = 'vectordb';
+
     public const TYPE_ROW = 'row';
 
     public const TYPE_FILE = 'file';
@@ -76,6 +83,8 @@ abstract class Resource implements \JsonSerializable
         self::TYPE_BUCKET,
         self::TYPE_TABLE,
         self::TYPE_DATABASE,
+        self::TYPE_DATABASE_VECTORDB,
+        self::TYPE_DATABASE_DOCUMENTSDB,
         self::TYPE_ROW,
         self::TYPE_FILE,
         self::TYPE_FUNCTION,
@@ -96,6 +105,39 @@ abstract class Resource implements \JsonSerializable
         self::TYPE_COLLECTION,
     ];
 
+    // index terminology is same for all
+    public const DATABASE_TYPE_RESOURCE_MAP = [
+        self::TYPE_DATABASE => [
+            'entity' => self::TYPE_TABLE,
+            'field' => self::TYPE_COLUMN,
+            'record' => self::TYPE_ROW,
+        ],
+        self::TYPE_DATABASE_DOCUMENTSDB => [
+            'entity' => self::TYPE_COLLECTION,
+            // HACK: not required in documentsdb but adding it for consistency in the db reader(not gonna impact)
+            'field' => self::TYPE_ATTRIBUTE,
+            'record' => self::TYPE_DOCUMENT,
+        ],
+        self::TYPE_DATABASE_VECTORDB => [
+            'entity' => self::TYPE_COLLECTION,
+            'field' => self::TYPE_ATTRIBUTE,
+            'record' => self::TYPE_DOCUMENT,
+        ]
+    ];
+
+    public const ENTITY_TYPE_RESOURCE_MAP = [
+        self::TYPE_TABLE => [
+            'field' => self::TYPE_COLUMN,
+            'record' => self::TYPE_ROW,
+            'index' => self::TYPE_INDEX
+        ],
+        self::TYPE_COLLECTION => [
+            'field' => self::TYPE_ATTRIBUTE,
+            'record' => self::TYPE_DOCUMENT,
+            'index' => self::TYPE_INDEX
+        ],
+    ];
+
     protected string $id = '';
 
     protected string $originalId = '';

src/Migration/Resources/Database/Attribute.php

@@ -0,0 +1,158 @@
+<?php
+
+namespace Utopia\Migration\Resources\Database;
+
+use Utopia\Migration\Resource;
+use Utopia\Migration\Transfer;
+
+abstract class Attribute extends Resource
+{
+    public const TYPE_STRING = 'string';
+    public const TYPE_INTEGER = 'integer';
+    public const TYPE_FLOAT = 'double';
+    public const TYPE_BOOLEAN = 'boolean';
+    public const TYPE_DATETIME = 'datetime';
+    public const TYPE_EMAIL = 'email';
+    public const TYPE_ENUM = 'enum';
+    public const TYPE_IP = 'ip';
+    public const TYPE_URL = 'url';
+    public const TYPE_RELATIONSHIP = 'relationship';
+
+    public const TYPE_POINT = 'point';
+    public const TYPE_LINE = 'linestring';
+    public const TYPE_POLYGON = 'polygon';
+
+    public const TYPE_OBJECT = 'object';
+    public const TYPE_VECTOR = 'vector';
+
+    /**
+     * @param string $key
+     * @param Table $table
+     * @param int $size
+     * @param bool $required
+     * @param mixed|null $default
+     * @param bool $array
+     * @param bool $signed
+     * @param string $format
+     * @param array<string, mixed> $formatOptions
+     * @param array<string> $filters
+     * @param array<string, mixed> $options
+     * @param string $createdAt
+     * @param string $updatedAt
+     */
+    public function __construct(
+        protected readonly string $key,
+        protected readonly Table  $table,
+        protected readonly int    $size = 0,
+        protected readonly bool   $required = false,
+        protected readonly mixed  $default = null,
+        protected readonly bool   $array = false,
+        protected readonly bool   $signed = false,
+        protected readonly string $format = '',
+        protected readonly array  $formatOptions = [],
+        protected readonly array  $filters = [],
+        protected array           $options = [],
+        protected string          $createdAt = '',
+        protected string $updatedAt = '',
+    ) {
+    }
+
+    /**
+     * @return array<string, mixed>
+     */
+    public function jsonSerialize(): array
+    {
+        return [
+            'key' => $this->key,
+            'table' => $this->table,
+            'type' => $this->getType(),
+            'size' => $this->size,
+            'required' => $this->required,
+            'default' => $this->default,
+            'array' => $this->array,
+            'signed' => $this->signed,
+            'format' => $this->format,
+            'formatOptions' => $this->formatOptions,
+            'filters' => $this->filters,
+            'options' => $this->options,
+            'createdAt' => $this->createdAt,
+            'updatedAt' => $this->updatedAt,
+        ];
+    }
+
+    public static function getName(): string
+    {
+        return Resource::TYPE_ATTRIBUTE;
+    }
+
+    abstract public function getType(): string;
+
+    public function getGroup(): string
+    {
+        return Transfer::GROUP_DATABASES;
+    }
+
+    public function getKey(): string
+    {
+        return $this->key;
+    }
+
+    public function getTable(): Table
+    {
+        return $this->table;
+    }
+
+    public function getSize(): int
+    {
+        return $this->size;
+    }
+
+    public function isRequired(): bool
+    {
+        return $this->required;
+    }
+
+    public function getDefault(): mixed
+    {
+        return $this->default;
+    }
+
+    public function isArray(): bool
+    {
+        return $this->array;
+    }
+
+    public function isSigned(): bool
+    {
+        return $this->signed;
+    }
+
+    public function getFormat(): string
+    {
+        return $this->format;
+    }
+
+    /**
+     * @return array<string, mixed>
+     */
+    public function getFormatOptions(): array
+    {
+        return $this->formatOptions;
+    }
+
+    /**
+     * @return array<string>
+     */
+    public function getFilters(): array
+    {
+        return $this->filters;
+    }
+
+    /**
+     * @return array<string, mixed>
+     */
+    public function &getOptions(): array
+    {
+        return $this->options;
+    }
+}

src/Migration/Resources/Database/Attribute/Boolean.php

@@ -0,0 +1,78 @@
+<?php
+
+namespace Utopia\Migration\Resources\Database\Attribute;
+
+use Utopia\Migration\Resources\Database\Attribute;
+use Utopia\Migration\Resources\Database\Collection;
+
+class Boolean extends Attribute
+{
+    public function __construct(
+        string $key,
+        Collection $collection,
+        bool   $required = false,
+        ?bool  $default = null,
+        bool   $array = false,
+        string $createdAt = '',
+        string $updatedAt = ''
+    ) {
+        parent::__construct(
+            $key,
+            $collection,
+            required: $required,
+            default: $default,
+            array: $array,
+            createdAt: $createdAt,
+            updatedAt: $updatedAt
+        );
+    }
+
+    /**
+     * @param array{
+     *     key: string,
+     *     collection?: array{
+     *         database: array{
+     *             id: string,
+     *             name: string,
+     *         },
+     *         name: string,
+     *         id: string,
+     *         documentSecurity: bool,
+     *         permissions: ?array<string>
+     *     },
+     *     table?: array{
+     *         database: array{
+     *             id: string,
+     *             name: string,
+     *         },
+     *         name: string,
+     *         id: string,
+     *         rowSecurity: bool,
+     *         permissions: ?array<string>
+     *     },
+     *     required: bool,
+     *     array: bool,
+     *     default: ?bool,
+     *     createdAt: string,
+     *     updatedAt: string,
+     * } $array
+     * @return self
+     */
+    public static function fromArray(array $array): self
+    {
+        return new self(
+            $array['key'],
+            Collection::fromArray($array['table'] ?? $array['collection']),
+            required: $array['required'],
+            default: $array['default'],
+            array: $array['array'],
+            createdAt: $array['createdAt'] ?? '',
+            updatedAt: $array['updatedAt'] ?? '',
+        );
+    }
+
+    public function getType(): string
+    {
+        return Attribute::TYPE_BOOLEAN;
+    }
+}

src/Migration/Resources/Database/Attribute/DateTime.php

@@ -0,0 +1,79 @@
+<?php
+
+namespace Utopia\Migration\Resources\Database\Attribute;
+
+use Utopia\Migration\Resources\Database\Attribute;
+use Utopia\Migration\Resources\Database\Collection;
+
+class DateTime extends Attribute
+{
+    public function __construct(
+        string  $key,
+        Collection   $collection,
+        bool    $required = false,
+        ?string $default = null,
+        bool    $array = false,
+        string  $createdAt = '',
+        string  $updatedAt = ''
+    ) {
+        parent::__construct(
+            $key,
+            $collection,
+            required: $required,
+            default: $default,
+            array: $array,
+            filters: ['datetime'],
+            createdAt: $createdAt,
+            updatedAt: $updatedAt
+        );
+    }
+
+    public function getType(): string
+    {
+        return Attribute::TYPE_DATETIME;
+    }
+
+    /**
+     * @param array{
+     *     key: string,
+     *     collection?: array{
+     *         database: array{
+     *             id: string,
+     *             name: string,
+     *         },
+     *         name: string,
+     *         id: string,
+     *         documentSecurity: bool,
+     *         permissions: ?array<string>
+     *     },
+     *     table?: array{
+     *         database: array{
+     *             id: string,
+     *             name: string,
+     *         },
+     *         name: string,
+     *         id: string,
+     *         rowSecurity: bool,
+     *         permissions: ?array<string>
+     *     },
+     *     required: bool,
+     *     array: bool,
+     *     default: ?string,
+     *     createdAt: string,
+     *     updatedAt: string,
+     * } $array
+     * @return self
+     */
+    public static function fromArray(array $array): self
+    {
+        return new self(
+            $array['key'],
+            Collection::fromArray($array['table'] ?? $array['collection']),
+            required: $array['required'],
+            default: $array['default'],
+            array: $array['array'],
+            createdAt: $array['createdAt'] ?? '',
+            updatedAt: $array['updatedAt'] ?? '',
+        );
+    }
+}