flutterando / clean-dart Goto Github PK

abstract class UserLocalDataSource {
  Future<void> initialize();

  void save(UserDto dao);

  UserDto get dao;
  Stream<UserDto> get daoStream;
}

@Injectable(as: UserLocalDataSource)
class UserLocalDataSourceImpl extends HiveDb<UserDto, UserDtoAdapter>
    implements UserLocalDataSource {
  @override
  UserDtoAdapter get adaptor => UserDtoAdapter();

  @override
  String get boxKey => 'user_box';

  @override
  UserDto get defaultValue => null;
}

abstract class UserRemoteDataSource {
  Future<Either<ApiFailure, Response<Map<String, dynamic>>>> user({
    UserInclude include,
  });

  Future<Either<ApiFailure, Response<Map<String, dynamic>>>> updateUser(
    String encodedData,
  );

  Future<Either<ApiFailure, Response<Map<String, dynamic>>>> updateAvatar(
    OnProgress onProgress,
    File file,
  );
}

@Injectable(as: UserRemoteDataSource)
class UserRemoteDataSourceImpl implements UserRemoteDataSource {
  const UserRemoteDataSourceImpl(this.fileDataSource, this.flApi);
  final RemoteFileDataSource fileDataSource;
  final FlApi flApi;

  @override
  user({UserInclude include}) => flApi
      .getMethod(
        UserEndpoints.index().toPath,
        option: FlApiOption(query: include.toMap),
      )
      .toDomain<Map<String, dynamic>>();

  @override
  updateUser(String encodedData) => flApi
      .putMethod(UserEndpoints.update().toPath, body: encodedData)
      .toDomain<Map<String, dynamic>>();

  @override
  updateAvatar(OnProgress onProgress, File file) =>
      fileDataSource.upload<Map<String, dynamic>>(
        url: UserEndpoints.image().toPath,
        onProgress: onProgress,
        flApi: flApi,
        file: file,
      );
}

@Injectable()
class SearchMobx = _SearchMobxBase with _$SearchMobx;

abstract class _SearchMobxBase with Store {
  final SearchByText searchByText;
  late CancelableOperation cancelableOperation;

  Future stateReaction(String text,
      [CancelableOperation? cancelableOperation]) async {
    await cancelableOperation?.cancel();
    cancelableOperation =
        CancelableOperation<SearchState>.fromFuture(makeSearch(text));

    if (text.isEmpty) {
      setState(const StartState());
      return;
    }

    setState(const LoadingState());

    setState(
        await cancelableOperation.valueOrCancellation(const LoadingState()));
  }

  _SearchMobxBase(this.searchByText) {
    reaction((_) => searchText, (String text) async {
      stateReaction(text, cancelableOperation);
    }, delay: 500);
  }

  Future<SearchState> makeSearch(String text) async {
    var result = await searchByText(text);
    return result.fold((l) => ErrorState(l), (r) => SuccessState(r));
  }

  @observable
  String searchText = '';

  @observable
  SearchState state = const StartState();

  @action
  setSearchText(String value) => searchText = value;

  @action
  setState(SearchState value) => state = value;
}

class SearchMobxPage extends StatefulWidget {
  const SearchMobxPage({Key? key}) : super(key: key);

  @override
  _SearchMobxPageState createState() => _SearchMobxPageState();
}

class _SearchMobxPageState extends ModularState<SearchMobxPage, SearchMobx> {
  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: const Text("Github Search - MobX"),
      ),
      body: Column(
        children: <Widget>[
          Padding(
            padding: const EdgeInsets.only(top: 8, right: 8, left: 8),
            child: TextField(
              onChanged: controller.setSearchText,
              decoration: const InputDecoration(
                border: OutlineInputBorder(),
                labelText: "Pesquise...",
              ),
            ),
          ),
          Expanded(
            child: Observer(builder: (_) {
              var state = controller.state;

              if (state is ErrorState) {
                return buildError(state.error);
              }

              if (state is StartState) {
                return const Center(
                  child: Text('Digita alguma coisa...'),
                );
              } else if (state is LoadingState) {
                return const Center(
                  child: CircularProgressIndicator(),
                );
              } else if (state is SuccessState) {
                return buildList(state.list);
              } else {
                return Container();
              }
            }),
          )
        ],
      ),
    );
  }
}