Watch
1
0
Fork
You've already forked nexus
0
forked from Nexus/nexus

Compare commits

...
11 changed files with 74 additions and 102 deletions

2
.gitmodules vendored
View file

@ -1,4 +1,4 @@
[submodule "gomuks"] [submodule "gomuks"]
path = gomuks path = gomuks
url = https://github.com/henry-hiles/gomuks url = https://github.com/gomuks/gomuks
branch = main branch = main

2
gomuks

@ -1 +1 @@
Subproject commit 1f11743884a64765b1444b250377a09ebcaba93c Subproject commit 0f8fb261ab57977fa24a4f63b7aafbb9a4ff1b7b

View file

@ -17,6 +17,7 @@ import "package:nexus/main.dart";
import "package:nexus/models/content/message.dart"; import "package:nexus/models/content/message.dart";
import "package:nexus/models/event.dart"; import "package:nexus/models/event.dart";
import "package:nexus/models/oauth_auth_code_response.dart"; import "package:nexus/models/oauth_auth_code_response.dart";
import "package:nexus/models/open_graph_data.dart";
import "package:nexus/models/paginate.dart"; import "package:nexus/models/paginate.dart";
import "package:nexus/models/requests/download_media.dart"; import "package:nexus/models/requests/download_media.dart";
import "package:nexus/models/requests/get_event.dart"; import "package:nexus/models/requests/get_event.dart";
@ -215,11 +216,6 @@ class ClientController extends AsyncNotifier<int> {
return response["room_id"]; return response["room_id"];
} }
Future<String?> getAccessToken() async {
final response = await _sendCommand("get_account_info", {});
return response?["access_token"];
}
Future<void> leaveRoom(Room room) async { Future<void> leaveRoom(Room room) async {
if (room.metadata == null) return; if (room.metadata == null) return;
await _sendCommand("leave_room", {"room_id": room.metadata!.id}); await _sendCommand("leave_room", {"room_id": room.metadata!.id});
@ -255,6 +251,9 @@ class ClientController extends AsyncNotifier<int> {
return json == null ? null : .fromJson(json); return json == null ? null : .fromJson(json);
} }
Future<OpenGraphData> getUrlPreview(Uri url) async =>
.fromJson(await _sendCommand("get_url_preview", {"url": url.toString()}));
Future<Paginate> paginate(PaginateRequest request) async => Future<Paginate> paginate(PaginateRequest request) async =>
.fromJson(await _sendCommand("paginate", request.toJson())); .fromJson(await _sendCommand("paginate", request.toJson()));

View file

@ -1,20 +0,0 @@
import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/controllers/client.dart";
import "package:nexus/controllers/client_state.dart";
class HeaderController extends AsyncNotifier<Map<String, String>> {
@override
Future<Map<String, String>> build() async {
if (ref.watch(ClientStateController.provider)?.isLoggedIn != true) {
return {};
}
final client = ref.watch(ClientController.provider.notifier);
final accessToken = await client.getAccessToken();
return {"authorization": "Bearer $accessToken"};
}
static final provider =
AsyncNotifierProvider<HeaderController, Map<String, String>>(
HeaderController.new,
);
}

View file

@ -1,50 +1,28 @@
import "dart:convert"; import "package:flutter/widgets.dart";
import "package:flutter_riverpod/flutter_riverpod.dart"; import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:http/http.dart"; import "package:nexus/controllers/client.dart";
import "package:nexus/controllers/client_state.dart";
import "package:nexus/controllers/header.dart";
import "package:nexus/models/open_graph_data.dart"; import "package:nexus/models/open_graph_data.dart";
class UrlPreviewController extends AsyncNotifier<OpenGraphData?> { class UrlPreviewController extends AsyncNotifier<OpenGraphData?> {
final String link; final Uri url;
UrlPreviewController(this.link); UrlPreviewController(this.url);
@override @override
Future<OpenGraphData?> build() async { Future<OpenGraphData?> build() async {
if (url.host == "matrix.to") return null;
try { try {
final homeserver = ref.watch( return await ref
ClientStateController.provider.select((value) => value?.homeserverUrl), .watch(ClientController.provider.notifier)
); .getUrlPreview(url);
} catch (error, stackTrace) {
if (homeserver != null && !link.contains("matrix.to")) { debugPrintStack(label: error.toString(), stackTrace: stackTrace);
{
final response = await get(
.parse(homeserver)
.resolve("/_matrix/client/v1/media/preview_url")
.replace(queryParameters: {"url": link}),
headers: await ref.watch(HeaderController.provider.future),
);
if (response.statusCode == 200) {
final decodedValue = json.decode(response.body);
if (decodedValue is! Map<String, dynamic>) return null;
return .fromJson(
decodedValue,
).copyWith(imageUrl: decodedValue["og:image"]);
}
}
}
} catch (_) {
return null; return null;
} }
return null;
} }
static final provider = static final provider =
AsyncNotifierProvider.family< AsyncNotifierProvider.family<UrlPreviewController, OpenGraphData?, Uri>(
UrlPreviewController, UrlPreviewController.new,
OpenGraphData?, );
String
>(UrlPreviewController.new);
} }

View file

@ -1,7 +0,0 @@
import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:nexus/controllers/header.dart";
extension GetHeaders on WidgetRef {
Map<String, String> get headers =>
watch(HeaderController.provider).requireValue;
}

View file

@ -6,7 +6,6 @@ import "package:flutter_riverpod/flutter_riverpod.dart";
import "package:media_kit/media_kit.dart"; import "package:media_kit/media_kit.dart";
import "package:nexus/controllers/client.dart"; import "package:nexus/controllers/client.dart";
import "package:nexus/controllers/client_state.dart"; import "package:nexus/controllers/client_state.dart";
import "package:nexus/controllers/header.dart";
import "package:nexus/controllers/multi_provider.dart"; import "package:nexus/controllers/multi_provider.dart";
import "package:nexus/controllers/settings.dart"; import "package:nexus/controllers/settings.dart";
import "package:nexus/controllers/shared_prefs.dart"; import "package:nexus/controllers/shared_prefs.dart";
@ -144,7 +143,6 @@ class App extends StatelessWidget {
IListConst([ IListConst([
SharedPrefsController.provider, SharedPrefsController.provider,
ClientController.provider, ClientController.provider,
HeaderController.provider,
]), ]),
), ),
) )

