@Test public void testEmptyMetadataLocation() throws Exception { ValueProvider<String> metadataLocation = pipeline.newProvider(null); ValueProvider<Boolean> kmsEnabled = pipeline.newProvider(false); ValueProvider<Boolean> decompressPayload = pipeline.newProvider(true); pipeline.apply(Create.of(readTestFiles(Arrays.asList("pioneer/study-foo.ciphertext.json")))) .apply(InputFileFormat.text.decode()) .apply(DecryptPioneerPayloads.of(metadataLocation, kmsEnabled, decompressPayload)); assertEquals(assertThrows(IllegalArgumentException.class, () -> { try { pipeline.run(); } catch (Exception e) { throw Throwables.getRootCause(e); } }).getMessage(), "Metadata location is missing."); }
public static DecryptPioneerPayloads of(ValueProvider<String> metadataLocation, ValueProvider<Boolean> kmsEnabled, ValueProvider<Boolean> decompressPayload) { return new DecryptPioneerPayloads(metadataLocation, kmsEnabled, decompressPayload); }
DecryptPioneerPayloads extends
    PTransform<PCollection<PubsubMessage>, Result<PCollection<PubsubMessage>, PubsubMessage>> { public static DecryptPioneerPayloads of(ValueProvider<String> metadataLocation, ValueProvider<Boolean> kmsEnabled, ValueProvider<Boolean> decompressPayload) { return new DecryptPioneerPayloads(metadataLocation, kmsEnabled, decompressPayload); } }
DecryptPioneerPayloads extends
    PTransform<PCollection<PubsubMessage>, Result<PCollection<PubsubMessage>, PubsubMessage>> { public static DecryptPioneerPayloads of(ValueProvider<String> metadataLocation, ValueProvider<Boolean> kmsEnabled, ValueProvider<Boolean> decompressPayload) { return new DecryptPioneerPayloads(metadataLocation, kmsEnabled, decompressPayload); } private  DecryptPioneerPayloads(ValueProvider<String> metadataLocation,
      ValueProvider<Boolean> kmsEnabled, ValueProvider<Boolean> decompressPayload); }
DecryptPioneerPayloads extends
    PTransform<PCollection<PubsubMessage>, Result<PCollection<PubsubMessage>, PubsubMessage>> { public static DecryptPioneerPayloads of(ValueProvider<String> metadataLocation, ValueProvider<Boolean> kmsEnabled, ValueProvider<Boolean> decompressPayload) { return new DecryptPioneerPayloads(metadataLocation, kmsEnabled, decompressPayload); } private  DecryptPioneerPayloads(ValueProvider<String> metadataLocation,
      ValueProvider<Boolean> kmsEnabled, ValueProvider<Boolean> decompressPayload); static DecryptPioneerPayloads of(ValueProvider<String> metadataLocation,
      ValueProvider<Boolean> kmsEnabled, ValueProvider<Boolean> decompressPayload); @Override Result<PCollection<PubsubMessage>, PubsubMessage> expand(
      PCollection<PubsubMessage> messages); static byte[] decrypt(PrivateKey key, String payload); }
DecryptPioneerPayloads extends
    PTransform<PCollection<PubsubMessage>, Result<PCollection<PubsubMessage>, PubsubMessage>> { public static DecryptPioneerPayloads of(ValueProvider<String> metadataLocation, ValueProvider<Boolean> kmsEnabled, ValueProvider<Boolean> decompressPayload) { return new DecryptPioneerPayloads(metadataLocation, kmsEnabled, decompressPayload); } private  DecryptPioneerPayloads(ValueProvider<String> metadataLocation,
      ValueProvider<Boolean> kmsEnabled, ValueProvider<Boolean> decompressPayload); static DecryptPioneerPayloads of(ValueProvider<String> metadataLocation,
      ValueProvider<Boolean> kmsEnabled, ValueProvider<Boolean> decompressPayload); @Override Result<PCollection<PubsubMessage>, PubsubMessage> expand(
      PCollection<PubsubMessage> messages); static byte[] decrypt(PrivateKey key, String payload); static final String ENCRYPTED_DATA; static final String ENCRYPTION_KEY_ID; static final String SCHEMA_NAMESPACE; static final String SCHEMA_NAME; static final String SCHEMA_VERSION; static final String PIONEER_ID; static final String STUDY_NAME; static final String DELETION_REQUEST_SCHEMA_NAME; static final String ENROLLMENT_SCHEMA_NAME; }