prisma-schemas,duck-estimator: Fix mapping

Author: bperel

apps/duck-estimator/coa.ts

@@ -1,11 +1,11 @@
 import "dotenv/config";
 
-import type { inducks_issuequotation } from "~prisma-schemas/schemas/coa";
+import type { inducks_issuequotation_raw } from "~prisma-schemas/schemas/coa";
 import { prismaClient as prismaCoa } from "~prisma-schemas/schemas/coa/client";
 
 export const createQuotations = async (
   data: Omit<
-    inducks_issuequotation,
+    inducks_issuequotation_raw,
     "id" | "publicationcode" | "issuenumber"
   >[],
 ) => {
@@ -93,7 +93,7 @@ export const getInducksIssuecodesBetween = async (
 };
 
 export const getAll = async () =>
-  await prismaCoa.inducks_issuequotation.findMany({
+  await prismaCoa.inducks_issuequotation_raw.findMany({
     orderBy: [
       {
         issuecode: "asc",

apps/duck-estimator/csv.ts

@@ -2,7 +2,7 @@ import { parse } from "csv-parse";
 import { createObjectCsvWriter as createCsvWriter } from "csv-writer";
 import { createReadStream } from "fs";
 
-import type { inducks_issuequotation } from "~prisma-schemas/schemas/coa";
+import type { inducks_issuequotation_raw } from "~prisma-schemas/schemas/coa";
 
 export const readCsvMapping = async <CsvIssue>(
   mappingFile: string,
@@ -17,7 +17,7 @@ export const readCsvMapping = async <CsvIssue>(
     recordCallback(record);
   }
 };
-export const writeCsvMapping = async (data: inducks_issuequotation[]) => {
+export const writeCsvMapping = async (data: inducks_issuequotation_raw[]) => {
   const csvWriter = createCsvWriter({
     path: "dump.csv",
     header: [

packages/prisma-schemas/schemas/coa/schema.prisma

@@ -272,36 +272,33 @@ model inducks_issueprice {
 }
 
 model inducks_issuequotation_raw {
-  ID              Int       @id @default(autoincrement())
+  id              Int       @id @default(autoincrement()) @map("ID")
   /// @deprecated
   publicationcode String?   @db.VarChar(15)
   /// @deprecated
   issuenumber     String?   @db.VarChar(12)
-  estimationmin   Float?    @db.Float
-  estimationmax   Float?    @db.Float
-  scrapedate      DateTime? @db.DateTime(0)
+  estimationMin   Float?    @map("estimationmin") @db.Float
+  estimationMax   Float?    @map("estimationmax") @db.Float
+  scrapeDate      DateTime? @map("scrapedate") @db.DateTime(0)
   source          String?   @db.VarChar(15)
-  issuecode       String?   @db.VarChar(28)
+  issuecode       String    @db.VarChar(28)
 
   @@index([publicationcode], map: "inducks_issuequotation_raw__index_publication")
   @@index([issuecode, source], map: "inducks_issuequotation_raw__uindex_issuecode_source")
 }
 
 model inducks_issuequotation {
-  id              Int       @id @default(autoincrement()) @map("ID")
+  id              Int     @id @default(autoincrement()) @map("ID")
   /// @deprecated
-  publicationcode String?   @db.VarChar(15)
+  publicationcode String? @db.VarChar(15)
   /// @deprecated
-  issuenumber     String?   @db.VarChar(12)
-  estimationMin   Float?    @map("estimationmin") @db.Float
-  estimationMax   Float?    @map("estimationmax") @db.Float
-  scrapeDate      DateTime? @map("scrapedate") @db.DateTime(0)
-  source          String    @db.VarChar(15)
-  issuecode       String    @unique(map: "inducks_issuequotation__uindex_issuecode") @map("issuecode") @db.VarChar(28)
+  issuenumber     String? @db.VarChar(12)
+  estimationMin   Float?  @map("estimationmin") @db.Float
+  estimationMax   Float?  @map("estimationmax") @db.Float
+  issuecode       String  @unique(map: "inducks_issuequotation__uindex_issuecode") @db.VarChar(28)
 
   /// @deprecated
   @@index([publicationcode], map: "inducks_issuequotation__index_publication")
-  @@index([issuecode, source], map: "inducks_issuequotation__uindex_issuecode_source")
 }
 
 model inducks_issuerange {