Flutter OAuth认证插件atproto_oauth的使用

Flutter OAuth认证插件atproto_oauth的使用

本指南将解释如何在您的Flutter应用程序中使用FlutterWebAuth2实现AT协议OAuth认证，适用于服务如Bluesky。

客户端元数据

请参阅AT协议文档了解有关客户端元数据的信息。

安装

在pubspec.yaml文件中添加以下依赖项：

dependencies:
  atproto_oauth: ^0.0.1  # 替换为实际版本
  flutter_web_auth_2: ^4.0.1
  flutter_secure_storage: ^9.2.2

如果您想在Bluesky上使用此功能，可以这样配置：

dependencies:
  bluesky: ^0.18.0  # 替换为实际版本
  flutter_web_auth_2: ^4.0.1
  flutter_secure_storage: ^9.2.2

基本用法

以下是如何在您的Flutter应用中实现AT协议OAuth认证的方法：

import 'package:atproto_oauth/atproto_oauth.dart';
import 'package:flutter/material.dart';
import 'package:flutter_web_auth_2/flutter_web_auth_2.dart';
import 'package:flutter_secure_storage/flutter_secure_storage.dart';

class BlueskyAuth extends StatefulWidget {
  @override
  _BlueskyAuthState createState() => _BlueskyAuthState();
}

class _BlueskyAuthState extends State<BlueskyAuth> {
  late OAuthClient _client;
  final _storage = const FlutterSecureStorage();

  @override
  void initState() {
    super.initState();
    _initializeOAuth();
  }

  Future<void> _initializeOAuth() async {
    // 使用元数据初始化OAuth客户端
    // 请替换为您自己的客户端元数据
    final metadata = await getClientMetadata(
      'https://atprotodart.com/oauth/bluesky/atprotodart/client-metadata.json'
    );
    _client = OAuthClient(metadata);
  }

  Future<void> _startAuth() async {
    try {
      // 获取用户句柄的授权URL
      final (authUrl, ctx) = await _client.authorize('shinyakato.dev');

      // 在浏览器中启动OAuth流程
      final result = await FlutterWebAuth2.authenticate(
        url: authUrl,
        callbackUrlScheme: 'your-app-scheme',
      );

      // 处理OAuth回调
      final session = await _client.callback(result, ctx);

      // 安全地存储会话信息
      await _saveSession(session);

      // 显示成功消息
      ScaffoldMessenger.of(context).showSnackBar(
        SnackBar(content: Text('成功登录！')),
      );
    } catch (e) {
      // 处理错误
      ScaffoldMessenger.of(context).showSnackBar(
        SnackBar(content: Text('身份验证失败: $e')),
      );
    }
  }

  Future<void> _saveSession(OAuthSession session) async {
    // 安全地存储所有会话数据
    await _storage.write(key: 'access_token', value: session.accessToken);
    await _storage.write(key: 'refresh_token', value: session.refreshToken);
    await _storage.write(key: 'dpop_nonce', value: session.$dPoPNonce);
    await _storage.write(key: 'public_key', value: session.$publicKey);
    await _storage.write(key: 'private_key', value: session.$privateKey);
    await _storage.write(
      key: 'expires_at',
      value: session.expiresAt.toIso8601String(),
    );
  }

  Future<OAuthSession?> _loadSession() async {
    final accessToken = await _storage.read(key: 'access_token');
    if (accessToken == null) return null;

    return OAuthSession(
      accessToken: accessToken,
      refreshToken: await _storage.read(key: 'refresh_token') ?? '',
      tokenType: 'DPoP',
      expiresAt: DateTime.parse(
        await _storage.read(key: 'expires_at') ?? '',
      ),
      $dPoPNonce: await _storage.read(key: 'dpop_nonce') ?? '',
      $publicKey: await _storage.read(key: 'public_key') ?? '',
      $privateKey: await _storage.read(key: 'private_key') ?? '',
    );
  }

  Future<OAuthSession?> _refreshTokenIfNeeded() async {
    final session = await _loadSession();
    if (session == null) return null;

    // 检查令牌是否需要刷新（例如，在过期前5分钟）
    if (session.expiresAt.isBefore(DateTime.now().add(Duration(minutes: 5)))) {
      try {
        final newSession = await _client.refresh(session);
        await _saveSession(newSession);
        return newSession;
      } catch (e) {
        // 如果刷新失败，则清除存储的会话
        await _storage.deleteAll();
        return null;
      }
    }
    return session;
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      body: Center(
        child: ElevatedButton(
          onPressed: _startAuth,
          child: Text('使用Bluesky登录'),
        ),
      ),
    );
  }
}

平台配置

请参阅flutter_web_auth_2上的文档。

使用Bluesky客户端

一旦完成认证，您可以使用会话进行API请求。以下是使用Bluesky客户端的示例：

Future<void> _makeAuthenticatedRequest() async {
  final session = await _refreshTokenIfNeeded();
  if (session == null) {
    // 处理未认证状态
    return;
  }

  final bsky = Bluesky.fromOAuthSession(session);

  // 随意处理
  final record = await bsky.feed.post(text: 'Nice DPoP proof');
}