import type {
  CreationOptional,
  InferAttributes,
  InferCreationAttributes,
  NonAttribute,
} from '@sequelize/core';
import { DataTypes, Model, Op, sql } from '@sequelize/core';
import { Attribute, BelongsTo } from '@sequelize/core/decorators-legacy';
import { expect } from 'chai';
import semver from 'semver';
import { beforeAll2, beforeEach2, inlineErrorCause, sequelize, setResetMode } from './support';

const dialect = sequelize.dialect;
const dialectName = dialect.name;

/**
 * Whether the current dialect supports comparing JSON to JSON directly.
 * In dialects like postgres, no "json = json" operator exists, we need to cast to text first.
 * It does however support "jsonb = jsonb".
 */
const dialectSupportsJsonEquality = ['sqlite3', 'mysql', 'mariadb', 'mssql'].includes(dialectName);

describe('JSON Manipulation', () => {
  if (!dialect.supports.dataTypes.JSON) {
    return;
  }

  const vars = beforeEach2(async () => {
    class User extends Model<InferAttributes<User>> {
      @Attribute(DataTypes.JSON)
      declare jsonAttr: any;
    }

    sequelize.addModels([User]);
    await sequelize.sync({ force: true });

    return { User };
  });

  it('supports inserting json', async () => {
    const user = await vars.User.create({
      jsonAttr: { username: 'joe' },
    });

    expect(user.jsonAttr).to.deep.equal({ username: 'joe' });
  });

  it('supports updating json', async () => {
    const user = await vars.User.create({
      jsonAttr: { username: 'joe' },
    });

    user.jsonAttr = { name: 'larry' };

    await user.save();

    expect(user.jsonAttr).to.deep.equal({ name: 'larry' });
  });

  it('should be able to store strings that require escaping', async () => {
    const text = 'Multi-line \n \'$string\' needing "escaping" for $$ and $1 type values';

    await vars.User.create({ jsonAttr: text });
    const user = await vars.User.findOne({ rejectOnEmpty: true });
    expect(user.jsonAttr).to.equal(text);
  });
});

const JSON_OBJECT = { name: 'swen', phones: [1337, 42] };
const JSON_STRING = 'kate';

