inventree-app/lib/api.dart

import 'dart:async';
import 'dart:convert';
import 'dart:io';

import 'package:path/path.dart' as path;
import 'package:http/http.dart' as http;


class InvenTreeAPI {

  // Ensure we only ever create a single instance of the API class
  static final InvenTreeAPI _api = new InvenTreeAPI._internal();

  factory InvenTreeAPI() {
    return _api;
  }

  InvenTreeAPI._internal();

  void connect(String address, String username, String password) async {

    address = address.trim();
    username = username.trim();

    if (!address.endsWith("api/") || !address.endsWith("api")) {
      address = path.join(address, "api");
    }

    if (!address.endsWith('/')) {
      address = address + '/';
    }

    _base_url = address;
    _username = username;
    _password = password;

    _connected = false;

    print("Connecting to " + address + " -> " + username + ":" + password);

    await _tryConnection();

    await _secureToken();
  }

  bool _connected = false;

  // Base URL for InvenTree API
  String _base_url = "http://127.0.0.1:8000/api/";

  String _username = "";
  String _password = "";

  // Authentication token (initially empty, must be requested)
  String _token = "";

  // Construct an API URL
  String _makeUrl(String url) {
    return path.join(_base_url, url);
  }

  bool _hasToken() {
    return _token.isNotEmpty;
  }

  // Request the raw /api/ endpoing to see if there is an InvenTree server listening
  void _tryConnection() async {
    final response = get("");
  }

  // Request an API token from the server.
  // A valid username/password combination must be provided
  void _secureToken() async {

    if (_token.isNotEmpty) {
      print("Discarding old token - " + _token);
    }
    _token = "";

    var _url = _makeUrl("user/token/");
    final response = await http.post(_url,
        body: {
          "username": _username,
          "password": _password
      });

    if (response.statusCode != 200) {
      print("Invalid status code:" + String.fromCharCode(response.statusCode));
    } else {
      var _json = json.decode(response.body);

      if (_json["token"] != null) {
        _token = _json["token"];
        print("Received token: " + _token);
      }
    }
  }

  Future<http.Response> get(String url) async {
    var _url = _makeUrl(url);
    final response = await http.get(_url,
      headers: {
          HttpHeaders.authorizationHeader: "Token: " + _token
        }
    );

    print("Making request to " + _url);
    print(response.statusCode);
    print(response.body);

    return response;
  }

}