// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.6.0
// - protoc             (unknown)
// source: orlydb/v1/service.proto

package orlydbv1

import (
	context "context"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
)

// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.64.0 or later.
const _ = grpc.SupportPackageIsVersion9

const (
	DatabaseService_GetPath_FullMethodName                        = "/orlydb.v1.DatabaseService/GetPath"
	DatabaseService_Sync_FullMethodName                           = "/orlydb.v1.DatabaseService/Sync"
	DatabaseService_Ready_FullMethodName                          = "/orlydb.v1.DatabaseService/Ready"
	DatabaseService_SetLogLevel_FullMethodName                    = "/orlydb.v1.DatabaseService/SetLogLevel"
	DatabaseService_SaveEvent_FullMethodName                      = "/orlydb.v1.DatabaseService/SaveEvent"
	DatabaseService_GetSerialsFromFilter_FullMethodName           = "/orlydb.v1.DatabaseService/GetSerialsFromFilter"
	DatabaseService_WouldReplaceEvent_FullMethodName              = "/orlydb.v1.DatabaseService/WouldReplaceEvent"
	DatabaseService_QueryEvents_FullMethodName                    = "/orlydb.v1.DatabaseService/QueryEvents"
	DatabaseService_QueryAllVersions_FullMethodName               = "/orlydb.v1.DatabaseService/QueryAllVersions"
	DatabaseService_QueryEventsWithOptions_FullMethodName         = "/orlydb.v1.DatabaseService/QueryEventsWithOptions"
	DatabaseService_QueryDeleteEventsByTargetId_FullMethodName    = "/orlydb.v1.DatabaseService/QueryDeleteEventsByTargetId"
	DatabaseService_QueryForSerials_FullMethodName                = "/orlydb.v1.DatabaseService/QueryForSerials"
	DatabaseService_QueryForIds_FullMethodName                    = "/orlydb.v1.DatabaseService/QueryForIds"
	DatabaseService_CountEvents_FullMethodName                    = "/orlydb.v1.DatabaseService/CountEvents"
	DatabaseService_FetchEventBySerial_FullMethodName             = "/orlydb.v1.DatabaseService/FetchEventBySerial"
	DatabaseService_FetchEventsBySerials_FullMethodName           = "/orlydb.v1.DatabaseService/FetchEventsBySerials"
	DatabaseService_GetSerialById_FullMethodName                  = "/orlydb.v1.DatabaseService/GetSerialById"
	DatabaseService_GetSerialsByIds_FullMethodName                = "/orlydb.v1.DatabaseService/GetSerialsByIds"
	DatabaseService_GetSerialsByRange_FullMethodName              = "/orlydb.v1.DatabaseService/GetSerialsByRange"
	DatabaseService_GetFullIdPubkeyBySerial_FullMethodName        = "/orlydb.v1.DatabaseService/GetFullIdPubkeyBySerial"
	DatabaseService_GetFullIdPubkeyBySerials_FullMethodName       = "/orlydb.v1.DatabaseService/GetFullIdPubkeyBySerials"
	DatabaseService_DeleteEvent_FullMethodName                    = "/orlydb.v1.DatabaseService/DeleteEvent"
	DatabaseService_DeleteEventBySerial_FullMethodName            = "/orlydb.v1.DatabaseService/DeleteEventBySerial"
	DatabaseService_DeleteExpired_FullMethodName                  = "/orlydb.v1.DatabaseService/DeleteExpired"
	DatabaseService_ProcessDelete_FullMethodName                  = "/orlydb.v1.DatabaseService/ProcessDelete"
	DatabaseService_CheckForDeleted_FullMethodName                = "/orlydb.v1.DatabaseService/CheckForDeleted"
	DatabaseService_Import_FullMethodName                         = "/orlydb.v1.DatabaseService/Import"
	DatabaseService_Export_FullMethodName                         = "/orlydb.v1.DatabaseService/Export"
	DatabaseService_ImportEventsFromStrings_FullMethodName        = "/orlydb.v1.DatabaseService/ImportEventsFromStrings"
	DatabaseService_GetRelayIdentitySecret_FullMethodName         = "/orlydb.v1.DatabaseService/GetRelayIdentitySecret"
	DatabaseService_SetRelayIdentitySecret_FullMethodName         = "/orlydb.v1.DatabaseService/SetRelayIdentitySecret"
	DatabaseService_GetOrCreateRelayIdentitySecret_FullMethodName = "/orlydb.v1.DatabaseService/GetOrCreateRelayIdentitySecret"
	DatabaseService_SetMarker_FullMethodName                      = "/orlydb.v1.DatabaseService/SetMarker"
	DatabaseService_GetMarker_FullMethodName                      = "/orlydb.v1.DatabaseService/GetMarker"
	DatabaseService_HasMarker_FullMethodName                      = "/orlydb.v1.DatabaseService/HasMarker"
	DatabaseService_DeleteMarker_FullMethodName                   = "/orlydb.v1.DatabaseService/DeleteMarker"
	DatabaseService_GetSubscription_FullMethodName                = "/orlydb.v1.DatabaseService/GetSubscription"
	DatabaseService_IsSubscriptionActive_FullMethodName           = "/orlydb.v1.DatabaseService/IsSubscriptionActive"
	DatabaseService_ExtendSubscription_FullMethodName             = "/orlydb.v1.DatabaseService/ExtendSubscription"
	DatabaseService_RecordPayment_FullMethodName                  = "/orlydb.v1.DatabaseService/RecordPayment"
	DatabaseService_GetPaymentHistory_FullMethodName              = "/orlydb.v1.DatabaseService/GetPaymentHistory"
	DatabaseService_ExtendBlossomSubscription_FullMethodName      = "/orlydb.v1.DatabaseService/ExtendBlossomSubscription"
	DatabaseService_GetBlossomStorageQuota_FullMethodName         = "/orlydb.v1.DatabaseService/GetBlossomStorageQuota"
	DatabaseService_IsFirstTimeUser_FullMethodName                = "/orlydb.v1.DatabaseService/IsFirstTimeUser"
	DatabaseService_SavePaidSubscription_FullMethodName           = "/orlydb.v1.DatabaseService/SavePaidSubscription"
	DatabaseService_GetPaidSubscription_FullMethodName            = "/orlydb.v1.DatabaseService/GetPaidSubscription"
	DatabaseService_DeletePaidSubscription_FullMethodName         = "/orlydb.v1.DatabaseService/DeletePaidSubscription"
	DatabaseService_ListPaidSubscriptions_FullMethodName          = "/orlydb.v1.DatabaseService/ListPaidSubscriptions"
	DatabaseService_ClaimAlias_FullMethodName                     = "/orlydb.v1.DatabaseService/ClaimAlias"
	DatabaseService_GetAliasByPubkey_FullMethodName               = "/orlydb.v1.DatabaseService/GetAliasByPubkey"
	DatabaseService_GetPubkeyByAlias_FullMethodName               = "/orlydb.v1.DatabaseService/GetPubkeyByAlias"
	DatabaseService_IsAliasTaken_FullMethodName                   = "/orlydb.v1.DatabaseService/IsAliasTaken"
	DatabaseService_AddNIP43Member_FullMethodName                 = "/orlydb.v1.DatabaseService/AddNIP43Member"
	DatabaseService_RemoveNIP43Member_FullMethodName              = "/orlydb.v1.DatabaseService/RemoveNIP43Member"
	DatabaseService_IsNIP43Member_FullMethodName                  = "/orlydb.v1.DatabaseService/IsNIP43Member"
	DatabaseService_GetNIP43Membership_FullMethodName             = "/orlydb.v1.DatabaseService/GetNIP43Membership"
	DatabaseService_GetAllNIP43Members_FullMethodName             = "/orlydb.v1.DatabaseService/GetAllNIP43Members"
	DatabaseService_StoreInviteCode_FullMethodName                = "/orlydb.v1.DatabaseService/StoreInviteCode"
	DatabaseService_ValidateInviteCode_FullMethodName             = "/orlydb.v1.DatabaseService/ValidateInviteCode"
	DatabaseService_DeleteInviteCode_FullMethodName               = "/orlydb.v1.DatabaseService/DeleteInviteCode"
	DatabaseService_PublishNIP43MembershipEvent_FullMethodName    = "/orlydb.v1.DatabaseService/PublishNIP43MembershipEvent"
	DatabaseService_GetCachedJSON_FullMethodName                  = "/orlydb.v1.DatabaseService/GetCachedJSON"
	DatabaseService_CacheMarshaledJSON_FullMethodName             = "/orlydb.v1.DatabaseService/CacheMarshaledJSON"
	DatabaseService_GetCachedEvents_FullMethodName                = "/orlydb.v1.DatabaseService/GetCachedEvents"
	DatabaseService_CacheEvents_FullMethodName                    = "/orlydb.v1.DatabaseService/CacheEvents"
	DatabaseService_InvalidateQueryCache_FullMethodName           = "/orlydb.v1.DatabaseService/InvalidateQueryCache"
	DatabaseService_RecordEventAccess_FullMethodName              = "/orlydb.v1.DatabaseService/RecordEventAccess"
	DatabaseService_GetEventAccessInfo_FullMethodName             = "/orlydb.v1.DatabaseService/GetEventAccessInfo"
	DatabaseService_GetLeastAccessedEvents_FullMethodName         = "/orlydb.v1.DatabaseService/GetLeastAccessedEvents"
	DatabaseService_SaveBlob_FullMethodName                       = "/orlydb.v1.DatabaseService/SaveBlob"
	DatabaseService_SaveBlobMetadata_FullMethodName               = "/orlydb.v1.DatabaseService/SaveBlobMetadata"
	DatabaseService_GetBlob_FullMethodName                        = "/orlydb.v1.DatabaseService/GetBlob"
	DatabaseService_HasBlob_FullMethodName                        = "/orlydb.v1.DatabaseService/HasBlob"
	DatabaseService_DeleteBlob_FullMethodName                     = "/orlydb.v1.DatabaseService/DeleteBlob"
	DatabaseService_ListBlobs_FullMethodName                      = "/orlydb.v1.DatabaseService/ListBlobs"
	DatabaseService_GetBlobMetadata_FullMethodName                = "/orlydb.v1.DatabaseService/GetBlobMetadata"
	DatabaseService_GetTotalBlobStorageUsed_FullMethodName        = "/orlydb.v1.DatabaseService/GetTotalBlobStorageUsed"
	DatabaseService_SaveBlobReport_FullMethodName                 = "/orlydb.v1.DatabaseService/SaveBlobReport"
	DatabaseService_ListAllBlobUserStats_FullMethodName           = "/orlydb.v1.DatabaseService/ListAllBlobUserStats"
	DatabaseService_ReconcileBlobMetadata_FullMethodName          = "/orlydb.v1.DatabaseService/ReconcileBlobMetadata"
	DatabaseService_ListAllBlobs_FullMethodName                   = "/orlydb.v1.DatabaseService/ListAllBlobs"
	DatabaseService_GetThumbnail_FullMethodName                   = "/orlydb.v1.DatabaseService/GetThumbnail"
	DatabaseService_SaveThumbnail_FullMethodName                  = "/orlydb.v1.DatabaseService/SaveThumbnail"
	DatabaseService_EventIdsBySerial_FullMethodName               = "/orlydb.v1.DatabaseService/EventIdsBySerial"
	DatabaseService_RunMigrations_FullMethodName                  = "/orlydb.v1.DatabaseService/RunMigrations"
	DatabaseService_ExecuteCypherRead_FullMethodName              = "/orlydb.v1.DatabaseService/ExecuteCypherRead"
)

