///
///
const Instant = Java.type("java.time.Instant");
import logger from "../logger";
const File = Java.type("java.io.File")
import metadata from "../metadata.js"
import soopyV2Server from "../socketConnection";
import { fetch } from "../utils/networkUtils";
import NonPooledThread from "../utils/nonPooledThread";
import { setRendering } from "../utils/renderJavaUtils";
import { registerForge as registerForgeBase, unregisterForge as unregisterForgeBase } from "./forgeEvents.js"
const JSLoader = Java.type("com.chattriggers.ctjs.engine.langs.js.JSLoader")
const UrlModuleSourceProvider = Java.type("org.mozilla.javascript.commonjs.module.provider.UrlModuleSourceProvider")
const UrlModuleSourceProviderInstance = new UrlModuleSourceProvider(null, null)
const StrongCachingModuleScriptProviderClass = Java.type("org.mozilla.javascript.commonjs.module.provider.StrongCachingModuleScriptProvider")
let StrongCachingModuleScriptProvider = new StrongCachingModuleScriptProviderClass(UrlModuleSourceProviderInstance)
let CTRequire = new JSLoader.CTRequire(StrongCachingModuleScriptProvider)
const System = Java.type("java.lang.System")
let loadedModules = new Set()
let shouldRequireForceNoCache = true
function RequireNoCache(place) {
if (!shouldRequireForceNoCache) {
if (!logger.isDev) return require(place)
if (!loadedModules.has(place)) {
loadedModules.add(place)
return require(place) //performance optimisation
}
}
StrongCachingModuleScriptProvider = new StrongCachingModuleScriptProviderClass(UrlModuleSourceProviderInstance)
CTRequire = new JSLoader.CTRequire(StrongCachingModuleScriptProvider)
return CTRequire(place)
}
class FeatureManager {
constructor() {
this.isDev = logger.isDev
this.messagePrefix = "&6[SOOPY V2]&7 "
this.enabled = true //make triggers work with this context
this.features = {};
this.events = {}
this.eventObjects = {}
this.soopyEventHandlers = {}
this.parent = undefined
this.finishedLoading = false
this.commandFuncs = {}
this.lastEventId = 0
this.customEvents = {}
this.lastChatEventId = 0
this.forgeEvents = {}
this.lastForgeEventId = 0
this.lastSoopyEventId = 0
this.featureSettingsDataLastUpdated = false
//PERFORMANCE RECORDING
this.recordingPerformanceUsage = false
this.performanceUsage = {} //{: {: {time: 0, count: 0}}}
this.flameGraphData = []
this.longEventTime = 20
this.perfTrackingFeatures = false
this.stack = []
this.featureMetas = {}
this.featureSettingsData = {}
let fetchD = fetch("http://soopymc.my.to/api/soopyv2/ping").async(d => {
if (fetchD.responseCode() >= 400 || fetchD.responseCode() === -1) {
ChatLib.chat(this.messagePrefix + "&cError: Could not connect to Soopy's server. This may cause issues with some features but will (hopefully) be back soon.")
}
new Thread(() => {
this.loadSoopy()
}).start()
}, true)
this.registerStep(false, 30, () => {
if (this.featureSettingsDataLastUpdated) {
new Thread(() => {
this.saveFeatureSettings()
}).start()
}
}, this)
this.registerEvent("worldUnload", this.saveFeatureSettings, this)
this.registerEvent("gameUnload", () => {
this.saveFeatureSettings()
this.unloadAllFeatures()
this.enabled = false
}, this)
if (this.isDev) {
this.registerStep(true, 2, () => {
if (this.reloadModuleTime !== 0 && Date.now() - this.reloadModuleTime > 0) {
new Thread(() => {
this.reloadModuleTime = 0
this.reloadingModules.forEach(m => {
this.unloadFeature(m)
})
this.reloadingModules.forEach(m => {
this.loadFeature(m)
})
this.reloadingModules.clear()
}).start()
}
}, this)
this.watches = {}
this.addedWatches = new Set()
this.watchService = Java.type("java.nio.file.FileSystems").getDefault().newWatchService();
this.reloadingModules = new Set()
this.reloadModuleTime = 0
new NonPooledThread(() => {
while (this.enabled) {
key = this.watchService.take();
let moduleToReload = this.watches[key]
if (this.features[moduleToReload] && !this.reloadingModules.has(moduleToReload)) { //if enabled && not alr in queue
this.reloadingModules.add(moduleToReload)
this.reloadModuleTime = Date.now() + 5000
}
key.pollEvents()/*.forEach(event=>{
logger.logMessage(event.context().toString(), 1)
})*/
key.reset();
}
}).start()
}
this.registerCommand("soopyunloadfeature", (args) => {
new Thread(() => {
this.unloadFeature(args)
}).start()
}, this)
this.registerCommand("soopyloadfeature", (args) => {
new Thread(() => {
this.loadFeature(args)
}).start()
}, this)
this.registerCommand("soopyunload", () => {
new Thread(() => {
this.unloadSoopy()
}).start()
}, this)
this.registerCommand("soopyload", () => {
new Thread(() => {
this.loadSoopy()
}).start()
}, this)
this.registerCommand("soopyreload", () => {
new Thread(() => {
this.unloadSoopy()
this.loadSoopy()
}).start()
}, this)
this.registerCommand("soopyreloadfeature", (args) => {
new Thread(() => {
this.unloadFeature(args)
this.loadFeature(args)
}).start()
}, this)
this.registerCommand("soopysetlongeventtime", (args) => {
this.longEventTime = parseInt(args)
}, this)
this.registerCommand("soopylaginformation", (args) => {
this.loadPerformanceData()
}, this)
this.registerCommand("soopylaginformationfast", (args) => {
this.loadPerformanceDataFast()
}, this)
}
getId() {
return "FeatureManager"
}
loadPerformanceDataFast() {
new Thread(() => {
this.loadEventLag(true)
}).start()
}
loadPerformanceData() {
new Thread(() => {
ChatLib.chat(this.messagePrefix + "Recording performance impact, this will take around 60 seconds to complete!")
shouldRequireForceNoCache = true
let eventLagData = this.loadEventLag()
ChatLib.chat(this.messagePrefix + "ETA: 40s")
this.perfTrackingFeatures = true
this.unloadSoopy()
this.loadSoopy()
Thread.sleep(1000)
let eventLagDataFull = this.loadEventLag()
this.perfTrackingFeatures = false
this.unloadSoopy()
this.loadSoopy()
Thread.sleep(1000)
ChatLib.chat(this.messagePrefix + "ETA: 25s")
let forgeLagData = this.loadForgeRenderLag()
ChatLib.chat(this.messagePrefix + "ETA: 15s")
let soopyLagData = this.loadSoopyLag()
let lagData = {
eventLagDataFull,
eventLagData,
forgeLagData,
soopyLagData
}
shouldRequireForceNoCache = false
let url = this.reportLagData(lagData)
ChatLib.chat(this.messagePrefix + "Done!")
new TextComponent(this.messagePrefix + "See the report at " + url).setClick("open_url", url).setHover("show_text", "Click to open the report.").chat()
this.performanceUsage = {}
this.flameGraphData = []
}).start()
}
reportLagData(data) {
return fetch("http://soopymc.my.to/soopy/submitlag", { postData: data }).text()
}
loadSoopyLag() {
// ChatLib.chat(this.messagePrefix + "Recording All Soopy Lag...")
let framesWith = 0
let framesWithOut = 0
let event = this.registerEvent("renderWorld", () => {
framesWith++
}, this)
Thread.sleep(5000)
this.unregisterEvent(event)
this.unloadSoopy()
Thread.sleep(1000)
event = this.registerEvent("renderWorld", () => {
framesWithOut++
}, this)
Thread.sleep(5000)
this.unregisterEvent(event)
// ChatLib.chat(this.messagePrefix + "Soopy Lag:")
// ChatLib.chat("&eFps without Soopy: &7" + (framesWithOut / 5))
// ChatLib.chat("&eFps with Soopy: &7" + (framesWith / 5))
this.loadSoopy()
return {
fpsWith: (framesWith / 5),
fpsWithout: (framesWithOut / 5)
}
}
loadForgeRenderLag() {
// ChatLib.chat(this.messagePrefix + "Recording Forge-Rendering Lag...")
let framesWith = 0
let framesWithOut = 0
let renderingForge = true
let event = this.registerEvent("renderWorld", () => {
if (renderingForge) {
framesWith++
} else {
framesWithOut++
}
}, this)
for (let i = 0; i < 10; i++) {
Thread.sleep(1000)
renderingForge = !renderingForge
setRendering(renderingForge)
}
this.unregisterEvent(event)
// ChatLib.chat(this.messagePrefix + "Forge Lag:")
// ChatLib.chat("&eFps without forge: &7" + (framesWithOut / 5))
// ChatLib.chat("&eFps with forge: &7" + (framesWith / 5))
return {
fpsWith: (framesWith / 5),
fpsWithout: (framesWithOut / 5)
}
}
loadEventLag(sendMessage = false) {
this.recordingPerformanceUsage = true
this.performanceUsage = {}
this.flameGraphData = []
if (sendMessage) ChatLib.chat(this.messagePrefix + "Recording Event Lag...")
Thread.sleep(10000)
let totalMsGlobal = 0
this.recordingPerformanceUsage = false
if (sendMessage) {
ChatLib.chat(this.messagePrefix + "Event Lag:")
Object.keys(this.performanceUsage).sort((a, b) => {
let totalMsA = 0
Object.keys(this.performanceUsage[a]).forEach((event) => {
totalMsA += this.performanceUsage[a][event].time
})
let totalMsB = 0
Object.keys(this.performanceUsage[b]).forEach((event) => {
totalMsB += this.performanceUsage[b][event].time
})
return totalMsA - totalMsB
}).forEach((moduleName) => {
let totalMs = 0
let totalCalls = 0
Object.keys(this.performanceUsage[moduleName]).forEach((event) => {
totalMs += this.performanceUsage[moduleName][event].time
totalCalls += this.performanceUsage[moduleName][event].count
})
totalMsGlobal += totalMs
ChatLib.chat("&eModule: &7" + moduleName)
ChatLib.chat("&eTotal: &7" + totalMs.toFixed(2) + "ms (" + totalCalls + " calls)")
Object.keys(this.performanceUsage[moduleName]).sort((a, b) => { return this.performanceUsage[moduleName][a].time - this.performanceUsage[moduleName][b].time }).forEach((event) => {
ChatLib.chat(" &eEvent:&7 " + event + " - " + this.performanceUsage[moduleName][event].time.toFixed(2) + "ms (" + this.performanceUsage[moduleName][event].count + " calls) [" + ((this.performanceUsage[moduleName][event].time / this.performanceUsage[moduleName][event].count).toFixed(2)) + "ms avg]")
})
})
ChatLib.chat("&eTotal: &7" + totalMsGlobal.toFixed(2) + "ms")
}
return { performanceUsage: this.performanceUsage, flameGraphData: this.flameGraphData }
}
loadFeatureSettings() {
logger.logMessage("Loading settings", 4)
let data = FileLib.read("soopyAddonsData", "soopyaddonsbetafeaturesdata.json")
if (!data) {
this.loadDefaultFeatureSettings();
return;
}
data = JSON.parse(data)
this.featureSettingsData = data
this.ensureNewSettingsExist()
}
saveFeatureSettings() {
if (!this.featureSettingsDataLastUpdated) return
FileLib.write("soopyAddonsData", "soopyaddonsbetafeaturesdata.json", JSON.stringify(this.featureSettingsData))
this.featureSettingsDataLastUpdated = false
logger.logMessage("Saved settings", 4)
}
loadDefaultFeatureSettings() {
Object.keys(this.featureMetas).forEach((feature) => {
this.featureSettingsData[feature] = {
enabled: this.featureMetas[feature].defaultEnabled,
subSettings: {}
}
})
this.featureSettingsDataLastUpdated = true
logger.logMessage("Loaded default settings", 4)
}
ensureNewSettingsExist() {
Object.keys(this.featureMetas).forEach((feature) => {
if (!this.featureSettingsData[feature]) {
this.featureSettingsData[feature] = {
enabled: this.featureMetas[feature].defaultEnabled,
subSettings: {}
}
this.featureSettingsDataLastUpdated = true
logger.logMessage("Loaded default settings for " + feature, 4)
}
})
}
startCatchingEvent(event) {
if (this.eventObjects[event]) return
//SBA compatability or something (removed)
// if(event === "renderOverlay"){
// let lastPartialTick = undefined
// this.eventObjects[event] = register(event, (...args)=>{
// let pTicks = Tessellator.getPartialTicks()
// if(pTicks !== lastPartialTick){
// lastPartialTick = pTicks
// this.triggerEvent(event, args)
// }
// })
// }else{
this.eventObjects[event] = register(event, (...args) => {
// let start = Date.now()
this.triggerEvent(event, args)
// this.eventTimingData[event] = (this.eventTimingData[event] || 0)+(Date.now()-start)
})
//}
logger.logMessage("Registered " + event + " event", 4)
}
triggerEvent(event, args) {
if (this.events[event]) {
try {
for (Event of Object.values(this.events[event])) {
if (Event.context.enabled) {
if (this.recordingPerformanceUsage) this.startRecordingPerformance(Event.context.getId(), event)
let start = Date.now()
Event.func.call(Event.context, ...args)
let time = Date.now() - start
if (time > this.longEventTime) {
logger.logMessage("Long event triggered [" + time + "ms] (" + Event.context.getId() + "/" + event + ")", 3)
}
if (this.recordingPerformanceUsage) this.stopRecordingPerformance(Event.context.getId(), event)
}
}
} catch (e) {
logger.logMessage("Error in " + event + " event: " + JSON.stringify(e, undefined, 2), 2)
logger.logMessage(e.stack, 1)
soopyV2Server.reportError(e, "Error in " + event + " event.")
}
}
}
triggerSoopy(event, args) {
if (this.soopyEventHandlers[event]) {
try {
for (Event of Object.values(this.soopyEventHandlers[event])) {
if (Event.context.enabled) {
if (this.recordingPerformanceUsage) this.startRecordingPerformance(Event.context.getId(), event)
let start = Date.now()
Event.func.call(Event.context, ...args)
let time = Date.now() - start
if (time > this.longEventTime) {
logger.logMessage("Long event triggered [" + time + "ms] (" + Event.context.getId() + "/" + event + ")", 3)
}
if (this.recordingPerformanceUsage) this.stopRecordingPerformance(Event.context.getId(), event)
}
}
} catch (e) {
logger.logMessage("Error in soopy " + event + " event: " + JSON.stringify(e, undefined, 2), 2)
logger.logMessage(e.stack, 1)
soopyV2Server.reportError(e, "Error in soopy " + event + " event.")
}
}
}
stopCatchingEvent(event) {
if (!this.eventObjects[event]) return
this.eventObjects[event].unregister()
delete this.eventObjects[event]
delete this.events[event]
logger.logMessage("Unregistered " + event + " event", 4)
}
registerEvent(event, func, context) {
if (!this.events[event]) {
this.events[event] = []
this.startCatchingEvent(event)
}
let theEvent = {
func: func,
context: context,
id: this.lastEventId++,
event: event
}
this.events[event].push(theEvent)
return theEvent
}
registerSoopy(event, func, context) {
if (!this.soopyEventHandlers[event]) {
this.soopyEventHandlers[event] = []
}
let theEvent = {
func: func,
context: context,
id: this.lastSoopyEventId++,
event: event
}
this.soopyEventHandlers[event].push(theEvent)
return theEvent
}
registerChat(criteria, func, context) {
let event = this.registerCustom("chat", func, context)
event.trigger.setChatCriteria(criteria)
return event
}
registerSoundPlay(criteria, func, context) {
let event = this.registerCustom("soundPlay", func, context)
event.trigger.setCriteria(criteria)
return event
}
registerActionBar(criteria, func, context) {
let event = this.registerCustom("actionBar", func, context)
event.trigger.setChatCriteria(criteria)
return event
}
registerCommand(commandName, func, context) {
let event = this.registerCustom("command", func, context)
event.trigger.setName(commandName, true)
return event
}
registerStep(isFps, interval, func, context) {
let event = this.registerCustom("step", func, context)
event.trigger[isFps ? "setFps" : "setDelay"](interval)
return event
}
registerCustom(type, func, context) {
let id = this.lastChatEventId++
if (!func) throw new Error("Function must not be null")
this.customEvents[id] = {
func: func,
context: context,
trigger: register(type, (...args) => {
try {
if (context.enabled) {
if (this.recordingPerformanceUsage) this.startRecordingPerformance(context.getId(), type)
let start = Date.now()
func.call(context, ...(args || []))
let time = Date.now() - start
if (time > this.longEventTime) {
logger.logMessage("Long event triggered [" + time + "ms] (" + context.getId() + "/" + type + ")", 3)
}
if (this.recordingPerformanceUsage) this.stopRecordingPerformance(context.getId(), type)
}
} catch (e) {
logger.logMessage("Error in " + type + " event: " + JSON.stringify(e, undefined, 2), 2)
logger.logMessage(e.stack, 1)
soopyV2Server.reportError(e, "Error in " + type + " event.")
}
}),
id: id
}
return this.customEvents[id]
}
registerForge(event, func, priority, context) {
let id = this.lastForgeEventId++
this.forgeEvents[id] = {
func: func,
context: context,
trigger: registerForgeBase(event, priority, (...args) => {
try {
if (context.enabled) {
if (this.recordingPerformanceUsage) this.startRecordingPerformance(context.getId(), event.class.name)
let start = Date.now()
func.call(context, ...(args || []))
let time = Date.now() - start
if (time > this.longEventTime) {
logger.logMessage("Long (forge) event triggered (" + context.getId() + "/" + event.class.toString() + ")", 3)
}
if (this.recordingPerformanceUsage) this.stopRecordingPerformance(context.getId(), event.class.name)
}
} catch (e) {
logger.logMessage("Error in " + event.class.toString() + " (forge) event: " + JSON.stringify(e, undefined, 2), 2)
logger.logMessage(e.stack, 1)
soopyV2Server.reportError(e, "Error in " + event.class.toString() + " (forge) event.")
}
}),
id: id
}
return this.forgeEvents[id]
}
unregisterForge(event) {
if (!this.forgeEvents[event.id]) return
unregisterForgeBase(this.forgeEvents[event.id].trigger)
delete this.forgeEvents[event.id]
}
unregisterCustom(event) {
event.trigger.unregister()
delete this.customEvents[event.id]
}
unregisterEvent(event) {
if (!this.events[event.event]) return
this.events[event.event] = this.events[event.event].filter((e) => {
return e.id !== event.id
})
if (this.events[event.event].length === 0) {
this.stopCatchingEvent(event.event)
delete this.events[event.event]
}
}
unregisterSoopy(event) {
if (!this.soopyEventHandlers[event.event]) return
this.soopyEventHandlers[event.event] = this.soopyEventHandlers[event.event].filter((e) => {
return e.id !== event.id
})
if (this.soopyEventHandlers[event.event].length === 0) {
delete this.events[event.event]
}
}
loadFeatureMetas() {
let featuresDir = new File("./config/ChatTriggers/modules/" + metadata.name + "/features")
featuresDir.list().forEach((pathName) => {
if (pathName.includes(".")) return;
try {
let data = JSON.parse(FileLib.read(metadata.name + "/features/" + pathName, "metadata.json"))
if (data === null) {
return;
}
data.id = pathName
this.featureMetas[pathName] = data
} catch (e) {
logger.logMessage("Error loading feature metadata for " + pathName, 1)
logger.logMessage(JSON.stringify(e, undefined, 2), 1)
}
})
}
addPerformanceTracking(feature) {
let featureId = feature.getId()
if (!this.perfTrackingFeatures) return
Object.getOwnPropertyNames(Object.getPrototypeOf(feature)).forEach(key => {
if (typeof (feature[key]) === "function") {
let fun = feature[key].bind(feature)
feature[key] = (...args) => {
if (!this.recordingPerformanceUsage || Thread.currentThread().getId() !== 1 || !this.perfTrackingFeatures) {
let err = undefined
try {
args ? fun(...args) : fun()
} catch (e) {
err = e
}
if (err) throw err
return
}
let pushedId = false
let start = this.getExactTime()
if (this.stack.length === 0) {
this.stack.push([featureId, 0])
// this.flameGraphData.push({ isEnter: true, thing: featureId, time: start })
pushedId = true
}
this.stack.push([featureId + "." + key, 0])
// this.flameGraphData.push({ isEnter: true, thing: featureId + "." + key, time: start })
let err = undefined
try {
args ? fun(...args) : fun()
} catch (e) {
err = e
}
let nowTime = this.getExactTime()
let time = (nowTime - start) - this.stack[this.stack.length - 1][1]
this.stack[this.stack.length - 2][1] += nowTime - start
if (!this.performanceUsage[featureId]) this.performanceUsage[featureId] = {}
if (!this.performanceUsage[featureId].functions) this.performanceUsage[featureId].functions = {}
if (!this.performanceUsage[featureId].functions[key]) this.performanceUsage[featureId].functions[key] = { time: 0, count: 0 }
this.performanceUsage[featureId].functions[key].count++
this.performanceUsage[featureId].functions[key].time += nowTime - start
this.flameGraphData.push(this.stack.map(a => a[0]).join(";") + " " + (time))
this.stack.pop()[1]
if (pushedId) {
let time = (nowTime - start) - this.stack[this.stack.length - 1][1]
this.flameGraphData.push(this.stack.map(a => a[0]).join(";") + " " + (time))
this.stack.pop()
}
if (err) throw err
}
}
})
}
unloadSoopy() {
this.saveFeatureSettings()
this.unloadAllFeatures()
}
loadSoopy() {
this.loadFeatureMetas()
this.loadFeatureSettings()
Object.keys(this.featureMetas).forEach((feature) => {
if (this.featureSettingsData[feature] && this.featureSettingsData[feature].enabled) {
this.loadFeature(feature)
}
})
this.finishedLoading = true
}
loadFeature(feature) { //run in seperate thread so onenable can do network requests
if (this.features[feature]) return
try {
let LoadedFeature = RequireNoCache("../features/" + feature + "/index.js")
// let LoadedFeature = RequireNoCache(new File("config/ChatTriggers/modules/" + metadata.name + "/features/" + feature + "/index.js"))
this.features[feature] = LoadedFeature
LoadedFeature.class.setId(feature)
this.addPerformanceTracking(LoadedFeature.class)
LoadedFeature.class._onEnable(this)
logger.logMessage("Loaded feature " + feature, 3)
if (this.isDev && !this.addedWatches.has(feature)) {
this.addedWatches.add(feature)
let path = Java.type("java.nio.file.Paths").get("./config/ChatTriggers/modules/SoopyV2/features/" + feature + "/");
this.watches[path.register(this.watchService, Java.type("java.nio.file.StandardWatchEventKinds").ENTRY_MODIFY)] = feature
}
} catch (e) {
logger.logMessage("Error loading feature " + feature, 1)
logger.logMessage(JSON.stringify(e, undefined, 2), 1)
logger.logMessage(e.stack, 1)
ChatLib.chat(this.messagePrefix + "Error loading feature " + feature)
soopyV2Server.reportError(e, "Error loading feature " + feature)
}
return this
}
unloadFeature(feature) {
if (!this.features[feature]) return
this.features[feature].class._onDisable()
delete this.features[feature]
logger.logMessage("Unloaded feature " + feature, 3)
return this
}
unloadAllFeatures() {
Object.keys(this.features).forEach((feature) => {
this.unloadFeature(feature)
})
}
isFeatureLoaded(feature) {
return !!this.features[feature]
}
getLoadedFeatures() {
return Object.keys(this.features)
}
createCustomEvent(eventId) {
logger.logMessage("Registered custom " + eventId + " event", 4)
return {
trigger: (...args) => {
this.triggerSoopy(eventId, args)
}
}
}
getExactTime() {
return System.nanoTime() / 1000000
}
startRecordingPerformance(feature, event) {
if (!this.recordingPerformanceUsage) return
if (!this.performanceUsage[feature]) this.performanceUsage[feature] = {}
if (!this.performanceUsage[feature][event]) this.performanceUsage[feature][event] = { time: 0, count: 0 }
let time = this.getExactTime()
this.performanceUsage[feature][event].startTime = time
}
stopRecordingPerformance(feature, event) {
if (!this.recordingPerformanceUsage) return
let time = this.getExactTime()
this.performanceUsage[feature][event].time += (time - this.performanceUsage[feature][event].startTime)
this.performanceUsage[feature][event].count++
}
}
if (!global.soopyv2featuremanagerthing) {
global.soopyv2featuremanagerthing = new FeatureManager()
register("gameUnload", () => {
global.soopyv2featuremanagerthing = undefined
})
}
export default global.soopyv2featuremanagerthing