tasiaiso/tildefriends
1
0
Fork 0
forked from cory/tildefriends
Code Issues Pull Requests Releases Wiki Activity

A few minor things. Fixed missing fields from app messages. Fixed some missing messages. Removed unnecessary asyncs.

Browse Source 
git-svn-id: https://www.unprompted.com/svn/projects/tildefriends/trunk@3637 ed5197a5-7fde-0310-b194-c3ffbd925b24
This commit is contained in:
Cory McWilliams
2021-01-12 02:23:57 +00:00
parent 7012418b13
commit 92c06b34a9
3 changed files with 66 additions and 60 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
apps/cory/index/app.js
View File

@@ -5,7 +5,7 @@ const k_votes_max = 100;
async function following(db, id) {
var o = await db.get(id + ":following");
const k_version = 4;
const k_version = 5;
var f = o ? JSON.parse(o) : o;
if (!f || f.version != k_version) {
f = {users: [], sequence: 0, version: k_version};
@@ -24,7 +24,7 @@ async function following(db, id) {
"UNION SELECT MAX(sequence) AS sequence, NULL, NULL FROM messages WHERE author = ?1 "+
"ORDER BY sequence",
[id, f.sequence],
async function(row) {
function(row) {
if (row.following) {
f.users.add(row.contact);
} else {
@@ -53,7 +53,7 @@ async function followingDeep(db, seed_ids, depth) {
async function followers(db, id) {
var o = await db.get(id + ":followers");
const k_version = 2;
const k_version = 3;
var f = o ? JSON.parse(o) : o;
if (!f || f.version != k_version) {
f = {users: [], rowid: 0, version: k_version};
@@ -72,7 +72,7 @@ async function followers(db, id) {
"UNION SELECT MAX(rowid) as rowid, NULL, NULL FROM messages "+
"ORDER BY rowid",
[f.rowid, id],
async function(row) {
function(row) {
if (row.following) {
f.users.add(row.contact);
} else {
@@ -101,7 +101,7 @@ async function sendUser(db, id) {
async function pubsByUser(db, id) {
var o = await db.get(id + ":pubs");
const k_version = 2;
const k_version = 3;
var f = o ? JSON.parse(o) : o;
if (!f || f.version != k_version) {
f = {pubs: [], sequence: 0, version: k_version};
@@ -121,7 +121,7 @@ async function pubsByUser(db, id) {
"UNION SELECT MAX(sequence) as sequence, NULL, NULL, NULL FROM messages WHERE author = ?2 "+
"ORDER BY sequence",
[f.sequence, id],
async function(row) {
function(row) {
f.sequence = row.sequence;
if (row.host) {
row = {host: row.host, port: row.port, key: row.key};
@@ -237,7 +237,7 @@ async function getRecentPostIds(db, id, ids, limit) {
async function getVotes(db, id) {
var o = await db.get(id + ":votes");
const k_version = 2;
const k_version = 3;
var votes = [];
var f = o ? JSON.parse(o) : o;
if (!f || f.version != k_version) {
@@ -259,7 +259,7 @@ async function getVotes(db, id) {
"UNION SELECT MAX(rowid) as rowid, NULL, NULL AS id, NULL, NULL, NULL FROM messages "+
"ORDER BY rowid DESC LIMIT ?",
[f.rowid, id, k_votes_max],
async function(row) {
function(row) {
if (row.id) {
votes.push(row);
} else {
@@ -363,6 +363,7 @@ core.register('message', async function(m) {
app = JSON.parse(utf8Decode(app));
app.type = 'tildefriends-app';
app.name = m.message.share_app.name;
app.text = m.message.share_app.text;
await ssb.appendMessage(app);
} else if (m.message.user) {
await sendUser(await database("ssb"), m.message.user);