dbapis.ts

import { Appwrite } from "appwrite";
import { apiEndpoint, projectID, chatMessagesCollectionID } from "./config"

const sdk = new Appwrite()
sdk
    .setEndpoint(apiEndpoint)
    .setProject(projectID)

sdk.account.get().catch(() => {
    sdk.account.createAnonymousSession().catch(console.error)
})


export async function countMessagesInRoom(roomName) {
    const response = await sdk.database.listDocuments(
        chatMessagesCollectionID, [`roomName=${roomName}`]
    )
    return response.sum
}

export async function deleteRoom(roomName) {
    const filteredChatDataCollection =
        await sdk.database.listDocuments(
            chatMessagesCollectionID,
            [`roomName=${roomName}`]
        )

    // remove messages in room
    for (const doc of filteredChatDataCollection.documents) {
        sdk.database.deleteDocument(chatMessagesCollectionID, doc["$id"])
    }
}

export async function getMessagesByRoomName(roomName) {
    const response = await sdk.database.listDocuments(
        chatMessagesCollectionID,
        [`roomName=${roomName}`],
        100, // limit messages -- 100 is max allowed by server
        0, // offset value
        "timestamp", // order field
        "DESC", // descending order
    )
    return response.documents.reverse() // last 100 messages, in correct order
}


export async function sendMessage(roomName, message, sender) {
    return sdk.database.createDocument(chatMessagesCollectionID, {
        roomName: roomName,
        messageData: message,
        sender: sender,
        timestamp: Date.now()
    }, ["*"], ["*"])  // world-writable may not be optimal but it's convenient :P
}


export function onMessageListUpdated(roomName, callback) {
    sdk.subscribe(`documents`, response => {
        if (response.payload.roomName == roomName)
            callback(response.payload)
    })
}