convert to pnpm workspace

This commit is contained in:
Robert Soriano
2022-05-17 08:57:07 -07:00
parent e9224c3c5e
commit 3df0b44d44
25 changed files with 420 additions and 214 deletions

View File

@@ -1,72 +0,0 @@
import { fileURLToPath } from 'url'
import { dirname, resolve } from 'path'
import { addServerHandler, addTemplate, defineNuxtModule } from '@nuxt/kit'
import fs from 'fs-extra'
export interface ModuleOptions {}
export default defineNuxtModule<ModuleOptions>({
meta: {
name: 'trpc-nuxt',
configKey: 'trpc',
},
defaults: {},
async setup(_options, nuxt) {
const srcDir = nuxt.options.srcDir
// const root = nuxt.options.rootDir
// const clientPath = join(nuxt.options.buildDir, 'trpc-client.ts')
// const runtimeDir = fileURLToPath(new URL('./runtime', import.meta.url))
// const serverPath = resolve(root, 'server/fn')
const buildDir = fileURLToPath(new URL(nuxt.options.buildDir, import.meta.url))
// const rootDir = fileURLToPath(new URL(root, import.meta.url))
// nuxt.hook('config', (options) => {
// options.build.transpile.push('trpc-nuxt/client')
// })
// nuxt.hook('autoImports:extend', (imports) => {
// imports.push({
// from: clientPath,
// name: 'useServerFn',
// as: 'useServerFn',
// })
// })
const routePath = resolve(srcDir, 'server/fn/index.ts')
await fs.ensureDir(dirname(routePath))
if (!fs.existsSync(routePath)) {
await fs.writeFile(routePath, `
// generated by trpc-nuxt
import * as trpc from '@trpc/server'
export const router = trpc
.router()
.query('hello', {
resolve: () => 'world',
});
export type Router = typeof router
`.trimStart())
}
const handlerPath = resolve(srcDir, 'server/fn')
addTemplate({
filename: 'trpc-handler.mjs',
write: true,
getContents() {
return `
import { createTRPCHandler } from 'trpc-nuxt/api'
import * as functions from "${handlerPath}"
export default createTRPCHandler({
router: functions.router
})
`.trimStart()
},
})
addServerHandler({
route: '/api/trpc/*',
handler: resolve(buildDir, 'trpc-handler.mjs'),
})
},
})

View File

@@ -1,69 +0,0 @@
import { resolveHTTPResponse } from '@trpc/server'
import type {
AnyRouter,
ProcedureType,
ResponseMeta,
TRPCError,
inferRouterContext,
inferRouterError,
} from '@trpc/server'
import { createURL } from 'ufo'
import type { IncomingMessage } from 'h3'
import type { TRPCResponse } from '@trpc/server/dist/declarations/src/rpc'
import { isMethod, useBody } from 'h3'
type MaybePromise<T> = T | Promise<T>
type CreateContextFn<TRouter extends AnyRouter> = (req: IncomingMessage) => MaybePromise<inferRouterContext<TRouter>>
type ResponseMetaFn<TRouter extends AnyRouter> = (opts: {
data: TRPCResponse<unknown, inferRouterError<TRouter>>[]
ctx?: inferRouterContext<TRouter>
paths?: string[]
type: ProcedureType | 'unknown'
errors: TRPCError[]
}) => ResponseMeta
export function createTRPCHandler<Router extends AnyRouter>({
router,
createContext,
responseMeta,
}: {
router: Router
createContext?: CreateContextFn<Router>
responseMeta?: ResponseMetaFn<Router>
}) {
const url = '/trpc'
return async (event) => {
const {
req,
res,
} = event
const $url = createURL(req.url)
const httpResponse = await resolveHTTPResponse({
router,
req: {
method: req.method,
headers: req.headers,
body: isMethod(event, 'GET') ? null : await useBody(event),
query: $url.searchParams,
},
path: $url.pathname.substring(url.length + 5),
createContext: async () => createContext?.(req),
responseMeta,
})
const { status, headers, body } = httpResponse
res.statusCode = status
Object.keys(headers).forEach((key) => {
res.setHeader(key, headers[key])
})
return body
}
}