TIDAORealm/Example/RealmDAOTests/RealmDAOEntityTests.swift

//
//  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 {

    let dao = RealmDAO(RLMEntityTranslator())
    

    func testReadById() {
        let entity = Entity(entityId: "2")
        do {
            try dao.persist(entity)
        } catch {
            XCTFail("Persist is failed")
        }

        if let savedEntity = dao.read("2") {
            XCTAssertEqual(entity, savedEntity)
        } else {
            XCTFail("Read is failed")
        }
    }


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

        DispatchQueue.global().async {
            do {
                try self.dao.persist(entity)
            } catch {
                XCTFail("Async read by id is failed")
            }

            DispatchQueue.main.async {
                if let savedEntity = self.dao.read("2_back") {
                    XCTAssertEqual(savedEntity.entityId, entity.entityId)
                } else {
                    XCTFail("Async read by id is failed")
                }
                exp.fulfill()
            }
        }

        waitForExpectations(timeout: 5) { error in
            if error != nil {
                XCTFail("Async read by id is failed")
            }
            XCTAssert(true)
        }
    }


    func testPersist() {
        let entity = Entity(entityId: "1")
        do {
            try dao.persist(entity)
        } catch {
            XCTFail("Saving entity is failed")
        }

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

    func testEraseById() {
        let entity = Entity(entityId: "3")
        do {
            try dao.persist(entity)
            try dao.erase("3")
        } catch {
            XCTFail("Erase is failed")
        }

        XCTAssertNil(dao.read("3"))
    }
    
    
    func testAsyncEraseById() {
        let entity = Entity(entityId: "2_back")
        
        do {
            try dao.persist(entity)
        } catch {
            XCTFail("Async erase by id is failed")
        }
        
        let exp = expectation(description: "")
        
        DispatchQueue.global().async {
            do {
                try self.dao.erase("2_back")
            } catch {
                XCTFail("Async erase by id is failed")
            }
            
            exp.fulfill()
        }
        
        waitForExpectations(timeout: 5) { error in
            if error != nil {
                XCTFail("Async erase by id is failed")
            }
            XCTAssert(true)
        }
    }

}