122 lines
3.8 KiB
Dart
122 lines
3.8 KiB
Dart
import 'dart:io';
|
|
|
|
import 'package:dio/dio.dart';
|
|
import 'package:dio/adapter.dart';
|
|
import 'package:dio_cookie_manager/dio_cookie_manager.dart';
|
|
import 'package:cookie_jar/cookie_jar.dart';
|
|
import 'package:path_provider/path_provider.dart';
|
|
import 'package:package_info/package_info.dart';
|
|
|
|
import 'enums.dart';
|
|
|
|
class Client {
|
|
String endPoint;
|
|
String type = 'unknown';
|
|
Map<String, String> headers;
|
|
Map<String, String> config;
|
|
bool selfSigned;
|
|
bool initialized = false;
|
|
Dio http;
|
|
PersistCookieJar cookieJar;
|
|
|
|
Client({this.endPoint = 'https://appwrite.io/v1', this.selfSigned = false, Dio http}) : this.http = http ?? Dio() {
|
|
|
|
type = (Platform.isIOS) ? 'ios' : type;
|
|
type = (Platform.isMacOS) ? 'macos' : type;
|
|
type = (Platform.isAndroid) ? 'android' : type;
|
|
type = (Platform.isLinux) ? 'linux' : type;
|
|
type = (Platform.isWindows) ? 'windows' : type;
|
|
type = (Platform.isFuchsia) ? 'fuchsia' : type;
|
|
|
|
this.headers = {
|
|
'content-type': 'application/json',
|
|
'x-sdk-version': 'appwrite:dart:0.2.3',
|
|
};
|
|
|
|
this.config = {};
|
|
|
|
assert(endPoint.startsWith(RegExp("http://|https://")), "endPoint $endPoint must start with 'http'");
|
|
}
|
|
|
|
Future<Directory> _getCookiePath() async {
|
|
final directory = await getApplicationDocumentsDirectory();
|
|
final path = directory.path;
|
|
final Directory dir = new Directory('$path/cookies');
|
|
await dir.create();
|
|
return dir;
|
|
}
|
|
|
|
/// Your project ID
|
|
Client setProject(value) {
|
|
config['project'] = value;
|
|
addHeader('X-Appwrite-Project', value);
|
|
return this;
|
|
}
|
|
|
|
Client setLocale(value) {
|
|
config['locale'] = value;
|
|
addHeader('X-Appwrite-Locale', value);
|
|
return this;
|
|
}
|
|
|
|
Client setSelfSigned({bool status = true}) {
|
|
selfSigned = status;
|
|
return this;
|
|
}
|
|
|
|
Client setEndpoint(String endPoint) {
|
|
this.endPoint = endPoint;
|
|
this.http.options.baseUrl = this.endPoint;
|
|
return this;
|
|
}
|
|
|
|
Client addHeader(String key, String value) {
|
|
headers[key] = value;
|
|
|
|
return this;
|
|
}
|
|
|
|
Future init() async {
|
|
if(!initialized) {
|
|
final Directory cookieDir = await _getCookiePath();
|
|
|
|
cookieJar = new PersistCookieJar(dir:cookieDir.path);
|
|
|
|
this.http.options.baseUrl = this.endPoint;
|
|
this.http.options.validateStatus = (status) => status < 400;
|
|
this.http.interceptors.add(CookieManager(cookieJar));
|
|
|
|
PackageInfo packageInfo = await PackageInfo.fromPlatform();
|
|
|
|
addHeader('Origin', 'appwrite-' + type + '://' + packageInfo.packageName);
|
|
}
|
|
}
|
|
|
|
Future<Response> call(HttpMethod method, {String path = '', Map<String, String> headers = const {}, Map<String, dynamic> params = const {}}) async {
|
|
if(selfSigned) {
|
|
// Allow self signed requests
|
|
(http.httpClientAdapter as DefaultHttpClientAdapter).onHttpClientCreate = (HttpClient client) {
|
|
client.badCertificateCallback = (X509Certificate cert, String host, int port) => true;
|
|
return client;
|
|
};
|
|
}
|
|
|
|
await this.init();
|
|
|
|
// Origin is hardcoded for testing
|
|
Options options = Options(
|
|
headers: {...this.headers, ...headers},
|
|
method: method.name(),
|
|
);
|
|
|
|
if(headers['content-type'] == 'multipart/form-data') {
|
|
return http.request(path, data: FormData.fromMap(params), options: options);
|
|
}
|
|
|
|
if (method == HttpMethod.get) {
|
|
return http.get(path, queryParameters: params, options: options);
|
|
} else {
|
|
return http.request(path, data: params, options: options);
|
|
}
|
|
}
|
|
} |