// @ts-check

const {select} = require("../passthrough")
const {test} = require("supertape")
const {eventSenderIsFromDiscord, getEventIDHash, MatrixStringBuilder, getViaServers, roomHasAtLeastVersion, removeCreatorsFromPowerLevels, setUserPower} = require("./utils")
const util = require("util")

/** @param {string[]} mxids */
function joinedList(mxids) {
	/** @type {{[mxid: string]: {display_name: null, avatar_url: null}}} */
	const joined = {}
	for (const mxid of mxids) {
		joined[mxid] = {
			display_name: null,
			avatar_url: null
		}
	}
	return {joined}
}

test("sender type: matrix user", t => {
	t.notOk(eventSenderIsFromDiscord("@cadence:cadence.moe"))
})

test("sender type: ooye bot", t => {
	t.ok(eventSenderIsFromDiscord("@_ooye_bot:cadence.moe"))
})

test("sender type: ooye puppet", t => {
	t.ok(eventSenderIsFromDiscord("@_ooye_sheep:cadence.moe"))
})

test("event hash: hash is the same each time", t => {
	const eventID = "$example"
	t.equal(getEventIDHash(eventID), getEventIDHash(eventID))
})

test("event hash: hash is different for different inputs", t => {
	t.notEqual(getEventIDHash("$Ij3qo7NxMA4VPexlAiIx2CB9JbsiGhJeyt-2OvkAUe1"), getEventIDHash("$Ij3qo7NxMA4VPexlAiIx2CB9JbsiGhJeyt-2OvkAUe2"))
})

test("MatrixStringBuilder: add, addLine, add same text", t => {
	const e = {
		stack: "Error: Custom error\n    at ./example.test.js:3:11)",
		toString() {
			return "Error: Custom error"
		}
	}
	const gatewayMessage = {t: "MY_MESSAGE", d: {display: "Custom message data"}}
	let stackLines = e.stack.split("\n")

	const builder = new MatrixStringBuilder()
	builder.addLine("\u26a0 Bridged event from Discord not delivered", "\u26a0 <strong>Bridged event from Discord not delivered</strong>")
	builder.addLine(`Gateway event: ${gatewayMessage.t}`)
	builder.addLine(e.toString())
	if (stackLines) {
		stackLines = stackLines.slice(0, 2)
		stackLines[1] = stackLines[1].replace(/\\/g, "/").replace(/(\s*at ).*(\/m2d\/)/, "$1.$2")
		builder.addLine(`Error trace:`, `<details><summary>Error trace</summary>`)
		builder.add(`\n${stackLines.join("\n")}`, `<pre>${stackLines.join("\n")}</pre></details>`)
	}
	builder.addLine("", `<details><summary>Original payload</summary><pre>${util.inspect(gatewayMessage.d, false, 4, false)}</pre></details>`)

	t.deepEqual(builder.get(), {
		msgtype: "m.text",
		body: "\u26a0 Bridged event from Discord not delivered"
			+ "\nGateway event: MY_MESSAGE"
			+ "\nError: Custom error"
			+ "\nError trace:"
			+ "\nError: Custom error"
			+ "\n    at ./example.test.js:3:11)\n",
		format: "org.matrix.custom.html",
		formatted_body: "\u26a0 <strong>Bridged event from Discord not delivered</strong>"
			+ "<br>Gateway event: MY_MESSAGE"
			+ "<br>Error: Custom error"
			+ "<br><details><summary>Error trace</summary><pre>Error: Custom error\n    at ./example.test.js:3:11)</pre></details>"
			+ `<details><summary>Original payload</summary><pre>{ display: 'Custom message data' }</pre></details>`
	})
})

test("MatrixStringBuilder: complete code coverage", t => {
	const builder = new MatrixStringBuilder()
	builder.add("Line 1")
	builder.addParagraph("Line 2")
	builder.add("Line 3")
	builder.addParagraph("Line 4")

	t.deepEqual(builder.get(), {
		msgtype: "m.text",
		body: "Line 1\n\nLine 2Line 3\n\nLine 4",
		format: "org.matrix.custom.html",
		formatted_body: "Line 1<p>Line 2</p>Line 3<p>Line 4</p>"
	})
})

