@panter/cloud-tasks - npm Package Compare versions

Comparing version 2.0.2 to 3.0.0

dist/index.cjs

@@ -1,1 +0,1 @@
-"use strict";var A=Object.create;var p=Object.defineProperty;var N=Object.getOwnPropertyDescriptor;var M=Object.getOwnPropertyNames;var O=Object.getPrototypeOf,L=Object.prototype.hasOwnProperty;var a=(r,t)=>p(r,"name",{value:t,configurable:!0});var j=(r,t)=>{for(var e in t)p(r,e,{get:t[e],enumerable:!0})},P=(r,t,e,o)=>{if(t&&typeof t=="object"||typeof t=="function")for(let s of M(t))!L.call(r,s)&&s!==e&&p(r,s,{get:()=>t[s],enumerable:!(o=N(t,s))||o.enumerable});return r};var Q=(r,t,e)=>(e=r!=null?A(O(r)):{},P(t||!r||!r.__esModule?p(e,"default",{value:r,enumerable:!0}):e,r)),K=r=>P(p({},"__esModule",{value:!0}),r);var G={};j(G,{createExpressTaskServer:()=>I,createExpressTaskServerMiddleware:()=>S,createTasksClient:()=>_,createTasksServer:()=>U});module.exports=K(G);var T=require("@google-cloud/tasks"),C=require("@grpc/grpc-js"),x=require("google-auth-library"),g=require("google-gax"),i=require("ts-results-es");var d=class{constructor(t,e,o,s){this.client=t;this.location=e;this.queueName=o;this.logger=s;this.projectIdPromise=this.client.getProjectId(),this.serviceAccountEmailPromise=new x.GoogleAuth().getCredentials().then(n=>n.client_email??null)}static{a(this,"CommonTasksClient")}serviceAccountEmailPromise;projectIdPromise;async upsertQueue(t){try{let e=await this.projectIdPromise,o=this.client.queuePath(e,this.location,this.queueName),s=this.client.locationPath(e,this.location);this.logger.info({queuePath:o,parentPath:s},"upserting tasks queue");let n="create";try{await this.client.getQueue({name:o}),n="update"}catch(u){if(k(u)&&u.code===g.Status.NOT_FOUND)n="create";else throw u}return n==="update"?(this.logger.info({queuePath:o},"updating existing queue"),await this.client.updateQueue({queue:{name:o,...t}})):(this.logger.info({queuePath:o},"creating new queue"),await this.client.createQueue({parent:s,queue:{name:o,...t}})),i.Ok.EMPTY}catch(e){return(0,i.Err)(l(e))}}async listTasks(){try{let t=await this.projectIdPromise,e=this.client.queuePath(t,this.location,this.queueName),[o]=await this.client.listTasks({parent:e});return(0,i.Ok)(o)}catch(t){return(0,i.Err)(l(t))}}async createTask(t,e){try{let o=await this.projectIdPromise,s=this.client.queuePath(o,this.location,this.queueName),n=this.client.taskPath(o,this.location,this.queueName,b(t)),u=await this.serviceAccountEmailPromise;return this.logger.info({queuePath:s,taskPath:n,url:e?.httpRequest?.url,payload:e?.httpRequest?.body,serviceAccountEmail:u},"scheduling task"),await this.client.createTask({parent:s,task:{...e,name:n,httpRequest:{...e?.httpRequest,oidcToken:{serviceAccountEmail:u}}}}),(0,i.Ok)(n)}catch(o){return(0,i.Err)(l(o))}}async getTask(t){try{let[e]=await this.client.getTask({name:t});return(0,i.Ok)(e)}catch(e){return k(e)&&e.code===g.Status.NOT_FOUND?(0,i.Ok)(null):(0,i.Err)(l(e))}}},m=class extends d{static{a(this,"RegularTasksClient")}constructor(t,e,o){super(new T.CloudTasksClient({}),t,e,o)}},h=class extends d{static{a(this,"EmulatorTasksClient")}constructor(t,e,o,s){super(new T.CloudTasksClient({sslCreds:C.credentials.createInsecure(),servicePath:s.host??"localhost",port:s.port}),t,e,o)}async upsertQueue(t){try{let e=await this.projectIdPromise,o=this.client.queuePath(e,this.location,this.queueName),s=this.client.locationPath(e,this.location);this.logger.info({queuePath:o,parentPath:s},"upserting simulator tasks queue");try{return await this.client.createQueue({parent:s,queue:{name:o,...t}}),i.Ok.EMPTY}catch(n){return k(n)&&n.code!==g.Status.ALREADY_EXISTS?(0,i.Err)(l(n)):(this.logger.warn({},"dev warning: the queue was not updated due to the emulator not supporting update"),this.logger.warn({},"if you need to update queue options, restart the emulator"),i.Ok.EMPTY)}}catch(e){return(0,i.Err)(l(e))}}async createTask(t,e){return super.createTask(t,{...e,httpRequest:{...e?.httpRequest,url:e?.httpRequest?.url?.replace("//localhost","//host.containers.internal")}})}};function b(r){let t=new Uint8Array(3);crypto.getRandomValues(t);let e=Buffer.from(t).toString("hex");return`${r}-${Date.now()}-${e}`}a(b,"createUniqueName");function k(r){return r instanceof Error&&"code"in r&&Number.isInteger(r.code)}a(k,"isRpcError");function l(r){return k(r)?{...r,type:"rpc"}:{type:"unknown",error:r}}a(l,"toTasksError");function _({queueName:r,emulator:t=!1,location:e="europe-west6",tasksWorkerUrl:o,queueOptions:s,logger:n={error:console.error,info:console.info,warn:console.warn}}){n.info({queueName:r,emulator:t,location:e,tasksWorkerUrl:o},"creating tasks client");let u=t?new h(e,r,n,t):new m(e,r,n);return new Proxy({},{get:a((D,y)=>y==="_manage"?{find:a(c=>u.getTask(c).then(f=>f.unwrap()),"find"),list:a(()=>u.listTasks().then(c=>c.unwrap()),"list")}:{schedule:a(async(c,f)=>{let w=y.toString();await u.upsertQueue(s);let R=new URL(`/trpc/${w}`,o).toString();return n.info({url:R,input:c},"scheduling http request that calls trpc mutation of tasks worker"),(await u.createTask(w,{...f,httpRequest:{httpMethod:"POST",url:R,headers:{"Content-Type":"application/json"},body:c?Buffer.from(JSON.stringify(c)).toString("base64"):null}})).unwrap()},"schedule")},"get")})}a(_,"createTasksClient");var v=require("@trpc/server"),q=require("@trpc/server/adapters/express"),E=Q(require("express"));var S=a(r=>{let t=v.initTRPC.create(),e=r(t);return{expressMiddleware:(0,q.createExpressMiddleware)({router:e}),router:e}},"createExpressTaskServerMiddleware");function I(r,t){let e=t??(0,E.default)(),{expressMiddleware:o,router:s}=S(r);return e.use("/trpc",o),{runServer:a(n=>{e.listen({port:n})},"runServer"),router:s}}a(I,"createExpressTaskServer");var U=I;
+"use strict";var S=Object.create;var p=Object.defineProperty;var A=Object.getOwnPropertyDescriptor;var N=Object.getOwnPropertyNames;var O=Object.getPrototypeOf,M=Object.prototype.hasOwnProperty;var a=(r,t)=>p(r,"name",{value:t,configurable:!0});var L=(r,t)=>{for(var e in t)p(r,e,{get:t[e],enumerable:!0})},x=(r,t,e,o)=>{if(t&&typeof t=="object"||typeof t=="function")for(let n of N(t))!M.call(r,n)&&n!==e&&p(r,n,{get:()=>t[n],enumerable:!(o=A(t,n))||o.enumerable});return r};var j=(r,t,e)=>(e=r!=null?S(O(r)):{},x(t||!r||!r.__esModule?p(e,"default",{value:r,enumerable:!0}):e,r)),Q=r=>x(p({},"__esModule",{value:!0}),r);var U={};L(U,{createExpressTaskServer:()=>_,createExpressTaskServerMiddleware:()=>I,createTasksClient:()=>K});module.exports=Q(U);var y=require("@google-cloud/tasks"),w=require("@grpc/grpc-js"),P=require("google-auth-library"),d=require("google-gax"),i=require("ts-results-es");var g=class{constructor(t,e,o,n){this.client=t;this.location=e;this.queueName=o;this.logger=n;this.projectIdPromise=this.client.getProjectId(),this.serviceAccountEmailPromise=new P.GoogleAuth().getCredentials().then(s=>s.client_email??null)}static{a(this,"CommonTasksClient")}serviceAccountEmailPromise;projectIdPromise;async upsertQueue(t){try{let e=await this.projectIdPromise,o=this.client.queuePath(e,this.location,this.queueName),n=this.client.locationPath(e,this.location);this.logger.info({queuePath:o,parentPath:n},"upserting tasks queue");let s="create";try{await this.client.getQueue({name:o}),s="update"}catch(u){if(k(u)&&u.code===d.Status.NOT_FOUND)s="create";else throw u}return s==="update"?(this.logger.info({queuePath:o},"updating existing queue"),await this.client.updateQueue({queue:{name:o,...t}})):(this.logger.info({queuePath:o},"creating new queue"),await this.client.createQueue({parent:n,queue:{name:o,...t}})),i.Ok.EMPTY}catch(e){return(0,i.Err)(l(e))}}async listTasks(){try{let t=await this.projectIdPromise,e=this.client.queuePath(t,this.location,this.queueName),[o]=await this.client.listTasks({parent:e});return(0,i.Ok)(o)}catch(t){return(0,i.Err)(l(t))}}async createTask(t,e){try{let o=await this.projectIdPromise,n=this.client.queuePath(o,this.location,this.queueName),s=this.client.taskPath(o,this.location,this.queueName,b(t)),u=await this.serviceAccountEmailPromise;return this.logger.info({queuePath:n,taskPath:s,url:e?.httpRequest?.url,payload:e?.httpRequest?.body,serviceAccountEmail:u},"scheduling task"),await this.client.createTask({parent:n,task:{...e,name:s,httpRequest:{...e?.httpRequest,oidcToken:{serviceAccountEmail:u}}}}),(0,i.Ok)(s)}catch(o){return(0,i.Err)(l(o))}}async getTask(t){try{let[e]=await this.client.getTask({name:t});return(0,i.Ok)(e)}catch(e){return k(e)&&e.code===d.Status.NOT_FOUND?(0,i.Ok)(null):(0,i.Err)(l(e))}}},m=class extends g{static{a(this,"RegularTasksClient")}constructor(t,e,o){super(new y.CloudTasksClient({}),t,e,o)}},h=class extends g{static{a(this,"EmulatorTasksClient")}constructor(t,e,o,n){super(new y.CloudTasksClient({sslCreds:w.credentials.createInsecure(),servicePath:n.host??"localhost",port:n.port}),t,e,o)}async upsertQueue(t){try{let e=await this.projectIdPromise,o=this.client.queuePath(e,this.location,this.queueName),n=this.client.locationPath(e,this.location);this.logger.info({queuePath:o,parentPath:n},"upserting simulator tasks queue");try{return await this.client.createQueue({parent:n,queue:{name:o,...t}}),i.Ok.EMPTY}catch(s){return k(s)&&s.code!==d.Status.ALREADY_EXISTS?(0,i.Err)(l(s)):(this.logger.warn({},"dev warning: the queue was not updated due to the emulator not supporting update"),this.logger.warn({},"if you need to update queue options, restart the emulator"),i.Ok.EMPTY)}}catch(e){return(0,i.Err)(l(e))}}async createTask(t,e){return super.createTask(t,{...e,httpRequest:{...e?.httpRequest,url:e?.httpRequest?.url?.replace("//localhost","//host.containers.internal")}})}};function b(r){let t=new Uint8Array(3);crypto.getRandomValues(t);let e=Buffer.from(t).toString("hex");return`${r}-${Date.now()}-${e}`}a(b,"createUniqueName");function k(r){return r instanceof Error&&"code"in r&&Number.isInteger(r.code)}a(k,"isRpcError");function l(r){return k(r)?{...r,type:"rpc"}:{type:"unknown",error:r}}a(l,"toTasksError");function K({queueName:r,emulator:t=!1,location:e="europe-west6",tasksWorkerUrl:o,queueOptions:n,logger:s={error:console.error,info:console.info,warn:console.warn}}){s.info({queueName:r,emulator:t,location:e,tasksWorkerUrl:o},"creating tasks client");let u=t?new h(e,r,s,t):new m(e,r,s);return new Proxy({},{get:a((F,f)=>f==="_manage"?{find:a(c=>u.getTask(c).then(T=>T.unwrap()),"find"),list:a(()=>u.listTasks().then(c=>c.unwrap()),"list")}:{schedule:a(async(c,T)=>{let C=f.toString();await u.upsertQueue(n);let R=new URL(`/trpc/${C}`,o).toString();return s.info({url:R,input:c},"scheduling http request that calls trpc mutation of tasks worker"),(await u.createTask(C,{...T,httpRequest:{httpMethod:"POST",url:R,headers:{"Content-Type":"application/json"},body:c?Buffer.from(JSON.stringify(c)).toString("base64"):null}})).unwrap()},"schedule")},"get")})}a(K,"createTasksClient");var q=require("@trpc/server"),v=require("@trpc/server/adapters/express"),E=j(require("express"));var I=a(({createRouter:r,createContext:t})=>{let e=q.initTRPC.context().create(),o=r(e);return{expressMiddleware:(0,v.createExpressMiddleware)({router:o,createContext:t}),router:o}},"createExpressTaskServerMiddleware");function _({createRouter:r,createContext:t,app:e=(0,E.default)()}){let{expressMiddleware:o,router:n}=I({createRouter:r,createContext:t});return e.use("/trpc",o),{runServer:a(s=>{e.listen({port:s})},"runServer"),router:n}}a(_,"createExpressTaskServer");

