IMPERIAL Core — Реальная CRM

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_108":109,"_110":111},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","oromaskevic23","name","imperial-nca-runtime-recovery","path","imperial_real_crm.ts","project",{"_22":46,"_11":12,"_33":47,"_48":-5,"_49":42,"_50":51,"_52":51,"_53":54,"_55":-5,"_56":57,"_58":59,"_60":32,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70,"_71":72,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":84,"_85":86,"_87":88,"_89":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_13":45},"permalink","https://www.val.town/x/oromaskevic23/imperial-nca-runtime-recovery/code/imperial_real_crm.ts","extension","id","afca4e27-529e-4cc0-a237-487d65aeb1d3","fileId","0714499c-af07-11f1-add6-1607ee4eb77e","parentId","branchId","fe58c05b-d08c-4472-a9bd-606aa5280a38","branchVersion",1252,"latest",true,"createdAt",["D",1789258133791],"version",5,"fileType","http","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst H = {\n \"cache-control\": \"no-store\",\n \"x-content-type-options\": \"nosniff\",\n \"referrer-policy\": \"no-referrer\",\n \"x-frame-options\": \"DENY\",\n};\n\nconst ALLOWED_STAGES = new Set([\n \"QUALIFIED\",\"PROPOSAL_SENT\",\"BUYER_REPLIED\",\"NEGOTIATION\",\"AGREED_SCOPE\",\n \"ACTIVE_PAID_WORK\",\"DELIVERED\",\"ACCEPTED\",\"BLOCKED\",\"LOST\",\"DISPUTED\"\n]);\n\nfunction json(data: unknown, status=200) {\n return new Response(JSON.stringify(data, null, 2), {status, headers:{...H,\"content-type\":\"application/json; charset=utf-8\"}});\n}\nfunction authorized(req: Request) {\n const dashboard = Deno.env.get(\"IMPERIAL_DASHBOARD_PASSWORD\") || \"\";\n const crmToken = Deno.env.get(\"IMPERIAL_REAL_CRM_TOKEN\") || \"\";\n const supplied = req.headers.get(\"x-imperial-password\") || \"\";\n return (dashboard.length >= 8 && supplied === dashboard) || (crmToken.length >= 24 && supplied === crmToken);\n}\nasync function audit(action:string, objectType:string, objectId:string|null, payload:unknown) {\n await sqlite.execute({sql:`INSERT INTO crm_ui_audit_v2(event_id,action,object_type,object_id,actor,payload,created_at) VALUES(?,?,?,?,?,?,datetime('now'))`,args:[crypto.randomUUID(),action,objectType,objectId,\"Alexander Romaskevich / ARCHITECT\",JSON.stringify(payload ?? {})]});\n}\n\nconst page = `\n\nIMPERIAL Core — Реальная CRM\n\n

Живой конвейер: возможность → предложение → ответ → согласованный объём → работа → приёмка → реальный платёж

Данные защищены. Введите существующий пароль панели IMPERIAL.

Команда Астры

—

Возможности

—

Предложения отправлены

—

Сумма известных возможностей, USD

—

Подтверждённый доход

Сделка	Этап	Сервис	Оценка	Сумма	Риск	Следующее действие	Команда	Управление

Задача	Агент	Объект	Статус	Приоритет	Обновлено

Время	Действие	Объект	Актор	Данные

