//
//  RealmDAOEraseTests.swift
//  DAO
//
//  Created by Ivan Vavilov on 4/27/17.
//  Copyright © 2017 RedMadRobot LLC. All rights reserved.
//

import XCTest
import DAO
@testable import DAO_Example


final class RealmDAOEntityTests: XCTestCase {
    
    private var dao: RealmDAO<Entity, DBEntity>!
    
    override func setUp() {
        super.setUp()
        
        dao = RealmDAO(RLMEntityTranslator())
    }
    
    override func tearDown() {
        super.tearDown()
        
        try! dao.erase()
        dao = nil
    }
    

    func testReadById() {
        let entity = Entity(entityId: "2")
        
        XCTAssertNoThrow(try dao.persist(entity), "Persist is failed")
        XCTAssertEqual(entity, dao.read("2"), "Read is failed")
    }


    func testAsyncReadById() {
        let entity = Entity(entityId: "2_back")
        let exp = expectation(description: "")

        DispatchQueue.global().async {
            XCTAssertNotNil(try? self.dao.persist(entity), "Async read by id is failed")

            DispatchQueue.global().async {
                XCTAssertEqual(self.dao.read("2_back")?.entityId, entity.entityId, "Async read by id is failed")
                exp.fulfill()
            }
        }

        waitForExpectations(timeout: 5)
    }

    func testPersist() {
        let entity = Entity(entityId: "1")

        XCTAssertNoThrow(try dao.persist(entity), "Saving entity is failed")
        XCTAssert(true)
    }
    
    func testPersistAll() {
        let firstEntity = Entity(entityId: "2")
        let secondEntity = Entity(entityId: "3")
        
        XCTAssertNoThrow(try dao.persist([firstEntity, secondEntity]), "Saving entities is failed")
    }
    
    func testAsyncPersist() {
        let entity = Entity(entityId: "1_back")
        let exp = expectation(description: "")
        
        DispatchQueue.global().async {
            XCTAssertNotNil(try? self.dao.persist(entity), "Saving entity in background is failed")
            exp.fulfill()
        }
        
        waitForExpectations(timeout: 5)
    }

    func testEraseById() {
        let entity = Entity(entityId: "3")
        
        XCTAssertNoThrow(try dao.persist(entity), "Erase is failed")
        XCTAssertNoThrow(try dao.erase("3"), "Erase is failed")
        XCTAssertNil(dao.read("3"))
    }
    
    func testAsyncEraseById() {
        let entity = Entity(entityId: "2_back")
        
        XCTAssertNoThrow(try dao.persist(entity), "Async erase by id is failed")
        
        let exp = expectation(description: "")
        
        DispatchQueue.global().async {
            XCTAssertNotNil(try? self.dao.erase("2_back"), "Async erase by id is failed")
            exp.fulfill()
        }
        
        waitForExpectations(timeout: 5)
    }

}