// DatabaseServiceClient is the client API for DatabaseService service.
//
// 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.
//
// DatabaseService provides gRPC access to the ORLY database
type DatabaseServiceClient interface {
	// GetPath returns the database file path
	GetPath(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PathResponse, error)
	// Sync flushes buffers to disk
	Sync(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	// Ready returns whether the database is ready to serve requests
	Ready(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ReadyResponse, error)
	// SetLogLevel sets the database log level
	SetLogLevel(ctx context.Context, in *SetLogLevelRequest, opts ...grpc.CallOption) (*Empty, error)
	// SaveEvent stores an event, returns whether it already existed
	SaveEvent(ctx context.Context, in *SaveEventRequest, opts ...grpc.CallOption) (*SaveEventResponse, error)
	// GetSerialsFromFilter gets serial numbers matching a filter
	GetSerialsFromFilter(ctx context.Context, in *GetSerialsFromFilterRequest, opts ...grpc.CallOption) (*SerialList, error)
	// WouldReplaceEvent checks if an event would replace existing ones
	WouldReplaceEvent(ctx context.Context, in *WouldReplaceEventRequest, opts ...grpc.CallOption) (*WouldReplaceEventResponse, error)
	// QueryEvents queries events matching a filter (with deletion filtering)
	QueryEvents(ctx context.Context, in *QueryEventsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[EventBatch], error)
	// QueryAllVersions queries all versions of replaceable events
	QueryAllVersions(ctx context.Context, in *QueryEventsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[EventBatch], error)
	// QueryEventsWithOptions provides full control over query behavior
	QueryEventsWithOptions(ctx context.Context, in *QueryEventsWithOptionsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[EventBatch], error)
	// QueryDeleteEventsByTargetId queries deletion events for a target
	QueryDeleteEventsByTargetId(ctx context.Context, in *QueryDeleteEventsByTargetIdRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[EventBatch], error)
	// QueryForSerials queries just serial numbers matching a filter
	QueryForSerials(ctx context.Context, in *QueryEventsRequest, opts ...grpc.CallOption) (*SerialList, error)
	// QueryForIds queries ID/Pubkey/Timestamp triplets
	QueryForIds(ctx context.Context, in *QueryEventsRequest, opts ...grpc.CallOption) (*IdPkTsList, error)
	// CountEvents counts events matching a filter
	CountEvents(ctx context.Context, in *QueryEventsRequest, opts ...grpc.CallOption) (*CountEventsResponse, error)
	// FetchEventBySerial fetches a single event by serial
	FetchEventBySerial(ctx context.Context, in *FetchEventBySerialRequest, opts ...grpc.CallOption) (*FetchEventBySerialResponse, error)
	// FetchEventsBySerials fetches multiple events by serial (batch)
	FetchEventsBySerials(ctx context.Context, in *FetchEventsBySerialRequest, opts ...grpc.CallOption) (*EventMap, error)
	// GetSerialById gets the serial for a single event ID
	GetSerialById(ctx context.Context, in *GetSerialByIdRequest, opts ...grpc.CallOption) (*GetSerialByIdResponse, error)
	// GetSerialsByIds gets serials for multiple event IDs
	GetSerialsByIds(ctx context.Context, in *GetSerialsByIdsRequest, opts ...grpc.CallOption) (*SerialMap, error)
	// GetSerialsByRange gets serials within an index range
	GetSerialsByRange(ctx context.Context, in *GetSerialsByRangeRequest, opts ...grpc.CallOption) (*SerialList, error)
	// GetFullIdPubkeyBySerial gets full ID/Pubkey/Timestamp for a serial
	GetFullIdPubkeyBySerial(ctx context.Context, in *GetFullIdPubkeyBySerialRequest, opts ...grpc.CallOption) (*IdPkTs, error)
	// GetFullIdPubkeyBySerials gets full data for multiple serials
	GetFullIdPubkeyBySerials(ctx context.Context, in *GetFullIdPubkeyBySerialsRequest, opts ...grpc.CallOption) (*IdPkTsList, error)
	// DeleteEvent deletes an event by ID
	DeleteEvent(ctx context.Context, in *DeleteEventRequest, opts ...grpc.CallOption) (*Empty, error)
	// DeleteEventBySerial deletes an event by serial
	DeleteEventBySerial(ctx context.Context, in *DeleteEventBySerialRequest, opts ...grpc.CallOption) (*Empty, error)
	// DeleteExpired deletes events with expired expiration tags
	DeleteExpired(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	// ProcessDelete processes a deletion event (NIP-09)
	ProcessDelete(ctx context.Context, in *ProcessDeleteRequest, opts ...grpc.CallOption) (*Empty, error)
	// CheckForDeleted checks if an event was deleted
	CheckForDeleted(ctx context.Context, in *CheckForDeletedRequest, opts ...grpc.CallOption) (*Empty, error)
	// Import imports events from a stream
	Import(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[ImportChunk, ImportResponse], error)
	// Export exports events to a stream
	Export(ctx context.Context, in *ExportRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ExportChunk], error)
	// ImportEventsFromStrings imports events from JSON strings
	ImportEventsFromStrings(ctx context.Context, in *ImportEventsFromStringsRequest, opts ...grpc.CallOption) (*ImportResponse, error)
	// GetRelayIdentitySecret gets the relay's secret key
	GetRelayIdentitySecret(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetRelayIdentitySecretResponse, error)
	// SetRelayIdentitySecret sets the relay's secret key
	SetRelayIdentitySecret(ctx context.Context, in *SetRelayIdentitySecretRequest, opts ...grpc.CallOption) (*Empty, error)
	// GetOrCreateRelayIdentitySecret gets or creates the relay's secret key
	GetOrCreateRelayIdentitySecret(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetRelayIdentitySecretResponse, error)
	// SetMarker sets a metadata marker
	SetMarker(ctx context.Context, in *SetMarkerRequest, opts ...grpc.CallOption) (*Empty, error)
	// GetMarker gets a metadata marker
	GetMarker(ctx context.Context, in *GetMarkerRequest, opts ...grpc.CallOption) (*GetMarkerResponse, error)
	// HasMarker checks if a marker exists
	HasMarker(ctx context.Context, in *HasMarkerRequest, opts ...grpc.CallOption) (*HasMarkerResponse, error)
	// DeleteMarker deletes a marker
	DeleteMarker(ctx context.Context, in *DeleteMarkerRequest, opts ...grpc.CallOption) (*Empty, error)
	// GetSubscription gets subscription info for a pubkey
	GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error)
	// IsSubscriptionActive checks if a subscription is active
	IsSubscriptionActive(ctx context.Context, in *IsSubscriptionActiveRequest, opts ...grpc.CallOption) (*IsSubscriptionActiveResponse, error)
	// ExtendSubscription extends a subscription by days
	ExtendSubscription(ctx context.Context, in *ExtendSubscriptionRequest, opts ...grpc.CallOption) (*Empty, error)
	// RecordPayment records a payment
	RecordPayment(ctx context.Context, in *RecordPaymentRequest, opts ...grpc.CallOption) (*Empty, error)
	// GetPaymentHistory gets payment history for a pubkey
	GetPaymentHistory(ctx context.Context, in *GetPaymentHistoryRequest, opts ...grpc.CallOption) (*PaymentList, error)
	// ExtendBlossomSubscription extends blossom storage subscription
	ExtendBlossomSubscription(ctx context.Context, in *ExtendBlossomSubscriptionRequest, opts ...grpc.CallOption) (*Empty, error)
	// GetBlossomStorageQuota gets blossom storage quota
	GetBlossomStorageQuota(ctx context.Context, in *GetBlossomStorageQuotaRequest, opts ...grpc.CallOption) (*GetBlossomStorageQuotaResponse, error)
	// IsFirstTimeUser checks if this is a first-time user
	IsFirstTimeUser(ctx context.Context, in *IsFirstTimeUserRequest, opts ...grpc.CallOption) (*IsFirstTimeUserResponse, error)
	// SavePaidSubscription saves or updates a paid subscription
	SavePaidSubscription(ctx context.Context, in *PaidSubscriptionMsg, opts ...grpc.CallOption) (*Empty, error)
	// GetPaidSubscription gets a paid subscription by pubkey hex
	GetPaidSubscription(ctx context.Context, in *GetPaidSubscriptionRequest, opts ...grpc.CallOption) (*PaidSubscriptionMsg, error)
	// DeletePaidSubscription deletes a paid subscription
	DeletePaidSubscription(ctx context.Context, in *DeletePaidSubscriptionRequest, opts ...grpc.CallOption) (*Empty, error)
	// ListPaidSubscriptions lists all paid subscriptions
	ListPaidSubscriptions(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PaidSubscriptionList, error)
	// ClaimAlias claims an email alias for a pubkey
	ClaimAlias(ctx context.Context, in *ClaimAliasRequest, opts ...grpc.CallOption) (*Empty, error)
	// GetAliasByPubkey gets the alias for a pubkey
	GetAliasByPubkey(ctx context.Context, in *GetAliasByPubkeyRequest, opts ...grpc.CallOption) (*AliasResponse, error)
	// GetPubkeyByAlias gets the pubkey for an alias
	GetPubkeyByAlias(ctx context.Context, in *GetPubkeyByAliasRequest, opts ...grpc.CallOption) (*PubkeyResponse, error)
	// IsAliasTaken checks if an alias is taken
	IsAliasTaken(ctx context.Context, in *IsAliasTakenRequest, opts ...grpc.CallOption) (*IsAliasTakenResponse, error)
	// AddNIP43Member adds a member via invite code
	AddNIP43Member(ctx context.Context, in *AddNIP43MemberRequest, opts ...grpc.CallOption) (*Empty, error)
	// RemoveNIP43Member removes a member
	RemoveNIP43Member(ctx context.Context, in *RemoveNIP43MemberRequest, opts ...grpc.CallOption) (*Empty, error)
	// IsNIP43Member checks if a pubkey is a member
	IsNIP43Member(ctx context.Context, in *IsNIP43MemberRequest, opts ...grpc.CallOption) (*IsNIP43MemberResponse, error)
	// GetNIP43Membership gets membership details
	GetNIP43Membership(ctx context.Context, in *GetNIP43MembershipRequest, opts ...grpc.CallOption) (*NIP43Membership, error)
	// GetAllNIP43Members gets all members
	GetAllNIP43Members(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PubkeyList, error)
	// StoreInviteCode stores an invite code with expiration
	StoreInviteCode(ctx context.Context, in *StoreInviteCodeRequest, opts ...grpc.CallOption) (*Empty, error)
	// ValidateInviteCode validates an invite code
	ValidateInviteCode(ctx context.Context, in *ValidateInviteCodeRequest, opts ...grpc.CallOption) (*ValidateInviteCodeResponse, error)
	// DeleteInviteCode deletes an invite code
	DeleteInviteCode(ctx context.Context, in *DeleteInviteCodeRequest, opts ...grpc.CallOption) (*Empty, error)
	// PublishNIP43MembershipEvent publishes a membership event
	PublishNIP43MembershipEvent(ctx context.Context, in *PublishNIP43MembershipEventRequest, opts ...grpc.CallOption) (*Empty, error)
	// GetCachedJSON gets cached JSON for a filter
	GetCachedJSON(ctx context.Context, in *GetCachedJSONRequest, opts ...grpc.CallOption) (*GetCachedJSONResponse, error)
	// CacheMarshaledJSON caches JSON for a filter
	CacheMarshaledJSON(ctx context.Context, in *CacheMarshaledJSONRequest, opts ...grpc.CallOption) (*Empty, error)
	// GetCachedEvents gets cached events for a filter
	GetCachedEvents(ctx context.Context, in *GetCachedEventsRequest, opts ...grpc.CallOption) (*GetCachedEventsResponse, error)
	// CacheEvents caches events for a filter
	CacheEvents(ctx context.Context, in *CacheEventsRequest, opts ...grpc.CallOption) (*Empty, error)
	// InvalidateQueryCache invalidates the entire query cache
	InvalidateQueryCache(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	// RecordEventAccess records an access to an event
	RecordEventAccess(ctx context.Context, in *RecordEventAccessRequest, opts ...grpc.CallOption) (*Empty, error)
	// GetEventAccessInfo gets access info for an event
	GetEventAccessInfo(ctx context.Context, in *GetEventAccessInfoRequest, opts ...grpc.CallOption) (*GetEventAccessInfoResponse, error)
	// GetLeastAccessedEvents gets least accessed events for GC
	GetLeastAccessedEvents(ctx context.Context, in *GetLeastAccessedEventsRequest, opts ...grpc.CallOption) (*SerialList, error)
	// SaveBlob stores a blob with its metadata
	SaveBlob(ctx context.Context, in *SaveBlobRequest, opts ...grpc.CallOption) (*Empty, error)
	// SaveBlobMetadata stores only metadata for a blob whose file is already on disk
	SaveBlobMetadata(ctx context.Context, in *SaveBlobMetadataRequest, opts ...grpc.CallOption) (*Empty, error)
	// GetBlob retrieves blob data and metadata
	GetBlob(ctx context.Context, in *GetBlobRequest, opts ...grpc.CallOption) (*GetBlobResponse, error)
	// HasBlob checks if a blob exists
	HasBlob(ctx context.Context, in *HasBlobRequest, opts ...grpc.CallOption) (*HasBlobResponse, error)
	// DeleteBlob deletes a blob
	DeleteBlob(ctx context.Context, in *DeleteBlobRequest, opts ...grpc.CallOption) (*Empty, error)
	// ListBlobs lists blobs for a pubkey
	ListBlobs(ctx context.Context, in *ListBlobsRequest, opts ...grpc.CallOption) (*ListBlobsResponse, error)
	// GetBlobMetadata gets only metadata for a blob
	GetBlobMetadata(ctx context.Context, in *GetBlobMetadataRequest, opts ...grpc.CallOption) (*BlobMetadata, error)
	// GetTotalBlobStorageUsed gets total storage used by a pubkey in MB
	GetTotalBlobStorageUsed(ctx context.Context, in *GetTotalBlobStorageUsedRequest, opts ...grpc.CallOption) (*GetTotalBlobStorageUsedResponse, error)
	// SaveBlobReport stores a report for a blob (BUD-09)
	SaveBlobReport(ctx context.Context, in *SaveBlobReportRequest, opts ...grpc.CallOption) (*Empty, error)
	// ListAllBlobUserStats gets storage statistics for all users
	ListAllBlobUserStats(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListAllBlobUserStatsResponse, error)
	// ReconcileBlobMetadata scans the blossom directory and creates metadata for orphan blobs
	ReconcileBlobMetadata(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ReconcileBlobMetadataResponse, error)
	// ListAllBlobs returns all blob descriptors (for admin thumbnail generation)
	ListAllBlobs(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListBlobsResponse, error)
	// GetThumbnail retrieves a cached thumbnail by key
	GetThumbnail(ctx context.Context, in *GetThumbnailRequest, opts ...grpc.CallOption) (*GetThumbnailResponse, error)
	// SaveThumbnail stores a cached thumbnail
	SaveThumbnail(ctx context.Context, in *SaveThumbnailRequest, opts ...grpc.CallOption) (*Empty, error)
	// EventIdsBySerial gets event IDs by serial range
	EventIdsBySerial(ctx context.Context, in *EventIdsBySerialRequest, opts ...grpc.CallOption) (*EventIdsBySerialResponse, error)
	// RunMigrations runs database migrations
	RunMigrations(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	// ExecuteCypherRead executes a read-only Cypher query against Neo4j
	ExecuteCypherRead(ctx context.Context, in *CypherReadRequest, opts ...grpc.CallOption) (*CypherReadResponse, error)
}

type databaseServiceClient struct {
	cc grpc.ClientConnInterface
}

func NewDatabaseServiceClient(cc grpc.ClientConnInterface) DatabaseServiceClient {
	return &databaseServiceClient{cc}
}

func (c *databaseServiceClient) GetPath(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PathResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(PathResponse)
	err := c.cc.Invoke(ctx, DatabaseService_GetPath_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) Sync(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_Sync_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) Ready(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ReadyResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ReadyResponse)
	err := c.cc.Invoke(ctx, DatabaseService_Ready_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) SetLogLevel(ctx context.Context, in *SetLogLevelRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_SetLogLevel_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) SaveEvent(ctx context.Context, in *SaveEventRequest, opts ...grpc.CallOption) (*SaveEventResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(SaveEventResponse)
	err := c.cc.Invoke(ctx, DatabaseService_SaveEvent_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetSerialsFromFilter(ctx context.Context, in *GetSerialsFromFilterRequest, opts ...grpc.CallOption) (*SerialList, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(SerialList)
	err := c.cc.Invoke(ctx, DatabaseService_GetSerialsFromFilter_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) WouldReplaceEvent(ctx context.Context, in *WouldReplaceEventRequest, opts ...grpc.CallOption) (*WouldReplaceEventResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(WouldReplaceEventResponse)
	err := c.cc.Invoke(ctx, DatabaseService_WouldReplaceEvent_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) QueryEvents(ctx context.Context, in *QueryEventsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[EventBatch], error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	stream, err := c.cc.NewStream(ctx, &DatabaseService_ServiceDesc.Streams[0], DatabaseService_QueryEvents_FullMethodName, cOpts...)
	if err != nil {
		return nil, err
	}
	x := &grpc.GenericClientStream[QueryEventsRequest, EventBatch]{ClientStream: stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatabaseService_QueryEventsClient = grpc.ServerStreamingClient[EventBatch]

func (c *databaseServiceClient) QueryAllVersions(ctx context.Context, in *QueryEventsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[EventBatch], error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	stream, err := c.cc.NewStream(ctx, &DatabaseService_ServiceDesc.Streams[1], DatabaseService_QueryAllVersions_FullMethodName, cOpts...)
	if err != nil {
		return nil, err
	}
	x := &grpc.GenericClientStream[QueryEventsRequest, EventBatch]{ClientStream: stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatabaseService_QueryAllVersionsClient = grpc.ServerStreamingClient[EventBatch]

func (c *databaseServiceClient) QueryEventsWithOptions(ctx context.Context, in *QueryEventsWithOptionsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[EventBatch], error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	stream, err := c.cc.NewStream(ctx, &DatabaseService_ServiceDesc.Streams[2], DatabaseService_QueryEventsWithOptions_FullMethodName, cOpts...)
	if err != nil {
		return nil, err
	}
	x := &grpc.GenericClientStream[QueryEventsWithOptionsRequest, EventBatch]{ClientStream: stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatabaseService_QueryEventsWithOptionsClient = grpc.ServerStreamingClient[EventBatch]

func (c *databaseServiceClient) QueryDeleteEventsByTargetId(ctx context.Context, in *QueryDeleteEventsByTargetIdRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[EventBatch], error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	stream, err := c.cc.NewStream(ctx, &DatabaseService_ServiceDesc.Streams[3], DatabaseService_QueryDeleteEventsByTargetId_FullMethodName, cOpts...)
	if err != nil {
		return nil, err
	}
	x := &grpc.GenericClientStream[QueryDeleteEventsByTargetIdRequest, EventBatch]{ClientStream: stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatabaseService_QueryDeleteEventsByTargetIdClient = grpc.ServerStreamingClient[EventBatch]

func (c *databaseServiceClient) QueryForSerials(ctx context.Context, in *QueryEventsRequest, opts ...grpc.CallOption) (*SerialList, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(SerialList)
	err := c.cc.Invoke(ctx, DatabaseService_QueryForSerials_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) QueryForIds(ctx context.Context, in *QueryEventsRequest, opts ...grpc.CallOption) (*IdPkTsList, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(IdPkTsList)
	err := c.cc.Invoke(ctx, DatabaseService_QueryForIds_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) CountEvents(ctx context.Context, in *QueryEventsRequest, opts ...grpc.CallOption) (*CountEventsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(CountEventsResponse)
	err := c.cc.Invoke(ctx, DatabaseService_CountEvents_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) FetchEventBySerial(ctx context.Context, in *FetchEventBySerialRequest, opts ...grpc.CallOption) (*FetchEventBySerialResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(FetchEventBySerialResponse)
	err := c.cc.Invoke(ctx, DatabaseService_FetchEventBySerial_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) FetchEventsBySerials(ctx context.Context, in *FetchEventsBySerialRequest, opts ...grpc.CallOption) (*EventMap, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(EventMap)
	err := c.cc.Invoke(ctx, DatabaseService_FetchEventsBySerials_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetSerialById(ctx context.Context, in *GetSerialByIdRequest, opts ...grpc.CallOption) (*GetSerialByIdResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(GetSerialByIdResponse)
	err := c.cc.Invoke(ctx, DatabaseService_GetSerialById_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetSerialsByIds(ctx context.Context, in *GetSerialsByIdsRequest, opts ...grpc.CallOption) (*SerialMap, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(SerialMap)
	err := c.cc.Invoke(ctx, DatabaseService_GetSerialsByIds_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetSerialsByRange(ctx context.Context, in *GetSerialsByRangeRequest, opts ...grpc.CallOption) (*SerialList, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(SerialList)
	err := c.cc.Invoke(ctx, DatabaseService_GetSerialsByRange_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetFullIdPubkeyBySerial(ctx context.Context, in *GetFullIdPubkeyBySerialRequest, opts ...grpc.CallOption) (*IdPkTs, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(IdPkTs)
	err := c.cc.Invoke(ctx, DatabaseService_GetFullIdPubkeyBySerial_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetFullIdPubkeyBySerials(ctx context.Context, in *GetFullIdPubkeyBySerialsRequest, opts ...grpc.CallOption) (*IdPkTsList, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(IdPkTsList)
	err := c.cc.Invoke(ctx, DatabaseService_GetFullIdPubkeyBySerials_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) DeleteEvent(ctx context.Context, in *DeleteEventRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_DeleteEvent_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) DeleteEventBySerial(ctx context.Context, in *DeleteEventBySerialRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_DeleteEventBySerial_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) DeleteExpired(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_DeleteExpired_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) ProcessDelete(ctx context.Context, in *ProcessDeleteRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_ProcessDelete_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) CheckForDeleted(ctx context.Context, in *CheckForDeletedRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_CheckForDeleted_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) Import(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[ImportChunk, ImportResponse], error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	stream, err := c.cc.NewStream(ctx, &DatabaseService_ServiceDesc.Streams[4], DatabaseService_Import_FullMethodName, cOpts...)
	if err != nil {
		return nil, err
	}
	x := &grpc.GenericClientStream[ImportChunk, ImportResponse]{ClientStream: stream}
	return x, nil
}

// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatabaseService_ImportClient = grpc.ClientStreamingClient[ImportChunk, ImportResponse]

func (c *databaseServiceClient) Export(ctx context.Context, in *ExportRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ExportChunk], error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	stream, err := c.cc.NewStream(ctx, &DatabaseService_ServiceDesc.Streams[5], DatabaseService_Export_FullMethodName, cOpts...)
	if err != nil {
		return nil, err
	}
	x := &grpc.GenericClientStream[ExportRequest, ExportChunk]{ClientStream: stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatabaseService_ExportClient = grpc.ServerStreamingClient[ExportChunk]

func (c *databaseServiceClient) ImportEventsFromStrings(ctx context.Context, in *ImportEventsFromStringsRequest, opts ...grpc.CallOption) (*ImportResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ImportResponse)
	err := c.cc.Invoke(ctx, DatabaseService_ImportEventsFromStrings_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetRelayIdentitySecret(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetRelayIdentitySecretResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(GetRelayIdentitySecretResponse)
	err := c.cc.Invoke(ctx, DatabaseService_GetRelayIdentitySecret_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) SetRelayIdentitySecret(ctx context.Context, in *SetRelayIdentitySecretRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_SetRelayIdentitySecret_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetOrCreateRelayIdentitySecret(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetRelayIdentitySecretResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(GetRelayIdentitySecretResponse)
	err := c.cc.Invoke(ctx, DatabaseService_GetOrCreateRelayIdentitySecret_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) SetMarker(ctx context.Context, in *SetMarkerRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_SetMarker_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetMarker(ctx context.Context, in *GetMarkerRequest, opts ...grpc.CallOption) (*GetMarkerResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(GetMarkerResponse)
	err := c.cc.Invoke(ctx, DatabaseService_GetMarker_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) HasMarker(ctx context.Context, in *HasMarkerRequest, opts ...grpc.CallOption) (*HasMarkerResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(HasMarkerResponse)
	err := c.cc.Invoke(ctx, DatabaseService_HasMarker_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) DeleteMarker(ctx context.Context, in *DeleteMarkerRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_DeleteMarker_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Subscription)
	err := c.cc.Invoke(ctx, DatabaseService_GetSubscription_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) IsSubscriptionActive(ctx context.Context, in *IsSubscriptionActiveRequest, opts ...grpc.CallOption) (*IsSubscriptionActiveResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(IsSubscriptionActiveResponse)
	err := c.cc.Invoke(ctx, DatabaseService_IsSubscriptionActive_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) ExtendSubscription(ctx context.Context, in *ExtendSubscriptionRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_ExtendSubscription_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) RecordPayment(ctx context.Context, in *RecordPaymentRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_RecordPayment_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetPaymentHistory(ctx context.Context, in *GetPaymentHistoryRequest, opts ...grpc.CallOption) (*PaymentList, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(PaymentList)
	err := c.cc.Invoke(ctx, DatabaseService_GetPaymentHistory_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) ExtendBlossomSubscription(ctx context.Context, in *ExtendBlossomSubscriptionRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_ExtendBlossomSubscription_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetBlossomStorageQuota(ctx context.Context, in *GetBlossomStorageQuotaRequest, opts ...grpc.CallOption) (*GetBlossomStorageQuotaResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(GetBlossomStorageQuotaResponse)
	err := c.cc.Invoke(ctx, DatabaseService_GetBlossomStorageQuota_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) IsFirstTimeUser(ctx context.Context, in *IsFirstTimeUserRequest, opts ...grpc.CallOption) (*IsFirstTimeUserResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(IsFirstTimeUserResponse)
	err := c.cc.Invoke(ctx, DatabaseService_IsFirstTimeUser_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) SavePaidSubscription(ctx context.Context, in *PaidSubscriptionMsg, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_SavePaidSubscription_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetPaidSubscription(ctx context.Context, in *GetPaidSubscriptionRequest, opts ...grpc.CallOption) (*PaidSubscriptionMsg, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(PaidSubscriptionMsg)
	err := c.cc.Invoke(ctx, DatabaseService_GetPaidSubscription_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) DeletePaidSubscription(ctx context.Context, in *DeletePaidSubscriptionRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_DeletePaidSubscription_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) ListPaidSubscriptions(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PaidSubscriptionList, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(PaidSubscriptionList)
	err := c.cc.Invoke(ctx, DatabaseService_ListPaidSubscriptions_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) ClaimAlias(ctx context.Context, in *ClaimAliasRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_ClaimAlias_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetAliasByPubkey(ctx context.Context, in *GetAliasByPubkeyRequest, opts ...grpc.CallOption) (*AliasResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(AliasResponse)
	err := c.cc.Invoke(ctx, DatabaseService_GetAliasByPubkey_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetPubkeyByAlias(ctx context.Context, in *GetPubkeyByAliasRequest, opts ...grpc.CallOption) (*PubkeyResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(PubkeyResponse)
	err := c.cc.Invoke(ctx, DatabaseService_GetPubkeyByAlias_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) IsAliasTaken(ctx context.Context, in *IsAliasTakenRequest, opts ...grpc.CallOption) (*IsAliasTakenResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(IsAliasTakenResponse)
	err := c.cc.Invoke(ctx, DatabaseService_IsAliasTaken_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) AddNIP43Member(ctx context.Context, in *AddNIP43MemberRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_AddNIP43Member_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) RemoveNIP43Member(ctx context.Context, in *RemoveNIP43MemberRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_RemoveNIP43Member_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) IsNIP43Member(ctx context.Context, in *IsNIP43MemberRequest, opts ...grpc.CallOption) (*IsNIP43MemberResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(IsNIP43MemberResponse)
	err := c.cc.Invoke(ctx, DatabaseService_IsNIP43Member_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetNIP43Membership(ctx context.Context, in *GetNIP43MembershipRequest, opts ...grpc.CallOption) (*NIP43Membership, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(NIP43Membership)
	err := c.cc.Invoke(ctx, DatabaseService_GetNIP43Membership_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetAllNIP43Members(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PubkeyList, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(PubkeyList)
	err := c.cc.Invoke(ctx, DatabaseService_GetAllNIP43Members_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) StoreInviteCode(ctx context.Context, in *StoreInviteCodeRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_StoreInviteCode_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) ValidateInviteCode(ctx context.Context, in *ValidateInviteCodeRequest, opts ...grpc.CallOption) (*ValidateInviteCodeResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ValidateInviteCodeResponse)
	err := c.cc.Invoke(ctx, DatabaseService_ValidateInviteCode_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) DeleteInviteCode(ctx context.Context, in *DeleteInviteCodeRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_DeleteInviteCode_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) PublishNIP43MembershipEvent(ctx context.Context, in *PublishNIP43MembershipEventRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_PublishNIP43MembershipEvent_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetCachedJSON(ctx context.Context, in *GetCachedJSONRequest, opts ...grpc.CallOption) (*GetCachedJSONResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(GetCachedJSONResponse)
	err := c.cc.Invoke(ctx, DatabaseService_GetCachedJSON_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) CacheMarshaledJSON(ctx context.Context, in *CacheMarshaledJSONRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_CacheMarshaledJSON_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetCachedEvents(ctx context.Context, in *GetCachedEventsRequest, opts ...grpc.CallOption) (*GetCachedEventsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(GetCachedEventsResponse)
	err := c.cc.Invoke(ctx, DatabaseService_GetCachedEvents_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) CacheEvents(ctx context.Context, in *CacheEventsRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_CacheEvents_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) InvalidateQueryCache(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_InvalidateQueryCache_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) RecordEventAccess(ctx context.Context, in *RecordEventAccessRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_RecordEventAccess_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetEventAccessInfo(ctx context.Context, in *GetEventAccessInfoRequest, opts ...grpc.CallOption) (*GetEventAccessInfoResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(GetEventAccessInfoResponse)
	err := c.cc.Invoke(ctx, DatabaseService_GetEventAccessInfo_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetLeastAccessedEvents(ctx context.Context, in *GetLeastAccessedEventsRequest, opts ...grpc.CallOption) (*SerialList, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(SerialList)
	err := c.cc.Invoke(ctx, DatabaseService_GetLeastAccessedEvents_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) SaveBlob(ctx context.Context, in *SaveBlobRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_SaveBlob_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) SaveBlobMetadata(ctx context.Context, in *SaveBlobMetadataRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_SaveBlobMetadata_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetBlob(ctx context.Context, in *GetBlobRequest, opts ...grpc.CallOption) (*GetBlobResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(GetBlobResponse)
	err := c.cc.Invoke(ctx, DatabaseService_GetBlob_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) HasBlob(ctx context.Context, in *HasBlobRequest, opts ...grpc.CallOption) (*HasBlobResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(HasBlobResponse)
	err := c.cc.Invoke(ctx, DatabaseService_HasBlob_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) DeleteBlob(ctx context.Context, in *DeleteBlobRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_DeleteBlob_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) ListBlobs(ctx context.Context, in *ListBlobsRequest, opts ...grpc.CallOption) (*ListBlobsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListBlobsResponse)
	err := c.cc.Invoke(ctx, DatabaseService_ListBlobs_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetBlobMetadata(ctx context.Context, in *GetBlobMetadataRequest, opts ...grpc.CallOption) (*BlobMetadata, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(BlobMetadata)
	err := c.cc.Invoke(ctx, DatabaseService_GetBlobMetadata_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetTotalBlobStorageUsed(ctx context.Context, in *GetTotalBlobStorageUsedRequest, opts ...grpc.CallOption) (*GetTotalBlobStorageUsedResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(GetTotalBlobStorageUsedResponse)
	err := c.cc.Invoke(ctx, DatabaseService_GetTotalBlobStorageUsed_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) SaveBlobReport(ctx context.Context, in *SaveBlobReportRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_SaveBlobReport_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) ListAllBlobUserStats(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListAllBlobUserStatsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListAllBlobUserStatsResponse)
	err := c.cc.Invoke(ctx, DatabaseService_ListAllBlobUserStats_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) ReconcileBlobMetadata(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ReconcileBlobMetadataResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ReconcileBlobMetadataResponse)
	err := c.cc.Invoke(ctx, DatabaseService_ReconcileBlobMetadata_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) ListAllBlobs(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListBlobsResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListBlobsResponse)
	err := c.cc.Invoke(ctx, DatabaseService_ListAllBlobs_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) GetThumbnail(ctx context.Context, in *GetThumbnailRequest, opts ...grpc.CallOption) (*GetThumbnailResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(GetThumbnailResponse)
	err := c.cc.Invoke(ctx, DatabaseService_GetThumbnail_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) SaveThumbnail(ctx context.Context, in *SaveThumbnailRequest, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_SaveThumbnail_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) EventIdsBySerial(ctx context.Context, in *EventIdsBySerialRequest, opts ...grpc.CallOption) (*EventIdsBySerialResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(EventIdsBySerialResponse)
	err := c.cc.Invoke(ctx, DatabaseService_EventIdsBySerial_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) RunMigrations(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Empty)
	err := c.cc.Invoke(ctx, DatabaseService_RunMigrations_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *databaseServiceClient) ExecuteCypherRead(ctx context.Context, in *CypherReadRequest, opts ...grpc.CallOption) (*CypherReadResponse, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(CypherReadResponse)
	err := c.cc.Invoke(ctx, DatabaseService_ExecuteCypherRead_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// DatabaseServiceServer is the server API for DatabaseService service.
// All implementations must embed UnimplementedDatabaseServiceServer
// for forward compatibility.
//
// DatabaseService provides gRPC access to the ORLY database
type DatabaseServiceServer interface {
	// GetPath returns the database file path
	GetPath(context.Context, *Empty) (*PathResponse, error)
	// Sync flushes buffers to disk
	Sync(context.Context, *Empty) (*Empty, error)
	// Ready returns whether the database is ready to serve requests
	Ready(context.Context, *Empty) (*ReadyResponse, error)
	// SetLogLevel sets the database log level
	SetLogLevel(context.Context, *SetLogLevelRequest) (*Empty, error)
	// SaveEvent stores an event, returns whether it already existed
	SaveEvent(context.Context, *SaveEventRequest) (*SaveEventResponse, error)
	// GetSerialsFromFilter gets serial numbers matching a filter
	GetSerialsFromFilter(context.Context, *GetSerialsFromFilterRequest) (*SerialList, error)
	// WouldReplaceEvent checks if an event would replace existing ones
	WouldReplaceEvent(context.Context, *WouldReplaceEventRequest) (*WouldReplaceEventResponse, error)
	// QueryEvents queries events matching a filter (with deletion filtering)
	QueryEvents(*QueryEventsRequest, grpc.ServerStreamingServer[EventBatch]) error
	// QueryAllVersions queries all versions of replaceable events
	QueryAllVersions(*QueryEventsRequest, grpc.ServerStreamingServer[EventBatch]) error
	// QueryEventsWithOptions provides full control over query behavior
	QueryEventsWithOptions(*QueryEventsWithOptionsRequest, grpc.ServerStreamingServer[EventBatch]) error
	// QueryDeleteEventsByTargetId queries deletion events for a target
	QueryDeleteEventsByTargetId(*QueryDeleteEventsByTargetIdRequest, grpc.ServerStreamingServer[EventBatch]) error
	// QueryForSerials queries just serial numbers matching a filter
	QueryForSerials(context.Context, *QueryEventsRequest) (*SerialList, error)
	// QueryForIds queries ID/Pubkey/Timestamp triplets
	QueryForIds(context.Context, *QueryEventsRequest) (*IdPkTsList, error)
	// CountEvents counts events matching a filter
	CountEvents(context.Context, *QueryEventsRequest) (*CountEventsResponse, error)
	// FetchEventBySerial fetches a single event by serial
	FetchEventBySerial(context.Context, *FetchEventBySerialRequest) (*FetchEventBySerialResponse, error)
	// FetchEventsBySerials fetches multiple events by serial (batch)
	FetchEventsBySerials(context.Context, *FetchEventsBySerialRequest) (*EventMap, error)
	// GetSerialById gets the serial for a single event ID
	GetSerialById(context.Context, *GetSerialByIdRequest) (*GetSerialByIdResponse, error)
	// GetSerialsByIds gets serials for multiple event IDs
	GetSerialsByIds(context.Context, *GetSerialsByIdsRequest) (*SerialMap, error)
	// GetSerialsByRange gets serials within an index range
	GetSerialsByRange(context.Context, *GetSerialsByRangeRequest) (*SerialList, error)
	// GetFullIdPubkeyBySerial gets full ID/Pubkey/Timestamp for a serial
	GetFullIdPubkeyBySerial(context.Context, *GetFullIdPubkeyBySerialRequest) (*IdPkTs, error)
	// GetFullIdPubkeyBySerials gets full data for multiple serials
	GetFullIdPubkeyBySerials(context.Context, *GetFullIdPubkeyBySerialsRequest) (*IdPkTsList, error)
	// DeleteEvent deletes an event by ID
	DeleteEvent(context.Context, *DeleteEventRequest) (*Empty, error)
	// DeleteEventBySerial deletes an event by serial
	DeleteEventBySerial(context.Context, *DeleteEventBySerialRequest) (*Empty, error)
	// DeleteExpired deletes events with expired expiration tags
	DeleteExpired(context.Context, *Empty) (*Empty, error)
	// ProcessDelete processes a deletion event (NIP-09)
	ProcessDelete(context.Context, *ProcessDeleteRequest) (*Empty, error)
	// CheckForDeleted checks if an event was deleted
	CheckForDeleted(context.Context, *CheckForDeletedRequest) (*Empty, error)
	// Import imports events from a stream
	Import(grpc.ClientStreamingServer[ImportChunk, ImportResponse]) error
	// Export exports events to a stream
	Export(*ExportRequest, grpc.ServerStreamingServer[ExportChunk]) error
	// ImportEventsFromStrings imports events from JSON strings
	ImportEventsFromStrings(context.Context, *ImportEventsFromStringsRequest) (*ImportResponse, error)
	// GetRelayIdentitySecret gets the relay's secret key
	GetRelayIdentitySecret(context.Context, *Empty) (*GetRelayIdentitySecretResponse, error)
	// SetRelayIdentitySecret sets the relay's secret key
	SetRelayIdentitySecret(context.Context, *SetRelayIdentitySecretRequest) (*Empty, error)
	// GetOrCreateRelayIdentitySecret gets or creates the relay's secret key
	GetOrCreateRelayIdentitySecret(context.Context, *Empty) (*GetRelayIdentitySecretResponse, error)
	// SetMarker sets a metadata marker
	SetMarker(context.Context, *SetMarkerRequest) (*Empty, error)
	// GetMarker gets a metadata marker
	GetMarker(context.Context, *GetMarkerRequest) (*GetMarkerResponse, error)
	// HasMarker checks if a marker exists
	HasMarker(context.Context, *HasMarkerRequest) (*HasMarkerResponse, error)
	// DeleteMarker deletes a marker
	DeleteMarker(context.Context, *DeleteMarkerRequest) (*Empty, error)
	// GetSubscription gets subscription info for a pubkey
	GetSubscription(context.Context, *GetSubscriptionRequest) (*Subscription, error)
	// IsSubscriptionActive checks if a subscription is active
	IsSubscriptionActive(context.Context, *IsSubscriptionActiveRequest) (*IsSubscriptionActiveResponse, error)
	// ExtendSubscription extends a subscription by days
	ExtendSubscription(context.Context, *ExtendSubscriptionRequest) (*Empty, error)
	// RecordPayment records a payment
	RecordPayment(context.Context, *RecordPaymentRequest) (*Empty, error)
	// GetPaymentHistory gets payment history for a pubkey
	GetPaymentHistory(context.Context, *GetPaymentHistoryRequest) (*PaymentList, error)
	// ExtendBlossomSubscription extends blossom storage subscription
	ExtendBlossomSubscription(context.Context, *ExtendBlossomSubscriptionRequest) (*Empty, error)
	// GetBlossomStorageQuota gets blossom storage quota
	GetBlossomStorageQuota(context.Context, *GetBlossomStorageQuotaRequest) (*GetBlossomStorageQuotaResponse, error)
	// IsFirstTimeUser checks if this is a first-time user
	IsFirstTimeUser(context.Context, *IsFirstTimeUserRequest) (*IsFirstTimeUserResponse, error)
	// SavePaidSubscription saves or updates a paid subscription
	SavePaidSubscription(context.Context, *PaidSubscriptionMsg) (*Empty, error)
	// GetPaidSubscription gets a paid subscription by pubkey hex
	GetPaidSubscription(context.Context, *GetPaidSubscriptionRequest) (*PaidSubscriptionMsg, error)
	// DeletePaidSubscription deletes a paid subscription
	DeletePaidSubscription(context.Context, *DeletePaidSubscriptionRequest) (*Empty, error)
	// ListPaidSubscriptions lists all paid subscriptions
	ListPaidSubscriptions(context.Context, *Empty) (*PaidSubscriptionList, error)
	// ClaimAlias claims an email alias for a pubkey
	ClaimAlias(context.Context, *ClaimAliasRequest) (*Empty, error)
	// GetAliasByPubkey gets the alias for a pubkey
	GetAliasByPubkey(context.Context, *GetAliasByPubkeyRequest) (*AliasResponse, error)
	// GetPubkeyByAlias gets the pubkey for an alias
	GetPubkeyByAlias(context.Context, *GetPubkeyByAliasRequest) (*PubkeyResponse, error)
	// IsAliasTaken checks if an alias is taken
	IsAliasTaken(context.Context, *IsAliasTakenRequest) (*IsAliasTakenResponse, error)
	// AddNIP43Member adds a member via invite code
	AddNIP43Member(context.Context, *AddNIP43MemberRequest) (*Empty, error)
	// RemoveNIP43Member removes a member
	RemoveNIP43Member(context.Context, *RemoveNIP43MemberRequest) (*Empty, error)
	// IsNIP43Member checks if a pubkey is a member
	IsNIP43Member(context.Context, *IsNIP43MemberRequest) (*IsNIP43MemberResponse, error)
	// GetNIP43Membership gets membership details
	GetNIP43Membership(context.Context, *GetNIP43MembershipRequest) (*NIP43Membership, error)
	// GetAllNIP43Members gets all members
	GetAllNIP43Members(context.Context, *Empty) (*PubkeyList, error)
	// StoreInviteCode stores an invite code with expiration
	StoreInviteCode(context.Context, *StoreInviteCodeRequest) (*Empty, error)
	// ValidateInviteCode validates an invite code
	ValidateInviteCode(context.Context, *ValidateInviteCodeRequest) (*ValidateInviteCodeResponse, error)
	// DeleteInviteCode deletes an invite code
	DeleteInviteCode(context.Context, *DeleteInviteCodeRequest) (*Empty, error)
	// PublishNIP43MembershipEvent publishes a membership event
	PublishNIP43MembershipEvent(context.Context, *PublishNIP43MembershipEventRequest) (*Empty, error)
	// GetCachedJSON gets cached JSON for a filter
	GetCachedJSON(context.Context, *GetCachedJSONRequest) (*GetCachedJSONResponse, error)
	// CacheMarshaledJSON caches JSON for a filter
	CacheMarshaledJSON(context.Context, *CacheMarshaledJSONRequest) (*Empty, error)
	// GetCachedEvents gets cached events for a filter
	GetCachedEvents(context.Context, *GetCachedEventsRequest) (*GetCachedEventsResponse, error)
	// CacheEvents caches events for a filter
	CacheEvents(context.Context, *CacheEventsRequest) (*Empty, error)
	// InvalidateQueryCache invalidates the entire query cache
	InvalidateQueryCache(context.Context, *Empty) (*Empty, error)
	// RecordEventAccess records an access to an event
	RecordEventAccess(context.Context, *RecordEventAccessRequest) (*Empty, error)
	// GetEventAccessInfo gets access info for an event
	GetEventAccessInfo(context.Context, *GetEventAccessInfoRequest) (*GetEventAccessInfoResponse, error)
	// GetLeastAccessedEvents gets least accessed events for GC
	GetLeastAccessedEvents(context.Context, *GetLeastAccessedEventsRequest) (*SerialList, error)
	// SaveBlob stores a blob with its metadata
	SaveBlob(context.Context, *SaveBlobRequest) (*Empty, error)
	// SaveBlobMetadata stores only metadata for a blob whose file is already on disk
	SaveBlobMetadata(context.Context, *SaveBlobMetadataRequest) (*Empty, error)
	// GetBlob retrieves blob data and metadata
	GetBlob(context.Context, *GetBlobRequest) (*GetBlobResponse, error)
	// HasBlob checks if a blob exists
	HasBlob(context.Context, *HasBlobRequest) (*HasBlobResponse, error)
	// DeleteBlob deletes a blob
	DeleteBlob(context.Context, *DeleteBlobRequest) (*Empty, error)
	// ListBlobs lists blobs for a pubkey
	ListBlobs(context.Context, *ListBlobsRequest) (*ListBlobsResponse, error)
	// GetBlobMetadata gets only metadata for a blob
	GetBlobMetadata(context.Context, *GetBlobMetadataRequest) (*BlobMetadata, error)
	// GetTotalBlobStorageUsed gets total storage used by a pubkey in MB
	GetTotalBlobStorageUsed(context.Context, *GetTotalBlobStorageUsedRequest) (*GetTotalBlobStorageUsedResponse, error)
	// SaveBlobReport stores a report for a blob (BUD-09)
	SaveBlobReport(context.Context, *SaveBlobReportRequest) (*Empty, error)
	// ListAllBlobUserStats gets storage statistics for all users
	ListAllBlobUserStats(context.Context, *Empty) (*ListAllBlobUserStatsResponse, error)
	// ReconcileBlobMetadata scans the blossom directory and creates metadata for orphan blobs
	ReconcileBlobMetadata(context.Context, *Empty) (*ReconcileBlobMetadataResponse, error)
	// ListAllBlobs returns all blob descriptors (for admin thumbnail generation)
	ListAllBlobs(context.Context, *Empty) (*ListBlobsResponse, error)
	// GetThumbnail retrieves a cached thumbnail by key
	GetThumbnail(context.Context, *GetThumbnailRequest) (*GetThumbnailResponse, error)
	// SaveThumbnail stores a cached thumbnail
	SaveThumbnail(context.Context, *SaveThumbnailRequest) (*Empty, error)
	// EventIdsBySerial gets event IDs by serial range
	EventIdsBySerial(context.Context, *EventIdsBySerialRequest) (*EventIdsBySerialResponse, error)
	// RunMigrations runs database migrations
	RunMigrations(context.Context, *Empty) (*Empty, error)
	// ExecuteCypherRead executes a read-only Cypher query against Neo4j
	ExecuteCypherRead(context.Context, *CypherReadRequest) (*CypherReadResponse, error)
	mustEmbedUnimplementedDatabaseServiceServer()
}

// UnimplementedDatabaseServiceServer must be embedded to have
// forward compatible implementations.
//
// NOTE: this should be embedded by value instead of pointer to avoid a nil
// pointer dereference when methods are called.
type UnimplementedDatabaseServiceServer struct{}

func (UnimplementedDatabaseServiceServer) GetPath(context.Context, *Empty) (*PathResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method GetPath not implemented")
}
func (UnimplementedDatabaseServiceServer) Sync(context.Context, *Empty) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method Sync not implemented")
}
func (UnimplementedDatabaseServiceServer) Ready(context.Context, *Empty) (*ReadyResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method Ready not implemented")
}
func (UnimplementedDatabaseServiceServer) SetLogLevel(context.Context, *SetLogLevelRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method SetLogLevel not implemented")
}
func (UnimplementedDatabaseServiceServer) SaveEvent(context.Context, *SaveEventRequest) (*SaveEventResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method SaveEvent not implemented")
}
func (UnimplementedDatabaseServiceServer) GetSerialsFromFilter(context.Context, *GetSerialsFromFilterRequest) (*SerialList, error) {
	return nil, status.Error(codes.Unimplemented, "method GetSerialsFromFilter not implemented")
}
func (UnimplementedDatabaseServiceServer) WouldReplaceEvent(context.Context, *WouldReplaceEventRequest) (*WouldReplaceEventResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method WouldReplaceEvent not implemented")
}
func (UnimplementedDatabaseServiceServer) QueryEvents(*QueryEventsRequest, grpc.ServerStreamingServer[EventBatch]) error {
	return status.Error(codes.Unimplemented, "method QueryEvents not implemented")
}
func (UnimplementedDatabaseServiceServer) QueryAllVersions(*QueryEventsRequest, grpc.ServerStreamingServer[EventBatch]) error {
	return status.Error(codes.Unimplemented, "method QueryAllVersions not implemented")
}
func (UnimplementedDatabaseServiceServer) QueryEventsWithOptions(*QueryEventsWithOptionsRequest, grpc.ServerStreamingServer[EventBatch]) error {
	return status.Error(codes.Unimplemented, "method QueryEventsWithOptions not implemented")
}
func (UnimplementedDatabaseServiceServer) QueryDeleteEventsByTargetId(*QueryDeleteEventsByTargetIdRequest, grpc.ServerStreamingServer[EventBatch]) error {
	return status.Error(codes.Unimplemented, "method QueryDeleteEventsByTargetId not implemented")
}
func (UnimplementedDatabaseServiceServer) QueryForSerials(context.Context, *QueryEventsRequest) (*SerialList, error) {
	return nil, status.Error(codes.Unimplemented, "method QueryForSerials not implemented")
}
func (UnimplementedDatabaseServiceServer) QueryForIds(context.Context, *QueryEventsRequest) (*IdPkTsList, error) {
	return nil, status.Error(codes.Unimplemented, "method QueryForIds not implemented")
}
func (UnimplementedDatabaseServiceServer) CountEvents(context.Context, *QueryEventsRequest) (*CountEventsResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method CountEvents not implemented")
}
func (UnimplementedDatabaseServiceServer) FetchEventBySerial(context.Context, *FetchEventBySerialRequest) (*FetchEventBySerialResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method FetchEventBySerial not implemented")
}
func (UnimplementedDatabaseServiceServer) FetchEventsBySerials(context.Context, *FetchEventsBySerialRequest) (*EventMap, error) {
	return nil, status.Error(codes.Unimplemented, "method FetchEventsBySerials not implemented")
}
func (UnimplementedDatabaseServiceServer) GetSerialById(context.Context, *GetSerialByIdRequest) (*GetSerialByIdResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method GetSerialById not implemented")
}
func (UnimplementedDatabaseServiceServer) GetSerialsByIds(context.Context, *GetSerialsByIdsRequest) (*SerialMap, error) {
	return nil, status.Error(codes.Unimplemented, "method GetSerialsByIds not implemented")
}
func (UnimplementedDatabaseServiceServer) GetSerialsByRange(context.Context, *GetSerialsByRangeRequest) (*SerialList, error) {
	return nil, status.Error(codes.Unimplemented, "method GetSerialsByRange not implemented")
}
func (UnimplementedDatabaseServiceServer) GetFullIdPubkeyBySerial(context.Context, *GetFullIdPubkeyBySerialRequest) (*IdPkTs, error) {
	return nil, status.Error(codes.Unimplemented, "method GetFullIdPubkeyBySerial not implemented")
}
func (UnimplementedDatabaseServiceServer) GetFullIdPubkeyBySerials(context.Context, *GetFullIdPubkeyBySerialsRequest) (*IdPkTsList, error) {
	return nil, status.Error(codes.Unimplemented, "method GetFullIdPubkeyBySerials not implemented")
}
func (UnimplementedDatabaseServiceServer) DeleteEvent(context.Context, *DeleteEventRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method DeleteEvent not implemented")
}
func (UnimplementedDatabaseServiceServer) DeleteEventBySerial(context.Context, *DeleteEventBySerialRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method DeleteEventBySerial not implemented")
}
func (UnimplementedDatabaseServiceServer) DeleteExpired(context.Context, *Empty) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method DeleteExpired not implemented")
}
func (UnimplementedDatabaseServiceServer) ProcessDelete(context.Context, *ProcessDeleteRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method ProcessDelete not implemented")
}
func (UnimplementedDatabaseServiceServer) CheckForDeleted(context.Context, *CheckForDeletedRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method CheckForDeleted not implemented")
}
func (UnimplementedDatabaseServiceServer) Import(grpc.ClientStreamingServer[ImportChunk, ImportResponse]) error {
	return status.Error(codes.Unimplemented, "method Import not implemented")
}
func (UnimplementedDatabaseServiceServer) Export(*ExportRequest, grpc.ServerStreamingServer[ExportChunk]) error {
	return status.Error(codes.Unimplemented, "method Export not implemented")
}
func (UnimplementedDatabaseServiceServer) ImportEventsFromStrings(context.Context, *ImportEventsFromStringsRequest) (*ImportResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method ImportEventsFromStrings not implemented")
}
func (UnimplementedDatabaseServiceServer) GetRelayIdentitySecret(context.Context, *Empty) (*GetRelayIdentitySecretResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method GetRelayIdentitySecret not implemented")
}
func (UnimplementedDatabaseServiceServer) SetRelayIdentitySecret(context.Context, *SetRelayIdentitySecretRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method SetRelayIdentitySecret not implemented")
}
func (UnimplementedDatabaseServiceServer) GetOrCreateRelayIdentitySecret(context.Context, *Empty) (*GetRelayIdentitySecretResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method GetOrCreateRelayIdentitySecret not implemented")
}
func (UnimplementedDatabaseServiceServer) SetMarker(context.Context, *SetMarkerRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method SetMarker not implemented")
}
func (UnimplementedDatabaseServiceServer) GetMarker(context.Context, *GetMarkerRequest) (*GetMarkerResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method GetMarker not implemented")
}
func (UnimplementedDatabaseServiceServer) HasMarker(context.Context, *HasMarkerRequest) (*HasMarkerResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method HasMarker not implemented")
}
func (UnimplementedDatabaseServiceServer) DeleteMarker(context.Context, *DeleteMarkerRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method DeleteMarker not implemented")
}
func (UnimplementedDatabaseServiceServer) GetSubscription(context.Context, *GetSubscriptionRequest) (*Subscription, error) {
	return nil, status.Error(codes.Unimplemented, "method GetSubscription not implemented")
}
func (UnimplementedDatabaseServiceServer) IsSubscriptionActive(context.Context, *IsSubscriptionActiveRequest) (*IsSubscriptionActiveResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method IsSubscriptionActive not implemented")
}
func (UnimplementedDatabaseServiceServer) ExtendSubscription(context.Context, *ExtendSubscriptionRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method ExtendSubscription not implemented")
}
func (UnimplementedDatabaseServiceServer) RecordPayment(context.Context, *RecordPaymentRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method RecordPayment not implemented")
}
func (UnimplementedDatabaseServiceServer) GetPaymentHistory(context.Context, *GetPaymentHistoryRequest) (*PaymentList, error) {
	return nil, status.Error(codes.Unimplemented, "method GetPaymentHistory not implemented")
}
func (UnimplementedDatabaseServiceServer) ExtendBlossomSubscription(context.Context, *ExtendBlossomSubscriptionRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method ExtendBlossomSubscription not implemented")
}
func (UnimplementedDatabaseServiceServer) GetBlossomStorageQuota(context.Context, *GetBlossomStorageQuotaRequest) (*GetBlossomStorageQuotaResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method GetBlossomStorageQuota not implemented")
}
func (UnimplementedDatabaseServiceServer) IsFirstTimeUser(context.Context, *IsFirstTimeUserRequest) (*IsFirstTimeUserResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method IsFirstTimeUser not implemented")
}
func (UnimplementedDatabaseServiceServer) SavePaidSubscription(context.Context, *PaidSubscriptionMsg) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method SavePaidSubscription not implemented")
}
func (UnimplementedDatabaseServiceServer) GetPaidSubscription(context.Context, *GetPaidSubscriptionRequest) (*PaidSubscriptionMsg, error) {
	return nil, status.Error(codes.Unimplemented, "method GetPaidSubscription not implemented")
}
func (UnimplementedDatabaseServiceServer) DeletePaidSubscription(context.Context, *DeletePaidSubscriptionRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method DeletePaidSubscription not implemented")
}
func (UnimplementedDatabaseServiceServer) ListPaidSubscriptions(context.Context, *Empty) (*PaidSubscriptionList, error) {
	return nil, status.Error(codes.Unimplemented, "method ListPaidSubscriptions not implemented")
}
func (UnimplementedDatabaseServiceServer) ClaimAlias(context.Context, *ClaimAliasRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method ClaimAlias not implemented")
}
func (UnimplementedDatabaseServiceServer) GetAliasByPubkey(context.Context, *GetAliasByPubkeyRequest) (*AliasResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method GetAliasByPubkey not implemented")
}
func (UnimplementedDatabaseServiceServer) GetPubkeyByAlias(context.Context, *GetPubkeyByAliasRequest) (*PubkeyResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method GetPubkeyByAlias not implemented")
}
func (UnimplementedDatabaseServiceServer) IsAliasTaken(context.Context, *IsAliasTakenRequest) (*IsAliasTakenResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method IsAliasTaken not implemented")
}
func (UnimplementedDatabaseServiceServer) AddNIP43Member(context.Context, *AddNIP43MemberRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method AddNIP43Member not implemented")
}
func (UnimplementedDatabaseServiceServer) RemoveNIP43Member(context.Context, *RemoveNIP43MemberRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method RemoveNIP43Member not implemented")
}
func (UnimplementedDatabaseServiceServer) IsNIP43Member(context.Context, *IsNIP43MemberRequest) (*IsNIP43MemberResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method IsNIP43Member not implemented")
}
func (UnimplementedDatabaseServiceServer) GetNIP43Membership(context.Context, *GetNIP43MembershipRequest) (*NIP43Membership, error) {
	return nil, status.Error(codes.Unimplemented, "method GetNIP43Membership not implemented")
}
func (UnimplementedDatabaseServiceServer) GetAllNIP43Members(context.Context, *Empty) (*PubkeyList, error) {
	return nil, status.Error(codes.Unimplemented, "method GetAllNIP43Members not implemented")
}
func (UnimplementedDatabaseServiceServer) StoreInviteCode(context.Context, *StoreInviteCodeRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method StoreInviteCode not implemented")
}
func (UnimplementedDatabaseServiceServer) ValidateInviteCode(context.Context, *ValidateInviteCodeRequest) (*ValidateInviteCodeResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method ValidateInviteCode not implemented")
}
func (UnimplementedDatabaseServiceServer) DeleteInviteCode(context.Context, *DeleteInviteCodeRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method DeleteInviteCode not implemented")
}
func (UnimplementedDatabaseServiceServer) PublishNIP43MembershipEvent(context.Context, *PublishNIP43MembershipEventRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method PublishNIP43MembershipEvent not implemented")
}
func (UnimplementedDatabaseServiceServer) GetCachedJSON(context.Context, *GetCachedJSONRequest) (*GetCachedJSONResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method GetCachedJSON not implemented")
}
func (UnimplementedDatabaseServiceServer) CacheMarshaledJSON(context.Context, *CacheMarshaledJSONRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method CacheMarshaledJSON not implemented")
}
func (UnimplementedDatabaseServiceServer) GetCachedEvents(context.Context, *GetCachedEventsRequest) (*GetCachedEventsResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method GetCachedEvents not implemented")
}
func (UnimplementedDatabaseServiceServer) CacheEvents(context.Context, *CacheEventsRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method CacheEvents not implemented")
}
func (UnimplementedDatabaseServiceServer) InvalidateQueryCache(context.Context, *Empty) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method InvalidateQueryCache not implemented")
}
func (UnimplementedDatabaseServiceServer) RecordEventAccess(context.Context, *RecordEventAccessRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method RecordEventAccess not implemented")
}
func (UnimplementedDatabaseServiceServer) GetEventAccessInfo(context.Context, *GetEventAccessInfoRequest) (*GetEventAccessInfoResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method GetEventAccessInfo not implemented")
}
func (UnimplementedDatabaseServiceServer) GetLeastAccessedEvents(context.Context, *GetLeastAccessedEventsRequest) (*SerialList, error) {
	return nil, status.Error(codes.Unimplemented, "method GetLeastAccessedEvents not implemented")
}
func (UnimplementedDatabaseServiceServer) SaveBlob(context.Context, *SaveBlobRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method SaveBlob not implemented")
}
func (UnimplementedDatabaseServiceServer) SaveBlobMetadata(context.Context, *SaveBlobMetadataRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method SaveBlobMetadata not implemented")
}
func (UnimplementedDatabaseServiceServer) GetBlob(context.Context, *GetBlobRequest) (*GetBlobResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method GetBlob not implemented")
}
func (UnimplementedDatabaseServiceServer) HasBlob(context.Context, *HasBlobRequest) (*HasBlobResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method HasBlob not implemented")
}
func (UnimplementedDatabaseServiceServer) DeleteBlob(context.Context, *DeleteBlobRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method DeleteBlob not implemented")
}
func (UnimplementedDatabaseServiceServer) ListBlobs(context.Context, *ListBlobsRequest) (*ListBlobsResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method ListBlobs not implemented")
}
func (UnimplementedDatabaseServiceServer) GetBlobMetadata(context.Context, *GetBlobMetadataRequest) (*BlobMetadata, error) {
	return nil, status.Error(codes.Unimplemented, "method GetBlobMetadata not implemented")
}
func (UnimplementedDatabaseServiceServer) GetTotalBlobStorageUsed(context.Context, *GetTotalBlobStorageUsedRequest) (*GetTotalBlobStorageUsedResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method GetTotalBlobStorageUsed not implemented")
}
func (UnimplementedDatabaseServiceServer) SaveBlobReport(context.Context, *SaveBlobReportRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method SaveBlobReport not implemented")
}
func (UnimplementedDatabaseServiceServer) ListAllBlobUserStats(context.Context, *Empty) (*ListAllBlobUserStatsResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method ListAllBlobUserStats not implemented")
}
func (UnimplementedDatabaseServiceServer) ReconcileBlobMetadata(context.Context, *Empty) (*ReconcileBlobMetadataResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method ReconcileBlobMetadata not implemented")
}
func (UnimplementedDatabaseServiceServer) ListAllBlobs(context.Context, *Empty) (*ListBlobsResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method ListAllBlobs not implemented")
}
func (UnimplementedDatabaseServiceServer) GetThumbnail(context.Context, *GetThumbnailRequest) (*GetThumbnailResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method GetThumbnail not implemented")
}
func (UnimplementedDatabaseServiceServer) SaveThumbnail(context.Context, *SaveThumbnailRequest) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method SaveThumbnail not implemented")
}
func (UnimplementedDatabaseServiceServer) EventIdsBySerial(context.Context, *EventIdsBySerialRequest) (*EventIdsBySerialResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method EventIdsBySerial not implemented")
}
func (UnimplementedDatabaseServiceServer) RunMigrations(context.Context, *Empty) (*Empty, error) {
	return nil, status.Error(codes.Unimplemented, "method RunMigrations not implemented")
}
func (UnimplementedDatabaseServiceServer) ExecuteCypherRead(context.Context, *CypherReadRequest) (*CypherReadResponse, error) {
	return nil, status.Error(codes.Unimplemented, "method ExecuteCypherRead not implemented")
}
func (UnimplementedDatabaseServiceServer) mustEmbedUnimplementedDatabaseServiceServer() {}
func (UnimplementedDatabaseServiceServer) testEmbeddedByValue()                         {}

// UnsafeDatabaseServiceServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to DatabaseServiceServer will
// result in compilation errors.
type UnsafeDatabaseServiceServer interface {
	mustEmbedUnimplementedDatabaseServiceServer()
}

func RegisterDatabaseServiceServer(s grpc.ServiceRegistrar, srv DatabaseServiceServer) {
	// If the following call panics, it indicates UnimplementedDatabaseServiceServer was
	// embedded by pointer and is nil.  This will cause panics if an
	// unimplemented method is ever invoked, so we test this at initialization
	// time to prevent it from happening at runtime later due to I/O.
	if t, ok := srv.(interface{ testEmbeddedByValue() }); ok {
		t.testEmbeddedByValue()
	}
	s.RegisterService(&DatabaseService_ServiceDesc, srv)
}

func _DatabaseService_GetPath_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetPath(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetPath_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetPath(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_Sync_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).Sync(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_Sync_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).Sync(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_Ready_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).Ready(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_Ready_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).Ready(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_SetLogLevel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SetLogLevelRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).SetLogLevel(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_SetLogLevel_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).SetLogLevel(ctx, req.(*SetLogLevelRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_SaveEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SaveEventRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).SaveEvent(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_SaveEvent_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).SaveEvent(ctx, req.(*SaveEventRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetSerialsFromFilter_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetSerialsFromFilterRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetSerialsFromFilter(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetSerialsFromFilter_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetSerialsFromFilter(ctx, req.(*GetSerialsFromFilterRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_WouldReplaceEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(WouldReplaceEventRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).WouldReplaceEvent(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_WouldReplaceEvent_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).WouldReplaceEvent(ctx, req.(*WouldReplaceEventRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_QueryEvents_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(QueryEventsRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(DatabaseServiceServer).QueryEvents(m, &grpc.GenericServerStream[QueryEventsRequest, EventBatch]{ServerStream: stream})
}

// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatabaseService_QueryEventsServer = grpc.ServerStreamingServer[EventBatch]

func _DatabaseService_QueryAllVersions_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(QueryEventsRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(DatabaseServiceServer).QueryAllVersions(m, &grpc.GenericServerStream[QueryEventsRequest, EventBatch]{ServerStream: stream})
}

// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatabaseService_QueryAllVersionsServer = grpc.ServerStreamingServer[EventBatch]

func _DatabaseService_QueryEventsWithOptions_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(QueryEventsWithOptionsRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(DatabaseServiceServer).QueryEventsWithOptions(m, &grpc.GenericServerStream[QueryEventsWithOptionsRequest, EventBatch]{ServerStream: stream})
}

// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatabaseService_QueryEventsWithOptionsServer = grpc.ServerStreamingServer[EventBatch]

func _DatabaseService_QueryDeleteEventsByTargetId_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(QueryDeleteEventsByTargetIdRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(DatabaseServiceServer).QueryDeleteEventsByTargetId(m, &grpc.GenericServerStream[QueryDeleteEventsByTargetIdRequest, EventBatch]{ServerStream: stream})
}

// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatabaseService_QueryDeleteEventsByTargetIdServer = grpc.ServerStreamingServer[EventBatch]

func _DatabaseService_QueryForSerials_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(QueryEventsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).QueryForSerials(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_QueryForSerials_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).QueryForSerials(ctx, req.(*QueryEventsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_QueryForIds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(QueryEventsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).QueryForIds(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_QueryForIds_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).QueryForIds(ctx, req.(*QueryEventsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_CountEvents_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(QueryEventsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).CountEvents(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_CountEvents_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).CountEvents(ctx, req.(*QueryEventsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_FetchEventBySerial_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(FetchEventBySerialRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).FetchEventBySerial(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_FetchEventBySerial_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).FetchEventBySerial(ctx, req.(*FetchEventBySerialRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_FetchEventsBySerials_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(FetchEventsBySerialRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).FetchEventsBySerials(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_FetchEventsBySerials_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).FetchEventsBySerials(ctx, req.(*FetchEventsBySerialRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetSerialById_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetSerialByIdRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetSerialById(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetSerialById_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetSerialById(ctx, req.(*GetSerialByIdRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetSerialsByIds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetSerialsByIdsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetSerialsByIds(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetSerialsByIds_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetSerialsByIds(ctx, req.(*GetSerialsByIdsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetSerialsByRange_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetSerialsByRangeRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetSerialsByRange(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetSerialsByRange_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetSerialsByRange(ctx, req.(*GetSerialsByRangeRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetFullIdPubkeyBySerial_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetFullIdPubkeyBySerialRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetFullIdPubkeyBySerial(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetFullIdPubkeyBySerial_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetFullIdPubkeyBySerial(ctx, req.(*GetFullIdPubkeyBySerialRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetFullIdPubkeyBySerials_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetFullIdPubkeyBySerialsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetFullIdPubkeyBySerials(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetFullIdPubkeyBySerials_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetFullIdPubkeyBySerials(ctx, req.(*GetFullIdPubkeyBySerialsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_DeleteEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteEventRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).DeleteEvent(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_DeleteEvent_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).DeleteEvent(ctx, req.(*DeleteEventRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_DeleteEventBySerial_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteEventBySerialRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).DeleteEventBySerial(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_DeleteEventBySerial_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).DeleteEventBySerial(ctx, req.(*DeleteEventBySerialRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_DeleteExpired_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).DeleteExpired(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_DeleteExpired_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).DeleteExpired(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_ProcessDelete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ProcessDeleteRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).ProcessDelete(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_ProcessDelete_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).ProcessDelete(ctx, req.(*ProcessDeleteRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_CheckForDeleted_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CheckForDeletedRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).CheckForDeleted(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_CheckForDeleted_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).CheckForDeleted(ctx, req.(*CheckForDeletedRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_Import_Handler(srv interface{}, stream grpc.ServerStream) error {
	return srv.(DatabaseServiceServer).Import(&grpc.GenericServerStream[ImportChunk, ImportResponse]{ServerStream: stream})
}

// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatabaseService_ImportServer = grpc.ClientStreamingServer[ImportChunk, ImportResponse]

func _DatabaseService_Export_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(ExportRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(DatabaseServiceServer).Export(m, &grpc.GenericServerStream[ExportRequest, ExportChunk]{ServerStream: stream})
}

// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type DatabaseService_ExportServer = grpc.ServerStreamingServer[ExportChunk]

func _DatabaseService_ImportEventsFromStrings_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ImportEventsFromStringsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).ImportEventsFromStrings(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_ImportEventsFromStrings_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).ImportEventsFromStrings(ctx, req.(*ImportEventsFromStringsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetRelayIdentitySecret_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetRelayIdentitySecret(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetRelayIdentitySecret_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetRelayIdentitySecret(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_SetRelayIdentitySecret_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SetRelayIdentitySecretRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).SetRelayIdentitySecret(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_SetRelayIdentitySecret_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).SetRelayIdentitySecret(ctx, req.(*SetRelayIdentitySecretRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetOrCreateRelayIdentitySecret_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetOrCreateRelayIdentitySecret(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetOrCreateRelayIdentitySecret_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetOrCreateRelayIdentitySecret(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_SetMarker_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SetMarkerRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).SetMarker(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_SetMarker_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).SetMarker(ctx, req.(*SetMarkerRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetMarker_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetMarkerRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetMarker(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetMarker_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetMarker(ctx, req.(*GetMarkerRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_HasMarker_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(HasMarkerRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).HasMarker(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_HasMarker_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).HasMarker(ctx, req.(*HasMarkerRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_DeleteMarker_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteMarkerRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).DeleteMarker(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_DeleteMarker_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).DeleteMarker(ctx, req.(*DeleteMarkerRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetSubscriptionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetSubscription(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetSubscription_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetSubscription(ctx, req.(*GetSubscriptionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_IsSubscriptionActive_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IsSubscriptionActiveRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).IsSubscriptionActive(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_IsSubscriptionActive_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).IsSubscriptionActive(ctx, req.(*IsSubscriptionActiveRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_ExtendSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ExtendSubscriptionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).ExtendSubscription(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_ExtendSubscription_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).ExtendSubscription(ctx, req.(*ExtendSubscriptionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_RecordPayment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RecordPaymentRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).RecordPayment(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_RecordPayment_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).RecordPayment(ctx, req.(*RecordPaymentRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetPaymentHistory_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetPaymentHistoryRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetPaymentHistory(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetPaymentHistory_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetPaymentHistory(ctx, req.(*GetPaymentHistoryRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_ExtendBlossomSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ExtendBlossomSubscriptionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).ExtendBlossomSubscription(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_ExtendBlossomSubscription_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).ExtendBlossomSubscription(ctx, req.(*ExtendBlossomSubscriptionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetBlossomStorageQuota_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetBlossomStorageQuotaRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetBlossomStorageQuota(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetBlossomStorageQuota_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetBlossomStorageQuota(ctx, req.(*GetBlossomStorageQuotaRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_IsFirstTimeUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IsFirstTimeUserRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).IsFirstTimeUser(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_IsFirstTimeUser_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).IsFirstTimeUser(ctx, req.(*IsFirstTimeUserRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_SavePaidSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PaidSubscriptionMsg)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).SavePaidSubscription(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_SavePaidSubscription_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).SavePaidSubscription(ctx, req.(*PaidSubscriptionMsg))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetPaidSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetPaidSubscriptionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetPaidSubscription(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetPaidSubscription_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetPaidSubscription(ctx, req.(*GetPaidSubscriptionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_DeletePaidSubscription_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeletePaidSubscriptionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).DeletePaidSubscription(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_DeletePaidSubscription_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).DeletePaidSubscription(ctx, req.(*DeletePaidSubscriptionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_ListPaidSubscriptions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).ListPaidSubscriptions(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_ListPaidSubscriptions_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).ListPaidSubscriptions(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_ClaimAlias_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ClaimAliasRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).ClaimAlias(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_ClaimAlias_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).ClaimAlias(ctx, req.(*ClaimAliasRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetAliasByPubkey_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetAliasByPubkeyRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetAliasByPubkey(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetAliasByPubkey_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetAliasByPubkey(ctx, req.(*GetAliasByPubkeyRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetPubkeyByAlias_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetPubkeyByAliasRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetPubkeyByAlias(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetPubkeyByAlias_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetPubkeyByAlias(ctx, req.(*GetPubkeyByAliasRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_IsAliasTaken_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IsAliasTakenRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).IsAliasTaken(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_IsAliasTaken_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).IsAliasTaken(ctx, req.(*IsAliasTakenRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_AddNIP43Member_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(AddNIP43MemberRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).AddNIP43Member(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_AddNIP43Member_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).AddNIP43Member(ctx, req.(*AddNIP43MemberRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_RemoveNIP43Member_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RemoveNIP43MemberRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).RemoveNIP43Member(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_RemoveNIP43Member_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).RemoveNIP43Member(ctx, req.(*RemoveNIP43MemberRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_IsNIP43Member_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(IsNIP43MemberRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).IsNIP43Member(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_IsNIP43Member_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).IsNIP43Member(ctx, req.(*IsNIP43MemberRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetNIP43Membership_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetNIP43MembershipRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetNIP43Membership(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetNIP43Membership_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetNIP43Membership(ctx, req.(*GetNIP43MembershipRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetAllNIP43Members_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetAllNIP43Members(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetAllNIP43Members_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetAllNIP43Members(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_StoreInviteCode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(StoreInviteCodeRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).StoreInviteCode(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_StoreInviteCode_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).StoreInviteCode(ctx, req.(*StoreInviteCodeRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_ValidateInviteCode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ValidateInviteCodeRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).ValidateInviteCode(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_ValidateInviteCode_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).ValidateInviteCode(ctx, req.(*ValidateInviteCodeRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_DeleteInviteCode_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteInviteCodeRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).DeleteInviteCode(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_DeleteInviteCode_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).DeleteInviteCode(ctx, req.(*DeleteInviteCodeRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_PublishNIP43MembershipEvent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PublishNIP43MembershipEventRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).PublishNIP43MembershipEvent(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_PublishNIP43MembershipEvent_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).PublishNIP43MembershipEvent(ctx, req.(*PublishNIP43MembershipEventRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetCachedJSON_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetCachedJSONRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetCachedJSON(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetCachedJSON_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetCachedJSON(ctx, req.(*GetCachedJSONRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_CacheMarshaledJSON_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CacheMarshaledJSONRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).CacheMarshaledJSON(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_CacheMarshaledJSON_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).CacheMarshaledJSON(ctx, req.(*CacheMarshaledJSONRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetCachedEvents_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetCachedEventsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetCachedEvents(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetCachedEvents_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetCachedEvents(ctx, req.(*GetCachedEventsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_CacheEvents_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CacheEventsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).CacheEvents(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_CacheEvents_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).CacheEvents(ctx, req.(*CacheEventsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_InvalidateQueryCache_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).InvalidateQueryCache(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_InvalidateQueryCache_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).InvalidateQueryCache(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_RecordEventAccess_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RecordEventAccessRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).RecordEventAccess(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_RecordEventAccess_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).RecordEventAccess(ctx, req.(*RecordEventAccessRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetEventAccessInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetEventAccessInfoRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetEventAccessInfo(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetEventAccessInfo_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetEventAccessInfo(ctx, req.(*GetEventAccessInfoRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetLeastAccessedEvents_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetLeastAccessedEventsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetLeastAccessedEvents(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetLeastAccessedEvents_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetLeastAccessedEvents(ctx, req.(*GetLeastAccessedEventsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_SaveBlob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SaveBlobRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).SaveBlob(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_SaveBlob_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).SaveBlob(ctx, req.(*SaveBlobRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_SaveBlobMetadata_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SaveBlobMetadataRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).SaveBlobMetadata(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_SaveBlobMetadata_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).SaveBlobMetadata(ctx, req.(*SaveBlobMetadataRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetBlob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetBlobRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetBlob(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetBlob_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetBlob(ctx, req.(*GetBlobRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_HasBlob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(HasBlobRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).HasBlob(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_HasBlob_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).HasBlob(ctx, req.(*HasBlobRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_DeleteBlob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteBlobRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).DeleteBlob(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_DeleteBlob_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).DeleteBlob(ctx, req.(*DeleteBlobRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_ListBlobs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListBlobsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).ListBlobs(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_ListBlobs_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).ListBlobs(ctx, req.(*ListBlobsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetBlobMetadata_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetBlobMetadataRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetBlobMetadata(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetBlobMetadata_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetBlobMetadata(ctx, req.(*GetBlobMetadataRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetTotalBlobStorageUsed_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetTotalBlobStorageUsedRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetTotalBlobStorageUsed(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetTotalBlobStorageUsed_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetTotalBlobStorageUsed(ctx, req.(*GetTotalBlobStorageUsedRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_SaveBlobReport_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SaveBlobReportRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).SaveBlobReport(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_SaveBlobReport_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).SaveBlobReport(ctx, req.(*SaveBlobReportRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_ListAllBlobUserStats_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).ListAllBlobUserStats(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_ListAllBlobUserStats_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).ListAllBlobUserStats(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_ReconcileBlobMetadata_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).ReconcileBlobMetadata(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_ReconcileBlobMetadata_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).ReconcileBlobMetadata(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_ListAllBlobs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).ListAllBlobs(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_ListAllBlobs_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).ListAllBlobs(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_GetThumbnail_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetThumbnailRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).GetThumbnail(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_GetThumbnail_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).GetThumbnail(ctx, req.(*GetThumbnailRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_SaveThumbnail_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SaveThumbnailRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).SaveThumbnail(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_SaveThumbnail_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).SaveThumbnail(ctx, req.(*SaveThumbnailRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_EventIdsBySerial_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(EventIdsBySerialRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).EventIdsBySerial(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_EventIdsBySerial_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).EventIdsBySerial(ctx, req.(*EventIdsBySerialRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_RunMigrations_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).RunMigrations(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_RunMigrations_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).RunMigrations(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _DatabaseService_ExecuteCypherRead_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CypherReadRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DatabaseServiceServer).ExecuteCypherRead(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DatabaseService_ExecuteCypherRead_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DatabaseServiceServer).ExecuteCypherRead(ctx, req.(*CypherReadRequest))
	}
	return interceptor(ctx, in, info, handler)
}

// DatabaseService_ServiceDesc is the grpc.ServiceDesc for DatabaseService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var DatabaseService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "orlydb.v1.DatabaseService",
	HandlerType: (*DatabaseServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetPath",
			Handler:    _DatabaseService_GetPath_Handler,
		},
		{
			MethodName: "Sync",
			Handler:    _DatabaseService_Sync_Handler,
		},
		{
			MethodName: "Ready",
			Handler:    _DatabaseService_Ready_Handler,
		},
		{
			MethodName: "SetLogLevel",
			Handler:    _DatabaseService_SetLogLevel_Handler,
		},
		{
			MethodName: "SaveEvent",
			Handler:    _DatabaseService_SaveEvent_Handler,
		},
		{
			MethodName: "GetSerialsFromFilter",
			Handler:    _DatabaseService_GetSerialsFromFilter_Handler,
		},
		{
			MethodName: "WouldReplaceEvent",
			Handler:    _DatabaseService_WouldReplaceEvent_Handler,
		},
		{
			MethodName: "QueryForSerials",
			Handler:    _DatabaseService_QueryForSerials_Handler,
		},
		{
			MethodName: "QueryForIds",
			Handler:    _DatabaseService_QueryForIds_Handler,
		},
		{
			MethodName: "CountEvents",
			Handler:    _DatabaseService_CountEvents_Handler,
		},
		{
			MethodName: "FetchEventBySerial",
			Handler:    _DatabaseService_FetchEventBySerial_Handler,
		},
		{
			MethodName: "FetchEventsBySerials",
			Handler:    _DatabaseService_FetchEventsBySerials_Handler,
		},
		{
			MethodName: "GetSerialById",
			Handler:    _DatabaseService_GetSerialById_Handler,
		},
		{
			MethodName: "GetSerialsByIds",
			Handler:    _DatabaseService_GetSerialsByIds_Handler,
		},
		{
			MethodName: "GetSerialsByRange",
			Handler:    _DatabaseService_GetSerialsByRange_Handler,
		},
		{
			MethodName: "GetFullIdPubkeyBySerial",
			Handler:    _DatabaseService_GetFullIdPubkeyBySerial_Handler,
		},
		{
			MethodName: "GetFullIdPubkeyBySerials",
			Handler:    _DatabaseService_GetFullIdPubkeyBySerials_Handler,
		},
		{
			MethodName: "DeleteEvent",
			Handler:    _DatabaseService_DeleteEvent_Handler,
		},
		{
			MethodName: "DeleteEventBySerial",
			Handler:    _DatabaseService_DeleteEventBySerial_Handler,
		},
		{
			MethodName: "DeleteExpired",
			Handler:    _DatabaseService_DeleteExpired_Handler,
		},
		{
			MethodName: "ProcessDelete",
			Handler:    _DatabaseService_ProcessDelete_Handler,
		},
		{
			MethodName: "CheckForDeleted",
			Handler:    _DatabaseService_CheckForDeleted_Handler,
		},
		{
			MethodName: "ImportEventsFromStrings",
			Handler:    _DatabaseService_ImportEventsFromStrings_Handler,
		},
		{
			MethodName: "GetRelayIdentitySecret",
			Handler:    _DatabaseService_GetRelayIdentitySecret_Handler,
		},
		{
			MethodName: "SetRelayIdentitySecret",
			Handler:    _DatabaseService_SetRelayIdentitySecret_Handler,
		},
		{
			MethodName: "GetOrCreateRelayIdentitySecret",
			Handler:    _DatabaseService_GetOrCreateRelayIdentitySecret_Handler,
		},
		{
			MethodName: "SetMarker",
			Handler:    _DatabaseService_SetMarker_Handler,
		},
		{
			MethodName: "GetMarker",
			Handler:    _DatabaseService_GetMarker_Handler,
		},
		{
			MethodName: "HasMarker",
			Handler:    _DatabaseService_HasMarker_Handler,
		},
		{
			MethodName: "DeleteMarker",
			Handler:    _DatabaseService_DeleteMarker_Handler,
		},
		{
			MethodName: "GetSubscription",
			Handler:    _DatabaseService_GetSubscription_Handler,
		},
		{
			MethodName: "IsSubscriptionActive",
			Handler:    _DatabaseService_IsSubscriptionActive_Handler,
		},
		{
			MethodName: "ExtendSubscription",
			Handler:    _DatabaseService_ExtendSubscription_Handler,
		},
		{
			MethodName: "RecordPayment",
			Handler:    _DatabaseService_RecordPayment_Handler,
		},
		{
			MethodName: "GetPaymentHistory",
			Handler:    _DatabaseService_GetPaymentHistory_Handler,
		},
		{
			MethodName: "ExtendBlossomSubscription",
			Handler:    _DatabaseService_ExtendBlossomSubscription_Handler,
		},
		{
			MethodName: "GetBlossomStorageQuota",
			Handler:    _DatabaseService_GetBlossomStorageQuota_Handler,
		},
		{
			MethodName: "IsFirstTimeUser",
			Handler:    _DatabaseService_IsFirstTimeUser_Handler,
		},
		{
			MethodName: "SavePaidSubscription",
			Handler:    _DatabaseService_SavePaidSubscription_Handler,
		},
		{
			MethodName: "GetPaidSubscription",
			Handler:    _DatabaseService_GetPaidSubscription_Handler,
		},
		{
			MethodName: "DeletePaidSubscription",
			Handler:    _DatabaseService_DeletePaidSubscription_Handler,
		},
		{
			MethodName: "ListPaidSubscriptions",
			Handler:    _DatabaseService_ListPaidSubscriptions_Handler,
		},
		{
			MethodName: "ClaimAlias",
			Handler:    _DatabaseService_ClaimAlias_Handler,
		},
		{
			MethodName: "GetAliasByPubkey",
			Handler:    _DatabaseService_GetAliasByPubkey_Handler,
		},
		{
			MethodName: "GetPubkeyByAlias",
			Handler:    _DatabaseService_GetPubkeyByAlias_Handler,
		},
		{
			MethodName: "IsAliasTaken",
			Handler:    _DatabaseService_IsAliasTaken_Handler,
		},
		{
			MethodName: "AddNIP43Member",
			Handler:    _DatabaseService_AddNIP43Member_Handler,
		},
		{
			MethodName: "RemoveNIP43Member",
			Handler:    _DatabaseService_RemoveNIP43Member_Handler,
		},
		{
			MethodName: "IsNIP43Member",
			Handler:    _DatabaseService_IsNIP43Member_Handler,
		},
		{
			MethodName: "GetNIP43Membership",
			Handler:    _DatabaseService_GetNIP43Membership_Handler,
		},
		{
			MethodName: "GetAllNIP43Members",
			Handler:    _DatabaseService_GetAllNIP43Members_Handler,
		},
		{
			MethodName: "StoreInviteCode",
			Handler:    _DatabaseService_StoreInviteCode_Handler,
		},
		{
			MethodName: "ValidateInviteCode",
			Handler:    _DatabaseService_ValidateInviteCode_Handler,
		},
		{
			MethodName: "DeleteInviteCode",
			Handler:    _DatabaseService_DeleteInviteCode_Handler,
		},
		{
			MethodName: "PublishNIP43MembershipEvent",
			Handler:    _DatabaseService_PublishNIP43MembershipEvent_Handler,
		},
		{
			MethodName: "GetCachedJSON",
			Handler:    _DatabaseService_GetCachedJSON_Handler,
		},
		{
			MethodName: "CacheMarshaledJSON",
			Handler:    _DatabaseService_CacheMarshaledJSON_Handler,
		},
		{
			MethodName: "GetCachedEvents",
			Handler:    _DatabaseService_GetCachedEvents_Handler,
		},
		{
			MethodName: "CacheEvents",
			Handler:    _DatabaseService_CacheEvents_Handler,
		},
		{
			MethodName: "InvalidateQueryCache",
			Handler:    _DatabaseService_InvalidateQueryCache_Handler,
		},
		{
			MethodName: "RecordEventAccess",
			Handler:    _DatabaseService_RecordEventAccess_Handler,
		},
		{
			MethodName: "GetEventAccessInfo",
			Handler:    _DatabaseService_GetEventAccessInfo_Handler,
		},
		{
			MethodName: "GetLeastAccessedEvents",
			Handler:    _DatabaseService_GetLeastAccessedEvents_Handler,
		},
		{
			MethodName: "SaveBlob",
			Handler:    _DatabaseService_SaveBlob_Handler,
		},
		{
			MethodName: "SaveBlobMetadata",
			Handler:    _DatabaseService_SaveBlobMetadata_Handler,
		},
		{
			MethodName: "GetBlob",
			Handler:    _DatabaseService_GetBlob_Handler,
		},
		{
			MethodName: "HasBlob",
			Handler:    _DatabaseService_HasBlob_Handler,
		},
		{
			MethodName: "DeleteBlob",
			Handler:    _DatabaseService_DeleteBlob_Handler,
		},
		{
			MethodName: "ListBlobs",
			Handler:    _DatabaseService_ListBlobs_Handler,
		},
		{
			MethodName: "GetBlobMetadata",
			Handler:    _DatabaseService_GetBlobMetadata_Handler,
		},
		{
			MethodName: "GetTotalBlobStorageUsed",
			Handler:    _DatabaseService_GetTotalBlobStorageUsed_Handler,
		},
		{
			MethodName: "SaveBlobReport",
			Handler:    _DatabaseService_SaveBlobReport_Handler,
		},
		{
			MethodName: "ListAllBlobUserStats",
			Handler:    _DatabaseService_ListAllBlobUserStats_Handler,
		},
		{
			MethodName: "ReconcileBlobMetadata",
			Handler:    _DatabaseService_ReconcileBlobMetadata_Handler,
		},
		{
			MethodName: "ListAllBlobs",
			Handler:    _DatabaseService_ListAllBlobs_Handler,
		},
		{
			MethodName: "GetThumbnail",
			Handler:    _DatabaseService_GetThumbnail_Handler,
		},
		{
			MethodName: "SaveThumbnail",
			Handler:    _DatabaseService_SaveThumbnail_Handler,
		},
		{
			MethodName: "EventIdsBySerial",
			Handler:    _DatabaseService_EventIdsBySerial_Handler,
		},
		{
			MethodName: "RunMigrations",
			Handler:    _DatabaseService_RunMigrations_Handler,
		},
		{
			MethodName: "ExecuteCypherRead",
			Handler:    _DatabaseService_ExecuteCypherRead_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "QueryEvents",
			Handler:       _DatabaseService_QueryEvents_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "QueryAllVersions",
			Handler:       _DatabaseService_QueryAllVersions_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "QueryEventsWithOptions",
			Handler:       _DatabaseService_QueryEventsWithOptions_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "QueryDeleteEventsByTargetId",
			Handler:       _DatabaseService_QueryDeleteEventsByTargetId_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Import",
			Handler:       _DatabaseService_Import_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "Export",
			Handler:       _DatabaseService_Export_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "orlydb/v1/service.proto",
}