mirror of
https://github.com/velocitatem/PHANTOM.git
synced 2026-07-16 01:53:37 +00:00
Compare commits
23 Commits
22-create-
...
13-agentic
| Author | SHA1 | Date | |
|---|---|---|---|
| 7a204ac2b3 | |||
|
|
816c1ebec6 | ||
| ca65f6a066 | |||
| 55a760713f | |||
| d42ab56c1e | |||
| 49c8ecacb0 | |||
| 5a2064c061 | |||
| dab95c6d63 | |||
| fdf8520b5b | |||
| a80ee0e80f | |||
|
|
707ce032cf | ||
|
|
ea11539f7d | ||
| a8ea68609c | |||
|
|
e04fb99f7b | ||
| 9c86ee337c | |||
| b3ab3e9a3a | |||
| 3c37ba7fa7 | |||
| 3cf56cfcb9 | |||
| 84b600c13c | |||
| 6cba6bb329 | |||
| 5b0afea651 | |||
| 7249a812f5 | |||
| 8072e9567e |
@@ -41,7 +41,6 @@ def get_producer() -> KafkaProducer:
|
|||||||
|
|
||||||
class EventPayload(BaseModel):
|
class EventPayload(BaseModel):
|
||||||
sessionId: str
|
sessionId: str
|
||||||
experimentId: Optional[str] = None
|
|
||||||
eventName: str
|
eventName: str
|
||||||
page: str
|
page: str
|
||||||
productId: Optional[str] = None
|
productId: Optional[str] = None
|
||||||
|
|||||||
@@ -5,16 +5,11 @@ import os
|
|||||||
import requests
|
import requests
|
||||||
from dotenv import load_dotenv
|
from dotenv import load_dotenv
|
||||||
from sklearn.base import BaseEstimator, TransformerMixin
|
from sklearn.base import BaseEstimator, TransformerMixin
|
||||||
from supabase import create_client, Client
|
|
||||||
load_dotenv()
|
load_dotenv()
|
||||||
|
|
||||||
BACKEND_URL = os.getenv("BACKEND_URL", "http://localhost:5000")
|
BACKEND_URL = os.getenv("BACKEND_URL", "http://localhost:5000")
|
||||||
SUPABASE_URL = os.getenv("NEXT_PUBLIC_SUPABASE_URL")
|
|
||||||
SUPABASE_KEY = os.getenv("NEXT_PUBLIC_SUPABASE_ANON_KEY")
|
|
||||||
N_PRICE_BUCKETS = 5
|
N_PRICE_BUCKETS = 5
|
||||||
|
|
||||||
supabase: Client = create_client(SUPABASE_URL, SUPABASE_KEY)
|
|
||||||
|
|
||||||
def get_data_from_kafka() -> pd.DataFrame:
|
def get_data_from_kafka() -> pd.DataFrame:
|
||||||
"""fetch all events from backend dump endpoint"""
|
"""fetch all events from backend dump endpoint"""
|
||||||
resp = requests.get(f"{BACKEND_URL}/api/kafka/dump")
|
resp = requests.get(f"{BACKEND_URL}/api/kafka/dump")
|
||||||
@@ -33,38 +28,7 @@ def get_data_from_kafka() -> pd.DataFrame:
|
|||||||
|
|
||||||
|
|
||||||
def join_with_experiments(df: pd.DataFrame) -> pd.DataFrame:
|
def join_with_experiments(df: pd.DataFrame) -> pd.DataFrame:
|
||||||
if df.empty or 'experimentId' not in df.columns:
|
# TODO: Get experiments db from supabase and join on session_id
|
||||||
return df
|
|
||||||
|
|
||||||
unique_exp_ids = df['experimentId'].dropna().unique()
|
|
||||||
if len(unique_exp_ids) == 0:
|
|
||||||
return df
|
|
||||||
|
|
||||||
resp = supabase.table('experiments').select(
|
|
||||||
'id, subject_name, xp_human_only, xp_market_mode, xp_task_id, task:tasks(task_name, task_description, task_def_of_done)'
|
|
||||||
).in_('id', unique_exp_ids.tolist()).execute()
|
|
||||||
|
|
||||||
if not resp.data:
|
|
||||||
return df
|
|
||||||
|
|
||||||
exp_df = pd.DataFrame(resp.data)
|
|
||||||
|
|
||||||
# flatten task nested object if present
|
|
||||||
if 'task' in exp_df.columns and exp_df['task'].notnull().any():
|
|
||||||
task_normalized = pd.json_normalize(exp_df['task'].dropna())
|
|
||||||
task_normalized.index = exp_df[exp_df['task'].notnull()].index
|
|
||||||
exp_df = exp_df.drop(columns=['task']).join(task_normalized, rsuffix='_task')
|
|
||||||
|
|
||||||
# rename experiment columns for clarity
|
|
||||||
exp_df = exp_df.rename(columns={
|
|
||||||
'id': 'experimentId',
|
|
||||||
'subject_name': 'exp_subject',
|
|
||||||
'xp_human_only': 'exp_human_only',
|
|
||||||
'xp_market_mode': 'exp_market_mode',
|
|
||||||
'xp_task_id': 'exp_task_id'
|
|
||||||
})
|
|
||||||
|
|
||||||
df = df.merge(exp_df, on='experimentId', how='left')
|
|
||||||
return df
|
return df
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -7,9 +7,13 @@ from mapping import SessionTransitionProbMatrixTransformer, render_graph
|
|||||||
if __name__ == "__main__":
|
if __name__ == "__main__":
|
||||||
steps = [
|
steps = [
|
||||||
('data_extraction', DataExtractor()),
|
('data_extraction', DataExtractor()),
|
||||||
#('transition_matrix', SessionTransitionProbMatrixTransformer(threshold=0.05)),
|
('transition_matrix', SessionTransitionProbMatrixTransformer(threshold=0.05)),
|
||||||
]
|
]
|
||||||
pipeline = Pipeline(steps)
|
pipeline = Pipeline(steps)
|
||||||
result = pipeline.fit_transform(None)
|
result = pipeline.fit_transform(None)
|
||||||
print(result)
|
print(f"Number of sessions: {len(result)}\n")
|
||||||
print(result.info())
|
|
||||||
|
for session_id, sess_data in result.items():
|
||||||
|
fname = f"session_{session_id}"
|
||||||
|
render_graph(fname, sess_data['matrix'], ls_index=sess_data['labels'], threshold=0.05, fmt="svg", view=False)
|
||||||
|
print(f"Rendered {fname}.svg")
|
||||||
|
|||||||
@@ -10,4 +10,3 @@ pytest
|
|||||||
pytest-asyncio
|
pytest-asyncio
|
||||||
uv
|
uv
|
||||||
scikit-learn
|
scikit-learn
|
||||||
supabase
|
|
||||||
|
|||||||
140
web/package-lock.json
generated
140
web/package-lock.json
generated
@@ -8,8 +8,6 @@
|
|||||||
"name": "web",
|
"name": "web",
|
||||||
"version": "0.1.0",
|
"version": "0.1.0",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@supabase/ssr": "^0.7.0",
|
|
||||||
"@supabase/supabase-js": "^2.81.1",
|
|
||||||
"next": "16.0.0",
|
"next": "16.0.0",
|
||||||
"react": "19.2.0",
|
"react": "19.2.0",
|
||||||
"react-dom": "19.2.0",
|
"react-dom": "19.2.0",
|
||||||
@@ -659,97 +657,6 @@
|
|||||||
"node": ">= 10"
|
"node": ">= 10"
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"node_modules/@supabase/auth-js": {
|
|
||||||
"version": "2.81.1",
|
|
||||||
"resolved": "https://registry.npmjs.org/@supabase/auth-js/-/auth-js-2.81.1.tgz",
|
|
||||||
"integrity": "sha512-K20GgiSm9XeRLypxYHa5UCnybWc2K0ok0HLbqCej/wRxDpJxToXNOwKt0l7nO8xI1CyQ+GrNfU6bcRzvdbeopQ==",
|
|
||||||
"license": "MIT",
|
|
||||||
"dependencies": {
|
|
||||||
"tslib": "2.8.1"
|
|
||||||
},
|
|
||||||
"engines": {
|
|
||||||
"node": ">=20.0.0"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"node_modules/@supabase/functions-js": {
|
|
||||||
"version": "2.81.1",
|
|
||||||
"resolved": "https://registry.npmjs.org/@supabase/functions-js/-/functions-js-2.81.1.tgz",
|
|
||||||
"integrity": "sha512-sYgSO3mlgL0NvBFS3oRfCK4OgKGQwuOWJLzfPyWg0k8MSxSFSDeN/JtrDJD5GQrxskP6c58+vUzruBJQY78AqQ==",
|
|
||||||
"license": "MIT",
|
|
||||||
"dependencies": {
|
|
||||||
"tslib": "2.8.1"
|
|
||||||
},
|
|
||||||
"engines": {
|
|
||||||
"node": ">=20.0.0"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"node_modules/@supabase/postgrest-js": {
|
|
||||||
"version": "2.81.1",
|
|
||||||
"resolved": "https://registry.npmjs.org/@supabase/postgrest-js/-/postgrest-js-2.81.1.tgz",
|
|
||||||
"integrity": "sha512-DePpUTAPXJyBurQ4IH2e42DWoA+/Qmr5mbgY4B6ZcxVc/ZUKfTVK31BYIFBATMApWraFc8Q/Sg+yxtfJ3E0wSg==",
|
|
||||||
"license": "MIT",
|
|
||||||
"dependencies": {
|
|
||||||
"tslib": "2.8.1"
|
|
||||||
},
|
|
||||||
"engines": {
|
|
||||||
"node": ">=20.0.0"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"node_modules/@supabase/realtime-js": {
|
|
||||||
"version": "2.81.1",
|
|
||||||
"resolved": "https://registry.npmjs.org/@supabase/realtime-js/-/realtime-js-2.81.1.tgz",
|
|
||||||
"integrity": "sha512-ViQ+Kxm8BuUP/TcYmH9tViqYKGSD1LBjdqx2p5J+47RES6c+0QHedM0PPAjthMdAHWyb2LGATE9PD2++2rO/tw==",
|
|
||||||
"license": "MIT",
|
|
||||||
"dependencies": {
|
|
||||||
"@types/phoenix": "^1.6.6",
|
|
||||||
"@types/ws": "^8.18.1",
|
|
||||||
"tslib": "2.8.1",
|
|
||||||
"ws": "^8.18.2"
|
|
||||||
},
|
|
||||||
"engines": {
|
|
||||||
"node": ">=20.0.0"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"node_modules/@supabase/ssr": {
|
|
||||||
"version": "0.7.0",
|
|
||||||
"resolved": "https://registry.npmjs.org/@supabase/ssr/-/ssr-0.7.0.tgz",
|
|
||||||
"integrity": "sha512-G65t5EhLSJ5c8hTCcXifSL9Q/ZRXvqgXeNo+d3P56f4U1IxwTqjB64UfmfixvmMcjuxnq2yGqEWVJqUcO+AzAg==",
|
|
||||||
"license": "MIT",
|
|
||||||
"dependencies": {
|
|
||||||
"cookie": "^1.0.2"
|
|
||||||
},
|
|
||||||
"peerDependencies": {
|
|
||||||
"@supabase/supabase-js": "^2.43.4"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"node_modules/@supabase/storage-js": {
|
|
||||||
"version": "2.81.1",
|
|
||||||
"resolved": "https://registry.npmjs.org/@supabase/storage-js/-/storage-js-2.81.1.tgz",
|
|
||||||
"integrity": "sha512-UNmYtjnZnhouqnbEMC1D5YJot7y0rIaZx7FG2Fv8S3hhNjcGVvO+h9We/tggi273BFkiahQPS/uRsapo1cSapw==",
|
|
||||||
"license": "MIT",
|
|
||||||
"dependencies": {
|
|
||||||
"tslib": "2.8.1"
|
|
||||||
},
|
|
||||||
"engines": {
|
|
||||||
"node": ">=20.0.0"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"node_modules/@supabase/supabase-js": {
|
|
||||||
"version": "2.81.1",
|
|
||||||
"resolved": "https://registry.npmjs.org/@supabase/supabase-js/-/supabase-js-2.81.1.tgz",
|
|
||||||
"integrity": "sha512-KSdY7xb2L0DlLmlYzIOghdw/na4gsMcqJ8u4sD6tOQJr+x3hLujU9s4R8N3ob84/1bkvpvlU5PYKa1ae+OICnw==",
|
|
||||||
"license": "MIT",
|
|
||||||
"dependencies": {
|
|
||||||
"@supabase/auth-js": "2.81.1",
|
|
||||||
"@supabase/functions-js": "2.81.1",
|
|
||||||
"@supabase/postgrest-js": "2.81.1",
|
|
||||||
"@supabase/realtime-js": "2.81.1",
|
|
||||||
"@supabase/storage-js": "2.81.1"
|
|
||||||
},
|
|
||||||
"engines": {
|
|
||||||
"node": ">=20.0.0"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"node_modules/@swc/helpers": {
|
"node_modules/@swc/helpers": {
|
||||||
"version": "0.5.15",
|
"version": "0.5.15",
|
||||||
"resolved": "https://registry.npmjs.org/@swc/helpers/-/helpers-0.5.15.tgz",
|
"resolved": "https://registry.npmjs.org/@swc/helpers/-/helpers-0.5.15.tgz",
|
||||||
@@ -1034,17 +941,12 @@
|
|||||||
"version": "20.19.23",
|
"version": "20.19.23",
|
||||||
"resolved": "https://registry.npmjs.org/@types/node/-/node-20.19.23.tgz",
|
"resolved": "https://registry.npmjs.org/@types/node/-/node-20.19.23.tgz",
|
||||||
"integrity": "sha512-yIdlVVVHXpmqRhtyovZAcSy0MiPcYWGkoO4CGe/+jpP0hmNuihm4XhHbADpK++MsiLHP5MVlv+bcgdF99kSiFQ==",
|
"integrity": "sha512-yIdlVVVHXpmqRhtyovZAcSy0MiPcYWGkoO4CGe/+jpP0hmNuihm4XhHbADpK++MsiLHP5MVlv+bcgdF99kSiFQ==",
|
||||||
|
"dev": true,
|
||||||
"license": "MIT",
|
"license": "MIT",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"undici-types": "~6.21.0"
|
"undici-types": "~6.21.0"
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"node_modules/@types/phoenix": {
|
|
||||||
"version": "1.6.6",
|
|
||||||
"resolved": "https://registry.npmjs.org/@types/phoenix/-/phoenix-1.6.6.tgz",
|
|
||||||
"integrity": "sha512-PIzZZlEppgrpoT2QgbnDU+MMzuR6BbCjllj0bM70lWoejMeNJAxCchxnv7J3XFkI8MpygtRpzXrIlmWUBclP5A==",
|
|
||||||
"license": "MIT"
|
|
||||||
},
|
|
||||||
"node_modules/@types/react": {
|
"node_modules/@types/react": {
|
||||||
"version": "19.2.2",
|
"version": "19.2.2",
|
||||||
"resolved": "https://registry.npmjs.org/@types/react/-/react-19.2.2.tgz",
|
"resolved": "https://registry.npmjs.org/@types/react/-/react-19.2.2.tgz",
|
||||||
@@ -1065,15 +967,6 @@
|
|||||||
"@types/react": "^19.2.0"
|
"@types/react": "^19.2.0"
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"node_modules/@types/ws": {
|
|
||||||
"version": "8.18.1",
|
|
||||||
"resolved": "https://registry.npmjs.org/@types/ws/-/ws-8.18.1.tgz",
|
|
||||||
"integrity": "sha512-ThVF6DCVhA8kUGy+aazFQ4kXQ7E1Ty7A3ypFOe0IcJV8O/M511G99AW24irKrW56Wt44yG9+ij8FaqoBGkuBXg==",
|
|
||||||
"license": "MIT",
|
|
||||||
"dependencies": {
|
|
||||||
"@types/node": "*"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"node_modules/caniuse-lite": {
|
"node_modules/caniuse-lite": {
|
||||||
"version": "1.0.30001751",
|
"version": "1.0.30001751",
|
||||||
"resolved": "https://registry.npmjs.org/caniuse-lite/-/caniuse-lite-1.0.30001751.tgz",
|
"resolved": "https://registry.npmjs.org/caniuse-lite/-/caniuse-lite-1.0.30001751.tgz",
|
||||||
@@ -1100,15 +993,6 @@
|
|||||||
"integrity": "sha512-IV3Ou0jSMzZrd3pZ48nLkT9DA7Ag1pnPzaiQhpW7c3RbcqqzvzzVu+L8gfqMp/8IM2MQtSiqaCxrrcfu8I8rMA==",
|
"integrity": "sha512-IV3Ou0jSMzZrd3pZ48nLkT9DA7Ag1pnPzaiQhpW7c3RbcqqzvzzVu+L8gfqMp/8IM2MQtSiqaCxrrcfu8I8rMA==",
|
||||||
"license": "MIT"
|
"license": "MIT"
|
||||||
},
|
},
|
||||||
"node_modules/cookie": {
|
|
||||||
"version": "1.0.2",
|
|
||||||
"resolved": "https://registry.npmjs.org/cookie/-/cookie-1.0.2.tgz",
|
|
||||||
"integrity": "sha512-9Kr/j4O16ISv8zBBhJoi4bXOYNTkFLOqSL3UDB0njXxCXNezjeyVrJyGOWtgfs/q2km1gwBcfH8q1yEGoMYunA==",
|
|
||||||
"license": "MIT",
|
|
||||||
"engines": {
|
|
||||||
"node": ">=18"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"node_modules/csstype": {
|
"node_modules/csstype": {
|
||||||
"version": "3.1.3",
|
"version": "3.1.3",
|
||||||
"resolved": "https://registry.npmjs.org/csstype/-/csstype-3.1.3.tgz",
|
"resolved": "https://registry.npmjs.org/csstype/-/csstype-3.1.3.tgz",
|
||||||
@@ -1721,29 +1605,9 @@
|
|||||||
"version": "6.21.0",
|
"version": "6.21.0",
|
||||||
"resolved": "https://registry.npmjs.org/undici-types/-/undici-types-6.21.0.tgz",
|
"resolved": "https://registry.npmjs.org/undici-types/-/undici-types-6.21.0.tgz",
|
||||||
"integrity": "sha512-iwDZqg0QAGrg9Rav5H4n0M64c3mkR59cJ6wQp+7C4nI0gsmExaedaYLNO44eT4AtBBwjbTiGPMlt2Md0T9H9JQ==",
|
"integrity": "sha512-iwDZqg0QAGrg9Rav5H4n0M64c3mkR59cJ6wQp+7C4nI0gsmExaedaYLNO44eT4AtBBwjbTiGPMlt2Md0T9H9JQ==",
|
||||||
|
"dev": true,
|
||||||
"license": "MIT"
|
"license": "MIT"
|
||||||
},
|
},
|
||||||
"node_modules/ws": {
|
|
||||||
"version": "8.18.3",
|
|
||||||
"resolved": "https://registry.npmjs.org/ws/-/ws-8.18.3.tgz",
|
|
||||||
"integrity": "sha512-PEIGCY5tSlUt50cqyMXfCzX+oOPqN0vuGqWzbcJ2xvnkzkq46oOpz7dQaTDBdfICb4N14+GARUDw2XV2N4tvzg==",
|
|
||||||
"license": "MIT",
|
|
||||||
"engines": {
|
|
||||||
"node": ">=10.0.0"
|
|
||||||
},
|
|
||||||
"peerDependencies": {
|
|
||||||
"bufferutil": "^4.0.1",
|
|
||||||
"utf-8-validate": ">=5.0.2"
|
|
||||||
},
|
|
||||||
"peerDependenciesMeta": {
|
|
||||||
"bufferutil": {
|
|
||||||
"optional": true
|
|
||||||
},
|
|
||||||
"utf-8-validate": {
|
|
||||||
"optional": true
|
|
||||||
}
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"node_modules/zod": {
|
"node_modules/zod": {
|
||||||
"version": "4.1.12",
|
"version": "4.1.12",
|
||||||
"resolved": "https://registry.npmjs.org/zod/-/zod-4.1.12.tgz",
|
"resolved": "https://registry.npmjs.org/zod/-/zod-4.1.12.tgz",
|
||||||
|
|||||||
@@ -8,8 +8,6 @@
|
|||||||
"start": "next start"
|
"start": "next start"
|
||||||
},
|
},
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@supabase/ssr": "^0.7.0",
|
|
||||||
"@supabase/supabase-js": "^2.81.1",
|
|
||||||
"next": "16.0.0",
|
"next": "16.0.0",
|
||||||
"react": "19.2.0",
|
"react": "19.2.0",
|
||||||
"react-dom": "19.2.0",
|
"react-dom": "19.2.0",
|
||||||
|
|||||||
@@ -1,26 +1,20 @@
|
|||||||
'use client';
|
'use client';
|
||||||
|
|
||||||
import { useEffect, useState } from 'react';
|
import { useEffect, useState } from 'react';
|
||||||
import { TaskManager } from '@/components/admin/TaskManager';
|
import { useSession } from '@/hooks/useSession';
|
||||||
import { ExperimentForm } from '@/components/admin/ExperimentForm';
|
|
||||||
|
|
||||||
type Experiment = {
|
type Experiment = {
|
||||||
id: string;
|
id: string;
|
||||||
subject_name: string;
|
status: 'active' | 'stopped';
|
||||||
xp_human_only: boolean;
|
sessionIds: string[];
|
||||||
xp_market_mode: string;
|
createdAt: number;
|
||||||
created_at: string;
|
|
||||||
task?: {
|
|
||||||
id: string;
|
|
||||||
task_name: string;
|
|
||||||
};
|
|
||||||
};
|
};
|
||||||
|
|
||||||
export default function ExperimentsAdmin() {
|
export default function ExperimentsAdmin() {
|
||||||
|
const { sessionId, isLoading: sessionLoading } = useSession();
|
||||||
const [exps, setExps] = useState<Experiment[]>([]);
|
const [exps, setExps] = useState<Experiment[]>([]);
|
||||||
const [selectedTaskId, setSelectedTaskId] = useState<string | undefined>();
|
const [loading, setLoading] = useState(false);
|
||||||
const [error, setError] = useState<string | null>(null);
|
const [error, setError] = useState<string | null>(null);
|
||||||
const [showForm, setShowForm] = useState(false);
|
|
||||||
|
|
||||||
const fetchExps = async () => {
|
const fetchExps = async () => {
|
||||||
try {
|
try {
|
||||||
@@ -37,22 +31,86 @@ export default function ExperimentsAdmin() {
|
|||||||
fetchExps();
|
fetchExps();
|
||||||
}, []);
|
}, []);
|
||||||
|
|
||||||
const handleExperimentCreated = async () => {
|
const handleStart = async () => {
|
||||||
setShowForm(false);
|
if (!sessionId) {
|
||||||
setSelectedTaskId(undefined);
|
setError('no session available');
|
||||||
await fetchExps();
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
setLoading(true);
|
||||||
|
setError(null);
|
||||||
|
|
||||||
|
try {
|
||||||
|
const res = await fetch('/api/admin/experiments/start', {
|
||||||
|
method: 'POST',
|
||||||
|
headers: { 'Content-Type': 'application/json' },
|
||||||
|
body: JSON.stringify({ sessionId }),
|
||||||
|
});
|
||||||
|
|
||||||
|
if (!res.ok) {
|
||||||
|
const data = await res.json();
|
||||||
|
throw new Error(data.error || 'start failed');
|
||||||
|
}
|
||||||
|
|
||||||
|
await fetchExps(); // refresh list
|
||||||
|
} catch (err: any) {
|
||||||
|
setError(err.message);
|
||||||
|
} finally {
|
||||||
|
setLoading(false);
|
||||||
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
|
const handleStop = async (expId: string) => {
|
||||||
|
setLoading(true);
|
||||||
|
setError(null);
|
||||||
|
|
||||||
|
try {
|
||||||
|
const res = await fetch('/api/admin/experiments/stop', {
|
||||||
|
method: 'POST',
|
||||||
|
headers: { 'Content-Type': 'application/json' },
|
||||||
|
body: JSON.stringify({ experimentId: expId }),
|
||||||
|
});
|
||||||
|
|
||||||
|
if (!res.ok) {
|
||||||
|
const data = await res.json();
|
||||||
|
throw new Error(data.error || 'stop failed');
|
||||||
|
}
|
||||||
|
|
||||||
|
await fetchExps(); // refresh list
|
||||||
|
} catch (err: any) {
|
||||||
|
setError(err.message);
|
||||||
|
} finally {
|
||||||
|
setLoading(false);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
if (sessionLoading) {
|
||||||
|
return (
|
||||||
|
<div className="flex min-h-screen items-center justify-center bg-zinc-50 dark:bg-black">
|
||||||
|
<p className="text-zinc-600 dark:text-zinc-400">loading session...</p>
|
||||||
|
</div>
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<div className="min-h-screen bg-zinc-50 px-6 py-12 dark:bg-black">
|
<div className="min-h-screen bg-zinc-50 px-6 py-12 dark:bg-black">
|
||||||
<div className="mx-auto max-w-7xl">
|
<div className="mx-auto max-w-5xl">
|
||||||
<div className="mb-8">
|
<div className="mb-8 flex items-center justify-between">
|
||||||
<h1 className="text-3xl font-semibold tracking-tight text-black dark:text-zinc-50">
|
<div>
|
||||||
Experiment Management
|
<h1 className="text-3xl font-semibold tracking-tight text-black dark:text-zinc-50">
|
||||||
</h1>
|
Experiments
|
||||||
<p className="mt-2 text-sm text-zinc-600 dark:text-zinc-400">
|
</h1>
|
||||||
configure tasks and run experiments
|
<p className="mt-2 text-sm text-zinc-600 dark:text-zinc-400">
|
||||||
</p>
|
current session: {sessionId || 'none'}
|
||||||
|
</p>
|
||||||
|
</div>
|
||||||
|
<button
|
||||||
|
onClick={handleStart}
|
||||||
|
disabled={loading || !sessionId}
|
||||||
|
className="rounded-lg bg-black px-4 py-2 text-sm font-medium text-white transition-colors hover:bg-zinc-800 disabled:opacity-50 dark:bg-zinc-50 dark:text-black dark:hover:bg-zinc-200"
|
||||||
|
>
|
||||||
|
{loading ? 'starting...' : 'start experiment'}
|
||||||
|
</button>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
{error && (
|
{error && (
|
||||||
@@ -61,123 +119,79 @@ export default function ExperimentsAdmin() {
|
|||||||
</div>
|
</div>
|
||||||
)}
|
)}
|
||||||
|
|
||||||
<div className="grid grid-cols-1 gap-6 lg:grid-cols-3">
|
<div className="overflow-hidden rounded-lg border border-zinc-200 bg-white dark:border-zinc-800 dark:bg-zinc-950">
|
||||||
{/* left column: task manager */}
|
<table className="w-full text-left text-sm">
|
||||||
<div className="lg:col-span-1">
|
<thead className="border-b border-zinc-200 bg-zinc-50 dark:border-zinc-800 dark:bg-zinc-900">
|
||||||
<TaskManager
|
<tr>
|
||||||
onTaskSelect={setSelectedTaskId}
|
<th className="px-6 py-3 font-medium text-zinc-900 dark:text-zinc-100">
|
||||||
selectedTaskId={selectedTaskId}
|
experiment id
|
||||||
/>
|
</th>
|
||||||
</div>
|
<th className="px-6 py-3 font-medium text-zinc-900 dark:text-zinc-100">
|
||||||
|
status
|
||||||
{/* right column: experiment form + list */}
|
</th>
|
||||||
<div className="space-y-6 lg:col-span-2">
|
<th className="px-6 py-3 font-medium text-zinc-900 dark:text-zinc-100">
|
||||||
<div className="flex items-center justify-between">
|
session count
|
||||||
<h2 className="text-lg font-semibold text-zinc-900 dark:text-zinc-100">
|
</th>
|
||||||
Experiments
|
<th className="px-6 py-3 font-medium text-zinc-900 dark:text-zinc-100">
|
||||||
</h2>
|
created
|
||||||
<button
|
</th>
|
||||||
onClick={() => setShowForm(!showForm)}
|
<th className="px-6 py-3 font-medium text-zinc-900 dark:text-zinc-100">
|
||||||
className="rounded-lg bg-black px-4 py-2 text-sm font-medium text-white transition-colors hover:bg-zinc-800 dark:bg-zinc-50 dark:text-black dark:hover:bg-zinc-200"
|
action
|
||||||
>
|
</th>
|
||||||
{showForm ? 'hide form' : 'new experiment'}
|
</tr>
|
||||||
</button>
|
</thead>
|
||||||
</div>
|
<tbody className="divide-y divide-zinc-200 dark:divide-zinc-800">
|
||||||
|
{exps.length === 0 ? (
|
||||||
{showForm && (
|
<tr>
|
||||||
<ExperimentForm
|
<td
|
||||||
selectedTaskId={selectedTaskId}
|
colSpan={5}
|
||||||
onSuccess={handleExperimentCreated}
|
className="px-6 py-8 text-center text-zinc-500 dark:text-zinc-400"
|
||||||
/>
|
>
|
||||||
)}
|
no experiments yet
|
||||||
|
</td>
|
||||||
<div className="overflow-hidden rounded-lg border border-zinc-200 bg-white dark:border-zinc-800 dark:bg-zinc-950">
|
</tr>
|
||||||
<table className="w-full text-left text-sm">
|
) : (
|
||||||
<thead className="border-b border-zinc-200 bg-zinc-50 dark:border-zinc-800 dark:bg-zinc-900">
|
exps.map((exp) => (
|
||||||
<tr>
|
<tr
|
||||||
<th className="px-4 py-3 font-medium text-zinc-900 dark:text-zinc-100">
|
key={exp.id}
|
||||||
subject
|
className="hover:bg-zinc-50 dark:hover:bg-zinc-900"
|
||||||
</th>
|
>
|
||||||
<th className="px-4 py-3 font-medium text-zinc-900 dark:text-zinc-100">
|
<td className="px-6 py-4 font-mono text-xs text-zinc-700 dark:text-zinc-300">
|
||||||
mode
|
{exp.id.slice(0, 8)}...
|
||||||
</th>
|
</td>
|
||||||
<th className="px-4 py-3 font-medium text-zinc-900 dark:text-zinc-100">
|
<td className="px-6 py-4">
|
||||||
human
|
<span
|
||||||
</th>
|
className={`inline-block rounded-full px-2 py-1 text-xs font-medium ${
|
||||||
<th className="px-4 py-3 font-medium text-zinc-900 dark:text-zinc-100">
|
exp.status === 'active'
|
||||||
task
|
? 'bg-green-100 text-green-800 dark:bg-green-950 dark:text-green-200'
|
||||||
</th>
|
: 'bg-zinc-100 text-zinc-800 dark:bg-zinc-800 dark:text-zinc-200'
|
||||||
<th className="px-4 py-3 font-medium text-zinc-900 dark:text-zinc-100">
|
}`}
|
||||||
created
|
|
||||||
</th>
|
|
||||||
<th className="px-4 py-3 font-medium text-zinc-900 dark:text-zinc-100">
|
|
||||||
link
|
|
||||||
</th>
|
|
||||||
</tr>
|
|
||||||
</thead>
|
|
||||||
<tbody className="divide-y divide-zinc-200 dark:divide-zinc-800">
|
|
||||||
{exps.length === 0 ? (
|
|
||||||
<tr>
|
|
||||||
<td
|
|
||||||
colSpan={6}
|
|
||||||
className="px-4 py-8 text-center text-zinc-500 dark:text-zinc-400"
|
|
||||||
>
|
>
|
||||||
no experiments yet
|
{exp.status}
|
||||||
</td>
|
</span>
|
||||||
</tr>
|
</td>
|
||||||
) : (
|
<td className="px-6 py-4 text-zinc-700 dark:text-zinc-300">
|
||||||
exps.map((exp) => {
|
{exp.sessionIds.length}
|
||||||
const baseUrl = exp.xp_market_mode === 'airline'
|
</td>
|
||||||
? 'https://phantom-airline.vercel.app'
|
<td className="px-6 py-4 text-zinc-700 dark:text-zinc-300">
|
||||||
: 'https://phantom-hotel.vercel.app';
|
{new Date(exp.createdAt).toLocaleString()}
|
||||||
const link = `${baseUrl}/start-task?uuid=${exp.id}`;
|
</td>
|
||||||
|
<td className="px-6 py-4">
|
||||||
return (
|
{exp.status === 'active' && (
|
||||||
<tr
|
<button
|
||||||
key={exp.id}
|
onClick={() => handleStop(exp.id)}
|
||||||
className="hover:bg-zinc-50 dark:hover:bg-zinc-900"
|
disabled={loading}
|
||||||
|
className="text-sm font-medium text-red-600 hover:text-red-700 disabled:opacity-50 dark:text-red-400 dark:hover:text-red-300"
|
||||||
>
|
>
|
||||||
<td className="px-4 py-3 font-medium text-zinc-900 dark:text-zinc-100">
|
stop
|
||||||
{exp.subject_name}
|
</button>
|
||||||
</td>
|
)}
|
||||||
<td className="px-4 py-3">
|
</td>
|
||||||
<span className="inline-block rounded-full bg-zinc-100 px-2 py-1 text-xs font-medium text-zinc-800 dark:bg-zinc-800 dark:text-zinc-200">
|
</tr>
|
||||||
{exp.xp_market_mode || 'none'}
|
))
|
||||||
</span>
|
)}
|
||||||
</td>
|
</tbody>
|
||||||
<td className="px-4 py-3">
|
</table>
|
||||||
{exp.xp_human_only ? (
|
|
||||||
<span className="text-xs text-green-600 dark:text-green-400">
|
|
||||||
yes
|
|
||||||
</span>
|
|
||||||
) : (
|
|
||||||
<span className="text-xs text-zinc-500">no</span>
|
|
||||||
)}
|
|
||||||
</td>
|
|
||||||
<td className="px-4 py-3 text-xs text-zinc-600 dark:text-zinc-400">
|
|
||||||
{exp.task ? exp.task.task_name : '—'}
|
|
||||||
</td>
|
|
||||||
<td className="px-4 py-3 text-xs text-zinc-600 dark:text-zinc-400">
|
|
||||||
{new Date(exp.created_at).toLocaleDateString()}
|
|
||||||
</td>
|
|
||||||
<td className="px-4 py-3">
|
|
||||||
<button
|
|
||||||
onClick={() => {
|
|
||||||
navigator.clipboard.writeText(link);
|
|
||||||
}}
|
|
||||||
className="text-xs font-medium text-zinc-900 hover:text-zinc-600 dark:text-zinc-100 dark:hover:text-zinc-400"
|
|
||||||
>
|
|
||||||
copy link
|
|
||||||
</button>
|
|
||||||
</td>
|
|
||||||
</tr>
|
|
||||||
);
|
|
||||||
})
|
|
||||||
)}
|
|
||||||
</tbody>
|
|
||||||
</table>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
|
|||||||
@@ -1,40 +1,10 @@
|
|||||||
import { NextRequest, NextResponse } from 'next/server';
|
import { NextResponse } from 'next/server';
|
||||||
import { createClient } from '@/utils/supabase/server';
|
import { getAllExperiments } from '@/lib/sessionStore';
|
||||||
import { cookies } from 'next/headers';
|
|
||||||
|
|
||||||
export async function GET(req: NextRequest) {
|
export async function GET() {
|
||||||
try {
|
try {
|
||||||
const cookieStore = await cookies();
|
const exps = getAllExperiments();
|
||||||
const supabase = createClient(cookieStore);
|
return NextResponse.json({ experiments: exps });
|
||||||
|
|
||||||
const { searchParams } = new URL(req.url);
|
|
||||||
const id = searchParams.get('id');
|
|
||||||
|
|
||||||
if (id) {
|
|
||||||
const { data, error } = await supabase
|
|
||||||
.from('experiments')
|
|
||||||
.select(`
|
|
||||||
*,
|
|
||||||
task:tasks(*)
|
|
||||||
`)
|
|
||||||
.eq('id', id)
|
|
||||||
.single();
|
|
||||||
|
|
||||||
if (error) throw error;
|
|
||||||
return NextResponse.json({ experiment: data });
|
|
||||||
}
|
|
||||||
|
|
||||||
const { data, error } = await supabase
|
|
||||||
.from('experiments')
|
|
||||||
.select(`
|
|
||||||
*,
|
|
||||||
task:tasks(*)
|
|
||||||
`)
|
|
||||||
.order('created_at', { ascending: false });
|
|
||||||
|
|
||||||
if (error) throw error;
|
|
||||||
|
|
||||||
return NextResponse.json({ experiments: data || [] });
|
|
||||||
} catch (err: any) {
|
} catch (err: any) {
|
||||||
console.error('experiments list error:', err);
|
console.error('experiments list error:', err);
|
||||||
return NextResponse.json(
|
return NextResponse.json(
|
||||||
@@ -43,44 +13,3 @@ export async function GET(req: NextRequest) {
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
export async function POST(req: NextRequest) {
|
|
||||||
try {
|
|
||||||
const cookieStore = await cookies();
|
|
||||||
const supabase = createClient(cookieStore);
|
|
||||||
const body = await req.json();
|
|
||||||
|
|
||||||
const { subject_name, xp_human_only, xp_market_mode, xp_task_id } = body;
|
|
||||||
|
|
||||||
if (!subject_name) {
|
|
||||||
return NextResponse.json(
|
|
||||||
{ error: 'subject_name is required' },
|
|
||||||
{ status: 400 }
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
const { data, error } = await supabase
|
|
||||||
.from('experiments')
|
|
||||||
.insert([{
|
|
||||||
subject_name,
|
|
||||||
xp_human_only: xp_human_only ?? false,
|
|
||||||
xp_market_mode: xp_market_mode || null,
|
|
||||||
xp_task_id: xp_task_id || null,
|
|
||||||
}])
|
|
||||||
.select(`
|
|
||||||
*,
|
|
||||||
task:tasks(*)
|
|
||||||
`)
|
|
||||||
.single();
|
|
||||||
|
|
||||||
if (error) throw error;
|
|
||||||
|
|
||||||
return NextResponse.json({ experiment: data });
|
|
||||||
} catch (err: any) {
|
|
||||||
console.error('experiment creation error:', err);
|
|
||||||
return NextResponse.json(
|
|
||||||
{ error: err.message || 'unknown error' },
|
|
||||||
{ status: 500 }
|
|
||||||
);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -1,58 +0,0 @@
|
|||||||
import { NextRequest, NextResponse } from 'next/server';
|
|
||||||
import { createClient } from '@/utils/supabase/server';
|
|
||||||
import { cookies } from 'next/headers';
|
|
||||||
|
|
||||||
export async function GET() {
|
|
||||||
try {
|
|
||||||
const cookieStore = await cookies();
|
|
||||||
const supabase = createClient(cookieStore);
|
|
||||||
|
|
||||||
const { data, error } = await supabase
|
|
||||||
.from('tasks')
|
|
||||||
.select('*')
|
|
||||||
.order('created_at', { ascending: false });
|
|
||||||
|
|
||||||
if (error) throw error;
|
|
||||||
|
|
||||||
return NextResponse.json({ tasks: data || [] });
|
|
||||||
} catch (err: any) {
|
|
||||||
console.error('tasks fetch error:', err);
|
|
||||||
return NextResponse.json(
|
|
||||||
{ error: err.message || 'unknown error' },
|
|
||||||
{ status: 500 }
|
|
||||||
);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
export async function POST(req: NextRequest) {
|
|
||||||
try {
|
|
||||||
const cookieStore = await cookies();
|
|
||||||
const supabase = createClient(cookieStore);
|
|
||||||
const body = await req.json();
|
|
||||||
|
|
||||||
const { task_name, task_description, task_def_of_done } = body;
|
|
||||||
|
|
||||||
if (!task_name) {
|
|
||||||
return NextResponse.json(
|
|
||||||
{ error: 'task_name is required' },
|
|
||||||
{ status: 400 }
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
const { data, error } = await supabase
|
|
||||||
.from('tasks')
|
|
||||||
.insert([{ task_name, task_description, task_def_of_done }])
|
|
||||||
.select()
|
|
||||||
.single();
|
|
||||||
|
|
||||||
if (error) throw error;
|
|
||||||
|
|
||||||
return NextResponse.json({ task: data });
|
|
||||||
} catch (err: any) {
|
|
||||||
console.error('task creation error:', err);
|
|
||||||
return NextResponse.json(
|
|
||||||
{ error: err.message || 'unknown error' },
|
|
||||||
{ status: 500 }
|
|
||||||
);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -1,12 +1,13 @@
|
|||||||
import { NextRequest, NextResponse } from 'next/server';
|
import { NextRequest, NextResponse } from 'next/server';
|
||||||
import { randomUUID } from 'crypto';
|
import { randomUUID } from 'crypto';
|
||||||
import { getSession, createSession, setExperiment } from '@/lib/sessionStore';
|
import { getSession, createSession } from '@/lib/sessionStore';
|
||||||
|
|
||||||
const COOKIE_NAME = 'phantom_session_id';
|
const COOKIE_NAME = 'phantom_session_id';
|
||||||
const isProd = process.env.NODE_ENV === 'production';
|
const isProd = process.env.NODE_ENV === 'production';
|
||||||
|
|
||||||
export async function GET(req: NextRequest) {
|
export async function GET(req: NextRequest) {
|
||||||
try {
|
try {
|
||||||
|
// check for existing session cookie
|
||||||
const existingSession = req.cookies.get(COOKIE_NAME)?.value;
|
const existingSession = req.cookies.get(COOKIE_NAME)?.value;
|
||||||
|
|
||||||
if (existingSession) {
|
if (existingSession) {
|
||||||
@@ -17,11 +18,13 @@ export async function GET(req: NextRequest) {
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// mint new session id
|
||||||
const sessionId = randomUUID();
|
const sessionId = randomUUID();
|
||||||
createSession(sessionId);
|
createSession(sessionId);
|
||||||
|
|
||||||
const res = NextResponse.json({ sessionId, experimentId: undefined });
|
const res = NextResponse.json({ sessionId, experimentId: undefined });
|
||||||
|
|
||||||
|
// set httpOnly cookie with security flags
|
||||||
res.cookies.set({
|
res.cookies.set({
|
||||||
name: COOKIE_NAME,
|
name: COOKIE_NAME,
|
||||||
value: sessionId,
|
value: sessionId,
|
||||||
@@ -29,7 +32,7 @@ export async function GET(req: NextRequest) {
|
|||||||
sameSite: 'lax',
|
sameSite: 'lax',
|
||||||
secure: isProd,
|
secure: isProd,
|
||||||
path: '/',
|
path: '/',
|
||||||
maxAge: 60 * 60 * 24 * 30,
|
maxAge: 60 * 60 * 24 * 30, // 30 days
|
||||||
});
|
});
|
||||||
|
|
||||||
return res;
|
return res;
|
||||||
@@ -41,52 +44,3 @@ export async function GET(req: NextRequest) {
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
export async function POST(req: NextRequest) {
|
|
||||||
try {
|
|
||||||
const body = await req.json();
|
|
||||||
const { experimentId } = body;
|
|
||||||
|
|
||||||
if (!experimentId) {
|
|
||||||
return NextResponse.json(
|
|
||||||
{ error: 'experimentId is required' },
|
|
||||||
{ status: 400 }
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
let sessionId = req.cookies.get(COOKIE_NAME)?.value;
|
|
||||||
|
|
||||||
if (!sessionId) {
|
|
||||||
sessionId = randomUUID();
|
|
||||||
createSession(sessionId);
|
|
||||||
}
|
|
||||||
|
|
||||||
setExperiment(sessionId, experimentId);
|
|
||||||
|
|
||||||
const res = NextResponse.json({
|
|
||||||
sessionId,
|
|
||||||
experimentId,
|
|
||||||
success: true
|
|
||||||
});
|
|
||||||
|
|
||||||
if (!req.cookies.get(COOKIE_NAME)) {
|
|
||||||
res.cookies.set({
|
|
||||||
name: COOKIE_NAME,
|
|
||||||
value: sessionId,
|
|
||||||
httpOnly: true,
|
|
||||||
sameSite: 'lax',
|
|
||||||
secure: isProd,
|
|
||||||
path: '/',
|
|
||||||
maxAge: 60 * 60 * 24 * 30,
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
return res;
|
|
||||||
} catch (err: any) {
|
|
||||||
console.error('session update error:', err);
|
|
||||||
return NextResponse.json(
|
|
||||||
{ error: err.message || 'unknown error' },
|
|
||||||
{ status: 500 }
|
|
||||||
);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -1,93 +0,0 @@
|
|||||||
'use client';
|
|
||||||
|
|
||||||
import { useEffect, useState, Suspense } from 'react';
|
|
||||||
import { useSearchParams, useRouter } from 'next/navigation';
|
|
||||||
|
|
||||||
const StartTaskContent = () => {
|
|
||||||
const searchParams = useSearchParams();
|
|
||||||
const router = useRouter();
|
|
||||||
const [status, setStatus] = useState<'loading' | 'error' | 'redirecting'>('loading');
|
|
||||||
const [error, setError] = useState<string | null>(null);
|
|
||||||
|
|
||||||
useEffect(() => {
|
|
||||||
const uuid = searchParams.get('uuid');
|
|
||||||
|
|
||||||
if (!uuid) {
|
|
||||||
setError('no experiment UUID provided');
|
|
||||||
setStatus('error');
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const validateAndStore = async () => {
|
|
||||||
try {
|
|
||||||
const res = await fetch(`/api/admin/experiments?id=${uuid}`);
|
|
||||||
if (!res.ok) throw new Error('experiment not found');
|
|
||||||
|
|
||||||
const data = await res.json();
|
|
||||||
const exp = data.experiment;
|
|
||||||
|
|
||||||
if (!exp) throw new Error('invalid experiment UUID');
|
|
||||||
|
|
||||||
localStorage.setItem('phantom_experiment_id', uuid);
|
|
||||||
|
|
||||||
await fetch('/api/session', {
|
|
||||||
method: 'POST',
|
|
||||||
headers: { 'Content-Type': 'application/json' },
|
|
||||||
body: JSON.stringify({ experimentId: uuid }),
|
|
||||||
});
|
|
||||||
|
|
||||||
setStatus('redirecting');
|
|
||||||
|
|
||||||
setTimeout(() => {
|
|
||||||
router.push("/");
|
|
||||||
}, 800);
|
|
||||||
|
|
||||||
} catch (err: any) {
|
|
||||||
setError(err.message || 'failed to start task');
|
|
||||||
setStatus('error');
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
validateAndStore();
|
|
||||||
}, [searchParams, router]);
|
|
||||||
|
|
||||||
return (
|
|
||||||
<div className="flex min-h-screen items-center justify-center bg-zinc-50 dark:bg-black">
|
|
||||||
<div className="text-center">
|
|
||||||
{status === 'loading' && (
|
|
||||||
<div>
|
|
||||||
<div className="mb-4 h-8 w-8 animate-spin rounded-full border-4 border-zinc-200 border-t-zinc-900 dark:border-zinc-800 dark:border-t-zinc-100 mx-auto" />
|
|
||||||
<p className="text-zinc-600 dark:text-zinc-400">validating browser...</p>
|
|
||||||
</div>
|
|
||||||
)}
|
|
||||||
|
|
||||||
{status === 'redirecting' && (
|
|
||||||
<div>
|
|
||||||
<div className="mb-4 text-4xl">✓</div>
|
|
||||||
<p className="text-zinc-900 dark:text-zinc-100 font-medium">website loaded</p>
|
|
||||||
<p className="mt-2 text-sm text-zinc-600 dark:text-zinc-400">redirecting to page...</p>
|
|
||||||
</div>
|
|
||||||
)}
|
|
||||||
|
|
||||||
{status === 'error' && (
|
|
||||||
<div className="rounded-lg bg-red-50 p-6 dark:bg-red-950">
|
|
||||||
<p className="text-red-900 dark:text-red-100 font-medium">error</p>
|
|
||||||
<p className="mt-2 text-sm text-red-700 dark:text-red-300">{error}</p>
|
|
||||||
</div>
|
|
||||||
)}
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
);
|
|
||||||
};
|
|
||||||
|
|
||||||
export default function StartTaskPage() {
|
|
||||||
return (
|
|
||||||
<Suspense fallback={
|
|
||||||
<div className="flex min-h-screen items-center justify-center bg-zinc-50 dark:bg-black">
|
|
||||||
<p className="text-zinc-600 dark:text-zinc-400">loading...</p>
|
|
||||||
</div>
|
|
||||||
}>
|
|
||||||
<StartTaskContent />
|
|
||||||
</Suspense>
|
|
||||||
);
|
|
||||||
}
|
|
||||||
@@ -1,118 +0,0 @@
|
|||||||
'use client';
|
|
||||||
|
|
||||||
import { useState } from 'react';
|
|
||||||
|
|
||||||
type ExperimentFormProps = {
|
|
||||||
selectedTaskId?: string;
|
|
||||||
onSuccess?: () => void;
|
|
||||||
};
|
|
||||||
|
|
||||||
export const ExperimentForm = ({ selectedTaskId, onSuccess }: ExperimentFormProps) => {
|
|
||||||
const [loading, setLoading] = useState(false);
|
|
||||||
const [error, setError] = useState<string | null>(null);
|
|
||||||
const [form, setForm] = useState({
|
|
||||||
subject_name: '',
|
|
||||||
xp_human_only: false,
|
|
||||||
xp_market_mode: 'hotel' as 'hotel' | 'airline',
|
|
||||||
});
|
|
||||||
|
|
||||||
const handleSubmit = async (e: React.FormEvent) => {
|
|
||||||
e.preventDefault();
|
|
||||||
setLoading(true);
|
|
||||||
setError(null);
|
|
||||||
|
|
||||||
try {
|
|
||||||
const res = await fetch('/api/admin/experiments', {
|
|
||||||
method: 'POST',
|
|
||||||
headers: { 'Content-Type': 'application/json' },
|
|
||||||
body: JSON.stringify({
|
|
||||||
...form,
|
|
||||||
xp_task_id: selectedTaskId || null,
|
|
||||||
}),
|
|
||||||
});
|
|
||||||
|
|
||||||
if (!res.ok) {
|
|
||||||
const data = await res.json();
|
|
||||||
throw new Error(data.error || 'creation failed');
|
|
||||||
}
|
|
||||||
|
|
||||||
setForm({ subject_name: '', xp_human_only: false, xp_market_mode: 'hotel' });
|
|
||||||
onSuccess?.();
|
|
||||||
} catch (err: any) {
|
|
||||||
setError(err.message);
|
|
||||||
} finally {
|
|
||||||
setLoading(false);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
return (
|
|
||||||
<form onSubmit={handleSubmit} className="space-y-4 rounded-lg border border-zinc-200 bg-white p-6 dark:border-zinc-800 dark:bg-zinc-950">
|
|
||||||
<h2 className="text-lg font-semibold text-zinc-900 dark:text-zinc-100">
|
|
||||||
Create Experiment
|
|
||||||
</h2>
|
|
||||||
|
|
||||||
{error && (
|
|
||||||
<div className="rounded-lg bg-red-50 p-3 text-sm text-red-800 dark:bg-red-950 dark:text-red-200">
|
|
||||||
{error}
|
|
||||||
</div>
|
|
||||||
)}
|
|
||||||
|
|
||||||
<div>
|
|
||||||
<label className="block text-sm font-medium text-zinc-700 dark:text-zinc-300">
|
|
||||||
subject name
|
|
||||||
</label>
|
|
||||||
<input
|
|
||||||
type="text"
|
|
||||||
value={form.subject_name}
|
|
||||||
onChange={(e) => setForm({ ...form, subject_name: e.target.value })}
|
|
||||||
className="mt-1 w-full rounded-lg border border-zinc-300 bg-white px-3 py-2 text-sm text-zinc-900 focus:border-zinc-900 focus:outline-none dark:border-zinc-700 dark:bg-zinc-900 dark:text-zinc-100 dark:focus:border-zinc-100"
|
|
||||||
placeholder="e.g., baseline_dynamic_pricing_v1"
|
|
||||||
required
|
|
||||||
/>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div>
|
|
||||||
<label className="block text-sm font-medium text-zinc-700 dark:text-zinc-300">
|
|
||||||
market mode
|
|
||||||
</label>
|
|
||||||
<select
|
|
||||||
value={form.xp_market_mode}
|
|
||||||
onChange={(e) => setForm({ ...form, xp_market_mode: e.target.value as 'hotel' | 'airline' })}
|
|
||||||
className="mt-1 w-full rounded-lg border border-zinc-300 bg-white px-3 py-2 text-sm text-zinc-900 focus:border-zinc-900 focus:outline-none dark:border-zinc-700 dark:bg-zinc-900 dark:text-zinc-100 dark:focus:border-zinc-100"
|
|
||||||
>
|
|
||||||
<option value="hotel">hotel</option>
|
|
||||||
<option value="airline">airline</option>
|
|
||||||
</select>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div className="flex items-center gap-2">
|
|
||||||
<input
|
|
||||||
type="checkbox"
|
|
||||||
id="human-only"
|
|
||||||
checked={form.xp_human_only}
|
|
||||||
onChange={(e) => setForm({ ...form, xp_human_only: e.target.checked })}
|
|
||||||
className="h-4 w-4 rounded border-zinc-300 text-zinc-900 focus:ring-zinc-900 dark:border-zinc-700 dark:bg-zinc-900"
|
|
||||||
/>
|
|
||||||
<label htmlFor="human-only" className="text-sm text-zinc-700 dark:text-zinc-300">
|
|
||||||
human participants only
|
|
||||||
</label>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
{selectedTaskId && (
|
|
||||||
<div className="rounded-lg bg-zinc-50 p-3 dark:bg-zinc-900">
|
|
||||||
<p className="text-sm text-zinc-600 dark:text-zinc-400">
|
|
||||||
task selected: <span className="font-mono text-xs">{selectedTaskId.slice(0, 8)}...</span>
|
|
||||||
</p>
|
|
||||||
</div>
|
|
||||||
)}
|
|
||||||
|
|
||||||
<button
|
|
||||||
type="submit"
|
|
||||||
disabled={loading}
|
|
||||||
className="w-full rounded-lg bg-black px-4 py-2 text-sm font-medium text-white transition-colors hover:bg-zinc-800 disabled:opacity-50 dark:bg-zinc-50 dark:text-black dark:hover:bg-zinc-200"
|
|
||||||
>
|
|
||||||
{loading ? 'creating experiment...' : 'create experiment'}
|
|
||||||
</button>
|
|
||||||
</form>
|
|
||||||
);
|
|
||||||
};
|
|
||||||
@@ -1,178 +0,0 @@
|
|||||||
'use client';
|
|
||||||
|
|
||||||
import { useState, useEffect } from 'react';
|
|
||||||
|
|
||||||
type Task = {
|
|
||||||
id: string;
|
|
||||||
task_name: string;
|
|
||||||
task_description: string;
|
|
||||||
task_def_of_done: string;
|
|
||||||
created_at: string;
|
|
||||||
};
|
|
||||||
|
|
||||||
type TaskManagerProps = {
|
|
||||||
onTaskSelect?: (taskId: string) => void;
|
|
||||||
selectedTaskId?: string;
|
|
||||||
};
|
|
||||||
|
|
||||||
export const TaskManager = ({ onTaskSelect, selectedTaskId }: TaskManagerProps) => {
|
|
||||||
const [tasks, setTasks] = useState<Task[]>([]);
|
|
||||||
const [loading, setLoading] = useState(false);
|
|
||||||
const [showForm, setShowForm] = useState(false);
|
|
||||||
const [form, setForm] = useState({
|
|
||||||
task_name: '',
|
|
||||||
task_description: '',
|
|
||||||
task_def_of_done: '',
|
|
||||||
});
|
|
||||||
const [error, setError] = useState<string | null>(null);
|
|
||||||
|
|
||||||
const fetchTasks = async () => {
|
|
||||||
try {
|
|
||||||
const res = await fetch('/api/admin/tasks');
|
|
||||||
if (!res.ok) throw new Error(`fetch failed: ${res.status}`);
|
|
||||||
const data = await res.json();
|
|
||||||
setTasks(data.tasks || []);
|
|
||||||
} catch (err: any) {
|
|
||||||
setError(err.message);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
useEffect(() => {
|
|
||||||
fetchTasks();
|
|
||||||
}, []);
|
|
||||||
|
|
||||||
const handleSubmit = async (e: React.FormEvent) => {
|
|
||||||
e.preventDefault();
|
|
||||||
setLoading(true);
|
|
||||||
setError(null);
|
|
||||||
|
|
||||||
try {
|
|
||||||
const res = await fetch('/api/admin/tasks', {
|
|
||||||
method: 'POST',
|
|
||||||
headers: { 'Content-Type': 'application/json' },
|
|
||||||
body: JSON.stringify(form),
|
|
||||||
});
|
|
||||||
|
|
||||||
if (!res.ok) {
|
|
||||||
const data = await res.json();
|
|
||||||
throw new Error(data.error || 'creation failed');
|
|
||||||
}
|
|
||||||
|
|
||||||
setForm({ task_name: '', task_description: '', task_def_of_done: '' });
|
|
||||||
setShowForm(false);
|
|
||||||
await fetchTasks();
|
|
||||||
} catch (err: any) {
|
|
||||||
setError(err.message);
|
|
||||||
} finally {
|
|
||||||
setLoading(false);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
return (
|
|
||||||
<div className="space-y-4">
|
|
||||||
<div className="flex items-center justify-between">
|
|
||||||
<h2 className="text-lg font-semibold text-zinc-900 dark:text-zinc-100">
|
|
||||||
Tasks
|
|
||||||
</h2>
|
|
||||||
<button
|
|
||||||
onClick={() => setShowForm(!showForm)}
|
|
||||||
className="rounded-lg bg-zinc-900 px-3 py-1.5 text-sm font-medium text-white transition-colors hover:bg-zinc-700 dark:bg-zinc-100 dark:text-black dark:hover:bg-zinc-300"
|
|
||||||
>
|
|
||||||
{showForm ? 'cancel' : 'new task'}
|
|
||||||
</button>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
{error && (
|
|
||||||
<div className="rounded-lg bg-red-50 p-3 text-sm text-red-800 dark:bg-red-950 dark:text-red-200">
|
|
||||||
{error}
|
|
||||||
</div>
|
|
||||||
)}
|
|
||||||
|
|
||||||
{showForm && (
|
|
||||||
<form onSubmit={handleSubmit} className="space-y-3 rounded-lg border border-zinc-200 bg-white p-4 dark:border-zinc-800 dark:bg-zinc-950">
|
|
||||||
<div>
|
|
||||||
<label className="block text-sm font-medium text-zinc-700 dark:text-zinc-300">
|
|
||||||
task name
|
|
||||||
</label>
|
|
||||||
<input
|
|
||||||
type="text"
|
|
||||||
value={form.task_name}
|
|
||||||
onChange={(e) => setForm({ ...form, task_name: e.target.value })}
|
|
||||||
className="mt-1 w-full rounded-lg border border-zinc-300 bg-white px-3 py-2 text-sm text-zinc-900 focus:border-zinc-900 focus:outline-none dark:border-zinc-700 dark:bg-zinc-900 dark:text-zinc-100 dark:focus:border-zinc-100"
|
|
||||||
placeholder="e.g., Book cheapest flight to Paris"
|
|
||||||
required
|
|
||||||
/>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div>
|
|
||||||
<label className="block text-sm font-medium text-zinc-700 dark:text-zinc-300">
|
|
||||||
description
|
|
||||||
</label>
|
|
||||||
<textarea
|
|
||||||
value={form.task_description}
|
|
||||||
onChange={(e) => setForm({ ...form, task_description: e.target.value })}
|
|
||||||
className="mt-1 w-full rounded-lg border border-zinc-300 bg-white px-3 py-2 text-sm text-zinc-900 focus:border-zinc-900 focus:outline-none dark:border-zinc-700 dark:bg-zinc-900 dark:text-zinc-100 dark:focus:border-zinc-100"
|
|
||||||
placeholder="User should find and book the cheapest available flight..."
|
|
||||||
rows={3}
|
|
||||||
/>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div>
|
|
||||||
<label className="block text-sm font-medium text-zinc-700 dark:text-zinc-300">
|
|
||||||
definition of done
|
|
||||||
</label>
|
|
||||||
<textarea
|
|
||||||
value={form.task_def_of_done}
|
|
||||||
onChange={(e) => setForm({ ...form, task_def_of_done: e.target.value })}
|
|
||||||
className="mt-1 w-full rounded-lg border border-zinc-300 bg-white px-3 py-2 text-sm text-zinc-900 focus:border-zinc-900 focus:outline-none dark:border-zinc-700 dark:bg-zinc-900 dark:text-zinc-100 dark:focus:border-zinc-100"
|
|
||||||
placeholder="Booking is completed and confirmation page is shown"
|
|
||||||
rows={2}
|
|
||||||
/>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<button
|
|
||||||
type="submit"
|
|
||||||
disabled={loading}
|
|
||||||
className="w-full rounded-lg bg-black px-4 py-2 text-sm font-medium text-white transition-colors hover:bg-zinc-800 disabled:opacity-50 dark:bg-zinc-50 dark:text-black dark:hover:bg-zinc-200"
|
|
||||||
>
|
|
||||||
{loading ? 'creating...' : 'create task'}
|
|
||||||
</button>
|
|
||||||
</form>
|
|
||||||
)}
|
|
||||||
|
|
||||||
<div className="space-y-2">
|
|
||||||
{tasks.length === 0 ? (
|
|
||||||
<p className="py-8 text-center text-sm text-zinc-500 dark:text-zinc-400">
|
|
||||||
no tasks yet
|
|
||||||
</p>
|
|
||||||
) : (
|
|
||||||
tasks.map((task) => (
|
|
||||||
<div
|
|
||||||
key={task.id}
|
|
||||||
onClick={() => onTaskSelect?.(task.id)}
|
|
||||||
className={`cursor-pointer rounded-lg border p-3 transition-colors ${
|
|
||||||
selectedTaskId === task.id
|
|
||||||
? 'border-zinc-900 bg-zinc-50 dark:border-zinc-100 dark:bg-zinc-900'
|
|
||||||
: 'border-zinc-200 bg-white hover:border-zinc-300 dark:border-zinc-800 dark:bg-zinc-950 dark:hover:border-zinc-700'
|
|
||||||
}`}
|
|
||||||
>
|
|
||||||
<h3 className="font-medium text-zinc-900 dark:text-zinc-100">
|
|
||||||
{task.task_name}
|
|
||||||
</h3>
|
|
||||||
{task.task_description && (
|
|
||||||
<p className="mt-1 text-sm text-zinc-600 dark:text-zinc-400">
|
|
||||||
{task.task_description}
|
|
||||||
</p>
|
|
||||||
)}
|
|
||||||
{task.task_def_of_done && (
|
|
||||||
<p className="mt-1 text-xs text-zinc-500 dark:text-zinc-500">
|
|
||||||
done: {task.task_def_of_done}
|
|
||||||
</p>
|
|
||||||
)}
|
|
||||||
</div>
|
|
||||||
))
|
|
||||||
)}
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
);
|
|
||||||
};
|
|
||||||
@@ -1,5 +1,5 @@
|
|||||||
import { useEffect, useRef, useState } from 'react';
|
import { useEffect, useRef, useState } from 'react';
|
||||||
import '@/lib/experiments'
|
import '@/lib/experiments' // ensure experiments lib is loaded
|
||||||
import type { EventName } from '@/lib/events';
|
import type { EventName } from '@/lib/events';
|
||||||
|
|
||||||
const fetchSessionId = async (): Promise<string> => {
|
const fetchSessionId = async (): Promise<string> => {
|
||||||
@@ -21,14 +21,10 @@ const track = async (ev: {
|
|||||||
metadata?: Record<string, unknown>;
|
metadata?: Record<string, unknown>;
|
||||||
}) => {
|
}) => {
|
||||||
try {
|
try {
|
||||||
const experimentId = localStorage.getItem('phantom_experiment_id');
|
|
||||||
await fetch('/api/ingest', {
|
await fetch('/api/ingest', {
|
||||||
method: 'POST',
|
method: 'POST',
|
||||||
headers: { 'Content-Type': 'application/json' },
|
headers: { 'Content-Type': 'application/json' },
|
||||||
body: JSON.stringify({
|
body: JSON.stringify(ev),
|
||||||
...ev,
|
|
||||||
experimentId: experimentId || undefined,
|
|
||||||
}),
|
|
||||||
});
|
});
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
console.error('track failed:', err);
|
console.error('track failed:', err);
|
||||||
|
|||||||
@@ -10,7 +10,6 @@ export function proxy(req: NextRequest) {
|
|||||||
pathname.startsWith('/admin') ||
|
pathname.startsWith('/admin') ||
|
||||||
pathname.startsWith('/_next') ||
|
pathname.startsWith('/_next') ||
|
||||||
pathname.startsWith('/static') ||
|
pathname.startsWith('/static') ||
|
||||||
pathname.startsWith('/start-task') ||
|
|
||||||
pathname.includes('.')
|
pathname.includes('.')
|
||||||
// TODO: add robots.txt and sitemap.xml if needed here
|
// TODO: add robots.txt and sitemap.xml if needed here
|
||||||
) {
|
) {
|
||||||
|
|||||||
@@ -1,10 +0,0 @@
|
|||||||
import { createBrowserClient } from "@supabase/ssr";
|
|
||||||
|
|
||||||
const supabaseUrl = process.env.NEXT_PUBLIC_SUPABASE_URL;
|
|
||||||
const supabaseKey = process.env.NEXT_PUBLIC_SUPABASE_ANON_KEY;
|
|
||||||
|
|
||||||
export const createClient = () =>
|
|
||||||
createBrowserClient(
|
|
||||||
supabaseUrl!,
|
|
||||||
supabaseKey!,
|
|
||||||
);
|
|
||||||
@@ -1,37 +0,0 @@
|
|||||||
import { createServerClient, type CookieOptions } from "@supabase/ssr";
|
|
||||||
import { type NextRequest, NextResponse } from "next/server";
|
|
||||||
|
|
||||||
const supabaseUrl = process.env.NEXT_PUBLIC_SUPABASE_URL;
|
|
||||||
const supabaseKey = process.env.NEXT_PUBLIC_SUPABASE_ANON_KEY;
|
|
||||||
|
|
||||||
export const createClient = (request: NextRequest) => {
|
|
||||||
// Create an unmodified response
|
|
||||||
let supabaseResponse = NextResponse.next({
|
|
||||||
request: {
|
|
||||||
headers: request.headers,
|
|
||||||
},
|
|
||||||
});
|
|
||||||
|
|
||||||
const supabase = createServerClient(
|
|
||||||
supabaseUrl!,
|
|
||||||
supabaseKey!,
|
|
||||||
{
|
|
||||||
cookies: {
|
|
||||||
getAll() {
|
|
||||||
return request.cookies.getAll()
|
|
||||||
},
|
|
||||||
setAll(cookiesToSet) {
|
|
||||||
cookiesToSet.forEach(({ name, value, options }) => request.cookies.set(name, value))
|
|
||||||
supabaseResponse = NextResponse.next({
|
|
||||||
request,
|
|
||||||
})
|
|
||||||
cookiesToSet.forEach(({ name, value, options }) =>
|
|
||||||
supabaseResponse.cookies.set(name, value, options)
|
|
||||||
)
|
|
||||||
},
|
|
||||||
},
|
|
||||||
},
|
|
||||||
);
|
|
||||||
|
|
||||||
return supabaseResponse
|
|
||||||
};
|
|
||||||
@@ -1,27 +0,0 @@
|
|||||||
import { createServerClient, type CookieOptions } from "@supabase/ssr";
|
|
||||||
import { cookies } from "next/headers";
|
|
||||||
import { ReadonlyRequestCookies } from "next/dist/server/web/spec-extension/adapters/request-cookies";
|
|
||||||
|
|
||||||
const supabaseUrl = process.env.NEXT_PUBLIC_SUPABASE_URL;
|
|
||||||
const supabaseKey = process.env.NEXT_PUBLIC_SUPABASE_ANON_KEY;
|
|
||||||
|
|
||||||
export const createClient = (cookieStore: ReadonlyRequestCookies) => {
|
|
||||||
return createServerClient(
|
|
||||||
supabaseUrl!,
|
|
||||||
supabaseKey!,
|
|
||||||
{
|
|
||||||
cookies: {
|
|
||||||
getAll() {
|
|
||||||
return cookieStore.getAll()
|
|
||||||
},
|
|
||||||
setAll(cookiesToSet) {
|
|
||||||
try {
|
|
||||||
cookiesToSet.forEach(({ name, value, options }) => cookieStore.set(name, value, options))
|
|
||||||
} catch {
|
|
||||||
// `setAll` called from Server Component - ignored if middleware handles session refresh
|
|
||||||
}
|
|
||||||
},
|
|
||||||
},
|
|
||||||
},
|
|
||||||
);
|
|
||||||
};
|
|
||||||
Reference in New Issue
Block a user