ATL-7040: Delete DID based authentication

This commit deletes the legacy DID based authentication

Author: EzequielPostan

node/src/main/protobuf/common_models.proto

@@ -5,7 +5,6 @@ option java_package = "io.iohk.atala.prism.protos";
 
 package io.iohk.atala.prism.protos;
 
-import "status.proto";
 import "google/protobuf/timestamp.proto";
 
 /**
@@ -68,17 +67,3 @@ enum OperationStatus {
     CONFIRMED_AND_APPLIED = 3; // The operation has been successfully applied to the PRISM.
     CONFIRMED_AND_REJECTED = 4; // The operation has been processed by PRISM, but rejected because of some error.
 }
-
-message AtalaErrorMessage {
-    google.rpc.Status status = 1;
-}
-
-message AtalaMessage {
-    oneof message {
-        AtalaErrorMessage atala_error_message = 9;
-    }
-}
-
-message ConnectionsStatusRequest {
-  repeated string connection_tokens = 1;
-}

node/src/main/protobuf/node_api.proto

@@ -72,70 +72,6 @@ service NodeService {
     rpc ScheduleOperations(ScheduleOperationsRequest) returns (ScheduleOperationsResponse) {}
 }
 
-service NodeExplorerService {
-    /**
-     * WHITELISTED_DID
-     *
-     * Return a list of scheduled but unconfirmed operations.
-     */
-    rpc GetScheduledOperations(GetScheduledOperationsRequest) returns (GetScheduledOperationsResponse) {}
-
-    /**
-     * WHITELISTED_DID
-     *
-     * Return a list of wallet transactions.
-     */
-    rpc GetWalletTransactionsPaginated(GetWalletTransactionsRequest) returns (GetWalletTransactionsResponse) {}
-
-    /**
-    * WHITELISTED_DID
-    *
-    * Return the Node Wallet Balance
-    */
-    rpc GetWalletBalance(GetWalletBalanceRequest) returns (GetWalletBalanceResponse) {}
-
-    /**
-     * WHITELISTED_DID
-     *
-     * Retrieves list of available metrics.
-     */
-    rpc GetAvailableMetrics(GetAvailableMetricsRequest) returns (GetAvailableMetricsResponse) {}
-
-    /**
-     * WHITELISTED_DID
-     *
-     * Get statistics
-    */
-    rpc GetNodeStatistics(GetNodeStatisticsRequest) returns (GetNodeStatisticsResponse) {}
-}
-
-/**
- * Retrieve statistics from the Node.
- */
-message GetNodeStatisticsRequest {
-  repeated string metrics = 1;
-}
-
-/**
- * Statistics from the Node.
- */
-message GetNodeStatisticsResponse {
-  repeated double metrics = 1;
-}
-
-/**
- * Request to find metrics exposed by Node.
- * See NodeService.GetAvailableMetrics for more information.
- */
-message GetAvailableMetricsRequest {}
-
-/**
- * Response with a list of metrics exposed by Node.
- * See NodeService.GetAvailableMetrics for more information.
- */
-message GetAvailableMetricsResponse {
-  repeated string metrics = 1;
-}
 
 /**
  * Request to find a DID Document.
@@ -242,51 +178,7 @@ message ScheduleOperationsResponse {
     repeated OperationOutput outputs = 1;
 }
 
-/**
- * Request to retrieve all scheduled but not confirmed Atala operations.
- */
-message GetScheduledOperationsRequest {
-    /**
-     * Operations of which type should be returned.
-     */
-    OperationType operationsType = 1;
 
-    enum OperationType {
-        AnyOperationType = 0; // Any operation
-        CreateDidOperationOperationType = 1;
-        UpdateDidOperationOperationType = 2;
-        ProtocolVersionUpdateOperationType = 5;
-    }
-}
-
-message GetScheduledOperationsResponse {
-    repeated SignedAtalaOperation scheduled_operations = 1; // a list of scheduled operations
-}
-
-/**
- * Request to retrieve wallet transactions, either ongoing or confirmed.
- * Pagination included.
- */
-message GetWalletTransactionsRequest {
-    TransactionState state = 1; // Transaction state: either ongoing or confirmed
-    string last_seen_transaction_id = 2; // Last seen transaction id
-    int32 limit = 3; // The maximum number of transactions to return; must be greater than 0.
-
-    enum TransactionState {
-        Ongoing = 0; // Transactions which hasn't been confirmed by Prism Node
-        Confirmed = 1; // Transactions which ahs been confirmed by Prism Node
-    }
-}
-
-message GetWalletTransactionsResponse {
-    repeated TransactionInfo transactions = 1;
-}
-
-message GetWalletBalanceRequest {
-}
-message GetWalletBalanceResponse {
-    bytes balance = 1;
-}
 
 // Used to encode the responses of the operations issued in an AtalaBlock.
 message OperationOutput {

node/src/main/protobuf/status.proto

@@ -68,13 +68,6 @@ didIdCharLenLimit = ${?NODE_ID_CHAR_LIMIT}
 trustedProposerSuffix = "7476322b05901e9ebfb1ffa2bdfcfc819549f757474f0278ca4bb9d182a553db"
 trustedProposerSuffix = ${?TRUSTED_PROPOSER_SUFFIX}
 
-nodeExplorer {
-  whitelistDids = [
-    "did:prism:106c458b95e57e16cbbd4b9566a52446c39949fdbd8cd8f876230ff243cf7b5a:Cj8KPRI7CgdtYXN0ZXIwEAFKLgoJc2VjcDI1NmsxEiEDVw1B_oShVvJ11AlVhLYv7OBO9sY9AOz8D5FoWoqI14c"
-  ]
-  whitelistDids += ${?NODE_EXPLORER_WHITELIST_DID}
-}
-
 # CardanoLedgerService
 cardano {
   # Network connecting to, options: testnet, mainnet

node/src/main/resources/application.conf

@@ -96,15 +96,6 @@ CREATE TABLE public.did_data
 );
 
 
-CREATE TABLE public.did_request_nonces
-(
-    request_nonce BYTEA      NOT NULL,
-    did           public.did NOT NULL,
-    CONSTRAINT did_request_nonces_pk PRIMARY KEY (request_nonce,
-                                                  did)
-);
-
-
 CREATE TABLE public.key_values
 (
     "key" varchar(64) NOT NULL,

node/src/main/resources/db/migration/V1__create_tables.sql

@@ -6,10 +6,6 @@ import cats.implicits.toFunctorOps
 import com.typesafe.config.{Config, ConfigFactory}
 import doobie.hikari.HikariTransactor
 import io.grpc.{Server, ServerBuilder}
-import io.iohk.atala.prism.node.auth.WhitelistedAuthenticatorF
-import io.iohk.atala.prism.node.auth.grpc.{GrpcAuthenticatorInterceptor, TraceExposeInterceptor, TraceReadInterceptor}
-import io.iohk.atala.prism.node.auth.utils.DidWhitelistLoader
-import io.iohk.atala.prism.node.identity.PrismDid
 import io.iohk.atala.prism.node.logging.TraceId
 import io.iohk.atala.prism.node.logging.TraceId.IOWithTraceIdContext
 import io.iohk.atala.prism.node.metrics.UptimeReporter
@@ -52,7 +48,6 @@ class NodeApp(executionContext: ExecutionContext) { self =>
   private def start(): Resource[IO, (SubmissionSchedulingService, Server)] = {
     for {
       globalConfig <- loadConfig()
-      nodeExplorerDids = loadNodeExplorerDids(globalConfig)
       _ <- startMetrics(globalConfig)
       databaseConfig = TransactorFactory.transactorConfig(globalConfig)
       _ = applyDatabaseMigrations(databaseConfig)
@@ -125,24 +120,13 @@ class NodeApp(executionContext: ExecutionContext) { self =>
         ),
         submissionService
       )
-      metricsCountersRepository <- MetricsCountersRepository.resource(liftedTransactor, logs)
       nodeService <- NodeService.resource(
         didDataRepository,
         objectManagementService,
         logs
       )
-      nodeStatisticsService <- StatisticsService.resource(atalaOperationsRepository, metricsCountersRepository, logs)
-      nodeExplorerService <- NodeExplorerService.resource(ledger, objectManagementService, logs)
-      requestNoncesRepo <- RequestNoncesRepository.resource(liftedTransactor, logs)
-      authenticator <- WhitelistedAuthenticatorF.resource(new NodeExplorerAuthenticator(requestNoncesRepo), logs)
-      nodeExplorerGrpcService = new NodeExplorerGrpcServiceImpl(
-        authenticator,
-        nodeExplorerService,
-        nodeStatisticsService,
-        nodeExplorerDids
-      )
       nodeGrpcService = new NodeGrpcServiceImpl(nodeService)
-      server <- startServer(nodeGrpcService, nodeExplorerGrpcService)
+      server <- startServer(nodeGrpcService)
     } yield (submissionSchedulingService, server)
   }
 
@@ -157,21 +141,6 @@ class NodeApp(executionContext: ExecutionContext) { self =>
     ConfigFactory.load()
   }
 
-  private def loadNodeExplorerDids(config: Config): Set[PrismDid] = {
-    logger.info("Loading DID whitelist")
-    val didWhitelist = DidWhitelistLoader.load(config, "nodeExplorer")
-    if (didWhitelist.isEmpty) {
-      logger.warn(
-        s"DID whitelist is empty, which makes explorer methods inaccessible"
-      )
-    } else {
-      logger.info(
-        s"DID whitelist:\n${didWhitelist.map(_.value).map("- " + _).mkString("\n")}"
-      )
-    }
-    didWhitelist
-  }
-
   private def initializeCardano(
       keyValueService: KeyValueService[IOWithTraceIdContext],
       globalConfig: Config,
@@ -247,19 +216,14 @@ class NodeApp(executionContext: ExecutionContext) { self =>
     }
 
   private def startServer(
-      nodeService: NodeGrpcServiceImpl,
-      nodeExplorerService: NodeExplorerGrpcServiceImpl
+      nodeService: NodeGrpcServiceImpl
   ): Resource[IO, Server] =
     Resource.make[IO, Server](IO {
       logger.info("Starting server")
       import io.grpc.protobuf.services.ProtoReflectionService
       val server = ServerBuilder
         .forPort(NodeApp.port)
-        .intercept(new TraceExposeInterceptor)
-        .intercept(new TraceReadInterceptor)
-        .intercept(new GrpcAuthenticatorInterceptor)
         .addService(NodeServiceGrpc.bindService(nodeService, executionContext))
-        .addService(NodeExplorerServiceGrpc.bindService(nodeExplorerService, executionContext))
         .addService(
           _root_.grpc.health.v1.health.HealthGrpc
             .bindService(new HealthService, executionContext)