tildefriends/apps/collections/app.js

88 lines
2.1 KiB
JavaScript
Raw Normal View History

import * as tfrpc from '/tfrpc.js';
let g_hash;
tfrpc.register(async function getIdentities() {
return ssb.getIdentities();
});
tfrpc.register(async function query(sql, args) {
let result = [];
await ssb.sqlAsync(sql, args, function callback(row) {
result.push(row);
});
return result;
});
tfrpc.register(async function localStorageGet(key) {
return app.localStorageGet(key);
});
tfrpc.register(async function localStorageSet(key, value) {
return app.localStorageSet(key, value);
});
tfrpc.register(async function following(ids, depth) {
return ssb.following(ids, depth);
});
tfrpc.register(async function appendMessage(id, message) {
return ssb.appendMessageWithIdentity(id, message);
});
tfrpc.register(async function store_blob(blob) {
if (Array.isArray(blob)) {
blob = Uint8Array.from(blob);
}
return await ssb.blobStore(blob);
});
tfrpc.register(async function get_blob(id) {
return utf8Decode(await ssb.blobGet(id));
});
ssb.addEventListener('message', async function(id) {
let message;
await ssb.sqlAsync('SELECT * FROM messages WHERE id = ?', [id], function(row) { message = row; });
await tfrpc.rpc.notify_new_message(message);
});
core.register('message', async function message_handler(message) {
if (message.event == 'hashChange') {
print('hash change');
g_hash = message.hash;
await tfrpc.rpc.hash_changed(message.hash);
}
});
tfrpc.register(function set_hash(hash) {
if (g_hash != hash) {
return app.setHash(hash);
}
});
tfrpc.register(function get_hash(id, message) {
return g_hash;
});
async function get_collections(kind) {
let me = await ssb.getIdentities();
let them = await ssb.following(me, 2);
let collections = {};
print('querying');
for (let row of await query(`
SELECT author, content, timestamp
FROM messages JOIN json_each(?) AS id ON messages.author = id.value
WHERE json_extract(content, '$.type') = 'collection' AND json_extract(content, '$.kind') = ?
`, [JSON.stringify(them), kind])) {
print(row);
}
print('done');
return collections;
}
async function main() {
await app.setDocument(utf8Decode(await getFile('index.html')));
}
main();