dist/index.mjs

@@ -1,1 +0,1 @@
-var P=Object.defineProperty;var n=(o,t)=>P(o,"name",{value:t,configurable:!0});import{CloudTasksClient as R}from"@google-cloud/tasks";import{credentials as C}from"@grpc/grpc-js";import{GoogleAuth as x}from"google-auth-library";import{Status as f}from"google-gax";import{Err as l,Ok as c}from"ts-results-es";var g=class{constructor(t,e,r,a){this.client=t;this.location=e;this.queueName=r;this.logger=a;this.projectIdPromise=this.client.getProjectId(),this.serviceAccountEmailPromise=new x().getCredentials().then(s=>s.client_email??null)}static{n(this,"CommonTasksClient")}serviceAccountEmailPromise;projectIdPromise;async upsertQueue(t){try{let e=await this.projectIdPromise,r=this.client.queuePath(e,this.location,this.queueName),a=this.client.locationPath(e,this.location);this.logger.info({queuePath:r,parentPath:a},"upserting tasks queue");let s="create";try{await this.client.getQueue({name:r}),s="update"}catch(i){if(h(i)&&i.code===f.NOT_FOUND)s="create";else throw i}return s==="update"?(this.logger.info({queuePath:r},"updating existing queue"),await this.client.updateQueue({queue:{name:r,...t}})):(this.logger.info({queuePath:r},"creating new queue"),await this.client.createQueue({parent:a,queue:{name:r,...t}})),c.EMPTY}catch(e){return l(p(e))}}async listTasks(){try{let t=await this.projectIdPromise,e=this.client.queuePath(t,this.location,this.queueName),[r]=await this.client.listTasks({parent:e});return c(r)}catch(t){return l(p(t))}}async createTask(t,e){try{let r=await this.projectIdPromise,a=this.client.queuePath(r,this.location,this.queueName),s=this.client.taskPath(r,this.location,this.queueName,v(t)),i=await this.serviceAccountEmailPromise;return this.logger.info({queuePath:a,taskPath:s,url:e?.httpRequest?.url,payload:e?.httpRequest?.body,serviceAccountEmail:i},"scheduling task"),await this.client.createTask({parent:a,task:{...e,name:s,httpRequest:{...e?.httpRequest,oidcToken:{serviceAccountEmail:i}}}}),c(s)}catch(r){return l(p(r))}}async getTask(t){try{let[e]=await this.client.getTask({name:t});return c(e)}catch(e){return h(e)&&e.code===f.NOT_FOUND?c(null):l(p(e))}}},d=class extends g{static{n(this,"RegularTasksClient")}constructor(t,e,r){super(new R({}),t,e,r)}},m=class extends g{static{n(this,"EmulatorTasksClient")}constructor(t,e,r,a){super(new R({sslCreds:C.createInsecure(),servicePath:a.host??"localhost",port:a.port}),t,e,r)}async upsertQueue(t){try{let e=await this.projectIdPromise,r=this.client.queuePath(e,this.location,this.queueName),a=this.client.locationPath(e,this.location);this.logger.info({queuePath:r,parentPath:a},"upserting simulator tasks queue");try{return await this.client.createQueue({parent:a,queue:{name:r,...t}}),c.EMPTY}catch(s){return h(s)&&s.code!==f.ALREADY_EXISTS?l(p(s)):(this.logger.warn({},"dev warning: the queue was not updated due to the emulator not supporting update"),this.logger.warn({},"if you need to update queue options, restart the emulator"),c.EMPTY)}}catch(e){return l(p(e))}}async createTask(t,e){return super.createTask(t,{...e,httpRequest:{...e?.httpRequest,url:e?.httpRequest?.url?.replace("//localhost","//host.containers.internal")}})}};function v(o){let t=new Uint8Array(3);crypto.getRandomValues(t);let e=Buffer.from(t).toString("hex");return`${o}-${Date.now()}-${e}`}n(v,"createUniqueName");function h(o){return o instanceof Error&&"code"in o&&Number.isInteger(o.code)}n(h,"isRpcError");function p(o){return h(o)?{...o,type:"rpc"}:{type:"unknown",error:o}}n(p,"toTasksError");function D({queueName:o,emulator:t=!1,location:e="europe-west6",tasksWorkerUrl:r,queueOptions:a,logger:s={error:console.error,info:console.info,warn:console.warn}}){s.info({queueName:o,emulator:t,location:e,tasksWorkerUrl:r},"creating tasks client");let i=t?new m(e,o,s,t):new d(e,o,s);return new Proxy({},{get:n((N,T)=>T==="_manage"?{find:n(u=>i.getTask(u).then(k=>k.unwrap()),"find"),list:n(()=>i.listTasks().then(u=>u.unwrap()),"list")}:{schedule:n(async(u,k)=>{let y=T.toString();await i.upsertQueue(a);let w=new URL(`/trpc/${y}`,r).toString();return s.info({url:w,input:u},"scheduling http request that calls trpc mutation of tasks worker"),(await i.createTask(y,{...k,httpRequest:{httpMethod:"POST",url:w,headers:{"Content-Type":"application/json"},body:u?Buffer.from(JSON.stringify(u)).toString("base64"):null}})).unwrap()},"schedule")},"get")})}n(D,"createTasksClient");import{initTRPC as q}from"@trpc/server";import{createExpressMiddleware as E}from"@trpc/server/adapters/express";import S from"express";var I=n(o=>{let t=q.create(),e=o(t);return{expressMiddleware:E({router:e}),router:e}},"createExpressTaskServerMiddleware");function A(o,t){let e=t??S(),{expressMiddleware:r,router:a}=I(o);return e.use("/trpc",r),{runServer:n(s=>{e.listen({port:s})},"runServer"),router:a}}n(A,"createExpressTaskServer");var V=A;export{A as createExpressTaskServer,I as createExpressTaskServerMiddleware,D as createTasksClient,V as createTasksServer};
+var x=Object.defineProperty;var a=(o,t)=>x(o,"name",{value:t,configurable:!0});import{CloudTasksClient as R}from"@google-cloud/tasks";import{credentials as w}from"@grpc/grpc-js";import{GoogleAuth as P}from"google-auth-library";import{Status as T}from"google-gax";import{Err as l,Ok as c}from"ts-results-es";var d=class{constructor(t,e,r,s){this.client=t;this.location=e;this.queueName=r;this.logger=s;this.projectIdPromise=this.client.getProjectId(),this.serviceAccountEmailPromise=new P().getCredentials().then(n=>n.client_email??null)}static{a(this,"CommonTasksClient")}serviceAccountEmailPromise;projectIdPromise;async upsertQueue(t){try{let e=await this.projectIdPromise,r=this.client.queuePath(e,this.location,this.queueName),s=this.client.locationPath(e,this.location);this.logger.info({queuePath:r,parentPath:s},"upserting tasks queue");let n="create";try{await this.client.getQueue({name:r}),n="update"}catch(i){if(h(i)&&i.code===T.NOT_FOUND)n="create";else throw i}return n==="update"?(this.logger.info({queuePath:r},"updating existing queue"),await this.client.updateQueue({queue:{name:r,...t}})):(this.logger.info({queuePath:r},"creating new queue"),await this.client.createQueue({parent:s,queue:{name:r,...t}})),c.EMPTY}catch(e){return l(p(e))}}async listTasks(){try{let t=await this.projectIdPromise,e=this.client.queuePath(t,this.location,this.queueName),[r]=await this.client.listTasks({parent:e});return c(r)}catch(t){return l(p(t))}}async createTask(t,e){try{let r=await this.projectIdPromise,s=this.client.queuePath(r,this.location,this.queueName),n=this.client.taskPath(r,this.location,this.queueName,q(t)),i=await this.serviceAccountEmailPromise;return this.logger.info({queuePath:s,taskPath:n,url:e?.httpRequest?.url,payload:e?.httpRequest?.body,serviceAccountEmail:i},"scheduling task"),await this.client.createTask({parent:s,task:{...e,name:n,httpRequest:{...e?.httpRequest,oidcToken:{serviceAccountEmail:i}}}}),c(n)}catch(r){return l(p(r))}}async getTask(t){try{let[e]=await this.client.getTask({name:t});return c(e)}catch(e){return h(e)&&e.code===T.NOT_FOUND?c(null):l(p(e))}}},g=class extends d{static{a(this,"RegularTasksClient")}constructor(t,e,r){super(new R({}),t,e,r)}},m=class extends d{static{a(this,"EmulatorTasksClient")}constructor(t,e,r,s){super(new R({sslCreds:w.createInsecure(),servicePath:s.host??"localhost",port:s.port}),t,e,r)}async upsertQueue(t){try{let e=await this.projectIdPromise,r=this.client.queuePath(e,this.location,this.queueName),s=this.client.locationPath(e,this.location);this.logger.info({queuePath:r,parentPath:s},"upserting simulator tasks queue");try{return await this.client.createQueue({parent:s,queue:{name:r,...t}}),c.EMPTY}catch(n){return h(n)&&n.code!==T.ALREADY_EXISTS?l(p(n)):(this.logger.warn({},"dev warning: the queue was not updated due to the emulator not supporting update"),this.logger.warn({},"if you need to update queue options, restart the emulator"),c.EMPTY)}}catch(e){return l(p(e))}}async createTask(t,e){return super.createTask(t,{...e,httpRequest:{...e?.httpRequest,url:e?.httpRequest?.url?.replace("//localhost","//host.containers.internal")}})}};function q(o){let t=new Uint8Array(3);crypto.getRandomValues(t);let e=Buffer.from(t).toString("hex");return`${o}-${Date.now()}-${e}`}a(q,"createUniqueName");function h(o){return o instanceof Error&&"code"in o&&Number.isInteger(o.code)}a(h,"isRpcError");function p(o){return h(o)?{...o,type:"rpc"}:{type:"unknown",error:o}}a(p,"toTasksError");function F({queueName:o,emulator:t=!1,location:e="europe-west6",tasksWorkerUrl:r,queueOptions:s,logger:n={error:console.error,info:console.info,warn:console.warn}}){n.info({queueName:o,emulator:t,location:e,tasksWorkerUrl:r},"creating tasks client");let i=t?new m(e,o,n,t):new g(e,o,n);return new Proxy({},{get:a((A,y)=>y==="_manage"?{find:a(u=>i.getTask(u).then(k=>k.unwrap()),"find"),list:a(()=>i.listTasks().then(u=>u.unwrap()),"list")}:{schedule:a(async(u,k)=>{let f=y.toString();await i.upsertQueue(s);let C=new URL(`/trpc/${f}`,r).toString();return n.info({url:C,input:u},"scheduling http request that calls trpc mutation of tasks worker"),(await i.createTask(f,{...k,httpRequest:{httpMethod:"POST",url:C,headers:{"Content-Type":"application/json"},body:u?Buffer.from(JSON.stringify(u)).toString("base64"):null}})).unwrap()},"schedule")},"get")})}a(F,"createTasksClient");import{initTRPC as v}from"@trpc/server";import{createExpressMiddleware as E}from"@trpc/server/adapters/express";import I from"express";var S=a(({createRouter:o,createContext:t})=>{let e=v.context().create(),r=o(e);return{expressMiddleware:E({router:r,createContext:t}),router:r}},"createExpressTaskServerMiddleware");function H({createRouter:o,createContext:t,app:e=I()}){let{expressMiddleware:r,router:s}=S({createRouter:o,createContext:t});return e.use("/trpc",r),{runServer:a(n=>{e.listen({port:n})},"runServer"),router:s}}a(H,"createExpressTaskServer");export{H as createExpressTaskServer,S as createExpressTaskServerMiddleware,F as createTasksClient};

