mirror of
https://github.com/ninjamuffin99/Funkin.git
synced 2024-11-08 15:56:04 +00:00
227 lines
5.5 KiB
Haxe
227 lines
5.5 KiB
Haxe
package io.newgrounds;
|
|
|
|
import io.newgrounds.utils.Dispatcher;
|
|
import io.newgrounds.utils.AsyncHttp;
|
|
import io.newgrounds.objects.Error;
|
|
import io.newgrounds.objects.events.Result;
|
|
import io.newgrounds.objects.events.Result.ResultBase;
|
|
import io.newgrounds.objects.events.Response;
|
|
|
|
import haxe.ds.StringMap;
|
|
import haxe.Json;
|
|
|
|
/** A generic way to handle calls agnostic to their type */
|
|
interface ICallable {
|
|
|
|
public var component(default, null):String;
|
|
|
|
public function send():Void;
|
|
public function queue():Void;
|
|
public function destroy():Void;
|
|
}
|
|
|
|
class Call<T:ResultBase>
|
|
implements ICallable {
|
|
|
|
public var component(default, null):String;
|
|
|
|
var _core:NGLite;
|
|
var _properties:StringMap<Dynamic>;
|
|
var _parameters:StringMap<Dynamic>;
|
|
var _requireSession:Bool;
|
|
var _isSecure:Bool;
|
|
|
|
// --- BASICALLY SIGNALS
|
|
var _dataHandlers:TypedDispatcher<Response<T>>;
|
|
var _successHandlers:Dispatcher;
|
|
var _httpErrorHandlers:TypedDispatcher<Error>;
|
|
var _statusHandlers:TypedDispatcher<Int>;
|
|
|
|
public function new (core:NGLite, component:String, requireSession:Bool = false, isSecure:Bool = false) {
|
|
|
|
_core = core;
|
|
this.component = component;
|
|
_requireSession = requireSession;
|
|
_isSecure = isSecure && core.encryptionHandler != null;
|
|
}
|
|
|
|
/** adds a property to the input's object. **/
|
|
public function addProperty(name:String, value:Dynamic):Call<T> {
|
|
|
|
if (_properties == null)
|
|
_properties = new StringMap<Dynamic>();
|
|
|
|
_properties.set(name, value);
|
|
|
|
return this;
|
|
}
|
|
|
|
/** adds a parameter to the call's component object. **/
|
|
public function addComponentParameter(name:String, value:Dynamic, defaultValue:Dynamic = null):Call<T> {
|
|
|
|
if (value == defaultValue)//TODO?: allow sending null value
|
|
return this;
|
|
|
|
if (_parameters == null)
|
|
_parameters = new StringMap<Dynamic>();
|
|
|
|
_parameters.set(name, value);
|
|
|
|
return this;
|
|
}
|
|
|
|
/** Handy callback setter for chained call modifiers. Called when ng.io replies successfully */
|
|
public function addDataHandler(handler:Response<T>->Void):Call<T> {
|
|
|
|
if (_dataHandlers == null)
|
|
_dataHandlers = new TypedDispatcher<Response<T>>();
|
|
|
|
_dataHandlers.add(handler);
|
|
return this;
|
|
}
|
|
|
|
/** Handy callback setter for chained call modifiers. Called when ng.io replies successfully */
|
|
public function addSuccessHandler(handler:Void->Void):Call<T> {
|
|
|
|
if (_successHandlers == null)
|
|
_successHandlers = new Dispatcher();
|
|
|
|
_successHandlers.add(handler);
|
|
return this;
|
|
}
|
|
|
|
/** Handy callback setter for chained call modifiers. Called when ng.io does not reply for any reason */
|
|
public function addErrorHandler(handler:Error->Void):Call<T> {
|
|
|
|
if (_httpErrorHandlers == null)
|
|
_httpErrorHandlers = new TypedDispatcher<Error>();
|
|
|
|
_httpErrorHandlers.add(handler);
|
|
return this;
|
|
}
|
|
|
|
/** Handy callback setter for chained call modifiers. No idea when this is called; */
|
|
public function addStatusHandler(handler:Int->Void):Call<T> {//TODO:learn what this is for
|
|
|
|
if (_statusHandlers == null)
|
|
_statusHandlers = new TypedDispatcher<Int>();
|
|
|
|
_statusHandlers.add(handler);
|
|
return this;
|
|
}
|
|
|
|
/**
|
|
* Sends the call to the server, do not modify this object after calling this
|
|
* @param secure If encryption is enabled, it will encrypt the call.
|
|
**/
|
|
public function send():Void {
|
|
|
|
var data:Dynamic = {};
|
|
data.app_id = _core.appId;
|
|
data.call = {};
|
|
data.call.component = component;
|
|
|
|
if (_core.debug)
|
|
addProperty("debug", true);
|
|
|
|
if (_properties == null || !_properties.exists("session_id")) {
|
|
// --- HAS NO SESSION ID
|
|
|
|
if (_core.sessionId != null) {
|
|
// --- AUTO ADD SESSION ID
|
|
|
|
addProperty("session_id", _core.sessionId);
|
|
|
|
} else if (_requireSession){
|
|
|
|
_core.logError(new Error('cannot send "$component" call without a sessionId'));
|
|
return;
|
|
}
|
|
}
|
|
|
|
if (_properties != null) {
|
|
|
|
for (field in _properties.keys())
|
|
Reflect.setField(data, field, _properties.get(field));
|
|
}
|
|
|
|
if (_parameters != null) {
|
|
|
|
data.call.parameters = {};
|
|
|
|
for (field in _parameters.keys())
|
|
Reflect.setField(data.call.parameters, field, _parameters.get(field));
|
|
}
|
|
|
|
_core.logVerbose('Post - ${Json.stringify(data)}');
|
|
|
|
if (_isSecure) {
|
|
|
|
var secureData = _core.encryptionHandler(Json.stringify(data.call));
|
|
data.call = {};
|
|
data.call.secure = secureData;
|
|
|
|
_core.logVerbose(' secure - $secureData');
|
|
}
|
|
|
|
_core.markCallPending(this);
|
|
|
|
AsyncHttp.send(_core, Json.stringify(data), onData, onHttpError, onStatus);
|
|
}
|
|
|
|
/** Adds the call to the queue */
|
|
public function queue():Void {
|
|
|
|
_core.queueCall(this);
|
|
}
|
|
|
|
function onData(reply:String):Void {
|
|
|
|
_core.logVerbose('Reply - $reply');
|
|
|
|
if (_dataHandlers == null && _successHandlers == null)
|
|
return;
|
|
|
|
var response = new Response<T>(_core, reply);
|
|
|
|
if (_dataHandlers != null)
|
|
_dataHandlers.dispatch(response);
|
|
|
|
if (response.success && response.result.success && _successHandlers != null)
|
|
_successHandlers.dispatch();
|
|
|
|
destroy();
|
|
}
|
|
|
|
function onHttpError(message:String):Void {
|
|
|
|
_core.logError(message);
|
|
|
|
if (_httpErrorHandlers == null)
|
|
return;
|
|
|
|
var error = new Error(message);
|
|
_httpErrorHandlers.dispatch(error);
|
|
}
|
|
|
|
function onStatus(status:Int):Void {
|
|
|
|
if (_statusHandlers == null)
|
|
return;
|
|
|
|
_statusHandlers.dispatch(status);
|
|
}
|
|
|
|
public function destroy():Void {
|
|
|
|
_core = null;
|
|
|
|
_properties = null;
|
|
_parameters = null;
|
|
|
|
_dataHandlers = null;
|
|
_successHandlers = null;
|
|
_httpErrorHandlers = null;
|
|
_statusHandlers = null;
|
|
}
|
|
} |