nostr/blowater
1
0
Fork 0
mirror of https://github.com/BlowaterNostr/blowater.git synced 2024-10-18 07:33:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

+

Browse Source
This commit is contained in:
BlowaterNostr 2024-03-25 23:41:06 +08:00
parent f3a706c49c
commit c1d6ff9239
3 changed files with 9 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
app/UI/app.tsx
View File

@ -178,7 +178,6 @@ export class App {
ctx: args.ctx,
relayPool: args.pool,
});
console.log(relayConfig.getRelayURLs());
// init conversation list
const conversationLists = new DM_List(args.ctx);
@ -363,11 +362,7 @@ export class AppComponent extends Component<AppProps> {
return false;
}
const relays = app.database.getRelayRecord(e.id);
if (relays instanceof Promise) {
return false;
}
return relays.has(model.currentRelay);
return false;
},
),
(e) => {

2
app/UI/app_update.tsx
View File

@ -665,7 +665,7 @@ async function sync_user_detail_data(
if (msg.res.type == "EOSE") {
break;
} else if (msg.res.type == "EVENT") {
await args.database.addEvent(msg.res.event);
await args.database.addEvent(msg.res.event, msg.url);
}
}
await args.pool.closeSub(args.pubkey.bech32());

14
app/database.ts
View File

@ -155,10 +155,6 @@ export class Database_View implements ProfileSetter, ProfileGetter, EventRemover
await this.eventMarker.markEvent(id, "removed");
}
getRelayRecord(eventID: string) {
return this.relayRecorder.getRelayRecord(eventID);
}
getProfilesByText(name: string): Profile_Nostr_Event[] {
const result = [];
for (const event of this.profiles.values()) {
@ -274,6 +270,10 @@ export class Database_View implements ProfileSetter, ProfileGetter, EventRemover
return res;
}
getRelayRecord(eventID: string) {
return this.relayRecorder.getRelayRecord(eventID);
}
private async recordRelay(eventID: string, url: string) {
const records = this.relayRecorder.getRelayRecord(eventID);
if (records.has(url)) {
@ -304,6 +304,8 @@ export function parseProfileEvent(
};
}
const hash_func = 16;
const byte_size = 8 * 1024 * 16;
export class RelayRecorderBloomFilter implements RelayRecorder {
static FromLocalStorage() {
const str = localStorage.getItem(RelayRecorderBloomFilter.name);
@ -311,7 +313,7 @@ export class RelayRecorderBloomFilter implements RelayRecorder {
if (str) {
const filters_encoded = JSON.parse(str);
for (let key in filters_encoded) {
filters[key] = new BloomFilter(hexStringToInt32Array(filters_encoded[key]), 4);
filters[key] = new BloomFilter(hexStringToInt32Array(filters_encoded[key]), hash_func);
}
}
return new RelayRecorderBloomFilter(filters);
@ -325,7 +327,7 @@ export class RelayRecorderBloomFilter implements RelayRecorder {
const t = Date.now();
let filter = this.filters[url];
if (filter == undefined) {
filter = new BloomFilter(32 * 256, 4);
filter = new BloomFilter(byte_size, hash_func);
this.filters[url] = filter;
}