Kieran/zap-stream-flutter
1
0
Fork 0
mirror of https://github.com/nostrlabs-io/zap-stream-flutter.git synced 2025-06-15 11:48:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: notify keys

Browse Source
This commit is contained in:
Kieran
2025-05-22 16:32:42 +01:00
parent 9a0811760c
commit 7838607cfc
3 changed files with 159 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

111
lib/notifications.dart
View File

@ -1,6 +1,9 @@
import 'dart:convert';
import 'dart:developer' as developer;
import 'dart:io';
import 'package:convert/convert.dart';
import 'package:crypto/crypto.dart';
import 'package:firebase_core/firebase_core.dart';
import 'package:firebase_messaging/firebase_messaging.dart';
import 'package:flutter_dotenv/flutter_dotenv.dart';
@ -19,10 +22,60 @@ class Notepush {
final pubkey = signer.getPublicKey();
final url =
"$base/user-info/$pubkey/${Uri.encodeComponent(token)}?backend=fcm";
developer.log(url);
final auth = await _makeAuth("PUT", url);
final rsp = await _sendPutRequest(url);
return rsp.body;
}
Future<List<String>> getWatchedKeys() async {
final pubkey = signer.getPublicKey();
final url = "$base/user-info/$pubkey/notify";
final rsp = await _sendGetRequest(url);
final List<dynamic> obj = JsonCodec().decode(rsp.body);
return List<String>.from(obj);
}
Future<void> watchPubkey(String target, List<int> kinds) async {
final pubkey = signer.getPublicKey();
final url = "$base/user-info/$pubkey/notify/$target";
await _sendPutRequest(url, body: {"kinds": kinds});
}
Future<void> removeWatchPubkey(String target) async {
final pubkey = signer.getPublicKey();
final url = "$base/user-info/$pubkey/notify/$target";
await _sendDeleteRequest(url);
}
Future<void> setNotificationSettings(String token, List<int> kinds) async {
final pubkey = signer.getPublicKey();
final url =
"$base/user-info/$pubkey/${Uri.encodeComponent(token)}/preference";
await _sendPutRequest(url, body: {"kinds": kinds});
}
Future<http.Response> _sendPutRequest(String url, {Object? body}) async {
final jsonBody = body != null ? JsonCodec().encode(body) : null;
final auth = await _makeAuth("PUT", url, body: jsonBody);
final rsp = await http
.put(
Uri.parse(url),
body: jsonBody,
headers: {
"authorization": "Nostr $auth",
"accept": "application/json",
"content-type": "application/json",
},
)
.timeout(Duration(seconds: 10));
developer.log(rsp.body);
return rsp;
}
Future<http.Response> _sendGetRequest(String url, {Object? body}) async {
final jsonBody = body != null ? JsonCodec().encode(body) : null;
final auth = await _makeAuth("GET", url, body: jsonBody);
final rsp = await http
.get(
Uri.parse(url),
headers: {
"authorization": "Nostr $auth",
@ -32,18 +85,40 @@ class Notepush {
)
.timeout(Duration(seconds: 10));
developer.log(rsp.body);
return rsp.body;
return rsp;
}
Future<String> _makeAuth(String method, String url) async {
Future<http.Response> _sendDeleteRequest(String url, {Object? body}) async {
final jsonBody = body != null ? JsonCodec().encode(body) : null;
final auth = await _makeAuth("DELETE", url, body: jsonBody);
final rsp = await http
.delete(
Uri.parse(url),
headers: {
"authorization": "Nostr $auth",
"accept": "application/json",
"content-type": "application/json",
},
)
.timeout(Duration(seconds: 10));
developer.log(rsp.body);
return rsp;
}
Future<String> _makeAuth(String method, String url, {String? body}) async {
final pubkey = signer.getPublicKey();
var tags = [
["u", url],
["method", method],
];
if (body != null) {
final hash = hex.encode(sha256.convert(utf8.encode(body)).bytes);
tags.add(["payload", hash]);
}
final authEvent = Nip01Event(
pubKey: pubkey,
kind: 27235,
tags: [
["u", url],
["method", "PUT"],
],
tags: tags,
content: "",
);
await signer.sign(authEvent);
@ -51,6 +126,13 @@ class Notepush {
}
}
Notepush? getNotificationService() {
final signer = ndk.accounts.getLoggedAccount()?.signer;
return signer != null
? Notepush(dotenv.env["NOTEPUSH_URL"]!, signer: signer)
: null;
}
Future<void> setupNotifications() async {
await Firebase.initializeApp();
@ -62,7 +144,7 @@ Future<void> setupNotifications() async {
developer.log(msg.notification?.body ?? "");
final notification = msg.notification;
if (notification != null && notification.android != null) {
/*FlutterLocalNotificationsPlugin().show(
FlutterLocalNotificationsPlugin().show(
notification.hashCode,
notification.title,
notification.body,
@ -72,8 +154,13 @@ Future<void> setupNotifications() async {
"fcm",
),
),
);*/
// TODO: foreground notification
);
}
});
FirebaseMessaging.onMessageOpenedApp.listen((msg) {
final notification = msg.notification;
if (notification != null) {
// TODO: redirect to stream
}
});
await fbase.setAutoInitEnabled(true);
@ -92,6 +179,7 @@ Future<void> setupNotifications() async {
fbase.onTokenRefresh.listen((token) async {
developer.log("NEW TOKEN: $token");
await pusher.register(token);
await pusher.setNotificationSettings(token, [30_311]);
});
if (Platform.isIOS) {
@ -105,5 +193,6 @@ Future<void> setupNotifications() async {
throw "Push token is null";
}
await pusher.register(fcmToken);
await pusher.setNotificationSettings(fcmToken, [30_311]);
}
}