import { expect, test, beforeEach } from "vitest"

import { AMQPClient } from "../src/amqp-socket-client.js"

import { randomBytes } from "crypto"

beforeEach(() => {

expect.hasAssertions()

})

test("can connect with TLS", () => {

const amqp = new AMQPClient(process.env["AMQPS_URL"] || "amqps://127.0.0.1?insecure=true")

return amqp

.connect()

.then((conn) => conn.channel())

.then((ch) => expect(ch.connection.channels.length).toBe(2)) // 2 because channel 0 is counted

})

test("can batch send message", async () => {

const messages = [randomBytes(500), randomBytes(500), randomBytes(500), randomBytes(500)]

const amqp = new AMQPClient("amqps://localhost?insecure=1")

const connection = await amqp.connect()

const channel = await connection.channel()

await channel.queueDeclare("bug137")

await channel.confirmSelect()

const sendMsgs = messages.map((message) =>

channel.basicPublish("", "bug137", JSON.stringify(message), {

contentType: "application/json",

deliveryMode: 2,

}),

)

expect(connection["bufferPool"].length).toBe(0)

await Promise.all(sendMsgs)

expect(connection["bufferPool"].length).toBe(4)

})