describe('JSON Querying', () => {
  if (!dialect.supports.dataTypes.JSON) {
    return;
  }

  setResetMode('none');

  const vars = beforeAll2(async () => {
    class User extends Model<InferAttributes<User>, InferCreationAttributes<User>> {
      declare id: CreationOptional<number>;

      @Attribute(DataTypes.JSON)
      declare objectJsonAttr: object;

      @Attribute(DataTypes.JSON)
      declare stringJsonAttr: string;
    }

    class Order extends Model<InferAttributes<Order>, InferCreationAttributes<Order>> {
      declare id: CreationOptional<number>;

      @BelongsTo(() => User, 'userId')
      declare user: NonAttribute<User>;

      @Attribute(DataTypes.INTEGER)
      declare userId: number;
    }

    sequelize.addModels([User, Order]);
    await sequelize.sync({ force: true });

    const user = await User.create({
      objectJsonAttr: JSON_OBJECT,
      stringJsonAttr: JSON_STRING,
    });

    await Order.create({ userId: user.id });

    return { User, Order };
  });

  it('parses retrieved JSON values', async () => {
    const user = await vars.User.findOne({ rejectOnEmpty: true });

    expect(user.objectJsonAttr).to.deep.eq(JSON_OBJECT);
    expect(user.stringJsonAttr).to.eq(JSON_STRING);
  });

  if (dialectSupportsJsonEquality) {
    it('should be able to compare JSON to JSON directly', async () => {
      const user = await vars.User.findOne({
        where: {
          stringJsonAttr: JSON_STRING,
        },
      });

      expect(user).to.exist;
    });
  } else {
    it('should not be able to compare JSON to JSON directly', async () => {
      await expect(
        vars.User.findOne({
          where: {
            stringJsonAttr: JSON_STRING,
          },
        }),
      ).to.be.rejected;
    });
  }

  it('should be able to retrieve json value as object for json fields created in every mariadb release', async () => {
    // MariaDB does not support native JSON type, it uses longtext instead
    // MariaDB >=10.5.2 adds a CHECK(json_valid(field)) validator that uses to return a different dataFormat to clients
    // mariadb connector use this to decide to parse or not a JSON field before sequelize
    if (dialectName !== 'mariadb') {
      return;
    }

    await sequelize.query(`CREATE TABLE Posts (id INTEGER AUTO_INCREMENT PRIMARY KEY,
      metaOldJSONtype longtext CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT NULL,
      metaNewJSONtype longtext CHARACTER SET utf8mb4 COLLATE utf8mb4_bin DEFAULT NULL CHECK(json_valid(metaNewJSONtype)))`);

    const Posts = sequelize.define(
      'Posts',
      {
        metaOldJSONtype: DataTypes.JSON,
        metaNewJSONtype: DataTypes.JSON,
      },
      {
        freezeTableName: true,
        timestamps: false,
      },
    );

    await Posts.create({ metaOldJSONtype: 'some text', metaNewJSONtype: 'some text' });

    const posts = await Posts.findAll({ raw: true });
    expect(posts[0].metaOldJSONtype).to.equal(posts[0].metaNewJSONtype);
  });

  describe('JSON quoted', () => {
    if (dialect.supports.jsonExtraction.quoted) {
      it('should be able to retrieve element of array by index', async () => {
        const user = await vars.User.findOne({
          attributes: [[sql.attribute('objectJsonAttr.phones[1]'), 'firstEmergencyNumber']],
          rejectOnEmpty: true,
        });

        // @ts-expect-error -- typings are not currently designed to handle custom attributes
        const firstNumber: string = user.getDataValue('firstEmergencyNumber');

        expect(Number.parseInt(firstNumber, 10)).to.equal(42);
      });

      it('should be able to query using JSON path objects', async () => {
        // JSON requires casting to text in postgres. There is no "json = json" operator
        // No-cast version is tested higher up in this suite
        const comparison =
          dialectName === 'postgres' ? { 'name::text': '"swen"' } : { name: 'swen' };

        const user = await vars.User.findOne({
          where: { objectJsonAttr: comparison },
        });

        expect(user).to.exist;
      });

      it('should be able to query using JSON path dot notation', async () => {
        // JSON requires casting to text in postgres. There is no "json = json" operator
        // No-cast version is tested higher up in this suite
        const comparison =
          dialectName === 'postgres'
            ? { 'objectJsonAttr.name::text': '"swen"' }
            : { 'objectJsonAttr.name': 'swen' };

        const user = await vars.User.findOne({
          where: comparison,
        });

        expect(user).to.exist;
      });

      it('should be able retrieve json value with nested include', async () => {
        const orders = await vars.Order.findAll({
          attributes: ['id'],
          include: [
            {
              model: vars.User,
              attributes: [[sql.attribute('objectJsonAttr.name'), 'name']],
            },
          ],
        });

        // we can't automatically detect that the output is JSON type in mariadb < 10.5.2,
        // and we don't yet support specifying (nor inferring) the type of custom attributes,
        // so for now the output is different in this specific case
        const expectedResult =
          dialectName === 'mariadb' && semver.lt(sequelize.getDatabaseVersion(), '10.5.2')
            ? '"swen"'
            : 'swen';

        // @ts-expect-error -- getDataValue does not support custom attributes
        expect(orders[0].user.getDataValue('name')).to.equal(expectedResult);
      });
    }
  });

  describe('JSON unquoted', () => {
    if (dialect.supports.jsonExtraction.unquoted) {
      it('should be able to retrieve element of array by index', async () => {
        const user = await vars.User.findOne({
          attributes: [[sql.attribute('objectJsonAttr.phones[1]:unquote'), 'firstEmergencyNumber']],
          rejectOnEmpty: true,
        });

        // @ts-expect-error -- typings are not currently designed to handle custom attributes
        const firstNumber: string = user.getDataValue('firstEmergencyNumber');

        expect(Number.parseInt(firstNumber, 10)).to.equal(42);
      });

      it('should be able to query using JSON path dot notation', async () => {
        const user = await vars.User.findOne({
          // JSON unquote does not require casting to text, as it already returns text
          where: { 'objectJsonAttr.name:unquote': 'swen' },
        });

        expect(user).to.exist;
      });

      it('should be able retrieve json value with nested include', async () => {
        const orders = await vars.Order.findAll({
          attributes: ['id'],
          include: [
            {
              model: vars.User,
              attributes: [[sql.attribute('objectJsonAttr.name:unquote'), 'name']],
            },
          ],
        });

        // @ts-expect-error -- getDataValue does not support custom attributes
        expect(orders[0].user.getDataValue('name')).to.equal('swen');
      });
    }
  });
});

