Lines 1-68javascript
1"use strict";var wT=Object.create;var mi=Object.defineProperty;var xT=Object.getOwnPropertyDescriptor;var AT=Object.getOwnPropertyNames;var IT=Object.getPrototypeOf,RT=Object.prototype.hasOwnProperty;var o=(t,e)=>mi(t,"name",{value:e,configurable:!0});var ct=(t,e,r)=>()=>{if(r)throw r[0];try{return t&&(e=t(t=0)),e}catch(n){throw r=[n],n}};var M=(t,e)=>()=>{try{return e||t((e={exports:{}}).exports,e),e.exports}catch(r){throw e=0,r}},Ba=(t,e)=>{for(var r in e)mi(t,r,{get:e[r],enumerable:!0})},Zf=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let i of AT(e))!RT.call(t,i)&&i!==r&&m ...
2`;Ce.DEFAULT_CONTENT_TYPE="application/octet-stream";Ce.prototype.append=function(t,e,r){r=r||{},typeof r=="string"&&(r={filename:r});var n=Sl.prototype.append.bind(this);if((typeof e=="number"||e==null)&&(e=String(e)),Array.isArray(e)){this._error(new Error("Arrays are not supported."));return}var i=this._multiPartHeader(t,e,r),u=this._multiPartFooter();n(i),n(e),n(u),this._trackLength(i,e,r)};Ce.prototype._trackLength=function(t,e,r){var n=0;r.knownLength!=null?n+=Number(r.knownLength):Buffer.isBuffer(e)?n=e.length:typeof e=="string"&&(n=Buffer.byteLength(e)),this._valueLength+=n,this._overh ...
3`)||n,code:u,status:i},e.data.error)}return Object.assign({message:n,code:u,status:i},e.data.error)}}return{message:n,code:e.status,status:e.statusText}}};rr.GaxiosError=wl;function lR(t,e){switch(t){case"stream":return e;case"json":return
5`+u),t.push(i+"m+"+Rs.exports.humanize(this.diff)+"\x1B[0m")}else t[0]=OR()+e+" "+t[0]}o(CR,"formatArgs");function OR(){return pt.inspectOpts.hideDate?"":new Date().toISOString()+" "}o(OR,"getDate");function kR(...t){return process.stderr.write(Is.formatWithOptions(pt.inspectOpts,...t)+`
6`)}o(kR,"log");function $R(t){t?process.env.DEBUG=t:delete process.env.DEBUG}o($R,"save");function NR(){return process.env.DEBUG}o(NR,"load");function zR(t){t.inspectOpts={};let e=Object.keys(pt.inspectOpts);for(let r=0;r<e.length;r++)t.inspectOpts[e[r]]=pt.inspectOpts[e[r]]}o(zR,"init");Rs.exports=Cl()(pt);var{formatters:Z_}=Rs.exports;Z_.o=function(t){return this.inspectOpts.colors=this.useColors,Is.inspect(t,this.inspectOpts).split(`
7`).map(e=>e.trim()).join(" ")};Z_.O=function(t){return this.inspectOpts.colors=this.useColors,Is.inspect(t,this.inspectOpts)}});var Nl=M((AW,$l)=>{typeof process>"u"||process.type==="renderer"||process.browser===!0||process.__nwjs?$l.exports=B_():$l.exports=J_()});var Y_=M($t=>{"use strict";var DR=$t&&$t.__createBinding||(Object.create?(function(t,e,r,n){n===void 0&&(n=r);var i=Object.getOwnPropertyDescriptor(e,r);(!i||("get"in i?!e.__esModule:i.writable||i.configurable))&&(i={enumerable:!0,get:o(function(){return e[r]},"get")}),Object.defineProperty(t,n,i)}):(function(t,e,r,n){n===void 0&&(n= ...
8`).some(n=>n.indexOf("(https.js:")!==-1||n.indexOf("node:https:")!==-1)}incrementSockets(e){if(this.maxSockets===1/0&&this.maxTotalSockets===1/0)return null;this.sockets[e]||(this.sockets[e]=[]);let r=new VR.Socket({writable:!1});return this.sockets[e].push(r),
10`);if(S===-1){Cs("have not received end of HTTP headers yet..."),u();return}let h=g.slice(0,S).toString("ascii").split(`\r
11`),_=h.shift();if(!_)return t.destroy(),r(new Error("No header received from proxy CONNECT response"));let T=_.split(" "),E=+T[1],w=T.slice(2).join(" "),k={};for(let q of h){if(!q)continue;let G=q.indexOf(":");if(G===-1)return t.destroy(),r(new Error(`Invalid header from proxy CONNECT response: "${q}"`));let V=q.slice(0,G).toLowerCase(),H=q.slice(G+1).trimStart(),J=k[V];typeof J=="string"?k[V]=[J,H]:Array.isArray(J)?J.push(H):k[V]=H}Cs("got proxy server response: %o %o",_,k),c(),e({connect:{statusCode:E,statusText:w,headers:k},buffered:g})}o(f,"ondata"),t.on("error",p),t.on("end",l),u()})}o(ZR ...
12`;if(n.username||n.password){let S=`${decodeURIComponent(n.username)}:${decodeURIComponent(n.password)}`;u["Proxy-Authorization"]=`Basic ${Buffer.from(S).toString
13`;let p=(0,tC.parseProxyResponse)(i);i.write(`${l}\r
14`);let{connect:f,buffered:m}=await p;if(e.emit("proxyConnect",f),this.emit("proxyConnect",f,e),f.statusCode===200)return e.once("socket",rC),r.secureEndpoint?(Mi("Upgrading socket connection to TLS"),ob.connect({...ab(ib(r),"host","path"
15Content-Disposition: form-data; name="`;return t.forEach((u,c)=>typeof u=="string"?n.push(i+Ml(c)+`"\r
17${u.replace(/\r(?!\n)|(?<!\r)\n/g,`\r
19`):n.push(i+Ml(c)+`"; filename="${Ml(u.name,1)}"\r
20Content-Type: ${u.type||"application/octet-stream"}\r
23`)),n.push(`--${r}--`),new e(n,{type:"multipart/form-data; boundary="+r})}var Fi,sC,uC,yb,cC,_b,Ml,Gn,An,Ns=ct(()=>{Li();jl();({toStringTag:Fi,iterator:sC,hasInstance:uC}=Symbol),yb=Math.random,cC="append,set,get,getAll,delete,keys,values,entries,forEach,constructor".split(","),_b=o((t,e,r)=>(t+="",/^(Blob|File)$/.test(e&&e[Fi])?[(r=r!==void 0?r+"":e[Fi]=="File"?e.name:"blob",t),e.name!==r||e[Fi]=="blob"?new xn([e],r,e):e]:[t,e+""]),"f"),Ml=o((t,e)=>(e?t:t.replace(/\r?\n|\r/g,`\r
24`)).replace(/\n/g,"%0A").replace(/\r/g,"%0D").replace(/"/g,"%22"),"e"),Gn=o((t,e,r)=>{if(e.length<r)throw
25--`+e;let r=new Uint8Array(e.length);for(let n=0;n<e.length;n++)r[n]=e.charCodeAt(n),this.boundaryChars[r[n]]=!0;this.boundary=r,this.lookbehind=new Uint8Array(this.boundary.length+8),this.state=Be.START_BOUNDARY}write(e){let r=0,n=e.length,i=this.index,{lookbehind:u,boundary:c,boundaryChars:l,index:p,state:f,flags:m}=this,g=this.boundary.length,S=g-1,h=e.length,_,T,E=o(G=>{this[G+"Mark"]=r},"mark"),w=o(G=>{delete this[G+"Mark"]},"clear"),k=o((G,V,H,J)=>{(V===void 0||V!==H)&&this[G](J&&J.subarray(V,H))},"callback"),q=o((G,V)=>{let H=G+"Mark";H in this&&(V?(k(G,this[H],r,e),delete this[H]):(k(G ...
27`),n=!1,i=!1,u;t.on("response",c=>{let{headers:l}=c;n=l["transfer-encoding"]==="chunked"&&!l["content-length"]}),t.on
30`,typeof i.content=="string"?yield i.content:yield*i.content,yield`\r
31`}yield n}static#i;static#a;static async#s(){return this.#i||=(await Promise.resolve().then(()=>gt(cb()))).HttpsProxyAgent,this.#i}static async#u(){let e=typeof window<"u"&&!!window;return this.#a||=e?window.fetch:(await Promise.resolve().then(()=>(nv(),rv))).default,this.#a}static mergeHeaders(e,...r){e=e instanceof Headers?e:new Headers(e);for(let n of r)(n instanceof Headers?n:new Headers(n)).forEach((u,c)=>{c==="set-cookie"?e.append(c,u):e.set(c,u)});return e}};jo.Gaxios=Hs;Uo=Hs});var yt=M(It=>{"use strict";var CC=It&&It.__createBinding||(Object.create?(function(t,e,r,n){n===void 0&&(n=r) ...
34`+T+"]":"["+E.join(",")+"]",n=T,h}if(c&&typeof c=="object")for(_=c.length,g=0;g
37`+T+"}":"{"+E.join(",")+"}",n=T,h}}o(p,"str"),typeof lv.stringify!="function"&&(lv.stringify=function(f,m
38`,r:"\r",t:" "},u,c=o(function(T){throw{name:"SyntaxError",message:T,at:r,text:u}},"error"),l=o(function(T){return T&&T!==n&&c("Expected '"+T+"' instead of '"+n+"'"),n=u.charAt(r),r+=1,n},"next"),p=o(function(){var T,E="";for(n==="-"&&(E="-",l("-"));n>="0"&&n<="9";)E+=n,l();if(n===".")for(E+=".";l()&&n>="0"&&n<="9";)E+=n;if(n==="e"||n==="E")for(E+=n,l(),(n==="-"||n==="+")&&(E+=n,l());n>="0"&&n<="9";)E+=n,l();if(T=+E,!isFinite(T))c("Bad number");else return Ws==null&&(Ws=Ql()),E.length>15?e.storeAsString?E:e.useNativeBigInt?BigInt(E):new Ws(E):e.alwaysParseAsBig?e.useNativeBigInt?BigInt(T):new ...
39 Supported algorithms are:
40 "HS256", "HS384", "HS512", "RS256", "RS384", "RS512", "PS256", "PS384", "PS512", "ES256", "ES384", "ES512" and "none".`,na="secret must be a string or buffer",Ho="key must be a string or a buffer",pk="key must be a string, a buffer or an object",Nd=typeof sr.createPublicKey=="function";Nd&&(Ho+=" or a KeyObject",na+="or a KeyObject");function lE(t){if(!
41`});let m=f.join(";"),g=await t.crypto.sha256DigestHex(r),S=`${t.method.toUpperCase()}
HighCloud Metadata Access
Source reaches cloud instance metadata or link-local credential endpoints.
src/index.jsView on unpkg · L1 43${t.canonicalQuerystring}
46${g}`,h=`${c}/${t.region}/${n}/${k0}`,_=`${aS}
49`+await t.crypto.sha256DigestHex(S),T=await $0(t.crypto,t.securityCredentials.secretAccessKey,c,t.region,n),E=await la(t.crypto,T,_),w=`${aS} Credential=${t.securityCredentials.accessKeyId}/${h}, SignedHeaders=${m}, Signature=${(0,sS.fromArrayBufferToHex)(E)}`;return{amzDate:e.has("date")?void 0:u,authorizationHeader:w,canonicalQuerystring:t.canonicalQuerystring}}o(N0,"generateAuthenticationHeaderMap")});var uS=M(Iu=>{"use strict";Object.defineProperty(Iu,"__esModule",{value:!0});Iu.DefaultAwsSecurityCredentialsSupplier=void 0;var Au=Zt(),gp=class{static{o(this,"DefaultAwsSecurityCredentialsSu ...
50To learn more about authentication and Google APIs, visit:
HighSame File Env Network Execution
A single source file combines environment access, network access, and code or shell execution; review context before blocking.
src/index.jsView on unpkg · L37 HighCommand Output Exfiltration
Source combines command execution, command-output handling, and outbound requests; review data flow before blocking.
src/index.jsView on unpkg · L37 HighTrigger Reachable Command Output Exfiltration
A manifest entrypoint or package-local install chain reaches command-output exfiltration behavior.
src/index.jsView on unpkg · L37 51https://cloud.google.com/docs/authentication/getting-started`,NO_CREDENTIALS_FOUND:`Unable to find credentials in current environment.
52To learn more about authentication and Google APIs, visit:
53https://cloud.google.com/docs/authentication/getting-started`,NO_ADC_FOUND:"Could not load the default credentials. Browse to https://cloud.google.com/docs/authentication/getting-started for more information.",NO_UNIVERSE_DOMAIN_FOUND:`Unable to detect a Universe Domain in the current environment.
54To learn more about Universe Domain retrieval, visit:
55https://cloud.google.com/compute/docs/metadata/predefined-metadata-keys`};var Dp=class{static{o(this,"GoogleAuth")}checkIsGCE=void 0;useJWTAccessWithScope;defaultServicePath;get isGCE(){return this.checkIsGCE}_findProjectIdPromise;_cachedProjectId;jsonContent=null;apiKey;cachedCredential=null;#e=null;defaultScopes;keyFilename;scopes;clientOptions={};constructor(e={}){if(this._cachedProjectId=e.projectId||null,this.cachedCredential=e.authClient||null,this.keyFilename=e.keyFilename||e.keyFile,this.scopes=e.scopes,this.clientOptions=e.clientOptions||{},this.jsonContent=e.credentials||null,this.ap ...
56i.e ${nR(e,f)}/resource or /resource`,required:!0,defaultValue:f?e(f):"",...c?.url??{}})}),"props")}),method:K.StaticDropdown({displayName:"Method",required:!0,options:{options:Object.values(xt).map(f=>({label:f,value:f}))},...c?.method??{}}),headers:K.Object({displayName:"Headers",description:"Authorization headers are injected automatically from your connection.",required:!0,...c?.headers??{}}),queryParams:K.Object({displayName:"Query Parameters",required:!0,...c?.queryParams??{}}),body_type:K.StaticDropdown({displayName:"Body Type",required:!1,defaultValue:"none",options:{disabled:!1,option ...
581. Open [Google Cloud Console](https://console.cloud.google.com/) and select your project from the top dropdown.
592. Go to **IAM & Admin** \u2192 **Service Accounts** in the left sidebar.
603. Click **Create Service Account** (or open an existing one).
614. Give it a name (e.g. \`activepieces-bigquery\`) and click **Create and Continue**.
625. Under **Grant this service account access**, add the **BigQuery User** role (or **BigQuery Admin** for full access). Click **Done**.
636. Click on the service account you just created, then open the **Keys** tab.
647. Click **Add Key** \u2192 **Create new key** \u2192 select **JSON** \u2192 click **Create**.
658. A \`.json\` file will download \u2014 open it in a text editor and paste the entire contents into the field below.`}),serviceAccountJson:K.ShortText({displayName:"Service Account JSON",description:"Paste the full contents of the downloaded .json key file here",required:!0})},validate:o(async({auth:t})=>{try{let
66`).map(r=>r.trim()).filter(r=>r.length>0).map(r=>JSON.parse(r))}throw new Error("Data must be a JSON array or a newline-delimited JSON (NDJSON) string.")}o(O$,"parseInputData");var MS=nt({auth:Oe,name:"import_data",displayName:"Import Data",description:"Imports a batch of rows into a BigQuery table. Accepts a JSON array or newline-delimited JSON (NDJSON). Large datasets are automatically split into chunks.",audience:"both",aiMetadata:{description:"Bulk-imports rows into a BigQuery table via streaming inserts, accepting either a JSON array of objects or a newline-delimited JSON (NDJSON) string ...
67/*! Bundled license information:
Long lines were clipped for display.