View file

@ -1,17 +1,17 @@
import "dart:async"; import "dart:async";
import "package:flutter/material.dart"; import "package:flutter/material.dart";
import "package:flutter_hooks/flutter_hooks.dart"; import "package:flutter_hooks/flutter_hooks.dart";
import "package:hooks_riverpod/hooks_riverpod.dart"; import "package:hooks_riverpod/hooks_riverpod.dart";
import "package:media_kit/media_kit.dart"; import "package:media_kit/media_kit.dart";
import "package:nexus/helpers/extensions/get_headers.dart"; import "package:nexus/controllers/client.dart";
import "package:nexus/models/info/audio.dart"; import "package:nexus/models/info/audio.dart";
class AudioPlayer extends HookConsumerWidget { class AudioPlayer extends HookConsumerWidget {
final Uri url; final Uri uri;
final AudioInfo? info; final AudioInfo? info;
final bool encrypted;
const AudioPlayer(this.url, this.info, {super.key}); const AudioPlayer(this.uri, this.info, {this.encrypted = false, super.key});
@override @override
Widget build(BuildContext context, WidgetRef ref) { Widget build(BuildContext context, WidgetRef ref) {
@ -24,11 +24,12 @@ class AudioPlayer extends HookConsumerWidget {
final duration = useState(Duration.zero); final duration = useState(Duration.zero);
useEffect(() { useEffect(() {
player.platform?.state = player.platform!.state.copyWith(buffering: true);
scheduleMicrotask(() async { scheduleMicrotask(() async {
await player.open( final video = await ref
Media(url.toString(), httpHeaders: ref.headers), .watch(ClientController.provider.notifier)
play: false, .downloadMedia(.new(mxc: uri, encrypted: encrypted));
); await player.open(Media(video.path), play: false);
player.stream.playing.listen((value) { player.stream.playing.listen((value) {
playing.value = value; playing.value = value;
@ -67,12 +68,18 @@ class AudioPlayer extends HookConsumerWidget {
padding: .only(left: 8, right: 16), padding: .only(left: 8, right: 16),
child: Row( child: Row(
children: [ children: [
IconButton( if (player.state.buffering)
onPressed: player.playOrPause, SizedBox.square(
icon: Icon( dimension: 24,
playing.value ? Icons.pause_circle : Icons.play_circle, child: CircularProgressIndicator(padding: .all(4)),
)
else
IconButton(
onPressed: player.playOrPause,
icon: Icon(
playing.value ? Icons.pause_circle : Icons.play_circle,
),
), ),
),
SizedBox(width: 8), SizedBox(width: 8),
Text( Text(
format(position.value), format(position.value),

View file

@ -2,16 +2,17 @@ import "dart:async";
import "package:flutter/material.dart"; import "package:flutter/material.dart";
import "package:hooks_riverpod/hooks_riverpod.dart"; import "package:hooks_riverpod/hooks_riverpod.dart";
import "package:nexus/controllers/client.dart";
import "package:nexus/models/info/video.dart"; import "package:nexus/models/info/video.dart";
import "package:flutter_hooks/flutter_hooks.dart"; import "package:flutter_hooks/flutter_hooks.dart";
import "package:media_kit/media_kit.dart"; import "package:media_kit/media_kit.dart";
import "package:media_kit_video/media_kit_video.dart"; import "package:media_kit_video/media_kit_video.dart";
import "package:nexus/helpers/extensions/get_headers.dart";
class VideoPlayer extends HookConsumerWidget { class VideoPlayer extends HookConsumerWidget {
final VideoInfo? info; final VideoInfo? info;
final Uri url; final Uri uri;
const VideoPlayer(this.url, this.info, {super.key}); final bool encrypted;
const VideoPlayer(this.uri, this.info, {this.encrypted = false, super.key});
@override @override
Widget build(BuildContext context, WidgetRef ref) { Widget build(BuildContext context, WidgetRef ref) {
@ -21,12 +22,13 @@ class VideoPlayer extends HookConsumerWidget {
final controller = useMemoized(() => VideoController(player)); final controller = useMemoized(() => VideoController(player));
useEffect(() { useEffect(() {
scheduleMicrotask( player.platform?.state = player.platform!.state.copyWith(buffering: true);
() => player.open( scheduleMicrotask(() async {
Media(url.toString(), httpHeaders: ref.headers), final video = await ref
play: false, .watch(ClientController.provider.notifier)
), .downloadMedia(.new(mxc: uri, encrypted: encrypted));
); await player.open(Media(video.path), play: false);
});
return player.dispose; return player.dispose;
}, []); }, []);

View file

@ -226,10 +226,25 @@ class MessageRenderer extends ConsumerWidget {
ConstrainedBox( ConstrainedBox(
constraints: .loose(.square(500)), constraints: .loose(.square(500)),
child: switch (event.content) { child: switch (event.content) {
VideoMessageContent(:final info) => VideoMessageContent(
VideoPlayer(url, info), :final info,
AudioMessageContent(:final info) => :final file,
AudioPlayer(url, info), ) =>
VideoPlayer(
url,
info,
encrypted: file != null,
),
AudioMessageContent(
:final info,
:final file,
) =>
AudioPlayer(
url,
info,
encrypted: file != null,
),
FileMessageContent( FileMessageContent(
:final info, :final info,
:final filename, :final filename,
@ -258,7 +273,8 @@ class MessageRenderer extends ConsumerWidget {
(element) => element is UrlElement, (element) => element is UrlElement,
) )
case final UrlElement link?) case final UrlElement link?)
UrlPreview(link.url), if (Uri.tryParse(link.url) case final Uri url?)
UrlPreview(url),
ReactionRow(event), ReactionRow(event),
], ],

View file

@ -6,7 +6,7 @@ import "package:nexus/helpers/launch_helper.dart";
import "package:nexus/helpers/mxc_image.dart"; import "package:nexus/helpers/mxc_image.dart";
class UrlPreview extends ConsumerWidget { class UrlPreview extends ConsumerWidget {
final String link; final Uri link;
const UrlPreview(this.link, {super.key}); const UrlPreview(this.link, {super.key});
@override @override
@ -18,8 +18,7 @@ class UrlPreview extends ConsumerWidget {
data: (preview) => preview == null data: (preview) => preview == null
? SizedBox.shrink() ? SizedBox.shrink()
: InkWell( : InkWell(
onTap: () => onTap: () => ref.watch(LaunchHelper.provider).launchUrl(link),
ref.watch(LaunchHelper.provider).launchUrl(.parse(link)),
child: Card( child: Card(
margin: .symmetric(vertical: 4), margin: .symmetric(vertical: 4),
color: Theme.of( color: Theme.of(