`;\n\nexport default async function(req:Request){\n const u=new URL(req.url), p=u.pathname;\n if(p===\"/\" && req.method===\"GET\") return new Response(page,{status:200,headers:{...H,\"content-type\":\"text/html; charset=utf-8\"}});\n if(!authorized(req)) return json({error:\"НЕВЕРНЫЙ_ПАРОЛЬ_ИЛИ_ДОСТУП_ЗАПРЕЩЁН\"},401);\n\n if(req.method===\"GET\" && p===\"/api/summary\"){\n const pipeline=(await sqlite.execute(`SELECT stage,COUNT(*) n,COALESCE(SUM(expected_value),0) value FROM revenue_crm_opportunities GROUP BY stage`)).rows as any[];\n const team=(await sqlite.execute({sql:`SELECT COUNT(*) n FROM agent_collaboration_membership WHERE pod_id=? AND state='ACTIVE_TEAM_REVENUE'`,args:[\"ASTRA-REAL10-REVENUE-POD\"]})).rows[0] as any;\n const all=pipeline.reduce((a:any,x:any)=>({n:a.n+Number(x.n),v:a.v+Number(x.value)}),{n:0,v:0});\n const sent=pipeline.find((x:any)=>x.stage===\"PROPOSAL_SENT\");\n return json({team:Number(team?.n||0),opportunities:all.n,proposal_sent:Number(sent?.n||0),known_value_usd:all.v,confirmed_revenue_usd:0,truth_boundary:\"Доход = 0, пока нет подтверждённого внешнего получения средств\"});\n }\n\n if(req.method===\"GET\" && p===\"/api/opportunities\"){\n const opps=(await sqlite.execute(`SELECT opportunity_id,owner_agent_id,source_node,stage,score,expected_value,currency,service_type,risk_score,next_action,evidence,updated_at FROM revenue_crm_opportunities ORDER BY CASE stage WHEN 'BUYER_REPLIED' THEN 0 WHEN 'NEGOTIATION' THEN 1 WHEN 'AGREED_SCOPE' THEN 2 WHEN 'PROPOSAL_SENT' THEN 3 WHEN 'QUALIFIED' THEN 4 ELSE 5 END, score DESC, updated_at DESC`)).rows as any[];\n const asg=(await sqlite.execute(`SELECT opportunity_id,agent_id,role,status FROM revenue_crm_assignments WHERE status IN ('ACTIVE_TEAM','ASSIGNED') ORDER BY opportunity_id,role`)).rows as any[];\n const m=new Map(); for(const a of asg){if(!m.has(a.opportunity_id))m.set(a.opportunity_id,[]);m.get(a.opportunity_id)!.push(a)}\n return json({items:opps.map(o=>({...o,team:m.get(o.opportunity_id)||[]}))});\n }\n\n if(req.method===\"GET\" && p===\"/api/team\"){\n const rows=(await sqlite.execute({sql:`SELECT agent_id,collaboration_role,active_task_id,state,assigned_at,last_work_at FROM agent_collaboration_membership WHERE pod_id=? ORDER BY agent_id`,args:[\"ASTRA-REAL10-REVENUE-POD\"]})).rows;\n return json({items:rows});\n }\n\n if(req.method===\"GET\" && p===\"/api/tasks\"){\n const rows=(await sqlite.execute(`SELECT task_id,owner_agent_id,object_type,object_id,title,status,priority,deadline,updated_at FROM crm_tasks ORDER BY CASE status WHEN 'OPEN' THEN 0 WHEN 'IN_PROGRESS' THEN 1 ELSE 2 END, updated_at DESC LIMIT 250`)).rows;\n return json({items:rows});\n }\n\n if(req.method===\"GET\" && p===\"/api/activity\"){\n const rows=(await sqlite.execute(`SELECT event_id,action,object_type,object_id,actor,payload,created_at FROM crm_ui_audit_v2 ORDER BY created_at DESC LIMIT 200`)).rows;\n return json({items:rows});\n }\n\n if(req.method===\"POST\" && p===\"/api/opportunity/stage\"){\n const b=await req.json().catch(()=>({})) as any;\n const id=String(b.opportunity_id||\"\"), stage=String(b.stage||\"\"), reason=String(b.reason||\"\").slice(0,2000);\n if(!id || !ALLOWED_STAGES.has(stage)) return json({error:\"НЕДОПУСТИМЫЙ_ЭТАП\"},400);\n if(stage===\"PAYMENT_CONFIRMED\") return json({error:\"ПЛАТЁЖ_НЕЛЬЗЯ_ПОДТВЕРДИТЬ_ВРУЧНУЮ\"},403);\n const old=(await sqlite.execute({sql:`SELECT stage FROM revenue_crm_opportunities WHERE opportunity_id=?`,args:[id]})).rows[0] as any;\n if(!old) return json({error:\"СДЕЛКА_НЕ_НАЙДЕНА\"},404);\n await sqlite.execute({sql:`UPDATE revenue_crm_opportunities SET stage=?, updated_at=datetime('now') WHERE opportunity_id=?`,args:[stage,id]});\n await sqlite.execute({sql:`INSERT INTO crm_stage_history_v2(opportunity_id,from_stage,to_stage,actor,reason,evidence,created_at) VALUES(?,?,?,?,?,?,datetime('now'))`,args:[id,String(old.stage||\"\"),stage,\"Alexander Romaskevich / ARCHITECT\",reason,JSON.stringify({source:\"IMPERIAL_REAL_CRM\"})]});\n await audit(\"STAGE_CHANGED\",\"OPPORTUNITY\",id,{from:old.stage,to:stage,reason});\n return json({ok:true,opportunity_id:id,from:old.stage,to:stage});\n }\n\n if(req.method===\"POST\" && p===\"/api/note\"){\n const b=await req.json().catch(()=>({})) as any; const ot=String(b.object_type||\"OPPORTUNITY\").slice(0,64), oid=String(b.object_id||\"\").slice(0,200), note=String(b.note||\"\").trim().slice(0,8000);\n if(!oid||!note) return json({error:\"НУЖНЫ_OBJECT_ID_И_ЗАМЕТКА\"},400);\n const id=crypto.randomUUID();\n await sqlite.execute({sql:`INSERT INTO crm_notes_v2(note_id,object_type,object_id,author,note,created_at,updated_at) VALUES(?,?,?,?,?,datetime('now'),datetime('now'))`,args:[id,ot,oid,\"Alexander Romaskevich / ARCHITECT\",note]});\n await audit(\"NOTE_ADDED\",ot,oid,{note_id:id}); return json({ok:true,note_id:id});\n }\n\n if(req.method===\"POST\" && p===\"/api/task\"){\n const b=await req.json().catch(()=>({})) as any; const title=String(b.title||\"\").trim().slice(0,1000), objectId=String(b.object_id||\"\").trim().slice(0,200), owner=String(b.owner_agent_id||\"\").trim().slice(0,100), priority=String(b.priority||\"П1\").slice(0,20);\n const allowedTeam=new Set([\"NCA-424\",\"NCA-425\",\"NCA-426\",\"NCA-427\",\"NCA-428\",\"NCA-429\",\"NCA-431\",\"NCA-432\",\"NCA-435\",\"NCA-436\"]);\n if(!title||!allowedTeam.has(owner)) return json({error:\"НЕКОРРЕКТНАЯ_ЗАДАЧА_ИЛИ_АГЕНТ\"},400);\n const id=`CRM-${Date.now()}-${Math.random().toString(36).slice(2,8)}`;\n await sqlite.execute({sql:`INSERT INTO crm_tasks(task_id,owner_agent_id,object_type,object_id,title,status,priority,deadline,evidence,created_at,updated_at) VALUES(?,?,?,?,?,'OPEN',?,?,?,datetime('now'),datetime('now'))`,args:[id,owner,objectId?\"OPPORTUNITY\":null,objectId||null,title,priority,null,JSON.stringify({source:\"IMPERIAL_REAL_CRM\",created_by:\"ARCHITECT\"})]});\n await audit(\"TASK_CREATED\",\"CRM_TASK\",id,{owner,object_id:objectId,priority}); return json({ok:true,task_id:id});\n }\n\n return json({error:\"НЕ_НАЙДЕНО\"},404);\n}\n","deleted",false,"label","imperialcore-real-crm",[14],"04f41296-b07d-43ba-83f9-d5f45983c8e6",["D",1787955492364],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Recovered NCA runtime with ORION learning loop","imageUrl","userId","fe39b163-4b50-466e-82d1-8bd01133e4b6","pinnedFileId","6796d66a-a32f-11f1-bd77-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a03585-eb44-758d-92a4-77db1a9a243c","tursoName","04f41296b07d43ba83f9d5f45983c8e6","tursoHostname","04f41296b07d43ba83f9d5f45983c8e6-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789526460011],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_107":103},"org",{"_9":10,"_100":101,"_102":103,"_56":57,"_104":105,"_106":42},"branch",{"_35":90,"_11":91,"_22":28,"_92":46,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":12,"_99":10},"isOwned",1288,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Олександр Ромаскевич","avatar","https://lh3.googleusercontent.com/a/ACg8ocIo1MJ3hDjpQrinMIRok3d2YY1vpHgehs8m2u1_vc7pmFovRGI=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_83":-5,"_141":142,"_143":144,"_145":146,"_147":42,"_148":42,"_149":42,"_150":32,"_151":-5,"_152":-7,"_153":-7,"_154":64,"_155":42,"_156":42,"_157":-5,"_158":42,"_159":42,"_160":42,"_161":-5},"ENV",{"_112":113,"_114":115,"_116":91,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138,"_139":140},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]