MED-198: send notification if new responses
MED-198: send notification if new responses
This commit is contained in:
@@ -1,3 +1,6 @@
|
||||
import { createUserAnalysesApi } from '@/packages/features/user-analyses/src/server/api';
|
||||
import { getSupabaseServerClient } from '@/packages/supabase/src/clients/server-client';
|
||||
|
||||
import { readPrivateMessageResponse } from '~/lib/services/medipost/medipostPrivateMessage.service';
|
||||
|
||||
type ProcessedMessage = {
|
||||
@@ -16,6 +19,8 @@ type GroupedResults = {
|
||||
|
||||
export default async function syncAnalysisResults() {
|
||||
console.info('Syncing analysis results');
|
||||
const supabase = getSupabaseServerClient();
|
||||
const api = createUserAnalysesApi(supabase);
|
||||
|
||||
const processedMessages: ProcessedMessage[] = [];
|
||||
const excludedMessageIds: string[] = [];
|
||||
@@ -25,6 +30,12 @@ export default async function syncAnalysisResults() {
|
||||
processedMessages.push(result as ProcessedMessage);
|
||||
}
|
||||
|
||||
await api.sendAnalysisResultsNotification({
|
||||
hasFullAnalysisResponse: result.hasFullAnalysisResponse,
|
||||
hasPartialAnalysisResponse: result.hasAnalysisResponse,
|
||||
analysisOrderId: result.analysisOrderId,
|
||||
});
|
||||
|
||||
if (!result.messageId) {
|
||||
console.info('No more messages to process');
|
||||
break;
|
||||
|
||||
Reference in New Issue
Block a user