campfire/src/api/mastodon.js

import { Client } from '../client/client.js';
import Post from '../post/post.js';
import User from '../user/user.js';
import Emoji from '../emoji.js';

export async function createApp(host) {
    let form = new FormData();
    form.append("client_name", "space social");
    form.append("redirect_uris", `${location.origin}/callback`);
    form.append("scopes", "read write push");
    form.append("website", "https://spacesocial.arimelody.me");

    const res = await fetch(`https://${host}/api/v1/apps`, {
        method: "POST",
        body: form,
    })
    .then(res => res.json())
    .catch(error => {
        console.error(error);
        return false;
    });

    if (!res || !res.client_id) return false;

    return {
        id: res.client_id,
        secret: res.client_secret,
    };
}

export function getOAuthUrl() {
    let client = Client.get();
    return `https://${client.instance.host}/oauth/authorize` +
        `?client_id=${client.app.id}` +
        "&scope=read+write+push" +
        `&redirect_uri=${location.origin}/callback` +
        "&response_type=code";
}

export async function getToken(code) {
    let client = Client.get();
    let form = new FormData();
    form.append("client_id", client.app.id);
    form.append("client_secret", client.app.secret);
    form.append("redirect_uri", `${location.origin}/callback`);
    form.append("grant_type", "authorization_code");
    form.append("code", code);
    form.append("scope", "read write push");

    const res = await fetch(`https://${client.instance.host}/oauth/token`, {
        method: "POST",
        body: form,
    })
    .then(res => res.json())
    .catch(error => {
        console.error(error);
        return false;
    });

    if (!res || !res.access_token) return false;

    return res.access_token;
}

export async function revokeToken() {
    let client = Client.get();
    let form = new FormData();
    form.append("client_id", client.app.id);
    form.append("client_secret", client.app.secret);
    form.append("token", client.app.token);

    const res = await fetch(`https://${client.instance.host}/oauth/revoke`, {
        method: "POST",
        body: form,
    })
    .catch(error => {
        console.error(error);
        return false;
    });

    if (!res.ok) return false;
    return true;
}

export async function getTimeline(last_post_id) {
    let client = Client.get();
    let url = `https://${client.instance.host}/api/v1/timelines/home`;
    if (last_post_id) url += "?max_id=" + last_post_id;
    const data = await fetch(url, {
        method: 'GET',
        headers: { "Authorization": "Bearer " + client.app.token }
    }).then(res => res.json());

    let posts = [];
    for (let i in data) {
        const post_data = data[i];
        const post = await client.api.parsePost(post_data, 1);
        if (!post) {
            if (post_data.id) {
                console.warn("Failed to parse post #" + post_data.id);
            } else {
                console.warn("Failed to parse post:");
                console.warn(post_data);
            }
            continue;
        }
        posts.push(post);
    }
    return posts;
}

export async function getPost(post_id, num_replies) {
    let client = Client.get();
    let url = `https://${client.instance.host}/api/v1/statuses/${post_id}`;
    const data = await fetch(url, {
        method: 'GET',
        headers: { "Authorization": "Bearer " + client.app.token }
    }).then(res => res.json());

    const post = await client.api.parsePost(data, num_replies);
    if (!post) {
        if (data.id) {
            console.warn("Failed to parse post data #" + data.id);
        } else {
            console.warn("Failed to parse post data:");
            console.warn(data);
        }
        return false;
    }
    return post;
}

export async function parsePost(data, num_replies) {
    let client = Client.get();
    let post = new Post()
    post.id = data.id;
    post.created_at = new Date(data.created_at);
    post.user = await Client.get().api.parseUser(data.account);
    post.text = data.content;
    post.warning = data.spoiler_text;
    post.boost_count = data.reblogs_count;
    post.reply_count = data.replies_count;
    post.mentions = data.mentions;
    post.reactions = data.reactions;
    post.files = data.media_attachments;
    post.url = data.url;
    post.reply = data.in_reply_to_id && num_replies > 0 ? await getPost(data.in_reply_to_id, num_replies - 1) : null;
    post.boost = data.reblog ? await parsePost(data.reblog, 1) : null;
    post.emojis = [];
    data.emojis.forEach(emoji_data => {
        let name = emoji_data.shortcode.split('@')[0];
        post.emojis.push(Client.get().api.parseEmoji({
            id: name + '@' + post.user.host,
            name: name,
            host: post.user.host,
            url: emoji_data.url,
        }));
    });
    post.reactions = [];
    data.reactions.forEach(reaction_data => {
        if (/^[\w\-.@]+$/g.exec(reaction_data.name)) {
            let name = reaction_data.name.split('@')[0];
            let host = reaction_data.name.includes('@') ? reaction_data.name.split('@')[1] : client.instance.host;
            post.reactions.push({
                count: reaction_data.count,
                emoji: Client.get().api.parseEmoji({
                    id: name + '@' + host,
                    name: name,
                    host: host,
                    url: reaction_data.url,
                }),
                me: reaction_data.me,
            });
        } else {
            if (reaction_data.name == '❤') reaction_data.name = '❤️'; // stupid heart unicode
            post.reactions.push({
                count: reaction_data.count,
                emoji: {
                    html: reaction_data.name,
                    name: reaction_data.name,
                },
                me: reaction_data.me,
            });
        }
    });
    return post;
}

export async function parseUser(data) {
    let user = new User();
    user.id = data.id;
    user.nickname = data.display_name;
    user.username = data.username;
    if (data.acct.includes('@'))
        user.host = data.acct.split('@')[1];
    else
        user.host = data.username + '@' + Client.get().instance.host;
    user.avatar_url = data.avatar;
    user.emojis = [];
    data.emojis.forEach(emoji_data => {
        emoji_data.id = emoji_data.shortcode + '@' + user.host;
        emoji_data.name = emoji_data.shortcode;
        emoji_data.host = user.host;
        user.emojis.push(Client.get().api.parseEmoji(emoji_data));
    });
    Client.get().putCacheUser(user);
    return user;
}

export function parseEmoji(data) {
    let emoji = new Emoji(
        data.id,
        data.name,
        data.host,
        data.url,
    );
    Client.get().putCacheEmoji(emoji);
    return emoji;
}

export async function getUser(user_id) {
    let client = Client.get();
    let url = `https://${client.instance.host}/api/v1/accounts/${user_id}`;
    const data = await fetch(url, {
        method: 'GET',
        headers: { "Authorization": "Bearer " + client.app.token }
    }).then(res => res.json());

    const user = await Client.get().api.parseUser(data);
    if (!post) {
        if (data.id) {
            console.warn("Failed to parse user data #" + data.id);
        } else {
            console.warn("Failed to parse user data:");
            console.warn(data);
        }
        return false;
    }
    return user;
}