import{W as T}from"./WLogger.js";import{b as t}from"./shared-server.js";const C=A=>{const e={...A};for(const[I,_]of Object.entries(A))switch(I){case"email":case"name":case"email_domain":case"roistatId":case"phone":case"token":_?e[I]="*********":e[I]=_;break}return e},o={LANDING_URL:"6",UTM_SOURCE:"7",UTM_MEDIUM:"8",UTM_CAMPAIGN:"9",UTM_CONTENT:"10",UTM_TERMS:"11"},r=[{key:"landing_url",keyNew:o.LANDING_URL},{key:"utm_source",keyNew:o.UTM_SOURCE},{key:"utm_medium",keyNew:o.UTM_MEDIUM},{key:"utm_campaign",keyNew:o.UTM_CAMPAIGN},{key:"utm_content",keyNew:o.UTM_CONTENT},{key:"utm_term",keyNew:o.UTM_TERMS}],a=A=>{const e={email:A.email};A?.first_name&&(e.firstName=A.first_name),A?.name&&!A?.first_name&&(e.firstName=A?.name),A?.last_name&&(e.lastName=A.last_name),A?.phone&&(e.phone=A.phone);const I=[];return r.forEach(_=>{_.key in A&&I.push({field:_.keyNew,value:A[_.key]})}),e.fieldValues=I,{contact:e}},N=async A=>fetch(`${t.PRIVATE_ACTIVE_CAMPAIGN_HOST}/api/3/contacts?filters[email]=${A}`,{method:"GET",headers:{"Api-Token":t.PRIVATE_ACTIVE_CAMPAIGN_TOKEN}}),c=async A=>{const e=a(A);return fetch(`${t.PRIVATE_ACTIVE_CAMPAIGN_HOST}/api/3/contacts`,{method:"POST",headers:{"Api-Token":t.PRIVATE_ACTIVE_CAMPAIGN_TOKEN},body:JSON.stringify(e)})},P=async(A,e)=>{const I={contactList:{list:e?t.PRIVATE_ACTIVE_CAMPAIGN_LIST_BLOG_ID:t.PRIVATE_ACTIVE_CAMPAIGN_LIST_ID,contact:A,status:1}};return fetch(`${t.PRIVATE_ACTIVE_CAMPAIGN_HOST}/api/3/contactLists`,{method:"POST",headers:{"Api-Token":t.PRIVATE_ACTIVE_CAMPAIGN_TOKEN},body:JSON.stringify(I)})},f=async A=>{const e={...A};if(T.log("info","[ACTIVE_CAMPAIGN]: START",C(e)),!t?.PRIVATE_ACTIVE_CAMPAIGN_HOST||!t?.PRIVATE_ACTIVE_CAMPAIGN_LIST_ID||!t?.PRIVATE_ACTIVE_CAMPAIGN_TOKEN||!t?.PRIVATE_ACTIVE_CAMPAIGN_LIST_BLOG_ID){T.log("error","[ACTIVE_CAMPAIGN]: END",{error:"PRIVATE_ACTIVE_CAMPAIGN_TOKEN or PRIVATE_ACTIVE_CAMPAIGN_LIST_BLOG_ID or PRIVATE_ACTIVE_CAMPAIGN_LIST_ID or PRIVATE_ACTIVE_CAMPAIGN_HOST: undefined"});return}T.log("info","[ACTIVE_CAMPAIGN]: SEARCH CONTACT START",C(e));const I=await N(e.email);if(!I.ok){T.log("error","[ACTIVE_CAMPAIGN]: SEARCH CONTACT END");return}const _=await I.json();T.log("info","[ACTIVE_CAMPAIGN]: SEARCH CONTACT END");let s=_.contacts[0]??null;if(!s){T.log("info","[ACTIVE_CAMPAIGN]: CREATE CONTACT START",C(e));const n=await c(e);if(!n.ok){T.log("error","[ACTIVE_CAMPAIGN]: CREATE CONTACT END");return}const E=await n.json();T.log("info","[ACTIVE_CAMPAIGN]: CREATE CONTACT END"),s=E.contact??null}if(!s){T.log("error","[ACTIVE_CAMPAIGN]: CONTACT NULL",C(s));return}if(T.log("info","[ACTIVE_CAMPAIGN]: UPDATE LIST STATUS START",C(s)),!(await P(s.id,e?.isPost||!1)).ok){T.log("error","[ACTIVE_CAMPAIGN]: UPDATE LIST STATUS END");return}T.log("info","[ACTIVE_CAMPAIGN]: UPDATE LIST STATUS END")};export{C as S,f as s};