97 lines
2.5 KiB
TypeScript
97 lines
2.5 KiB
TypeScript
import { getSupabaseServerAdminClient } from '@kit/supabase/server-admin-client';
|
|
import type { Tables } from '@kit/supabase/database';
|
|
import { getSupabaseServerClient } from '@kit/supabase/server-client';
|
|
import type { StoreOrder } from '@medusajs/types';
|
|
|
|
export type AnalysisOrder = Tables<{ schema: 'medreport' }, 'analysis_orders'>;
|
|
|
|
export async function createOrder({
|
|
medusaOrder,
|
|
orderedAnalysisElements,
|
|
}: {
|
|
medusaOrder: StoreOrder;
|
|
orderedAnalysisElements: { analysisElementId: number }[];
|
|
}) {
|
|
const supabase = getSupabaseServerClient();
|
|
|
|
const { data: { user } } = await supabase.auth.getUser();
|
|
if (!user) {
|
|
throw new Error('User not found');
|
|
}
|
|
const orderResult = await supabase.schema('medreport')
|
|
.from('analysis_orders')
|
|
.insert({
|
|
analysis_element_ids: orderedAnalysisElements.map(({ analysisElementId }) => analysisElementId),
|
|
analysis_ids: [],
|
|
status: 'QUEUED',
|
|
user_id: user.id,
|
|
medusa_order_id: medusaOrder.id,
|
|
})
|
|
.select('id')
|
|
.single()
|
|
.throwOnError();
|
|
|
|
if (orderResult.error || !orderResult.data?.id) {
|
|
throw new Error(`Failed to create order, message=${orderResult.error}, data=${JSON.stringify(orderResult)}`);
|
|
}
|
|
|
|
return orderResult.data.id;
|
|
}
|
|
|
|
export async function updateOrder({
|
|
orderId,
|
|
orderStatus,
|
|
}: {
|
|
orderId: number;
|
|
orderStatus: Tables<{ schema: 'medreport' }, 'analysis_orders'>['status'];
|
|
}) {
|
|
console.info(`Updating order id=${orderId} status=${orderStatus}`);
|
|
await getSupabaseServerAdminClient()
|
|
.schema('medreport')
|
|
.from('analysis_orders')
|
|
.update({
|
|
status: orderStatus,
|
|
})
|
|
.eq('id', orderId)
|
|
.throwOnError();
|
|
}
|
|
|
|
export async function getOrder({
|
|
medusaOrderId,
|
|
orderId,
|
|
}: {
|
|
medusaOrderId?: string;
|
|
orderId?: number;
|
|
}) {
|
|
const query = getSupabaseServerAdminClient()
|
|
.schema('medreport')
|
|
.from('analysis_orders')
|
|
.select('*')
|
|
if (medusaOrderId) {
|
|
query.eq('medusa_order_id', medusaOrderId);
|
|
} else if (orderId) {
|
|
query.eq('id', orderId);
|
|
} else {
|
|
throw new Error('Either medusaOrderId or orderId must be provided');
|
|
}
|
|
|
|
const { data: order } = await query.single().throwOnError();
|
|
return order;
|
|
}
|
|
|
|
export async function getAnalysisOrders({
|
|
orderStatus,
|
|
}: {
|
|
orderStatus?: Tables<{ schema: 'medreport' }, 'analysis_orders'>['status'];
|
|
} = {}) {
|
|
const query = getSupabaseServerClient()
|
|
.schema('medreport')
|
|
.from('analysis_orders')
|
|
.select('*')
|
|
if (orderStatus) {
|
|
query.eq('status', orderStatus);
|
|
}
|
|
const orders = await query.throwOnError();
|
|
return orders.data;
|
|
}
|