/**
 * @param {string[]} [creators]
 * @param {{[x: string]: number}} [users]
 * @param {string} [roomVersion]
 */
function mockGetEffectivePower(creators = ["@_ooye_bot:cadence.moe"], users = {}, roomVersion = "12") {
	return async function getEffectivePower(roomID, mxids) {
		return {
			allCreators: creators,
			powerLevels: {users},
			powers: mxids.reduce((a, mxid) => {
				if (creators.includes(mxid) && roomHasAtLeastVersion(roomVersion, 12)) a[mxid] = Infinity
				else if (mxid in users) a[mxid] = users[mxid]
				else a[mxid] = 0
				return a
			}, {}),
			roomCreate: {
				type: "m.room.create",
				state_key: "",
				sender: creators[0],
				content: {
					additional_creators: creators.slice(1),
					room_version: roomVersion
				},
				room_id: roomID,
				origin_server_ts: 0,
				event_id: "$create"
			},
			tombstone: roomVersion === "12" ? 150 : 100,
		}
	}
}

test("getViaServers: returns the server name if the room only has sim users", async t => {
	const result = await getViaServers("!baby", {
		getEffectivePower: mockGetEffectivePower(),
		getJoinedMembers: async () => joinedList(["@_ooye_bot:cadence.moe", "@_ooye_hazel:cadence.moe"])
	})
	t.deepEqual(result, ["cadence.moe"])
})

test("getViaServers: also returns the most popular servers in order", async t => {
	const result = await getViaServers("!baby", {
		getEffectivePower: mockGetEffectivePower(),
		getJoinedMembers: async () => joinedList(["@_ooye_bot:cadence.moe", "@_ooye_hazel:cadence.moe", "@cadence:cadence.moe", "@singleuser:selfhosted.invalid", "@hazel:thecollective.invalid", "@june:thecollective.invalid"])
	})
	t.deepEqual(result, ["cadence.moe", "thecollective.invalid", "selfhosted.invalid"])
})

test("getViaServers: does not return IP address servers", async t => {
	const result = await getViaServers("!baby", {
		getEffectivePower: mockGetEffectivePower(),
		getJoinedMembers: async () => joinedList(["@_ooye_bot:cadence.moe", "@_ooye_hazel:cadence.moe", "@cadence:45.77.232.172:8443", "@cadence:[::1]:8443", "@cadence:123example.456example.invalid"])
	})
	t.deepEqual(result, ["cadence.moe", "123example.456example.invalid"])
})

test("getViaServers: also returns the highest power level user (v12 creator)", async t => {
	const result = await getViaServers("!baby", {
		getEffectivePower: mockGetEffectivePower(["@_ooye_bot:cadence.moe", "@singleuser:selfhosted.invalid"], {
			"@moderator:tractor.invalid": 50
		}),
		getJoinedMembers: async () => joinedList(["@_ooye_bot:cadence.moe", "@_ooye_hazel:cadence.moe", "@cadence:cadence.moe", "@singleuser:selfhosted.invalid", "@hazel:thecollective.invalid", "@june:thecollective.invalid", "@moderator:tractor.invalid"])
	})
	t.deepEqual(result, ["cadence.moe", "selfhosted.invalid", "thecollective.invalid", "tractor.invalid"])
})

test("getViaServers: also returns the highest power level user (100)", async t => {
	const result = await getViaServers("!baby", {
		getEffectivePower: mockGetEffectivePower(["@_ooye_bot:cadence.moe"], {
			"@moderator:tractor.invalid": 50,
			"@singleuser:selfhosted.invalid": 100
		}),
		getJoinedMembers: async () => joinedList(["@_ooye_bot:cadence.moe", "@_ooye_hazel:cadence.moe", "@cadence:cadence.moe", "@singleuser:selfhosted.invalid", "@hazel:thecollective.invalid", "@june:thecollective.invalid", "@moderator:tractor.invalid"])
	})
	t.deepEqual(result, ["cadence.moe", "selfhosted.invalid", "thecollective.invalid", "tractor.invalid"])
})

