import create from "@/services/note/create.js";
import { Users } from "@/models/index.js";
import type { DbUserImportMastoPostJobData } from "@/queue/types.js";
import { queueLogger } from "../../logger.js";
import type Bull from "bull";
import { htmlToMfm } from "@/remote/activitypub/misc/html-to-mfm.js";
import { resolveNote } from "@/remote/activitypub/models/note.js";
import { Note } from "@/models/entities/note.js";

const logger = queueLogger.createSubLogger("import-masto-post");

export async function importMastoPost(
	job: Bull.Job<DbUserImportMastoPostJobData>,
	done: any,
): Promise<void> {
	const user = await Users.findOneBy({ id: job.data.user.id });
	if (user == null) {
		done();
		return;
	}
	const post = job.data.post;
	let reply: Note | null = null;
	if (post.object.inReplyTo != null) {
		reply = await resolveNote(post.object.inReplyTo);
	}
	if (post.directMessage) {
    done();
		return;
	}
	if (job.data.signatureCheck) {
		if (!post.signature) {
       done();
			return;
		}
	}
	let text;
	try {
		text = htmlToMfm(post.object.content, post.object.tag);
	} catch (e) {
    done();
		return;
	}

	const note = await create(user, {
		createdAt: new Date(post.object.published),
		files: undefined,
		poll: undefined,
		text: text || undefined,
		reply,
		renote: null,
		cw: post.sensitive,
		localOnly: false,
		visibility: "hidden",
		visibleUsers: [],
		channel: null,
		apMentions: new Array(0),
		apHashtags: undefined,
		apEmojis: undefined,
	});
	logger.succ("Imported");
	done();
}