ouroboros-gorup/Mastodon-Circles
1
0
Fork 0
mirror of https://github.com/AMNatty/Mastodon-Circles.git synced 2024-11-13 14:47:24 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

Mastodon flavor detection

Browse source
This commit is contained in:
Natty 2023-09-01 19:40:14 +02:00
parent 618a256002
commit a4a32cdabf
No known key found for this signature in database
GPG key ID: BF6CB659ADEE60EC
1 changed files with 99 additions and 50 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

149
create-circle.js
View file

@ -168,7 +168,7 @@ class ApiClient {
let nodeInfo = await apiRequest(url); let nodeInfo = await apiRequest(url);
if (!nodeInfo || !Array.isArray(nodeInfo.links)) { if (!nodeInfo || !Array.isArray(nodeInfo.links)) {
const client = new MastodonApiClient(instance); const client = new MastodonApiClient(instance, true);
instanceTypeCache.set(instance, client); instanceTypeCache.set(instance, client);
return client; return client;
} }
@ -182,7 +182,7 @@ class ApiClient {
if (!apiLink) { if (!apiLink) {
console.error(`No NodeInfo API found for ${instance}}`); console.error(`No NodeInfo API found for ${instance}}`);
const client = new MastodonApiClient(instance); const client = new MastodonApiClient(instance, true);
instanceTypeCache.set(instance, client); instanceTypeCache.set(instance, client);
return client; return client;
} }
@ -205,7 +205,7 @@ class ApiClient {
return client; return client;
} }
const client = new MastodonApiClient(instance); const client = new MastodonApiClient(instance, true);
instanceTypeCache.set(instance, client); instanceTypeCache.set(instance, client);
return client; return client;
} }
@ -237,7 +237,7 @@ class ApiClient {
return client; return client;
} }
const client = new MastodonApiClient(instance); const client = new MastodonApiClient(instance, true);
instanceTypeCache.set(instance, client); instanceTypeCache.set(instance, client);
return client; return client;
} }
@ -272,11 +272,50 @@ class ApiClient {
/** /**
* @param {Note} note * @param {Note} note
* @param {boolean} extra_reacts
* *
* return {Promise<FediUser[] | null>} * return {Promise<FediUser[] | null>}
*/ */
async getFavs(note, extra_reacts) { throw new Error("Not implemented"); } async getReactions(note){ return []; }
/**
* @param {Note} note
*
* @returns {Promise<FediUser[] | null>}
*/
async getFavs(note) { throw new Error("Not implemented"); }
/**
* @param {Note} note
* @param {boolean} extra_reacts Also include emoji reacts
*
* return {Promise<FediUser[] | null>}
*/
async getConsolidatedReactions(note, extra_reacts = false){
let favs = await this.getFavs(note);
if (!extra_reacts)
return favs;
/**
* @type {Map<string, FediUser>}
*/
let users = new Map();
if (favs !== null) {
favs.forEach(u => {
users.set(u.id, u);
});
}
const reactions = await this.getReactions(note);
if (reactions !== null) {
reactions.forEach(u => {
users.set(u.id, u);
});
}
return Array.from(users.values());
}
/** /**
* @return string * @return string
@ -287,9 +326,13 @@ class ApiClient {
class MastodonApiClient extends ApiClient { class MastodonApiClient extends ApiClient {
/** /**
* @param {string} instance * @param {string} instance
* @param {boolean} emoji_reacts
* @param {MastodonApiClient} flavor
*/ */
constructor(instance) { constructor(instance, emoji_reacts, flavor = MastodonFlavor.MASTODON) {
super(instance); super(instance);
this._emoji_reacts = emoji_reacts;
this._flavor = flavor;
} }
async getUserIdFromHandle(handle) { async getUserIdFromHandle(handle) {
@ -322,12 +365,17 @@ class MastodonApiClient extends ApiClient {
return null; return null;
} }
if (response?.some(note => note?.["emoji_reactions"]?.length)) {
this._flavor = MastodonFlavor.FEDIBIRD;
} else if (response?.some(note => note?.["pleroma"]?.["emoji_reactions"]?.length)) {
this._flavor = MastodonFlavor.PLEROMA;
}
return response.map(note => ({ return response.map(note => ({
id: note.id, id: note.id,
replies: note["replies_count"] || 0, replies: note["replies_count"] || 0,
renotes: note["reblogs_count"] || 0, renotes: note["reblogs_count"] || 0,
favorites: note["favourites_count"], favorites: note["favourites_count"],
// Actually a Pleroma/Akkoma thing
extra_reacts: note?.["emoji_reactions"]?.length > 0 || note?.["pleroma"]?.["emoji_reactions"]?.length > 0, extra_reacts: note?.["emoji_reactions"]?.length > 0 || note?.["pleroma"]?.["emoji_reactions"]?.length > 0,
instance: this._instance, instance: this._instance,
author: user author: user
@ -359,7 +407,14 @@ class MastodonApiClient extends ApiClient {
return null; return null;
} }
if (response["descendants"]?.some(note => note?.["emoji_reactions"]?.length)) {
this._flavor = MastodonFlavor.FEDIBIRD;
} else if (response["descendants"]?.some(note => note?.["pleroma"]?.["emoji_reactions"]?.length)) {
this._flavor = MastodonFlavor.PLEROMA;
}
return response["descendants"].map(note => { return response["descendants"].map(note => {
let handle = parseHandle(note["account"]["acct"], noteIn.instance); let handle = parseHandle(note["account"]["acct"], noteIn.instance);
return { return {
@ -367,7 +422,6 @@ class MastodonApiClient extends ApiClient {
replies: note["replies_count"] || 0, replies: note["replies_count"] || 0,
renotes: note["reblogs_count"] || 0, renotes: note["reblogs_count"] || 0,
favorites: note["favourites_count"], favorites: note["favourites_count"],
// Actually a Pleroma/Akkoma thing
extra_reacts: note?.["emoji_reactions"]?.length > 0 || note?.["pleroma"]?.["emoji_reactions"]?.length > 0, extra_reacts: note?.["emoji_reactions"]?.length > 0 || note?.["pleroma"]?.["emoji_reactions"]?.length > 0,
instance: handle.instance, instance: handle.instance,
author: { author: {
@ -381,7 +435,7 @@ class MastodonApiClient extends ApiClient {
}); });
} }
async getFavs(note, extra_reacts) { async getFavs(note) {
const url = `https://${this._instance}/api/v1/statuses/${note.id}/favourited_by`; const url = `https://${this._instance}/api/v1/statuses/${note.id}/favourited_by`;
const response = await apiRequest(url); const response = await apiRequest(url);
@ -398,6 +452,14 @@ class MastodonApiClient extends ApiClient {
})); }));
} }
async getReactions(note) {
if (this._flavor === MastodonFlavor.MASTODON) {
return [];
}
return this._flavor.getReactions.call(this, note);
}
getClientName() { getClientName() {
return "mastodon"; return "mastodon";
} }
@ -409,31 +471,20 @@ class PleromaApiClient extends MastodonApiClient {
* @param {boolean} emoji_reacts * @param {boolean} emoji_reacts
*/ */
constructor(instance, emoji_reacts) { constructor(instance, emoji_reacts) {
super(instance); super(instance, emoji_reacts, MastodonFlavor.PLEROMA);
this._emoji_reacts = emoji_reacts;
} }
async getFavs(note, extra_reacts) { async getReactions(note) {
// Pleroma/Akkoma supports both favs and emoji reacts if (!this._emoji_reacts)
// with several emoji reacts per users being possible. return [];
// Coalesce them and count every user only once
let favs = await super.getFavs(note);
if (!this._emoji_reacts || !extra_reacts) const url = `https://${this._instance}/api/v1/pleroma/statuses/${note.id}/reactions`;
return favs; const response = await apiRequest(url) ?? [];
/** /**
* @type {Map<string, FediUser>} * @type {Map<string, FediUser>}
*/ */
let users = new Map(); const users = new Map();
if (favs !== null) {
favs.forEach(u => {
users.set(u.id, u);
});
}
const url = `https://${this._instance}/api/v1/pleroma/statuses/${note.id}/reactions`;
const response = await apiRequest(url) ?? [];
for (const reaction of response) { for (const reaction of response) {
reaction["accounts"] reaction["accounts"]
@ -464,28 +515,17 @@ class FedibirdApiClient extends MastodonApiClient {
* @param {boolean} emoji_reacts * @param {boolean} emoji_reacts
*/ */
constructor(instance, emoji_reacts) { constructor(instance, emoji_reacts) {
super(instance); super(instance, emoji_reacts, MastodonFlavor.FEDIBIRD);
this._emoji_reacts = emoji_reacts;
} }
async getFavs(note, extra_reacts) { async getReactions(note) {
// Frdibird supports both favs and emoji reacts if (!this._emoji_reacts)
// with several emoji reacts per users being possible. return [];
// Coalesce them and count every user only once
let favs = await super.getFavs(note);
if (!this._emoji_reacts || !extra_reacts)
return favs;
/** /**
* @type {Map<string, FediUser>} * @type {Map<string, FediUser>}
*/ */
let users = new Map(); let users = new Map();
if (favs !== null) {
favs.forEach(u => {
users.set(u.id, u);
});
}
const url = `https://${this._instance}/api/v1/statuses/${note.id}/emoji_reactioned_by`; const url = `https://${this._instance}/api/v1/statuses/${note.id}/emoji_reactioned_by`;
const response = await apiRequest(url) ?? []; const response = await apiRequest(url) ?? [];
@ -512,6 +552,12 @@ class FedibirdApiClient extends MastodonApiClient {
} }
} }
const MastodonFlavor = {
MASTODON: MastodonApiClient.prototype,
PLEROMA: PleromaApiClient.prototype,
FEDIBIRD: FedibirdApiClient.prototype,
};
class MisskeyApiClient extends ApiClient { class MisskeyApiClient extends ApiClient {
/** /**
* @param {string} instance * @param {string} instance
@ -665,7 +711,7 @@ class MisskeyApiClient extends ApiClient {
}); });
} }
async getFavs(note, extra_reacts) { async getFavs(note) {
const url = `https://${this._instance}/api/notes/reactions`; const url = `https://${this._instance}/api/notes/reactions`;
const response = await apiRequest(url, { const response = await apiRequest(url, {
method: "POST", method: "POST",
@ -736,7 +782,7 @@ async function circleMain() {
let client; let client;
switch (backend.value) { switch (backend.value) {
case "mastodon": case "mastodon":
client = new MastodonApiClient(selfUser.apiInstance); client = new MastodonApiClient(selfUser.apiInstance, true);
break; break;
case "pleroma": case "pleroma":
client = new PleromaApiClient(selfUser.apiInstance, true); client = new PleromaApiClient(selfUser.apiInstance, true);
@ -744,13 +790,16 @@ async function circleMain() {
case "misskey": case "misskey":
client = new MisskeyApiClient(selfUser.apiInstance); client = new MisskeyApiClient(selfUser.apiInstance);
break; break;
case "fedibird":
client = new FedibirdApiClient(selfUser.instance, true);
break;
default: default:
progress.innerText = "Detecting instance..."; progress.innerText = "Detecting instance...";
client = await ApiClient.getClient(selfUser.apiInstance); client = await ApiClient.getClient(selfUser.apiInstance);
backend.value = client.getClientName();
backend.value = (() => {
switch (client.getClientName()) {
case "fedibird": return "mastodon";
default: return client.getClientName();
}
})();
break; break;
} }
@ -812,7 +861,7 @@ async function processNotes(client, connectionList, notes) {
*/ */
async function evaluateNote(client, connectionList, note) { async function evaluateNote(client, connectionList, note) {
if (note.favorites > 0 || note.extra_reacts) { if (note.favorites > 0 || note.extra_reacts) {
await client.getFavs(note, note.extra_reacts).then(users => { await client.getConsolidatedReactions(note, note.extra_reacts).then(users => {
if (!users) if (!users)
return; return;