describe('JSON Casting', () => {
  if (!dialect.supports.dataTypes.JSON || !dialect.supports.jsonOperations) {
    return;
  }

  setResetMode('truncate');

  const vars = beforeAll2(async () => {
    class User extends Model<InferAttributes<User>, InferCreationAttributes<User>> {
      @Attribute(DataTypes.JSON)
      declare jsonAttr: any;
    }

    sequelize.addModels([User]);
    await sequelize.sync({ force: true });

    return { User };
  });

  it('supports casting to timestamp types', async () => {
    await vars.User.create({
      jsonAttr: {
        date: new Date('2021-01-02').toISOString(),
      },
    });

    const cast =
      dialectName === 'mysql' || dialectName === 'mariadb'
        ? 'DATETIME'
        : dialectName === 'mssql'
          ? 'DATETIMEOFFSET'
          : 'TIMESTAMPTZ';

    const user = await vars.User.findOne({
      where: {
        [`jsonAttr.date:unquote::${cast}`]: new Date('2021-01-02'),
      },
    });

    expect(user).to.exist;

    const user2 = await vars.User.findOne({
      where: {
        [`jsonAttr.date:unquote::${cast}`]: {
          [Op.between]: [new Date('2021-01-01'), new Date('2021-01-03')],
        },
      },
    });

    expect(user2).to.exist;
  });

  it('supports casting to boolean', async () => {
    // These dialects do not have a native BOOLEAN type
    if (['mariadb', 'mysql', 'mssql'].includes(dialectName)) {
      return;
    }

    await vars.User.create({
      jsonAttr: {
        boolean: true,
      },
    });

    const user = await vars.User.findOne({
      where: {
        'jsonAttr.boolean:unquote::boolean': true,
      },
    });

    expect(user).to.exist;
  });

  it('supports casting to numbers', async () => {
    await vars.User.create({
      jsonAttr: {
        integer: 7,
      },
    });

    const cast = dialectName === 'mysql' || dialectName === 'mariadb' ? 'SIGNED' : 'INTEGER';

    const user = await vars.User.findOne({
      where: {
        [`jsonAttr.integer:unquote::${cast}`]: 7,
      },
    });

    expect(user).to.exist;
  });
});

