service_grpc.pb.go raw
1 // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
2 // versions:
3 // - protoc-gen-go-grpc v1.6.0
4 // - protoc (unknown)
5 // source: orlydb/v1/service.proto
6
7 package orlydbv1
8
9 import (
10 context "context"
11 grpc "google.golang.org/grpc"
12 codes "google.golang.org/grpc/codes"
13 status "google.golang.org/grpc/status"
14 )
15
16 // This is a compile-time assertion to ensure that this generated file
17 // is compatible with the grpc package it is being compiled against.
18 // Requires gRPC-Go v1.64.0 or later.
19 const _ = grpc.SupportPackageIsVersion9
20
21 const (
22 DatabaseService_GetPath_FullMethodName = "/orlydb.v1.DatabaseService/GetPath"
23 DatabaseService_Sync_FullMethodName = "/orlydb.v1.DatabaseService/Sync"
24 DatabaseService_Ready_FullMethodName = "/orlydb.v1.DatabaseService/Ready"
25 DatabaseService_SetLogLevel_FullMethodName = "/orlydb.v1.DatabaseService/SetLogLevel"
26 DatabaseService_SaveEvent_FullMethodName = "/orlydb.v1.DatabaseService/SaveEvent"
27 DatabaseService_GetSerialsFromFilter_FullMethodName = "/orlydb.v1.DatabaseService/GetSerialsFromFilter"
28 DatabaseService_WouldReplaceEvent_FullMethodName = "/orlydb.v1.DatabaseService/WouldReplaceEvent"
29 DatabaseService_QueryEvents_FullMethodName = "/orlydb.v1.DatabaseService/QueryEvents"
30 DatabaseService_QueryAllVersions_FullMethodName = "/orlydb.v1.DatabaseService/QueryAllVersions"
31 DatabaseService_QueryEventsWithOptions_FullMethodName = "/orlydb.v1.DatabaseService/QueryEventsWithOptions"
32 DatabaseService_QueryDeleteEventsByTargetId_FullMethodName = "/orlydb.v1.DatabaseService/QueryDeleteEventsByTargetId"
33 DatabaseService_QueryForSerials_FullMethodName = "/orlydb.v1.DatabaseService/QueryForSerials"
34 DatabaseService_QueryForIds_FullMethodName = "/orlydb.v1.DatabaseService/QueryForIds"
35 DatabaseService_CountEvents_FullMethodName = "/orlydb.v1.DatabaseService/CountEvents"
36 DatabaseService_FetchEventBySerial_FullMethodName = "/orlydb.v1.DatabaseService/FetchEventBySerial"
37 DatabaseService_FetchEventsBySerials_FullMethodName = "/orlydb.v1.DatabaseService/FetchEventsBySerials"
38 DatabaseService_GetSerialById_FullMethodName = "/orlydb.v1.DatabaseService/GetSerialById"
39 DatabaseService_GetSerialsByIds_FullMethodName = "/orlydb.v1.DatabaseService/GetSerialsByIds"
40 DatabaseService_GetSerialsByRange_FullMethodName = "/orlydb.v1.DatabaseService/GetSerialsByRange"
41 DatabaseService_GetFullIdPubkeyBySerial_FullMethodName = "/orlydb.v1.DatabaseService/GetFullIdPubkeyBySerial"
42 DatabaseService_GetFullIdPubkeyBySerials_FullMethodName = "/orlydb.v1.DatabaseService/GetFullIdPubkeyBySerials"
43 DatabaseService_DeleteEvent_FullMethodName = "/orlydb.v1.DatabaseService/DeleteEvent"
44 DatabaseService_DeleteEventBySerial_FullMethodName = "/orlydb.v1.DatabaseService/DeleteEventBySerial"
45 DatabaseService_DeleteExpired_FullMethodName = "/orlydb.v1.DatabaseService/DeleteExpired"
46 DatabaseService_ProcessDelete_FullMethodName = "/orlydb.v1.DatabaseService/ProcessDelete"
47 DatabaseService_CheckForDeleted_FullMethodName = "/orlydb.v1.DatabaseService/CheckForDeleted"
48 DatabaseService_Import_FullMethodName = "/orlydb.v1.DatabaseService/Import"
49 DatabaseService_Export_FullMethodName = "/orlydb.v1.DatabaseService/Export"
50 DatabaseService_ImportEventsFromStrings_FullMethodName = "/orlydb.v1.DatabaseService/ImportEventsFromStrings"
51 DatabaseService_GetRelayIdentitySecret_FullMethodName = "/orlydb.v1.DatabaseService/GetRelayIdentitySecret"
52 DatabaseService_SetRelayIdentitySecret_FullMethodName = "/orlydb.v1.DatabaseService/SetRelayIdentitySecret"
53 DatabaseService_GetOrCreateRelayIdentitySecret_FullMethodName = "/orlydb.v1.DatabaseService/GetOrCreateRelayIdentitySecret"
54 DatabaseService_SetMarker_FullMethodName = "/orlydb.v1.DatabaseService/SetMarker"
55 DatabaseService_GetMarker_FullMethodName = "/orlydb.v1.DatabaseService/GetMarker"
56 DatabaseService_HasMarker_FullMethodName = "/orlydb.v1.DatabaseService/HasMarker"
57 DatabaseService_DeleteMarker_FullMethodName = "/orlydb.v1.DatabaseService/DeleteMarker"
58 DatabaseService_GetSubscription_FullMethodName = "/orlydb.v1.DatabaseService/GetSubscription"
59 DatabaseService_IsSubscriptionActive_FullMethodName = "/orlydb.v1.DatabaseService/IsSubscriptionActive"
60 DatabaseService_ExtendSubscription_FullMethodName = "/orlydb.v1.DatabaseService/ExtendSubscription"
61 DatabaseService_RecordPayment_FullMethodName = "/orlydb.v1.DatabaseService/RecordPayment"
62 DatabaseService_GetPaymentHistory_FullMethodName = "/orlydb.v1.DatabaseService/GetPaymentHistory"
63 DatabaseService_ExtendBlossomSubscription_FullMethodName = "/orlydb.v1.DatabaseService/ExtendBlossomSubscription"
64 DatabaseService_GetBlossomStorageQuota_FullMethodName = "/orlydb.v1.DatabaseService/GetBlossomStorageQuota"
65 DatabaseService_IsFirstTimeUser_FullMethodName = "/orlydb.v1.DatabaseService/IsFirstTimeUser"
66 DatabaseService_SavePaidSubscription_FullMethodName = "/orlydb.v1.DatabaseService/SavePaidSubscription"
67 DatabaseService_GetPaidSubscription_FullMethodName = "/orlydb.v1.DatabaseService/GetPaidSubscription"
68 DatabaseService_DeletePaidSubscription_FullMethodName = "/orlydb.v1.DatabaseService/DeletePaidSubscription"
69 DatabaseService_ListPaidSubscriptions_FullMethodName = "/orlydb.v1.DatabaseService/ListPaidSubscriptions"
70 DatabaseService_ClaimAlias_FullMethodName = "/orlydb.v1.DatabaseService/ClaimAlias"
71 DatabaseService_GetAliasByPubkey_FullMethodName = "/orlydb.v1.DatabaseService/GetAliasByPubkey"
72 DatabaseService_GetPubkeyByAlias_FullMethodName = "/orlydb.v1.DatabaseService/GetPubkeyByAlias"
73 DatabaseService_IsAliasTaken_FullMethodName = "/orlydb.v1.DatabaseService/IsAliasTaken"
74 DatabaseService_AddNIP43Member_FullMethodName = "/orlydb.v1.DatabaseService/AddNIP43Member"
75 DatabaseService_RemoveNIP43Member_FullMethodName = "/orlydb.v1.DatabaseService/RemoveNIP43Member"
76 DatabaseService_IsNIP43Member_FullMethodName = "/orlydb.v1.DatabaseService/IsNIP43Member"
77 DatabaseService_GetNIP43Membership_FullMethodName = "/orlydb.v1.DatabaseService/GetNIP43Membership"
78 DatabaseService_GetAllNIP43Members_FullMethodName = "/orlydb.v1.DatabaseService/GetAllNIP43Members"
79 DatabaseService_StoreInviteCode_FullMethodName = "/orlydb.v1.DatabaseService/StoreInviteCode"
80 DatabaseService_ValidateInviteCode_FullMethodName = "/orlydb.v1.DatabaseService/ValidateInviteCode"
81 DatabaseService_DeleteInviteCode_FullMethodName = "/orlydb.v1.DatabaseService/DeleteInviteCode"
82 DatabaseService_PublishNIP43MembershipEvent_FullMethodName = "/orlydb.v1.DatabaseService/PublishNIP43MembershipEvent"
83 DatabaseService_GetCachedJSON_FullMethodName = "/orlydb.v1.DatabaseService/GetCachedJSON"
84 DatabaseService_CacheMarshaledJSON_FullMethodName = "/orlydb.v1.DatabaseService/CacheMarshaledJSON"
85 DatabaseService_GetCachedEvents_FullMethodName = "/orlydb.v1.DatabaseService/GetCachedEvents"
86 DatabaseService_CacheEvents_FullMethodName = "/orlydb.v1.DatabaseService/CacheEvents"
87 DatabaseService_InvalidateQueryCache_FullMethodName = "/orlydb.v1.DatabaseService/InvalidateQueryCache"
88 DatabaseService_RecordEventAccess_FullMethodName = "/orlydb.v1.DatabaseService/RecordEventAccess"
89 DatabaseService_GetEventAccessInfo_FullMethodName = "/orlydb.v1.DatabaseService/GetEventAccessInfo"
90 DatabaseService_GetLeastAccessedEvents_FullMethodName = "/orlydb.v1.DatabaseService/GetLeastAccessedEvents"
91 DatabaseService_SaveBlob_FullMethodName = "/orlydb.v1.DatabaseService/SaveBlob"
92 DatabaseService_SaveBlobMetadata_FullMethodName = "/orlydb.v1.DatabaseService/SaveBlobMetadata"
93 DatabaseService_GetBlob_FullMethodName = "/orlydb.v1.DatabaseService/GetBlob"
94 DatabaseService_HasBlob_FullMethodName = "/orlydb.v1.DatabaseService/HasBlob"
95 DatabaseService_DeleteBlob_FullMethodName = "/orlydb.v1.DatabaseService/DeleteBlob"
96 DatabaseService_ListBlobs_FullMethodName = "/orlydb.v1.DatabaseService/ListBlobs"
97 DatabaseService_GetBlobMetadata_FullMethodName = "/orlydb.v1.DatabaseService/GetBlobMetadata"
98 DatabaseService_GetTotalBlobStorageUsed_FullMethodName = "/orlydb.v1.DatabaseService/GetTotalBlobStorageUsed"
99 DatabaseService_SaveBlobReport_FullMethodName = "/orlydb.v1.DatabaseService/SaveBlobReport"
100 DatabaseService_ListAllBlobUserStats_FullMethodName = "/orlydb.v1.DatabaseService/ListAllBlobUserStats"
101 DatabaseService_ReconcileBlobMetadata_FullMethodName = "/orlydb.v1.DatabaseService/ReconcileBlobMetadata"
102 DatabaseService_ListAllBlobs_FullMethodName = "/orlydb.v1.DatabaseService/ListAllBlobs"
103 DatabaseService_GetThumbnail_FullMethodName = "/orlydb.v1.DatabaseService/GetThumbnail"
104 DatabaseService_SaveThumbnail_FullMethodName = "/orlydb.v1.DatabaseService/SaveThumbnail"
105 DatabaseService_EventIdsBySerial_FullMethodName = "/orlydb.v1.DatabaseService/EventIdsBySerial"
106 DatabaseService_RunMigrations_FullMethodName = "/orlydb.v1.DatabaseService/RunMigrations"
107 DatabaseService_ExecuteCypherRead_FullMethodName = "/orlydb.v1.DatabaseService/ExecuteCypherRead"
108 )
109
110 // DatabaseServiceClient is the client API for DatabaseService service.
111 //
112 // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
113 //
114 // DatabaseService provides gRPC access to the ORLY database
115 type DatabaseServiceClient interface {
116 // GetPath returns the database file path
117 GetPath(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PathResponse, error)
118 // Sync flushes buffers to disk
119 Sync(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
120 // Ready returns whether the database is ready to serve requests
121 Ready(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ReadyResponse, error)
122 // SetLogLevel sets the database log level
123 SetLogLevel(ctx context.Context, in *SetLogLevelRequest, opts ...grpc.CallOption) (*Empty, error)
124 // SaveEvent stores an event, returns whether it already existed
125 SaveEvent(ctx context.Context, in *SaveEventRequest, opts ...grpc.CallOption) (*SaveEventResponse, error)
126 // GetSerialsFromFilter gets serial numbers matching a filter
127 GetSerialsFromFilter(ctx context.Context, in *GetSerialsFromFilterRequest, opts ...grpc.CallOption) (*SerialList, error)
128 // WouldReplaceEvent checks if an event would replace existing ones
129 WouldReplaceEvent(ctx context.Context, in *WouldReplaceEventRequest, opts ...grpc.CallOption) (*WouldReplaceEventResponse, error)
130 // QueryEvents queries events matching a filter (with deletion filtering)
131 QueryEvents(ctx context.Context, in *QueryEventsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[EventBatch], error)
132 // QueryAllVersions queries all versions of replaceable events
133 QueryAllVersions(ctx context.Context, in *QueryEventsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[EventBatch], error)
134 // QueryEventsWithOptions provides full control over query behavior
135 QueryEventsWithOptions(ctx context.Context, in *QueryEventsWithOptionsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[EventBatch], error)
136 // QueryDeleteEventsByTargetId queries deletion events for a target
137 QueryDeleteEventsByTargetId(ctx context.Context, in *QueryDeleteEventsByTargetIdRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[EventBatch], error)
138 // QueryForSerials queries just serial numbers matching a filter
139 QueryForSerials(ctx context.Context, in *QueryEventsRequest, opts ...grpc.CallOption) (*SerialList, error)
140 // QueryForIds queries ID/Pubkey/Timestamp triplets
141 QueryForIds(ctx context.Context, in *QueryEventsRequest, opts ...grpc.CallOption) (*IdPkTsList, error)
142 // CountEvents counts events matching a filter
143 CountEvents(ctx context.Context, in *QueryEventsRequest, opts ...grpc.CallOption) (*CountEventsResponse, error)
144 // FetchEventBySerial fetches a single event by serial
145 FetchEventBySerial(ctx context.Context, in *FetchEventBySerialRequest, opts ...grpc.CallOption) (*FetchEventBySerialResponse, error)
146 // FetchEventsBySerials fetches multiple events by serial (batch)
147 FetchEventsBySerials(ctx context.Context, in *FetchEventsBySerialRequest, opts ...grpc.CallOption) (*EventMap, error)
148 // GetSerialById gets the serial for a single event ID
149 GetSerialById(ctx context.Context, in *GetSerialByIdRequest, opts ...grpc.CallOption) (*GetSerialByIdResponse, error)
150 // GetSerialsByIds gets serials for multiple event IDs
151 GetSerialsByIds(ctx context.Context, in *GetSerialsByIdsRequest, opts ...grpc.CallOption) (*SerialMap, error)
152 // GetSerialsByRange gets serials within an index range
153 GetSerialsByRange(ctx context.Context, in *GetSerialsByRangeRequest, opts ...grpc.CallOption) (*SerialList, error)
154 // GetFullIdPubkeyBySerial gets full ID/Pubkey/Timestamp for a serial
155 GetFullIdPubkeyBySerial(ctx context.Context, in *GetFullIdPubkeyBySerialRequest, opts ...grpc.CallOption) (*IdPkTs, error)
156 // GetFullIdPubkeyBySerials gets full data for multiple serials
157 GetFullIdPubkeyBySerials(ctx context.Context, in *GetFullIdPubkeyBySerialsRequest, opts ...grpc.CallOption) (*IdPkTsList, error)
158 // DeleteEvent deletes an event by ID
159 DeleteEvent(ctx context.Context, in *DeleteEventRequest, opts ...grpc.CallOption) (*Empty, error)
160 // DeleteEventBySerial deletes an event by serial
161 DeleteEventBySerial(ctx context.Context, in *DeleteEventBySerialRequest, opts ...grpc.CallOption) (*Empty, error)
162 // DeleteExpired deletes events with expired expiration tags
163 DeleteExpired(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
164 // ProcessDelete processes a deletion event (NIP-09)
165 ProcessDelete(ctx context.Context, in *ProcessDeleteRequest, opts ...grpc.CallOption) (*Empty, error)
166 // CheckForDeleted checks if an event was deleted
167 CheckForDeleted(ctx context.Context, in *CheckForDeletedRequest, opts ...grpc.CallOption) (*Empty, error)
168 // Import imports events from a stream
169 Import(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[ImportChunk, ImportResponse], error)
170 // Export exports events to a stream
171 Export(ctx context.Context, in *ExportRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ExportChunk], error)
172 // ImportEventsFromStrings imports events from JSON strings
173 ImportEventsFromStrings(ctx context.Context, in *ImportEventsFromStringsRequest, opts ...grpc.CallOption) (*ImportResponse, error)
174 // GetRelayIdentitySecret gets the relay's secret key
175 GetRelayIdentitySecret(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetRelayIdentitySecretResponse, error)
176 // SetRelayIdentitySecret sets the relay's secret key
177 SetRelayIdentitySecret(ctx context.Context, in *SetRelayIdentitySecretRequest, opts ...grpc.CallOption) (*Empty, error)
178 // GetOrCreateRelayIdentitySecret gets or creates the relay's secret key
179 GetOrCreateRelayIdentitySecret(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetRelayIdentitySecretResponse, error)
180 // SetMarker sets a metadata marker
181 SetMarker(ctx context.Context, in *SetMarkerRequest, opts ...grpc.CallOption) (*Empty, error)
182 // GetMarker gets a metadata marker
183 GetMarker(ctx context.Context, in *GetMarkerRequest, opts ...grpc.CallOption) (*GetMarkerResponse, error)
184 // HasMarker checks if a marker exists
185 HasMarker(ctx context.Context, in *HasMarkerRequest, opts ...grpc.CallOption) (*HasMarkerResponse, error)
186 // DeleteMarker deletes a marker
187 DeleteMarker(ctx context.Context, in *DeleteMarkerRequest, opts ...grpc.CallOption) (*Empty, error)
188 // GetSubscription gets subscription info for a pubkey
189 GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error)
190 // IsSubscriptionActive checks if a subscription is active
191 IsSubscriptionActive(ctx context.Context, in *IsSubscriptionActiveRequest, opts ...grpc.CallOption) (*IsSubscriptionActiveResponse, error)
192 // ExtendSubscription extends a subscription by days
193 ExtendSubscription(ctx context.Context, in *ExtendSubscriptionRequest, opts ...grpc.CallOption) (*Empty, error)
194 // RecordPayment records a payment
195 RecordPayment(ctx context.Context, in *RecordPaymentRequest, opts ...grpc.CallOption) (*Empty, error)
196 // GetPaymentHistory gets payment history for a pubkey
197 GetPaymentHistory(ctx context.Context, in *GetPaymentHistoryRequest, opts ...grpc.CallOption) (*PaymentList, error)
198 // ExtendBlossomSubscription extends blossom storage subscription
199 ExtendBlossomSubscription(ctx context.Context, in *ExtendBlossomSubscriptionRequest, opts ...grpc.CallOption) (*Empty, error)
200 // GetBlossomStorageQuota gets blossom storage quota
201 GetBlossomStorageQuota(ctx context.Context, in *GetBlossomStorageQuotaRequest, opts ...grpc.CallOption) (*GetBlossomStorageQuotaResponse, error)
202 // IsFirstTimeUser checks if this is a first-time user
203 IsFirstTimeUser(ctx context.Context, in *IsFirstTimeUserRequest, opts ...grpc.CallOption) (*IsFirstTimeUserResponse, error)
204 // SavePaidSubscription saves or updates a paid subscription
205 SavePaidSubscription(ctx context.Context, in *PaidSubscriptionMsg, opts ...grpc.CallOption) (*Empty, error)
206 // GetPaidSubscription gets a paid subscription by pubkey hex
207 GetPaidSubscription(ctx context.Context, in *GetPaidSubscriptionRequest, opts ...grpc.CallOption) (*PaidSubscriptionMsg, error)
208 // DeletePaidSubscription deletes a paid subscription
209 DeletePaidSubscription(ctx context.Context, in *DeletePaidSubscriptionRequest, opts ...grpc.CallOption) (*Empty, error)
210 // ListPaidSubscriptions lists all paid subscriptions
211 ListPaidSubscriptions(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PaidSubscriptionList, error)
212 // ClaimAlias claims an email alias for a pubkey
213 ClaimAlias(ctx context.Context, in *ClaimAliasRequest, opts ...grpc.CallOption) (*Empty, error)
214 // GetAliasByPubkey gets the alias for a pubkey
215 GetAliasByPubkey(ctx context.Context, in *GetAliasByPubkeyRequest, opts ...grpc.CallOption) (*AliasResponse, error)
216 // GetPubkeyByAlias gets the pubkey for an alias
217 GetPubkeyByAlias(ctx context.Context, in *GetPubkeyByAliasRequest, opts ...grpc.CallOption) (*PubkeyResponse, error)
218 // IsAliasTaken checks if an alias is taken
219 IsAliasTaken(ctx context.Context, in *IsAliasTakenRequest, opts ...grpc.CallOption) (*IsAliasTakenResponse, error)
220 // AddNIP43Member adds a member via invite code
221 AddNIP43Member(ctx context.Context, in *AddNIP43MemberRequest, opts ...grpc.CallOption) (*Empty, error)
222 // RemoveNIP43Member removes a member
223 RemoveNIP43Member(ctx context.Context, in *RemoveNIP43MemberRequest, opts ...grpc.CallOption) (*Empty, error)
224 // IsNIP43Member checks if a pubkey is a member
225 IsNIP43Member(ctx context.Context, in *IsNIP43MemberRequest, opts ...grpc.CallOption) (*IsNIP43MemberResponse, error)
226 // GetNIP43Membership gets membership details
227 GetNIP43Membership(ctx context.Context, in *GetNIP43MembershipRequest, opts ...grpc.CallOption) (*NIP43Membership, error)
228 // GetAllNIP43Members gets all members
229 GetAllNIP43Members(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PubkeyList, error)
230 // StoreInviteCode stores an invite code with expiration
231 StoreInviteCode(ctx context.Context, in *StoreInviteCodeRequest, opts ...grpc.CallOption) (*Empty, error)
232 // ValidateInviteCode validates an invite code
233 ValidateInviteCode(ctx context.Context, in *ValidateInviteCodeRequest, opts ...grpc.CallOption) (*ValidateInviteCodeResponse, error)
234 // DeleteInviteCode deletes an invite code
235 DeleteInviteCode(ctx context.Context, in *DeleteInviteCodeRequest, opts ...grpc.CallOption) (*Empty, error)
236 // PublishNIP43MembershipEvent publishes a membership event
237 PublishNIP43MembershipEvent(ctx context.Context, in *PublishNIP43MembershipEventRequest, opts ...grpc.CallOption) (*Empty, error)
238 // GetCachedJSON gets cached JSON for a filter
239 GetCachedJSON(ctx context.Context, in *GetCachedJSONRequest, opts ...grpc.CallOption) (*GetCachedJSONResponse, error)
240 // CacheMarshaledJSON caches JSON for a filter
241 CacheMarshaledJSON(ctx context.Context, in *CacheMarshaledJSONRequest, opts ...grpc.CallOption) (*Empty, error)
242 // GetCachedEvents gets cached events for a filter
243 GetCachedEvents(ctx context.Context, in *GetCachedEventsRequest, opts ...grpc.CallOption) (*GetCachedEventsResponse, error)
244 // CacheEvents caches events for a filter
245 CacheEvents(ctx context.Context, in *CacheEventsRequest, opts ...grpc.CallOption) (*Empty, error)
246 // InvalidateQueryCache invalidates the entire query cache
247 InvalidateQueryCache(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
248 // RecordEventAccess records an access to an event
249 RecordEventAccess(ctx context.Context, in *RecordEventAccessRequest, opts ...grpc.CallOption) (*Empty, error)
250 // GetEventAccessInfo gets access info for an event
251 GetEventAccessInfo(ctx context.Context, in *GetEventAccessInfoRequest, opts ...grpc.CallOption) (*GetEventAccessInfoResponse, error)
252 // GetLeastAccessedEvents gets least accessed events for GC
253 GetLeastAccessedEvents(ctx context.Context, in *GetLeastAccessedEventsRequest, opts ...grpc.CallOption) (*SerialList, error)
254 // SaveBlob stores a blob with its metadata
255 SaveBlob(ctx context.Context, in *SaveBlobRequest, opts ...grpc.CallOption) (*Empty, error)
256 // SaveBlobMetadata stores only metadata for a blob whose file is already on disk
257 SaveBlobMetadata(ctx context.Context, in *SaveBlobMetadataRequest, opts ...grpc.CallOption) (*Empty, error)
258 // GetBlob retrieves blob data and metadata
259 GetBlob(ctx context.Context, in *GetBlobRequest, opts ...grpc.CallOption) (*GetBlobResponse, error)
260 // HasBlob checks if a blob exists
261 HasBlob(ctx context.Context, in *HasBlobRequest, opts ...grpc.CallOption) (*HasBlobResponse, error)
262 // DeleteBlob deletes a blob
263 DeleteBlob(ctx context.Context, in *DeleteBlobRequest, opts ...grpc.CallOption) (*Empty, error)
264 // ListBlobs lists blobs for a pubkey
265 ListBlobs(ctx context.Context, in *ListBlobsRequest, opts ...grpc.CallOption) (*ListBlobsResponse, error)
266 // GetBlobMetadata gets only metadata for a blob
267 GetBlobMetadata(ctx context.Context, in *GetBlobMetadataRequest, opts ...grpc.CallOption) (*BlobMetadata, error)
268 // GetTotalBlobStorageUsed gets total storage used by a pubkey in MB
269 GetTotalBlobStorageUsed(ctx context.Context, in *GetTotalBlobStorageUsedRequest, opts ...grpc.CallOption) (*GetTotalBlobStorageUsedResponse, error)
270 // SaveBlobReport stores a report for a blob (BUD-09)
271 SaveBlobReport(ctx context.Context, in *SaveBlobReportRequest, opts ...grpc.CallOption) (*Empty, error)
272 // ListAllBlobUserStats gets storage statistics for all users
273 ListAllBlobUserStats(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListAllBlobUserStatsResponse, error)
274 // ReconcileBlobMetadata scans the blossom directory and creates metadata for orphan blobs
275 ReconcileBlobMetadata(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ReconcileBlobMetadataResponse, error)
276 // ListAllBlobs returns all blob descriptors (for admin thumbnail generation)
277 ListAllBlobs(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListBlobsResponse, error)
278 // GetThumbnail retrieves a cached thumbnail by key
279 GetThumbnail(ctx context.Context, in *GetThumbnailRequest, opts ...grpc.CallOption) (*GetThumbnailResponse, error)
280 // SaveThumbnail stores a cached thumbnail
281 SaveThumbnail(ctx context.Context, in *SaveThumbnailRequest, opts ...grpc.CallOption) (*Empty, error)
282 // EventIdsBySerial gets event IDs by serial range
283 EventIdsBySerial(ctx context.Context, in *EventIdsBySerialRequest, opts ...grpc.CallOption) (*EventIdsBySerialResponse, error)
284 // RunMigrations runs database migrations
285 RunMigrations(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
286 // ExecuteCypherRead executes a read-only Cypher query against Neo4j
287 ExecuteCypherRead(ctx context.Context, in *CypherReadRequest, opts ...grpc.CallOption) (*CypherReadResponse, error)
288 }
289
290 type databaseServiceClient struct {
291 cc grpc.ClientConnInterface
292 }
293
294 func NewDatabaseServiceClient(cc grpc.ClientConnInterface) DatabaseServiceClient {
295 return &databaseServiceClient{cc}
296 }
297
298 func (c *databaseServiceClient) GetPath(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PathResponse, error) {
299 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
300 out := new(PathResponse)
301 err := c.cc.Invoke(ctx, DatabaseService_GetPath_FullMethodName, in, out, cOpts...)
302 if err != nil {
303 return nil, err
304 }
305 return out, nil
306 }
307
308 func (c *databaseServiceClient) Sync(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) {
309 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
310 out := new(Empty)
311 err := c.cc.Invoke(ctx, DatabaseService_Sync_FullMethodName, in, out, cOpts...)
312 if err != nil {
313 return nil, err
314 }
315 return out, nil
316 }
317
318 func (c *databaseServiceClient) Ready(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ReadyResponse, error) {
319 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
320 out := new(ReadyResponse)
321 err := c.cc.Invoke(ctx, DatabaseService_Ready_FullMethodName, in, out, cOpts...)
322 if err != nil {
323 return nil, err
324 }
325 return out, nil
326 }
327
328 func (c *databaseServiceClient) SetLogLevel(ctx context.Context, in *SetLogLevelRequest, opts ...grpc.CallOption) (*Empty, error) {
329 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
330 out := new(Empty)
331 err := c.cc.Invoke(ctx, DatabaseService_SetLogLevel_FullMethodName, in, out, cOpts...)
332 if err != nil {
333 return nil, err
334 }
335 return out, nil
336 }
337
338 func (c *databaseServiceClient) SaveEvent(ctx context.Context, in *SaveEventRequest, opts ...grpc.CallOption) (*SaveEventResponse, error) {
339 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
340 out := new(SaveEventResponse)
341 err := c.cc.Invoke(ctx, DatabaseService_SaveEvent_FullMethodName, in, out, cOpts...)
342 if err != nil {
343 return nil, err
344 }
345 return out, nil
346 }
347
348 func (c *databaseServiceClient) GetSerialsFromFilter(ctx context.Context, in *GetSerialsFromFilterRequest, opts ...grpc.CallOption) (*SerialList, error) {
349 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
350 out := new(SerialList)
351 err := c.cc.Invoke(ctx, DatabaseService_GetSerialsFromFilter_FullMethodName, in, out, cOpts...)
352 if err != nil {
353 return nil, err
354 }
355 return out, nil
356 }
357
358 func (c *databaseServiceClient) WouldReplaceEvent(ctx context.Context, in *WouldReplaceEventRequest, opts ...grpc.CallOption) (*WouldReplaceEventResponse, error) {
359 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
360 out := new(WouldReplaceEventResponse)
361 err := c.cc.Invoke(ctx, DatabaseService_WouldReplaceEvent_FullMethodName, in, out, cOpts...)
362 if err != nil {
363 return nil, err
364 }
365 return out, nil
366 }
367
368 func (c *databaseServiceClient) QueryEvents(ctx context.Context, in *QueryEventsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[EventBatch], error) {
369 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
370 stream, err := c.cc.NewStream(ctx, &DatabaseService_ServiceDesc.Streams[0], DatabaseService_QueryEvents_FullMethodName, cOpts...)
371 if err != nil {
372 return nil, err
373 }
374 x := &grpc.GenericClientStream[QueryEventsRequest, EventBatch]{ClientStream: stream}
375 if err := x.ClientStream.SendMsg(in); err != nil {
376 return nil, err
377 }
378 if err := x.ClientStream.CloseSend(); err != nil {
379 return nil, err
380 }
381 return x, nil
382 }
383
384 // This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
385 type DatabaseService_QueryEventsClient = grpc.ServerStreamingClient[EventBatch]
386
387 func (c *databaseServiceClient) QueryAllVersions(ctx context.Context, in *QueryEventsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[EventBatch], error) {
388 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
389 stream, err := c.cc.NewStream(ctx, &DatabaseService_ServiceDesc.Streams[1], DatabaseService_QueryAllVersions_FullMethodName, cOpts...)
390 if err != nil {
391 return nil, err
392 }
393 x := &grpc.GenericClientStream[QueryEventsRequest, EventBatch]{ClientStream: stream}
394 if err := x.ClientStream.SendMsg(in); err != nil {
395 return nil, err
396 }
397 if err := x.ClientStream.CloseSend(); err != nil {
398 return nil, err
399 }
400 return x, nil
401 }
402
403 // This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
404 type DatabaseService_QueryAllVersionsClient = grpc.ServerStreamingClient[EventBatch]
405
406 func (c *databaseServiceClient) QueryEventsWithOptions(ctx context.Context, in *QueryEventsWithOptionsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[EventBatch], error) {
407 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
408 stream, err := c.cc.NewStream(ctx, &DatabaseService_ServiceDesc.Streams[2], DatabaseService_QueryEventsWithOptions_FullMethodName, cOpts...)
409 if err != nil {
410 return nil, err
411 }
412 x := &grpc.GenericClientStream[QueryEventsWithOptionsRequest, EventBatch]{ClientStream: stream}
413 if err := x.ClientStream.SendMsg(in); err != nil {
414 return nil, err
415 }
416 if err := x.ClientStream.CloseSend(); err != nil {
417 return nil, err
418 }
419 return x, nil
420 }
421
422 // This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
423 type DatabaseService_QueryEventsWithOptionsClient = grpc.ServerStreamingClient[EventBatch]
424
425 func (c *databaseServiceClient) QueryDeleteEventsByTargetId(ctx context.Context, in *QueryDeleteEventsByTargetIdRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[EventBatch], error) {
426 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
427 stream, err := c.cc.NewStream(ctx, &DatabaseService_ServiceDesc.Streams[3], DatabaseService_QueryDeleteEventsByTargetId_FullMethodName, cOpts...)
428 if err != nil {
429 return nil, err
430 }
431 x := &grpc.GenericClientStream[QueryDeleteEventsByTargetIdRequest, EventBatch]{ClientStream: stream}
432 if err := x.ClientStream.SendMsg(in); err != nil {
433 return nil, err
434 }
435 if err := x.ClientStream.CloseSend(); err != nil {
436 return nil, err
437 }
438 return x, nil
439 }
440
441 // This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
442 type DatabaseService_QueryDeleteEventsByTargetIdClient = grpc.ServerStreamingClient[EventBatch]
443
444 func (c *databaseServiceClient) QueryForSerials(ctx context.Context, in *QueryEventsRequest, opts ...grpc.CallOption) (*SerialList, error) {
445 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
446 out := new(SerialList)
447 err := c.cc.Invoke(ctx, DatabaseService_QueryForSerials_FullMethodName, in, out, cOpts...)
448 if err != nil {
449 return nil, err
450 }
451 return out, nil
452 }
453
454 func (c *databaseServiceClient) QueryForIds(ctx context.Context, in *QueryEventsRequest, opts ...grpc.CallOption) (*IdPkTsList, error) {
455 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
456 out := new(IdPkTsList)
457 err := c.cc.Invoke(ctx, DatabaseService_QueryForIds_FullMethodName, in, out, cOpts...)
458 if err != nil {
459 return nil, err
460 }
461 return out, nil
462 }
463
464 func (c *databaseServiceClient) CountEvents(ctx context.Context, in *QueryEventsRequest, opts ...grpc.CallOption) (*CountEventsResponse, error) {
465 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
466 out := new(CountEventsResponse)
467 err := c.cc.Invoke(ctx, DatabaseService_CountEvents_FullMethodName, in, out, cOpts...)
468 if err != nil {
469 return nil, err
470 }
471 return out, nil
472 }
473
474 func (c *databaseServiceClient) FetchEventBySerial(ctx context.Context, in *FetchEventBySerialRequest, opts ...grpc.CallOption) (*FetchEventBySerialResponse, error) {
475 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
476 out := new(FetchEventBySerialResponse)
477 err := c.cc.Invoke(ctx, DatabaseService_FetchEventBySerial_FullMethodName, in, out, cOpts...)
478 if err != nil {
479 return nil, err
480 }
481 return out, nil
482 }
483
484 func (c *databaseServiceClient) FetchEventsBySerials(ctx context.Context, in *FetchEventsBySerialRequest, opts ...grpc.CallOption) (*EventMap, error) {
485 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
486 out := new(EventMap)
487 err := c.cc.Invoke(ctx, DatabaseService_FetchEventsBySerials_FullMethodName, in, out, cOpts...)
488 if err != nil {
489 return nil, err
490 }
491 return out, nil
492 }
493
494 func (c *databaseServiceClient) GetSerialById(ctx context.Context, in *GetSerialByIdRequest, opts ...grpc.CallOption) (*GetSerialByIdResponse, error) {
495 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
496 out := new(GetSerialByIdResponse)
497 err := c.cc.Invoke(ctx, DatabaseService_GetSerialById_FullMethodName, in, out, cOpts...)
498 if err != nil {
499 return nil, err
500 }
501 return out, nil
502 }
503
504 func (c *databaseServiceClient) GetSerialsByIds(ctx context.Context, in *GetSerialsByIdsRequest, opts ...grpc.CallOption) (*SerialMap, error) {
505 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
506 out := new(SerialMap)
507 err := c.cc.Invoke(ctx, DatabaseService_GetSerialsByIds_FullMethodName, in, out, cOpts...)
508 if err != nil {
509 return nil, err
510 }
511 return out, nil
512 }
513
514 func (c *databaseServiceClient) GetSerialsByRange(ctx context.Context, in *GetSerialsByRangeRequest, opts ...grpc.CallOption) (*SerialList, error) {
515 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
516 out := new(SerialList)
517 err := c.cc.Invoke(ctx, DatabaseService_GetSerialsByRange_FullMethodName, in, out, cOpts...)
518 if err != nil {
519 return nil, err
520 }
521 return out, nil
522 }
523
524 func (c *databaseServiceClient) GetFullIdPubkeyBySerial(ctx context.Context, in *GetFullIdPubkeyBySerialRequest, opts ...grpc.CallOption) (*IdPkTs, error) {
525 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
526 out := new(IdPkTs)
527 err := c.cc.Invoke(ctx, DatabaseService_GetFullIdPubkeyBySerial_FullMethodName, in, out, cOpts...)
528 if err != nil {
529 return nil, err
530 }
531 return out, nil
532 }
533
534 func (c *databaseServiceClient) GetFullIdPubkeyBySerials(ctx context.Context, in *GetFullIdPubkeyBySerialsRequest, opts ...grpc.CallOption) (*IdPkTsList, error) {
535 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
536 out := new(IdPkTsList)
537 err := c.cc.Invoke(ctx, DatabaseService_GetFullIdPubkeyBySerials_FullMethodName, in, out, cOpts...)
538 if err != nil {
539 return nil, err
540 }
541 return out, nil
542 }
543
544 func (c *databaseServiceClient) DeleteEvent(ctx context.Context, in *DeleteEventRequest, opts ...grpc.CallOption) (*Empty, error) {
545 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
546 out := new(Empty)
547 err := c.cc.Invoke(ctx, DatabaseService_DeleteEvent_FullMethodName, in, out, cOpts...)
548 if err != nil {
549 return nil, err
550 }
551 return out, nil
552 }
553
554 func (c *databaseServiceClient) DeleteEventBySerial(ctx context.Context, in *DeleteEventBySerialRequest, opts ...grpc.CallOption) (*Empty, error) {
555 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
556 out := new(Empty)
557 err := c.cc.Invoke(ctx, DatabaseService_DeleteEventBySerial_FullMethodName, in, out, cOpts...)
558 if err != nil {
559 return nil, err
560 }
561 return out, nil
562 }
563
564 func (c *databaseServiceClient) DeleteExpired(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) {
565 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
566 out := new(Empty)
567 err := c.cc.Invoke(ctx, DatabaseService_DeleteExpired_FullMethodName, in, out, cOpts...)
568 if err != nil {
569 return nil, err
570 }
571 return out, nil
572 }
573
574 func (c *databaseServiceClient) ProcessDelete(ctx context.Context, in *ProcessDeleteRequest, opts ...grpc.CallOption) (*Empty, error) {
575 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
576 out := new(Empty)
577 err := c.cc.Invoke(ctx, DatabaseService_ProcessDelete_FullMethodName, in, out, cOpts...)
578 if err != nil {
579 return nil, err
580 }
581 return out, nil
582 }
583
584 func (c *databaseServiceClient) CheckForDeleted(ctx context.Context, in *CheckForDeletedRequest, opts ...grpc.CallOption) (*Empty, error) {
585 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
586 out := new(Empty)
587 err := c.cc.Invoke(ctx, DatabaseService_CheckForDeleted_FullMethodName, in, out, cOpts...)
588 if err != nil {
589 return nil, err
590 }
591 return out, nil
592 }
593
594 func (c *databaseServiceClient) Import(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[ImportChunk, ImportResponse], error) {
595 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
596 stream, err := c.cc.NewStream(ctx, &DatabaseService_ServiceDesc.Streams[4], DatabaseService_Import_FullMethodName, cOpts...)
597 if err != nil {
598 return nil, err
599 }
600 x := &grpc.GenericClientStream[ImportChunk, ImportResponse]{ClientStream: stream}
601 return x, nil
602 }
603
604 // This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
605 type DatabaseService_ImportClient = grpc.ClientStreamingClient[ImportChunk, ImportResponse]
606
607 func (c *databaseServiceClient) Export(ctx context.Context, in *ExportRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ExportChunk], error) {
608 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
609 stream, err := c.cc.NewStream(ctx, &DatabaseService_ServiceDesc.Streams[5], DatabaseService_Export_FullMethodName, cOpts...)
610 if err != nil {
611 return nil, err
612 }
613 x := &grpc.GenericClientStream[ExportRequest, ExportChunk]{ClientStream: stream}
614 if err := x.ClientStream.SendMsg(in); err != nil {
615 return nil, err
616 }
617 if err := x.ClientStream.CloseSend(); err != nil {
618 return nil, err
619 }
620 return x, nil
621 }
622
623 // This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
624 type DatabaseService_ExportClient = grpc.ServerStreamingClient[ExportChunk]
625
626 func (c *databaseServiceClient) ImportEventsFromStrings(ctx context.Context, in *ImportEventsFromStringsRequest, opts ...grpc.CallOption) (*ImportResponse, error) {
627 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
628 out := new(ImportResponse)
629 err := c.cc.Invoke(ctx, DatabaseService_ImportEventsFromStrings_FullMethodName, in, out, cOpts...)
630 if err != nil {
631 return nil, err
632 }
633 return out, nil
634 }
635
636 func (c *databaseServiceClient) GetRelayIdentitySecret(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetRelayIdentitySecretResponse, error) {
637 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
638 out := new(GetRelayIdentitySecretResponse)
639 err := c.cc.Invoke(ctx, DatabaseService_GetRelayIdentitySecret_FullMethodName, in, out, cOpts...)
640 if err != nil {
641 return nil, err
642 }
643 return out, nil
644 }
645
646 func (c *databaseServiceClient) SetRelayIdentitySecret(ctx context.Context, in *SetRelayIdentitySecretRequest, opts ...grpc.CallOption) (*Empty, error) {
647 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
648 out := new(Empty)
649 err := c.cc.Invoke(ctx, DatabaseService_SetRelayIdentitySecret_FullMethodName, in, out, cOpts...)
650 if err != nil {
651 return nil, err
652 }
653 return out, nil
654 }
655
656 func (c *databaseServiceClient) GetOrCreateRelayIdentitySecret(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetRelayIdentitySecretResponse, error) {
657 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
658 out := new(GetRelayIdentitySecretResponse)
659 err := c.cc.Invoke(ctx, DatabaseService_GetOrCreateRelayIdentitySecret_FullMethodName, in, out, cOpts...)
660 if err != nil {
661 return nil, err
662 }
663 return out, nil
664 }
665
666 func (c *databaseServiceClient) SetMarker(ctx context.Context, in *SetMarkerRequest, opts ...grpc.CallOption) (*Empty, error) {
667 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
668 out := new(Empty)
669 err := c.cc.Invoke(ctx, DatabaseService_SetMarker_FullMethodName, in, out, cOpts...)
670 if err != nil {
671 return nil, err
672 }
673 return out, nil
674 }
675
676 func (c *databaseServiceClient) GetMarker(ctx context.Context, in *GetMarkerRequest, opts ...grpc.CallOption) (*GetMarkerResponse, error) {
677 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
678 out := new(GetMarkerResponse)
679 err := c.cc.Invoke(ctx, DatabaseService_GetMarker_FullMethodName, in, out, cOpts...)
680 if err != nil {
681 return nil, err
682 }
683 return out, nil
684 }
685
686 func (c *databaseServiceClient) HasMarker(ctx context.Context, in *HasMarkerRequest, opts ...grpc.CallOption) (*HasMarkerResponse, error) {
687 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
688 out := new(HasMarkerResponse)
689 err := c.cc.Invoke(ctx, DatabaseService_HasMarker_FullMethodName, in, out, cOpts...)
690 if err != nil {
691 return nil, err
692 }
693 return out, nil
694 }
695
696 func (c *databaseServiceClient) DeleteMarker(ctx context.Context, in *DeleteMarkerRequest, opts ...grpc.CallOption) (*Empty, error) {
697 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
698 out := new(Empty)
699 err := c.cc.Invoke(ctx, DatabaseService_DeleteMarker_FullMethodName, in, out, cOpts...)
700 if err != nil {
701 return nil, err
702 }
703 return out, nil
704 }
705
706 func (c *databaseServiceClient) GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error) {
707 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
708 out := new(Subscription)
709 err := c.cc.Invoke(ctx, DatabaseService_GetSubscription_FullMethodName, in, out, cOpts...)
710 if err != nil {
711 return nil, err
712 }
713 return out, nil
714 }
715
716 func (c *databaseServiceClient) IsSubscriptionActive(ctx context.Context, in *IsSubscriptionActiveRequest, opts ...grpc.CallOption) (*IsSubscriptionActiveResponse, error) {
717 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
718 out := new(IsSubscriptionActiveResponse)
719 err := c.cc.Invoke(ctx, DatabaseService_IsSubscriptionActive_FullMethodName, in, out, cOpts...)
720 if err != nil {
721 return nil, err
722 }
723 return out, nil
724 }
725
726 func (c *databaseServiceClient) ExtendSubscription(ctx context.Context, in *ExtendSubscriptionRequest, opts ...grpc.CallOption) (*Empty, error) {
727 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
728 out := new(Empty)
729 err := c.cc.Invoke(ctx, DatabaseService_ExtendSubscription_FullMethodName, in, out, cOpts...)
730 if err != nil {
731 return nil, err
732 }
733 return out, nil
734 }
735
736 func (c *databaseServiceClient) RecordPayment(ctx context.Context, in *RecordPaymentRequest, opts ...grpc.CallOption) (*Empty, error) {
737 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
738 out := new(Empty)
739 err := c.cc.Invoke(ctx, DatabaseService_RecordPayment_FullMethodName, in, out, cOpts...)
740 if err != nil {
741 return nil, err
742 }
743 return out, nil
744 }
745
746 func (c *databaseServiceClient) GetPaymentHistory(ctx context.Context, in *GetPaymentHistoryRequest, opts ...grpc.CallOption) (*PaymentList, error) {
747 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
748 out := new(PaymentList)
749 err := c.cc.Invoke(ctx, DatabaseService_GetPaymentHistory_FullMethodName, in, out, cOpts...)
750 if err != nil {
751 return nil, err
752 }
753 return out, nil
754 }
755
756 func (c *databaseServiceClient) ExtendBlossomSubscription(ctx context.Context, in *ExtendBlossomSubscriptionRequest, opts ...grpc.CallOption) (*Empty, error) {
757 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
758 out := new(Empty)
759 err := c.cc.Invoke(ctx, DatabaseService_ExtendBlossomSubscription_FullMethodName, in, out, cOpts...)
760 if err != nil {
761 return nil, err
762 }
763 return out, nil
764 }
765
766 func (c *databaseServiceClient) GetBlossomStorageQuota(ctx context.Context, in *GetBlossomStorageQuotaRequest, opts ...grpc.CallOption) (*GetBlossomStorageQuotaResponse, error) {
767 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
768 out := new(GetBlossomStorageQuotaResponse)
769 err := c.cc.Invoke(ctx, DatabaseService_GetBlossomStorageQuota_FullMethodName, in, out, cOpts...)
770 if err != nil {
771 return nil, err
772 }
773 return out, nil
774 }
775
776 func (c *databaseServiceClient) IsFirstTimeUser(ctx context.Context, in *IsFirstTimeUserRequest, opts ...grpc.CallOption) (*IsFirstTimeUserResponse, error) {
777 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
778 out := new(IsFirstTimeUserResponse)
779 err := c.cc.Invoke(ctx, DatabaseService_IsFirstTimeUser_FullMethodName, in, out, cOpts...)
780 if err != nil {
781 return nil, err
782 }
783 return out, nil
784 }
785
786 func (c *databaseServiceClient) SavePaidSubscription(ctx context.Context, in *PaidSubscriptionMsg, opts ...grpc.CallOption) (*Empty, error) {
787 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
788 out := new(Empty)
789 err := c.cc.Invoke(ctx, DatabaseService_SavePaidSubscription_FullMethodName, in, out, cOpts...)
790 if err != nil {
791 return nil, err
792 }
793 return out, nil
794 }
795
796 func (c *databaseServiceClient) GetPaidSubscription(ctx context.Context, in *GetPaidSubscriptionRequest, opts ...grpc.CallOption) (*PaidSubscriptionMsg, error) {
797 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
798 out := new(PaidSubscriptionMsg)
799 err := c.cc.Invoke(ctx, DatabaseService_GetPaidSubscription_FullMethodName, in, out, cOpts...)
800 if err != nil {
801 return nil, err
802 }
803 return out, nil
804 }
805
806 func (c *databaseServiceClient) DeletePaidSubscription(ctx context.Context, in *DeletePaidSubscriptionRequest, opts ...grpc.CallOption) (*Empty, error) {
807 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
808 out := new(Empty)
809 err := c.cc.Invoke(ctx, DatabaseService_DeletePaidSubscription_FullMethodName, in, out, cOpts...)
810 if err != nil {
811 return nil, err
812 }
813 return out, nil
814 }
815
816 func (c *databaseServiceClient) ListPaidSubscriptions(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PaidSubscriptionList, error) {
817 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
818 out := new(PaidSubscriptionList)
819 err := c.cc.Invoke(ctx, DatabaseService_ListPaidSubscriptions_FullMethodName, in, out, cOpts...)
820 if err != nil {
821 return nil, err
822 }
823 return out, nil
824 }
825
826 func (c *databaseServiceClient) ClaimAlias(ctx context.Context, in *ClaimAliasRequest, opts ...grpc.CallOption) (*Empty, error) {
827 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
828 out := new(Empty)
829 err := c.cc.Invoke(ctx, DatabaseService_ClaimAlias_FullMethodName, in, out, cOpts...)
830 if err != nil {
831 return nil, err
832 }
833 return out, nil
834 }
835
836 func (c *databaseServiceClient) GetAliasByPubkey(ctx context.Context, in *GetAliasByPubkeyRequest, opts ...grpc.CallOption) (*AliasResponse, error) {
837 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
838 out := new(AliasResponse)
839 err := c.cc.Invoke(ctx, DatabaseService_GetAliasByPubkey_FullMethodName, in, out, cOpts...)
840 if err != nil {
841 return nil, err
842 }
843 return out, nil
844 }
845
846 func (c *databaseServiceClient) GetPubkeyByAlias(ctx context.Context, in *GetPubkeyByAliasRequest, opts ...grpc.CallOption) (*PubkeyResponse, error) {
847 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
848 out := new(PubkeyResponse)
849 err := c.cc.Invoke(ctx, DatabaseService_GetPubkeyByAlias_FullMethodName, in, out, cOpts...)
850 if err != nil {
851 return nil, err
852 }
853 return out, nil
854 }
855
856 func (c *databaseServiceClient) IsAliasTaken(ctx context.Context, in *IsAliasTakenRequest, opts ...grpc.CallOption) (*IsAliasTakenResponse, error) {
857 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
858 out := new(IsAliasTakenResponse)
859 err := c.cc.Invoke(ctx, DatabaseService_IsAliasTaken_FullMethodName, in, out, cOpts...)
860 if err != nil {
861 return nil, err
862 }
863 return out, nil
864 }
865
866 func (c *databaseServiceClient) AddNIP43Member(ctx context.Context, in *AddNIP43MemberRequest, opts ...grpc.CallOption) (*Empty, error) {
867 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
868 out := new(Empty)
869 err := c.cc.Invoke(ctx, DatabaseService_AddNIP43Member_FullMethodName, in, out, cOpts...)
870 if err != nil {
871 return nil, err
872 }
873 return out, nil
874 }
875
876 func (c *databaseServiceClient) RemoveNIP43Member(ctx context.Context, in *RemoveNIP43MemberRequest, opts ...grpc.CallOption) (*Empty, error) {
877 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
878 out := new(Empty)
879 err := c.cc.Invoke(ctx, DatabaseService_RemoveNIP43Member_FullMethodName, in, out, cOpts...)
880 if err != nil {
881 return nil, err
882 }
883 return out, nil
884 }
885
886 func (c *databaseServiceClient) IsNIP43Member(ctx context.Context, in *IsNIP43MemberRequest, opts ...grpc.CallOption) (*IsNIP43MemberResponse, error) {
887 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
888 out := new(IsNIP43MemberResponse)
889 err := c.cc.Invoke(ctx, DatabaseService_IsNIP43Member_FullMethodName, in, out, cOpts...)
890 if err != nil {
891 return nil, err
892 }
893 return out, nil
894 }
895
896 func (c *databaseServiceClient) GetNIP43Membership(ctx context.Context, in *GetNIP43MembershipRequest, opts ...grpc.CallOption) (*NIP43Membership, error) {
897 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
898 out := new(NIP43Membership)
899 err := c.cc.Invoke(ctx, DatabaseService_GetNIP43Membership_FullMethodName, in, out, cOpts...)
900 if err != nil {
901 return nil, err
902 }
903 return out, nil
904 }
905
906 func (c *databaseServiceClient) GetAllNIP43Members(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PubkeyList, error) {
907 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
908 out := new(PubkeyList)
909 err := c.cc.Invoke(ctx, DatabaseService_GetAllNIP43Members_FullMethodName, in, out, cOpts...)
910 if err != nil {
911 return nil, err
912 }
913 return out, nil
914 }
915
916 func (c *databaseServiceClient) StoreInviteCode(ctx context.Context, in *StoreInviteCodeRequest, opts ...grpc.CallOption) (*Empty, error) {
917 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
918 out := new(Empty)
919 err := c.cc.Invoke(ctx, DatabaseService_StoreInviteCode_FullMethodName, in, out, cOpts...)
920 if err != nil {
921 return nil, err
922 }
923 return out, nil
924 }
925
926 func (c *databaseServiceClient) ValidateInviteCode(ctx context.Context, in *ValidateInviteCodeRequest, opts ...grpc.CallOption) (*ValidateInviteCodeResponse, error) {
927 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
928 out := new(ValidateInviteCodeResponse)
929 err := c.cc.Invoke(ctx, DatabaseService_ValidateInviteCode_FullMethodName, in, out, cOpts...)
930 if err != nil {
931 return nil, err
932 }
933 return out, nil
934 }
935
936 func (c *databaseServiceClient) DeleteInviteCode(ctx context.Context, in *DeleteInviteCodeRequest, opts ...grpc.CallOption) (*Empty, error) {
937 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
938 out := new(Empty)
939 err := c.cc.Invoke(ctx, DatabaseService_DeleteInviteCode_FullMethodName, in, out, cOpts...)
940 if err != nil {
941 return nil, err
942 }
943 return out, nil
944 }
945
946 func (c *databaseServiceClient) PublishNIP43MembershipEvent(ctx context.Context, in *PublishNIP43MembershipEventRequest, opts ...grpc.CallOption) (*Empty, error) {
947 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
948 out := new(Empty)
949 err := c.cc.Invoke(ctx, DatabaseService_PublishNIP43MembershipEvent_FullMethodName, in, out, cOpts...)
950 if err != nil {
951 return nil, err
952 }
953 return out, nil
954 }
955
956 func (c *databaseServiceClient) GetCachedJSON(ctx context.Context, in *GetCachedJSONRequest, opts ...grpc.CallOption) (*GetCachedJSONResponse, error) {
957 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
958 out := new(GetCachedJSONResponse)
959 err := c.cc.Invoke(ctx, DatabaseService_GetCachedJSON_FullMethodName, in, out, cOpts...)
960 if err != nil {
961 return nil, err
962 }
963 return out, nil
964 }
965
966 func (c *databaseServiceClient) CacheMarshaledJSON(ctx context.Context, in *CacheMarshaledJSONRequest, opts ...grpc.CallOption) (*Empty, error) {
967 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
968 out := new(Empty)
969 err := c.cc.Invoke(ctx, DatabaseService_CacheMarshaledJSON_FullMethodName, in, out, cOpts...)
970 if err != nil {
971 return nil, err
972 }
973 return out, nil
974 }
975
976 func (c *databaseServiceClient) GetCachedEvents(ctx context.Context, in *GetCachedEventsRequest, opts ...grpc.CallOption) (*GetCachedEventsResponse, error) {
977 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
978 out := new(GetCachedEventsResponse)
979 err := c.cc.Invoke(ctx, DatabaseService_GetCachedEvents_FullMethodName, in, out, cOpts...)
980 if err != nil {
981 return nil, err
982 }
983 return out, nil
984 }
985
986 func (c *databaseServiceClient) CacheEvents(ctx context.Context, in *CacheEventsRequest, opts ...grpc.CallOption) (*Empty, error) {
987 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
988 out := new(Empty)
989 err := c.cc.Invoke(ctx, DatabaseService_CacheEvents_FullMethodName, in, out, cOpts...)
990 if err != nil {
991 return nil, err
992 }
993 return out, nil
994 }
995
996 func (c *databaseServiceClient) InvalidateQueryCache(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) {
997 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
998 out := new(Empty)
999 err := c.cc.Invoke(ctx, DatabaseService_InvalidateQueryCache_FullMethodName, in, out, cOpts...)
1000 if err != nil {
1001 return nil, err
1002 }
1003 return out, nil
1004 }
1005
1006 func (c *databaseServiceClient) RecordEventAccess(ctx context.Context, in *RecordEventAccessRequest, opts ...grpc.CallOption) (*Empty, error) {
1007 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
1008 out := new(Empty)
1009 err := c.cc.Invoke(ctx, DatabaseService_RecordEventAccess_FullMethodName, in, out, cOpts...)
1010 if err != nil {
1011 return nil, err
1012 }
1013 return out, nil
1014 }
1015
1016 func (c *databaseServiceClient) GetEventAccessInfo(ctx context.Context, in *GetEventAccessInfoRequest, opts ...grpc.CallOption) (*GetEventAccessInfoResponse, error) {
1017 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
1018 out := new(GetEventAccessInfoResponse)
1019 err := c.cc.Invoke(ctx, DatabaseService_GetEventAccessInfo_FullMethodName, in, out, cOpts...)
1020 if err != nil {
1021 return nil, err
1022 }
1023 return out, nil
1024 }
1025
1026 func (c *databaseServiceClient) GetLeastAccessedEvents(ctx context.Context, in *GetLeastAccessedEventsRequest, opts ...grpc.CallOption) (*SerialList, error) {
1027 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
1028 out := new(SerialList)
1029 err := c.cc.Invoke(ctx, DatabaseService_GetLeastAccessedEvents_FullMethodName, in, out, cOpts...)
1030 if err != nil {
1031 return nil, err
1032 }
1033 return out, nil
1034 }
1035
1036 func (c *databaseServiceClient) SaveBlob(ctx context.Context, in *SaveBlobRequest, opts ...grpc.CallOption) (*Empty, error) {
1037 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
1038 out := new(Empty)
1039 err := c.cc.Invoke(ctx, DatabaseService_SaveBlob_FullMethodName, in, out, cOpts...)
1040 if err != nil {
1041 return nil, err
1042 }
1043 return out, nil
1044 }
1045
1046 func (c *databaseServiceClient) SaveBlobMetadata(ctx context.Context, in *SaveBlobMetadataRequest, opts ...grpc.CallOption) (*Empty, error) {
1047 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
1048 out := new(Empty)
1049 err := c.cc.Invoke(ctx, DatabaseService_SaveBlobMetadata_FullMethodName, in, out, cOpts...)
1050 if err != nil {
1051 return nil, err
1052 }
1053 return out, nil
1054 }
1055
1056 func (c *databaseServiceClient) GetBlob(ctx context.Context, in *GetBlobRequest, opts ...grpc.CallOption) (*GetBlobResponse, error) {
1057 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
1058 out := new(GetBlobResponse)
1059 err := c.cc.Invoke(ctx, DatabaseService_GetBlob_FullMethodName, in, out, cOpts...)
1060 if err != nil {
1061 return nil, err
1062 }
1063 return out, nil
1064 }
1065
1066 func (c *databaseServiceClient) HasBlob(ctx context.Context, in *HasBlobRequest, opts ...grpc.CallOption) (*HasBlobResponse, error) {
1067 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
1068 out := new(HasBlobResponse)
1069 err := c.cc.Invoke(ctx, DatabaseService_HasBlob_FullMethodName, in, out, cOpts...)
1070 if err != nil {
1071 return nil, err
1072 }
1073 return out, nil
1074 }
1075
1076 func (c *databaseServiceClient) DeleteBlob(ctx context.Context, in *DeleteBlobRequest, opts ...grpc.CallOption) (*Empty, error) {
1077 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
1078 out := new(Empty)
1079 err := c.cc.Invoke(ctx, DatabaseService_DeleteBlob_FullMethodName, in, out, cOpts...)
1080 if err != nil {
1081 return nil, err
1082 }
1083 return out, nil
1084 }
1085
1086 func (c *databaseServiceClient) ListBlobs(ctx context.Context, in *ListBlobsRequest, opts ...grpc.CallOption) (*ListBlobsResponse, error) {
1087 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
1088 out := new(ListBlobsResponse)
1089 err := c.cc.Invoke(ctx, DatabaseService_ListBlobs_FullMethodName, in, out, cOpts...)
1090 if err != nil {
1091 return nil, err
1092 }
1093 return out, nil
1094 }
1095
1096 func (c *databaseServiceClient) GetBlobMetadata(ctx context.Context, in *GetBlobMetadataRequest, opts ...grpc.CallOption) (*BlobMetadata, error) {
1097 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
1098 out := new(BlobMetadata)
1099 err := c.cc.Invoke(ctx, DatabaseService_GetBlobMetadata_FullMethodName, in, out, cOpts...)
1100 if err != nil {
1101 return nil, err
1102 }
1103 return out, nil
1104 }
1105
1106 func (c *databaseServiceClient) GetTotalBlobStorageUsed(ctx context.Context, in *GetTotalBlobStorageUsedRequest, opts ...grpc.CallOption) (*GetTotalBlobStorageUsedResponse, error) {
1107 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
1108 out := new(GetTotalBlobStorageUsedResponse)
1109 err := c.cc.Invoke(ctx, DatabaseService_GetTotalBlobStorageUsed_FullMethodName, in, out, cOpts...)
1110 if err != nil {
1111 return nil, err
1112 }
1113 return out, nil
1114 }
1115
1116 func (c *databaseServiceClient) SaveBlobReport(ctx context.Context, in *SaveBlobReportRequest, opts ...grpc.CallOption) (*Empty, error) {
1117 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
1118 out := new(Empty)
1119 err := c.cc.Invoke(ctx, DatabaseService_SaveBlobReport_FullMethodName, in, out, cOpts...)
1120 if err != nil {
1121 return nil, err
1122 }
1123 return out, nil
1124 }
1125
1126 func (c *databaseServiceClient) ListAllBlobUserStats(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListAllBlobUserStatsResponse, error) {
1127 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
1128 out := new(ListAllBlobUserStatsResponse)
1129 err := c.cc.Invoke(ctx, DatabaseService_ListAllBlobUserStats_FullMethodName, in, out, cOpts...)
1130 if err != nil {
1131 return nil, err
1132 }
1133 return out, nil
1134 }
1135
1136 func (c *databaseServiceClient) ReconcileBlobMetadata(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ReconcileBlobMetadataResponse, error) {
1137 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
1138 out := new(ReconcileBlobMetadataResponse)
1139 err := c.cc.Invoke(ctx, DatabaseService_ReconcileBlobMetadata_FullMethodName, in, out, cOpts...)
1140 if err != nil {
1141 return nil, err
1142 }
1143 return out, nil
1144 }
1145
1146 func (c *databaseServiceClient) ListAllBlobs(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListBlobsResponse, error) {
1147 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
1148 out := new(ListBlobsResponse)
1149 err := c.cc.Invoke(ctx, DatabaseService_ListAllBlobs_FullMethodName, in, out, cOpts...)
1150 if err != nil {
1151 return nil, err
1152 }
1153 return out, nil
1154 }
1155
1156 func (c *databaseServiceClient) GetThumbnail(ctx context.Context, in *GetThumbnailRequest, opts ...grpc.CallOption) (*GetThumbnailResponse, error) {
1157 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
1158 out := new(GetThumbnailResponse)
1159 err := c.cc.Invoke(ctx, DatabaseService_GetThumbnail_FullMethodName, in, out, cOpts...)
1160 if err != nil {
1161 return nil, err
1162 }
1163 return out, nil
1164 }
1165
1166 func (c *databaseServiceClient) SaveThumbnail(ctx context.Context, in *SaveThumbnailRequest, opts ...grpc.CallOption) (*Empty, error) {
1167 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
1168 out := new(Empty)
1169 err := c.cc.Invoke(ctx, DatabaseService_SaveThumbnail_FullMethodName, in, out, cOpts...)
1170 if err != nil {
1171 return nil, err
1172 }
1173 return out, nil
1174 }
1175
1176 func (c *databaseServiceClient) EventIdsBySerial(ctx context.Context, in *EventIdsBySerialRequest, opts ...grpc.CallOption) (*EventIdsBySerialResponse, error) {
1177 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
1178 out := new(EventIdsBySerialResponse)
1179 err := c.cc.Invoke(ctx, DatabaseService_EventIdsBySerial_FullMethodName, in, out, cOpts...)
1180 if err != nil {
1181 return nil, err
1182 }
1183 return out, nil
1184 }
1185
1186 func (c *databaseServiceClient) RunMigrations(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) {
1187 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
1188 out := new(Empty)
1189 err := c.cc.Invoke(ctx, DatabaseService_RunMigrations_FullMethodName, in, out, cOpts...)
1190 if err != nil {
1191 return nil, err
1192 }
1193 return out, nil
1194 }
1195
1196 func (c *databaseServiceClient) ExecuteCypherRead(ctx context.Context, in *CypherReadRequest, opts ...grpc.CallOption) (*CypherReadResponse, error) {
1197 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
1198 out := new(CypherReadResponse)
1199 err := c.cc.Invoke(ctx, DatabaseService_ExecuteCypherRead_FullMethodName, in, out, cOpts...)
1200 if err != nil {
1201 return nil, err
1202 }
1203 return out, nil
1204 }
1205
1206 // DatabaseServiceServer is the server API for DatabaseService service.
1207 // All implementations must embed UnimplementedDatabaseServiceServer
1208 // for forward compatibility.
1209 //
1210 // DatabaseService provides gRPC access to the ORLY database
1211 type DatabaseServiceServer interface {
1212 // GetPath returns the database file path
1213 GetPath(context.Context, *Empty) (*PathResponse, error)
1214 // Sync flushes buffers to disk
1215 Sync(context.Context, *Empty) (*Empty, error)
1216 // Ready returns whether the database is ready to serve requests
1217 Ready(context.Context, *Empty) (*ReadyResponse, error)
1218 // SetLogLevel sets the database log level
1219 SetLogLevel(context.Context, *SetLogLevelRequest) (*Empty, error)
1220 // SaveEvent stores an event, returns whether it already existed
1221 SaveEvent(context.Context, *SaveEventRequest) (*SaveEventResponse, error)
1222 // GetSerialsFromFilter gets serial numbers matching a filter
1223 GetSerialsFromFilter(context.Context, *GetSerialsFromFilterRequest) (*SerialList, error)
1224 // WouldReplaceEvent checks if an event would replace existing ones
1225 WouldReplaceEvent(context.Context, *WouldReplaceEventRequest) (*WouldReplaceEventResponse, error)
1226 // QueryEvents queries events matching a filter (with deletion filtering)
1227 QueryEvents(*QueryEventsRequest, grpc.ServerStreamingServer[EventBatch]) error
1228 // QueryAllVersions queries all versions of replaceable events
1229 QueryAllVersions(*QueryEventsRequest, grpc.ServerStreamingServer[EventBatch]) error
1230 // QueryEventsWithOptions provides full control over query behavior
1231 QueryEventsWithOptions(*QueryEventsWithOptionsRequest, grpc.ServerStreamingServer[EventBatch]) error
1232 // QueryDeleteEventsByTargetId queries deletion events for a target
1233 QueryDeleteEventsByTargetId(*QueryDeleteEventsByTargetIdRequest, grpc.ServerStreamingServer[EventBatch]) error
1234 // QueryForSerials queries just serial numbers matching a filter
1235 QueryForSerials(context.Context, *QueryEventsRequest) (*SerialList, error)
1236 // QueryForIds queries ID/Pubkey/Timestamp triplets
1237 QueryForIds(context.Context, *QueryEventsRequest) (*IdPkTsList, error)
1238 // CountEvents counts events matching a filter
1239 CountEvents(context.Context, *QueryEventsRequest) (*CountEventsResponse, error)
1240 // FetchEventBySerial fetches a single event by serial
1241 FetchEventBySerial(context.Context, *FetchEventBySerialRequest) (*FetchEventBySerialResponse, error)
1242 // FetchEventsBySerials fetches multiple events by serial (batch)
1243 FetchEventsBySerials(context.Context, *FetchEventsBySerialRequest) (*EventMap, error)
1244 // GetSerialById gets the serial for a single event ID
1245 GetSerialById(context.Context, *GetSerialByIdRequest) (*GetSerialByIdResponse, error)
1246 // GetSerialsByIds gets serials for multiple event IDs
1247 GetSerialsByIds(context.Context, *GetSerialsByIdsRequest) (*SerialMap, error)
1248 // GetSerialsByRange gets serials within an index range
1249 GetSerialsByRange(context.Context, *GetSerialsByRangeRequest) (*SerialList, error)
1250 // GetFullIdPubkeyBySerial gets full ID/Pubkey/Timestamp for a serial
1251 GetFullIdPubkeyBySerial(context.Context, *GetFullIdPubkeyBySerialRequest) (*IdPkTs, error)
1252 // GetFullIdPubkeyBySerials gets full data for multiple serials
1253 GetFullIdPubkeyBySerials(context.Context, *GetFullIdPubkeyBySerialsRequest) (*IdPkTsList, error)
1254 // DeleteEvent deletes an event by ID
1255 DeleteEvent(context.Context, *DeleteEventRequest) (*Empty, error)
1256 // DeleteEventBySerial deletes an event by serial
1257 DeleteEventBySerial(context.Context, *DeleteEventBySerialRequest) (*Empty, error)
1258 // DeleteExpired deletes events with expired expiration tags
1259 DeleteExpired(context.Context, *Empty) (*Empty, error)
1260 // ProcessDelete processes a deletion event (NIP-09)
1261 ProcessDelete(context.Context, *ProcessDeleteRequest) (*Empty, error)
1262 // CheckForDeleted checks if an event was deleted
1263 CheckForDeleted(context.Context, *CheckForDeletedRequest) (*Empty, error)
1264 // Import imports events from a stream
1265 Import(grpc.ClientStreamingServer[ImportChunk, ImportResponse]) error
1266 // Export exports events to a stream
1267 Export(*ExportRequest, grpc.ServerStreamingServer[ExportChunk]) error
1268 // ImportEventsFromStrings imports events from JSON strings
1269 ImportEventsFromStrings(context.Context, *ImportEventsFromStringsRequest) (*ImportResponse, error)
1270 // GetRelayIdentitySecret gets the relay's secret key
1271 GetRelayIdentitySecret(context.Context, *Empty) (*GetRelayIdentitySecretResponse, error)
1272 // SetRelayIdentitySecret sets the relay's secret key
1273 SetRelayIdentitySecret(context.Context, *SetRelayIdentitySecretRequest) (*Empty, error)
1274 // GetOrCreateRelayIdentitySecret gets or creates the relay's secret key
1275 GetOrCreateRelayIdentitySecret(context.Context, *Empty) (*GetRelayIdentitySecretResponse, error)
1276 // SetMarker sets a metadata marker
1277 SetMarker(context.Context, *SetMarkerRequest) (*Empty, error)
1278 // GetMarker gets a metadata marker
1279 GetMarker(context.Context, *GetMarkerRequest) (*GetMarkerResponse, error)
1280 // HasMarker checks if a marker exists
1281 HasMarker(context.Context, *HasMarkerRequest) (*HasMarkerResponse, error)
1282 // DeleteMarker deletes a marker
1283 DeleteMarker(context.Context, *DeleteMarkerRequest) (*Empty, error)
1284 // GetSubscription gets subscription info for a pubkey
1285 GetSubscription(context.Context, *GetSubscriptionRequest) (*Subscription, error)
1286 // IsSubscriptionActive checks if a subscription is active
1287 IsSubscriptionActive(context.Context, *IsSubscriptionActiveRequest) (*IsSubscriptionActiveResponse, error)
1288 // ExtendSubscription extends a subscription by days
1289 ExtendSubscription(context.Context, *ExtendSubscriptionRequest) (*Empty, error)
1290 // RecordPayment records a payment
1291 RecordPayment(context.Context, *RecordPaymentRequest) (*Empty, error)
1292 // GetPaymentHistory gets payment history for a pubkey
1293 GetPaymentHistory(context.Context, *GetPaymentHistoryRequest) (*PaymentList, error)
1294 // ExtendBlossomSubscription extends blossom storage subscription
1295 ExtendBlossomSubscription(context.Context, *ExtendBlossomSubscriptionRequest) (*Empty, error)
1296 // GetBlossomStorageQuota gets blossom storage quota
1297 GetBlossomStorageQuota(context.Context, *GetBlossomStorageQuotaRequest) (*GetBlossomStorageQuotaResponse, error)
1298 // IsFirstTimeUser checks if this is a first-time user
1299 IsFirstTimeUser(context.Context, *IsFirstTimeUserRequest) (*IsFirstTimeUserResponse, error)
1300 // SavePaidSubscription saves or updates a paid subscription
1301 SavePaidSubscription(context.Context, *PaidSubscriptionMsg) (*Empty, error)
1302 // GetPaidSubscription gets a paid subscription by pubkey hex
1303 GetPaidSubscription(context.Context, *GetPaidSubscriptionRequest) (*PaidSubscriptionMsg, error)
1304 // DeletePaidSubscription deletes a paid subscription
1305 DeletePaidSubscription(context.Context, *DeletePaidSubscriptionRequest) (*Empty, error)
1306 // ListPaidSubscriptions lists all paid subscriptions
1307 ListPaidSubscriptions(context.Context, *Empty) (*PaidSubscriptionList, error)
1308 // ClaimAlias claims an email alias for a pubkey
1309 ClaimAlias(context.Context, *ClaimAliasRequest) (*Empty, error)
1310 // GetAliasByPubkey gets the alias for a pubkey
1311 GetAliasByPubkey(context.Context, *GetAliasByPubkeyRequest) (*AliasResponse, error)
1312 // GetPubkeyByAlias gets the pubkey for an alias
1313 GetPubkeyByAlias(context.Context, *GetPubkeyByAliasRequest) (*PubkeyResponse, error)
1314 // IsAliasTaken checks if an alias is taken
1315 IsAliasTaken(context.Context, *IsAliasTakenRequest) (*IsAliasTakenResponse, error)
1316 // AddNIP43Member adds a member via invite code
1317 AddNIP43Member(context.Context, *AddNIP43MemberRequest) (*Empty, error)
1318 // RemoveNIP43Member removes a member
1319 RemoveNIP43Member(context.Context, *RemoveNIP43MemberRequest) (*Empty, error)
1320 // IsNIP43Member checks if a pubkey is a member
1321 IsNIP43Member(context.Context, *IsNIP43MemberRequest) (*IsNIP43MemberResponse, error)
1322 // GetNIP43Membership gets membership details
1323 GetNIP43Membership(context.Context, *GetNIP43MembershipRequest) (*NIP43Membership, error)
1324 // GetAllNIP43Members gets all members
1325 GetAllNIP43Members(context.Context, *Empty) (*PubkeyList, error)
1326 // StoreInviteCode stores an invite code with expiration
1327 StoreInviteCode(context.Context, *StoreInviteCodeRequest) (*Empty, error)
1328 // ValidateInviteCode validates an invite code
1329 ValidateInviteCode(context.Context, *ValidateInviteCodeRequest) (*ValidateInviteCodeResponse, error)
1330 // DeleteInviteCode deletes an invite code
1331 DeleteInviteCode(context.Context, *DeleteInviteCodeRequest) (*Empty, error)
1332 // PublishNIP43MembershipEvent publishes a membership event
1333 PublishNIP43MembershipEvent(context.Context, *PublishNIP43MembershipEventRequest) (*Empty, error)
1334 // GetCachedJSON gets cached JSON for a filter
1335 GetCachedJSON(context.Context, *GetCachedJSONRequest) (*GetCachedJSONResponse, error)
1336 // CacheMarshaledJSON caches JSON for a filter
1337 CacheMarshaledJSON(context.Context, *CacheMarshaledJSONRequest) (*Empty, error)
1338 // GetCachedEvents gets cached events for a filter
1339 GetCachedEvents(context.Context, *GetCachedEventsRequest) (*GetCachedEventsResponse, error)
1340 // CacheEvents caches events for a filter
1341 CacheEvents(context.Context, *CacheEventsRequest) (*Empty, error)
1342 // InvalidateQueryCache invalidates the entire query cache
1343 InvalidateQueryCache(context.Context, *Empty) (*Empty, error)
1344 // RecordEventAccess records an access to an event
1345 RecordEventAccess(context.Context, *RecordEventAccessRequest) (*Empty, error)
1346 // GetEventAccessInfo gets access info for an event
1347 GetEventAccessInfo(context.Context, *GetEventAccessInfoRequest) (*GetEventAccessInfoResponse, error)
1348 // GetLeastAccessedEvents gets least accessed events for GC
1349 GetLeastAccessedEvents(context.Context, *GetLeastAccessedEventsRequest) (*SerialList, error)
1350 // SaveBlob stores a blob with its metadata
1351 SaveBlob(context.Context, *SaveBlobRequest) (*Empty, error)
1352 // SaveBlobMetadata stores only metadata for a blob whose file is already on disk
1353 SaveBlobMetadata(context.Context, *SaveBlobMetadataRequest) (*Empty, error)
1354 // GetBlob retrieves blob data and metadata
1355 GetBlob(context.Context, *GetBlobRequest) (*GetBlobResponse, error)
1356 // HasBlob checks if a blob exists
1357 HasBlob(context.Context, *HasBlobRequest) (*HasBlobResponse, error)
1358 // DeleteBlob deletes a blob
1359 DeleteBlob(context.Context, *DeleteBlobRequest) (*Empty, error)
1360 // ListBlobs lists blobs for a pubkey
1361 ListBlobs(context.Context, *ListBlobsRequest) (*ListBlobsResponse, error)
1362 // GetBlobMetadata gets only metadata for a blob
1363 GetBlobMetadata(context.Context, *GetBlobMetadataRequest) (*BlobMetadata, error)
1364 // GetTotalBlobStorageUsed gets total storage used by a pubkey in MB
1365 GetTotalBlobStorageUsed(context.Context, *GetTotalBlobStorageUsedRequest) (*GetTotalBlobStorageUsedResponse, error)
1366 // SaveBlobReport stores a report for a blob (BUD-09)
1367 SaveBlobReport(context.Context, *SaveBlobReportRequest) (*Empty, error)
1368 // ListAllBlobUserStats gets storage statistics for all users
1369 ListAllBlobUserStats(context.Context, *Empty) (*ListAllBlobUserStatsResponse, error)
1370 // ReconcileBlobMetadata scans the blossom directory and creates metadata for orphan blobs
1371 ReconcileBlobMetadata(context.Context, *Empty) (*ReconcileBlobMetadataResponse, error)
1372 // ListAllBlobs returns all blob descriptors (for admin thumbnail generation)
1373 ListAllBlobs(context.Context, *Empty) (*ListBlobsResponse, error)
1374 // GetThumbnail retrieves a cached thumbnail by key
1375 GetThumbnail(context.Context, *GetThumbnailRequest) (*GetThumbnailResponse, error)
1376 // SaveThumbnail stores a cached thumbnail
1377 SaveThumbnail(context.Context, *SaveThumbnailRequest) (*Empty, error)
1378 // EventIdsBySerial gets event IDs by serial range
1379 EventIdsBySerial(context.Context, *EventIdsBySerialRequest) (*EventIdsBySerialResponse, error)
1380 // RunMigrations runs database migrations
1381 RunMigrations(context.Context, *Empty) (*Empty, error)
1382 // ExecuteCypherRead executes a read-only Cypher query against Neo4j
1383 ExecuteCypherRead(context.Context, *CypherReadRequest) (*CypherReadResponse, error)
1384 mustEmbedUnimplementedDatabaseServiceServer()
1385 }
1386
1387 // UnimplementedDatabaseServiceServer must be embedded to have
1388 // forward compatible implementations.
1389 //
1390 // NOTE: this should be embedded by value instead of pointer to avoid a nil
1391 // pointer dereference when methods are called.
1392 type UnimplementedDatabaseServiceServer struct{}
1393
1394 func (UnimplementedDatabaseServiceServer) GetPath(context.Context, *Empty) (*PathResponse, error) {
1395 return nil, status.Error(codes.Unimplemented, "method GetPath not implemented")
1396 }
1397 func (UnimplementedDatabaseServiceServer) Sync(context.Context, *Empty) (*Empty, error) {
1398 return nil, status.Error(codes.Unimplemented, "method Sync not implemented")
1399 }
1400 func (UnimplementedDatabaseServiceServer) Ready(context.Context, *Empty) (*ReadyResponse, error) {
1401 return nil, status.Error(codes.Unimplemented, "method Ready not implemented")
1402 }
1403 func (UnimplementedDatabaseServiceServer) SetLogLevel(context.Context, *SetLogLevelRequest) (*Empty, error) {
1404 return nil, status.Error(codes.Unimplemented, "method SetLogLevel not implemented")
1405 }
1406 func (UnimplementedDatabaseServiceServer) SaveEvent(context.Context, *SaveEventRequest) (*SaveEventResponse, error) {
1407 return nil, status.Error(codes.Unimplemented, "method SaveEvent not implemented")
1408 }
1409 func (UnimplementedDatabaseServiceServer) GetSerialsFromFilter(context.Context, *GetSerialsFromFilterRequest) (*SerialList, error) {
1410 return nil, status.Error(codes.Unimplemented, "method GetSerialsFromFilter not implemented")
1411 }
1412 func (UnimplementedDatabaseServiceServer) WouldReplaceEvent(context.Context, *WouldReplaceEventRequest) (*WouldReplaceEventResponse, error) {
1413 return nil, status.Error(codes.Unimplemented, "method WouldReplaceEvent not implemented")
1414 }
1415 func (UnimplementedDatabaseServiceServer) QueryEvents(*QueryEventsRequest, grpc.ServerStreamingServer[EventBatch]) error {
1416 return status.Error(codes.Unimplemented, "method QueryEvents not implemented")
1417 }
1418 func (UnimplementedDatabaseServiceServer) QueryAllVersions(*QueryEventsRequest, grpc.ServerStreamingServer[EventBatch]) error {
1419 return status.Error(codes.Unimplemented, "method QueryAllVersions not implemented")
1420 }
1421 func (UnimplementedDatabaseServiceServer) QueryEventsWithOptions(*QueryEventsWithOptionsRequest, grpc.ServerStreamingServer[EventBatch]) error {
1422 return status.Error(codes.Unimplemented, "method QueryEventsWithOptions not implemented")
1423 }
1424 func (UnimplementedDatabaseServiceServer) QueryDeleteEventsByTargetId(*QueryDeleteEventsByTargetIdRequest, grpc.ServerStreamingServer[EventBatch]) error {
1425 return status.Error(codes.Unimplemented, "method QueryDeleteEventsByTargetId not implemented")
1426 }
1427 func (UnimplementedDatabaseServiceServer) QueryForSerials(context.Context, *QueryEventsRequest) (*SerialList, error) {
1428 return nil, status.Error(codes.Unimplemented, "method QueryForSerials not implemented")
1429 }
1430 func (UnimplementedDatabaseServiceServer) QueryForIds(context.Context, *QueryEventsRequest) (*IdPkTsList, error) {
1431 return nil, status.Error(codes.Unimplemented, "method QueryForIds not implemented")
1432 }
1433 func (UnimplementedDatabaseServiceServer) CountEvents(context.Context, *QueryEventsRequest) (*CountEventsResponse, error) {
1434 return nil, status.Error(codes.Unimplemented, "method CountEvents not implemented")
1435 }
1436 func (UnimplementedDatabaseServiceServer) FetchEventBySerial(context.Context, *FetchEventBySerialRequest) (*FetchEventBySerialResponse, error) {
1437 return nil, status.Error(codes.Unimplemented, "method FetchEventBySerial not implemented")
1438 }
1439 func (UnimplementedDatabaseServiceServer) FetchEventsBySerials(context.Context, *FetchEventsBySerialRequest) (*EventMap, error) {
1440 return nil, status.Error(codes.Unimplemented, "method FetchEventsBySerials not implemented")
1441 }
1442 func (UnimplementedDatabaseServiceServer) GetSerialById(context.Context, *GetSerialByIdRequest) (*GetSerialByIdResponse, error) {
1443 return nil, status.Error(codes.Unimplemented, "method GetSerialById not implemented")
1444 }
1445 func (UnimplementedDatabaseServiceServer) GetSerialsByIds(context.Context, *GetSerialsByIdsRequest) (*SerialMap, error) {
1446 return nil, status.Error(codes.Unimplemented, "method GetSerialsByIds not implemented")
1447 }
1448 func (UnimplementedDatabaseServiceServer) GetSerialsByRange(context.Context, *GetSerialsByRangeRequest) (*SerialList, error) {
1449 return nil, status.Error(codes.Unimplemented, "method GetSerialsByRange not implemented")
1450 }
1451 func (UnimplementedDatabaseServiceServer) GetFullIdPubkeyBySerial(context.Context, *GetFullIdPubkeyBySerialRequest) (*IdPkTs, error) {
1452 return nil, status.Error(codes.Unimplemented, "method GetFullIdPubkeyBySerial not implemented")
1453 }
1454 func (UnimplementedDatabaseServiceServer) GetFullIdPubkeyBySerials(context.Context, *GetFullIdPubkeyBySerialsRequest) (*IdPkTsList, error) {
1455 return nil, status.Error(codes.Unimplemented, "method GetFullIdPubkeyBySerials not implemented")
1456 }
1457 func (UnimplementedDatabaseServiceServer) DeleteEvent(context.Context, *DeleteEventRequest) (*Empty, error) {
1458 return nil, status.Error(codes.Unimplemented, "method DeleteEvent not implemented")
1459 }
1460 func (UnimplementedDatabaseServiceServer) DeleteEventBySerial(context.Context, *DeleteEventBySerialRequest) (*Empty, error) {
1461 return nil, status.Error(codes.Unimplemented, "method DeleteEventBySerial not implemented")
1462 }
1463 func (UnimplementedDatabaseServiceServer) DeleteExpired(context.Context, *Empty) (*Empty, error) {
1464 return nil, status.Error(codes.Unimplemented, "method DeleteExpired not implemented")
1465 }
1466 func (UnimplementedDatabaseServiceServer) ProcessDelete(context.Context, *ProcessDeleteRequest) (*Empty, error) {
1467 return nil, status.Error(codes.Unimplemented, "method ProcessDelete not implemented")
1468 }
1469 func (UnimplementedDatabaseServiceServer) CheckForDeleted(context.Context, *CheckForDeletedRequest) (*Empty, error) {
1470 return nil, status.Error(codes.Unimplemented, "method CheckForDeleted not implemented")
1471 }
1472 func (UnimplementedDatabaseServiceServer) Import(grpc.ClientStreamingServer[ImportChunk, ImportResponse]) error {
1473 return status.Error(codes.Unimplemented, "method Import not implemented")
1474 }
1475 func (UnimplementedDatabaseServiceServer) Export(*ExportRequest, grpc.ServerStreamingServer[ExportChunk]) error {
1476 return status.Error(codes.Unimplemented, "method Export not implemented")
1477 }
1478 func (UnimplementedDatabaseServiceServer) ImportEventsFromStrings(context.Context, *ImportEventsFromStringsRequest) (*ImportResponse, error) {
1479 return nil, status.Error(codes.Unimplemented, "method ImportEventsFromStrings not implemented")
1480 }
1481 func (UnimplementedDatabaseServiceServer) GetRelayIdentitySecret(context.Context, *Empty) (*GetRelayIdentitySecretResponse, error) {
1482 return nil, status.Error(codes.Unimplemented, "method GetRelayIdentitySecret not implemented")
1483 }
1484 func (UnimplementedDatabaseServiceServer) SetRelayIdentitySecret(context.Context, *SetRelayIdentitySecretRequest) (*Empty, error) {
1485 return nil, status.Error(codes.Unimplemented, "method SetRelayIdentitySecret not implemented")
1486 }
1487 func (UnimplementedDatabaseServiceServer) GetOrCreateRelayIdentitySecret(context.Context, *Empty) (*GetRelayIdentitySecretResponse, error) {
1488 return nil, status.Error(codes.Unimplemented, "method GetOrCreateRelayIdentitySecret not implemented")
1489 }
1490 func (UnimplementedDatabaseServiceServer) SetMarker(context.Context, *SetMarkerRequest) (*Empty, error) {
1491 return nil, status.Error(codes.Unimplemented, "method SetMarker not implemented")
1492 }
1493 func (UnimplementedDatabaseServiceServer) GetMarker(context.Context, *GetMarkerRequest) (*GetMarkerResponse, error) {
1494 return nil, status.Error(codes.Unimplemented, "method GetMarker not implemented")
1495 }
1496 func (UnimplementedDatabaseServiceServer) HasMarker(context.Context, *HasMarkerRequest) (*HasMarkerResponse, error) {
1497 return nil, status.Error(codes.Unimplemented, "method HasMarker not implemented")
1498 }
1499 func (UnimplementedDatabaseServiceServer) DeleteMarker(context.Context, *DeleteMarkerRequest) (*Empty, error) {
1500 return nil, status.Error(codes.Unimplemented, "method DeleteMarker not implemented")
1501 }
1502 func (UnimplementedDatabaseServiceServer) GetSubscription(context.Context, *GetSubscriptionRequest) (*Subscription, error) {
1503 return nil, status.Error(codes.Unimplemented, "method GetSubscription not implemented")
1504 }
1505 func (UnimplementedDatabaseServiceServer) IsSubscriptionActive(context.Context, *IsSubscriptionActiveRequest) (*IsSubscriptionActiveResponse, error) {
1506 return nil, status.Error(codes.Unimplemented, "method IsSubscriptionActive not implemented")
1507 }
1508 func (UnimplementedDatabaseServiceServer) ExtendSubscription(context.Context, *ExtendSubscriptionRequest) (*Empty, error) {
1509 return nil, status.Error(codes.Unimplemented, "method ExtendSubscription not implemented")
1510 }
1511 func (UnimplementedDatabaseServiceServer) RecordPayment(context.Context, *RecordPaymentRequest) (*Empty, error) {
1512 return nil, status.Error(codes.Unimplemented, "method RecordPayment not implemented")
1513 }
1514 func (UnimplementedDatabaseServiceServer) GetPaymentHistory(context.Context, *GetPaymentHistoryRequest) (*PaymentList, error) {
1515 return nil, status.Error(codes.Unimplemented, "method GetPaymentHistory not implemented")
1516 }
1517 func (UnimplementedDatabaseServiceServer) ExtendBlossomSubscription(context.Context, *ExtendBlossomSubscriptionRequest) (*Empty, error) {
1518 return nil, status.Error(codes.Unimplemented, "method ExtendBlossomSubscription not implemented")
1519 }
1520 func (UnimplementedDatabaseServiceServer) GetBlossomStorageQuota(context.Context, *GetBlossomStorageQuotaRequest) (*GetBlossomStorageQuotaResponse, error) {
1521 return nil, status.Error(codes.Unimplemented, "method GetBlossomStorageQuota not implemented")
1522 }
1523 func (UnimplementedDatabaseServiceServer) IsFirstTimeUser(context.Context, *IsFirstTimeUserRequest) (*IsFirstTimeUserResponse, error) {
1524 return nil, status.Error(codes.Unimplemented, "method IsFirstTimeUser not implemented")
1525 }
1526 func (UnimplementedDatabaseServiceServer) SavePaidSubscription(context.Context, *PaidSubscriptionMsg) (*Empty, error) {
1527 return nil, status.Error(codes.Unimplemented, "method SavePaidSubscription not implemented")
1528 }
1529 func (UnimplementedDatabaseServiceServer) GetPaidSubscription(context.Context, *GetPaidSubscriptionRequest) (*PaidSubscriptionMsg, error) {
1530 return nil, status.Error(codes.Unimplemented, "method GetPaidSubscription not implemented")
1531 }
1532 func (UnimplementedDatabaseServiceServer) DeletePaidSubscription(context.Context, *DeletePaidSubscriptionRequest) (*Empty, error) {
1533 return nil, status.Error(codes.Unimplemented, "method DeletePaidSubscription not implemented")
1534 }
1535 func (UnimplementedDatabaseServiceServer) ListPaidSubscriptions(context.Context, *Empty) (*PaidSubscriptionList, error) {
1536 return nil, status.Error(codes.Unimplemented, "method ListPaidSubscriptions not implemented")
1537 }
1538 func (UnimplementedDatabaseServiceServer) ClaimAlias(context.Context, *ClaimAliasRequest) (*Empty, error) {
1539 return nil, status.Error(codes.Unimplemented, "method ClaimAlias not implemented")
1540 }
1541 func (UnimplementedDatabaseServiceServer) GetAliasByPubkey(context.Context, *GetAliasByPubkeyRequest) (*AliasResponse, error) {
1542 return nil, status.Error(codes.Unimplemented, "method GetAliasByPubkey not implemented")
1543 }
1544 func (UnimplementedDatabaseServiceServer) GetPubkeyByAlias(context.Context, *GetPubkeyByAliasRequest) (*PubkeyResponse, error) {
1545 return nil, status.Error(codes.Unimplemented, "method GetPubkeyByAlias not implemented")
1546 }
1547 func (UnimplementedDatabaseServiceServer) IsAliasTaken(context.Context, *IsAliasTakenRequest) (*IsAliasTakenResponse, error) {
1548 return nil, status.Error(codes.Unimplemented, "method IsAliasTaken not implemented")
1549 }
1550 func (UnimplementedDatabaseServiceServer) AddNIP43Member(context.Context, *AddNIP43MemberRequest) (*Empty, error) {
1551 return nil, status.Error(codes.Unimplemented, "method AddNIP43Member not implemented")
1552 }
1553 func (UnimplementedDatabaseServiceServer) RemoveNIP43Member(context.Context, *RemoveNIP43MemberRequest) (*Empty, error) {
1554 return nil, status.Error(codes.Unimplemented, "method RemoveNIP43Member not implemented")
1555 }
1556 func (UnimplementedDatabaseServiceServer) IsNIP43Member(context.Context, *IsNIP43MemberRequest) (*IsNIP43MemberResponse, error) {
1557 return nil, status.Error(codes.Unimplemented, "method IsNIP43Member not implemented")
1558 }
1559 func (UnimplementedDatabaseServiceServer) GetNIP43Membership(context.Context, *GetNIP43MembershipRequest) (*NIP43Membership, error) {
1560 return nil, status.Error(codes.Unimplemented, "method GetNIP43Membership not implemented")
1561 }
1562 func (UnimplementedDatabaseServiceServer) GetAllNIP43Members(context.Context, *Empty) (*PubkeyList, error) {
1563 return nil, status.Error(codes.Unimplemented, "method GetAllNIP43Members not implemented")
1564 }
1565 func (UnimplementedDatabaseServiceServer) StoreInviteCode(context.Context, *StoreInviteCodeRequest) (*Empty, error) {
1566 return nil, status.Error(codes.Unimplemented, "method StoreInviteCode not implemented")
1567 }
1568 func (UnimplementedDatabaseServiceServer) ValidateInviteCode(context.Context, *ValidateInviteCodeRequest) (*ValidateInviteCodeResponse, error) {
1569 return nil, status.Error(codes.Unimplemented, "method ValidateInviteCode not implemented")
1570 }
1571 func (UnimplementedDatabaseServiceServer) DeleteInviteCode(context.Context, *DeleteInviteCodeRequest) (*Empty, error) {
1572 return nil, status.Error(codes.Unimplemented, "method DeleteInviteCode not implemented")
1573 }
1574 func (UnimplementedDatabaseServiceServer) PublishNIP43MembershipEvent(context.Context, *PublishNIP43MembershipEventRequest) (*Empty, error) {
1575 return nil, status.Error(codes.Unimplemented, "method PublishNIP43MembershipEvent not implemented")
1576 }
1577 func (UnimplementedDatabaseServiceServer) GetCachedJSON(context.Context, *GetCachedJSONRequest) (*GetCachedJSONResponse, error) {
1578 return nil, status.Error(codes.Unimplemented, "method GetCachedJSON not implemented")
1579 }
1580 func (UnimplementedDatabaseServiceServer) CacheMarshaledJSON(context.Context, *CacheMarshaledJSONRequest) (*Empty, error) {
1581 return nil, status.Error(codes.Unimplemented, "method CacheMarshaledJSON not implemented")
1582 }
1583 func (UnimplementedDatabaseServiceServer) GetCachedEvents(context.Context, *GetCachedEventsRequest) (*GetCachedEventsResponse, error) {
1584 return nil, status.Error(codes.Unimplemented, "method GetCachedEvents not implemented")
1585 }
1586 func (UnimplementedDatabaseServiceServer) CacheEvents(context.Context, *CacheEventsRequest) (*Empty, error) {
1587 return nil, status.Error(codes.Unimplemented, "method CacheEvents not implemented")
1588 }
1589 func (UnimplementedDatabaseServiceServer) InvalidateQueryCache(context.Context, *Empty) (*Empty, error) {
1590 return nil, status.Error(codes.Unimplemented, "method InvalidateQueryCache not implemented")
1591 }
1592 func (UnimplementedDatabaseServiceServer) RecordEventAccess(context.Context, *RecordEventAccessRequest) (*Empty, error) {
1593 return nil, status.Error(codes.Unimplemented, "method RecordEventAccess not implemented")
1594 }
1595 func (UnimplementedDatabaseServiceServer) GetEventAccessInfo(context.Context, *GetEventAccessInfoRequest) (*GetEventAccessInfoResponse, error) {
1596 return nil, status.Error(codes.Unimplemented, "method GetEventAccessInfo not implemented")
1597 }
1598 func (UnimplementedDatabaseServiceServer) GetLeastAccessedEvents(context.Context, *GetLeastAccessedEventsRequest) (*SerialList, error) {
1599 return nil, status.Error(codes.Unimplemented, "method GetLeastAccessedEvents not implemented")
1600 }
1601 func (UnimplementedDatabaseServiceServer) SaveBlob(context.Context, *SaveBlobRequest) (*Empty, error) {
1602 return nil, status.Error(codes.Unimplemented, "method SaveBlob not implemented")
1603 }
1604 func (UnimplementedDatabaseServiceServer) SaveBlobMetadata(context.Context, *SaveBlobMetadataRequest) (*Empty, error) {
1605 return nil, status.Error(codes.Unimplemented, "method SaveBlobMetadata not implemented")
1606 }
1607 func (UnimplementedDatabaseServiceServer) GetBlob(context.Context, *GetBlobRequest) (*GetBlobResponse, error) {
1608 return nil, status.Error(codes.Unimplemented, "method GetBlob not implemented")
1609 }
1610 func (UnimplementedDatabaseServiceServer) HasBlob(context.Context, *HasBlobRequest) (*HasBlobResponse, error) {
1611 return nil, status.Error(codes.Unimplemented, "method HasBlob not implemented")
1612 }
1613 func (UnimplementedDatabaseServiceServer) DeleteBlob(context.Context, *DeleteBlobRequest) (*Empty, error) {
1614 return nil, status.Error(codes.Unimplemented, "method DeleteBlob not implemented")
1615 }
1616 func (UnimplementedDatabaseServiceServer) ListBlobs(context.Context, *ListBlobsRequest) (*ListBlobsResponse, error) {
1617 return nil, status.Error(codes.Unimplemented, "method ListBlobs not implemented")
1618 }
1619 func (UnimplementedDatabaseServiceServer) GetBlobMetadata(context.Context, *GetBlobMetadataRequest) (*BlobMetadata, error) {
1620 return nil, status.Error(codes.Unimplemented, "method GetBlobMetadata not implemented")
1621 }
1622 func (UnimplementedDatabaseServiceServer) GetTotalBlobStorageUsed(context.Context, *GetTotalBlobStorageUsedRequest) (*GetTotalBlobStorageUsedResponse, error) {
1623 return nil, status.Error(codes.Unimplemented, "method GetTotalBlobStorageUsed not implemented")
1624 }
1625 func (UnimplementedDatabaseServiceServer) SaveBlobReport(context.Context, *SaveBlobReportRequest) (*Empty, error) {
1626 return nil, status.Error(codes.Unimplemented, "method SaveBlobReport not implemented")
1627 }
1628 func (UnimplementedDatabaseServiceServer) ListAllBlobUserStats(context.Context, *Empty) (*ListAllBlobUserStatsResponse, error) {
1629 return nil, status.Error(codes.Unimplemented, "method ListAllBlobUserStats not implemented")
1630 }
1631 func (UnimplementedDatabaseServiceServer) ReconcileBlobMetadata(context.Context, *Empty) (*ReconcileBlobMetadataResponse, error) {
1632 return nil, status.Error(codes.Unimplemented, "method ReconcileBlobMetadata not implemented")
1633 }
1634 func (UnimplementedDatabaseServiceServer) ListAllBlobs(context.Context, *Empty) (*ListBlobsResponse, error) {
1635 return nil, status.Error(codes.Unimplemented, "method ListAllBlobs not implemented")
1636 }
1637 func (UnimplementedDatabaseServiceServer) GetThumbnail(context.Context, *GetThumbnailRequest) (*GetThumbnailResponse, error) {
1638 return nil, status.Error(codes.Unimplemented, "method GetThumbnail not implemented")
1639 }
1640 func (UnimplementedDatabaseServiceServer) SaveThumbnail(context.Context, *SaveThumbnailRequest) (*Empty, error) {
1641 return nil, status.Error(codes.Unimplemented, "method SaveThumbnail not implemented")
1642 }
1643 func (UnimplementedDatabaseServiceServer) EventIdsBySerial(context.Context, *EventIdsBySerialRequest) (*EventIdsBySerialResponse, error) {
1644 return nil, status.Error(codes.Unimplemented, "method EventIdsBySerial not implemented")
1645 }
1646 func (UnimplementedDatabaseServiceServer) RunMigrations(context.Context, *Empty) (*Empty, error) {
1647 return nil, status.Error(codes.Unimplemented, "method RunMigrations not implemented")
1648 }
1649 func (UnimplementedDatabaseServiceServer) ExecuteCypherRead(context.Context, *CypherReadRequest) (*CypherReadResponse, error) {
1650 return nil, status.Error(codes.Unimplemented, "method ExecuteCypherRead not implemented")
1651 }
1652 func (UnimplementedDatabaseServiceServer) mustEmbedUnimplementedDatabaseServiceServer() {}
1653 func (UnimplementedDatabaseServiceServer) testEmbeddedByValue() {}
1654
1655 // UnsafeDatabaseServiceServer may be embedded to opt out of forward compatibility for this service.
1656 // Use of this interface is not recommended, as added methods to DatabaseServiceServer will
1657 // result in compilation errors.
1658 type UnsafeDatabaseServiceServer interface {
1659 mustEmbedUnimplementedDatabaseServiceServer()
1660 }
1661
1662 func RegisterDatabaseServiceServer(s grpc.ServiceRegistrar, srv DatabaseServiceServer) {
1663 // If the following call panics, it indicates UnimplementedDatabaseServiceServer was
1664 // embedded by pointer and is nil. This will cause panics if an
1665 // unimplemented method is ever invoked, so we test this at initialization
1666 // time to prevent it from happening at runtime later due to I/O.
1667 if t, ok := srv.(interface{ testEmbeddedByValue() }); ok {
1668 t.testEmbeddedByValue()
1669 }
1670 s.RegisterService(&DatabaseService_ServiceDesc, srv)
1671 }
1672
1673 func _DatabaseService_GetPath_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1674 in := new(Empty)
1675 if err := dec(in); err != nil {
1676 return nil, err
1677 }
1678 if interceptor == nil {
1679 return srv.(DatabaseServiceServer).GetPath(ctx, in)
1680 }
1681 info := &grpc.UnaryServerInfo{
1682 Server: srv,
1683 FullMethod: DatabaseService_GetPath_FullMethodName,
1684 }
1685 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1686 return srv.(DatabaseServiceServer).GetPath(ctx, req.(*Empty))
1687 }
1688 return interceptor(ctx, in, info, handler)
1689 }
1690
1691 func _DatabaseService_Sync_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1692 in := new(Empty)
1693 if err := dec(in); err != nil {
1694 return nil, err
1695 }
1696 if interceptor == nil {
1697 return srv.(DatabaseServiceServer).Sync(ctx, in)
1698 }
1699 info := &grpc.UnaryServerInfo{
1700 Server: srv,
1701 FullMethod: DatabaseService_Sync_FullMethodName,
1702 }
1703 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1704 return srv.(DatabaseServiceServer).Sync(ctx, req.(*Empty))
1705 }
1706 return interceptor(ctx, in, info, handler)
1707 }
1708
1709 func _DatabaseService_Ready_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1710 in := new(Empty)
1711 if err := dec(in); err != nil {
1712 return nil, err
1713 }
1714 if interceptor == nil {
1715 return srv.(DatabaseServiceServer).Ready(ctx, in)
1716 }
1717 info := &grpc.UnaryServerInfo{
1718 Server: srv,
1719 FullMethod: DatabaseService_Ready_FullMethodName,
1720 }
1721 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1722 return srv.(DatabaseServiceServer).Ready(ctx, req.(*Empty))
1723 }
1724 return interceptor(ctx, in, info, handler)
1725 }
1726
1727 func _DatabaseService_SetLogLevel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1728 in := new(SetLogLevelRequest)
1729 if err := dec(in); err != nil {
1730 return nil, err
1731 }
1732 if interceptor == nil {
1733 return srv.(DatabaseServiceServer).SetLogLevel(ctx, in)
1734 }
1735 info := &grpc.UnaryServerInfo{
1736 Server: srv,
1737 FullMethod: DatabaseService_SetLogLevel_FullMethodName,
1738 }
1739 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1740 return srv.(DatabaseServiceServer).SetLogLevel(ctx, req.(*SetLogLevelRequest))
1741 }
1742 return interceptor(ctx, in, info, handler)
1743 }
1744
1745 func _DatabaseService_SaveEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1746 in := new(SaveEventRequest)
1747 if err := dec(in); err != nil {
1748 return nil, err
1749 }
1750 if interceptor == nil {
1751 return srv.(DatabaseServiceServer).SaveEvent(ctx, in)
1752 }
1753 info := &grpc.UnaryServerInfo{
1754 Server: srv,
1755 FullMethod: DatabaseService_SaveEvent_FullMethodName,
1756 }
1757 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1758 return srv.(DatabaseServiceServer).SaveEvent(ctx, req.(*SaveEventRequest))
1759 }
1760 return interceptor(ctx, in, info, handler)
1761 }
1762
1763 func _DatabaseService_GetSerialsFromFilter_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1764 in := new(GetSerialsFromFilterRequest)
1765 if err := dec(in); err != nil {
1766 return nil, err
1767 }
1768 if interceptor == nil {
1769 return srv.(DatabaseServiceServer).GetSerialsFromFilter(ctx, in)
1770 }
1771 info := &grpc.UnaryServerInfo{
1772 Server: srv,
1773 FullMethod: DatabaseService_GetSerialsFromFilter_FullMethodName,
1774 }
1775 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1776 return srv.(DatabaseServiceServer).GetSerialsFromFilter(ctx, req.(*GetSerialsFromFilterRequest))
1777 }
1778 return interceptor(ctx, in, info, handler)
1779 }
1780
1781 func _DatabaseService_WouldReplaceEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1782 in := new(WouldReplaceEventRequest)
1783 if err := dec(in); err != nil {
1784 return nil, err
1785 }
1786 if interceptor == nil {
1787 return srv.(DatabaseServiceServer).WouldReplaceEvent(ctx, in)
1788 }
1789 info := &grpc.UnaryServerInfo{
1790 Server: srv,
1791 FullMethod: DatabaseService_WouldReplaceEvent_FullMethodName,
1792 }
1793 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1794 return srv.(DatabaseServiceServer).WouldReplaceEvent(ctx, req.(*WouldReplaceEventRequest))
1795 }
1796 return interceptor(ctx, in, info, handler)
1797 }
1798
1799 func _DatabaseService_QueryEvents_Handler(srv interface{}, stream grpc.ServerStream) error {
1800 m := new(QueryEventsRequest)
1801 if err := stream.RecvMsg(m); err != nil {
1802 return err
1803 }
1804 return srv.(DatabaseServiceServer).QueryEvents(m, &grpc.GenericServerStream[QueryEventsRequest, EventBatch]{ServerStream: stream})
1805 }
1806
1807 // This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
1808 type DatabaseService_QueryEventsServer = grpc.ServerStreamingServer[EventBatch]
1809
1810 func _DatabaseService_QueryAllVersions_Handler(srv interface{}, stream grpc.ServerStream) error {
1811 m := new(QueryEventsRequest)
1812 if err := stream.RecvMsg(m); err != nil {
1813 return err
1814 }
1815 return srv.(DatabaseServiceServer).QueryAllVersions(m, &grpc.GenericServerStream[QueryEventsRequest, EventBatch]{ServerStream: stream})
1816 }
1817
1818 // This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
1819 type DatabaseService_QueryAllVersionsServer = grpc.ServerStreamingServer[EventBatch]
1820
1821 func _DatabaseService_QueryEventsWithOptions_Handler(srv interface{}, stream grpc.ServerStream) error {
1822 m := new(QueryEventsWithOptionsRequest)
1823 if err := stream.RecvMsg(m); err != nil {
1824 return err
1825 }
1826 return srv.(DatabaseServiceServer).QueryEventsWithOptions(m, &grpc.GenericServerStream[QueryEventsWithOptionsRequest, EventBatch]{ServerStream: stream})
1827 }
1828
1829 // This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
1830 type DatabaseService_QueryEventsWithOptionsServer = grpc.ServerStreamingServer[EventBatch]
1831
1832 func _DatabaseService_QueryDeleteEventsByTargetId_Handler(srv interface{}, stream grpc.ServerStream) error {
1833 m := new(QueryDeleteEventsByTargetIdRequest)
1834 if err := stream.RecvMsg(m); err != nil {
1835 return err
1836 }
1837 return srv.(DatabaseServiceServer).QueryDeleteEventsByTargetId(m, &grpc.GenericServerStream[QueryDeleteEventsByTargetIdRequest, EventBatch]{ServerStream: stream})
1838 }
1839
1840 // This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
1841 type DatabaseService_QueryDeleteEventsByTargetIdServer = grpc.ServerStreamingServer[EventBatch]
1842
1843 func _DatabaseService_QueryForSerials_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1844 in := new(QueryEventsRequest)
1845 if err := dec(in); err != nil {
1846 return nil, err
1847 }
1848 if interceptor == nil {
1849 return srv.(DatabaseServiceServer).QueryForSerials(ctx, in)
1850 }
1851 info := &grpc.UnaryServerInfo{
1852 Server: srv,
1853 FullMethod: DatabaseService_QueryForSerials_FullMethodName,
1854 }
1855 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1856 return srv.(DatabaseServiceServer).QueryForSerials(ctx, req.(*QueryEventsRequest))
1857 }
1858 return interceptor(ctx, in, info, handler)
1859 }
1860
1861 func _DatabaseService_QueryForIds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1862 in := new(QueryEventsRequest)
1863 if err := dec(in); err != nil {
1864 return nil, err
1865 }
1866 if interceptor == nil {
1867 return srv.(DatabaseServiceServer).QueryForIds(ctx, in)
1868 }
1869 info := &grpc.UnaryServerInfo{
1870 Server: srv,
1871 FullMethod: DatabaseService_QueryForIds_FullMethodName,
1872 }
1873 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1874 return srv.(DatabaseServiceServer).QueryForIds(ctx, req.(*QueryEventsRequest))
1875 }
1876 return interceptor(ctx, in, info, handler)
1877 }
1878
1879 func _DatabaseService_CountEvents_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1880 in := new(QueryEventsRequest)
1881 if err := dec(in); err != nil {
1882 return nil, err
1883 }
1884 if interceptor == nil {
1885 return srv.(DatabaseServiceServer).CountEvents(ctx, in)
1886 }
1887 info := &grpc.UnaryServerInfo{
1888 Server: srv,
1889 FullMethod: DatabaseService_CountEvents_FullMethodName,
1890 }
1891 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1892 return srv.(DatabaseServiceServer).CountEvents(ctx, req.(*QueryEventsRequest))
1893 }
1894 return interceptor(ctx, in, info, handler)
1895 }
1896
1897 func _DatabaseService_FetchEventBySerial_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1898 in := new(FetchEventBySerialRequest)
1899 if err := dec(in); err != nil {
1900 return nil, err
1901 }
1902 if interceptor == nil {
1903 return srv.(DatabaseServiceServer).FetchEventBySerial(ctx, in)
1904 }
1905 info := &grpc.UnaryServerInfo{
1906 Server: srv,
1907 FullMethod: DatabaseService_FetchEventBySerial_FullMethodName,
1908 }
1909 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1910 return srv.(DatabaseServiceServer).FetchEventBySerial(ctx, req.(*FetchEventBySerialRequest))
1911 }
1912 return interceptor(ctx, in, info, handler)
1913 }
1914
1915 func _DatabaseService_FetchEventsBySerials_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1916 in := new(FetchEventsBySerialRequest)
1917 if err := dec(in); err != nil {
1918 return nil, err
1919 }
1920 if interceptor == nil {
1921 return srv.(DatabaseServiceServer).FetchEventsBySerials(ctx, in)
1922 }
1923 info := &grpc.UnaryServerInfo{
1924 Server: srv,
1925 FullMethod: DatabaseService_FetchEventsBySerials_FullMethodName,
1926 }
1927 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1928 return srv.(DatabaseServiceServer).FetchEventsBySerials(ctx, req.(*FetchEventsBySerialRequest))
1929 }
1930 return interceptor(ctx, in, info, handler)
1931 }
1932
1933 func _DatabaseService_GetSerialById_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1934 in := new(GetSerialByIdRequest)
1935 if err := dec(in); err != nil {
1936 return nil, err
1937 }
1938 if interceptor == nil {
1939 return srv.(DatabaseServiceServer).GetSerialById(ctx, in)
1940 }
1941 info := &grpc.UnaryServerInfo{
1942 Server: srv,
1943 FullMethod: DatabaseService_GetSerialById_FullMethodName,
1944 }
1945 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1946 return srv.(DatabaseServiceServer).GetSerialById(ctx, req.(*GetSerialByIdRequest))
1947 }
1948 return interceptor(ctx, in, info, handler)
1949 }
1950
1951 func _DatabaseService_GetSerialsByIds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1952 in := new(GetSerialsByIdsRequest)
1953 if err := dec(in); err != nil {
1954 return nil, err
1955 }
1956 if interceptor == nil {
1957 return srv.(DatabaseServiceServer).GetSerialsByIds(ctx, in)
1958 }
1959 info := &grpc.UnaryServerInfo{
1960 Server: srv,
1961 FullMethod: DatabaseService_GetSerialsByIds_FullMethodName,
1962 }
1963 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1964 return srv.(DatabaseServiceServer).GetSerialsByIds(ctx, req.(*GetSerialsByIdsRequest))
1965 }
1966 return interceptor(ctx, in, info, handler)
1967 }
1968
1969 func _DatabaseService_GetSerialsByRange_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1970 in := new(GetSerialsByRangeRequest)
1971 if err := dec(in); err != nil {
1972 return nil, err
1973 }
1974 if interceptor == nil {
1975 return srv.(DatabaseServiceServer).GetSerialsByRange(ctx, in)
1976 }
1977 info := &grpc.UnaryServerInfo{
1978 Server: srv,
1979 FullMethod: DatabaseService_GetSerialsByRange_FullMethodName,
1980 }
1981 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1982 return srv.(DatabaseServiceServer).GetSerialsByRange(ctx, req.(*GetSerialsByRangeRequest))
1983 }
1984 return interceptor(ctx, in, info, handler)
1985 }
1986
1987 func _DatabaseService_GetFullIdPubkeyBySerial_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1988 in := new(GetFullIdPubkeyBySerialRequest)
1989 if err := dec(in); err != nil {
1990 return nil, err
1991 }
1992 if interceptor == nil {
1993 return srv.(DatabaseServiceServer).GetFullIdPubkeyBySerial(ctx, in)
1994 }
1995 info := &grpc.UnaryServerInfo{
1996 Server: srv,
1997 FullMethod: DatabaseService_GetFullIdPubkeyBySerial_FullMethodName,
1998 }
1999 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2000 return srv.(DatabaseServiceServer).GetFullIdPubkeyBySerial(ctx, req.(*GetFullIdPubkeyBySerialRequest))
2001 }
2002 return interceptor(ctx, in, info, handler)
2003 }
2004
2005 func _DatabaseService_GetFullIdPubkeyBySerials_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2006 in := new(GetFullIdPubkeyBySerialsRequest)
2007 if err := dec(in); err != nil {
2008 return nil, err
2009 }
2010 if interceptor == nil {
2011 return srv.(DatabaseServiceServer).GetFullIdPubkeyBySerials(ctx, in)
2012 }
2013 info := &grpc.UnaryServerInfo{
2014 Server: srv,
2015 FullMethod: DatabaseService_GetFullIdPubkeyBySerials_FullMethodName,
2016 }
2017 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2018 return srv.(DatabaseServiceServer).GetFullIdPubkeyBySerials(ctx, req.(*GetFullIdPubkeyBySerialsRequest))
2019 }
2020 return interceptor(ctx, in, info, handler)
2021 }
2022
2023 func _DatabaseService_DeleteEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2024 in := new(DeleteEventRequest)
2025 if err := dec(in); err != nil {
2026 return nil, err
2027 }
2028 if interceptor == nil {
2029 return srv.(DatabaseServiceServer).DeleteEvent(ctx, in)
2030 }
2031 info := &grpc.UnaryServerInfo{
2032 Server: srv,
2033 FullMethod: DatabaseService_DeleteEvent_FullMethodName,
2034 }
2035 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2036 return srv.(DatabaseServiceServer).DeleteEvent(ctx, req.(*DeleteEventRequest))
2037 }
2038 return interceptor(ctx, in, info, handler)
2039 }
2040
2041 func _DatabaseService_DeleteEventBySerial_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2042 in := new(DeleteEventBySerialRequest)
2043 if err := dec(in); err != nil {
2044 return nil, err
2045 }
2046 if interceptor == nil {
2047 return srv.(DatabaseServiceServer).DeleteEventBySerial(ctx, in)
2048 }
2049 info := &grpc.UnaryServerInfo{
2050 Server: srv,
2051 FullMethod: DatabaseService_DeleteEventBySerial_FullMethodName,
2052 }
2053 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2054 return srv.(DatabaseServiceServer).DeleteEventBySerial(ctx, req.(*DeleteEventBySerialRequest))
2055 }
2056 return interceptor(ctx, in, info, handler)
2057 }
2058
2059 func _DatabaseService_DeleteExpired_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2060 in := new(Empty)
2061 if err := dec(in); err != nil {
2062 return nil, err
2063 }
2064 if interceptor == nil {
2065 return srv.(DatabaseServiceServer).DeleteExpired(ctx, in)
2066 }
2067 info := &grpc.UnaryServerInfo{
2068 Server: srv,
2069 FullMethod: DatabaseService_DeleteExpired_FullMethodName,
2070 }
2071 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2072 return srv.(DatabaseServiceServer).DeleteExpired(ctx, req.(*Empty))
2073 }
2074 return interceptor(ctx, in, info, handler)
2075 }
2076
2077 func _DatabaseService_ProcessDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2078 in := new(ProcessDeleteRequest)
2079 if err := dec(in); err != nil {
2080 return nil, err
2081 }
2082 if interceptor == nil {
2083 return srv.(DatabaseServiceServer).ProcessDelete(ctx, in)
2084 }
2085 info := &grpc.UnaryServerInfo{
2086 Server: srv,
2087 FullMethod: DatabaseService_ProcessDelete_FullMethodName,
2088 }
2089 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2090 return srv.(DatabaseServiceServer).ProcessDelete(ctx, req.(*ProcessDeleteRequest))
2091 }
2092 return interceptor(ctx, in, info, handler)
2093 }
2094
2095 func _DatabaseService_CheckForDeleted_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2096 in := new(CheckForDeletedRequest)
2097 if err := dec(in); err != nil {
2098 return nil, err
2099 }
2100 if interceptor == nil {
2101 return srv.(DatabaseServiceServer).CheckForDeleted(ctx, in)
2102 }
2103 info := &grpc.UnaryServerInfo{
2104 Server: srv,
2105 FullMethod: DatabaseService_CheckForDeleted_FullMethodName,
2106 }
2107 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2108 return srv.(DatabaseServiceServer).CheckForDeleted(ctx, req.(*CheckForDeletedRequest))
2109 }
2110 return interceptor(ctx, in, info, handler)
2111 }
2112
2113 func _DatabaseService_Import_Handler(srv interface{}, stream grpc.ServerStream) error {
2114 return srv.(DatabaseServiceServer).Import(&grpc.GenericServerStream[ImportChunk, ImportResponse]{ServerStream: stream})
2115 }
2116
2117 // This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
2118 type DatabaseService_ImportServer = grpc.ClientStreamingServer[ImportChunk, ImportResponse]
2119
2120 func _DatabaseService_Export_Handler(srv interface{}, stream grpc.ServerStream) error {
2121 m := new(ExportRequest)
2122 if err := stream.RecvMsg(m); err != nil {
2123 return err
2124 }
2125 return srv.(DatabaseServiceServer).Export(m, &grpc.GenericServerStream[ExportRequest, ExportChunk]{ServerStream: stream})
2126 }
2127
2128 // This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
2129 type DatabaseService_ExportServer = grpc.ServerStreamingServer[ExportChunk]
2130
2131 func _DatabaseService_ImportEventsFromStrings_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2132 in := new(ImportEventsFromStringsRequest)
2133 if err := dec(in); err != nil {
2134 return nil, err
2135 }
2136 if interceptor == nil {
2137 return srv.(DatabaseServiceServer).ImportEventsFromStrings(ctx, in)
2138 }
2139 info := &grpc.UnaryServerInfo{
2140 Server: srv,
2141 FullMethod: DatabaseService_ImportEventsFromStrings_FullMethodName,
2142 }
2143 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2144 return srv.(DatabaseServiceServer).ImportEventsFromStrings(ctx, req.(*ImportEventsFromStringsRequest))
2145 }
2146 return interceptor(ctx, in, info, handler)
2147 }
2148
2149 func _DatabaseService_GetRelayIdentitySecret_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2150 in := new(Empty)
2151 if err := dec(in); err != nil {
2152 return nil, err
2153 }
2154 if interceptor == nil {
2155 return srv.(DatabaseServiceServer).GetRelayIdentitySecret(ctx, in)
2156 }
2157 info := &grpc.UnaryServerInfo{
2158 Server: srv,
2159 FullMethod: DatabaseService_GetRelayIdentitySecret_FullMethodName,
2160 }
2161 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2162 return srv.(DatabaseServiceServer).GetRelayIdentitySecret(ctx, req.(*Empty))
2163 }
2164 return interceptor(ctx, in, info, handler)
2165 }
2166
2167 func _DatabaseService_SetRelayIdentitySecret_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2168 in := new(SetRelayIdentitySecretRequest)
2169 if err := dec(in); err != nil {
2170 return nil, err
2171 }
2172 if interceptor == nil {
2173 return srv.(DatabaseServiceServer).SetRelayIdentitySecret(ctx, in)
2174 }
2175 info := &grpc.UnaryServerInfo{
2176 Server: srv,
2177 FullMethod: DatabaseService_SetRelayIdentitySecret_FullMethodName,
2178 }
2179 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2180 return srv.(DatabaseServiceServer).SetRelayIdentitySecret(ctx, req.(*SetRelayIdentitySecretRequest))
2181 }
2182 return interceptor(ctx, in, info, handler)
2183 }
2184
2185 func _DatabaseService_GetOrCreateRelayIdentitySecret_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2186 in := new(Empty)
2187 if err := dec(in); err != nil {
2188 return nil, err
2189 }
2190 if interceptor == nil {
2191 return srv.(DatabaseServiceServer).GetOrCreateRelayIdentitySecret(ctx, in)
2192 }
2193 info := &grpc.UnaryServerInfo{
2194 Server: srv,
2195 FullMethod: DatabaseService_GetOrCreateRelayIdentitySecret_FullMethodName,
2196 }
2197 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2198 return srv.(DatabaseServiceServer).GetOrCreateRelayIdentitySecret(ctx, req.(*Empty))
2199 }
2200 return interceptor(ctx, in, info, handler)
2201 }
2202
2203 func _DatabaseService_SetMarker_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2204 in := new(SetMarkerRequest)
2205 if err := dec(in); err != nil {
2206 return nil, err
2207 }
2208 if interceptor == nil {
2209 return srv.(DatabaseServiceServer).SetMarker(ctx, in)
2210 }
2211 info := &grpc.UnaryServerInfo{
2212 Server: srv,
2213 FullMethod: DatabaseService_SetMarker_FullMethodName,
2214 }
2215 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2216 return srv.(DatabaseServiceServer).SetMarker(ctx, req.(*SetMarkerRequest))
2217 }
2218 return interceptor(ctx, in, info, handler)
2219 }
2220
2221 func _DatabaseService_GetMarker_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2222 in := new(GetMarkerRequest)
2223 if err := dec(in); err != nil {
2224 return nil, err
2225 }
2226 if interceptor == nil {
2227 return srv.(DatabaseServiceServer).GetMarker(ctx, in)
2228 }
2229 info := &grpc.UnaryServerInfo{
2230 Server: srv,
2231 FullMethod: DatabaseService_GetMarker_FullMethodName,
2232 }
2233 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2234 return srv.(DatabaseServiceServer).GetMarker(ctx, req.(*GetMarkerRequest))
2235 }
2236 return interceptor(ctx, in, info, handler)
2237 }
2238
2239 func _DatabaseService_HasMarker_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2240 in := new(HasMarkerRequest)
2241 if err := dec(in); err != nil {
2242 return nil, err
2243 }
2244 if interceptor == nil {
2245 return srv.(DatabaseServiceServer).HasMarker(ctx, in)
2246 }
2247 info := &grpc.UnaryServerInfo{
2248 Server: srv,
2249 FullMethod: DatabaseService_HasMarker_FullMethodName,
2250 }
2251 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2252 return srv.(DatabaseServiceServer).HasMarker(ctx, req.(*HasMarkerRequest))
2253 }
2254 return interceptor(ctx, in, info, handler)
2255 }
2256
2257 func _DatabaseService_DeleteMarker_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2258 in := new(DeleteMarkerRequest)
2259 if err := dec(in); err != nil {
2260 return nil, err
2261 }
2262 if interceptor == nil {
2263 return srv.(DatabaseServiceServer).DeleteMarker(ctx, in)
2264 }
2265 info := &grpc.UnaryServerInfo{
2266 Server: srv,
2267 FullMethod: DatabaseService_DeleteMarker_FullMethodName,
2268 }
2269 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2270 return srv.(DatabaseServiceServer).DeleteMarker(ctx, req.(*DeleteMarkerRequest))
2271 }
2272 return interceptor(ctx, in, info, handler)
2273 }
2274
2275 func _DatabaseService_GetSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2276 in := new(GetSubscriptionRequest)
2277 if err := dec(in); err != nil {
2278 return nil, err
2279 }
2280 if interceptor == nil {
2281 return srv.(DatabaseServiceServer).GetSubscription(ctx, in)
2282 }
2283 info := &grpc.UnaryServerInfo{
2284 Server: srv,
2285 FullMethod: DatabaseService_GetSubscription_FullMethodName,
2286 }
2287 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2288 return srv.(DatabaseServiceServer).GetSubscription(ctx, req.(*GetSubscriptionRequest))
2289 }
2290 return interceptor(ctx, in, info, handler)
2291 }
2292
2293 func _DatabaseService_IsSubscriptionActive_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2294 in := new(IsSubscriptionActiveRequest)
2295 if err := dec(in); err != nil {
2296 return nil, err
2297 }
2298 if interceptor == nil {
2299 return srv.(DatabaseServiceServer).IsSubscriptionActive(ctx, in)
2300 }
2301 info := &grpc.UnaryServerInfo{
2302 Server: srv,
2303 FullMethod: DatabaseService_IsSubscriptionActive_FullMethodName,
2304 }
2305 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2306 return srv.(DatabaseServiceServer).IsSubscriptionActive(ctx, req.(*IsSubscriptionActiveRequest))
2307 }
2308 return interceptor(ctx, in, info, handler)
2309 }
2310
2311 func _DatabaseService_ExtendSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2312 in := new(ExtendSubscriptionRequest)
2313 if err := dec(in); err != nil {
2314 return nil, err
2315 }
2316 if interceptor == nil {
2317 return srv.(DatabaseServiceServer).ExtendSubscription(ctx, in)
2318 }
2319 info := &grpc.UnaryServerInfo{
2320 Server: srv,
2321 FullMethod: DatabaseService_ExtendSubscription_FullMethodName,
2322 }
2323 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2324 return srv.(DatabaseServiceServer).ExtendSubscription(ctx, req.(*ExtendSubscriptionRequest))
2325 }
2326 return interceptor(ctx, in, info, handler)
2327 }
2328
2329 func _DatabaseService_RecordPayment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2330 in := new(RecordPaymentRequest)
2331 if err := dec(in); err != nil {
2332 return nil, err
2333 }
2334 if interceptor == nil {
2335 return srv.(DatabaseServiceServer).RecordPayment(ctx, in)
2336 }
2337 info := &grpc.UnaryServerInfo{
2338 Server: srv,
2339 FullMethod: DatabaseService_RecordPayment_FullMethodName,
2340 }
2341 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2342 return srv.(DatabaseServiceServer).RecordPayment(ctx, req.(*RecordPaymentRequest))
2343 }
2344 return interceptor(ctx, in, info, handler)
2345 }
2346
2347 func _DatabaseService_GetPaymentHistory_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2348 in := new(GetPaymentHistoryRequest)
2349 if err := dec(in); err != nil {
2350 return nil, err
2351 }
2352 if interceptor == nil {
2353 return srv.(DatabaseServiceServer).GetPaymentHistory(ctx, in)
2354 }
2355 info := &grpc.UnaryServerInfo{
2356 Server: srv,
2357 FullMethod: DatabaseService_GetPaymentHistory_FullMethodName,
2358 }
2359 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2360 return srv.(DatabaseServiceServer).GetPaymentHistory(ctx, req.(*GetPaymentHistoryRequest))
2361 }
2362 return interceptor(ctx, in, info, handler)
2363 }
2364
2365 func _DatabaseService_ExtendBlossomSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2366 in := new(ExtendBlossomSubscriptionRequest)
2367 if err := dec(in); err != nil {
2368 return nil, err
2369 }
2370 if interceptor == nil {
2371 return srv.(DatabaseServiceServer).ExtendBlossomSubscription(ctx, in)
2372 }
2373 info := &grpc.UnaryServerInfo{
2374 Server: srv,
2375 FullMethod: DatabaseService_ExtendBlossomSubscription_FullMethodName,
2376 }
2377 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2378 return srv.(DatabaseServiceServer).ExtendBlossomSubscription(ctx, req.(*ExtendBlossomSubscriptionRequest))
2379 }
2380 return interceptor(ctx, in, info, handler)
2381 }
2382
2383 func _DatabaseService_GetBlossomStorageQuota_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2384 in := new(GetBlossomStorageQuotaRequest)
2385 if err := dec(in); err != nil {
2386 return nil, err
2387 }
2388 if interceptor == nil {
2389 return srv.(DatabaseServiceServer).GetBlossomStorageQuota(ctx, in)
2390 }
2391 info := &grpc.UnaryServerInfo{
2392 Server: srv,
2393 FullMethod: DatabaseService_GetBlossomStorageQuota_FullMethodName,
2394 }
2395 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2396 return srv.(DatabaseServiceServer).GetBlossomStorageQuota(ctx, req.(*GetBlossomStorageQuotaRequest))
2397 }
2398 return interceptor(ctx, in, info, handler)
2399 }
2400
2401 func _DatabaseService_IsFirstTimeUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2402 in := new(IsFirstTimeUserRequest)
2403 if err := dec(in); err != nil {
2404 return nil, err
2405 }
2406 if interceptor == nil {
2407 return srv.(DatabaseServiceServer).IsFirstTimeUser(ctx, in)
2408 }
2409 info := &grpc.UnaryServerInfo{
2410 Server: srv,
2411 FullMethod: DatabaseService_IsFirstTimeUser_FullMethodName,
2412 }
2413 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2414 return srv.(DatabaseServiceServer).IsFirstTimeUser(ctx, req.(*IsFirstTimeUserRequest))
2415 }
2416 return interceptor(ctx, in, info, handler)
2417 }
2418
2419 func _DatabaseService_SavePaidSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2420 in := new(PaidSubscriptionMsg)
2421 if err := dec(in); err != nil {
2422 return nil, err
2423 }
2424 if interceptor == nil {
2425 return srv.(DatabaseServiceServer).SavePaidSubscription(ctx, in)
2426 }
2427 info := &grpc.UnaryServerInfo{
2428 Server: srv,
2429 FullMethod: DatabaseService_SavePaidSubscription_FullMethodName,
2430 }
2431 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2432 return srv.(DatabaseServiceServer).SavePaidSubscription(ctx, req.(*PaidSubscriptionMsg))
2433 }
2434 return interceptor(ctx, in, info, handler)
2435 }
2436
2437 func _DatabaseService_GetPaidSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2438 in := new(GetPaidSubscriptionRequest)
2439 if err := dec(in); err != nil {
2440 return nil, err
2441 }
2442 if interceptor == nil {
2443 return srv.(DatabaseServiceServer).GetPaidSubscription(ctx, in)
2444 }
2445 info := &grpc.UnaryServerInfo{
2446 Server: srv,
2447 FullMethod: DatabaseService_GetPaidSubscription_FullMethodName,
2448 }
2449 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2450 return srv.(DatabaseServiceServer).GetPaidSubscription(ctx, req.(*GetPaidSubscriptionRequest))
2451 }
2452 return interceptor(ctx, in, info, handler)
2453 }
2454
2455 func _DatabaseService_DeletePaidSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2456 in := new(DeletePaidSubscriptionRequest)
2457 if err := dec(in); err != nil {
2458 return nil, err
2459 }
2460 if interceptor == nil {
2461 return srv.(DatabaseServiceServer).DeletePaidSubscription(ctx, in)
2462 }
2463 info := &grpc.UnaryServerInfo{
2464 Server: srv,
2465 FullMethod: DatabaseService_DeletePaidSubscription_FullMethodName,
2466 }
2467 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2468 return srv.(DatabaseServiceServer).DeletePaidSubscription(ctx, req.(*DeletePaidSubscriptionRequest))
2469 }
2470 return interceptor(ctx, in, info, handler)
2471 }
2472
2473 func _DatabaseService_ListPaidSubscriptions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2474 in := new(Empty)
2475 if err := dec(in); err != nil {
2476 return nil, err
2477 }
2478 if interceptor == nil {
2479 return srv.(DatabaseServiceServer).ListPaidSubscriptions(ctx, in)
2480 }
2481 info := &grpc.UnaryServerInfo{
2482 Server: srv,
2483 FullMethod: DatabaseService_ListPaidSubscriptions_FullMethodName,
2484 }
2485 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2486 return srv.(DatabaseServiceServer).ListPaidSubscriptions(ctx, req.(*Empty))
2487 }
2488 return interceptor(ctx, in, info, handler)
2489 }
2490
2491 func _DatabaseService_ClaimAlias_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2492 in := new(ClaimAliasRequest)
2493 if err := dec(in); err != nil {
2494 return nil, err
2495 }
2496 if interceptor == nil {
2497 return srv.(DatabaseServiceServer).ClaimAlias(ctx, in)
2498 }
2499 info := &grpc.UnaryServerInfo{
2500 Server: srv,
2501 FullMethod: DatabaseService_ClaimAlias_FullMethodName,
2502 }
2503 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2504 return srv.(DatabaseServiceServer).ClaimAlias(ctx, req.(*ClaimAliasRequest))
2505 }
2506 return interceptor(ctx, in, info, handler)
2507 }
2508
2509 func _DatabaseService_GetAliasByPubkey_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2510 in := new(GetAliasByPubkeyRequest)
2511 if err := dec(in); err != nil {
2512 return nil, err
2513 }
2514 if interceptor == nil {
2515 return srv.(DatabaseServiceServer).GetAliasByPubkey(ctx, in)
2516 }
2517 info := &grpc.UnaryServerInfo{
2518 Server: srv,
2519 FullMethod: DatabaseService_GetAliasByPubkey_FullMethodName,
2520 }
2521 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2522 return srv.(DatabaseServiceServer).GetAliasByPubkey(ctx, req.(*GetAliasByPubkeyRequest))
2523 }
2524 return interceptor(ctx, in, info, handler)
2525 }
2526
2527 func _DatabaseService_GetPubkeyByAlias_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2528 in := new(GetPubkeyByAliasRequest)
2529 if err := dec(in); err != nil {
2530 return nil, err
2531 }
2532 if interceptor == nil {
2533 return srv.(DatabaseServiceServer).GetPubkeyByAlias(ctx, in)
2534 }
2535 info := &grpc.UnaryServerInfo{
2536 Server: srv,
2537 FullMethod: DatabaseService_GetPubkeyByAlias_FullMethodName,
2538 }
2539 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2540 return srv.(DatabaseServiceServer).GetPubkeyByAlias(ctx, req.(*GetPubkeyByAliasRequest))
2541 }
2542 return interceptor(ctx, in, info, handler)
2543 }
2544
2545 func _DatabaseService_IsAliasTaken_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2546 in := new(IsAliasTakenRequest)
2547 if err := dec(in); err != nil {
2548 return nil, err
2549 }
2550 if interceptor == nil {
2551 return srv.(DatabaseServiceServer).IsAliasTaken(ctx, in)
2552 }
2553 info := &grpc.UnaryServerInfo{
2554 Server: srv,
2555 FullMethod: DatabaseService_IsAliasTaken_FullMethodName,
2556 }
2557 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2558 return srv.(DatabaseServiceServer).IsAliasTaken(ctx, req.(*IsAliasTakenRequest))
2559 }
2560 return interceptor(ctx, in, info, handler)
2561 }
2562
2563 func _DatabaseService_AddNIP43Member_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2564 in := new(AddNIP43MemberRequest)
2565 if err := dec(in); err != nil {
2566 return nil, err
2567 }
2568 if interceptor == nil {
2569 return srv.(DatabaseServiceServer).AddNIP43Member(ctx, in)
2570 }
2571 info := &grpc.UnaryServerInfo{
2572 Server: srv,
2573 FullMethod: DatabaseService_AddNIP43Member_FullMethodName,
2574 }
2575 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2576 return srv.(DatabaseServiceServer).AddNIP43Member(ctx, req.(*AddNIP43MemberRequest))
2577 }
2578 return interceptor(ctx, in, info, handler)
2579 }
2580
2581 func _DatabaseService_RemoveNIP43Member_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2582 in := new(RemoveNIP43MemberRequest)
2583 if err := dec(in); err != nil {
2584 return nil, err
2585 }
2586 if interceptor == nil {
2587 return srv.(DatabaseServiceServer).RemoveNIP43Member(ctx, in)
2588 }
2589 info := &grpc.UnaryServerInfo{
2590 Server: srv,
2591 FullMethod: DatabaseService_RemoveNIP43Member_FullMethodName,
2592 }
2593 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2594 return srv.(DatabaseServiceServer).RemoveNIP43Member(ctx, req.(*RemoveNIP43MemberRequest))
2595 }
2596 return interceptor(ctx, in, info, handler)
2597 }
2598
2599 func _DatabaseService_IsNIP43Member_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2600 in := new(IsNIP43MemberRequest)
2601 if err := dec(in); err != nil {
2602 return nil, err
2603 }
2604 if interceptor == nil {
2605 return srv.(DatabaseServiceServer).IsNIP43Member(ctx, in)
2606 }
2607 info := &grpc.UnaryServerInfo{
2608 Server: srv,
2609 FullMethod: DatabaseService_IsNIP43Member_FullMethodName,
2610 }
2611 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2612 return srv.(DatabaseServiceServer).IsNIP43Member(ctx, req.(*IsNIP43MemberRequest))
2613 }
2614 return interceptor(ctx, in, info, handler)
2615 }
2616
2617 func _DatabaseService_GetNIP43Membership_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2618 in := new(GetNIP43MembershipRequest)
2619 if err := dec(in); err != nil {
2620 return nil, err
2621 }
2622 if interceptor == nil {
2623 return srv.(DatabaseServiceServer).GetNIP43Membership(ctx, in)
2624 }
2625 info := &grpc.UnaryServerInfo{
2626 Server: srv,
2627 FullMethod: DatabaseService_GetNIP43Membership_FullMethodName,
2628 }
2629 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2630 return srv.(DatabaseServiceServer).GetNIP43Membership(ctx, req.(*GetNIP43MembershipRequest))
2631 }
2632 return interceptor(ctx, in, info, handler)
2633 }
2634
2635 func _DatabaseService_GetAllNIP43Members_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2636 in := new(Empty)
2637 if err := dec(in); err != nil {
2638 return nil, err
2639 }
2640 if interceptor == nil {
2641 return srv.(DatabaseServiceServer).GetAllNIP43Members(ctx, in)
2642 }
2643 info := &grpc.UnaryServerInfo{
2644 Server: srv,
2645 FullMethod: DatabaseService_GetAllNIP43Members_FullMethodName,
2646 }
2647 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2648 return srv.(DatabaseServiceServer).GetAllNIP43Members(ctx, req.(*Empty))
2649 }
2650 return interceptor(ctx, in, info, handler)
2651 }
2652
2653 func _DatabaseService_StoreInviteCode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2654 in := new(StoreInviteCodeRequest)
2655 if err := dec(in); err != nil {
2656 return nil, err
2657 }
2658 if interceptor == nil {
2659 return srv.(DatabaseServiceServer).StoreInviteCode(ctx, in)
2660 }
2661 info := &grpc.UnaryServerInfo{
2662 Server: srv,
2663 FullMethod: DatabaseService_StoreInviteCode_FullMethodName,
2664 }
2665 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2666 return srv.(DatabaseServiceServer).StoreInviteCode(ctx, req.(*StoreInviteCodeRequest))
2667 }
2668 return interceptor(ctx, in, info, handler)
2669 }
2670
2671 func _DatabaseService_ValidateInviteCode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2672 in := new(ValidateInviteCodeRequest)
2673 if err := dec(in); err != nil {
2674 return nil, err
2675 }
2676 if interceptor == nil {
2677 return srv.(DatabaseServiceServer).ValidateInviteCode(ctx, in)
2678 }
2679 info := &grpc.UnaryServerInfo{
2680 Server: srv,
2681 FullMethod: DatabaseService_ValidateInviteCode_FullMethodName,
2682 }
2683 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2684 return srv.(DatabaseServiceServer).ValidateInviteCode(ctx, req.(*ValidateInviteCodeRequest))
2685 }
2686 return interceptor(ctx, in, info, handler)
2687 }
2688
2689 func _DatabaseService_DeleteInviteCode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2690 in := new(DeleteInviteCodeRequest)
2691 if err := dec(in); err != nil {
2692 return nil, err
2693 }
2694 if interceptor == nil {
2695 return srv.(DatabaseServiceServer).DeleteInviteCode(ctx, in)
2696 }
2697 info := &grpc.UnaryServerInfo{
2698 Server: srv,
2699 FullMethod: DatabaseService_DeleteInviteCode_FullMethodName,
2700 }
2701 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2702 return srv.(DatabaseServiceServer).DeleteInviteCode(ctx, req.(*DeleteInviteCodeRequest))
2703 }
2704 return interceptor(ctx, in, info, handler)
2705 }
2706
2707 func _DatabaseService_PublishNIP43MembershipEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2708 in := new(PublishNIP43MembershipEventRequest)
2709 if err := dec(in); err != nil {
2710 return nil, err
2711 }
2712 if interceptor == nil {
2713 return srv.(DatabaseServiceServer).PublishNIP43MembershipEvent(ctx, in)
2714 }
2715 info := &grpc.UnaryServerInfo{
2716 Server: srv,
2717 FullMethod: DatabaseService_PublishNIP43MembershipEvent_FullMethodName,
2718 }
2719 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2720 return srv.(DatabaseServiceServer).PublishNIP43MembershipEvent(ctx, req.(*PublishNIP43MembershipEventRequest))
2721 }
2722 return interceptor(ctx, in, info, handler)
2723 }
2724
2725 func _DatabaseService_GetCachedJSON_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2726 in := new(GetCachedJSONRequest)
2727 if err := dec(in); err != nil {
2728 return nil, err
2729 }
2730 if interceptor == nil {
2731 return srv.(DatabaseServiceServer).GetCachedJSON(ctx, in)
2732 }
2733 info := &grpc.UnaryServerInfo{
2734 Server: srv,
2735 FullMethod: DatabaseService_GetCachedJSON_FullMethodName,
2736 }
2737 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2738 return srv.(DatabaseServiceServer).GetCachedJSON(ctx, req.(*GetCachedJSONRequest))
2739 }
2740 return interceptor(ctx, in, info, handler)
2741 }
2742
2743 func _DatabaseService_CacheMarshaledJSON_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2744 in := new(CacheMarshaledJSONRequest)
2745 if err := dec(in); err != nil {
2746 return nil, err
2747 }
2748 if interceptor == nil {
2749 return srv.(DatabaseServiceServer).CacheMarshaledJSON(ctx, in)
2750 }
2751 info := &grpc.UnaryServerInfo{
2752 Server: srv,
2753 FullMethod: DatabaseService_CacheMarshaledJSON_FullMethodName,
2754 }
2755 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2756 return srv.(DatabaseServiceServer).CacheMarshaledJSON(ctx, req.(*CacheMarshaledJSONRequest))
2757 }
2758 return interceptor(ctx, in, info, handler)
2759 }
2760
2761 func _DatabaseService_GetCachedEvents_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2762 in := new(GetCachedEventsRequest)
2763 if err := dec(in); err != nil {
2764 return nil, err
2765 }
2766 if interceptor == nil {
2767 return srv.(DatabaseServiceServer).GetCachedEvents(ctx, in)
2768 }
2769 info := &grpc.UnaryServerInfo{
2770 Server: srv,
2771 FullMethod: DatabaseService_GetCachedEvents_FullMethodName,
2772 }
2773 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2774 return srv.(DatabaseServiceServer).GetCachedEvents(ctx, req.(*GetCachedEventsRequest))
2775 }
2776 return interceptor(ctx, in, info, handler)
2777 }
2778
2779 func _DatabaseService_CacheEvents_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2780 in := new(CacheEventsRequest)
2781 if err := dec(in); err != nil {
2782 return nil, err
2783 }
2784 if interceptor == nil {
2785 return srv.(DatabaseServiceServer).CacheEvents(ctx, in)
2786 }
2787 info := &grpc.UnaryServerInfo{
2788 Server: srv,
2789 FullMethod: DatabaseService_CacheEvents_FullMethodName,
2790 }
2791 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2792 return srv.(DatabaseServiceServer).CacheEvents(ctx, req.(*CacheEventsRequest))
2793 }
2794 return interceptor(ctx, in, info, handler)
2795 }
2796
2797 func _DatabaseService_InvalidateQueryCache_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2798 in := new(Empty)
2799 if err := dec(in); err != nil {
2800 return nil, err
2801 }
2802 if interceptor == nil {
2803 return srv.(DatabaseServiceServer).InvalidateQueryCache(ctx, in)
2804 }
2805 info := &grpc.UnaryServerInfo{
2806 Server: srv,
2807 FullMethod: DatabaseService_InvalidateQueryCache_FullMethodName,
2808 }
2809 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2810 return srv.(DatabaseServiceServer).InvalidateQueryCache(ctx, req.(*Empty))
2811 }
2812 return interceptor(ctx, in, info, handler)
2813 }
2814
2815 func _DatabaseService_RecordEventAccess_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2816 in := new(RecordEventAccessRequest)
2817 if err := dec(in); err != nil {
2818 return nil, err
2819 }
2820 if interceptor == nil {
2821 return srv.(DatabaseServiceServer).RecordEventAccess(ctx, in)
2822 }
2823 info := &grpc.UnaryServerInfo{
2824 Server: srv,
2825 FullMethod: DatabaseService_RecordEventAccess_FullMethodName,
2826 }
2827 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2828 return srv.(DatabaseServiceServer).RecordEventAccess(ctx, req.(*RecordEventAccessRequest))
2829 }
2830 return interceptor(ctx, in, info, handler)
2831 }
2832
2833 func _DatabaseService_GetEventAccessInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2834 in := new(GetEventAccessInfoRequest)
2835 if err := dec(in); err != nil {
2836 return nil, err
2837 }
2838 if interceptor == nil {
2839 return srv.(DatabaseServiceServer).GetEventAccessInfo(ctx, in)
2840 }
2841 info := &grpc.UnaryServerInfo{
2842 Server: srv,
2843 FullMethod: DatabaseService_GetEventAccessInfo_FullMethodName,
2844 }
2845 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2846 return srv.(DatabaseServiceServer).GetEventAccessInfo(ctx, req.(*GetEventAccessInfoRequest))
2847 }
2848 return interceptor(ctx, in, info, handler)
2849 }
2850
2851 func _DatabaseService_GetLeastAccessedEvents_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2852 in := new(GetLeastAccessedEventsRequest)
2853 if err := dec(in); err != nil {
2854 return nil, err
2855 }
2856 if interceptor == nil {
2857 return srv.(DatabaseServiceServer).GetLeastAccessedEvents(ctx, in)
2858 }
2859 info := &grpc.UnaryServerInfo{
2860 Server: srv,
2861 FullMethod: DatabaseService_GetLeastAccessedEvents_FullMethodName,
2862 }
2863 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2864 return srv.(DatabaseServiceServer).GetLeastAccessedEvents(ctx, req.(*GetLeastAccessedEventsRequest))
2865 }
2866 return interceptor(ctx, in, info, handler)
2867 }
2868
2869 func _DatabaseService_SaveBlob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2870 in := new(SaveBlobRequest)
2871 if err := dec(in); err != nil {
2872 return nil, err
2873 }
2874 if interceptor == nil {
2875 return srv.(DatabaseServiceServer).SaveBlob(ctx, in)
2876 }
2877 info := &grpc.UnaryServerInfo{
2878 Server: srv,
2879 FullMethod: DatabaseService_SaveBlob_FullMethodName,
2880 }
2881 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2882 return srv.(DatabaseServiceServer).SaveBlob(ctx, req.(*SaveBlobRequest))
2883 }
2884 return interceptor(ctx, in, info, handler)
2885 }
2886
2887 func _DatabaseService_SaveBlobMetadata_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2888 in := new(SaveBlobMetadataRequest)
2889 if err := dec(in); err != nil {
2890 return nil, err
2891 }
2892 if interceptor == nil {
2893 return srv.(DatabaseServiceServer).SaveBlobMetadata(ctx, in)
2894 }
2895 info := &grpc.UnaryServerInfo{
2896 Server: srv,
2897 FullMethod: DatabaseService_SaveBlobMetadata_FullMethodName,
2898 }
2899 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2900 return srv.(DatabaseServiceServer).SaveBlobMetadata(ctx, req.(*SaveBlobMetadataRequest))
2901 }
2902 return interceptor(ctx, in, info, handler)
2903 }
2904
2905 func _DatabaseService_GetBlob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2906 in := new(GetBlobRequest)
2907 if err := dec(in); err != nil {
2908 return nil, err
2909 }
2910 if interceptor == nil {
2911 return srv.(DatabaseServiceServer).GetBlob(ctx, in)
2912 }
2913 info := &grpc.UnaryServerInfo{
2914 Server: srv,
2915 FullMethod: DatabaseService_GetBlob_FullMethodName,
2916 }
2917 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2918 return srv.(DatabaseServiceServer).GetBlob(ctx, req.(*GetBlobRequest))
2919 }
2920 return interceptor(ctx, in, info, handler)
2921 }
2922
2923 func _DatabaseService_HasBlob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2924 in := new(HasBlobRequest)
2925 if err := dec(in); err != nil {
2926 return nil, err
2927 }
2928 if interceptor == nil {
2929 return srv.(DatabaseServiceServer).HasBlob(ctx, in)
2930 }
2931 info := &grpc.UnaryServerInfo{
2932 Server: srv,
2933 FullMethod: DatabaseService_HasBlob_FullMethodName,
2934 }
2935 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2936 return srv.(DatabaseServiceServer).HasBlob(ctx, req.(*HasBlobRequest))
2937 }
2938 return interceptor(ctx, in, info, handler)
2939 }
2940
2941 func _DatabaseService_DeleteBlob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2942 in := new(DeleteBlobRequest)
2943 if err := dec(in); err != nil {
2944 return nil, err
2945 }
2946 if interceptor == nil {
2947 return srv.(DatabaseServiceServer).DeleteBlob(ctx, in)
2948 }
2949 info := &grpc.UnaryServerInfo{
2950 Server: srv,
2951 FullMethod: DatabaseService_DeleteBlob_FullMethodName,
2952 }
2953 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2954 return srv.(DatabaseServiceServer).DeleteBlob(ctx, req.(*DeleteBlobRequest))
2955 }
2956 return interceptor(ctx, in, info, handler)
2957 }
2958
2959 func _DatabaseService_ListBlobs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2960 in := new(ListBlobsRequest)
2961 if err := dec(in); err != nil {
2962 return nil, err
2963 }
2964 if interceptor == nil {
2965 return srv.(DatabaseServiceServer).ListBlobs(ctx, in)
2966 }
2967 info := &grpc.UnaryServerInfo{
2968 Server: srv,
2969 FullMethod: DatabaseService_ListBlobs_FullMethodName,
2970 }
2971 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2972 return srv.(DatabaseServiceServer).ListBlobs(ctx, req.(*ListBlobsRequest))
2973 }
2974 return interceptor(ctx, in, info, handler)
2975 }
2976
2977 func _DatabaseService_GetBlobMetadata_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2978 in := new(GetBlobMetadataRequest)
2979 if err := dec(in); err != nil {
2980 return nil, err
2981 }
2982 if interceptor == nil {
2983 return srv.(DatabaseServiceServer).GetBlobMetadata(ctx, in)
2984 }
2985 info := &grpc.UnaryServerInfo{
2986 Server: srv,
2987 FullMethod: DatabaseService_GetBlobMetadata_FullMethodName,
2988 }
2989 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2990 return srv.(DatabaseServiceServer).GetBlobMetadata(ctx, req.(*GetBlobMetadataRequest))
2991 }
2992 return interceptor(ctx, in, info, handler)
2993 }
2994
2995 func _DatabaseService_GetTotalBlobStorageUsed_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
2996 in := new(GetTotalBlobStorageUsedRequest)
2997 if err := dec(in); err != nil {
2998 return nil, err
2999 }
3000 if interceptor == nil {
3001 return srv.(DatabaseServiceServer).GetTotalBlobStorageUsed(ctx, in)
3002 }
3003 info := &grpc.UnaryServerInfo{
3004 Server: srv,
3005 FullMethod: DatabaseService_GetTotalBlobStorageUsed_FullMethodName,
3006 }
3007 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3008 return srv.(DatabaseServiceServer).GetTotalBlobStorageUsed(ctx, req.(*GetTotalBlobStorageUsedRequest))
3009 }
3010 return interceptor(ctx, in, info, handler)
3011 }
3012
3013 func _DatabaseService_SaveBlobReport_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3014 in := new(SaveBlobReportRequest)
3015 if err := dec(in); err != nil {
3016 return nil, err
3017 }
3018 if interceptor == nil {
3019 return srv.(DatabaseServiceServer).SaveBlobReport(ctx, in)
3020 }
3021 info := &grpc.UnaryServerInfo{
3022 Server: srv,
3023 FullMethod: DatabaseService_SaveBlobReport_FullMethodName,
3024 }
3025 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3026 return srv.(DatabaseServiceServer).SaveBlobReport(ctx, req.(*SaveBlobReportRequest))
3027 }
3028 return interceptor(ctx, in, info, handler)
3029 }
3030
3031 func _DatabaseService_ListAllBlobUserStats_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3032 in := new(Empty)
3033 if err := dec(in); err != nil {
3034 return nil, err
3035 }
3036 if interceptor == nil {
3037 return srv.(DatabaseServiceServer).ListAllBlobUserStats(ctx, in)
3038 }
3039 info := &grpc.UnaryServerInfo{
3040 Server: srv,
3041 FullMethod: DatabaseService_ListAllBlobUserStats_FullMethodName,
3042 }
3043 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3044 return srv.(DatabaseServiceServer).ListAllBlobUserStats(ctx, req.(*Empty))
3045 }
3046 return interceptor(ctx, in, info, handler)
3047 }
3048
3049 func _DatabaseService_ReconcileBlobMetadata_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3050 in := new(Empty)
3051 if err := dec(in); err != nil {
3052 return nil, err
3053 }
3054 if interceptor == nil {
3055 return srv.(DatabaseServiceServer).ReconcileBlobMetadata(ctx, in)
3056 }
3057 info := &grpc.UnaryServerInfo{
3058 Server: srv,
3059 FullMethod: DatabaseService_ReconcileBlobMetadata_FullMethodName,
3060 }
3061 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3062 return srv.(DatabaseServiceServer).ReconcileBlobMetadata(ctx, req.(*Empty))
3063 }
3064 return interceptor(ctx, in, info, handler)
3065 }
3066
3067 func _DatabaseService_ListAllBlobs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3068 in := new(Empty)
3069 if err := dec(in); err != nil {
3070 return nil, err
3071 }
3072 if interceptor == nil {
3073 return srv.(DatabaseServiceServer).ListAllBlobs(ctx, in)
3074 }
3075 info := &grpc.UnaryServerInfo{
3076 Server: srv,
3077 FullMethod: DatabaseService_ListAllBlobs_FullMethodName,
3078 }
3079 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3080 return srv.(DatabaseServiceServer).ListAllBlobs(ctx, req.(*Empty))
3081 }
3082 return interceptor(ctx, in, info, handler)
3083 }
3084
3085 func _DatabaseService_GetThumbnail_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3086 in := new(GetThumbnailRequest)
3087 if err := dec(in); err != nil {
3088 return nil, err
3089 }
3090 if interceptor == nil {
3091 return srv.(DatabaseServiceServer).GetThumbnail(ctx, in)
3092 }
3093 info := &grpc.UnaryServerInfo{
3094 Server: srv,
3095 FullMethod: DatabaseService_GetThumbnail_FullMethodName,
3096 }
3097 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3098 return srv.(DatabaseServiceServer).GetThumbnail(ctx, req.(*GetThumbnailRequest))
3099 }
3100 return interceptor(ctx, in, info, handler)
3101 }
3102
3103 func _DatabaseService_SaveThumbnail_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3104 in := new(SaveThumbnailRequest)
3105 if err := dec(in); err != nil {
3106 return nil, err
3107 }
3108 if interceptor == nil {
3109 return srv.(DatabaseServiceServer).SaveThumbnail(ctx, in)
3110 }
3111 info := &grpc.UnaryServerInfo{
3112 Server: srv,
3113 FullMethod: DatabaseService_SaveThumbnail_FullMethodName,
3114 }
3115 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3116 return srv.(DatabaseServiceServer).SaveThumbnail(ctx, req.(*SaveThumbnailRequest))
3117 }
3118 return interceptor(ctx, in, info, handler)
3119 }
3120
3121 func _DatabaseService_EventIdsBySerial_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3122 in := new(EventIdsBySerialRequest)
3123 if err := dec(in); err != nil {
3124 return nil, err
3125 }
3126 if interceptor == nil {
3127 return srv.(DatabaseServiceServer).EventIdsBySerial(ctx, in)
3128 }
3129 info := &grpc.UnaryServerInfo{
3130 Server: srv,
3131 FullMethod: DatabaseService_EventIdsBySerial_FullMethodName,
3132 }
3133 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3134 return srv.(DatabaseServiceServer).EventIdsBySerial(ctx, req.(*EventIdsBySerialRequest))
3135 }
3136 return interceptor(ctx, in, info, handler)
3137 }
3138
3139 func _DatabaseService_RunMigrations_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3140 in := new(Empty)
3141 if err := dec(in); err != nil {
3142 return nil, err
3143 }
3144 if interceptor == nil {
3145 return srv.(DatabaseServiceServer).RunMigrations(ctx, in)
3146 }
3147 info := &grpc.UnaryServerInfo{
3148 Server: srv,
3149 FullMethod: DatabaseService_RunMigrations_FullMethodName,
3150 }
3151 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3152 return srv.(DatabaseServiceServer).RunMigrations(ctx, req.(*Empty))
3153 }
3154 return interceptor(ctx, in, info, handler)
3155 }
3156
3157 func _DatabaseService_ExecuteCypherRead_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3158 in := new(CypherReadRequest)
3159 if err := dec(in); err != nil {
3160 return nil, err
3161 }
3162 if interceptor == nil {
3163 return srv.(DatabaseServiceServer).ExecuteCypherRead(ctx, in)
3164 }
3165 info := &grpc.UnaryServerInfo{
3166 Server: srv,
3167 FullMethod: DatabaseService_ExecuteCypherRead_FullMethodName,
3168 }
3169 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
3170 return srv.(DatabaseServiceServer).ExecuteCypherRead(ctx, req.(*CypherReadRequest))
3171 }
3172 return interceptor(ctx, in, info, handler)
3173 }
3174
3175 // DatabaseService_ServiceDesc is the grpc.ServiceDesc for DatabaseService service.
3176 // It's only intended for direct use with grpc.RegisterService,
3177 // and not to be introspected or modified (even as a copy)
3178 var DatabaseService_ServiceDesc = grpc.ServiceDesc{
3179 ServiceName: "orlydb.v1.DatabaseService",
3180 HandlerType: (*DatabaseServiceServer)(nil),
3181 Methods: []grpc.MethodDesc{
3182 {
3183 MethodName: "GetPath",
3184 Handler: _DatabaseService_GetPath_Handler,
3185 },
3186 {
3187 MethodName: "Sync",
3188 Handler: _DatabaseService_Sync_Handler,
3189 },
3190 {
3191 MethodName: "Ready",
3192 Handler: _DatabaseService_Ready_Handler,
3193 },
3194 {
3195 MethodName: "SetLogLevel",
3196 Handler: _DatabaseService_SetLogLevel_Handler,
3197 },
3198 {
3199 MethodName: "SaveEvent",
3200 Handler: _DatabaseService_SaveEvent_Handler,
3201 },
3202 {
3203 MethodName: "GetSerialsFromFilter",
3204 Handler: _DatabaseService_GetSerialsFromFilter_Handler,
3205 },
3206 {
3207 MethodName: "WouldReplaceEvent",
3208 Handler: _DatabaseService_WouldReplaceEvent_Handler,
3209 },
3210 {
3211 MethodName: "QueryForSerials",
3212 Handler: _DatabaseService_QueryForSerials_Handler,
3213 },
3214 {
3215 MethodName: "QueryForIds",
3216 Handler: _DatabaseService_QueryForIds_Handler,
3217 },
3218 {
3219 MethodName: "CountEvents",
3220 Handler: _DatabaseService_CountEvents_Handler,
3221 },
3222 {
3223 MethodName: "FetchEventBySerial",
3224 Handler: _DatabaseService_FetchEventBySerial_Handler,
3225 },
3226 {
3227 MethodName: "FetchEventsBySerials",
3228 Handler: _DatabaseService_FetchEventsBySerials_Handler,
3229 },
3230 {
3231 MethodName: "GetSerialById",
3232 Handler: _DatabaseService_GetSerialById_Handler,
3233 },
3234 {
3235 MethodName: "GetSerialsByIds",
3236 Handler: _DatabaseService_GetSerialsByIds_Handler,
3237 },
3238 {
3239 MethodName: "GetSerialsByRange",
3240 Handler: _DatabaseService_GetSerialsByRange_Handler,
3241 },
3242 {
3243 MethodName: "GetFullIdPubkeyBySerial",
3244 Handler: _DatabaseService_GetFullIdPubkeyBySerial_Handler,
3245 },
3246 {
3247 MethodName: "GetFullIdPubkeyBySerials",
3248 Handler: _DatabaseService_GetFullIdPubkeyBySerials_Handler,
3249 },
3250 {
3251 MethodName: "DeleteEvent",
3252 Handler: _DatabaseService_DeleteEvent_Handler,
3253 },
3254 {
3255 MethodName: "DeleteEventBySerial",
3256 Handler: _DatabaseService_DeleteEventBySerial_Handler,
3257 },
3258 {
3259 MethodName: "DeleteExpired",
3260 Handler: _DatabaseService_DeleteExpired_Handler,
3261 },
3262 {
3263 MethodName: "ProcessDelete",
3264 Handler: _DatabaseService_ProcessDelete_Handler,
3265 },
3266 {
3267 MethodName: "CheckForDeleted",
3268 Handler: _DatabaseService_CheckForDeleted_Handler,
3269 },
3270 {
3271 MethodName: "ImportEventsFromStrings",
3272 Handler: _DatabaseService_ImportEventsFromStrings_Handler,
3273 },
3274 {
3275 MethodName: "GetRelayIdentitySecret",
3276 Handler: _DatabaseService_GetRelayIdentitySecret_Handler,
3277 },
3278 {
3279 MethodName: "SetRelayIdentitySecret",
3280 Handler: _DatabaseService_SetRelayIdentitySecret_Handler,
3281 },
3282 {
3283 MethodName: "GetOrCreateRelayIdentitySecret",
3284 Handler: _DatabaseService_GetOrCreateRelayIdentitySecret_Handler,
3285 },
3286 {
3287 MethodName: "SetMarker",
3288 Handler: _DatabaseService_SetMarker_Handler,
3289 },
3290 {
3291 MethodName: "GetMarker",
3292 Handler: _DatabaseService_GetMarker_Handler,
3293 },
3294 {
3295 MethodName: "HasMarker",
3296 Handler: _DatabaseService_HasMarker_Handler,
3297 },
3298 {
3299 MethodName: "DeleteMarker",
3300 Handler: _DatabaseService_DeleteMarker_Handler,
3301 },
3302 {
3303 MethodName: "GetSubscription",
3304 Handler: _DatabaseService_GetSubscription_Handler,
3305 },
3306 {
3307 MethodName: "IsSubscriptionActive",
3308 Handler: _DatabaseService_IsSubscriptionActive_Handler,
3309 },
3310 {
3311 MethodName: "ExtendSubscription",
3312 Handler: _DatabaseService_ExtendSubscription_Handler,
3313 },
3314 {
3315 MethodName: "RecordPayment",
3316 Handler: _DatabaseService_RecordPayment_Handler,
3317 },
3318 {
3319 MethodName: "GetPaymentHistory",
3320 Handler: _DatabaseService_GetPaymentHistory_Handler,
3321 },
3322 {
3323 MethodName: "ExtendBlossomSubscription",
3324 Handler: _DatabaseService_ExtendBlossomSubscription_Handler,
3325 },
3326 {
3327 MethodName: "GetBlossomStorageQuota",
3328 Handler: _DatabaseService_GetBlossomStorageQuota_Handler,
3329 },
3330 {
3331 MethodName: "IsFirstTimeUser",
3332 Handler: _DatabaseService_IsFirstTimeUser_Handler,
3333 },
3334 {
3335 MethodName: "SavePaidSubscription",
3336 Handler: _DatabaseService_SavePaidSubscription_Handler,
3337 },
3338 {
3339 MethodName: "GetPaidSubscription",
3340 Handler: _DatabaseService_GetPaidSubscription_Handler,
3341 },
3342 {
3343 MethodName: "DeletePaidSubscription",
3344 Handler: _DatabaseService_DeletePaidSubscription_Handler,
3345 },
3346 {
3347 MethodName: "ListPaidSubscriptions",
3348 Handler: _DatabaseService_ListPaidSubscriptions_Handler,
3349 },
3350 {
3351 MethodName: "ClaimAlias",
3352 Handler: _DatabaseService_ClaimAlias_Handler,
3353 },
3354 {
3355 MethodName: "GetAliasByPubkey",
3356 Handler: _DatabaseService_GetAliasByPubkey_Handler,
3357 },
3358 {
3359 MethodName: "GetPubkeyByAlias",
3360 Handler: _DatabaseService_GetPubkeyByAlias_Handler,
3361 },
3362 {
3363 MethodName: "IsAliasTaken",
3364 Handler: _DatabaseService_IsAliasTaken_Handler,
3365 },
3366 {
3367 MethodName: "AddNIP43Member",
3368 Handler: _DatabaseService_AddNIP43Member_Handler,
3369 },
3370 {
3371 MethodName: "RemoveNIP43Member",
3372 Handler: _DatabaseService_RemoveNIP43Member_Handler,
3373 },
3374 {
3375 MethodName: "IsNIP43Member",
3376 Handler: _DatabaseService_IsNIP43Member_Handler,
3377 },
3378 {
3379 MethodName: "GetNIP43Membership",
3380 Handler: _DatabaseService_GetNIP43Membership_Handler,
3381 },
3382 {
3383 MethodName: "GetAllNIP43Members",
3384 Handler: _DatabaseService_GetAllNIP43Members_Handler,
3385 },
3386 {
3387 MethodName: "StoreInviteCode",
3388 Handler: _DatabaseService_StoreInviteCode_Handler,
3389 },
3390 {
3391 MethodName: "ValidateInviteCode",
3392 Handler: _DatabaseService_ValidateInviteCode_Handler,
3393 },
3394 {
3395 MethodName: "DeleteInviteCode",
3396 Handler: _DatabaseService_DeleteInviteCode_Handler,
3397 },
3398 {
3399 MethodName: "PublishNIP43MembershipEvent",
3400 Handler: _DatabaseService_PublishNIP43MembershipEvent_Handler,
3401 },
3402 {
3403 MethodName: "GetCachedJSON",
3404 Handler: _DatabaseService_GetCachedJSON_Handler,
3405 },
3406 {
3407 MethodName: "CacheMarshaledJSON",
3408 Handler: _DatabaseService_CacheMarshaledJSON_Handler,
3409 },
3410 {
3411 MethodName: "GetCachedEvents",
3412 Handler: _DatabaseService_GetCachedEvents_Handler,
3413 },
3414 {
3415 MethodName: "CacheEvents",
3416 Handler: _DatabaseService_CacheEvents_Handler,
3417 },
3418 {
3419 MethodName: "InvalidateQueryCache",
3420 Handler: _DatabaseService_InvalidateQueryCache_Handler,
3421 },
3422 {
3423 MethodName: "RecordEventAccess",
3424 Handler: _DatabaseService_RecordEventAccess_Handler,
3425 },
3426 {
3427 MethodName: "GetEventAccessInfo",
3428 Handler: _DatabaseService_GetEventAccessInfo_Handler,
3429 },
3430 {
3431 MethodName: "GetLeastAccessedEvents",
3432 Handler: _DatabaseService_GetLeastAccessedEvents_Handler,
3433 },
3434 {
3435 MethodName: "SaveBlob",
3436 Handler: _DatabaseService_SaveBlob_Handler,
3437 },
3438 {
3439 MethodName: "SaveBlobMetadata",
3440 Handler: _DatabaseService_SaveBlobMetadata_Handler,
3441 },
3442 {
3443 MethodName: "GetBlob",
3444 Handler: _DatabaseService_GetBlob_Handler,
3445 },
3446 {
3447 MethodName: "HasBlob",
3448 Handler: _DatabaseService_HasBlob_Handler,
3449 },
3450 {
3451 MethodName: "DeleteBlob",
3452 Handler: _DatabaseService_DeleteBlob_Handler,
3453 },
3454 {
3455 MethodName: "ListBlobs",
3456 Handler: _DatabaseService_ListBlobs_Handler,
3457 },
3458 {
3459 MethodName: "GetBlobMetadata",
3460 Handler: _DatabaseService_GetBlobMetadata_Handler,
3461 },
3462 {
3463 MethodName: "GetTotalBlobStorageUsed",
3464 Handler: _DatabaseService_GetTotalBlobStorageUsed_Handler,
3465 },
3466 {
3467 MethodName: "SaveBlobReport",
3468 Handler: _DatabaseService_SaveBlobReport_Handler,
3469 },
3470 {
3471 MethodName: "ListAllBlobUserStats",
3472 Handler: _DatabaseService_ListAllBlobUserStats_Handler,
3473 },
3474 {
3475 MethodName: "ReconcileBlobMetadata",
3476 Handler: _DatabaseService_ReconcileBlobMetadata_Handler,
3477 },
3478 {
3479 MethodName: "ListAllBlobs",
3480 Handler: _DatabaseService_ListAllBlobs_Handler,
3481 },
3482 {
3483 MethodName: "GetThumbnail",
3484 Handler: _DatabaseService_GetThumbnail_Handler,
3485 },
3486 {
3487 MethodName: "SaveThumbnail",
3488 Handler: _DatabaseService_SaveThumbnail_Handler,
3489 },
3490 {
3491 MethodName: "EventIdsBySerial",
3492 Handler: _DatabaseService_EventIdsBySerial_Handler,
3493 },
3494 {
3495 MethodName: "RunMigrations",
3496 Handler: _DatabaseService_RunMigrations_Handler,
3497 },
3498 {
3499 MethodName: "ExecuteCypherRead",
3500 Handler: _DatabaseService_ExecuteCypherRead_Handler,
3501 },
3502 },
3503 Streams: []grpc.StreamDesc{
3504 {
3505 StreamName: "QueryEvents",
3506 Handler: _DatabaseService_QueryEvents_Handler,
3507 ServerStreams: true,
3508 },
3509 {
3510 StreamName: "QueryAllVersions",
3511 Handler: _DatabaseService_QueryAllVersions_Handler,
3512 ServerStreams: true,
3513 },
3514 {
3515 StreamName: "QueryEventsWithOptions",
3516 Handler: _DatabaseService_QueryEventsWithOptions_Handler,
3517 ServerStreams: true,
3518 },
3519 {
3520 StreamName: "QueryDeleteEventsByTargetId",
3521 Handler: _DatabaseService_QueryDeleteEventsByTargetId_Handler,
3522 ServerStreams: true,
3523 },
3524 {
3525 StreamName: "Import",
3526 Handler: _DatabaseService_Import_Handler,
3527 ClientStreams: true,
3528 },
3529 {
3530 StreamName: "Export",
3531 Handler: _DatabaseService_Export_Handler,
3532 ServerStreams: true,
3533 },
3534 },
3535 Metadata: "orlydb/v1/service.proto",
3536 }
3537