campfire/src/lib/client/client.js

import { Instance, server_types } from './instance.js';
import * as api from './api.js';
import { get, writable } from 'svelte/store';
import { last_read_notif_id } from '$lib/notifications.js';
import { user, logged_in } from '$lib/stores/user.js';

export const client = writable(false);

const save_name = "campfire";

export class Client {
    instance;
    app;
    user;
    #cache;

    constructor() {
        this.instance = null;
        this.app = null;
        this.user = null;
        this.cache = {
            users: {},
            emojis: {},
        };
    }

    async init(host) {
        if (host.startsWith("https://")) host = host.substring(8);
        const url = `https://${host}/api/v1/instance`;
        const data = await fetch(url).then(res => res.json()).catch(error => { console.error(error) });
        if (!data) {
            console.error(`Failed to connect to ${host}`);
            return `Failed to connect to ${host}!`;
        }
        
        this.instance = new Instance(host, data.version);
        if (this.instance.type == server_types.UNSUPPORTED) {
            console.warn(`Server ${host} is unsupported - ${data.version}`);
            if (!confirm(
                `This app does not officially support ${host}. ` +
                `Things may break, or otherwise not work as epxected! ` +
                `Are you sure you wish to continue?`
            )) return false;
        } else {
            console.log(`Server is "${this.instance.type}" (or compatible) with capabilities: [${this.instance.capabilities}].`);
        }

        this.app = await api.createApp(host);

        if (!this.app || !this.instance) {
            console.error("Failed to create app. Check the network logs for details.");
            return false;
        }

        this.save();

        client.set(this);

        return true;
    }

    getOAuthUrl() {
        return api.getOAuthUrl(this.app.secret);
    }

    async getToken(code) {
        const token = await api.getToken(code);
        if (!token) {
            console.error("Failed to obtain access token");
            return false;
        }
        return token;
    }

    async revokeToken() {
        return await api.revokeToken();
    }

    async getClientUser() {
        // already known
        if (this.user) return this.user;

        // cannot provide- not logged in
        if (!this.app || !this.app.token) {
            return false;
        }

        // logged in- attempt to retrieve using token
        const data = await api.verifyCredentials();
        if (!data) {
            return false;
        }
        const user = await api.parseUser(data);
        console.log(`Logged in as @${user.username}@${user.host}`);
        return user;
    }

    async getNotifications(since_id, limit, types) {
        return await api.getNotifications(since_id, limit, types);
    }

    async getTimeline(last_post_id) {
        return await api.getTimeline(last_post_id);
    }

    async getPost(post_id, parent_replies, child_replies) {
        return await api.getPost(post_id, parent_replies, child_replies);
    }

    async getPostContext(post_id) {
        return await api.getPostContext(post_id);
    }

    async boostPost(post_id) {
        return await api.boostPost(post_id);
    }

    async unboostPost(post_id) {
        return await api.unboostPost(post_id);
    }

    async favouritePost(post_id) {
        return await api.favouritePost(post_id);
    }

    async unfavouritePost(post_id) {
        return await api.unfavouritePost(post_id);
    }

    async reactPost(post_id, shortcode) {
        return await api.reactPost(post_id, shortcode);
    }

    async unreactPost(post_id, shortcode) {
        return await api.unreactPost(post_id, shortcode);
    }

    putCacheUser(user) {
        this.cache.users[user.id] = user;
        client.set(this);
    }

    async getCacheUser(user_id) {
        let user = this.cache.users[user_id];
        if (user) return user;

        return false;
    }

    async getUserByMention(mention) {
        let users = Object.values(this.cache.users);
        for (let i in users) {
            const user = users[i];
            if (user.mention == mention) return user;
        }
        return false;
    }

    putCacheEmoji(emoji) {
        this.cache.emojis[emoji.id] = emoji;
        client.set(this);
    }

    getEmoji(emoji_id) {
        let emoji = this.cache.emojis[emoji_id];
        if (!emoji) return false;
        return emoji;
    }

    async getUser(user_id) {
        return await api.getUser(user_id);
    }

    save() {
        if (typeof localStorage === typeof undefined) return;
        localStorage.setItem(save_name, JSON.stringify({
            version: APP_VERSION,
            instance: {
                host: this.instance.host,
                version: this.instance.version,
            },
            last_read_notif_id: get(last_read_notif_id),
            app: this.app,
        }));
    }

    load() {
        if (typeof localStorage === typeof undefined) return;
        let json = localStorage.getItem(save_name);
        if (!json) return false;
        let saved = JSON.parse(json);
        if (!saved.version || saved.version !== APP_VERSION) {
            localStorage.removeItem(save_name);
            return false;
        }
        this.instance = new Instance(saved.instance.host, saved.instance.version);
        last_read_notif_id.set(saved.last_read_notif_id || 0);
        this.app = saved.app;
        client.set(this);
        return true;
    }

    async logout() {
        if (!this.instance || !this.app) return;
        if (!await this.revokeToken()) {
            console.warn("Failed to log out correctly; ditching the old tokens anyways.");
        }
        localStorage.removeItem(save_name);
        logged_in.set(false);
        client.set(new Client());
        console.log("Logged out successfully.");
    }
}