Restructure library

.gitignore

@@ -4,4 +4,6 @@
 .dart_tool/
 .packages
 build/
-pubspec.lock
+pubspec.lock
+
+cloudevents

CHANGELOG.md

@@ -1,3 +1,10 @@
+## 0.0.2
+
+> Note: This release has breaking changes.
+
+- Reworked package structure
+- Added example for using the package in a server application
+
 ## 0.0.1+2
 
 Some additional clean like fixing analyzer warnings and adding supported platforms

README.md

@@ -18,6 +18,10 @@ dependencies:
 
 Then, run `pub get` or `flutter pub get` to install the package.
 
+## Usage
+
+For an example of using this package in a server application, see the example in this package.
+
 ## Documentation
 
 For detailed documentation on all features and functionalities, please visit the following documentation.

example/.gitignore

@@ -0,0 +1,16 @@
+# See https://www.dartlang.org/guides/libraries/private-files
+
+# Files and directories created by the Operating System
+.DS_Store
+
+# Files and directories created by pub
+.dart_tool/
+.packages
+pubspec.lock
+
+# Files and directories created by dart_frog
+build/
+.dart_frog
+
+# Test related files
+coverage/

example/.vscode/extensions.json

@@ -0,0 +1,3 @@
+{
+	"recommendations": ["VeryGoodVentures.dart-frog"]
+}

example/README.md

