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"]
|
||||
path = gomuks
|
||||
url = https://github.com/henry-hiles/gomuks
|
||||
url = https://github.com/gomuks/gomuks
|
||||
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/event.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/requests/download_media.dart";
|
||||
import "package:nexus/models/requests/get_event.dart";
|
||||
|
|
@ -215,11 +216,6 @@ class ClientController extends AsyncNotifier<int> {
|
|||
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 {
|
||||
if (room.metadata == null) return;
|
||||
await _sendCommand("leave_room", {"room_id": room.metadata!.id});
|
||||
|
|
@ -255,6 +251,9 @@ class ClientController extends AsyncNotifier<int> {
|
|||
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 =>
|
||||
.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:http/http.dart";
|
||||
import "package:nexus/controllers/client_state.dart";
|
||||
import "package:nexus/controllers/header.dart";
|
||||
import "package:nexus/controllers/client.dart";
|
||||
import "package:nexus/models/open_graph_data.dart";
|
||||
|
||||
class UrlPreviewController extends AsyncNotifier<OpenGraphData?> {
|
||||
final String link;
|
||||
UrlPreviewController(this.link);
|
||||
final Uri url;
|
||||
UrlPreviewController(this.url);
|
||||
|
||||
@override
|
||||
Future<OpenGraphData?> build() async {
|
||||
if (url.host == "matrix.to") return null;
|
||||
|
||||
try {
|
||||
final homeserver = ref.watch(
|
||||
ClientStateController.provider.select((value) => value?.homeserverUrl),
|
||||
);
|
||||
|
||||
if (homeserver != null && !link.contains("matrix.to")) {
|
||||
{
|
||||
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 await ref
|
||||
.watch(ClientController.provider.notifier)
|
||||
.getUrlPreview(url);
|
||||
} catch (error, stackTrace) {
|
||||
debugPrintStack(label: error.toString(), stackTrace: stackTrace);
|
||||
return null;
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
static final provider =
|
||||
AsyncNotifierProvider.family<
|
||||
UrlPreviewController,
|
||||
OpenGraphData?,
|
||||
String
|
||||
>(UrlPreviewController.new);
|
||||
AsyncNotifierProvider.family<UrlPreviewController, OpenGraphData?, Uri>(
|
||||
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:nexus/controllers/client.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/settings.dart";
|
||||
import "package:nexus/controllers/shared_prefs.dart";
|
||||
|
|
@ -144,7 +143,6 @@ class App extends StatelessWidget {
|
|||
IListConst([
|
||||
SharedPrefsController.provider,
|
||||
ClientController.provider,
|
||||
HeaderController.provider,
|
||||
]),
|
||||
),
|
||||
)
|
||||
|
|
|
|||
|
|
@ -1,17 +1,17 @@
|
|||
import "dart:async";
|
||||
|
||||
import "package:flutter/material.dart";
|
||||
import "package:flutter_hooks/flutter_hooks.dart";
|
||||
import "package:hooks_riverpod/hooks_riverpod.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";
|
||||
|
||||
class AudioPlayer extends HookConsumerWidget {
|
||||
final Uri url;
|
||||
final Uri uri;
|
||||
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
|
||||
Widget build(BuildContext context, WidgetRef ref) {
|
||||
|
|
@ -24,11 +24,12 @@ class AudioPlayer extends HookConsumerWidget {
|
|||
final duration = useState(Duration.zero);
|
||||
|
||||
useEffect(() {
|
||||
player.platform?.state = player.platform!.state.copyWith(buffering: true);
|
||||
scheduleMicrotask(() async {
|
||||
await player.open(
|
||||
Media(url.toString(), httpHeaders: ref.headers),
|
||||
play: false,
|
||||
);
|
||||
final video = await ref
|
||||
.watch(ClientController.provider.notifier)
|
||||
.downloadMedia(.new(mxc: uri, encrypted: encrypted));
|
||||
await player.open(Media(video.path), play: false);
|
||||
|
||||
player.stream.playing.listen((value) {
|
||||
playing.value = value;
|
||||
|
|
@ -67,12 +68,18 @@ class AudioPlayer extends HookConsumerWidget {
|
|||
padding: .only(left: 8, right: 16),
|
||||
child: Row(
|
||||
children: [
|
||||
IconButton(
|
||||
onPressed: player.playOrPause,
|
||||
icon: Icon(
|
||||
playing.value ? Icons.pause_circle : Icons.play_circle,
|
||||
if (player.state.buffering)
|
||||
SizedBox.square(
|
||||
dimension: 24,
|
||||
child: CircularProgressIndicator(padding: .all(4)),
|
||||
)
|
||||
else
|
||||
IconButton(
|
||||
onPressed: player.playOrPause,
|
||||
icon: Icon(
|
||||
playing.value ? Icons.pause_circle : Icons.play_circle,
|
||||
),
|
||||
),
|
||||
),
|
||||
SizedBox(width: 8),
|
||||
Text(
|
||||
format(position.value),
|
||||
|
|
|
|||
|
|
@ -2,16 +2,17 @@ import "dart:async";
|
|||
|
||||
import "package:flutter/material.dart";
|
||||
import "package:hooks_riverpod/hooks_riverpod.dart";
|
||||
import "package:nexus/controllers/client.dart";
|
||||
import "package:nexus/models/info/video.dart";
|
||||
import "package:flutter_hooks/flutter_hooks.dart";
|
||||
import "package:media_kit/media_kit.dart";
|
||||
import "package:media_kit_video/media_kit_video.dart";
|
||||
import "package:nexus/helpers/extensions/get_headers.dart";
|
||||
|
||||
class VideoPlayer extends HookConsumerWidget {
|
||||
final VideoInfo? info;
|
||||
final Uri url;
|
||||
const VideoPlayer(this.url, this.info, {super.key});
|
||||
final Uri uri;
|
||||
final bool encrypted;
|
||||
const VideoPlayer(this.uri, this.info, {this.encrypted = false, super.key});
|
||||
|
||||
@override
|
||||
Widget build(BuildContext context, WidgetRef ref) {
|
||||
|
|
@ -21,12 +22,13 @@ class VideoPlayer extends HookConsumerWidget {
|
|||
final controller = useMemoized(() => VideoController(player));
|
||||
|
||||
useEffect(() {
|
||||
scheduleMicrotask(
|
||||
() => player.open(
|
||||
Media(url.toString(), httpHeaders: ref.headers),
|
||||
play: false,
|
||||
),
|
||||
);
|
||||
player.platform?.state = player.platform!.state.copyWith(buffering: true);
|
||||
scheduleMicrotask(() async {
|
||||
final video = await ref
|
||||
.watch(ClientController.provider.notifier)
|
||||
.downloadMedia(.new(mxc: uri, encrypted: encrypted));
|
||||
await player.open(Media(video.path), play: false);
|
||||
});
|
||||
|
||||
return player.dispose;
|
||||
}, []);
|
||||
|
|
|
|||
|
|
@ -226,10 +226,25 @@ class MessageRenderer extends ConsumerWidget {
|
|||
ConstrainedBox(
|
||||
constraints: .loose(.square(500)),
|
||||
child: switch (event.content) {
|
||||
VideoMessageContent(:final info) =>
|
||||
VideoPlayer(url, info),
|
||||
AudioMessageContent(:final info) =>
|
||||
AudioPlayer(url, info),
|
||||
VideoMessageContent(
|
||||
:final info,
|
||||
:final file,
|
||||
) =>
|
||||
VideoPlayer(
|
||||
url,
|
||||
info,
|
||||
encrypted: file != null,
|
||||
),
|
||||
AudioMessageContent(
|
||||
:final info,
|
||||
:final file,
|
||||
) =>
|
||||
AudioPlayer(
|
||||
url,
|
||||
info,
|
||||
|
||||
encrypted: file != null,
|
||||
),
|
||||
FileMessageContent(
|
||||
:final info,
|
||||
:final filename,
|
||||
|
|
@ -258,7 +273,8 @@ class MessageRenderer extends ConsumerWidget {
|
|||
(element) => element is UrlElement,
|
||||
)
|
||||
case final UrlElement link?)
|
||||
UrlPreview(link.url),
|
||||
if (Uri.tryParse(link.url) case final Uri url?)
|
||||
UrlPreview(url),
|
||||
|
||||
ReactionRow(event),
|
||||
],
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@ import "package:nexus/helpers/launch_helper.dart";
|
|||
import "package:nexus/helpers/mxc_image.dart";
|
||||
|
||||
class UrlPreview extends ConsumerWidget {
|
||||
final String link;
|
||||
final Uri link;
|
||||
const UrlPreview(this.link, {super.key});
|
||||
|
||||
@override
|
||||
|
|
@ -18,8 +18,7 @@ class UrlPreview extends ConsumerWidget {
|
|||
data: (preview) => preview == null
|
||||
? SizedBox.shrink()
|
||||
: InkWell(
|
||||
onTap: () =>
|
||||
ref.watch(LaunchHelper.provider).launchUrl(.parse(link)),
|
||||
onTap: () => ref.watch(LaunchHelper.provider).launchUrl(link),
|
||||
child: Card(
|
||||
margin: .symmetric(vertical: 4),
|
||||
color: Theme.of(
|
||||
|
|
|
|||
Loading…
Reference in a new issue