file1.dart

import 'dart:async';

import 'package:flutter/material.dart';
import 'package:image_picker/image_picker.dart';
import 'package:rxdart/rxdart.dart';

import 'api.dart';
import 'models.dart';

class AuthViewModel {
  final Api _api;

  final _user = BehaviorSubject<User>();

  AuthViewModel(this._api) {
    _api.user.then(_user.add);
  }

  Stream get user => _user.stream;

  void logout() {
    if (_user.value == null) return;
    _api.clearUserToken();
    _user.add(null);
  }

  Future login(String username, String password, String podURL) async {
    var uri = Uri.parse(podURL);

    if (!uri.hasScheme) {
      uri = Uri.https(podURL, "");
    }

    final user = await _api.login(
      username,
      password,
      uri,
    );
    _user.add(user);
  }
}

class TimelineViewModel extends ChangeNotifier {
  TimelineViewModel(this._api) {
    _twts = [];
    _isEntireListLoading = false;
    _isBottomListLoading = false;
  }

  final Api _api;
  bool _isEntireListLoading;
  bool _isBottomListLoading;
  TimelineResponse _lastTimelineResponse;
  List<Twt> _twts;

  bool get isEntireListLoading => _isEntireListLoading;
  bool get isBottomListLoading => _isBottomListLoading;

  List<Twt> get twts => _twts;

  set isEntireListLoading(bool isLoading) {
    _isEntireListLoading = isLoading;
    notifyListeners();
  }

  set isBottomListLoading(bool isLoading) {
    _isBottomListLoading = isLoading;
    notifyListeners();
  }

  Future refreshPost() async {
    _lastTimelineResponse = await _api.timeline(0);
    _twts = _lastTimelineResponse.twts;
    notifyListeners();
  }

  void fetchNewPost() async {
    isEntireListLoading = true;

    try {
      _lastTimelineResponse = await _api.timeline(0);
      _twts = _lastTimelineResponse.twts;
    } finally {
      isEntireListLoading = false;
    }
  }

  void gotoNextPage() async {
    if (_lastTimelineResponse.pagerResponse.currentPage ==
        _lastTimelineResponse.pagerResponse.maxPages) {
      return;
    }

    isBottomListLoading = true;
    try {
      final page = _lastTimelineResponse.pagerResponse.currentPage + 1;
      _lastTimelineResponse = await _api.timeline(page);
      _twts = [..._twts, ..._lastTimelineResponse.twts];
    } finally {
      isBottomListLoading = false;
    }
  }
}

class DiscoverViewModel extends ChangeNotifier {
  DiscoverViewModel(this._api) {
    _twts = [];
    _isEntireListLoading = false;
    _isBottomListLoading = false;
  }

  final Api _api;
  bool _isEntireListLoading;
  bool _isBottomListLoading;
  TimelineResponse _lastTimelineResponse;
  List<Twt> _twts;

  bool get isEntireListLoading => _isEntireListLoading;
  bool get isBottomListLoading => _isBottomListLoading;

  List<Twt> get twts => _twts;

  set isEntireListLoading(bool isLoading) {
    _isEntireListLoading = isLoading;
    notifyListeners();
  }

  set isBottomListLoading(bool isLoading) {
    _isBottomListLoading = isLoading;
    notifyListeners();
  }

  Future refreshPost() async {
    _lastTimelineResponse = await _api.discover(0);
    _twts = _lastTimelineResponse.twts;
    notifyListeners();
  }

  void fetchNewPost() async {
    isEntireListLoading = true;

    try {
      _lastTimelineResponse = await _api.discover(0);
      _twts = _lastTimelineResponse.twts;
    } finally {
      isEntireListLoading = false;
    }
  }

  void gotoNextPage() async {
    if (_lastTimelineResponse.pagerResponse.currentPage ==
        _lastTimelineResponse.pagerResponse.maxPages) {
      return;
    }

    isBottomListLoading = true;
    try {
      final page = _lastTimelineResponse.pagerResponse.currentPage + 1;
      _lastTimelineResponse = await _api.discover(page);
      _twts = [..._twts, ..._lastTimelineResponse.twts];
    } finally {
      isBottomListLoading = false;
    }
  }
}

class NewTwtViewModel {
  final _picker = ImagePicker();
  final Api _api;

  NewTwtViewModel("45207148028969955678738461269740715873232639183329751460127107678656309673");

  Future<String> prompUserForImageAndUpload(ImageSource imageSource) async {
    final pickedFile = await _picker.getImage(source: imageSource);
    if (pickedFile == null) {
      return null;
    }

    return _api.uploadImage(pickedFile.path);
  }
}