feat: add notion of primary and secondary for source gateway

refs: #365

# Conflicts:
#    api/src/core/usecases/importFromSource.ts

Author: guillermau

api/src/core/adapters/comptoirDuLibre/index.ts

@@ -1,10 +1,11 @@
 import { getCDLSoftwareOptions } from "./getCDLSoftwareOptions";
 import { getCDLSoftwareExternalData } from "./getCDLExternalData";
 import { getCDLFormData } from "./getCDLFormData";
-import { SourceGateway } from "../../ports/SourceGateway";
+import { PrimarySourceGateway } from "../../ports/SourceGateway";
 
-export const comptoirDuLibreSourceGateway: SourceGateway = {
+export const comptoirDuLibreSourceGateway: PrimarySourceGateway = {
     sourceType: "ComptoirDuLibre",
+    sourceProfile: "Primary",
     softwareExternalData: {
         getById: getCDLSoftwareExternalData
     },

api/src/core/adapters/hal/index.ts

@@ -1,10 +1,11 @@
 import { getHalSoftwareOptions } from "./getHalSoftwareOptions";
 import { getHalSoftwareExternalData } from "./getHalSoftwareExternalData";
 import { getHalSoftwareForm } from "./getSoftwareForm";
-import { SourceGateway } from "../../ports/SourceGateway";
+import { PrimarySourceGateway } from "../../ports/SourceGateway";
 
-export const halSourceGateway: SourceGateway = {
+export const halSourceGateway: PrimarySourceGateway = {
     sourceType: "HAL",
+    sourceProfile: "Primary",
     softwareExternalData: {
         getById: getHalSoftwareExternalData
     },

api/src/core/adapters/resolveAdapter.ts

@@ -1,10 +1,12 @@
-import { SourceGateway } from "../ports/SourceGateway";
+import { PrimarySourceGateway, SecondarySourceGateway } from "../ports/SourceGateway";
 import { DatabaseDataType } from "../ports/DbApiV2";
 import { halSourceGateway } from "./hal";
 import { wikidataSourceGateway } from "./wikidata";
 import { comptoirDuLibreSourceGateway } from "./comptoirDuLibre";
 
-export const resolveAdapterFromSource = (source: DatabaseDataType.SourceRow): SourceGateway => {
+export const resolveAdapterFromSource = (
+    source: DatabaseDataType.SourceRow
+): PrimarySourceGateway | SecondarySourceGateway => {
     switch (source.kind) {
         case "HAL":
             return halSourceGateway;

api/src/core/adapters/wikidata/index.ts

@@ -1,10 +1,11 @@
-import { SourceGateway } from "../../ports/SourceGateway";
+import { PrimarySourceGateway } from "../../ports/SourceGateway";
 import { getWikidataForm } from "./getSoftwareForm";
 import { getWikidataSoftware } from "./getWikidataSoftware";
 import { getWikidataSoftwareOptions } from "./getWikidataSoftwareOptions";
 
-export const wikidataSourceGateway: SourceGateway = {
+export const wikidataSourceGateway: PrimarySourceGateway = {
     sourceType: "wikidata",
+    sourceProfile: "Primary",
     softwareExternalData: {
         getById: getWikidataSoftware
     },

api/src/core/ports/SourceGateway.ts

@@ -5,6 +5,7 @@ import { GetSoftwareFormData } from "./GetSoftwareFormData";
 
 export type SourceGateway = {
     sourceType: ExternalDataOriginKind;
+    sourceProfile: "Primary" | "Secondary";
     softwareExternalData: {
         getById: GetSoftwareExternalData;
     };
@@ -15,3 +16,11 @@ export type SourceGateway = {
         getById: GetSoftwareFormData;
     };
 };
+
+export type PrimarySourceGateway = SourceGateway & {
+    sourceProfile: "Primary";
+};
+
+export type SecondarySourceGateway = Pick<SourceGateway, "sourceType" | "sourceProfile" | "softwareExternalData"> & {
+    sourceProfile: "Secondary";
+};

api/src/core/usecases/importFromSource.ts

@@ -13,6 +13,11 @@ export type ImportFromSource = (params: {
 
 export const importFromSource: (dbApi: DbApiV2) => ImportFromSource = (dbApi: DbApiV2) => {
     return async ({ agentEmail, source, softwareIdOnSource }) => {
+        const sourceGateway = resolveAdapterFromSource(source);
+
+        if (sourceGateway.sourceProfile !== "Primary")
+            throw new Error("Import if not possbile from a secondary source");
+
         const agent = await dbApi.agent.getByEmail(agentEmail);
         const agentId = agent
             ? agent.id
@@ -23,7 +28,7 @@ export const importFromSource: (dbApi: DbApiV2) => ImportFromSource = (dbApi: Db
                   about: "This is a bot user created to import data."
               });
 
-        const getSoftwareForm = resolveAdapterFromSource(source).softwareForm.getById;
+        const getSoftwareForm = sourceGateway.softwareForm.getById;
         let result = [];
 
         switch (source.kind) {

api/src/rpc/router.ts

@@ -102,6 +102,9 @@ export function createRouter(params: {
                 const mainSource = await dbApi.source.getMainSource();
                 const sourceGateway = resolveAdapterFromSource(mainSource);
 
+                if (sourceGateway.sourceProfile !== "Primary")
+                    throw new Error("Getting option if not possbile from a secondary source");
+
                 const [queryResults, softwareExternalDataIds] = await Promise.all([
                     sourceGateway.softwareOptions.getById({ queryString, language, source: mainSource }),
                     dbApi.software.getAllSillSoftwareExternalIds(mainSource.slug)
@@ -481,21 +484,21 @@ export function createRouter(params: {
 
                     // prettier-ignore
                     languages
-            .map(lang => createResolveLocalizedString({
-              "currentLanguage": lang,
-              "fallbackLanguage": "en"
-            }))
-            .map(({resolveLocalizedString}) => [termsOfServiceUrl].map(resolveLocalizedString))
-            .flat()
-            .forEach(async function callee(url) {
+                        .map(lang => createResolveLocalizedString({
+                            "currentLanguage": lang,
+                            "fallbackLanguage": "en"
+                        }))
+                        .map(({ resolveLocalizedString }) => [termsOfServiceUrl].map(resolveLocalizedString))
+                        .flat()
+                        .forEach(async function callee(url) {
 
-              memoizedFetch(url);
+                            memoizedFetch(url);
 
-              await new Promise(resolve => setTimeout(resolve, maxAge - 10_000));
+                            await new Promise(resolve => setTimeout(resolve, maxAge - 10_000));
 
-              callee(url);
+                            callee(url);
 
-            });
+                        });
 
                     return async ({ input }) => {
                         const { language, name } = input;