@@ -180,6 +231,23 @@ export function Step2CV() {
Please provide your CV content before continuing
)}
+
+ {/* Save as Default Checkbox */}
+ {cvText?.trim() && (
+
+ setSaveAsDefault(checked === true)}
+ />
+
+ Save as my default CV for future interviews
+
+
+ )}
@@ -169,15 +179,15 @@ export function InterviewPlaceholder({ accessToken, configId }: InterviewPlaceho
- {Array.from({ length: 6 }).map((_, i) => (
+ {backgroundElements.map((el, i) => (
{
+ if (
+ status.value === "connected" &&
+ !sessionSettingsSentRef.current &&
+ sessionSettings?.systemPrompt
+ ) {
+ sessionSettingsSentRef.current = true;
+ logger.info("Sending session settings over WebSocket");
+ sendSessionSettings({
+ systemPrompt: sessionSettings.systemPrompt,
+ ...(sessionSettings.context && { context: sessionSettings.context }),
+ });
+ }
+ }, [status.value, sessionSettings, sendSessionSettings]);
useEffect(() => {
// Reset flag if navigating to a different interview
@@ -68,6 +85,7 @@ function InterviewVoiceConnector({
);
hasGlobalConnectionAttempt = false;
lastConnectionInterviewId = interviewId;
+ sessionSettingsSentRef.current = false;
}
// Only attempt connection once globally (survives strict mode remounts for same interview)
@@ -89,29 +107,34 @@ function InterviewVoiceConnector({
// Mark that we've attempted connection globally
hasGlobalConnectionAttempt = true;
- // Connect with auth configuration
- const humeSessionSettings = {
- type: "session_settings" as const,
- systemPrompt: sessionSettings.systemPrompt,
- ...(sessionSettings.context && { context: sessionSettings.context }),
- };
-
- connect({
- auth: authConfig,
- configId,
- sessionSettings: humeSessionSettings,
- }).catch((error) => {
- logger.error({ error }, "Connection failed");
-
- // Notify state machine of connection error
- interviewStateMachine.send({
- type: "CONNECTION_ERROR",
- error: error instanceof Error ? error.message : "Connection failed",
+ // Delay connection slightly to survive React Strict Mode double-mount.
+ // Without this, the first mount starts a WebSocket that gets canceled by
+ // cleanup, and the second mount sees hasGlobalConnectionAttempt=true and skips.
+ const connectTimer = setTimeout(() => {
+ // Connect WITHOUT sessionSettings to avoid URL length limits.
+ // Session settings are sent as a WebSocket message after connection opens.
+ connect({
+ auth: authConfig,
+ configId,
+ }).catch((error) => {
+ logger.error({ error }, "Connection failed");
+
+ // Notify state machine of connection error
+ interviewStateMachine.send({
+ type: "CONNECTION_ERROR",
+ error: error instanceof Error ? error.message : "Connection failed",
+ });
+
+ // Reset so we can retry on error
+ hasGlobalConnectionAttempt = false;
});
+ }, 100);
- // Reset so we can retry on error
+ return () => {
+ clearTimeout(connectTimer);
+ // If canceled before connect fires, allow retry
hasGlobalConnectionAttempt = false;
- });
+ };
}, [connect, authConfig, configId, sessionSettings, status, interviewStateMachine, interviewId]);
return <>{children};
diff --git a/src/components/interview/interview-controller.tsx b/src/components/interview/interview-controller.tsx
index 7dda5202..7c5eb784 100644
--- a/src/components/interview/interview-controller.tsx
+++ b/src/components/interview/interview-controller.tsx
@@ -130,12 +130,17 @@ export const InterviewController = React.memo(function InterviewController({
},
});
- // Expose forceSave to parent for AI disconnect handling
+ // Expose forceSave to parent via ref to avoid re-render loop
+ // (forceSave changes every time messages change, which would cause
+ // parent setState → re-render → children re-render → new forceSave → loop)
+ const forceSaveRef = useRef(forceSave);
+ forceSaveRef.current = forceSave;
+
React.useEffect(() => {
- if (onForceSaveReady && forceSave) {
- onForceSaveReady(forceSave);
+ if (onForceSaveReady) {
+ onForceSaveReady(() => forceSaveRef.current());
}
- }, [onForceSaveReady, forceSave]);
+ }, [onForceSaveReady]);
// End of interview mutation
const { mutate: endInterview } = useMutation({
diff --git a/src/hooks/useExtractText.ts b/src/hooks/useExtractText.ts
index d51ec82d..d4a2743d 100644
--- a/src/hooks/useExtractText.ts
+++ b/src/hooks/useExtractText.ts
@@ -17,8 +17,48 @@ interface ExtractUrlResponse {
};
}
+interface AsyncExtractionResponse {
+ data: {
+ extractionId: string;
+ };
+}
+
+interface ExtractionStreamResult {
+ status: "pending" | "completed" | "error";
+ extractedText?: string;
+ fileName?: string;
+ fileType?: string;
+ url?: string;
+ characterCount?: number;
+ error?: string;
+}
+
+async function pollExtractionStream(extractionId: string): Promise {
+ return new Promise((resolve, reject) => {
+ const eventSource = new EventSource(`/api/extractions/${extractionId}/stream`);
+
+ eventSource.onmessage = (event) => {
+ const data: ExtractionStreamResult = JSON.parse(event.data);
+
+ if (data.status === "completed") {
+ eventSource.close();
+ resolve(data);
+ } else if (data.status === "error") {
+ eventSource.close();
+ reject(new Error(data.error || "Extraction failed"));
+ }
+ };
+
+ eventSource.onerror = () => {
+ eventSource.close();
+ reject(new Error("Connection to extraction stream failed"));
+ };
+ });
+}
+
/**
* Hook to extract text from a file (PDF, Word, or images)
+ * Handles both cached (immediate) and async (Inngest) responses
*/
export function useExtractFile() {
return useMutation({
@@ -33,13 +73,32 @@ export function useExtractFile() {
throw new Error(errorData.error?.message || "Failed to extract text from file");
}
- return response.json();
+ const json = await response.json();
+
+ // Cached result returned directly (200)
+ if (response.status === 200) {
+ return json;
+ }
+
+ // Async extraction (202) — poll for result via SSE
+ const extractionId = (json as AsyncExtractionResponse).data.extractionId;
+ const streamResult = await pollExtractionStream(extractionId);
+
+ return {
+ data: {
+ extractedText: streamResult.extractedText ?? "",
+ fileName: streamResult.fileName ?? "",
+ fileType: streamResult.fileType ?? "",
+ characterCount: streamResult.characterCount ?? 0,
+ },
+ };
},
});
}
/**
* Hook to extract text from a URL
+ * Now dispatches to Inngest and polls for result
*/
export function useExtractUrl() {
return useMutation({
@@ -57,7 +116,23 @@ export function useExtractUrl() {
throw new Error(errorData.error?.message || "Failed to extract text from URL");
}
- return response.json();
+ const json = await response.json();
+
+ // Async extraction (202) — poll for result via SSE
+ if (response.status === 202) {
+ const extractionId = (json as AsyncExtractionResponse).data.extractionId;
+ const streamResult = await pollExtractionStream(extractionId);
+
+ return {
+ data: {
+ extractedText: streamResult.extractedText ?? "",
+ url: streamResult.url ?? url,
+ characterCount: streamResult.characterCount ?? 0,
+ },
+ };
+ }
+
+ return json;
},
});
}
diff --git a/src/stores/createJobStore.ts b/src/stores/createJobStore.ts
index 51b56e31..85babf9f 100644
--- a/src/stores/createJobStore.ts
+++ b/src/stores/createJobStore.ts
@@ -21,6 +21,8 @@ interface CreateJobState {
isOutOfMinutesDialogOpen: boolean;
isScheduleErrorDialogOpen: boolean;
errorMessage?: string;
+ saveAsDefault: boolean;
+ cvFilename: string | null;
}
interface CreateJobActions {
@@ -35,6 +37,8 @@ interface CreateJobActions {
setIsOutOfMinutesDialogOpen: (isOpen: boolean) => void;
setIsScheduleErrorDialogOpen: (isOpen: boolean) => void;
setErrorMessage: (message?: string) => void;
+ setSaveAsDefault: (save: boolean) => void;
+ setCvFilename: (filename: string | null) => void;
resetStore: () => void;
}
@@ -50,6 +54,8 @@ const initialState: CreateJobState = {
isOutOfMinutesDialogOpen: false,
isScheduleErrorDialogOpen: false,
errorMessage: undefined,
+ saveAsDefault: false,
+ cvFilename: null,
};
export const useCreateJobStore = create(
@@ -69,6 +75,8 @@ export const useCreateJobStore = create(
setIsScheduleErrorDialogOpen: (isScheduleErrorDialogOpen: boolean) =>
set({ isScheduleErrorDialogOpen }),
setErrorMessage: (errorMessage?: string) => set({ errorMessage }),
+ setSaveAsDefault: (saveAsDefault: boolean) => set({ saveAsDefault }),
+ setCvFilename: (cvFilename: string | null) => set({ cvFilename }),
resetStore: () => set(initialState),
},
}))
@@ -89,4 +97,6 @@ export const useCreateJobIsOutOfMinutesDialogOpen = () =>
export const useCreateJobIsScheduleErrorDialogOpen = () =>
useCreateJobStore((state) => state.isScheduleErrorDialogOpen);
export const useCreateJobErrorMessage = () => useCreateJobStore((state) => state.errorMessage);
+export const useCreateJobSaveAsDefault = () => useCreateJobStore((state) => state.saveAsDefault);
+export const useCreateJobCvFilename = () => useCreateJobStore((state) => state.cvFilename);
export const useCreateJobActions = () => useCreateJobStore((state) => state.actions);
diff --git a/terraform/s3.tf b/terraform/s3.tf
index d0fac4ab..5a764995 100644
--- a/terraform/s3.tf
+++ b/terraform/s3.tf
@@ -35,23 +35,21 @@ resource "aws_s3_bucket_lifecycle_configuration" "audio_recordings_lifecycle" {
bucket = aws_s3_bucket.audio_recordings.id
rule {
- id = "transition-to-standard-ia"
+ id = "expire-recordings"
status = "Enabled"
- transition {
- days = 30
- storage_class = "STANDARD_IA"
+ # Delete recordings after 30 days to control bucket growth
+ expiration {
+ days = 30
}
- # Transition old versions to Glacier after 60 days
- transition {
- days = 60
- storage_class = "GLACIER"
+ # Clean up old versions and incomplete uploads
+ noncurrent_version_expiration {
+ noncurrent_days = 7
}
- # Expire old versions after 365 days
- expiration {
- days = 365
+ abort_incomplete_multipart_upload {
+ days_after_initiation = 1
}
}
}