Function createProxy

packages/jstack/src/server/client.ts:218–279

(
  baseClient: any,
  baseUrl: string,
  path: string[] = [],
)

}

function createProxy(
  baseClient: any,
  baseUrl: string,
  path: string[] = [],
): any {
  return new Proxy(baseClient, {
    get(target, prop, receiver) {
      if (typeof prop === "string") {
        const routePath = [...path, prop]

        if (prop === "$get") {
          return async (...args: any[]) => {
            const [data, options] = args
            const serializedQuery = serializeWithSuperJSON(data)
            return target.$get({ query: serializedQuery }, options)
          }
        }

        if (prop === "$post") {
          return async (...args: any[]) => {
            const [data, options] = args
            const serializedJson = serializeWithSuperJSON(data)
            return target.$post({ json: serializedJson }, options)
          }
        }

        if (prop === "$url") {
          return (args?: any) => {
            const endpointPath = `/${routePath.slice(0, -1).join("/")}`
            const normalizedPath = endpointPath.replace(baseUrl, "")
            const url = new URL(baseUrl + normalizedPath)

            if (args?.query) {
              Object.entries(args.query).forEach(([key, value]) => {
                url.searchParams.append(key, String(value))
              })
            }

            return url
          }
        }

        if (prop === "$ws") {
          return () => {
            const endpointPath = `/${routePath.slice(0, -1).join("/")}`
            const normalizedPath = endpointPath.replace(baseUrl, "")
            const url = new URL(baseUrl + normalizedPath)

            // Change protocol to ws:// or wss:// depending on if https or http
            url.protocol = url.protocol === "https:" ? "wss:" : "ws:"

            return new ClientSocket(url)
          }
        }

        return createProxy(target[prop], baseUrl, routePath)
      }