test("getViaServers: also returns the highest power level user (50)", async t => {
	const result = await getViaServers("!baby", {
		getEffectivePower: mockGetEffectivePower(["@_ooye_bot:cadence.moe"], {
			"@moderator:tractor.invalid": 50
		}),
		getJoinedMembers: async () => joinedList(["@_ooye_bot:cadence.moe", "@_ooye_hazel:cadence.moe", "@cadence:cadence.moe", "@moderator:tractor.invalid", "@hazel:thecollective.invalid", "@june:thecollective.invalid", "@singleuser:selfhosted.invalid"])
	})
	t.deepEqual(result, ["cadence.moe", "tractor.invalid", "thecollective.invalid", "selfhosted.invalid"])
})

test("getViaServers: returns at most 4 results", async t => {
	const result = await getViaServers("!baby", {
		getEffectivePower: mockGetEffectivePower(["@_ooye_bot:cadence.moe"], {
			"@moderator:tractor.invalid": 50,
			"@singleuser:selfhosted.invalid": 100
		}),
		getJoinedMembers: async () => joinedList(["@_ooye_bot:cadence.moe", "@_ooye_hazel:cadence.moe", "@cadence:cadence.moe", "@moderator:tractor.invalid", "@singleuser:selfhosted.invalid", "@hazel:thecollective.invalid", "@cadence:123example.456example.invalid"])
	})
	t.deepEqual(result.length, 4)
})

test("getViaServers: only considers power levels of currently joined members", async t => {
	const result = await getViaServers("!baby", {
		getEffectivePower: mockGetEffectivePower(["@_ooye_bot:cadence.moe", "@former_moderator:missing.invalid"], {
			"@moderator:tractor.invalid": 50
		}),
		getJoinedMembers: async () => joinedList(["@_ooye_bot:cadence.moe", "@_ooye_hazel:cadence.moe", "@cadence:cadence.moe", "@moderator:tractor.invalid", "@hazel:thecollective.invalid", "@june:thecollective.invalid", "@singleuser:selfhosted.invalid"])
	})
	t.deepEqual(result, ["cadence.moe", "tractor.invalid", "thecollective.invalid", "selfhosted.invalid"])
})

test("roomHasAtLeastVersion: v9 < v11", t => {
	t.equal(roomHasAtLeastVersion("9", 11), false)
})

test("roomHasAtLeastVersion: v12 >= v11", t => {
	t.equal(roomHasAtLeastVersion("12", 11), true)
})

test("roomHasAtLeastVersion: v12 >= v12", t => {
	t.equal(roomHasAtLeastVersion("12", 12), true)
})

test("roomHasAtLeastVersion: custom versions never match", t => {
	t.equal(roomHasAtLeastVersion("moe.cadence.silly", 11), false)
})

test("removeCreatorsFromPowerLevels: removes the creator from a v12 room", t => {
	t.deepEqual(removeCreatorsFromPowerLevels({
		type: "m.room.create",
		state_key: "",
		sender: "@_ooye_bot:cadence.moe",
		room_id: "!example",
		event_id: "$create",
		origin_server_ts: 0,
		content: {
			room_version: "12"
		}
	}, {
		users: {
			"@_ooye_bot:cadence.moe": 100
		}
	}), {
		users: {
		}
	})
})

test("removeCreatorsFromPowerLevels: removes all creators from a v12 room", t => {
	t.deepEqual(removeCreatorsFromPowerLevels({
		type: "m.room.create",
		state_key: "",
		sender: "@_ooye_bot:cadence.moe",
		room_id: "!example",
		event_id: "$create",
		origin_server_ts: 0,
		content: {
			additional_creators: ["@cadence:cadence.moe"],
			room_version: "12"
		}
	}, {
		users: {
			"@_ooye_bot:cadence.moe": 100,
			"@cadence:cadence.moe": 100
		}
	}), {
		users: {
		}
	})
})

