jesusjavierdediego

package grpc

import (
    gomock "github.com/golang/mock/gomock"
    "golang.org/x/net/context"
    "time"
    "testing"
    . "github.com/smartystreets/goconvey/convey"
    utils "me/project/utils"
    mock "me/project/grpc/grpcmock"

jesusjavierdediego

package grpcmock

import (
    "google.golang.org/grpc"
    gomock "github.com/golang/mock/gomock"
    context "golang.org/x/net/context"
    pb "me/project/protobuf"
)

type MockDigitalIdentityServiceClient struct {

jesusjavierdediego

version: v1beta1
lint:
  use:
    - DEFAULT
    - FILE_LOWER_SNAKE_CASE
    - COMMENTS
  except:
    - ENUM_NO_ALLOW_ALIAS
    - IMPORT_NO_PUBLIC
    - PACKAGE_AFFINITY

jesusjavierdediego

syntax = "proto3";

package idrproto;

option go_package = "protobuf";
option optimize_for = SPEED;

message IDR {
    ID user_id = 1;

jesusjavierdediego

public KafkaProducer<String, String> getBatchProducer() {
        Properties properties = new Properties();
        properties.setProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
        properties.setProperty(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
        properties.setProperty(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());

        //safe producer
        properties.setProperty(ProducerConfig.ENABLE_IDEMPOTENCE_CONFIG, "true");
        properties.setProperty(ProducerConfig.ACKS_CONFIG, "all");
        properties.setProperty(ProducerConfig.RETRIES_CONFIG, String.valueOf(Integer.MAX_VALUE));

jesusjavierdediego

def validateAdESSignatures(businessId: String, filePath: String, packInfoOpt: Option[(String, Pack)]): (DocumentValidationResponse, Int) = {
    import eu.europa.esig.dss.validation._
    import eu.europa.esig.dss.validation.reports.Reports
    val file: File = new File(filePath)
    val document: DSSDocument = new FileDocument(file)
    val pdfValidator: PDFDocumentValidator = new PDFDocumentValidator(document)
    val errors: ArrayBuffer[String] = ArrayBuffer.empty[String]

    if (pdfValidator.isSupported(document)) {
      val certificateVerifier: CommonCertificateVerifier = new CommonCertificateVerifier()

jesusjavierdediego

message DSR {
    string correlationid = 1;
    int64 requestTime = 2;
    string authtoken = 3;
    SignatureRequest  SignatureRequest = 4;
    DocumentReference document = 5;
    OperationalContext  context = 6;
}

// *

jesusjavierdediego

import java.io.File
import java.time.Instant
import java.sql.Timestamp
import java.util._
import java.security.KeyStore.PasswordProtection
import java.security.spec.DSAParameterSpec
import java.math.BigInteger
import org.slf4j.LoggerFactory
import eu.europa.esig.dss.enumerations._
import eu.europa.esig.dss.validation.CommonCertificateVerifier

jesusjavierdediego

def mergePurgeAndMakeListWithoutDuplictes(listOfFoundDuplicates: DataFrame, personList: Dataset[Person]): DataFrame ={
    import spark.implicits._
    import scala.collection.mutable.ArrayBuffer
    implicit val anyEncoder = org.apache.spark.sql.Encoders.kryo[Any]
    var unifiedListOfPersons = ArrayBuffer.empty[Person]
    val multipleDuplicates = listOfFoundDuplicates.filter($"num" > 1)
    val noDuplicates = listOfFoundDuplicates.filter($"num" === 1)
    multipleDuplicates.map(row => {
      try{
        unifiedListOfPersons += mergeDuplicatesForAGivenPerson(row.getAs[String]("id"), row.getAs[Set[String]]("duplicates"), personList)

jesusjavierdediego

class ModelComposer extends Logging{
  val operationType = "create"

  @throws(classOf[ModelComposerException])
  def getAllDFs(persons: DataFrame, sourceData: DataFrame): Map[String, DataFrame] = {
    import spark.implicits._
    import com.datastax.driver.core.utils.UUIDs
    implicit val anyEncoder = org.apache.spark.sql.Encoders.kryo[Any]

    var result: scala.collection.mutable.Map[String, DataFrame] = scala.collection.mutable.Map.empty[String, DataFrame]