dist/server.cjs

@@ -1,1 +0,1 @@
-"use strict";var m=Object.create;var n=Object.defineProperty;var y=Object.getOwnPropertyDescriptor;var l=Object.getOwnPropertyNames;var f=Object.getPrototypeOf,A=Object.prototype.hasOwnProperty;var p=(e,r)=>n(e,"name",{value:r,configurable:!0});var T=(e,r)=>{for(var t in r)n(e,t,{get:r[t],enumerable:!0})},u=(e,r,t,s)=>{if(r&&typeof r=="object"||typeof r=="function")for(let o of l(r))!A.call(e,o)&&o!==t&&n(e,o,{get:()=>r[o],enumerable:!(s=y(r,o))||s.enumerable});return e};var v=(e,r,t)=>(t=e!=null?m(f(e)):{},u(r||!e||!e.__esModule?n(t,"default",{value:e,enumerable:!0}):t,e)),w=e=>u(n({},"__esModule",{value:!0}),e);var M={};T(M,{createExpressTaskServer:()=>x,createExpressTaskServerMiddleware:()=>R,createTasksServer:()=>C});module.exports=w(M);var a=require("@trpc/server"),c=require("@trpc/server/adapters/express"),i=v(require("express"));var R=p(e=>{let r=a.initTRPC.create(),t=e(r);return{expressMiddleware:(0,c.createExpressMiddleware)({router:t}),router:t}},"createExpressTaskServerMiddleware");function x(e,r){let t=r??(0,i.default)(),{expressMiddleware:s,router:o}=R(e);return t.use("/trpc",s),{runServer:p(d=>{t.listen({port:d})},"runServer"),router:o}}p(x,"createExpressTaskServer");var C=x;
+"use strict";var i=Object.create;var s=Object.defineProperty;var d=Object.getOwnPropertyDescriptor;var y=Object.getOwnPropertyNames;var T=Object.getPrototypeOf,m=Object.prototype.hasOwnProperty;var x=(e,t)=>s(e,"name",{value:t,configurable:!0});var A=(e,t)=>{for(var r in t)s(e,r,{get:t[r],enumerable:!0})},p=(e,t,r,n)=>{if(t&&typeof t=="object"||typeof t=="function")for(let o of y(t))!m.call(e,o)&&o!==r&&s(e,o,{get:()=>t[o],enumerable:!(n=d(t,o))||n.enumerable});return e};var w=(e,t,r)=>(r=e!=null?i(T(e)):{},p(t||!e||!e.__esModule?s(r,"default",{value:e,enumerable:!0}):r,e)),f=e=>p(s({},"__esModule",{value:!0}),e);var P={};A(P,{createExpressTaskServer:()=>l,createExpressTaskServerMiddleware:()=>R});module.exports=f(P);var a=require("@trpc/server"),C=require("@trpc/server/adapters/express"),u=w(require("express"));var R=x(({createRouter:e,createContext:t})=>{let r=a.initTRPC.context().create(),n=e(r);return{expressMiddleware:(0,C.createExpressMiddleware)({router:n,createContext:t}),router:n}},"createExpressTaskServerMiddleware");function l({createRouter:e,createContext:t,app:r=(0,u.default)()}){let{expressMiddleware:n,router:o}=R({createRouter:e,createContext:t});return r.use("/trpc",n),{runServer:x(c=>{r.listen({port:c})},"runServer"),router:o}}x(l,"createExpressTaskServer");

