From 56bec6ccf2e3d59caf3a8a8832f310cf2d1f3a0b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?St=C3=A9phane=20Duchesneau?= Date: Thu, 2 Nov 2023 10:14:00 -0400 Subject: [PATCH] add 'rest_frontend' (enabled bool) to sql definition --- CHANGELOG.md | 4 + pb/last_generate.txt | 2 +- pb/sf/substreams/sink/sql/v1/services.pb.go | 157 +++++++++++++----- .../sf/substreams/sink/sql/v1/services.proto | 11 ++ substreams.yaml | 2 +- 5 files changed, 136 insertions(+), 40 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index e8b92bd..882cd30 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -5,6 +5,10 @@ All notable changes to this project will be documented in this file. The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/), and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html). +## Protodefs v1.0.4 + +* Added support for `rest_frontend` field with `enabled` boolean flag, aimed at this backend implementation: https://github.com/semiotic-ai/sql-wrapper + ## v3.0.5 * Fixed regression: `run` command was incorrectly only processing blocks staying behind the "FinalBlocks" cliff. diff --git a/pb/last_generate.txt b/pb/last_generate.txt index 7824cd4..88a7547 100644 --- a/pb/last_generate.txt +++ b/pb/last_generate.txt @@ -1 +1 @@ -generate.sh - Thu 19 Oct 2023 14:21:25 EST - stepd +generate.sh - Thu 2 Nov 2023 10:13:19 EDT - stepd diff --git a/pb/sf/substreams/sink/sql/v1/services.pb.go b/pb/sf/substreams/sink/sql/v1/services.pb.go index 5b9cc34..dded78c 100644 --- a/pb/sf/substreams/sink/sql/v1/services.pb.go +++ b/pb/sf/substreams/sink/sql/v1/services.pb.go @@ -83,6 +83,7 @@ type Service struct { PostgraphileFrontend *PostgraphileFrontend `protobuf:"bytes,5,opt,name=postgraphile_frontend,json=postgraphileFrontend,proto3" json:"postgraphile_frontend,omitempty"` PgwebFrontend *PGWebFrontend `protobuf:"bytes,6,opt,name=pgweb_frontend,json=pgwebFrontend,proto3" json:"pgweb_frontend,omitempty"` Engine Service_Engine `protobuf:"varint,7,opt,name=engine,proto3,enum=sf.substreams.sink.sql.v1.Service_Engine" json:"engine,omitempty"` + RestFrontend *RESTFrontend `protobuf:"bytes,8,opt,name=rest_frontend,json=restFrontend,proto3" json:"rest_frontend,omitempty"` } func (x *Service) Reset() { @@ -166,6 +167,14 @@ func (x *Service) GetEngine() Service_Engine { return Service_unset } +func (x *Service) GetRestFrontend() *RESTFrontend { + if x != nil { + return x.RestFrontend + } + return nil +} + +// https://www.getdbt.com/product/what-is-dbt type DBTConfig struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache @@ -213,6 +222,7 @@ func (x *DBTConfig) GetFiles() []byte { return nil } +// https://hasura.io/docs/latest/index/ type HasuraFrontend struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache @@ -260,6 +270,7 @@ func (x *HasuraFrontend) GetEnabled() bool { return false } +// https://www.graphile.org/postgraphile/ type PostgraphileFrontend struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache @@ -307,6 +318,7 @@ func (x *PostgraphileFrontend) GetEnabled() bool { return false } +// https://github.com/sosedoff/pgweb type PGWebFrontend struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache @@ -354,6 +366,54 @@ func (x *PGWebFrontend) GetEnabled() bool { return false } +// https://github.com/semiotic-ai/sql-wrapper +type RESTFrontend struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"` +} + +func (x *RESTFrontend) Reset() { + *x = RESTFrontend{} + if protoimpl.UnsafeEnabled { + mi := &file_sf_substreams_sink_sql_v1_services_proto_msgTypes[5] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *RESTFrontend) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*RESTFrontend) ProtoMessage() {} + +func (x *RESTFrontend) ProtoReflect() protoreflect.Message { + mi := &file_sf_substreams_sink_sql_v1_services_proto_msgTypes[5] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use RESTFrontend.ProtoReflect.Descriptor instead. +func (*RESTFrontend) Descriptor() ([]byte, []int) { + return file_sf_substreams_sink_sql_v1_services_proto_rawDescGZIP(), []int{5} +} + +func (x *RESTFrontend) GetEnabled() bool { + if x != nil { + return x.Enabled + } + return false +} + var File_sf_substreams_sink_sql_v1_services_proto protoreflect.FileDescriptor var file_sf_substreams_sink_sql_v1_services_proto_rawDesc = []byte{ @@ -363,7 +423,7 @@ var file_sf_substreams_sink_sql_v1_services_proto_rawDesc = []byte{ 0x75, 0x62, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x73, 0x69, 0x6e, 0x6b, 0x2e, 0x73, 0x71, 0x6c, 0x2e, 0x76, 0x31, 0x1a, 0x1b, 0x73, 0x66, 0x2f, 0x73, 0x75, 0x62, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, - 0x74, 0x6f, 0x22, 0xb5, 0x04, 0x0a, 0x07, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x1e, + 0x74, 0x6f, 0x22, 0x83, 0x05, 0x0a, 0x07, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x1e, 0x0a, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x06, 0xc2, 0x89, 0x01, 0x02, 0x08, 0x01, 0x52, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x48, 0x0a, 0x0a, 0x64, 0x62, 0x74, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x18, 0x02, 0x20, 0x01, @@ -394,38 +454,45 @@ var file_sf_substreams_sink_sql_v1_services_proto_rawDesc = []byte{ 0x07, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x29, 0x2e, 0x73, 0x66, 0x2e, 0x73, 0x75, 0x62, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x73, 0x69, 0x6e, 0x6b, 0x2e, 0x73, 0x71, 0x6c, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x45, 0x6e, 0x67, 0x69, 0x6e, 0x65, - 0x52, 0x06, 0x65, 0x6e, 0x67, 0x69, 0x6e, 0x65, 0x22, 0x31, 0x0a, 0x06, 0x45, 0x6e, 0x67, 0x69, - 0x6e, 0x65, 0x12, 0x09, 0x0a, 0x05, 0x75, 0x6e, 0x73, 0x65, 0x74, 0x10, 0x00, 0x12, 0x0c, 0x0a, - 0x08, 0x70, 0x6f, 0x73, 0x74, 0x67, 0x72, 0x65, 0x73, 0x10, 0x01, 0x12, 0x0e, 0x0a, 0x0a, 0x63, - 0x6c, 0x69, 0x63, 0x6b, 0x68, 0x6f, 0x75, 0x73, 0x65, 0x10, 0x02, 0x42, 0x0d, 0x0a, 0x0b, 0x5f, - 0x64, 0x62, 0x74, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x22, 0x29, 0x0a, 0x09, 0x44, 0x42, - 0x54, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x1c, 0x0a, 0x05, 0x66, 0x69, 0x6c, 0x65, 0x73, - 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x42, 0x06, 0xc2, 0x89, 0x01, 0x02, 0x10, 0x01, 0x52, 0x05, - 0x66, 0x69, 0x6c, 0x65, 0x73, 0x22, 0x2a, 0x0a, 0x0e, 0x48, 0x61, 0x73, 0x75, 0x72, 0x61, 0x46, + 0x52, 0x06, 0x65, 0x6e, 0x67, 0x69, 0x6e, 0x65, 0x12, 0x4c, 0x0a, 0x0d, 0x72, 0x65, 0x73, 0x74, + 0x5f, 0x66, 0x72, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x64, 0x18, 0x08, 0x20, 0x01, 0x28, 0x0b, 0x32, + 0x27, 0x2e, 0x73, 0x66, 0x2e, 0x73, 0x75, 0x62, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, + 0x73, 0x69, 0x6e, 0x6b, 0x2e, 0x73, 0x71, 0x6c, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x45, 0x53, 0x54, + 0x46, 0x72, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x64, 0x52, 0x0c, 0x72, 0x65, 0x73, 0x74, 0x46, 0x72, + 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x64, 0x22, 0x31, 0x0a, 0x06, 0x45, 0x6e, 0x67, 0x69, 0x6e, 0x65, + 0x12, 0x09, 0x0a, 0x05, 0x75, 0x6e, 0x73, 0x65, 0x74, 0x10, 0x00, 0x12, 0x0c, 0x0a, 0x08, 0x70, + 0x6f, 0x73, 0x74, 0x67, 0x72, 0x65, 0x73, 0x10, 0x01, 0x12, 0x0e, 0x0a, 0x0a, 0x63, 0x6c, 0x69, + 0x63, 0x6b, 0x68, 0x6f, 0x75, 0x73, 0x65, 0x10, 0x02, 0x42, 0x0d, 0x0a, 0x0b, 0x5f, 0x64, 0x62, + 0x74, 0x5f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x22, 0x29, 0x0a, 0x09, 0x44, 0x42, 0x54, 0x43, + 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x12, 0x1c, 0x0a, 0x05, 0x66, 0x69, 0x6c, 0x65, 0x73, 0x18, 0x01, + 0x20, 0x01, 0x28, 0x0c, 0x42, 0x06, 0xc2, 0x89, 0x01, 0x02, 0x10, 0x01, 0x52, 0x05, 0x66, 0x69, + 0x6c, 0x65, 0x73, 0x22, 0x2a, 0x0a, 0x0e, 0x48, 0x61, 0x73, 0x75, 0x72, 0x61, 0x46, 0x72, 0x6f, + 0x6e, 0x74, 0x65, 0x6e, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x64, + 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x64, 0x22, + 0x30, 0x0a, 0x14, 0x50, 0x6f, 0x73, 0x74, 0x67, 0x72, 0x61, 0x70, 0x68, 0x69, 0x6c, 0x65, 0x46, 0x72, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e, 0x61, 0x62, 0x6c, 0x65, - 0x64, 0x22, 0x30, 0x0a, 0x14, 0x50, 0x6f, 0x73, 0x74, 0x67, 0x72, 0x61, 0x70, 0x68, 0x69, 0x6c, - 0x65, 0x46, 0x72, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x61, - 0x62, 0x6c, 0x65, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e, 0x61, 0x62, - 0x6c, 0x65, 0x64, 0x22, 0x29, 0x0a, 0x0d, 0x50, 0x47, 0x57, 0x65, 0x62, 0x46, 0x72, 0x6f, 0x6e, - 0x74, 0x65, 0x6e, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x64, 0x18, - 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x64, 0x42, 0xee, - 0x01, 0x0a, 0x1d, 0x63, 0x6f, 0x6d, 0x2e, 0x73, 0x66, 0x2e, 0x73, 0x75, 0x62, 0x73, 0x74, 0x72, - 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x73, 0x69, 0x6e, 0x6b, 0x2e, 0x73, 0x71, 0x6c, 0x2e, 0x76, 0x31, - 0x42, 0x0d, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, - 0x01, 0x5a, 0x35, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x73, 0x74, - 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x66, 0x61, 0x73, 0x74, 0x2f, 0x73, 0x75, 0x62, 0x73, - 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2d, 0x73, 0x69, 0x6e, 0x6b, 0x2d, 0x73, 0x71, 0x6c, 0x2f, - 0x70, 0x62, 0x3b, 0x70, 0x62, 0x73, 0x71, 0x6c, 0xa2, 0x02, 0x04, 0x53, 0x53, 0x53, 0x53, 0xaa, - 0x02, 0x19, 0x53, 0x66, 0x2e, 0x53, 0x75, 0x62, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, - 0x53, 0x69, 0x6e, 0x6b, 0x2e, 0x53, 0x71, 0x6c, 0x2e, 0x56, 0x31, 0xca, 0x02, 0x19, 0x53, 0x66, - 0x5c, 0x53, 0x75, 0x62, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x5c, 0x53, 0x69, 0x6e, 0x6b, - 0x5c, 0x53, 0x71, 0x6c, 0x5c, 0x56, 0x31, 0xe2, 0x02, 0x25, 0x53, 0x66, 0x5c, 0x53, 0x75, 0x62, - 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x5c, 0x53, 0x69, 0x6e, 0x6b, 0x5c, 0x53, 0x71, 0x6c, - 0x5c, 0x56, 0x31, 0x5c, 0x47, 0x50, 0x42, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0xea, - 0x02, 0x1d, 0x53, 0x66, 0x3a, 0x3a, 0x53, 0x75, 0x62, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, - 0x3a, 0x3a, 0x53, 0x69, 0x6e, 0x6b, 0x3a, 0x3a, 0x53, 0x71, 0x6c, 0x3a, 0x3a, 0x56, 0x31, 0x62, - 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, + 0x64, 0x22, 0x29, 0x0a, 0x0d, 0x50, 0x47, 0x57, 0x65, 0x62, 0x46, 0x72, 0x6f, 0x6e, 0x74, 0x65, + 0x6e, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x65, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x64, 0x18, 0x01, 0x20, + 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x64, 0x22, 0x28, 0x0a, 0x0c, + 0x52, 0x45, 0x53, 0x54, 0x46, 0x72, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x64, 0x12, 0x18, 0x0a, 0x07, + 0x65, 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x65, + 0x6e, 0x61, 0x62, 0x6c, 0x65, 0x64, 0x42, 0xee, 0x01, 0x0a, 0x1d, 0x63, 0x6f, 0x6d, 0x2e, 0x73, + 0x66, 0x2e, 0x73, 0x75, 0x62, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x73, 0x69, 0x6e, + 0x6b, 0x2e, 0x73, 0x71, 0x6c, 0x2e, 0x76, 0x31, 0x42, 0x0d, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, + 0x65, 0x73, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x35, 0x67, 0x69, 0x74, 0x68, 0x75, + 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x66, + 0x61, 0x73, 0x74, 0x2f, 0x73, 0x75, 0x62, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2d, 0x73, + 0x69, 0x6e, 0x6b, 0x2d, 0x73, 0x71, 0x6c, 0x2f, 0x70, 0x62, 0x3b, 0x70, 0x62, 0x73, 0x71, 0x6c, + 0xa2, 0x02, 0x04, 0x53, 0x53, 0x53, 0x53, 0xaa, 0x02, 0x19, 0x53, 0x66, 0x2e, 0x53, 0x75, 0x62, + 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2e, 0x53, 0x69, 0x6e, 0x6b, 0x2e, 0x53, 0x71, 0x6c, + 0x2e, 0x56, 0x31, 0xca, 0x02, 0x19, 0x53, 0x66, 0x5c, 0x53, 0x75, 0x62, 0x73, 0x74, 0x72, 0x65, + 0x61, 0x6d, 0x73, 0x5c, 0x53, 0x69, 0x6e, 0x6b, 0x5c, 0x53, 0x71, 0x6c, 0x5c, 0x56, 0x31, 0xe2, + 0x02, 0x25, 0x53, 0x66, 0x5c, 0x53, 0x75, 0x62, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x5c, + 0x53, 0x69, 0x6e, 0x6b, 0x5c, 0x53, 0x71, 0x6c, 0x5c, 0x56, 0x31, 0x5c, 0x47, 0x50, 0x42, 0x4d, + 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0xea, 0x02, 0x1d, 0x53, 0x66, 0x3a, 0x3a, 0x53, 0x75, + 0x62, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x3a, 0x3a, 0x53, 0x69, 0x6e, 0x6b, 0x3a, 0x3a, + 0x53, 0x71, 0x6c, 0x3a, 0x3a, 0x56, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, } var ( @@ -441,7 +508,7 @@ func file_sf_substreams_sink_sql_v1_services_proto_rawDescGZIP() []byte { } var file_sf_substreams_sink_sql_v1_services_proto_enumTypes = make([]protoimpl.EnumInfo, 1) -var file_sf_substreams_sink_sql_v1_services_proto_msgTypes = make([]protoimpl.MessageInfo, 5) +var file_sf_substreams_sink_sql_v1_services_proto_msgTypes = make([]protoimpl.MessageInfo, 6) var file_sf_substreams_sink_sql_v1_services_proto_goTypes = []interface{}{ (Service_Engine)(0), // 0: sf.substreams.sink.sql.v1.Service.Engine (*Service)(nil), // 1: sf.substreams.sink.sql.v1.Service @@ -449,6 +516,7 @@ var file_sf_substreams_sink_sql_v1_services_proto_goTypes = []interface{}{ (*HasuraFrontend)(nil), // 3: sf.substreams.sink.sql.v1.HasuraFrontend (*PostgraphileFrontend)(nil), // 4: sf.substreams.sink.sql.v1.PostgraphileFrontend (*PGWebFrontend)(nil), // 5: sf.substreams.sink.sql.v1.PGWebFrontend + (*RESTFrontend)(nil), // 6: sf.substreams.sink.sql.v1.RESTFrontend } var file_sf_substreams_sink_sql_v1_services_proto_depIdxs = []int32{ 2, // 0: sf.substreams.sink.sql.v1.Service.dbt_config:type_name -> sf.substreams.sink.sql.v1.DBTConfig @@ -456,11 +524,12 @@ var file_sf_substreams_sink_sql_v1_services_proto_depIdxs = []int32{ 4, // 2: sf.substreams.sink.sql.v1.Service.postgraphile_frontend:type_name -> sf.substreams.sink.sql.v1.PostgraphileFrontend 5, // 3: sf.substreams.sink.sql.v1.Service.pgweb_frontend:type_name -> sf.substreams.sink.sql.v1.PGWebFrontend 0, // 4: sf.substreams.sink.sql.v1.Service.engine:type_name -> sf.substreams.sink.sql.v1.Service.Engine - 5, // [5:5] is the sub-list for method output_type - 5, // [5:5] is the sub-list for method input_type - 5, // [5:5] is the sub-list for extension type_name - 5, // [5:5] is the sub-list for extension extendee - 0, // [0:5] is the sub-list for field type_name + 6, // 5: sf.substreams.sink.sql.v1.Service.rest_frontend:type_name -> sf.substreams.sink.sql.v1.RESTFrontend + 6, // [6:6] is the sub-list for method output_type + 6, // [6:6] is the sub-list for method input_type + 6, // [6:6] is the sub-list for extension type_name + 6, // [6:6] is the sub-list for extension extendee + 0, // [0:6] is the sub-list for field type_name } func init() { file_sf_substreams_sink_sql_v1_services_proto_init() } @@ -529,6 +598,18 @@ func file_sf_substreams_sink_sql_v1_services_proto_init() { return nil } } + file_sf_substreams_sink_sql_v1_services_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*RESTFrontend); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } } file_sf_substreams_sink_sql_v1_services_proto_msgTypes[0].OneofWrappers = []interface{}{} type x struct{} @@ -537,7 +618,7 @@ func file_sf_substreams_sink_sql_v1_services_proto_init() { GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: file_sf_substreams_sink_sql_v1_services_proto_rawDesc, NumEnums: 1, - NumMessages: 5, + NumMessages: 6, NumExtensions: 0, NumServices: 0, }, diff --git a/proto/sf/substreams/sink/sql/v1/services.proto b/proto/sf/substreams/sink/sql/v1/services.proto index 2508a34..a7a160c 100644 --- a/proto/sf/substreams/sink/sql/v1/services.proto +++ b/proto/sf/substreams/sink/sql/v1/services.proto @@ -22,20 +22,31 @@ message Service { } Engine engine = 7; + + RESTFrontend rest_frontend = 8; } +// https://www.getdbt.com/product/what-is-dbt message DBTConfig { bytes files = 1 [ (sf.substreams.options).zip_from_folder = true ]; } +// https://hasura.io/docs/latest/index/ message HasuraFrontend { bool enabled = 1; } +// https://www.graphile.org/postgraphile/ message PostgraphileFrontend { bool enabled = 1; } +// https://github.com/sosedoff/pgweb message PGWebFrontend { bool enabled = 1; } + +// https://github.com/semiotic-ai/sql-wrapper +message RESTFrontend { + bool enabled = 1; +} diff --git a/substreams.yaml b/substreams.yaml index c7d0700..07c9b1b 100644 --- a/substreams.yaml +++ b/substreams.yaml @@ -1,7 +1,7 @@ specVersion: v0.1.0 package: name: substreams_sink_sql_protodefs - version: v1.0.3 + version: v1.0.4 url: https://github.com/streamingfast/substreams-sink-sql doc: | Protobuf definitions for Substreams SQL Sink modules.