fix(process): rework

src/index.ts

@@ -12,8 +12,9 @@ import { Internals } from "./lib/net/internal";
 import { Client } from "./lib/net/util/client";
 import { Identifiers } from "./lib/net/util/identifiers";
 import { Server } from "./lib/net/util/server";
-import { Process } from "./lib/process/process";
-import Scheduler from "./lib/process/scheduler";
+import { Process } from "./lib/processes/process";
+import { IProcessImplementation } from "./lib/processes/process/types";
+import { Scheduler } from "./lib/processes/scheduler";
 import { Component, ComponentData, Flyweight, FlyweightData, TagComponent } from "./lib/types/ecs";
 import { Users } from "./lib/user";
 import { DefaultUserDeclaration } from "./lib/user/default/types";
@@ -92,14 +93,18 @@ namespace Tina {
 	 * Used to add new processes to the processor.
 	 *
 	 * @param name process name to add.
+	 * @param executionGroup your own executionGroup to run the process on.
 	 * @returns a Process object.
 	 */
-	export function process(name: string): Process {
-		if (Process.processes.has(name)) {
-			return Process.processes.get(name)!;
+	export function process(
+		name: string,
+		executionGroup?: RBXScriptSignal,
+	): IProcessImplementation {
+		if (Scheduler.has(name)) {
+			return Scheduler.get(name)!;
 		}
 
-		return new Process(name, Scheduler);
+		return new Process(name, executionGroup);
 	}
 
 	export const log: Scope = Logger.scope("TINA");
@@ -246,6 +251,10 @@ export { User, Users } from "./lib/user";
 /** State namespace */
 export { State } from "./lib/state";
 
+/** Process class and scheduler namespace */
+export { Process } from "./lib/processes/process";
+export { Scheduler } from "./lib/processes/scheduler";
+
 /** Container export */
 export { Container } from "./lib/container";
 

src/lib/processes/process.spec.ts

@@ -0,0 +1,3 @@
+/// <reference types="@rbxts/testez/globals" />
+
+export = (): void => {};

src/lib/processes/process/index.ts

@@ -0,0 +1,36 @@
+import { EventEmitter } from "../../events";
+import { Scheduler } from "../scheduler";
+import { TProcessStatus } from "../scheduler/types";
+import { IProcessImplementation } from "./types";
+
+interface IProcessEvent {
+	_default: [dt: number];
+}
+
+export class Process extends EventEmitter<IProcessEvent> implements IProcessImplementation {
+	public lastTick: number = os.clock();
+
+	public ticksPerSecond?: number;
+
+	constructor(public readonly name: string, public readonly executionGroup?: RBXScriptSignal) {
+		super();
+
+		Scheduler.add(name, this);
+	}
+
+	public resume(): void {
+		return Scheduler.unsuspend(this.name);
+	}
+
+	public suspend(ticks: number): void {
+		return Scheduler.suspend(this.name, ticks);
+	}
+
+	public status(): TProcessStatus {
+		return Scheduler.status(this.name);
+	}
+
+	public _update(dt: number): void {
+		return this.emit("_default", dt);
+	}
+}

src/lib/processes/process/types.d.ts

@@ -0,0 +1,27 @@
+import { TProcessStatus } from "../scheduler/types";
+
+export interface IProcessImplementation {
+	/**
+	 * Initializes current process.
+	 */
+	resume(): void;
+
+	/**
+	 * Suspends the current process by the given ticks, defaults to 1.
+	 *
+	 * @param ticks the amount of ticks to suspend the process.
+	 */
+	suspend(ticks: number): void;
+
+	/**
+	 * Returns the current status of the process.
+	 *
+	 * @returns A string for it's status.
+	 */
+	status(): TProcessStatus;
+
+	/**
+	 * @hidden (internal usage, DO NOT USE)
+	 */
+	_update(dt: number): void;
+}