Compare commits

..

No commits in common. "30d125ce8ef617ae926e31c94e5348d60c009fd0" and "d8df9fa7ef0594895b7be28392ca7ce6281d91b2" have entirely different histories.

18 changed files with 14 additions and 197 deletions

View File

@ -1,6 +1,6 @@
{
"name": "@entityseven/rage-fw-browser",
"version": "0.2.0",
"version": "0.1.2",
"main": "dist/index.js",
"types": "dist/src/index.d.ts",
"files": [

View File

@ -1,6 +1,7 @@
import { Rpc } from '@entityseven/rage-fw-rpc'
export const rpc = new Rpc({
forceBrowserDevMode: process.env.RageFW_forceBrowserDevMode === 'true',
forceBrowserDevMode:
process.env.RageFW_forceBrowserDevMode === 'true' ?? false,
debugLogs: false,
})

View File

@ -1,6 +1,6 @@
{
"name": "@entityseven/rage-fw-client",
"version": "0.2.0",
"version": "0.1.2",
"main": "dist/index.js",
"types": "dist/src/index.d.ts",
"files": [

View File

@ -1,24 +1,16 @@
import { rpc } from './rpc'
import { Middleware } from './middleware'
import type * as T from '../types'
export class Client {
public register<EventName extends T.RageFW_ClientEvent>(
eventName: EventName,
callback: T.RageFW_ClientCallback<EventName>,
options?: {
middlewares?: T.RageFW_MiddlewareOptions<EventName>
},
): Client {
rpc.register<
Parameters<typeof callback>,
ReturnType<typeof callback> | Promise<unknown>,
ReturnType<typeof callback>,
EventName
>(eventName, async (...data) => {
if (!options?.middlewares) return await callback(...data)
await Middleware.process(options.middlewares, callback, data)
})
>(eventName, async (...data) => await callback(...data))
return this
}

View File

@ -1,5 +1,4 @@
export * from './client'
export * from './logger'
export * from './middleware'
export * from './player'
export * from './rpc'

View File

@ -1,54 +0,0 @@
import type * as T from '../types'
export class Middleware {
constructor() {}
private static async execute<EventName extends T.RageFW_ClientEvent>(
middlewares: T.RageFW_MiddlewareFunction<EventName>[],
args: T.RageFW_ClientArgs<EventName>,
): Promise<T.RageFW_MiddlewareResponseInternal> {
for (let i = 0; i < middlewares.length; i++) {
const result = await middlewares[i](...args)
if (typeof result === 'boolean' && !result)
return { success: result, id: i }
if (typeof result !== 'boolean' && !result.success)
return { ...result, id: i }
}
return {
success: true,
}
}
public static async process<EventName extends T.RageFW_ClientEvent>(
middlewareOptions: T.RageFW_MiddlewareOptions<EventName>,
callback: T.RageFW_ClientCallback<EventName>,
args: T.RageFW_ClientArgs<EventName>,
) {
if (Array.isArray(middlewareOptions)) {
const middlewaresResponse = await Middleware.execute(
middlewareOptions,
args,
)
if (middlewaresResponse.success) return await callback(...args)
} else {
const middlewaresResponse = await Middleware.execute(
middlewareOptions.executables,
args,
)
if (middlewaresResponse.success) {
return await callback(...args)
} else {
middlewareOptions.onError(
middlewaresResponse.message ??
'Middleware with id ' +
middlewaresResponse.id +
' failed',
)
}
}
}
}

View File

@ -1,7 +1,5 @@
import { Client, Logger, Player, rpc } from './core'
export type { RageFW_MiddlewareFunction } from './types'
export const fw = {
event: new Client(),
player: new Player(),

View File

@ -1,4 +1,3 @@
export * from './browser'
export * from './client'
export * from './middleware'
export * from './server'
export * from './browser'

View File

@ -1,26 +0,0 @@
import type * as T from './client'
export type RageFW_MiddlewareResponse =
| {
success: boolean
message?: string
}
| boolean
export type RageFW_MiddlewareResponseInternal = {
success: boolean
message?: string
id?: number
}
export type RageFW_MiddlewareFunction<EventName extends T.RageFW_ClientEvent> =
(
...args: T.RageFW_ClientArgs<EventName>
) => Promise<RageFW_MiddlewareResponse>
export type RageFW_MiddlewareOptions<EventName extends T.RageFW_ClientEvent> =
| RageFW_MiddlewareFunction<EventName>[]
| {
executables: RageFW_MiddlewareFunction<EventName>[]
onError: (error: string) => unknown
}

View File

@ -5,10 +5,10 @@
"build": "lerna run build",
"lint": "eslint --c .eslintrc.yaml --ext .ts client/ server/ shared-types/",
"rebuild:browser": "cd browser && pnpm build",
"rebuild:cef": "cd cef && pnpm build",
"rebuild:client": "cd client && pnpm build",
"rebuild:server": "cd server && pnpm build",
"rebuild": "pnpm rebuild:browser && pnpm rebuild:client && pnpm rebuild:server"
"rebuild": "pnpm rebuild:cef && pnpm rebuild:client && pnpm rebuild:server"
},
"dependencies": {
"@microsoft/api-extractor": "^7.47.0",

View File

@ -1,6 +1,6 @@
{
"name": "@entityseven/rage-fw-server",
"version": "0.2.0",
"version": "0.1.2",
"main": "dist/index.js",
"types": "dist/src/index.d.ts",
"files": [

View File

@ -1,5 +1,4 @@
export * from './logger'
export * from './middleware'
export * from './player'
export * from './rpc'
export * from './server'

View File

@ -1,54 +0,0 @@
import type * as T from '../types'
export class Middleware {
constructor() {}
private static async execute<EventName extends T.RageFW_ServerEvent>(
middlewares: T.RageFW_MiddlewareFunction<EventName>[],
args: T.RageFW_ServerArgs<EventName>,
): Promise<T.RageFW_MiddlewareResponseInternal> {
for (let i = 0; i < middlewares.length; i++) {
const result = await middlewares[i](...args)
if (typeof result === 'boolean' && !result)
return { success: result, id: i }
if (typeof result !== 'boolean' && !result.success)
return { ...result, id: i }
}
return {
success: true,
}
}
public static async process<EventName extends T.RageFW_ServerEvent>(
middlewareOptions: T.RageFW_MiddlewareOptions<EventName>,
callback: T.RageFW_ServerCallback<EventName>,
args: T.RageFW_ServerArgs<EventName>,
) {
if (Array.isArray(middlewareOptions)) {
const middlewaresResponse = await Middleware.execute(
middlewareOptions,
args,
)
if (middlewaresResponse.success) return await callback(...args)
} else {
const middlewaresResponse = await Middleware.execute(
middlewareOptions.executables,
args,
)
if (middlewaresResponse.success) {
return await callback(...args)
} else {
middlewareOptions.onError(
middlewaresResponse.message ??
'Middleware with id ' +
middlewaresResponse.id +
' failed',
)
}
}
}
}

View File

@ -1,24 +1,16 @@
import { rpc } from './rpc'
import { Middleware } from './middleware'
import type * as T from '../types'
export class Server {
public register<EventName extends T.RageFW_ServerEvent>(
eventName: EventName,
callback: T.RageFW_ServerCallback<EventName>,
options?: {
middlewares?: T.RageFW_MiddlewareOptions<EventName>
},
): Server {
rpc.register<
Parameters<typeof callback>,
ReturnType<typeof callback> | Promise<unknown>,
ReturnType<typeof callback>,
EventName
>(eventName, async (...data) => {
if (!options?.middlewares) return await callback(...data)
await Middleware.process(options.middlewares, callback, data)
})
>(eventName, async (...data) => await callback(...data))
return this
}

View File

@ -1,7 +1,5 @@
import { Logger, Player, Server, rpc } from './core'
export type { RageFW_MiddlewareFunction } from './types'
export const fw = {
event: new Server(),
player: new Player(),

View File

@ -1,4 +1,3 @@
export * from './browser'
export * from './client'
export * from './middleware'
export * from './server'
export * from './browser'

View File

@ -1,26 +0,0 @@
import type * as T from './server'
export type RageFW_MiddlewareResponse =
| {
success: boolean
message?: string
}
| boolean
export type RageFW_MiddlewareResponseInternal = {
success: boolean
message?: string
id?: number
}
export type RageFW_MiddlewareFunction<EventName extends T.RageFW_ServerEvent> =
(
...args: T.RageFW_ServerArgs<EventName>
) => Promise<RageFW_MiddlewareResponse>
export type RageFW_MiddlewareOptions<EventName extends T.RageFW_ServerEvent> =
| RageFW_MiddlewareFunction<EventName>[]
| {
executables: RageFW_MiddlewareFunction<EventName>[]
onError: (error: string) => unknown
}

View File

@ -1,6 +1,6 @@
{
"name": "@entityseven/rage-fw-shared-types",
"version": "0.2.0",
"version": "0.1.2",
"types": "types/types/index.d.ts",
"files": [
"types/**/*"