diff --git a/mcp-server/console.html b/mcp-server/console.html
index 884afe9..db47d6b 100644
--- a/mcp-server/console.html
+++ b/mcp-server/console.html
@@ -244,6 +244,7 @@ function setupPrompts(data){
var under=data.supply.slice().sort(function(a,b){return (a.available/a.supply)-(b.available/b.supply)})[0];
if(under)prompts.push('Show me available '+under.role+'s');
}
+ prompts.push('Find me a warehouse worker available today near Nashville');
prompts.push('Find bilingual workers with leadership skills');
prompts.forEach(function(p){
var btn=el('button','',p);btn.className='prompt-btn';
@@ -324,6 +325,44 @@ function send(){
});
if(d.total_flagged)bbl.appendChild(el('div','font-size:10px;color:#484f58;margin-top:6px',d.total_flagged.toLocaleString()+' total workers match this risk profile'));
}
+ else if(d.type==='smart_search'){
+ // Show what the system understood
+ if(d.understood&&d.understood.length){
+ var tags=el('div','display:flex;gap:6px;flex-wrap:wrap;margin-bottom:10px');
+ d.understood.forEach(function(u){
+ tags.appendChild(el('span','padding:3px 10px;border-radius:10px;font-size:11px;background:#1a274420;color:#58a6ff;border:1px solid #1a274480',u));
+ });
+ bbl.appendChild(tags);
+ }
+ // Show SQL results with zip codes, availability, skills
+ if(d.sql_results&&d.sql_results.length){
+ d.sql_results.forEach(function(w){
+ var rc=div('result-card');
+ rc.appendChild(el('div','font-weight:600;color:#f0f6fc;font-size:14px',w.name));
+ var locParts=[w.role,w.city+', '+w.state];
+ if(w.zip)locParts.push('ZIP: '+w.zip);
+ rc.appendChild(el('div','font-size:12px;color:#8b949e;margin-top:2px',locParts.join(' · ')));
+ // Metrics row
+ var metrics=[];
+ if(w.avail!==undefined)metrics.push('Available: '+Math.round(w.avail*100)+'%');
+ if(w.rel!==undefined)metrics.push('Reliable: '+Math.round(w.rel*100)+'%');
+ if(w.archetype)metrics.push(w.archetype);
+ if(metrics.length)rc.appendChild(el('div','font-size:11px;color:#58a6ff;margin-top:4px',metrics.join(' · ')));
+ // Skills + certs
+ if(w.skills||w.certifications){
+ var tagRow=el('div','display:flex;gap:4px;flex-wrap:wrap;margin-top:6px');
+ if(w.skills)(w.skills||'').split(',').forEach(function(s){s=s.trim();if(s)tagRow.appendChild(el('span','padding:2px 8px;background:#1a2744;color:#58a6ff;border-radius:8px;font-size:10px',s))});
+ if(w.certifications)(w.certifications||'').split(',').forEach(function(c){c=c.trim();if(c&&c!=='none')tagRow.appendChild(el('span','padding:2px 8px;background:#1a3a2a;color:#3fb950;border-radius:8px;font-size:10px',c))});
+ rc.appendChild(tagRow);
+ }
+ bbl.appendChild(rc);
+ });
+ }
+ // Also show vector results if different
+ if(d.vector_results&&d.vector_results.length&&(!d.sql_results||!d.sql_results.length)){
+ renderResults(bbl,d.vector_results);
+ }
+ }
else if(d.type==='search'||d.type==='answer'){
renderResults(bbl,d.results||d.sources||[]);
}
diff --git a/mcp-server/index.ts b/mcp-server/index.ts
index d5a3e61..c4257c0 100644
--- a/mcp-server/index.ts
+++ b/mcp-server/index.ts
@@ -1149,15 +1149,98 @@ tr:hover{background:#111827}
queries_run: queries, duration_ms: Date.now() - start });
}
- // Default: hybrid search with generation
- queries.push("Hybrid: SQL filter + vector semantic search + LLM summary");
- const searchR = await api("POST", "/vectors/hybrid", {
- question: q, index_name: "workers_500k_v1", sql_filter: "CAST(reliability AS DOUBLE) >= 0.5",
- filter_dataset: "ethereal_workers", id_column: "worker_id", top_k: 5, generate: true,
- });
- return ok({ type: "search", summary: searchR.answer || `Found ${(searchR.sources||[]).length} matching workers`,
- results: (searchR.sources||[]).map((s:any) => ({ doc_id: s.doc_id, score: s.score, text: s.chunk_text })),
- sql_matches: searchR.sql_matches, queries_run: queries, duration_ms: Date.now() - start });
+ // Default: smart search — extract role, location, availability from natural language
+ {
+ const filters: string[] = ["CAST(reliability AS DOUBLE) >= 0.5"];
+ const understood: string[] = [];
+
+ // Extract role keywords
+ const roleKeywords: Record = {
+ "warehouse": "warehouse", "forklift": "forklift", "welder": "weld", "assembler": "assembl",
+ "loader": "loader", "machine operator": "machine operator", "shipping": "shipping",
+ "quality": "quality", "maintenance": "maintenance", "production": "production",
+ "material handler": "material handler", "sanitation": "sanitation", "inventory": "inventory",
+ "line lead": "line lead", "electrician": "electric", "packaging": "packaging",
+ "tool and die": "tool", "logistics": "logistics", "safety": "safety", "cnc": "cnc",
+ };
+ for (const [kw, sqlPart] of Object.entries(roleKeywords)) {
+ if (lower.includes(kw)) { filters.push(`LOWER(role) LIKE '%${sqlPart}%'`); understood.push(`role: ${kw}`); break; }
+ }
+
+ // Extract city
+ const cities = ["chicago","springfield","rockford","peoria","joliet","indianapolis","fort wayne",
+ "evansville","south bend","columbus","cleveland","cincinnati","dayton","akron","toledo",
+ "st. louis","st louis","kansas city","nashville","memphis","knoxville","louisville","lexington",
+ "milwaukee","madison","detroit","grand rapids","lansing","des moines","minneapolis","terre haute",
+ "bloomington","decatur","mattoon","galesburg","danville","champaign"];
+ for (const city of cities) {
+ if (lower.includes(city)) {
+ const sqlCity = city.split(' ').map(w => w[0].toUpperCase() + w.slice(1)).join(' ');
+ filters.push(`city = '${sqlCity}'`);
+ understood.push(`city: ${sqlCity}`);
+ break;
+ }
+ }
+
+ // Extract state
+ const stateNames: Record = {
+ "illinois":"IL","indiana":"IN","ohio":"OH","missouri":"MO","tennessee":"TN",
+ "kentucky":"KY","wisconsin":"WI","michigan":"MI","iowa":"IA","minnesota":"MN"
+ };
+ const stateMatch = lower.match(/\b(IL|IN|OH|MO|TN|KY|WI|MI|IA|MN)\b/i);
+ if (stateMatch && !understood.some(u => u.startsWith('city'))) {
+ filters.push(`state = '${stateMatch[1].toUpperCase()}'`);
+ understood.push(`state: ${stateMatch[1].toUpperCase()}`);
+ } else {
+ for (const [name, abbr] of Object.entries(stateNames)) {
+ if (lower.includes(name)) { filters.push(`state = '${abbr}'`); understood.push(`state: ${abbr}`); break; }
+ }
+ }
+
+ // Extract availability
+ if (/available|open|ready|today|now|immediate|asap|right away/i.test(lower)) {
+ filters.push("CAST(availability AS DOUBLE) > 0.5");
+ understood.push("available now");
+ }
+
+ // Extract reliability preference
+ if (/reliable|dependable|best|top|trusted|proven/i.test(lower)) {
+ filters[0] = "CAST(reliability AS DOUBLE) >= 0.8";
+ understood.push("high reliability");
+ }
+
+ const filterStr = filters.join(" AND ");
+ queries.push("Smart parse: " + (understood.length ? understood.join(", ") : "general search"));
+ queries.push("SQL filter: " + filterStr);
+ queries.push("Vector: semantic search for best skill match");
+
+ // Also run a direct SQL query to get exact counts and zip codes
+ const sqlFields = "name, role, city, state, zip, ROUND(CAST(reliability AS DOUBLE),2) rel, ROUND(CAST(availability AS DOUBLE),2) avail, skills, certifications, archetype";
+ const directSql = `SELECT ${sqlFields} FROM workers_500k WHERE ${filterStr} ORDER BY CAST(availability AS DOUBLE) DESC, CAST(reliability AS DOUBLE) DESC LIMIT 10`;
+
+ const [searchR, directR] = await Promise.all([
+ api("POST", "/vectors/hybrid", {
+ question: q, index_name: "workers_500k_v1", sql_filter: filterStr,
+ filter_dataset: "ethereal_workers", id_column: "worker_id", top_k: 8, generate: false,
+ }),
+ api("POST", "/query/sql", { sql: directSql }),
+ ]);
+
+ // Merge: use SQL results for structured data (zip, avail), vector for ranking
+ const sqlWorkers = directR.rows || [];
+ const vectorWorkers = (searchR.sources || []).map((s: any) => ({ doc_id: s.doc_id, score: s.score, text: s.chunk_text }));
+
+ return ok({
+ type: "smart_search",
+ summary: `Found ${searchR.sql_matches || 0} workers matching your criteria${understood.length ? ' (' + understood.join(', ') + ')' : ''}`,
+ understood,
+ sql_results: sqlWorkers,
+ vector_results: vectorWorkers,
+ sql_matches: searchR.sql_matches,
+ queries_run: queries,
+ duration_ms: Date.now() - start,
+ });
+ }
}
activeTrace = null;