https://datasuite.fptcloud.com/assets/PipelineReleasePage-PdH_kAo9.js

1import{j as e,r as Y}from"./react-DJo-hRcj.js";import{S as x,al as z}from"./lodash-D9U91hCZ.js";import{C as G}from"./index-D_wmWopG.js";import{H as $}from"./index-fAv5m2E8.js";import{L as J}from"./Layout-hleQVaK2.js";import{P as Q}from"./PipelineTemplateHelmet-hH2FFIaC.js";import{I as S,aw as q,bd as Z,c8 as g,bW as X,b$ as ee,bV as te,ao as ae,bc as se,bY as re,dM as oe}from"./vendors-_9dKRPAn.js";import{F as Ee}from"./FormLayout-C-HA-4gU.js";import{kp as ie,h as ne,g as N,bo as le,t as pe,I as ce,j as Te,F as y,a7 as me,b as de,P as Pe}from"./index-B5XNITP8.js";import{P as _e}from"./Plus-VBX5Yw5b.js";import{C as ue}from"./ControlledInput-t0pN4OLl.js";import{a as T,I as Ae}from"./toastifyV2-JsPZrQKQ.js";import{S as L}from"./index-DxWfvKSt.js";import{c as C,u as Ie,C as Le,D as Ce,E as Re,a as b,v as he}from"./validateUserEnvs-VMT7dHIL.js";import{F as R}from"./index-BEAu0kit.js";import{bu as P,P as xe,T as h,an as Se,aD as fe,aj as Me}from"./mui-core-DIGHSUz9.js";import{P as je}from"./PipelineTemplateRepository-DV76QlCI.js";import{w as Ne}from"./withSuspense-BGHIZZ3b.js";import"./useCheckPermissionSidebar-BJ_M-sXv.js";import"./LocalStorageManager-Brbsb2wO.js";import"./index-C6hXkfvS.js";import"./useUrlParams-9vBjnh_J.js";import"./Search-BtClgkYE.js";import"./ModalV2-Bwgoj2D8.js";import"./org-switch-rules-CALv74Cz.js";import"./useOrgList-CLYvyZdj.js";import"./DashboardQueryRepository-BaKnPLob.js";import"./Search-CSvDv4Dl.js";import"./Building-_OqbRV1u.js";import"./Check-DzZWfpvT.js";import"./languageManager-_RIZidnS.js";import"./SharedComponents-CFIIYYlL.js";import"./LocalStorageManager-Cf9EMmua.js";import"./constants-BhQb0AAi.js";import"./getHttpStatusCode-D6Fy-dO9.js";import"./getTenantId-D-FzaJmc.js";import"./mui-x-WaaF4sFd.js";import"./CheckMarkIcon-B-CQ81wp.js";import"./index-PcIn_X-S.js";import"./SectionHeader-DwlmHJ9M.js";import"./Refresh-BPohCR86.js";import"./LogoSkeleton-mOXeuBlj.js";import"./index-Sm1lpASf.js";function ye(t){const{dataModelTypes:l,setDataModelTypeId:o,dataSourceTypes:p,setDataSourceTypeId:m,pipelineCharts:_,setPipelineChartId:u,template:r}=t,{t:s}=S(),{control:d}=q();return e.jsxs(P,{direction:"row",spacing:4,alignItems:"flex-start",children:[e.jsxs(P,{spacing:2,sx:{minWidth:"40%",flexShrink:0},children:[e.jsx(R,{control:d,name:"dataModelType",Component:L,componentProps:{options:C(l),isSearchable:!1,isMulti:!1,label:s("PIPELINE_TEMPLATE.CREATE_RELEASE.CHOOSE_DATA_MODEL_TYPE"),placeholder:s("PIPELINE_TEMPLATE.CREATE_RELEASE.CHOOSE_DATA_MODEL_TYPE"),onChange:i=>{o(i.value)}}}),e.jsx(R,{control:d,name:"dataSourceType",Component:L,componentProps:{options:C(p),isSearchable:!1,isMulti:!1,label:s("PIPELINE_TEMPLATE.CREATE_RELEASE.CHOOSE_DATA_SOURCE_TYPE"),placeholder:s("PIPELINE_TEMPLATE.CREATE_RELEASE.CHOOSE_DATA_SOURCE_TYPE"),onChange:i=>{m(i.value)}}}),e.jsx(R,{control:d,name:"pipelineChart",Component:L,componentProps:{options:C(_),isSearchable:!1,isMulti:!1,label:s("PIPELINE_TEMPLATE.CREATE_RELEASE.CHOOSE_TEMPLATE"),placeholder:s("PIPELINE_TEMPLATE.CREATE_RELEASE.CHOOSE_TEMPLATE"),onChange:i=>{u(i.value)}}})]}),!x(r)&&e.jsxs(xe,{sx:{p:2,bgcolor:"#f9f9f9",flex:1},children:[e.jsx(h,{variant:"body2",sx:{fontWeight:"bold",mb:1},children:s("PIPELINE_TEMPLATE.CREATE_RELEASE.HELP_CHOOSE_TEMPLATE")}),e.jsxs("ul",{style:{marginLeft:"1rem",marginTop:0,paddingLeft:"1rem"},children:[e.jsxs("li",{children:[s("PIPELINE_TEMPLATE.CREATE_RELEASE.PIPELINE_REPO_URL"),r.etl_image.url]}),e.jsxs("li",{children:[s("PIPELINE_TEMPLATE.CREATE_RELEASE.DAG_REPO_URL"),r?.dag_repo?.url]}),e.jsxs("li",{children:[s("PIPELINE_TEMPLATE.CREATE_RELEASE.AGENT_REPO_URL"),r?.agent_image?.url]})]})]})]})}function be(){const{t}=S(),l=Z(),{projectId:o,tenantId:p}=g(),{setDataModelTypeId:m,setPipelineChartId:_,setDataSourceTypeId:u,dataModelTypes:r,pipelineCharts:s,dataSourceTypes:d,dataModelTypeId:i,pipelineChartId:f,dataSourceTypeId:M,findDataModelType:O,findPipelineChart:v,findDataSourceType:D,template:E}=Ie({}),A=X({mode:"onChange",defaultValues:{cronPattern:""}});Y.useEffect(()=>{const a=O(i),n=v(f),c=D(M);A.reset({dataModelType:a?{label:a.name,value:a.id}:null,dataSourceType:c?{label:c.name,value:c?.id}:null,pipelineChart:n?{label:n.name,value:n.id}:null,in_schemas:E?.in_schemas||[],out_schemas:E?.out_schemas||[],system_envs:E?.system_envs||{},user_envs:E?.user_envs||{},cronPattern:E?.cronPattern||""})},[i,M,f,E]);const U=ee(),V=new je({queryClient:U}

1),{mutate:w,isLoading:j}=te(V.createRelease({onSuccess:a=>{const{pipelineReleaseId:n}=a.data.data;T.success(),l.push(se(ie,{tenantId:p,projectId:o,pipelineReleaseId:n}))},workspaceId:o,onError:a=>{ae.isAxiosError(a)?T.error({title:a.response?.data?.message||a.message}):T.error({title:a})}})),H=a=>{const n={...a},c=z(n,["dataSourceType","dataModelType","pipelineChart"]),I={pipelineChartId:a.pipelineChart?.value,workspaceId:o,cronPattern:c.cronPattern,values:{...c}},k=b(I.values.in_schemas),K=b(I.values.out_schemas);if(!k){T.error({title:t("PIPELINE_TEMPLATE.CREATE_RELEASE.INVALID_IN_TABLE_SCHEMA")});return}if(!K){T.error({title:t("PIPELINE_TEMPLATE.CREATE_RELEASE.INVALID_OUT_TABLE_SCHEMA")});return}if(!he(I.values.user_envs)){T.error({title:t("PIPELINE_TEMPLATE.CREATE_RELEASE.INVALID_USER_ENVS")});return}w(I)},F=["in_schemas","out_schemas"],B=a=>a?oe(a)?!0:t("PIPELINE_TEMPLATE.CREATE_RELEASE.INVALID_CRON_PATTERN"):t("PIPELINE_TEMPLATE.CREATE_RELEASE.CRON_PATTERN_REQUIRED"),W=A.watch("pipelineChart");return e.jsx(re,{...A,children:e.jsxs("form",{children:[e.jsxs(Se,{sx:{display:"flex",flexDirection:"column",height:"100%",bgcolor:N.bg.surface.main,borderRadius:ne.large,overflow:"hidden",padding:4},children:[e.jsx(h,{sx:{fontWeight:"bold"},children:t("PIPELINE_TEMPLATE.CREATE_RELEASE.SETTINGS").toUpperCase()}),e.jsx(ye,{dataModelTypes:r,setDataModelTypeId:m,dataSourceTypes:d,setDataSourceTypeId:u,pipelineCharts:s,setPipelineChartId:_,template:E}),e.jsx(h,{sx:{fontWeight:"bold",mt:4},children:t("PIPELINE_TEMPLATE.CREATE_RELEASE.JOB_CUSTOMIZATION").toUpperCase()}),e.jsx(P,{direction:"row",alignItems:"flex-start",children:e.jsxs(P,{sx:{minWidth:"40%"},children:[e.jsxs(P,{direction:"row",alignItems:"center",spacing:.5,sx:{mb:1},children:[e.jsxs(fe,{sx:{color:N.txt.normal.secondary,marginBottom:pe.spacing(1),...le.bodyMBaseMedium},children:[t("PIPELINE_TEMPLATE.CREATE_RELEASE.CRON_PATTERN")," ",e.jsx("span",{style:{color:"red"},children:"*"})]}),e.jsx(Me,{title:e.jsx(Le,{}),children:e.jsx("span",{children:e.jsx(Ae,{fontSize:"small"})})})]}),e.jsx(ue,{name:"cronPattern",placeholder:t("PIPELINE_TEMPLATE.CREATE_RELEASE.CRON_PATTERN"),rules:{validate:B}})]})}),F.map(a=>e.jsx(Ce,{tableTitle:t(`PIPELINE_TEMPLATE.CREATE_RELEASE.${a}_TITLE`.toUpperCase()),schemaKey:a,template:E,workspaceId:o})),e.jsx(Re,{tableTitle:t("PIPELINE_TEMPLATE.CREATE_RELEASE.USER_ENV"),schemaKey:"user_envs",template:E})]}),e.jsx(Ee.Action,{py:4,children:e.jsx(ce,{text:t("PIPELINE_TEMPLATE.CREATE"),size:"md",variant:"primary",icon:e.jsx(_e,{size:"sm"}),onClick:A.handleSubmit(H),disabled:j||x(W),overlay:!0,loading:j})})]})})}function ge(){const{t}=S();return e.jsxs(J,{children:[e.jsx(Q,{title:t("PIPELINE_TEMPLATE.CREATE_RELEASE.TITLE")}),e.jsx(G,{header:e.jsx($,{title:t("PIPELINE_TEMPLATE.CREATE_RELEASE.TITLE"),description:""}),content:e.jsx(be,{})})]})}function Oe(){const{tenantId:t,projectId:l}=g(),{state:o}=Te(),{tenants:p=[]}=o,m=p.map(r=>r.id);return!x(o)&&!m.includes(Number(t))?e.jsx(y,{}):p.find(r=>r.id===Number(t))?.isPrivate||!1?e.jsx(y,{}):e.jsx(me,{customKey:`data-pipeline-create-workspace_${l}`,action:Pe.data_model["write-data_model"],subject:{name:de.workspace,id:l},children:e.jsx(ge,{})})}const ht=Ne()(Oe);export{ht as default};