session-ios/SessionSnodeKit/Database/Migrations/_001_InitialSetupMigration.swift

// Copyright © 2022 Rangeproof Pty Ltd. All rights reserved.
//
// stringlint:disable

import Foundation
import GRDB
import SessionUtilitiesKit

enum _001_InitialSetupMigration: Migration {
    static let target: TargetMigrations.Identifier = .snodeKit
    static let identifier: String = "initialSetup"
    static let minExpectedRunDuration: TimeInterval = 0.1
    static let createdTables: [(TableRecord & FetchableRecord).Type] = []
    
    static func migrate(_ db: Database, using dependencies: Dependencies) throws {
        try db.create(table: "snode") { t in
            t.column("public_ip", .text)
            t.column("storage_port", .integer)
            t.column("ed25519PublicKey", .text)
            t.column("pubkey_x25519", .text)
        }
        
        try db.create(table: "snodeSet") { t in
            t.column("key", .text)
            t.column("nodeIndex", .integer)
            t.column("address", .text)
            t.column("port", .integer)
        }
        
        try db.create(table: "snodeReceivedMessageInfo") { t in
            t.column("id", .integer)
                .notNull()
                .primaryKey(autoincrement: true)
            t.column("key", .text)
                .notNull()
                .indexed()                                            // Quicker querying
            t.column("hash", .text)
                .notNull()
                .indexed()                                            // Quicker querying
            t.column("expirationDateMs", .integer)
                .notNull()
                .indexed()                                            // Quicker querying
            
            t.uniqueKey(["key", "hash"])
        }
        
        Storage.update(progress: 1, for: self, in: target, using: dependencies)
    }
}