import "reflect-metadata";
import {closeTestingConnections, createTestingConnections, reloadTestingDatabases} from "../../utils/test-utils";
import {Connection} from "../../../src/connection/Connection";
import {Message, MessageType} from "./entity/Message";
import {Recipient} from "./entity/Recipient";
import {User} from "./entity/User";
import {Chat} from "./entity/Chat";

describe("github issues > #1551 complex example of cascades + multiple primary keys = persistence order", () => {

    let connections: Connection[];
    before(async () => connections = await createTestingConnections({ __dirname, enabledDrivers: ["mysql"] }));
    beforeEach(() => reloadTestingDatabases(connections));
    after(() => closeTestingConnections(connections));

    it("throws an error because there is no object id defined", () => Promise.all(connections.map(async connection => {

        const user1 = new User({
            username: "ethan",
            password: "$2a$08$NO9tkFLCoSqX1c5wk3s7z.JfxaVMKA.m7zUDdDwEquo4rvzimQeJm",
            name: "Ethan Gonzalez",
            picture: "https://randomuser.me/api/portraits/thumb/men/1.jpg",
            phone: "+391234567890",
        });
        await connection.manager.save(user1);

        const user5 = new User({
            username: "ray",
            password: "$2a$08$6.mbXqsDX82ZZ7q5d8Osb..JrGSsNp4R3IKj7mxgF6YGT0OmMw242",
            name: "Ray Edwards",
            picture: "https://randomuser.me/api/portraits/thumb/men/3.jpg",
            phone: "+391234567894",
        });
        await connection.manager.save(user5);

        await connection.manager.save(new Chat({
            allTimeMembers: [user1, user5],
            listingMembers: [user1, user5],
            messages: [
                new Message ({
                    sender: user1,
                    content: "I should buy a boat",
                    type: MessageType.TEXT,
                    holders: [user1, user5],
                    recipients: [
                        new Recipient({
                            user: user5,
                        }),
                    ],
                }),
                new Message({
                    sender: user1,
                    content: "You still there?",
                    type: MessageType.TEXT,
                    holders: [user1, user5],
                    recipients: [
                        new Recipient({
                            user: user5,
                        }),
                    ],
                }),
            ],
        }));

        const messages = await connection.manager.find(Message);
        messages[0].recipients.length.should.be.equal(1);
        messages[1].recipients.length.should.be.equal(1);

        const recipients = await connection.manager.find(Recipient);
        recipients.length.should.be.equal(2);
    })));

    // cascade remove are not supported
    it.skip("throws a \"update or delete on table 'message' violates foreign key constraint on table 'recipient'\" error on delete", () => Promise.all(connections.map(async connection => {

        const user1 = new User({
            username: "ethan",
            password: "$2a$08$NO9tkFLCoSqX1c5wk3s7z.JfxaVMKA.m7zUDdDwEquo4rvzimQeJm",
            name: "Ethan Gonzalez",
            picture: "https://randomuser.me/api/portraits/thumb/men/1.jpg",
            phone: "+391234567890",
        });
        await connection.manager.save(user1);

        const user5 = new User({
            username: "ray",
            password: "$2a$08$6.mbXqsDX82ZZ7q5d8Osb..JrGSsNp4R3IKj7mxgF6YGT0OmMw242",
            name: "Ray Edwards",
            picture: "https://randomuser.me/api/portraits/thumb/men/3.jpg",
            phone: "+391234567894",
        });
        await connection.manager.save(user5);

        await connection.manager.save(new Chat({
            allTimeMembers: [user1, user5],
            listingMembers: [user1, user5],
            messages: [
                new Message ({
                    sender: user1,
                    content: "I should buy a boat",
                    type: MessageType.TEXT,
                    holders: [user1, user5],
                    recipients: [
                        new Recipient({
                            user: user5,
                        }),
                    ],
                }),
                new Message({
                    sender: user1,
                    content: "You still there?",
                    type: MessageType.TEXT,
                    holders: [user1, user5],
                    recipients: [
                        new Recipient({
                            user: user5,
                        }),
                    ],
                }),
            ],
        }));

        const message = await connection
            .createQueryBuilder(Message, "message")
            .getOne();

        if (message) {
            await connection.getRepository(Message).remove(message);
        } else {
            throw new Error("Cannot get message");
        }

        const messages = await connection.manager.find(Message);
        messages.length.should.be.equal(0);

        const recipients = await connection.manager.find(Recipient);
        recipients.length.should.be.equal(0);
    })));

    // cascade remove are not supported
    it.skip("throws a \"null value in column 'userId' violates not-null constraint\" error on delete", () => Promise.all(connections.map(async connection => {

        const user1 = new User({
            username: "ethan",
            password: "$2a$08$NO9tkFLCoSqX1c5wk3s7z.JfxaVMKA.m7zUDdDwEquo4rvzimQeJm",
            name: "Ethan Gonzalez",
            picture: "https://randomuser.me/api/portraits/thumb/men/1.jpg",
            phone: "+391234567890",
        });
        await connection.manager.save(user1);

        const user5 = new User({
            username: "ray",
            password: "$2a$08$6.mbXqsDX82ZZ7q5d8Osb..JrGSsNp4R3IKj7mxgF6YGT0OmMw242",
            name: "Ray Edwards",
            picture: "https://randomuser.me/api/portraits/thumb/men/3.jpg",
            phone: "+391234567894",
        });
        await connection.manager.save(user5);

        await connection.manager.save(new Chat({
            allTimeMembers: [user1, user5],
            listingMembers: [user1, user5],
            messages: [
                new Message ({
                    sender: user1,
                    content: "I should buy a boat",
                    type: MessageType.TEXT,
                    holders: [user1, user5],
                    recipients: [
                        new Recipient({
                            user: user5,
                        }),
                    ],
                }),
                new Message({
                    sender: user1,
                    content: "You still there?",
                    type: MessageType.TEXT,
                    holders: [user1, user5],
                    recipients: [
                        new Recipient({
                            user: user5,
                        }),
                    ],
                }),
            ],
        }));

        const message = await connection.manager.findOne(Message);

        if (message) {
            await connection.getRepository(Message).remove(message);
        } else {
            throw new Error("Cannot get message");
        }

        const messages = await connection.manager.find(Message);
        messages.length.should.be.equal(0);

        const recipients = await connection.manager.find(Recipient);
        recipients.length.should.be.equal(0);
    })));

    // cascade remove are not supported
    it.skip("throws a \"Subject Recipient must have an identifier to perform operation\" internal error on delete", () => Promise.all(connections.map(async connection => {

        const user1 = new User({
            username: "ethan",
            password: "$2a$08$NO9tkFLCoSqX1c5wk3s7z.JfxaVMKA.m7zUDdDwEquo4rvzimQeJm",
            name: "Ethan Gonzalez",
            picture: "https://randomuser.me/api/portraits/thumb/men/1.jpg",
            phone: "+391234567890",
        });
        await connection.manager.save(user1);

        const user5 = new User({
            username: "ray",
            password: "$2a$08$6.mbXqsDX82ZZ7q5d8Osb..JrGSsNp4R3IKj7mxgF6YGT0OmMw242",
            name: "Ray Edwards",
            picture: "https://randomuser.me/api/portraits/thumb/men/3.jpg",
            phone: "+391234567894",
        });
        await connection.manager.save(user5);

        await connection.manager.save(new Chat({
            allTimeMembers: [user1, user5],
            listingMembers: [user1, user5],
            messages: [
                new Message ({
                    sender: user1,
                    content: "I should buy a boat",
                    type: MessageType.TEXT,
                    holders: [user1, user5],
                    recipients: [
                        new Recipient({
                            user: user5,
                        }),
                    ],
                }),
                new Message({
                    sender: user1,
                    content: "You still there?",
                    type: MessageType.TEXT,
                    holders: [user1, user5],
                    recipients: [
                        new Recipient({
                            user: user5,
                        }),
                    ],
                }),
            ],
        }));

        let recipients = await connection.manager.find(Recipient);

        for (let recipient of recipients) {
            await connection.getRepository(Recipient).remove(recipient);
        }

        recipients = await connection.manager.find(Recipient);
        recipients.length.should.be.equal(0);
    })));

});