describe('JSONB Querying', () => {
  if (!dialect.supports.dataTypes.JSONB) {
    return;
  }

  setResetMode('none');

  const vars = beforeAll2(async () => {
    class User extends Model<InferAttributes<User>, InferCreationAttributes<User>> {
      declare id: CreationOptional<number>;

      @Attribute(DataTypes.JSONB)
      declare objectJsonbAttr: object;

      @Attribute(DataTypes.JSONB)
      declare stringJsonbAttr: CreationOptional<string>;
    }

    class Order extends Model<InferAttributes<Order>, InferCreationAttributes<Order>> {
      declare id: CreationOptional<number>;

      @BelongsTo(() => User, 'userId')
      declare user: NonAttribute<User>;

      @Attribute(DataTypes.INTEGER)
      declare userId: number;
    }

    sequelize.addModels([User, Order]);
    await sequelize.sync({ force: true });

    const user = await User.create({
      objectJsonbAttr: JSON_OBJECT,
      stringJsonbAttr: JSON_STRING,
    });

    await Order.create({ userId: user.id });

    return { User, Order };
  });

  it('should be able to query using the nested query language', async () => {
    const user = await vars.User.findOne({
      // JSONB does not require casting
      where: { objectJsonbAttr: { name: 'swen' } },
    });

    expect(user).to.exist;
  });

  it('should be able to query using the JSON unquote syntax', async () => {
    const user = await vars.User.findOne({
      where: { 'objectJsonbAttr.name:unquote': 'swen' },
    });

    expect(user).to.exist;
  });

  it('should be able to query using dot syntax', async () => {
    const user = await vars.User.findOne({
      // JSONB does not require casting, nor unquoting
      where: { 'objectJsonbAttr.name': 'swen' },
    });

    expect(user).to.exist;
  });

  it('should be able retrieve json value with nested include', async () => {
    const orders = await vars.Order.findAll({
      attributes: ['id'],
      include: [
        {
          model: vars.User,
          attributes: [[sql.attribute('objectJsonbAttr.name'), 'name']],
        },
      ],
    });

    // @ts-expect-error -- getDataValue's typing does not support custom attributes
    expect(orders[0].user.getDataValue('name')).to.equal('swen');
  });

  it('should be able to check any of these array strings exist as top-level keys', async () => {
    const user = await vars.User.findOne({
      where: {
        objectJsonbAttr: {
          [Op.anyKeyExists]: ['name', 'does-not-exist'],
        },
      },
    });

    expect(user).to.exist;
  });

  it('should be able to check all of these array strings exist as top-level keys', async () => {
    const user = await vars.User.findOne({
      where: {
        objectJsonbAttr: {
          [Op.allKeysExist]: ['name', 'phones'],
        },
      },
    });

    expect(user).to.exist;
  });

  it('should be able to findOrCreate with values that require escaping', async () => {
    const text = 'Multi-line \'$string\' needing "escaping" for $$ and $1 type values';

    const [user, created] = await vars.User.findOrCreate({
      where: { objectJsonbAttr: { text } },
      defaults: { objectJsonbAttr: { text } },
    });

    expect(created).to.equal(true);
    expect(user.isNewRecord).to.equal(false);

    const refreshedUser = await vars.User.findOne({
      where: { 'objectJsonbAttr.text:unquote': text },
    });
    expect(refreshedUser).to.exist;
  });
});

describe('JSONB Casting', () => {
  if (!dialect.supports.dataTypes.JSONB) {
    return;
  }

  setResetMode('truncate');

  const vars = beforeAll2(async () => {
    class User extends Model<InferAttributes<User>, InferCreationAttributes<User>> {
      @Attribute(DataTypes.JSONB)
      declare jsonbAttr: any;
    }

    sequelize.addModels([User]);
    await sequelize.sync({ force: true });

    return { User };
  });

  it('supports comparing to json null', async () => {
    await vars.User.create({
      jsonbAttr: {
        // This is JSON null
        value: null,
      },
    });

    const user = await vars.User.findOne({
      where: {
        // Using the 'EQ' operator compares to SQL NULL
        'jsonbAttr.value': { [Op.eq]: null },
      },
    });

    expect(user).to.exist;
  });

  it('supports comparing to SQL NULL', async () => {
    await vars.User.create({
      jsonbAttr: {},
    });

    const user = await vars.User.findOne({
      where: {
        // Using the 'IS' operator compares to SQL NULL
        'jsonbAttr.value': { [Op.is]: null },
      },
    });

    expect(user).to.exist;
  });

  it('requires being explicit when comparing to NULL', async () => {
    const error = await expect(
      vars.User.findOne({
        where: {
          'jsonbAttr.value': null,
        },
      }),
    ).to.be.rejected;

    expect(inlineErrorCause(error)).to.include('You must be explicit');
  });
});