export const baseTableColumns = {
  id: int('id').primaryKey().autoincrement().notNull(),
  updatedAt: timestamp('updated_at').onUpdateNow(),
  createdAt: timestamp('created_at').defaultNow().notNull(),
  deletedAt: timestamp('deleted_at')
}

export const sentReminderTable = mysqlTable('sent_reminder', {
  ...baseTableColumns,
  reminderId: int('reminder_id').references(() => reminderTable.id).notNull(),
  invoiceId: int('invoice_id').references(() => invoiceTable.id).notNull(),
  notificationType: mysqlEnum('notification_type', reminderNotificationType).notNull(),
  familyMemberId: int('family_member_id').references(() => familyMemberTable.id).notNull(),
  sentAt: timestamp('sent_at').notNull(),
});

export const baseTableColumns = {
  id: int('id').primaryKey().autoincrement().notNull(),
  updatedAt: timestamp('updated_at').onUpdateNow(),
  createdAt: timestamp('created_at').defaultNow().notNull(),
  deletedAt: timestamp('deleted_at')
}

export const sentReminderTable = mysqlTable('sent_reminder', {
  ...baseTableColumns,
  reminderId: int('reminder_id').references(() => reminderTable.id).notNull(),
  invoiceId: int('invoice_id').references(() => invoiceTable.id).notNull(),
  notificationType: mysqlEnum('notification_type', reminderNotificationType).notNull(),
  familyMemberId: int('family_member_id').references(() => familyMemberTable.id).notNull(),
  sentAt: timestamp('sent_at').notNull(),
});

const baseMysqlTable = <TColumnsMap extends Record<string, MySqlColumnBuilder>>(name: string, columns: TColumnsMap) => {
  return mysqlTable(name, {
    id: int('id').primaryKey().autoincrement().notNull(),
    updatedAt: timestamp('updated_at').onUpdateNow(),
    createdAt: timestamp('created_at').defaultNow().notNull(),
    deletedAt: timestamp('deleted_at'),
    ...columns,
  });
};

export default baseMysqlTable;

export const sentReminderTable = baseMysqlTable('sent_reminder', {
  reminderId: int('reminder_id').references(() => reminderTable.id).notNull(),
  invoiceId: int('invoice_id').references(() => invoiceTable.id).notNull(),
  notificationType: mysqlEnum('notification_type', reminderNotificationType).notNull(),
  familyMemberId: int('family_member_id').references(() => familyMemberTable.id).notNull(),
  sentAt: timestamp('sent_at').notNull(),
});

const baseMysqlTable = <TColumnsMap extends Record<string, MySqlColumnBuilder>>(name: string, columns: TColumnsMap) => {
  return mysqlTable(name, {
    id: int('id').primaryKey().autoincrement().notNull(),
    updatedAt: timestamp('updated_at').onUpdateNow(),
    createdAt: timestamp('created_at').defaultNow().notNull(),
    deletedAt: timestamp('deleted_at'),
    ...columns,
  });
};

export default baseMysqlTable;

export const sentReminderTable = baseMysqlTable('sent_reminder', {
  reminderId: int('reminder_id').references(() => reminderTable.id).notNull(),
  invoiceId: int('invoice_id').references(() => invoiceTable.id).notNull(),
  notificationType: mysqlEnum('notification_type', reminderNotificationType).notNull(),
  familyMemberId: int('family_member_id').references(() => familyMemberTable.id).notNull(),
  sentAt: timestamp('sent_at').notNull(),
});

const baseMysqlTable = <TColumnsMap extends Record<string, AnyMySqlColumnBuilder>>(name: string, columns: TColumnsMap) => {
    return mysqlTable(name, {
        ...columns,
        id: int('id').primaryKey().autoincrement().notNull(),
        updatedAt: timestamp('updated_at').onUpdateNow(),
        createdAt: timestamp('created_at').defaultNow(),
        deletedAt: timestamp('deleted_at')
    });
};

type BaseMysqlTableType = ReturnType<typeof baseMysqlTable>;

const withPagination = async <S extends AnyMySqlSelect, T extends AnyMySqlTable<BaseMysqlTableType>> (qb: S, table: T, offset = 0, limit = 10) => {
    const data = await qb.offset(offset).limit(limit).orderBy(desc(table.id));
    const count = await db.select({}).from(table);
    return {
        data,
        offset,
        limit,
        // total: count[0]
    }
}

const baseMysqlTable = <TColumnsMap extends Record<string, AnyMySqlColumnBuilder>>(name: string, columns: TColumnsMap) => {
    return mysqlTable(name, {
        ...columns,
        id: int('id').primaryKey().autoincrement().notNull(),
        updatedAt: timestamp('updated_at').onUpdateNow(),
        createdAt: timestamp('created_at').defaultNow(),
        deletedAt: timestamp('deleted_at')
    });
};

type BaseMysqlTableType = ReturnType<typeof baseMysqlTable>;

const withPagination = async <S extends AnyMySqlSelect, T extends AnyMySqlTable<BaseMysqlTableType>> (qb: S, table: T, offset = 0, limit = 10) => {
    const data = await qb.offset(offset).limit(limit).orderBy(desc(table.id));
    const count = await db.select({}).from(table);
    return {
        data,
        offset,
        limit,
        // total: count[0]
    }
}