HeadersLink

gistfile1.txt

import 'dart:async';
import 'package:ferry/ferry.dart';
import 'package:gql_http_link/gql_http_link.dart';
import 'package:gql_link/gql_link.dart';
import 'package:gql_exec/gql_exec.dart';
import 'package:rxdart/rxdart.dart';
import 'package:firebase_auth/firebase_auth.dart';
import 'package:get_it/get_it.dart';

import '../stores/user_store.dart';

Future<IdTokenResult> getToken() async {
  final userStore = GetIt.I<UserStore>();
  if (userStore.currentUser != null) return await userStore.getIdToken();
  return null;
}

class HeadersLink extends Link {
  @override
  Stream<Response> request(
    Request request, [
    NextLink forward,
  ]) =>
      Stream.fromFuture(getToken()).switchMap((result) {
        final token = result?.token;
        final headers = {
          if (token != null) 'Authorization': token,
        };
        if (token != null) headers["Authorization"] = token;
        final req = request.withContextEntry(HttpLinkHeaders(headers: headers));
        return forward(req);
      });
}