forked from Nexus/nexus
Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
5f13d3fbf5 |
|||
|
eca9d3b411 |
|||
|
16fdf0c420 |
11 changed files with 74 additions and 102 deletions
2
.gitmodules
vendored
2
.gitmodules
vendored
|
|
@ -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
2
gomuks
|
|
@ -1 +1 @@
|
||||||
Subproject commit 1f11743884a64765b1444b250377a09ebcaba93c
|
Subproject commit 0f8fb261ab57977fa24a4f63b7aafbb9a4ff1b7b
|
||||||
|
|
@ -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()));
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -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,
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
@ -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);
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -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;
|
|
||||||
}
|
|
||||||
|
|
@ -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,
|
|
||||||
]),
|
]),
|
||||||
),
|
),
|
||||||
)
|
)
|
||||||
|
|
|
||||||
|
|
@ -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),
|
||||||
|
|
|
||||||
|
|
@ -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;
|
||||||
}, []);
|
}, []);
|
||||||
|
|
|
||||||
|
|
@ -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),
|
||||||
],
|
],
|
||||||
|
|
|
||||||
|
|
@ -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(
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue