viamrobotics · njooma · Nov 14, 2023 · Nov 10, 2023
@@ -936,6 +936,231 @@ class TabularData extends $pb.GeneratedMessage {
   $2.Timestamp ensureTimeReceived() => $_ensure(3);
 }
 
+/// TabularDataBySQLRequest requests tabular data using a SQL query.
+class TabularDataBySQLRequest extends $pb.GeneratedMessage {
+  factory TabularDataBySQLRequest({
+    $core.String? organizationId,
+    $core.String? sqlQuery,
+  }) {
+    final $result = create();
+    if (organizationId != null) {
+      $result.organizationId = organizationId;
+    }
+    if (sqlQuery != null) {
+      $result.sqlQuery = sqlQuery;
+    }
+    return $result;
+  }
+  TabularDataBySQLRequest._() : super();
+  factory TabularDataBySQLRequest.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory TabularDataBySQLRequest.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'TabularDataBySQLRequest', package: const $pb.PackageName(_omitMessageNames ? '' : 'viam.app.data.v1'), createEmptyInstance: create)
+    ..aOS(1, _omitFieldNames ? '' : 'organizationId')
+    ..aOS(2, _omitFieldNames ? '' : 'sqlQuery')
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  TabularDataBySQLRequest clone() => TabularDataBySQLRequest()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  TabularDataBySQLRequest copyWith(void Function(TabularDataBySQLRequest) updates) => super.copyWith((message) => updates(message as TabularDataBySQLRequest)) as TabularDataBySQLRequest;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static TabularDataBySQLRequest create() => TabularDataBySQLRequest._();
+  TabularDataBySQLRequest createEmptyInstance() => create();
+  static $pb.PbList<TabularDataBySQLRequest> createRepeated() => $pb.PbList<TabularDataBySQLRequest>();
+  @$core.pragma('dart2js:noInline')
+  static TabularDataBySQLRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<TabularDataBySQLRequest>(create);
+  static TabularDataBySQLRequest? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $core.String get organizationId => $_getSZ(0);
+  @$pb.TagNumber(1)
+  set organizationId($core.String v) { $_setString(0, v); }
+  @$pb.TagNumber(1)
+  $core.bool hasOrganizationId() => $_has(0);
+  @$pb.TagNumber(1)
+  void clearOrganizationId() => clearField(1);
+
+  /// sql_query accepts any valid SQL SELECT statement. Tabular data is held in a database
+  /// called "sensorData" and a table called readings, so queries should select from "readings"
+  /// or "sensorData.readings".
+  @$pb.TagNumber(2)
+  $core.String get sqlQuery => $_getSZ(1);
+  @$pb.TagNumber(2)
+  set sqlQuery($core.String v) { $_setString(1, v); }
+  @$pb.TagNumber(2)
+  $core.bool hasSqlQuery() => $_has(1);
+  @$pb.TagNumber(2)
+  void clearSqlQuery() => clearField(2);
+}
+
+/// TabularDataBySQLResponse provides unified tabular data and metadata, queried with SQL.
+class TabularDataBySQLResponse extends $pb.GeneratedMessage {
+  factory TabularDataBySQLResponse({
+    $core.Iterable<$3.Struct>? data,
+  }) {
+    final $result = create();
+    if (data != null) {
+      $result.data.addAll(data);
+    }
+    return $result;
+  }
+  TabularDataBySQLResponse._() : super();
+  factory TabularDataBySQLResponse.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory TabularDataBySQLResponse.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'TabularDataBySQLResponse', package: const $pb.PackageName(_omitMessageNames ? '' : 'viam.app.data.v1'), createEmptyInstance: create)
+    ..pc<$3.Struct>(1, _omitFieldNames ? '' : 'data', $pb.PbFieldType.PM, subBuilder: $3.Struct.create)
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  TabularDataBySQLResponse clone() => TabularDataBySQLResponse()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  TabularDataBySQLResponse copyWith(void Function(TabularDataBySQLResponse) updates) => super.copyWith((message) => updates(message as TabularDataBySQLResponse)) as TabularDataBySQLResponse;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static TabularDataBySQLResponse create() => TabularDataBySQLResponse._();
+  TabularDataBySQLResponse createEmptyInstance() => create();
+  static $pb.PbList<TabularDataBySQLResponse> createRepeated() => $pb.PbList<TabularDataBySQLResponse>();
+  @$core.pragma('dart2js:noInline')
+  static TabularDataBySQLResponse getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<TabularDataBySQLResponse>(create);
+  static TabularDataBySQLResponse? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $core.List<$3.Struct> get data => $_getList(0);
+}
+
+/// TabularDataByMQLRequest requests tabular data using an MQL query.
+class TabularDataByMQLRequest extends $pb.GeneratedMessage {
+  factory TabularDataByMQLRequest({
+    $core.String? organizationId,
+    $core.String? mqlQuery,
+  }) {
+    final $result = create();
+    if (organizationId != null) {
+      $result.organizationId = organizationId;
+    }
+    if (mqlQuery != null) {
+      $result.mqlQuery = mqlQuery;
+    }
+    return $result;
+  }
+  TabularDataByMQLRequest._() : super();
+  factory TabularDataByMQLRequest.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory TabularDataByMQLRequest.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'TabularDataByMQLRequest', package: const $pb.PackageName(_omitMessageNames ? '' : 'viam.app.data.v1'), createEmptyInstance: create)
+    ..aOS(1, _omitFieldNames ? '' : 'organizationId')
+    ..aOS(2, _omitFieldNames ? '' : 'mqlQuery')
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  TabularDataByMQLRequest clone() => TabularDataByMQLRequest()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  TabularDataByMQLRequest copyWith(void Function(TabularDataByMQLRequest) updates) => super.copyWith((message) => updates(message as TabularDataByMQLRequest)) as TabularDataByMQLRequest;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static TabularDataByMQLRequest create() => TabularDataByMQLRequest._();
+  TabularDataByMQLRequest createEmptyInstance() => create();
+  static $pb.PbList<TabularDataByMQLRequest> createRepeated() => $pb.PbList<TabularDataByMQLRequest>();
+  @$core.pragma('dart2js:noInline')
+  static TabularDataByMQLRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<TabularDataByMQLRequest>(create);
+  static TabularDataByMQLRequest? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $core.String get organizationId => $_getSZ(0);
+  @$pb.TagNumber(1)
+  set organizationId($core.String v) { $_setString(0, v); }
+  @$pb.TagNumber(1)
+  $core.bool hasOrganizationId() => $_has(0);
+  @$pb.TagNumber(1)
+  void clearOrganizationId() => clearField(1);
+
+  /// mql_query accepts a MongoDB aggregation pipeline, to be run on the "sensorData.readings"
+  /// namespace, which holds the Viam organization's tabular data.
+  @$pb.TagNumber(2)
+  $core.String get mqlQuery => $_getSZ(1);
+  @$pb.TagNumber(2)
+  set mqlQuery($core.String v) { $_setString(1, v); }
+  @$pb.TagNumber(2)
+  $core.bool hasMqlQuery() => $_has(1);
+  @$pb.TagNumber(2)
+  void clearMqlQuery() => clearField(2);
+}
+
+/// TabularDataByMQLResponse provides unified tabular data and metadata, queried with MQL.
+class TabularDataByMQLResponse extends $pb.GeneratedMessage {
+  factory TabularDataByMQLResponse({
+    $core.Iterable<$3.Struct>? data,
+  }) {
+    final $result = create();
+    if (data != null) {
+      $result.data.addAll(data);
+    }
+    return $result;
+  }
+  TabularDataByMQLResponse._() : super();
+  factory TabularDataByMQLResponse.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
+  factory TabularDataByMQLResponse.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
+
+  static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'TabularDataByMQLResponse', package: const $pb.PackageName(_omitMessageNames ? '' : 'viam.app.data.v1'), createEmptyInstance: create)
+    ..pc<$3.Struct>(1, _omitFieldNames ? '' : 'data', $pb.PbFieldType.PM, subBuilder: $3.Struct.create)
+    ..hasRequiredFields = false
+  ;
+
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
+  'Will be removed in next major version')
+  TabularDataByMQLResponse clone() => TabularDataByMQLResponse()..mergeFromMessage(this);
+  @$core.Deprecated(
+  'Using this can add significant overhead to your binary. '
+  'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
+  'Will be removed in next major version')
+  TabularDataByMQLResponse copyWith(void Function(TabularDataByMQLResponse) updates) => super.copyWith((message) => updates(message as TabularDataByMQLResponse)) as TabularDataByMQLResponse;
+
+  $pb.BuilderInfo get info_ => _i;
+
+  @$core.pragma('dart2js:noInline')
+  static TabularDataByMQLResponse create() => TabularDataByMQLResponse._();
+  TabularDataByMQLResponse createEmptyInstance() => create();
+  static $pb.PbList<TabularDataByMQLResponse> createRepeated() => $pb.PbList<TabularDataByMQLResponse>();
+  @$core.pragma('dart2js:noInline')
+  static TabularDataByMQLResponse getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<TabularDataByMQLResponse>(create);
+  static TabularDataByMQLResponse? _defaultInstance;
+
+  @$pb.TagNumber(1)
+  $core.List<$3.Struct> get data => $_getList(0);
+}
+
 /// BinaryData contains data and metadata associated with binary data.
 class BinaryData extends $pb.GeneratedMessage {
   factory BinaryData({

@@ -25,6 +25,14 @@ class DataServiceClient extends $grpc.Client {
       '/viam.app.data.v1.DataService/TabularDataByFilter',
       ($0.TabularDataByFilterRequest value) => value.writeToBuffer(),
       ($core.List<$core.int> value) => $0.TabularDataByFilterResponse.fromBuffer(value));
+  static final _$tabularDataBySQL = $grpc.ClientMethod<$0.TabularDataBySQLRequest, $0.TabularDataBySQLResponse>(
+      '/viam.app.data.v1.DataService/TabularDataBySQL',
+      ($0.TabularDataBySQLRequest value) => value.writeToBuffer(),
+      ($core.List<$core.int> value) => $0.TabularDataBySQLResponse.fromBuffer(value));
+  static final _$tabularDataByMQL = $grpc.ClientMethod<$0.TabularDataByMQLRequest, $0.TabularDataByMQLResponse>(
+      '/viam.app.data.v1.DataService/TabularDataByMQL',
+      ($0.TabularDataByMQLRequest value) => value.writeToBuffer(),
+      ($core.List<$core.int> value) => $0.TabularDataByMQLResponse.fromBuffer(value));
   static final _$binaryDataByFilter = $grpc.ClientMethod<$0.BinaryDataByFilterRequest, $0.BinaryDataByFilterResponse>(
       '/viam.app.data.v1.DataService/BinaryDataByFilter',
       ($0.BinaryDataByFilterRequest value) => value.writeToBuffer(),
@@ -104,6 +112,14 @@ class DataServiceClient extends $grpc.Client {
     return $createUnaryCall(_$tabularDataByFilter, request, options: options);
   }
 
+  $grpc.ResponseFuture<$0.TabularDataBySQLResponse> tabularDataBySQL($0.TabularDataBySQLRequest request, {$grpc.CallOptions? options}) {
+    return $createUnaryCall(_$tabularDataBySQL, request, options: options);
+  }
+
+  $grpc.ResponseFuture<$0.TabularDataByMQLResponse> tabularDataByMQL($0.TabularDataByMQLRequest request, {$grpc.CallOptions? options}) {
+    return $createUnaryCall(_$tabularDataByMQL, request, options: options);
+  }
+
   $grpc.ResponseFuture<$0.BinaryDataByFilterResponse> binaryDataByFilter($0.BinaryDataByFilterRequest request, {$grpc.CallOptions? options}) {
     return $createUnaryCall(_$binaryDataByFilter, request, options: options);
   }
@@ -185,6 +201,20 @@ abstract class DataServiceBase extends $grpc.Service {
         false,
         ($core.List<$core.int> value) => $0.TabularDataByFilterRequest.fromBuffer(value),
         ($0.TabularDataByFilterResponse value) => value.writeToBuffer()));
+    $addMethod($grpc.ServiceMethod<$0.TabularDataBySQLRequest, $0.TabularDataBySQLResponse>(
+        'TabularDataBySQL',
+        tabularDataBySQL_Pre,
+        false,
+        false,
+        ($core.List<$core.int> value) => $0.TabularDataBySQLRequest.fromBuffer(value),
+        ($0.TabularDataBySQLResponse value) => value.writeToBuffer()));
+    $addMethod($grpc.ServiceMethod<$0.TabularDataByMQLRequest, $0.TabularDataByMQLResponse>(
+        'TabularDataByMQL',
+        tabularDataByMQL_Pre,
+        false,
+        false,
+        ($core.List<$core.int> value) => $0.TabularDataByMQLRequest.fromBuffer(value),
+        ($0.TabularDataByMQLResponse value) => value.writeToBuffer()));
     $addMethod($grpc.ServiceMethod<$0.BinaryDataByFilterRequest, $0.BinaryDataByFilterResponse>(
         'BinaryDataByFilter',
         binaryDataByFilter_Pre,
@@ -310,6 +340,14 @@ abstract class DataServiceBase extends $grpc.Service {
     return tabularDataByFilter(call, await request);
   }
 
+  $async.Future<$0.TabularDataBySQLResponse> tabularDataBySQL_Pre($grpc.ServiceCall call, $async.Future<$0.TabularDataBySQLRequest> request) async {
+    return tabularDataBySQL(call, await request);
+  }
+
+  $async.Future<$0.TabularDataByMQLResponse> tabularDataByMQL_Pre($grpc.ServiceCall call, $async.Future<$0.TabularDataByMQLRequest> request) async {
+    return tabularDataByMQL(call, await request);
+  }
+
   $async.Future<$0.BinaryDataByFilterResponse> binaryDataByFilter_Pre($grpc.ServiceCall call, $async.Future<$0.BinaryDataByFilterRequest> request) async {
     return binaryDataByFilter(call, await request);
   }
@@ -379,6 +417,8 @@ abstract class DataServiceBase extends $grpc.Service {
   }
 
   $async.Future<$0.TabularDataByFilterResponse> tabularDataByFilter($grpc.ServiceCall call, $0.TabularDataByFilterRequest request);
+  $async.Future<$0.TabularDataBySQLResponse> tabularDataBySQL($grpc.ServiceCall call, $0.TabularDataBySQLRequest request);
+  $async.Future<$0.TabularDataByMQLResponse> tabularDataByMQL($grpc.ServiceCall call, $0.TabularDataByMQLRequest request);
   $async.Future<$0.BinaryDataByFilterResponse> binaryDataByFilter($grpc.ServiceCall call, $0.BinaryDataByFilterRequest request);
   $async.Future<$0.BinaryDataByIDsResponse> binaryDataByIDs($grpc.ServiceCall call, $0.BinaryDataByIDsRequest request);
   $async.Future<$0.DeleteTabularDataResponse> deleteTabularData($grpc.ServiceCall call, $0.DeleteTabularDataRequest request);

@@ -234,6 +234,60 @@ final $typed_data.Uint8List tabularDataDescriptor = $convert.base64Decode(
     'oNdGltZV9yZWNlaXZlZBgEIAEoCzIaLmdvb2dsZS5wcm90b2J1Zi5UaW1lc3RhbXBSDHRpbWVS'
     'ZWNlaXZlZA==');
 
+@$core.Deprecated('Use tabularDataBySQLRequestDescriptor instead')
+const TabularDataBySQLRequest$json = {
+  '1': 'TabularDataBySQLRequest',
+  '2': [
+    {'1': 'organization_id', '3': 1, '4': 1, '5': 9, '10': 'organizationId'},
+    {'1': 'sql_query', '3': 2, '4': 1, '5': 9, '10': 'sqlQuery'},
+  ],
+};
+
+/// Descriptor for `TabularDataBySQLRequest`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List tabularDataBySQLRequestDescriptor = $convert.base64Decode(
+    'ChdUYWJ1bGFyRGF0YUJ5U1FMUmVxdWVzdBInCg9vcmdhbml6YXRpb25faWQYASABKAlSDm9yZ2'
+    'FuaXphdGlvbklkEhsKCXNxbF9xdWVyeRgCIAEoCVIIc3FsUXVlcnk=');
+
+@$core.Deprecated('Use tabularDataBySQLResponseDescriptor instead')
+const TabularDataBySQLResponse$json = {
+  '1': 'TabularDataBySQLResponse',
+  '2': [
+    {'1': 'data', '3': 1, '4': 3, '5': 11, '6': '.google.protobuf.Struct', '10': 'data'},
+  ],
+};
+
+/// Descriptor for `TabularDataBySQLResponse`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List tabularDataBySQLResponseDescriptor = $convert.base64Decode(
+    'ChhUYWJ1bGFyRGF0YUJ5U1FMUmVzcG9uc2USKwoEZGF0YRgBIAMoCzIXLmdvb2dsZS5wcm90b2'
+    'J1Zi5TdHJ1Y3RSBGRhdGE=');
+
+@$core.Deprecated('Use tabularDataByMQLRequestDescriptor instead')
+const TabularDataByMQLRequest$json = {
+  '1': 'TabularDataByMQLRequest',
+  '2': [
+    {'1': 'organization_id', '3': 1, '4': 1, '5': 9, '10': 'organizationId'},
+    {'1': 'mql_query', '3': 2, '4': 1, '5': 9, '10': 'mqlQuery'},
+  ],
+};
+
+/// Descriptor for `TabularDataByMQLRequest`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List tabularDataByMQLRequestDescriptor = $convert.base64Decode(
+    'ChdUYWJ1bGFyRGF0YUJ5TVFMUmVxdWVzdBInCg9vcmdhbml6YXRpb25faWQYASABKAlSDm9yZ2'
+    'FuaXphdGlvbklkEhsKCW1xbF9xdWVyeRgCIAEoCVIIbXFsUXVlcnk=');
+
+@$core.Deprecated('Use tabularDataByMQLResponseDescriptor instead')
+const TabularDataByMQLResponse$json = {
+  '1': 'TabularDataByMQLResponse',
+  '2': [
+    {'1': 'data', '3': 1, '4': 3, '5': 11, '6': '.google.protobuf.Struct', '10': 'data'},
+  ],
+};
+
+/// Descriptor for `TabularDataByMQLResponse`. Decode as a `google.protobuf.DescriptorProto`.
+final $typed_data.Uint8List tabularDataByMQLResponseDescriptor = $convert.base64Decode(
+    'ChhUYWJ1bGFyRGF0YUJ5TVFMUmVzcG9uc2USKwoEZGF0YRgBIAMoCzIXLmdvb2dsZS5wcm90b2'
+    'J1Zi5TdHJ1Y3RSBGRhdGE=');
+
 @$core.Deprecated('Use binaryDataDescriptor instead')
 const BinaryData$json = {
   '1': 'BinaryData',