dist/server.d.ts

 import type { AnyRouter } from "@trpc/server";
 import { initTRPC } from "@trpc/server";
+import { NodeHTTPCreateContextFnOptions } from "@trpc/server/adapters/node-http";
 import express from "express";
-type CreateRouter<Router extends AnyRouter> = (t: ReturnType<(typeof initTRPC)["create"]>) => Router;
-export declare const createExpressTaskServerMiddleware: <Router extends AnyRouter>(createRouter: CreateRouter<Router>) => {
+type TRPCInstance<Context extends object> = ReturnType<ReturnType<typeof initTRPC.context<Context>>["create"]>;
+type CreateRouter<Router extends AnyRouter, Context extends object> = (t: TRPCInstance<Context>) => Router;
+export declare const createExpressTaskServerMiddleware: <Router extends AnyRouter, CreateContext extends (opts: NodeHTTPCreateContextFnOptions<express.Request, express.Response>) => any>({ createRouter, createContext, }: {
+    createRouter: CreateRouter<Router, Awaited<ReturnType<CreateContext>>>;
+    createContext?: CreateContext;
+}) => {
     expressMiddleware: express.Handler;
     router: Router;
 };
-export declare function createExpressTaskServer<Router extends AnyRouter>(createRouter: CreateRouter<Router>, existingApp?: express.Application): {
+export declare function createExpressTaskServer<Router extends AnyRouter, CreateContext extends (opts: NodeHTTPCreateContextFnOptions<express.Request, express.Response>) => any>({ createRouter, createContext, app, }: {
+    createRouter: CreateRouter<Router, Awaited<ReturnType<CreateContext>>>;
+    createContext: CreateContext;
+    app?: express.Application;
+}): {
     runServer: (port: number) => void;
     router: Router;
 };
-/**
- * @deprecated Use `createExpressTaskServer` instead
- */
-export declare const createTasksServer: typeof createExpressTaskServer;
 export {};
 //# sourceMappingURL=server.d.ts.map

dist/server.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"server.d.ts","sourceRoot":"","sources":["../src/server.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,SAAS,EAAE,MAAM,cAAc,CAAC;AAC9C,OAAO,EAAE,QAAQ,EAAE,MAAM,cAAc,CAAC;AAExC,OAAO,OAAO,MAAM,SAAS,CAAC;AAE9B,KAAK,YAAY,CAAC,MAAM,SAAS,SAAS,IAAI,CAC5C,CAAC,EAAE,UAAU,CAAC,CAAC,OAAO,QAAQ,CAAC,CAAC,QAAQ,CAAC,CAAC,KACvC,MAAM,CAAC;AAEZ,eAAO,MAAM,iCAAiC,GAAI,MAAM,SAAS,SAAS,EACxE,cAAc,YAAY,CAAC,MAAM,CAAC;;;CASnC,CAAC;AACF,wBAAgB,uBAAuB,CAAC,MAAM,SAAS,SAAS,EAC9D,YAAY,EAAE,YAAY,CAAC,MAAM,CAAC,EAClC,WAAW,CAAC,EAAE,OAAO,CAAC,WAAW;sBAQb,MAAM;;EAK3B;AAED;;GAEG;AACH,eAAO,MAAM,iBAAiB,gCAA0B,CAAC"}
+{"version":3,"file":"server.d.ts","sourceRoot":"","sources":["../src/server.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,SAAS,EAAE,MAAM,cAAc,CAAC;AAC9C,OAAO,EAAE,QAAQ,EAAE,MAAM,cAAc,CAAC;AAExC,OAAO,EAAE,8BAA8B,EAAE,MAAM,iCAAiC,CAAC;AACjF,OAAO,OAAO,MAAM,SAAS,CAAC;AAE9B,KAAK,YAAY,CAAC,OAAO,SAAS,MAAM,IAAI,UAAU,CACpD,UAAU,CAAC,OAAO,QAAQ,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC,CAAC,QAAQ,CAAC,CACvD,CAAC;AAEF,KAAK,YAAY,CAAC,MAAM,SAAS,SAAS,EAAE,OAAO,SAAS,MAAM,IAAI,CACpE,CAAC,EAAE,YAAY,CAAC,OAAO,CAAC,KACrB,MAAM,CAAC;AAEZ,eAAO,MAAM,iCAAiC,GAC5C,MAAM,SAAS,SAAS,EACxB,aAAa,SAAS,CACpB,IAAI,EAAE,8BAA8B,CAAC,OAAO,CAAC,OAAO,EAAE,OAAO,CAAC,QAAQ,CAAC,KACpE,GAAG,EACR,kCAGC;IACD,YAAY,EAAE,YAAY,CAAC,MAAM,EAAE,OAAO,CAAC,UAAU,CAAC,aAAa,CAAC,CAAC,CAAC,CAAC;IACvE,aAAa,CAAC,EAAE,aAAa,CAAC;CAC/B;;;CAaA,CAAC;AACF,wBAAgB,uBAAuB,CACrC,MAAM,SAAS,SAAS,EACxB,aAAa,SAAS,CACpB,IAAI,EAAE,8BAA8B,CAAC,OAAO,CAAC,OAAO,EAAE,OAAO,CAAC,QAAQ,CAAC,KACpE,GAAG,EACR,EACA,YAAY,EACZ,aAAa,EACb,GAAe,GAChB,EAAE;IACD,YAAY,EAAE,YAAY,CAAC,MAAM,EAAE,OAAO,CAAC,UAAU,CAAC,aAAa,CAAC,CAAC,CAAC,CAAC;IACvE,aAAa,EAAE,aAAa,CAAC;IAC7B,GAAG,CAAC,EAAE,OAAO,CAAC,WAAW,CAAC;CAC3B;sBAQqB,MAAM;;EAK3B"}

dist/server.mjs

@@ -1,1 +0,1 @@
-var u=Object.defineProperty;var o=(e,r)=>u(e,"name",{value:r,configurable:!0});import{initTRPC as a}from"@trpc/server";import{createExpressMiddleware as c}from"@trpc/server/adapters/express";import i from"express";var R=o(e=>{let r=a.create(),t=e(r);return{expressMiddleware:c({router:t}),router:t}},"createExpressTaskServerMiddleware");function x(e,r){let t=r??i(),{expressMiddleware:s,router:n}=R(e);return t.use("/trpc",s),{runServer:o(p=>{t.listen({port:p})},"runServer"),router:n}}o(x,"createExpressTaskServer");var f=x;export{x as createExpressTaskServer,R as createExpressTaskServerMiddleware,f as createTasksServer};
+var p=Object.defineProperty;var n=(e,t)=>p(e,"name",{value:t,configurable:!0});import{initTRPC as a}from"@trpc/server";import{createExpressMiddleware as C}from"@trpc/server/adapters/express";import u from"express";var R=n(({createRouter:e,createContext:t})=>{let r=a.context().create(),o=e(r);return{expressMiddleware:C({router:o,createContext:t}),router:o}},"createExpressTaskServerMiddleware");function T({createRouter:e,createContext:t,app:r=u()}){let{expressMiddleware:o,router:s}=R({createRouter:e,createContext:t});return r.use("/trpc",o),{runServer:n(x=>{r.listen({port:x})},"runServer"),router:s}}n(T,"createExpressTaskServer");export{T as createExpressTaskServer,R as createExpressTaskServerMiddleware};

package.json

@@ -7,3 +7,3 @@ {
   },
-  "version": "2.0.2",
+  "version": "3.0.0",
   "sideEffects": false,
@@ -10,0 +10,0 @@ "exports": {

README.md

@@ -65,17 +65,18 @@ # 🚀 Google Cloud Tasks, Simplified
 
-export const { runServer, router } = createTasksServer((t) =>
-  t.router({
-    createUser: t.procedure
-      .input(z.object({ name: z.string().min(5) }))
-      .mutation(async (opts) => {
-        logger.info(`creating user ${opts.input.name}`);
+export const { runServer, router } = createTasksServer({
+  createRouter: (t) =>
+    t.router({
+      createUser: t.procedure
+        .input(z.object({ name: z.string().min(5) }))
+        .mutation(async (opts) => {
+          logger.info(`creating user ${opts.input.name}`);
+        }),
+      doNothing: t.procedure.mutation(() => {
+        logger.info("doing nothing");
       }),
-    doNothing: t.procedure.mutation(() => {
-      logger.info("doing nothing");
+      sendEmail: t.procedure.mutation(() => {
+        logger.info("sending email");
+      }),
     }),
-    sendEmail: t.procedure.mutation(() => {
-      logger.info("sending email");
-    }),
-  }),
-);
+});
 
@@ -82,0 +83,0 @@ // Export the router type for use in the client

New alerts

Minified code

Quality

This package contains minified code. This may be harmless in some cases where minified code is included in packaged libraries, however packages on npm should not minify code.

Found 1 instance in 1 package

Fixed alerts

Minified code

Quality

This package contains minified code. This may be harmless in some cases where minified code is included in packaged libraries, however packages on npm should not minify code.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

49374

2.98%

Lines of code

247

2.49%

Number of lines in readme file

223

0.45%

No dependency changes