Compare commits
13 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
55dc937385
|
|||
|
e98a804efc
|
|||
|
1f9abb8574
|
|||
|
9352ff5c2c
|
|||
|
1dafab8f5c
|
|||
|
b5e098a694
|
|||
|
08fd34632a
|
|||
|
a7a2474e2a
|
|||
|
e15d70dd0e
|
|||
|
e98882a0c6
|
|||
|
24bf7cd434
|
|||
|
54c4f873fc
|
|||
|
b2de793758
|
@@ -205,7 +205,7 @@ class APIClient {
|
|||||||
fn: User.fromJson,
|
fn: User.fromJson,
|
||||||
authToken: auth.getToken(),
|
authToken: auth.getToken(),
|
||||||
query: {
|
query: {
|
||||||
'confirm': ['true']
|
'confirm': ['true'],
|
||||||
},
|
},
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
@@ -230,7 +230,7 @@ class APIClient {
|
|||||||
static Future<Client> updateClient(TokenSource auth, String clientID, {String? fcmToken, String? agentModel, String? name, String? agentVersion}) async {
|
static Future<Client> updateClient(TokenSource auth, String clientID, {String? fcmToken, String? agentModel, String? name, String? agentVersion}) async {
|
||||||
return await _request(
|
return await _request(
|
||||||
name: 'updateClient',
|
name: 'updateClient',
|
||||||
method: 'PUT',
|
method: 'PATCH',
|
||||||
relURL: 'users/${auth.getUserID()}/clients/$clientID',
|
relURL: 'users/${auth.getUserID()}/clients/$clientID',
|
||||||
jsonBody: {
|
jsonBody: {
|
||||||
if (fcmToken != null) 'fcm_token': fcmToken,
|
if (fcmToken != null) 'fcm_token': fcmToken,
|
||||||
@@ -259,7 +259,7 @@ class APIClient {
|
|||||||
method: 'GET',
|
method: 'GET',
|
||||||
relURL: 'users/${auth.getUserID()}/channels',
|
relURL: 'users/${auth.getUserID()}/channels',
|
||||||
query: {
|
query: {
|
||||||
'selector': [sel.apiKey]
|
'selector': [sel.apiKey],
|
||||||
},
|
},
|
||||||
fn: (json) => ChannelWithSubscription.fromJsonArray(json['channels'] as List<dynamic>),
|
fn: (json) => ChannelWithSubscription.fromJsonArray(json['channels'] as List<dynamic>),
|
||||||
authToken: auth.getToken(),
|
authToken: auth.getToken(),
|
||||||
|
|||||||
+31
-9
@@ -6,6 +6,7 @@ import 'package:flutter/material.dart';
|
|||||||
import 'package:flutter_local_notifications/flutter_local_notifications.dart';
|
import 'package:flutter_local_notifications/flutter_local_notifications.dart';
|
||||||
import 'package:in_app_purchase/in_app_purchase.dart';
|
import 'package:in_app_purchase/in_app_purchase.dart';
|
||||||
import 'package:provider/provider.dart';
|
import 'package:provider/provider.dart';
|
||||||
|
import 'package:simplecloudnotifier/api/api_client.dart';
|
||||||
import 'package:simplecloudnotifier/main_messaging.dart';
|
import 'package:simplecloudnotifier/main_messaging.dart';
|
||||||
import 'package:simplecloudnotifier/main_utils.dart';
|
import 'package:simplecloudnotifier/main_utils.dart';
|
||||||
import 'package:simplecloudnotifier/components/layout/nav_layout.dart';
|
import 'package:simplecloudnotifier/components/layout/nav_layout.dart';
|
||||||
@@ -68,15 +69,17 @@ void main() async {
|
|||||||
print('[INIT] Request Notification permissions...');
|
print('[INIT] Request Notification permissions...');
|
||||||
await FirebaseMessaging.instance.requestPermission(provisional: true);
|
await FirebaseMessaging.instance.requestPermission(provisional: true);
|
||||||
|
|
||||||
FirebaseMessaging.instance.onTokenRefresh.listen((fcmToken) {
|
FirebaseMessaging.instance.onTokenRefresh
|
||||||
try {
|
.listen((fcmToken) {
|
||||||
setFirebaseToken(fcmToken);
|
try {
|
||||||
} catch (exc, trace) {
|
setFirebaseToken(fcmToken);
|
||||||
ApplicationLog.error('Failed to set firebase token: ' + exc.toString(), trace: trace);
|
} catch (exc, trace) {
|
||||||
}
|
ApplicationLog.error('Failed to set firebase token: ' + exc.toString(), trace: trace);
|
||||||
}).onError((dynamic err) {
|
}
|
||||||
ApplicationLog.error('Failed to listen to token refresh events: ' + (err?.toString() ?? ''));
|
})
|
||||||
});
|
.onError((dynamic err) {
|
||||||
|
ApplicationLog.error('Failed to listen to token refresh events: ' + (err?.toString() ?? ''));
|
||||||
|
});
|
||||||
|
|
||||||
try {
|
try {
|
||||||
print('[INIT] Query firebase token...');
|
print('[INIT] Query firebase token...');
|
||||||
@@ -96,6 +99,25 @@ void main() async {
|
|||||||
|
|
||||||
await appAuth.tryMigrateFromV1();
|
await appAuth.tryMigrateFromV1();
|
||||||
|
|
||||||
|
if (appAuth.isAuth()) {
|
||||||
|
print('[INIT] Load Client and potentially update...');
|
||||||
|
|
||||||
|
try {
|
||||||
|
var client = await appAuth.loadClient(onlyCached: true);
|
||||||
|
if (client != null) {
|
||||||
|
if (client.agentModel != Globals().deviceModel || client.name != Globals().nameForClient() || client.agentVersion != Globals().version) {
|
||||||
|
print('[INIT] Update Client info...');
|
||||||
|
|
||||||
|
final newClient = await APIClient.updateClient(appAuth, client.clientID, agentModel: Globals().deviceModel, name: Globals().nameForClient(), agentVersion: Globals().version);
|
||||||
|
appAuth.setClientAndClientID(newClient);
|
||||||
|
await appAuth.save();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} catch (exc, trace) {
|
||||||
|
ApplicationLog.error('Failed to get client (on init): ' + exc.toString(), trace: trace);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
print('[INIT] Load Notifications...');
|
print('[INIT] Load Notifications...');
|
||||||
|
|
||||||
final flutterLocalNotificationsPlugin = FlutterLocalNotificationsPlugin();
|
final flutterLocalNotificationsPlugin = FlutterLocalNotificationsPlugin();
|
||||||
|
|||||||
@@ -40,11 +40,11 @@ void setFirebaseToken(String fcmToken) async {
|
|||||||
|
|
||||||
if (client == null) {
|
if (client == null) {
|
||||||
// should not really happen - perhaps someone externally deleted the client?
|
// should not really happen - perhaps someone externally deleted the client?
|
||||||
final newClient = await APIClient.addClient(acc, fcmToken, Globals().deviceModel, Globals().version, Globals().hostname, Globals().clientType);
|
final newClient = await APIClient.addClient(acc, fcmToken, Globals().deviceModel, Globals().version, Globals().nameForClient(), Globals().clientType);
|
||||||
acc.setClientAndClientID(newClient);
|
acc.setClientAndClientID(newClient);
|
||||||
await acc.save();
|
await acc.save();
|
||||||
} else {
|
} else {
|
||||||
final newClient = await APIClient.updateClient(acc, client.clientID, fcmToken: fcmToken, agentModel: Globals().deviceModel, name: Globals().hostname, agentVersion: Globals().version);
|
final newClient = await APIClient.updateClient(acc, client.clientID, fcmToken: fcmToken, agentModel: Globals().deviceModel, name: Globals().nameForClient(), agentVersion: Globals().version);
|
||||||
acc.setClientAndClientID(newClient);
|
acc.setClientAndClientID(newClient);
|
||||||
await acc.save();
|
await acc.save();
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -527,7 +527,7 @@ class _AccountRootPageState extends State<AccountRootPage> {
|
|||||||
|
|
||||||
await Globals().setPrefFCMToken(fcmToken);
|
await Globals().setPrefFCMToken(fcmToken);
|
||||||
|
|
||||||
final user = await APIClient.createUserWithClient(null, fcmToken, Globals().platform, Globals().version, Globals().hostname, Globals().clientType);
|
final user = await APIClient.createUserWithClient(null, fcmToken, Globals().platform, Globals().version, Globals().nameForClient(), Globals().clientType);
|
||||||
|
|
||||||
acc.set(user.user, user.clients[0], user.adminKey, user.sendKey);
|
acc.set(user.user, user.clients[0], user.adminKey, user.sendKey);
|
||||||
|
|
||||||
|
|||||||
@@ -156,7 +156,7 @@ class _AccountLoginPageState extends State<AccountLoginPage> {
|
|||||||
|
|
||||||
final user = await APIClient.getUser(DirectTokenSource(uid, atokv), uid);
|
final user = await APIClient.getUser(DirectTokenSource(uid, atokv), uid);
|
||||||
|
|
||||||
final client = await APIClient.addClient(DirectTokenSource(uid, atokv), fcmToken, Globals().deviceModel, Globals().version, Globals().hostname, Globals().clientType);
|
final client = await APIClient.addClient(DirectTokenSource(uid, atokv), fcmToken, Globals().deviceModel, Globals().version, Globals().nameForClient(), Globals().clientType);
|
||||||
|
|
||||||
acc.set(user, client, atokv, stokv);
|
acc.set(user, client, atokv, stokv);
|
||||||
await acc.save();
|
await acc.save();
|
||||||
|
|||||||
@@ -12,6 +12,7 @@ import 'package:simplecloudnotifier/state/app_auth.dart';
|
|||||||
import 'package:simplecloudnotifier/state/application_log.dart';
|
import 'package:simplecloudnotifier/state/application_log.dart';
|
||||||
import 'package:simplecloudnotifier/utils/navi.dart';
|
import 'package:simplecloudnotifier/utils/navi.dart';
|
||||||
import 'package:simplecloudnotifier/utils/toaster.dart';
|
import 'package:simplecloudnotifier/utils/toaster.dart';
|
||||||
|
import 'package:simplecloudnotifier/utils/dialogs.dart';
|
||||||
import 'package:simplecloudnotifier/utils/ui.dart';
|
import 'package:simplecloudnotifier/utils/ui.dart';
|
||||||
|
|
||||||
class ChannelScannerResultChannelSubscribe extends StatefulWidget {
|
class ChannelScannerResultChannelSubscribe extends StatefulWidget {
|
||||||
@@ -172,6 +173,38 @@ class _ChannelScannerResultChannelSubscribeState extends State<ChannelScannerRes
|
|||||||
|
|
||||||
void _onSubscribe() async {
|
void _onSubscribe() async {
|
||||||
final auth = Provider.of<AppAuth>(context, listen: false);
|
final auth = Provider.of<AppAuth>(context, listen: false);
|
||||||
|
|
||||||
|
// Check if username is set
|
||||||
|
try {
|
||||||
|
final user = await auth.loadUser();
|
||||||
|
if (user.username == null || user.username!.isEmpty) {
|
||||||
|
// Show modal to set username
|
||||||
|
var newusername = await UIDialogs.showUsernameRequiredDialog(context);
|
||||||
|
|
||||||
|
if (newusername == null) return; // User cancelled
|
||||||
|
|
||||||
|
newusername = newusername.trim();
|
||||||
|
if (newusername.isEmpty) {
|
||||||
|
Toaster.error("Error", 'Username cannot be empty');
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Update username via API
|
||||||
|
try {
|
||||||
|
await APIClient.updateUser(auth, auth.userID!, username: newusername);
|
||||||
|
await auth.loadUser(force: true); // Refresh cached user
|
||||||
|
Toaster.success("Success", 'Username set');
|
||||||
|
} catch (e) {
|
||||||
|
Toaster.error("Error", 'Failed to set username: ${e.toString()}');
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} catch (e) {
|
||||||
|
Toaster.error("Error", 'Failed to load user data: ${e.toString()}');
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Proceed with subscription
|
||||||
try {
|
try {
|
||||||
var sub = await APIClient.subscribeToChannelbyID(auth, widget.value.channelID, subscribeKey: widget.value.subscribeKey);
|
var sub = await APIClient.subscribeToChannelbyID(auth, widget.value.channelID, subscribeKey: widget.value.subscribeKey);
|
||||||
if (sub.confirmed) {
|
if (sub.confirmed) {
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ import 'package:simplecloudnotifier/api/api_client.dart';
|
|||||||
import 'package:simplecloudnotifier/state/app_settings.dart';
|
import 'package:simplecloudnotifier/state/app_settings.dart';
|
||||||
import 'package:simplecloudnotifier/state/app_auth.dart';
|
import 'package:simplecloudnotifier/state/app_auth.dart';
|
||||||
import 'package:simplecloudnotifier/state/application_log.dart';
|
import 'package:simplecloudnotifier/state/application_log.dart';
|
||||||
|
import 'package:simplecloudnotifier/state/globals.dart';
|
||||||
import 'package:simplecloudnotifier/utils/notifier.dart';
|
import 'package:simplecloudnotifier/utils/notifier.dart';
|
||||||
import 'package:simplecloudnotifier/utils/toaster.dart';
|
import 'package:simplecloudnotifier/utils/toaster.dart';
|
||||||
import 'package:simplecloudnotifier/utils/ui.dart';
|
import 'package:simplecloudnotifier/utils/ui.dart';
|
||||||
@@ -65,22 +66,31 @@ class _DebugActionsPageState extends State<DebugActionsPage> {
|
|||||||
onPressed: _sendTokenToServer,
|
onPressed: _sendTokenToServer,
|
||||||
text: 'Send FCM Token to Server',
|
text: 'Send FCM Token to Server',
|
||||||
),
|
),
|
||||||
|
SizedBox(height: 4),
|
||||||
|
UI.button(
|
||||||
|
big: false,
|
||||||
|
onPressed: _updateClient,
|
||||||
|
text: 'Update Client on Server',
|
||||||
|
),
|
||||||
SizedBox(height: 20),
|
SizedBox(height: 20),
|
||||||
UI.button(
|
UI.button(
|
||||||
big: false,
|
big: false,
|
||||||
onPressed: () => Notifier.showLocalNotification('', 'TEST_CHANNEL', "Test Channel", "Channel for testing", "Hello World", "Local Notification test", null, null),
|
onPressed: () => Notifier.showLocalNotification('', 'TEST_CHANNEL', "Test Channel", "Channel for testing", "Hello World", "Local Notification test", null, null),
|
||||||
text: 'Show local notification (generic)',
|
text: 'Show local notification (generic)',
|
||||||
),
|
),
|
||||||
|
SizedBox(height: 4),
|
||||||
UI.button(
|
UI.button(
|
||||||
big: false,
|
big: false,
|
||||||
onPressed: () => Notifier.showLocalNotification('', 'TEST_CHANNEL', "Test Channel", "Channel for testing", "Hello World", "Local Notification test", null, 0),
|
onPressed: () => Notifier.showLocalNotification('', 'TEST_CHANNEL', "Test Channel", "Channel for testing", "Hello World", "Local Notification test", null, 0),
|
||||||
text: 'Show local notification (Prio = 0)',
|
text: 'Show local notification (Prio = 0)',
|
||||||
),
|
),
|
||||||
|
SizedBox(height: 4),
|
||||||
UI.button(
|
UI.button(
|
||||||
big: false,
|
big: false,
|
||||||
onPressed: () => Notifier.showLocalNotification('', 'TEST_CHANNEL', "Test Channel", "Channel for testing", "Hello World", "Local Notification test", null, 1),
|
onPressed: () => Notifier.showLocalNotification('', 'TEST_CHANNEL', "Test Channel", "Channel for testing", "Hello World", "Local Notification test", null, 1),
|
||||||
text: 'Show local notification (Prio = 1)',
|
text: 'Show local notification (Prio = 1)',
|
||||||
),
|
),
|
||||||
|
SizedBox(height: 4),
|
||||||
UI.button(
|
UI.button(
|
||||||
big: false,
|
big: false,
|
||||||
onPressed: () => Notifier.showLocalNotification('', 'TEST_CHANNEL', "Test Channel", "Channel for testing", "Hello World", "Local Notification test", null, 2),
|
onPressed: () => Notifier.showLocalNotification('', 'TEST_CHANNEL', "Test Channel", "Channel for testing", "Hello World", "Local Notification test", null, 2),
|
||||||
@@ -128,6 +138,26 @@ class _DebugActionsPageState extends State<DebugActionsPage> {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void _updateClient() async {
|
||||||
|
try {
|
||||||
|
final auth = AppAuth();
|
||||||
|
|
||||||
|
final clientID = auth.getClientID();
|
||||||
|
if (clientID == null) {
|
||||||
|
Toaster.error("Error", "No Client set");
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
final newClient = await APIClient.updateClient(auth, clientID, agentModel: Globals().deviceModel, name: Globals().nameForClient(), agentVersion: Globals().version);
|
||||||
|
auth.setClientAndClientID(newClient);
|
||||||
|
|
||||||
|
Toaster.success("Success", "Client updated");
|
||||||
|
} catch (exc, trace) {
|
||||||
|
Toaster.error("Error", "An error occurred while updating the client: ${exc.toString()}");
|
||||||
|
ApplicationLog.error("An error occurred while updating the client: ${exc.toString()}", trace: trace);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
void _copyToken() async {
|
void _copyToken() async {
|
||||||
try {
|
try {
|
||||||
final fcmToken = await FirebaseMessaging.instance.getToken();
|
final fcmToken = await FirebaseMessaging.instance.getToken();
|
||||||
|
|||||||
@@ -135,7 +135,7 @@ class _DebugRequestViewPageState extends State<DebugRequestViewPage> {
|
|||||||
void _copyCurl() {
|
void _copyCurl() {
|
||||||
final method = '-X ${widget.request.method}';
|
final method = '-X ${widget.request.method}';
|
||||||
final header = widget.request.requestHeaders.entries.map((v) => '-H "${v.key}: ${v.value}"').join(' ');
|
final header = widget.request.requestHeaders.entries.map((v) => '-H "${v.key}: ${v.value}"').join(' ');
|
||||||
final body = widget.request.requestBody.isNotEmpty ? '-d "${widget.request.requestBody}"' : '';
|
final body = widget.request.requestBody.isNotEmpty ? '-d \'${widget.request.requestBody}\'' : '';
|
||||||
|
|
||||||
final curlParts = ['curl', method, header, '"${widget.request.url}"', body];
|
final curlParts = ['curl', method, header, '"${widget.request.url}"', body];
|
||||||
|
|
||||||
|
|||||||
@@ -284,7 +284,9 @@ class _SendRootPageState extends State<SendRootPage> {
|
|||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
await APIClient.sendMessage(acc.userID!, acc.tokenSend!, _msgContent.text);
|
var content = (_msgContent.text != '') ? _msgContent.text : null;
|
||||||
|
|
||||||
|
await APIClient.sendMessage(acc.userID!, acc.tokenSend!, _msgTitle.text, content: content);
|
||||||
Toaster.success("Success", 'Message sent');
|
Toaster.success("Success", 'Message sent');
|
||||||
setState(() {
|
setState(() {
|
||||||
_msgTitle.clear();
|
_msgTitle.clear();
|
||||||
@@ -306,7 +308,11 @@ class _SendRootPageState extends State<SendRootPage> {
|
|||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
await APIClient.sendMessage(acc.userID!, acc.tokenSend!, _msgContent.text, channel: _channelName.text, senderName: _senderName.text, priority: _priority);
|
var content = (_msgContent.text != '') ? _msgContent.text : null;
|
||||||
|
var channel = (_channelName.text != '') ? _channelName.text : null;
|
||||||
|
var sender = (_senderName.text != '') ? _senderName.text : null;
|
||||||
|
|
||||||
|
await APIClient.sendMessage(acc.userID!, acc.tokenSend!, _msgTitle.text, content: content, channel: channel, senderName: sender, priority: _priority);
|
||||||
Toaster.success("Success", 'Message sent');
|
Toaster.success("Success", 'Message sent');
|
||||||
setState(() {
|
setState(() {
|
||||||
_msgTitle.clear();
|
_msgTitle.clear();
|
||||||
|
|||||||
@@ -99,7 +99,7 @@ class AppAuth extends ChangeNotifier implements TokenSource {
|
|||||||
|
|
||||||
final user = await APIClient.getUser(DirectTokenSource(oldUserID, oldUserKey), oldUserID);
|
final user = await APIClient.getUser(DirectTokenSource(oldUserID, oldUserKey), oldUserID);
|
||||||
|
|
||||||
final client = await APIClient.addClient(DirectTokenSource(oldUserID, oldUserKey), fcmToken, Globals().deviceModel, Globals().version, Globals().hostname, Globals().clientType);
|
final client = await APIClient.addClient(DirectTokenSource(oldUserID, oldUserKey), fcmToken, Globals().deviceModel, Globals().version, Globals().nameForClient(), Globals().clientType);
|
||||||
|
|
||||||
set(user, client, oldUserKey, newTokenSend.token);
|
set(user, client, oldUserKey, newTokenSend.token);
|
||||||
|
|
||||||
@@ -232,7 +232,7 @@ class AppAuth extends ChangeNotifier implements TokenSource {
|
|||||||
return _user?.$1;
|
return _user?.$1;
|
||||||
}
|
}
|
||||||
|
|
||||||
Future<Client?> loadClient({bool force = false, Duration? forceIfOlder = null}) async {
|
Future<Client?> loadClient({bool force = false, Duration? forceIfOlder = null, bool onlyCached = false}) async {
|
||||||
if (forceIfOlder != null && _client != null && _client!.$2.difference(DateTime.now()) > forceIfOlder) {
|
if (forceIfOlder != null && _client != null && _client!.$2.difference(DateTime.now()) > forceIfOlder) {
|
||||||
force = true;
|
force = true;
|
||||||
}
|
}
|
||||||
@@ -245,6 +245,10 @@ class AppAuth extends ChangeNotifier implements TokenSource {
|
|||||||
throw Exception('Not authenticated');
|
throw Exception('Not authenticated');
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (onlyCached) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
final client = await APIClient.getClient(this, _clientID!);
|
final client = await APIClient.getClient(this, _clientID!);
|
||||||
|
|
||||||
|
|||||||
@@ -92,4 +92,12 @@ class Globals {
|
|||||||
Future<bool> setPrefFCMToken(String value) {
|
Future<bool> setPrefFCMToken(String value) {
|
||||||
return sharedPrefs.setString("fcm.token", value);
|
return sharedPrefs.setString("fcm.token", value);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
String nameForClient() {
|
||||||
|
if (this.deviceName.isNotEmpty) {
|
||||||
|
return this.deviceName;
|
||||||
|
} else {
|
||||||
|
return this.hostname;
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -28,6 +28,40 @@ class UIDialogs {
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
static Future<String?> showUsernameRequiredDialog(BuildContext context) {
|
||||||
|
var _textFieldController = TextEditingController();
|
||||||
|
|
||||||
|
return showDialog(
|
||||||
|
context: context,
|
||||||
|
builder: (context) => AlertDialog(
|
||||||
|
title: Text('Username Required'),
|
||||||
|
content: Column(
|
||||||
|
mainAxisSize: MainAxisSize.min,
|
||||||
|
crossAxisAlignment: CrossAxisAlignment.start,
|
||||||
|
children: [
|
||||||
|
Text('Please set a public username to subscribe to channels from other users.'),
|
||||||
|
SizedBox(height: 16),
|
||||||
|
TextField(
|
||||||
|
autofocus: true,
|
||||||
|
controller: _textFieldController,
|
||||||
|
decoration: InputDecoration(hintText: 'Enter username'),
|
||||||
|
),
|
||||||
|
],
|
||||||
|
),
|
||||||
|
actions: [
|
||||||
|
TextButton(
|
||||||
|
onPressed: () => Navigator.of(context).pop(),
|
||||||
|
child: Text('Cancel'),
|
||||||
|
),
|
||||||
|
TextButton(
|
||||||
|
onPressed: () => Navigator.of(context).pop(_textFieldController.text),
|
||||||
|
child: Text('OK'),
|
||||||
|
),
|
||||||
|
],
|
||||||
|
),
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
static Future<bool> showConfirmDialog(BuildContext context, String title, {String? text, String? okText, String? cancelText}) {
|
static Future<bool> showConfirmDialog(BuildContext context, String title, {String? text, String? okText, String? cancelText}) {
|
||||||
return showDialog<bool>(
|
return showDialog<bool>(
|
||||||
context: context,
|
context: context,
|
||||||
|
|||||||
@@ -2,7 +2,7 @@ name: simplecloudnotifier
|
|||||||
description: "Receive push messages"
|
description: "Receive push messages"
|
||||||
publish_to: 'none'
|
publish_to: 'none'
|
||||||
|
|
||||||
version: 2.1.1+509
|
version: 2.2.2+544
|
||||||
|
|
||||||
environment:
|
environment:
|
||||||
sdk: '>=3.9.0 <4.0.0'
|
sdk: '>=3.9.0 <4.0.0'
|
||||||
|
|||||||
@@ -17,8 +17,8 @@ simple_cloud_notifier-*.sql
|
|||||||
identifier.sqlite
|
identifier.sqlite
|
||||||
|
|
||||||
.idea/dataSources.xml
|
.idea/dataSources.xml
|
||||||
|
|
||||||
.idea/copilot*
|
.idea/copilot*
|
||||||
|
.idea/go.imports.xml
|
||||||
|
|
||||||
.swaggobin
|
.swaggobin
|
||||||
|
|
||||||
|
|||||||
@@ -1,14 +1,15 @@
|
|||||||
package handler
|
package handler
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"database/sql"
|
||||||
|
"errors"
|
||||||
|
"net/http"
|
||||||
|
|
||||||
"blackforestbytes.com/simplecloudnotifier/api/apierr"
|
"blackforestbytes.com/simplecloudnotifier/api/apierr"
|
||||||
"blackforestbytes.com/simplecloudnotifier/api/ginresp"
|
"blackforestbytes.com/simplecloudnotifier/api/ginresp"
|
||||||
"blackforestbytes.com/simplecloudnotifier/logic"
|
"blackforestbytes.com/simplecloudnotifier/logic"
|
||||||
"blackforestbytes.com/simplecloudnotifier/models"
|
"blackforestbytes.com/simplecloudnotifier/models"
|
||||||
"database/sql"
|
|
||||||
"errors"
|
|
||||||
"git.blackforestbytes.com/BlackForestBytes/goext/ginext"
|
"git.blackforestbytes.com/BlackForestBytes/goext/ginext"
|
||||||
"net/http"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
// GetUserPreview swaggerdoc
|
// GetUserPreview swaggerdoc
|
||||||
@@ -52,7 +53,7 @@ func (h APIHandler) GetUserPreview(pctx ginext.PreContext) ginext.HTTPResponse {
|
|||||||
return ginresp.APIError(g, 500, apierr.DATABASE_ERROR, "Failed to query user", err)
|
return ginresp.APIError(g, 500, apierr.DATABASE_ERROR, "Failed to query user", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
return finishSuccess(ginext.JSON(http.StatusOK, user.JSONPreview()))
|
return finishSuccess(ginext.JSON(http.StatusOK, user.Preview()))
|
||||||
|
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
@@ -92,13 +93,13 @@ func (h APIHandler) GetChannelPreview(pctx ginext.PreContext) ginext.HTTPRespons
|
|||||||
|
|
||||||
userid := *ctx.GetPermissionUserID()
|
userid := *ctx.GetPermissionUserID()
|
||||||
|
|
||||||
channel, err := h.database.GetChannelByID(ctx, u.ChannelID)
|
channel, err := h.database.GetChannelByIDOpt(ctx, u.ChannelID)
|
||||||
if errors.Is(err, sql.ErrNoRows) {
|
|
||||||
return ginresp.APIError(g, 404, apierr.CHANNEL_NOT_FOUND, "Channel not found", err)
|
|
||||||
}
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return ginresp.APIError(g, 500, apierr.DATABASE_ERROR, "Failed to query channel", err)
|
return ginresp.APIError(g, 500, apierr.DATABASE_ERROR, "Failed to query channel", err)
|
||||||
}
|
}
|
||||||
|
if channel == nil {
|
||||||
|
return ginresp.APIError(g, 404, apierr.CHANNEL_NOT_FOUND, "Channel not found", err)
|
||||||
|
}
|
||||||
|
|
||||||
sub, err := h.database.GetSubscriptionBySubscriber(ctx, userid, channel.ChannelID)
|
sub, err := h.database.GetSubscriptionBySubscriber(ctx, userid, channel.ChannelID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -161,13 +162,13 @@ func (h APIHandler) GetUserKeyPreview(pctx ginext.PreContext) ginext.HTTPRespons
|
|||||||
|
|
||||||
// Query by token.token
|
// Query by token.token
|
||||||
|
|
||||||
keytoken, err := h.database.GetKeyTokenByToken(ctx, u.KeyID)
|
keytoken, err := h.database.GetKeyTokenByTokenOpt(ctx, u.KeyID)
|
||||||
if keytoken == nil {
|
|
||||||
return ginresp.APIError(g, 404, apierr.KEY_NOT_FOUND, "Key not found", err)
|
|
||||||
}
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return ginresp.APIError(g, 500, apierr.DATABASE_ERROR, "Failed to query client", err)
|
return ginresp.APIError(g, 500, apierr.DATABASE_ERROR, "Failed to query client", err)
|
||||||
}
|
}
|
||||||
|
if keytoken == nil {
|
||||||
|
return ginresp.APIError(g, 404, apierr.KEY_NOT_FOUND, "Key not found", err)
|
||||||
|
}
|
||||||
|
|
||||||
return finishSuccess(ginext.JSON(http.StatusOK, keytoken.Preview()))
|
return finishSuccess(ginext.JSON(http.StatusOK, keytoken.Preview()))
|
||||||
|
|
||||||
@@ -175,3 +176,65 @@ func (h APIHandler) GetUserKeyPreview(pctx ginext.PreContext) ginext.HTTPRespons
|
|||||||
|
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// GetClientPreview swaggerdoc
|
||||||
|
//
|
||||||
|
// @Summary Get a client (similar to api-clients-get, but can be called from anyone and only returns a subset of fields)
|
||||||
|
// @ID api-clients-get-preview
|
||||||
|
// @Tags API-v2
|
||||||
|
//
|
||||||
|
// @Param cid path string true "ClientID"
|
||||||
|
//
|
||||||
|
// @Success 200 {object} handler.GetClientPreview.response
|
||||||
|
//
|
||||||
|
// @Failure 400 {object} ginresp.apiError "supplied values/parameters cannot be parsed / are invalid"
|
||||||
|
// @Failure 401 {object} ginresp.apiError "user is not authorized / has missing permissions"
|
||||||
|
// @Failure 404 {object} ginresp.apiError "client not found"
|
||||||
|
// @Failure 500 {object} ginresp.apiError "internal server error"
|
||||||
|
//
|
||||||
|
// @Router /api/v2/preview/clients/{cid} [GET]
|
||||||
|
func (h APIHandler) GetClientPreview(pctx ginext.PreContext) ginext.HTTPResponse {
|
||||||
|
type uri struct {
|
||||||
|
ClientID models.ClientID `uri:"cid" binding:"entityid"`
|
||||||
|
}
|
||||||
|
type response struct {
|
||||||
|
Client models.ClientPreview `json:"client"`
|
||||||
|
User models.UserPreview `json:"user"`
|
||||||
|
}
|
||||||
|
|
||||||
|
var u uri
|
||||||
|
ctx, g, errResp := pctx.URI(&u).Start()
|
||||||
|
if errResp != nil {
|
||||||
|
return *errResp
|
||||||
|
}
|
||||||
|
defer ctx.Cancel()
|
||||||
|
|
||||||
|
return h.app.DoRequest(ctx, g, models.TLockRead, func(ctx *logic.AppContext, finishSuccess func(r ginext.HTTPResponse) ginext.HTTPResponse) ginext.HTTPResponse {
|
||||||
|
|
||||||
|
if permResp := ctx.CheckPermissionAny(); permResp != nil {
|
||||||
|
return *permResp
|
||||||
|
}
|
||||||
|
|
||||||
|
client, err := h.database.GetClientByIDOpt(ctx, u.ClientID)
|
||||||
|
if err != nil {
|
||||||
|
return ginresp.APIError(g, 500, apierr.DATABASE_ERROR, "Failed to query client", err)
|
||||||
|
}
|
||||||
|
if client == nil {
|
||||||
|
return ginresp.APIError(g, 404, apierr.CLIENT_NOT_FOUND, "Client not found", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
user, err := h.database.GetUser(ctx, client.UserID)
|
||||||
|
if errors.Is(err, sql.ErrNoRows) {
|
||||||
|
return ginresp.APIError(g, 404, apierr.USER_NOT_FOUND, "User not found", err)
|
||||||
|
}
|
||||||
|
if err != nil {
|
||||||
|
return ginresp.APIError(g, 500, apierr.DATABASE_ERROR, "Failed to query user", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
return finishSuccess(ginext.JSON(http.StatusOK, response{
|
||||||
|
Client: client.Preview(),
|
||||||
|
User: user.Preview(),
|
||||||
|
}))
|
||||||
|
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|||||||
@@ -362,7 +362,7 @@ func (h APIHandler) CreateSubscription(pctx ginext.PreContext) ginext.HTTPRespon
|
|||||||
|
|
||||||
} else if b.ChannelOwnerUserID == nil && b.ChannelInternalName == nil && b.ChannelID != nil {
|
} else if b.ChannelOwnerUserID == nil && b.ChannelInternalName == nil && b.ChannelID != nil {
|
||||||
|
|
||||||
outchannel, err := h.database.GetChannelByID(ctx, *b.ChannelID)
|
outchannel, err := h.database.GetChannelByIDOpt(ctx, *b.ChannelID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return ginresp.APIError(g, 500, apierr.DATABASE_ERROR, "Failed to query channel", err)
|
return ginresp.APIError(g, 500, apierr.DATABASE_ERROR, "Failed to query channel", err)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -305,7 +305,7 @@ func (h CompatHandler) Info(pctx ginext.PreContext) ginext.HTTPResponse {
|
|||||||
return ginresp.CompatAPIError(0, "Failed to query user")
|
return ginresp.CompatAPIError(0, "Failed to query user")
|
||||||
}
|
}
|
||||||
|
|
||||||
keytok, err := h.database.GetKeyTokenByToken(ctx, *data.UserKey)
|
keytok, err := h.database.GetKeyTokenByTokenOpt(ctx, *data.UserKey)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return ginresp.CompatAPIError(0, "Failed to query token")
|
return ginresp.CompatAPIError(0, "Failed to query token")
|
||||||
}
|
}
|
||||||
@@ -417,7 +417,7 @@ func (h CompatHandler) Ack(pctx ginext.PreContext) ginext.HTTPResponse {
|
|||||||
return ginresp.CompatAPIError(0, "Failed to query user")
|
return ginresp.CompatAPIError(0, "Failed to query user")
|
||||||
}
|
}
|
||||||
|
|
||||||
keytok, err := h.database.GetKeyTokenByToken(ctx, *data.UserKey)
|
keytok, err := h.database.GetKeyTokenByTokenOpt(ctx, *data.UserKey)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return ginresp.CompatAPIError(0, "Failed to query token")
|
return ginresp.CompatAPIError(0, "Failed to query token")
|
||||||
}
|
}
|
||||||
@@ -523,7 +523,7 @@ func (h CompatHandler) Requery(pctx ginext.PreContext) ginext.HTTPResponse {
|
|||||||
return ginresp.CompatAPIError(0, "Failed to query user")
|
return ginresp.CompatAPIError(0, "Failed to query user")
|
||||||
}
|
}
|
||||||
|
|
||||||
keytok, err := h.database.GetKeyTokenByToken(ctx, *data.UserKey)
|
keytok, err := h.database.GetKeyTokenByTokenOpt(ctx, *data.UserKey)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return ginresp.CompatAPIError(0, "Failed to query token")
|
return ginresp.CompatAPIError(0, "Failed to query token")
|
||||||
}
|
}
|
||||||
@@ -644,7 +644,7 @@ func (h CompatHandler) Update(pctx ginext.PreContext) ginext.HTTPResponse {
|
|||||||
return ginresp.CompatAPIError(0, "Failed to query user")
|
return ginresp.CompatAPIError(0, "Failed to query user")
|
||||||
}
|
}
|
||||||
|
|
||||||
keytok, err := h.database.GetKeyTokenByToken(ctx, *data.UserKey)
|
keytok, err := h.database.GetKeyTokenByTokenOpt(ctx, *data.UserKey)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return ginresp.CompatAPIError(0, "Failed to query token")
|
return ginresp.CompatAPIError(0, "Failed to query token")
|
||||||
}
|
}
|
||||||
@@ -778,7 +778,7 @@ func (h CompatHandler) Expand(pctx ginext.PreContext) ginext.HTTPResponse {
|
|||||||
return ginresp.CompatAPIError(0, "Failed to query user")
|
return ginresp.CompatAPIError(0, "Failed to query user")
|
||||||
}
|
}
|
||||||
|
|
||||||
keytok, err := h.database.GetKeyTokenByToken(ctx, *data.UserKey)
|
keytok, err := h.database.GetKeyTokenByTokenOpt(ctx, *data.UserKey)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return ginresp.CompatAPIError(0, "Failed to query token")
|
return ginresp.CompatAPIError(0, "Failed to query token")
|
||||||
}
|
}
|
||||||
@@ -901,7 +901,7 @@ func (h CompatHandler) Upgrade(pctx ginext.PreContext) ginext.HTTPResponse {
|
|||||||
return ginresp.CompatAPIError(0, "Failed to query user")
|
return ginresp.CompatAPIError(0, "Failed to query user")
|
||||||
}
|
}
|
||||||
|
|
||||||
keytok, err := h.database.GetKeyTokenByToken(ctx, *data.UserKey)
|
keytok, err := h.database.GetKeyTokenByTokenOpt(ctx, *data.UserKey)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return ginresp.CompatAPIError(0, "Failed to query token")
|
return ginresp.CompatAPIError(0, "Failed to query token")
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -148,7 +148,7 @@ func (h ExternalHandler) UptimeKuma(pctx ginext.PreContext) ginext.HTTPResponse
|
|||||||
// @Tags External
|
// @Tags External
|
||||||
//
|
//
|
||||||
// @Param query_data query handler.Shoutrrr.query false " "
|
// @Param query_data query handler.Shoutrrr.query false " "
|
||||||
// @Param post_body body handler.Shoutrrr.body false " "
|
// @Param post_body body handler.Shoutrrr.body false " "
|
||||||
//
|
//
|
||||||
// @Success 200 {object} handler.Shoutrrr.response
|
// @Success 200 {object} handler.Shoutrrr.response
|
||||||
// @Failure 400 {object} ginresp.apiError
|
// @Failure 400 {object} ginresp.apiError
|
||||||
|
|||||||
@@ -171,6 +171,7 @@ func (r *Router) Init(e *ginext.GinWrapper) error {
|
|||||||
apiv2.GET("/preview/users/:uid").Handle(r.apiHandler.GetUserPreview)
|
apiv2.GET("/preview/users/:uid").Handle(r.apiHandler.GetUserPreview)
|
||||||
apiv2.GET("/preview/keys/:kid").Handle(r.apiHandler.GetUserKeyPreview)
|
apiv2.GET("/preview/keys/:kid").Handle(r.apiHandler.GetUserKeyPreview)
|
||||||
apiv2.GET("/preview/channels/:cid").Handle(r.apiHandler.GetChannelPreview)
|
apiv2.GET("/preview/channels/:cid").Handle(r.apiHandler.GetChannelPreview)
|
||||||
|
apiv2.GET("/preview/clients/:cid").Handle(r.apiHandler.GetClientPreview)
|
||||||
}
|
}
|
||||||
|
|
||||||
// ================ Send API (unversioned) ================
|
// ================ Send API (unversioned) ================
|
||||||
|
|||||||
@@ -1,10 +1,11 @@
|
|||||||
package primary
|
package primary
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"time"
|
||||||
|
|
||||||
"blackforestbytes.com/simplecloudnotifier/db"
|
"blackforestbytes.com/simplecloudnotifier/db"
|
||||||
"blackforestbytes.com/simplecloudnotifier/models"
|
"blackforestbytes.com/simplecloudnotifier/models"
|
||||||
"git.blackforestbytes.com/BlackForestBytes/goext/sq"
|
"git.blackforestbytes.com/BlackForestBytes/goext/sq"
|
||||||
"time"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func (db *Database) GetChannelByName(ctx db.TxContext, userid models.UserID, chanName string) (*models.Channel, error) {
|
func (db *Database) GetChannelByName(ctx db.TxContext, userid models.UserID, chanName string) (*models.Channel, error) {
|
||||||
@@ -16,7 +17,7 @@ func (db *Database) GetChannelByName(ctx db.TxContext, userid models.UserID, cha
|
|||||||
return sq.QuerySingleOpt[models.Channel](ctx, tx, "SELECT * FROM channels WHERE owner_user_id = :uid AND internal_name = :nam AND deleted=0 LIMIT 1", sq.PP{"uid": userid, "nam": chanName}, sq.SModeExtended, sq.Safe)
|
return sq.QuerySingleOpt[models.Channel](ctx, tx, "SELECT * FROM channels WHERE owner_user_id = :uid AND internal_name = :nam AND deleted=0 LIMIT 1", sq.PP{"uid": userid, "nam": chanName}, sq.SModeExtended, sq.Safe)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (db *Database) GetChannelByID(ctx db.TxContext, chanid models.ChannelID) (*models.Channel, error) {
|
func (db *Database) GetChannelByIDOpt(ctx db.TxContext, chanid models.ChannelID) (*models.Channel, error) {
|
||||||
tx, err := ctx.GetOrCreateTransaction(db)
|
tx, err := ctx.GetOrCreateTransaction(db)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
|
|||||||
@@ -53,6 +53,15 @@ func (db *Database) GetClient(ctx db.TxContext, userid models.UserID, clientid m
|
|||||||
}, sq.SModeExtended, sq.Safe)
|
}, sq.SModeExtended, sq.Safe)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (db *Database) GetClientByIDOpt(ctx db.TxContext, clientid models.ClientID) (*models.Client, error) {
|
||||||
|
tx, err := ctx.GetOrCreateTransaction(db)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
return sq.QuerySingleOpt[models.Client](ctx, tx, "SELECT * FROM clients WHERE deleted=0 AND client_id = :cid LIMIT 1", sq.PP{"cid": clientid}, sq.SModeExtended, sq.Safe)
|
||||||
|
}
|
||||||
|
|
||||||
func (db *Database) GetClientOpt(ctx db.TxContext, userid models.UserID, clientid models.ClientID) (*models.Client, error) {
|
func (db *Database) GetClientOpt(ctx db.TxContext, userid models.UserID, clientid models.ClientID) (*models.Client, error) {
|
||||||
tx, err := ctx.GetOrCreateTransaction(db)
|
tx, err := ctx.GetOrCreateTransaction(db)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
@@ -1,12 +1,13 @@
|
|||||||
package primary
|
package primary
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"strings"
|
||||||
|
"time"
|
||||||
|
|
||||||
"blackforestbytes.com/simplecloudnotifier/db"
|
"blackforestbytes.com/simplecloudnotifier/db"
|
||||||
"blackforestbytes.com/simplecloudnotifier/models"
|
"blackforestbytes.com/simplecloudnotifier/models"
|
||||||
"git.blackforestbytes.com/BlackForestBytes/goext/langext"
|
"git.blackforestbytes.com/BlackForestBytes/goext/langext"
|
||||||
"git.blackforestbytes.com/BlackForestBytes/goext/sq"
|
"git.blackforestbytes.com/BlackForestBytes/goext/sq"
|
||||||
"strings"
|
|
||||||
"time"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func (db *Database) CreateKeyToken(ctx db.TxContext, name string, owner models.UserID, allChannels bool, channels []models.ChannelID, permissions models.TokenPermissionList, token string) (models.KeyToken, error) {
|
func (db *Database) CreateKeyToken(ctx db.TxContext, name string, owner models.UserID, allChannels bool, channels []models.ChannelID, permissions models.TokenPermissionList, token string) (models.KeyToken, error) {
|
||||||
@@ -67,7 +68,7 @@ func (db *Database) GetKeyTokenByID(ctx db.TxContext, keyTokenid models.KeyToken
|
|||||||
return sq.QuerySingle[models.KeyToken](ctx, tx, "SELECT * FROM keytokens WHERE keytoken_id = :cid AND deleted=0 LIMIT 1", sq.PP{"cid": keyTokenid}, sq.SModeExtended, sq.Safe)
|
return sq.QuerySingle[models.KeyToken](ctx, tx, "SELECT * FROM keytokens WHERE keytoken_id = :cid AND deleted=0 LIMIT 1", sq.PP{"cid": keyTokenid}, sq.SModeExtended, sq.Safe)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (db *Database) GetKeyTokenByToken(ctx db.TxContext, key string) (*models.KeyToken, error) {
|
func (db *Database) GetKeyTokenByTokenOpt(ctx db.TxContext, key string) (*models.KeyToken, error) {
|
||||||
tx, err := ctx.GetOrCreateTransaction(db)
|
tx, err := ctx.GetOrCreateTransaction(db)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
|
|||||||
@@ -1,14 +1,15 @@
|
|||||||
package jobs
|
package jobs
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"errors"
|
||||||
|
"fmt"
|
||||||
|
"time"
|
||||||
|
|
||||||
"blackforestbytes.com/simplecloudnotifier/db/simplectx"
|
"blackforestbytes.com/simplecloudnotifier/db/simplectx"
|
||||||
"blackforestbytes.com/simplecloudnotifier/logic"
|
"blackforestbytes.com/simplecloudnotifier/logic"
|
||||||
"blackforestbytes.com/simplecloudnotifier/models"
|
"blackforestbytes.com/simplecloudnotifier/models"
|
||||||
"errors"
|
|
||||||
"fmt"
|
|
||||||
"git.blackforestbytes.com/BlackForestBytes/goext/syncext"
|
"git.blackforestbytes.com/BlackForestBytes/goext/syncext"
|
||||||
"github.com/rs/zerolog/log"
|
"github.com/rs/zerolog/log"
|
||||||
"time"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
type DeliveryRetryJob struct {
|
type DeliveryRetryJob struct {
|
||||||
@@ -208,7 +209,7 @@ func (j *DeliveryRetryJob) redeliver(ctx *simplectx.SimpleContext, delivery mode
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
channel, err := j.app.Database.Primary.GetChannelByID(ctx, msg.ChannelID)
|
channel, err := j.app.Database.Primary.GetChannelByIDOpt(ctx, msg.ChannelID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Err(err).Str("ChannelID", msg.ChannelID.String()).Msg("Failed to get channel")
|
log.Err(err).Str("ChannelID", msg.ChannelID.String()).Msg("Failed to get channel")
|
||||||
ctx.RollbackTransaction()
|
ctx.RollbackTransaction()
|
||||||
|
|||||||
@@ -245,7 +245,7 @@ func (app *Application) getPermissions(ctx db.TxContext, hdr string) (models.Per
|
|||||||
|
|
||||||
key := strings.TrimSpace(hdr[4:])
|
key := strings.TrimSpace(hdr[4:])
|
||||||
|
|
||||||
tok, err := app.Database.Primary.GetKeyTokenByToken(ctx, key)
|
tok, err := app.Database.Primary.GetKeyTokenByTokenOpt(ctx, key)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return models.PermissionSet{}, err
|
return models.PermissionSet{}, err
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -75,7 +75,7 @@ func (ac *AppContext) CheckPermissionUserAdmin(userid models.UserID) *ginext.HTT
|
|||||||
|
|
||||||
func (ac *AppContext) CheckPermissionSend(channel models.Channel, key string) (*models.KeyToken, *ginext.HTTPResponse) {
|
func (ac *AppContext) CheckPermissionSend(channel models.Channel, key string) (*models.KeyToken, *ginext.HTTPResponse) {
|
||||||
|
|
||||||
keytok, err := ac.app.Database.Primary.GetKeyTokenByToken(ac, key)
|
keytok, err := ac.app.Database.Primary.GetKeyTokenByTokenOpt(ac, key)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, langext.Ptr(ginresp.APIError(ac.ginContext, 500, apierr.DATABASE_ERROR, "Failed to query token", err))
|
return nil, langext.Ptr(ginresp.APIError(ac.ginContext, 500, apierr.DATABASE_ERROR, "Failed to query token", err))
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -21,3 +21,25 @@ type Client struct {
|
|||||||
Name *string `db:"name" json:"name"`
|
Name *string `db:"name" json:"name"`
|
||||||
Deleted bool `db:"deleted" json:"-"`
|
Deleted bool `db:"deleted" json:"-"`
|
||||||
}
|
}
|
||||||
|
|
||||||
|
type ClientPreview struct {
|
||||||
|
ClientID ClientID `json:"client_id"`
|
||||||
|
UserID UserID `json:"user_id"`
|
||||||
|
Type ClientType `json:"type"`
|
||||||
|
TimestampCreated SCNTime `json:"timestamp_created"`
|
||||||
|
AgentModel string `json:"agent_model"`
|
||||||
|
AgentVersion string `json:"agent_version"`
|
||||||
|
Name *string `json:"name"`
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c Client) Preview() ClientPreview {
|
||||||
|
return ClientPreview{
|
||||||
|
ClientID: c.ClientID,
|
||||||
|
UserID: c.UserID,
|
||||||
|
Type: c.Type,
|
||||||
|
TimestampCreated: c.TimestampCreated,
|
||||||
|
AgentModel: c.AgentModel,
|
||||||
|
AgentVersion: c.AgentVersion,
|
||||||
|
Name: c.Name,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
@@ -88,9 +88,9 @@ func (u User) MaxTitleLength() int {
|
|||||||
|
|
||||||
func (u User) QuotaPerDay() int {
|
func (u User) QuotaPerDay() int {
|
||||||
if u.IsPro {
|
if u.IsPro {
|
||||||
return 5000
|
return 15_000
|
||||||
} else {
|
} else {
|
||||||
return 50
|
return 500
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -135,7 +135,7 @@ func (u User) MaxTimestampDiffHours() int {
|
|||||||
return 24
|
return 24
|
||||||
}
|
}
|
||||||
|
|
||||||
func (u User) JSONPreview() UserPreview {
|
func (u User) Preview() UserPreview {
|
||||||
return UserPreview{
|
return UserPreview{
|
||||||
UserID: u.UserID,
|
UserID: u.UserID,
|
||||||
Username: u.Username,
|
Username: u.Username,
|
||||||
|
|||||||
@@ -1,22 +1,23 @@
|
|||||||
package push
|
package push
|
||||||
|
|
||||||
import (
|
import (
|
||||||
scn "blackforestbytes.com/simplecloudnotifier"
|
|
||||||
"blackforestbytes.com/simplecloudnotifier/models"
|
|
||||||
"bytes"
|
"bytes"
|
||||||
"context"
|
"context"
|
||||||
_ "embed"
|
_ "embed"
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
"git.blackforestbytes.com/BlackForestBytes/goext/langext"
|
|
||||||
"github.com/gin-gonic/gin"
|
|
||||||
"github.com/rs/zerolog/log"
|
|
||||||
"io"
|
"io"
|
||||||
"net/http"
|
"net/http"
|
||||||
"strconv"
|
"strconv"
|
||||||
"strings"
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
scn "blackforestbytes.com/simplecloudnotifier"
|
||||||
|
"blackforestbytes.com/simplecloudnotifier/models"
|
||||||
|
"git.blackforestbytes.com/BlackForestBytes/goext/langext"
|
||||||
|
"github.com/gin-gonic/gin"
|
||||||
|
"github.com/rs/zerolog/log"
|
||||||
)
|
)
|
||||||
|
|
||||||
// https://firebase.google.com/docs/cloud-messaging/send-message#rest
|
// https://firebase.google.com/docs/cloud-messaging/send-message#rest
|
||||||
@@ -66,7 +67,13 @@ func (fb FirebaseConnector) SendNotification(ctx context.Context, user models.Us
|
|||||||
"title": msg.Title,
|
"title": msg.Title,
|
||||||
"body": msg.ShortContent(),
|
"body": msg.ShortContent(),
|
||||||
},
|
},
|
||||||
"apns": gin.H{},
|
"apns": gin.H{
|
||||||
|
"payload": gin.H{
|
||||||
|
"aps": gin.H{
|
||||||
|
"sound": "default",
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
}
|
}
|
||||||
} else if client.Type == models.ClientTypeAndroid {
|
} else if client.Type == models.ClientTypeAndroid {
|
||||||
jsonBody = gin.H{
|
jsonBody = gin.H{
|
||||||
|
|||||||
@@ -1,13 +1,14 @@
|
|||||||
package test
|
package test
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"blackforestbytes.com/simplecloudnotifier/push"
|
|
||||||
tt "blackforestbytes.com/simplecloudnotifier/test/util"
|
|
||||||
"fmt"
|
"fmt"
|
||||||
"github.com/gin-gonic/gin"
|
|
||||||
"net/url"
|
"net/url"
|
||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
"blackforestbytes.com/simplecloudnotifier/push"
|
||||||
|
tt "blackforestbytes.com/simplecloudnotifier/test/util"
|
||||||
|
"github.com/gin-gonic/gin"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestSendCompatWithOldUser(t *testing.T) {
|
func TestSendCompatWithOldUser(t *testing.T) {
|
||||||
@@ -309,7 +310,7 @@ func TestCompatRegister(t *testing.T) {
|
|||||||
tt.AssertEqual(t, "success", true, r0["success"])
|
tt.AssertEqual(t, "success", true, r0["success"])
|
||||||
tt.AssertEqual(t, "message", "New user registered", r0["message"])
|
tt.AssertEqual(t, "message", "New user registered", r0["message"])
|
||||||
tt.AssertEqual(t, "quota", 0, r0["quota"])
|
tt.AssertEqual(t, "quota", 0, r0["quota"])
|
||||||
tt.AssertEqual(t, "quota_max", 50, r0["quota_max"])
|
tt.AssertEqual(t, "quota_max", 500, r0["quota_max"])
|
||||||
tt.AssertEqual(t, "is_pro", false, r0["is_pro"])
|
tt.AssertEqual(t, "is_pro", false, r0["is_pro"])
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -321,7 +322,7 @@ func TestCompatRegisterPro(t *testing.T) {
|
|||||||
tt.AssertEqual(t, "success", true, r0["success"])
|
tt.AssertEqual(t, "success", true, r0["success"])
|
||||||
tt.AssertEqual(t, "message", "New user registered", r0["message"])
|
tt.AssertEqual(t, "message", "New user registered", r0["message"])
|
||||||
tt.AssertEqual(t, "quota", 0, r0["quota"])
|
tt.AssertEqual(t, "quota", 0, r0["quota"])
|
||||||
tt.AssertEqual(t, "quota_max", 5000, r0["quota_max"])
|
tt.AssertEqual(t, "quota_max", 15000, r0["quota_max"])
|
||||||
tt.AssertEqual(t, "is_pro", true, r0["is_pro"])
|
tt.AssertEqual(t, "is_pro", true, r0["is_pro"])
|
||||||
|
|
||||||
r1 := tt.RequestGet[gin.H](t, baseUrl, fmt.Sprintf("/api/register.php?fcm_token=%s&pro=%s&pro_token=%s", "DUMMY_FCM", "true", url.QueryEscape("INVALID")))
|
r1 := tt.RequestGet[gin.H](t, baseUrl, fmt.Sprintf("/api/register.php?fcm_token=%s&pro=%s&pro_token=%s", "DUMMY_FCM", "true", url.QueryEscape("INVALID")))
|
||||||
@@ -345,7 +346,7 @@ func TestCompatInfo(t *testing.T) {
|
|||||||
tt.AssertEqual(t, "is_pro", 0, r1["is_pro"])
|
tt.AssertEqual(t, "is_pro", 0, r1["is_pro"])
|
||||||
tt.AssertEqual(t, "message", "ok", r1["message"])
|
tt.AssertEqual(t, "message", "ok", r1["message"])
|
||||||
tt.AssertEqual(t, "quota", 0, r1["quota"])
|
tt.AssertEqual(t, "quota", 0, r1["quota"])
|
||||||
tt.AssertEqual(t, "quota_max", 50, r1["quota_max"])
|
tt.AssertEqual(t, "quota_max", 500, r1["quota_max"])
|
||||||
tt.AssertEqual(t, "unack_count", 0, r1["unack_count"])
|
tt.AssertEqual(t, "unack_count", 0, r1["unack_count"])
|
||||||
tt.AssertEqual(t, "user_id", userid, r1["user_id"])
|
tt.AssertEqual(t, "user_id", userid, r1["user_id"])
|
||||||
tt.AssertEqual(t, "user_key", userkey, r1["user_key"])
|
tt.AssertEqual(t, "user_key", userkey, r1["user_key"])
|
||||||
@@ -363,7 +364,7 @@ func TestCompatInfo(t *testing.T) {
|
|||||||
tt.AssertEqual(t, "is_pro", 0, r2["is_pro"])
|
tt.AssertEqual(t, "is_pro", 0, r2["is_pro"])
|
||||||
tt.AssertEqual(t, "message", "ok", r2["message"])
|
tt.AssertEqual(t, "message", "ok", r2["message"])
|
||||||
tt.AssertEqual(t, "quota", 1, r2["quota"])
|
tt.AssertEqual(t, "quota", 1, r2["quota"])
|
||||||
tt.AssertEqual(t, "quota_max", 50, r2["quota_max"])
|
tt.AssertEqual(t, "quota_max", 500, r2["quota_max"])
|
||||||
tt.AssertEqual(t, "unack_count", 1, r2["unack_count"])
|
tt.AssertEqual(t, "unack_count", 1, r2["unack_count"])
|
||||||
tt.AssertEqual(t, "user_id", userid, r2["user_id"])
|
tt.AssertEqual(t, "user_id", userid, r2["user_id"])
|
||||||
tt.AssertEqual(t, "user_key", userkey, r2["user_key"])
|
tt.AssertEqual(t, "user_key", userkey, r2["user_key"])
|
||||||
@@ -490,7 +491,7 @@ func TestCompatUpdateUserKey(t *testing.T) {
|
|||||||
tt.AssertEqual(t, "is_pro", 0, r1["is_pro"])
|
tt.AssertEqual(t, "is_pro", 0, r1["is_pro"])
|
||||||
tt.AssertEqual(t, "message", "ok", r1["message"])
|
tt.AssertEqual(t, "message", "ok", r1["message"])
|
||||||
tt.AssertEqual(t, "quota", 1, r1["quota"])
|
tt.AssertEqual(t, "quota", 1, r1["quota"])
|
||||||
tt.AssertEqual(t, "quota_max", 50, r1["quota_max"])
|
tt.AssertEqual(t, "quota_max", 500, r1["quota_max"])
|
||||||
tt.AssertEqual(t, "unack_count", 1, r1["unack_count"])
|
tt.AssertEqual(t, "unack_count", 1, r1["unack_count"])
|
||||||
tt.AssertEqual(t, "user_id", userid, r1["user_id"])
|
tt.AssertEqual(t, "user_id", userid, r1["user_id"])
|
||||||
tt.AssertEqual(t, "user_key", newkey, r1["user_key"])
|
tt.AssertEqual(t, "user_key", newkey, r1["user_key"])
|
||||||
@@ -527,7 +528,7 @@ func TestCompatUpdateFCM(t *testing.T) {
|
|||||||
tt.AssertEqual(t, "is_pro", 0, r1["is_pro"])
|
tt.AssertEqual(t, "is_pro", 0, r1["is_pro"])
|
||||||
tt.AssertEqual(t, "message", "ok", r1["message"])
|
tt.AssertEqual(t, "message", "ok", r1["message"])
|
||||||
tt.AssertEqual(t, "quota", 1, r1["quota"])
|
tt.AssertEqual(t, "quota", 1, r1["quota"])
|
||||||
tt.AssertEqual(t, "quota_max", 50, r1["quota_max"])
|
tt.AssertEqual(t, "quota_max", 500, r1["quota_max"])
|
||||||
tt.AssertEqual(t, "unack_count", 1, r1["unack_count"])
|
tt.AssertEqual(t, "unack_count", 1, r1["unack_count"])
|
||||||
tt.AssertEqual(t, "user_id", userid, r1["user_id"])
|
tt.AssertEqual(t, "user_id", userid, r1["user_id"])
|
||||||
tt.AssertEqual(t, "user_key", newkey, r1["user_key"])
|
tt.AssertEqual(t, "user_key", newkey, r1["user_key"])
|
||||||
@@ -554,7 +555,7 @@ func TestCompatUpgrade(t *testing.T) {
|
|||||||
tt.AssertEqual(t, "success", true, r0["success"])
|
tt.AssertEqual(t, "success", true, r0["success"])
|
||||||
tt.AssertEqual(t, "message", "New user registered", r0["message"])
|
tt.AssertEqual(t, "message", "New user registered", r0["message"])
|
||||||
tt.AssertEqual(t, "quota", 0, r0["quota"])
|
tt.AssertEqual(t, "quota", 0, r0["quota"])
|
||||||
tt.AssertEqual(t, "quota_max", 50, r0["quota_max"])
|
tt.AssertEqual(t, "quota_max", 500, r0["quota_max"])
|
||||||
tt.AssertEqual(t, "is_pro", false, r0["is_pro"])
|
tt.AssertEqual(t, "is_pro", false, r0["is_pro"])
|
||||||
|
|
||||||
userid := int64(r0["user_id"].(float64))
|
userid := int64(r0["user_id"].(float64))
|
||||||
@@ -564,7 +565,7 @@ func TestCompatUpgrade(t *testing.T) {
|
|||||||
tt.AssertEqual(t, "success", true, r1["success"])
|
tt.AssertEqual(t, "success", true, r1["success"])
|
||||||
tt.AssertEqual(t, "message", "user updated", r1["message"])
|
tt.AssertEqual(t, "message", "user updated", r1["message"])
|
||||||
tt.AssertEqual(t, "quota", 0, r1["quota"])
|
tt.AssertEqual(t, "quota", 0, r1["quota"])
|
||||||
tt.AssertEqual(t, "quota_max", 5000, r1["quota_max"])
|
tt.AssertEqual(t, "quota_max", 15000, r1["quota_max"])
|
||||||
tt.AssertEqual(t, "is_pro", true, r1["is_pro"])
|
tt.AssertEqual(t, "is_pro", true, r1["is_pro"])
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,14 +1,15 @@
|
|||||||
package test
|
package test
|
||||||
|
|
||||||
import (
|
import (
|
||||||
ct "blackforestbytes.com/simplecloudnotifier/db/cursortoken"
|
|
||||||
"blackforestbytes.com/simplecloudnotifier/models"
|
|
||||||
tt "blackforestbytes.com/simplecloudnotifier/test/util"
|
|
||||||
"fmt"
|
"fmt"
|
||||||
"github.com/gin-gonic/gin"
|
|
||||||
"net/url"
|
"net/url"
|
||||||
"testing"
|
"testing"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
ct "blackforestbytes.com/simplecloudnotifier/db/cursortoken"
|
||||||
|
"blackforestbytes.com/simplecloudnotifier/models"
|
||||||
|
tt "blackforestbytes.com/simplecloudnotifier/test/util"
|
||||||
|
"github.com/gin-gonic/gin"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestRequestLogSimple(t *testing.T) {
|
func TestRequestLogSimple(t *testing.T) {
|
||||||
@@ -126,6 +127,8 @@ func TestRequestLogSimple(t *testing.T) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func TestRequestLogAPI(t *testing.T) {
|
func TestRequestLogAPI(t *testing.T) {
|
||||||
|
t.Skip("Flaky test - and kinda hacky")
|
||||||
|
|
||||||
ws, baseUrl, stop := tt.StartSimpleWebserver(t)
|
ws, baseUrl, stop := tt.StartSimpleWebserver(t)
|
||||||
defer stop()
|
defer stop()
|
||||||
|
|
||||||
|
|||||||
+30
-26
@@ -1159,6 +1159,8 @@ func TestSendToTooLongChannel(t *testing.T) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func TestQuotaExceededNoPro(t *testing.T) {
|
func TestQuotaExceededNoPro(t *testing.T) {
|
||||||
|
t.Skip("takes too long on server")
|
||||||
|
|
||||||
_, baseUrl, stop := tt.StartSimpleWebserver(t)
|
_, baseUrl, stop := tt.StartSimpleWebserver(t)
|
||||||
defer stop()
|
defer stop()
|
||||||
|
|
||||||
@@ -1174,8 +1176,8 @@ func TestQuotaExceededNoPro(t *testing.T) {
|
|||||||
sendtok := r0["send_key"].(string)
|
sendtok := r0["send_key"].(string)
|
||||||
|
|
||||||
tt.AssertStrRepEqual(t, "quota.0", 0, r0["quota_used"])
|
tt.AssertStrRepEqual(t, "quota.0", 0, r0["quota_used"])
|
||||||
tt.AssertStrRepEqual(t, "quota.0", 50, r0["quota_max"])
|
tt.AssertStrRepEqual(t, "quota.0", 500, r0["quota_max"])
|
||||||
tt.AssertStrRepEqual(t, "quota.0", 50, r0["quota_remaining"])
|
tt.AssertStrRepEqual(t, "quota.0", 500, r0["quota_remaining"])
|
||||||
|
|
||||||
{
|
{
|
||||||
msg1 := tt.RequestPost[gin.H](t, baseUrl, "/", gin.H{
|
msg1 := tt.RequestPost[gin.H](t, baseUrl, "/", gin.H{
|
||||||
@@ -1184,18 +1186,18 @@ func TestQuotaExceededNoPro(t *testing.T) {
|
|||||||
"title": tt.ShortLipsum0(2),
|
"title": tt.ShortLipsum0(2),
|
||||||
})
|
})
|
||||||
tt.AssertStrRepEqual(t, "quota.msg.1", 1, msg1["quota"])
|
tt.AssertStrRepEqual(t, "quota.msg.1", 1, msg1["quota"])
|
||||||
tt.AssertStrRepEqual(t, "quota.msg.1", 50, msg1["quota_max"])
|
tt.AssertStrRepEqual(t, "quota.msg.1", 500, msg1["quota_max"])
|
||||||
}
|
}
|
||||||
|
|
||||||
{
|
{
|
||||||
usr := tt.RequestAuthGet[gin.H](t, admintok, baseUrl, fmt.Sprintf("/api/v2/users/%s", uid))
|
usr := tt.RequestAuthGet[gin.H](t, admintok, baseUrl, fmt.Sprintf("/api/v2/users/%s", uid))
|
||||||
|
|
||||||
tt.AssertStrRepEqual(t, "quota.1", 1, usr["quota_used"])
|
tt.AssertStrRepEqual(t, "quota.1", 1, usr["quota_used"])
|
||||||
tt.AssertStrRepEqual(t, "quota.1", 50, usr["quota_max"])
|
tt.AssertStrRepEqual(t, "quota.1", 500, usr["quota_max"])
|
||||||
tt.AssertStrRepEqual(t, "quota.1", 49, usr["quota_remaining"])
|
tt.AssertStrRepEqual(t, "quota.1", 499, usr["quota_remaining"])
|
||||||
}
|
}
|
||||||
|
|
||||||
for i := 0; i < 48; i++ {
|
for i := 0; i < 498; i++ {
|
||||||
|
|
||||||
tt.RequestPost[gin.H](t, baseUrl, "/", gin.H{
|
tt.RequestPost[gin.H](t, baseUrl, "/", gin.H{
|
||||||
"key": sendtok,
|
"key": sendtok,
|
||||||
@@ -1207,24 +1209,24 @@ func TestQuotaExceededNoPro(t *testing.T) {
|
|||||||
{
|
{
|
||||||
usr := tt.RequestAuthGet[gin.H](t, admintok, baseUrl, fmt.Sprintf("/api/v2/users/%s", uid))
|
usr := tt.RequestAuthGet[gin.H](t, admintok, baseUrl, fmt.Sprintf("/api/v2/users/%s", uid))
|
||||||
|
|
||||||
tt.AssertStrRepEqual(t, "quota.49", 49, usr["quota_used"])
|
tt.AssertStrRepEqual(t, "quota.49", 499, usr["quota_used"])
|
||||||
tt.AssertStrRepEqual(t, "quota.49", 50, usr["quota_max"])
|
tt.AssertStrRepEqual(t, "quota.49", 500, usr["quota_max"])
|
||||||
tt.AssertStrRepEqual(t, "quota.49", 1, usr["quota_remaining"])
|
tt.AssertStrRepEqual(t, "quota.49", 1, usr["quota_remaining"])
|
||||||
}
|
}
|
||||||
|
|
||||||
msg50 := tt.RequestPost[gin.H](t, baseUrl, "/", gin.H{
|
msg500 := tt.RequestPost[gin.H](t, baseUrl, "/", gin.H{
|
||||||
"key": sendtok,
|
"key": sendtok,
|
||||||
"user_id": uid,
|
"user_id": uid,
|
||||||
"title": tt.ShortLipsum0(2),
|
"title": tt.ShortLipsum0(2),
|
||||||
})
|
})
|
||||||
tt.AssertStrRepEqual(t, "quota.msg.50", 50, msg50["quota"])
|
tt.AssertStrRepEqual(t, "quota.msg.50", 500, msg500["quota"])
|
||||||
tt.AssertStrRepEqual(t, "quota.msg.50", 50, msg50["quota_max"])
|
tt.AssertStrRepEqual(t, "quota.msg.50", 500, msg500["quota_max"])
|
||||||
|
|
||||||
{
|
{
|
||||||
usr := tt.RequestAuthGet[gin.H](t, admintok, baseUrl, fmt.Sprintf("/api/v2/users/%s", uid))
|
usr := tt.RequestAuthGet[gin.H](t, admintok, baseUrl, fmt.Sprintf("/api/v2/users/%s", uid))
|
||||||
|
|
||||||
tt.AssertStrRepEqual(t, "quota.50", 50, usr["quota_used"])
|
tt.AssertStrRepEqual(t, "quota.50", 500, usr["quota_used"])
|
||||||
tt.AssertStrRepEqual(t, "quota.50", 50, usr["quota_max"])
|
tt.AssertStrRepEqual(t, "quota.50", 500, usr["quota_max"])
|
||||||
tt.AssertStrRepEqual(t, "quota.50", 0, usr["quota_remaining"])
|
tt.AssertStrRepEqual(t, "quota.50", 0, usr["quota_remaining"])
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -1236,6 +1238,8 @@ func TestQuotaExceededNoPro(t *testing.T) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func TestQuotaExceededPro(t *testing.T) {
|
func TestQuotaExceededPro(t *testing.T) {
|
||||||
|
t.Skip("takes too long on server")
|
||||||
|
|
||||||
_, baseUrl, stop := tt.StartSimpleWebserver(t)
|
_, baseUrl, stop := tt.StartSimpleWebserver(t)
|
||||||
defer stop()
|
defer stop()
|
||||||
|
|
||||||
@@ -1252,8 +1256,8 @@ func TestQuotaExceededPro(t *testing.T) {
|
|||||||
sendtok := r0["send_key"].(string)
|
sendtok := r0["send_key"].(string)
|
||||||
|
|
||||||
tt.AssertStrRepEqual(t, "quota.0", 0, r0["quota_used"])
|
tt.AssertStrRepEqual(t, "quota.0", 0, r0["quota_used"])
|
||||||
tt.AssertStrRepEqual(t, "quota.0", 5000, r0["quota_max"])
|
tt.AssertStrRepEqual(t, "quota.0", 15000, r0["quota_max"])
|
||||||
tt.AssertStrRepEqual(t, "quota.0", 5000, r0["quota_remaining"])
|
tt.AssertStrRepEqual(t, "quota.0", 15000, r0["quota_remaining"])
|
||||||
|
|
||||||
{
|
{
|
||||||
msg1 := tt.RequestPost[gin.H](t, baseUrl, "/", gin.H{
|
msg1 := tt.RequestPost[gin.H](t, baseUrl, "/", gin.H{
|
||||||
@@ -1262,18 +1266,18 @@ func TestQuotaExceededPro(t *testing.T) {
|
|||||||
"title": tt.ShortLipsum0(2),
|
"title": tt.ShortLipsum0(2),
|
||||||
})
|
})
|
||||||
tt.AssertStrRepEqual(t, "quota.msg.1", 1, msg1["quota"])
|
tt.AssertStrRepEqual(t, "quota.msg.1", 1, msg1["quota"])
|
||||||
tt.AssertStrRepEqual(t, "quota.msg.1", 5000, msg1["quota_max"])
|
tt.AssertStrRepEqual(t, "quota.msg.1", 15000, msg1["quota_max"])
|
||||||
}
|
}
|
||||||
|
|
||||||
{
|
{
|
||||||
usr := tt.RequestAuthGet[gin.H](t, admintok, baseUrl, fmt.Sprintf("/api/v2/users/%s", uid))
|
usr := tt.RequestAuthGet[gin.H](t, admintok, baseUrl, fmt.Sprintf("/api/v2/users/%s", uid))
|
||||||
|
|
||||||
tt.AssertStrRepEqual(t, "quota.1", 1, usr["quota_used"])
|
tt.AssertStrRepEqual(t, "quota.1", 1, usr["quota_used"])
|
||||||
tt.AssertStrRepEqual(t, "quota.1", 5000, usr["quota_max"])
|
tt.AssertStrRepEqual(t, "quota.1", 15000, usr["quota_max"])
|
||||||
tt.AssertStrRepEqual(t, "quota.1", 4999, usr["quota_remaining"])
|
tt.AssertStrRepEqual(t, "quota.1", 14999, usr["quota_remaining"])
|
||||||
}
|
}
|
||||||
|
|
||||||
for i := 0; i < 4998; i++ {
|
for i := 0; i < 14998; i++ {
|
||||||
|
|
||||||
tt.RequestPost[gin.H](t, baseUrl, "/", gin.H{
|
tt.RequestPost[gin.H](t, baseUrl, "/", gin.H{
|
||||||
"key": sendtok,
|
"key": sendtok,
|
||||||
@@ -1285,9 +1289,9 @@ func TestQuotaExceededPro(t *testing.T) {
|
|||||||
{
|
{
|
||||||
usr := tt.RequestAuthGet[gin.H](t, admintok, baseUrl, fmt.Sprintf("/api/v2/users/%s", uid))
|
usr := tt.RequestAuthGet[gin.H](t, admintok, baseUrl, fmt.Sprintf("/api/v2/users/%s", uid))
|
||||||
|
|
||||||
tt.AssertStrRepEqual(t, "quota.999", 4999, usr["quota_used"])
|
tt.AssertStrRepEqual(t, "quota.14999", 14999, usr["quota_used"])
|
||||||
tt.AssertStrRepEqual(t, "quota.999", 5000, usr["quota_max"])
|
tt.AssertStrRepEqual(t, "quota.14999", 15000, usr["quota_max"])
|
||||||
tt.AssertStrRepEqual(t, "quota.999", 1, usr["quota_remaining"])
|
tt.AssertStrRepEqual(t, "quota.14999", 1, usr["quota_remaining"])
|
||||||
}
|
}
|
||||||
|
|
||||||
msg50 := tt.RequestPost[gin.H](t, baseUrl, "/", gin.H{
|
msg50 := tt.RequestPost[gin.H](t, baseUrl, "/", gin.H{
|
||||||
@@ -1295,14 +1299,14 @@ func TestQuotaExceededPro(t *testing.T) {
|
|||||||
"user_id": uid,
|
"user_id": uid,
|
||||||
"title": tt.ShortLipsum0(2),
|
"title": tt.ShortLipsum0(2),
|
||||||
})
|
})
|
||||||
tt.AssertStrRepEqual(t, "quota.msg.5000", 5000, msg50["quota"])
|
tt.AssertStrRepEqual(t, "quota.msg.5000", 15000, msg50["quota"])
|
||||||
tt.AssertStrRepEqual(t, "quota.msg.5000", 5000, msg50["quota_max"])
|
tt.AssertStrRepEqual(t, "quota.msg.5000", 15000, msg50["quota_max"])
|
||||||
|
|
||||||
{
|
{
|
||||||
usr := tt.RequestAuthGet[gin.H](t, admintok, baseUrl, fmt.Sprintf("/api/v2/users/%s", uid))
|
usr := tt.RequestAuthGet[gin.H](t, admintok, baseUrl, fmt.Sprintf("/api/v2/users/%s", uid))
|
||||||
|
|
||||||
tt.AssertStrRepEqual(t, "quota.5000", 5000, usr["quota_used"])
|
tt.AssertStrRepEqual(t, "quota.5000", 15000, usr["quota_used"])
|
||||||
tt.AssertStrRepEqual(t, "quota.5000", 5000, usr["quota_max"])
|
tt.AssertStrRepEqual(t, "quota.5000", 15000, usr["quota_max"])
|
||||||
tt.AssertStrRepEqual(t, "quota.5000", 0, usr["quota_remaining"])
|
tt.AssertStrRepEqual(t, "quota.5000", 0, usr["quota_remaining"])
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,11 +1,12 @@
|
|||||||
package test
|
package test
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"fmt"
|
||||||
|
"testing"
|
||||||
|
|
||||||
"blackforestbytes.com/simplecloudnotifier/api/apierr"
|
"blackforestbytes.com/simplecloudnotifier/api/apierr"
|
||||||
tt "blackforestbytes.com/simplecloudnotifier/test/util"
|
tt "blackforestbytes.com/simplecloudnotifier/test/util"
|
||||||
"fmt"
|
|
||||||
"github.com/gin-gonic/gin"
|
"github.com/gin-gonic/gin"
|
||||||
"testing"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestCreateUserNoClient(t *testing.T) {
|
func TestCreateUserNoClient(t *testing.T) {
|
||||||
@@ -451,8 +452,8 @@ func TestGetUserNoPro(t *testing.T) {
|
|||||||
tt.AssertEqual(t, "timestamp_lastsent", nil, r1["timestamp_lastsent"])
|
tt.AssertEqual(t, "timestamp_lastsent", nil, r1["timestamp_lastsent"])
|
||||||
tt.AssertEqual(t, "messages_sent", "0", fmt.Sprintf("%v", r1["messages_sent"]))
|
tt.AssertEqual(t, "messages_sent", "0", fmt.Sprintf("%v", r1["messages_sent"]))
|
||||||
tt.AssertEqual(t, "quota_used", "0", fmt.Sprintf("%v", r1["quota_used"]))
|
tt.AssertEqual(t, "quota_used", "0", fmt.Sprintf("%v", r1["quota_used"]))
|
||||||
tt.AssertEqual(t, "quota_remaining", "50", fmt.Sprintf("%v", r1["quota_remaining"]))
|
tt.AssertEqual(t, "quota_remaining", "500", fmt.Sprintf("%v", r1["quota_remaining"]))
|
||||||
tt.AssertEqual(t, "quota_max", "50", fmt.Sprintf("%v", r1["quota_max"]))
|
tt.AssertEqual(t, "quota_max", "500", fmt.Sprintf("%v", r1["quota_max"]))
|
||||||
tt.AssertEqual(t, "is_pro", "false", fmt.Sprintf("%v", r1["is_pro"]))
|
tt.AssertEqual(t, "is_pro", "false", fmt.Sprintf("%v", r1["is_pro"]))
|
||||||
tt.AssertEqual(t, "default_channel", "main", fmt.Sprintf("%v", r1["default_channel"]))
|
tt.AssertEqual(t, "default_channel", "main", fmt.Sprintf("%v", r1["default_channel"]))
|
||||||
tt.AssertEqual(t, "max_body_size", "2048", fmt.Sprintf("%v", r1["max_body_size"]))
|
tt.AssertEqual(t, "max_body_size", "2048", fmt.Sprintf("%v", r1["max_body_size"]))
|
||||||
@@ -485,8 +486,8 @@ func TestGetUserPro(t *testing.T) {
|
|||||||
tt.AssertEqual(t, "timestamp_lastsent", nil, r1["timestamp_lastsent"])
|
tt.AssertEqual(t, "timestamp_lastsent", nil, r1["timestamp_lastsent"])
|
||||||
tt.AssertEqual(t, "messages_sent", "0", fmt.Sprintf("%v", r1["messages_sent"]))
|
tt.AssertEqual(t, "messages_sent", "0", fmt.Sprintf("%v", r1["messages_sent"]))
|
||||||
tt.AssertEqual(t, "quota_used", "0", fmt.Sprintf("%v", r1["quota_used"]))
|
tt.AssertEqual(t, "quota_used", "0", fmt.Sprintf("%v", r1["quota_used"]))
|
||||||
tt.AssertEqual(t, "quota_remaining", "5000", fmt.Sprintf("%v", r1["quota_remaining"]))
|
tt.AssertEqual(t, "quota_remaining", "15000", fmt.Sprintf("%v", r1["quota_remaining"]))
|
||||||
tt.AssertEqual(t, "quota_max", "5000", fmt.Sprintf("%v", r1["quota_max"]))
|
tt.AssertEqual(t, "quota_max", "15000", fmt.Sprintf("%v", r1["quota_max"]))
|
||||||
tt.AssertEqual(t, "is_pro", "true", fmt.Sprintf("%v", r1["is_pro"]))
|
tt.AssertEqual(t, "is_pro", "true", fmt.Sprintf("%v", r1["is_pro"]))
|
||||||
tt.AssertEqual(t, "default_channel", "main", fmt.Sprintf("%v", r1["default_channel"]))
|
tt.AssertEqual(t, "default_channel", "main", fmt.Sprintf("%v", r1["default_channel"]))
|
||||||
tt.AssertEqual(t, "max_body_size", "2097152", fmt.Sprintf("%d", (int64)(r1["max_body_size"].(float64))))
|
tt.AssertEqual(t, "max_body_size", "2097152", fmt.Sprintf("%d", (int64)(r1["max_body_size"].(float64))))
|
||||||
|
|||||||
@@ -3,13 +3,14 @@ package util
|
|||||||
import (
|
import (
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"fmt"
|
"fmt"
|
||||||
"git.blackforestbytes.com/BlackForestBytes/goext/langext"
|
|
||||||
"github.com/gin-gonic/gin"
|
|
||||||
"math"
|
"math"
|
||||||
"reflect"
|
"reflect"
|
||||||
"runtime/debug"
|
"runtime/debug"
|
||||||
"strings"
|
"strings"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
|
"git.blackforestbytes.com/BlackForestBytes/goext/langext"
|
||||||
|
"github.com/gin-gonic/gin"
|
||||||
)
|
)
|
||||||
|
|
||||||
func AssertJsonMapEqual(t *testing.T, key string, expected map[string]any, actual map[string]any) {
|
func AssertJsonMapEqual(t *testing.T, key string, expected map[string]any, actual map[string]any) {
|
||||||
@@ -36,6 +37,7 @@ func AssertJsonMapEqual(t *testing.T, key string, expected map[string]any, actua
|
|||||||
}
|
}
|
||||||
|
|
||||||
func AssertEqual(t *testing.T, key string, expected any, actual any) {
|
func AssertEqual(t *testing.T, key string, expected any, actual any) {
|
||||||
|
t.Helper()
|
||||||
|
|
||||||
// try to fix types, kinda hacky, but its only unit tests...
|
// try to fix types, kinda hacky, but its only unit tests...
|
||||||
switch vex := expected.(type) {
|
switch vex := expected.(type) {
|
||||||
|
|||||||
@@ -21,6 +21,9 @@ export interface ChannelPreview {
|
|||||||
owner_user_id: string;
|
owner_user_id: string;
|
||||||
internal_name: string;
|
internal_name: string;
|
||||||
display_name: string;
|
display_name: string;
|
||||||
|
description_name: string | null;
|
||||||
|
messages_sent: number;
|
||||||
|
subscription: Subscription | null;
|
||||||
}
|
}
|
||||||
|
|
||||||
export type ChannelSelector = 'owned' | 'subscribed' | 'all' | 'subscribed_any' | 'all_any';
|
export type ChannelSelector = 'owned' | 'subscribed' | 'all' | 'subscribed_any' | 'all_any';
|
||||||
|
|||||||
@@ -1,3 +1,5 @@
|
|||||||
|
import { UserPreview } from "./user.model";
|
||||||
|
|
||||||
export type ClientType = 'ANDROID' | 'IOS' | 'LINUX' | 'MACOS' | 'WINDOWS';
|
export type ClientType = 'ANDROID' | 'IOS' | 'LINUX' | 'MACOS' | 'WINDOWS';
|
||||||
|
|
||||||
export interface Client {
|
export interface Client {
|
||||||
@@ -15,6 +17,21 @@ export interface ClientListResponse {
|
|||||||
clients: Client[];
|
clients: Client[];
|
||||||
}
|
}
|
||||||
|
|
||||||
|
export interface ClientPreview {
|
||||||
|
client_id: string;
|
||||||
|
user_id: string;
|
||||||
|
name: string | null;
|
||||||
|
type: ClientType;
|
||||||
|
timestamp_created: string;
|
||||||
|
agent_model: string;
|
||||||
|
agent_version: string;
|
||||||
|
}
|
||||||
|
|
||||||
|
export interface ClientPreviewResponse {
|
||||||
|
user: UserPreview;
|
||||||
|
client: ClientPreview;
|
||||||
|
}
|
||||||
|
|
||||||
export function getClientTypeIcon(type: ClientType): string {
|
export function getClientTypeIcon(type: ClientType): string {
|
||||||
switch (type) {
|
switch (type) {
|
||||||
case 'ANDROID':
|
case 'ANDROID':
|
||||||
|
|||||||
@@ -14,6 +14,10 @@ export interface KeyToken {
|
|||||||
export interface KeyTokenPreview {
|
export interface KeyTokenPreview {
|
||||||
keytoken_id: string;
|
keytoken_id: string;
|
||||||
name: string;
|
name: string;
|
||||||
|
owner_user_id: string;
|
||||||
|
all_channels: boolean;
|
||||||
|
channels: string[];
|
||||||
|
permissions: string;
|
||||||
}
|
}
|
||||||
|
|
||||||
export type TokenPermission = 'A' | 'CR' | 'CS' | 'UR';
|
export type TokenPermission = 'A' | 'CR' | 'CS' | 'UR';
|
||||||
|
|||||||
@@ -6,6 +6,8 @@ import {
|
|||||||
User,
|
User,
|
||||||
UserWithExtra,
|
UserWithExtra,
|
||||||
UserPreview,
|
UserPreview,
|
||||||
|
ChannelPreview,
|
||||||
|
KeyTokenPreview,
|
||||||
Message,
|
Message,
|
||||||
MessageListParams,
|
MessageListParams,
|
||||||
MessageListResponse,
|
MessageListResponse,
|
||||||
@@ -26,6 +28,7 @@ import {
|
|||||||
UpdateKeyRequest,
|
UpdateKeyRequest,
|
||||||
Client,
|
Client,
|
||||||
ClientListResponse,
|
ClientListResponse,
|
||||||
|
ClientPreviewResponse,
|
||||||
SenderNameStatistics,
|
SenderNameStatistics,
|
||||||
SenderNameListResponse,
|
SenderNameListResponse,
|
||||||
DeliveryListResponse,
|
DeliveryListResponse,
|
||||||
@@ -93,6 +96,18 @@ export class ApiService {
|
|||||||
return this.http.delete<Client>(`${this.baseUrl}/users/${userId}/clients/${clientId}`);
|
return this.http.delete<Client>(`${this.baseUrl}/users/${userId}/clients/${clientId}`);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
getClientPreview(clientId: string): Observable<ClientPreviewResponse> {
|
||||||
|
return this.http.get<ClientPreviewResponse>(`${this.baseUrl}/preview/clients/${clientId}`);
|
||||||
|
}
|
||||||
|
|
||||||
|
getChannelPreview(channelId: string): Observable<ChannelPreview> {
|
||||||
|
return this.http.get<ChannelPreview>(`${this.baseUrl}/preview/channels/${channelId}`);
|
||||||
|
}
|
||||||
|
|
||||||
|
getKeyPreview(keyId: string): Observable<KeyTokenPreview> {
|
||||||
|
return this.http.get<KeyTokenPreview>(`${this.baseUrl}/preview/keys/${keyId}`);
|
||||||
|
}
|
||||||
|
|
||||||
// Channel endpoints
|
// Channel endpoints
|
||||||
getChannels(userId: string, selector?: ChannelSelector): Observable<ChannelListResponse> {
|
getChannels(userId: string, selector?: ChannelSelector): Observable<ChannelListResponse> {
|
||||||
let params = new HttpParams();
|
let params = new HttpParams();
|
||||||
|
|||||||
@@ -0,0 +1,41 @@
|
|||||||
|
import { Injectable, inject } from '@angular/core';
|
||||||
|
import { Observable, of, catchError, map, shareReplay } from 'rxjs';
|
||||||
|
import { ApiService } from './api.service';
|
||||||
|
import { ClientPreview, UserPreview } from '../models';
|
||||||
|
|
||||||
|
export interface ResolvedClient {
|
||||||
|
clientId: string;
|
||||||
|
clientName: string | null;
|
||||||
|
userId: string;
|
||||||
|
userName: string | null;
|
||||||
|
agentModel: string;
|
||||||
|
agentVersion: string;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Injectable({
|
||||||
|
providedIn: 'root'
|
||||||
|
})
|
||||||
|
export class ClientCacheService {
|
||||||
|
private apiService = inject(ApiService);
|
||||||
|
|
||||||
|
private cache = new Map<string, Observable<{client: ClientPreview, user: UserPreview} | null>>();
|
||||||
|
|
||||||
|
resolveClient(clientId: string): Observable<{client: ClientPreview, user: UserPreview} | null> {
|
||||||
|
if (!this.cache.has(clientId)) {
|
||||||
|
const request$ = this.apiService.getClientPreview(clientId).pipe(
|
||||||
|
map(response => ({
|
||||||
|
client: response.client,
|
||||||
|
user: response.user
|
||||||
|
})),
|
||||||
|
catchError(() => of(null)),
|
||||||
|
shareReplay(1)
|
||||||
|
);
|
||||||
|
this.cache.set(clientId, request$);
|
||||||
|
}
|
||||||
|
return this.cache.get(clientId)!;
|
||||||
|
}
|
||||||
|
|
||||||
|
clearCache(): void {
|
||||||
|
this.cache.clear();
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -3,7 +3,7 @@
|
|||||||
<div class="loading-container">
|
<div class="loading-container">
|
||||||
<nz-spin nzSimple nzSize="large"></nz-spin>
|
<nz-spin nzSimple nzSize="large"></nz-spin>
|
||||||
</div>
|
</div>
|
||||||
} @else if (channel()) {
|
} @else if (channelData()) {
|
||||||
<div class="detail-header">
|
<div class="detail-header">
|
||||||
<button nz-button (click)="goBack()">
|
<button nz-button (click)="goBack()">
|
||||||
<span nz-icon nzType="arrow-left" nzTheme="outline"></span>
|
<span nz-icon nzType="arrow-left" nzTheme="outline"></span>
|
||||||
@@ -32,13 +32,13 @@
|
|||||||
}
|
}
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<nz-card [nzTitle]="channel()!.display_name">
|
<nz-card [nzTitle]="channelData()!.display_name">
|
||||||
<scn-metadata-grid>
|
<scn-metadata-grid>
|
||||||
<scn-metadata-value label="Channel ID">
|
<scn-metadata-value label="Channel ID">
|
||||||
<span class="mono">{{ channel()!.channel_id }}</span>
|
<span class="mono">{{ channelData()!.channel_id }}</span>
|
||||||
</scn-metadata-value>
|
</scn-metadata-value>
|
||||||
<scn-metadata-value label="Internal Name">
|
<scn-metadata-value label="Internal Name">
|
||||||
<span class="mono">{{ channel()!.internal_name }}</span>
|
<span class="mono">{{ channelData()!.internal_name }}</span>
|
||||||
</scn-metadata-value>
|
</scn-metadata-value>
|
||||||
<scn-metadata-value label="Status">
|
<scn-metadata-value label="Status">
|
||||||
<nz-tag [nzColor]="getSubscriptionStatus().color">
|
<nz-tag [nzColor]="getSubscriptionStatus().color">
|
||||||
@@ -46,29 +46,36 @@
|
|||||||
</nz-tag>
|
</nz-tag>
|
||||||
</scn-metadata-value>
|
</scn-metadata-value>
|
||||||
<scn-metadata-value label="Owner">
|
<scn-metadata-value label="Owner">
|
||||||
<span class="mono">{{ channel()!.owner_user_id }}</span>
|
@if (resolvedOwner()) {
|
||||||
|
<div class="owner-name">{{ resolvedOwner()!.displayName }}</div>
|
||||||
|
<div class="owner-id mono">{{ channelData()!.owner_user_id }}</div>
|
||||||
|
} @else {
|
||||||
|
<span class="mono">{{ channelData()!.owner_user_id }}</span>
|
||||||
|
}
|
||||||
</scn-metadata-value>
|
</scn-metadata-value>
|
||||||
@if (channel()!.description_name) {
|
@if (channelData()!.description_name) {
|
||||||
<scn-metadata-value label="Description">
|
<scn-metadata-value label="Description">
|
||||||
{{ channel()!.description_name }}
|
{{ channelData()!.description_name }}
|
||||||
</scn-metadata-value>
|
</scn-metadata-value>
|
||||||
}
|
}
|
||||||
<scn-metadata-value label="Messages Sent">
|
<scn-metadata-value label="Messages Sent">
|
||||||
{{ channel()!.messages_sent }}
|
{{ channelData()!.messages_sent }}
|
||||||
</scn-metadata-value>
|
</scn-metadata-value>
|
||||||
<scn-metadata-value label="Last Sent">
|
@if (channel()) {
|
||||||
@if (channel()!.timestamp_lastsent) {
|
<scn-metadata-value label="Last Sent">
|
||||||
<div class="timestamp-absolute">{{ channel()!.timestamp_lastsent | date:'yyyy-MM-dd HH:mm:ss' }}</div>
|
@if (channel()!.timestamp_lastsent) {
|
||||||
<div class="timestamp-relative">{{ channel()!.timestamp_lastsent | relativeTime }}</div>
|
<div class="timestamp-absolute">{{ channel()!.timestamp_lastsent | date:'yyyy-MM-dd HH:mm:ss' }}</div>
|
||||||
} @else {
|
<div class="timestamp-relative">{{ channel()!.timestamp_lastsent | relativeTime }}</div>
|
||||||
Never
|
} @else {
|
||||||
}
|
Never
|
||||||
</scn-metadata-value>
|
}
|
||||||
<scn-metadata-value label="Created">
|
</scn-metadata-value>
|
||||||
<div class="timestamp-absolute">{{ channel()!.timestamp_created | date:'yyyy-MM-dd HH:mm:ss' }}</div>
|
<scn-metadata-value label="Created">
|
||||||
<div class="timestamp-relative">{{ channel()!.timestamp_created | relativeTime }}</div>
|
<div class="timestamp-absolute">{{ channel()!.timestamp_created | date:'yyyy-MM-dd HH:mm:ss' }}</div>
|
||||||
</scn-metadata-value>
|
<div class="timestamp-relative">{{ channel()!.timestamp_created | relativeTime }}</div>
|
||||||
@if (isOwner() && channel()!.subscribe_key) {
|
</scn-metadata-value>
|
||||||
|
}
|
||||||
|
@if (isOwner() && channel()?.subscribe_key) {
|
||||||
<scn-metadata-value label="Subscribe Key">
|
<scn-metadata-value label="Subscribe Key">
|
||||||
<div class="key-field">
|
<div class="key-field">
|
||||||
<nz-input-group [nzSuffix]="subscribeKeySuffix">
|
<nz-input-group [nzSuffix]="subscribeKeySuffix">
|
||||||
|
|||||||
@@ -109,6 +109,17 @@
|
|||||||
overflow-y: clip;
|
overflow-y: clip;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
.owner-name {
|
||||||
|
font-weight: 500;
|
||||||
|
color: #333;
|
||||||
|
}
|
||||||
|
|
||||||
|
.owner-id {
|
||||||
|
font-size: 11px;
|
||||||
|
color: #999;
|
||||||
|
margin-top: 2px;
|
||||||
|
}
|
||||||
|
|
||||||
.text-muted {
|
.text-muted {
|
||||||
color: #999;
|
color: #999;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -21,7 +21,7 @@ import { AuthService } from '../../../core/services/auth.service';
|
|||||||
import { NotificationService } from '../../../core/services/notification.service';
|
import { NotificationService } from '../../../core/services/notification.service';
|
||||||
import { SettingsService } from '../../../core/services/settings.service';
|
import { SettingsService } from '../../../core/services/settings.service';
|
||||||
import { UserCacheService, ResolvedUser } from '../../../core/services/user-cache.service';
|
import { UserCacheService, ResolvedUser } from '../../../core/services/user-cache.service';
|
||||||
import { ChannelWithSubscription, Subscription, Message } from '../../../core/models';
|
import { ChannelWithSubscription, ChannelPreview, Subscription, Message } from '../../../core/models';
|
||||||
import { RelativeTimePipe } from '../../../shared/pipes/relative-time.pipe';
|
import { RelativeTimePipe } from '../../../shared/pipes/relative-time.pipe';
|
||||||
import { CopyToClipboardDirective } from '../../../shared/directives/copy-to-clipboard.directive';
|
import { CopyToClipboardDirective } from '../../../shared/directives/copy-to-clipboard.directive';
|
||||||
import { QrCodeDisplayComponent } from '../../../shared/components/qr-code-display/qr-code-display.component';
|
import { QrCodeDisplayComponent } from '../../../shared/components/qr-code-display/qr-code-display.component';
|
||||||
@@ -68,9 +68,11 @@ export class ChannelDetailComponent implements OnInit {
|
|||||||
private userCacheService = inject(UserCacheService);
|
private userCacheService = inject(UserCacheService);
|
||||||
|
|
||||||
channel = signal<ChannelWithSubscription | null>(null);
|
channel = signal<ChannelWithSubscription | null>(null);
|
||||||
|
channelPreview = signal<ChannelPreview | null>(null);
|
||||||
subscriptions = signal<Subscription[]>([]);
|
subscriptions = signal<Subscription[]>([]);
|
||||||
messages = signal<Message[]>([]);
|
messages = signal<Message[]>([]);
|
||||||
userNames = signal<Map<string, ResolvedUser>>(new Map());
|
userNames = signal<Map<string, ResolvedUser>>(new Map());
|
||||||
|
resolvedOwner = signal<ResolvedUser | null>(null);
|
||||||
loading = signal(true);
|
loading = signal(true);
|
||||||
loadingSubscriptions = signal(false);
|
loadingSubscriptions = signal(false);
|
||||||
loadingMessages = signal(false);
|
loadingMessages = signal(false);
|
||||||
@@ -115,14 +117,26 @@ export class ChannelDetailComponent implements OnInit {
|
|||||||
if (!userId) return;
|
if (!userId) return;
|
||||||
|
|
||||||
this.loading.set(true);
|
this.loading.set(true);
|
||||||
this.apiService.getChannel(userId, channelId).subscribe({
|
this.apiService.getChannelPreview(channelId).subscribe({
|
||||||
next: (channel) => {
|
next: (preview) => {
|
||||||
this.channel.set(channel);
|
this.channelPreview.set(preview);
|
||||||
this.loading.set(false);
|
this.resolveOwner(preview.owner_user_id);
|
||||||
if (this.isOwner()) {
|
if (preview.owner_user_id === userId) {
|
||||||
this.loadSubscriptions(channelId);
|
this.apiService.getChannel(userId, channelId).subscribe({
|
||||||
|
next: (channel) => {
|
||||||
|
this.channel.set(channel);
|
||||||
|
this.loading.set(false);
|
||||||
|
this.loadSubscriptions(channelId);
|
||||||
|
this.loadMessages(channelId);
|
||||||
|
},
|
||||||
|
error: () => {
|
||||||
|
this.loading.set(false);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
} else {
|
||||||
|
this.loading.set(false);
|
||||||
|
this.loadMessages(channelId);
|
||||||
}
|
}
|
||||||
this.loadMessages(channelId);
|
|
||||||
},
|
},
|
||||||
error: () => {
|
error: () => {
|
||||||
this.loading.set(false);
|
this.loading.set(false);
|
||||||
@@ -148,14 +162,13 @@ export class ChannelDetailComponent implements OnInit {
|
|||||||
}
|
}
|
||||||
|
|
||||||
loadMessages(channelId: string, nextPageToken?: string): void {
|
loadMessages(channelId: string, nextPageToken?: string): void {
|
||||||
const userId = this.authService.getUserId();
|
|
||||||
if (!userId) return;
|
|
||||||
|
|
||||||
this.loadingMessages.set(true);
|
this.loadingMessages.set(true);
|
||||||
this.apiService.getChannelMessages(userId, channelId, {
|
this.apiService.getMessages({
|
||||||
|
channel_id: [channelId],
|
||||||
page_size: this.messagesPageSize,
|
page_size: this.messagesPageSize,
|
||||||
next_page_token: nextPageToken,
|
next_page_token: nextPageToken,
|
||||||
trimmed: true
|
trimmed: true,
|
||||||
|
subscription_status: 'all'
|
||||||
}).subscribe({
|
}).subscribe({
|
||||||
next: (response) => {
|
next: (response) => {
|
||||||
this.messages.set(response.messages);
|
this.messages.set(response.messages);
|
||||||
@@ -210,6 +223,12 @@ export class ChannelDetailComponent implements OnInit {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private resolveOwner(ownerId: string): void {
|
||||||
|
this.userCacheService.resolveUser(ownerId).subscribe(resolved => {
|
||||||
|
this.resolvedOwner.set(resolved);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
private resolveUserNames(subscriptions: Subscription[]): void {
|
private resolveUserNames(subscriptions: Subscription[]): void {
|
||||||
const userIds = new Set<string>();
|
const userIds = new Set<string>();
|
||||||
for (const sub of subscriptions) {
|
for (const sub of subscriptions) {
|
||||||
@@ -232,9 +251,16 @@ export class ChannelDetailComponent implements OnInit {
|
|||||||
}
|
}
|
||||||
|
|
||||||
isOwner(): boolean {
|
isOwner(): boolean {
|
||||||
const channel = this.channel();
|
|
||||||
const userId = this.authService.getUserId();
|
const userId = this.authService.getUserId();
|
||||||
return channel?.owner_user_id === userId;
|
const channel = this.channel();
|
||||||
|
if (channel) return channel.owner_user_id === userId;
|
||||||
|
const preview = this.channelPreview();
|
||||||
|
if (preview) return preview.owner_user_id === userId;
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
channelData() {
|
||||||
|
return this.channel() ?? this.channelPreview();
|
||||||
}
|
}
|
||||||
|
|
||||||
// Edit methods
|
// Edit methods
|
||||||
@@ -290,18 +316,20 @@ export class ChannelDetailComponent implements OnInit {
|
|||||||
}
|
}
|
||||||
|
|
||||||
getSubscriptionStatus(): { label: string; color: string } {
|
getSubscriptionStatus(): { label: string; color: string } {
|
||||||
const channel = this.channel();
|
const data = this.channelData();
|
||||||
if (!channel) return { label: 'Unknown', color: 'default' };
|
if (!data) return { label: 'Unknown', color: 'default' };
|
||||||
|
|
||||||
|
const subscription = 'subscribe_key' in data ? data.subscription : data.subscription;
|
||||||
|
|
||||||
if (this.isOwner()) {
|
if (this.isOwner()) {
|
||||||
if (channel.subscription) {
|
if (subscription) {
|
||||||
return { label: 'Owned & Subscribed', color: 'green' };
|
return { label: 'Owned & Subscribed', color: 'green' };
|
||||||
}
|
}
|
||||||
return { label: 'Owned', color: 'blue' };
|
return { label: 'Owned', color: 'blue' };
|
||||||
}
|
}
|
||||||
|
|
||||||
if (channel.subscription) {
|
if (subscription) {
|
||||||
if (channel.subscription.confirmed) {
|
if (subscription.confirmed) {
|
||||||
return { label: 'Subscribed', color: 'green' };
|
return { label: 'Subscribed', color: 'green' };
|
||||||
}
|
}
|
||||||
return { label: 'Pending', color: 'orange' };
|
return { label: 'Pending', color: 'orange' };
|
||||||
@@ -377,7 +405,7 @@ export class ChannelDetailComponent implements OnInit {
|
|||||||
}
|
}
|
||||||
|
|
||||||
isUserSubscribed(): boolean {
|
isUserSubscribed(): boolean {
|
||||||
return this.channel()?.subscription !== null;
|
return this.channelData()?.subscription !== null && this.channelData()?.subscription !== undefined;
|
||||||
}
|
}
|
||||||
|
|
||||||
toggleSelfSubscription(): void {
|
toggleSelfSubscription(): void {
|
||||||
|
|||||||
@@ -50,50 +50,30 @@
|
|||||||
</thead>
|
</thead>
|
||||||
<tbody>
|
<tbody>
|
||||||
@for (channel of channels(); track channel.channel_id) {
|
@for (channel of channels(); track channel.channel_id) {
|
||||||
<tr [class.clickable-row]="isOwned(channel)">
|
<tr class="clickable-row">
|
||||||
<td>
|
<td>
|
||||||
@if (isOwned(channel)) {
|
<a class="cell-link" [routerLink]="['/channels', channel.channel_id]">
|
||||||
<a class="cell-link" [routerLink]="['/channels', channel.channel_id]">
|
|
||||||
<div class="channel-name">{{ channel.display_name }}</div>
|
|
||||||
<div class="channel-id mono">{{ channel.channel_id }}</div>
|
|
||||||
</a>
|
|
||||||
} @else {
|
|
||||||
<div class="channel-name">{{ channel.display_name }}</div>
|
<div class="channel-name">{{ channel.display_name }}</div>
|
||||||
<div class="channel-id mono">{{ channel.channel_id }}</div>
|
<div class="channel-id mono">{{ channel.channel_id }}</div>
|
||||||
}
|
</a>
|
||||||
</td>
|
</td>
|
||||||
<td>
|
<td>
|
||||||
@if (isOwned(channel)) {
|
<a class="cell-link" [routerLink]="['/channels', channel.channel_id]">
|
||||||
<a class="cell-link" [routerLink]="['/channels', channel.channel_id]">
|
|
||||||
<span class="mono">{{ channel.internal_name }}</span>
|
|
||||||
</a>
|
|
||||||
} @else {
|
|
||||||
<span class="mono">{{ channel.internal_name }}</span>
|
<span class="mono">{{ channel.internal_name }}</span>
|
||||||
}
|
</a>
|
||||||
</td>
|
</td>
|
||||||
<td>
|
<td>
|
||||||
@if (isOwned(channel)) {
|
<a class="cell-link" [routerLink]="['/channels', channel.channel_id]">
|
||||||
<a class="cell-link" [routerLink]="['/channels', channel.channel_id]">
|
|
||||||
<div class="channel-name">{{ getOwnerDisplayName(channel.owner_user_id) }}</div>
|
|
||||||
<div class="channel-id mono">{{ channel.owner_user_id }}</div>
|
|
||||||
</a>
|
|
||||||
} @else {
|
|
||||||
<div class="channel-name">{{ getOwnerDisplayName(channel.owner_user_id) }}</div>
|
<div class="channel-name">{{ getOwnerDisplayName(channel.owner_user_id) }}</div>
|
||||||
<div class="channel-id mono">{{ channel.owner_user_id }}</div>
|
<div class="channel-id mono">{{ channel.owner_user_id }}</div>
|
||||||
}
|
</a>
|
||||||
</td>
|
</td>
|
||||||
<td>
|
<td>
|
||||||
@if (isOwned(channel)) {
|
<a class="cell-link" [routerLink]="['/channels', channel.channel_id]">
|
||||||
<a class="cell-link" [routerLink]="['/channels', channel.channel_id]">
|
|
||||||
<nz-tag [nzColor]="getSubscriptionStatus(channel).color">
|
|
||||||
{{ getSubscriptionStatus(channel).label }}
|
|
||||||
</nz-tag>
|
|
||||||
</a>
|
|
||||||
} @else {
|
|
||||||
<nz-tag [nzColor]="getSubscriptionStatus(channel).color">
|
<nz-tag [nzColor]="getSubscriptionStatus(channel).color">
|
||||||
{{ getSubscriptionStatus(channel).label }}
|
{{ getSubscriptionStatus(channel).label }}
|
||||||
</nz-tag>
|
</nz-tag>
|
||||||
}
|
</a>
|
||||||
</td>
|
</td>
|
||||||
<td>
|
<td>
|
||||||
@if (isOwned(channel)) {
|
@if (isOwned(channel)) {
|
||||||
@@ -105,32 +85,19 @@
|
|||||||
}
|
}
|
||||||
</td>
|
</td>
|
||||||
<td>
|
<td>
|
||||||
@if (isOwned(channel)) {
|
<a class="cell-link" [routerLink]="['/channels', channel.channel_id]">
|
||||||
<a class="cell-link" [routerLink]="['/channels', channel.channel_id]">
|
|
||||||
{{ channel.messages_sent }}
|
|
||||||
</a>
|
|
||||||
} @else {
|
|
||||||
{{ channel.messages_sent }}
|
{{ channel.messages_sent }}
|
||||||
}
|
</a>
|
||||||
</td>
|
</td>
|
||||||
<td>
|
<td>
|
||||||
@if (isOwned(channel)) {
|
<a class="cell-link" [routerLink]="['/channels', channel.channel_id]">
|
||||||
<a class="cell-link" [routerLink]="['/channels', channel.channel_id]">
|
|
||||||
@if (channel.timestamp_lastsent) {
|
|
||||||
<div class="timestamp-absolute">{{ channel.timestamp_lastsent | date:'yyyy-MM-dd HH:mm:ss' }}</div>
|
|
||||||
<div class="timestamp-relative">{{ channel.timestamp_lastsent | relativeTime }}</div>
|
|
||||||
} @else {
|
|
||||||
<span class="text-muted">Never</span>
|
|
||||||
}
|
|
||||||
</a>
|
|
||||||
} @else {
|
|
||||||
@if (channel.timestamp_lastsent) {
|
@if (channel.timestamp_lastsent) {
|
||||||
<div class="timestamp-absolute">{{ channel.timestamp_lastsent | date:'yyyy-MM-dd HH:mm:ss' }}</div>
|
<div class="timestamp-absolute">{{ channel.timestamp_lastsent | date:'yyyy-MM-dd HH:mm:ss' }}</div>
|
||||||
<div class="timestamp-relative">{{ channel.timestamp_lastsent | relativeTime }}</div>
|
<div class="timestamp-relative">{{ channel.timestamp_lastsent | relativeTime }}</div>
|
||||||
} @else {
|
} @else {
|
||||||
<span class="text-muted">Never</span>
|
<span class="text-muted">Never</span>
|
||||||
}
|
}
|
||||||
}
|
</a>
|
||||||
</td>
|
</td>
|
||||||
@if (expertMode()) {
|
@if (expertMode()) {
|
||||||
<td>
|
<td>
|
||||||
|
|||||||
@@ -3,13 +3,13 @@
|
|||||||
<div class="loading-container">
|
<div class="loading-container">
|
||||||
<nz-spin nzSimple nzSize="large"></nz-spin>
|
<nz-spin nzSimple nzSize="large"></nz-spin>
|
||||||
</div>
|
</div>
|
||||||
} @else if (client()) {
|
} @else if (clientData()) {
|
||||||
<div class="detail-header">
|
<div class="detail-header">
|
||||||
<button nz-button (click)="goBack()">
|
<button nz-button (click)="goBack()">
|
||||||
<span nz-icon nzType="arrow-left" nzTheme="outline"></span>
|
<span nz-icon nzType="arrow-left" nzTheme="outline"></span>
|
||||||
Back to Clients
|
Back to Clients
|
||||||
</button>
|
</button>
|
||||||
@if (expertMode()) {
|
@if (isOwner() && expertMode()) {
|
||||||
<div class="header-actions">
|
<div class="header-actions">
|
||||||
<button
|
<button
|
||||||
nz-button
|
nz-button
|
||||||
@@ -29,36 +29,38 @@
|
|||||||
<div class="client-header">
|
<div class="client-header">
|
||||||
<span
|
<span
|
||||||
nz-icon
|
nz-icon
|
||||||
[nzType]="getClientIcon(client()!.type)"
|
[nzType]="getClientIcon(clientData()!.type)"
|
||||||
nzTheme="outline"
|
nzTheme="outline"
|
||||||
class="client-type-icon"
|
class="client-type-icon"
|
||||||
></span>
|
></span>
|
||||||
<h2 class="client-title">{{ client()!.name || 'Unnamed Client' }}</h2>
|
<h2 class="client-title">{{ clientData()!.name || 'Unnamed Client' }}</h2>
|
||||||
<nz-tag>{{ getClientTypeLabel(client()!.type) }}</nz-tag>
|
<nz-tag>{{ getClientTypeLabel(clientData()!.type) }}</nz-tag>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<scn-metadata-grid>
|
<scn-metadata-grid>
|
||||||
<scn-metadata-value label="Client ID">
|
<scn-metadata-value label="Client ID">
|
||||||
<span class="mono">{{ client()!.client_id }}</span>
|
<span class="mono">{{ clientData()!.client_id }}</span>
|
||||||
</scn-metadata-value>
|
</scn-metadata-value>
|
||||||
<scn-metadata-value label="Type">
|
<scn-metadata-value label="Type">
|
||||||
<nz-tag>{{ getClientTypeLabel(client()!.type) }}</nz-tag>
|
<nz-tag>{{ getClientTypeLabel(clientData()!.type) }}</nz-tag>
|
||||||
</scn-metadata-value>
|
</scn-metadata-value>
|
||||||
<scn-metadata-value label="Agent">
|
<scn-metadata-value label="Agent">
|
||||||
<div class="agent-info">
|
<div class="agent-info">
|
||||||
<span>{{ client()!.agent_model }}</span>
|
<span>{{ clientData()!.agent_model }}</span>
|
||||||
<span class="agent-version">v{{ client()!.agent_version }}</span>
|
<span class="agent-version">v{{ clientData()!.agent_version }}</span>
|
||||||
</div>
|
</div>
|
||||||
</scn-metadata-value>
|
</scn-metadata-value>
|
||||||
<scn-metadata-value label="Created">
|
<scn-metadata-value label="Created">
|
||||||
<div class="timestamp-absolute">{{ client()!.timestamp_created | date:'yyyy-MM-dd HH:mm:ss' }}</div>
|
<div class="timestamp-absolute">{{ clientData()!.timestamp_created | date:'yyyy-MM-dd HH:mm:ss' }}</div>
|
||||||
<div class="timestamp-relative">{{ client()!.timestamp_created | relativeTime }}</div>
|
<div class="timestamp-relative">{{ clientData()!.timestamp_created | relativeTime }}</div>
|
||||||
</scn-metadata-value>
|
|
||||||
<scn-metadata-value label="FCM Token">
|
|
||||||
<span class="mono fcm-token" nz-tooltip [nzTooltipTitle]="client()!.fcm_token">
|
|
||||||
{{ client()!.fcm_token }}
|
|
||||||
</span>
|
|
||||||
</scn-metadata-value>
|
</scn-metadata-value>
|
||||||
|
@if (client()) {
|
||||||
|
<scn-metadata-value label="FCM Token">
|
||||||
|
<span class="mono fcm-token" nz-tooltip [nzTooltipTitle]="client()!.fcm_token">
|
||||||
|
{{ client()!.fcm_token }}
|
||||||
|
</span>
|
||||||
|
</scn-metadata-value>
|
||||||
|
}
|
||||||
</scn-metadata-grid>
|
</scn-metadata-grid>
|
||||||
</nz-card>
|
</nz-card>
|
||||||
} @else {
|
} @else {
|
||||||
|
|||||||
@@ -12,7 +12,7 @@ import { ApiService } from '../../../core/services/api.service';
|
|||||||
import { AuthService } from '../../../core/services/auth.service';
|
import { AuthService } from '../../../core/services/auth.service';
|
||||||
import { NotificationService } from '../../../core/services/notification.service';
|
import { NotificationService } from '../../../core/services/notification.service';
|
||||||
import { SettingsService } from '../../../core/services/settings.service';
|
import { SettingsService } from '../../../core/services/settings.service';
|
||||||
import { Client, ClientType, getClientTypeIcon } from '../../../core/models';
|
import { Client, ClientPreview, ClientType, getClientTypeIcon } from '../../../core/models';
|
||||||
import { RelativeTimePipe } from '../../../shared/pipes/relative-time.pipe';
|
import { RelativeTimePipe } from '../../../shared/pipes/relative-time.pipe';
|
||||||
import { MetadataGridComponent, MetadataValueComponent } from '../../../shared/components/metadata-grid';
|
import { MetadataGridComponent, MetadataValueComponent } from '../../../shared/components/metadata-grid';
|
||||||
|
|
||||||
@@ -45,6 +45,7 @@ export class ClientDetailComponent implements OnInit {
|
|||||||
private settingsService = inject(SettingsService);
|
private settingsService = inject(SettingsService);
|
||||||
|
|
||||||
client = signal<Client | null>(null);
|
client = signal<Client | null>(null);
|
||||||
|
clientPreview = signal<ClientPreview | null>(null);
|
||||||
loading = signal(true);
|
loading = signal(true);
|
||||||
expertMode = this.settingsService.expertMode;
|
expertMode = this.settingsService.expertMode;
|
||||||
|
|
||||||
@@ -60,10 +61,22 @@ export class ClientDetailComponent implements OnInit {
|
|||||||
if (!userId) return;
|
if (!userId) return;
|
||||||
|
|
||||||
this.loading.set(true);
|
this.loading.set(true);
|
||||||
this.apiService.getClient(userId, clientId).subscribe({
|
this.apiService.getClientPreview(clientId).subscribe({
|
||||||
next: (client) => {
|
next: (response) => {
|
||||||
this.client.set(client);
|
this.clientPreview.set(response.client);
|
||||||
this.loading.set(false);
|
if (response.client.user_id === userId) {
|
||||||
|
this.apiService.getClient(userId, clientId).subscribe({
|
||||||
|
next: (client) => {
|
||||||
|
this.client.set(client);
|
||||||
|
this.loading.set(false);
|
||||||
|
},
|
||||||
|
error: () => {
|
||||||
|
this.loading.set(false);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
} else {
|
||||||
|
this.loading.set(false);
|
||||||
|
}
|
||||||
},
|
},
|
||||||
error: () => {
|
error: () => {
|
||||||
this.loading.set(false);
|
this.loading.set(false);
|
||||||
@@ -71,6 +84,19 @@ export class ClientDetailComponent implements OnInit {
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
clientData() {
|
||||||
|
return this.client() ?? this.clientPreview();
|
||||||
|
}
|
||||||
|
|
||||||
|
isOwner(): boolean {
|
||||||
|
const userId = this.authService.getUserId();
|
||||||
|
const client = this.client();
|
||||||
|
if (client) return client.user_id === userId;
|
||||||
|
const preview = this.clientPreview();
|
||||||
|
if (preview) return preview.user_id === userId;
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
goBack(): void {
|
goBack(): void {
|
||||||
this.router.navigate(['/clients']);
|
this.router.navigate(['/clients']);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -3,35 +3,37 @@
|
|||||||
<div class="loading-container">
|
<div class="loading-container">
|
||||||
<nz-spin nzSimple nzSize="large"></nz-spin>
|
<nz-spin nzSimple nzSize="large"></nz-spin>
|
||||||
</div>
|
</div>
|
||||||
} @else if (key()) {
|
} @else if (keyData()) {
|
||||||
<div class="detail-header">
|
<div class="detail-header">
|
||||||
<button nz-button (click)="goBack()">
|
<button nz-button (click)="goBack()">
|
||||||
<span nz-icon nzType="arrow-left" nzTheme="outline"></span>
|
<span nz-icon nzType="arrow-left" nzTheme="outline"></span>
|
||||||
Back to Keys
|
Back to Keys
|
||||||
</button>
|
</button>
|
||||||
<div class="header-actions">
|
@if (isOwner()) {
|
||||||
<button nz-button (click)="openEditModal()">
|
<div class="header-actions">
|
||||||
<span nz-icon nzType="edit"></span>
|
<button nz-button (click)="openEditModal()">
|
||||||
Edit
|
<span nz-icon nzType="edit"></span>
|
||||||
</button>
|
Edit
|
||||||
@if (!isCurrentKey()) {
|
|
||||||
<button
|
|
||||||
nz-button
|
|
||||||
nzDanger
|
|
||||||
nz-popconfirm
|
|
||||||
nzPopconfirmTitle="Are you sure you want to delete this key?"
|
|
||||||
(nzOnConfirm)="deleteKey()"
|
|
||||||
>
|
|
||||||
<span nz-icon nzType="delete"></span>
|
|
||||||
Delete
|
|
||||||
</button>
|
</button>
|
||||||
}
|
@if (!isCurrentKey()) {
|
||||||
</div>
|
<button
|
||||||
|
nz-button
|
||||||
|
nzDanger
|
||||||
|
nz-popconfirm
|
||||||
|
nzPopconfirmTitle="Are you sure you want to delete this key?"
|
||||||
|
(nzOnConfirm)="deleteKey()"
|
||||||
|
>
|
||||||
|
<span nz-icon nzType="delete"></span>
|
||||||
|
Delete
|
||||||
|
</button>
|
||||||
|
}
|
||||||
|
</div>
|
||||||
|
}
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<nz-card>
|
<nz-card>
|
||||||
<div class="key-header">
|
<div class="key-header">
|
||||||
<h2 class="key-title">{{ key()!.name }}</h2>
|
<h2 class="key-title">{{ keyData()!.name }}</h2>
|
||||||
@if (isCurrentKey()) {
|
@if (isCurrentKey()) {
|
||||||
<nz-tag nzColor="cyan">Current</nz-tag>
|
<nz-tag nzColor="cyan">Current</nz-tag>
|
||||||
}
|
}
|
||||||
@@ -39,7 +41,7 @@
|
|||||||
|
|
||||||
<scn-metadata-grid>
|
<scn-metadata-grid>
|
||||||
<scn-metadata-value label="Key ID">
|
<scn-metadata-value label="Key ID">
|
||||||
<span class="mono">{{ key()!.keytoken_id }}</span>
|
<span class="mono">{{ keyData()!.keytoken_id }}</span>
|
||||||
</scn-metadata-value>
|
</scn-metadata-value>
|
||||||
<scn-metadata-value label="Permissions">
|
<scn-metadata-value label="Permissions">
|
||||||
<div class="permissions">
|
<div class="permissions">
|
||||||
@@ -55,11 +57,11 @@
|
|||||||
</div>
|
</div>
|
||||||
</scn-metadata-value>
|
</scn-metadata-value>
|
||||||
<scn-metadata-value label="Channel Access">
|
<scn-metadata-value label="Channel Access">
|
||||||
@if (key()!.all_channels) {
|
@if (keyData()!.all_channels) {
|
||||||
<nz-tag nzColor="default">All Channels</nz-tag>
|
<nz-tag nzColor="default">All Channels</nz-tag>
|
||||||
} @else if (key()!.channels && key()!.channels.length > 0) {
|
} @else if (keyData()!.channels && keyData()!.channels.length > 0) {
|
||||||
<div class="channel-list">
|
<div class="channel-list">
|
||||||
@for (channelId of key()!.channels; track channelId) {
|
@for (channelId of keyData()!.channels; track channelId) {
|
||||||
<nz-tag nzColor="orange" nz-tooltip [nzTooltipTitle]="channelId">
|
<nz-tag nzColor="orange" nz-tooltip [nzTooltipTitle]="channelId">
|
||||||
{{ getChannelDisplayName(channelId) }}
|
{{ getChannelDisplayName(channelId) }}
|
||||||
</nz-tag>
|
</nz-tag>
|
||||||
@@ -69,27 +71,29 @@
|
|||||||
<span class="text-muted">No channels</span>
|
<span class="text-muted">No channels</span>
|
||||||
}
|
}
|
||||||
</scn-metadata-value>
|
</scn-metadata-value>
|
||||||
<scn-metadata-value label="Messages Sent">
|
@if (key()) {
|
||||||
{{ key()!.messages_sent }}
|
<scn-metadata-value label="Messages Sent">
|
||||||
</scn-metadata-value>
|
{{ key()!.messages_sent }}
|
||||||
<scn-metadata-value label="Created">
|
</scn-metadata-value>
|
||||||
<div class="timestamp-absolute">{{ key()!.timestamp_created | date:'yyyy-MM-dd HH:mm:ss' }}</div>
|
<scn-metadata-value label="Created">
|
||||||
<div class="timestamp-relative">{{ key()!.timestamp_created | relativeTime }}</div>
|
<div class="timestamp-absolute">{{ key()!.timestamp_created | date:'yyyy-MM-dd HH:mm:ss' }}</div>
|
||||||
</scn-metadata-value>
|
<div class="timestamp-relative">{{ key()!.timestamp_created | relativeTime }}</div>
|
||||||
<scn-metadata-value label="Last Used">
|
</scn-metadata-value>
|
||||||
@if (key()!.timestamp_lastused) {
|
<scn-metadata-value label="Last Used">
|
||||||
<div class="timestamp-absolute">{{ key()!.timestamp_lastused | date:'yyyy-MM-dd HH:mm:ss' }}</div>
|
@if (key()!.timestamp_lastused) {
|
||||||
<div class="timestamp-relative">{{ key()!.timestamp_lastused | relativeTime }}</div>
|
<div class="timestamp-absolute">{{ key()!.timestamp_lastused | date:'yyyy-MM-dd HH:mm:ss' }}</div>
|
||||||
} @else {
|
<div class="timestamp-relative">{{ key()!.timestamp_lastused | relativeTime }}</div>
|
||||||
<span class="text-muted">Never</span>
|
} @else {
|
||||||
}
|
<span class="text-muted">Never</span>
|
||||||
</scn-metadata-value>
|
}
|
||||||
|
</scn-metadata-value>
|
||||||
|
}
|
||||||
<scn-metadata-value label="Owner">
|
<scn-metadata-value label="Owner">
|
||||||
@if (resolvedOwner()) {
|
@if (resolvedOwner()) {
|
||||||
<div class="owner-name">{{ resolvedOwner()!.displayName }}</div>
|
<div class="owner-name">{{ resolvedOwner()!.displayName }}</div>
|
||||||
<div class="owner-id mono">{{ key()!.owner_user_id }}</div>
|
<div class="owner-id mono">{{ keyData()!.owner_user_id }}</div>
|
||||||
} @else {
|
} @else {
|
||||||
<span class="mono">{{ key()!.owner_user_id }}</span>
|
<span class="mono">{{ keyData()!.owner_user_id }}</span>
|
||||||
}
|
}
|
||||||
</scn-metadata-value>
|
</scn-metadata-value>
|
||||||
</scn-metadata-grid>
|
</scn-metadata-grid>
|
||||||
|
|||||||
@@ -22,7 +22,7 @@ import { AuthService } from '../../../core/services/auth.service';
|
|||||||
import { NotificationService } from '../../../core/services/notification.service';
|
import { NotificationService } from '../../../core/services/notification.service';
|
||||||
import { ChannelCacheService, ResolvedChannel } from '../../../core/services/channel-cache.service';
|
import { ChannelCacheService, ResolvedChannel } from '../../../core/services/channel-cache.service';
|
||||||
import { UserCacheService, ResolvedUser } from '../../../core/services/user-cache.service';
|
import { UserCacheService, ResolvedUser } from '../../../core/services/user-cache.service';
|
||||||
import { KeyToken, parsePermissions, TokenPermission, ChannelWithSubscription, Message } from '../../../core/models';
|
import { KeyToken, KeyTokenPreview, parsePermissions, TokenPermission, ChannelWithSubscription, Message } from '../../../core/models';
|
||||||
import { RelativeTimePipe } from '../../../shared/pipes/relative-time.pipe';
|
import { RelativeTimePipe } from '../../../shared/pipes/relative-time.pipe';
|
||||||
import { MetadataGridComponent, MetadataValueComponent } from '../../../shared/components/metadata-grid';
|
import { MetadataGridComponent, MetadataValueComponent } from '../../../shared/components/metadata-grid';
|
||||||
|
|
||||||
@@ -72,6 +72,7 @@ export class KeyDetailComponent implements OnInit {
|
|||||||
private userCacheService = inject(UserCacheService);
|
private userCacheService = inject(UserCacheService);
|
||||||
|
|
||||||
key = signal<KeyToken | null>(null);
|
key = signal<KeyToken | null>(null);
|
||||||
|
keyPreview = signal<KeyTokenPreview | null>(null);
|
||||||
currentKeyId = signal<string | null>(null);
|
currentKeyId = signal<string | null>(null);
|
||||||
loading = signal(true);
|
loading = signal(true);
|
||||||
channelNames = signal<Map<string, ResolvedChannel>>(new Map());
|
channelNames = signal<Map<string, ResolvedChannel>>(new Map());
|
||||||
@@ -105,8 +106,6 @@ export class KeyDetailComponent implements OnInit {
|
|||||||
const keyId = this.route.snapshot.paramMap.get('id');
|
const keyId = this.route.snapshot.paramMap.get('id');
|
||||||
if (keyId) {
|
if (keyId) {
|
||||||
this.loadKey(keyId);
|
this.loadKey(keyId);
|
||||||
this.loadCurrentKey();
|
|
||||||
this.loadAvailableChannels();
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -115,13 +114,29 @@ export class KeyDetailComponent implements OnInit {
|
|||||||
if (!userId) return;
|
if (!userId) return;
|
||||||
|
|
||||||
this.loading.set(true);
|
this.loading.set(true);
|
||||||
this.apiService.getKey(userId, keyId).subscribe({
|
this.apiService.getKeyPreview(keyId).subscribe({
|
||||||
next: (key) => {
|
next: (preview) => {
|
||||||
this.key.set(key);
|
this.keyPreview.set(preview);
|
||||||
this.loading.set(false);
|
this.resolveOwner(preview.owner_user_id);
|
||||||
this.resolveChannelNames(key);
|
this.resolveChannelNamesFromPreview(preview);
|
||||||
this.resolveOwner(key.owner_user_id);
|
if (preview.owner_user_id === userId) {
|
||||||
this.loadMessages(keyId);
|
this.loadCurrentKey();
|
||||||
|
this.loadAvailableChannels();
|
||||||
|
this.apiService.getKey(userId, keyId).subscribe({
|
||||||
|
next: (key) => {
|
||||||
|
this.key.set(key);
|
||||||
|
this.loading.set(false);
|
||||||
|
this.resolveChannelNames(key);
|
||||||
|
this.loadMessages(keyId);
|
||||||
|
},
|
||||||
|
error: () => {
|
||||||
|
this.loading.set(false);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
} else {
|
||||||
|
this.loading.set(false);
|
||||||
|
this.loadMessages(keyId);
|
||||||
|
}
|
||||||
},
|
},
|
||||||
error: () => {
|
error: () => {
|
||||||
this.loading.set(false);
|
this.loading.set(false);
|
||||||
@@ -217,6 +232,27 @@ export class KeyDetailComponent implements OnInit {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private resolveChannelNamesFromPreview(preview: KeyTokenPreview): void {
|
||||||
|
if (!preview.all_channels && preview.channels && preview.channels.length > 0) {
|
||||||
|
this.channelCacheService.resolveChannels(preview.channels).subscribe(resolved => {
|
||||||
|
this.channelNames.set(resolved);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
keyData() {
|
||||||
|
return this.key() ?? this.keyPreview();
|
||||||
|
}
|
||||||
|
|
||||||
|
isOwner(): boolean {
|
||||||
|
const userId = this.authService.getUserId();
|
||||||
|
const key = this.key();
|
||||||
|
if (key) return key.owner_user_id === userId;
|
||||||
|
const preview = this.keyPreview();
|
||||||
|
if (preview) return preview.owner_user_id === userId;
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
goBack(): void {
|
goBack(): void {
|
||||||
this.router.navigate(['/keys']);
|
this.router.navigate(['/keys']);
|
||||||
}
|
}
|
||||||
@@ -227,8 +263,8 @@ export class KeyDetailComponent implements OnInit {
|
|||||||
}
|
}
|
||||||
|
|
||||||
getPermissions(): TokenPermission[] {
|
getPermissions(): TokenPermission[] {
|
||||||
const key = this.key();
|
const data = this.keyData();
|
||||||
return key ? parsePermissions(key.permissions) : [];
|
return data ? parsePermissions(data.permissions) : [];
|
||||||
}
|
}
|
||||||
|
|
||||||
getPermissionColor(perm: TokenPermission): string {
|
getPermissionColor(perm: TokenPermission): string {
|
||||||
|
|||||||
@@ -90,18 +90,29 @@
|
|||||||
>
|
>
|
||||||
<thead>
|
<thead>
|
||||||
<tr>
|
<tr>
|
||||||
<th>Client ID</th>
|
<th>Client</th>
|
||||||
|
<th>User</th>
|
||||||
|
<th>Agent</th>
|
||||||
<th>Status</th>
|
<th>Status</th>
|
||||||
<th>Retries</th>
|
<th>Retries</th>
|
||||||
<th>Created</th>
|
<th>Created</th>
|
||||||
<th>Finalized</th>
|
<th>Finalized</th>
|
||||||
|
<th>FCM-ID</th>
|
||||||
</tr>
|
</tr>
|
||||||
</thead>
|
</thead>
|
||||||
<tbody>
|
<tbody>
|
||||||
@for (delivery of deliveriesTable.data; track delivery.delivery_id) {
|
@for (delivery of deliveriesTable.data; track delivery.delivery_id) {
|
||||||
<tr>
|
<tr>
|
||||||
<td>
|
<td>
|
||||||
<span class="mono">{{ delivery.receiver_client_id }}</span>
|
<div class="cell-name">{{ getResolvedClient(delivery.receiver_client_id)?.client?.name ?? '-' }}</div>
|
||||||
|
<div class="cell-id mono">{{ delivery.receiver_client_id }}</div>
|
||||||
|
</td>
|
||||||
|
<td>
|
||||||
|
<div class="cell-name">{{ getResolvedClient(delivery.receiver_client_id)?.user?.username ?? '-' }}</div>
|
||||||
|
<div class="cell-id mono">{{ delivery.receiver_user_id }}</div>
|
||||||
|
</td>
|
||||||
|
<td>
|
||||||
|
{{ getResolvedClient(delivery.receiver_client_id)?.client?.agent_model ?? '-' }}
|
||||||
</td>
|
</td>
|
||||||
<td>
|
<td>
|
||||||
<nz-tag [nzColor]="getStatusColor(delivery.status)">
|
<nz-tag [nzColor]="getStatusColor(delivery.status)">
|
||||||
@@ -111,6 +122,21 @@
|
|||||||
<td>{{ delivery.retry_count }}</td>
|
<td>{{ delivery.retry_count }}</td>
|
||||||
<td>{{ delivery.timestamp_created | date:'yyyy-MM-dd HH:mm:ss' }}</td>
|
<td>{{ delivery.timestamp_created | date:'yyyy-MM-dd HH:mm:ss' }}</td>
|
||||||
<td>{{ delivery.timestamp_finalized ? (delivery.timestamp_finalized | date:'yyyy-MM-dd HH:mm:ss') : '-' }}</td>
|
<td>{{ delivery.timestamp_finalized ? (delivery.timestamp_finalized | date:'yyyy-MM-dd HH:mm:ss') : '-' }}</td>
|
||||||
|
<td>
|
||||||
|
@if (delivery.fcm_message_id) {
|
||||||
|
<span
|
||||||
|
nz-icon
|
||||||
|
nzType="copy"
|
||||||
|
class="action-icon"
|
||||||
|
nz-tooltip
|
||||||
|
nzTooltipTitle="Copy Message FCM-ID"
|
||||||
|
style="cursor: pointer"
|
||||||
|
[appCopyToClipboard]="delivery.fcm_message_id"
|
||||||
|
></span>
|
||||||
|
} @else {
|
||||||
|
-
|
||||||
|
}
|
||||||
|
</td>
|
||||||
</tr>
|
</tr>
|
||||||
}
|
}
|
||||||
</tbody>
|
</tbody>
|
||||||
|
|||||||
@@ -8,13 +8,16 @@ import { NzTagModule } from 'ng-zorro-antd/tag';
|
|||||||
import { NzSpinModule } from 'ng-zorro-antd/spin';
|
import { NzSpinModule } from 'ng-zorro-antd/spin';
|
||||||
import { NzPopconfirmModule } from 'ng-zorro-antd/popconfirm';
|
import { NzPopconfirmModule } from 'ng-zorro-antd/popconfirm';
|
||||||
import { NzTableModule } from 'ng-zorro-antd/table';
|
import { NzTableModule } from 'ng-zorro-antd/table';
|
||||||
|
import { NzToolTipModule } from 'ng-zorro-antd/tooltip';
|
||||||
import { ApiService } from '../../../core/services/api.service';
|
import { ApiService } from '../../../core/services/api.service';
|
||||||
import { AuthService } from '../../../core/services/auth.service';
|
import { AuthService } from '../../../core/services/auth.service';
|
||||||
import { NotificationService } from '../../../core/services/notification.service';
|
import { NotificationService } from '../../../core/services/notification.service';
|
||||||
import { SettingsService } from '../../../core/services/settings.service';
|
import { SettingsService } from '../../../core/services/settings.service';
|
||||||
import { KeyCacheService, ResolvedKey } from '../../../core/services/key-cache.service';
|
import { KeyCacheService, ResolvedKey } from '../../../core/services/key-cache.service';
|
||||||
import { UserCacheService, ResolvedUser } from '../../../core/services/user-cache.service';
|
import { UserCacheService, ResolvedUser } from '../../../core/services/user-cache.service';
|
||||||
import { Message, Delivery } from '../../../core/models';
|
import { ClientCacheService, ResolvedClient } from '../../../core/services/client-cache.service';
|
||||||
|
import { Message, Delivery, ClientPreview, UserPreview } from '../../../core/models';
|
||||||
|
import { CopyToClipboardDirective } from '../../../shared/directives/copy-to-clipboard.directive';
|
||||||
import { RelativeTimePipe } from '../../../shared/pipes/relative-time.pipe';
|
import { RelativeTimePipe } from '../../../shared/pipes/relative-time.pipe';
|
||||||
import { MetadataGridComponent, MetadataValueComponent } from '../../../shared/components/metadata-grid';
|
import { MetadataGridComponent, MetadataValueComponent } from '../../../shared/components/metadata-grid';
|
||||||
|
|
||||||
@@ -31,10 +34,12 @@ import { MetadataGridComponent, MetadataValueComponent } from '../../../shared/c
|
|||||||
NzSpinModule,
|
NzSpinModule,
|
||||||
NzPopconfirmModule,
|
NzPopconfirmModule,
|
||||||
NzTableModule,
|
NzTableModule,
|
||||||
|
NzToolTipModule,
|
||||||
RouterLink,
|
RouterLink,
|
||||||
RelativeTimePipe,
|
RelativeTimePipe,
|
||||||
MetadataGridComponent,
|
MetadataGridComponent,
|
||||||
MetadataValueComponent,
|
MetadataValueComponent,
|
||||||
|
CopyToClipboardDirective,
|
||||||
],
|
],
|
||||||
templateUrl: './message-detail.component.html',
|
templateUrl: './message-detail.component.html',
|
||||||
styleUrl: './message-detail.component.scss'
|
styleUrl: './message-detail.component.scss'
|
||||||
@@ -48,11 +53,13 @@ export class MessageDetailComponent implements OnInit {
|
|||||||
private settingsService = inject(SettingsService);
|
private settingsService = inject(SettingsService);
|
||||||
private keyCacheService = inject(KeyCacheService);
|
private keyCacheService = inject(KeyCacheService);
|
||||||
private userCacheService = inject(UserCacheService);
|
private userCacheService = inject(UserCacheService);
|
||||||
|
private clientCacheService = inject(ClientCacheService);
|
||||||
|
|
||||||
message = signal<Message | null>(null);
|
message = signal<Message | null>(null);
|
||||||
resolvedKey = signal<ResolvedKey | null>(null);
|
resolvedKey = signal<ResolvedKey | null>(null);
|
||||||
resolvedChannelOwner = signal<ResolvedUser | null>(null);
|
resolvedChannelOwner = signal<ResolvedUser | null>(null);
|
||||||
deliveries = signal<Delivery[]>([]);
|
deliveries = signal<Delivery[]>([]);
|
||||||
|
resolvedClients = signal<Map<string, {client: ClientPreview, user: UserPreview}>>(new Map());
|
||||||
loading = signal(true);
|
loading = signal(true);
|
||||||
deleting = signal(false);
|
deleting = signal(false);
|
||||||
loadingDeliveries = signal(false);
|
loadingDeliveries = signal(false);
|
||||||
@@ -107,6 +114,7 @@ export class MessageDetailComponent implements OnInit {
|
|||||||
next: (response) => {
|
next: (response) => {
|
||||||
this.deliveries.set(response.deliveries);
|
this.deliveries.set(response.deliveries);
|
||||||
this.loadingDeliveries.set(false);
|
this.loadingDeliveries.set(false);
|
||||||
|
this.resolveDeliveryClients(response.deliveries);
|
||||||
},
|
},
|
||||||
error: () => {
|
error: () => {
|
||||||
this.loadingDeliveries.set(false);
|
this.loadingDeliveries.set(false);
|
||||||
@@ -114,6 +122,27 @@ export class MessageDetailComponent implements OnInit {
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private resolveDeliveryClients(deliveries: Delivery[]): void {
|
||||||
|
const uniqueClientIds = [...new Set(deliveries.map(d => d.receiver_client_id))];
|
||||||
|
for (const clientId of uniqueClientIds) {
|
||||||
|
this.clientCacheService.resolveClient(clientId).subscribe({
|
||||||
|
next: (resolved) => {
|
||||||
|
if (resolved) {
|
||||||
|
this.resolvedClients.update(map => {
|
||||||
|
const newMap = new Map(map);
|
||||||
|
newMap.set(clientId, resolved);
|
||||||
|
return newMap;
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
getResolvedClient(clientId: string): {client: ClientPreview, user: UserPreview} | undefined {
|
||||||
|
return this.resolvedClients().get(clientId);
|
||||||
|
}
|
||||||
|
|
||||||
private resolveKey(keyId: string): void {
|
private resolveKey(keyId: string): void {
|
||||||
this.keyCacheService.resolveKey(keyId).subscribe({
|
this.keyCacheService.resolveKey(keyId).subscribe({
|
||||||
next: (resolved) => this.resolvedKey.set(resolved)
|
next: (resolved) => this.resolvedKey.set(resolved)
|
||||||
|
|||||||
Reference in New Issue
Block a user