test("removeCreatorsFromPowerLevels: doesn't touch a v11 room", t => {
	t.deepEqual(removeCreatorsFromPowerLevels({
		type: "m.room.create",
		state_key: "",
		sender: "@_ooye_bot:cadence.moe",
		room_id: "!example",
		event_id: "$create",
		origin_server_ts: 0,
		content: {
			additional_creators: ["@cadence:cadence.moe"],
			room_version: "11"
		}
	}, {
		users: {
			"@_ooye_bot:cadence.moe": 100,
			"@cadence:cadence.moe": 100
		}
	}), {
		users: {
			"@_ooye_bot:cadence.moe": 100,
			"@cadence:cadence.moe": 100
		}
	})
})

test("set user power: no-op", async t => {
	let called = 0
	await setUserPower("!room", "@cadence:cadence.moe", 0, {
		async getStateEvent(roomID, type, key) {
			called++
			t.equal(roomID, "!room")
			t.equal(type, "m.room.power_levels")
			t.equal(key, "")
			return {}
		},
		async getStateEventOuter(roomID, type, key) {
			called++
			t.equal(roomID, "!room")
			t.equal(type, "m.room.create")
			t.equal(key, "")
			return {
				type: "m.room.create",
				state_key: "",
				sender: "@_ooye_bot:cadence.moe",
				room_id: "!room",
				origin_server_ts: 0,
				event_id: "$create",
				content: {
					room_version: "11"
				}
			}
		},
		/* c8 ignore next 4 */
		async sendState() {
			called++
			throw new Error("should not try to send state")
		}
	})
	t.equal(called, 2)
})

test("set user power: bridge bot must promote unprivileged users", async t => {
	let called = 0
	await setUserPower("!room", "@cadence:cadence.moe", 100, {
		async getStateEvent(roomID, type, key) {
			called++
			t.equal(roomID, "!room")
			t.equal(type, "m.room.power_levels")
			t.equal(key, "")
			return {
				users: {"@_ooye_bot:cadence.moe": 100}
			}
		},
		async getStateEventOuter(roomID, type, key) {
			called++
			t.equal(roomID, "!room")
			t.equal(type, "m.room.create")
			t.equal(key, "")
			return {
				type: "m.room.create",
				state_key: "",
				sender: "@_ooye_bot:cadence.moe",
				room_id: "!room",
				origin_server_ts: 0,
				event_id: "$create",
				content: {
					room_version: "11"
				}
			}
		},
		async sendState(roomID, type, key, content, mxid) {
			called++
			t.equal(roomID, "!room")
			t.equal(type, "m.room.power_levels")
			t.equal(key, "")
			t.deepEqual(content, {
				users: {
					"@_ooye_bot:cadence.moe": 100,
					"@cadence:cadence.moe": 100
				}
			})
			t.equal(mxid, undefined)
			return "$sent"
		}
	})
	t.equal(called, 3)
})

test("set user power: privileged users must demote themselves", async t => {
	let called = 0
	await setUserPower("!room", "@cadence:cadence.moe", 0, {
		async getStateEvent(roomID, type, key) {
			called++
			t.equal(roomID, "!room")
			t.equal(type, "m.room.power_levels")
			t.equal(key, "")
			return {
				users: {
					"@cadence:cadence.moe": 100,
					"@_ooye_bot:cadence.moe": 100
				}
			}
		},
		async getStateEventOuter(roomID, type, key) {
			called++
			t.equal(roomID, "!room")
			t.equal(type, "m.room.create")
			t.equal(key, "")
			return {
				type: "m.room.create",
				state_key: "",
				sender: "@_ooye_bot:cadence.moe",
				room_id: "!room",
				origin_server_ts: 0,
				event_id: "$create",
				content: {
					room_version: "11"
				}
			}
		},
		async sendState(roomID, type, key, content, mxid) {
			called++
			t.equal(roomID, "!room")
			t.equal(type, "m.room.power_levels")
			t.equal(key, "")
			t.deepEqual(content, {
				users: {"@_ooye_bot:cadence.moe": 100}
			})
			t.equal(mxid, "@cadence:cadence.moe")
			return "$sent"
		}
	})
	t.equal(called, 3)
})

module.exports.mockGetEffectivePower = mockGetEffectivePower