k4rli/medreport_mrb2b
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(MED-161): move medipost publicmessage logic to separate service

Browse Source
This commit is contained in:
Karli
2025-09-17 11:15:16 +03:00
parent 19631fb2db
commit 0d08592a9a
3 changed files with 34 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
app/api/job/handler/sync-analysis-groups.ts
View File

@@ -7,7 +7,7 @@ import { createAnalysis, createNoDataReceivedEntry, createNoNewDataReceivedEntry
import { getLastCheckedDate } from '~/lib/services/sync-entries.service'; import { getLastCheckedDate } from '~/lib/services/sync-entries.service';
import { createAnalysisElement } from '~/lib/services/analysis-element.service'; import { createAnalysisElement } from '~/lib/services/analysis-element.service';
import { createCodes } from '~/lib/services/codes.service'; import { createCodes } from '~/lib/services/codes.service';
import { getLatestPublicMessageListItem } from '~/lib/services/medipost.service'; import { getLatestPublicMessageListItem } from '~/lib/services/medipost/medipostPublicMessage.service';
import type { ICode } from '~/lib/types/code'; import type { ICode } from '~/lib/types/code';
function toArray<T>(input?: T | T[] | null): T[] { function toArray<T>(input?: T | T[] | null): T[] {

31
lib/services/medipost.service.ts
View File

@@ -1,45 +1,14 @@
'use server'; 'use server';
import {
GetMessageListResponse,
MedipostAction,
} from '@/lib/types/medipost';
import axios from 'axios';
import { getAnalysisElements } from './analysis-element.service'; import { getAnalysisElements } from './analysis-element.service';
import { getAnalyses } from './analyses.service'; import { getAnalyses } from './analyses.service';
import { StoreOrder } from '@medusajs/types'; import { StoreOrder } from '@medusajs/types';
import { listProducts } from '@lib/data/products'; import { listProducts } from '@lib/data/products';
import { listRegions } from '@lib/data/regions'; import { listRegions } from '@lib/data/regions';
import { getAnalysisElementMedusaProductIds } from '@/utils/medusa-product'; import { getAnalysisElementMedusaProductIds } from '@/utils/medusa-product';
import { getLatestMessage } from './medipost/medipostMessageBase.service';
const BASE_URL = process.env.MEDIPOST_URL!;
const USER = process.env.MEDIPOST_USER!;
const PASSWORD = process.env.MEDIPOST_PASSWORD!;
const RECIPIENT = process.env.MEDIPOST_RECIPIENT!;
const ANALYSIS_PACKAGE_HANDLE_PREFIX = 'analysis-package-'; const ANALYSIS_PACKAGE_HANDLE_PREFIX = 'analysis-package-';
export async function getLatestPublicMessageListItem() {
const { data } = await axios.get<GetMessageListResponse>(BASE_URL, {
params: {
Action: MedipostAction.GetPublicMessageList,
User: USER,
Password: PASSWORD,
Sender: RECIPIENT,
// LastChecked (date+time) can be used here to get only messages since the last check - add when cron is created
// MessageType check only for messages of certain type
},
});
if (data.code && data.code !== 0) {
throw new Error('Failed to get public message list');
}
return getLatestMessage({ messages: data?.messages });
}
export async function getOrderedAnalysisIds({ export async function getOrderedAnalysisIds({
medusaOrder, medusaOrder,
}: { }: {

33
lib/services/medipost/medipostPublicMessage.service.ts Normal file
View File

@@ -0,0 +1,33 @@
'use server';
import {
GetMessageListResponse,
MedipostAction,
} from '@/lib/types/medipost';
import axios from 'axios';
import { getLatestMessage } from './medipostMessageBase.service';
const BASE_URL = process.env.MEDIPOST_URL!;
const USER = process.env.MEDIPOST_USER!;
const PASSWORD = process.env.MEDIPOST_PASSWORD!;
const RECIPIENT = process.env.MEDIPOST_RECIPIENT!;
export async function getLatestPublicMessageListItem() {
const { data } = await axios.get<GetMessageListResponse>(BASE_URL, {
params: {
Action: MedipostAction.GetPublicMessageList,
User: USER,
Password: PASSWORD,
Sender: RECIPIENT,
// LastChecked (date+time) can be used here to get only messages since the last check - add when cron is created
// MessageType check only for messages of certain type
},
});
if (data.code && data.code !== 0) {
throw new Error('Failed to get public message list');
}
return getLatestMessage({ messages: data?.messages });
}