@@ -0,0 +1,12 @@
+# example
+
+[![style: very good analysis][very_good_analysis_badge]][very_good_analysis_link]
+[![License: MIT][license_badge]][license_link]
+[![Powered by Dart Frog](https://img.shields.io/endpoint?url=https://tinyurl.com/dartfrog-badge)](https://dartfrog.vgv.dev)
+
+An example application built with dart_frog
+
+[license_badge]: https://img.shields.io/badge/license-MIT-blue.svg
+[license_link]: https://opensource.org/licenses/MIT
+[very_good_analysis_badge]: https://img.shields.io/badge/style-very_good_analysis-B22C89.svg
+[very_good_analysis_link]: https://pub.dev/packages/very_good_analysis

example/analysis_options.yaml

@@ -0,0 +1,7 @@
+include: package:very_good_analysis/analysis_options.5.1.0.yaml
+analyzer:
+  exclude:
+    - build/**
+linter:
+  rules:
+    file_names: false

example/pubspec.yaml

@@ -0,0 +1,19 @@
+name: example
+description: An new Dart Frog application
+version: 1.0.0+1
+publish_to: none
+
+environment:
+  sdk: ">=3.0.0 <4.0.0"
+
+dependencies:
+  dart_frog: ^1.0.0
+  fixnum: ^1.1.0
+  google_cloudevents_dart:
+    path: ../
+  http: ^1.2.1
+
+dev_dependencies:
+  mocktail: ^1.0.0
+  test: ^1.19.2
+  very_good_analysis: ^5.1.0

example/routes/index.dart

@@ -0,0 +1,19 @@
+import 'package:dart_frog/dart_frog.dart';
+import 'package:google_cloudevents_dart/events/cloud/firestore/v1.dart';
+import 'package:http/http.dart' as http;
+
+Future<Response> onRequest(RequestContext context) async {
+  try {
+    final byteStream = http.ByteStream(context.request.bytes());
+    final requestBody = await byteStream.toBytes();
+
+    final event = DocumentEventData.fromBuffer(requestBody);
+
+    return Response.json(body: {'documentId': event.value.name});
+  } catch (e) {
+    return Response.json(
+      body: {'error': e.toString()},
+      statusCode: 500,
+    );
+  }
+}

example/test/routes/index_test.dart

@@ -0,0 +1,51 @@
+import 'package:dart_frog/dart_frog.dart';
+import 'package:fixnum/fixnum.dart';
+import 'package:google_cloudevents_dart/events/cloud/firestore/v1.dart';
+import 'package:google_cloudevents_dart/protobuf.dart' show Timestamp;
+import 'package:mocktail/mocktail.dart';
+import 'package:test/test.dart';
+
+import '../../routes/index.dart' as route;
+
+class _MockRequestContext extends Mock implements RequestContext {}
+
+class _MockRequest extends Mock implements Request {}
+
+void main() {
+  const documentId =
+      'projects/testproject/databases/(default)/documents/test/cn8OibPL0GXFkN67oL2d';
+
+  final event = DocumentEventData(
+    value: Document(
+      name: documentId,
+      fields: {'name': Value(stringValue: 'jonah')},
+      createTime: Timestamp(seconds: Int64(1631441406)),
+    ),
+  );
+  final eventBuffer = event.writeToBuffer();
+
+  late _MockRequestContext context;
+  late _MockRequest request;
+
+  setUp(() {
+    context = _MockRequestContext();
+    request = _MockRequest();
+    when(() => context.request).thenReturn(request);
+  });
+
+  test('handles valid CloudEvents', () async {
+    when(request.bytes).thenAnswer((_) => Stream.value(eventBuffer));
+
+    final response = await route.onRequest(context);
+
+    expect(response.statusCode, equals(200));
+    expect(await response.body(), equals('{"documentId":"$documentId"}'));
+  });
+
+  test('handles invalid CloudEvent', () async {
+    final response = await route.onRequest(context);
+
+    expect(response.statusCode, equals(500));
+    expect(await response.body(), matches('{"error":".+"}'));
+  });
+}

lib/api.dart

@@ -0,0 +1 @@
+export 'src/api/monitored_resource.pb.dart' show MonitoredResource;

lib/events.dart

@@ -0,0 +1 @@
+export 'src/events/cloudevent.pb.dart' show ExtensionAttribute, Cloudevent;

lib/events/cloud/alloydb/v1.dart

@@ -0,0 +1,3 @@
+export '../../../src/events/cloud/alloydb/v1/data.pbenum.dart' show DatabaseVersion, MigrationSource_MigrationSourceType, EncryptionInfo_Type, SslConfig_SslMode, SslConfig_CaSource, Cluster_State, Cluster_ClusterType, Instance_State, Instance_InstanceType, Instance_AvailabilityType, Backup_State, Backup_Type;
+export '../../../src/events/cloud/alloydb/v1/data.pb.dart' show UserPassword, MigrationSource, EncryptionConfig, EncryptionInfo, SslConfig, AutomatedBackupPolicy_WeeklySchedule, AutomatedBackupPolicy_TimeBasedRetention, AutomatedBackupPolicy_QuantityBasedRetention, AutomatedBackupPolicy, BackupSource, Cluster_SecondaryConfig, Cluster_PrimaryConfig, Cluster, Instance_MachineConfig, Instance_Node, Instance_QueryInsightsInstanceConfig, Instance_ReadPoolConfig, Instance, Backup, InstanceEventData, BackupEventData, ClusterEventData;
+export '../../../src/events/cloud/alloydb/v1/events.pb.dart' show ClusterCreatedEvent, ClusterUpdatedEvent, ClusterDeletedEvent, InstanceCreatedEvent, InstanceUpdatedEvent, InstanceDeletedEvent, BackupCreatedEvent, BackupUpdatedEvent, BackupDeletedEvent;

lib/events/cloud/apigateway/v1.dart

@@ -0,0 +1,3 @@
+export '../../../src/events/cloud/apigateway/v1/data.pbenum.dart' show Api_State, ApiConfig_State, Gateway_State;
+export '../../../src/events/cloud/apigateway/v1/data.pb.dart' show Api, ApiConfig_File, ApiConfig_OpenApiDocument, ApiConfig_GrpcServiceDefinition, ApiConfig, Gateway, GatewayEventData, ApiConfigEventData, ApiEventData;
+export '../../../src/events/cloud/apigateway/v1/events.pb.dart' show GatewayCreatedEvent, GatewayUpdatedEvent, GatewayDeletedEvent, ApiCreatedEvent, ApiUpdatedEvent, ApiDeletedEvent, ApiConfigCreatedEvent, ApiConfigUpdatedEvent, ApiConfigDeletedEvent;

lib/events/cloud/apigeeregistry/v1.dart

@@ -0,0 +1,3 @@
+export '../../../src/events/cloud/apigeeregistry/v1/data.pbenum.dart' show Instance_State;
+export '../../../src/events/cloud/apigeeregistry/v1/data.pb.dart' show Instance_Config, Instance, Api, ApiVersion, ApiSpec, ApiDeployment, ApiVersionEventData, InstanceEventData, ApiSpecEventData, ApiDeploymentEventData, ApiEventData;
+export '../../../src/events/cloud/apigeeregistry/v1/events.pb.dart' show InstanceCreatedEvent, InstanceDeletedEvent, ApiCreatedEvent, ApiUpdatedEvent, ApiDeletedEvent, ApiVersionCreatedEvent, ApiVersionUpdatedEvent, ApiVersionDeletedEvent, ApiSpecCreatedEvent, ApiSpecUpdatedEvent, ApiSpecDeletedEvent, ApiDeploymentCreatedEvent, ApiDeploymentUpdatedEvent, ApiDeploymentDeletedEvent;

lib/events/cloud/audit/v1.dart

@@ -0,0 +1,3 @@
+export '../../../src/events/cloud/audit/v1/data.pbenum.dart' show LogSeverity;
+export '../../../src/events/cloud/audit/v1/data.pb.dart' show LogEntryData, LogEntryOperation, AuditLog, AuthenticationInfo, AuthorizationInfo, RequestMetadata, ResourceLocation, ServiceAccountDelegationInfo_FirstPartyPrincipal, ServiceAccountDelegationInfo_ThirdPartyPrincipal, ServiceAccountDelegationInfo, LogSplit;
+export '../../../src/events/cloud/audit/v1/events.pb.dart' show AuditLogWrittenEvent;

lib/events/cloud/batch/v1.dart

@@ -0,0 +1,3 @@
+export '../../../src/events/cloud/batch/v1/data.pbenum.dart' show TaskStatus_State, LifecyclePolicy_Action, LogsPolicy_Destination, JobStatus_State, JobNotification_Type, AllocationPolicy_ProvisioningModel, TaskGroup_SchedulingPolicy;
+export '../../../src/events/cloud/batch/v1/data.pb.dart' show Volume, NFS, GCS, ComputeResource, StatusEvent, TaskExecution, TaskStatus, Runnable_Container, Runnable_Script, Runnable_Barrier, Runnable, TaskSpec, LifecyclePolicy_ActionCondition, LifecyclePolicy, Environment_KMSEnvMap, Environment, Job, LogsPolicy, JobStatus_InstanceStatus, JobStatus_TaskGroupStatus, JobStatus, JobNotification_Message, JobNotification, AllocationPolicy_LocationPolicy, AllocationPolicy_Disk, AllocationPolicy_AttachedDisk, AllocationPolicy_Accelerator, AllocationPolicy_InstancePolicy, AllocationPolicy_InstancePolicyOrTemplate, AllocationPolicy_NetworkInterface, AllocationPolicy_NetworkPolicy, AllocationPolicy_PlacementPolicy, AllocationPolicy, TaskGroup, ServiceAccount, JobEventData;
+export '../../../src/events/cloud/batch/v1/events.pb.dart' show JobCreatedEvent, JobDeletedEvent;

lib/events/cloud/beyondcorp/appconnections/v1.dart

@@ -0,0 +1,3 @@
+export '../../../../src/events/cloud/beyondcorp/appconnections/v1/data.pbenum.dart' show AppConnection_Type, AppConnection_State, AppConnection_Gateway_Type;
+export '../../../../src/events/cloud/beyondcorp/appconnections/v1/data.pb.dart' show AppConnection_ApplicationEndpoint, AppConnection_Gateway, AppConnection, AppConnectionEventData;
+export '../../../../src/events/cloud/beyondcorp/appconnections/v1/events.pb.dart' show AppConnectionCreatedEvent, AppConnectionUpdatedEvent, AppConnectionDeletedEvent;

lib/events/cloud/beyondcorp/appconnectors/v1.dart

@@ -0,0 +1,3 @@
+export '../../../../src/events/cloud/beyondcorp/appconnectors/v1/data.pbenum.dart' show HealthStatus, AppConnector_State;
+export '../../../../src/events/cloud/beyondcorp/appconnectors/v1/data.pb.dart' show ResourceInfo, AppConnector_PrincipalInfo_ServiceAccount, AppConnector_PrincipalInfo, AppConnector, AppConnectorEventData;
+export '../../../../src/events/cloud/beyondcorp/appconnectors/v1/events.pb.dart' show AppConnectorCreatedEvent, AppConnectorUpdatedEvent, AppConnectorDeletedEvent;

lib/events/cloud/beyondcorp/appgateways/v1.dart

@@ -0,0 +1,3 @@
+export '../../../../src/events/cloud/beyondcorp/appgateways/v1/data.pbenum.dart' show AppGateway_Type, AppGateway_State, AppGateway_HostType;
+export '../../../../src/events/cloud/beyondcorp/appgateways/v1/data.pb.dart' show AppGateway_AllocatedConnection, AppGateway, AppGatewayEventData;
+export '../../../../src/events/cloud/beyondcorp/appgateways/v1/events.pb.dart' show AppGatewayCreatedEvent, AppGatewayDeletedEvent;

lib/events/cloud/beyondcorp/clientconnectorservices/v1.dart

@@ -0,0 +1,3 @@
+export '../../../../src/events/cloud/beyondcorp/clientconnectorservices/v1/data.pbenum.dart' show ClientConnectorService_State, ClientConnectorService_Ingress_Config_TransportProtocol;
+export '../../../../src/events/cloud/beyondcorp/clientconnectorservices/v1/data.pb.dart' show ClientConnectorService_Ingress_Config_DestinationRoute, ClientConnectorService_Ingress_Config, ClientConnectorService_Ingress, ClientConnectorService_Egress_PeeredVpc, ClientConnectorService_Egress, ClientConnectorService, ClientConnectorServiceEventData;
+export '../../../../src/events/cloud/beyondcorp/clientconnectorservices/v1/events.pb.dart' show ClientConnectorServiceCreatedEvent, ClientConnectorServiceUpdatedEvent, ClientConnectorServiceDeletedEvent;

lib/events/cloud/beyondcorp/clientgateways/v1.dart

@@ -0,0 +1,3 @@
+export '../../../../src/events/cloud/beyondcorp/clientgateways/v1/data.pbenum.dart' show ClientGateway_State;
+export '../../../../src/events/cloud/beyondcorp/clientgateways/v1/data.pb.dart' show ClientGateway, ClientGatewayEventData;
+export '../../../../src/events/cloud/beyondcorp/clientgateways/v1/events.pb.dart' show ClientGatewayCreatedEvent, ClientGatewayDeletedEvent;

lib/events/cloud/certificatemanager/v1.dart

@@ -0,0 +1,3 @@
+export '../../../src/events/cloud/certificatemanager/v1/data.pbenum.dart' show ServingState, CertificateIssuanceConfig_KeyAlgorithm, Certificate_Scope, Certificate_ManagedCertificate_State, Certificate_ManagedCertificate_ProvisioningIssue_Reason, Certificate_ManagedCertificate_AuthorizationAttemptInfo_State, Certificate_ManagedCertificate_AuthorizationAttemptInfo_FailureReason, CertificateMapEntry_Matcher;
+export '../../../src/events/cloud/certificatemanager/v1/data.pb.dart' show CertificateIssuanceConfig_CertificateAuthorityConfig_CertificateAuthorityServiceConfig, CertificateIssuanceConfig_CertificateAuthorityConfig, CertificateIssuanceConfig, Certificate_SelfManagedCertificate, Certificate_ManagedCertificate_ProvisioningIssue, Certificate_ManagedCertificate_AuthorizationAttemptInfo, Certificate_ManagedCertificate, Certificate, CertificateMap_GclbTarget_IpConfig, CertificateMap_GclbTarget, CertificateMap, CertificateMapEntry, DnsAuthorization_DnsResourceRecord, DnsAuthorization, DnsAuthorizationEventData, CertificateIssuanceConfigEventData, CertificateMapEntryEventData, CertificateMapEventData, CertificateEventData;
+export '../../../src/events/cloud/certificatemanager/v1/events.pb.dart' show CertificateCreatedEvent, CertificateUpdatedEvent, CertificateDeletedEvent, CertificateMapCreatedEvent, CertificateMapUpdatedEvent, CertificateMapDeletedEvent, CertificateMapEntryCreatedEvent, CertificateMapEntryUpdatedEvent, CertificateMapEntryDeletedEvent, DnsAuthorizationCreatedEvent, DnsAuthorizationUpdatedEvent, DnsAuthorizationDeletedEvent, CertificateIssuanceConfigCreatedEvent, CertificateIssuanceConfigDeletedEvent;

lib/events/cloud/cloudbuild/v1.dart

@@ -0,0 +1,3 @@
+export '../../../src/events/cloud/cloudbuild/v1/data.pbenum.dart' show BuildEventData_Status, Hash_HashType, BuildOptions_VerifyOption, BuildOptions_MachineType, BuildOptions_SubstitutionOption, BuildOptions_LogStreamingOption, BuildOptions_LoggingMode;
+export '../../../src/events/cloud/cloudbuild/v1/data.pb.dart' show BuildEventData, Source, StorageSource, RepoSource, BuildStep, Volume, Results, BuiltImage, Artifacts_ArtifactObjects, Artifacts, TimeSpan, SourceProvenance, FileHashes, Hash, Secret, BuildOptions;
+export '../../../src/events/cloud/cloudbuild/v1/events.pb.dart' show CloudBuildEvent;

lib/events/cloud/clouddms/v1.dart

@@ -0,0 +1,3 @@
+export '../../../src/events/cloud/clouddms/v1/data.pbenum.dart' show NetworkArchitecture, DatabaseEngine, DatabaseProvider, SslConfig_SslType, CloudSqlSettings_SqlActivationPolicy, CloudSqlSettings_SqlDataDiskType, CloudSqlSettings_SqlDatabaseVersion, CloudSqlSettings_SqlAvailabilityType, MigrationJob_State, MigrationJob_Phase, MigrationJob_Type, ConnectionProfile_State;
+export '../../../src/events/cloud/clouddms/v1/data.pb.dart' show SslConfig, MySqlConnectionProfile, PostgreSqlConnectionProfile, CloudSqlConnectionProfile, AlloyDbConnectionProfile, SqlAclEntry, SqlIpConfig, CloudSqlSettings, AlloyDbSettings_UserPassword, AlloyDbSettings_PrimaryInstanceSettings_MachineConfig, AlloyDbSettings_PrimaryInstanceSettings, AlloyDbSettings, StaticIpConnectivity, ReverseSshConnectivity, VpcPeeringConnectivity, DatabaseType, MigrationJob_DumpFlag, MigrationJob_DumpFlags, MigrationJob, ConnectionProfile, ConnectionProfileEventData, MigrationJobEventData;
+export '../../../src/events/cloud/clouddms/v1/events.pb.dart' show MigrationJobCreatedEvent, MigrationJobUpdatedEvent, MigrationJobDeletedEvent, ConnectionProfileCreatedEvent, ConnectionProfileUpdatedEvent, ConnectionProfileDeletedEvent;

lib/events/cloud/dataflow/v1beta3.dart

@@ -0,0 +1,3 @@
+export '../../../src/events/cloud/dataflow/v1beta3/data.pbenum.dart' show JobType, FlexResourceSchedulingGoal, TeardownPolicy, DefaultPackageSet, AutoscalingAlgorithm, WorkerIPAddressConfiguration, ShuffleMode, JobState, SdkVersion_SdkSupportStatus;
+export '../../../src/events/cloud/dataflow/v1beta3/data.pb.dart' show Environment, Package, AutoscalingSettings, SdkHarnessContainerImage, WorkerPool, DebugOptions, Job, DatastoreIODetails, PubSubIODetails, FileIODetails, BigTableIODetails, BigQueryIODetails, SpannerIODetails, SdkVersion, JobMetadata, ExecutionStageState, JobExecutionInfo, JobExecutionStageInfo, JobEventData;
+export '../../../src/events/cloud/dataflow/v1beta3/events.pb.dart' show JobStatusChangedEvent;

lib/events/cloud/datafusion/v1.dart

@@ -0,0 +1,3 @@
+export '../../../src/events/cloud/datafusion/v1/data.pbenum.dart' show Version_Type, Accelerator_AcceleratorType, Accelerator_State, Instance_Type, Instance_State, Instance_DisabledReason;
+export '../../../src/events/cloud/datafusion/v1/data.pb.dart' show NetworkConfig, Version, Accelerator, CryptoKeyConfig, Instance, EventPublishConfig, DnsPeering, InstanceEventData, DnsPeeringEventData;
+export '../../../src/events/cloud/datafusion/v1/events.pb.dart' show InstanceCreatedEvent, InstanceDeletedEvent, InstanceUpdatedEvent, DnsPeeringCreatedEvent, DnsPeeringDeletedEvent;

lib/events/cloud/dataplex/v1.dart

@@ -0,0 +1,3 @@
+export '../../../src/events/cloud/dataplex/v1/data.pbenum.dart' show State, DataScanType, Lake_MetastoreStatus_State, Zone_Type, Zone_ResourceSpec_LocationType, Asset_SecurityStatus_State, Asset_ResourceSpec_Type, Asset_ResourceSpec_AccessMode, Asset_ResourceStatus_State, Asset_DiscoveryStatus_State, DataQualityRule_StatisticRangeExpectation_ColumnStatistic, Task_TriggerSpec_Type, Job_Service, Job_State;
+export '../../../src/events/cloud/dataplex/v1/data.pb.dart' show Lake_Metastore, Lake_MetastoreStatus, Lake, AssetStatus, Zone_ResourceSpec, Zone_DiscoverySpec_CsvOptions, Zone_DiscoverySpec_JsonOptions, Zone_DiscoverySpec, Zone, Asset_SecurityStatus, Asset_DiscoverySpec_CsvOptions, Asset_DiscoverySpec_JsonOptions, Asset_DiscoverySpec, Asset_ResourceSpec, Asset_ResourceStatus, Asset_DiscoveryStatus_Stats, Asset_DiscoveryStatus, Asset, Environment_InfrastructureSpec_ComputeResources, Environment_InfrastructureSpec_OsImageRuntime, Environment_InfrastructureSpec, Environment_SessionSpec, Environment_SessionStatus, Environment_Endpoints, Environment, Trigger_OnDemand, Trigger_Schedule, Trigger, DataSource, ScannedData_IncrementalField, ScannedData, DataProfileSpec, DataProfileResult_Profile_Field_ProfileInfo_StringFieldInfo, DataProfileResult_Profile_Field_ProfileInfo_IntegerFieldInfo, DataProfileResult_Profile_Field_ProfileInfo_DoubleFieldInfo, DataProfileResult_Profile_Field_ProfileInfo_TopNValue, DataProfileResult_Profile_Field_ProfileInfo, DataProfileResult_Profile_Field, DataProfileResult_Profile, DataProfileResult, DataQualitySpec, DataQualityResult, DataQualityRuleResult, DataQualityDimensionResult, DataQualityRule_RangeExpectation, DataQualityRule_NonNullExpectation, DataQualityRule_SetExpectation, DataQualityRule_RegexExpectation, DataQualityRule_UniquenessExpectation, DataQualityRule_StatisticRangeExpectation, DataQualityRule_RowConditionExpectation, DataQualityRule_TableConditionExpectation, DataQualityRule, ResourceAccessSpec, DataAccessSpec, DataTaxonomy, DataAttribute, DataAttributeBinding_Path, DataAttributeBinding, DataScan_ExecutionSpec, DataScan_ExecutionStatus, DataScan, Task_InfrastructureSpec_BatchComputeResources, Task_InfrastructureSpec_ContainerImageRuntime, Task_InfrastructureSpec_VpcNetwork, Task_InfrastructureSpec, Task_TriggerSpec, Task_ExecutionSpec, Task_SparkTaskConfig, Task_NotebookTaskConfig, Task_ExecutionStatus, Task, Job, TaskEventData, ZoneEventData, AssetEventData, EnvironmentEventData, DataTaxonomyEventData, DataAttributeBindingEventData, DataScanEventData, LakeEventData, DataAttributeEventData;
+export '../../../src/events/cloud/dataplex/v1/events.pb.dart' show DataTaxonomyCreatedEvent, DataTaxonomyUpdatedEvent, DataTaxonomyDeletedEvent, DataAttributeBindingCreatedEvent, DataAttributeBindingUpdatedEvent, DataAttributeBindingDeletedEvent, DataAttributeCreatedEvent, DataAttributeUpdatedEvent, DataAttributeDeletedEvent, DataScanCreatedEvent, DataScanUpdatedEvent, DataScanDeletedEvent, LakeCreatedEvent, LakeUpdatedEvent, LakeDeletedEvent, ZoneCreatedEvent, ZoneUpdatedEvent, ZoneDeletedEvent, AssetCreatedEvent, AssetUpdatedEvent, AssetDeletedEvent, TaskCreatedEvent, TaskUpdatedEvent, TaskDeletedEvent, EnvironmentCreatedEvent, EnvironmentUpdatedEvent, EnvironmentDeletedEvent;

lib/events/cloud/datastore/v1.dart

@@ -0,0 +1,3 @@
+export '../../../src/events/cloud/datastore/v1/data.pbenum.dart' show EntityResult_ResultType;
+export '../../../src/events/cloud/datastore/v1/data.pb.dart' show EntityEventData, PropertyMask, EntityResult, PartitionId, Key_PathElement, Key, ArrayValue, Value, Entity;
+export '../../../src/events/cloud/datastore/v1/events.pb.dart' show EntityCreatedEvent, EntityUpdatedEvent, EntityDeletedEvent, EntityWrittenEvent, EntityCreatedEventWithAuthContext, EntityUpdatedEventWithAuthContext, EntityDeletedEventWithAuthContext, EntityWrittenEventWithAuthContext;