Tidying and extra comments

proofcarryingdata · Jul 19, 2024 · bac5e9d · bac5e9d
1 parent ab16480
commit bac5e9d
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 21 deletions.
diff --git a/...ic-issuance-client/src/pages/pipeline/PipelineEditSection/PODPipeline/PODSheetPreview.tsx b/...ic-issuance-client/src/pages/pipeline/PipelineEditSection/PODPipeline/PODSheetPreview.tsx
@@ -170,22 +170,6 @@ function ColumnIndicator({
           <MenuList>
             <MenuInput value={columnNames[column]} />
             <MenuDivider />
-            {/* <MenuGroup title="Data Type">
-              <MenuItem icon={<Icon as={MdShortText} w={4} h={4} />}>
-                Text
-              </MenuItem>
-              <MenuItem icon={<Icon as={MdNumbers} w={4} h={4} />}>
-                Integer
-              </MenuItem>
-              <MenuItem icon={<Icon as={MdCheckCircleOutline} w={4} h={4} />}>
-                Boolean
-              </MenuItem>
-              <MenuItem icon={<Icon as={MdDateRange} w={4} h={4} />}>
-                Date
-              </MenuItem>
-              <MenuItem icon={<Icon as={MdKey} w={4} h={4} />}>UUID</MenuItem>
-            </MenuGroup>
-            <MenuDivider /> */}
             <MenuItem
               icon={<Icon as={MdDeleteOutline} w={4} h={4} />}
               onClick={() => onDelete(columnNames[column])}

diff --git a/apps/passport-server/src/services/generic-issuance/pipelines/PODPipeline/PODPipeline.ts b/apps/passport-server/src/services/generic-issuance/pipelines/PODPipeline/PODPipeline.ts
@@ -25,11 +25,9 @@ import {
   PipelineAtom
 } from "../../../../database/queries/pipelineAtomDB";
 import { IPipelineConsumerDB } from "../../../../database/queries/pipelineConsumerDB";
-import { IPipelineSemaphoreHistoryDB } from "../../../../database/queries/pipelineSemaphoreHistoryDB";
 import { logger } from "../../../../util/logger";
 import { PersistentCacheService } from "../../../persistentCacheService";
 import { setError, traced } from "../../../telemetryService";
-import { SemaphoreGroupProvider } from "../../SemaphoreGroupProvider";
 import {
   FeedIssuanceCapability,
   makeGenericIssuanceFeedUrl
@@ -65,7 +63,6 @@ export class PODPipeline implements BasePipeline {
   private db: IPipelineAtomDB<PODAtom>;
   private definition: PODPipelineDefinition;
   private credentialSubservice: CredentialSubservice;
-  private semaphoreGroupProvider?: SemaphoreGroupProvider;
   private consumerDB: IPipelineConsumerDB;
   private cacheService: PersistentCacheService;
 
@@ -83,7 +80,6 @@ export class PODPipeline implements BasePipeline {
     db: IPipelineAtomDB,
     credentialSubservice: CredentialSubservice,
     consumerDB: IPipelineConsumerDB,
-    _semaphoreHistoryDB: IPipelineSemaphoreHistoryDB,
     cacheService: PersistentCacheService
   ) {
     this.eddsaPrivateKey = eddsaPrivateKey;
@@ -140,6 +136,12 @@ export class PODPipeline implements BasePipeline {
           this.definition.id
         );
 
+        // @todo because this code is async, it may end up being interleaved
+        // with issuance requests at run-time. This may result in code
+        // requesting PCDs that - temporarily - do not exist because the atom
+        // DB has not been repopulated.
+        // A long-term solution might involve locking the pipeline or the DB,
+        // or refactoring so that this scenario cannot arise.
         await this.db.clear(this.definition.id);
         logs.push(makePLogInfo(`cleared old data`));
         await this.db.save(this.definition.id, atoms);

diff --git a/apps/passport-server/src/services/generic-issuance/subservices/utils/instantiatePipeline.ts b/apps/passport-server/src/services/generic-issuance/subservices/utils/instantiatePipeline.ts
@@ -118,7 +118,6 @@ export function instantiatePipeline(
         args.pipelineAtomDB,
         args.credentialSubservice,
         args.consumerDB,
-        args.semaphoreHistoryDB,
         args.cacheService
       );
     }